5iK dZddlZddlmZmZmZddlZddlm Z m Z ddl m Z ejdZded ed eeeeffd Zded ed eeeeffd Zd eeeefded efdZy)z Tier 2: Market / sportsbook sanity validation. Cross-checks internal player-team mappings against market data. Uses SGO API player props to confirm market presence. N)ListDictAny)normalize_player_namenormalize_team_abbrev) SourceTierz pub-integrityleaguerun_idreturnc|jtjj}|j d|f|j }|j g}|D]o}|j|d|dt|dxsdt|jddxsd|d|jddd tj|d qtjd t|d ||S) z Read rm_forecast_precomputed for PLAYER_PROP entries. These represent props that sportsbooks are actively offering. cursor_factorya SELECT event_id, player_name, league, team_id, status, created_at FROM rm_forecast_precomputed WHERE LOWER(league) = LOWER(%s) AND forecast_type = 'PLAYER_PROP' AND date_et = (NOW() AT TIME ZONE 'America/New_York')::date event_id player_nameteam_idstatusACTIVErm_forecast_precomputed) rrnormalized_nameteamr prop_type market_statussource source_tierr [market] Ingested z market props for )cursorpsycopg2extrasRealDictCursorexecutefetchallcloseappendrrgetr MARKETloginfolen)connr r currowsresultsrows M/var/www/html/rainmaker/backend/scripts/publishing_integrity/market_ingest.pyingest_market_propsr1s ++X__%C%C+ DCKK  <<>DIIKG  J}-4S5G5M2N)#'')R*@*FBG WWXx8/%,,    HH!#g,/A& JK Nc |jtjj}|j d|f|j }|j g}|D]}|jdxsi}|jdg}t|ts;|D]|} | jddxs| jdd} | s,|j|d| t| t|jd dxsd|d tj|d ~tj!d t#|d ||S)z Read player prop data from rm_events.prop_count and rm_team_props_cache. This tells us which players the sportsbooks are actively pricing. ra  SELECT event_id, team, team_name, team_short, league, props_data, created_at FROM rm_team_props_cache WHERE LOWER(league) = LOWER(%s) AND DATE(created_at AT TIME ZONE 'America/New_York') = (NOW() AT TIME ZONE 'America/New_York')::date props_dataplayers playerNamerplayerrrrm_team_props_cache)rrrrr rrr rz. market-confirmed players from team props for )rrr r!r"r#r$r& isinstancelistr%rrr r'r(r)r*) r+r r r,r-r.r/r4r5ppnames r0ingest_market_from_sgo_oddsr=8s4 ++X__%C%C+ DCKK   <<>DIIKGWW\*0b ..B/ gt $ lB/F15523FNN$' O',+@+G 5cggfb6I6OR P"("7'1'8'8"( $   $HH!#g,/]^d]e fg Nr2 market_propsrcTt|}|D]}|jd|k(syy)zBCheck if a player has an active market across any sportsbook data.rTF)rr&)r>rnormmps r0check_market_presencerB`s5  -D 66# $ , r2)__doc__loggingtypingrrrpsycopg2.extrasr normalizationrrenumsr getLoggerr(strr1r=boolrBr2r0rMs""Gg("c"3"4S#X;O"J%c%3%4SRUXCW%PT#s(^(<3SWr2