?i~O dZddlZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z ddl mZmZddlmZdZdd d d Zd d dd ZdefdZdedefdZdede efdZehdZdede e de efdZd0dedede ee ffdZ d1de edede de deddf d Z d2ded!ed"ed#ede ee ff d$Zd%e ee fde efd&Z d%e ee fde e!fd'Z"d(edefd)Z#d3ded*ed+e ede$fd,Z%d4de$fd-Z&d5d.e ee fdede e ee ffd/Z'y)6zPolymarket prediction market search via Gamma API (free, no auth required). Uses gamma-api.polymarket.com for event/market discovery. No API key needed - public read-only API with generous rate limits (350 req/10s). N)ThreadPoolExecutor as_completed)AnyDictListOptional) quote_plus urlencode)httpz.https://gamma-api.polymarket.com/public-search)quickdefaultdeepmsgctjjrBtjjd|dtjj yy)zHLog to stderr (only in TTY mode to avoid cluttering Claude Code output).z[PM]  N)sysstderrisattywriteflush)rs U/home/ubuntu/.openclaw/workspace/skills/last30days-official/scripts/lib/polymarket.py_logr"sA zz 5R) topicreturnc|j}gd}|D])}tj|d|tj}+|jS)zExtract core subject from topic string. Strips common prefixes like 'last 7 days', 'what are people saying about', etc. )z^last \d+ days?\s+zL^what(?:'s| is| are) (?:people saying about|happening with|going on with)\s+z^how (?:is|are)\s+z^tell me about\s+z ^research\s+)flags)stripresub IGNORECASE)r prefixespatterns r_extract_core_subjectr+)sM KKMEH@wE?@ ;;=rc t|}|g}|j}t|dk\r'|D]"}t|dkDs|j|$|j j |j k7r|j|j t }g}|D]X}|j j }|s$||vs)|j||j|j Z|ddS)aGenerate search queries to cast a wider net. Strategy: - Always include the core subject - Add ALL individual words as standalone searches (not just first) - Include the full topic if different from core - Cap at 6 queries, dedupe r N)r+splitlenappendlowerr%setadd) r corequerieswordswordseenuniqueqq_lowers r_expand_queriesr=<s ! 'DfG JJLE 5zQ %D4y1}t$ %  {{} ,u{{}% 5D F %'')//# wd* HHW  MM!'') $ % "1:r> pop culturecryptosportsculturesciencepoliticseventsctt|jj}i}|D]}|j dxsg}|D]h}t |t r|j ddn t|}|s3|j}|tvrL||vrQ|j |ddz||<jt|jdD cgc] \}} | dk\r|c} }d d} | Scc} }w) aExtract domain-indicator search terms from first-pass event tags. Uses structured tag metadata from Gamma API events to discover broader domain categories (e.g., 'NCAA CBB' from a Big 12 basketball event). Falls back to frequent title bigrams if no useful tags exist. tagslabelr#rr c|d SNr xs rz)_extract_domain_queries..|s AaD5rkeyr-N) r3r+r2r/get isinstancedictstr _GENERIC_TAGSsorteditems) r rD query_words tag_countseventrFtagrG label_lowercountdomain_queriess r_extract_domain_queriesr^as +E288:@@BCK"$J =yy &B =C,6sD,ACGGGR(s3xE++-Km+k) *ua 81 >/ "5'b <=s1v.. / "5'b <=s1v../s-?B1!A93B19 B1!B,&B1,B1r6pages all_eventserrors start_idxcttdt||z5}i}t||D]5\}}t d|dzD]} |j t || } ||| < 7t|D]} || } | jd} | jdr|j| d| jdg} | D]6}|jd d }|s||vr|| f||<$| ||dks0|| f||<8 d d d y #t$r$}|jt|Yd }~d }~wwxYw#1swYy xYw) zDRun (query, page) combinations in parallel, merging into all_events.) max_workers)startr r)rdrfrDidr#N) rminr0 enumeraterangesubmitrorresultrPr1rjrS)r6rprqrrrsexecutorfuturesir;pfuture query_idxrmrDrYevent_idrns r_run_queries_parallelrsr As7|e/C(D E&gY7 $DAq1eai( $!)=q!D"# $ $ #7+ &FI &!===4<<(MM(7"34!h3#BE$yyr2H# z105y/A 8,"Z%9!%<<05y/A 8,B &&&. & c!f%% &/&&s=AD??A:D: DD? D<D72D?7D<<D??E from_dateto_datedepthc 6tj|td}tj|td}t|}t d|d|d|di}g}t |||||j D cgc]\} } |  } } } t|| } |D chc]} | j}} | Dcgc]}|j|vs|} }| r't d| t | d||t|t|j d D cgc]\} } |  }} } t|t| z}t d t|d |d ||d}|r|sdj|dd|d<|Scc} } wcc} wcc}wcc} } w)aSearch Polymarket via Gamma API with two-pass query expansion. Pass 1: Run expanded queries in parallel, merge and dedupe by event ID. Pass 2: Extract domain-indicator terms from first-pass titles, search those. Args: topic: Search topic from_date: Start date (YYYY-MM-DD) - used for activity filtering to_date: End date (YYYY-MM-DD) depth: 'quick', 'default', or 'deep' Returns: Dict with 'events' list and optional 'error'. rzSearching for 'z' with queries: z (pages=)zDomain expansion queries: r )rsc |dSrIrJrKs rrMz#search_polymarket..s qQRtrrNzFound z unique events across z queries)rD_capz; Nr-rf) DEPTH_CONFIGrP RESULT_CAPr=rrvaluesr^r2r0rUjoin)r rrrrpcapr6rqrrev_first_pass_eventsr]r; seen_queriesdq merged_events total_queriesr}s rsearch_polymarketrs(   UL$; 0T Vs FF <FF" Fmarketct|jdxsd|jddft|jdxsd|jddft|jdxsd|jddfg}|jdd |d\}}}|d kry |dkDrd nd}|dz}|d|dd|S)zPick the most significant price change and format it. Returns string like 'down 11.7% this month' or None if no significant change. oneDayPriceChangertodayoneWeekPriceChangez this weekoneMonthPriceChangez this monthc |dS)NrrJrKs rrMz(_format_price_movement..s qtrTrOreverse{Gz?Nupdownd z.1fz% )absrPsort)rchanges abs_change raw_changeperiod directionpcts r_format_price_movementrs VZZ+ , 1 2FJJ?R4SU\] VZZ, - 2 3VZZ@T5UWbc VZZ- . 3! 4fjjAV6WYefG LL^TL2%,QZ"J FD"QFI s C[#c"VH --rcJ|jdxsg}|jd}|sgS t|trtj|}n|} t|trtj|}n|}g}t|D]?\}} t|}|t|kr||nd|dz} |j| |fA|S#tj t f$rg}YwxYw#tj t f$rgcYSwxYw#tt f$rYwxYw)zJParse outcomePrices JSON string into list of (outcome_name, price) tuples.outcomes outcomePriceszOutcome r ) rPrQrSjsonloadsJSONDecodeError TypeErrorrzfloat ValueErrorr0r1) r outcomes_raw prices_rawrpricesr}rpricernames r_parse_outcome_pricesrs/::j)/RLO,J   lC (zz,/H#H j# &ZZ +FFFf%!5 e A #h-/x{x!u5E tQi ! M)  ) ,  ) , I&   s5(C(C/ DC,+C,/D  D D"!D"questionc|jjd}tjd|tj}|r|j djStjd|tj}|rJt |j djdkr|j djSt |dkDr|ddS|S)zExtract a short display name from a market question. 'Will Arizona win the 2026 NCAA Tournament?' -> 'Arizona' 'Will Duke be a number 1 seed in the 2026 NCAA...' -> 'Duke' rbz^Will\s+(.+?)\s+(?:win|be|make|reach|have|lose|qualify|advance|strike|agree|pass|sign|get|become|remain|stay|leave|survive|next)\br z^Will\s+(.+?)\s+r(N)r%rstripr&matchr(groupr0r/)rr;ms r_shorten_questionr#s $A WYZ\^\i\i jAwwqz!! $a7AS!!# $ )wwqz!!MB.8CR=.market_volumes9 QUU8Q/4155 *  s !33rrrr-yesnor c3NK|]\}}|jdk(s|yw)rN)r2).0rrs r z,parse_polymarket_response..s!!RaDJJLE.s !A$r volume1mo volume1wk competitive volume24hrzhttps://polymarket.com/event/ updatedAt endDaterrrr rrrg333333?g333333?g?c3DK|]}t|dkDs|vyw)r-N)r0)rtok name_lowers rrz,parse_polymarket_response.. s!XS3s8VW.(s Q{^rr)rPrzrrrr1rrr0r2nextrrr IndexErrorrrymathlog1prrr+r3r/anyround);rmr rDrVrrYrrrractive_marketsrliqr top_marketall_outcome_namesrrrrnrtop_outcomes_are_binarysynth_outcomesr;pairs yes_pricerrevent_volume1moevent_volume1wkevent_liquidityevent_competitiverrrl updated_atdate_strr text_scorevol_raw vol_score liq_score day_change week_change month_change max_changemovement_scorecompetitive_scorerr5r reorderedrestpair top_outcomes remainingrrs; @rparse_polymarket_responser"cs\\(B 'F Ef%s 599T2& '2&yy$ 99Xu % yy4( ))Ir*  )AuuXu%554( AEE+q16Q7Qw%%a( )    t<$A&  3A4Q7 3 e4':Q'>N# :EE*b)-a0 !R5!RTXY (Y->"))1i.9 :###EHV!W1#4Q#7";!W!W0 ;&eii &<=%eii &<=%eii &<=' -(@A >+3N'O 9=-dV4DabjakBlYY{B/   %cr? >>),  #CR= SX-eUC!DqH :>>*?@EAF [,? S*q.1. :  9   9   > ! " $ $  %  ^(/557Ddjjl+KID& &!!W]]_ J&**<XKXX$$T*KK% &!*T!1&bq) '!+ q=I  "z59*"+,$(" y!,1%*>  Is l JJ+TJ: ,,vs5z *C #;} *  N7"X, *   *  sBV!V0V6 V<$WV-,V-<WWW'&W')r )r)r)N)r)r#)(__doc__rrr&rconcurrent.futuresrrtypingrrrr urllib.parser r r#r rgrrrSrr+r= frozensetrTr^introrrrtuplerrrrrr"rJrrr*s  ?,,.C    c&349D_` 3T tCyD / /3 /tCH~ /"VW& #Y&"&04&>B&OR& &F 1 111  1  #s(^ 1h.4S>.hsm.0"$sCx."T%["J===$#'C#'#'tCy#'TY#'LUGS#XGsGDQUVY[^V^Q_L`Gr