[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_261":262,"_263":264},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":53,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"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":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",73,"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","http_ingest.ts","latestPath","fileId","8b0df644-7faa-11f1-9a9d-1607ee4eb77e","name","fileType","http","content","// http_ingest.ts — endpoint HTTP del val: webhook Telegram (comandi bot),\n// GET /watchlist per il fetcher Mac, POST /ingest_vinted con la pipeline\n// verdetto→lingua→alert (DESIGN.md §cron_vinted, §webhook_telegram).\n// Tutte le dipendenze esterne sono iniettabili per i test.\n\nimport { CONFIG_DEFAULTS, initSchema, type SqliteExecutor } from \"./db.ts\";\nimport {\n assegnaBanda,\n type Banda,\n classificaLingua,\n classificaVersione,\n type Fonte,\n isLotto,\n mediana,\n spedizionePer,\n valuta,\n versioneCoerente,\n versionePiuEconomica,\n} from \"./verdict.ts\";\nimport { validaRiferimento } from \"./verdict.ts\";\nimport {\n fetchPriceGuide as fetchPriceGuideReal,\n fetchProducts as fetchProductsReal,\n type PriceRow,\n type Product,\n resolveCandidates,\n} from \"./refs.ts\";\nimport {\n checkFotoLingua as checkFotoLinguaReal,\n type LinguaFoto,\n} from \"./lang_vision.ts\";\nimport {\n type AnnuncioAlert,\n parseCommand,\n type RefAlert,\n sendAlert,\n sendMsg,\n tgApi,\n} from \"./telegram.ts\";\n\nexport type IngestDeps = {\n sqlite: SqliteExecutor;\n env: {\n TG_TOKEN: string;\n TG_SECRET: string;\n INGEST_SECRET: string;\n TG_CHAT_ID: string;\n };\n tgFetcher?: typeof fetch;\n fetchProducts: () => Promise;\n fetchPriceGuide: () => Promise>;\n checkFotoLingua: (url: string) => Promise;\n adesso: () => string; // ISO, iniettabile nei test\n};\n\nexport type AnnuncioVinted = {\n id: string | number;\n codice: string;\n title: string;\n total_item_price: number;\n url: string;\n photo_url?: string;\n seller_country?: string;\n descrizione?: string;\n};\n\n// std/sqlite di val.town ritorna rows come array di array + columns;\n// node:sqlite (test) ritorna oggetti. Normalizza a oggetti.\nasync function query(\n sq: SqliteExecutor,\n sql: string,\n args: unknown[] = [],\n): Promise[]> {\n const res = await sq.execute({ sql, args }) as {\n rows?: unknown[];\n columns?: string[];\n };\n const rows = res?.rows ?? [];\n if (rows.length > 0 && Array.isArray(rows[0])) {\n const cols = res.columns ?? [];\n return (rows as unknown[][]).map((r) =>\n Object.fromEntries(cols.map((c, i) => [c, r[i]]))\n );\n }\n return rows as Record[];\n}\n\nasync function leggiConfig(\n sq: SqliteExecutor,\n): Promise> {\n const rows = await query(sq, \"SELECT chiave, valore FROM config\");\n const conf: Record = { ...CONFIG_DEFAULTS };\n for (const r of rows) conf[String(r.chiave)] = String(r.valore);\n return conf;\n}\n\n// ---- router ----\n\nexport async function handleRequest(\n req: Request,\n deps: IngestDeps,\n): Promise {\n const path = new URL(req.url).pathname;\n\n if (path.endsWith(\"/telegram\") && req.method === \"POST\") {\n if (\n req.headers.get(\"x-telegram-bot-api-secret-token\") !== deps.env.TG_SECRET\n ) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n await gestisciUpdate(await req.json(), deps);\n return new Response(\"ok\");\n }\n\n const authOk = req.headers.get(\"authorization\") ===\n `Bearer ${deps.env.INGEST_SECRET}`;\n\n if (path.endsWith(\"/watchlist\") && req.method === \"GET\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const rows = await query(\n deps.sqlite,\n \"SELECT codice, auto FROM watchlist WHERE attiva = 1 AND (snooze_until IS NULL OR snooze_until <= ?) ORDER BY codice\",\n [deps.adesso()],\n );\n return Response.json({\n codici: rows.map((r) => r.codice),\n manuali: rows.filter((r) => !r.auto).map((r) => r.codice),\n radar: rows.filter((r) => Boolean(r.auto)).map((r) => r.codice),\n });\n }\n\n // il fetcher Mac non ha il token Telegram: gli errori passano da qui\n // (un solo messaggio dopo 3 fallimenti consecutivi, deduplica sul Mac)\n if (path.endsWith(\"/fetcher_error\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const { testo } = await req.json() as { testo?: string };\n await sendMsg(deps.env.TG_CHAT_ID, testo ?? \"⚠️ Sniper: errore fetcher\", {\n token: deps.env.TG_TOKEN,\n fetcher: deps.tgFetcher,\n });\n return new Response(\"ok\");\n }\n\n // ops: forza l'aggiornamento prezzi/bande senza aspettare il cron notturno\n // (serve al primo avvio del detect v2: le bande nascono qui)\n if (path.endsWith(\"/aggiorna_prezzi\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const { aggiornaPrezzi } = await import(\"./cron_priceguide.ts\");\n const { fetchPriceGuide, fetchProducts, montreLookup } = await import(\n \"./refs.ts\"\n );\n const esito = await aggiornaPrezzi({\n sqlite: deps.sqlite,\n fetchPriceGuide,\n fetchProducts,\n montreLookup,\n adesso: deps.adesso,\n notifica: (testo) =>\n sendMsg(deps.env.TG_CHAT_ID, testo, {\n token: deps.env.TG_TOKEN,\n fetcher: deps.tgFetcher,\n }),\n });\n return Response.json(esito);\n }\n\n // ops: aggiorna le chiavi di config. Serve perché initSchema usa\n // INSERT OR IGNORE: i default cambiati nel codice NON toccano un DB già\n // inizializzato (23/7: radar_n e le soglie radar erano ferme ai valori\n // vecchi da giorni, e il radar restava strozzato a 2 carte).\n if (path.endsWith(\"/config\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const patch = await req.json() as Record;\n for (const [k, v] of Object.entries(patch)) {\n await deps.sqlite.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES (?, ?)\",\n args: [k, String(v)],\n });\n }\n const rows = await query(deps.sqlite, \"SELECT chiave, valore FROM config ORDER BY chiave\");\n return Response.json({ aggiornate: Object.keys(patch), config: rows });\n }\n\n // le carte da leggere su Cardmarket (idProduct della versione tracciata):\n // il lettore giornaliero apre queste pagine e rimanda i minimi a /ingest_cm\n if (path.endsWith(\"/cm_targets\") && req.method === \"GET\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const rows = await query(\n deps.sqlite,\n `SELECT w.codice, w.version, b.id_product, w.nome\n FROM watchlist w JOIN bande b\n ON w.codice = b.codice AND w.version = b.version\n WHERE w.attiva = 1 AND b.id_product IS NOT NULL\n ORDER BY w.codice`,\n );\n return Response.json({ targets: rows });\n }\n\n // minimi Cardmarket EN letti 1×/giorno dal browser (supera Cloudflare)\n if (path.endsWith(\"/ingest_cm\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const righe = await req.json() as Array<{\n id_product: number;\n codice?: string;\n min_en?: number | null;\n min_en_it?: number | null;\n }>;\n const oggi = deps.adesso().slice(0, 10);\n for (const r of righe) {\n await deps.sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO cardmarket (id_product, codice, min_en, min_en_it, data) VALUES (?, ?, ?, ?, ?)\",\n args: [r.id_product, r.codice ?? null, r.min_en ?? null, r.min_en_it ?? null, oggi],\n });\n }\n return Response.json({ scritti: righe.length });\n }\n\n if (path.endsWith(\"/ingest_vinted\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const annunci = await req.json() as AnnuncioVinted[];\n const esiti: string[] = [];\n for (const a of annunci) {\n esiti.push(await processaAnnuncio(a, deps));\n }\n console.log(\"ingest:\", JSON.stringify(esiti));\n return Response.json({ esiti });\n }\n\n return new Response(\"not found\", { status: 404 });\n}\n\n// ---- comandi bot (Task 9) ----\n\nconst VERSIONI = [\"base\", \"v2\", \"manga\"];\n\nasync function gestisciUpdate(update: unknown, deps: IngestDeps) {\n const c = parseCommand(update);\n if (!c) return;\n // solo la chat autorizzata\n if (String(c.chatId) !== String(deps.env.TG_CHAT_ID)) return;\n\n const tg = { token: deps.env.TG_TOKEN, fetcher: deps.tgFetcher };\n const sq = deps.sqlite;\n const rispondi = (testo: string, extra: Record = {}) =>\n sendMsg(c.chatId, testo, tg, extra);\n\n if (c.tipo === \"callback\") {\n const [azione, codice, idProduct, version] = c.data.split(\":\");\n if (azione === \"snooze\") {\n const fino = new Date(Date.parse(deps.adesso()) + 24 * 3600 * 1000)\n .toISOString();\n await sq.execute({\n sql: \"UPDATE watchlist SET snooze_until = ? WHERE codice = ?\",\n args: [fino, codice],\n });\n await tgApi(\"answerCallbackQuery\", {\n callback_query_id: c.callbackQueryId,\n text: `${codice} in pausa 24h`,\n }, tg);\n } else if (azione === \"pick\") {\n await sq.execute({\n sql: \"UPDATE watchlist SET id_product = ?, version = ? WHERE codice = ?\",\n args: [Number(idProduct), version, codice],\n });\n await tgApi(\"answerCallbackQuery\", {\n callback_query_id: c.callbackQueryId,\n text: `${codice} → ${version}`,\n }, tg);\n await rispondi(`✅ ${codice} traccia la versione ${version} (idProduct ${idProduct})`);\n }\n return;\n }\n\n const arg0 = c.args[0]?.toUpperCase();\n\n switch (c.cmd) {\n case \"add\": {\n if (!arg0) return void await rispondi(\"Uso: /add CODICE [max_override]\");\n const maxOverride = c.args[1] != null ? Number(c.args[1]) : null;\n const prodotti = await deps.fetchProducts();\n const candidati = resolveCandidates(arg0, prodotti);\n if (candidati.length === 0) {\n return void await rispondi(`Codice ${arg0} non trovato su Cardmarket`);\n }\n const nome = candidati[0].name.replace(` (${arg0})`, \"\");\n await sq.execute({\n sql:\n \"INSERT OR REPLACE INTO watchlist (codice, nome, version, id_product, max_override, attiva) VALUES (?, ?, ?, ?, ?, 1)\",\n args: [\n arg0,\n nome,\n candidati.length === 1 ? \"base\" : null,\n candidati.length === 1 ? candidati[0].idProduct : null,\n maxOverride,\n ],\n });\n if (candidati.length === 1) {\n return void await rispondi(`✅ ${arg0} ${nome} in watchlist`);\n }\n const guida = await deps.fetchPriceGuide();\n const bottoni = candidati.map((p, i) => {\n const v = VERSIONI[i] ?? `v${i + 1}`;\n const trend = guida.get(p.idProduct)?.trend;\n return [{\n text: `${v}${trend != null ? ` — trend €${trend}` : \"\"}`,\n callback_data: `pick:${arg0}:${p.idProduct}:${v}`,\n }];\n });\n return void await rispondi(\n `${arg0} ${nome}: ${candidati.length} versioni, scegli quale tracciare`,\n { reply_markup: { inline_keyboard: bottoni } },\n );\n }\n case \"remove\": {\n if (!arg0) return void await rispondi(\"Uso: /remove CODICE\");\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE codice = ?\",\n args: [arg0],\n });\n return void await rispondi(`🗑 ${arg0} rimossa`);\n }\n case \"list\": {\n const rows = await query(\n sq,\n \"SELECT codice, nome, version, id_product, max_override, attiva, snooze_until, auto FROM watchlist ORDER BY codice\",\n );\n if (rows.length === 0) return void await rispondi(\"Watchlist vuota\");\n const righe = rows.map((r) => {\n const stato = !r.attiva\n ? \"⏸\"\n : (r.snooze_until && String(r.snooze_until) > deps.adesso())\n ? \"😴\"\n : \"👁\";\n const extra = [\n r.version ? String(r.version) : \"versione da scegliere\",\n r.max_override != null ? `max €${r.max_override}` : null,\n ].filter(Boolean).join(\", \");\n return `${r.auto ? \"🤖\" : stato} ${r.codice} ${r.nome} (${extra})`;\n });\n return void await rispondi(righe.join(\"\\n\"));\n }\n case \"pause\":\n case \"resume\": {\n const attiva = c.cmd === \"resume\" ? 1 : 0;\n if (arg0) {\n await sq.execute({\n sql:\n \"UPDATE watchlist SET attiva = ?, snooze_until = NULL WHERE codice = ?\",\n args: [attiva, arg0],\n });\n } else {\n await sq.execute({\n sql: \"UPDATE watchlist SET attiva = ?, snooze_until = NULL\",\n args: [attiva],\n });\n }\n return void await rispondi(\n `${attiva ? \"▶️ Riattivata\" : \"⏸ In pausa\"}${arg0 ? ` ${arg0}` : \" (tutte)\"}`,\n );\n }\n case \"hot\": {\n const rows = await query(\n sq,\n `SELECT p.codice, p.low, p.avg1, p.avg7 FROM prices p\n WHERE p.hot = 1 AND p.data = (SELECT MAX(data) FROM prices p2 WHERE p2.codice = p.codice)\n ORDER BY p.codice`,\n );\n if (rows.length === 0) return void await rispondi(\"Nessuna carta 🔥 oggi\");\n return void await rispondi(\n rows.map((r) => `🔥 ${r.codice} low €${r.low} (avg1 €${r.avg1} vs avg7 €${r.avg7})`)\n .join(\"\\n\"),\n );\n }\n case \"radar\": {\n const arg = c.args[0]?.toLowerCase();\n if (arg === \"off\") {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_attivo', 'false')\",\n args: [],\n });\n await sq.execute({ sql: \"DELETE FROM watchlist WHERE auto = 1\",\n args: [],\n });\n return void await rispondi(\"📡 Radar spento, voci auto rimosse. Le tue carte restano.\");\n }\n if (arg === \"on\") {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_attivo', 'true')\",\n args: [],\n });\n return void await rispondi(\"📡 Radar acceso: i movers entrano al prossimo cron notturno (05:00)\");\n }\n if (arg && !Number.isNaN(Number(arg))) {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_n', ?)\",\n args: [String(Math.max(1, Math.floor(Number(arg))))],\n });\n return void await rispondi(`📡 Radar: max ${Math.floor(Number(arg))} carte`);\n }\n const conf = await leggiConfig(sq);\n const autoRows = await query(\n sq,\n \"SELECT codice, nome, ultimo_hot FROM watchlist WHERE auto = 1 ORDER BY codice\",\n );\n const stato = conf.radar_attivo === \"true\" ? \"attivo\" : \"spento\";\n const righe = [\n `📡 Radar ${stato} · max ${conf.radar_n} carte · trend min €${conf.radar_trend_min} · scadenza ${conf.radar_scadenza_giorni}gg`,\n ];\n for (const r of autoRows) {\n righe.push(`🤖 ${r.codice} ${r.nome} (dal ${r.ultimo_hot})`);\n }\n if (autoRows.length === 0) righe.push(\"Nessuna carta radar al momento\");\n righe.push(\"Uso: /radar on · /radar off · /radar N\");\n return void await rispondi(righe.join(\"\\n\"));\n }\n case \"stato\": {\n const conf = await leggiConfig(sq);\n const [wl] = await query(sq, \"SELECT COUNT(*) AS n FROM watchlist WHERE attiva = 1\");\n const [sn] = await query(sq, \"SELECT COUNT(*) AS n FROM seen\");\n return void await rispondi(\n [\n `👁 Carte attive: ${wl.n}`,\n `📋 Annunci visti: ${sn.n}`,\n `📈 Ultima Price Guide: ${conf.priceguide_last_ok ?? \"mai\"}`,\n `⚙️ margine ${conf.margine_minimo} | sped ${conf.spedizione_stimata} | hot ${conf.soglia_hot}`,\n ].join(\"\\n\"),\n );\n }\n default:\n return void await rispondi(\n \"Comandi: /add CODICE [max] · /remove CODICE · /list · /pause [CODICE] · /resume [CODICE] · /hot · /radar · /stato\",\n );\n }\n}\n\n// ---- pipeline ingest (Task 10) ----\n\nasync function scriviSeen(\n sq: SqliteExecutor,\n id: string,\n codice: string,\n quando: string,\n) {\n await sq.execute({\n sql: \"INSERT OR IGNORE INTO seen (id_annuncio, codice, notificato_il) VALUES (?, ?, ?)\",\n args: [id, codice, quando],\n });\n}\n\n// Alert fallito → niente seen (riprova al ciclo dopo); dopo 3 tentativi si\n// scrive comunque seen per non ciclare all'infinito (DESIGN.md §Error handling).\nasync function alertConRetry(\n ok: boolean,\n sq: SqliteExecutor,\n id: string,\n codice: string,\n adesso: string,\n): Promise {\n const chiave = `tent:${id}`;\n if (ok) {\n await scriviSeen(sq, id, codice, adesso);\n await sq.execute({\n sql: \"DELETE FROM config WHERE chiave = ?\",\n args: [chiave],\n });\n return \"alert\";\n }\n const rows = await query(\n sq,\n \"SELECT valore FROM config WHERE chiave = ?\",\n [chiave],\n );\n const tentativi = Number(rows[0]?.valore ?? 0) + 1;\n if (tentativi >= 3) {\n console.log(`telegram KO x3 per ${id}, scrivo seen e mollo`);\n await scriviSeen(sq, id, codice, adesso);\n await sq.execute({\n sql: \"DELETE FROM config WHERE chiave = ?\",\n args: [chiave],\n });\n return \"alert_fallito_x3\";\n }\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES (?, ?)\",\n args: [chiave, String(tentativi)],\n });\n return \"alert_fallito_riprova\";\n}\n\nasync function processaAnnuncio(\n a: AnnuncioVinted,\n deps: IngestDeps,\n): Promise {\n const sq = deps.sqlite;\n const id = String(a.id);\n const adesso = deps.adesso();\n const tg = {\n token: deps.env.TG_TOKEN,\n chatId: deps.env.TG_CHAT_ID,\n fetcher: deps.tgFetcher,\n };\n\n // carta attiva e non snoozata?\n const [wl] = await query(\n sq,\n \"SELECT * FROM watchlist WHERE codice = ? AND attiva = 1 AND (snooze_until IS NULL OR snooze_until <= ?)\",\n [a.codice, adesso],\n );\n if (!wl) return \"skip_watchlist\";\n\n const [visto] = await query(\n sq,\n \"SELECT id_annuncio FROM seen WHERE id_annuncio = ?\",\n [id],\n );\n if (visto) return \"skip_seen\";\n\n const conf = await leggiConfig(sq);\n const [pr] = await query(\n sq,\n \"SELECT * FROM prices WHERE codice = ? ORDER BY data DESC LIMIT 1\",\n [a.codice],\n );\n\n const annuncioAlert: AnnuncioAlert = {\n id,\n codice: a.codice,\n title: a.title,\n total_item_price: a.total_item_price,\n url: a.url,\n photo_url: a.photo_url,\n };\n const refAlert: RefAlert = {\n low: pr ? Number(pr.low) : null,\n trend: pr ? Number(pr.trend) : null,\n hot: Boolean(pr?.hot),\n montre_prezzo: pr?.montre_prezzo != null ? Number(pr.montre_prezzo) : null,\n montre_disp: pr?.montre_disp != null ? Boolean(pr.montre_disp) : null,\n };\n\n const radar = Boolean(wl.auto);\n\n // spedizione reale dal paese del venditore (16/7): dal Regno Unito non\n // spediscono in Italia → l'annuncio non è comprabile, si archivia e basta\n const spedizione = spedizionePer(a.seller_country, conf as never);\n if (spedizione === null) {\n console.log(`scarto paese ${a.seller_country} ${id}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_paese\";\n }\n\n // lotto: mai AFFARE, solo 📦 (prezzo non confrontabile)\n if (isLotto(a.title)) {\n const ok = await sendAlert(annuncioAlert, null, refAlert, \"ignoto\", tg, {\n lotto: true,\n radar,\n paese: a.seller_country,\n spedizione,\n });\n return alertConRetry(ok, sq, id, a.codice, adesso);\n }\n\n // ==========================================================================\n // Detect v2 (DESIGN-DETECT-V2, 17/7): l'alert è una CONGIUNZIONE DI PROVE.\n // versione certa ∧ lingua certa ∧ riferimento validato da ≥2 fonti ∧\n // margine sopra soglia. Manca una prova → silenzio, non \"⚠️ verifica tu\"\n // (scelta di Alessandro dopo i 16 alert falsi del 17/7 mattina).\n // ==========================================================================\n\n const versioneAnnuncio = classificaVersione(a.title, a.descrizione ?? \"\");\n\n // Graded (PSA/PCA in slab): di default SPENTE (20/7, scelta di Alessandro).\n // Il bot non ha un prezzo affidabile per le slab (PSA non copre OPTCG, su\n // Cardmarket le graded non sono un dato strutturato) → non può giudicare\n // l'affare, e il riferimento della carta sciolta è solo rumore. Interruttore\n // graded_attive: se riacceso, si segnalano SOLO le EN (una PSA10 Jap non\n // interessa) come 💎 \"valuta a mano\".\n if (versioneAnnuncio === \"graded\") {\n if (conf.graded_attive !== \"true\") {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_graded\";\n }\n const linguaG = classificaLingua(a.title, a.descrizione ?? \"\", a.seller_country ?? \"\");\n if (linguaG === \"SCARTO\") {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"scarto_lingua\";\n }\n const ok = await sendAlert(annuncioAlert, null, refAlert, \"ignoto\", tg, {\n graded: true,\n radar,\n paese: a.seller_country,\n spedizione,\n });\n const esito = await alertConRetry(ok, sq, id, a.codice, adesso);\n return esito === \"alert\" ? \"alert_graded\" : esito;\n }\n\n // ---- S2: bande di prezzo + coorte -----------------------------------\n const bandeRows = await query(\n sq,\n \"SELECT version, trend FROM bande WHERE codice = ?\",\n [a.codice],\n );\n const bande: Banda[] = bandeRows.map((r) => ({\n version: String(r.version),\n trend: r.trend != null ? Number(r.trend) : null,\n }));\n\n // il marker del titolo, tradotto nell'etichetta di versione della watchlist\n const SLOT: Record = { base: \"base\", alt: \"v2\", manga: \"manga\" };\n const slotTitolo = SLOT[versioneAnnuncio] ?? null;\n const maxDist = Number(conf.banda_versione_max ?? 2.5);\n const slotBanda = assegnaBanda(a.total_item_price, bande, maxDist);\n\n // Coorte: il prezzo di OGNI annuncio è mercato vivo (fonte F3), anche di\n // versioni diverse dalla tracciata — alimentano la mediana del loro slot.\n await sq.execute({\n sql:\n \"INSERT OR REPLACE INTO coorte (id_annuncio, codice, prezzo, versione, data) VALUES (?, ?, ?, ?, ?)\",\n args: [\n id,\n a.codice,\n a.total_item_price,\n slotTitolo ?? (slotBanda && slotBanda !== \"anomala\" ? slotBanda : null),\n adesso.slice(0, 10),\n ],\n });\n\n // veto sul marker: il titolo dichiara un'ALTRA versione → il riferimento\n // non descrive questa carta (17/7: \"Rare Englisch\" mentre tracciamo la alt)\n const vc = versioneCoerente(wl.version as string | null, versioneAnnuncio);\n if (!vc.coerente) {\n console.log(`scarto versione ${a.codice}: ${vc.motivo} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione\";\n }\n\n // senza bande non si può provare niente: niente seen, si riprova post-cron\n if (bande.filter((b) => b.trend != null && b.trend > 0).length === 0) {\n return \"skip_no_bande\";\n }\n\n const trackedSlot = String(wl.version ?? \"base\");\n if (slotBanda === \"anomala\") {\n // fuori da ogni banda: l'84% di sconto non esiste, è versione sbagliata\n // o truffa (17/7: base di Shanks a €2,80 in mezzo fra base €0,48 e alt €17)\n console.log(`scarto prezzo anomalo ${a.codice} €${a.total_item_price} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_prezzo_anomalo\";\n }\n if (slotBanda !== null && slotBanda !== trackedSlot) {\n // il prezzo appartiene alla banda di un'altra versione\n console.log(`scarto banda ${a.codice}: €${a.total_item_price} è da ${slotBanda}, tracciamo ${trackedSlot}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione_banda\";\n }\n // se la tracciata NON è la versione più economica del codice, il titolo\n // muto è il canale principale degli alert falsi → serve il marker esplicito\n const richiedeMarker = (versionePiuEconomica(bande) ?? trackedSlot) !== trackedSlot;\n if (richiedeMarker && slotTitolo !== trackedSlot) {\n console.log(`scarto versione non dichiarata ${a.codice} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione_incerta\";\n }\n\n // ---- lingua ------------------------------------------------------------\n // Marcatori non-EN → scarto certo. EN dichiarato → prova.\n // NOVITÀ 23/7: \"nessuna prova\" non è più uno scarto automatico. In Italia\n // moltissimi venditori di carte inglesi NON scrivono \"eng\" (lo danno per\n // scontato): scartarli tutti costava 9 annunci su 42 e quasi tutti gli\n // affari veri. Ora un venditore ITALIANO senza alcun marcatore non-EN è\n // \"EN probabile\" e l'annuncio prosegue — ma la decisione finale si prende\n // DOPO il verdetto, perché lo si segnala solo se l'affare è grosso\n // (margine_pct_incerta): vale la pena aprire la foto solo per quelli.\n const lingua = classificaLingua(\n a.title,\n a.descrizione ?? \"\",\n a.seller_country ?? \"\",\n );\n if (lingua === \"SCARTO\") {\n console.log(`scarto lingua (testo) ${id} ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"scarto_lingua\";\n }\n let linguaDa = \"\";\n if (lingua === \"EN_TESTO\") {\n linguaDa = \"titolo\";\n } else if (conf.vision_attiva === \"true\" && a.photo_url) {\n const esito = await deps.checkFotoLingua(a.photo_url);\n if (esito !== \"en\" && esito !== \"incerto\") {\n console.log(`scarto lingua (foto=${esito}) ${id}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return `scarto_foto_${esito}`;\n }\n if (esito === \"en\") linguaDa = \"foto\";\n }\n // EN non dimostrato: si prosegue solo se il venditore è italiano (mercato\n // di casa, in prevalenza carte EN) e nessun segnale contrario\n const paeseIT = (a.seller_country ?? \"\").toUpperCase() === \"IT\";\n const linguaProbabile = linguaDa === \"\" && paeseIT &&\n conf.lingua_it_probabile !== \"false\";\n if (linguaDa === \"\" && !linguaProbabile) {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_lingua_incerta\";\n }\n\n // ---- S3: il riferimento esiste solo se ≥2 fonti concordano -------------\n if (!pr) return \"skip_no_ref\"; // niente seen: riprova dopo il cron\n\n const rincaro = Number(conf.montre_rincaro ?? 1.35);\n const trendTracked = bande.find((b) => b.version === trackedSlot)?.trend ??\n (pr.trend != null ? Number(pr.trend) : null);\n const fonti: Fonte[] = [];\n // Cardmarket EN: il minimo reale filtrato inglese della versione tracciata\n // (letto 1×/giorno). È la fonte autorevole del valore di rimpiazzo EN —\n // se concorda con un'altra, il riferimento è quello. Preferisci il minimo\n // da venditore IT quando c'è (spedizione bassa, mercato di casa).\n const [cm] = await query(\n sq,\n \"SELECT min_en, min_en_it FROM cardmarket WHERE id_product = ?\",\n [wl.id_product],\n );\n const cmEn = cm?.min_en_it != null\n ? Number(cm.min_en_it)\n : (cm?.min_en != null ? Number(cm.min_en) : null);\n if (cmEn != null && cmEn > 0) {\n fonti.push({ nome: \"Cardmarket EN\", valore: cmEn });\n }\n if (trendTracked != null && trendTracked > 0) {\n fonti.push({ nome: \"trend CM\", valore: trendTracked });\n }\n if (pr.montre_prezzo != null && Number(pr.montre_prezzo) > 0) {\n fonti.push({\n nome: \"Montre÷\" + rincaro,\n valore: Math.round((Number(pr.montre_prezzo) / rincaro) * 100) / 100,\n });\n }\n const giorniCoorte = Number(conf.coorte_giorni ?? 7);\n const dataMin = new Date(Date.parse(adesso) - giorniCoorte * 24 * 3600 * 1000)\n .toISOString().slice(0, 10);\n const campioni = await query(\n sq,\n \"SELECT prezzo FROM coorte WHERE codice = ? AND versione = ? AND data >= ? AND id_annuncio != ?\",\n [a.codice, trackedSlot, dataMin, id],\n );\n if (campioni.length >= Number(conf.coorte_min ?? 3)) {\n const med = mediana(campioni.map((r) => Number(r.prezzo)));\n if (med != null && med > 0) {\n fonti.push({ nome: `coorte Vinted (${campioni.length})`, valore: med });\n }\n }\n const val = validaRiferimento(fonti, Number(conf.fonti_max_div ?? 1.6));\n if (!val.valido) {\n console.log(`rif. non validato ${a.codice}: ${val.motivo}`);\n return \"skip_rif_non_validato\"; // niente seen: coorte e cron migliorano\n }\n\n // ---- S4: verdetto ------------------------------------------------------\n const verdetto = valuta(\n { total_item_price: a.total_item_price },\n {\n low: val.rif!,\n hot: Boolean(pr.hot),\n max_override: wl.max_override != null ? Number(wl.max_override) : null,\n },\n conf as {\n margine_minimo: string;\n margine_pct: string;\n moltiplicatore_hot: string;\n spedizione_stimata: string;\n },\n spedizione,\n );\n if (!verdetto.affare) {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"no_affare\";\n }\n\n // lingua solo probabile (venditore IT, EN non dichiarato): si segnala\n // soltanto se lo sconto è ampio — per un affare grosso vale la pena aprire\n // la foto, per un margine risicato no (23/7)\n if (linguaDa === \"\") {\n const scontoPct = verdetto.riferimento > 0\n ? 1 - verdetto.costo / verdetto.riferimento\n : 0;\n const soglia = Number(conf.margine_pct_incerta ?? 0.3);\n if (scontoPct < soglia) {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_lingua_incerta\";\n }\n linguaDa = \"venditore IT (da confermare dalla foto)\";\n }\n\n // ---- S5: 🎯 con le prove stampate --------------------------------------\n const ok = await sendAlert(annuncioAlert, verdetto, refAlert, \"en\", tg, {\n radar,\n paese: a.seller_country,\n spedizione,\n prove: {\n rif: val.rif!,\n fonti: val.usate,\n versione: richiedeMarker ? \"dichiarata nel titolo + banda prezzo\" : \"banda prezzo\",\n lingua: linguaDa,\n },\n });\n return alertConRetry(ok, sq, id, a.codice, adesso);\n}\n\n// ---- entrypoint val.town (HTTP trigger) ----\n\nlet schemaPronto = false;\n\nexport default async function (req: Request): Promise {\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n if (!schemaPronto) {\n await initSchema(sqlite);\n schemaPronto = true;\n }\n return handleRequest(req, {\n sqlite,\n env: {\n TG_TOKEN: Deno.env.get(\"TG_TOKEN\") ?? \"\",\n TG_SECRET: Deno.env.get(\"TG_SECRET\") ?? \"\",\n INGEST_SECRET: Deno.env.get(\"INGEST_SECRET\") ?? \"\",\n TG_CHAT_ID: Deno.env.get(\"TG_CHAT_ID\") ?? \"\",\n },\n fetchProducts: fetchProductsReal,\n fetchPriceGuide: fetchPriceGuideReal,\n checkFotoLingua: checkFotoLinguaReal,\n adesso: () => new Date().toISOString(),\n });\n}\n","// http_ingest.ts — endpoint HTTP del val: webhook Telegram (comandi bot),\n// GET /watchlist per il fetcher Mac, POST /ingest_vinted con la pipeline\n// verdetto→lingua→alert (DESIGN.md §cron_vinted, §webhook_telegram).\n// Tutte le dipendenze esterne sono iniettabili per i test.\n\nimport { CONFIG_DEFAULTS, initSchema, type SqliteExecutor } from \"./db.ts\";\nimport {\n assegnaBanda,\n type Banda,\n classificaLingua,\n classificaVersione,\n type Fonte,\n isLotto,\n mediana,\n spedizionePer,\n valuta,\n versioneCoerente,\n versionePiuEconomica,\n} from \"./verdict.ts\";\nimport { validaRiferimento } from \"./verdict.ts\";\nimport {\n fetchPriceGuide as fetchPriceGuideReal,\n fetchProducts as fetchProductsReal,\n type PriceRow,\n type Product,\n resolveCandidates,\n} from \"./refs.ts\";\nimport {\n checkFotoLingua as checkFotoLinguaReal,\n type LinguaFoto,\n} from \"./lang_vision.ts\";\nimport {\n type AnnuncioAlert,\n parseCommand,\n type RefAlert,\n sendAlert,\n sendMsg,\n tgApi,\n} from \"./telegram.ts\";\n\nexport type IngestDeps = {\n sqlite: SqliteExecutor;\n env: {\n TG_TOKEN: string;\n TG_SECRET: string;\n INGEST_SECRET: string;\n TG_CHAT_ID: string;\n };\n tgFetcher?: typeof fetch;\n fetchProducts: () => Promise;\n fetchPriceGuide: () => Promise>;\n checkFotoLingua: (url: string) => Promise;\n adesso: () => string; // ISO, iniettabile nei test\n};\n\nexport type AnnuncioVinted = {\n id: string | number;\n codice: string;\n title: string;\n total_item_price: number;\n url: string;\n photo_url?: string;\n seller_country?: string;\n descrizione?: string;\n};\n\n// std/sqlite di val.town ritorna rows come array di array + columns;\n// node:sqlite (test) ritorna oggetti. Normalizza a oggetti.\nasync function query(\n sq: SqliteExecutor,\n sql: string,\n args: unknown[] = [],\n): Promise[]> {\n const res = await sq.execute({ sql, args }) as {\n rows?: unknown[];\n columns?: string[];\n };\n const rows = res?.rows ?? [];\n if (rows.length > 0 && Array.isArray(rows[0])) {\n const cols = res.columns ?? [];\n return (rows as unknown[][]).map((r) =>\n Object.fromEntries(cols.map((c, i) => [c, r[i]]))\n );\n }\n return rows as Record[];\n}\n\nasync function leggiConfig(\n sq: SqliteExecutor,\n): Promise> {\n const rows = await query(sq, \"SELECT chiave, valore FROM config\");\n const conf: Record = { ...CONFIG_DEFAULTS };\n for (const r of rows) conf[String(r.chiave)] = String(r.valore);\n return conf;\n}\n\n// ---- router ----\n\nexport async function handleRequest(\n req: Request,\n deps: IngestDeps,\n): Promise {\n const path = new URL(req.url).pathname;\n\n if (path.endsWith(\"/telegram\") && req.method === \"POST\") {\n if (\n req.headers.get(\"x-telegram-bot-api-secret-token\") !== deps.env.TG_SECRET\n ) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n await gestisciUpdate(await req.json(), deps);\n return new Response(\"ok\");\n }\n\n const authOk = req.headers.get(\"authorization\") ===\n `Bearer ${deps.env.INGEST_SECRET}`;\n\n if (path.endsWith(\"/watchlist\") && req.method === \"GET\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const rows = await query(\n deps.sqlite,\n \"SELECT codice, auto FROM watchlist WHERE attiva = 1 AND (snooze_until IS NULL OR snooze_until <= ?) ORDER BY codice\",\n [deps.adesso()],\n );\n return Response.json({\n codici: rows.map((r) => r.codice),\n manuali: rows.filter((r) => !r.auto).map((r) => r.codice),\n radar: rows.filter((r) => Boolean(r.auto)).map((r) => r.codice),\n });\n }\n\n // il fetcher Mac non ha il token Telegram: gli errori passano da qui\n // (un solo messaggio dopo 3 fallimenti consecutivi, deduplica sul Mac)\n if (path.endsWith(\"/fetcher_error\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const { testo } = await req.json() as { testo?: string };\n await sendMsg(deps.env.TG_CHAT_ID, testo ?? \"⚠️ Sniper: errore fetcher\", {\n token: deps.env.TG_TOKEN,\n fetcher: deps.tgFetcher,\n });\n return new Response(\"ok\");\n }\n\n // ops: forza l'aggiornamento prezzi/bande senza aspettare il cron notturno\n // (serve al primo avvio del detect v2: le bande nascono qui)\n if (path.endsWith(\"/aggiorna_prezzi\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const { aggiornaPrezzi } = await import(\"./cron_priceguide.ts\");\n const { fetchPriceGuide, fetchProducts, montreLookup } = await import(\n \"./refs.ts\"\n );\n const esito = await aggiornaPrezzi({\n sqlite: deps.sqlite,\n fetchPriceGuide,\n fetchProducts,\n montreLookup,\n adesso: deps.adesso,\n notifica: (testo) =>\n sendMsg(deps.env.TG_CHAT_ID, testo, {\n token: deps.env.TG_TOKEN,\n fetcher: deps.tgFetcher,\n }),\n });\n return Response.json(esito);\n }\n\n // ops: aggiorna le chiavi di config. Serve perché initSchema usa\n // INSERT OR IGNORE: i default cambiati nel codice NON toccano un DB già\n // inizializzato (23/7: radar_n e le soglie radar erano ferme ai valori\n // vecchi da giorni, e il radar restava strozzato a 2 carte).\n if (path.endsWith(\"/config\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const patch = await req.json() as Record;\n for (const [k, v] of Object.entries(patch)) {\n await deps.sqlite.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES (?, ?)\",\n args: [k, String(v)],\n });\n }\n const rows = await query(deps.sqlite, \"SELECT chiave, valore FROM config ORDER BY chiave\");\n return Response.json({ aggiornate: Object.keys(patch), config: rows });\n }\n\n // le carte da leggere su Cardmarket (idProduct della versione tracciata):\n // il lettore giornaliero apre queste pagine e rimanda i minimi a /ingest_cm\n if (path.endsWith(\"/cm_targets\") && req.method === \"GET\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const rows = await query(\n deps.sqlite,\n `SELECT w.codice, w.version, b.id_product, w.nome\n FROM watchlist w JOIN bande b\n ON w.codice = b.codice AND w.version = b.version\n WHERE w.attiva = 1 AND b.id_product IS NOT NULL\n ORDER BY w.codice`,\n );\n return Response.json({ targets: rows });\n }\n\n // minimi Cardmarket EN letti 1×/giorno dal browser (supera Cloudflare)\n if (path.endsWith(\"/ingest_cm\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const righe = await req.json() as Array<{\n id_product: number;\n codice?: string;\n min_en?: number | null;\n min_en_it?: number | null;\n }>;\n const oggi = deps.adesso().slice(0, 10);\n for (const r of righe) {\n await deps.sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO cardmarket (id_product, codice, min_en, min_en_it, data) VALUES (?, ?, ?, ?, ?)\",\n args: [r.id_product, r.codice ?? null, r.min_en ?? null, r.min_en_it ?? null, oggi],\n });\n }\n return Response.json({ scritti: righe.length });\n }\n\n if (path.endsWith(\"/ingest_vinted\") && req.method === \"POST\") {\n if (!authOk) return new Response(\"unauthorized\", { status: 401 });\n const annunci = await req.json() as AnnuncioVinted[];\n const esiti: string[] = [];\n for (const a of annunci) {\n esiti.push(await processaAnnuncio(a, deps));\n }\n console.log(\"ingest:\", JSON.stringify(esiti));\n return Response.json({ esiti });\n }\n\n return new Response(\"not found\", { status: 404 });\n}\n\n// ---- comandi bot (Task 9) ----\n\nconst VERSIONI = [\"base\", \"v2\", \"manga\"];\n\nasync function gestisciUpdate(update: unknown, deps: IngestDeps) {\n const c = parseCommand(update);\n if (!c) return;\n // solo la chat autorizzata\n if (String(c.chatId) !== String(deps.env.TG_CHAT_ID)) return;\n\n const tg = { token: deps.env.TG_TOKEN, fetcher: deps.tgFetcher };\n const sq = deps.sqlite;\n const rispondi = (testo: string, extra: Record = {}) =>\n sendMsg(c.chatId, testo, tg, extra);\n\n if (c.tipo === \"callback\") {\n const [azione, codice, idProduct, version] = c.data.split(\":\");\n if (azione === \"snooze\") {\n const fino = new Date(Date.parse(deps.adesso()) + 24 * 3600 * 1000)\n .toISOString();\n await sq.execute({\n sql: \"UPDATE watchlist SET snooze_until = ? WHERE codice = ?\",\n args: [fino, codice],\n });\n await tgApi(\"answerCallbackQuery\", {\n callback_query_id: c.callbackQueryId,\n text: `${codice} in pausa 24h`,\n }, tg);\n } else if (azione === \"pick\") {\n await sq.execute({\n sql: \"UPDATE watchlist SET id_product = ?, version = ? WHERE codice = ?\",\n args: [Number(idProduct), version, codice],\n });\n await tgApi(\"answerCallbackQuery\", {\n callback_query_id: c.callbackQueryId,\n text: `${codice} → ${version}`,\n }, tg);\n await rispondi(`✅ ${codice} traccia la versione ${version} (idProduct ${idProduct})`);\n }\n return;\n }\n\n const arg0 = c.args[0]?.toUpperCase();\n\n switch (c.cmd) {\n case \"add\": {\n if (!arg0) return void await rispondi(\"Uso: /add CODICE [max_override]\");\n const maxOverride = c.args[1] != null ? Number(c.args[1]) : null;\n const prodotti = await deps.fetchProducts();\n const candidati = resolveCandidates(arg0, prodotti);\n if (candidati.length === 0) {\n return void await rispondi(`Codice ${arg0} non trovato su Cardmarket`);\n }\n const nome = candidati[0].name.replace(` (${arg0})`, \"\");\n await sq.execute({\n sql:\n \"INSERT OR REPLACE INTO watchlist (codice, nome, version, id_product, max_override, attiva) VALUES (?, ?, ?, ?, ?, 1)\",\n args: [\n arg0,\n nome,\n candidati.length === 1 ? \"base\" : null,\n candidati.length === 1 ? candidati[0].idProduct : null,\n maxOverride,\n ],\n });\n if (candidati.length === 1) {\n return void await rispondi(`✅ ${arg0} ${nome} in watchlist`);\n }\n const guida = await deps.fetchPriceGuide();\n const bottoni = candidati.map((p, i) => {\n const v = VERSIONI[i] ?? `v${i + 1}`;\n const trend = guida.get(p.idProduct)?.trend;\n return [{\n text: `${v}${trend != null ? ` — trend €${trend}` : \"\"}`,\n callback_data: `pick:${arg0}:${p.idProduct}:${v}`,\n }];\n });\n return void await rispondi(\n `${arg0} ${nome}: ${candidati.length} versioni, scegli quale tracciare`,\n { reply_markup: { inline_keyboard: bottoni } },\n );\n }\n case \"remove\": {\n if (!arg0) return void await rispondi(\"Uso: /remove CODICE\");\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE codice = ?\",\n args: [arg0],\n });\n return void await rispondi(`🗑 ${arg0} rimossa`);\n }\n case \"list\": {\n const rows = await query(\n sq,\n \"SELECT codice, nome, version, id_product, max_override, attiva, snooze_until, auto FROM watchlist ORDER BY codice\",\n );\n if (rows.length === 0) return void await rispondi(\"Watchlist vuota\");\n const righe = rows.map((r) => {\n const stato = !r.attiva\n ? \"⏸\"\n : (r.snooze_until && String(r.snooze_until) > deps.adesso())\n ? \"😴\"\n : \"👁\";\n const extra = [\n r.version ? String(r.version) : \"versione da scegliere\",\n r.max_override != null ? `max €${r.max_override}` : null,\n ].filter(Boolean).join(\", \");\n return `${r.auto ? \"🤖\" : stato} ${r.codice} ${r.nome} (${extra})`;\n });\n return void await rispondi(righe.join(\"\\n\"));\n }\n case \"pause\":\n case \"resume\": {\n const attiva = c.cmd === \"resume\" ? 1 : 0;\n if (arg0) {\n await sq.execute({\n sql:\n \"UPDATE watchlist SET attiva = ?, snooze_until = NULL WHERE codice = ?\",\n args: [attiva, arg0],\n });\n } else {\n await sq.execute({\n sql: \"UPDATE watchlist SET attiva = ?, snooze_until = NULL\",\n args: [attiva],\n });\n }\n return void await rispondi(\n `${attiva ? \"▶️ Riattivata\" : \"⏸ In pausa\"}${arg0 ? ` ${arg0}` : \" (tutte)\"}`,\n );\n }\n case \"hot\": {\n const rows = await query(\n sq,\n `SELECT p.codice, p.low, p.avg1, p.avg7 FROM prices p\n WHERE p.hot = 1 AND p.data = (SELECT MAX(data) FROM prices p2 WHERE p2.codice = p.codice)\n ORDER BY p.codice`,\n );\n if (rows.length === 0) return void await rispondi(\"Nessuna carta 🔥 oggi\");\n return void await rispondi(\n rows.map((r) => `🔥 ${r.codice} low €${r.low} (avg1 €${r.avg1} vs avg7 €${r.avg7})`)\n .join(\"\\n\"),\n );\n }\n case \"radar\": {\n const arg = c.args[0]?.toLowerCase();\n if (arg === \"off\") {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_attivo', 'false')\",\n args: [],\n });\n await sq.execute({ sql: \"DELETE FROM watchlist WHERE auto = 1\",\n args: [],\n });\n return void await rispondi(\"📡 Radar spento, voci auto rimosse. Le tue carte restano.\");\n }\n if (arg === \"on\") {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_attivo', 'true')\",\n args: [],\n });\n return void await rispondi(\"📡 Radar acceso: i movers entrano al prossimo cron notturno (05:00)\");\n }\n if (arg && !Number.isNaN(Number(arg))) {\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('radar_n', ?)\",\n args: [String(Math.max(1, Math.floor(Number(arg))))],\n });\n return void await rispondi(`📡 Radar: max ${Math.floor(Number(arg))} carte`);\n }\n const conf = await leggiConfig(sq);\n const autoRows = await query(\n sq,\n \"SELECT codice, nome, ultimo_hot FROM watchlist WHERE auto = 1 ORDER BY codice\",\n );\n const stato = conf.radar_attivo === \"true\" ? \"attivo\" : \"spento\";\n const righe = [\n `📡 Radar ${stato} · max ${conf.radar_n} carte · trend min €${conf.radar_trend_min} · scadenza ${conf.radar_scadenza_giorni}gg`,\n ];\n for (const r of autoRows) {\n righe.push(`🤖 ${r.codice} ${r.nome} (dal ${r.ultimo_hot})`);\n }\n if (autoRows.length === 0) righe.push(\"Nessuna carta radar al momento\");\n righe.push(\"Uso: /radar on · /radar off · /radar N\");\n return void await rispondi(righe.join(\"\\n\"));\n }\n case \"stato\": {\n const conf = await leggiConfig(sq);\n const [wl] = await query(sq, \"SELECT COUNT(*) AS n FROM watchlist WHERE attiva = 1\");\n const [sn] = await query(sq, \"SELECT COUNT(*) AS n FROM seen\");\n return void await rispondi(\n [\n `👁 Carte attive: ${wl.n}`,\n `📋 Annunci visti: ${sn.n}`,\n `📈 Ultima Price Guide: ${conf.priceguide_last_ok ?? \"mai\"}`,\n `⚙️ margine ${conf.margine_minimo} | sped ${conf.spedizione_stimata} | hot ${conf.soglia_hot}`,\n ].join(\"\\n\"),\n );\n }\n default:\n return void await rispondi(\n \"Comandi: /add CODICE [max] · /remove CODICE · /list · /pause [CODICE] · /resume [CODICE] · /hot · /radar · /stato\",\n );\n }\n}\n\n// ---- pipeline ingest (Task 10) ----\n\nasync function scriviSeen(\n sq: SqliteExecutor,\n id: string,\n codice: string,\n quando: string,\n) {\n await sq.execute({\n sql: \"INSERT OR IGNORE INTO seen (id_annuncio, codice, notificato_il) VALUES (?, ?, ?)\",\n args: [id, codice, quando],\n });\n}\n\n// Alert fallito → niente seen (riprova al ciclo dopo); dopo 3 tentativi si\n// scrive comunque seen per non ciclare all'infinito (DESIGN.md §Error handling).\nasync function alertConRetry(\n ok: boolean,\n sq: SqliteExecutor,\n id: string,\n codice: string,\n adesso: string,\n): Promise {\n const chiave = `tent:${id}`;\n if (ok) {\n await scriviSeen(sq, id, codice, adesso);\n await sq.execute({\n sql: \"DELETE FROM config WHERE chiave = ?\",\n args: [chiave],\n });\n return \"alert\";\n }\n const rows = await query(\n sq,\n \"SELECT valore FROM config WHERE chiave = ?\",\n [chiave],\n );\n const tentativi = Number(rows[0]?.valore ?? 0) + 1;\n if (tentativi >= 3) {\n console.log(`telegram KO x3 per ${id}, scrivo seen e mollo`);\n await scriviSeen(sq, id, codice, adesso);\n await sq.execute({\n sql: \"DELETE FROM config WHERE chiave = ?\",\n args: [chiave],\n });\n return \"alert_fallito_x3\";\n }\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES (?, ?)\",\n args: [chiave, String(tentativi)],\n });\n return \"alert_fallito_riprova\";\n}\n\nasync function processaAnnuncio(\n a: AnnuncioVinted,\n deps: IngestDeps,\n): Promise {\n const sq = deps.sqlite;\n const id = String(a.id);\n const adesso = deps.adesso();\n const tg = {\n token: deps.env.TG_TOKEN,\n chatId: deps.env.TG_CHAT_ID,\n fetcher: deps.tgFetcher,\n };\n\n // carta attiva e non snoozata?\n const [wl] = await query(\n sq,\n \"SELECT * FROM watchlist WHERE codice = ? AND attiva = 1 AND (snooze_until IS NULL OR snooze_until <= ?)\",\n [a.codice, adesso],\n );\n if (!wl) return \"skip_watchlist\";\n\n const [visto] = await query(\n sq,\n \"SELECT id_annuncio FROM seen WHERE id_annuncio = ?\",\n [id],\n );\n if (visto) return \"skip_seen\";\n\n const conf = await leggiConfig(sq);\n const [pr] = await query(\n sq,\n \"SELECT * FROM prices WHERE codice = ? ORDER BY data DESC LIMIT 1\",\n [a.codice],\n );\n\n const annuncioAlert: AnnuncioAlert = {\n id,\n codice: a.codice,\n title: a.title,\n total_item_price: a.total_item_price,\n url: a.url,\n photo_url: a.photo_url,\n };\n const refAlert: RefAlert = {\n low: pr ? Number(pr.low) : null,\n trend: pr ? Number(pr.trend) : null,\n hot: Boolean(pr?.hot),\n montre_prezzo: pr?.montre_prezzo != null ? Number(pr.montre_prezzo) : null,\n montre_disp: pr?.montre_disp != null ? Boolean(pr.montre_disp) : null,\n };\n\n const radar = Boolean(wl.auto);\n\n // spedizione reale dal paese del venditore (16/7): dal Regno Unito non\n // spediscono in Italia → l'annuncio non è comprabile, si archivia e basta\n const spedizione = spedizionePer(a.seller_country, conf as never);\n if (spedizione === null) {\n console.log(`scarto paese ${a.seller_country} ${id}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_paese\";\n }\n\n // lotto: mai AFFARE, solo 📦 (prezzo non confrontabile)\n if (isLotto(a.title)) {\n const ok = await sendAlert(annuncioAlert, null, refAlert, \"ignoto\", tg, {\n lotto: true,\n radar,\n paese: a.seller_country,\n spedizione,\n });\n return alertConRetry(ok, sq, id, a.codice, adesso);\n }\n\n // ==========================================================================\n // Detect v2 (DESIGN-DETECT-V2, 17/7): l'alert è una CONGIUNZIONE DI PROVE.\n // versione certa ∧ lingua certa ∧ riferimento validato da ≥2 fonti ∧\n // margine sopra soglia. Manca una prova → silenzio, non \"⚠️ verifica tu\"\n // (scelta di Alessandro dopo i 16 alert falsi del 17/7 mattina).\n // ==========================================================================\n\n const versioneAnnuncio = classificaVersione(a.title, a.descrizione ?? \"\");\n\n // Graded (PSA/PCA in slab): di default SPENTE (20/7, scelta di Alessandro).\n // Il bot non ha un prezzo affidabile per le slab (PSA non copre OPTCG, su\n // Cardmarket le graded non sono un dato strutturato) → non può giudicare\n // l'affare, e il riferimento della carta sciolta è solo rumore. Interruttore\n // graded_attive: se riacceso, si segnalano SOLO le EN (una PSA10 Jap non\n // interessa) come 💎 \"valuta a mano\".\n if (versioneAnnuncio === \"graded\") {\n if (conf.graded_attive !== \"true\") {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_graded\";\n }\n const linguaG = classificaLingua(a.title, a.descrizione ?? \"\", a.seller_country ?? \"\");\n if (linguaG === \"SCARTO\") {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"scarto_lingua\";\n }\n const ok = await sendAlert(annuncioAlert, null, refAlert, \"ignoto\", tg, {\n graded: true,\n radar,\n paese: a.seller_country,\n spedizione,\n });\n const esito = await alertConRetry(ok, sq, id, a.codice, adesso);\n return esito === \"alert\" ? \"alert_graded\" : esito;\n }\n\n // ---- S2: bande di prezzo + coorte -----------------------------------\n const bandeRows = await query(\n sq,\n \"SELECT version, trend FROM bande WHERE codice = ?\",\n [a.codice],\n );\n const bande: Banda[] = bandeRows.map((r) => ({\n version: String(r.version),\n trend: r.trend != null ? Number(r.trend) : null,\n }));\n\n // il marker del titolo, tradotto nell'etichetta di versione della watchlist\n const SLOT: Record = { base: \"base\", alt: \"v2\", manga: \"manga\" };\n const slotTitolo = SLOT[versioneAnnuncio] ?? null;\n const maxDist = Number(conf.banda_versione_max ?? 2.5);\n const slotBanda = assegnaBanda(a.total_item_price, bande, maxDist);\n\n // Coorte: il prezzo di OGNI annuncio è mercato vivo (fonte F3), anche di\n // versioni diverse dalla tracciata — alimentano la mediana del loro slot.\n await sq.execute({\n sql:\n \"INSERT OR REPLACE INTO coorte (id_annuncio, codice, prezzo, versione, data) VALUES (?, ?, ?, ?, ?)\",\n args: [\n id,\n a.codice,\n a.total_item_price,\n slotTitolo ?? (slotBanda && slotBanda !== \"anomala\" ? slotBanda : null),\n adesso.slice(0, 10),\n ],\n });\n\n // veto sul marker: il titolo dichiara un'ALTRA versione → il riferimento\n // non descrive questa carta (17/7: \"Rare Englisch\" mentre tracciamo la alt)\n const vc = versioneCoerente(wl.version as string | null, versioneAnnuncio);\n if (!vc.coerente) {\n console.log(`scarto versione ${a.codice}: ${vc.motivo} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione\";\n }\n\n // senza bande non si può provare niente: niente seen, si riprova post-cron\n if (bande.filter((b) => b.trend != null && b.trend > 0).length === 0) {\n return \"skip_no_bande\";\n }\n\n const trackedSlot = String(wl.version ?? \"base\");\n if (slotBanda === \"anomala\") {\n // fuori da ogni banda: l'84% di sconto non esiste, è versione sbagliata\n // o truffa (17/7: base di Shanks a €2,80 in mezzo fra base €0,48 e alt €17)\n console.log(`scarto prezzo anomalo ${a.codice} €${a.total_item_price} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_prezzo_anomalo\";\n }\n if (slotBanda !== null && slotBanda !== trackedSlot) {\n // il prezzo appartiene alla banda di un'altra versione\n console.log(`scarto banda ${a.codice}: €${a.total_item_price} è da ${slotBanda}, tracciamo ${trackedSlot}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione_banda\";\n }\n // se la tracciata NON è la versione più economica del codice, il titolo\n // muto è il canale principale degli alert falsi → serve il marker esplicito\n const richiedeMarker = (versionePiuEconomica(bande) ?? trackedSlot) !== trackedSlot;\n if (richiedeMarker && slotTitolo !== trackedSlot) {\n console.log(`scarto versione non dichiarata ${a.codice} — ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_versione_incerta\";\n }\n\n // ---- lingua ------------------------------------------------------------\n // Marcatori non-EN → scarto certo. EN dichiarato → prova.\n // NOVITÀ 23/7: \"nessuna prova\" non è più uno scarto automatico. In Italia\n // moltissimi venditori di carte inglesi NON scrivono \"eng\" (lo danno per\n // scontato): scartarli tutti costava 9 annunci su 42 e quasi tutti gli\n // affari veri. Ora un venditore ITALIANO senza alcun marcatore non-EN è\n // \"EN probabile\" e l'annuncio prosegue — ma la decisione finale si prende\n // DOPO il verdetto, perché lo si segnala solo se l'affare è grosso\n // (margine_pct_incerta): vale la pena aprire la foto solo per quelli.\n const lingua = classificaLingua(\n a.title,\n a.descrizione ?? \"\",\n a.seller_country ?? \"\",\n );\n if (lingua === \"SCARTO\") {\n console.log(`scarto lingua (testo) ${id} ${a.title}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return \"scarto_lingua\";\n }\n let linguaDa = \"\";\n if (lingua === \"EN_TESTO\") {\n linguaDa = \"titolo\";\n } else if (conf.vision_attiva === \"true\" && a.photo_url) {\n const esito = await deps.checkFotoLingua(a.photo_url);\n if (esito !== \"en\" && esito !== \"incerto\") {\n console.log(`scarto lingua (foto=${esito}) ${id}`);\n await scriviSeen(sq, id, a.codice, adesso);\n return `scarto_foto_${esito}`;\n }\n if (esito === \"en\") linguaDa = \"foto\";\n }\n // EN non dimostrato: si prosegue solo se il venditore è italiano (mercato\n // di casa, in prevalenza carte EN) e nessun segnale contrario\n const paese = (a.seller_country ?? \"\").trim().toUpperCase();\n const paeseIT = paese === \"IT\";\n const linguaProbabile = linguaDa === \"\" && paeseIT &&\n conf.lingua_it_probabile !== \"false\";\n if (linguaDa === \"\" && !linguaProbabile) {\n // paese ANCORA IGNOTO: il fetcher risolve i profili a scaglioni (tetto\n // per ciclo), quindi al primo passaggio molti annunci non hanno il paese.\n // Scriverli in `seen` li condannerebbe per sempre: senza paese non si può\n // decidere, si riprova al ciclo dopo (23/7).\n if (!paese) return \"skip_paese_ignoto\";\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_lingua_incerta\";\n }\n\n // ---- S3: il riferimento esiste solo se ≥2 fonti concordano -------------\n if (!pr) return \"skip_no_ref\"; // niente seen: riprova dopo il cron\n\n const rincaro = Number(conf.montre_rincaro ?? 1.35);\n const trendTracked = bande.find((b) => b.version === trackedSlot)?.trend ??\n (pr.trend != null ? Number(pr.trend) : null);\n const fonti: Fonte[] = [];\n // Cardmarket EN: il minimo reale filtrato inglese della versione tracciata\n // (letto 1×/giorno). È la fonte autorevole del valore di rimpiazzo EN —\n // se concorda con un'altra, il riferimento è quello. Preferisci il minimo\n // da venditore IT quando c'è (spedizione bassa, mercato di casa).\n const [cm] = await query(\n sq,\n \"SELECT min_en, min_en_it FROM cardmarket WHERE id_product = ?\",\n [wl.id_product],\n );\n const cmEn = cm?.min_en_it != null\n ? Number(cm.min_en_it)\n : (cm?.min_en != null ? Number(cm.min_en) : null);\n if (cmEn != null && cmEn > 0) {\n fonti.push({ nome: \"Cardmarket EN\", valore: cmEn });\n }\n if (trendTracked != null && trendTracked > 0) {\n fonti.push({ nome: \"trend CM\", valore: trendTracked });\n }\n if (pr.montre_prezzo != null && Number(pr.montre_prezzo) > 0) {\n fonti.push({\n nome: \"Montre÷\" + rincaro,\n valore: Math.round((Number(pr.montre_prezzo) / rincaro) * 100) / 100,\n });\n }\n const giorniCoorte = Number(conf.coorte_giorni ?? 7);\n const dataMin = new Date(Date.parse(adesso) - giorniCoorte * 24 * 3600 * 1000)\n .toISOString().slice(0, 10);\n const campioni = await query(\n sq,\n \"SELECT prezzo FROM coorte WHERE codice = ? AND versione = ? AND data >= ? AND id_annuncio != ?\",\n [a.codice, trackedSlot, dataMin, id],\n );\n if (campioni.length >= Number(conf.coorte_min ?? 3)) {\n const med = mediana(campioni.map((r) => Number(r.prezzo)));\n if (med != null && med > 0) {\n fonti.push({ nome: `coorte Vinted (${campioni.length})`, valore: med });\n }\n }\n const val = validaRiferimento(fonti, Number(conf.fonti_max_div ?? 1.6));\n if (!val.valido) {\n console.log(`rif. non validato ${a.codice}: ${val.motivo}`);\n return \"skip_rif_non_validato\"; // niente seen: coorte e cron migliorano\n }\n\n // ---- S4: verdetto ------------------------------------------------------\n const verdetto = valuta(\n { total_item_price: a.total_item_price },\n {\n low: val.rif!,\n hot: Boolean(pr.hot),\n max_override: wl.max_override != null ? Number(wl.max_override) : null,\n },\n conf as {\n margine_minimo: string;\n margine_pct: string;\n moltiplicatore_hot: string;\n spedizione_stimata: string;\n },\n spedizione,\n );\n if (!verdetto.affare) {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"no_affare\";\n }\n\n // lingua solo probabile (venditore IT, EN non dichiarato): si segnala\n // soltanto se lo sconto è ampio — per un affare grosso vale la pena aprire\n // la foto, per un margine risicato no (23/7)\n if (linguaDa === \"\") {\n const scontoPct = verdetto.riferimento > 0\n ? 1 - verdetto.costo / verdetto.riferimento\n : 0;\n const soglia = Number(conf.margine_pct_incerta ?? 0.3);\n if (scontoPct < soglia) {\n await scriviSeen(sq, id, a.codice, adesso);\n return \"skip_lingua_incerta\";\n }\n linguaDa = \"venditore IT (da confermare dalla foto)\";\n }\n\n // ---- S5: 🎯 con le prove stampate --------------------------------------\n const ok = await sendAlert(annuncioAlert, verdetto, refAlert, \"en\", tg, {\n radar,\n paese: a.seller_country,\n spedizione,\n prove: {\n rif: val.rif!,\n fonti: val.usate,\n versione: richiedeMarker ? \"dichiarata nel titolo + banda prezzo\" : \"banda prezzo\",\n lingua: linguaDa,\n },\n });\n return alertConRetry(ok, sq, id, a.codice, adesso);\n}\n\n// ---- entrypoint val.town (HTTP trigger) ----\n\nlet schemaPronto = false;\n\nexport default async function (req: Request): Promise {\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n if (!schemaPronto) {\n await initSchema(sqlite);\n schemaPronto = true;\n }\n return handleRequest(req, {\n sqlite,\n env: {\n TG_TOKEN: Deno.env.get(\"TG_TOKEN\") ?? \"\",\n TG_SECRET: Deno.env.get(\"TG_SECRET\") ?? \"\",\n INGEST_SECRET: Deno.env.get(\"INGEST_SECRET\") ?? \"\",\n TG_CHAT_ID: Deno.env.get(\"TG_CHAT_ID\") ?? \"\",\n },\n fetchProducts: fetchProductsReal,\n fetchPriceGuide: fetchPriceGuideReal,\n checkFotoLingua: checkFotoLinguaReal,\n adesso: () => new Date().toISOString(),\n });\n}\n","createdAt",["D",1784801637910],"branchVersion","branchId","631bce5f-f950-4d74-8662-f7a1555d0b2f","id","1a83564a-5812-4b1c-8f41-d403c0ef1329","sniper",["D",1784047215381],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","c988cd39-b64a-46d9-852a-ea4d3736b03c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e75a3-092f-750e-981e-1081519f9b3e","tursoName","1a83564a58124b1c8f41d403c0ef1329","tursoHostname","1a83564a58124b1c8f41d403c0ef1329-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789489305251],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":97,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",84,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lqdocelot","handle","displayName","avatar","https://avatars.githubusercontent.com/u/34916293?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":256,"_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":65,"_66":67,"_68":257,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":258,"_82":259,"_84":260,"_86":25},"tree",[219,220,221,222,223,224,225,226,227],"files",[219,220,221,222,223,224,225,226,227],"counts",{"_208":61,"_209":210,"_211":61,"_212":213,"_214":215},"contents",[128,129,130,131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":200,"_32":201,"_30":202,"_140":-5,"_41":42,"_40":203,"_142":25,"_38":204,"_13":197,"_33":205,"_35":206,"_24":25,"_147":-5,"_27":207},{"_43":192,"_32":193,"_30":194,"_140":-5,"_41":42,"_40":195,"_142":25,"_38":196,"_13":197,"_33":145,"_35":198,"_24":25,"_147":-5,"_27":199},{"_43":188,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":25,"_38":189,"_13":190,"_33":34,"_35":37,"_24":25,"_147":-5,"_27":191},{"_43":180,"_32":181,"_30":182,"_140":-5,"_41":42,"_40":183,"_142":123,"_38":184,"_13":185,"_33":145,"_35":186,"_24":25,"_147":-5,"_27":187},{"_43":172,"_32":173,"_30":174,"_140":-5,"_41":42,"_40":175,"_142":123,"_38":176,"_13":177,"_33":145,"_35":178,"_24":25,"_147":-5,"_27":179},{"_43":164,"_32":165,"_30":166,"_140":-5,"_41":42,"_40":167,"_142":123,"_38":168,"_13":169,"_33":145,"_35":170,"_24":25,"_147":-5,"_27":171},{"_43":156,"_32":157,"_30":158,"_140":-5,"_41":42,"_40":159,"_142":123,"_38":160,"_13":161,"_33":145,"_35":162,"_24":25,"_147":-5,"_27":163},{"_43":149,"_32":150,"_30":151,"_140":-5,"_41":42,"_40":152,"_142":123,"_38":153,"_13":144,"_33":145,"_35":154,"_24":25,"_147":-5,"_27":155},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":25,"_38":143,"_13":144,"_33":145,"_35":146,"_24":25,"_147":-5,"_27":148},"8d6fc40d-067c-4680-aff0-827e155661fd","verdict.ts","00c5798e-7fa6-11f1-adfd-1607ee4eb77e","parentId",52,"latest",["D",1784294049484],5,"script","// verdict.ts — cuore logico: formula affare, filtro lingua keyword, filtro\n// lotti (DESIGN.md §Formula dell'affare). I numeri arrivano dalla tabella\n// config (stringhe), niente hardcode.\n\nexport type Annuncio = {\n total_item_price: number; // Vinted: prezzo + protezione acquirente inclusa\n};\n\nexport type Riferimento = {\n low: number;\n hot: boolean;\n max_override?: number | null;\n};\n\nexport type VerdictConfig = {\n margine_minimo: string;\n margine_pct: string; // v2: il margine è max(minimo, pct × riferimento)\n moltiplicatore_hot: string;\n spedizione_stimata: string;\n};\n\nexport type Verdetto = {\n affare: boolean;\n costo: number;\n riferimento: number;\n margine: number;\n};\n\nconst round2 = (n: number) => Math.round(n * 100) / 100;\n\n// costo = total_item_price + spedizione_stimata\n// riferimento = low (carta normale) | low × moltiplicatore_hot (carta 🔥)\n// AFFARE se costo ≤ riferimento − margine_minimo.\n// max_override batte tutto: AFFARE se costo ≤ max_override (\"sotto €25 e basta\").\nexport function valuta(\n annuncio: Annuncio,\n ref: Riferimento,\n config: VerdictConfig,\n spedizioneReale?: number,\n): Verdetto {\n // la spedizione vera dipende dal paese del venditore (spedizionePer);\n // se non passata si usa la stima locale di config\n const spedizione = spedizioneReale ?? Number(config.spedizione_stimata);\n const margineMinimo = Number(config.margine_minimo);\n const margPct = Number(config.margine_pct ?? \"0\");\n const moltiplicatoreHot = Number(config.moltiplicatore_hot);\n\n const costo = round2(annuncio.total_item_price + spedizione);\n\n let riferimento: number;\n let soglia: number;\n if (ref.max_override != null) {\n riferimento = round2(ref.max_override);\n soglia = riferimento;\n } else {\n riferimento = round2(ref.hot ? ref.low * moltiplicatoreHot : ref.low);\n // −€1 su €10 non è un affare: margine assoluto E percentuale (v2)\n soglia = round2(riferimento - Math.max(margineMinimo, riferimento * margPct));\n }\n\n return {\n affare: costo <= soglia + 1e-9,\n costo,\n riferimento,\n margine: round2(riferimento - costo),\n };\n}\n\n// ---- Lingua (REQUISITO TASSATIVO: solo carte EN — DESIGN.md §Formula) ----\n// Livello 1 (testo) + livello 2 (paese venditore). Il livello 3 (foto/vision)\n// sta in lang_vision.ts e si usa solo su SOSPETTO/IGNOTO candidati-affare.\n\nexport type EsitoLingua = \"SCARTO\" | \"EN_TESTO\" | \"SOSPETTO\" | \"IGNOTO\";\n\n// Marker tassativi: qualsiasi segnale non-EN → SCARTO immediato.\nconst TOKEN_NON_EN = new Set([\n \"fr\", \"francese\", \"française\", \"francaise\", \"vf\",\n \"jap\", \"jp\", \"giapponese\", \"japanese\", \"japonaise\",\n \"cn\", \"cinese\", \"chinese\",\n \"kr\", \"coreano\", \"coreana\", \"korean\",\n]);\n\nconst TOKEN_EN = new Set([\"eng\", \"en\", \"english\", \"inglese\"]);\n\n// Titolo palesemente francese: ≥2 parole tipiche (\"carte\" da sola non basta,\n// è anche italiano).\nconst PAROLE_FRANCESI = new Set([\n \"carte\", \"cartes\", \"neuve\", \"neuf\", \"envoi\", \"état\", \"etat\", \"très\", \"tres\",\n]);\n\n// Paesi venditore che pesano come segnale negativo (mercati non-EN raggiungibili\n// da vinted.it). IT è il mercato di casa → nessun segnale.\nconst PAESI_SOSPETTI = new Set([\n \"FR\", \"ES\", \"DE\", \"NL\", \"BE\", \"PL\", \"PT\", \"CZ\", \"SK\", \"HU\", \"RO\",\n \"LT\", \"LV\", \"EE\", \"HR\", \"SI\", \"AT\", \"LU\",\n]);\n\nfunction tokenizza(testo: string): string[] {\n return testo.toLowerCase().split(/[^a-zà-ÿ]+/).filter(Boolean);\n}\n\nexport function classificaLingua(\n titolo: string,\n descrizione: string,\n paeseVenditore: string,\n): EsitoLingua {\n const tokens = tokenizza(`${titolo} ${descrizione}`);\n\n if (tokens.some((t) => TOKEN_NON_EN.has(t))) return \"SCARTO\";\n\n const francesi = new Set(tokens.filter((t) => PAROLE_FRANCESI.has(t)));\n if (francesi.size >= 2) return \"SCARTO\";\n\n if (tokens.some((t) => TOKEN_EN.has(t))) return \"EN_TESTO\";\n\n if (PAESI_SOSPETTI.has(paeseVenditore?.toUpperCase?.() ?? \"\")) {\n return \"SOSPETTO\";\n }\n return \"IGNOTO\";\n}\n\n// ---- Lotti: il prezzo copre più carte e falserebbe il verdetto.\n// Un lotto non è mai AFFARE, solo 📦 da valutare a mano (DESIGN.md).\nconst RE_LOTTO = /\\b(lot|lotto|bundle|x[2-9]|playset)\\b/i;\n\n// Un titolo che cita DUE codici carta vende due carte, anche senza dirlo:\n// \"OP12-118 sec / OP14-111\" (visto su Vinted il 17/7) non ha nessuna parola\n// chiave da lotto, e il prezzo — che copre entrambe — falsava il verdetto.\nconst RE_CODICE_CARTA = /\\b[A-Z]{2,3}\\d{2}-\\d{3}\\b/gi;\n\nexport function isLotto(titolo: string): boolean {\n if (RE_LOTTO.test(titolo)) return true;\n const codici = new Set(\n (titolo.match(RE_CODICE_CARTA) ?? []).map((c) => c.toUpperCase()),\n );\n return codici.size >= 2;\n}\n\n// ---- Versione dell'annuncio dal titolo (17/7) ----------------------------\n// Il bot cerca su Vinted per CODICE e riceve annunci di tutte le versioni, ma\n// li confronta col riferimento di UNA sola: sotto OP12-118 convivono la sec a\n// €17 e la manga a €668, quindi la versione sbagliata trasforma un annuncio\n// normale in un \"affare\" inesistente (alert falso su OP13-119, 16/7).\n// Vocabolario ricavato dai titoli veri di Vinted (17/7), non a intuito:\n// \"Jewelry Bonney (OP12-118) (V.2)\" → V.2 = alt \"(V.3)\" → manga\n// \"Perona OP12-034 SR* AA\" → AA = Alternate Art\n// \"Shanks Alternate OP14-027\" → alternate\n// \"Bonney Manga Op12-118\" → manga\n// \"Perona OP12-034 3rd Anniversary\" → versione Anniversary (esiste su Montre)\n// \"Jewelry Bonney OP12-118 PCA 9.5\" → graded: mercato a parte, rif. non vale\n\nexport type VersioneAnnuncio =\n | \"base\"\n | \"alt\"\n | \"manga\"\n | \"anniversary\"\n | \"graded\"\n | \"ignota\";\n\n// Le sigle dei graders seguite da un voto (anche col formato italiano \"9,5\"),\n// oppure la parola grading/graded da sola: la carta è in slab e vale un altro\n// mercato — il nostro riferimento CM non la descrive.\n// NIENTE \"ACE\" fra i graders: Ace è anche un personaggio di One Piece\n// (OP13-119 è Portgas D. Ace) e il falso positivo è garantito.\nconst RE_GRADED =\n /\\b((psa|pca|bgs|cgc|aog)\\s*\\.?\\s*(10|[1-9]([.,]5)?)|graded|grading|gradat[ao])\\b/i;\nconst RE_MANGA = /\\b(manga|v\\.?3)\\b/i;\nconst RE_ALT = /\\b(alt|alternate|alternata|alterata|aa|v\\.?2|parallel)\\b/i;\nconst RE_ANNIVERSARY = /\\b(anniversary|anniversario)\\b/i;\n// Rarità BASSE scritte per esteso = è la carta base (17/7: \"Shanks OP14-027\n// Rare Englisch\" a €2,80 era la base da €1 spacciata dal bot per affare\n// contro il riferimento della alt a €17). Solo le parole non ambigue:\n// SR/SEC/L restano fuori perché sono anche la rarità della versione tracciata.\nconst RE_BASE = /\\b(rare|rara|uncommon|non comune|uc|common|comune)\\b/i;\n\nexport function classificaVersione(\n titolo: string,\n descrizione = \"\",\n): VersioneAnnuncio {\n const t = titolo.toLowerCase();\n // Graded si cerca anche nella descrizione: caso reale del 17/7, titolo\n // \"Bonney Manga Op12-118\" con descrizione \"Aog grading 9,5\" — dal titolo\n // sembrava una manga, era uno slab. Alt/manga invece si leggono SOLO dal\n // titolo: le descrizioni sono piene di hashtag spam (#manga #altart...)\n // che parlano di altre carte del venditore, non di questa.\n if (RE_GRADED.test(`${t} ${descrizione.toLowerCase()}`)) return \"graded\";\n if (RE_ANNIVERSARY.test(t)) return \"anniversary\";\n if (RE_MANGA.test(t)) return \"manga\";\n if (RE_ALT.test(t)) return \"alt\"; // \"rare alt\" è una alt: alt vince sulla rarità\n if (RE_BASE.test(t)) return \"base\";\n return \"ignota\"; // nessun marcatore: NON assumere \"base\", non lo sappiamo\n}\n\n// La versione tracciata in watchlist (\"base\"/\"v2\"/\"manga\"/\"radar\") e quella\n// letta dal titolo parlano lingue diverse: qui si decide se sono compatibili.\n// Politica: si blocca solo quando il titolo dice ESPLICITAMENTE un'altra\n// versione. Titolo muto (\"ignota\") non basta a scartare — sarebbe metà degli\n// annunci — ma non basta nemmeno a confermare: quel caso resta da valutare.\nexport function versioneCoerente(\n versioneTracciata: string | null | undefined,\n versioneAnnuncio: VersioneAnnuncio,\n): { coerente: boolean; motivo: string } {\n if (versioneAnnuncio === \"graded\") {\n return { coerente: false, motivo: \"carta graded: mercato diverso dal rif. CM\" };\n }\n if (versioneAnnuncio === \"ignota\") return { coerente: true, motivo: \"\" };\n\n const tracciata = (versioneTracciata ?? \"\").toLowerCase();\n const attesa: Record = {\n base: \"base\",\n v2: \"alt\",\n manga: \"manga\",\n };\n const att = attesa[tracciata];\n if (!att) return { coerente: true, motivo: \"\" }; // radar/ignota: nessun vincolo\n\n if (att === \"base\" && versioneAnnuncio !== \"base\") {\n return {\n coerente: false,\n motivo: `annuncio ${versioneAnnuncio}, ma tracciamo la base`,\n };\n }\n if (att !== \"base\" && versioneAnnuncio !== att) {\n return {\n coerente: false,\n motivo: `annuncio ${versioneAnnuncio}, ma tracciamo ${att}`,\n };\n }\n return { coerente: true, motivo: \"\" };\n}\n\n// ---- Spedizione per paese venditore (16/7) -------------------------------\n// Il costo reale del pacco cambia con l'origine: ~2€ dall'Italia, 5-6€ dal\n// resto d'Europa, e dal Regno Unito i venditori non spediscono (Brexit).\n// Il paese arriva da /api/v2/users/ (il catalogo Vinted non lo espone).\n\nexport type ConfigSpedizione = {\n spedizione_stimata: string;\n spedizione_estero: string;\n paesi_esclusi: string;\n};\n\nexport function spedizionePer(\n paese: string | undefined | null,\n config: ConfigSpedizione,\n): number | null {\n const p = (paese ?? \"\").trim().toUpperCase();\n const esclusi = (config.paesi_esclusi ?? \"\")\n .split(\",\")\n .map((x) => x.trim().toUpperCase())\n .filter(Boolean);\n if (p && esclusi.includes(p)) return null; // non spedisce in Italia\n // paese ignoto: vinted.it è in prevalenza mercato italiano\n if (!p || p === \"IT\") return Number(config.spedizione_stimata);\n return Number(config.spedizione_estero);\n}\n\n// ============================================================================\n// Detect v2 (DESIGN-DETECT-V2, 17/7 — dopo i 16 alert falsi in una mattina).\n// Sostituisce refAffidabile/riferimentoEN: il riferimento non è più l'opinione\n// di una fonte con dei cancelli, ma un fatto che richiede l'accordo di ≥2\n// fonti indipendenti; e la versione dell'annuncio si stabilisce anche dal\n// prezzo (le bande), non solo dal titolo.\n// ============================================================================\n\nexport type Banda = { version: string; trend: number | null };\n\n// S2 — a quale versione appartiene questo prezzo? La più vicina in scala\n// logaritmica, accettata solo entro maxDist. \"anomala\" = fuori da ogni banda\n// (l'84% di sconto non esiste: è una versione sbagliata o una truffa).\n// null = nessuna banda utilizzabile, il prezzo non dice niente.\nexport function assegnaBanda(\n prezzo: number,\n bande: Banda[],\n maxDist: number,\n): string | \"anomala\" | null {\n const valide = bande.filter((b) => b.trend != null && b.trend > 0);\n if (prezzo <= 0 || valide.length === 0) return null;\n let migliore = valide[0];\n let minScarto = Infinity;\n for (const b of valide) {\n const scarto = Math.abs(Math.log(prezzo / b.trend!));\n if (scarto < minScarto) {\n minScarto = scarto;\n migliore = b;\n }\n }\n return Math.exp(minScarto) <= maxDist ? migliore.version : \"anomala\";\n}\n\n// La versione col trend più basso: se tracciamo QUELLA, un annuncio di\n// un'altra versione costerebbe di più e non farebbe mai scattare l'affare,\n// quindi il titolo muto è tollerabile. Se tracciamo una versione più cara,\n// il titolo muto è il canale principale degli alert falsi (base da €1\n// contro il riferimento della alt) e serve il marker esplicito.\nexport function versionePiuEconomica(bande: Banda[]): string | null {\n const valide = bande.filter((b) => b.trend != null && b.trend > 0);\n if (valide.length === 0) return null;\n return valide.reduce((a, b) => (a.trend! <= b.trend! ? a : b)).version;\n}\n\n// S3 — il riferimento esiste solo se ≥2 fonti indipendenti concordano\n// (max/min ≤ maxDiv). Riferimento = il MINIMO delle fonti in accordo:\n// conservativo per costruzione. Fonti tipiche: trend CM della versione,\n// Montre variante ÷ rincaro, mediana coorte Vinted.\nexport type Fonte = { nome: string; valore: number };\n\nexport function validaRiferimento(\n fonti: Fonte[],\n maxDiv: number,\n): { valido: boolean; rif: number | null; usate: Fonte[]; motivo: string } {\n const buone = fonti.filter((f) => Number.isFinite(f.valore) && f.valore > 0)\n .sort((a, b) => a.valore - b.valore);\n if (buone.length < 2) {\n return {\n valido: false,\n rif: null,\n usate: [],\n motivo: `solo ${buone.length} fonte/i disponibile/i, ne servono 2`,\n };\n }\n // il sottoinsieme in accordo più grande = finestra più lunga sull'ordinato\n let inizio = 0;\n let migliore: Fonte[] = [];\n for (let fine = 0; fine < buone.length; fine++) {\n while (buone[fine].valore > buone[inizio].valore * maxDiv) inizio++;\n if (fine - inizio + 1 > migliore.length) {\n migliore = buone.slice(inizio, fine + 1);\n }\n }\n if (migliore.length < 2) {\n const elenco = buone.map((f) => `${f.nome} €${f.valore}`).join(\" vs \");\n return {\n valido: false,\n rif: null,\n usate: [],\n motivo: `fonti in disaccordo: ${elenco}`,\n };\n }\n return {\n valido: true,\n rif: round2(migliore[0].valore),\n usate: migliore,\n motivo: \"\",\n };\n}\n\n// F3 — mediana della coorte Vinted (prezzi visti negli ultimi giorni per la\n// stessa versione dello stesso codice).\nexport function mediana(valori: number[]): number | null {\n if (valori.length === 0) return null;\n const v = [...valori].sort((a, b) => a - b);\n const m = Math.floor(v.length / 2);\n return v.length % 2 === 1 ? v[m] : round2((v[m - 1] + v[m]) / 2);\n}\n","label",[138],"3911674c-7511-4555-b9db-4ed4a9ccbc77","telegram.ts","79cdeb06-7fa9-11f1-b72f-1607ee4eb77e",57,["D",1784294052171],"// telegram.ts — parsing update, formato alert e invio messaggi.\n// Bot dedicato nuovo (BotFather), token/secret SOLO in env vars val.town\n// (DESIGN.md §webhook_telegram). fetch iniettabile per i test.\n\nexport type Comando =\n | { tipo: \"comando\"; cmd: string; args: string[]; chatId: number }\n | {\n tipo: \"callback\";\n data: string;\n chatId: number;\n callbackQueryId: string;\n messageId: number;\n };\n\nexport function parseCommand(update: unknown): Comando | null {\n const u = update as {\n message?: { chat?: { id: number }; text?: string };\n callback_query?: {\n id: string;\n data?: string;\n message?: { chat?: { id: number }; message_id?: number };\n };\n };\n if (u?.callback_query?.data && u.callback_query.message?.chat) {\n return {\n tipo: \"callback\",\n data: u.callback_query.data,\n chatId: u.callback_query.message.chat.id,\n callbackQueryId: u.callback_query.id,\n messageId: u.callback_query.message.message_id ?? 0,\n };\n }\n const testo = u?.message?.text;\n if (!testo?.startsWith(\"/\") || !u.message?.chat) return null;\n const [primo, ...args] = testo.trim().split(/\\s+/);\n const cmd = primo.slice(1).split(\"@\")[0].toLowerCase();\n return { tipo: \"comando\", cmd, args, chatId: u.message.chat.id };\n}\n\n// ---- formato alert (DESIGN.md §Formato alert) ----\n\nexport type AnnuncioAlert = {\n id: string;\n codice: string;\n title: string;\n total_item_price: number;\n url: string;\n photo_url?: string;\n};\n\nexport type RefAlert = {\n low: number | null;\n trend: number | null;\n hot: boolean;\n montre_prezzo: number | null;\n montre_disp: boolean | null;\n};\n\nimport type { Verdetto } from \"./verdict.ts\";\n\nconst eur = (n: number) =>\n \"€\" + (Number.isInteger(n) ? String(n) : n.toFixed(2).replace(\".\", \",\"));\n\nexport function formatAlert(\n annuncio: AnnuncioAlert,\n verdetto: Verdetto | null,\n ref: RefAlert,\n lingua: string,\n opts: {\n lotto?: boolean;\n graded?: boolean;\n radar?: boolean;\n paese?: string;\n spedizione?: number;\n // Detect v2: le prove che hanno promosso l'annuncio a 🎯 — auditabili\n // dal telefono in 5 secondi (DESIGN-DETECT-V2 P6)\n prove?: {\n rif: number;\n fonti: { nome: string; valore: number }[];\n versione: string;\n lingua: string;\n };\n } = {},\n): string {\n const righe: string[] = [];\n\n // le carte scovate dal Radar (non scelte a mano) sono marcate 🤖\n const marchio = opts.radar ? \"🤖 \" : \"\";\n if (opts.lotto) {\n righe.push(`${marchio}📦 LOTTO: ${annuncio.codice} ${annuncio.title}`);\n } else if (opts.graded) {\n righe.push(`${marchio}💎 GRADED: ${annuncio.codice} ${annuncio.title}`);\n } else {\n // detect v2: se siamo qui le prove ci sono tutte — il ⚠️ non esiste più\n righe.push(`${marchio}🎯 AFFARE: ${annuncio.codice} ${annuncio.title}`);\n }\n\n // da dove parte il pacco: cambia la spedizione, quindi il verdetto\n const paese = (opts.paese ?? \"\").toUpperCase();\n const origine = !paese\n ? \"origine ignota\"\n : paese === \"IT\"\n ? \"🇮🇹 Italia\"\n : `🇪🇺 ${paese}`;\n const sped = opts.spedizione != null ? ` sped. ${eur2(opts.spedizione)}` : \"\";\n const senzaVerdetto = opts.graded ? \"graded\" : \"lotto\";\n const prezzoRiga = verdetto\n ? `Vinted ${eur2(annuncio.total_item_price)} (tot. ${eur2(verdetto.costo)} · ${origine}${sped})`\n : `Vinted ${eur2(annuncio.total_item_price)} · ${origine} (${senzaVerdetto}: verdetto non applicabile)`;\n righe.push(prezzoRiga);\n\n const hot = ref.hot ? \" 🔥\" : \"\";\n const montre = ref.montre_prezzo == null\n ? \"Montre n.d.\"\n : `Montre ${eur(ref.montre_prezzo)}${ref.montre_disp ? \"\" : \" (esaurita)\"}`;\n righe.push(\n `Rif. CM low: ${ref.low == null ? \"n.d.\" : eur2(ref.low)}${hot} | trend ${\n ref.trend == null ? \"n.d.\" : eur(ref.trend)\n } | ${montre}`,\n );\n\n if (verdetto) {\n const segno = verdetto.margine >= 0 ? \"+\" : \"−\";\n const pct = verdetto.riferimento > 0\n ? Math.round((verdetto.costo / verdetto.riferimento - 1) * 100)\n : 0;\n righe.push(\n `Margine stimato: ${segno}${eur2(Math.abs(verdetto.margine))} (${pct}%)`,\n );\n }\n\n if (opts.lotto) {\n righe.push(\"📦 Prezzo da valutare a mano (più carte)\");\n } else if (opts.graded) {\n // scelta di Alessandro (17/7): non si giocano, ma valgono da collezione.\n // Il rif. CM sopra è della carta sciolta: serve solo come pavimento.\n righe.push(\"💎 Slab da collezione: valuta a mano (il rif. CM è della carta sciolta)\");\n } else if (opts.prove) {\n const fonti = opts.prove.fonti\n .map((f) => `${f.nome} ${eur(f.valore)}`)\n .join(\" ≈ \");\n righe.push(`✅ Prove: rif. ${eur(opts.prove.rif)} (${fonti})`);\n righe.push(` versione da ${opts.prove.versione} · EN da ${opts.prove.lingua}`);\n } else {\n righe.push(\"✅ EN confermata\");\n }\n\n return righe.join(\"\\n\");\n}\n\nfunction eur2(n: number): string {\n return \"€\" + n.toFixed(2).replace(\".\", \",\");\n}\n\nexport function tastieraAlert(url: string, codice: string) {\n return {\n inline_keyboard: [[\n { text: \"Apri annuncio\", url },\n { text: \"Ignora 24h\", callback_data: `snooze:${codice}` },\n ]],\n };\n}\n\n// ---- invio ----\n\nexport type TgDeps = {\n token: string;\n chatId?: number | string;\n fetcher?: typeof fetch;\n};\n\nexport async function tgApi(\n metodo: string,\n payload: Record,\n deps: TgDeps,\n): Promise {\n const fetcher = deps.fetcher ?? fetch;\n try {\n const res = await fetcher(\n `https://api.telegram.org/bot${deps.token}/${metodo}`,\n {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(payload),\n },\n );\n if (!res.ok) return false;\n const body = await res.json();\n return body?.ok === true;\n } catch {\n return false;\n }\n}\n\nexport function sendMsg(\n chatId: number | string,\n text: string,\n deps: TgDeps,\n extra: Record = {},\n): Promise {\n return tgApi(\"sendMessage\", { chat_id: chatId, text, ...extra }, deps);\n}\n\nexport function sendAlert(\n annuncio: AnnuncioAlert,\n verdetto: Verdetto | null,\n ref: RefAlert,\n lingua: string,\n deps: TgDeps & { chatId: number | string },\n opts: {\n lotto?: boolean;\n graded?: boolean;\n radar?: boolean;\n paese?: string;\n spedizione?: number;\n prove?: {\n rif: number;\n fonti: { nome: string; valore: number }[];\n versione: string;\n lingua: string;\n };\n } = {},\n): Promise {\n return sendMsg(\n deps.chatId,\n formatAlert(annuncio, verdetto, ref, lingua, opts),\n deps,\n { reply_markup: tastieraAlert(annuncio.url, annuncio.codice) },\n );\n}\n",[150],"bfbf01d1-775a-4a9b-9602-ae81bb7cf189","refs.ts","18599e66-7fa3-11f1-a727-1607ee4eb77e",43,["D",1784239110599],6,"// refs.ts — riferimenti prezzo Cardmarket (Price Guide pubblica S3).\n// Il join sul nome NON distingue le versioni (6 omonimi per OP12-118):\n// resolveCandidates produce i candidati del gruppo più recente, la scelta\n// finale dell'idProduct la fa l'utente all'/add (DESIGN.md §cron_priceguide).\n\nconst BASE = \"https://downloads.s3.cardmarket.com/productCatalog\";\nexport const PRODUCTS_URL = `${BASE}/productList/products_singles_18.json`;\nexport const PRICE_GUIDE_URL = `${BASE}/priceGuide/price_guide_18.json`;\n\nexport type Product = {\n idProduct: number;\n name: string;\n idExpansion: number;\n dateAdded: string;\n};\n\nexport type PriceRow = {\n idProduct: number;\n low: number | null;\n trend: number | null;\n avg1: number | null;\n avg7: number | null;\n avg30: number | null;\n};\n\n// Candidati per un codice carta: filtra i prodotti \"Nome (CODICE)\" e raggruppa\n// per idExpansion. Il set VERO (Asia/EU) è l'espansione che contiene tante\n// carte dello stesso set; le promo/box speciali ne hanno una manciata anche se\n// aggiunte più di recente (bug scoperto il 14/7: OP12-031 agganciava una promo\n// a low 32.85 invece della EU a 10.75). Tra i gruppi del set vero vince il più\n// recente (= stampa EU, esce dopo l'Asia); ordine per idProduct crescente\n// (base, alt, manga).\nexport function resolveCandidates(\n codice: string,\n products: Product[],\n): Product[] {\n const marker = `(${codice.toUpperCase()})`;\n const match = products.filter((p) =>\n p.name.toUpperCase().includes(marker)\n );\n if (match.length === 0) return [];\n\n // quante carte del set (es. \"(OP12-\") vivono in ogni espansione\n const setMarker = `(${codice.toUpperCase().split(\"-\")[0]}-`;\n const carteDelSet = new Map();\n for (const p of products) {\n if (p.name.toUpperCase().includes(setMarker)) {\n carteDelSet.set(\n p.idExpansion,\n (carteDelSet.get(p.idExpansion) ?? 0) + 1,\n );\n }\n }\n\n const gruppi = new Map();\n for (const p of match) {\n const g = gruppi.get(p.idExpansion) ?? [];\n g.push(p);\n gruppi.set(p.idExpansion, g);\n }\n\n const dataMax = (g: Product[]) =>\n Math.max(...g.map((p) => Date.parse(p.dateAdded)));\n\n const maxCarte = Math.max(\n ...[...gruppi.keys()].map((id) => carteDelSet.get(id) ?? 0),\n );\n // Asia ed EU hanno numerosità simile (il set intero); le promo restano fuori\n const setVero = [...gruppi.entries()].filter(\n ([id]) => (carteDelSet.get(id) ?? 0) >= maxCarte / 2,\n );\n const scelto = setVero.sort((a, b) => dataMax(b[1]) - dataMax(a[1]))[0][1];\n\n return scelto.sort((a, b) => a.idProduct - b.idProduct);\n}\n\n// Scarica la Price Guide → map idProduct → prezzi.\nexport async function fetchPriceGuide(\n fetcher: typeof fetch = fetch,\n): Promise> {\n const res = await fetcher(PRICE_GUIDE_URL);\n if (!res.ok) {\n throw new Error(`Price Guide HTTP ${res.status}`);\n }\n const body = await res.json();\n const map = new Map();\n for (const r of body.priceGuides ?? []) {\n map.set(r.idProduct, {\n idProduct: r.idProduct,\n low: r.low ?? null,\n trend: r.trend ?? null,\n avg1: r.avg1 ?? null,\n avg7: r.avg7 ?? null,\n avg30: r.avg30 ?? null,\n });\n }\n return map;\n}\n\n// Scarica l'anagrafica prodotti (serve solo all'/add per i candidati).\nexport async function fetchProducts(\n fetcher: typeof fetch = fetch,\n): Promise {\n const res = await fetcher(PRODUCTS_URL);\n if (!res.ok) {\n throw new Error(`Product list HTTP ${res.status}`);\n }\n const body = await res.json();\n return body.products ?? [];\n}\n\n// Flag 🔥 hot: il prezzo si sta muovendo (in entrambe le direzioni) —\n// |avg1/avg7 − 1| > soglia. Col flag hot il verdetto usa low × moltiplicatore\n// perché il low notturno può essere già vecchio (DESIGN.md §Formula).\nexport function isHot(\n avg1: number | null | undefined,\n avg7: number | null | undefined,\n soglia: number,\n): boolean {\n if (!avg1 || !avg7) return false;\n return Math.abs(avg1 / avg7 - 1) > soglia;\n}\n\nexport type MontreVariante = {\n titolo: string; // \"Rara\", \"Alterata\", \"Manga\", \"Secret\"…\n prezzo: number;\n disponibile: boolean;\n};\n\nexport type MontreRef = {\n handle: string;\n varianti: MontreVariante[];\n};\n\n// Terzo riferimento prezzo: Montrestore (Shopify). Suggest → primo handle →\n// /products/.js → TUTTE le varianti (centesimi/100).\n// L'handle viene cachato dal chiamante in watchlist.montre_handle.\n// Fino al 16/7 si leggeva `variants[0]` e si buttava il resto: sotto un codice\n// Montre ha una variante per rarità (il variant-picker della pagina), e la\n// prima è quasi sempre la più economica → si confrontava l'alt di Cardmarket\n// col prezzo della base, bocciando riferimenti sani.\nexport async function montreLookup(\n codice: string,\n fetcher: typeof fetch = fetch,\n): Promise {\n const suggestUrl =\n `https://montrestore.com/search/suggest.json?q=${encodeURIComponent(codice)}&resources[type]=product`;\n const sRes = await fetcher(suggestUrl);\n if (!sRes.ok) return null;\n const sBody = await sRes.json();\n const primo = sBody?.resources?.results?.products?.[0];\n if (!primo?.handle) return null;\n\n const pRes = await fetcher(\n `https://montrestore.com/products/${primo.handle}.js`,\n );\n if (!pRes.ok) return null;\n const prodotto = await pRes.json();\n const varianti: MontreVariante[] = (prodotto?.variants ?? [])\n .filter((v: { price?: number }) => (v?.price ?? 0) > 0) // le \"Prize\" a €0 non prezzano\n .map((v: { title?: string; price: number; available?: boolean }) => ({\n titolo: String(v.title ?? \"\"),\n prezzo: v.price / 100,\n disponibile: Boolean(v.available),\n }));\n if (varianti.length === 0) return null;\n\n return { handle: primo.handle, varianti };\n}\n\n// Appaia la variante Montre alla versione Cardmarket che stiamo tracciando.\n// Il criterio è il trend CM (una media, quindi robusta — il low invece è il\n// minimo e può essere un annuncio-civetta) maggiorato del rincaro tipico di\n// Montre (~+30%, la regola di Alessandro): si cerca la variante più vicina a\n// quel prezzo atteso. Senza il rincaro l'appaiamento sbaglia sulle carte con\n// più rarità vicine — su OP12-034 l'alt (trend €25,86) finiva su \"Super rara\"\n// €17,50 invece che su \"Alterata\" €39.\n// La variante si accetta solo se resta dentro `banda` rispetto al trend nudo:\n// gli accostamenti sbagliati cadono a 7× o 0,2× → nessun prezzo, che è meglio\n// del prezzo di un'altra carta (16/7).\nexport function scegliVariante(\n varianti: MontreVariante[],\n trendCM: number | null | undefined,\n banda: number,\n rincaro = 1.3,\n): MontreVariante | null {\n if (!trendCM || trendCM <= 0) return null; // senza scala non si può appaiare\n const atteso = trendCM * rincaro;\n let scelta: MontreVariante | null = null;\n let minScarto = Infinity;\n for (const v of varianti) {\n if (v.prezzo <= 0) continue;\n const scarto = Math.abs(Math.log(v.prezzo / atteso));\n if (scarto < minScarto) {\n minScarto = scarto;\n scelta = v;\n }\n }\n if (!scelta) return null;\n const rapporto = scelta.prezzo / trendCM;\n return rapporto >= 1 / banda && rapporto <= banda ? scelta : null;\n}\n",[157],"ad7e8c5b-e5d5-4eb9-b818-68ad9f2e2873","radar.ts","8018397a-8013-11f1-be3b-1607ee4eb77e",58,["D",1784294608511],7,"// radar.ts — Radar 🔥: scova i movers dell'intero catalogo dalla Price Guide\n// notturna (già scaricata) e li propone come voci auto della watchlist.\n// \"Best seller\"/tendenza ≈ carte il cui avg1 si stacca da avg7; il bulk resta\n// fuori con la soglia sul trend, le promo restano fuori riusando la logica\n// del set vero EU (resolveCandidates).\n\nimport { type PriceRow, type Product, resolveCandidates } from \"./refs.ts\";\n\nexport type RadarPick = {\n codice: string;\n idProduct: number;\n nome: string;\n trend: number;\n movimento: number; // |avg1/avg7 − 1|\n version: string; // base | v2 | manga… : QUALE versione stiamo agganciando\n};\n\nexport type RadarOpts = {\n n: number; // quante carte al massimo\n trendMin: number; // sotto questo trend è bulk, fuori\n sogliaMov: number; // movimento minimo per contare come mover\n spreadMax: number; // divario massimo fra la versione più cara e la più economica\n // liquidità (fase C, 17/7): il trend non può stare oltre N× la media a 30\n // giorni. Sui mercati sottili i \"movers\" sono artefatti: Nami OP10-088\n // trend 13,11 con avg30 5,75 (2,3×) e Zoro OP10-113 25,66 su 6,43 (4×) —\n // entrambi alert falsi; la Bonney sana sta a 1,08×.\n liqMax: number;\n};\n\n// Il bot cerca su Vinted per CODICE e riceve annunci di tutte le versioni, ma\n// confronta col riferimento di UNA sola: quando le versioni costano uguale\n// l'ambiguità non fa danno, quando sono lontane sì. Il radar sceglie il mover\n// più forte, e le versioni rare si muovono di più proprio perché quasi nessuno\n// le vende: il 16/7 ha agganciato OP13-119 alla 6ª versione (trend €7596) con\n// le altre a partire da €3 → contro quel riferimento QUALUNQUE annuncio della\n// base sembrava un affare (alert falso delle 08:03). Se dall'annuncio non si\n// può capire quale versione sia, la carta non entra in watchlist da sola.\nexport function versioniAmbigue(\n versioni: Product[],\n guide: Map,\n spreadMax: number,\n): boolean {\n const trend = versioni\n .map((p) => guide.get(p.idProduct)?.trend)\n .filter((t): t is number => t != null && t > 0);\n if (trend.length < 2) return false; // una sola versione: nessuna ambiguità\n return Math.max(...trend) > Math.min(...trend) * spreadMax;\n}\n\nconst RE_CODICE = /\$([A-Z]{1,3}\\d{2,3}-\\d{3})\$/;\n\n// Stesse etichette del comando /add: resolveCandidates ordina per idProduct\n// (base, alt, manga). Il radar deve dire QUALE versione aggancia, altrimenti\n// a valle il filtro versione non ha niente con cui confrontare l'annuncio —\n// ed e' esattamente il buco che il 17/7 ha lasciato passare l'alert falso su\n// OP13-119 (radar sulla 6a versione, annunci della base).\nexport const VERSIONI = [\"base\", \"v2\", \"manga\"];\n\nexport function selezionaRadar(\n products: Product[],\n guide: Map,\n opts: RadarOpts,\n): RadarPick[] {\n // candidati grezzi: trend e movimento sopra soglia\n const candidati: RadarPick[] = [];\n for (const p of products) {\n const g = guide.get(p.idProduct);\n if (!g || g.trend == null || g.trend < opts.trendMin) continue;\n if (!g.avg1 || !g.avg7) continue;\n // mercato sottile: trend lontano dalla media a 30gg → aggregati fasulli\n if (!g.avg30 || g.trend > g.avg30 * opts.liqMax) continue;\n // low fuori scala sul trend = annuncio-civetta su CM: riferimento\n // inservibile, la carta non deve nemmeno entrare in watchlist (15/7)\n if (!g.low || g.low > g.trend * 2) continue;\n const movimento = Math.abs(g.avg1 / g.avg7 - 1);\n if (movimento < opts.sogliaMov) continue;\n const codice = p.name.match(RE_CODICE)?.[1];\n if (!codice) continue;\n candidati.push({\n codice,\n idProduct: p.idProduct,\n nome: p.name.replace(` (${codice})`, \"\"),\n trend: g.trend,\n movimento: Math.round(movimento * 1000) / 1000,\n version: \"\", // deciso sotto, quando si conosce la posizione nel set EU\n });\n }\n\n candidati.sort((a, b) => b.movimento - a.movimento);\n\n // un pick per codice, solo varianti del set vero EU\n const scelti: RadarPick[] = [];\n const codiciPresi = new Set();\n for (const c of candidati) {\n if (scelti.length >= opts.n) break;\n if (codiciPresi.has(c.codice)) continue;\n const setEU = resolveCandidates(c.codice, products);\n const idx = setEU.findIndex((p) => p.idProduct === c.idProduct);\n if (idx < 0) continue; // promo/Asia\n // versioni troppo lontane di prezzo → dall'annuncio Vinted non si capisce\n // quale sia: meglio non tracciarla che gridare affari inesistenti\n if (versioniAmbigue(setEU, guide, opts.spreadMax)) continue;\n codiciPresi.add(c.codice);\n scelti.push({ ...c, version: VERSIONI[idx] ?? `v${idx + 1}` });\n }\n return scelti;\n}\n",[165],"6063dd7a-ec17-40af-a761-83150d7aea7b","main.ts","b0e0d254-7fa2-11f1-8e47-1607ee4eb77e",30,["D",1784069260911],2,"// main.ts — setup + sonda di stato: schema idempotente e dump watchlist/prezzi.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { initSchema } from \"./db.ts\";\n\nawait initSchema(sqlite);\n\nconst wl = await sqlite.execute(\n \"SELECT codice, version, id_product, max_override, attiva FROM watchlist ORDER BY codice\",\n);\nconst pr = await sqlite.execute(\n \"SELECT codice, data, low, trend, hot, montre_prezzo FROM prices WHERE data = (SELECT MAX(data) FROM prices p2 WHERE p2.codice = prices.codice) ORDER BY codice\",\n);\nconsole.log(\"watchlist:\", JSON.stringify(wl.rows));\nconsole.log(\"prices:\", JSON.stringify(pr.rows));",[173],"06a035f6-2148-4a13-b498-cbaf2f132eda","lang_vision.ts","429a5438-7fa6-11f1-9494-1607ee4eb77e",49,["D",1784239113634],3,"// lang_vision.ts — livello 3 del filtro lingua: classifica la PRIMA foto\n// dell'annuncio con Claude Haiku (vision). Si chiama SOLO sui candidati-affare\n// con lingua SOSPETTO/IGNOTO (pochi al giorno → costi in centesimi).\n// Politica: foto non conclusiva → \"incerto\" → alert declassato a ⚠️DA\n// VERIFICARE, mai AFFARE (DESIGN.md §Formula).\n\nexport type LinguaFoto = \"en\" | \"fr\" | \"jp\" | \"cn\" | \"kr\" | \"incerto\";\n\nconst MODEL = \"claude-haiku-4-5-20251001\";\nconst PROMPT =\n \"Guarda il testo di gioco stampato su questa carta One Piece TCG. \" +\n \"In che lingua è il testo? Rispondi con UNA sola parola tra: en, fr, jp, cn, kr. \" +\n \"Se non riesci a leggere il testo (retro, sleeve riflettente, sfocata) rispondi: incerto\";\n\nconst LINGUE: LinguaFoto[] = [\"en\", \"fr\", \"jp\", \"cn\", \"kr\", \"incerto\"];\n\nfunction toBase64(bytes: Uint8Array): string {\n let bin = \"\";\n const CHUNK = 0x8000;\n for (let i = 0; i < bytes.length; i += CHUNK) {\n bin += String.fromCharCode(...bytes.subarray(i, i + CHUNK));\n }\n return btoa(bin);\n}\n\nexport async function checkFotoLingua(\n fotoUrl: string,\n opts: { fetcher?: typeof fetch; apiKey?: string } = {},\n): Promise {\n const fetcher = opts.fetcher ?? fetch;\n const apiKey = opts.apiKey ?? Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!apiKey) return \"incerto\";\n\n try {\n const fotoRes = await fetcher(fotoUrl);\n if (!fotoRes.ok) return \"incerto\";\n const mediaType = fotoRes.headers.get(\"content-type\")?.split(\";\")[0] ??\n \"image/jpeg\";\n const data = toBase64(new Uint8Array(await fotoRes.arrayBuffer()));\n\n const apiRes = await fetcher(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n },\n body: JSON.stringify({\n model: MODEL,\n max_tokens: 10,\n messages: [{\n role: \"user\",\n content: [\n { type: \"image\", source: { type: \"base64\", media_type: mediaType, data } },\n { type: \"text\", text: PROMPT },\n ],\n }],\n }),\n });\n if (!apiRes.ok) return \"incerto\";\n const body = await apiRes.json();\n const testo: string = body?.content?.[0]?.text ?? \"\";\n const parola = testo.trim().toLowerCase().split(/[^a-z]+/)[0] ?? \"\";\n return (LINGUE as string[]).includes(parola)\n ? (parola as LinguaFoto)\n : \"incerto\";\n } catch {\n return \"incerto\";\n }\n}\n",[181],"ec1ab2fd-72ee-43f9-b86e-173f4301388a",["D",1784801637910],14,[28],"9ffacd5a-6d24-4f02-b559-af40330c2fc4","db.ts","bd501356-7fa2-11f1-ba18-1607ee4eb77e",72,["D",1784801426715],11,"// db.ts — unica sorgente dello schema SQLite dello sniper (DESIGN.md §Storage).\n// Su val.town: import { sqlite } from \"https://esm.town/v/std/sqlite\" e passa\n// l'oggetto a initSchema(). Nei test locali si inietta un adapter node:sqlite.\n\nexport type SqliteExecutor = {\n execute(\n stmt: string | { sql: string; args?: unknown[] },\n ): Promise;\n};\n\nexport const SCHEMA: string[] = [\n `CREATE TABLE IF NOT EXISTS watchlist (\n codice TEXT PRIMARY KEY,\n nome TEXT,\n version TEXT,\n id_product INTEGER,\n max_override REAL,\n attiva INTEGER NOT NULL DEFAULT 1,\n snooze_until TEXT,\n montre_handle TEXT,\n auto INTEGER NOT NULL DEFAULT 0,\n ultimo_hot TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS prices (\n codice TEXT NOT NULL,\n data TEXT NOT NULL,\n low REAL,\n trend REAL,\n avg1 REAL,\n avg7 REAL,\n avg30 REAL,\n hot INTEGER NOT NULL DEFAULT 0,\n montre_prezzo REAL,\n montre_disp INTEGER,\n PRIMARY KEY (codice, data)\n )`,\n `CREATE TABLE IF NOT EXISTS seen (\n id_annuncio TEXT PRIMARY KEY,\n codice TEXT,\n notificato_il TEXT\n )`,\n `CREATE TABLE IF NOT EXISTS config (\n chiave TEXT PRIMARY KEY,\n valore TEXT NOT NULL\n )`,\n // Detect v2 (DESIGN-DETECT-V2 §5): trend CM di OGNI versione di ogni codice\n // in watchlist, scritti dal cron. Servono a S2 (bande di prezzo → la\n // versione dell'annuncio) e a S3 (fonte F1 del riferimento).\n `CREATE TABLE IF NOT EXISTS bande (\n codice TEXT NOT NULL,\n version TEXT NOT NULL,\n id_product INTEGER,\n trend REAL,\n data TEXT,\n PRIMARY KEY (codice, version)\n )`,\n // Detect v2: i prezzi Vinted già scaricati ogni 10 minuti (prima buttati).\n // Fonte F3: la mediana per codice+versione è un prezzo di mercato vivo.\n `CREATE TABLE IF NOT EXISTS coorte (\n id_annuncio TEXT PRIMARY KEY,\n codice TEXT NOT NULL,\n prezzo REAL NOT NULL,\n versione TEXT,\n data TEXT NOT NULL\n )`,\n // Minimo Cardmarket filtrato INGLESE per la versione tracciata (17/7,\n // scelta di Alessandro): letto 1×/giorno dalla pagina prodotto vera —\n // superando Cloudflare con un browser — che la Price Guide non espone.\n // È la fonte prezzo più autorevole: il vero valore di rimpiazzo EN.\n // Chiave id_product = la variante esatta che seguiamo.\n `CREATE TABLE IF NOT EXISTS cardmarket (\n id_product INTEGER PRIMARY KEY,\n codice TEXT,\n min_en REAL,\n min_en_it REAL,\n data TEXT\n )`,\n];\n\n// Migrazioni additive su tabelle già esistenti in produzione (CREATE IF NOT\n// EXISTS non aggiunge colonne). Ogni ALTER fallisce in silenzio se la colonna\n// c'è già.\nexport const MIGRAZIONI: string[] = [\n // Radar v1.1: voci auto-scoperte dai movers della Price Guide\n \"ALTER TABLE watchlist ADD COLUMN auto INTEGER NOT NULL DEFAULT 0\",\n \"ALTER TABLE watchlist ADD COLUMN ultimo_hot TEXT\",\n];\n\n// Tutti i numeri della formula vivono qui, niente hardcode (DESIGN.md).\n// La protezione acquirente NON serve: si usa total_item_price di Vinted,\n// che la include già (PLAN.md Task 4).\nexport const CONFIG_DEFAULTS: Record = {\n margine_minimo: \"1.0\",\n soglia_hot: \"0.15\",\n moltiplicatore_hot: \"0.85\",\n spedizione_stimata: \"2.20\",\n lingua_strict: \"true\",\n // Scelta di Alessandro (17/7): niente operazioni a pagamento. Il check foto\n // via Haiku (~0,1 cent a foto) si accende solo mettendo \"true\" qui: da\n // spento i candidati a lingua ignota arrivano come ⚠️ DA VERIFICARE.\n vision_attiva: \"false\",\n // Graded (slab PSA/PCA): SPENTE (20/7). Il bot non ha un prezzo affidabile\n // per le slab → non può giudicarle, sarebbe solo rumore. Se riacceso,\n // segnala solo le graded EN come 💎 \"valuta a mano\" (vedi http_ingest).\n graded_attive: \"false\",\n // 23/7: venditore italiano senza marcatori non-EN = \"EN probabile\"; si\n // segnala solo se lo sconto supera margine_pct_incerta (l'affare grosso\n // giustifica il controllo della foto). \"false\" per tornare al rigore pieno.\n lingua_it_probabile: \"true\",\n margine_pct_incerta: \"0.3\",\n // Radar 🔥: auto-watchlist dai movers del catalogo\n radar_attivo: \"true\",\n radar_n: \"25\",\n radar_trend_min: \"8\",\n // movimento minimo perché una carta entri nel radar (separato da soglia_hot)\n radar_mov_min: \"0.10\",\n radar_scadenza_giorni: \"7\",\n // divario massimo fra le versioni di un codice perché il radar lo tracci:\n // oltre, dall'annuncio Vinted non si capisce quale versione sia (vedi\n // versioniAmbigue) e il riferimento sbagliato produce alert falsi\n radar_spread_max: \"6\",\n // liquidità: il trend di un pick radar deve stare entro N× l'avg30\n // (mercato spesso); oltre è un artefatto da annunci-civetta (fase C)\n radar_liq_max: \"3\",\n // Montre mostra varianti a prezzi troppo lontani (max/min) → carta ambigua,\n // fuori dal radar: su Vinted arrivano annunci di entrambe e non si\n // distinguono (20/7: OP15-094 Non comune 0,50 vs Dash Pack 10 = 20×)\n radar_montre_spread: \"8\",\n // Quanto può discostarsi il prezzo Montre dal trend CM perché le due voci\n // siano la stessa versione (vedi scegliVariante): oltre, Montre sta quotando\n // un'altra rarità e non fa da riferimento\n montre_banda: \"3\",\n // Montre vende a ~+35% sul mercato: la fonte F2 è variante ÷ rincaro\n montre_rincaro: \"1.35\",\n // ---- Detect v2 (17/7, DESIGN-DETECT-V2 dopo i 16 alert falsi) ----\n // margine: il costo deve stare sotto il riferimento di ALMENO\n // max(margine_minimo, margine_pct × riferimento) — scelta di Alessandro\n margine_pct: \"0.15\",\n // due fonti concordano se max/min ≤ questo (S3)\n fonti_max_div: \"1.6\",\n // banda di prezzo (S2): un annuncio appartiene a una versione se il\n // rapporto col suo trend sta entro questo; oltre ogni banda → anomalo\n banda_versione_max: \"2.5\",\n // coorte Vinted (F3): finestra giorni e campioni minimi per fare mediana\n coorte_giorni: \"7\",\n coorte_min: \"3\",\n // Spedizione reale per origine (16/7): ~2€ dall'Italia, 5-6€ dall'estero,\n // dal Regno Unito non spediscono in Italia\n spedizione_estero: \"6.00\",\n paesi_esclusi: \"GB,UK\",\n};\n\nexport async function initSchema(sqlite: SqliteExecutor): Promise {\n for (const sql of SCHEMA) {\n await sqlite.execute(sql);\n }\n for (const sql of MIGRAZIONI) {\n try {\n await sqlite.execute(sql);\n } catch {\n // colonna già presente\n }\n }\n for (const [chiave, valore] of Object.entries(CONFIG_DEFAULTS)) {\n await sqlite.execute({\n sql: \"INSERT OR IGNORE INTO config (chiave, valore) VALUES (?, ?)\",\n args: [chiave, valore],\n });\n }\n}\n",[193],"bcfc4c24-ef52-49d9-8dd7-ff171eb19ca2","cron_priceguide.ts","2f70abe6-7fab-11f1-8fa8-1607ee4eb77e",71,["D",1784801426413],"interval","// cron_priceguide.ts — cron notturno (03:00 UTC): per ogni carta in watchlist\n// scrive la riga prices del giorno (storico, mai sovrascritto tra giorni),\n// calcola il flag 🔥 hot e rinfresca il riferimento Montrestore\n// (DESIGN.md §cron_priceguide). Se il download fallisce resta il dato del\n// giorno prima; config.priceguide_last_ok traccia l'ultimo run riuscito.\n\nimport { initSchema, type SqliteExecutor } from \"./db.ts\";\nimport {\n fetchPriceGuide as fetchPriceGuideReal,\n fetchProducts as fetchProductsReal,\n isHot,\n type MontreRef,\n montreLookup as montreLookupReal,\n type PriceRow,\n type Product,\n resolveCandidates,\n scegliVariante,\n} from \"./refs.ts\";\nimport { selezionaRadar, VERSIONI } from \"./radar.ts\";\nimport { sendMsg } from \"./telegram.ts\";\n\nexport type CronDeps = {\n sqlite: SqliteExecutor;\n fetchPriceGuide: () => Promise>;\n fetchProducts: () => Promise;\n montreLookup: (codice: string) => Promise;\n adesso: () => string; // ISO\n // avvisi di sanità (default: Telegram via env); iniettabile nei test\n notifica?: (testo: string) => Promise;\n};\n\nasync function query(\n sq: SqliteExecutor,\n sql: string,\n args: unknown[] = [],\n): Promise[]> {\n const res = await sq.execute({ sql, args }) as {\n rows?: unknown[];\n columns?: string[];\n };\n const rows = res?.rows ?? [];\n if (rows.length > 0 && Array.isArray(rows[0])) {\n const cols = res.columns ?? [];\n return (rows as unknown[][]).map((r) =>\n Object.fromEntries(cols.map((c, i) => [c, r[i]]))\n );\n }\n return rows as Record[];\n}\n\nexport async function aggiornaPrezzi(\n deps: CronDeps,\n): Promise<{ aggiornate: number; senzaProdotto: number; anomalie: number }> {\n const sq = deps.sqlite;\n const adesso = deps.adesso();\n const oggi = adesso.slice(0, 10);\n\n const confRows = await query(sq, \"SELECT chiave, valore FROM config\");\n const conf: Record = {};\n for (const r of confRows) conf[String(r.chiave)] = String(r.valore);\n const sogliaHot = Number(conf.soglia_hot ?? 0.15);\n\n const guida = await deps.fetchPriceGuide();\n\n // ---- Radar 🔥 (v1.1): i movers di tutto il catalogo entrano come voci\n // auto; le voci manuali (auto=0) non vengono MAI toccate. Le auto che non\n // si ri-qualificano per radar_scadenza_giorni escono da sole.\n const prodotti = await deps.fetchProducts();\n\n if ((conf.radar_attivo ?? \"true\") === \"true\") {\n const picks = selezionaRadar(prodotti, guida, {\n n: Number(conf.radar_n ?? 10),\n trendMin: Number(conf.radar_trend_min ?? 8),\n // 23/7: soglia di movimento del radar separata da soglia_hot (che\n // serve al flag 🔥 negli alert): così si allarga la rete delle carte\n // in tendenza senza toccare la semantica di \"hot\"\n sogliaMov: Number(conf.radar_mov_min ?? sogliaHot),\n spreadMax: Number(conf.radar_spread_max ?? 3),\n liqMax: Number(conf.radar_liq_max ?? 1.8),\n });\n for (const p of picks) {\n await sq.execute({\n // la versione vera (base/v2/manga), non la stringa 'radar': senza,\n // a valle il filtro versione non ha niente da confrontare (buco del\n // 17/7 → alert falso su OP13-119)\n sql: `INSERT INTO watchlist (codice, nome, version, id_product, attiva, auto, ultimo_hot)\n VALUES (?, ?, ?, ?, 1, 1, ?)\n ON CONFLICT(codice) DO UPDATE SET\n id_product = excluded.id_product,\n nome = excluded.nome,\n version = excluded.version,\n ultimo_hot = excluded.ultimo_hot\n WHERE watchlist.auto = 1`,\n args: [p.codice, p.nome, p.version, p.idProduct, oggi],\n });\n }\n // Migrazione 17/7: le righe radar create prima del fix versione portano\n // version='radar' e l'idProduct del mover più illiquido — sono ESATTAMENTE\n // le carte-trappola (OP13-119 & co) e la scadenza a 7 giorni le terrebbe\n // vive una settimana. I pick nuovi hanno la versione vera, quindi questa\n // DELETE colpisce solo il passato.\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE auto = 1 AND version = 'radar'\",\n args: [],\n });\n const scadenza = new Date(\n Date.parse(adesso) -\n Number(conf.radar_scadenza_giorni ?? 7) * 24 * 3600 * 1000,\n ).toISOString().slice(0, 10);\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE auto = 1 AND (ultimo_hot IS NULL OR ultimo_hot < ?)\",\n args: [scadenza],\n });\n console.log(`radar: ${picks.length} movers → ${picks.map((p) => p.codice).join(\", \") || \"nessuno\"}`);\n }\n const carte = await query(\n sq,\n \"SELECT codice, id_product, version, auto FROM watchlist ORDER BY codice\",\n );\n\n let aggiornate = 0;\n let senzaProdotto = 0;\n const anomalie: string[] = [];\n\n for (const carta of carte) {\n const codice = String(carta.codice);\n if (carta.id_product == null) {\n console.log(`priceguide: ${codice} senza id_product (manca il pick all'/add)`);\n senzaProdotto++;\n continue;\n }\n const prezzi = guida.get(Number(carta.id_product));\n if (!prezzi) {\n console.log(`priceguide: idProduct ${carta.id_product} non in guida`);\n senzaProdotto++;\n continue;\n }\n\n // Detect v2 — bande: il trend CM di OGNI versione del codice. Servono a\n // S2 (il prezzo dell'annuncio dice quale versione è) e come fonte F1.\n const candidati = resolveCandidates(codice, prodotti);\n for (let i = 0; i < candidati.length; i++) {\n await sq.execute({\n sql:\n \"INSERT OR REPLACE INTO bande (codice, version, id_product, trend, data) VALUES (?, ?, ?, ?, ?)\",\n args: [\n codice,\n VERSIONI[i] ?? `v${i + 1}`,\n candidati[i].idProduct,\n guida.get(candidati[i].idProduct)?.trend ?? null,\n oggi,\n ],\n });\n }\n\n const montre = await deps.montreLookup(codice);\n if (montre?.handle) {\n await sq.execute({\n sql: \"UPDATE watchlist SET montre_handle = ? WHERE codice = ?\",\n args: [montre.handle, codice],\n });\n }\n\n // Montre ha una variante per rarita' (il variant-picker della pagina): si\n // prende quella che corrisponde alla versione tracciata, non la prima della\n // lista (16/7). Se nessuna combacia resta null -> Montre non fa da\n // riferimento per questa carta, meglio che dare il prezzo di un'altra.\n const variante = montre\n ? scegliVariante(\n montre.varianti,\n prezzi.trend,\n Number(conf.montre_banda ?? 3),\n )\n : null;\n\n // Radar su carta illiquida (17/7): se NIENTE di ciò che Montre vende\n // sotto questo codice arriva neanche vicino al trend CM, il riferimento\n // è spazzatura da annunci-civetta (Nami OP10-088: Montre \"Non comune\"\n // €0,50 contro trend CM €13 → 1 alert falso; Zoro OP10-113: €0,50 contro\n // low CM €45,95 → 2 alert falsi). Era la protezione che il vecchio\n // cancello Montre dava gratis e che l'appaiamento per varianti aveva\n // silenziato (variante fuori banda → null → cancello muto). Solo per le\n // voci auto: le manuali le ha scelte Alessandro, si segnala e basta.\n if (Boolean(carta.auto) && montre && !variante && prezzi.trend != null) {\n const maxMontre = Math.max(...montre.varianti.map((v) => v.prezzo));\n const banda = Number(conf.montre_banda ?? 3);\n if (maxMontre * banda < Number(prezzi.trend)) {\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE codice = ? AND auto = 1\",\n args: [codice],\n });\n console.log(\n `radar: fuori ${codice} — Montre max €${maxMontre} vs trend CM €${prezzi.trend} (riferimento fasullo)`,\n );\n continue;\n }\n }\n\n // Montre stessa mostra varianti a prezzi lontanissimi (20/7): OP15-094\n // \"Non comune €0,50\" e \"Dash Pack €10\" — il trend CM 8,15 aggancia la\n // Dash Pack, ma su Vinted arrivano annunci della comune da 0,50 e il\n // riferimento gonfiato produce alert falsi. Se Montre — fonte più\n // affidabile del nostro resolveCandidates — dice che sotto un codice\n // convivono prezzi con spread eccessivo, la carta è ambigua come per\n // versioniAmbigue: fuori dal radar. Solo AUTO; le manuali le sceglie\n // Alessandro consapevolmente.\n if (Boolean(carta.auto) && montre) {\n const prezziM = montre.varianti.map((v) => v.prezzo).filter((p) => p > 0);\n if (prezziM.length >= 2) {\n const spread = Math.max(...prezziM) / Math.min(...prezziM);\n if (spread > Number(conf.radar_montre_spread ?? 4)) {\n await sq.execute({\n sql: \"DELETE FROM watchlist WHERE codice = ? AND auto = 1\",\n args: [codice],\n });\n console.log(\n `radar: fuori ${codice} — varianti Montre da €${Math.min(...prezziM)} a €${Math.max(...prezziM)} (spread ${spread.toFixed(1)}× → ambigua)`,\n );\n continue;\n }\n }\n }\n\n // Sanity check (regola di Alessandro): Montre prezza a ~CM+20/30%, quindi\n // un low oltre Montre x1.5 e' quasi certamente agganciato alla versione\n // sbagliata. Ora vale per OGNI versione: prima il prezzo Montre era sempre\n // quello della base, quindi il confronto reggeva solo sulle base.\n if (\n variante && prezzi.low != null &&\n Number(prezzi.low) > variante.prezzo * 1.5\n ) {\n anomalie.push(\n `${codice} (${carta.version}): low CM \\u20ac${prezzi.low} vs Montre ${variante.titolo} \\u20ac${variante.prezzo}`,\n );\n }\n\n await sq.execute({\n sql:\n `INSERT OR REPLACE INTO prices\n (codice, data, low, trend, avg1, avg7, avg30, hot, montre_prezzo, montre_disp)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n codice,\n oggi,\n prezzi.low,\n prezzi.trend,\n prezzi.avg1,\n prezzi.avg7,\n prezzi.avg30,\n isHot(prezzi.avg1, prezzi.avg7, sogliaHot) ? 1 : 0,\n variante?.prezzo ?? null,\n variante ? (variante.disponibile ? 1 : 0) : null,\n ],\n });\n aggiornate++;\n }\n\n await sq.execute({\n sql: \"INSERT OR REPLACE INTO config (chiave, valore) VALUES ('priceguide_last_ok', ?)\",\n args: [adesso],\n });\n\n if (anomalie.length > 0 && deps.notifica) {\n await deps.notifica(\n \"\\u26a0\\ufe0f Sanity check riferimenti \\u2014 probabile versione sbagliata:\\n\" +\n anomalie.join(\"\\n\") +\n \"\\nSistema con /remove CODICE + /add CODICE\",\n );\n }\n\n console.log(\n `priceguide: ${aggiornate} aggiornate, ${senzaProdotto} saltate, ${anomalie.length} anomalie`,\n );\n return { aggiornate, senzaProdotto, anomalie: anomalie.length };\n}\n\n// entrypoint val.town (cron trigger, 0 3 * * *)\nexport default async function () {\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n await initSchema(sqlite);\n return aggiornaPrezzi({\n sqlite,\n fetchPriceGuide: fetchPriceGuideReal,\n fetchProducts: fetchProductsReal,\n montreLookup: montreLookupReal,\n adesso: () => new Date().toISOString(),\n notifica: (testo) =>\n sendMsg(Deno.env.get(\"TG_CHAT_ID\") ?? \"\", testo, {\n token: Deno.env.get(\"TG_TOKEN\") ?? \"\",\n }),\n });\n}\n",[201],"pulls","branches",1,"forks","envVars",{"_216":144,"_218":61},"connections",{"_216":61,"_217":61},"count","unfilledCount","emptyCount",{"_43":200,"_32":201,"_30":202,"_140":-5,"_41":42,"_40":203,"_142":25,"_38":253,"_13":197,"_33":205,"_35":206,"_24":25,"_147":-5,"_229":254,"_27":255},{"_43":192,"_32":193,"_30":194,"_140":-5,"_41":42,"_40":195,"_142":25,"_38":250,"_13":197,"_33":145,"_35":198,"_24":25,"_147":-5,"_229":251,"_27":252},{"_43":188,"_32":28,"_30":31,"_140":-5,"_41":42,"_40":14,"_142":25,"_38":247,"_13":190,"_33":34,"_35":37,"_24":25,"_147":-5,"_229":248,"_27":249},{"_43":180,"_32":181,"_30":182,"_140":-5,"_41":42,"_40":183,"_142":123,"_38":244,"_13":185,"_33":145,"_35":186,"_24":25,"_147":-5,"_229":245,"_27":246},{"_43":172,"_32":173,"_30":174,"_140":-5,"_41":42,"_40":175,"_142":123,"_38":241,"_13":177,"_33":145,"_35":178,"_24":25,"_147":-5,"_229":242,"_27":243},{"_43":164,"_32":165,"_30":166,"_140":-5,"_41":42,"_40":167,"_142":123,"_38":238,"_13":169,"_33":145,"_35":170,"_24":25,"_147":-5,"_229":239,"_27":240},{"_43":156,"_32":157,"_30":158,"_140":-5,"_41":42,"_40":159,"_142":123,"_38":235,"_13":161,"_33":145,"_35":162,"_24":25,"_147":-5,"_229":236,"_27":237},{"_43":149,"_32":150,"_30":151,"_140":-5,"_41":42,"_40":152,"_142":123,"_38":232,"_13":144,"_33":145,"_35":154,"_24":25,"_147":-5,"_229":233,"_27":234},{"_43":137,"_32":138,"_30":139,"_140":-5,"_41":42,"_40":141,"_142":25,"_38":228,"_13":144,"_33":145,"_35":146,"_24":25,"_147":-5,"_229":230,"_27":231},["D",1784294049484],"children",[],[138],["D",1784294052171],[],[150],["D",1784239110599],[],[157],["D",1784294608511],[],[165],["D",1784069260911],[],[173],["D",1784239113634],[],[181],["D",1784801637910],[],[28],["D",1784801426715],[],[193],["D",1784801426413],[],[201],["D",1784047215381],["D",1789489305251],{"_98":97,"_105":101},{"_98":97,"_99":97,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":294,"_295":296,"_297":298,"_299":25,"_300":25,"_301":25,"_302":123,"_303":-5,"_304":-7,"_305":-7,"_306":61,"_307":25,"_308":25,"_309":-5,"_310":25,"_311":25,"_312":25,"_313":-5},"ENV",{"_265":266,"_267":268,"_269":88,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v73