[{"_1":2,"_179":-5,"_180":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isPaidOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","d1375c05ce15aa00f0f5fc1d56cfa8d009f00f8a","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_157":158,"_176":177,"_178":-5},"handle","Eytanmsk111","name","automatic","path","main.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":76,"_114":76,"_12":115,"_116":-5,"_117":20,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":123,"_124":125,"_126":-5,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":136,"_138":139,"_143":144,"_156":20},"id","65b50042-25f8-11f1-9e43-42dde27851f2","createdAt",["D",1774188421366],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019d15d8-3c04-7630-8b39-2956d1da8c26","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019d15d8-7d1d-7718-9412-8abdb3f7d4ba","tursoName","65b5004225f811f19e4342dde27851f2","tursoHostname","65b5004225f811f19e4342dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_137":-5},"profileImageUrl","org",{"_97":98,"_140":-5,"_12":-5,"_141":142},"avatar","tier","business","branch",{"_145":146,"_99":45,"_105":147,"_148":106,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":100,"_155":98},"version",9,"65b624e0-25f8-11f1-9e43-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":159,"_99":102,"_160":161,"_162":-5,"_163":147,"_164":146,"_165":166,"_107":167,"_145":168,"_169":170,"_171":172,"_173":20,"_174":-5,"_101":175},"c2f879a6-2787-11f1-bb15-42dde27851f2","fileId","65ba7b80-25f8-11f1-9e43-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1774359947021],8,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WASENDER_API_KEY = Deno.env.get(\"WASENDER_API_KEY\")!;\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\")!;\nconst SLACK_WEBHOOK_URL = Deno.env.get(\"SLACK_WEBHOOK_URL\")!;\n\n// ─── DB Setup ─────────────────────────────────────────────────────────────────\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sent_messages (\n phone TEXT PRIMARY KEY,\n firstName TEXT,\n company TEXT,\n status TEXT,\n sentAt TEXT\n )\n`);\n\n// ─── Templates ────────────────────────────────────────────────────────────────\n\nconst TEMPLATES: Record = {\n A:\n \"Hi {firstName}\\n\\nI sent you an email a few days ago, wanted to follow up here in case it got buried.\\n\\nI'm Eytan, founder of Nilos. We raised $12M and work with 100+ clients including Ebanx, Flutterwave, Carry1st, and Moniepoint.\\n\\nWe currently process about $2B in volume in Nigeria alone.\\n\\nWe mainly operate on 2 levels:\\n1. We give merchants/importers access to FBO USD named accounts to collect and payout using SWIFT, ACH/Fedwire and CNY in China\\n2. We are reliable liquidity buyers of NGN against USD in big clips\\n\\nBeen following {company} on LinkedIn. Really think we could partner here.\\n\\nWould love to connect, happy to jump on a quick WhatsApp call this week?\",\n B:\n \"Hi {firstName}\\n\\nFollowing up on an email I sent you, figured WhatsApp might be easier.\\n\\nI'm Eytan, founder of Nilos. I know you've probably been pitched this a few times already.\\n\\nBut there's a reason why the biggest merchants in the world work with us, Ebanx, Moniepoint, Flutterwave, OnAfriq...\\n\\nHere's what makes us different:\\n1. Full transparency, platform where you track where/how funds move in real time\\n2. Strong WhatsApp support, you always get answers\\n3. 99% instant or T+1 worst case, we use stablecoins, no intermediaries\\n4. No credit line required\\n5. Automatic reconciliation engine\\n6. Volume-based pricing, nothing upfront\\n7. We only partner with CBN-licensed banks and FIs\\n\\nWorst case you spend 15 min getting to know us. Best case we save you 1-2% margin + improve your experience.\\n\\nLet me know if you're interested,\\nHappy to chat\",\n};\n\n// ─── Types ────────────────────────────────────────────────────────────────────\n\ninterface WaSenderWebhookBody {\n event?: string;\n sessionId?: string;\n data?: {\n message?: {\n conversation?: string;\n extendedTextMessage?: { text: string };\n };\n key?: {\n remoteJid?: string;\n fromMe?: boolean;\n };\n pushName?: string;\n /** Cleaned phone number, e.g. \"33664703116\" */\n cleanedSenderPn?: string;\n /** Full WA JID, e.g. \"33664703116@s.whatsapp.net\" */\n senderPn?: string;\n /** Plain message text fallback used by some WaSender versions */\n messageBody?: string;\n };\n}\n\ninterface Prospect {\n firstName: string;\n company: string;\n phone: string;\n}\n\ninterface SendResult {\n phone: string;\n firstName: string;\n company: string;\n status: \"sent\" | \"failed\" | \"not_on_whatsapp\" | \"skipped\";\n error?: string;\n}\n\n// ─── Helpers ──────────────────────────────────────────────────────────────────\n\n/** Extract phone number and message text from WaSender webhook payload */\nfunction extractMessage(body: WaSenderWebhookBody): {\n phone: string;\n remoteJid: string;\n text: string;\n name: string;\n} | null {\n const data = body?.data;\n const key = data?.key;\n const msg = data?.message;\n\n // Ignore messages sent by the bot itself\n if (key?.fromMe === true) {\n console.log(\"Skipping fromMe message\");\n return null;\n }\n\n // ── Text extraction ──────────────────────────────────────────────────────\n // Try message sub-fields first, then fall back to top-level messageBody\n const text =\n msg?.conversation ??\n msg?.extendedTextMessage?.text ??\n data?.messageBody ??\n null;\n\n if (!text?.trim()) {\n console.log(\"No text found in message, skipping\");\n return null;\n }\n\n // ── Phone extraction ─────────────────────────────────────────────────────\n // WaSender may send remoteJid as LID format (\"47322000015437@lid\"), so we\n // prefer the explicit phone fields when available.\n const remoteJid = key?.remoteJid ?? \"\";\n\n let rawPhone: string;\n if (data?.cleanedSenderPn) {\n // Best option: already clean, e.g. \"33664703116\"\n rawPhone = data.cleanedSenderPn;\n console.log(\"[extractMessage] phone source: cleanedSenderPn →\", rawPhone);\n } else if (data?.senderPn) {\n // Strip @s.whatsapp.net suffix, e.g. \"33664703116@s.whatsapp.net\" → \"33664703116\"\n rawPhone = data.senderPn.replace(/@.*$/, \"\");\n console.log(\"[extractMessage] phone source: senderPn →\", rawPhone);\n } else if (remoteJid) {\n // Last resort – remoteJid may be a real number or a LID\n rawPhone = remoteJid.replace(/@.*$/, \"\");\n console.log(\"[extractMessage] phone source: remoteJid (fallback) →\", rawPhone);\n } else {\n console.log(\"No phone/remoteJid found, skipping\");\n return null;\n }\n\n // Always prefix with + for international format\n const phone = rawPhone.startsWith(\"+\") ? rawPhone : `+${rawPhone}`;\n const name = data?.pushName || phone;\n\n console.log(\"[extractMessage] extracted phone:\", phone);\n console.log(\"[extractMessage] extracted text:\", text.trim());\n console.log(\"[extractMessage] pushName:\", data?.pushName ?? \"(none)\");\n\n return { phone, remoteJid: remoteJid || phone, text: text.trim(), name };\n}\n\n/** Remove internal tags before sending the reply to WhatsApp */\nfunction stripInternalTags(reply: string): string {\n return reply\n .replace(/\\[OPT-OUT\\]/gi, \"\")\n .replace(/\\[CALL-BOOKED:[^\\]]*\\]/gi, \"\")\n .replace(/\\[TIER-\\d+\\]/gi, \"\")\n .trim();\n}\n\n/** Detect internal tags for Slack reporting */\nfunction detectTags(reply: string): string[] {\n const tags: string[] = [];\n if (/\\[OPT-OUT\\]/i.test(reply)) tags.push(\"🚫 OPT-OUT\");\n const callBooked = reply.match(/\\[CALL-BOOKED:([^\\]]+)\\]/i);\n if (callBooked) tags.push(`📅 CALL BOOKED: ${callBooked[1].trim()}`);\n if (/\\[TIER-\\d+\\]/i.test(reply)) {\n const tier = reply.match(/\\[TIER-(\\d+)\\]/i);\n if (tier) tags.push(`🏷️ TIER-${tier[1]}`);\n }\n return tags;\n}\n\n/** Call Claude API and return the raw reply (with tags intact) */\nasync function askClaude(userMessage: string): Promise {\n const response = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": ANTHROPIC_API_KEY,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({\n model: \"claude-3-5-sonnet-20241022\",\n max_tokens: 400,\n system:\n \"You are Eytan Messika, founder of Nilos. Short WhatsApp replies only (max 5 lines). Push toward booking a call. Match language (EN/FR). Never share pricing numbers. Add [OPT-OUT] if they opt out. Add [CALL-BOOKED: day time] if call confirmed.\",\n messages: [{ role: \"user\", content: userMessage }],\n }),\n });\n\n if (!response.ok) {\n const err = await response.text();\n throw new Error(`Anthropic API error ${response.status}: ${err}`);\n }\n\n const json = await response.json();\n const content = json?.content?.[0]?.text as string | undefined;\n if (!content) throw new Error(\"Empty response from Anthropic\");\n return content.trim();\n}\n\n/** Send a WhatsApp message via WaSender */\nasync function sendWhatsApp(remoteJid: string, text: string): Promise {\n // WaSender expects the full remoteJid (e.g. \"972501234567@s.whatsapp.net\")\n const payload = {\n to: remoteJid,\n text,\n };\n\n console.log(\"Sending WaSender payload:\", JSON.stringify(payload));\n\n const response = await fetch(\"https://www.wasenderapi.com/api/send-message\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${WASENDER_API_KEY}`,\n },\n body: JSON.stringify(payload),\n });\n\n const responseText = await response.text();\n console.log(`WaSender response ${response.status}:`, responseText);\n\n if (!response.ok) {\n throw new Error(`WaSender error ${response.status}: ${responseText}`);\n }\n}\n\n/** Notify Slack with a summary of the exchange */\nasync function notifySlack(\n name: string,\n phone: string,\n inbound: string,\n rawReply: string,\n cleanReply: string,\n tags: string[],\n): Promise {\n const tagLine = tags.length ? `\\n*Tags:* ${tags.join(\" \")}` : \"\";\n\n const text =\n `💬 *New WhatsApp message — ${name}* (${phone})\\n` +\n `*Prospect:* ${inbound}\\n` +\n `*Nilos reply:* ${cleanReply}` +\n tagLine;\n\n const response = await fetch(SLACK_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ text }),\n });\n\n if (!response.ok) {\n console.error(`Slack notify failed: ${response.status}`);\n }\n}\n\n/** Notify Slack with a batch send summary */\nasync function notifySlackBatch(\n results: SendResult[],\n templateKey: string,\n): Promise {\n const sent = results.filter((r) => r.status === \"sent\").length;\n const failed = results.filter((r) => r.status === \"failed\").length;\n const notOnWa = results.filter((r) => r.status === \"not_on_whatsapp\").length;\n const skipped = results.filter((r) => r.status === \"skipped\").length;\n\n const lines = results.map((r) => {\n const icon = r.status === \"sent\"\n ? \"✅\"\n : r.status === \"not_on_whatsapp\"\n ? \"📵\"\n : r.status === \"skipped\"\n ? \"⏭️\"\n : \"❌\";\n const extra = r.error ? ` — ${r.error}` : \"\";\n return `${icon} ${r.firstName} (${r.company}) ${r.phone}${extra}`;\n });\n\n const text =\n `📤 *Batch send complete — Template ${templateKey}*\\n` +\n `✅ Sent: ${sent} ❌ Failed: ${failed} 📵 Not on WA: ${notOnWa} ⏭️ Skipped: ${skipped}\\n\\n` +\n lines.join(\"\\n\");\n\n const response = await fetch(SLACK_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ text }),\n });\n\n if (!response.ok) {\n console.error(`Slack batch notify failed: ${response.status}`);\n }\n}\n\n/** Send outbound batch messages in the background */\nasync function processBatch(\n prospects: Prospect[],\n templateKey: string,\n): Promise {\n const template = TEMPLATES[templateKey];\n const results: SendResult[] = [];\n\n for (let i = 0; i < prospects.length; i++) {\n const { firstName, company, phone } = prospects[i];\n\n // Check if already sent\n const existing = await sqlite.execute({\n sql: \"SELECT phone FROM sent_messages WHERE phone = ?\",\n args: [phone],\n });\n\n if (existing.rows.length > 0) {\n console.log(`[batch] Skipping ${phone} — already sent`);\n results.push({ phone, firstName, company, status: \"skipped\" });\n // Still wait between iterations (except last) to be safe\n if (i < prospects.length - 1) {\n await new Promise((resolve) => setTimeout(resolve, 65_000));\n }\n continue;\n }\n\n // Build message\n const message = template\n .replace(/\\{firstName\\}/g, firstName)\n .replace(/\\{company\\}/g, company);\n\n // WaSender expects phone as-is (e.g. +2349051133007)\n const to = phone;\n\n let status: SendResult[\"status\"] = \"sent\";\n let errorMsg: string | undefined;\n\n try {\n console.log(`[batch] Sending to ${phone} (${firstName} @ ${company})`);\n await sendWhatsApp(to, message);\n console.log(`[batch] Sent to ${phone}`);\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(`[batch] Failed for ${phone}:`, msg);\n\n // WaSender returns specific wording for non-WA numbers\n if (\n msg.toLowerCase().includes(\"not on whatsapp\") ||\n msg.toLowerCase().includes(\"not registered\")\n ) {\n status = \"not_on_whatsapp\";\n } else {\n status = \"failed\";\n }\n errorMsg = msg;\n }\n\n // Persist to DB regardless of outcome (avoid retry storms)\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO sent_messages (phone, firstName, company, status, sentAt) VALUES (?, ?, ?, ?, ?)\",\n args: [phone, firstName, company, status, new Date().toISOString()],\n });\n\n results.push({ phone, firstName, company, status, ...(errorMsg ? { error: errorMsg } : {}) });\n\n // Respect 65-second rate limit between sends (skip after last)\n if (i < prospects.length - 1) {\n console.log(`[batch] Waiting 65 s before next send...`);\n await new Promise((resolve) => setTimeout(resolve, 65_000));\n }\n }\n\n // Post summary to Slack\n console.log(\"[batch] All done, posting Slack summary\");\n await notifySlackBatch(results, templateKey);\n}\n\n// ─── Main Handler ─────────────────────────────────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n\n // ── GET /status ─────────────────────────────────────────────────────────\n if (req.method === \"GET\" && url.pathname === \"/status\") {\n const todayPrefix = new Date().toISOString().slice(0, 10); // \"YYYY-MM-DD\"\n\n const todayResult = await sqlite.execute({\n sql: \"SELECT COUNT(*) as cnt FROM sent_messages WHERE sentAt LIKE ?\",\n args: [`${todayPrefix}%`],\n });\n\n const totalResult = await sqlite.execute({\n sql: \"SELECT COUNT(*) as cnt FROM sent_messages\",\n args: [],\n });\n\n const todayCount = Number((todayResult.rows[0] as { cnt: number }).cnt);\n const totalCount = Number((totalResult.rows[0] as { cnt: number }).cnt);\n\n return new Response(\n JSON.stringify({ sentToday: todayCount, sentTotal: totalCount, queue: \"idle\" }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // ── GET (health check) ───────────────────────────────────────────────────\n if (req.method === \"GET\") {\n return new Response(\"Nilos WhatsApp Agent running\", { status: 200 });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n // ── POST /send-batch ─────────────────────────────────────────────────────\n if (url.pathname === \"/send-batch\") {\n let body: { prospects?: Prospect[]; template?: string };\n try {\n body = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n const prospects = body.prospects;\n const templateKey = (body.template ?? \"A\").toUpperCase();\n\n if (!Array.isArray(prospects) || prospects.length === 0) {\n return new Response(\n JSON.stringify({ error: \"prospects must be a non-empty array\" }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n if (!TEMPLATES[templateKey]) {\n return new Response(\n JSON.stringify({ error: `Unknown template \"${templateKey}\". Use A or B.` }),\n { status: 400, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // Respond immediately, process in background\n setTimeout(() => {\n processBatch(prospects, templateKey).catch((err) => {\n console.error(\"[batch] Unhandled error in processBatch:\", err);\n });\n }, 0);\n\n return new Response(\n JSON.stringify({ queued: true, count: prospects.length, template: templateKey }),\n { status: 202, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n\n // ── POST / (inbound WaSender webhook) ───────────────────────────────────\n\n // Parse body\n let body: WaSenderWebhookBody;\n try {\n body = await req.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n console.log(\"Webhook received:\", JSON.stringify(body, null, 2));\n\n // Extract message\n const parsed = extractMessage(body);\n if (!parsed) {\n return new Response(JSON.stringify({ ignored: true }), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n const { phone, remoteJid, text, name } = parsed;\n\n try {\n // 1. Ask Claude (raw reply, tags intact)\n console.log(`[${phone}] User: ${text}`);\n console.log(`[${phone}] Calling Claude API... (pushName: ${name})`);\n const rawReply = await askClaude(text);\n console.log(`[${phone}] Claude (raw): ${rawReply}`);\n\n // 2. Detect tags before stripping\n const tags = detectTags(rawReply);\n\n // 3. Strip internal tags for WhatsApp delivery\n const cleanReply = stripInternalTags(rawReply);\n console.log(`[${phone}] Sending: ${cleanReply}`);\n\n // 4. Send via WaSender (use full remoteJid with @s.whatsapp.net)\n await sendWhatsApp(remoteJid, cleanReply);\n console.log(`[${phone}] Reply sent`);\n\n // 5. Notify Slack\n await notifySlack(name, phone, text, rawReply, cleanReply, tags);\n\n return new Response(\n JSON.stringify({ success: true, phone, tags }),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (err: unknown) {\n const message = err instanceof Error ? err.message : String(err);\n console.error(\"Handler error:\", message);\n\n // Best-effort Slack error alert\n try {\n await fetch(SLACK_WEBHOOK_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n text: `❌ *Nilos WhatsApp relay error*\\n*From:* ${name} (${phone})\\n*Message:* ${text}\\n*Error:* ${message}`,\n }),\n });\n } catch { /* ignore */ }\n\n return new Response(\n JSON.stringify({ success: false, error: message }),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}\n","deleted","label",[102],"permalink","https://www.val.town/x/Eytanmsk111/automatic/code/main.ts","extension","actionData","errors"]