o ̿Si" @sdZddlmZmZmZmZmZddlmZm Z m Z m Z ddl Z ddl Z ddlmZmZddlZddlZddlmZddlmZddlmZmZmZmZdd lmZdd lmZdd lm Z dd l!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'm(Z(ddlm)Z)e)edddZ*dde edefddZ+de,de-de-de.e-e-ffddZ/ddde,de edee,e ffddZ0dd l1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8eZ9e :e;Zd$e,d'e,ddfd(d)Z?d$e,d*e,d+e-de@fd,d-ZAd$e,d*e,ddfd.d/ZBd0ee,e fd1e,dee,e ffd2d3ZCd4e e,d5ee,e fde e,fd6d7ZDe9jEd8d9d:edd;d<eejFeefd1e,d=e e,fd>d?ZGe9jHd@dAd:eddBd<edCdDd<eejFeefdEe e,dFe@fdGdHZIe9jEdIdJd:edKdLd<eejFeefdMe,fdNdOZJe9jHdPdQd:eidReejFeefd1e,dSee,e ffdTdUZKe9jEdVdWd:edXdYd<eejFeefdZe-fd[d\ZLe9jEd]d^d:edXd_d<edd`d<eddad<eejFeefdZe-d1e e,dbe e,fdcddZMe9jHdedfd:edKeejFeefd1e,dSee,e ffdgdhZNe9jHdidjd:edKeejFeefd1e,dSee,e ffdkdlZOe9jEdmdnd:edKdod<eejFeefdMe,fdpdqZPe9jEdrdsd:edtdud<eddvd<eejFeefd1e,dZe-dwe e,fdxdyZQe9jHdzd{d:edKeejFeefdSee,e ffd|d}ZRe9jEd~dd:edtdd<eddd<eejFeefdZe-de e,fddZSe9jEddd:eddd<eddd<eejFeefde,dZe-fddZTe9jEddd:ee-e Uddpdddddee-e Uddpdddddee-e Uddpdddddee-e Uddpdddddeddd<eejFeefde-de-de-de-de e,f ddZVe9jEddd:eejFeefddZWe9jHddd:edKeejFeefde,dSee,e ffddZXdS)zfAnalysis + chat + orders + misc endpoints for platform teGPT. NOTE: Move-only split from `teGPT.py`. ) APIRouterDepends HTTPExceptionBodyQuery)DictAnyListOptionalN)datetime timedeltadatabase)get_current_userdetails)chat_with_stock_serviceget_user_signals_serviceget_zerodha_client_serviceplace_order_service)get_stock_history)build_early_movers_snapshot)normalize_confidence) ist_date_str)backend_market_window format_windowis_backend_market_hourslocal_time_strmarket_tz_name)timezone)hoursminutesnow_utcreturncCsB|pt}z |jtjdtWSty tjtdYSw)N)tzinfo)tz) r utcnowreplacerutc astimezone_IST Exceptionnow)r"r,r-D/var/www/html/Trade-python/app/v1/routers/platform/teGPT_analysis.py_ist_now,s  r/v default_h default_mcCszR|pd}|r d|vr||fWS|dd\}}t|}t|}d|kr,dkrDnnd|kr8dkrNnn||fWSW||fSW||fSW||fSW||fSty^Y||fSw)N:r;)stripsplitintr+)r0r1r2shhmmhmr-r-r. _parse_hhmm4s*   0  r@)r" today_istc Csptdd}t|ddd\}}t|}|j|jf||fk}t|p"|}|r'|n|}|||||dd|ddS) z}Return preferred early movers snapshot date key. Rule: after 20:00 IST, prefer next trading day; else prefer today. (EARLY_MOVERS_DEFAULT_NEXT_DAY_AFTER_HHMMz20:00r)r1r202dr4) preferredrA tomorrow_ist after_cutoff cutoff_hhmm)osgetenvr@r/hourminute_next_trading_day_key) rAr" cutoff_rawchcmnow_istrGrFrEr-r-r._default_early_movers_date_keyCs   rRr5)_confidence_score_extract_analysis_fields_format_analysis_for_stream_row_get_latest_snapshot_by_symbol_get_symbols_from_live_movers_normalize_mover_param _what_changeddate_keycCslz tt|}Wn tyYdSw|tdd}|dkr2|tdd}|dks%|S)Nr5)daysr) r fromisoformatstrr8dater+r weekday isoformat)rZbasedr-r-r.rMes   rMkeycCs8|dd|i}|s dS|d}|durdSt|S)N system_metarcvalue)find_onegetr])dbrcdocr0r-r-r._get_system_meta_valueps  rjrecCs,|djd|id||tdidddS)Nrdrc$set)rcre updated_atTupsert) update_oner r&)rhrcrer-r-r._set_system_meta_valuexs  rpowner ttl_secondsc Cst}|ttdt|d}z|d||||dWdStyL}z!t|}t|dd}|dkp>d|vp>d | v} | sBWYd}~nd}~ww|dj |d d |iid d d iid|igdd|||did d} | j dkS)Nr)secondsrd)rcrq expires_atrlTcodei*E11000z duplicate keyrtz$ltz$existsFrq)rcz$orrk)rqrtrlrmr5) r r&r maxr: insert_oner+r]getattrlowerromodified_count) rhrcrqrrr,expiresemsgruis_dupresr-r-r._acquire_meta_locks2      rcCsRz|d||ddttdiWdSty(tjdddYdSw)Nrdrcrqrk)rtrlz)Early movers manual: error releasing lockT)exc_info)ror r&r+loggerdebug)rhrcrqr-r-r._release_meta_locks rsnapshotsymbolcCs|pd}t|dtr|dni}t|dtr$|dng}t|dtr3|dng}t|D]#\}}t|tr\|dpHd|kr\d|d|t|dSq9t|D]#\}}t|tr|dppd|krd |d|t|dSqadddddS) Nr3topbullishbearishrBULLISHr5)biasrankentry total_in_biasBEARISH)r8upper isinstancergdictlist enumeratelen)rrsymrrridxitr-r-r._find_early_mover_entrys$$rralgoc Cs:g}|pd}|d}|d}|d}|d}|d}|d} |dkrJ|d |dur=|d ||durI|d |n!|d krk|d |dur_|d||durk|d||durw|d||dur|d||dur|d|| dur|d| |S)Nr3 key_leveldistance_to_level_pct atr_ratio vol_ratiorelative_strength_5dsma20_dist_pctrz#Setup: bullish early breakout watchzKey resistance level: zDistance to resistance (%): rz$Setup: bearish early breakdown watchzKey support level: zDistance to support (%): z$Volatility contraction (ATR ratio): z%Volume condition (vol ratio vs 20D): z!Relative strength vs index (5D): zSMA20 proximity (%): )r8rrgappend) rroutbrdistrrrs5dsma20dr-r-r._early_mover_algo_explanations<        rz/early-movers/study/{symbol}z$DB-only: Early Mover Advantage study)summaryzGOptional snapshot date (YYYY-MM-DD). Defaults to today IST else latest.) description snapshot_datec s|pd}|stddd|tdd}d}|r.t|r.|dt|i}|sDt}|d|i}|sD|jid gd }t|t sOtd d dt ||}t| d t ra| d ni} | d} | d} | d| d| d| d| d| d| d| dd} t| dt r| dnd} t| dt r| dng}|d|dddddd pi}| d!}|rt |t|pdd"ng}t|t sg}| ddurt|rtzd#tttfd$tfd%d&}td'd(|D|d)}g}|D]!}zt| d*}|dkr||Wqty"Yqwt| d+t r1| d+ni}t| d,ttfrEt| d,nd}|durht|d-krh|d.|d/d0d1}t||d2| d<Wn tysYnwid3|d4| dd5| d6d+| d+d7| d7d| d8| d9| d9d:| r| d:ndd;| r| d;ndd<| d| d=t| dt r| dndd|d>t| | d?d@dA|iS)BzReturn the early-movers snapshot entry + daily candles for a symbol. IMPORTANT: DB-only. Must not call Zerodha/ET/GPT. Weekly/monthly candles are derived by the frontend from daily candles. r3symbol is required status_codedetail EARLY_MOVERS_SNAPSHOT_COLLECTIONearly_movers_snapshotsNr^r^sortz&No early movers snapshot available yetrrrrratr10rrrrmarket_context)rrrrrrrrgpt risk_flagsstocksNSE)rexchangerr5)_idstock_idrrdayxr#cSs"|d}|rt|ddSdS)Nr^ r3)rgr])rrbr-r-r._dks zearly_mover_study.._dkcSsg|] }t|tr|qSr-)rr).0cr-r-r. "sz%early_mover_study..rcclosemarketnifty_5d_returnri?Y@rrsnapshot_generated_at generated_atuniverse rank_in_biasr algo_score final_scorer snapshot_gptalgo_explanation)rrcandlesdaily)r8rrrIrJr]rfrrrrrgrrrrsortedfloatrr+r:rroundr)rrrh current_userrcollsnapist_datefoundrrrrrr stock_docrrr daily_sortedclosesrclmktnifty_5dstock_5dr-r-r.early_mover_studys        "     (           rz/early-movers/runz#Run early movers snapshot on demandzrIST date to build snapshot for (YYYY-MM-DD). If omitted, uses next trading day from latest stock-history EOD meta.Fz6If true, allow re-run even if snapshot already exists. target_dateforcecsttdddv}td|r|pdndt|t|ttt |sDt rDt }t ddt |d t d td |td d }tdd}ttdd}dt} tdd} |ro|pldnd} | stdd} t|| } | st dd| d t| } | st ddd |s|d| iddirddd| dSt||| |d st dd!d tt}|d"d#t| t|t|trt|d$d?d%d&d'dnd| |t|d(d)}z|| jd|id*|idd+Wntyt||| d,t d-d.d wd/td0td1td2td3td4td5tfd6d7}ztj||| t|| |t|| d8dd9}| Wn*ty_t||| d,|| d|id*d:ttd;d<it d-d=d wdd|| d>S)@zjManual trigger (for an admin button). NOTE: This may call GPT if `EARLY_MOVERS_GPT_MODE=rerank`. -EARLY_MOVERS_MANUAL_ALLOW_DURING_MARKET_HOURS0)1trueyesz`Early movers manual run requested | target_date=%s force=%s allow_during_mkt=%s now=%s in_mkt=%sr3Niz9Manual Early Movers run is disabled during market hours ( z). Now: rrrEARLY_MOVERS_LOCK_META_KEYearly_movers_snapshot_lockEARLY_MOVERS_LOCK_TTL_SECONDS1800z manual:pid=EARLY_MOVERS_JOBS_COLLECTION system_jobsSTOCK_HISTORY_LAST_EOD_META_KEY"stock_history_refresh_last_eod_runzMissing system_meta.rzCould not compute target_dater^rr5Tsnapshot_existsokskippedreasonr^)rcrqrrz Early movers is busy (lock held)early_movers_runqueuedrgcSdSNr-krbr-r-r.z"run_early_movers..email)rqlock_keylock_ttl)rtypestatus created_atrr requested_bymetarkrmrFailed to create job recordjob_idtdrrqr r  jobs_collcSsd}zFzddlm}ddlm} |\}} | |d|iddttdi| t dd } |s| d |idd ir| |d|idd ttd d d|ddiWWz|durmddlm}t | ||dWn t ywYnwz|dur| WdSWdSt yYdSw| | } | stdt} t| | |d}t| }| |d|iddttt||diWnGt y}z:z)|durddlm}|\}} | |d|iddttt|diWn t yYnwWYd}~nd}~wwWz|dur#ddlm}t | ||dWn t y.Ynwz|dur<| WdSWdSt yIYdSwz|dur]ddlm}t | ||dWn t yhYnwz |duru| WwWwt yYww)Nrr )_get_global_zerodha_clientrrkrunningr  started_atrlrrr^r5rTrr)r  finished_atrlresultrz!Global Zerodha client unavailable)rhzerodha_clientrr)r rrlduration_secondsrerrorr rrlr)app.dbr!app.v1.background.global_intradayrcreate_mongo_client_and_dbror r&rIrJrfrr+r RuntimeErrorr total_secondsrr])rrrrqr r rclient_dbmodrjob_dbsnapshot_coll2zt0rdt_sr}r-r-r._run_job_in_backgrounds     (              z0run_early_movers.._run_job_in_background)rrrrqr r rtargetkwargsdaemonr!Failed to start background threadrFailed to start background job)renqueuedrr^r)!r]rIrJr8rzrinfoboolrrrrrrr:getpidrjrMrfruuiduuid4r r&rrryror+r threadingThreadstart)rrrhr allow_duringw snapshot_collr r rqjobs_coll_namereod_keylast_eodrjob_docr+tr-r-r.run_early_moversIs           &P    rCz/early-movers/run/statusz,Get status of an early movers manual run job.z)Job id returned by POST /early-movers/runrcsvtdd}||dt|idddddddddddd }|s'tddd|d p-d d kr6tdddd |d S)Nrrrr5) rr r r rrrrrrrr Job not foundrr r3rTrjob)rIrJrfr]rrg)rrhrr>rir-r-r.early_movers_run_statuss 0   rGz/analyze/{symbol}z#Analyze single symbol using ChatGPT)defaultpayloadc stzt||}|stddd|dpi}t|tr|d|p#d|d}t|tr;|d| t |dpE|d |d |d d |d<|d }|d }t|tr|ri} t|trs|rs| |t| dtr| dst|dtr|d| d<| ddur|ddur|d| d<| d} |d} t| tr| ri} t| tr| | | D]\} }| | vst| | t rt| | s|| | <q| | d<nt| tr| s| dur| | d<| ddur |ddur |d| d<| |d <d||dWStyty9}ztd|tdt|dd}~ww)zDB-only analysis endpoint used by Stream UI. IMPORTANT: This endpoint must NOT call Zerodha or GPT. It returns the latest persisted analysis snapshot from `stock_analysis_snapshots` for the requested symbol. rz"No analysis snapshot available yetranalysisrr3 timestamp confidenceconfidence_leveldecision_probabilityscore)rNrO market_dataquoteinstrument_tokenNrsuccess)r rrJz+Failed to fetch DB analysis snapshot for %sr)rVrrgrr setdefaultr8rr r`rupdateitemsrrr+r exceptionr])rrIrhrrrJtsmd_snap md_analysismerged c_analysisc_snap out_candlestfrowsr}r-r-r.analyze_symbolsh             &   raz/alerts-legacyz*Get user-specific alerts (legacy, DB-only)rCzMax items per sectionlimitc sfzt|d}t|d|ddddi}dd|D}|s0d ggggd td WSt|d dd |iidddd}dd|Dt|ddd |iidddd}dd|D}fdd|D} i} | rd|vr|d|d | iddg} | D]} | dpd } | r| | vr| | | <qg}g}g}g}|D]}|}|sq|dpd }|sqt|dd|idg d}|sqt |||d}t |dkrt |||dnd}t |||d<||pi}|d |d <|d!|d!<| |}|r4|d"pd }|d#vr)||q|d$vr4||q|d%p;d& }t|d'pHd}|d(vrZ|dkrZ||q||qd)tttffd*d+}||||fD] }|j|d,qqd |d||d||d||d|d td WSty}z td-td.t|d/d}~ww)0zDB-only alerts endpoint. Builds user-specific opportunities from: - `user_likes` (is_active=True) - latest `stock_analysis_snapshots` - optional `orders` for Triggered/Closed bucketing IMPORTANT: Must NOT call Zerodha or GPT. r user_likesT)user_id is_activerr5cS g|] }|dr|dqSrrg)rrbr-r-r.ru z#get_user_alerts..r) top_signals monitoring triggeredclosed)r datarKr$in)rrrRcS"i|] }|dr|d|qSrgrhrr;r-r-r. "z#get_user_alerts.. live_movers)rr mover_typecSrprgrhrrr-r-r.rrrscs4g|]}|p idr|pidqS)rrh)rsid by_stock_idr-r.rs orders)rdrr rrr3stock_analysis_snapshotsrKrrN what_changedrrur )PLACEDOPEN TRIGGERED)COMPLETECLOSED CANCELLEDREJECTEDdecisionHOLDrLBUYSELLrowcSsL|d}t|trt|nd}t|dpd}|dpd}| ||fS)Nri'rLr3rK)rgrr:rS)rrrank_valconf_valrXr-r-r.sort_keys  z!get_user_alerts..sort_keyrzFailed to build alertsrr)r]rgrfindr r&list_collection_namesrr8rrbrTrrYrrSrrr+rrWr) rbrhrrdlikes stock_idsr live_rowslive_by_stock_idsymbolslatest_order_by_symbolcurorrjrkrlrmrxstockrsnapscurrprevliveorderr rconfrarrr}r-ryr.get_user_alertsbs     $             rz/signalsz"Get user's latest signals/analysiszMaximum number of signalszFilter by symbolz#Filter by decision: BUY, SELL, HOLDrc s^zt|t|d|||d}d|dWSty.}z tdtdt|dd}~ww) z7Get user's latest trading signals from ChatGPT analysisr)rhrdrbrrrS)r signalszFailed to get signalsrrN)rr]rgr+rrWr)rbrrrhrrr}r-r-r. get_signalss    rz/chat/{symbol}z(Interactive chat about a specific symbolc sz&t||}t||||ddt|d|d|ddd}d|d WStyC}ztd |td t|d d }~ww)z Interactive chat about a symbol with real-time market data Payload: { "message": "What's the RSI looking like?", "include_fresh_data": true, "conversation_id": "optional-uuid" } messager3rconversation_idinclude_fresh_dataTrhrrrrdrrrS)r responsezChat failed for symbol rrN)rrrgr]r+rrWr)rrIrhrrrr}r-r-r.chat_with_symbols$     rz/chat/{symbol}/enqueuez Enqueue interactive chat (async)cst|tr t|dnd}|stddd|pd}|dp%d}|s0tddd|s8tdd dtd td d }tt }|d pRtt } t |dd} |ddt t ||| || t|trzt|dd*ddddndd } z||jd|id| iddWn tytdddwdtdtdtdtd td tdt fd!d"} ztj| |||||| | d#dd$} | Wn"ty||d|idd%t t d&d'itdd(dwdd|| |d)S)+zNon-blocking chat. Returns immediately with a job_id; the frontend should poll the status endpoint. Payload: { "message": "...", "include_fresh_data": true, "conversation_id": "optional-uuid" } rr3 Unauthorizedrrrrzmessage is requiredCHAT_JOBS_COLLECTIONrrrrTchat_runrrgNcSrrr-rr-r-r.r>rz*chat_with_symbol_enqueue..r) rr r r rlrdrrrrrrkrmrrrrrdrr~cSsd}zz^ddlm}|\}} | |d|iddttdid|i} d} |r1t| | } t} t| | |||||d} t| }| |d|iddttt || d iWnEt y}z9z)|durzddlm}|\}} | |d|idd ttt |d iWn t yYnwWYd}~nd}~wwWz|dur| WdSWdSt yYdSwz |dur| WwWwt yYww) Nrr rrkrrrr)r rrlrrrr) rrr!ror r&rrr#rr+r]r)rrrdrr~rrr$r%r&current_user_stubrr)rr*r}r-r-r._run_chat_job_in_backgroundHs           z=chat_with_symbol_enqueue.._run_chat_job_in_background)rrrdrr~rrr,rr0rr1)rr2rrrr)rrr]rgrr8rrIrJr6r7r4r r&ryror+r8r9r:)rrIrhrrdrr~r>rrrrArrBr-r-r.chat_with_symbol_enqueuesp       &C   rz/chat/enqueue/statuszGet status of an async chat jobz.Job id returned by POST /chat/{symbol}/enqueuecst|tr t|dnd}|stdddtdtdd}||t|d |d d d d d d d d d d d d d }|sCtd ddd|dS)Nrr3rrrrrrr)rr rdr5) rr r r rrrrrrrrrDTrE)rrr]rgrrIrJrf)rrhrrdr>rir-r-r.chat_job_statuss   rz/chat/{symbol}/historyzGet chat history for a symbol2zMaximum messageszOptional conversation idrc sz8t|d}||ddid}|r||d<t|d|dd|}|D] }t|d|d<q)d |d WStyU} ztd |t d t| d d} ~ ww)z&Get chat history for a specific symbolrz$neT)rdris_context_snapshotrchatsr rrS)r historyzFailed to get chat history for rrN r]rgrrrrbr+rrWr) rrbrrhrrdqrchatr}r-r-r.get_chat_historys   rz /order/placez%Place order based on ChatGPT analysiscsz5t||}t||t|d|d|d|d|dd|d|d|d d d }d |d WSty>tyV}z tdtdt|dd}~ww)aq Place trading order with ChatGPT risk validation Payload: { "symbol": "RELIANCE", "action": "BUY" | "SELL", "quantity": 10, "order_type": "MARKET" | "LIMIT", "price": 2500.0, // Required for LIMIT orders "analysis_id": "optional-analysis-reference", "confirm": true // Required for execution } rractionquantity order_typeMARKETprice analysis_idconfirmF) rhrrdrrrrrr confirmedrS)r rzOrder placement failedrrN)rrr]rgrr+rrW)rIrhrrrr}r-r-r.place_trading_orders.      rz/ordersGet user's order historyzMaximum orderszFilter by statusr c sz4t|d}d|i}|r||d<t|d|dd|}|D] }t|d|d<q%d|dWStyN}z td t d t|d d }~ww) rrrdr r{r rrS)r r{zFailed to get ordersrrNr) rbr rhrrdqueryr{rr}r-r-r. get_orderss   rz/livez(Legacy compatibility - get live analysisgainerszgainers or losersrzNumber of symbols to analyzemoverc&szdtdttfdddttttfdttttfdttffdd }d td ttttfd ttd ttd ttdttf fdd }d td ttttfd ttdttffdd }t|}|dkrt|dddiddddd ddg |}t|dddiddddd ddg |} || d|} n!i} |dvr|| d<t|d| ddddd ddg |} dd| pgD} | sd dgd!WSt|d"d#d$| iiddddd%} d&d'| D}i}|d(d#d$| ii d)d*g}|D]}| d#}|r||vr|||<qg}| D]}| d#}|s-q | |}|s7q | d+p>i}t |t sGq | |pNi}| d,pVd-}| d.}t |t rk| dnd}d}t | dt r| dpi d}|durt |t r| d}d}t | dt r| d}nt |t r|}|||}| d/}g}t |trLJfd0d|D}t | d t r| d nd}| d1} | d }!| dur| n|!}"|t| d d2||"d3}"|t| d d2|| d p| d4|"p| d5|d6}| d }#d}$t |#ttfr5|#r5|#d}$|id,| d,pC|pCd-d7t|dd8| d8pWd-d | d d2d9| d9d:d.| d.durt| d.n|d;|d |d<| d<d=| d=d1|"d/|d>| d>d | d d5| d5d?| d?d@| d@| d4| d d2| d9d:dAdAdAdBdBdBd-dBdC | dDg| dEi| dFi| d |$dG| dHdIq d t| |d!WSty}%z tdJtdKt|%dLd}%~%ww)MzDB-only legacy endpoint. IMPORTANT: Must NOT call Zerodha or GPT. Uses latest `stock_analysis_snapshots` for symbols in `live_movers`. r0r#cSsdz'|durWdSt|trWdSt|}||ks"|tdtdfvr%WdS|WSty1YdSw)Ninf-inf)rr4rr+)r0fr-r-r. _safe_float's  z&get_live_analysis.._safe_floatrQrPcs>t|trk|rk|dp|dp|dp|dp|d}|}|dur*|S|dp4|d}|dp=id }|durR|rR|d krR||d S|d }|durk|rk|d krk|||d St|trr|stdS|d }t|tr|sdSdD]?}||} t| trt| dkrq| dpid } | dpid } | dus| dus| d krq| | | d SzO|d} t| trt| dkr| d pid} | dpid } | dur | dur| d kr| | | d WSWdSWdSWdSWdSWdStyYdSw)Nnet_change_percentagepercentage_changepercent_changepchangepChange net_changechangeohlcrrr last_pricer)rDAY1day15minute15min5minuterrropen)rrrgrrr+)rQrPdirectrnetrlastrr_series last_close prev_closes5 first_openrr-r._compute_change_pct4sl     z.get_live_analysis.._compute_change_pctr entry_zone entry_pricesltargetscsfdd|D}d}t|tr>|dp|d}|dp&|d}|dur>|dur>|dkr>|dkr>||d}|durD|n|} | } |}|pQd } | dusb|dusb| d vrh|dd S| d krp| |n|| } | dus|| dkr|dd St|dkr| d kr| | n| | } | d kr| d | n| d | } t| d t| d gSt|d krt|d} | d krt| | | d | } n t | | | d | } | tt| d |dd S)Nc g|] }|durt|qSrr)rrBrr-r.rnrizBget_live_analysis.._ensure_two_targets..lowrzhighrrg@r3rrrr5) rrrgr8rrrrrwminr)rrrrrrzone_midlohi entry_refrbriskt1t2rr-r._ensure_two_targetsfs6          z.get_live_analysis.._ensure_two_targetsc s"|}|dus t|ts|S|dp|d}|dp%|d}|dus7|dus7|dks7|dkr9|S|p._ensure_sl_sideBOTHrtruGAINERrr5)rrrrurr5 last_updatedrLOSERN)rrcSrfrgrhrvr-r-r.rriz%get_live_analysis..rS)r scannedresultsrrro)rrrrRcSrprgrhrqr-r-r.rrrsz%get_live_analysis..r}r~rrrJrr3rR exec_targetscrrrrrrr-r.r riexec_slr)rrr current_price stop_loss)rrrrrr trend_labelrLLOW change_pctentry_trigger_reason signal_state exec_rr_ratio price_targetrisk_reward_ratioF) rrL volume_drop momentum_dropema_gaprsi_divergencemacd_divergencewedge pivot_levelnear_upper_circuit rationalefeaturestechnical_indicators)rexitrK)r metricsr r!r"rrKzLegacy live analysis failedrr)rr rrr]r rXrrrrbrgrrr8rtuplerrr+rrWr)&rrbrhrrrrrurlosersrrrr stock_by_id latest_by_idrrrxformatted_resultsrrrfallback_symbolfallback_tokenmdrQ md_for_changerraw_exec_targetsr rsl_exec sl_fallbackr raw_targets exit_targetr}r-rr.get_live_analysissh 6 2,"                                    0 r3z/streamz(DB-only: stream (single call, multi-tab)STREAM_FRESHNESS_MINUTESr<z4Used only for reporting freshness stats (no compute))gelerSTREAM_MOVERS_LIMIT20rz'Max ET movers per side (gainers/losers)STREAM_EARLY_MOVERS_LIMIT40z+Max early movers (bullish+bearish combined)STREAM_WATCHLIST_LIMIT50zMax personal watchlist symbolszEarly movers snapshot date to show: 'today', 'tomorrow', or YYYY-MM-DD. If omitted, after 20:00 IST prefers next trading day (fallback to today).freshness_minutes movers_limitearly_movers_limitwatchlist_limitearly_movers_datec7s zt|d}t}ttt|d} t|d||ddddd d d g t|} d d | D} |t d d} t |d} d}|pLd}|r|}|dkr^| d}n!|dkrg| d}nz t|d|}Wn ty~tdddw|p| d}| d|i}|s|| dkr| d| di}|s| jidgd}g}d}it|trPt|dtr|dni}t|dtr|dng}t|d tr|d ng}t|d!tr|d!ng}g}|s|r|D] }t|tr||q|D]}t|tr||qn|D]}t|tr'||qd}|D]}t|ts7q-|d"p>d}|sHq-||vrOq-|||d#p[dpbd}|d$pjdpqd}|s|r|d%krd&}n|d'krd(}||t|d)p|d*pdt|d+p|d,p|d)p|d*pd-t|d.p|d/p|d0pd|d1|<|d7}q-|dkr|dt|}|d}d} |r|| dkr| d} n|r|| dkr| d} d2}!| r%zt| d| iddi}!Wn ty$d2}!Ynw||| d| dt| d3| d4| t|!|d5|d6|d7|d8|d9d: }gg}"|dkrt|d;d d?d@g t|t|d;d d?d@g t|}"dBttttfdCttfdDdEfdFd |"D}#ttg| |}$i|$rt|dGd"dH|$iidddddddI}%|%D]}&|&d"pd}|r|&|<qi|#rt|dGdJdH|#iidddddddI}%|%D]}&|&dJ}'|'r|&|'<qg}(|$D]}|p%idJ}'|'r6|'|(vr6|(|'q|#D]}'|'rI|'|(vrI|(|'q:i|(rw|dKdJdH|(ii dLdMg})|)D]}*|*dJ}'|'ru|'vru|*|'<qbdNtdOtdPtdCttttfffdQdR }+dStdOtdPtdCttttfffdTdU },g}-d}.g}/d}0|D]E}|+|dV|0dW}1|1sq|/|1z"|1dX}2t|2tr|2rt|2 dYdZ}3|3| kr|.d7}.Wn tyYnw|0d7}0qd[tttfdCtfd\d]}4|/j |4d^d_t!|/dd`D] \}5}1|5|1dP<q|-"|/d}0D]"}|dJ}'|'s-q!|,|'da|0db}1|1s9q!|-|1|0d7}0q!d}0|"D]"}|dJ}'|'sTqH|,|'dc|0db}1|1s`qH|-|1|0d7}0qHd}0| D]}|+|dd|0dW}1|1s}qo|-|1|0d7}0qode|-dft#|idft#idft#|"idft#| idg|t|.d||tdh WSty}6z t$%ditdjt|6dd}6~6ww)kzSingle-call DB-only stream endpoint. Returns 4 tabs worth of data in ONE response: - Early Movers - ET Gainers - ET Losers - Personal Watchlist IMPORTANT: Must NOT call Zerodha, NSE, ET scraping, or GPT. r)r!user_portfolio_itemsACTIVE)rdrr rr5)rr)rlrr|cSs4g|]}|dp dr|dpdqS)rr3)rgr8r)rrr-r-r.rs4z'get_combined_stream..rr)rANr3todayrAtomorrowrFz%Y-%m-%drz=Invalid early_movers_date; expected today|tomorrow|YYYY-MM-DDrrEr^rrrrrcombinedrrstrategyrBREAKOUTr BREAKDOWN overall_scoreroverall_score_floatfinal_score_floatrearly_mover_scorerrO)rrHrKrLrNrFrGrHrrrrr) r^requested_daterArFrGrHalternate_datealternate_existsrrrrrrtrur)rrrrrrr`r#cSs6g}|pgD]}|d}|r||vr||q|S)Nr)rgr)r`rrwrxr-r-r. _sid_lists    z&get_combined_stream.._sid_listcsg|] }|vr|qSr-r-r )rR gainers_rowsr-r.rsrro)rrrrrRnamerr}r~r rrrc s0|pi}|d}|r|nd}t|tr't|dtr'|dnd}t|tr;t|dtr;|dnd}|durL|dd|dd}n+t|}|d||ddurk|ddurk|d|d<|durw|d|t|||d }|d kr|pd } t| tr| |d <|S) NrrJrKrrrRrrrLrRrrr earlymoversr3 early_mover) rgrrr rTr`rUr8r) rrrrrxrrJts_dtrem)early_info_by_symbolr(stocks_by_symbolr-r._row_for_symbolRs. ((  z,get_combined_stream.._row_for_symbolrxcs|pi}|dp d}|sdS|}t|tr-t|dtr-|dnd}t|trAt|dtrA|dnd}|durR|dd|dd}n+t|}|d||ddurq|ddurq|d|d<|dur}|d|t|||d S) Nrr3rJrKrrrRrUrV) rgr8rrrr rTr`rU)rxrrrrrrJrY)r(mover_stocks_by_idr-r._row_for_stock_idps( (( z.get_combined_stream.._row_for_stock_idrW)rrrrKZz+00:00rcSsT|d}zt|}||ks|tdtdfvrWdSt|WSty)YdSw)NrrrgNgm)rgrabsr+)rr0rr-r-r. _abs_changes   z(get_combined_stream.._abs_changeT)rcreverse)r:r)rxrrr& portfoliorScount)rWrr&rd) r rtabsearly_movers_analysiscachedcomputedr>rrKzFailed to build combined streamr)&r]rgrr r&r r:rrrrbrIrJrRr8rzstrptimer+rrfrrrrrr4r rrfromkeysr r\r'rextendrrrW)7r>r?r@rArBrhrrdrcutoff manual_itemsportfolio_symbols early_collpref requested_keyraw_reqr preferred_keyem_snap early_symbols early_metarrrrGorderedrrnkrrrH used_datealt_date alt_exists losers_rowsmover_stock_ids all_symbolsdocsr;rxstock_ids_for_snapsrrr]r_rfresh early_rowsrwrrXdtrbir}r-)rRr[rSr(r^r\r.get_combined_stream[s,                        6*          "        .,                    rz/profilezGet Zerodha profile statusc sz+t||}z |}dd|dWWSty,}z ddddWYd}~WSd}~wwty[}z#|jd krEddd dWYd}~S|jd krVddd dWYd}~Sd}~wtyy}ztd ddt|dWYd}~Sd}~ww)z-Get Zerodha profile and authentication statusrT)r  authenticatedprofilerFzZerodha authentication required)r rrNrzZerodha settings not foundizZerodha not authenticatedzProfile check failed)rrr+rrrrWr])rhrrrr}r-r-r. get_profiles8     rz/stream/feedback/{analysis_id}zProvide feedback on analysisrc szg|d}|dvrtddd|dd|i}|s'|ddt|i}|s/tdd d|d }|s is_active=True - feedback="down" -> is_active=False We resolve `stock_id` by looking up the snapshot that contains `analysis.analysis_id == analysis_id`. feedback)updownrzfeedback must be 'up' or 'down'rr}zanalysis.analysis_idrzAnalysis snapshot not foundrzSnapshot missing stock_idrrrc)rdr)re last_feedbackrlr )rkz $setOnInsertTrmr)r rrrezFeedback update failedrN) rgrrfr]r r&ror+rrW) rrIrhrrrrrdr,rer}r-r-r.stream_feedbacksF        rr)Y__doc__fastapirrrrrtypingrrr r loggingrIr r r8r6rrapp.v1.dependencies.authrapp.v1.services.teGPTrrrrapp.v1.services.stock_historyrapp.v1.services.early_moversrapp.v1.utils.confidencer"app.v1.services.intraday_watchlistrapp.v1.utils.market_timerrrrrrr*r/r]r:r%r@rR teGPT_helpersrSrTrUrVrWrXrYrouter getLogger__name__rrMrjrpr4rrrrrg get_mongo_dbrpostrCrGrarrrrrrrrr3rJrrrr-r-r-r.s       "($  %& & #  f    4    Q  u                '       B    !