quj9BddlZddlmZddlmZddlZddlmZddlZddlZddl m Z ddl Z ejejdejdZd Zd Zd ed efd ZdPdZdPdZdefdZdefdZdefdZdedededefdZdededefdZdededefdZdQdede ede fd Z!ded efd!Z"ded"efd#Z#ded"efd$Z$dedefd%Z%dRded&ed'efd(Z&ded'efd)Z'ded*ed+efd,Z(ded*ed-efd.Z)ded*efd/Z*defd0Z+ded*ed1ed2efd3Z,ded*efd4Z-defd5Z.ded6efd7Z/ded8efd9Z0ded:efd;Z1deded?ed@e dAe dBe ded'efdCZ3dTdede fdDZ4dedEefdFZ5defdGZ6dedefdHZ7dIZ8defdJZ9defdKZ:dRdefdLZ;defdMZy)UN)sql)Json)settings)Listz4%(asctime)s - %(name)s - %(levelname)s - %(message)s)levelformatdatabaseAivoraa, ( s."isActive" = TRUE OR LOWER(COALESCE(s."status", '')) IN ('active', 'trial', 'trialing') OR ( s."trialStart" IS NOT NULL AND s."trialEnd" IS NOT NULL AND NOW() >= s."trialStart" AND NOW() <= s."trialEnd" ) ) product_namereturncNt|tsytfd|DS)NFc3K|]=}t|txr'|jdk(xr|jd?yw) productNamefeaturesN) isinstancedictget).0productr s 4/var/www/html/strategist-ai/app/services/database.py z$_plan_has_product.. sN  7D! $ KK &, 6 $ KK # $sAA)rlistany)product_featuresr s `r_plan_has_productrs- & - (  c 0t|D]g} tjtjtj tj tjtjd}|cSy #tj$rc}tjd|dzd|d|d||dz krtj|ntjdd |Yd }~d }~wt$r!}tjd |d |d }~wwxYw) z= Establishes a database connection with retry logic. hostportuserpassworddbnameconnect_timeoutzDatabase connection attempt  failed: . Retrying in s...z7Max retries reached. Could not connect to the database.Texc_infoNz)Unexpected error connecting to database: )rangepsycopg2connectrDB_HOSTDB_PORTDB_USER DB_PASSWORDDB_NAMEOperationalErrorloggerwarningtimesleeperror Exceptionretriesdelayattemptconnes rget_db_connectionrA's> ##%%%%%%!--'' " DK((  NN9'A+iPQsR`af`ggkl m1$ 5! Vae f"  LLDQCHSWL XG %A"A77D AC(( D4DDc 0t|D]g} tjtjtj tj tjtjd}|cSy #tj$rc}tjd|dzd|d|d||dz krtj|ntjdd |Yd }~d }~wt$r!}tjd |d |d }~wwxYw) zK Establishes a connection to the master database with retry logic. rrzMaster DB connection attempt r&r'r(r)z>Max retries reached. Could not connect to the master database.Tr*Nz0Unexpected error connecting to master database: )r,r-r.rr/r0r1r2MASTER_DB_NAMEr4r5r6r7r8r9r:r;s rget_master_db_connectionrEAs> ##%%%%%%!--.. " DK((  NN:7Q;-yQRPSSabgahhlm n1$ 5! ]hl m"  LLKA3OZ^L _G rB tenant_idc T|jddjddjs#tjd|t dtj d|t } |j5}|jd|jtjdjtj||jtjd jtj||jtjd jtj||jtjd jtj||jtjd jtj||jtjd jtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj|tj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjdjtj||jtjd jtj||jtjd!jtj||jtjd"jtj||jtjd#jtj||jtjd$jtj||jtjd%jtj||jtjd&jtj||jtjd'jtj||jtjd(jtj||jtjd)jtj||jtjd*jtj||jtjd+jtj||jtjd,jtj||jtjd-jtj|t|||jtj d.| t|}|rtj d/|d0|j5}tjd1jtj|}|j||fd2d2d2|j d2d2d2|j%y5#1swY3xYw#t $r%}tj#d3|d4|Yd2}~Od2}~wwxYw#1swYnxYwn@#t $r4}|j'tjd6|d4|d57|d2}~wwxYw |j%y2#|j%wxYw)8zw Creates the schema for the tenant if it doesn't exist and creates the relevant tables within that schema. _-zInvalid tenant_id format: zFInvalid tenant_id format. Must be alphanumeric, underscore, or hyphen.zBootstrapping tenant: z%CREATE EXTENSION IF NOT EXISTS vectorzCREATE SCHEMA IF NOT EXISTS {}aj CREATE TABLE IF NOT EXISTS {}.strategist_knowledge_base ( id SERIAL PRIMARY KEY, content TEXT NOT NULL, embedding vector(3072) NOT NULL, metadata JSONB, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zALTER TABLE {}.strategist_knowledge_base ADD COLUMN IF NOT EXISTS created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMPz^ALTER TABLE {}.strategist_knowledge_base ALTER COLUMN created_at SET DEFAULT CURRENT_TIMESTAMPz_UPDATE {}.strategist_knowledge_base SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULLa> CREATE TABLE IF NOT EXISTS {}.strategist_summaries ( id SERIAL PRIMARY KEY, ingestion_type TEXT NOT NULL, summary TEXT NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zzALTER TABLE {}.strategist_summaries ADD COLUMN IF NOT EXISTS created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMPzYALTER TABLE {}.strategist_summaries ALTER COLUMN created_at SET DEFAULT CURRENT_TIMESTAMPzZUPDATE {}.strategist_summaries SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULLa  CREATE TABLE IF NOT EXISTS {}.strategist_settings ( key TEXT PRIMARY KEY, value JSONB NOT NULL, updated_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) a CREATE TABLE IF NOT EXISTS {}.strategist_products ( id SERIAL PRIMARY KEY, product_key TEXT NOT NULL UNIQUE, name TEXT NOT NULL, description TEXT, image_url TEXT, product_url TEXT NOT NULL, category TEXT, ctas JSONB NOT NULL DEFAULT '[]', options JSONB NOT NULL DEFAULT '[]', raw JSONB NOT NULL DEFAULT '{{}}', related_keys TEXT[] NOT NULL DEFAULT '{{}}', extracted_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) z^CREATE INDEX IF NOT EXISTS strategist_products_url_idx ON {}.strategist_products (product_url)z`CREATE INDEX IF NOT EXISTS strategist_products_category_idx ON {}.strategist_products (category)a CREATE TABLE IF NOT EXISTS {}.strategist_tickets ( id SERIAL PRIMARY KEY, ticket_id TEXT UNIQUE NOT NULL, thread_id TEXT, user_name TEXT NOT NULL, heading TEXT NOT NULL, content TEXT NOT NULL, priority TEXT NOT NULL, status TEXT DEFAULT 'Open', email TEXT, contact_no TEXT, contact_medium TEXT, contact_details TEXT, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zxALTER TABLE {}.strategist_tickets ADD COLUMN IF NOT EXISTS created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMPzWALTER TABLE {}.strategist_tickets ALTER COLUMN created_at SET DEFAULT CURRENT_TIMESTAMPzXUPDATE {}.strategist_tickets SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULLzIALTER TABLE {}.strategist_tickets ADD COLUMN IF NOT EXISTS thread_id TEXTa CREATE TABLE IF NOT EXISTS {}.strategist_ticket_comments ( id SERIAL PRIMARY KEY, ticket_id TEXT NOT NULL REFERENCES {}.strategist_tickets(ticket_id) ON DELETE CASCADE, admin_name TEXT, comment TEXT NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zALTER TABLE {}.strategist_ticket_comments ADD COLUMN IF NOT EXISTS created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMPz_ALTER TABLE {}.strategist_ticket_comments ALTER COLUMN created_at SET DEFAULT CURRENT_TIMESTAMPa CREATE TABLE IF NOT EXISTS {}.strategist_feedback ( id SERIAL PRIMARY KEY, thread_id TEXT NOT NULL, user_name TEXT, question TEXT NOT NULL, answer TEXT NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zYALTER TABLE {}.strategist_feedback ADD COLUMN IF NOT EXISTS metadata JSONB DEFAULT '{{}}'a CREATE TABLE IF NOT EXISTS {}.strategist_llm_usage ( id SERIAL PRIMARY KEY, feature_name TEXT NOT NULL, model_name TEXT NOT NULL, prompt_tokens INTEGER NOT NULL, completion_tokens INTEGER NOT NULL, total_tokens INTEGER NOT NULL, thread_id TEXT, cumulative_prompt_tokens INTEGER DEFAULT 0, cumulative_completion_tokens INTEGER DEFAULT 0, metadata JSONB DEFAULT '{{}}', created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zKALTER TABLE {}.strategist_llm_usage ADD COLUMN IF NOT EXISTS thread_id TEXTzgALTER TABLE {}.strategist_llm_usage ADD COLUMN IF NOT EXISTS cumulative_prompt_tokens INTEGER DEFAULT 0zkALTER TABLE {}.strategist_llm_usage ADD COLUMN IF NOT EXISTS cumulative_completion_tokens INTEGER DEFAULT 0zZALTER TABLE {}.strategist_llm_usage ADD COLUMN IF NOT EXISTS metadata JSONB DEFAULT '{{}}'zzALTER TABLE {}.strategist_llm_usage ADD COLUMN IF NOT EXISTS created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMPzYALTER TABLE {}.strategist_llm_usage ALTER COLUMN created_at SET DEFAULT CURRENT_TIMESTAMPzZUPDATE {}.strategist_llm_usage SET created_at = CURRENT_TIMESTAMP WHERE created_at IS NULLax CREATE TABLE IF NOT EXISTS {}.strategist_thread_analytics ( thread_id TEXT PRIMARY KEY, sentiment_score FLOAT, intent TEXT, is_high_intent BOOLEAN, is_lead_qualified BOOLEAN, is_resolved BOOLEAN, escalation_needed BOOLEAN, positive_points TEXT, key_concerns TEXT, pain_point TEXT, feature_request TEXT, objection TEXT, cta_clicked BOOLEAN, summary TEXT, metadata JSONB, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP, last_analyzed_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zXALTER TABLE {}.strategist_thread_analytics ADD COLUMN IF NOT EXISTS positive_points TEXTzUALTER TABLE {}.strategist_thread_analytics ADD COLUMN IF NOT EXISTS key_concerns TEXTa8 CREATE TABLE IF NOT EXISTS {}.strategist_crawled_urls ( id SERIAL PRIMARY KEY, source_id TEXT NOT NULL, url TEXT NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP ) zVCREATE INDEX IF NOT EXISTS idx_usage_created_at ON {}.strategist_llm_usage(created_at)zXCREATE INDEX IF NOT EXISTS idx_feedback_created_at ON {}.strategist_feedback(created_at)zQCREATE INDEX IF NOT EXISTS idx_usage_thread ON {}.strategist_llm_usage(thread_id)z"Successfully bootstrapped tenant: zBrand persona found for z". Storing in strategist_summaries.z INSERT INTO {}.strategist_summaries (ingestion_type, summary) VALUES ('brand_persona', %s) Nz0Persona aggregation failed during bootstrap for : TzError bootstrapping tenant r*)replaceisalnumr5r9 ValueErrorinforAcursorexecuterSQLr Identifierensure_thread_id_columncommitfetch_brand_personar:r6closerollback)rFr?curpersona persona_cur insert_queryper@s rbootstrap_tenantr^[sm   S" % - -c2 6 > > @ 1)=>abb KK( 45  Dq [[]j c KK? @ KK @AHHXaIbc d KK!y12 4 KK!bcjjknkykyzCkDE F KK!ABIIJMJXJXYbJcd e KK!BCJJKNKYKYZcKde f KK!y12 4 KK!]^eefiftftu~f@ A KK {|DDEHESEST]E^_ ` KK |}EEFIFTFTU^F_` a KK! y12  4& KK!y12 4 KK:fS^^I./ 1 KK7fS^^I./ 1 KK! y12! 4$ KK![\ccdgdrdrs|d}~  KK yzBBCFCQCQR[C\] ^ KK z{CCDGDRDRS\D]^ _ KK klsstwuCuCDMuNO P KK!y13>>)3LM O KK!cdkklolzlz{DlEF G KK!BCJJKNKYKYZcKde f KK ! y12 4 KK {|DDEHESEST]E^_ ` KK!y12 4" KK mnuuvywEwEFOwPQ R KK!JKRRSVSaSabkSlm n KK!NOVVWZWeWefoWpq r KK |}EEFIFTFTU^F_` a KK!]^eefiftftu~f@ A KK {|DDEHESEST]E^_ ` KK |}EEFIFTFTU^F_` a KK!(y12) 4. KK z{CCDGDRDRS\D]^ _ KK wxADAOAOPYAZ[ \ KK!y12 4 KK xyAABEBPBPQZB[\ ] KK z{CCDGDRDRS\D]^ _ KK st{{|}K}KLU}VW X #Is 3 KKM KK%$++L7*E F KKMUj ` !FF e!QR[Q\\^_a^bcdd eOj j j V   29+RsCd SWj `  s7qj>p66pp p3p.)p6.p33p66p?;qr r /q;;rrr'ct} |j5}|jd|f|jds ddd|j yt j djt j|}|j||j}|r|ds ddd|j y|d}|jdg}|jdg}|Dcgc]%}|jds|jd'} }|D cgc]%} | jds| jd'} } | s| s ddd|j yg} | r#| jdd j| | r#| jd d j| d j| cddd|j Scc}wcc} w#1swYnxYwnA#t$r5} tjd |d | Yd} ~ |j yd} ~ wwxYw |j y#|j wxYw)z Fetches the latest brand analysis result and extracts tone and voice traits. Returns a string summarizing the brand persona. z SELECT EXISTS ( SELECT FROM information_schema.tables WHERE table_schema = %s AND table_name = 'brandforge_analyses' ) rNz~ SELECT full_result FROM {}.brandforge_analyses ORDER BY created_at DESC LIMIT 1 tonevoicetextzTone: z, zVoice: z | z!Error fetching brand persona for rK)rArPrQfetchonerWrrRrrSrappendjoinr:r5r9)rFr?rYqueryrow full_result tone_list voice_listtextracted_tonevextracted_voice persona_partsr@s rrVrVZs*  D, [[]& -c KK   <<>!$& -V =GGy12  KK ,,.Cc!f)& -V +a&K#3I$"5J5>P!%%-aeeFmPNP6@RAEE&MquuV}ROR!/=& -V M$$vdii.G-H%IJ$$wtyy/I.J%KL::m,M& -& -V #QR7& -& -& -N  8 2aSIJ O& -V  sH (G=H A G==H -G=G3G3-G=3G8 G8G=$H =AG= H 3 G==HH I II.IIII/cn |jd|f|js`tjd|d|jt j dj t j|yy#t$r%}tjd|d|Yd}~yd}~wwxYw)z Internal helper to add the thread_id column to the tickets table if missing. Used for self-healing legacy tenants. zSELECT column_name FROM information_schema.columns WHERE table_schema = %s AND table_name = 'strategist_tickets' AND column_name = 'thread_id'z)Self-healing: Adding thread_id column to z.strategist_ticketsz;ALTER TABLE {}.strategist_tickets ADD COLUMN thread_id TEXTz&Failed to ensure thread_id column for rKN) rQrcr5rOrrRrrSr:r6)rFrYr@s rrTrTs R eirht u||~ KKCI;Nab c KK ]^eefiftftu~fA B R? {"QCPQQRsBB B4B//B4content embeddingmetadatac Ltjd|ddlm}t |t r|j dnd}ttj|xsijd}t|xsdjd}t|xsgdz}td||z|z} ||d || t} | j5} tjd j!tj"|} | j%| ||tj|f| j' dd lm} t-|}| || ddd| j3y#t.$r%}tj1d |d|Yd}~Cd}~wwxYw#1swYnxYwn@#t.$r4}| j5tj7d|d|d|d}~wwxYw | j3y#| j3wxYw)Nz"Inserting vector data for tenant: r) check_quotauser_idzutf-8rIr&storage_vector_capacity)rvrequested_amountz INSERT INTO {}.strategist_knowledge_base (content, embedding, metadata) VALUES (%s, %s, %s) log_storage_snapshot#Failed to log storage snapshot for rKTz(Failed to insert vector data for tenant r*)r5rOapp.services.quotasrurrrlenjsondumpsencodemaxrArPrrRrrSrQrUapp.services.firestore_servicer{get_vector_db_sizer:r6rWrXr9)rFrqrrrsrurv metadata_size content_sizeembedding_sizeprojected_row_sizer?rYr\r{new_sizeser@s rinsert_vector_datars KK4YK@A0)3Hd)Chll9%G 8>r299'BCM 2--g67Lb)A-NQ } <~ MN!+   D [[] c77$y12  KK w 4::h;O&P Q KKM XO-i8$Y9# .  X!DYKrRTQUVWW X   $   ? {"QCP[_ `% .  sm F?A0F2 F'F2(F? F/ F*%F2*F//F22F;7F?>H? G</G77G<<HH#ingestion_typesummarycBtjd|d|t} |j5}t j dj t j|}|j|||f|j ddd|jy#1swYnxYwn@#t$r4}|jtjd|d|d|d}~wwxYw |jy#|jwxYw)NzInserting summary for tenant: , type: z{ INSERT INTO {}.strategist_summaries (ingestion_type, summary) VALUES (%s, %s) Tz$Failed to insert summary for tenant rKr*r5rOrArPrrRrrSrQrUrWr:rXr9)rFrrr?rYr\r@s rinsert_summaryrs KK0 8NCSTU  D [[] c77$y12  KK ~w&? @ KKM        ;I;bLW[ \   sAB:AB-B:-B62B:9D : C7/C22C77D D source_idurlchtjd|d|t} |j5}t j dj t j|}|j|||f|j ddd|jy#1swYnxYwnS#t$rG}|jtjd|d|dYd}~|jyd}~wwxYw |jy#|jwxYw) Nz"Inserting crawled URL for tenant: z , source_id: zu INSERT INTO {}.strategist_crawled_urls (source_id, url) VALUES (%s, %s) Tz(Failed to insert crawled URL for tenant rKr*Fr)rFrrr?rYr\r@s rinsert_crawled_urlrs KK4YK}YKXY  D [[] c77$y12  KK y#&6 7 KKM        ? {"QCP[_ `    sGB:AB-B:-B62B:9D: D -D0DD  DD1query_embeddinglimitc |tjd|t} |j5}|j d|f|j s4tj d|dgcddd|jStjdjtj|}ddjtt|zd z}|j |||f|j}g}|D],} |j!| d | d d t#| d z d .|cddd|jS#1swYnxYwn0#t$$r$} tj'd|d| d| d} ~ wwxYw |jy#|jwxYw)zL Performs cosine similarity search on the tenant's vector database. zSearching vectors for tenant: y SELECT schema_name FROM information_schema.schemata WHERE schema_name = %s Tenant schema z does not exist for search.Nz SELECT content, metadata, (embedding <=> CAST(%s AS vector)) as distance FROM {}.strategist_knowledge_base ORDER BY distance ASC LIMIT %s [,]rr&)rqrsscorez$Failed to search vectors for tenant rKTr*)r5rOrArPrQrcr6rWrrRrrSremapstrfetchallrdfloatr:r9) rFrrr?rYrf vector_strresults search_hitsrgr@s rsearch_vector_datars KK0 <=  D$ [[] c KK <<> {:UVW  F 3GG y12 sxxC(ABBSHJ KK E2 3llnGK """1v #As1v.$  =  F G   >  ;I;bLW[ \? F  sME'>E2 E' B4E E'E#E'&F)' F0FFF))F;ct} |j5}|jd|f|jdcddd|j S#1swYnxYwnA#t $r5}t jd|d|Yd}~|j yd}~wwxYw |j y#|j wxYw)zKWhether this tenant has been bootstrapped since strategist_settings landed.tSELECT EXISTS (SELECT FROM information_schema.tables WHERE table_schema = %s AND table_name = 'strategist_settings')rNz'Could not check the settings table for rKF)rArPrQrcrWr:r5r9rFr?rYr@s rsettings_table_existsrs  D  [[] %c KKR   <<>!$  % %  % % %  >ykA3OP  %  sFA)&A A)A%!A)(B<) B'2B" B<"B''B<<Ckeyc t} |j5}|jd|f|jds ddd|j y|jt j djt j||f|j}|r|dndcddd|j S#1swYnxYwnD#t$r8}tjd|d|d|Yd}~|j yd}~wwxYw |j y#|j wxYw)z>The stored value for a settings key, or None if there is none.rrNz7SELECT value FROM {}.strategist_settings WHERE key = %szCould not read setting '' for rK) rArPrQrcrWrrRrrSr:r5r9)rFrr?rYrgr@s r get_settingr-s   D [[] +c KKR   <<>!$ +"  KKQRy12SF <,,.C 3q6d + +" # + + +  /uF9+RsKL  +"  sSC$(CC$A C= C$C C$#D:$ D%-D  D: D%%D::E cjt} |j5}|jtjdj tj ||tif|jtjdj tj ||f|j}|r |dr|dnd}||}|jtjdj tj |t||fddd|j|jS#1swY+xYw#t$r/|jtjd|d|d wxYw#|jwxYw) aRead-modify-write a settings key under a row lock. `merge` receives the currently stored value (or None) and returns the value to store. It runs inside the transaction that holds the lock, so two concurrent saves cannot each read the old value and overwrite each other -- the second waits, then merges on top of the first one's result. The empty INSERT first is what makes the lock possible: SELECT FOR UPDATE locks nothing when the row does not exist yet. z\INSERT INTO {}.strategist_settings (key, value) VALUES (%s, %s) ON CONFLICT (key) DO NOTHINGzBSELECT value FROM {}.strategist_settings WHERE key = %s FOR UPDATErNz[UPDATE {}.strategist_settings SET value = %s, updated_at = CURRENT_TIMESTAMP WHERE key = %szCould not save setting 'rTr*)rArPrQrrRrrSrrcrUrWr:rXr5r9)rFrmerger?rYrgcurrentmergeds rupdate_settingrEsi  D [[] Ic KK78y12S$r(O E KK\]y12SF <,,.C #Ac!fDG7^F KKHIy12T&\34G I I"  1 I I&   /uF9+FQU V  s/E%DE/E%E"E%%8FF F2ctjd|d|t} |j5}|j d|f|j s3tj d|d ddd|jytjdjtj|}|j ||f|j }|r |d|dfnd cddd|jS#1swYnxYwn@#t$r4}tjd |d Yd}~|jy d}~wwxYw |jy#|jwxYw) Nz$Fetching latest summary for tenant: rrrz does not exist.z SELECT summary, created_at FROM {}.strategist_summaries WHERE ingestion_type = %s ORDER BY created_at DESC LIMIT 1 rr&NNzError fetching summary: Tr*)r5rOrArPrQrcr6rWrrRrrSr:r9)rFrr?rYrfresultr@s rget_latest_summaryrmsb KK6yk.IYZ[  D [[] Fc KK <<> {:JKL F0 GG y12  KK0 1\\^F-3F1Ivay)' F F0 1 F F F(  /s3d C ) F0  sSD>D5DA'D5 DDDE. E%E?E.EE..F ticket_data thread_idcVtjd|d|ddlm}m}t |t r|jdnd}||d|t} |j5}tjd jtj|} |j||d |d |d |d |dd|jd|jdxs|jd|jdxs|jd|f |j-d} |j+| cddd|j/S#t$r.} dt!| j#vrdt!| j#vrtj%d|d|j'|j5} t)|| |j+dddn #1swYnxYw|j||d |d |d |d |dd|jd|jdxs|jd|jdxs|jd|f n| Yd} ~ qd} ~ wwxYw#1swYnxYwnZ#|$rt$rI} |r|j'tj1d|d| dYd} ~ |j/yd} ~ wwxYw |j/y#|j/wxYw)z Inserts a new support ticket into the tenant-specific table. Self-healing: Automatically adds thread_id column if missing. zCreating ticket for tenant: , thread: r)ruQuotaExceededErrorrvN total_tickets)rva INSERT INTO {}.strategist_tickets (ticket_id, user_name, heading, content, priority, status, email, contact_no, contact_medium, thread_id) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s) RETURNING id ticket_id user_nameheadingrqpriorityOpenemail contact_no phone_numbercontact_mediumany_other_contact_mediumcolumnr"Self-healing: Adding thread_id to z during creation.z!Error creating ticket for tenant rKTr*)r5rOr}rurrrrrArPrrRrrSrQr:rlowerr6rXrTrUrcrWr9) rFrrrurrvr?rYrfr@ repair_curnew_ids r create_ticketrs  KK.ykI;OPD,6{D,Ikooi(tG ?G<  D8 [[]- cGGy12  "  E , , * * +OOG,OOL1T[__^5TOO$45dIc9d $ F\\^A&F KKM[- - n G s1v||~-+Q2ONN%G {Rc#deMMO&*/ :F &&&KK#K0#K0#I.#I.#J/#0# 5X9X#(89h[__Mg=h! ( G  )- - - \    MMO 8 2aSITX Y c- n  sJ*-8J&A>E"$$J J*" J,A0JH9 JH BJJJJJ&"J*)L*L8/K<'L<LLL(cPtjd|d|t} |j5}t j dj t j|} |j||f|j!}|r4|d |d |d |d |d |ddcddd|j#S ddd|j#y#t$r}dt|jvrdt|jvrtjd|d|j|j5}t|||jdddn #1swYnxYw|j||fn|Yd}~&d}~wwxYw#1swYnxYwnC#t$r7}tj%d|d|dYd}~|j#yd}~wwxYw |j#y#|j#wxYw)z Finds an existing ticket for a given conversation thread. Self-healing: Automatically adds thread_id column if missing. zGetting ticket for thread in tenant zpSELECT id, ticket_id, heading, content, priority, status FROM {}.strategist_tickets WHERE thread_id = %s LIMIT 1rrrz during fetch-by-thread.Nrr&r)idrrrqrstatusz Error fetching ticket by thread rKTr*)r5rOrArPrrRrrSrQr:rrr6rXrTrUrcrWr9)rFrr?rYrfr@rrgs rget_ticket_by_threadrs  KK,YK{9+NO  D  [[] cGGOPWWX[XfXfgpXqrE  EI<0,,.Ca&!$Q"1v"1v #A!!f %  > 5 > 7 s1v||~-+Q2ONN%G {Rj#klMMO&*/ :F &&&KK |4G5     6  7 {"QCHSW X 7 >  sF>8F10C#,F1/ F> F1 F># F.,A/F)F8 F)F F)#F1)F..F11F:6F>=H> G>G9$H9G>>HH%r update_datac~tjd|d|t} |j5}t j dj t j|}|j||d|d|d|f|j ddd|jy#1swYnxYwnS#t$rG}tjd |d |d |jYd}~|jy d}~wwxYw |jy#|jwxYw) z6 Updates an existing ticket with new details. zUpdating ticket for tenant: z UPDATE {}.strategist_tickets SET heading = %s, content = %s, priority = %s WHERE ticket_id = %s rrqrNTzFailed to update ticket rKr*F)r5rOrArPrrRrrSrQrUrWr:r9rX)rFrrr?rYrfr@s r update_ticketrs# KK"9+]9+FG  D [[] cGG y12  KKI&I&J'    KKM! , -   "  / {"QC@4 P  # ,  sGCA(B8C8C=CD* D-D;D*DD**D<rctjd|d|d|t} |j5}t j dj t j|}|j|||f|j|jdkDcddd|jS#1swYnxYwnS#t$rG}tjd|d|d |jYd}~|jy d}~wwxYw |jy#|jwxYw) z3 Updates the status of an existing ticket. zUpdating status of ticket z to 'z' for tenant: z UPDATE {}.strategist_tickets SET status = %s WHERE ticket_id = %s rNz#Failed to update status for ticket rKTr*F)r5rOrArPrrRrrSrQrUrowcountrWr:r9rX)rFrrr?rYrfr@s rupdate_ticket_statusrs KK,YKuVHNS\R]^_  D [[] $cGGy12  KK 2 3 KKM<$ C >CC D0 D-DD0DD00Ectjd|d|t} |j5}|j d|f|j s ddd|j ytjdjtj|}|j ||f|j }|re|d|d|d|d |d |d |d |d |d|d|d|dr|djnd|dd cddd|j S ddd|j y#1swYnxYwnF#t$r:}tjd|d|d|dYd}~|j yd}~wwxYw |j y#|j wxYw)z5 Retrieves a single ticket by its ticket_id. zFetching ticket rJSELECT schema_name FROM information_schema.schemata WHERE schema_name = %sNzSELECT id, ticket_id, user_name, heading, content, priority, status, email, contact_no, contact_medium, contact_details, created_at, thread_id FROM {}.strategist_tickets WHERE ticket_id = %srr&rrrrrw r rrrrrqrrrrrcontact_details created_atrzError fetching ticket for tenant rKTr*)r5rOrArPrQrcrWrrRrrS isoformatr:r9)rFrr?rYrfrgr@s r get_ticketr2s KK"9+]9+FG  D  [[] c KKdgpfr s<<>  > 3GG]^eefiftftu~f@E KK | ,,,.Ca&!$Q!$Q"1v"1v #A!!f V"%a&&)!f'*2w9 5 > ?   6  -i[ YKrRSQTU`d e 7 >  s_E%EE5B'E E6E7EEEF5 F & FF5F  F55Gc tjd|t} |j5}|j d|f|j sgcddd|j S tjdjtj|}|j ||j%}g}|D]]}|j'|d |d |d |d |d |d|d|d|d|d|d|dr|dj)nd|dd _|cddd|j S#t$r}dt|jvrdt|jvr}tjd|d|j|j5}t!|||j#dddn #1swYnxYw|j n|Yd}~Sd}~wwxYw#1swYnxYwnE#t$r9}tj+d|d|dgcYd}~|j Sd}~wwxYw |j y#|j wxYw)z Retrieves all tickets for a specific tenant. Self-healing: If thread_id is missing (legacy tenant), it applies the migration and retries. z!Fetching all tickets for tenant: rNzSELECT id, ticket_id, user_name, heading, content, priority, status, email, contact_no, contact_medium, contact_details, created_at, thread_id FROM {}.strategist_tickets ORDER BY created_at DESCrrzDetected missing thread_id in z. Applying migration...rr&rrrrrrrwrrrrrz"Error fetching tickets for tenant rKTr*)r5rOrArPrQrcrWrrRrrSr:rrr6rXrTrUrrdrr9) rFr?rYrfr@rrowsticketsrgs r get_ticketsrZs  KK3I;?@  D. [[]( c KKdgpfr s<<> ( ( Z O !efmmnqn|n|}FnGH E"<<>DG a&!$Q!$Q"1v"1v #A!!f V"%a&&)!f'*2w9   0 %GGdellmpm{m{|EmFGE KK | ,<<>DH a&!$Q"%a&"1v8;A#a&"2"2"4D ! '  0 1   (  :9+[QZP[[]^_]`alp q  ) 0  sYD<%D/ D<6BD/ D</D84D<;F< F!E<&F'F<FFF(ctjd|t} |j5}|j d|f|j sicddd|j Stjdjtj|}|j ||j}|Dcic]}|dxsd|dc}cddd|j Scc}w#1swYnxYwnE#t$r9}tjd|d |d icYd}~|j Sd}~wwxYw |j y#|j wxYw) z= Returns a dictionary of status counts for a tenant. z*Fetching ticket status counts for tenant: rNzBSELECT status, COUNT(*) FROM {}.strategist_tickets GROUP BY statusrUnknownr&z/Error fetching ticket status counts for tenant rKTr*)r5rOrArPrQrcrWrrRrrSrr:r9)rFr?rYrfrrgr@s rget_ticket_status_countsrsd KK A A GG`ahhiliwiwyBjCDE KK <<>D;?@CCF'iQ/@ A A A A A A  FykQSTUSVWbf g   A  skD%D D3ADC?#D% D?DD  DE( EE8E9E(EE((E: feedback_datactjd|t} |j5}t j dj t j|}|j||d|jd|d|dtj|jdif|jd}|j|cd d d |jS#1swYnxYwn@#t$r4}tj!d |d |d |j#|d }~wwxYw |jy #|jwxYw)zL Inserts user feedback into the tenant's strategist_feedback table. zInserting feedback for tenant: z INSERT INTO {}.strategist_feedback (thread_id, user_name, question, answer, metadata) VALUES (%s, %s, %s, %s, %s) RETURNING id rrquestionanswerrsrNz%Failed to insert feedback for tenant rKTr*)r5rOrArPrrRrrSrQrrrrcrUrWr:r9rX)rFrr?rYrffeedback_db_idr@s rinsert_feedbackrsP KK1)=>  D [[] "cGGy12  KKk*!!+.j)h' =,,Z<=   !\\^A.N KKM!! " ", - " " ""  >'source_id' = %s zi DELETE FROM {}.strategist_crawled_urls WHERE source_id = %s Deleted ) rows from strategist_knowledge_base for rzr|z after deletion: z(Failed to delete vector data for tenant rKTr*)r5rOrArPrQrcrWrrRrrSrrUrr{rr:r6r9rX) rFrr?rY delete_query deleted_countdelete_crawled_queryr{rrr@s rdelete_vector_data_by_sourcers KK3I;jQR  D) [[]" !c KKdgpfr s<<> " !P C77$y12  KK vi 0LLM$'77,$y12 ! KK,vi 8 KKM KK(=/1Z[dZeeopvowx yq kS1)#F/$ F<> F,F'"F/'F,,F//F84F<;H< G9/G44G99HH base_urlcntjd|d|t} |j5}|j d}t j djt j|}|j|||dzf|j}t j djt j|}|j|||dzf|jtjd|d|d |cd d d |r|jSS#1swYnxYwnB#t$r6}|r|jtjd |d |d |d }~wwxYw |r|jy y #|r|jwwxYw)z Deletes all vector data and crawled URLs for a base URL and its sub-paths. This is used to implement 'replacement' logic during re-analysis. z2Deleting vector data and crawled URLs for tenant: z , base_url: /z DELETE FROM {}.strategist_knowledge_base WHERE metadata->>'ingestion_type' = 'website' AND (metadata->>'source' = %s OR metadata->>'source' LIKE %s) z/%zt DELETE FROM {}.strategist_crawled_urls WHERE (url = %s OR url LIKE %s) rrz and its sub-paths.Nz Failed to delete by subpath for rKTr*)r5rOrArPrstriprrRrrSrQrrUrWr:rXr9) rFrr?rY url_patterndelete_kb_querykb_countdelete_urls_queryr@s r!delete_vector_data_by_url_subpathr9s  KKDYK|\d[efg  D [[] c"//#.K"gg'y12  KK+{T7I)J K||H!$)!y12  KK)Kt9K+L M KKM KK(8*,UV^U__rs t1  < 4=   2   7zA3GRV W3 < 444sAEC'D; E;EEF F1FFFF4 source_namect} |j5}|jd|f|jsgcddd|j St j djt j|}|j|||f|jDcgc] }|ds |dc}cddd|j Scc}w#1swYnxYwnC#t$r7}tjd|d|gcYd}~|j Sd}~wwxYw |j y#|j wxYw)z} Returns a list of source_ids matching a specific source name and type. Used for implementing replacement logic. rNz SELECT DISTINCT metadata->>'source_id' FROM {}.strategist_knowledge_base WHERE metadata->>'source' = %s AND metadata->>'ingestion_type' = %s rz&Error fetching source_ids by name for rK) rArPrQrcrWrrRrrSrr:r5r9)rFrrr?rYrfrgr@s rget_source_ids_by_nameras=  D [[] @c KKdgpfr s<<> @ @" GGy12  KK ^< =&)lln?sACF? @ @" @ @ @ @  =k]"QCPQ   @"  sqC8%C+ C8AC+8 C&C& C+ C8&C++C40C87E 8 D8D3D8E 3D88E E feature_name model_name prompt_tokenscompletion_tokens total_tokensc*tjd|d|d||s|r|jd}t} |j 5} | j d|f| j ds5tjd| ddd|r|jy y d} d} |rbtjd jtj|} | j | ||f| j } | r| \} } || kr|}|}n || z }|| z }||z}td|}td|}td|}tjd jtj|}| j |||||||||tj|xsif |j!tjd |d |d|d ddd|r|jyy#1swYnxYwnV#t"$rJ}|r|j%tj'd|d|Yd}~|r|jy y d}~wwxYw |r|jyy#|r|jwwxYw)z Persists LLM token usage data into the tenant's strategist_llm_usage table. Implements Delta-based tracking to avoid double-counting thread history. z#[DB] Logging LLM usage for tenant: z , feature: rrz SELECT EXISTS ( SELECT FROM information_schema.tables WHERE table_schema = %s AND table_name = 'strategist_llm_usage' ) rzA[DB] Skipping usage log: Table strategist_llm_usage not found in NFa  SELECT cumulative_prompt_tokens, cumulative_completion_tokens FROM {}.strategist_llm_usage WHERE thread_id = %s AND feature_name = %s ORDER BY created_at DESC LIMIT 1 a INSERT INTO {}.strategist_llm_usage ( feature_name, model_name, prompt_tokens, completion_tokens, total_tokens, thread_id, cumulative_prompt_tokens, cumulative_completion_tokens, metadata, created_at ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, CURRENT_TIMESTAMP) z[DB] Logged Delta: z tokens (Thread: z , Feature: )Tz#Failed to log LLM usage for tenant rK)r5rOrrArPrQrcr6rWrrRrrSrrrrUr:rXr9)rFrrrrrrsrr?rYlast_cumulative_promptlast_cumulative_completion fetch_queryrg delta_promptdelta_completion delta_totalr\r@s rinsert_llm_usager!{s  KK5i[ L>Ycdmcnop LL-  DO [[]H c KK   <<>!$!bclbmnoH \ 4A&' ")* &!gg' VCNN956   K)\)BCllnILF*,F55, #4 ,/EE #47Q#Q &)99Kq,/L"1&67 a-K77$y12  KK  ! 8>r* '  KKM KK-k]:KI;Vabnaoopq rQH \ 4]H H H R   :9+RsKL 4 SH \ 444sUHAHH+D>H)HH HI= I%-I I= I%%I==Jc tjd|t} |j5}t j dj t j|}|j||f|j}|Dcgc]2}|d|d|d|d|d|dr|djndd 4c}cddd|jScc}w#1swYnxYwnC#t$r7}tjd |d |gcYd}~|jSd}~wwxYw |jy#|jwxYw) NzFetching LLM usage for tenant: zSELECT feature_name, model_name, prompt_tokens, completion_tokens, total_tokens, created_at FROM {}.strategist_llm_usage ORDER BY created_at DESC LIMIT %srr&rrrr)featuremodelrrr timestampz Error fetching usage for tenant rK)r5rOrArPrrRrrSrQrrrWr:r9)rFrr?rYrfrrr@s r get_llm_usager'sk KK1)=>  D [[] cGGyzAABEBPBPQZB[\E KKx (<<>D Q41!"1%&qT !!121QqT^^-4         7 {"QCHI     s_C8AC+7C& C+ C8&C++C40C87E 8 D8D3D8E 3D88E Edatacltjd|jdd|t} |j 5}t j djt j|}|j||d|jd|jd|jd|jd|jd |jd |jd |jd |jd |jd|jd|jd|jdtj|jdif|j ddd|jy#1swYnxYwnP#t$rD}|jtj!d|dYd}~|jyd}~wwxYw |jy#|jwxYw)z= Inserts or updates analytics for a specific thread. z&Upserting thread analytics for thread rra INSERT INTO {}.strategist_thread_analytics ( thread_id, sentiment_score, intent, is_high_intent, is_lead_qualified, is_resolved, escalation_needed, positive_points, key_concerns, pain_point, feature_request, objection, cta_clicked, summary, metadata, last_analyzed_at ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, CURRENT_TIMESTAMP) ON CONFLICT (thread_id) DO UPDATE SET sentiment_score = EXCLUDED.sentiment_score, intent = EXCLUDED.intent, is_high_intent = EXCLUDED.is_high_intent, is_lead_qualified = EXCLUDED.is_lead_qualified, is_resolved = EXCLUDED.is_resolved, escalation_needed = EXCLUDED.escalation_needed, positive_points = EXCLUDED.positive_points, key_concerns = EXCLUDED.key_concerns, pain_point = EXCLUDED.pain_point, feature_request = EXCLUDED.feature_request, objection = EXCLUDED.objection, cta_clicked = EXCLUDED.cta_clicked, summary = EXCLUDED.summary, metadata = EXCLUDED.metadata, last_analyzed_at = CURRENT_TIMESTAMP sentiment_scoreintentis_high_intentis_lead_qualified is_resolvedescalation_neededpositive_points key_concerns pain_pointfeature_request objection cta_clickedrrsNTz#Failed to upsert thread analytics: r*F)r5rOrrArPrrRrrSrQrrrUrWr:rXr9)rFr(r?rY upsert_queryr@s rupsert_thread_analyticsr7s KK8+9N8O{[dZefg  D4 [[]- c77$0y121 4 KK [!*+")*,-',-*+(&*+%'# 488J34' " KKM[- f g- - - \   :1#> N ]- f  sHF?EF2F?2F;7F?>H!? H *H2H!H  H!!H3cbt} |j5}tjdj tj |tj |}|j ||jDcgc]}|d c}cddd|jScc}w#1swYnxYwnE#t$r9}tjd|d|dgcYd}~|jSd}~wwxYw |jy#|jwxYw)zV Returns unique thread IDs that are present in feedback but not in analytics. z SELECT DISTINCT thread_id FROM {}.strategist_feedback WHERE thread_id NOT IN (SELECT thread_id FROM {}.strategist_thread_analytics) rNz-Error fetching unanalyzed threads for tenant rKTr*) rArPrrRrrSrQrrWr:r5r9)rFr?rYrfrgr@s rget_unanalyzed_threadsr9*s  D  [[] 6cGGy13>>)3LM  KK &)lln5sCF5 6 6 6 6 6 6  DYKrRSQTU`d e   6  s_CA/B8 B3B8 C3B88C=CD DD,D-DDDD.c tjd|d|t} |j5}|j d|f|j sgcddd|j Stjdjtj|}|j ||f|j}g}|D]{}|d}|j|d|d|r|jjnd|r|jj!d nd|r|jnd|d d }|cddd|j S#1swYnxYwnE#t"$r9} tj%d |d | dgcYd} ~ |j Sd} ~ wwxYw |j y#|j wxYw)zX Returns a list of unique sources (filenames, URLs) for a given ingestion type. z-Listing unique knowledge sources for tenant: rrNa SELECT metadata->>'source_id' as source_id, metadata->>'source' as source_name, MIN(created_at) as first_ingested_at, metadata FROM {}.strategist_knowledge_base WHERE metadata->>'ingestion_type' = %s GROUP BY 1, 2, 4 ORDER BY first_ingested_at DESC rrr&z%H:%M:%Sr)rr ingested_date ingested_timerrsz-Failed to fetch knowledge sources for tenant rKTr*)r5rOrArPrQrcrWrrRrrSrrddaterr7strftimer:r9) rFrr?rYrfrsourcesrgdtr@s rget_knowledge_sourcesrA=s KK? {(SaRbcd  D& [[] c KKdgpfr s<<>  J ?GG  y12  KK0 1<<>DG V!$Q!!f>@RWWY%8%8%:dGIRWWY%7%7 %Ct46",,.D #A   A  J K   B  DYKrRSQTU`d e  C J  sYE:%E- E:6CE- E:-E62E:9G: F<F7!F<"G7F<<GG#c tjd t} |j5}dtd}|j ||j Dchc]6\}}t|tr!t|jdr|nd|8}}}|rJt|}tjdt|d||cddd|jStjdddd|j tjd t#} |j5}d }|j ||j Dcgc]}|d }}tjdt|d||cddd|jScc}}w#1swYxYw#|jwxYw#t$r$}tj!d |d Yd}~d}~wwxYwcc}w#1swYnxYwnB#t$r6}tj!d|d gcYd}~|jSd}~wwxYw |jy#|jwxYw)z Returns tenant schema names eligible for scheduled analytics refresh. Active Aivora subscriptions from master are authoritative. The legacy schema scan remains as a fallback if the master lookup is unavailable. z,Fetching list of eligible Strategist tenantsa  SELECT o."tenantId"::text, p."productFeatures" FROM "Organisations" o JOIN "Subscriptions" s ON s."organisationId" = o."id" JOIN "Plans" p ON p."id" = s."planId" WHERE zA ORDER BY o."tenantId"::text org_zFound z active/trial Aivora tenants: Nz>No active/trial Aivora subscriptions found in master database.z;Error fetching active Aivora tenants from master database: Tr*zEFalling back to tenant schemas that contain strategist_knowledge_basea SELECT DISTINCT table_schema FROM information_schema.tables WHERE table_name = 'strategist_knowledge_base' AND table_schema NOT IN ('public', 'information_schema', 'pg_catalog') rz eligible tenants: z!Error fetching eligible tenants: )r5rOrErPSUBSCRIPTION_ELIGIBILITY_SQLrQrrAIVORA_PRODUCT_NAMEr startswithsortedr~rWr6r:r9rA) r?rYrfrFrtenants tenant_listr@rgs rget_eligible_tenantsrJksa  KK>?g')  a# 889  E"8;||~3 #3()9;NO"%Y!:!:6!BI$ykHZZ "(/KKK&[)9(::XYdXe fg&% a a* JJL_`' a* JJL KKWX  D [[] cE KK ),8#s1v8G8 KK&W.A'K L   C a a* JJL g RSTRUVae ffg9     8GH HG?*H?HHH+czt} |j5}|rKtjdj tj |}|j ||fnF|j tjdj tj ||jdcddd|jS#1swYnxYwn-#t$r!}tjd|d|d}~wwxYw |jy#|jwxYw)zTReturns the number of tickets created for the tenant, optionally since a start date.zASELECT COUNT(*) FROM {}.strategist_tickets WHERE created_at >= %sz*SELECT COUNT(*) FROM {}.strategist_ticketsrNzError getting ticket count for rK rArPrrRrrSrQrcrWr:r5r9rF start_dater?rYrfr@s rget_ticket_countrbs  D  [[] %c cdkklolzlz|EmFG EJ=1 CGG$PQXXY\YgYghqYrst<<>!$  % %  % % %  6ykA3GH  %  AC)B&C C)C%!C)(D() D2DDD((D:ct} |j5}|jtjdj tj ||jdcddd|jS#1swYnxYwn-#t$r!}tjd|d|d}~wwxYw |jy#|jwxYw)zSELECT pg_total_relation_size('{0}.strategist_knowledge_base')rNz!Error getting vector db size for rK) rArPrQrrRrrSrcrWr:r5r9rs rrrs  D  [[] %c KK `ahhiliwiwyBjCD E<<>!$ % %  % % %  8 2aSIJ   %  sABAB5 BBBC C%CCCC-ct} |j5}|rKtjdj tj |}|j ||fnF|j tjdj tj ||j}|r |dr|dndcddd|jS#1swYnxYwn-#t$r!}tjd|d|d}~wwxYw |jy#|jwxYw)zNReturns the sum of total_tokens for the tenant, optionally since a start date.zLSELECT SUM(total_tokens) FROM {}.strategist_llm_usage WHERE created_at >= %sz5SELECT SUM(total_tokens) FROM {}.strategist_llm_usagerNzError getting token usage for rKr_)rFrar?rYrfrgr@s rget_total_token_usagerfs$  D  [[] 3c novvwzxFxFGPxQR EJ=1 CGG$[\ccdgdrdrs|d}~,,.C SV3q6 3 3  3 3 3  5i[1#FG  3  sAC4B1C' C4'C0,C43D34 D=DDD33Eczt} |j5}|rKtjdj tj |}|j ||fnF|j tjdj tj ||jdcddd|jS#1swYnxYwn-#t$r!}tjd|d|d}~wwxYw |jy#|jwxYw)zRReturns the number of unique threads that had activity [usage] since a start date.zTSELECT COUNT(DISTINCT thread_id) FROM {}.strategist_llm_usage WHERE created_at >= %sz=SELECT COUNT(DISTINCT thread_id) FROM {}.strategist_llm_usagerNz%Error getting conversation count for rKr_r`s rget_conversation_countrh.s(  D  [[] %c vw~~@C@N@NOX@YZ EJ=1 CGG$cdkklolzlz|EmFGH<<>!$  % %  % % %  rtsq $  ',,/ef   : & cd44}}~232h Rs R*#***PT*Xc3(##C(*#*U *C*XST$3S0%c%%P#sCC0&#&#&P535n##3QT>33B0s4>/C//b&&&PcS4[[3[C[X[[ps[DG[SW[kn[zS,:s:$:xc&,S,#,\6p!#!H434l" # S$cr