[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_161":162,"_163":164},"routes/_app.x.$handle.$name",{"_99":98,"_32":44,"_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":48,"_120":121,"_122":25,"_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",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_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":48},"version",52,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","test_dedup_race.ts","latestPath","fileId","477f5f0c-8a8c-11f1-aada-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// Isoliertes Test-Skript (eigene Tabelle, ruehrt helius_alert_dedup NICHT an)\n// zur Verifikation der atomaren UPSERT-Semantik fuer den Race-Condition-Fix.\n// Top-Level-Code (kein export default) - script-Vals fuehren das Modul\n// direkt beim Laden aus.\n\nawait sqlite.execute(\n `CREATE TABLE IF NOT EXISTS test_dedup_claim (\n token_mint TEXT,\n wallet_address TEXT,\n last_alert_at TEXT,\n PRIMARY KEY (token_mint, wallet_address)\n )`,\n);\nawait sqlite.execute({\n sql: \"DELETE FROM test_dedup_claim WHERE token_mint = ?\",\n args: [\"TESTMINT\"],\n});\n\nconst claimSql =\n \"INSERT INTO test_dedup_claim (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(test_dedup_claim.last_alert_at)) * 1440.0 >= ?\";\n\nconst t0 = new Date();\nconst t0Iso = t0.toISOString();\nconst r1 = await sqlite.execute({\n sql: claimSql,\n args: [\"TESTMINT\", \"TESTWALLET\", t0Iso, 10],\n});\n\nconst t1Iso = new Date(t0.getTime() + 1000).toISOString();\nconst r2 = await sqlite.execute({\n sql: claimSql,\n args: [\"TESTMINT\", \"TESTWALLET\", t1Iso, 10],\n});\n\nconst t2Iso = new Date(t0.getTime() + 11 * 60000).toISOString();\nconst r3 = await sqlite.execute({\n sql: claimSql,\n args: [\"TESTMINT\", \"TESTWALLET\", t2Iso, 10],\n});\n\nawait sqlite.execute({\n sql: \"DELETE FROM test_dedup_claim WHERE token_mint = ?\",\n args: [\"TESTMINT\"],\n});\nawait sqlite.execute(\"DROP TABLE test_dedup_claim\");\n\nconsole.log(\n \"ERGEBNIS \" + JSON.stringify({\n frischer_claim_rowsAffected: r1.rowsAffected,\n erwartet: 1,\n duplikat_1s_spaeter_rowsAffected: r2.rowsAffected,\n erwartet_2: 0,\n claim_nach_fenster_11min_rowsAffected: r3.rowsAffected,\n erwartet_3: 1,\n }, (_k, v) => (typeof v === \"bigint\" ? v.toString() : v)),\n);\n","createdAt",["D",1785247294221],"branchVersion","branchId","4f1ddced-871c-4509-b1d8-8ec1a5a28b75","id","c12a0a16-75c2-4e06-a152-0617bea7ff8f","sentry-helius-webhook",["D",1784922836796],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","d88c9cf0-3002-4a43-9725-2854852c6d09","pinnedFileId","67e70380-8799-11f1-a413-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f8659-48bc-71e6-8825-ef535d702ef9","tursoName","c12a0a1675c24e06a1520617bea7ff8f","tursoHostname","c12a0a1675c24e06a1520617bea7ff8f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789560647748],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_105":53},"org",{"_99":98,"_100":53,"_101":53,"_18":55,"_102":103,"_104":48},"branch",{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"isOwned",146,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","aouam_player","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":156,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":157,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":158,"_83":159,"_85":160,"_87":48},"tree",[151],"files",[151],"counts",{"_139":62,"_140":141,"_142":62,"_143":144,"_145":146},"contents",[127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":128,"_32":129,"_30":57,"_130":-5,"_40":41,"_39":131,"_132":48,"_37":133,"_13":134,"_33":135,"_35":136,"_24":48,"_137":44,"_27":138},"fbf252de-6c10-49b5-8458-f1428c37dbf1","main.ts","parentId",48,"latest",["D",1785246939816],47,"http","import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ============================================================================\n// Vollstaendige Verarbeitung: Parsing des Helius-Enhanced-Payloads (defensiv,\n// siehe classifyBuyEvent), Kaufrichtungs-Erkennung, RugCheck, Telegram,\n// Dedup - ueber ein Warteschlangen-Muster NACH der sofortigen HTTP-200-\n// Antwort an Helius.\n//\n// Payload-Format-Quellen: POST-Body ist ein JSON-ARRAY von Transaktions-\n// Objekten (https://www.helius.dev/docs/webhooks). Felder (type, source,\n// feePayer, signature, tokenTransfers[], nativeTransfers[], accountData[],\n// events.swap.{...}) laut\n// https://www.helius.dev/docs/api-reference/enhanced-transactions/gettransactions.\n// tokenInputs[]-Form ist NICHT explizit dokumentiert (Annahme: symmetrisch zu\n// tokenOutputs[]). Die Parsing-Logik ist bewusst so gebaut, dass jede\n// Abweichung von der erwarteten Struktur zu \"kein Alert, nur Status in der\n// Queue\" fuehrt - nie zu einem Crash oder einer geratenen Interpretation.\n//\n// Val Town unterstuetzt kein \"waitUntil\" fuer Hintergrundarbeit nach der\n// Response; ein nicht-awaiteter Fire-and-Forget-Call ist laut Val-Town-Doku\n// nicht 100% zuverlaessig. Deshalb: jedes Event landet zuerst synchron in\n// helius_event_queue (status='pending'), ein separater Cron-Val\n// (sentry-helius-queue-sweep.ts) verarbeitet liegen gebliebene Eintraege\n// nach, falls das Fire-and-Forget ausfiel.\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, auf ausdruecklichen Wunsch): Baustein A (Holder-\n// Konzentration), B (Top-10-Holder ueber vollen /report) und C (Liquiditaets-\n// Schwelle) wurden nach einem CLOVER/UNDERDOG-Verlust eingefuehrt, brachten\n// aber zu viel Instabilitaet (Baustein C blockierte zeitweise 42/42\n// Kandidaten) und wurden komplett entfernt - zurueck zu ausschliesslich\n// score_normalised. Bewusst akzeptiertes Risiko: das urspruengliche Problem\n// (extreme Holder-Konzentration/geringe Liquiditaet trotz niedrigem Score)\n// kann dadurch erneut auftreten - akzeptierte Kurskorrektur, kein neuer Bug.\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 / Pfad B) - 27.07.2026 abends, ERSETZT\n// MIN_SOL_AMOUNT komplett. Anders als der fruehere Python-Bot-Versuch\n// (sentry-bot/smart_wallet_monitor.py, database.check_confluence, nutzte\n// USD/Market-Cap via externe Preis-API) hier bewusst OHNE CoinGecko/externe\n// Preis-API - alle Schwellen direkt in SOL, keine USD-Umrechnung.\n//\n// Alert, wenn MINDESTENS EINER der beiden Pfade erfuellt ist:\n// PFAD A: mindestens PATH_A_MIN_DISTINCT_WALLETS verschiedene ueberwachte\n// Wallets kaufen denselben Coin innerhalb von CONFLUENCE_WINDOW_MINUTES,\n// gemeinsamer SOL-Inflow >= PATH_A_MIN_SOL_TOTAL.\n// PFAD B: eine einzelne Wallet kauft >= PATH_B_MIN_SOL_SINGLE SOL auf einmal.\n//\n// Da kein Live-SOL-Kurs verwendet wird, bilden diese Werte KEINE feste USD-\n// Zielspanne ab - bei starken SOL-Kursschwankungen manuell nachjustieren.\n//\n// WIEDERHOLUNGS-ALERTS: ein Coin mit bereits ausgeloestem Konfluenz-Alert\n// loest erst wieder aus, wenn seither >= REPEAT_ALERT_MIN_NEW_SOL_INFLOW SOL\n// neuer Inflow hinzukam (kumulativ, nicht auf das 5-Min.-Fenster beschraenkt\n// - siehe processBuySignal()). Bewusst = PATH_A_MIN_SOL_TOTAL (10 SOL), daher\n// als Referenz definiert statt dupliziert.\n//\n// FAIL-OPEN wie zuvor bei MIN_SOL_AMOUNT: unbekannter SOL-Betrag wird nicht\n// in helius_coin_buys protokolliert und blockiert die Pruefung NICHT.\n//\n// ARCHITEKTUR: helius_alert_dedup (Wallet+Mint, DEDUP_WINDOW_MINUTES) bleibt\n// bewusst UNVERAENDERT (Dedup-Grundmechanik + Debug-Routen sollen unangetastet\n// bleiben). Die neue, coin-weite Logik bekommt zwei SEPARATE, rein additive\n// Tabellen: helius_coin_buys (Rohlog aller Kaeufe, fuer Pfad-A-Aggregation)\n// und helius_confluence_alert_state (ein Zeitstempel pro Mint, fuer die\n// Wiederholungs-Pruefung).\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// NEU (Bot-Spec Punkt 3): Aktivitaets-Check via DexScreener - verhindert\n// Alerts auf toten/inaktiven Coins (Anlass: 1 Jahr alter Coin mit 0 Buys/\n// Sells in 5 Min. loeste faelschlich einen Alert aus). FAIL-CLOSED wie\n// RugCheck. Bewusst nur EINE Schwelle (m5 buys+sells) - siehe ROLLBACK-\n// Kommentar oben bei MAX_RISK_SCORE (mehrere Bausteine = instabil).\n// ============================================================================\nconst DEXSCREENER_TOKENS_URL =\n \"https://api.dexscreener.com/latest/dex/tokens/\";\nconst MIN_RECENT_ACTIVITY_TXNS_M5 = 2;\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\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\n// ist - siehe Test-Datei test_classify_buy_event.mjs (20 Assertions, alle\n// bestanden) fuer die vollstaendige Verifikation dieser Funktion gegen\n// synthetische, doku-konforme Payloads UND gegen absichtlich kaputte/\n// abweichende Strukturen.\n// ============================================================================\ntype ClassifyResult =\n | {\n kind: \"buy\";\n wallet: string;\n mint: string;\n humanAmount: number | null;\n tokenAccount: string | null;\n estimatedSolSpent: number | null;\n estimatedSolSpentSource: string | null;\n }\n | { kind: \"not_a_swap\"; type: string }\n | { kind: \"not_a_buy\"; reason: string }\n | { kind: \"ambiguous\"; reason: string }\n | { kind: \"unrecognized\"; reason: string };\n\nfunction classifyBuyEvent(payload: unknown): ClassifyResult {\n try {\n if (payload === null || typeof payload !== \"object\") {\n return { kind: \"unrecognized\", reason: \"Payload ist kein Objekt\" };\n }\n const p = payload as Record;\n const type = p.type;\n if (typeof type !== \"string\" || type.length === 0) {\n return {\n kind: \"unrecognized\",\n reason: 'kein (gueltiges) \"type\"-Feld vorhanden',\n };\n }\n if (type.toUpperCase() !== \"SWAP\") {\n return { kind: \"not_a_swap\", type };\n }\n\n const feePayer = p.feePayer;\n if (typeof feePayer !== \"string\" || feePayer.length === 0) {\n return {\n kind: \"unrecognized\",\n reason: 'kein (gueltiges) \"feePayer\"-Feld vorhanden',\n };\n }\n\n const events = p.events as Record | undefined;\n const swapEvent = events && typeof events === \"object\"\n ? (events.swap as Record | undefined)\n : undefined;\n let result: ClassifyResult | null = null;\n if (swapEvent && typeof swapEvent === \"object\") {\n result = classifyFromSwapEvent(swapEvent, feePayer);\n // swapEvent vorhanden, aber intern nicht auswertbar -> Fallback versuchen.\n }\n\n if (!result && Array.isArray(p.tokenTransfers)) {\n result = classifyFromTokenTransfers(p.tokenTransfers, feePayer);\n }\n\n if (!result) {\n return {\n kind: \"unrecognized\",\n reason:\n \"weder events.swap noch tokenTransfers[] in auswertbarer Form vorhanden\",\n };\n }\n\n // NEU (Mindest-Wert-Filter-Grundlage, siehe Chat): fuer jeden erkannten\n // Kauf zusaetzlich versuchen, den vom feePayer eingesetzten SOL-Betrag\n // zu schaetzen - als Naeherung fuer die Kaufgroesse, da Helius keinen\n // USD-Wert liefert. Ueberschreibt die Platzhalter aus den Sub-Funktionen.\n if (result.kind === \"buy\") {\n const solEstimate = estimateSolSpent(p, feePayer);\n result = {\n ...result,\n estimatedSolSpent: solEstimate.solAmount,\n estimatedSolSpentSource: solEstimate.source,\n };\n }\n\n return result;\n } catch (err) {\n return {\n kind: \"unrecognized\",\n reason: \"Fehler beim Parsen: \" + String(err),\n };\n }\n}\n\nfunction classifyFromSwapEvent(\n swapEvent: Record,\n feePayer: string,\n): ClassifyResult | null {\n const tokenOutputs = swapEvent.tokenOutputs;\n if (!Array.isArray(tokenOutputs)) return null;\n\n const received = tokenOutputs.filter(\n (o) =>\n o &&\n typeof o === \"object\" &&\n (o as Record).userAccount === feePayer &&\n typeof (o as Record).mint === \"string\" &&\n !KNOWN_QUOTE_MINTS.has((o as Record).mint as string),\n ) as Record[];\n\n if (received.length === 0) {\n return {\n kind: \"not_a_buy\",\n reason:\n \"feePayer erhielt in events.swap.tokenOutputs keinen Nicht-Quote-Token \" +\n \"(vermutlich Verkauf, oder feePayer ist bei diesem Swap nicht der Empfaenger)\",\n };\n }\n if (received.length > 1) {\n return {\n kind: \"ambiguous\",\n reason: \"feePayer erhielt \" + received.length +\n \" unterschiedliche Tokens im selben Swap - \" +\n \"nicht eindeutig genug fuer ein automatisches Signal, kein Alert\",\n };\n }\n\n const entry = received[0];\n const humanAmount = extractHumanAmount(entry.rawTokenAmount);\n return {\n kind: \"buy\",\n wallet: feePayer,\n mint: entry.mint as string,\n humanAmount,\n tokenAccount: typeof entry.tokenAccount === \"string\"\n ? (entry.tokenAccount as string)\n : null,\n // Platzhalter - werden von classifyBuyEvent() nach Rueckkehr ueberschrieben\n // (estimateSolSpent() braucht das volle Payload, nicht nur swapEvent).\n estimatedSolSpent: null,\n estimatedSolSpentSource: null,\n };\n}\n\nfunction classifyFromTokenTransfers(\n tokenTransfers: unknown[],\n feePayer: string,\n): ClassifyResult {\n const received = tokenTransfers.filter(\n (t) =>\n t &&\n typeof t === \"object\" &&\n (t as Record).toUserAccount === feePayer &&\n typeof (t as Record).mint === \"string\" &&\n !KNOWN_QUOTE_MINTS.has((t as Record).mint as string),\n ) as Record[];\n\n if (received.length === 0) {\n return {\n kind: \"not_a_buy\",\n reason:\n \"feePayer erhielt in tokenTransfers[] (Fallback) keinen Nicht-Quote-Token\",\n };\n }\n if (received.length > 1) {\n return {\n kind: \"ambiguous\",\n reason:\n \"feePayer erhielt in tokenTransfers[] (Fallback) mehrere unterschiedliche Tokens - kein Alert\",\n };\n }\n\n const entry = received[0];\n const humanAmount = typeof entry.tokenAmount === \"number\"\n ? (entry.tokenAmount as number)\n : null;\n return {\n kind: \"buy\",\n wallet: feePayer,\n mint: entry.mint as string,\n humanAmount,\n tokenAccount: typeof entry.toTokenAccount === \"string\"\n ? (entry.toTokenAccount as string)\n : null,\n estimatedSolSpent: null,\n estimatedSolSpentSource: null,\n };\n}\n\nfunction extractHumanAmount(rawTokenAmount: unknown): number | null {\n if (!rawTokenAmount || typeof rawTokenAmount !== \"object\") return null;\n const { tokenAmount, decimals } = rawTokenAmount as Record;\n if (typeof decimals !== \"number\" || !Number.isFinite(decimals)) return null;\n const raw = typeof tokenAmount === \"string\"\n ? Number(tokenAmount)\n : (tokenAmount as number);\n if (typeof raw !== \"number\" || !Number.isFinite(raw)) return null;\n return raw / Math.pow(10, decimals);\n}\n\nfunction formatWalletShort(wallet: string): string {\n if (typeof wallet !== \"string\" || wallet.length < 8) {\n return wallet ?? \"(unbekannt)\";\n }\n return wallet.slice(0, 4) + \"...\" + wallet.slice(-4);\n}\n\n// 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// Reine Hilfsfunktion (keine Netzwerk-/Zeit-Abhaengigkeit, isoliert testbar):\n// summiert die pct-Werte der ersten `topN` topHolders[]-Eintraege aus dem\n// VOLLEN /report (NICHT /report/summary - das enthaelt kein topHolders-Feld,\n// live verifiziert, siehe Baustein-B-Historie). Gibt null zurueck, wenn\n// topHolders fehlt/kein Array/leer ist ODER kein einziger Eintrag ein\n// numerisches pct-Feld hatte - NIE 0 in diesen Faellen, das wuerde\n// faelschlich \"0% Konzentration\" in der Anzeige suggerieren.\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 den vollen /report-Endpoint ab und liefert den Top-10-Holder-Anteil -\n// AUSSCHLIESSLICH informativ (siehe Kommentar oben bei\n// TOP10_HOLDER_INFO_TIMEOUT_MS). Liefert GARANTIERT entweder eine Zahl oder\n// null zurueck, wirft NIE eine Exception nach aussen, und braucht NIE laenger\n// als TOP10_HOLDER_INFO_TIMEOUT_MS (per Promise.race mit einem Timeout, der\n// bei Ueberschreitung einfach null liefert - der zugrundeliegende fetch-\n// Aufruf laeuft im Hintergrund aus, sein Ergebnis wird dann schlicht\n// ignoriert, es gibt keinen weiteren Seiteneffekt).\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\nasync function checkRecentCoinActivity(\n mint: string,\n fetchImpl: typeof fetch,\n): Promise<{ ok: true } | { ok: false; reason: string }> {\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 const m5 = (pair.txns as { m5?: { buys?: unknown; sells?: unknown } } | undefined)\n ?.m5;\n const total = (typeof m5?.buys === \"number\" ? m5.buys : 0) +\n (typeof m5?.sells === \"number\" ? m5.sells : 0);\n if (total < MIN_RECENT_ACTIVITY_TXNS_M5) {\n return {\n ok: false,\n reason: total + \" 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 };\n}\n\n// ============================================================================\n// NEU: Schaetzung des vom feePayer eingesetzten SOL-Betrags, als Naeherung\n// fuer die \"Kaufgroesse\" (Helius liefert keinen USD-Wert). UNVERIFIZIERT\n// gegen ein echtes SWAP-Payload (wie der Rest von events.swap.tokenInputs,\n// siehe Kopfkommentar) - deshalb mehrstufig mit Fallbacks, liefert IMMER\n// lieber \"nicht ermittelbar\" (solAmount: null) statt eine geratene Zahl.\n// Prioritaet (keine Summierung ueber Stufen hinweg, um Doppelzaehlung zu\n// vermeiden, falls mehrere Repraesentationen desselben Vorgangs vorkommen):\n// 1. events.swap.nativeInput - direktester doku-belegter Wert (Wallet\n// setzt natives SOL direkt in den Swap ein).\n// 2. events.swap.tokenInputs mit Wrapped-SOL-Mint - deckt den vermutlich\n// haeufigeren Fall ab, dass SOL als WSOL-Token bewegt wird (z.B. bei\n// Jupiter/Raydium-Routen).\n// 3. Summe aller nativeTransfers[] vom feePayer weg (grober Fallback).\n// Siehe test_classify_buy_event.mjs fuer die vollstaendige Verifikation\n// (Prioritaetsreihenfolge, Fallback-Verhalten, defensive Fehlerbehandlung).\n// ============================================================================\nfunction estimateSolSpent(\n payload: Record,\n feePayer: string,\n): { solAmount: number | null; source: string | null } {\n try {\n const events = payload.events as Record | undefined;\n const swapEvent = events && typeof events === \"object\"\n ? (events.swap as Record | undefined)\n : undefined;\n\n // 1. events.swap.nativeInput\n if (swapEvent && typeof swapEvent === \"object\") {\n const nativeInput = swapEvent.nativeInput as\n | Record\n | undefined;\n if (\n nativeInput && typeof nativeInput === \"object\" &&\n nativeInput.account === feePayer\n ) {\n const lamports = typeof nativeInput.amount === \"string\"\n ? Number(nativeInput.amount)\n : (nativeInput.amount as number);\n if (\n typeof lamports === \"number\" && Number.isFinite(lamports) &&\n lamports > 0\n ) {\n return {\n solAmount: lamports / LAMPORTS_PER_SOL,\n source: \"events.swap.nativeInput\",\n };\n }\n }\n\n // 2. events.swap.tokenInputs mit Wrapped-SOL-Mint (ANNAHME: gleiche\n // Feldform wie tokenOutputs - unverifiziert, siehe Kopfkommentar).\n if (Array.isArray(swapEvent.tokenInputs)) {\n const wsolInput = (swapEvent.tokenInputs as unknown[]).find(\n (i) =>\n i && typeof i === \"object\" &&\n (i as Record).userAccount === feePayer &&\n (i as Record).mint === WSOL_MINT,\n ) as Record | undefined;\n if (wsolInput) {\n const humanAmount = extractHumanAmount(wsolInput.rawTokenAmount);\n if (humanAmount !== null && humanAmount > 0) {\n return {\n solAmount: humanAmount,\n source: \"events.swap.tokenInputs (WSOL)\",\n };\n }\n }\n }\n }\n\n // 3. Fallback: Summe aller nativeTransfers[] vom feePayer weg.\n if (Array.isArray(payload.nativeTransfers)) {\n let sumLamports = 0;\n let foundAny = false;\n for (const t of payload.nativeTransfers as unknown[]) {\n const transfer = t as Record | null;\n if (\n transfer && typeof transfer === \"object\" &&\n transfer.fromUserAccount === feePayer &&\n typeof transfer.amount === \"number\" &&\n Number.isFinite(transfer.amount)\n ) {\n sumLamports += transfer.amount as number;\n foundAny = true;\n }\n }\n if (foundAny && sumLamports > 0) {\n return {\n solAmount: sumLamports / LAMPORTS_PER_SOL,\n source: \"nativeTransfers-Summe\",\n };\n }\n }\n\n return { solAmount: null, source: null };\n } catch (_err) {\n return { solAmount: null, source: null };\n }\n}\n\n// ============================================================================\n// 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 (Pfad A/B) ->\n// RugCheck -> Telegram -> Dedup-/Konfluenz-Zustand-Update. Siehe\n// test_process_buy_signal.mjs fuer die vollstaendige Verifikation via\n// Mock-sqlite/Mock-fetch.\n// ============================================================================\nasync function processBuySignal(\n buy: {\n wallet: string;\n mint: string;\n humanAmount: number | null;\n estimatedSolSpent: number | null;\n estimatedSolSpentSource: string | null;\n },\n): Promise<\n {\n action: \"done\" | \"skipped\" | \"error\";\n reason: string;\n rugcheckScore?: number;\n confluenceReason?: 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 // 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 };\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 = ? WHERE id = ?\",\n args: [queueStatus, result.reason, new Date().toISOString(), id],\n });\n\n console.log(\n \"Queue-Eintrag \" + id + \" verarbeitet: action=\" + result.action +\n \", reason=\" + result.reason +\n (result.rugcheckScore !== undefined\n ? \", rugcheckScore=\" + result.rugcheckScore\n : \"\"),\n );\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}","label",[129],"pulls","branches",1,"forks","envVars",{"_147":149,"_150":62},"connections",{"_147":62,"_148":62},"count","unfilledCount",2,"emptyCount",{"_42":128,"_32":129,"_30":57,"_130":-5,"_40":41,"_39":131,"_132":48,"_37":152,"_13":134,"_33":135,"_35":136,"_24":48,"_137":44,"_153":154,"_27":155},["D",1785246939816],"children",[],[129],["D",1784922836796],["D",1789560647748],{"_99":98,"_105":53},{"_99":98,"_100":53,"_101":53,"_18":55,"_102":103,"_104":48},{"_13":88,"_32":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_124":194,"_195":196,"_197":198,"_199":48,"_200":48,"_201":48,"_202":25,"_203":-5,"_204":-7,"_205":-7,"_206":62,"_207":48,"_208":48,"_209":-5,"_210":48,"_211":48,"_212":48,"_213":-5},"ENV",{"_165":166,"_167":168,"_169":89,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v52