[i- dZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z ddl m Z ddlZddlmZmZmZmZdZdZd Zd ZeGd d ZeGd dZ ddeedejde ede edef dZdejdeefdZdejfdZ dejdeefdZ!dejdeefdZ"dS)a LuckySt Syndicate - Game Scheduler with Base On-Chain Commitment Schedules a LuckBot Trader to trade a list of specific games in the next 24 hours. The schedule is committed to Base as an immutable self-transfer transaction, then stored in Redis for the execution engine to pick up and deploy at game time. Flow: 1. User provides list of games (tickers + start times + optional config) 2. Schedule commitment is written to Base (calldata = JSON schedule) 3. Schedule entries stored in Redis sorted set (score = start timestamp) 4. Background poller checks Redis every 30s and deploys instances at game time 5. When session ends, on-chain report is generated (via mm_core report hook) N) dataclassfieldasdict)datetimetimezone timedelta)Optional)write_report_to_chainLUCKYST_BUILDER_SUFFIX BASE_RPC_URL BASE_CHAIN_IDzluckyst:schedule:pendingzluckyst:schedule:meta:zluckyst:schedule:activezluckyst:schedule:donecjeZdZUdZeeed<eed<dZeeed<dZ e ed<dZ e ed <dS) GameEntryzA single game to be traded.markets start_timeN stop_time contract_sizeF higher_first) __name__ __module__ __qualname____doc__liststr__annotations__rr rintrbool(/app/agentic/syndicate/game_scheduler.pyrr.se%% #YOOO#Ix}###M3L$r rceZdZUdZeed<eeZee ed<dZ eed<dZ e eed<dZ eed <d efd Zed ed dfd ZdS)ScheduleCommitmentz Full schedule committed to Base. schedule_id)default_factorygames created_atNbase_txauthor_addressreturncHtjt|dS)N)indent)jsondumpsr)selfs r!to_jsonzScheduleCommitment.to_jsonAsz&,,q1111r rawc tj|}d|dgD}t|d||dd|d|ddS) Nc&g|]}tdi|S)r)r).0gs r! z0ScheduleCommitment.from_json..Gs"???AQ???r r&r$r(r'r)r*)r$r&r(r)r*)r/loadsgetr#)r3datar&s r! from_jsonzScheduleCommitment.from_jsonDsz#??'2)>)>???!]+xx b11HHY''88$4b99     r )rrrrrrrrr&rr(r)r r*r2 staticmethodr<rr r!r#r#8s**"U4888E4 ?888J!GXc]!!!NC22222  s  3    \    r r#r& redis_client base_addressbase_keyr+c xKttjdd}tjt j}g}|D]r}t|d|d|d|dd|dd  }| |st||| |pd } |r|r | d } d| z} t| ||d{V} | jr+| jr$| j| _t%d| jnt%d| jn)#t($r} t%d| Yd} ~ nd} ~ wwxYwt+|D]\}} tj|j}|}n$#t($r|}YnwxYw|d|}|||j|j|j|j|jd| jd }|t<||i|t@|tCj"||t@|| | S)a Create a game schedule, commit to Base, and store in Redis. Args: games: List of game dicts with keys: markets, start_time, stop_time, contract_size, higher_first redis_client: Redis connection base_address: Base address for on-chain commitment (optional) base_key: Private key for signing (optional) Returns: ScheduleCommitment with schedule_id and optional base_tx NrrrrrrF)rrrrrr')r$r&r(r*zutf-8u ✓ Schedule committed to Base: u⚠️ Base commit failed: u⚠️ Base commit error: :pending) r$ game_indexrrrrrstatusr))#ruuiduuid4rnowrutcrr:appendr# isoformatr2encoder successtx_hashr)printerror Exception enumerate fromisoformatr timestamprrrrzadd SCHEDULE_SETset SCHEDULE_METAr/r0)r&r>r?r@r$rJ game_entriesr7entry commitmentschedule_bytes chain_dataresulteigamestart_dtstart_tsgame_id game_metas r!create_schedulerhUs&djll##BQB'K ,x| $ $CL ##iLeeK((%%33~u55     E""""#==??#)r J 4 4 4'//1188AAN >1J0X|TTTTTTTTF~ D&. D%+^ "IIIJJJJBFLBBCCC 4 4 4 2q22 3 3 3 3 3 3 3 3 4\**MM4 '-do>>H))++HH ' ' '}}HHH '!&&1&&&|/!/ -!)    ,((;<<<M4744dj6K6KLLLL 4{44j6H6H6J6JKKK s+,B E99 FFF7-G%%HHc Ktjtj}g}|t d|}|D]}t|tr| n|}| t|}|s| t |jtjt|tr|n| }| ddkr| t | ||d| dd| dd d {V} d |d<| |d <tjtj|d <|t|tj||t(|| t |||t-d|d| | drm tj|d} | } |dtj|| d| in#t2$rYnwxYwq#t2$r} t-d|d| d|d<t| |d<|t|tj|| t |Yd } ~ d } ~ wwxYw|S)at Check for games that should start now and deploy them. Called periodically (every 30s) by a background task. Args: redis_client: Redis connection deploy_fn: async fn(markets, contract_size, higher_first) -> instance_id Should call the /terminal/auto/deploy API endpoint Returns: List of deployed game IDs -infrGrErrrrF)rrrNrunning instance_id deployed_atu✓ Scheduled game z deployed as instance #rluckyst:schedule:stops)rfrlu⚠️ Failed to deploy game : failedrR)rrJrrKrV zrangebyscorerX isinstancebytesdecoder:rZzremr/r9rrMrYr0saddSCHEDULE_ACTIVErLrQrUrWrS) r> deploy_fnrJdeployed due_games game_id_rawrfmeta_rawmetarlstop_dtstop_tsras r! check_and_deploy_scheduled_gamesrs" ,x| $ $ . . 0 0CH**<EEI 4545 *4[%*H*HY+$$&&&k ##}$?g$?$?@@    lG 4 4 4 zj3&?&?V((X__EVEVWW 88H   * *   lG 4 4 4 $ 5 ) Y"hh::!XXne<<!!!K'DN"-D "*,x|"<"<"F"F"H"HD     8w88$*T:J:J K K K   ow 7 7 7   lG 4 4 4 OOG $ $ $ UUU UU V V Vxx $$ &4T+5FGGG%//11G %%&> w{#S#STTV]A!D 5 5 5 @'@@Q@@ A A A%DNFFDM    8w88$*T:J:J K K K   lG 4 4 4 4 4 4 4 4  5 Os?0D%KAJ21K2 J?<K>J??K MA8M  Mc Ktjtj}|dd|}|D]}t jt|tr|n| }|d}|d} ||d{Vtd|d|n,#t$r}td|d |Yd}~nd}~wwxYw| d||t|} | rt jt| tr| n| } d | d <tjtj| d <|t|t j| |t(||t,|dS) z Check for games that should stop now and send stop commands. Args: redis_client: Redis connection stop_fn: async fn(instance_id) -> None rnrjrfrlNu✓ Scheduled stop for game z , instance #u⚠️ Failed to stop game ro completedrG stopped_at)rrJrrKrVrqr/r9rrrrtrQrSrur:rZrMrYr0sremrwrv SCHEDULE_DONE) r>stop_fnrJ due_stops entry_rawr\rfrlrar|r}s r!check_and_stop_scheduled_gamesrs# ,x| $ $ . . 0 0C**+CVSQQI66  9c(B(BZ99 HXHXHZHZ[[ "M*  @'+&& & & & & & & & SSSkSS T T T T @ @ @ >>>1>> ? ? ? ? ? ? ? ? @ 2I>>> ##}$?g$?$?@@  6:*Xs*C*CZhhIZIZ[[D(DN!)hl!;!;!E!E!G!GD     8w88$*T:J:J K K K   ow 7 7 7   mW 5 5 5+66s&C C-C((C-c|tddd}g}|D]\}}t|tr|n|}|t |}|rWtjt|tr|n|}||d<| ||S)z!List all pending scheduled games.rT) withscoresscheduled_start_ts) zrangerXrrrsrtr:rZr/r9rrL)r>game_idsresultsr{scorerfr|r}s r!list_pending_gamesr*s""<B4"HHHG&!! U*4[%*H*HY+$$&&&k##}$?g$?$?@@  !:*Xs*C*CZhhIZIZ[[D).D% & NN4 Nr c ~|t}g}|D]}t|tr|n|}|t |}|rP|tj t|tr|n||S)z+List all currently running scheduled games.) smembersrwrrrsrtr:rZrLr/r9r)r>rrr{rfr|s r!list_active_gamesr8s$$_55HGee *4[%*H*HY+$$&&&k##}$?g$?$?@@  e NN4:*Xs2K2K&bhhQYQ`Q`QbQbcc d d d Nr )NN)#rosr/rHasyncio dataclassesrrrrrrtypingr redisagentic.syndicate.chain_writerr r r r rXrZrwrrr#rdictRedisrrhrrrrrr r!rsZ   00000000002222222222 * ( +'             >#'" TT :T+T3-Tsm T  TTTTvM+M #YMMMM`#6+#6#6#6#6T U[ T$Z     EK DJ      r