7~jdZddlmZddlZddlZddlZddlmZddlm Z ddl Z ddl m Z ddl mZmZmZddlmZmZmZmZejeZd ZGd d ZdS) uPerplexity Sonar-Pro client. Two call shapes used by the pipeline: - city_intelligence(city, country, show_date) → CityIntelligence - local_news(city, country, since_date, show_date) → PerplexityNewsResult (also extracts competitor_warnings from the returned list) The competitor-warnings extraction happens here because Perplexity is the only provider that can scan current news sources; the Gemini fact-check stage only verifies what comes out of this stage. ) annotationsN)date)Any)settings)CityIntelligenceNewsItemPerplexityNewsResult)JsonExtractionError_build_semaphore extract_jsonhttp_post_jsonz*https://api.perplexity.ai/chat/completionscBeZdZdZddZddZddZdd ZddZddZ dS)PerplexityClientzDSonar-Pro HTTP client (OpenAI-compatible chat.completions endpoint).returnNonectjtj|_t tj|_dS)N)timeout)httpx AsyncClientrPERPLEXITY_TIMEOUT_clientr PERPLEXITY_MAX_CONCURRENCY_semselfs q/Users/abstractioneditor2/ai-workstation/projects/automation/show-city-briefing-agent/app/providers/perplexity.py__init__zPerplexityClient.__init__,s0(1LMMM $X%HII cHK|jd{VdS)N)raclosers rclosezPerplexityClient.close0s2l!!###########rdict[str, str]c(dtjdddS)NzBearer zapplication/json) Authorizationz Content-TypeAccept)rPERPLEXITY_API_KEYrs r_headerszPerplexityClient._headers3s%Dx'BDD.(   rsystemstruserdict[str, Any]c Ktjd|dd|dgdd}|j4d{Vt|jt ||ttjdd{V}dddd{Vn#1d{VswxYwY |dd d d }n)#ttf$r}td |d}~wwxYw| d g}||dS)Nr()rolecontentr*g?)modelmessages temperature perplexity)clienturlheaderspayloadr provider_namechoicesrmessager.z.perplexity: missing choices[0].message.content citationstextr:) rPERPLEXITY_MODELrr r_PERPLEXITY_URLr'floatrKeyError IndexErrorr get)rr(r*r6datar<excr:s r_chatzPerplexityClient._chat:s.!f55D11   9        '|# h9::* D                            a ?1%i0;DD*% a a a%&VWW]` ` aHH["-- 9555s*AB  BBB66CCCcitycountry show_daterrc TKd}d|d|d|d}|||d{V} t|d}n?#t$r2td|ddd gggd }YnwxYwt |d tr |d g|d <g}g} t |d trd |d D} t|d|d gDddd|dgDddt|dpd| dd|ddd|ddS)NuYou are a city-intelligence analyst for a stand-up comedy tour. Only return claims that you can support with current online sources. Do not speculate. If you cannot find a fact, omit it. Return STRICT JSON only — no commentary, no markdown fences.z I am preparing a comedy show in , z on a. Produce a JSON object with these keys: points_of_pride (up to 5 strings the city is known for locally), sensitivities_to_avoid (up to 5 topics a visiting comedian should not poke at), local_conversation_today (one sentence describing the biggest local conversation in this city right now), audience_competitors (list of up to 5 other comedians or shows currently competing for this city's live-comedy audience).r(r*r<z9perplexity city_intel returned non-JSON; storing raw text)local_conversation_todaypoints_of_pridesensitivities_to_avoidaudience_competitorsrNrPc,g|]}t|Sr).0xs r z6PerplexityClient.city_intelligence..wsJJJa3q66JJJrc,g|]}t|SrRrSrTs rrWz6PerplexityClient.city_intelligence..zsOOOSVVOOOrc,g|]}t|SrRrSrTs rrWz6PerplexityClient.city_intelligence..{s#]#]#]qCFF#]#]#]rrOrMir:r;)rFrNrOrMrPraw_provider_payload) isoformatrEr r loggerwarning isinstancerBr)listr) rrFrGrHr(r*rCparsedrows competitorss rcity_intelligencez"PerplexityClient.city_intelligenceUs# M  It I Iw I IIDWDWDYDY I I I ZZvDZ99999999 !$v,//FF"    NNV W W W,0L$,?#%*,(* FFF  fjj!233S 9 9 D)/0A)B(CF$ %!# fjj!788$ ? ? KJJ62H+IJJJKOOVZZ8I2-N-NOOOPRQRPRS#]#]FJJ?WY[4\4\#]#]#]^`_`^`#a%(4N)O)O)WSW%X%X!,RaR*.v,uu*=DQ\L]!^!^     sA9BB since_dater c LKd}d|d|d|d|d|d|d }||| d{V} t|d }n/#t$r"td ggd }YnwxYwt |tsggd }g} |d gddD]} | tt| ddpdddt| ddpdddt| dpdt| dpddg} |dgddD]} | tt| ddpdddt| ddpdddt| dpdt| dpddt| | S)NuYou are a local-news summarizer for a visiting comedian. Cite the original URLs when possible. Return STRICT JSON only — no commentary, no markdown fences.zReturn local news for rJz published between z and a,. Produce a JSON object with two keys: "recent_news": array of objects {title, summary, date, url} of up to 8 items most relevant to a visiting comedian. "competitor_warnings": array of objects {title, summary, date, url} of up to 5 items describing OTHER comedy shows or comedians performing in u within ±3 days of z4. If no competition is found, return an empty array.rKr<z9perplexity local_news returned non-JSON; storing raw text) recent_newscompetitor_warningsrgtitlei,summaryrLrr4F)rjrlrr4 is_competitorrhrYT) r\rEr r r]r^r_dictrBappendrr)r ) rrFrGrerHr(r*rCra news_rowsitemcompetitor_rowss r local_newszPerplexityClient.local_newss! "   AT A AW A A##%% A A,5,?,?,A,A A A" A A8A7J7J7L7L A A A ZZvDZ99999999 D!$v,//FF" D D D NNV W W W%'CCFFF D&$'' D%'CCF JJ}b11"1"5  D   X$((7B//5266tt<DHHY339r::5D5A&))1T22/400#     JJ4b99"1"=  D  " "8$((7B//5266tt<DHHY339r::5D5A&))1T22/400" $$$    $ ____s.B)B0/B0N)rr)rr")r(r)r*r)rr+)rFr)rGr)rHrrr) rFr)rGr)rerrHrrr ) __name__ __module__ __qualname____doc__rr!r'rErdrsrRrrrr)sNNJJJJ$$$$    66666* * * * \-`-`-`-`-`-`rr)rw __future__rasynciojsonloggingdatetimertypingrr app.configr app.modelsrrr app.providers._commonr r r r getLoggerrtr]r>rrRrrrsJ  #"""""     8 $ $>G`G`G`G`G`G`G`G`G`G`r