+ i$FRt^RIt^RIt^RIt^RIHtHtHtHt^RI H t H t RR.t RRlt RR ltR R ltR tR tRtRRltRRltRRltRR'RR(RR)/tRtRRltRRltRRltR*RR lltR+R!R"lltR#R$ltR%R&ltR#),z1OpenAI Responses API client for Reddit discovery.N)AnyDictListOptional)httpenvzgpt-4.1zgpt-4oc$V^8dQhR\/#msgstr)formats"Y/Users/bowang/.openclaw/workspace/skills/last30days-official/scripts/lib/openai_reddit.py __annotate__rsCc\PPRV R24\PP4R#)zLog error to stderr.z[REDDIT ERROR]  Nsysstderrwriteflushr s&r _log_errorrs-JJse2./JJrc$V^8dQhR\/#r r )rs"rrrs3rc\PPRV R24\PP4R#)zLog info to stderr.z [REDDIT] rNrrs&r _log_infors-JJyR()JJrcDV^8dQhR\PR\/#)r errorreturn)r HTTPErrorbool)rs"rrrs$..TrcaVPR9dR#VP'gR#VPP4o\;QJdV3RlR4F 'gK R# R#!V3RlR44#)z:Check if error is due to model access/verification issues.Fc3,<"TF qS9xK R#5i)N).0phrase body_lowers& r )_is_model_access_error..#s3#3sT)i)verifiedzorganization must bezdoes not have accessz not availablez not found) status_codebodylowerany)rr(s&@r_is_model_access_errorr1sq  * :::!!#J 3333333 rz#https://api.openai.com/v1/responsesz/https://chatgpt.com/backend-api/codex/responsesaYou are a research assistant for a skill that summarizes what people are discussing in the last 30 days. Your goal is to find relevant Reddit threads about the topic and return ONLY the required JSON. Be inclusive (return more rather than fewer), but avoid irrelevant results. Prefer threads with discussion and comments. If you can infer a date, include it; otherwise use null. Do not include developers.reddit.com or business.reddit.com.chV^8dQhR\R\\\\3,,/#)r chunkr )r rrr)rs"rrr8s'CHT#s(^$<rcVPR4p.pVFBpVPR4'gKVPVR,P44KD V'gR#RP V4P4pV'dVR8XdR#\ P !V4# \ PdR#i;i)z,Parse a single SSE chunk into a JSON object.rzdata::NNNz[DONE])split startswithappendstripjoinjsonloadsJSONDecodeError)r3lines data_lineslinedatas& r_parse_sse_chunkrB8s KK EJ ??7 # #   d2hnn. /  99Z & & (D 48#zz$   sB--CCchV^8dQhR\R\\\\3,,/#r rawr )r rrr)rs"rrrNs'stDcN';rc:.pRpVPRR7FJpW#, pRV9gKVPR^4wrB\V4pVfK.VPV4KA VP 4'd!\V4pVeVPV4V#)z6Parse SSE stream from raw text and return JSON events.T)keepends ) splitlinesr6rBr8r9)rEeventsbufferr3 event_chunkevents& r_parse_sse_stream_rawrONs#%F F."(,,vq"9 K$[1E  e$ /||~~ (   MM% MrcRV^8dQhR\R\\\3,/#rDr rr)rs"rrr`s"##S#T#s(^#rc\V4p\V4Fp\V\4'gKVP R4R8Xd1\VP R4\4'd VR,u#\VP R4\4'gKVR,u# RpVF}p\V\4'gKVP R4p\V\ 4'd W4, pKLVP R4p\V\ 4'gKuW5, pK V'dRRRR RR RV/././#/#) z@Parse SSE stream from Codex responses into a response-like dict.typezresponse.completedresponserGdeltatextoutputmessagecontent output_text)rOreversed isinstancedictgetr )rErKevtrZrUrVs& r_parse_codex_streamr``s "3 'F c4 wwv"66:cggjFY[_;`;`:&#''*-t44:&  K#t$$   eS ! !  K wwv dC  K I LM   IrquickdefaultdeepuFind Reddit discussion threads about: {topic} STEP 1: EXTRACT THE CORE SUBJECT Get the MAIN NOUN/PRODUCT/TOPIC: - "best nano banana prompting practices" → "nano banana" - "killer features of clawdbot" → "clawdbot" - "top Claude Code skills" → "Claude Code" DO NOT include "best", "top", "tips", "practices", "features" in your search. STEP 2: SEARCH BROADLY Search for the core subject: 1. "[core subject] site:reddit.com" 2. "reddit [core subject]" 3. "[core subject] reddit" Return as many relevant threads as you find. We filter by date server-side. STEP 3: INCLUDE ALL MATCHES - Include ALL threads about the core subject - Set date to "YYYY-MM-DD" if you can determine it, otherwise null - We verify dates and filter old content server-side - DO NOT pre-filter aggressively - include anything relevant REQUIRED: URLs must contain "/r/" AND "/comments/" REJECT: developers.reddit.com, business.reddit.com Find {min_items}-{max_items} threads. Return MORE rather than fewer. Return JSON: {{ "items": [ {{ "title": "Thread title", "url": "https://www.reddit.com/r/sub/comments/xyz/title/", "subreddit": "subreddit_name", "date": "YYYY-MM-DD or null", "why_relevant": "Why relevant", "relevance": 0.85 }} ] }}c0V^8dQhR\R\/#r topicr r )rs"rrrs))))rc.ROpVP4P4pVUu.uF q3V9gK VNK ppRPVR,4;'gT#uupi)z2Extract core subject from verbose query for retry. :NN)besttopzhow toztips for practicesfeatureskillerguidetutorialrecommendationsadvice promptingusingforwiththeofinon)r/r6r:)rfnoisewordswresults& r_extract_core_subjectrsZ KE KKM   !E 1A5.aaF 1 88F2J  ( (5(2s AAc0V^8dQhR\R\/#rer )rs"rrrs + +# +# +rc\V4pVPRR4PRR4P4pRV R2#)zBuild a subreddit-targeted search query for fallback. When standard search returns few results, try searching for the subreddit itself: 'r/kanye', 'r/howie', etc. .rGrhr/z site:reddit.com)rreplacer/)rfcoresub_names& r_build_subreddit_queryrsD ! 'D||C$,,S"5;;=H z) **rc vV^8dQhR\R\R\R\R\\\3,/#)r modelinstructions_text input_text auth_sourcer rQ)rs"rrrs=##3UX]abegjbj]krc RVRRRRRRRR .//.R R .R VR V/pV\P8XdRRRRRRRRV/./.VR &RVR&V#)z6Build responses payload for OpenAI or Codex endpoints.rstoreFtoolsrS web_searchfiltersallowed_domains reddit.comincludeweb_search_call.action.sources instructionsinputrXroleuserrYrrVTstream)rAUTH_SOURCE_CODEX)rrrrpayloads&&&& r_build_payloadrs  % ~   45)Gc+++ V\6:FG  ! NrcV^8dQhR\R\R\R\R\R\R\R\\,R \\,R \R \\\3,/ #) r api_keyrrf from_dateto_datedepthr account_id mock_response_retryr )r rrr"r)rs"rrrsx0x0 x0 x0 x0 x0  x0  x0x0 x0D>x0 x0 #s(^x0rc bVeV#\PV\R,4wrV\P8Xd*V'g \ R4hRRV 2RVRRR R R R /p \ p MRRV 2R R /p \ p VR 8Xd^ZM VR8Xd^xM^pV.\Uu.uF qV8wgK VNK up,p\PVVVV V R7pV\P8Xd^RI H pV.VPUu.uF qV8wgK VNK up,p\R,V,pRpVF?p\VVW&4p\P !V VWR7p\#T;'gR4u# V'dVh\P$!R4hRpVF0pRVRRRRRR.//.RR.R V/p\P*!V VWR7u# V'd\/R%V 24Vh\P$!R&4huupiuupi \P$d0pTpTP&R8Xd\)RT R24Rp?EKhRp?ii;i \P$dVpTp\-T4'd\)RT R!24Rp?KTP&R"8Xd\)R#T R$24Rp?EKhRp?ii;i)'aSearch Reddit for relevant threads using OpenAI Responses API. Args: api_key: OpenAI API key model: Model to use topic: Search topic from_date: Start date (YYYY-MM-DD) - only include threads after this to_date: End date (YYYY-MM-DD) - only include threads before this depth: Research depth - "quick", "default", or "deep" mock_response: Mock response for testing Returns: Raw API response Nrbz)Missing chatgpt_account_id for Codex auth AuthorizationzBearer zchatgpt-account-idz OpenAI-Betazresponses=experimental originatorpiz Content-Typeapplication/jsonra)rfrr min_items max_items)modelsrI)headerstimeoutrGr+zModel z+ not supported on Codex, trying fallback...z$No Codex-compatible models availablerrrSrrrrrrrz# not accessible, trying fallback...zRate limited on z, trying fallback model...zAll models failed. Last error: zNo models available) DEPTH_CONFIGr^rr ValueErrorCODEX_RESPONSES_URLOPENAI_RESPONSES_URLMODEL_FALLBACK_ORDERREDDIT_SEARCH_PROMPTrrGrCODEX_FALLBACK_MODELSCODEX_INSTRUCTIONSrrpost_rawr`r!r-rpostr1r)rrrfrrrrrrrrrrurlrm models_to_tryr models_modcodex_models_to_tryr last_error current_modelrrEes&&&&&&&&&& r search_redditrs4 '++E< 3JKIc+++HI I wwi0 * 3 $ .  " wwi0 . #W$b)1C#GG*>M*>Qu*qq*>MMM&,, -Jc+++*$gJ4T4T(c4Tq]bXb4T(cc.7*D 0M (8I5^mmC'S*399"55 1  nnCDDJ& ] L)L>  89 Z   99S'7L L!':4ZLAB ... //GN)d>>  ==C'}o5`ab  :~~ J%a((F=/1TUV}}#,]O;UVW  sZG3"G36G8G8.:G=(I=I"H<;H<<IJ."J) J)(J))J.cV^8dQhR\\,R\R\R\R\R\\\\3,,/#)r subredditsrfrr count_perr )rr intrr)rs"rrrfs]KKS K KK K  K  $sCx. Krcb.p\V4pVEFpVPR4pRV R2pR\V4 RV R2p V RV 2p R\PR R /p \P !W^^R 7p V P R /4P R .4p \ V 4EFwrVP R4R8wdKVP R /4pVP RR4pV'gKLRR\V4^, 2R\VP RR44P4RRV 2R\VP RV44P4RRRRV R2RR/pVP R4pV'd^R I H pVPV4VR&VPV4EK EK V# \PdAp\R!T R"T 24TP R#8Xd\R$4Rp?T#Rp?EKRp?i\"dp\R%T R"T 24Rp?EKRp?ii;i)&aSearch specific subreddits via Reddit's free JSON endpoint. No API key needed. Uses reddit.com/r/{sub}/search/.json endpoint. Used in Phase 2 supplemental search after entity extraction. Args: subreddits: List of subreddit names (without r/) topic: Search topic from_date: Start date (YYYY-MM-DD) to_date: End date (YYYY-MM-DD) count_per: Results to request per subreddit Returns: List of raw item dicts (same format as parse_reddit_response output). rzhttps://www.reddit.com/r/z /search/.jsonzq=z&restrict_sr=on&sort=new&limit=z &raw_json=1?z User-AgentAcceptr)rrretriesrAchildrenkindt3 permalinkrGidRStitlerzhttps://www.reddit.com subredditdateN why_relevantz Found in r/z supplemental search relevanceg? created_utc)dateszSubreddit search failed for r/z: ru;Reddit rate-limited (429) — skipping remaining subredditszSubreddit search error for r/)rlstrip _url_encoder USER_AGENTr^ enumeratelenr r9rGrtimestamp_to_dater8r!rr- Exception)rrfrrr all_itemsrsubrparamsfull_urlrrArichildrritemr dates_modrs&&&&& rsearch_subredditsrfs:,I  'Djj. B-cU-@C+d+,,KI;VabFax(Hdoo,G 88Hr1MDxx+// B?H%h/99V$,yy, HH["5  Bs9~a/01S'2!67==?3I;?TXXk3%?!@!F!F!HD"k#6J$K#hh}5 4#,#>#>{#KDL  &10!d ~~  6se2aSA B}}#WX  $ B 5cU"QC@ A A Bs1CF3)CF33H.-H H.H.H))H.c0V^8dQhR\R\/#)r rVr r )rs"rrrs))c)c)rc@^RIpVPPV4#)z)Simple URL encoding for query parameters.N) urllib.parseparse quote_plus)rVurllibs& rrrs << " "4 ((rcV^8dQhR\\\3,R\\\\3,,/#)r rTr )rr rr)rs"rrrs3YYDcNYtDcN7KYrc6.pRV9dVR,'dVR,p\V\4'dVPR\V44M \V4p\ RV 24\ P 'd,\ R\P!V^R7R, 24V#RpRV9dVR,p\V\4'dTpM\V\4'dVFp\V\4'dVPR 4R8Xd_VPR .4pVFEp\V\4'gKVPR 4R 8XgK3VPR R4pM, M)R V9d VR ,pM\V\4'dTpV'gKM V'g:R V9d3VR ,F%p RV 9gK V R,PR R4pM V'g*\R\VP44 2RR7V#\P!RV4p V 'd8\P!V P44p V PR.4p.p \#V4EFmwr\V\4'gKVPRR4pV'dRV9dKARRV ^, 2R\VPRR44P%4RVR\VPRR44P%4P'R4RVPR4R\VPRR44P%4R\)R\+R\-VPRR4444/pVR,'d3\P.!R \VR,44'gR!VR&V P1V4EKp V # \P dELi;i)"zvParse OpenAI response to extract Reddit items. Args: response: Raw API response Returns: List of item dicts rrXzOpenAI API error: zFull error response: )indent:NiNrGrWrSrYrZrVchoiceszH[REDDIT WARNING] No output text found in OpenAI response. Keys present: T)rz\{[\s\S]*"items"[\s\S]*\}itemsrrrRrrrrrrg?gg?z^\d{4}-\d{2}-\d{2}$N)r\r]r^r rrDEBUGr;dumpslistprintkeysresearchr<groupr=rr9rminmaxfloatmatchr8)rTrrerr_msgrZrWrrYcchoice json_matchrA clean_itemsrr clean_items& rparse_reddit_responsersp E(x00!6@6M6M%))Is5z2SVW\S]'y12 ::: .tzz(1/Me/T.UV W K8(# fc " " K  % %dD))xx'94"&((9b"9!(A)!T22quuV} 7U./eeFB.? %") 4&*6l c**"&K; 90y))FF"$Y/33IrB *  XY]^f^k^k^mYnXopx|} 7EJ ::j..01DHHWb)E KU#$%% hhub!l#-  AacU) S'2./557 3 TXXk267==?FFtL DHHV$ C <=CCE S#c5+s1K+L"MN  f  882C 68J4KLL%) 6":&/$2 =##   s6O??PP))2)Fd)rbrNNF)r5)__doc__r;rrtypingrrrrrGrrrrrr1rrrrBrOr`rrrrrrrrrr%rrrs7 ,,"8,  "=GC,$#P X x I (V) +:x0vK\) Yr