[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":25,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","f8a7dae4-60fb-11f1-851b-1607ee4eb77e","name","fileType","interval","content","// ════════════════════════════════════════════════════════════════════\n// Premium Options (formerly TradeOS) — Unattended Cloud Scanner (Val Town cron val)\n// ════════════════════════════════════════════════════════════════════\n// Runs in the cloud on a schedule, independent of your computer.\n// Scans your watchlist for qualifying credit put spreads (same rule as\n// the Premium Options dashboard) and texts the summary to you via Telegram.\n//\n// HOW TO DEPLOY (summary — full steps are in the chat):\n// 1. Create a Telegram bot via @BotFather → copy the BOT TOKEN.\n// 2. Get your numeric chat id (message the bot, then read getUpdates,\n// or use @userinfobot).\n// 3. On val.town: New → Cron val → paste this whole file.\n// 4. Add Environment Variables (Settings → Environment Variables):\n// TRADIER_KEY (required — your Tradier production token)\n// TELEGRAM_BOT_TOKEN (required)\n// TELEGRAM_CHAT_ID (required)\n// Optional overrides (defaults match the dashboard):\n// WATCHLIST, WIDTHS, DTE_MIN, DTE_MAX, OTM_MIN, OTM_MAX,\n// MIN_PREM_PCT, MAX_BID_ASK, DAY_DOWN_PCT, DAY_FILTER,\n// MAX_TICKERS, MAX_EXPS, FORCE\n// 5. Set the cron schedule to: 0 * * * * (every hour)\n// The code itself only does work at 10:00/12:00/14:00/16:00 ET on\n// weekdays while the US market is open — i.e. every ~2 hours.\n// Set FORCE=true to bypass the time gate for a one-off test run.\n// ════════════════════════════════════════════════════════════════════\n\nconst TRADIER = \"https://api.tradier.com/v1\";\n\nfunction env(key, fallback) {\n try {\n const v = Deno.env.get(key);\n return v === undefined || v === null || v === \"\" ? fallback : v;\n } catch {\n return fallback;\n }\n}\n\n// Default watchlist — kept in sync with the dashboard preset by\n// update-watchlist-from-yahoo.sh (re-paste the val after it runs).\n// Override with the WATCHLIST env var. Large lists are fine: quotes are\n// batched, and deep scans are capped at the MAX_TICKERS worst decliners.\nconst DEFAULT_WATCHLIST =\n \"UNFI,FLYW,PARR,ICHR,CORT,SNEX,FPS,KO,FLEX,ACHR,GILT,CDNL,TMC,AXTI,TE,SPCX,THLLY,ACM,SHAK,PL,BKSY,LUNR,CGNX,AME,IRDM,ENS,TRRVF,SANM,SIDU,SNPS,FNV,HEI,QBTS,GFS,VST,PRME,SUNB,RSG,RVMD,GTLB,FRSH,ARM,ET,CBRS,CBOE,CRDO,SNDK,HII,CW,BE,FERG,TPC,PRIM,EQT,IONQ,BBAI,FCX,WM,COPX,SOLS,OUST,CP,AMTM,STRL,NOK,TOTDY,RVI,CDRE,GEV,COHR,NXT,GNRC,ROL,XRAY,LZ,PCOR,MRKR,DUOT,MAX,RDW,ALHC,NNN,NFG,MSGS,VSNT,KTOS,DE,SYK,WHD,NI,RBC,HOOD,CRML,RRX,OKE,COLD,CACI,NVO,IREN,OKLO,EME,AVR,WY,AUR,NBIS,BKR,RGTI,WAY,CIFR,CRWV,PPTA,VMC,KNSL,PHR,GSM,PHIN,CRS,MTRN,AMSC,RKLB,OS,SPHR,IBM,A,AA,AAPL,ABBV,ABCB,ABNB,ABR,ABT,ACAD,ACI,ACLS,ACMR,ADBE,ADC,ADDYY,ADI,ADP,ADSK,AFL,AFRM,AGCO,AGM,AGNC,AIT,AKAM,ALAB,ALB,ALGM,ALGN,ALLY,ALNY,ALRM,AMAT,AMBA,AMD,AMKR,AMT,AMZN,ANET,AON,APA,APLD,APO,APOG,APPF,APTV,ARE,ARLP,ASML,ATKR,AVAV,AVGO,AVTR,AWI,AZTA,BABA,BAH,BAM,BBSI,BEP,BHC,BIDU,BILI,BIP,BITO,BITW,BKLC,BL,BLD,BMY,BR,BSM,BSX,BUG,BWA,BWXT,CALX,CAMT,CAT,CCI,CCL,CCOI,CDNA,CDNS,CEG,CEVA,CF,CHE,CHWY,CIEN,CLX,CMG,CMI,CNI,CNSWF,CODI,COHU,COIN,COMP,COST,CPNG,CPRT,CPT,CRAI,CRM,CRSP,CRWD,CSW,CSX,CVX,CWEN,CYBR,DAR,DDOG,DHI,DHR,DIOD,DIS,DKNG,DLR,DOCN,DOCU,DPZ,DT,DVN,DXCM,DY,EA,EBAY,EDU,EHC,EL,ENB,ENTG,EOLS,EPAM,EPD,EPR,EPRT,EQIX,EQR,ESS,ESTC,ETN,ETSY,EVC,EXE,EXTR,F,FANG,FCPT,FDS,FDX,FIGS,FLGT,FLS,FOUR,FRT,FSLR,FTNT,FVRR,GASS,GD,GE,GGG,GH,GILD,GLBE,GLOB,GMED,GNK,GOOGL,HASI,HCSG,HD,HDB,HI,HLF,HOLX,HOV,HTGC,HUBS,HWKN,HWM,HYD,PPLI,IDXX,IGOV,IIPR,INMD,INTC,INVH,IP,IPGP,ISRG,ITRI,JCI,JD,JMIA,JNJ,JPM,KEYS,KLAC,KMB,KNSA,KNX,KR,KRT,LAND,LC,LDOS,LEN,LEU,LH,LHX,LITE,LMAT,LMND,LMT,LOB,LPX,LRCX,LUNA,MA,MAIN,MANH,MAR,MARA,MASI,MATX,MCD,MCHP,MDB,MDLZ,MDT,MEDP,MEI,MELI,META,MGA,MGRC,MITK,MKC,MKL,MKSI,MKTX,MLKN,MMM,MOMO,MP,MPWR,MQ,MRK,MRVL,MSCI,MSFT,MSTR,MTCH,MTD,MTH,MTSI,MTZ,MU,MXL,NCNO,NEE,NEM,NET,NFLX,NKE,NLY,NNOX,NOW,NTLA,NUE,NVCR,NVDA,NVMI,NVR,NVS,NVT,NX,NXPI,O,OEC,OKTA,OLED,ON,ONTO,ORCL,ORI,OSCR,OSS,OXY,PAA,PAGP,PANW,PATK,PCG,PD,PEN,PFE,PGNY,PH,PHM,PII,PINE,PINS,PJT,PKX,PLD,PLTR,PODD,POWI,PRG,PRGS,PRLB,PSA,PSX,PUBM,PWR,PYPL,QCOM,QLYS,QQQ,QSR,QYLD,RBLX,RCL,RDNT,REG,RGA,RGNX,RIOT,RKT,RMD,ROK,ROP,RPM,RTX,SBUX,SE,SHLS,SHOP,SIEGY,SIMO,SKT,SLP,SLV,SMCI,SMG,SMLR,SNA,SNOW,SOFI,SONY,SOUN,SPG,SR,SSD,STAG,STIM,STM,STNE,SU,SUI,SWKS,SXI,SY,SYM,SYNA,T,TCEHY,TDG,TEAM,TEL,TEM,TENB,TER,TGLS,TGT,TLRY,TMFC,TMO,TNXP,TOL,TOST,TREX,TRIP,TRMB,TRUP,TSLA,TSLX,TSM,TTAN,TTC,TTD,TTWO,TUR,TW,TWLO,TXG,TXN,TYL,U,UA,UAA,UBER,UCTT,UI,UNH,UNP,UPST,UPWK,UTMD,V,VAC,VC,VCTR,VEEV,VERI,VKTX,VNO,VOO,VREX,VRT,VRTX,VTR,VXRT,W,WCC,WDAY,WDC,WELL,WEX,WFG,WHF,WIX,WMT,WPC,XIFR,XLC,XYZ,YELP,YEXT,Z,ZM,ZS,ZTO\";\n\nconst CFG = {\n watchlist: env(\"WATCHLIST\", DEFAULT_WATCHLIST)\n .split(\",\").map((s) => s.trim().toUpperCase()).filter(Boolean),\n widths: env(\"WIDTHS\", \"2,5,10,20\").split(\",\").map(Number).filter((w) =>\n w > 0\n ),\n dteMin: +env(\"DTE_MIN\", \"21\"),\n dteMax: +env(\"DTE_MAX\", \"180\"),\n otmMin: +env(\"OTM_MIN\", \"15\") / 100,\n otmMax: +env(\"OTM_MAX\", \"40\") / 100,\n minPremPct: +env(\"MIN_PREM_PCT\", \"28\") / 100,\n maxLegBaPct: +env(\"MAX_LEG_BA_PCT\", \"25\"),\n dayDown: +env(\"DAY_DOWN_PCT\", \"1.0\"),\n dayFilter: env(\"DAY_FILTER\", \"true\") !== \"false\",\n maxTickers: +env(\"MAX_TICKERS\", \"40\"),\n maxExps: +env(\"MAX_EXPS\", \"1\"),\n force: env(\"FORCE\", \"false\") === \"true\",\n};\n\n// US market state in Eastern time (handles DST automatically).\nfunction marketState(now = new Date()) {\n const et = new Date(\n now.toLocaleString(\"en-US\", { timeZone: \"America/New_York\" }),\n );\n const day = et.getDay();\n const mins = et.getHours() * 60 + et.getMinutes();\n const open = day >= 1 && day <= 5 && mins >= 570 && mins < 960; // 9:30–16:00 ET\n return { et, open, hour: et.getHours() };\n}\n\n// Scan only on a clean 2-hour cadence inside market hours.\nconst SCAN_HOURS = [10, 12, 14, 16];\n\nasync function tradier(path, params) {\n const url = new URL(TRADIER + path);\n Object.entries(params || {}).forEach(([k, v]) => url.searchParams.set(k, v));\n const res = await fetch(url.toString(), {\n headers: {\n Authorization: `Bearer ${env(\"TRADIER_KEY\")}`,\n Accept: \"application/json\",\n },\n });\n if (!res.ok) throw new Error(`Tradier ${res.status}: ${path}`);\n return res.json();\n}\n\n// Batched quote prefetch: 1 API call per 100 symbols (vs. 1 per ticker).\nasync function fetchQuotes(symbols) {\n const map = {};\n for (let i = 0; i < symbols.length; i += 100) {\n const batch = symbols.slice(i, i + 100);\n const q = await tradier(\"/markets/quotes\", {\n symbols: batch.join(\",\"),\n greeks: false,\n });\n let quotes = q?.quotes?.quote || [];\n if (!Array.isArray(quotes)) quotes = [quotes];\n for (const qt of quotes) if (qt?.symbol) map[qt.symbol] = qt;\n }\n return map;\n}\n\n// Deep-scan one ticker (quote already fetched in the batched prefetch).\nasync function scanTicker(ticker, quote) {\n const today = new Date();\n const price = quote.last;\n\n const ex = await tradier(\"/markets/options/expirations\", {\n symbol: ticker,\n includeAllRoots: true,\n });\n let exps = ex?.expirations?.date || [];\n if (!Array.isArray(exps)) exps = [exps];\n const valid = exps\n .filter((e) => {\n const d = Math.round((new Date(e) - today) / 86400000);\n return d >= CFG.dteMin && d <= CFG.dteMax;\n })\n .sort((a, b) => new Date(a) - new Date(b))\n .slice(0, CFG.maxExps);\n\n const out = [];\n for (const exp of valid) {\n const dte = Math.round((new Date(exp) - today) / 86400000);\n const ch = await tradier(\"/markets/options/chains\", {\n symbol: ticker,\n expiration: exp,\n greeks: false,\n });\n let opts = ch?.options?.option || [];\n if (!Array.isArray(opts)) opts = [opts];\n const puts = opts.filter((o) =>\n o.option_type === \"put\" && o.bid > 0 && o.ask > 0\n );\n\n for (const width of CFG.widths) {\n const shorts = puts.filter((p) => {\n const otm = (price - p.strike) / price;\n return otm >= CFG.otmMin && otm <= CFG.otmMax;\n });\n for (const sp of shorts) {\n const longStrike = +(sp.strike - width).toFixed(2);\n const lp = puts.find((p) => Math.abs(p.strike - longStrike) < 0.01);\n if (!lp) continue;\n // Net credit at mid-price (matches the dashboard scanner).\n const netCredit = +(((sp.bid + sp.ask) / 2) - ((lp.bid + lp.ask) / 2))\n .toFixed(2);\n if (netCredit <= 0) continue;\n // Liquidity guard: each leg's bid/ask width as a % of its mid price.\n // Auto-scales across price levels (matches the dashboard scanner).\n const legRel = (o) => {\n const m = (o.bid + o.ask) / 2;\n return m > 0 ? (o.ask - o.bid) / m : 1;\n };\n if (Math.max(legRel(sp), legRel(lp)) * 100 > CFG.maxLegBaPct) continue;\n const premiumPct = netCredit / width;\n out.push({\n ticker,\n exp,\n dte,\n price,\n shortStrike: sp.strike,\n longStrike,\n width,\n netCredit,\n premiumPct,\n qualifies: premiumPct >= CFG.minPremPct,\n });\n }\n }\n }\n return out;\n}\n\nasync function sendTelegram(text) {\n const token = env(\"TELEGRAM_BOT_TOKEN\");\n const chat = env(\"TELEGRAM_CHAT_ID\");\n if (!token || !chat) {\n throw new Error(\"Missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID\");\n }\n const res = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chat,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n if (!res.ok) throw new Error(`Telegram ${res.status}: ${await res.text()}`);\n}\n\nexport default async function () {\n const m = marketState();\n if (!CFG.force) {\n if (!m.open) {\n return `Market closed — skipped (${m.et.toLocaleString()} ET).`;\n }\n if (!SCAN_HOURS.includes(m.hour)) {\n return `Off-cadence ${m.hour}:00 ET — skipped.`;\n }\n }\n\n // Prefetch all quotes in batches, day-filter, then deep-scan only the\n // biggest decliners — capped at MAX_TICKERS so huge watchlists can't\n // blow past API rate limits or the val's execution time limit.\n let quoted = 0;\n let candidates = [];\n let prefetchError = null;\n try {\n const quotes = await fetchQuotes(CFG.watchlist);\n candidates = CFG.watchlist.map((t) => ({ t, q: quotes[t] })).filter((\n { q },\n ) => q && q.last);\n quoted = candidates.length;\n if (CFG.dayFilter) {\n candidates = candidates.filter(({ q }) =>\n q.change_percentage !== null && q.change_percentage !== undefined &&\n q.change_percentage <= -CFG.dayDown\n );\n }\n candidates.sort((a, b) =>\n (a.q.change_percentage ?? 0) - (b.q.change_percentage ?? 0)\n );\n } catch (e) {\n prefetchError = e.message;\n console.log(`quote prefetch: ${e.message}`);\n }\n const picks = candidates.slice(0, CFG.maxTickers);\n\n const all = [];\n let errors = 0;\n for (const { t, q } of picks) {\n try {\n all.push(...(await scanTicker(t, q)));\n } catch (e) {\n errors++;\n console.log(`${t}: ${e.message}`);\n }\n }\n\n const qualifying = all.filter((r) => r.qualifies);\n if (!qualifying.length) {\n // Daily heartbeat: on the last scan of the day (16:00 ET) — or a FORCE\n // test run — send a \"nothing found\" summary so a quiet market is\n // distinguishable from a silently broken scanner.\n if (m.hour === 16 || CFG.force) {\n const etStamp = new Date().toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n });\n await sendTelegram(\n `Premium Options — end-of-day scan: 0 qualifying spreads\\n` +\n `${etStamp} ET\\n` +\n `Quoted ${quoted}/${CFG.watchlist.length} tickers, deep-scanned ${picks.length}, ${all.length} spreads priced` +\n (errors\n ? `, ⚠️ ${errors} ticker error${\n errors > 1 ? \"s\" : \"\"\n } — check val logs`\n : \"\") +\n `.` +\n (prefetchError ? `\\n⚠️ Quote prefetch failed: ${prefetchError}` : \"\"),\n );\n return \"No qualifying spreads — heartbeat sent.\";\n }\n console.log(\"No qualifying spreads this run.\");\n return \"No qualifying spreads.\";\n }\n\n qualifying.sort((a, b) => b.premiumPct - a.premiumPct);\n const lines = qualifying.slice(0, 30).map(\n (r) =>\n `• ${r.ticker} ${r.shortStrike}P/${r.longStrike}P · w$${r.width} · ` +\n `${(r.premiumPct * 100).toFixed(1)}% · ${r.exp} (${r.dte}d)`,\n );\n const etStamp = new Date().toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n });\n const msg =\n `Premium Options — ${qualifying.length} qualifying spread${\n qualifying.length > 1 ? \"s\" : \"\"\n }\\n` +\n `${etStamp} ET\\n\\n` +\n lines.join(\"\\n\") +\n (qualifying.length > 30 ? `\\n…+${qualifying.length - 30} more` : \"\");\n\n await sendTelegram(msg);\n return `Sent ${qualifying.length} qualifying spread(s) to Telegram.`;\n}","// ════════════════════════════════════════════════════════════════════\n// Premium Options (formerly TradeOS) — Unattended Cloud Scanner (Val Town cron val)\n// ════════════════════════════════════════════════════════════════════\n// Runs in the cloud on a schedule, independent of your computer.\n// Scans your watchlist for qualifying credit put spreads (same rule as\n// the Premium Options dashboard) and texts the summary to you via Telegram.\n//\n// HOW TO DEPLOY (summary — full steps are in the chat):\n// 1. Create a Telegram bot via @BotFather → copy the BOT TOKEN.\n// 2. Get your numeric chat id (message the bot, then read getUpdates,\n// or use @userinfobot).\n// 3. On val.town: New → Cron val → paste this whole file.\n// 4. Add Environment Variables (Settings → Environment Variables):\n// TRADIER_KEY (required — your Tradier production token)\n// TELEGRAM_BOT_TOKEN (required)\n// TELEGRAM_CHAT_ID (required)\n// Optional overrides (defaults match the dashboard):\n// WATCHLIST, WIDTHS, DTE_MIN, DTE_MAX, OTM_MIN, OTM_MAX,\n// MIN_PREM_PCT, MAX_BID_ASK, DAY_DOWN_PCT, DAY_FILTER,\n// MAX_TICKERS, MAX_EXPS, FORCE\n// 5. Set the cron schedule to: 0 * * * * (every hour)\n// The code itself only does work at 10:00/12:00/14:00/16:00 ET on\n// weekdays while the US market is open — i.e. every ~2 hours.\n// Set FORCE=true to bypass the time gate for a one-off test run.\n// ════════════════════════════════════════════════════════════════════\n\nconst TRADIER = \"https://api.tradier.com/v1\";\n\nfunction env(key, fallback) {\n try {\n const v = Deno.env.get(key);\n return v === undefined || v === null || v === \"\" ? fallback : v;\n } catch {\n return fallback;\n }\n}\n\n// Default watchlist — kept in sync with the dashboard preset by\n// update-watchlist-from-yahoo.sh (re-paste the val after it runs).\n// Override with the WATCHLIST env var. Large lists are fine: quotes are\n// batched, and deep scans are capped at the MAX_TICKERS worst decliners.\nconst DEFAULT_WATCHLIST =\n \"PENG,RELY,FIG,FLY,AUGO,FRMI,XE,Q,MDLN,MBLY,VPG,KEEL,WYFI,TRT,AMPG,VYX,MOD,STX,APH,USAR,KXIAY,UNFI,FLYW,PARR,ICHR,CORT,SNEX,FPS,KO,FLEX,ACHR,GILT,CDNL,TMC,AXTI,TE,SPCX,THLLY,ACM,SHAK,PL,BKSY,LUNR,CGNX,AME,IRDM,ENS,TRRVF,SANM,SIDU,SNPS,FNV,HEI,QBTS,GFS,VST,PRME,SUNB,RSG,RVMD,GTLB,FRSH,ARM,ET,CBRS,CBOE,CRDO,SNDK,HII,CW,BE,FERG,TPC,PRIM,EQT,IONQ,BBAI,FCX,WM,COPX,SOLS,OUST,CP,AMTM,STRL,NOK,TOTDY,RVI,CDRE,GEV,COHR,NXT,GNRC,ROL,XRAY,LZ,PCOR,MRKR,DUOT,MAX,RDW,ALHC,NNN,NFG,MSGS,VSNT,KTOS,DE,SYK,WHD,NI,RBC,HOOD,CRML,RRX,OKE,COLD,CACI,NVO,IREN,OKLO,EME,AVR,WY,AUR,NBIS,BKR,RGTI,WAY,CIFR,CRWV,PPTA,VMC,KNSL,PHR,GSM,PHIN,CRS,MTRN,AMSC,RKLB,SPHR,IBM,A,AA,AAPL,ABBV,ABCB,ABNB,ABR,ABT,ACAD,ACI,ACLS,ACMR,ADBE,ADC,ADDYY,ADI,ADP,ADSK,AFL,AFRM,AGCO,AGM,AGNC,AIT,AKAM,ALAB,ALB,ALGM,ALGN,ALLY,ALNY,ALRM,AMAT,AMBA,AMD,AMKR,AMT,AMZN,ANET,AON,APA,APLD,APO,APOG,APPF,APTV,ARE,ARLP,ASML,ATKR,AVAV,AVGO,AVTR,AWI,AZTA,BABA,BAH,BAM,BBSI,BEP,BHC,BIDU,BILI,BIP,BITO,BITW,BKLC,BL,BLD,BMY,BR,BSM,BSX,BUG,BWA,BWXT,CALX,CAMT,CAT,CCI,CCL,CCOI,CDNA,CDNS,CEG,CEVA,CF,CHE,CHWY,CIEN,CLX,CMG,CMI,CNI,CNSWF,CODI,COHU,COIN,COMP,COST,CPNG,CPRT,CPT,CRAI,CRM,CRSP,CRWD,CSW,CSX,CVX,CWEN,DAR,DDOG,DHI,DHR,DIOD,DIS,DKNG,DLR,DOCN,DOCU,DPZ,DT,DVN,DXCM,DY,EA,EBAY,EDU,EHC,EL,ENB,ENTG,EOLS,EPAM,EPD,EPR,EPRT,EQIX,EQR,ESS,ESTC,ETN,ETSY,EVC,EXE,EXTR,F,FANG,FCPT,FDS,FDX,FIGS,FLGT,FLS,FOUR,FRT,FSLR,FTNT,FVRR,GASS,GD,GE,GGG,GH,GILD,GLBE,GLOB,GMED,GNK,GOOGL,HASI,HCSG,HD,HDB,HLF,HOV,HTGC,HUBS,HWKN,HWM,HYD,PPLI,IDXX,IGOV,IIPR,INMD,INTC,INVH,IP,IPGP,ISRG,ITRI,JCI,JD,JMIA,JNJ,JPM,KEYS,KLAC,KMB,KNSA,KNX,KR,KRT,LAND,LC,LDOS,LEN,LEU,LH,LHX,LITE,LMAT,LMND,LMT,LOB,LPX,LRCX,LUNA,MA,MAIN,MANH,MAR,MARA,MASI,MATX,MCD,MCHP,MDB,MDLZ,MDT,MEDP,MEI,MELI,META,MGA,MGRC,MITK,MKC,MKL,MKSI,MKTX,MLKN,MMM,MOMO,MP,MPWR,MQ,MRK,MRVL,MSCI,MSFT,MSTR,MTCH,MTD,MTH,MTSI,MTZ,MU,MXL,NCNO,NEE,NEM,NET,NFLX,NKE,NLY,NNOX,NOW,NTLA,NUE,NVCR,NVDA,NVMI,NVR,NVS,NVT,NX,NXPI,O,OEC,OKTA,OLED,ON,ONTO,ORCL,ORI,OSCR,OSS,OXY,PAA,PAGP,PANW,PATK,PCG,PD,PEN,PFE,PGNY,PH,PHM,PII,PINE,PINS,PJT,PKX,PLD,PLTR,PODD,POWI,PRG,PRGS,PRLB,PSA,PSX,PUBM,PWR,PYPL,QCOM,QLYS,QQQ,QSR,QYLD,RBLX,RCL,RDNT,REG,RGA,RGNX,RIOT,RKT,RMD,ROK,ROP,RPM,RTX,SBUX,SE,SHLS,SHOP,SIEGY,SIMO,SKT,SLP,SLV,SMCI,SMG,SNA,SNOW,SOFI,SONY,SOUN,SPG,SR,SSD,STAG,STIM,STM,STNE,SU,SUI,SWKS,SXI,SY,SYM,SYNA,T,TCEHY,TDG,TEAM,TEL,TEM,TENB,TER,TGLS,TGT,TLRY,TMFC,TMO,TNXP,TOL,TOST,TREX,TRIP,TRMB,TRUP,TSLA,TSLX,TSM,TTAN,TTC,TTD,TTWO,TUR,TW,TWLO,TXG,TXN,TYL,U,UA,UAA,UBER,UCTT,UI,UNH,UNP,UPST,UPWK,UTMD,V,VAC,VC,VCTR,VEEV,VERI,VKTX,VNO,VOO,VREX,VRT,VRTX,VTR,VXRT,W,WCC,WDAY,WDC,WELL,WEX,WFG,WHF,WIX,WMT,WPC,XIFR,XLC,XYZ,YELP,YEXT,Z,ZM,ZS,ZTO\";\n\nconst CFG = {\n watchlist: env(\"WATCHLIST\", DEFAULT_WATCHLIST)\n .split(\",\").map((s) => s.trim().toUpperCase()).filter(Boolean),\n widths: env(\"WIDTHS\", \"2,5,10,20\").split(\",\").map(Number).filter((w) =>\n w > 0\n ),\n dteMin: +env(\"DTE_MIN\", \"21\"),\n dteMax: +env(\"DTE_MAX\", \"180\"),\n otmMin: +env(\"OTM_MIN\", \"15\") / 100,\n otmMax: +env(\"OTM_MAX\", \"40\") / 100,\n minPremPct: +env(\"MIN_PREM_PCT\", \"28\") / 100,\n maxLegBaPct: +env(\"MAX_LEG_BA_PCT\", \"25\"),\n dayDown: +env(\"DAY_DOWN_PCT\", \"1.0\"),\n dayFilter: env(\"DAY_FILTER\", \"true\") !== \"false\",\n maxTickers: +env(\"MAX_TICKERS\", \"40\"),\n maxExps: +env(\"MAX_EXPS\", \"1\"),\n force: env(\"FORCE\", \"false\") === \"true\",\n};\n\n// US market state in Eastern time (handles DST automatically).\nfunction marketState(now = new Date()) {\n const et = new Date(\n now.toLocaleString(\"en-US\", { timeZone: \"America/New_York\" }),\n );\n const day = et.getDay();\n const mins = et.getHours() * 60 + et.getMinutes();\n const open = day >= 1 && day <= 5 && mins >= 570 && mins < 960; // 9:30–16:00 ET\n return { et, open, hour: et.getHours() };\n}\n\n// Scan only on a clean 2-hour cadence inside market hours.\nconst SCAN_HOURS = [10, 12, 14, 16];\n\nasync function tradier(path, params) {\n const url = new URL(TRADIER + path);\n Object.entries(params || {}).forEach(([k, v]) => url.searchParams.set(k, v));\n const res = await fetch(url.toString(), {\n headers: {\n Authorization: `Bearer ${env(\"TRADIER_KEY\")}`,\n Accept: \"application/json\",\n },\n });\n if (!res.ok) throw new Error(`Tradier ${res.status}: ${path}`);\n return res.json();\n}\n\n// Batched quote prefetch: 1 API call per 100 symbols (vs. 1 per ticker).\nasync function fetchQuotes(symbols) {\n const map = {};\n for (let i = 0; i < symbols.length; i += 100) {\n const batch = symbols.slice(i, i + 100);\n const q = await tradier(\"/markets/quotes\", {\n symbols: batch.join(\",\"),\n greeks: false,\n });\n let quotes = q?.quotes?.quote || [];\n if (!Array.isArray(quotes)) quotes = [quotes];\n for (const qt of quotes) if (qt?.symbol) map[qt.symbol] = qt;\n }\n return map;\n}\n\n// Deep-scan one ticker (quote already fetched in the batched prefetch).\nasync function scanTicker(ticker, quote) {\n const today = new Date();\n const price = quote.last;\n\n const ex = await tradier(\"/markets/options/expirations\", {\n symbol: ticker,\n includeAllRoots: true,\n });\n let exps = ex?.expirations?.date || [];\n if (!Array.isArray(exps)) exps = [exps];\n const valid = exps\n .filter((e) => {\n const d = Math.round((new Date(e) - today) / 86400000);\n return d >= CFG.dteMin && d <= CFG.dteMax;\n })\n .sort((a, b) => new Date(a) - new Date(b))\n .slice(0, CFG.maxExps);\n\n const out = [];\n for (const exp of valid) {\n const dte = Math.round((new Date(exp) - today) / 86400000);\n const ch = await tradier(\"/markets/options/chains\", {\n symbol: ticker,\n expiration: exp,\n greeks: false,\n });\n let opts = ch?.options?.option || [];\n if (!Array.isArray(opts)) opts = [opts];\n const puts = opts.filter((o) =>\n o.option_type === \"put\" && o.bid > 0 && o.ask > 0\n );\n\n for (const width of CFG.widths) {\n const shorts = puts.filter((p) => {\n const otm = (price - p.strike) / price;\n return otm >= CFG.otmMin && otm <= CFG.otmMax;\n });\n for (const sp of shorts) {\n const longStrike = +(sp.strike - width).toFixed(2);\n const lp = puts.find((p) => Math.abs(p.strike - longStrike) < 0.01);\n if (!lp) continue;\n // Net credit at mid-price (matches the dashboard scanner).\n const netCredit = +(((sp.bid + sp.ask) / 2) - ((lp.bid + lp.ask) / 2))\n .toFixed(2);\n if (netCredit <= 0) continue;\n // Liquidity guard: each leg's bid/ask width as a % of its mid price.\n // Auto-scales across price levels (matches the dashboard scanner).\n const legRel = (o) => {\n const m = (o.bid + o.ask) / 2;\n return m > 0 ? (o.ask - o.bid) / m : 1;\n };\n if (Math.max(legRel(sp), legRel(lp)) * 100 > CFG.maxLegBaPct) continue;\n const premiumPct = netCredit / width;\n out.push({\n ticker,\n exp,\n dte,\n price,\n shortStrike: sp.strike,\n longStrike,\n width,\n netCredit,\n premiumPct,\n qualifies: premiumPct >= CFG.minPremPct,\n });\n }\n }\n }\n return out;\n}\n\nasync function sendTelegram(text) {\n const token = env(\"TELEGRAM_BOT_TOKEN\");\n const chat = env(\"TELEGRAM_CHAT_ID\");\n if (!token || !chat) {\n throw new Error(\"Missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID\");\n }\n const res = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chat,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n if (!res.ok) throw new Error(`Telegram ${res.status}: ${await res.text()}`);\n}\n\nexport default async function () {\n const m = marketState();\n if (!CFG.force) {\n if (!m.open) {\n return `Market closed — skipped (${m.et.toLocaleString()} ET).`;\n }\n if (!SCAN_HOURS.includes(m.hour)) {\n return `Off-cadence ${m.hour}:00 ET — skipped.`;\n }\n }\n\n // Prefetch all quotes in batches, day-filter, then deep-scan only the\n // biggest decliners — capped at MAX_TICKERS so huge watchlists can't\n // blow past API rate limits or the val's execution time limit.\n let quoted = 0;\n let candidates = [];\n let prefetchError = null;\n try {\n const quotes = await fetchQuotes(CFG.watchlist);\n candidates = CFG.watchlist.map((t) => ({ t, q: quotes[t] })).filter((\n { q },\n ) => q && q.last);\n quoted = candidates.length;\n if (CFG.dayFilter) {\n candidates = candidates.filter(({ q }) =>\n q.change_percentage !== null && q.change_percentage !== undefined &&\n q.change_percentage <= -CFG.dayDown\n );\n }\n candidates.sort((a, b) =>\n (a.q.change_percentage ?? 0) - (b.q.change_percentage ?? 0)\n );\n } catch (e) {\n prefetchError = e.message;\n console.log(`quote prefetch: ${e.message}`);\n }\n const picks = candidates.slice(0, CFG.maxTickers);\n\n const all = [];\n let errors = 0;\n for (const { t, q } of picks) {\n try {\n all.push(...(await scanTicker(t, q)));\n } catch (e) {\n errors++;\n console.log(`${t}: ${e.message}`);\n }\n }\n\n const qualifying = all.filter((r) => r.qualifies);\n if (!qualifying.length) {\n // Daily heartbeat: on the last scan of the day (16:00 ET) — or a FORCE\n // test run — send a \"nothing found\" summary so a quiet market is\n // distinguishable from a silently broken scanner.\n if (m.hour === 16 || CFG.force) {\n const etStamp = new Date().toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n });\n await sendTelegram(\n `Premium Options — end-of-day scan: 0 qualifying spreads\\n` +\n `${etStamp} ET\\n` +\n `Quoted ${quoted}/${CFG.watchlist.length} tickers, deep-scanned ${picks.length}, ${all.length} spreads priced` +\n (errors\n ? `, ⚠️ ${errors} ticker error${\n errors > 1 ? \"s\" : \"\"\n } — check val logs`\n : \"\") +\n `.` +\n (prefetchError ? `\\n⚠️ Quote prefetch failed: ${prefetchError}` : \"\"),\n );\n return \"No qualifying spreads — heartbeat sent.\";\n }\n console.log(\"No qualifying spreads this run.\");\n return \"No qualifying spreads.\";\n }\n\n qualifying.sort((a, b) => b.premiumPct - a.premiumPct);\n const lines = qualifying.slice(0, 30).map(\n (r) =>\n `• ${r.ticker} ${r.shortStrike}P/${r.longStrike}P · w$${r.width} · ` +\n `${(r.premiumPct * 100).toFixed(1)}% · ${r.exp} (${r.dte}d)`,\n );\n const etStamp = new Date().toLocaleString(\"en-US\", {\n timeZone: \"America/New_York\",\n });\n const msg =\n `Premium Options — ${qualifying.length} qualifying spread${\n qualifying.length > 1 ? \"s\" : \"\"\n }\\n` +\n `${etStamp} ET\\n\\n` +\n lines.join(\"\\n\") +\n (qualifying.length > 30 ? `\\n…+${qualifying.length - 30} more` : \"\");\n\n await sendTelegram(msg);\n return `Sent ${qualifying.length} qualifying spread(s) to Telegram.`;\n}","createdAt",["D",1783640493085],"branchVersion","branchId","ae7deb7d-9729-4e8f-be94-8a824bf4846e","id","bfc3bd2b-5dcb-4932-8f7d-cabcdf5a3517","Premium-Options",["D",1780677074965],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Premium Options","imageUrl","4493a458-ab89-4edc-b378-0d0b5991cfa1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e989e-0f9b-75df-bfd3-24beed5c343f","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Hovito","handle","displayName","Hovsep Iskikian","avatar","https://lh3.googleusercontent.com/a/ACg8ocIPhgoc1Py8IAURV7MsHShIUSskxGN2bV7zcb2FssfM_TN4AfJ4aA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_134":61,"_135":136,"_137":61,"_138":139,"_140":141},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":129,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"619aca6d-2589-4d9a-b464-c271a5620cac","parentId","latest",true,["D",1783640493085],10,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":61},"connections",{"_142":61,"_143":61},"count","unfilledCount",3,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":129,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1783640493085],"children",[],[28],["D",1780677074965],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_122":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":129,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":84,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11