o jX"@s ddlZddlZddlZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl m Z mZmZddlmZddlmZddlZddlmZddlmZddlmZddlmZddlZdd lm Z!m"Z"m#Z#d Z$ej%d krvd Z&nd Z&edZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8ddddd d!d"d#d$d d%d&d'dd d(d)d*d+d d,d-d.d+d d/d0d1d2d d3d4d5d6d d7d8ddd d9d:d;dd?dd d@dAdBdd dCdDdEd2d dFdGdHdId dJdKdLdMd dNdOdPdQd dRdSdTdMd dUdVdWdXd dYdZd[d+d d\d]d^d_d d`dadbdcd dddedfd+d dgdhdfdid djdkdldmd dndodldMd dpdqdldmd gZ9dddrdd d!d"dsd$d d%d&dtdd d(d)dud+d d,d-dvd+d d/d0dwd2d d3d4dxd6d d7d8dydd d9d:d5ddzdd d@dAd{dd dCdDd|d2d dFdGd;dId dJdKd?dMd dNdOdHdQd dRdSdLdMd dUdVd}dXd dYdZd~d+d d\d]dTd_d d`dadWdcd ddded[d+d dgdhd^did djdkdbdmd dddbdMd dpdqdbdmd dddWdId dddfdd dddld2d dddld+d ddddd gZ:hdZ;dddddddZZ?ddhZ@eZAeAjBedgddgdgdeejCDdddZEiZFddZGddZHddZId]ddZJddZKddZLdeMdeNfddZOd^deMdePde=fddZQeLgdZRgdZSdeMdeTfddZUdeMdeMdeTfddZVe(fdePdeWfddZXdeTfddZYd_deMdeNfddZZd`dd„Z[ddĄZ\d_deMdeNfddDŽZ]d^deMdePde=fddʄZ^dadeMdePde=fdd΄Z_dddќZ`gdҢddggdբgd֢gdעddgdZadeMdeMfdd܄ZbdbdeMdePdeMfddZcdcdeMdeWdeNfddZdiZede=deNfddZfdeNdeNfddZgde=fddZhddZieiddZjddZkddZlddZmddZnddZoddZpddddZqdeddZrdfddZsddZteADdddZueADd deMfd d ZveADd d^deMdePfd dZweADddeMfddZxeADddeMfddZyeADdddZzeADdddZ{eADdddZ|eADddfdeTd eTfd!d"Z}eADd#d$d%Z~eADd&dgd'ePfd(d)ZeADd*d+d,ZeADd-dfdeTd eTfd.d/ZeADd0d1d2ZeADd3d4d5Zee'd6Zejeted7d8de'd9d:d;dd<ejeted7d=d>e'd9d?d@dd<ejeted7dAd>e'd9dBdCdd<ed8dDD]_ZdED]XZed8kred>krqedAkred>krqz/ejesed7eede'dFdGedHedHdIedHdJedHddKdLWqeyYqwqejesed7dDd>de'dFdMdNddOdLeedPe$edQedRedSedTedUdVdWZejeddXedYkrEddlZejeAdZd[d\dSdS(hN)datetime timedeltatimezone)FastAPI)CORSMiddleware)OpenAI)YouTubeTranscriptApi)BackgroundScheduler) CronTrigger)get_unique_stocks MIN_PRICE MAX_PRICEzv1.0.0ntpythonz%/home/dinkstrade/pdmp/venv/bin/pythonz Asia/Kolkataig?@g??g333333?g?Hzsentiment_history.dbz zones_15m.db HDFCBANK.NSz HDFC Bankgffffff"@Banks)symbolnameweightsector RELIANCE.NSRelianceg333333 @Energy ICICIBANK.NSz ICICI Bankg@zINFY.NSInfosysg333333@ITzTCS.NSTCSg@zITC.NSITCgffffff@FMCGzLT.NSzL&Tg @InfrazSBIN.NSSBIz BHARTIARTL.NSz Bharti Airtelg333333@Telecomz AXISBANK.NSz Axis Bankg@z KOTAKBANK.NSzKotak Mahindrag@z HINDUNILVR.NSHULg@z BAJFINANCE.NSz Bajaj Financeg333333@NBFCz MARUTI.NSz Maruti Suzukig@Autoz ASIANPAINT.NSz Asian Paintsg@PaintszM&M.NSzM&Mg?z SUNPHARMA.NSz Sun Pharmag333333?Pharmaz HCLTECH.NSzHCL Techg?zTITAN.NSTitan?Consumerz ULTRACEMCO.NSzUltraTech Cementgffffff?CementzWIPRO.NSWiprog?z ADANIENT.NSzAdani Enterprises ConglomeratezNTPC.NSNTPCg333333?Powerz BAJAJ-AUTO.NSz Bajaj Autoz POWERGRID.NSz Power Gridg+@g(@g"@g@g@g333333@g@g @gffffff @g @g@g@gffffff?z HEROMOTOCO.NSz Hero MotoCorpz BAJAJFINSV.NSz Bajaj Finservz INDUSINDBK.NSz IndusInd Bankz NESTLEIND.NSz Nestle IndiazTECHM.NSz Tech Mahindraz TATASTEEL.NSz Tata Steelg?Metals>rrrz"Nifty 50" stock market Indiaz4"Sensex" OR "BSE Sensex" -defence -bankex -auto -PSUz!"gold rate" OR "gold price" Indiaz%"silver rate" OR "silver price" Indiaz3"Crude Oil" OR "Crude price" OR "Brent crude" Indiaz"Bitcoin price" cryptocurrency)NIFTYSENSEXGOLDSILVERCRUDEOILBITCOINr6r7*T) allow_originsallow_credentials allow_methods allow_headers GROQ_API_KEYzhttps://api.groq.com/openai/v1)api_keybase_urlcCsVtt}|dkr dS|jddddd}|jddddd}||ko(|kSS)NF r)hourminutesecond microsecond)rnowISTweekdayreplace)rL market_open market_closerR/home/dinkstrade/pdmp/main.pyis_market_hours_nows  rTcCst}|dr|r dSdS|dr|rdSdS|dkr#|r!dSdS|dkr-|r+d SdS|d r8|r6d SdS|d krB|r@d SdS|rFd SdS) N option_chain_i constituents_rangeXi fii_dii_scorei sentiment_ latest_scani,)rT startswith)keyrPrRrRrS_auto_ttl_for_keys          r_cCs4|tvrt|\}}}t||kr|St|=dSN)CACHEtime)r^value timestampttlrRrRrS cache_gets rfcCs&|durt|}|t|ft|<dSr`)r_rbra)r^rc ttl_secondsrRrRrS cache_setsrhcCs|tvr t|dSdS)Nr)rar^rRrRrS cache_peeks rjcCsTtt}|}|dz|dWn tjyYnw||dS)Nac CREATE TABLE IF NOT EXISTS daily_sentiment ( date TEXT NOT NULL, symbol TEXT NOT NULL, score REAL NOT NULL, news_score REAL, twitter_score REAL, youtube_score REAL, fii_dii_score REAL, label TEXT, PRIMARY KEY (date, symbol) ) z9ALTER TABLE daily_sentiment ADD COLUMN fii_dii_score REAL)sqlite3connectSENTIMENT_DB_PATHcursorexecuteOperationalErrorcommitclose)connrnrRrRrSinit_sentiment_dbs    rtrresultcCsttd}z:tt}|}|d||| dd| dd| dd| dd| dd| d d f| | WdSt y_}zt d |d |WYd}~dSd}~ww) Nz%Y-%m-%dz INSERT OR REPLACE INTO daily_sentiment (date, symbol, score, news_score, twitter_score, youtube_score, fii_dii_score, label) VALUES (?, ?, ?, ?, ?, ?, ?, ?) scorer news_score twitter_score youtube_scorerZlabelNEUTRALzSentiment DB save error for : )rrLrMstrftimerkrlrmrnrogetrqrr Exceptionprint)rrutodayrsrnerRrRrSsave_to_historys(        "rdaysreturnc Csz#tt}|}|d||f|}|ddt|DWStyA}zt d|d|gWYd}~Sd}~ww)Nz SELECT date, score, label FROM daily_sentiment WHERE symbol = ? ORDER BY date DESC LIMIT ? cSs$g|]}|d|d|ddqS)rr)datervrzrR.0rrRrRrS s$zget_history..zSentiment DB read error for r|) rkrlrmrnrofetchallrrreversedrr)rrrsrnrowsrrRrRrS get_historys r)fallfallscrashcrashesplungeplungesdropdropsdeclinedeclinesslumpslumpsweaklosslossesdownbearishzsell-offsellofftumbletumblesslide)riserisessurgesurgesgaingainsjumpjumpsrallyrallieshighrecordstrongupbullishsoarsoarsclimbclimbsrecoverrecoverstextcsn|tfddtD}tfddtD}||}|dkr$dS|||d}ttdtd|dS) Nc3|]}|VqdSr`countrw text_lowerrRrS 2z keyword_score..c3rr`rrrrRrSr3rr ir)lowersum BULLISH_WORDS BEARISH_WORDSroundmaxmin)rbullbeartotalrvrRrrS keyword_score0sr text_blockc Cs tjdr |st|Sd|d|ddd}zHtjjjdddd d d d dd d d d d d|d gddddid}|j dj j }t d|}|r_ttdtdt|dWSt|WSty}ztd|d|dt|WYd}~Sd}~ww)NrAz2Analyze the sentiment of the following text about zW. Rate from -10 (very bearish) to +10 (very bullish). Reply with only a number. Text: i z Sentiment score:zopenai/gpt-oss-120buserz6Analyze: 'Nifty hits all-time high on strong earnings')rolecontent assistant7z-Analyze: 'Market crashes on weak global cues'z-6333333?2reasoning_effortlow)modelmessages temperature max_tokens extra_bodyrz -?\d+\.?\d*$$@r[z ] AI error: z. Using keyword fallback.)osenvironr~striprclientchat completionscreatechoicesmessagerresearchrrrfloatgrouprr)rrpromptresponserawmatchrrRrRrS ai_sentiment=s8    r max_age_hourscCsdt|dd}|s dSzt|dddtji}Wn ty"YdSwttjt|d}||kS)Npublished_parsedTtzinfohours)getattrrrutcrrLr)entryr published published_dtcutoffrRrRrSis_freshds  rc Csd}t|}|dur |Szdddd}tjd|dd}|jd kr0td |jt|d Wd S|}t|tr?t |d krGt|d Wd Sd}d}|D]=}t |d d }t |dd dd } zt| } Wn tyxd } Ynwd|vsd|vr| }qMd|vr| }qM|dus|durt|d Wd S||} tdtd| t} t| d} td|dd|dd| dd| t|| | WSty} ztd| t|d WYd} ~ d Sd} ~ ww)NrZzoMozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36zapplication/jsonzhttps://www.nseindia.com/)z User-AgentAcceptRefererz-https://www.nseindia.com/api/fiidiiTradeReactr)headerstimeoutu#⚠️ FII/DII NSE returned status rrcategorynetValue0,FIIFPIDIIrrrz[FII/DII] FII net: +.2fz cr | DII net: z cr | Combined: z cr | Score: u⚠️ FII/DII fetch error: )rfrequestsr~ status_coderrhjson isinstancelistlenstrupperrOrr ValueErrorrr FII_DII_SCALErr) cache_keycachedrrdatafii_netdii_netrowrnet_strnet combined_netrvrrRrRrSfetch_fii_dii_scorersp         r$c Csd|}t|}|dur|Sz}tjtjtjtd}tjt ||gdddd}|j dkrV|j p6d}t d|dd t|d |dd id |dd iWSt|j }t||t d |d |d d|didd|didd|d |WStjyt d|t|d did diYSty}zt d|t|d t|id t|iWYd}~Sd}~ww)NrUzoption_chain_helper.pyTrK)capture_outputrrrz unknown erroru#⚠️ Option chain helper failed: rerrorz[Option Chain] z spot=spotz R= resistancelevelz S=supportz PCR=pcru)⚠️ Option chain helper timed out for ru⚠️ Option chain error: )rfrpathjoindirnameabspath__file__ subprocessrun VENV_PYTHON returncodestderrrrrhjson_libloadsstdoutr~TimeoutExpiredrr)rrr helper_pathruerrrrrRrRrSfetch_option_chain_levelssL    r<c CsVz|durWdSt|}t|st|rWdSt||WSttfy*YdSwr`)rmathisnanisinfrr TypeError)valdecimalsfrRrRrS _safe_floats rDc CsTz|durWdSt|}t|st|rWdSt|WSttfy)YdSwr`)rr=r>r?intrr@)rArCrRrRrS _safe_ints rFindexcCshd|}t|}|dur|Sz|dkrtnt}dd|D}tjd|dddd dd d }g}|D]}|d }zrt|d krE|} n||jdvrQ||nd} | dusZ| j ru| ||d|d|ddddddddddd Wq3| d } d| vr| d nd} d| vr| d nd} t| dkr| ||d|d|dt| rt | j dndddddddddd Wq3t| j d} t| j d}t|| | dd}d}d}d}| durR| durRt| dkrRt| dkrRg}tddD]*}zt| j |}t| j |}||}|dkr| |Wqty'Yqw|rRtt|t|d}|dkrRt||dd}|dkrRtt||d}| durb| j sbt | j dnd}| durt| j stt | j dnd}d| vr| dj st| dj dnd}| ||d|d|dt|d|t| d||||||ddWq3ty}z%| ||d|d|dddddddddt|dd d WYd}~q3d}~ww|ttd!|t|d"}t||td#|d$t|d%|WSty3}z#td&|d'||t|dd(gd)}t|||WYd}~Sd}~ww)*NrWr6cSsg|]}|dqSrrR)rcrRrRrSrz&fetch_constituents.. 7d1dFtickerT)tickersperiodintervalprogressgroup_by auto_adjustthreadsrrrrrrno_data) rrrrprice change_pctatratr_pct move_vs_atrvolumeday_highday_lowr&CloseHighLowrinsufficient_historydrDVolume)rrrrrWrX prev_closerYrZr[r]r^r\r&P%d %b %Y, %I:%M %p IST)rGupdated constituentsrz[Constituents] z : fetched  stocksu$⚠️ Constituents fetch error for r|r)rGr&rl)rfNIFTY50_CONSTITUENTSSENSEX30_CONSTITUENTSyfdownloadr-rcolumnsget_level_valuesemptyappenddropnarDilocrrrXrrabsrFrrrLrMr}rhr)rGrrrlsymbolsrresultsrIr ticker_datacloseshighslowsrh current_pricerXrYrZr[ true_rangesihltrr]r^r\exrurr;rRrRrSfetch_constituentss       0    $$,      r max_headlinescCsPtjt||}d|d}t|}dd|jD}dd|d|DS)N%https://news.google.com/rss/search?q=&hl=en-IN&gl=IN&ceid=IN:encSg|]}t|r|qSrRrrrrRrRrSrpz(fetch_news_headlines..cSg|]}|jqSrRtitlerrrRrRrSrq)urllibparsequoteSEARCH_QUERIESr~ feedparserentries)rrqueryurlfeedfreshrRrRrSfetch_news_headlinesls   rrD max_postscCsZt||}tj|d}d|d}t|}dd|jD}dd|d|DS)Nz site:x.com OR site:twitter.comrrcSrrRrrrRrRrSrxrz'fetch_twitter_posts..cSrrRrrrRrRrSryr)rr~rrrrr)rrkeywordrrrrrRrRrSfetch_twitter_postsss   rcnbctv18ETNOW)z CNBC-TV18zET Now)niftynifty50znifty 50sensexz bse sensex)goldz gold pricez gold ratezmcx gold)silverz silver pricez silver rate)crudez crude oilbrentwtibitcoinbtcrcCstd|}|r |dSdS)Nz5(?:v=|youtu\.be/|/embed/|/shorts/)([A-Za-z0-9_-]{11})rr )rrr)rrrRrRrSextract_video_ids r max_charsc st||g}ttjttd}zt }Wnt y6}zt d|d|WYd}~dSd}~wwt D]\}}zd|}t|} | jD]~} t| dd} | sXqMt| dddtji} | |kriqM| jtfd d |DszqMt| j} | sqMz@|j| gd d }g}|D]}t|d d}|r||qd|}t d|d| jddd||d|WWSt yYqMwWq;t y}zt d|d|d|WYd}~q;d}~wwt d|ddS)Nrrz] YouTube init error: r z.https://www.youtube.com/feeds/videos.xml?user=rrrc3s|]}|vVqdSr`rR)rkw title_lowerrRrSrsz+fetch_youtube_transcript..)enzen-INhi) languagesrrKz] YouTube OK '<z' from z ] Channel z error: z%] YouTube: no usable transcript found)SYMBOL_KEYWORDSr~rrrLrrrNEWS_MAX_AGE_HOURSrrrFINANCE_CHANNELSitemsrrrrranyrlinkfetchrur-)rrkeywordsrapir channel_nameusernamefeed_urlrrrrvideo_id transcriptpartschunkr full_textrRrrSfetch_youtube_transcripts`          $  rF bypass_cachec Csd|}|st|}|r|St|}t|}t|}|tvr"tnd}|r.t|d|nd}|r:t|d|nd} |rCt||nd} gg} } |rV| d| ||rb| d| | |rn| d| | |tvr|| d| || s|ddddddggd d } t || t || | St | }t t d d t | | D|d }|dkrd}n |d krd}nd}||||| | |||t|d } t || t || | S)Nr[r rg?g?rr{F) rrvrzrwrxryrZ headlinestweets has_youtubecss|] \}}||VqdSr`rR)rsrrRrRrSrsz&get_sentiment_score..rrbBEARISHBULLISH)rfrrrFII_DII_SYMBOLSr$rr-rurhrrrzipbool)rrrrnewsr youtube_textrZrwrxryweightsscoresru total_weight final_scorerzrRrRrSget_sentiment_scoresT    "   rrlcCsi}|D]H}|ddurq|d}||vrdddgd||<||dd7<||d|d7<||d |d 7<||d |d q|D]}||ddkrlt||d||dd ||d<qO|S)NrXrrr)r avg_changerstocksrrrrrrrr)r~rur)rl sector_datarIrrRrRrS_build_sector_summarys &rstockcCs|d}|d}|dd}|tv}|durdddSt|}|r5|tkr,dddS|tkr5dd dS|dus=|d kr]|d krFdd dS|d krOdddS|dkrXdddSdddS||}|tkrjdddS|tkrsdddS|tkr|dddSdddS)NrXrZrr )r)suggested_actionMAJORuIExtreme move for a heavyweight — momentum may exhaust soon, use caution IMPORTANTuASignificant heavyweight move — chart may show entry opportunityrg@uExtreme move — use cautionru+Significant move — watch for continuationr.SIGNALu2Early mover — open chart, watch for continuationu7Extreme move — momentum may exhaust soon, use cautionu5Significant move — chart may show entry opportunity)r~ TIER1_SYMBOLSrxTIER1_MAJOR_FLOORTIER1_IMPORTANT_FLOORATR_MAJOR_MULTATR_IMPORTANT_MULTATR_SIGNAL_MULT)rpctrZris_tier1abs_pctr[rRrRrS_classify_move s2           rc&Cslg}d}d}d}d}d}d}td}z5td}|jdd} | jsFt| djd}t| dkrFt| djd } | rFt|| | d d}Wnt y`} z t d | WYd} ~ nd} ~ wwt d d g} |durt |tkr|d kr|ddddd|dd|ddddn|ddddd|dd|dddd| D]} | d}|durq| d d }tt ||d d!}| d"}|d krd#nd$}t| }| d%}| d&}|dkrd'\}}n|dkrd(\}}n |d)krd*\}}nq|durd+t|d d,nd-}d.|d/d0}|d1| d2d3|d4d5|d6||| }||||d7|||dqt| }|D]A\}}|d8d!krt |d9d:kr|d9d kr^d;nd<}|d=d>d?d|d@|dA|d9d4dB|d8dCdD|dEdqAdF|vrt| dFtr|dF d%}t dG}|dur|dur||}t |tkr|d krdHndI}|d=dJdKddL|dMt|dNdOt|dNdPddQ|vr)t| dQtr)|dQ d%}t dR} |dur)| dur)|| }t |tkr)|d kr dHndI}|d=dJdSddT|dMt| dNdOt|dNdUd| dV}t dW}!|durl|!durl||!}t |tkrl|d krOdXndY}"|dZd[d\d)d]|!ddO|dd^|"d_d`|"dtda}#|#r|# dbdur|#dbdckr|dddedfd)dg|#dbdhdidtdj}$|$r|$ dbdur|$dbd!kr|dddkdld)dm|$dbdndod| dp}t dq}%|dur|%dur||%}t |drkr|dsdtdud)dvt|%dNdOt|dNdwd|dur|tdG<|dur|tdR<|dur|tdW<|dur|tdq<|jdxdydz|dt}|s4|d{d|d}d~ddd|S)Nrr6 ^INDIAVIX5drPr_rbrrdrez[Action] VIX error: rlrru⚠️ vix_surgerz VIX surged +.1fz% to z.2fu — premium expansion warningu3Options getting expensive — avoid chasing premium)priorityicontyper)rru✅vix_droprz VIX dropped u — premium contractionu2Calmer market — options cheaper, potential entryrXrr[rrr)r)u🚨r)u🔔rr)u🔍ru • z% of 5-day ATRr u • contributing ~z.3fz % to NIFTYr|rrKrz% (u% weight) — _moverrr.rru📊 sector_alertz sector z: avg z % across rmz Coordinated u move — check sector rotationr* nifty_supportUPDOWNu📍 support_shiftzNIFTY Support shifted z from r z to z'Adjust stops and targets to new supportr(nifty_resistanceresistance_shiftzNIFTY Resistance shifted z*Adjust stops and targets to new resistancer+ nifty_pcrrrrDu🔄 pcr_shiftzPCR moved from u — z shiftzPositioning is now sentiment_CRUDEOILrvru🛢️ crude_warningzCrudeoil bearish (score u) — Reliance may followz#Watch Reliance for sympathetic movesentiment_GOLDu🥇 gold_strengthzGold bullish (score u) — defensive rotationz#Watch for risk-off trade developingmax_pain nifty_maxpainrru🎯 maxpain_shiftzMax Pain shifted from zExpiry target has movedcSs|dS)NrrR)xrRrRrSsz(generate_action_events..ricu⚪neutralINFOu2No significant events detected — market is quiet)r<rpTickerhistoryrtrrwrrrrrr~rxVIX_SURGE_MIN_PCTrurrErrrrdictPREVIOUS_SNAPSHOTSUPPORT_RESISTANCE_SHIFT_MIN PCR_SHIFT_MINrjsortACTION_DASHBOARD_MAX_EVENTS)&eventscurr_supcurr_rescurr_pcr curr_maxpain current_vixvix_change_pctnifty_oc vix_tickervix_dataprev_vixr nifty_constrrrimpactr[ directionclassificationr)rrratr_note impact_notersector_summaryrsdataprev_supdiffprev_resprev_pcrtone crude_sent gold_sent prev_maxpainrRrRrSgenerate_action_events-s           ".   $          $ $      r4cCs^tt}|}|d|dz|dWn tjy$Ynw||dS)Na CREATE TABLE IF NOT EXISTS zones ( id INTEGER PRIMARY KEY AUTOINCREMENT, symbol TEXT NOT NULL, name TEXT, sector TEXT, zone_type TEXT NOT NULL, zone_top REAL NOT NULL, zone_bottom REAL NOT NULL, created_at TEXT NOT NULL, created_price REAL, age_bars INTEGER DEFAULT 0, entry_count INTEGER DEFAULT 0, first_entry_at TEXT, last_entry_at TEXT, last_entry_price REAL, is_active INTEGER DEFAULT 1, UNIQUE(symbol, zone_type, created_at) ) a CREATE TABLE IF NOT EXISTS zone_events ( id INTEGER PRIMARY KEY AUTOINCREMENT, symbol TEXT NOT NULL, name TEXT, sector TEXT, event_type TEXT NOT NULL, zone_type TEXT, zone_top REAL, zone_bottom REAL, price REAL, event_at TEXT NOT NULL, tier TEXT, message TEXT ) z.ALTER TABLE zone_events ADD COLUMN sector TEXT)rkrl ZONES_DB_PATHrnrorprqrr)rsrIrRrRrS init_zones_dbs    r6cCs<tt}|}|d|||f|}||duS)NzDSELECT id FROM zones WHERE symbol=? AND zone_type=? AND created_at=?)rkrlr5rnrofetchonerr)r zone_type created_atrsrIr rRrRrS zone_existss r:c Cstt}|}z&|d|d|d|dd|d|d|d|d |d f|WntyH}z td |WYd}~nd}~ww| dS) Nz INSERT OR IGNORE INTO zones (symbol, name, sector, zone_type, zone_top, zone_bottom, created_at, created_price, age_bars, is_active) VALUES (?, ?, ?, ?, ?, ?, ?, ?, 0, 1) rrrr r8zone_top zone_bottomr9 created_pricezInsert zone error: rkrlr5rnror~rqrrrr)zonersrIrrRrRrS insert_zones    r@cCstt}|}z6|d|d|d|dd|d|d|d|d |d |d |d |d f |WntyX}z td|WYd}~nd}~ww| dS)Nz INSERT INTO zone_events (symbol, name, sector, event_type, zone_type, zone_top, zone_bottom, price, event_at, tier, message) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) rrrr  event_typer8r;r<rWevent_attierrzInsert zone event error: r>)eventrsrIrrRrRrSinsert_zone_events   rEcCsVttttd}tt}| }| d|f| }| dd|DS)Nra SELECT id, symbol, name, sector, zone_type, zone_top, zone_bottom, created_at, created_price, age_bars, entry_count, first_entry_at, last_entry_at, last_entry_price FROM zones WHERE is_active = 1 AND created_at >= ? cSsfg|]/}|d|d|d|d|d|d|d|d|d|d |d |d |d |d dqS)rrrrrrDrrrEr )idrrrr8r;r<r9r=age_bars entry_countfirst_entry_at last_entry_atlast_entry_pricerRrrRrRrSrs   z$get_active_zones..) rrLrMrZONE_MAX_AGE_HOURS isoformatrkrlr5rnrorrr)rrsrIrrRrRrSget_active_zoness rRcCs:tt}|}|d||||f||dS)Nz UPDATE zones SET entry_count = entry_count + 1, first_entry_at = COALESCE(first_entry_at, ?), last_entry_at = ?, last_entry_price = ? WHERE id = ? )rkrlr5rnrorqrr)zone_idrWat_timersrIrRrRrSupdate_zone_entry&s   rUcCsLttttd}tt}| }| d|f| | dS)Nrz3UPDATE zones SET is_active = 0 WHERE created_at < ?) rrLrMrrPrQrkrlr5rnrorqrr)rrsrIrRrRrSdeactivate_old_zones4s   rVc Csg}t|}|ttdkr|Stt|tD]}||}d}t|t|D]}||d|dkr6d}nq&|rUt|d|tdD]}||d|dkrTd}nqD|rt|d|d}t|d|}t|d|} ||dt|dt| d|d|d d d} t|t|D]}||d |d krd} nq| rt|d|tdD]}||d |d krd} nq| rt|d|d} t|d | }t|d | } ||d t|dt| d|d |d d q|S) NrTrFopenrrrrrb)rGrtopbottomrWrbrr)r PIVOT_LEFT PIVOT_RIGHTrXrrrur) barspivotsnrbar is_pivot_lowjbody_lowbox_top box_bottom is_pivot_high body_highrRrRrS find_pivots?s`  rgrc Csz^t|}|j|dddd}|jrgWSg}|D]>\}}z/||t|dt|dt|dt|dt t|d sJt |d nd d Wqt t fy[Yqw|WSt y|}ztd |d |gWYd}~Sd}~ww)Nd15mF)rPrQprepostOpenr`rar_rgr)rbrWrrrrr\rz] 15m fetch error: )rprrrtiterrowsrurQrr=r>rErr@rr)rrrNdfr\idxr rrRrRrSfetch_15m_barsss2       roc Cs|d|d}|d}|dkrdnd}|dkr6|rdnd }d |d |d |d d|dd }||fS|dkrq|dd} | dkr]d}d|d|d |d d|dd }||fSd }d|d|d| dd}||fSd }|d}||fS)Nrrr8ru 🟢 Bullishu 🔴 Bearish zone_createdrrz NEW ZONE: z created a z reversal zone (r<-r;) zone_enteredrLrz FIRST ENTRY: z entered z RE-ENTRY: z re-entered z zone (entry #rz zone event)r~) rr?rArrr8 zone_labelrCmsgrLrRrRrSclassify_zone_events&  &  & rvcstt}|dur |nt}|dur|nt}td|dd|d|dt}tdt|dt g}i}t D] }| |dg |q=d } d } d } |D]5} | d} zt | d d td krjWqSd d}||ksx||krzWqS| d7} t}|sWqSfdd|D}|D]Y}|d}t| |d|rq| d7} | | d| dd|d|d|d||dd}t|t| |ddd\}}| | | d| ddd|d|d|d||||d q|| g}|D]w}|d}|d }d!dD]f}|d"|kr|d"|kp-|d#|ko|d#|kp-|d"|ko-|d#|k}|rht|d$|d|dt| |d%\}}| | | d| ddd%|d&|||d|d||d | d7} nqqWqSty}ztd'| d(|WYd}~qSd}~ww|D]}t|qtt|}td)| d*t|d+td,| d-| td.|d/d0t||d1| td2d|Dtd3d|Dd4d|Dd5d|Dtt d6 }td7||S)8N [%Y-%m-%d %H:%M:%S ISTu&] Zone scan started (price filter: ₹u-₹z)...z Universe: z F&O stocksrrr)rrrbrrrcs(g|]}|dttdkr|qS)rGr)rr[)rpr\rRrSrs(z!run_zone_scan..rbrrrr rXrYrW)rrrr8r;r<r9r=rpTr rrrrAr8r;r<rWrBrCrr;r<rrrrJrsr8rz] scan error: z Scanned: /rmz New zones: z | Entries: z Completed in rrz%d %b %Y, %I:%M:%S %p ISTcSg|] }|ddkr|qSrArprRrrRrRrSr cSr}rArsrRrrRrRrSr rcSr}r~rRrrRrRrSrrcSr}rrRrrRrRrSrr) version scanned_atscanned_at_humanstocks_scannednew_zones_count entries_count new_zonesrecent_entriesactive_zones_totalr\)rrLrMr r rr}get_fno_stocksrrVrR setdefaultrurorgr:r~r@rvrQrUrrE total_secondsVERSIONrh) min_price max_pricestarted_min_maxr new_eventsactive_zones_by_symbolz scanned_count pivots_found entries_foundrrrr] fresh_pivotsryr9r?rCru symbol_zonesztzbr_touchedrevtelapsedrurRrzrS run_zone_scans                   rc CstdttddtD]8}zt|dd}td|d|dd |d d WqtyH}ztd|d |WYd}~qd}~wwtd dS)Nrwrxz ] Scheduled sentiment refresh...T)rz [z ] Score: rvz (rzrrz ] error: zSentiment refresh complete. )rrrLrMr}SYMBOLSrr)symrurrRrRrSscheduled_sentiment_refreshs (  rz/api/sentimentcCsddtDS)NcSsg|]}t|qSrR)r)rrrRrRrSr'rJz&get_all_sentiments..)rrRrRrRrSget_all_sentiments%srz/api/sentiment/{symbol}cC t|Sr`)rrrHrRrRrSget_single_sentiment) rz/api/history/{symbol}cCs|t||dS)N)rr)rr)rrrRrRrSget_symbol_history-srz/api/option-chain/{symbol}cCrr`)r<rrHrRrRrSget_option_chain1rrz/api/constituents/{index}cCs |}|dvr ddiSt|S)N)r6r7r&zIndex must be NIFTY or SENSEX)rr)rG index_upperrRrRrSget_constituents5srz/api/action-dashboardc Cszt}ttdt|t|dWSty?}z td|ttddgt |dddWYd}~Sd}~ww)Nrj)rkr max_eventsru⚠️ Action dashboard error: rr)rkrrr&) r4rrLrMr}rrrrr)rrrRrRrSget_action_dashboard<srz /api/rangec Cs td}|r|Szetd}td}|jdd}|jdd}|js%|jr*ddiWS|djd }|djd }|d kr@|d n|}||td }t|d t|d t||d t||d t|d d} t d| | WSt y} z dt | iWYd} ~ Sd} ~ ww)NrXz^NSEIrrMrr&zCould not fetch market data.r_rbg?rer) last_closevixrrmid) rfrprrrtrwr=sqrtrrhrr) rrr nifty_datar"rr vix_decimal daily_moverurrRrRrSget_expected_rangeKs2         rz/api/scan/zones-15mcCstd}|r|StS)Nr\)rfr)rrRrRrS get_zone_scanisrz/api/scan/rescanrrcCs t||dS)Nrr)rrrRrRrSforce_zone_rescanprrz/api/scan/active-zonescCst}t||dS)N)rzones)rRr)rrRrRrSget_active_zones_endpointtsrz/api/scan/recent-eventsrcCs`ttt|d}tt}|}| d|f| }| t |dd|DdS)Nrz SELECT symbol, name, sector, event_type, zone_type, zone_top, zone_bottom, price, event_at, tier, message FROM zone_events WHERE event_at >= ? ORDER BY event_at DESC LIMIT 100 cSsTg|]&}|d|d|d|d|d|d|d|d|d|d |d d qS) rrrrrrDrrrFrErr{rRrrRrRrSrs  z*get_recent_zone_events..)rr) rrLrMrrQrkrlr5rnrorrrr)rrrsrIrrRrRrSget_recent_zone_eventsys rz /api/statuscCsftt}|dk}d|jkodknp!|jdko!|jdk}|r(|r(dnd}||dtdS) NrDrErFrK Market Open Market Closedrj)statusrkr)rrLrMrNrGrHr}r)rL is_weekdayis_market_hoursrrRrRrSget_market_statuss  .rz/api/scan/statusc Cstt}|dk}d|jkodknp!|jdko!|jdk}|r(|r(dnd}|dur0|nt}|dur8|nt}t|| dt t t t dt |d t |||d tttd d S) NrDrErFrKrrrju₹u - ₹ri)leftrightzone_length_bars) rrrkuniverse_count active_zones price_filter price_min price_max timeframe pivot_config)rrLrMrNrGrHr r rr}rrrRrErZr[ZONE_LENGTH_BARS)rrrLrrrrrrRrRrS scan_statuss"  . rz /api/versioncCstdgddS)Nz 2026-10-02)zUNIFIED PLATFORM v1.0.0z--- Sentiment Scanner ---z4Multi-source AI sentiment (News + Twitter + YouTube)zFII/DII institutional flowsz.Option chain (Support/Resistance/Max Pain/PCR)zOI Buildup with net writer biasz(Nifty 50 Top 25 + Sensex 30 constituentsz(Weight-aware + ATR-based tiered alertingzLive Action Dashboardz--- Zone Scanner ---z15-minute reversal zone scannerz!Pine Script pivot detection logicz F&O stock universe (~190 stocks)zNew zone + zone entry detectionz"Tiered alerts (IMPORTANT / SIGNAL)z!Automatic 15-minute scan schedulez--- Shared ---z%Adaptive caching (market-hours-aware)zSQLite persistence (2 DBs)zScheduled snapshots)rrfeatures)rrRrRrRrS get_versionsrz/api/scheduler/statuscCs4t}tttttdtdd|DdS)NrxcSs.g|]}|j|j|jr|jdnddqS)z%Y-%m-%d %H:%M:%S %ZN)rJrnext_run)rJr next_run_timer})rrarRrRrSrs z$scheduler_status..)rr current_time market_hoursjobs) schedulerget_jobsrrrMrrLr}rT)rrRrRrSscheduler_statussr)rzmon-frirE) day_of_weekrGrHr sentiment_9amzSentiment 9:00 AM)triggerrJrreplace_existingrHrKsentiment_1230pmzSentiment 12:30 PMrFsentiment_330pmzSentiment 3:30 PM)rrFrK-)rrGrHrIrzone_02dz Zone scan :x)rrJrrmisfire_grace_timezone_1630_finalzFinal zone scan 16:30rYu 🚀 PDMP Unified Platform z: Sentiment: 3 daily snapshots (9:00 / 12:30 / 15:30 IST)z/ Zone Scanner: every 15 min + final 16:30 ISTz6 Universe: F&O (~190 stocks) + Sentiment (6 symbols)z API: http://0.0.0.0:8000z* Both scanners running from one process c Cs\tdztdttdWdSty-}ztd|WYd}~dSd}~ww)Nrz Running initial zone backfill...zZone backfill complete. zZone backfill error: )rbsleeprrr)rrRrRrSdelayed_backfill s r)targetdaemon__main__z0.0.0.0i@)hostportr`)r)r6)r)rD)r)F)r)T)NN)r)rrrbr=rkrr1 threadingrr6r urllib.parserrrrfastapirfastapi.middleware.corsryfinancerpopenairyoutube_transcript_apir!apscheduler.schedulers.backgroundr apscheduler.triggers.cronr pytz fno_stocksr rr r rrr3rMrrrrrrrrrrrrZr[rrPrmr5rnrorrrkeysrrappadd_middlewarerr~rrarTr_rfrhrjrtrrrrErrrrrrrrr$r<rDrFrrrrrrrrrrrr4r6r:r@rErRrUrVrgrorvrrrrrrrrrrrrrrrrrradd_jobrXrGrHrstartrrThread__name__uvicornr2rRrRrRrSs                                                               !    '> ) z  59 .  4 q