[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_106":89,"_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":58,"_123":-5,"_124":-5,"_125":126},"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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",68,"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","67e70380-8799-11f1-a413-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ============================================================================\n// Verarbeitet Helius-Enhanced-Payloads (JSON-Array, siehe\n// https://www.helius.dev/docs/webhooks): Kaufrichtungs-Erkennung\n// (classifyBuyEvent), Konfluenz, Aktivitaets-/Preis-/Liquiditaets-Check,\n// RugCheck, Telegram, Dedup. Jede Payload-Abweichung fuehrt zu \"kein Alert,\n// nur Status in der Queue\" - nie zu einem Crash.\n//\n// Val Town hat kein zuverlaessiges \"waitUntil\" fuer Hintergrundarbeit nach\n// der Response - deshalb landet jedes Event zuerst synchron in\n// helius_event_queue (status='pending'), ein Sweep-Cron\n// (sentry-helius-queue-sweep.ts) verarbeitet Liegengebliebenes nach.\n// ============================================================================\n\nconst MAX_LOGGED_BODY_CHARS = 200000;\nconst DEBUG_RECENT_LIMIT = 5;\n// NEU: Anzahl der Treffer, die die neue Payload-Suche (?debug=search&q=...)\n// maximal anzeigt (letzte N Treffer, neueste zuerst) - analog zu\n// DEBUG_RECENT_LIMIT, nur fuer die Such-Debug-Seite.\nconst DEBUG_SEARCH_LIMIT = 10;\n// Wie viele Zeichen vor/nach dem gefundenen Suchbegriff im Payload-Ausschnitt\n// mit angezeigt werden (Kontext, damit man nicht nur den nackten Treffer,\n// sondern etwas Umgebung sieht).\nconst DEBUG_SEARCH_EXCERPT_CONTEXT_CHARS = 150;\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// ROLLBACK (26.07.2026): Baustein A/B/C (Holder-Konzentration, Top-10-\n// Holder, Liquiditaets-Schwelle) kamen nach einem CLOVER/UNDERDOG-Verlust,\n// verursachten aber zu viel Instabilitaet (C blockierte zeitweise 42/42)\n// und wurden entfernt - zurueck zu nur score_normalised. Das Liquiditaets-\n// Risiko kehrt jetzt gezielter zurueck (siehe MIN_LIQUIDITY_USD unten, aus\n// DexScreener statt RugCheck - kein neuer Instabilitaets-Vektor).\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// ============================================================================\n// KONFLUENZ-LOGIK (Pfad A/B), ersetzt MIN_SOL_AMOUNT - bewusst ohne\n// CoinGecko/externe Preis-API (anders als der fruehere Python-Bot), alle\n// Schwellen direkt in SOL. Alert bei MINDESTENS einem Pfad erfuellt:\n// PFAD A: >= PATH_A_MIN_DISTINCT_WALLETS Wallets kaufen denselben Coin\n// innerhalb CONFLUENCE_WINDOW_MINUTES, SOL-Inflow >= PATH_A_MIN_SOL_TOTAL.\n// PFAD B: eine Wallet kauft >= PATH_B_MIN_SOL_SINGLE SOL auf einmal.\n// Wiederholungs-Alert: erst wieder ab >= REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL\n// neuem Inflow seit dem letzten Alert (kumulativ, kein Fenster).\n// FAIL-OPEN: unbekannter SOL-Betrag blockiert die Pruefung nicht.\n// helius_alert_dedup bleibt unveraendert; helius_coin_buys (Rohlog) und\n// helius_confluence_alert_state (Zeitstempel/Mint) sind additive Tabellen.\n// ============================================================================\nconst CONFLUENCE_WINDOW_MINUTES = 5;\nconst PATH_A_MIN_DISTINCT_WALLETS = 2;\nconst PATH_A_MIN_SOL_TOTAL = 10;\nconst PATH_B_MIN_SOL_SINGLE = 35;\nconst REPEAT_ALERT_MIN_NEW_SOL_INFLOW = PATH_A_MIN_SOL_TOTAL;\n\n// ============================================================================\n// Coin-Gesundheits-Check via DexScreener (EIN Abruf, drei Pruefungen,\n// FAIL-CLOSED wie RugCheck). Anlass Aktivitaets-Mindestschwelle (27.07.2026):\n// 1 Jahr alter Coin mit 0 Buys/Sells in 5 Min. loeste faelschlich einen\n// Alert aus. Anlass Preis-Crash + Liquiditaet (28.07.2026, OSCAR/Moondog-\n// Vorfall): die Mindestschwelle allein blockiert NICHTS gegen das Gegenteil\n// (Bot-/Sniper-Schwarm mit tausenden Trades) - deshalb zusaetzlich\n// priceChange und liquidity.usd auswerten, die DexScreener im selben Response\n// ohnehin mitliefert (kein Zusatz-Call). Bewusst weiterhin nur diese drei\n// einfachen Schwellen, keine kombinierten Bausteine (siehe ROLLBACK oben).\n// ============================================================================\nconst DEXSCREENER_TOKENS_URL =\n \"https://api.dexscreener.com/latest/dex/tokens/\";\nconst MIN_RECENT_ACTIVITY_TXNS_M5 = 2;\n// Preis-Crash-Filter: Coin faellt m5 <= -15% ODER h1 <= -50% -> kein Alert,\n// unabhaengig von Wallet-Konfluenz (ein aktiver Crash ist nie ein gesundes\n// Kaufsignal).\nconst PRICE_CRASH_M5_PCT = -15;\nconst PRICE_CRASH_H1_PCT = -50;\n// Liquiditaets-Untergrenze: unter diesem USD-Wert ist der Pool trivial\n// manipulierbar (OSCAR/Moondog hatte $2.513).\nconst MIN_LIQUIDITY_USD = 10000;\nconst ACTIVITY_CHECK_TIMEOUT_MS = 4000;\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// Rein informative Telegram-Zusatzzeile (Top-10-Holder-Anteil) - AUSDRUECKLICH\n// kein Filter (der fruehere, fail-closed Baustein B ist komplett entfernt).\n// Laeuft NACH der Sende-Entscheidung, kein Einfluss auf action/reason, liefert\n// bei Fehler/Timeout/Timeout einfach null (Zeile entfaellt, nie verzoegert).\nconst TOP_HOLDERS_TO_SUM = 10;\nconst TOP10_HOLDER_INFO_TIMEOUT_MS = 3000;\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 // NEU (28.07.2026, Diagnostik-Nachruestung nach OSCAR/Moondog-Vorfall):\n // Konfluenz-/DexScreener-/RugCheck-Zahlen auch bei status='done' speichern\n // (vorher NUR \"alert_sent\", keine Nachvollziehbarkeit). ALTER TABLE wirft\n // einen Fehler, wenn die Spalte schon existiert - das faengt try/catch ab,\n // analog zum retry_count-Pattern in sentry-helius-queue-sweep.\n try {\n await sqlite.execute(\n \"ALTER TABLE helius_event_queue ADD COLUMN diagnostics_json TEXT\",\n );\n } catch (_err) {\n // Spalte existiert bereits - Normalfall nach dem ersten Lauf.\n }\n\n // NEU: Dedup - ein Alert pro (Coin, Wallet)-Kombination innerhalb von\n // DEDUP_WINDOW_MINUTES. UNVERAENDERT durch die Konfluenz-Logik (27.07.2026\n // abends, siehe Kommentar bei den Pfad-A/B-Konstanten oben) - bewusst\n // exakt beibehalten.\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 // Konfluenz-Logik Pfad A/B: Rohlog jedes Kaufs mit bekanntem SOL-Betrag -\n // fuer die Pfad-A-Fensteraggregation und die Wiederholungs-Alert-Schwelle\n // (neuer Inflow seit letztem Alert). Getrennt von helius_alert_dedup.\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_coin_buys (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n mint TEXT,\n wallet_address TEXT,\n sol_amount REAL,\n bought_at TEXT\n )`,\n );\n\n // NEU (27.07.2026 abends, siehe Chat - Konfluenz-Logik Pfad A/B): ein\n // Zeitstempel PRO MINT (nicht pro Wallet+Mint wie helius_alert_dedup) -\n // dient AUSSCHLIESSLICH der Wiederholungs-Alert-Pruefung (mindestens\n // REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL neuer Inflow seit diesem Zeitpunkt).\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_confluence_alert_state (\n mint TEXT PRIMARY KEY,\n last_alert_at TEXT\n )`,\n );\n}\n\n// ============================================================================\n// KLASSIFIZIERUNG: erkennt, ob ein einzelnes Transaktions-Objekt ein KAUF ist.\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// Bot-Spec Punkt 5: bei Pfad A ALLE beteiligten Wallets, bei Pfad B nur eine.\nfunction formatWalletListLine(wallets: string[]): string {\n if (wallets.length <= 1) {\n return \"Wallet: \" + formatWalletShort(wallets[0] ?? \"(unbekannt)\");\n }\n return \"Wallets (\" + wallets.length + \"): \" +\n wallets.map(formatWalletShort).join(\", \");\n}\n\n// ============================================================================\n// Summiert die pct-Werte der ersten `topN` topHolders[]-Eintraege aus dem\n// VOLLEN /report (NICHT /report/summary - kein topHolders-Feld dort). Gibt\n// null zurueck (NIE 0) wenn topHolders fehlt/leer ist.\n// ============================================================================\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\n// ============================================================================\n// Ruft /report ab, liefert den Top-10-Holder-Anteil - AUSSCHLIESSLICH\n// informativ. Wirft NIE, braucht NIE laenger als TOP10_HOLDER_INFO_TIMEOUT_MS\n// (Promise.race mit Timeout -> null, der fetch laeuft im Hintergrund aus).\n// ============================================================================\nasync function fetchTop10HolderPctInfo(\n mint: string,\n fetchImpl: typeof fetch,\n): Promise {\n const timeoutPromise = new Promise((resolve) => {\n setTimeout(() => resolve(null), TOP10_HOLDER_INFO_TIMEOUT_MS);\n });\n const fetchPromise = (async (): Promise => {\n try {\n const res = await fetchImpl(RUGCHECK_BASE_URL + mint + \"/report\");\n if (!res.ok) return null;\n const data = await res.json();\n return sumTopHoldersPct(data, TOP_HOLDERS_TO_SUM);\n } catch (_err) {\n return null;\n }\n })();\n return Promise.race([fetchPromise, timeoutPromise]);\n}\n\n// Aktivitaets-Check via DexScreener, FAIL-CLOSED (siehe MIN_RECENT_ACTIVITY_TXNS_M5 oben).\nasync function fetchWithTimeout(\n url: string,\n timeoutMs: number,\n fetchImpl: typeof fetch,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n return await fetchImpl(url, { signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\n\n// Liquidestes Solana-Paar (chainId === \"solana\") - repraesentativer als andere.\nfunction mostLiquidSolanaPair(\n pairs: unknown,\n): Record | null {\n if (!Array.isArray(pairs)) return null;\n let best: Record | null = null;\n let bestLiquidity = -1;\n for (const p of pairs) {\n if (!p || typeof p !== \"object\") continue;\n const pair = p as Record;\n if (pair.chainId !== \"solana\") continue;\n const liq = (pair.liquidity as { usd?: unknown } | undefined)?.usd;\n const liquidity = typeof liq === \"number\" ? liq : 0;\n if (liquidity > bestLiquidity) {\n bestLiquidity = liquidity;\n best = pair;\n }\n }\n return best;\n}\n\ntype CoinHealthResult =\n | {\n ok: true;\n txnsM5: number;\n priceChangeM5: number | null;\n priceChangeH1: number | null;\n liquidityUsd: number;\n }\n | { ok: false; reason: string };\n\nasync function checkRecentCoinActivity(\n mint: string,\n fetchImpl: typeof fetch,\n): Promise {\n let res: Response;\n try {\n res = await fetchWithTimeout(\n DEXSCREENER_TOKENS_URL + mint,\n ACTIVITY_CHECK_TIMEOUT_MS,\n fetchImpl,\n );\n } catch (err) {\n return {\n ok: false,\n reason: \"DexScreener-Anfrage fehlgeschlagen/Timeout: \" + String(err),\n };\n }\n if (!res.ok) {\n return { ok: false, reason: \"DexScreener antwortete mit HTTP \" + res.status };\n }\n let data: unknown;\n try {\n data = await res.json();\n } catch (err) {\n return {\n ok: false,\n reason: \"DexScreener-Antwort war kein gueltiges JSON: \" + String(err),\n };\n }\n const pair = mostLiquidSolanaPair(\n (data as { pairs?: unknown } | null)?.pairs,\n );\n if (pair === null) {\n return {\n ok: false,\n reason: \"kein gehandeltes Solana-Paar fuer diesen Mint auf DexScreener gefunden\",\n };\n }\n\n // Liquiditaet zuerst (fail-closed bei unbekannt - ein Pool ohne\n // ermittelbare Liquiditaet ist genauso riskant wie einer unter der\n // Schwelle).\n const liqRaw = (pair.liquidity as { usd?: unknown } | undefined)?.usd;\n const liquidityUsd = typeof liqRaw === \"number\" ? liqRaw : null;\n if (liquidityUsd === null || liquidityUsd < MIN_LIQUIDITY_USD) {\n return {\n ok: false,\n reason: \"Liquiditaet \" +\n (liquidityUsd === null ? \"unbekannt\" : \"$\" + liquidityUsd.toFixed(0)) +\n \" < $\" + MIN_LIQUIDITY_USD + \" - Pool zu duenn/manipulierbar\",\n };\n }\n\n // Preis-Crash: OSCAR/Moondog-Vorfall (28.07.2026) - ein aktiv einbrechender\n // Preis ist kein gesundes Kaufsignal, unabhaengig von Wallet-Konfluenz.\n const pc = pair.priceChange as { m5?: unknown; h1?: unknown } | undefined;\n const priceChangeM5 = typeof pc?.m5 === \"number\" ? pc.m5 : null;\n const priceChangeH1 = typeof pc?.h1 === \"number\" ? pc.h1 : null;\n if (priceChangeM5 !== null && priceChangeM5 <= PRICE_CRASH_M5_PCT) {\n return {\n ok: false,\n reason: \"Preis \" + priceChangeM5.toFixed(1) + \"% in 5 Min. (<= \" +\n PRICE_CRASH_M5_PCT + \"%) - aktiver Crash\",\n };\n }\n if (priceChangeH1 !== null && priceChangeH1 <= PRICE_CRASH_H1_PCT) {\n return {\n ok: false,\n reason: \"Preis \" + priceChangeH1.toFixed(1) + \"% in 1h (<= \" +\n PRICE_CRASH_H1_PCT + \"%) - aktiver Crash\",\n };\n }\n\n // Aktivitaets-Mindestschwelle (urspruenglicher Zweck, 27.07.2026).\n const m5 = (pair.txns as { m5?: { buys?: unknown; sells?: unknown } } | undefined)\n ?.m5;\n const txnsM5 = (typeof m5?.buys === \"number\" ? m5.buys : 0) +\n (typeof m5?.sells === \"number\" ? m5.sells : 0);\n if (txnsM5 < MIN_RECENT_ACTIVITY_TXNS_M5) {\n return {\n ok: false,\n reason: txnsM5 + \" Buy/Sell-Transaktion(en) in den letzten 5 Minuten (< \" +\n MIN_RECENT_ACTIVITY_TXNS_M5 + \") - Coin wirkt inaktiv/tot\",\n };\n }\n return { ok: true, txnsM5, priceChangeM5, priceChangeH1, liquidityUsd };\n}\n\n// ============================================================================\n// Schaetzung des vom feePayer eingesetzten SOL-Betrags (Helius liefert\n// keinen USD-Wert) - IMMER lieber \"nicht ermittelbar\" als eine geratene\n// Zahl. Prioritaet (keine Summierung ueber Stufen hinweg): 1. events.swap.\n// nativeInput, 2. events.swap.tokenInputs (WSOL), 3. Summe aller\n// nativeTransfers[] vom feePayer weg (grober Fallback).\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// Bugfix-Historie: intermittierende \"HTTP 404\"-Telegram-Fehler trotz\n// gueltigem Bot-Token. Wahrscheinlichste Ursache laut Val-Town-Doku: neu\n// gesetzte Env-Vars erreichen bereits \"warme\" Isolates nicht, bis neu\n// deployt wird - manche parallelen Isolates haetten dann einen veralteten\n// (leeren) Token, andere den korrekten. Ein 404 von api.telegram.org passt\n// zu einem leeren/fehlenden Token in der URL (nicht zu Rate-Limiting, das\n// waere HTTP 429 mit retry_after - wird separat behandelt).\n// FIX: (a) vor jedem Versand wird Token/Chat-ID explizit geprueft, fehlt\n// eines wird sofort ein eindeutiger Grund zurueckgegeben (kein irrefuehrendes\n// 404 mehr). (b) ein echter HTTP-Fehler wird einmal automatisch erneut\n// versucht (429 respektiert retry_after, gedeckelt auf 5s).\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 -> Konfluenz -> Coin-Gesundheit\n// (DexScreener) -> RugCheck -> Dedup-Claim -> Telegram -> Zustand-Update.\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 confluenceReason?: string;\n diagnostics?: string;\n }\n> {\n const nowIso = new Date().toISOString();\n\n // 1. Dedup-Vorabpruefung - nur Optimierung, Garantie liegt seit dem\n // Race-Fix (28.07.2026) beim atomaren Claim in Schritt 5.\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 (27.07.2026 abends, siehe Chat): Konfluenz-Logik (Pfad A / Pfad\n // B) ERSETZT den bisherigen MIN_SOL_AMOUNT-Mindestwert-Filter komplett -\n // siehe ausfuehrlichen Kommentar bei den Konstanten oben.\n //\n // 2a. JEDER Kauf mit bekanntem SOL-Betrag wird in helius_coin_buys\n // protokolliert - nur so kann Pfad A ueberhaupt mehrere, zeitlich nahe\n // Kaeufe VERSCHIEDENER Wallets fuer denselben Coin zusammenzaehlen.\n if (buy.estimatedSolSpent !== null) {\n await sqlite.execute({\n sql:\n \"INSERT INTO helius_coin_buys (mint, wallet_address, sol_amount, bought_at) VALUES (?, ?, ?, ?)\",\n args: [buy.mint, buy.wallet, buy.estimatedSolSpent, nowIso],\n });\n } else {\n console.log(\n \"Konfluenz-Logik: SOL-Betrag nicht ermittelbar - dieser Kauf wird NICHT in helius_coin_buys \" +\n \"protokolliert (kann weder zu Pfad A beitragen noch selbst Pfad B ausloesen). FAIL-OPEN wie \" +\n \"zuvor beim MIN_SOL_AMOUNT-Filter: die Konfluenz-Pruefung selbst blockiert NICHT, Verarbeitung \" +\n \"laeuft normal weiter.\",\n );\n }\n\n let confluenceReason: string | null = null;\n // Default: nur auslösende Wallet, Pfad A erweitert unten auf alle.\n let confluenceWallets: string[] = [buy.wallet];\n if (buy.estimatedSolSpent === null) {\n confluenceReason =\n \"SOL-Betrag nicht ermittelbar - Konfluenz-Pruefung faellt aus (fail-open, wie zuvor bei MIN_SOL_AMOUNT)\";\n } else if (buy.estimatedSolSpent >= PATH_B_MIN_SOL_SINGLE) {\n confluenceReason = \"Pfad B: Einzelkauf \" +\n buy.estimatedSolSpent.toFixed(4) + \" SOL >= \" + PATH_B_MIN_SOL_SINGLE +\n \" SOL\";\n } else {\n const windowStartIso = new Date(\n new Date(nowIso).getTime() - CONFLUENCE_WINDOW_MINUTES * 60000,\n ).toISOString();\n const recentBuys = await sqlite.execute({\n sql:\n \"SELECT wallet_address, sol_amount FROM helius_coin_buys WHERE mint = ? AND bought_at >= ?\",\n args: [buy.mint, windowStartIso],\n });\n const distinctWallets = new Set();\n let totalSol = 0;\n for (const row of recentBuys.rows as [string, number][]) {\n distinctWallets.add(row[0]);\n totalSol += row[1];\n }\n if (\n distinctWallets.size >= PATH_A_MIN_DISTINCT_WALLETS &&\n totalSol >= PATH_A_MIN_SOL_TOTAL\n ) {\n confluenceReason = \"Pfad A: \" + distinctWallets.size +\n \" verschiedene Wallets, gemeinsamer SOL-Inflow \" +\n totalSol.toFixed(4) + \" SOL >= \" + PATH_A_MIN_SOL_TOTAL +\n \" SOL (Fenster: \" +\n CONFLUENCE_WINDOW_MINUTES + \" Min.)\";\n confluenceWallets = Array.from(distinctWallets);\n }\n }\n\n if (confluenceReason === null) {\n return {\n action: \"skipped\",\n reason: \"Konfluenz-Bedingung nicht erfuellt: weder Pfad A (>=\" +\n PATH_A_MIN_DISTINCT_WALLETS +\n \" Wallets, gemeinsam >=\" + PATH_A_MIN_SOL_TOTAL + \" SOL in \" +\n CONFLUENCE_WINDOW_MINUTES +\n \" Min.) noch Pfad B (>=\" + PATH_B_MIN_SOL_SINGLE +\n \" SOL Einzelkauf) erreicht\",\n };\n }\n\n // 2b. Wiederholungs-Alerts: hat dieser Coin BEREITS einen Konfluenz-Alert\n // ausgeloest, wird ein erneuter Alert nur zugelassen, wenn seit dem\n // letzten Alert mindestens REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL NEUER\n // Inflow hinzugekommen ist (kumulativ seit dem letzten Alert, NICHT auf\n // das 5-Minuten-Fenster aus Pfad A beschraenkt - siehe Chat).\n const stateResult = await sqlite.execute({\n sql:\n \"SELECT last_alert_at FROM helius_confluence_alert_state WHERE mint = ?\",\n args: [buy.mint],\n });\n if (stateResult.rows.length > 0) {\n const lastConfluenceAlertAt = stateResult.rows[0][0] as string;\n const newInflowResult = await sqlite.execute({\n sql:\n \"SELECT COALESCE(SUM(sol_amount), 0) FROM helius_coin_buys WHERE mint = ? AND bought_at > ?\",\n args: [buy.mint, lastConfluenceAlertAt],\n });\n const newInflowSinceLastAlert = Number(\n (newInflowResult.rows[0]?.[0] as number | undefined) ?? 0,\n );\n if (newInflowSinceLastAlert < REPEAT_ALERT_MIN_NEW_SOL_INFLOW) {\n return {\n action: \"skipped\",\n reason: \"Konfluenz-Bedingung (\" + confluenceReason +\n \") erfuellt, aber dieser Coin hat bereits am \" +\n lastConfluenceAlertAt +\n \" einen Konfluenz-Alert ausgeloest - seither erst \" +\n newInflowSinceLastAlert.toFixed(4) + \" SOL neuer Inflow (< \" +\n REPEAT_ALERT_MIN_NEW_SOL_INFLOW +\n \" SOL noetig fuer Wiederholungs-Alert)\",\n };\n }\n }\n\n // 3. NEU: Coin-Aktivitaets-Check (DexScreener, fail-closed, siehe oben) -\n // laeuft vor RugCheck, spart dessen Anfrage fuer inaktive Coins.\n const activityCheck = await checkRecentCoinActivity(buy.mint, fetch);\n if (!activityCheck.ok) {\n return {\n action: \"skipped\",\n reason: \"Aktivitaets-Check (DexScreener): \" + activityCheck.reason,\n };\n }\n\n // 4. RugCheck /report/summary - jeder Fehler fuehrt zu \"nicht sicher\", NIE\n // zu einem Alert ohne erfolgreiche Pruefung. ROLLBACK (26.07.2026, siehe\n // Kommentar oben bei MAX_RISK_SCORE): NUR noch score_normalised wird\n // ausgewertet - kein Baustein A (Holder-Risiko aus risks[]) und kein\n // Baustein C (Liquiditaets-Check) mehr, beide wurden komplett entfernt.\n let rugcheckScore: number;\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 } catch (err) {\n return {\n action: \"skipped\",\n reason: \"RugCheck-Fehler: \" + String(err) + \" - kein Alert\",\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 // ROLLBACK (26.07.2026): Baustein B als FILTER (exakter Top-10-Holder-\n // Anteil ueber den volleren, teureren /report-Endpoint, fail-closed) wurde\n // komplett entfernt und bleibt entfernt - die Sende-Entscheidung haengt\n // weiterhin ausschliesslich am Score-Check oben.\n\n // NEU (27.07.2026): rein informativer Top-10-Holder-Abruf, NUR fuer die\n // Telegram-Anzeige - siehe ausfuehrlichen Kommentar oben bei\n // TOP10_HOLDER_INFO_TIMEOUT_MS. Die Sende-Entscheidung steht zu diesem\n // Zeitpunkt bereits fest (Score-Check ist schon bestanden); dieser Aufruf\n // kann sie nicht mehr aendern. Zusaetzliches try/catch hier ist bewusste\n // Verteidigung in der Tiefe (fetchTop10HolderPctInfo() selbst wirft\n // bereits nach eigenem Anspruch nie) - unter GAR keinen Umstaenden darf\n // ein Fehler an dieser Stelle den Alert verhindern.\n let top10HolderPct: number | null = null;\n try {\n top10HolderPct = await fetchTop10HolderPctInfo(buy.mint, fetch);\n } catch (err) {\n console.error(\n \"Top-10-Holder-Info-Abruf fehlgeschlagen (rein informativ, Alert wird trotzdem gesendet): \" +\n String(err),\n );\n top10HolderPct = null;\n }\n const top10HolderLine = top10HolderPct !== null\n ? \"✅ Top-10-Holder: \" + top10HolderPct.toFixed(2) + \"%\\n\"\n : \"\";\n\n // 5. Race-Fix (28.07.2026): atomarer Dedup-Claim statt SELECT+INSERT-\n // nach-Versand (doppelte Helius-Zustellung sendete sonst denselben Alert\n // doppelt). ON CONFLICT...DO UPDATE...WHERE ist atomar: Update greift nur\n // nach Ablauf von DEDUP_WINDOW_MINUTES - bei Gleichzeitigkeit gewinnt nur einer.\n const dedupClaim = 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 \"WHERE (julianday(excluded.last_alert_at) - julianday(helius_alert_dedup.last_alert_at)) * 1440.0 >= ?\",\n args: [buy.mint, buy.wallet, nowIso, DEDUP_WINDOW_MINUTES],\n });\n if (dedupClaim.rowsAffected === 0) {\n return {\n action: \"skipped\",\n reason: \"Dedup: Wallet+Coin bereits innerhalb von \" + DEDUP_WINDOW_MINUTES +\n \" Min. gealertet (oder gleichzeitige Verarbeitung war schneller)\",\n };\n }\n\n // NEU (28.07.2026): Diagnostik fuer status_reason/diagnostics_json - siehe\n // Kommentar bei ensureTables(). Nutzt Zahlen, die ohnehin schon berechnet\n // wurden (kein Zusatz-Call), damit ein Vorfall wie OSCAR/Moondog kuenftig\n // aus der DB statt aus rohen Payloads rekonstruierbar ist.\n const diagnosticsJson = JSON.stringify({\n confluenceReason,\n confluenceWallets,\n rugcheckScore,\n activityTxnsM5: activityCheck.txnsM5,\n priceChangeM5: activityCheck.priceChangeM5,\n priceChangeH1: activityCheck.priceChangeH1,\n liquidityUsd: activityCheck.liquidityUsd,\n });\n\n // 6. 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 formatWalletListLine(confluenceWallets) + \"\\n\" +\n \"Kaufbetrag (Coin-Menge): \" + amountText + \"\\n\" +\n \"Kaufbetrag (SOL, geschaetzt): \" + solText + \"\\n\" +\n \"Ausloeser: \" + confluenceReason + \"\\n\\n\" +\n \"✅ RugCheck: Score \" + rugcheckScore + \"/100\\n\" +\n top10HolderLine +\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 // Claim zuruecknehmen, sonst wuerde ein echter Retry blockiert.\n await sqlite.execute({\n sql:\n \"DELETE FROM helius_alert_dedup WHERE token_mint = ? AND wallet_address = ? AND last_alert_at = ?\",\n args: [buy.mint, buy.wallet, nowIso],\n });\n return {\n action: \"error\",\n reason: telegramResult.reason ??\n \"Telegram-Versand fehlgeschlagen (unbekannter Grund)\",\n };\n }\n\n // 7. Konfluenz-Alert-Zustand (PRO MINT), fuer 2b - getrennt von Schritt 5.\n await sqlite.execute({\n sql:\n \"INSERT INTO helius_confluence_alert_state (mint, last_alert_at) VALUES (?, ?) \" +\n \"ON CONFLICT(mint) DO UPDATE SET last_alert_at = excluded.last_alert_at\",\n args: [buy.mint, nowIso],\n });\n\n return {\n action: \"done\",\n reason: \"alert_sent\",\n rugcheckScore,\n confluenceReason,\n diagnostics: diagnosticsJson,\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 // erfolgreich verarbeitet ODER endgueltig als Fehler markiert wurde, BEVOR\n // der Sweep-Cron ihn ebenfalls aufgreift, nicht ein zweites Mal Telegram/\n // RugCheck ausloesen. AUSNAHME (NEU, Gesamt-Check vom 26.07.2026):\n // \"telegram_failed\" ist bewusst NICHT terminal - genau dieser Status soll\n // vom Sweep-Cron erneut aufgegriffen werden koennen (siehe Kommentar\n // weiter unten), deshalb hier ausdruecklich durchgelassen.\n if (status !== \"pending\" && status !== \"telegram_failed\") {\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 // try/catch um processBuySignal(): ein unerwarteter Fehler darin (z.B.\n // sqlite-Fehler beim Dedup-Insert NACH bereits erfolgreichem Telegram-\n // Versand) darf die Queue-Zeile nicht auf \"pending\" haengen lassen, sonst\n // wuerde der Sweep-Cron denselben Kauf spaeter erneut verarbeiten und\n // moeglicherweise doppelt melden. Deshalb terminal auf \"error\" gesetzt\n // (kein Retry) - Vorsicht vor einem doppelten Alert geht hier vor Vorsicht\n // vor einem verlorenen Alert.\n let result: {\n action: \"done\" | \"skipped\" | \"error\";\n reason: string;\n rugcheckScore?: number;\n };\n try {\n 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 } catch (err) {\n console.error(\n \"Unerwarteter Fehler in processBuySignal() fuer Queue-ID \" + id +\n \" (kein Retry, siehe Kommentar):\",\n String(err),\n );\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ? WHERE id = ?\",\n args: [\n \"error\",\n \"Unerwarteter Fehler in processBuySignal(): \" + String(err),\n new Date().toISOString(),\n id,\n ],\n });\n return new Response(\n JSON.stringify({\n action: \"error\",\n reason: \"Unerwarteter Fehler in processBuySignal()\",\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n // Ein Telegram-Fehlschlag (action=\"error\", ausschliesslich der Telegram-\n // Fehlerfall aus processBuySignal) wird als \"telegram_failed\" (nicht\n // terminal) statt generisches \"error\" gespeichert, damit der Sweep-Cron\n // ihn erneut aufgreifen kann - ein bereits als sicher genug eingestufter\n // Alert soll nicht verloren gehen, nur weil Telegram kurz nicht erreichbar\n // war. Die zurueckgegebene JSON-Antwort bleibt \"action: error\"; nur der\n // interne Queue-Status unterscheidet sich.\n const queueStatus = result.action === \"error\"\n ? \"telegram_failed\"\n : result.action;\n\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ?, diagnostics_json = ? WHERE id = ?\",\n args: [\n queueStatus,\n result.reason,\n new Date().toISOString(),\n result.diagnostics ?? null,\n id,\n ],\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 );\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      \"

← 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\n// NEU: escaped einen vom Nutzer eingegebenen Suchbegriff fuer die Verwendung\n// in einem SQL-LIKE-Pattern - WICHTIG: verhindert, dass ein Suchbegriff, der\n// zufaellig \"%\" oder \"_\" enthaelt, als LIKE-Wildcard statt als woertlicher\n// Text interpretiert wird (das waere sonst z.B. bei einem Tickersymbol wie\n// \"AB_CD\" ein stiller Falsch-Treffer/Falsch-Negativ). Reihenfolge wichtig:\n// Backslash ZUERST escapen, sonst wuerden die danach fuer % und _\n// eingefuegten Backslashes selbst nochmal escaped.\nfunction escapeLikePattern(raw: string): string {\n return raw.replace(/\\\\/g, \"\\\\\\\\\").replace(/%/g, \"\\\\%\").replace(/_/g, \"\\\\_\");\n}\n\n// NEU: baut aus einem vollen payload_json-String einen kurzen, lesbaren\n// Ausschnitt rund um die erste Fundstelle des Suchbegriffs (statt den\n// gesamten, oft sehr langen Payload anzuzeigen). Case-insensitiver Vergleich\n// per toLowerCase() - deckt sich mit SQLite-LIKEs Standardverhalten fuer\n// ASCII-Zeichen (nicht volle Unicode-Gross-/Kleinschreibungs-Faltung, aber\n// fuer die hier erwarteten Suchbegriffe wie Ticker/Mint-Ausschnitte\n// ausreichend).\nfunction buildPayloadExcerpt(\n payloadJson: string | null | undefined,\n searchTerm: string,\n contextChars: number = DEBUG_SEARCH_EXCERPT_CONTEXT_CHARS,\n): string {\n if (payloadJson === null || payloadJson === undefined || payloadJson === \"\") {\n return \"(kein payload_json vorhanden)\";\n }\n const idx = payloadJson.toLowerCase().indexOf(searchTerm.toLowerCase());\n if (idx === -1) {\n // Sollte praktisch nicht vorkommen (die Zeile wurde ja gerade per\n // LIKE gefunden) - rein defensiv, falls SQLite-LIKE und JS toLowerCase()\n // sich bei Sonderzeichen/Unicode minimal unterschiedlich verhalten.\n // Zeigt dann einfach den Anfang des Payloads statt nichts.\n return payloadJson.length > 300\n ? payloadJson.slice(0, 300) + \"...\"\n : payloadJson;\n }\n const start = Math.max(0, idx - contextChars);\n const end = Math.min(\n payloadJson.length,\n idx + searchTerm.length + contextChars,\n );\n const prefix = start > 0 ? \"...\" : \"\";\n const suffix = end < payloadJson.length ? \"...\" : \"\";\n return prefix + payloadJson.slice(start, end) + suffix;\n}\n\nfunction debugSearchResultsHtml(\n searchTerm: string,\n rows: Array<{\n id: number | string | null;\n receivedAt: string | null;\n status: string | null;\n statusReason: string | null;\n payloadJson: string | null;\n }>,\n): string {\n const back = \"

← zurueck zur Statusseite

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

Suche nach "\" + escapeHtml(searchTerm) +\n \"" in payload_json

\" +\n \"

Zeigt die letzten \" + DEBUG_SEARCH_LIMIT +\n \" Treffer in helius_event_queue \" +\n \"(neueste zuerst). Suche ist case-insensitive (SQLite-LIKE).

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

Keine Treffer fuer "\" + escapeHtml(searchTerm) +\n \"" gefunden.

\" +\n back +\n \"\"\n );\n }\n\n const entriesHtml = rows\n .map((row, index) => {\n const excerpt = buildPayloadExcerpt(row.payloadJson, searchTerm);\n return (\n \"

\" +\n \"

Treffer \" + (index + 1) + \" von \" + rows.length + \" (Queue-ID \" +\n escapeHtml(row.id === null ? null : String(row.id), \"-\") + \")

\" +\n \"

Empfangen am: \" + escapeHtml(row.receivedAt, \"-\") +\n \"

\" +\n \"

Status: \" + escapeHtml(row.status, \"-\") + \"

\" +\n \"

Grund: \" + escapeHtml(row.statusReason, \"-\") +\n \"

\" +\n \"

Payload-Ausschnitt:

\" +\n \"

\" +\n        escapeHtml(excerpt) +\n        \"

\"\n );\n })\n .join(\"\");\n\n return head + entriesHtml + back + \"\";\n}\n\n// NEU: durchsucht payload_json in helius_event_queue nach einem vom Nutzer\n// im Browser eingegebenen Suchbegriff (?debug=search&q=...) - spart das\n// manuelle Schreiben von SQL fuer den haeufigen Fall \"kam ein bestimmter\n// Coin/Ticker/Mint ueberhaupt als Event rein, und wie wurde er verarbeitet?\".\nasync function handleDebugSearch(\n searchTermRaw: string | null,\n): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n const searchTerm = (searchTermRaw ?? \"\").trim();\n\n if (searchTerm.length === 0) {\n const html = \"\" +\n \"Sentry Helius Webhook - Payload-Suche\" +\n \"\" +\n \"

Payload-Suche

\" +\n \"

Kein Suchbegriff angegeben. Direkt per URL aufrufbar, z.B.:

\" +\n \"

\" +\n      \"?debug=search&q=DEINSUCHBEGRIFF

\" +\n \"

Oder hier eingeben:

\" +\n \"\" +\n back +\n \"\";\n return new Response(html, {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n try {\n await ensureTables();\n const likePattern = \"%\" + escapeLikePattern(searchTerm) + \"%\";\n const result = await sqlite.execute({\n sql:\n \"SELECT id, received_at, status, status_reason, payload_json FROM helius_event_queue \" +\n \"WHERE payload_json LIKE ? ESCAPE '\\\\' ORDER BY id DESC LIMIT \" +\n DEBUG_SEARCH_LIMIT,\n args: [likePattern],\n });\n const rows = (result.rows ?? []).map((\n [id, receivedAt, status, statusReason, payloadJson],\n ) => ({\n id,\n receivedAt,\n status,\n statusReason,\n payloadJson,\n }));\n return new Response(debugSearchResultsHtml(searchTerm, rows), {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\"Fehler bei der Payload-Suche:\", String(err));\n return new Response(\"Fehler bei der Payload-Suche: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\n// Debug-Route: alle eindeutigen wallet_address-Werte aus helius_alert_dedup\n// (jede Adresse, die je einen Alert ausgeloest hat) - zum Abgleich gegen die\n// aktuell ueberwachte Liste. Rein lesend, gleiches Muster wie andere Debug-Routen.\nasync function handleDebugAlertWallets(): Promise {\n const back = \"

← zurueck zur Statusseite

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

Alle Wallet-Adressen aus helius_alert_dedup (eindeutig, sortiert)

\" +\n \"

Jede Adresse, fuer die JEMALS erfolgreich ein Alert versendet wurde \" +\n \"(Spalte wallet_address, DISTINCT) - zum \" +\n \"Abgleich gegen die aktuell ueberwachte Wallet-Liste.

\";\n\n try {\n await ensureTables();\n const result = await sqlite.execute(\n \"SELECT DISTINCT wallet_address FROM helius_alert_dedup ORDER BY wallet_address\",\n );\n const addresses = (result.rows ?? [])\n .map(([walletAddress]) => walletAddress)\n .filter((a): a is string => typeof a === \"string\" && a.length > 0);\n\n if (addresses.length === 0) {\n return new Response(\n head +\n \"

Keine Eintraege in helius_alert_dedup gefunden - entweder wurde \" +\n \"noch nie erfolgreich ein Alert versendet, oder die Tabelle ist \" +\n \"(noch) leer.

\" +\n back +\n \"\",\n {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n },\n );\n }\n\n const listHtml = \"

\" + addresses.length +\n \" eindeutige Adresse(n) (eine pro Zeile, zum Kopieren markieren):

\" +\n \"

\" +\n      addresses.map((a) => escapeHtml(a)).join(\"\\n\") +\n      \"

\";\n\n return new Response(head + listHtml + back + \"\", {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\n \"Fehler beim Lesen der Alert-Wallets-Debug-Ansicht:\",\n String(err),\n );\n return new Response(\n \"Fehler beim Lesen von helius_alert_dedup: \" + String(err),\n {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n}\n\n// Debug-Route: wallet_address, token_mint UND last_alert_at aus\n// helius_alert_dedup (volle Zeilenansicht, nicht nur DISTINCT wallet_address\n// wie handleDebugAlertWallets() - eine Wallet kann mehrere Zeilen/Mints haben).\n// Optionaler Filter per ?wallet=..., sonst alle Zeilen, sortiert nach\n// last_alert_at aufsteigend. Rein lesend.\nasync function handleDebugAlertHistory(\n walletParam: string | null,\n): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n const filterNote = walletParam\n ? \"

Gefiltert auf Wallet-Adresse: \" +\n escapeHtml(walletParam) +\n \" - Filter entfernen (alle Zeilen zeigen)

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

Alert-Historie aus helius_alert_dedup (wallet_address, token_mint, last_alert_at)

\" +\n \"

Jede Zeile ist ein (token_mint, wallet_address)-Paar, fuer das JEMALS \" +\n \"erfolgreich ein Alert versendet wurde, mit dem Zeitpunkt des LETZTEN \" +\n \"Alerts fuer genau dieses Paar. Eine Wallet kann mehrere Zeilen haben \" +\n \"(eine je Mint). Sortiert nach last_alert_at, aeltester Alert zuerst.

\" +\n \"

Optionaler Filter: ?debug=alert-history&wallet=ADRESSE \" +\n \"zeigt nur Zeilen fuer genau diese Adresse.

\" +\n filterNote;\n\n try {\n await ensureTables();\n const result = walletParam\n ? await sqlite.execute({\n sql:\n \"SELECT wallet_address, token_mint, last_alert_at FROM helius_alert_dedup \" +\n \"WHERE wallet_address = ? ORDER BY last_alert_at ASC\",\n args: [walletParam],\n })\n : await sqlite.execute(\n \"SELECT wallet_address, token_mint, last_alert_at FROM helius_alert_dedup ORDER BY last_alert_at ASC\",\n );\n\n const rows = (result.rows ?? []).filter(\n (r: unknown[]) =>\n Array.isArray(r) && typeof r[0] === \"string\" && r[0].length > 0,\n ) as [string, string, string][];\n\n if (rows.length === 0) {\n const emptyMsg = walletParam\n ? \"Keine Eintraege in helius_alert_dedup fuer die Adresse \" +\n escapeHtml(walletParam) + \" gefunden.\"\n : \"Keine Eintraege in helius_alert_dedup gefunden - entweder wurde noch nie \" +\n \"erfolgreich ein Alert versendet, oder die Tabelle ist (noch) leer.\";\n return new Response(\n head + \"

\" + emptyMsg + \"

\" + back + \"\",\n {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n },\n );\n }\n\n const tableRows = rows\n .map(\n ([walletAddress, tokenMint, lastAlertAt]) =>\n \"\" +\n \"\" +\n escapeHtml(walletAddress) +\n \"\" +\n escapeHtml(tokenMint) +\n \"\" +\n escapeHtml(lastAlertAt) +\n \"\",\n )\n .join(\"\");\n\n const tableHtml = \"

\" + rows.length + \" Zeile(n):

\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n tableRows +\n \"

wallet_address	token_mint	last_alert_at

\";\n\n return new Response(head + tableHtml + back + \"\", {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\n \"Fehler beim Lesen der Alert-Historie-Debug-Ansicht:\",\n String(err),\n );\n return new Response(\n \"Fehler beim Lesen von helius_alert_dedup: \" + String(err),\n {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\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 \"

Payload-Suche: Queue nach Suchbegriff durchsuchen (Debug)

\" +\n \"

Vollstaendiger, ungekuerzter Payload zu EINER Queue-ID (Debug), z.B.: \" +\n \"?debug=payload&id=11469 (ID in der URL anpassen)

\" +\n \"

Alle eindeutigen Wallet-Adressen aus helius_alert_dedup anzeigen (Debug)

\" +\n \"

Alert-Historie mit Zeitstempeln (wallet_address, token_mint, last_alert_at) anzeigen (Debug) - \" +\n \"optional filterbar per &wallet=ADRESSE

\" +\n \"\"\n );\n}\n\n// Debug-Route: liefert den VOLLSTAENDIGEN, ungekuerzten payload_json fuer\n// GENAU eine Queue-ID als rohen Text/JSON-Body (keine Kuerzung wie in der\n// Such-Route, kein escapeHtml()). Fehlerfaelle als JSON, analog zu\n// handleProcessQueueItem().\nasync function handleDebugPayload(idParam: string | null): Promise {\n const id = idParam !== null ? Number(idParam) : NaN;\n if (\n idParam === null || idParam.trim() === \"\" || !Number.isFinite(id) || id <= 0\n ) {\n return new Response(\n JSON.stringify({\n error:\n \"ungueltige oder fehlende Queue-ID - Aufruf z.B.: ?debug=payload&id=11469\",\n }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n try {\n await ensureTables();\n const result = await sqlite.execute({\n sql: \"SELECT payload_json FROM helius_event_queue WHERE id = ?\",\n args: [id],\n });\n\n if (result.rows.length === 0) {\n return new Response(\n JSON.stringify({\n error: \"kein Queue-Eintrag mit ID \" + id + \" gefunden\",\n }),\n {\n status: 404,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n const [payloadJson] = result.rows[0] as [string | null];\n\n // Bewusst KEIN escapeHtml(), KEIN JSON.stringify(), KEINE Kuerzung -\n // genau der gespeicherte String, 1:1, wie ausdruecklich angefordert.\n return new Response(payloadJson ?? \"\", {\n status: 200,\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\n \"Fehler beim Abrufen des vollstaendigen Payloads fuer Queue-ID \" + id +\n \":\",\n String(err),\n );\n return new Response(\n JSON.stringify({\n error: \"Fehler beim Abrufen des Payloads: \" + String(err),\n }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\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 if (url.searchParams.get(\"debug\") === \"search\") {\n return await handleDebugSearch(url.searchParams.get(\"q\"));\n }\n if (url.searchParams.get(\"debug\") === \"payload\") {\n return await handleDebugPayload(url.searchParams.get(\"id\"));\n }\n if (url.searchParams.get(\"debug\") === \"alert-wallets\") {\n return await handleDebugAlertWallets();\n }\n if (url.searchParams.get(\"debug\") === \"alert-history\") {\n return await handleDebugAlertHistory(url.searchParams.get(\"wallet\"));\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\n// ============================================================================\n// Verarbeitet Helius-Enhanced-Payloads (JSON-Array, siehe\n// https://www.helius.dev/docs/webhooks): Kaufrichtungs-Erkennung\n// (classifyBuyEvent), Konfluenz, Aktivitaets-/Preis-/Liquiditaets-Check,\n// RugCheck, Telegram, Dedup. Jede Payload-Abweichung fuehrt zu \"kein Alert,\n// nur Status in der Queue\" - nie zu einem Crash.\n//\n// Val Town hat kein zuverlaessiges \"waitUntil\" fuer Hintergrundarbeit nach\n// der Response - deshalb landet jedes Event zuerst synchron in\n// helius_event_queue (status='pending'), ein Sweep-Cron\n// (sentry-helius-queue-sweep.ts) verarbeitet Liegengebliebenes nach.\n// ============================================================================\n\nconst MAX_LOGGED_BODY_CHARS = 200000;\nconst DEBUG_RECENT_LIMIT = 5;\n// NEU: Anzahl der Treffer, die die neue Payload-Suche (?debug=search&q=...)\n// maximal anzeigt (letzte N Treffer, neueste zuerst) - analog zu\n// DEBUG_RECENT_LIMIT, nur fuer die Such-Debug-Seite.\nconst DEBUG_SEARCH_LIMIT = 10;\n// Wie viele Zeichen vor/nach dem gefundenen Suchbegriff im Payload-Ausschnitt\n// mit angezeigt werden (Kontext, damit man nicht nur den nackten Treffer,\n// sondern etwas Umgebung sieht).\nconst DEBUG_SEARCH_EXCERPT_CONTEXT_CHARS = 150;\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// ROLLBACK (26.07.2026): Baustein A/B/C (Holder-Konzentration, Top-10-\n// Holder, Liquiditaets-Schwelle) kamen nach einem CLOVER/UNDERDOG-Verlust,\n// verursachten aber zu viel Instabilitaet (C blockierte zeitweise 42/42)\n// und wurden entfernt - zurueck zu nur score_normalised. Das Liquiditaets-\n// Risiko kehrt jetzt gezielter zurueck (siehe MIN_LIQUIDITY_USD unten, aus\n// DexScreener statt RugCheck - kein neuer Instabilitaets-Vektor).\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// ============================================================================\n// KONFLUENZ-LOGIK (Pfad A/B), ersetzt MIN_SOL_AMOUNT - bewusst ohne\n// CoinGecko/externe Preis-API (anders als der fruehere Python-Bot), alle\n// Schwellen direkt in SOL. Alert bei MINDESTENS einem Pfad erfuellt:\n// PFAD A: >= PATH_A_MIN_DISTINCT_WALLETS Wallets kaufen denselben Coin\n// innerhalb CONFLUENCE_WINDOW_MINUTES, SOL-Inflow >= PATH_A_MIN_SOL_TOTAL.\n// PFAD B: eine Wallet kauft >= PATH_B_MIN_SOL_SINGLE SOL auf einmal.\n// Wiederholungs-Alert: erst wieder ab >= REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL\n// neuem Inflow seit dem letzten Alert (kumulativ, kein Fenster).\n// FAIL-OPEN: unbekannter SOL-Betrag blockiert die Pruefung nicht.\n// helius_alert_dedup bleibt unveraendert; helius_coin_buys (Rohlog) und\n// helius_confluence_alert_state (Zeitstempel/Mint) sind additive Tabellen.\n// ============================================================================\nconst CONFLUENCE_WINDOW_MINUTES = 5;\nconst PATH_A_MIN_DISTINCT_WALLETS = 2;\nconst PATH_A_MIN_SOL_TOTAL = 10;\nconst PATH_B_MIN_SOL_SINGLE = 35;\nconst REPEAT_ALERT_MIN_NEW_SOL_INFLOW = PATH_A_MIN_SOL_TOTAL;\n\n// ============================================================================\n// Coin-Gesundheits-Check via DexScreener (EIN Abruf, drei Pruefungen,\n// FAIL-CLOSED wie RugCheck). Anlass Aktivitaets-Mindestschwelle (27.07.2026):\n// 1 Jahr alter Coin mit 0 Buys/Sells in 5 Min. loeste faelschlich einen\n// Alert aus. Anlass Preis-Crash + Liquiditaet (28.07.2026, OSCAR/Moondog-\n// Vorfall): die Mindestschwelle allein blockiert NICHTS gegen das Gegenteil\n// (Bot-/Sniper-Schwarm mit tausenden Trades) - deshalb zusaetzlich\n// priceChange und liquidity.usd auswerten, die DexScreener im selben Response\n// ohnehin mitliefert (kein Zusatz-Call). Bewusst weiterhin nur diese drei\n// einfachen Schwellen, keine kombinierten Bausteine (siehe ROLLBACK oben).\n// ============================================================================\nconst DEXSCREENER_TOKENS_URL =\n \"https://api.dexscreener.com/latest/dex/tokens/\";\nconst MIN_RECENT_ACTIVITY_TXNS_M5 = 2;\n// Preis-Crash-Filter: Coin faellt m5 <= -15% ODER h1 <= -50% -> kein Alert,\n// unabhaengig von Wallet-Konfluenz (ein aktiver Crash ist nie ein gesundes\n// Kaufsignal).\nconst PRICE_CRASH_M5_PCT = -15;\nconst PRICE_CRASH_H1_PCT = -50;\n// Liquiditaets-Untergrenze: unter diesem USD-Wert ist der Pool trivial\n// manipulierbar (OSCAR/Moondog hatte $2.513).\nconst MIN_LIQUIDITY_USD = 10000;\nconst ACTIVITY_CHECK_TIMEOUT_MS = 4000;\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// Rein informative Telegram-Zusatzzeile (Top-10-Holder-Anteil) - AUSDRUECKLICH\n// kein Filter (der fruehere, fail-closed Baustein B ist komplett entfernt).\n// Laeuft NACH der Sende-Entscheidung, kein Einfluss auf action/reason, liefert\n// bei Fehler/Timeout/Timeout einfach null (Zeile entfaellt, nie verzoegert).\nconst TOP_HOLDERS_TO_SUM = 10;\nconst TOP10_HOLDER_INFO_TIMEOUT_MS = 3000;\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 // NEU (28.07.2026, Diagnostik-Nachruestung nach OSCAR/Moondog-Vorfall):\n // Konfluenz-/DexScreener-/RugCheck-Zahlen auch bei status='done' speichern\n // (vorher NUR \"alert_sent\", keine Nachvollziehbarkeit). ALTER TABLE wirft\n // einen Fehler, wenn die Spalte schon existiert - das faengt try/catch ab,\n // analog zum retry_count-Pattern in sentry-helius-queue-sweep.\n try {\n await sqlite.execute(\n \"ALTER TABLE helius_event_queue ADD COLUMN diagnostics_json TEXT\",\n );\n } catch (_err) {\n // Spalte existiert bereits - Normalfall nach dem ersten Lauf.\n }\n\n // NEU: Dedup - ein Alert pro (Coin, Wallet)-Kombination innerhalb von\n // DEDUP_WINDOW_MINUTES. UNVERAENDERT durch die Konfluenz-Logik (27.07.2026\n // abends, siehe Kommentar bei den Pfad-A/B-Konstanten oben) - bewusst\n // exakt beibehalten.\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 // Konfluenz-Logik Pfad A/B: Rohlog jedes Kaufs mit bekanntem SOL-Betrag -\n // fuer die Pfad-A-Fensteraggregation und die Wiederholungs-Alert-Schwelle\n // (neuer Inflow seit letztem Alert). Getrennt von helius_alert_dedup.\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_coin_buys (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n mint TEXT,\n wallet_address TEXT,\n sol_amount REAL,\n bought_at TEXT\n )`,\n );\n\n // NEU (27.07.2026 abends, siehe Chat - Konfluenz-Logik Pfad A/B): ein\n // Zeitstempel PRO MINT (nicht pro Wallet+Mint wie helius_alert_dedup) -\n // dient AUSSCHLIESSLICH der Wiederholungs-Alert-Pruefung (mindestens\n // REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL neuer Inflow seit diesem Zeitpunkt).\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS helius_confluence_alert_state (\n mint TEXT PRIMARY KEY,\n last_alert_at TEXT\n )`,\n );\n}\n\n// ============================================================================\n// KLASSIFIZIERUNG: erkennt, ob ein einzelnes Transaktions-Objekt ein KAUF ist.\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// Bot-Spec Punkt 5: bei Pfad A ALLE beteiligten Wallets, bei Pfad B nur eine.\nfunction formatWalletListLine(wallets: string[]): string {\n if (wallets.length <= 1) {\n return \"Wallet: \" + formatWalletShort(wallets[0] ?? \"(unbekannt)\");\n }\n return \"Wallets (\" + wallets.length + \"): \" +\n wallets.map(formatWalletShort).join(\", \");\n}\n\n// ============================================================================\n// Summiert die pct-Werte der ersten `topN` topHolders[]-Eintraege aus dem\n// VOLLEN /report (NICHT /report/summary - kein topHolders-Feld dort). Gibt\n// null zurueck (NIE 0) wenn topHolders fehlt/leer ist.\n// ============================================================================\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\n// ============================================================================\n// Ruft /report ab, liefert den Top-10-Holder-Anteil - AUSSCHLIESSLICH\n// informativ. Wirft NIE, braucht NIE laenger als TOP10_HOLDER_INFO_TIMEOUT_MS\n// (Promise.race mit Timeout -> null, der fetch laeuft im Hintergrund aus).\n// ============================================================================\nasync function fetchTop10HolderPctInfo(\n mint: string,\n fetchImpl: typeof fetch,\n): Promise {\n const timeoutPromise = new Promise((resolve) => {\n setTimeout(() => resolve(null), TOP10_HOLDER_INFO_TIMEOUT_MS);\n });\n const fetchPromise = (async (): Promise => {\n try {\n const res = await fetchImpl(RUGCHECK_BASE_URL + mint + \"/report\");\n if (!res.ok) return null;\n const data = await res.json();\n return sumTopHoldersPct(data, TOP_HOLDERS_TO_SUM);\n } catch (_err) {\n return null;\n }\n })();\n return Promise.race([fetchPromise, timeoutPromise]);\n}\n\n// Aktivitaets-Check via DexScreener, FAIL-CLOSED (siehe MIN_RECENT_ACTIVITY_TXNS_M5 oben).\nasync function fetchWithTimeout(\n url: string,\n timeoutMs: number,\n fetchImpl: typeof fetch,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n return await fetchImpl(url, { signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\n\n// Liquidestes Solana-Paar (chainId === \"solana\") - repraesentativer als andere.\nfunction mostLiquidSolanaPair(\n pairs: unknown,\n): Record | null {\n if (!Array.isArray(pairs)) return null;\n let best: Record | null = null;\n let bestLiquidity = -1;\n for (const p of pairs) {\n if (!p || typeof p !== \"object\") continue;\n const pair = p as Record;\n if (pair.chainId !== \"solana\") continue;\n const liq = (pair.liquidity as { usd?: unknown } | undefined)?.usd;\n const liquidity = typeof liq === \"number\" ? liq : 0;\n if (liquidity > bestLiquidity) {\n bestLiquidity = liquidity;\n best = pair;\n }\n }\n return best;\n}\n\ntype CoinHealthResult =\n | {\n ok: true;\n txnsM5: number;\n priceChangeM5: number | null;\n priceChangeH1: number | null;\n liquidityUsd: number;\n }\n | { ok: false; reason: string };\n\nasync function checkRecentCoinActivity(\n mint: string,\n fetchImpl: typeof fetch,\n): Promise {\n let res: Response;\n try {\n res = await fetchWithTimeout(\n DEXSCREENER_TOKENS_URL + mint,\n ACTIVITY_CHECK_TIMEOUT_MS,\n fetchImpl,\n );\n } catch (err) {\n return {\n ok: false,\n reason: \"DexScreener-Anfrage fehlgeschlagen/Timeout: \" + String(err),\n };\n }\n if (!res.ok) {\n return { ok: false, reason: \"DexScreener antwortete mit HTTP \" + res.status };\n }\n let data: unknown;\n try {\n data = await res.json();\n } catch (err) {\n return {\n ok: false,\n reason: \"DexScreener-Antwort war kein gueltiges JSON: \" + String(err),\n };\n }\n const pair = mostLiquidSolanaPair(\n (data as { pairs?: unknown } | null)?.pairs,\n );\n if (pair === null) {\n return {\n ok: false,\n reason: \"kein gehandeltes Solana-Paar fuer diesen Mint auf DexScreener gefunden\",\n };\n }\n\n // Liquiditaet zuerst (fail-closed bei unbekannt - ein Pool ohne\n // ermittelbare Liquiditaet ist genauso riskant wie einer unter der\n // Schwelle).\n const liqRaw = (pair.liquidity as { usd?: unknown } | undefined)?.usd;\n const liquidityUsd = typeof liqRaw === \"number\" ? liqRaw : null;\n if (liquidityUsd === null || liquidityUsd < MIN_LIQUIDITY_USD) {\n return {\n ok: false,\n reason: \"Liquiditaet \" +\n (liquidityUsd === null ? \"unbekannt\" : \"$\" + liquidityUsd.toFixed(0)) +\n \" < $\" + MIN_LIQUIDITY_USD + \" - Pool zu duenn/manipulierbar\",\n };\n }\n\n // Preis-Crash: OSCAR/Moondog-Vorfall (28.07.2026) - ein aktiv einbrechender\n // Preis ist kein gesundes Kaufsignal, unabhaengig von Wallet-Konfluenz.\n const pc = pair.priceChange as { m5?: unknown; h1?: unknown } | undefined;\n const priceChangeM5 = typeof pc?.m5 === \"number\" ? pc.m5 : null;\n const priceChangeH1 = typeof pc?.h1 === \"number\" ? pc.h1 : null;\n if (priceChangeM5 !== null && priceChangeM5 <= PRICE_CRASH_M5_PCT) {\n return {\n ok: false,\n reason: \"Preis \" + priceChangeM5.toFixed(1) + \"% in 5 Min. (<= \" +\n PRICE_CRASH_M5_PCT + \"%) - aktiver Crash\",\n };\n }\n if (priceChangeH1 !== null && priceChangeH1 <= PRICE_CRASH_H1_PCT) {\n return {\n ok: false,\n reason: \"Preis \" + priceChangeH1.toFixed(1) + \"% in 1h (<= \" +\n PRICE_CRASH_H1_PCT + \"%) - aktiver Crash\",\n };\n }\n\n // Aktivitaets-Mindestschwelle (urspruenglicher Zweck, 27.07.2026).\n const m5 = (pair.txns as { m5?: { buys?: unknown; sells?: unknown } } | undefined)\n ?.m5;\n const txnsM5 = (typeof m5?.buys === \"number\" ? m5.buys : 0) +\n (typeof m5?.sells === \"number\" ? m5.sells : 0);\n if (txnsM5 < MIN_RECENT_ACTIVITY_TXNS_M5) {\n return {\n ok: false,\n reason: txnsM5 + \" Buy/Sell-Transaktion(en) in den letzten 5 Minuten (< \" +\n MIN_RECENT_ACTIVITY_TXNS_M5 + \") - Coin wirkt inaktiv/tot\",\n };\n }\n return { ok: true, txnsM5, priceChangeM5, priceChangeH1, liquidityUsd };\n}\n\n// ============================================================================\n// Schaetzung des vom feePayer eingesetzten SOL-Betrags (Helius liefert\n// keinen USD-Wert) - IMMER lieber \"nicht ermittelbar\" als eine geratene\n// Zahl. Prioritaet (keine Summierung ueber Stufen hinweg): 1. events.swap.\n// nativeInput, 2. events.swap.tokenInputs (WSOL), 3. Summe aller\n// nativeTransfers[] vom feePayer weg (grober Fallback).\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// Bugfix-Historie: intermittierende \"HTTP 404\"-Telegram-Fehler trotz\n// gueltigem Bot-Token. Wahrscheinlichste Ursache laut Val-Town-Doku: neu\n// gesetzte Env-Vars erreichen bereits \"warme\" Isolates nicht, bis neu\n// deployt wird - manche parallelen Isolates haetten dann einen veralteten\n// (leeren) Token, andere den korrekten. Ein 404 von api.telegram.org passt\n// zu einem leeren/fehlenden Token in der URL (nicht zu Rate-Limiting, das\n// waere HTTP 429 mit retry_after - wird separat behandelt).\n// FIX: (a) vor jedem Versand wird Token/Chat-ID explizit geprueft, fehlt\n// eines wird sofort ein eindeutiger Grund zurueckgegeben (kein irrefuehrendes\n// 404 mehr). (b) ein echter HTTP-Fehler wird einmal automatisch erneut\n// versucht (429 respektiert retry_after, gedeckelt auf 5s).\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 -> Konfluenz -> Coin-Gesundheit\n// (DexScreener) -> RugCheck -> Dedup-Claim -> Telegram -> Zustand-Update.\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 confluenceReason?: string;\n diagnostics?: string;\n }\n> {\n const nowIso = new Date().toISOString();\n\n // 1. Dedup-Vorabpruefung - nur Optimierung, Garantie liegt seit dem\n // Race-Fix (28.07.2026) beim atomaren Claim in Schritt 5.\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 (27.07.2026 abends, siehe Chat): Konfluenz-Logik (Pfad A / Pfad\n // B) ERSETZT den bisherigen MIN_SOL_AMOUNT-Mindestwert-Filter komplett -\n // siehe ausfuehrlichen Kommentar bei den Konstanten oben.\n //\n // 2a. JEDER Kauf mit bekanntem SOL-Betrag wird in helius_coin_buys\n // protokolliert - nur so kann Pfad A ueberhaupt mehrere, zeitlich nahe\n // Kaeufe VERSCHIEDENER Wallets fuer denselben Coin zusammenzaehlen.\n if (buy.estimatedSolSpent !== null) {\n await sqlite.execute({\n sql:\n \"INSERT INTO helius_coin_buys (mint, wallet_address, sol_amount, bought_at) VALUES (?, ?, ?, ?)\",\n args: [buy.mint, buy.wallet, buy.estimatedSolSpent, nowIso],\n });\n } else {\n console.log(\n \"Konfluenz-Logik: SOL-Betrag nicht ermittelbar - dieser Kauf wird NICHT in helius_coin_buys \" +\n \"protokolliert (kann weder zu Pfad A beitragen noch selbst Pfad B ausloesen). FAIL-OPEN wie \" +\n \"zuvor beim MIN_SOL_AMOUNT-Filter: die Konfluenz-Pruefung selbst blockiert NICHT, Verarbeitung \" +\n \"laeuft normal weiter.\",\n );\n }\n\n let confluenceReason: string | null = null;\n // Default: nur auslösende Wallet, Pfad A erweitert unten auf alle.\n let confluenceWallets: string[] = [buy.wallet];\n if (buy.estimatedSolSpent === null) {\n confluenceReason =\n \"SOL-Betrag nicht ermittelbar - Konfluenz-Pruefung faellt aus (fail-open, wie zuvor bei MIN_SOL_AMOUNT)\";\n } else if (buy.estimatedSolSpent >= PATH_B_MIN_SOL_SINGLE) {\n confluenceReason = \"Pfad B: Einzelkauf \" +\n buy.estimatedSolSpent.toFixed(4) + \" SOL >= \" + PATH_B_MIN_SOL_SINGLE +\n \" SOL\";\n } else {\n const windowStartIso = new Date(\n new Date(nowIso).getTime() - CONFLUENCE_WINDOW_MINUTES * 60000,\n ).toISOString();\n const recentBuys = await sqlite.execute({\n sql:\n \"SELECT wallet_address, sol_amount FROM helius_coin_buys WHERE mint = ? AND bought_at >= ?\",\n args: [buy.mint, windowStartIso],\n });\n const distinctWallets = new Set();\n let totalSol = 0;\n for (const row of recentBuys.rows as [string, number][]) {\n distinctWallets.add(row[0]);\n totalSol += row[1];\n }\n if (\n distinctWallets.size >= PATH_A_MIN_DISTINCT_WALLETS &&\n totalSol >= PATH_A_MIN_SOL_TOTAL\n ) {\n confluenceReason = \"Pfad A: \" + distinctWallets.size +\n \" verschiedene Wallets, gemeinsamer SOL-Inflow \" +\n totalSol.toFixed(4) + \" SOL >= \" + PATH_A_MIN_SOL_TOTAL +\n \" SOL (Fenster: \" +\n CONFLUENCE_WINDOW_MINUTES + \" Min.)\";\n confluenceWallets = Array.from(distinctWallets);\n }\n }\n\n if (confluenceReason === null) {\n return {\n action: \"skipped\",\n reason: \"Konfluenz-Bedingung nicht erfuellt: weder Pfad A (>=\" +\n PATH_A_MIN_DISTINCT_WALLETS +\n \" Wallets, gemeinsam >=\" + PATH_A_MIN_SOL_TOTAL + \" SOL in \" +\n CONFLUENCE_WINDOW_MINUTES +\n \" Min.) noch Pfad B (>=\" + PATH_B_MIN_SOL_SINGLE +\n \" SOL Einzelkauf) erreicht\",\n };\n }\n\n // 2b. Wiederholungs-Alerts: hat dieser Coin BEREITS einen Konfluenz-Alert\n // ausgeloest, wird ein erneuter Alert nur zugelassen, wenn seit dem\n // letzten Alert mindestens REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL NEUER\n // Inflow hinzugekommen ist (kumulativ seit dem letzten Alert, NICHT auf\n // das 5-Minuten-Fenster aus Pfad A beschraenkt - siehe Chat).\n const stateResult = await sqlite.execute({\n sql:\n \"SELECT last_alert_at FROM helius_confluence_alert_state WHERE mint = ?\",\n args: [buy.mint],\n });\n if (stateResult.rows.length > 0) {\n const lastConfluenceAlertAt = stateResult.rows[0][0] as string;\n const newInflowResult = await sqlite.execute({\n sql:\n \"SELECT COALESCE(SUM(sol_amount), 0) FROM helius_coin_buys WHERE mint = ? AND bought_at > ?\",\n args: [buy.mint, lastConfluenceAlertAt],\n });\n const newInflowSinceLastAlert = Number(\n (newInflowResult.rows[0]?.[0] as number | undefined) ?? 0,\n );\n if (newInflowSinceLastAlert < REPEAT_ALERT_MIN_NEW_SOL_INFLOW) {\n return {\n action: \"skipped\",\n reason: \"Konfluenz-Bedingung (\" + confluenceReason +\n \") erfuellt, aber dieser Coin hat bereits am \" +\n lastConfluenceAlertAt +\n \" einen Konfluenz-Alert ausgeloest - seither erst \" +\n newInflowSinceLastAlert.toFixed(4) + \" SOL neuer Inflow (< \" +\n REPEAT_ALERT_MIN_NEW_SOL_INFLOW +\n \" SOL noetig fuer Wiederholungs-Alert)\",\n };\n }\n }\n\n // 3. NEU: Coin-Aktivitaets-Check (DexScreener, fail-closed, siehe oben) -\n // laeuft vor RugCheck, spart dessen Anfrage fuer inaktive Coins.\n const activityCheck = await checkRecentCoinActivity(buy.mint, fetch);\n if (!activityCheck.ok) {\n return {\n action: \"skipped\",\n reason: \"Aktivitaets-Check (DexScreener): \" + activityCheck.reason,\n };\n }\n\n // 4. RugCheck /report/summary - jeder Fehler fuehrt zu \"nicht sicher\", NIE\n // zu einem Alert ohne erfolgreiche Pruefung. ROLLBACK (26.07.2026, siehe\n // Kommentar oben bei MAX_RISK_SCORE): NUR noch score_normalised wird\n // ausgewertet - kein Baustein A (Holder-Risiko aus risks[]) und kein\n // Baustein C (Liquiditaets-Check) mehr, beide wurden komplett entfernt.\n let rugcheckScore: number;\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 } catch (err) {\n return {\n action: \"skipped\",\n reason: \"RugCheck-Fehler: \" + String(err) + \" - kein Alert\",\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 // ROLLBACK (26.07.2026): Baustein B als FILTER (exakter Top-10-Holder-\n // Anteil ueber den volleren, teureren /report-Endpoint, fail-closed) wurde\n // komplett entfernt und bleibt entfernt - die Sende-Entscheidung haengt\n // weiterhin ausschliesslich am Score-Check oben.\n\n // NEU (27.07.2026): rein informativer Top-10-Holder-Abruf, NUR fuer die\n // Telegram-Anzeige - siehe ausfuehrlichen Kommentar oben bei\n // TOP10_HOLDER_INFO_TIMEOUT_MS. Die Sende-Entscheidung steht zu diesem\n // Zeitpunkt bereits fest (Score-Check ist schon bestanden); dieser Aufruf\n // kann sie nicht mehr aendern. Zusaetzliches try/catch hier ist bewusste\n // Verteidigung in der Tiefe (fetchTop10HolderPctInfo() selbst wirft\n // bereits nach eigenem Anspruch nie) - unter GAR keinen Umstaenden darf\n // ein Fehler an dieser Stelle den Alert verhindern.\n let top10HolderPct: number | null = null;\n try {\n top10HolderPct = await fetchTop10HolderPctInfo(buy.mint, fetch);\n } catch (err) {\n console.error(\n \"Top-10-Holder-Info-Abruf fehlgeschlagen (rein informativ, Alert wird trotzdem gesendet): \" +\n String(err),\n );\n top10HolderPct = null;\n }\n const top10HolderLine = top10HolderPct !== null\n ? \"✅ Top-10-Holder: \" + top10HolderPct.toFixed(2) + \"%\\n\"\n : \"\";\n\n // 5. Race-Fix (28.07.2026): atomarer Dedup-Claim statt SELECT+INSERT-\n // nach-Versand (doppelte Helius-Zustellung sendete sonst denselben Alert\n // doppelt). ON CONFLICT...DO UPDATE...WHERE ist atomar: Update greift nur\n // nach Ablauf von DEDUP_WINDOW_MINUTES - bei Gleichzeitigkeit gewinnt nur einer.\n const dedupClaim = 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 \"WHERE (julianday(excluded.last_alert_at) - julianday(helius_alert_dedup.last_alert_at)) * 1440.0 >= ?\",\n args: [buy.mint, buy.wallet, nowIso, DEDUP_WINDOW_MINUTES],\n });\n if (dedupClaim.rowsAffected === 0) {\n return {\n action: \"skipped\",\n reason: \"Dedup: Wallet+Coin bereits innerhalb von \" + DEDUP_WINDOW_MINUTES +\n \" Min. gealertet (oder gleichzeitige Verarbeitung war schneller)\",\n };\n }\n\n // NEU (28.07.2026): Diagnostik fuer status_reason/diagnostics_json - siehe\n // Kommentar bei ensureTables(). Nutzt Zahlen, die ohnehin schon berechnet\n // wurden (kein Zusatz-Call), damit ein Vorfall wie OSCAR/Moondog kuenftig\n // aus der DB statt aus rohen Payloads rekonstruierbar ist.\n const diagnosticsJson = JSON.stringify({\n confluenceReason,\n confluenceWallets,\n rugcheckScore,\n activityTxnsM5: activityCheck.txnsM5,\n priceChangeM5: activityCheck.priceChangeM5,\n priceChangeH1: activityCheck.priceChangeH1,\n liquidityUsd: activityCheck.liquidityUsd,\n });\n\n // 6. 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 formatWalletListLine(confluenceWallets) + \"\\n\" +\n \"Kaufbetrag (Coin-Menge): \" + amountText + \"\\n\" +\n \"Kaufbetrag (SOL, geschaetzt): \" + solText + \"\\n\" +\n \"Ausloeser: \" + confluenceReason + \"\\n\\n\" +\n \"✅ RugCheck: Score \" + rugcheckScore + \"/100\\n\" +\n top10HolderLine +\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 // Claim zuruecknehmen, sonst wuerde ein echter Retry blockiert.\n await sqlite.execute({\n sql:\n \"DELETE FROM helius_alert_dedup WHERE token_mint = ? AND wallet_address = ? AND last_alert_at = ?\",\n args: [buy.mint, buy.wallet, nowIso],\n });\n return {\n action: \"error\",\n reason: telegramResult.reason ??\n \"Telegram-Versand fehlgeschlagen (unbekannter Grund)\",\n };\n }\n\n // 7. Konfluenz-Alert-Zustand (PRO MINT), fuer 2b - getrennt von Schritt 5.\n await sqlite.execute({\n sql:\n \"INSERT INTO helius_confluence_alert_state (mint, last_alert_at) VALUES (?, ?) \" +\n \"ON CONFLICT(mint) DO UPDATE SET last_alert_at = excluded.last_alert_at\",\n args: [buy.mint, nowIso],\n });\n\n return {\n action: \"done\",\n reason: \"alert_sent\",\n rugcheckScore,\n confluenceReason,\n diagnostics: diagnosticsJson,\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 // erfolgreich verarbeitet ODER endgueltig als Fehler markiert wurde, BEVOR\n // der Sweep-Cron ihn ebenfalls aufgreift, nicht ein zweites Mal Telegram/\n // RugCheck ausloesen. AUSNAHME (NEU, Gesamt-Check vom 26.07.2026):\n // \"telegram_failed\" ist bewusst NICHT terminal - genau dieser Status soll\n // vom Sweep-Cron erneut aufgegriffen werden koennen (siehe Kommentar\n // weiter unten), deshalb hier ausdruecklich durchgelassen.\n if (status !== \"pending\" && status !== \"telegram_failed\") {\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 // try/catch um processBuySignal(): ein unerwarteter Fehler darin (z.B.\n // sqlite-Fehler beim Dedup-Insert NACH bereits erfolgreichem Telegram-\n // Versand) darf die Queue-Zeile nicht auf \"pending\" haengen lassen, sonst\n // wuerde der Sweep-Cron denselben Kauf spaeter erneut verarbeiten und\n // moeglicherweise doppelt melden. Deshalb terminal auf \"error\" gesetzt\n // (kein Retry) - Vorsicht vor einem doppelten Alert geht hier vor Vorsicht\n // vor einem verlorenen Alert.\n let result: {\n action: \"done\" | \"skipped\" | \"error\";\n reason: string;\n rugcheckScore?: number;\n };\n try {\n 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 } catch (err) {\n console.error(\n \"Unerwarteter Fehler in processBuySignal() fuer Queue-ID \" + id +\n \" (kein Retry, siehe Kommentar):\",\n String(err),\n );\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ? WHERE id = ?\",\n args: [\n \"error\",\n \"Unerwarteter Fehler in processBuySignal(): \" + String(err),\n new Date().toISOString(),\n id,\n ],\n });\n return new Response(\n JSON.stringify({\n action: \"error\",\n reason: \"Unerwarteter Fehler in processBuySignal()\",\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n // Ein Telegram-Fehlschlag (action=\"error\", ausschliesslich der Telegram-\n // Fehlerfall aus processBuySignal) wird als \"telegram_failed\" (nicht\n // terminal) statt generisches \"error\" gespeichert, damit der Sweep-Cron\n // ihn erneut aufgreifen kann - ein bereits als sicher genug eingestufter\n // Alert soll nicht verloren gehen, nur weil Telegram kurz nicht erreichbar\n // war. Die zurueckgegebene JSON-Antwort bleibt \"action: error\"; nur der\n // interne Queue-Status unterscheidet sich.\n const queueStatus = result.action === \"error\"\n ? \"telegram_failed\"\n : result.action;\n\n await sqlite.execute({\n sql:\n \"UPDATE helius_event_queue SET status = ?, status_reason = ?, processed_at = ?, diagnostics_json = ? WHERE id = ?\",\n args: [\n queueStatus,\n result.reason,\n new Date().toISOString(),\n result.diagnostics ?? null,\n id,\n ],\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 );\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 = \"

← zurueck zur Statusseite

\";\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        \"

← zurueck zur Statusseite

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      \"

← zurueck zur Statusseite

Letzte 20 Queue-Eintraege (neueste zuerst)

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

ID	Empfangen	Status	Grund	Verarbeitet

← zurueck zur Statusseite

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

Suche nach "\" + escapeHtml(searchTerm) +\n \"" in payload_json

\" +\n \"

Zeigt die letzten \" + DEBUG_SEARCH_LIMIT +\n \" Treffer in helius_event_queue \" +\n \"(neueste zuerst). Suche ist case-insensitive (SQLite-LIKE).

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

Keine Treffer fuer "\" + escapeHtml(searchTerm) +\n \"" gefunden.

\" +\n back +\n \"\"\n );\n }\n\n const entriesHtml = rows\n .map((row, index) => {\n const excerpt = buildPayloadExcerpt(row.payloadJson, searchTerm);\n return (\n \"

\" +\n \"

Treffer \" + (index + 1) + \" von \" + rows.length + \" (Queue-ID \" +\n escapeHtml(row.id === null ? null : String(row.id), \"-\") + \")

\" +\n \"

Empfangen am: \" + escapeHtml(row.receivedAt, \"-\") +\n \"

\" +\n \"

Status: \" + escapeHtml(row.status, \"-\") + \"

\" +\n \"

Grund: \" + escapeHtml(row.statusReason, \"-\") +\n \"

\" +\n \"

Payload-Ausschnitt:

\" +\n \"

\" +\n        escapeHtml(excerpt) +\n        \"

\"\n );\n })\n .join(\"\");\n\n return head + entriesHtml + back + \"\";\n}\n\n// Durchsucht payload_json in helius_event_queue nach einem Suchbegriff\n// (?debug=search&q=...), z.B. \"kam dieser Mint/Ticker ueberhaupt rein?\".\nasync function handleDebugSearch(\n searchTermRaw: string | null,\n): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n const searchTerm = (searchTermRaw ?? \"\").trim();\n\n if (searchTerm.length === 0) {\n const html = \"\" +\n \"Sentry Helius Webhook - Payload-Suche\" +\n \"\" +\n \"

Payload-Suche

\" +\n \"

Kein Suchbegriff angegeben. Direkt per URL aufrufbar, z.B.:

\" +\n \"

\" +\n      \"?debug=search&q=DEINSUCHBEGRIFF

\" +\n \"

Oder hier eingeben:

← zurueck zur Statusseite

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

Alle Wallet-Adressen aus helius_alert_dedup (eindeutig, sortiert)

\" +\n \"

Jede Adresse, fuer die JEMALS erfolgreich ein Alert versendet wurde \" +\n \"(Spalte wallet_address, DISTINCT) - zum \" +\n \"Abgleich gegen die aktuell ueberwachte Wallet-Liste.

Keine Eintraege in helius_alert_dedup gefunden - entweder wurde \" +\n \"noch nie erfolgreich ein Alert versendet, oder die Tabelle ist \" +\n \"(noch) leer.

\" +\n back +\n \"\",\n {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n },\n );\n }\n\n const listHtml = \"

\" + addresses.length +\n \" eindeutige Adresse(n) (eine pro Zeile, zum Kopieren markieren):

\" +\n \"

\" +\n      addresses.map((a) => escapeHtml(a)).join(\"\\n\") +\n      \"

← zurueck zur Statusseite

\";\n const filterNote = walletParam\n ? \"

Gefiltert auf Wallet-Adresse: \" +\n escapeHtml(walletParam) +\n \" - Filter entfernen (alle Zeilen zeigen)

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

Alert-Historie aus helius_alert_dedup (wallet_address, token_mint, last_alert_at)

\" +\n \"

Optionaler Filter: ?debug=alert-history&wallet=ADRESSE \" +\n \"zeigt nur Zeilen fuer genau diese Adresse.

\" + emptyMsg + \"

\" + rows.length + \" Zeile(n):

\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n \"\" +\n tableRows +\n \"

wallet_address	token_mint	last_alert_at

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 \"

Payload-Suche: Queue nach Suchbegriff durchsuchen (Debug)

\" +\n \"

Vollstaendiger, ungekuerzter Payload zu EINER Queue-ID (Debug), z.B.: \" +\n \"?debug=payload&id=11469 (ID in der URL anpassen)

\" +\n \"

Alle eindeutigen Wallet-Adressen aus helius_alert_dedup anzeigen (Debug)

\" +\n \"

Alert-Historie mit Zeitstempeln (wallet_address, token_mint, last_alert_at) anzeigen (Debug) - \" +\n \"optional filterbar per &wallet=ADRESSE

Diff · v68