Sentry Helius Webhook laeuft

\" +\n \"

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

\" +\n \"

Debug-/Diagnose-Routen (?debug=latest/raw-sql/queue/search/payload/\" +\n \"alert-wallets/alert-history) sind seit 28.07.2026 in einem separaten Val: \" +\n \"\" + DEBUG_VAL_URL + \"

\" +\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 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}","deleted","label",[117],"119d35e4-da93-4cb1-90c1-9aba164d7e2e","debug.ts","cf4efe64-8a92-11f1-85d5-1607ee4eb77e",90,["D",1785325688630],4,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ============================================================================\n// Ausgelagert aus main.ts (28.07.2026), um main.ts wieder Zeichen-Puffer\n// unter dem 80.000-Zeichen-Limit zu geben. Eigene Datei im SELBEN Val ->\n// gleiche projekt-gebundene sqlite-Datenbank wie main.ts (kein Setup\n// noetig), aber eigene Versionierung/Deploy, unabhaengig von main.ts.\n// Rein lesend - schreibt NICHTS in irgendeine Tabelle.\n// ============================================================================\nconst MAIN_STATUS_URL = \"https://sentry-helius-webhook.val.run/\";\nconst DEBUG_RECENT_LIMIT = 5;\nconst DEBUG_SEARCH_LIMIT = 10;\nconst DEBUG_SEARCH_EXCERPT_CONTEXT_CHARS = 150;\n\n// Erstellt NUR die Tabellen, die diese Debug-Routen lesen (nicht\n// helius_coin_buys/helius_confluence_alert_state - die liest nur main.ts).\nasync function ensureTables() {\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 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 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\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 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\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 { receivedAt: string | null; bodyRaw: string | null; bodyTruncated: boolean }\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 \"Alle Zeitstempel sind UTC, nicht deine lokale Zeit (bei MESZ/CEST: UTC + 2 Stunden). \" +\n \"Aktuelle Serverzeit gerade eben: \" + escapeHtml(new Date().toISOString()) +\n \" (UTC).

\";\n\n if (rows.length === 0) {\n return 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 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 \"

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 .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 ) => ({ receivedAt, bodyRaw, bodyTruncated: !!bodyTruncated }));\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(\"Fehler beim Lesen der letzten Debug-Eintraege:\", String(err));\n return new Response(\"Fehler beim Lesen der letzten Eintraege: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\nasync function handleDebugRawSql(): Promise {\n const back = \"

← zurueck zur Statusseite

\";\n try {\n await ensureTables();\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 const dump = { countResult, tableInfoResult, rawRowsResult };\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)) + \"

← 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 const nowUtc = new Date().toISOString();\n const html = \"\" +\n \"Sentry Helius Webhook - Queue Debug\" +\n \"\" +\n \"

Letzte 20 Queue-Eintraege (neueste zuerst)

\" +\n \"

\" +\n \"Alle Zeitstempel auf dieser Seite sind UTC, nicht deine lokale Zeit \" +\n \"(z.B. bei MESZ/CEST: UTC + 2 Stunden). Aktuelle Serverzeit gerade eben: \" +\n escapeHtml(nowUtc) + \" (UTC).

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

ID	Empfangen (UTC)	Status	Grund	Verarbeitet (UTC)

\" + back + \"\";\n return new Response(html, {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n } catch (err) {\n console.error(\"Fehler bei der Queue-Debug-Ansicht:\", String(err));\n return new Response(\"Fehler bei der Queue-Debug-Ansicht: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\nfunction escapeLikePattern(raw: string): string {\n return raw.replace(/\\\\/g, \"\\\\\\\\\").replace(/%/g, \"\\\\%\").replace(/_/g, \"\\\\_\");\n}\n\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 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(payloadJson.length, idx + searchTerm.length + contextChars);\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) + \"" in payload_json

\" +\n \"

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

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

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

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

\" +\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 .join(\"\");\n\n return head + entriesHtml + back + \"\";\n}\n\nasync function handleDebugSearch(searchTermRaw: string | null): 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 \"\" + back + \"\";\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 ) => ({ id, receivedAt, status, statusReason, payloadJson }));\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\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.

\" + back + \"\",\n { status: 200, headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\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 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(\"Fehler beim Lesen der Alert-Wallets-Debug-Ansicht:\", String(err));\n return new Response(\"Fehler beim Lesen von helius_alert_dedup: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\nasync function handleDebugAlertHistory(\n walletParam: string | null,\n): Promise {\n const back = \"

← zurueck zur Statusseite

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

Gefiltert auf Wallet-Adresse: \" + 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. Sortiert nach last_alert_at, aeltester Alert zuerst.

\" +\n \"

Optionaler Filter: ?debug=alert-history&wallet=ADRESSE.

\" +\n \"

\" +\n \"Alle Zeitstempel sind UTC, nicht deine lokale Zeit (bei MESZ/CEST: UTC + 2 Stunden). \" +\n \"Aktuelle Serverzeit gerade eben: \" + escapeHtml(new Date().toISOString()) +\n \" (UTC).

\" +\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(head + \"

\" + emptyMsg + \"

\" + back + \"\", {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\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 .join(\"\");\n\n const tableHtml = \"

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

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

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(\"Fehler beim Lesen der Alert-Historie-Debug-Ansicht:\", String(err));\n return new Response(\"Fehler beim Lesen von helius_alert_dedup: \" + String(err), {\n status: 500,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n}\n\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: \"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({ error: \"kein Queue-Eintrag mit ID \" + id + \" gefunden\" }),\n { status: 404, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n const [payloadJson] = result.rows[0] as [string | null];\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 String(err),\n );\n return new Response(\n JSON.stringify({ error: \"Fehler beim Abrufen des Payloads: \" + String(err) }),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}\n\nfunction indexPageHtml(): string {\n return \"\" +\n \"Sentry Helius Webhook - Debug-Val\" +\n \"\" +\n \"

Sentry Helius Webhook - Debug-Routen

\" +\n \"

Ausgelagert aus main.ts (28.07.2026) - liest dieselbe sqlite-Datenbank, \" +\n \"schreibt nichts. Haupt-Val: \" +\n MAIN_STATUS_URL + \"

\" +\n \"

Letzte 5 rohe Payloads anzeigen

\" +\n \"

Roh-Diagnose: Zeilenanzahl + ungemappte Rohdaten

\" +\n \"

Letzte 20 Queue-Eintraege anzeigen

\" +\n \"

Payload-Suche

\" +\n \"

Vollstaendiger Payload zu EINER Queue-ID, z.B.: \" +\n \"?debug=payload&id=11469

\" +\n \"

Alle eindeutigen Wallet-Adressen anzeigen

\" +\n \"

Alert-Historie mit Zeitstempeln anzeigen - \" +\n \"optional filterbar per &wallet=ADRESSE

\" +\n \"\";\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const debugParam = url.searchParams.get(\"debug\");\n\n if (debugParam === \"raw-sql\") return await handleDebugRawSql();\n if (debugParam === \"latest\") return await handleDebugRecent();\n if (debugParam === \"queue\") return await handleDebugQueue();\n if (debugParam === \"search\") {\n return await handleDebugSearch(url.searchParams.get(\"q\"));\n }\n if (debugParam === \"payload\") {\n return await handleDebugPayload(url.searchParams.get(\"id\"));\n }\n if (debugParam === \"alert-wallets\") return await handleDebugAlertWallets();\n if (debugParam === \"alert-history\") {\n return await handleDebugAlertHistory(url.searchParams.get(\"wallet\"));\n }\n\n return new Response(indexPageHtml(), {\n status: 200,\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n",[134],"pulls",1,"forks","envVars",{"_148":150,"_151":54},"connections",{"_148":54,"_149":54},"count","unfilledCount",2,"emptyCount",{"_20":133,"_13":134,"_118":135,"_119":-5,"_120":21,"_121":136,"_123":50,"_22":158,"_29":138,"_126":127,"_128":139,"_130":38,"_131":-5,"_155":159,"_92":160},{"_20":116,"_13":117,"_118":48,"_119":-5,"_120":21,"_121":122,"_123":50,"_22":154,"_29":125,"_126":127,"_128":129,"_130":38,"_131":14,"_155":156,"_92":157},["D",1785506993232],"children",[],[117],["D",1785325688630],[],[134],["D",1784922836796],["D",1789473745358],{"_11":12,"_90":43},{"_11":12,"_85":43,"_86":43,"_45":46,"_87":88,"_89":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_111":199,"_200":201,"_202":203,"_204":38,"_205":38,"_206":38,"_207":50,"_208":-5,"_209":-7,"_210":-7,"_211":54,"_212":38,"_213":38,"_214":-5,"_215":38,"_216":38,"_217":38,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":26,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"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"]

Branches1

Branches
1