.ؗjkT dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZddlmZmZmZddlmZmZedZedz Zej/d ed z Zed z Zed z Zedz Zej8ej:dej<edej>gej@dZ!e jDZ#dZ$dZ%ejLjOddjQZ)e)r?e)jUdDchc]#}|jQs|jQ%c}Z+ne%hZ+e%Z,ejLjOddjQxsdZ-iZ.ejLjOddjQZ/e/rQe/jUdD]=Z0de0vse0jUdd\Z1Z2e2jQe.e1jQ<?dZ3dZ4d Z5d!Z6e7d"e8ejLjOd#d$Z9d Z:d%Z;d&Zd(hZ?d)Z@e$d*ZAe$dOdPd+ZBe$dQdRd,ZCe$dSd-ZDe$dTdSd.ZEd/ZFe$e9fdUd0ZGe$e9f dVd1ZHe$d2ZIe$d3ZJe$dWd4ZKe$d5ZLdXd6ZMdYd7ZNdZd8ZOd[d9ZPdXd:ZQdXd;ZRe$ d\ d]d<ZSe$d^d=ZTe$d^d>ZUe$d_d?ZVe$d`dad@ZWe$dAZXe$dbdBZYe$dCZZda[dDZ\dcdEZ]dddFZ^GdGdHeZ_dIZ`dedJZadKZbdLZcdMZdeedNk(re`yycc}w)fu webhook_receiver.py — Webhook async per TV → Bybit V5. ARCHITETTURA (fix del bug timeout): TradingView ──HTTP POST──> webhook │ ├── validate secret + campi (~1ms) ├── enqueue su SQLite (persistente) ├── ritorna HTTP 200 IMMEDIATAMENTE ← chiave! │ └── background worker thread │ ├── fetch prezzo Bybit ├── auto-bump qty ├── set leva ├── place order ├── log su orders.log UNICO ├── email notification └── mark completed su DB PERCHÉ: - TradingView timeout = 5-10s - HTTP response deve tornare in <1s - Tutto il resto (chiamate Bybit lente) avviene in background - Se webhook crasha, la coda SQLite recupera gli ordini pending al restart - PID file garantisce UNA SOLA istanza attiva (no race condition) ENDPOINTS: - POST /webhook — riceve alert TV (fast, <100ms) - GET /health — health check - GET /status — stato coda (pending, completed, failed) ) annotationsN)Path)datetimetimezone timedelta)BaseHTTPRequestHandlerThreadingHTTPServerz /opt/charter-live/live_deploy_v2logsT)exist_okzwebhook_receiver.logz orders.logzwebhook_queue.dbzwebhook_receiver.pidz1%(asctime)s [%(levelname)s] %(name)s: %(message)sutf-8encoding)levelformathandlerswebhookcfd}|S)NcLt5|i|cdddS#1swYyxYwN)DB_LOCK)argskwargsfuncs &/tmp/webhook_receiver.py.intent_matrixwrapperzdb_serialized..wrapperPs(  )(( ) ) )s#)rrs` r db_serializedrOs) NTV_2026_MATTIA_DEMOWEBHOOK_SECRETS,WEBHOOK_DEFAULT_STRATEGYvptr3WEBHOOK_SECRET_STRATEGY_MAP:z0.0.0.0ig@g333333?<V2_PENDING_MAX_AGE_SECONDS6002240d VIRTUALUSDTctjrl ttjj }ddl}|j |r+tjd|tjdtjttj tj#dtj y#ttf$rYjwxYw)u>Se c'è già un'istanza attiva, esci. Previene race condition.rNu/ALTRO webhook_receiver già attivo PID=%d, escor'zPID file scritto: %d)PID_FILEexistsint read_textstrippsutil pid_existslogerrorsysexit ImportError ValueError write_textstrosgetpidinfo)old_pidr5s rcheck_singletonrCs (,,.4467G   ) KWU  BIIK()HH #RYY[1Z(   sA+CC,+C,c\tjtdd}|jd|jd |jd|jd|jd|j t jd t|S#t$rYYwxYw) z.Inizializza DB SQLite per la coda persistente.F )check_same_threadtimeoutzPRAGMA journal_mode=WALah CREATE TABLE IF NOT EXISTS queue ( id INTEGER PRIMARY KEY AUTOINCREMENT, request_id TEXT UNIQUE NOT NULL, received_at TEXT NOT NULL, payload TEXT NOT NULL, status TEXT NOT NULL DEFAULT 'pending', error TEXT, order_id TEXT, processed_at TEXT ) z=ALTER TABLE queue ADD COLUMN tunnel_pending INTEGER DEFAULT 0a CREATE TABLE IF NOT EXISTS orders ( id INTEGER PRIMARY KEY AUTOINCREMENT, request_id TEXT NOT NULL, order_id TEXT NOT NULL, symbol TEXT NOT NULL, side TEXT NOT NULL, qty REAL NOT NULL, price REAL, notional REAL, strategy TEXT, created_at TEXT NOT NULL ) aL CREATE TABLE IF NOT EXISTS position_ownership ( symbol TEXT PRIMARY KEY, strategy TEXT NOT NULL, side TEXT NOT NULL, entry_request_id TEXT, entry_order_id TEXT, opened_at TEXT NOT NULL, source TEXT NOT NULL DEFAULT 'webhook' ) zDB inizializzato: %s)sqlite3connectDB_PATHexecute Exceptioncommitr7rA)conns rinit_dbrOs ??7eR HDLL*+LL     TU LL    LL    KKMHH #W- K;    sB B+*B+cttj}|jd|t j t jjtj||rdndf|j|S)z/Inserisce richiesta nel DB. Ritorna request_id.zXINSERT INTO queue (request_id, received_at, payload, tunnel_pending) VALUES (?, ?, ?, ?)r'r) r>uuiduuid4rKrnowrutc isoformatjsondumpsrM)rNpayloadtunnel_pending request_ids renqueue_requestr[sfTZZ\"JLLb X\\(,,/99;TZZ=P! %  KKM rc |rdnd}|jd|||tjtjj |f|j y)z5Marca richiesta come processata (completed o failed). completedfailedzQUPDATE queue SET status=?, order_id=?, error=?, processed_at=? WHERE request_id=?NrKrrSrrTrUrM)rNrZorder_idr8statuss rmark_processedrbsN%[(FLL[ 5 hll # - - / =  KKMrc|jd|tjtjj |f|j y)zreplacerlrrT TypeErrorr<)valueparseds r_parse_queue_timerrs_''E (:(:3(IJvOFNN(,,N,OO z "s;AAA0/A0ctjtj}g}|j dj }|D]\}}t |}|||z j|kDs*|dn$tt||z j}d|d|} t||| |j|tjd|| |S)zETerminalizza i pending scaduti. Mai rieseguire un vecchio segnale TV.z@SELECT request_id, received_at FROM queue WHERE status='pending'unknownz expired_pending_ttl age_seconds=z limit=z-PENDING EXPIRED/QUARANTINED: request_id=%s %s)rrSrrTrKfetchallrr total_secondsr>r2riappendr7r8) rNmax_age_secondsrSexpiredrowsrZ received_atreceivedageres rexpire_stale_pendingr~s ,,x|| $CG <<J hj $([ K$[1  h==?/Q'/)ScHn=[=[=]9^5_C7uGOCTUF z6 2 NN: & IIEzSY Z[ Nrc|jd|fj}|stjd|y|\}}|dk7rtj d||yt |}|7t jtj|z j|kDr#t||tjd|yy)z@Difesa in profondita prima di qualsiasi chiamata ordine a Bybit.z8SELECT status, received_at FROM queue WHERE request_id=?z6QUEUE STATE MISSING: request_id=%s; processing blockedFpendingz,QUEUE TERMINAL SKIP: request_id=%s status=%sz1STALE REQUEST BLOCKED before Bybit: request_id=%sT) rKfetchoner7r8warningrrrrSrrTrvri)rNrZrxrowrar{r|s rrequest_is_fresh_pendingrs ,,BZM hj  JJWFK  BJPVW -HHLL6APPRUddT:& EzR rc|jdj}|Dcgc]}|dtj|df!c}Scc}w)z4Ritorna richieste pending (per recovery al startup).zRSELECT request_id, payload FROM queue WHERE status='pending' ORDER BY id LIMIT 100rr')rKrurVloadsrNrzrs r get_pendingr/sK <<\ hj /3 3QqT4::ad# $ 33 3s$A ct||jdj}|Dcgc]}|dtj|df!c}Scc}w)a FIX 2026-07-19 (Mavis handoff TAILSCALE_WATCHDOG): ritorna solo richieste pending NON bloccate da tunnel_pending=1. Il worker processa queste; le richieste con tunnel_pending=1 restano in coda finche' il tunnel non torna su (segnalato da set_tunnel_state).zgSELECT request_id, payload FROM queue WHERE status='pending' AND tunnel_pending=0 ORDER BY id LIMIT 100rr')r~rKrurVrrs rget_pending_unblockedr8sS  <<q hj /3 3QqT4::ad# $ 33 3s$AcR|jdj}|r|dSdS)zAFIX 2026-07-19: conta richieste in attesa che il tunnel torni su.FSELECT COUNT(*) FROM queue WHERE status='pending' AND tunnel_pending=1rrKr)rNrs rcount_pending_tunnel_blockedrEs2 ,,P hj3q6arct||jdj}|Dcgc]\}}| }}}d}|r.djd|D}|jd|d|}|j | |j nd}|t |k7r tjdt |||Dcgc]\}}|tj|fc}}Scc}}wcc}}w) zGSblocca solo richieste fresche e le restituisce per la coda in memoria.zgSELECT request_id, payload FROM queue WHERE status='pending' AND tunnel_pending=1 ORDER BY id LIMIT 100Nr"c3 K|]}dyw)?Nr).0_s r z-unblock_all_tunnel_pending..Ys99s zaUPDATE queue SET tunnel_pending=0 WHERE status='pending' AND tunnel_pending=1 AND request_id IN ()rz2TUNNEL UNBLOCK count drift: selected=%d updated=%d) r~rKrujoinrMrowcountlenr7rrVr) rNrzrZr request_idscur placeholdersupdatedrXs runblock_all_tunnel_pendingrNs << L hj 488-*a:8K8 Cxx9[99 ll77CnA G    KKM!ocll1G#d) H#d)U\]IM N2E*gZG, - NN9 Os C)!C/cdjt|xsdjjddjddj S)N r!r-)rr>lowerrnsplit)rps r_normalized_markerrfsF 88C $**,44S#>FFsCPVVX YYrc4dtfddDS)zBRiconosce in modo uniforme tutte le forme Pine note per le uscite.) zmax exitz exit barszopposite signalz exit shortz exit longz short exitz long exitztrailing shortz trailing longz trailing exitz close entryzstrategy closec3JK|]tfdDyw)c3VK|] }|tjv"ywrrget)rmarkerfieldrXs rrz5payload_has_close_intent...rs% SF(U);< < Ss&)Nany)rrmarkersrXs @rrz+payload_has_close_intent..qs$  S7 SSs#)comment alert_messager`r)rXrs`@rpayload_has_close_intentrjs&G = rcLddddddd}t|jd}t|jd}|j|}|j|}|| dd|d |fSd d d }d d d }|dk(r"||vr||} || k(rd d|fSdd|d| d|fS||vr"|dk(r||} || k(rd|dfSd|d| d|fS||vr!||k(r|||k(r d|d|dfSd|d|dfS||vr+||vr'||k7r"||} || k(r d|d|fSd|d|d| d|fSdd|d|d|fS)zIClassifica l'ordine TV dalla transizione, senza dedurlo dal testo libero.flatlongshort)rrrzmarket position flatzmarket position longzmarket position shortmarket_positionprev_market_positionLEGACYz missing/invalid transition prev=z current=buysell)rrENTRYzflat->INVALIDz requires side=z, got FULL_EXITz->flatz->flat requires side= PARTIAL_EXITz->z opposite-side orderSCALE_INz same-side orderREVERSALzunsupported transition z side=r) rXsidealiases current_raw previous_rawcurrentprevious entry_side exit_sideexpecteds rclassify_position_intentrws  &!(G %W[[1B%CDK%gkk2H&IJLkk+&G{{<(H(*;L;K9U`Tcddd&1J%0I6g3g&040@6'+, yzvNG  9F!2X&59X5E z01 (#8 &OL  9H!4 9X& &!hZr':N#OO OhZr'2BCCC9J!67h;Ng&9=9I xj7)45 (2gYohZvdVTP   /zG9F4&Q QQrc tt|jd}||z}||z }d|cxkrdkr|SdS#ttt f$rYywxYw)z@Quota della posizione TV precedente chiusa dall'ordine parziale. position_sizerr')absfloatrror<ZeroDivisionError)rXqty remainingbeforefractions rpartial_exit_fractionrsigkk/:;< S<8(q(81(c1 z#4 5s-?AAcvt|}|dvry|dvry|dvry|dvry|d vry |jd d xsd S)zBNome stabile usato per impedire chiusure incrociate tra strategie.)r$zvptr v3r$)z ma trailingzma trailing close ma_trailing)z rsi swingzrsi swing breakout rsi_swing)zrettangolo tv simplezrettangolo simplez rett simplerettangolo_simple) rettangoloz rettangolo v2rrrrt)rrnrpraws rcanonical_strategy_namers^ U #C "" 22 11 JJ" -- ;;sC -I-rcnt|xsdjj}|dvry|dvryy)Nr!rrrrrrrt)r>r4rrs rcanonical_position_siders< ekr  " ( ( *C o  rc |jd|t|t|||tjt j j|f|jy)NaSINSERT INTO position_ownership (symbol,strategy,side,entry_request_id,entry_order_id,opened_at,source) VALUES (?,?,?,?,?,?,?) ON CONFLICT(symbol) DO UPDATE SET strategy=excluded.strategy,side=excluded.side,entry_request_id=excluded.entry_request_id,entry_order_id=excluded.entry_order_id,opened_at=excluded.opened_at,source=excluded.source) rKrrrrSrrTrUrM)rNsymbolstrategyrrZr`sources rset_position_ownerrsZ LL > (24KD4Q Xx||HLL9CCEv O  KKMrc|jd|fj}|sy|d|d|d|d|d|ddS) NzlSELECT strategy,side,entry_request_id,entry_order_id,opened_at,source FROM position_ownership WHERE symbol=?rr')rrentry_request_identry_order_id opened_atrr)rNrrs rget_position_ownerrs^ ,, 139) hj FCFAa&s1vQ rcJ|jd|f|jy)Nz-DELETE FROM position_ownership WHERE symbol=?rKrM)rNrs rclear_position_ownerrsLL@6)LKKMrct||}t|}t|}|dd|dfS|d|k7rdd|dd||fS|d|k7rdd|dd ||fSd d |fS) zFFail-closed: una strategia chiude solo la posizione che le appartiene.NFz position_owner_missing incoming=rzposition_owner_mismatch owner=z incoming=rzposition_side_mismatch owner=z bybit=Tposition_owner_match)rrr)rNrr position_sideownerincoming actual_sides rposition_owner_allows_closers tV ,E&x0H)-8K }8 CTII ZH$,U:->,?z( T   V} #+E&M?'+ O   ' ..rcT|jd|rdnd|f|jy)zFIX 2026-07-19: marca una richiesta come bloccata (tunnel_pending=1) o sbloccata (tunnel_pending=0). Usato in do_POST quando tunnel e' giu'.z4UPDATE queue SET tunnel_pending=? WHERE request_id=?r'rNr)rNrZblockeds rset_tunnel_block_on_requestrs* LL>1j) KKMrc tjtjj } d| d|d|d|d|d|dt |dd|} t jd | |jd ||||||||| f |j ttd d 5} | j| dzdddy#1swYyxYw#t$r } t jd| Yd} ~ yd} ~ wwxYw)zBRegistra prima nel DB; il file testuale e' un audit non bloccante.[z ] orderId=rz qty=z price=z notional=rz strategy=z ORDER: %szINSERT INTO orders (request_id, order_id, symbol, side, qty, price, notional, strategy, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)ar r  Nz1ORDERS_LOG append failed (DB order preserved): %s)rrSrrTrUroundr7rArKrMopen ORDERS_LOGwriteOSErrorr8) rNrZr`rrrpricenotionalrtslinefexcs rlog_order_unifiedr s  hll # - - /B rd*XJaxqeC5wjY^_gijYkXllvwwA BDHH[$ LL Q XvtS%8RP KKML *cG 4 ! GGD4K  ! ! ! L EsKKLs6C*C?CC CC C=C88C=cD|jd|fjS)Nz