[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_151":152,"_153":154},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_101":84,"_27":53,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":25,"_115":116,"_117":25,"_118":-5,"_119":-5,"_120":121},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","196b6468-87a7-11f1-92d0-1607ee4eb77e","name","fileType","interval","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ============================================================================\n// SCHRITT 2/3 des Migrationsplans - VOLLSTAENDIGE VERARBEITUNG.\n//\n// Aufbauend auf Schritt 1 (reiner Roh-Empfaenger, unveraendert als\n// helius_webhook_raw_log erhalten) kommt jetzt hinzu:\n// - Parsing des Helius-Enhanced-Payloads (defensiv, siehe classifyBuyEvent)\n// - Kaufrichtungs-Erkennung, RugCheck, Telegram-Versand, Dedup\n// - Ein Warteschlangen-Muster fuer die eigentliche (langsamere) Verarbeitung,\n// NACH der sofortigen HTTP-200-Antwort an Helius (Begruendung siehe unten)\n//\n// QUELLENLAGE FUER DAS PAYLOAD-FORMAT (Projektregel: nichts annehmen ohne\n// Kennzeichnung):\n// - Der POST-Body ist laut offizieller Doku ein JSON-ARRAY von Transaktions-\n// Objekten (nicht ein einzelnes Objekt!):\n// https://www.helius.dev/docs/webhooks\n// (\"[{ ...transaction object... }]\")\n// - Die Felder pro Transaktions-Objekt (type, source, feePayer, signature,\n// tokenTransfers[], nativeTransfers[], accountData[], events.swap.{...})\n// sind zitiert aus:\n// https://www.helius.dev/docs/api-reference/enhanced-transactions/gettransactions\n// https://www.helius.dev/docs/api-reference/enhanced-transactions/llms.txt\n// - events.swap.tokenOutputs[]-Feldform ({ userAccount, tokenAccount, mint,\n// rawTokenAmount: { tokenAmount, decimals } }) ist im Doku-Beispiel EXPLIZIT\n// gezeigt. Die Form von tokenInputs[] ist NICHT explizit belegt - wir gehen\n// von derselben (symmetrischen) Form aus, das ist eine ANNAHME.\n// - WIR HABEN BISHER KEIN ECHTES SWAP-EVENT VON UNSEREM EIGENEN WEBHOOK\n// GESEHEN (nur ein NFT_SALE-Testereignis lief bereits durch). Die gesamte\n// Parsing-Logik unten ist deshalb bewusst so gebaut, dass JEDE Abweichung\n// von der erwarteten Struktur zu \"kein Alert, nur Status in der\n// Queue-Tabelle vermerken\" fuehrt - NIE zu einem Crash, NIE zu einer\n// geratenen/falschen Interpretation. Siehe Zusammenfassung am Ende des\n// Chats: was hier getestet ist (gegen synthetische, doku-konforme\n// Test-Payloads) und was noch eine Annahme ist (echte SWAP-Struktur).\n//\n// OFFENE FRAGE AUS SCHRITT 1 - JETZT GEKLAERT (nicht mehr offen):\n// Val Town unterstuetzt KEIN \"waitUntil\" fuer Hintergrundarbeit nach einer\n// zurueckgegebenen Response. Die offizielle Doku empfiehlt genau das Muster,\n// das hier umgesetzt ist: \"sending an unawaited HTTP request to a val which\n// does the longer processing\" (https://docs.val.town/vals/http/early-return/).\n// ABER: dieselbe Doku warnt explizit, dass ein nicht-awaiteter Promise\n// \"may or may not finish before the process is killed\" - das Fire-and-\n// Forget ist also NICHT 100% zuverlaessig. Deshalb zusaetzlich ein\n// Sicherheitsnetz: JEDES Event landet ZUERST synchron (vor der Response) in\n// der Queue-Tabelle (helius_event_queue, status='pending'). Ein SEPARATER\n// Cron-Val (sentry-helius-queue-sweep.ts) prueft in regelmaessigen\n// Abstaenden, ob liegen gebliebene \"pending\"-Eintraege existieren, und\n// verarbeitet sie nach - falls das Fire-and-Forget doch nicht durchkam.\n// Normalfall: Verarbeitung in Sekunden (Fire-and-Forget). Ausfall-Fall:\n// Verarbeitung erst beim naechsten Cron-Lauf (Intervall haengt vom\n// Val-Town-Plan ab - 1 Minute auf dem Pro-Plan, 15 Minuten auf dem\n// kostenlosen Plan, siehe docs.val.town/vals/cron/ - BITTE PRUEFEN, welcher\n// Plan aktiv ist, und den Cron im Dashboard auf das schnellstmoegliche\n// Intervall stellen).\n// ============================================================================\n\nconst MAX_LOGGED_BODY_CHARS = 200000;\nconst DEBUG_RECENT_LIMIT = 5;\n\n// Wie lange (Minuten) derselbe Coin (Mint) + dieselbe Wallet NICHT erneut\n// gemeldet wird - einfache Zeitfenster-Dedup, wie angefordert.\nconst DEDUP_WINDOW_MINUTES = 10;\n\n// RugCheck-Schwelle (score_normalised > diesem Wert = zu riskant, kein Alert)\n// - identisch zur bisherigen Schwelle im produktiven sentry-nansen-Val.\nconst MAX_RISK_SCORE = 50;\n\n// NEU (Baustein A, Root-Cause-Fund CLOVER/UNDERDOG-Verluste, siehe Chat):\n// score_normalised ist eine gewichtete SUMME ueber viele Risikokategorien\n// (Metadata, LP-Lock, Liquiditaet, Holder-Konzentration, ...) und kann bei\n// EXTREMER Holder-Konzentration trotzdem unter MAX_RISK_SCORE bleiben - live\n// gegen die echte RugCheck-API verifiziert: ein Token mit 100%\n// Single-Holder- und >70-80% Top-10-Konzentration hatte score_normalised=63,\n// nur knapp ueber der bisherigen Schwelle 50. Das bereits abgerufene\n// /report/summary enthaelt aber schon ein risks[]-Array mit benannten\n// Risikoeintraegen (z.B. \"Top 10 holders high ownership\", \"Single holder\n// ownership\", \"High ownership\", level=\"danger\") - wurde bisher NICHT\n// ausgewertet. Schluesselwort-Match statt exaktem String-Vergleich, weil\n// RugChecks Risiko-Namen nicht offiziell dokumentiert/stabil garantiert sind.\nconst HOLDER_RISK_KEYWORDS = [\"holder\", \"ownership\"];\nconst HOLDER_RISK_DANGER_LEVEL = \"danger\";\n\n// NEU (Baustein B): /report/summary enthaelt KEIN topHolders-Feld (live\n// verifiziert) - fuer einen EXAKTEN Top-10-Holder-Anteil ist der volle\n// /v1/tokens/{mint}/report-Endpoint noetig (schwerer, deshalb NUR fuer\n// Kandidaten, die Baustein A + den Score-Check bereits bestanden haben -\n// siehe processBuySignal(), spart RugCheck-Last fuer bereits aussortierte\n// Kandidaten). FAIL-CLOSED (ANDERS als MIN_SOL_AMOUNT): bei fehlgeschlagenem\n// Call oder nicht auswertbaren Daten wird KEIN Alert gesendet - dieser\n// Filter reagiert direkt auf reale Verluste, hier soll Vorsicht vor\n// Vollstaendigkeit gehen.\nconst MAX_TOP10_HOLDER_PCT = 50;\nconst TOP_HOLDERS_TO_SUM = 10;\n\n// Bekannte \"Quote\"-Mints (SOL/USDC/USDT). Wenn die ueberwachte Wallet in\n// einem Swap NUR einen dieser Mints \"erhaelt\", ist das vermutlich ein\n// VERKAUF ihres Coins gegen SOL/Stable - kein Kauf-Signal, wird deshalb\n// ausgeschlossen. Adressen sind oeffentliche Solana-Konstanten, verifiziert\n// ueber Solana Explorer / Solscan (siehe Recherche im Chat-Verlauf):\n// https://explorer.solana.com/address/So11111111111111111111111111111111111111112\n// https://solscan.io/token/EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v\nconst KNOWN_QUOTE_MINTS = new Set([\n \"So11111111111111111111111111111111111111112\", // Wrapped SOL\n \"EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v\", // USDC\n \"Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB\", // USDT\n]);\nconst WSOL_MINT = \"So11111111111111111111111111111111111111112\";\nconst LAMPORTS_PER_SOL = 1_000_000_000;\n\n// NEU (Mindest-Wert-Filter, DRINGEND laut Chat - zu viele Alerts fuer\n// uninteressante Kleinst-Kaeufe/Bot-Rauschen): Helius liefert keinen\n// USD-Wert, deshalb wird der vom feePayer eingesetzte SOL-Betrag als\n// Naeherung fuer die Kaufgroesse verwendet (siehe estimateSolSpent() unten).\n// ANGEPASST (Live-Beobachtung: ein Alert kam bei 0.1 SOL noch fuer einen\n// Kauf < $30 durch - kein starkes Ueberzeugungssignal). 1.5 SOL als fester\n// Mittelwert fuer eine Zielspanne von ca. $200-300 - da kein Live-USD-Kurs\n// im Code verfuegbar ist, KEIN dynamischer Wechselkurs, sondern ein reiner\n// Schaetzwert. WICHTIG: bei starken SOL-Kursschwankungen (deutlich rauf\n// oder runter) diesen Wert manuell nachjustieren, sonst driftet die\n// Ziel-USD-Spanne mit dem SOL-Kurs mit.\n// WICHTIG: FAIL-OPEN, falls der SOL-Betrag nicht ermittelbar ist (siehe\n// processBuySignal()) - lieber ein zusaetzlicher Alert als ein faelschlich\n// unterdruecktes echtes Signal.\nconst MIN_SOL_AMOUNT = 1.5;\n\nconst RUGCHECK_BASE_URL = \"https://api.rugcheck.xyz/v1/tokens/\";\nconst TELEGRAM_BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nconst TELEGRAM_CHAT_ID = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n// Baustein A: durchsucht risks[] aus /report/summary nach einem\n// Holder-Konzentrations-Risiko auf \"danger\"-Level. Gibt den gefundenen\n// Risikonamen zurueck, oder null, wenn keiner passt. Defensiv gegen jede\n// Abweichung vom erwarteten Format (fehlt/kein Array/kaputte Eintraege) -\n// gibt in diesem Fall null zurueck (kein Block durch dieses Baustein, aber\n// der bestehende Score-Check + Baustein B greifen weiterhin normal).\nfunction findHolderConcentrationRisk(summaryData: unknown): string | null {\n const risks = (summaryData as { risks?: unknown } | null | undefined)?.risks;\n if (!Array.isArray(risks)) {\n return null;\n }\n for (const entry of risks) {\n if (!entry || typeof entry !== \"object\") continue;\n const name = (entry as { name?: unknown }).name;\n const level = (entry as { level?: unknown }).level;\n if (typeof name !== \"string\" || typeof level !== \"string\") continue;\n if (level !== HOLDER_RISK_DANGER_LEVEL) continue;\n const nameLower = name.toLowerCase();\n if (HOLDER_RISK_KEYWORDS.some((kw) => nameLower.includes(kw))) {\n return name;\n }\n }\n return null;\n}\n\n// Baustein B: summiert die pct-Werte der ersten `topN` topHolders[]-\n// Eintraege aus dem VOLLEN /report (NICHT /report/summary). Gibt null\n// zurueck, wenn topHolders fehlt/kein Array/leer ist ODER kein einziger\n// Eintrag ein numerisches pct-Feld hatte - NIE 0 in diesen Faellen, das\n// wuerde faelschlich \"0% Konzentration\" (=sicher) suggerieren und das\n// gewuenschte Fail-Closed-Verhalten unterlaufen.\nfunction sumTopHoldersPct(\n fullReportData: unknown,\n topN: number,\n): number | null {\n const holders =\n (fullReportData as { topHolders?: unknown } | null | undefined)?.topHolders;\n if (!Array.isArray(holders) || holders.length === 0) {\n return null;\n }\n let sum = 0;\n let countedAny = false;\n for (const h of holders.slice(0, topN)) {\n const pct = (h as { pct?: unknown } | null | undefined)?.pct;\n if (typeof pct === \"number\" && Number.isFinite(pct)) {\n sum += pct;\n countedAny = true;\n }\n }\n return countedAny ? sum : null;\n}\n\nasync function ensureTables() {\n // Unveraendert aus Schritt 1 - reines Roh-Log, dient weiterhin nur der\n // manuellen Fehlersuche/Inspektion, wird von der neuen Verarbeitungslogik\n // NICHT gelesen (die liest stattdessen aus helius_event_queue).\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_webhook_raw_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n received_at TEXT,\n method TEXT,\n url TEXT,\n headers_json TEXT,\n body_raw TEXT,\n body_truncated INTEGER\n )`,\n );\n\n // NEU: eine Zeile PRO EINZELNEM EVENT (nicht pro HTTP-Request!), da ein\n // POST laut Doku ein ARRAY mehrerer Transaktionen enthalten kann.\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_event_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n received_at TEXT,\n raw_log_id INTEGER,\n payload_json TEXT,\n status TEXT,\n status_reason TEXT,\n processed_at TEXT\n )`,\n );\n\n // NEU: Dedup - ein Alert pro (Coin, Wallet)-Kombination innerhalb von\n // DEDUP_WINDOW_MINUTES.\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_alert_dedup (\n token_mint TEXT,\n wallet_address TEXT,\n last_alert_at TEXT,\n PRIMARY KEY (token_mint, wallet_address)\n )`,\n );\n}\n\n// ============================================================================\n// KLASSIFIZIERUNG: erkennt, ob ein einzelnes Transaktions-Objekt ein KAUF\n// ist - siehe Test-Datei test_classify_buy_event.mjs (20 Assertions, alle\n// bestanden) fuer die vollstaendige Verifikation dieser Funktion gegen\n// synthetische, doku-konforme Payloads UND gegen absichtlich kaputte/\n// abweichende Strukturen.\n// ============================================================================\ntype ClassifyResult =\n | {\n kind: \"buy\";\n wallet: string;\n mint: string;\n humanAmount: number | null;\n tokenAccount: string | null;\n estimatedSolSpent: number | null;\n estimatedSolSpentSource: string | null;\n }\n | { kind: \"not_a_swap\"; type: string }\n | { kind: \"not_a_buy\"; reason: string }\n | { kind: \"ambiguous\"; reason: string }\n | { kind: \"unrecognized\"; reason: string };\n\nfunction classifyBuyEvent(payload: unknown): ClassifyResult {\n try {\n if (payload === null || typeof payload !== \"object\") {\n return { kind: \"unrecognized\", reason: \"Payload ist kein Objekt\" };\n }\n const p = payload as Record;\n const type = p.type;\n if (typeof type !== \"string\" || type.length === 0) {\n return {\n kind: \"unrecognized\",\n reason: 'kein (gueltiges) \"type\"-Feld vorhanden',\n };\n }\n if (type.toUpperCase() !== \"SWAP\") {\n return { kind: \"not_a_swap\", type };\n }\n\n const feePayer = p.feePayer;\n if (typeof feePayer !== \"string\" || feePayer.length === 0) {\n return {\n kind: \"unrecognized\",\n reason: 'kein (gueltiges) \"feePayer\"-Feld vorhanden',\n };\n }\n\n const events = p.events as Record | undefined;\n const swapEvent = events && typeof events === \"object\"\n ? (events.swap as Record | undefined)\n : undefined;\n let result: ClassifyResult | null = null;\n if (swapEvent && typeof swapEvent === \"object\") {\n result = classifyFromSwapEvent(swapEvent, feePayer);\n // swapEvent vorhanden, aber intern nicht auswertbar -> Fallback versuchen.\n }\n\n if (!result && Array.isArray(p.tokenTransfers)) {\n result = classifyFromTokenTransfers(p.tokenTransfers, feePayer);\n }\n\n if (!result) {\n return {\n kind: \"unrecognized\",\n reason:\n \"weder events.swap noch tokenTransfers[] in auswertbarer Form vorhanden\",\n };\n }\n\n // NEU (Mindest-Wert-Filter-Grundlage, siehe Chat): fuer jeden erkannten\n // Kauf zusaetzlich versuchen, den vom feePayer eingesetzten SOL-Betrag\n // zu schaetzen - als Naeherung fuer die Kaufgroesse, da Helius keinen\n // USD-Wert liefert. Ueberschreibt die Platzhalter aus den Sub-Funktionen.\n if (result.kind === \"buy\") {\n const solEstimate = estimateSolSpent(p, feePayer);\n result = {\n ...result,\n estimatedSolSpent: solEstimate.solAmount,\n estimatedSolSpentSource: solEstimate.source,\n };\n }\n\n return result;\n } catch (err) {\n return {\n kind: \"unrecognized\",\n reason: \"Fehler beim Parsen: \" + String(err),\n };\n }\n}\n\nfunction classifyFromSwapEvent(\n swapEvent: Record,\n feePayer: string,\n): ClassifyResult | null {\n const tokenOutputs = swapEvent.tokenOutputs;\n if (!Array.isArray(tokenOutputs)) return null;\n\n const received = tokenOutputs.filter(\n (o) =>\n o &&\n typeof o === \"object\" &&\n (o as Record).userAccount === feePayer &&\n typeof (o as Record).mint === \"string\" &&\n !KNOWN_QUOTE_MINTS.has((o as Record).mint as string),\n ) as Record[];\n\n if (received.length === 0) {\n return {\n kind: \"not_a_buy\",\n reason:\n \"feePayer erhielt in events.swap.tokenOutputs keinen Nicht-Quote-Token \" +\n \"(vermutlich Verkauf, oder feePayer ist bei diesem Swap nicht der Empfaenger)\",\n };\n }\n if (received.length > 1) {\n return {\n kind: \"ambiguous\",\n reason: \"feePayer erhielt \" + received.length +\n \" unterschiedliche Tokens im selben Swap - \" +\n \"nicht eindeutig genug fuer ein automatisches Signal, kein Alert\",\n };\n }\n\n const entry = received[0];\n const humanAmount = extractHumanAmount(entry.rawTokenAmount);\n return {\n kind: \"buy\",\n wallet: feePayer,\n mint: entry.mint as string,\n humanAmount,\n tokenAccount: typeof entry.tokenAccount === \"string\"\n ? (entry.tokenAccount as string)\n : null,\n // Platzhalter - werden von classifyBuyEvent() nach Rueckkehr ueberschrieben\n // (estimateSolSpent() braucht das volle Payload, nicht nur swapEvent).\n estimatedSolSpent: null,\n estimatedSolSpentSource: null,\n };\n}\n\nfunction classifyFromTokenTransfers(\n tokenTransfers: unknown[],\n feePayer: string,\n): ClassifyResult {\n const received = tokenTransfers.filter(\n (t) =>\n t &&\n typeof t === \"object\" &&\n (t as Record).toUserAccount === feePayer &&\n typeof (t as Record).mint === \"string\" &&\n !KNOWN_QUOTE_MINTS.has((t as Record).mint as string),\n ) as Record[];\n\n if (received.length === 0) {\n return {\n kind: \"not_a_buy\",\n reason:\n \"feePayer erhielt in tokenTransfers[] (Fallback) keinen Nicht-Quote-Token\",\n };\n }\n if (received.length > 1) {\n return {\n kind: \"ambiguous\",\n reason:\n \"feePayer erhielt in tokenTransfers[] (Fallback) mehrere unterschiedliche Tokens - kein Alert\",\n };\n }\n\n const entry = received[0];\n const humanAmount = typeof entry.tokenAmount === \"number\"\n ? (entry.tokenAmount as number)\n : null;\n return {\n kind: \"buy\",\n wallet: feePayer,\n mint: entry.mint as string,\n humanAmount,\n tokenAccount: typeof entry.toTokenAccount === \"string\"\n ? (entry.toTokenAccount as string)\n : null,\n estimatedSolSpent: null,\n estimatedSolSpentSource: null,\n };\n}\n\nfunction extractHumanAmount(rawTokenAmount: unknown): number | null {\n if (!rawTokenAmount || typeof rawTokenAmount !== \"object\") return null;\n const { tokenAmount, decimals } = rawTokenAmount as Record;\n if (typeof decimals !== \"number\" || !Number.isFinite(decimals)) return null;\n const raw = typeof tokenAmount === \"string\"\n ? Number(tokenAmount)\n : (tokenAmount as number);\n if (typeof raw !== \"number\" || !Number.isFinite(raw)) return null;\n return raw / Math.pow(10, decimals);\n}\n\nfunction formatWalletShort(wallet: string): string {\n if (typeof wallet !== \"string\" || wallet.length < 8) {\n return wallet ?? \"(unbekannt)\";\n }\n return wallet.slice(0, 4) + \"...\" + wallet.slice(-4);\n}\n\n// ============================================================================\n// NEU: Schaetzung des vom feePayer eingesetzten SOL-Betrags, als Naeherung\n// fuer die \"Kaufgroesse\" (Helius liefert keinen USD-Wert). UNVERIFIZIERT\n// gegen ein echtes SWAP-Payload (wie der Rest von events.swap.tokenInputs,\n// siehe Kopfkommentar) - deshalb mehrstufig mit Fallbacks, liefert IMMER\n// lieber \"nicht ermittelbar\" (solAmount: null) statt eine geratene Zahl.\n// Prioritaet (keine Summierung ueber Stufen hinweg, um Doppelzaehlung zu\n// vermeiden, falls mehrere Repraesentationen desselben Vorgangs vorkommen):\n// 1. events.swap.nativeInput - direktester doku-belegter Wert (Wallet\n// setzt natives SOL direkt in den Swap ein).\n// 2. events.swap.tokenInputs mit Wrapped-SOL-Mint - deckt den vermutlich\n// haeufigeren Fall ab, dass SOL als WSOL-Token bewegt wird (z.B. bei\n// Jupiter/Raydium-Routen).\n// 3. Summe aller nativeTransfers[] vom feePayer weg (grober Fallback).\n// Siehe test_classify_buy_event.mjs fuer die vollstaendige Verifikation\n// (Prioritaetsreihenfolge, Fallback-Verhalten, defensive Fehlerbehandlung).\n// ============================================================================\nfunction estimateSolSpent(\n payload: Record,\n feePayer: string,\n): { solAmount: number | null; source: string | null } {\n try {\n const events = payload.events as Record | undefined;\n const swapEvent = events && typeof events === \"object\"\n ? (events.swap as Record | undefined)\n : undefined;\n\n // 1. events.swap.nativeInput\n if (swapEvent && typeof swapEvent === \"object\") {\n const nativeInput = swapEvent.nativeInput as\n | Record\n | undefined;\n if (\n nativeInput && typeof nativeInput === \"object\" &&\n nativeInput.account === feePayer\n ) {\n const lamports = typeof nativeInput.amount === \"string\"\n ? Number(nativeInput.amount)\n : (nativeInput.amount as number);\n if (\n typeof lamports === \"number\" && Number.isFinite(lamports) &&\n lamports > 0\n ) {\n return {\n solAmount: lamports / LAMPORTS_PER_SOL,\n source: \"events.swap.nativeInput\",\n };\n }\n }\n\n // 2. events.swap.tokenInputs mit Wrapped-SOL-Mint (ANNAHME: gleiche\n // Feldform wie tokenOutputs - unverifiziert, siehe Kopfkommentar).\n if (Array.isArray(swapEvent.tokenInputs)) {\n const wsolInput = (swapEvent.tokenInputs as unknown[]).find(\n (i) =>\n i && typeof i === \"object\" &&\n (i as Record).userAccount === feePayer &&\n (i as Record).mint === WSOL_MINT,\n ) as Record | undefined;\n if (wsolInput) {\n const humanAmount = extractHumanAmount(wsolInput.rawTokenAmount);\n if (humanAmount !== null && humanAmount > 0) {\n return {\n solAmount: humanAmount,\n source: \"events.swap.tokenInputs (WSOL)\",\n };\n }\n }\n }\n }\n\n // 3. Fallback: Summe aller nativeTransfers[] vom feePayer weg.\n if (Array.isArray(payload.nativeTransfers)) {\n let sumLamports = 0;\n let foundAny = false;\n for (const t of payload.nativeTransfers as unknown[]) {\n const transfer = t as Record | null;\n if (\n transfer && typeof transfer === \"object\" &&\n transfer.fromUserAccount === feePayer &&\n typeof transfer.amount === \"number\" &&\n Number.isFinite(transfer.amount)\n ) {\n sumLamports += transfer.amount as number;\n foundAny = true;\n }\n }\n if (foundAny && sumLamports > 0) {\n return {\n solAmount: sumLamports / LAMPORTS_PER_SOL,\n source: \"nativeTransfers-Summe\",\n };\n }\n }\n\n return { solAmount: null, source: null };\n } catch (_err) {\n return { solAmount: null, source: null };\n }\n}\n\n// ============================================================================\n// NEU (Bugfix, siehe Chat-Verlauf): intermittierende \"Telegram-Versand\n// fehlgeschlagen: HTTP 404\"-Fehler, obwohl der Bot-Token per direktem\n// getMe-Test bestaetigt gueltig war. UNTERSUCHUNG:\n//\n// 1. Der urspruenglich vermutete Mechanismus - \"Deno.env.get() auf Modul-\n// Ebene koennte bei parallelen Aufrufen inkonsistent sein/eine Race\n// Condition erzeugen\" - ist NACH Pruefung so NICHT der Mechanismus:\n// Deno.env.get() ist synchron, das Modul wird pro Isolate genau EINMAL\n// beim Kaltstart ausgewertet, der resultierende String ist danach eine\n// fixe Konstante. Es gibt in diesem Ablauf kein Interleaving-Fenster, in\n// dem ein bereits ausgewerteter Modul-Konstante \"zwischendurch\" undefined\n// werden koennte - das waere ein Zustand, den JS/Deno hier strukturell\n// nicht zulaesst.\n// 2. ABER: es gibt einen ANDEREN, tatsaechlich DOKUMENTIERTEN Mechanismus,\n// der GENAU zu \"intermittierend, nicht bei jedem Versuch\" passt:\n// docs.val.town/reference/environment-variables/ sagt woertlich, dass\n// neu gesetzte/geaenderte Env-Vars bereits \"warme\" Isolates NICHT\n// erreichen, bis diese neu deployt werden (\"Newly set or updated\n// environment variables don't reach isolates that are already warm\").\n// Bei 10+ parallelen Verarbeitungen/Sekunde laufen vermutlich mehrere\n// Isolate-Instanzen gleichzeitig - falls TELEGRAM_BOT_TOKEN/CHAT_ID zu\n// irgendeinem Zeitpunkt NACH dem ersten Start dieses Vals gesetzt/\n// bearbeitet wurden (auch nur einmal gespeichert/erneut eingegeben),\n// koennten seitdem laufende \"alte\" Isolates dauerhaft eine veraltete\n// (leere) Kopie behalten, waehrend neuere Isolates den korrekten Wert\n// haben - das erklaert exakt \"manche Anfragen klappen, manche nicht\",\n// ohne dass unser Code fehlerhaft ist. ABHILFE FALLS DAS ZUTRIFFT: einen\n// trivialen Edit an DIESEM Val speichern - das erzwingt laut Doku einen\n// Redeploy und frischt ALLE Isolates auf den aktuellen Wert auf.\n// 3. Zur eigenen Vermutung \"Telegram-Rate-Limiting\" als Ursache: das passt\n// NICHT zum beobachteten Statuscode. Telegram meldet Rate-Limiting laut\n// Bot-API als HTTP 429 (mit retry_after-Feld), NICHT als 404 - ein 404\n// von api.telegram.org bedeutet praktisch immer, dass der URL-Pfad\n// selbst nicht aufgeloest werden konnte, was zu einem leeren/fehlenden\n// Token in der URL passt (\"https://api.telegram.org/bot\" + undefined +\n// \"/sendMessage\" wird von JS zu \".../botundefined/sendMessage\" - das\n// ergibt bei Telegram zuverlaessig einen 404, kein anderer Fehlercode).\n// Trotzdem wird 429 unten separat und korrekt (mit retry_after)\n// behandelt, falls es zusaetzlich auftritt - schadet nicht, deckt einen\n// weiteren echten Fehlerfall ab.\n//\n// FIX: (a) VOR jedem Versandversuch wird explizit geprueft, ob Token/Chat-ID\n// ueberhaupt vorhanden sind - falls nicht, wird SOFORT ein eindeutiger Grund\n// zurueckgegeben (kein Telegram-Call, kein irrefuehrendes \"HTTP 404\" mehr).\n// (b) ein echter HTTP-Fehler (404/5xx/Netzwerkfehler) wird jetzt einmal\n// automatisch erneut versucht (kurze Wartezeit, bei 429 wird retry_after\n// respektiert, gedeckelt auf 5s) - faengt transiente Ausreisser ab, egal\n// welche der obigen Ursachen im Einzelfall zutrifft. Siehe\n// test_telegram_retry.mjs (17 Assertions, alle bestanden) fuer die\n// vollstaendige Verifikation dieser Logik per Mock-fetch/Mock-sleep.\n// ============================================================================\nconst TELEGRAM_MAX_ATTEMPTS = 2;\nconst TELEGRAM_RETRY_DELAY_MS = 700;\nconst TELEGRAM_MAX_RETRY_AFTER_MS = 5000;\n\nfunction sleep(ms: number): Promise {\n return new Promise((resolve) => setTimeout(resolve, ms));\n}\n\nfunction checkTelegramConfig(\n token: string | undefined,\n chatId: string | undefined,\n): { ok: boolean; reason?: string } {\n const missing: string[] = [];\n if (!token) missing.push(\"TELEGRAM_BOT_TOKEN\");\n if (!chatId) missing.push(\"TELEGRAM_CHAT_ID\");\n if (missing.length === 0) return { ok: true };\n return {\n ok: false,\n reason: missing.join(\" und \") +\n \" fehlt/fehlen zur Laufzeit (leer oder undefined) - NICHT versucht. \" +\n 'Moegliche Ursache: eine bereits laufende (\"warme\") Val-Town-Isolate hat eine Env-Var-Aenderung ' +\n \"noch nicht erhalten (siehe docs.val.town/reference/environment-variables/). Abhilfe: einen \" +\n \"trivialen Edit an diesem Val speichern - das erzwingt laut Doku einen Redeploy und frischt \" +\n \"alle Isolates auf.\",\n };\n}\n\nasync function sendTelegramWithRetry(\n text: string,\n): Promise<{ ok: boolean; reason?: string; attempts: number }> {\n const configCheck = checkTelegramConfig(TELEGRAM_BOT_TOKEN, TELEGRAM_CHAT_ID);\n if (!configCheck.ok) {\n return { ok: false, reason: configCheck.reason, attempts: 0 };\n }\n\n for (let attempt = 1; attempt <= TELEGRAM_MAX_ATTEMPTS; attempt++) {\n try {\n const res = await fetch(\n \"https://api.telegram.org/bot\" + TELEGRAM_BOT_TOKEN + \"/sendMessage\",\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: TELEGRAM_CHAT_ID, text }),\n },\n );\n\n if (res.ok) return { ok: true, attempts: attempt };\n\n const bodyText = await res.text();\n const isLastAttempt = attempt === TELEGRAM_MAX_ATTEMPTS;\n\n if (res.status === 429 && !isLastAttempt) {\n let waitMs = TELEGRAM_RETRY_DELAY_MS;\n try {\n const data = JSON.parse(bodyText);\n const retryAfterSec = data?.parameters?.retry_after;\n if (typeof retryAfterSec === \"number\" && retryAfterSec > 0) {\n waitMs = Math.min(\n retryAfterSec * 1000,\n TELEGRAM_MAX_RETRY_AFTER_MS,\n );\n }\n } catch {\n // Antwort nicht wie erwartet parsebar - Standard-Wartezeit verwenden.\n }\n console.error(\n \"Telegram HTTP 429 (Rate Limit), Retry in \" + waitMs + \"ms...\",\n );\n await sleep(waitMs);\n continue;\n }\n\n if (!isLastAttempt) {\n console.error(\"Telegram HTTP \" + res.status + \", Retry...\");\n await sleep(TELEGRAM_RETRY_DELAY_MS);\n continue;\n }\n\n return {\n ok: false,\n attempts: attempt,\n reason: \"Telegram-Versand fehlgeschlagen: HTTP \" + res.status + \" - \" +\n bodyText,\n };\n } catch (err) {\n const isLastAttempt = attempt === TELEGRAM_MAX_ATTEMPTS;\n if (!isLastAttempt) {\n await sleep(TELEGRAM_RETRY_DELAY_MS);\n continue;\n }\n return {\n ok: false,\n attempts: attempt,\n reason: \"Telegram-Versand-Fehler: \" + String(err),\n };\n }\n }\n\n return {\n ok: false,\n attempts: TELEGRAM_MAX_ATTEMPTS,\n reason: \"unerreichbar (sollte nie eintreten)\",\n };\n}\n\n// ============================================================================\n// VERARBEITUNG eines erkannten Kaufs: Dedup -> RugCheck -> Telegram -> Dedup-\n// Update. Siehe test_process_buy_signal.mjs (21 Assertions, alle bestanden)\n// fuer die vollstaendige Verifikation via Mock-sqlite/Mock-fetch.\n// ============================================================================\nasync function processBuySignal(\n buy: {\n wallet: string;\n mint: string;\n humanAmount: number | null;\n estimatedSolSpent: number | null;\n estimatedSolSpentSource: string | null;\n },\n): Promise<\n {\n action: \"done\" | \"skipped\" | \"error\";\n reason: string;\n rugcheckScore?: number;\n top10HolderPct?: number;\n }\n> {\n const nowIso = new Date().toISOString();\n\n // 1. Dedup-Pruefung (Objekt-Form { sql, args } - NICHT die alte,\n // bestaetigt kaputte Zwei-Argumente-Form!).\n const existing = await sqlite.execute({\n sql:\n \"SELECT last_alert_at FROM helius_alert_dedup WHERE token_mint = ? AND wallet_address = ?\",\n args: [buy.mint, buy.wallet],\n });\n\n if (existing.rows.length > 0) {\n const lastAlertAt = existing.rows[0][0] as string;\n const diffMinutes =\n (new Date(nowIso).getTime() - new Date(lastAlertAt).getTime()) / 60000;\n if (Number.isFinite(diffMinutes) && diffMinutes < DEDUP_WINDOW_MINUTES) {\n return {\n action: \"skipped\",\n reason: \"Dedup: dieselbe Wallet hat denselben Coin bereits vor \" +\n diffMinutes.toFixed(1) + \" Minute(n) ausgeloest (< \" +\n DEDUP_WINDOW_MINUTES + \" Min. Fenster)\",\n };\n }\n }\n\n // 2. NEU: Mindest-Wert-Filter (SOL-Naeherung, DRINGEND laut Chat - zu\n // viele Alerts fuer Kleinst-Kaeufe/Bot-Rauschen). Laeuft VOR RugCheck\n // (spart RugCheck-Calls fuer uninteressante Kaeufe). FAIL-OPEN wie\n // ausdruecklich gefordert: ist der SOL-Betrag nicht ermittelbar\n // (estimatedSolSpent === null), wird NICHT blockiert, sondern\n // durchgelassen - lieber ein zusaetzlicher Alert als ein faelschlich\n // unterdruecktes echtes Signal.\n if (buy.estimatedSolSpent !== null) {\n if (buy.estimatedSolSpent < MIN_SOL_AMOUNT) {\n return {\n action: \"skipped\",\n reason: \"Mindest-Wert-Filter: geschaetzter SOL-Einsatz \" +\n buy.estimatedSolSpent.toFixed(4) + \" SOL \" +\n \"(Quelle: \" + (buy.estimatedSolSpentSource ?? \"unbekannt\") +\n \") liegt unter MIN_SOL_AMOUNT=\" +\n MIN_SOL_AMOUNT + \" SOL - vermutlich Bot-Rauschen, kein Alert\",\n };\n }\n } else {\n console.log(\n \"Mindest-Wert-Filter: SOL-Betrag nicht ermittelbar (keine der bekannten Payload-Felder passte) - \" +\n \"Filter faellt fuer diesen Kauf aus (fail-open), Verarbeitung laeuft normal weiter.\",\n );\n }\n\n // 3. RugCheck /report/summary - jeder Fehler fuehrt zu \"nicht sicher\", NIE\n // zu einem Alert ohne erfolgreiche Pruefung. Baustein A (Holder-Risiko aus\n // risks[]) wird direkt aus DERSELBEN Antwort ausgewertet - keine\n // zusaetzliche Anfrage noetig.\n let rugcheckScore: number;\n let holderRiskName: string | null = null;\n try {\n const res = await fetch(RUGCHECK_BASE_URL + buy.mint + \"/report/summary\");\n if (!res.ok) {\n return {\n action: \"skipped\",\n reason: \"RugCheck: HTTP \" + res.status +\n \" - kein Report verfuegbar, kein Alert\",\n };\n }\n const data = await res.json();\n rugcheckScore = typeof data.score_normalised === \"number\"\n ? data.score_normalised\n : 100;\n holderRiskName = findHolderConcentrationRisk(data);\n } catch (err) {\n return {\n action: \"skipped\",\n reason: \"RugCheck-Fehler: \" + String(err) + \" - kein Alert\",\n };\n }\n\n // Baustein A: Holder-Konzentrations-Risiko blockiert UNABHAENGIG vom Score\n // (genau der Fall, der bei CLOVER/UNDERDOG trotz score_normalised<=50\n // durchgekommen ist - der Score allein hat das nicht zuverlaessig erkannt).\n if (holderRiskName !== null) {\n return {\n action: \"skipped\",\n reason: 'RugCheck-Risiko \"' + holderRiskName +\n '\" (danger) erkannt - Holder-Konzentration zu hoch, ' +\n \"unabhaengig von Score \" + rugcheckScore + \" blockiert\",\n rugcheckScore,\n };\n }\n\n if (rugcheckScore > MAX_RISK_SCORE) {\n return {\n action: \"skipped\",\n reason: \"RugCheck-Score \" + rugcheckScore + \"/100 ueber Schwelle (\" +\n MAX_RISK_SCORE + \") - zu riskant\",\n rugcheckScore,\n };\n }\n\n // Baustein B: NUR fuer Kandidaten, die Baustein A + den Score-Check bereits\n // bestanden haben - exakter Top-10-Holder-Anteil ueber den volleren\n // (teureren) /report-Endpoint (NICHT /report/summary - das enthaelt kein\n // topHolders-Feld, live verifiziert). FAIL-CLOSED bei jedem Fehler/nicht\n // auswertbaren Daten - anders als MIN_SOL_AMOUNT, weil dieser Filter direkt\n // auf reale Verluste reagiert und hier Vorsicht vor Vollstaendigkeit gehen soll.\n let top10HolderPct: number;\n try {\n const fullRes = await fetch(RUGCHECK_BASE_URL + buy.mint + \"/report\");\n if (!fullRes.ok) {\n return {\n action: \"skipped\",\n reason: \"RugCheck (voller Report): HTTP \" + fullRes.status +\n \" - Top-10-Holder-Check fehlgeschlagen (fail-closed), kein Alert\",\n rugcheckScore,\n };\n }\n const fullData = await fullRes.json();\n const summed = sumTopHoldersPct(fullData, TOP_HOLDERS_TO_SUM);\n if (summed === null) {\n return {\n action: \"skipped\",\n reason:\n \"RugCheck (voller Report): topHolders nicht auswertbar (fail-closed), kein Alert\",\n rugcheckScore,\n };\n }\n top10HolderPct = summed;\n } catch (err) {\n return {\n action: \"skipped\",\n reason: \"RugCheck (voller Report) Fehler: \" + String(err) +\n \" (fail-closed), kein Alert\",\n rugcheckScore,\n };\n }\n\n if (top10HolderPct > MAX_TOP10_HOLDER_PCT) {\n return {\n action: \"skipped\",\n reason: \"Top-10-Holder-Anteil \" + top10HolderPct.toFixed(2) +\n \"% ueber Schwelle (\" + MAX_TOP10_HOLDER_PCT + \"%) - \" +\n \"zu konzentriert, kein Alert\",\n rugcheckScore,\n top10HolderPct,\n };\n }\n\n // 4. Telegram-Versand\n const amountText = buy.humanAmount !== null\n ? buy.humanAmount.toLocaleString()\n : \"unbekannt\";\n const solText = buy.estimatedSolSpent !== null\n ? buy.estimatedSolSpent.toFixed(4) + \" SOL (Quelle: \" +\n buy.estimatedSolSpentSource + \")\"\n : \"nicht ermittelbar\";\n const text = \"🔥 Sentry: Smart-Money-Kauf erkannt\\n\\n\" +\n \"Coin (Mint): \" + buy.mint + \"\\n\" +\n \"Wallet: \" + formatWalletShort(buy.wallet) + \"\\n\" +\n \"Kaufbetrag (Coin-Menge): \" + amountText + \"\\n\" +\n \"Kaufbetrag (SOL, geschaetzt): \" + solText + \"\\n\\n\" +\n \"✅ RugCheck: Score \" + rugcheckScore + \"/100\\n\" +\n \"✅ Top-10-Holder: \" + top10HolderPct.toFixed(2) + \"%\\n\\n\" +\n \"Kaufen: https://axiom.trade/t/\" + buy.mint;\n\n const telegramResult = await sendTelegramWithRetry(text);\n const telegramOk = telegramResult.ok;\n if (!telegramOk) {\n return {\n action: \"error\",\n reason: telegramResult.reason ??\n \"Telegram-Versand fehlgeschlagen (unbekannter Grund)\",\n };\n }\n\n // 5. Dedup-Eintrag NUR bei erfolgreichem Versand aktualisieren (sonst\n // wuerde ein fehlgeschlagener Versand faelschlich als \"schon gemeldet\"\n // gelten und einen echten Retry stillschweigend unterdruecken).\n if (telegramOk) {\n await sqlite.execute({\n sql:\n \"INSERT INTO helius_alert_dedup (token_mint, wallet_address, last_alert_at) VALUES (?, ?, ?) \" +\n \"ON CONFLICT(token_mint, wallet_address) DO UPDATE SET last_alert_at = excluded.last_alert_at\",\n args: [buy.mint, buy.wallet, nowIso],\n });\n }\n\n return {\n action: \"done\",\n reason: \"alert_sent\",\n rugcheckScore,\n top10HolderPct,\n };\n}\n\n// ============================================================================\n// Verarbeitet EINEN Queue-Eintrag (per ID). Wird sowohl vom Fire-and-Forget-\n// Aufruf direkt nach dem Empfang (Normalfall, Sekunden) als auch vom\n// separaten Sweep-Cron (Sicherheitsnetz, falls Fire-and-Forget ausfiel)\n// aufgerufen - exakt dieselbe Logik, kein Doppel-Code.\n// ============================================================================\nasync function handleProcessQueueItem(\n idParam: string | null,\n): Promise {\n const id = idParam !== null ? Number(idParam) : NaN;\n if (!Number.isFinite(id) || id <= 0) {\n return new Response(\n JSON.stringify({ error: \"ungueltige oder fehlende Queue-ID\" }),\n {\n status: 400,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n await ensureTables();\n\n const rowResult = await sqlite.execute({\n sql: \"SELECT payload_json, status FROM helius_event_queue WHERE id = ?\",\n args: [id],\n });\n\n if (rowResult.rows.length === 0) {\n return new Response(\n JSON.stringify({ error: \"Queue-Eintrag \" + id + \" nicht gefunden\" }),\n {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n const [payloadJson, status] = rowResult.rows[0] as [string, string];\n\n // Idempotenz-Schutz: falls dieser Eintrag schon (z.B. vom Fire-and-Forget)\n // verarbeitet wurde, BEVOR der Sweep-Cron ihn ebenfalls aufgreift, nicht\n // ein zweites Mal Telegram/RugCheck ausloesen.\n if (status !== \"pending\") {\n return new Response(\n JSON.stringify({ action: \"already_processed\", status }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n let event: unknown;\n try {\n event = JSON.parse(payloadJson);\n } catch (err) {\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ? WHERE id = ?\",\n args: [\n \"error\",\n \"JSON.parse fehlgeschlagen: \" + String(err),\n new Date().toISOString(),\n id,\n ],\n });\n return new Response(\n JSON.stringify({ action: \"error\", reason: \"JSON.parse fehlgeschlagen\" }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n const classified = classifyBuyEvent(event);\n\n if (classified.kind !== \"buy\") {\n const reason = classified.kind === \"not_a_swap\"\n ? \"type=\" + classified.type\n : classified.reason;\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ? WHERE id = ?\",\n args: [\n \"skipped\",\n classified.kind + \": \" + reason,\n new Date().toISOString(),\n id,\n ],\n });\n return new Response(\n JSON.stringify({ action: \"skipped\", kind: classified.kind, reason }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n const result = await processBuySignal({\n wallet: classified.wallet,\n mint: classified.mint,\n humanAmount: classified.humanAmount,\n estimatedSolSpent: classified.estimatedSolSpent,\n estimatedSolSpentSource: classified.estimatedSolSpentSource,\n });\n\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ? WHERE id = ?\",\n args: [result.action, result.reason, new Date().toISOString(), id],\n });\n\n console.log(\n \"Queue-Eintrag \" + id + \" verarbeitet: action=\" + result.action +\n \", reason=\" + result.reason +\n (result.rugcheckScore !== undefined\n ? \", rugcheckScore=\" + result.rugcheckScore\n : \"\") +\n (result.top10HolderPct !== undefined\n ? \", top10HolderPct=\" + result.top10HolderPct\n : \"\"),\n );\n\n return new Response(JSON.stringify(result), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\n// ============================================================================\n// AB HIER: unveraendert aus Schritt 1 uebernommene Debug-/Statusseiten-Logik\n// (escapeHtml, formatBodyForDisplay, debugRecentEntriesHtml, safeStringify,\n// handleDebugRecent, handleDebugRawSql) - siehe Kommentare dort fuer die\n// jeweilige Historie/Begruendung. NICHT inhaltlich veraendert gegenueber dem\n// zuletzt gelieferten und diff-bestaetigten Stand.\n// ============================================================================\nfunction escapeHtml(\n input: string | null | undefined,\n fallback = \"(kein Wert vorhanden)\",\n): string {\n if (input === null || input === undefined) {\n return fallback;\n }\n const str = typeof input === \"string\" ? input : String(input);\n return str\n .replace(/&/g, \"&\")\n .replace(//g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\nfunction formatBodyForDisplay(bodyRaw: string | null | undefined): string {\n if (bodyRaw === null || bodyRaw === undefined) {\n return \"(kein body_raw gespeichert - diese Zeile hat gar keinen Payload-Wert in der Datenbank.)\";\n }\n if (bodyRaw === \"\") {\n return \"(leerer Body - der Request kam mit 0 Zeichen Inhalt an, vermutlich ein frueher Testaufruf ohne echten Payload.)\";\n }\n return escapeHtml(bodyRaw);\n}\n\nfunction debugRecentEntriesHtml(\n rows: Array<\n {\n receivedAt: string | null;\n bodyRaw: string | null;\n bodyTruncated: boolean;\n }\n >,\n): string {\n const back = \"

\";\n const head = \"\" +\n \"Sentry Helius Webhook - Debug\" +\n \"\" +\n \"

Letzte \" + DEBUG_RECENT_LIMIT +\n \" Helius-Webhook-Eintraege (neueste zuerst)

\";\n\n if (rows.length === 0) {\n return (\n head +\n \"

Noch KEIN Eintrag in helius_webhook_raw_log vorhanden - es ist \" +\n \"wahrscheinlich noch kein POST von Helius angekommen.

\" +\n back +\n \"\"\n );\n }\n\n const entriesHtml = rows\n .map((row, index) => {\n const truncatedNote = row.bodyTruncated\n ? \"

Hinweis: dieser Body war beim Speichern laenger als \" +\n \"MAX_LOGGED_BODY_CHARS und wurde gekappt.

\"\n : \"\";\n return (\n \"

\" +\n \"

Eintrag \" + (index + 1) + \" von \" + rows.length + \"

\" +\n \"

Empfangen am: \" +\n escapeHtml(row.receivedAt, \"(kein Zeitstempel vorhanden)\") + \"

\" +\n truncatedNote +\n \"

Roher Body (zum Kopieren markieren):

\" +\n \"

\" +\n        formatBodyForDisplay(row.bodyRaw) +\n        \"

\"\n );\n })\n .join(\"\");\n\n return head + entriesHtml + back + \"\";\n}\n\nasync function handleDebugRecent(): Promise {\n try {\n await ensureTables();\n const result = await sqlite.execute(\n \"SELECT received_at, body_raw, body_truncated FROM helius_webhook_raw_log ORDER BY id DESC LIMIT \" +\n DEBUG_RECENT_LIMIT,\n );\n const rows = (result.rows ?? []).map((\n [receivedAt, bodyRaw, bodyTruncated],\n ) => ({\n receivedAt,\n bodyRaw,\n bodyTruncated: !!bodyTruncated,\n }));\n return new Response(debugRecentEntriesHtml(rows), {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\n \"Fehler beim Lesen der letzten Debug-Eintraege:\",\n String(err),\n );\n return new Response(\n \"Fehler beim Lesen der letzten Eintraege: \" + String(err),\n {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n}\n\nfunction safeStringify(value: unknown): string {\n try {\n return JSON.stringify(\n value,\n (_key, val) => (typeof val === \"bigint\" ? val.toString() + \"n\" : val),\n 2,\n );\n } catch (err) {\n return \"\";\n }\n}\n\nasync function handleDebugRawSql(): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n try {\n await ensureTables();\n\n const countResult = await sqlite.execute(\n \"SELECT COUNT(*) AS row_count FROM helius_webhook_raw_log\",\n );\n const tableInfoResult = await sqlite.execute(\n \"PRAGMA table_info(helius_webhook_raw_log)\",\n );\n const rawRowsResult = await sqlite.execute(\n \"SELECT * FROM helius_webhook_raw_log ORDER BY id DESC LIMIT 3\",\n );\n\n const dump = { countResult, tableInfoResult, rawRowsResult };\n\n const html = \"\" +\n \"Sentry Helius Webhook - Raw SQL Debug\" +\n \"\" +\n \"

Roh-Diagnose (unformatiert, ungemappt)

\" +\n \"

Das hier ist GENAU das, was sqlite.execute() zurueckgibt - \" +\n \"keine Interpretation, kein Spalten-Mapping, keine Annahmen ueber die \" +\n \"Row-Struktur.

\" +\n \"

\" +\n      escapeHtml(safeStringify(dump)) +\n      \"

\" +\n back +\n \"\";\n\n return new Response(html, {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\"Fehler in der Roh-SQL-Diagnose:\", String(err));\n return new Response(\"Fehler in der Roh-SQL-Diagnose: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\n// NEU: zeigt die letzten Queue-Eintraege (Status, Grund, Zeiten) - damit man\n// nach dem Einspielen ohne Umweg ueber den Val-Town-Log-Viewer sehen kann,\n// ob echte Events ankommen und wie sie klassifiziert/verarbeitet wurden.\nasync function handleDebugQueue(): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n try {\n await ensureTables();\n const result = await sqlite.execute(\n \"SELECT id, received_at, status, status_reason, processed_at FROM helius_event_queue ORDER BY id DESC LIMIT 20\",\n );\n const rows = result.rows ?? [];\n const rowsHtml = rows\n .map(\n ([id, receivedAt, status, statusReason, processedAt]) =>\n \"\" +\n \"\" +\n escapeHtml(String(id)) + \"\" +\n \"\" +\n escapeHtml(receivedAt, \"-\") + \"\" +\n \"\" +\n escapeHtml(status, \"-\") + \"\" +\n \"\" +\n escapeHtml(statusReason, \"-\") + \"\" +\n \"\" +\n escapeHtml(processedAt, \"(noch nicht verarbeitet)\") + \"\" +\n \"\",\n )\n .join(\"\");\n\n const html = \"\" +\n \"Sentry Helius Webhook - Queue Debug\" +\n \"\" +\n \"

Letzte 20 Queue-Eintraege (neueste zuerst)

\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n rowsHtml +\n \"

ID	Empfangen	Status	Grund	Verarbeitet

\" +\n back +\n \"\";\n\n return new Response(html, {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\"Fehler bei der Queue-Debug-Ansicht:\", String(err));\n return new Response(\"Fehler bei der Queue-Debug-Ansicht: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\nfunction statusPageHtml(): string {\n return (\n \"\" +\n \"Sentry Helius Webhook\" +\n \"

Sentry Helius Webhook laeuft

\" +\n \"

Empfaengt Helius-SWAP-Events, klassifiziert Kaeufe, prueft RugCheck, \" +\n \"sendet Telegram-Alerts - mit Warteschlange + Sweep-Cron als Sicherheitsnetz.

\" +\n \"

Letzte 5 rohe Payloads anzeigen (Debug)

\" +\n \"

Roh-Diagnose: Zeilenanzahl + ungemappte Rohdaten (Debug)

\" +\n \"

Letzte 20 Queue-Eintraege (Status/Verarbeitung) anzeigen (Debug)

\" +\n \"\"\n );\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Verarbeitungs-Route: sowohl vom Fire-and-Forget-Call direkt nach dem\n // Empfang als auch vom separaten Sweep-Cron aufgerufen. Bewusst VOR der\n // GET/POST-Weiche geprueft, da diese Route sowohl per GET als auch POST\n // erreichbar sein soll (der Aufrufer entscheidet, beides wird gleich\n // behandelt).\n if (url.searchParams.get(\"process\") !== null) {\n return await handleProcessQueueItem(url.searchParams.get(\"process\"));\n }\n\n if (req.method === \"GET\") {\n if (url.searchParams.get(\"debug\") === \"raw-sql\") {\n return await handleDebugRawSql();\n }\n if (url.searchParams.get(\"debug\") === \"latest\") {\n return await handleDebugRecent();\n }\n if (url.searchParams.get(\"debug\") === \"queue\") {\n return await handleDebugQueue();\n }\n return new Response(statusPageHtml(), {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\n \"Method Not Allowed - erwartet GET (Statusseite) oder POST (Helius-Webhook)\",\n {\n status: 405,\n },\n );\n }\n\n // Ab hier: POST-Request, vermutlich von Helius.\n //\n // WICHTIG: nichts Blockierendes vor der Response ausser den beiden\n // schnellen, lokalen sqlite-Inserts (Roh-Log + Queue-Zeilen) - kein\n // RugCheck, kein Telegram, kein JSON-Parsing der einzelnen Events VOR der\n // Antwort (das JSON.parse hier ist nur, um die Events auf die Queue zu\n // verteilen; falls es fehlschlaegt, wird trotzdem sofort geantwortet).\n let bodyRaw = \"\";\n let bodyTruncated = false;\n let headersJson = \"{}\";\n\n try {\n bodyRaw = await req.text();\n if (bodyRaw.length > MAX_LOGGED_BODY_CHARS) {\n bodyRaw = bodyRaw.slice(0, MAX_LOGGED_BODY_CHARS);\n bodyTruncated = true;\n }\n } catch (err) {\n console.error(\"Fehler beim Lesen des Request-Body:\", String(err));\n bodyRaw = \"\";\n }\n\n try {\n headersJson = JSON.stringify(Object.fromEntries(req.headers.entries()));\n } catch (err) {\n console.error(\"Fehler beim Serialisieren der Headers:\", String(err));\n }\n\n let rawLogId: number | null = null;\n const queueIds: number[] = [];\n\n try {\n await ensureTables();\n\n const insertResult = await sqlite.execute({\n sql:\n \"INSERT INTO helius_webhook_raw_log (received_at, method, url, headers_json, body_raw, body_truncated) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [\n new Date().toISOString(),\n req.method,\n req.url,\n headersJson,\n bodyRaw,\n bodyTruncated ? 1 : 0,\n ],\n });\n // lastInsertRowid ist laut Val-Town-sqlite-Doku vorhanden, kann aber laut\n // derselben Doku je nach Statement null sein - defensiv behandeln, rein\n // informativ (raw_log_id ist nur ein Cross-Reference-Feld, nichts haengt\n // funktional davon ab).\n rawLogId = typeof insertResult.lastInsertRowid === \"bigint\"\n ? Number(insertResult.lastInsertRowid)\n : (insertResult.lastInsertRowid as number | null) ?? null;\n\n // Payload in einzelne Events aufteilen. Laut Doku ist der Body IMMER ein\n // Array - wir behandeln ein einzelnes Objekt trotzdem defensiv als\n // 1-Element-Array (falls Helius das Format doch mal aendert), statt\n // stillschweigend nichts zu verarbeiten.\n let events: unknown[] = [];\n try {\n const parsed = JSON.parse(bodyRaw);\n if (Array.isArray(parsed)) {\n events = parsed;\n } else if (parsed && typeof parsed === \"object\") {\n console.log(\n \"Hinweis: Payload war ein einzelnes Objekt statt eines Arrays (laut Doku erwartet) - als 1-Element behandelt.\",\n );\n events = [parsed];\n } else {\n console.error(\n \"Unerwartetes Payload-Format (weder Array noch Objekt) - nichts zu verarbeiten, nur Roh-Log vorhanden.\",\n );\n }\n } catch (err) {\n console.error(\n \"JSON.parse des Payloads fehlgeschlagen - nichts zu verarbeiten, nur Roh-Log vorhanden:\",\n String(err),\n );\n }\n\n const nowIso = new Date().toISOString();\n for (const event of events) {\n const eventJson = safeStringify(event);\n const queueInsert = await sqlite.execute({\n sql:\n \"INSERT INTO helius_event_queue (received_at, raw_log_id, payload_json, status, status_reason, processed_at) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [nowIso, rawLogId, eventJson, \"pending\", null, null],\n });\n const queueId = typeof queueInsert.lastInsertRowid === \"bigint\"\n ? Number(queueInsert.lastInsertRowid)\n : (queueInsert.lastInsertRowid as number | null);\n if (queueId !== null) queueIds.push(queueId);\n }\n\n console.log(\n \"Helius-Webhook-Payload geloggt (\" + bodyRaw.length + \" Zeichen\" +\n (bodyTruncated ? \", GEKAPPT\" : \"\") + \"), \" + events.length +\n \" Event(s) in die Queue eingereiht.\",\n );\n } catch (err) {\n console.error(\n \"KRITISCH: Fehler beim Loggen/Einreihen des Payloads:\",\n String(err),\n );\n console.error(\n \"Verlorener Payload (nur im Log, nicht garantiert in sqlite):\",\n bodyRaw.slice(0, 2000),\n );\n }\n\n // Fire-and-Forget: fuer jede neu eingereihte Queue-ID die Verarbeitung\n // ANSTOSSEN, aber NICHT awaiten (siehe Begruendung oben, docs.val.town/\n // vals/http/early-return/). Absichtlich NACH den schnellen sqlite-Inserts,\n // aber VOR der Response - der Call wird gestartet, sein Ergebnis aber\n // nicht abgewartet.\n for (const queueId of queueIds) {\n const processUrl = new URL(req.url);\n processUrl.search = \"\";\n processUrl.searchParams.set(\"process\", String(queueId));\n fetch(processUrl.toString(), { method: \"POST\" }).catch((err) => {\n console.error(\n \"Fire-and-Forget-Verarbeitung fehlgeschlagen fuer Queue-ID \" + queueId +\n \" (wird vom Sweep-Cron nachgeholt, falls dieser eingerichtet ist):\",\n String(err),\n );\n });\n }\n\n return new Response(JSON.stringify({ ok: true, queued: queueIds.length }), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst WEBHOOK_BASE_URL = \"https://sentry-helius-webhook.val.run/\";\nconst MIN_AGE_SECONDS = 20;\nconst SWEEP_BATCH_LIMIT = 50;\nconst MAX_TELEGRAM_RETRY_ATTEMPTS = 5;\n\nasync function ensureQueueTableExists() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_event_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n received_at TEXT,\n raw_log_id INTEGER,\n payload_json TEXT,\n status TEXT,\n status_reason TEXT,\n processed_at TEXT,\n retry_count INTEGER DEFAULT 0\n )`,\n );\n // Falls die Spalte retry_count in einer aelteren Tabellenversion noch\n // nicht existiert, fuegen wir sie defensiv nach - ALTER TABLE wirft\n // einen Fehler, wenn die Spalte schon da ist, das faehen wir ab.\n try {\n await sqlite.execute(\n \"ALTER TABLE helius_event_queue ADD COLUMN retry_count INTEGER DEFAULT 0\",\n );\n } catch (_err) {\n // Spalte existiert bereits - das ist der Normalfall nach dem ersten Lauf.\n }\n}\n\nexport default async function () {\n await ensureQueueTableExists();\n\n const cutoffIso = new Date(Date.now() - MIN_AGE_SECONDS * 1000).toISOString();\n\n // Pfad 1: normale \"pending\"-Eintraege (Fire-and-Forget kam nicht durch)\n const pendingResult = await sqlite.execute({\n sql:\n \"SELECT id FROM helius_event_queue WHERE status = ? AND received_at <= ? ORDER BY id ASC LIMIT ?\",\n args: [\"pending\", cutoffIso, SWEEP_BATCH_LIMIT],\n });\n const pendingIds = (pendingResult.rows ?? []).map((row) => row[0]);\n\n // Pfad 2: \"telegram_failed\"-Eintraege (Kauf war bereits als sicher\n // eingestuft, nur der Telegram-Versand ist gescheitert) - mit\n // Obergrenze, um keinen Eintrag endlos zu wiederholen.\n const telegramFailedResult = await sqlite.execute({\n sql:\n \"SELECT id FROM helius_event_queue WHERE status = ? AND retry_count < ? ORDER BY id ASC LIMIT ?\",\n args: [\"telegram_failed\", MAX_TELEGRAM_RETRY_ATTEMPTS, SWEEP_BATCH_LIMIT],\n });\n const telegramFailedIds = (telegramFailedResult.rows ?? []).map((row) =>\n row[0]\n );\n\n const allIds = [...pendingIds, ...telegramFailedIds];\n\n if (allIds.length === 0) {\n console.log(\n \"Sweep: keine liegen gebliebenen 'pending'- oder 'telegram_failed'-Eintraege gefunden.\",\n );\n return;\n }\n\n console.log(\n \"Sweep: \" + pendingIds.length + \" 'pending'- und \" +\n telegramFailedIds.length +\n \" 'telegram_failed'-Eintrag/Eintraege gefunden - verarbeite jetzt nach.\",\n );\n\n let processed = 0;\n let failed = 0;\n\n for (const id of allIds) {\n try {\n const processUrl = new URL(WEBHOOK_BASE_URL);\n processUrl.searchParams.set(\"process\", String(id));\n const res = await fetch(processUrl.toString(), { method: \"POST\" });\n\n if (!res.ok) {\n failed++;\n console.error(\n \"Sweep: Verarbeitung von Queue-ID \" + id + \" lieferte HTTP \" +\n res.status,\n );\n continue;\n }\n\n const result = await res.json();\n processed++;\n console.log(\n \"Sweep: Queue-ID \" + id + \" nachverarbeitet -> \" +\n JSON.stringify(result),\n );\n } catch (err) {\n failed++;\n console.error(\n \"Sweep: Fehler beim Nachverarbeiten von Queue-ID \" + id + \":\",\n String(err),\n );\n }\n }\n\n console.log(\n \"Sweep fertig: \" + processed + \" erfolgreich nachverarbeitet, \" + failed +\n \" fehlgeschlagen.\",\n );\n}","createdAt",["D",1785083754060],"branchVersion","branchId","ee4143d7-2a06-4f25-b167-f91317c6f155","id","17610679-aed9-4a16-830d-053d22e62713","sentry-helius-queue-sweep",["D",1784928718068],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","d88c9cf0-3002-4a43-9725-2854852c6d09","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8659-48bc-71e6-8825-ef535d702ef9","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_100":53},"org",{"_94":93,"_95":53,"_96":53,"_18":55,"_97":98,"_99":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","aouam_player","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":147,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":148,"_79":149,"_81":150,"_83":25},"tree",[142],"files",[142],"counts",{"_131":61,"_132":133,"_134":61,"_135":136,"_137":138},"contents",[122],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":123,"_32":28,"_30":31,"_124":-5,"_41":42,"_40":14,"_125":126,"_38":127,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_27":130},"d6541517-3b3a-4081-82ff-c76f6ca069cf","parentId","latest",true,["D",1785083754060],4,"label",[28],"pulls","branches",1,"forks","envVars",{"_139":61,"_141":61},"connections",{"_139":61,"_140":61},"count","unfilledCount","emptyCount",{"_43":123,"_32":28,"_30":31,"_124":-5,"_41":42,"_40":14,"_125":126,"_38":143,"_13":128,"_33":34,"_35":37,"_24":25,"_129":-5,"_144":145,"_27":146},["D",1785083754060],"children",[],[28],["D",1784928718068],{"_94":93,"_100":53},{"_94":93,"_95":53,"_96":53,"_18":55,"_97":98,"_99":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_119":184,"_185":186,"_187":188,"_189":25,"_190":25,"_191":25,"_192":126,"_193":-5,"_194":-7,"_195":-7,"_196":61,"_197":25,"_198":25,"_199":-5,"_200":25,"_201":25,"_202":25,"_203":-5},"ENV",{"_155":156,"_157":158,"_159":84,"_160":161,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5