📢 WhatsApp Group Broadcaster

\n\n \n

🔀 Mode

\n \n \n

\n\n \n

📱 WhatsApp API Setup

Get credentials from Meta Developer → WhatsApp → API Setup

\n \n \n

\n Requires env vars: WHATSAPP_TOKEN and WHATSAPP_PHONE_NUMBER_ID\n

\n\n \n \n\n \n

\n Disconnected\n ● Bot: Offline\n

\n\n \n

📊 Progress

\n 0 / 0\n

Sent: 0

Remaining: 0

Today: 0

\n\n \n

📋 Contacts

One per line: phone_number,name (e.g. 1234567890,John). Use {name} in message.

\n \n \n \n

\n\n \n

✏️ Broadcast Message

Use {name} or {group} for personalization.

\n \n \n \n

\n\n \n

⚙️ Broadcast Settings

Configure how messages are sent.

\n Min Delay (sec)\n \n

\n Max Delay (sec)\n \n

\n Batch Size\n \n

\n Batch Cooldown (min)\n \n

\n Daily Limit\n \n

\n Start Hour\n \n

\n End Hour\n \n

\n \n \n

\n\n \n

🎮 Controls

\n \n \n \n \n

\n\n \n

📋 Activity Log

System ready.

\n \n\n\n","label",[18],"pulls","branches","forks","envVars",{"_205":26,"_207":26},"connections",{"_205":26,"_206":26},"count","unfilledCount","emptyCount",{"_35":261,"_13":262,"_68":263,"_45":-5,"_37":38,"_190":264,"_191":116,"_39":265,"_41":42,"_70":21,"_194":266,"_71":24,"_196":-5,"_222":267,"_17":268},{"_35":254,"_13":255,"_68":256,"_45":-5,"_37":38,"_190":42,"_191":116,"_39":257,"_41":26,"_70":21,"_194":258,"_71":24,"_196":-5,"_222":259,"_17":260},{"_35":189,"_13":18,"_68":69,"_45":-5,"_37":38,"_190":95,"_191":116,"_39":251,"_41":193,"_70":21,"_194":195,"_71":24,"_196":-5,"_222":252,"_17":253},{"_35":242,"_13":243,"_68":114,"_45":-5,"_37":38,"_190":244,"_191":116,"_39":245,"_41":246,"_70":247,"_194":248,"_71":24,"_196":-5,"_222":249,"_17":250},{"_35":234,"_13":235,"_68":236,"_45":-5,"_37":38,"_190":139,"_191":116,"_39":237,"_41":238,"_70":220,"_194":239,"_71":24,"_196":-5,"_222":240,"_17":241},{"_35":225,"_13":226,"_68":227,"_45":-5,"_37":38,"_190":228,"_191":116,"_39":229,"_41":230,"_70":21,"_194":231,"_71":24,"_196":-5,"_222":232,"_17":233},{"_35":215,"_13":216,"_68":217,"_45":-5,"_37":38,"_190":218,"_191":116,"_39":219,"_41":42,"_70":220,"_194":221,"_71":24,"_196":-5,"_222":223,"_17":224},"43dd49a6-6f80-493b-9e69-a440cc2ba651","termux-bot.js","a16ea03a-85b0-11f1-b6b7-1607ee4eb77e",21,["D",1784713286104],"script","// ============================================================================\n// WhatsApp Broadcast Bot — Termux Edition\n// Runs on your phone via Termux, talks to Val Town dashboard\n// ============================================================================\n//\n// SETUP (run these in Termux EXACTLY in order):\n//\n// termux-setup-storage\n// pkg update && pkg upgrade -y\n// pkg install nodejs git python build-essential chromium -y\n// npm install whatsapp-web.js qrcode puppeteer-core\n//\n// Then run:\n// node termux-bot.js\n//\n// ============================================================================\n\n// ─── CONFIG: Set your dashboard URL here ───\nconst DASHBOARD_URL = \"https://peterg--019f892406aa7049b41b70666076acc8.web.val.run\";\n\n// ─── Default Safety Settings (overridden by dashboard) ───\nconst DEFAULT_SETTINGS = {\n minDelaySec: 30,\n maxDelaySec: 90,\n batchSize: 12,\n batchCooldownMin: 120,\n dailyLimit: 50,\n startHour: 9,\n endHour: 21,\n};\n\n// ─── Find Chromium on Termux ───\nconst { execSync } = require('child_process');\nlet chromiumPath = '';\nconst possiblePaths = [\n '/data/data/com.termux/files/usr/bin/chromium-browser',\n '/data/data/com.termux/files/usr/bin/chromium',\n '/usr/bin/chromium-browser',\n '/usr/bin/chromium',\n '/usr/bin/google-chrome',\n];\nfor (const p of possiblePaths) {\n try {\n execSync(`test -f \"${p}\"`, { stdio: 'ignore' });\n chromiumPath = p;\n break;\n } catch (e) { /* not found, try next */ }\n}\nif (!chromiumPath) {\n console.error('❌ Chromium not found! Install it: pkg install chromium');\n console.error(' Tried paths:', possiblePaths.join(', '));\n process.exit(1);\n}\nconsole.log(`🔍 Found Chromium at: ${chromiumPath}`);\n\n// ─── Imports ───\nconst { Client, LocalAuth } = require('whatsapp-web.js');\nconst QRCode = require('qrcode');\n\n// ─── State ───\nconst state = {\n status: 'disconnected',\n qrCode: null,\n broadcastMessage: '',\n groups: [],\n totalGroups: 0,\n sentCount: 0,\n currentIndex: 0,\n isPaused: false,\n isLoopRunning: false,\n sentToday: 0,\n lastSentDate: null,\n lastCommand: 'idle',\n settings: { ...DEFAULT_SETTINGS },\n};\n\n// ─── Utility Functions ───\nfunction sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)); }\nfunction randomDelay(min, max) { return Math.floor(Math.random() * (max - min + 1)) + min; }\nfunction isWithinWorkingHours() {\n const hour = new Date().getHours();\n return hour >= state.settings.startHour && hour < state.settings.endHour;\n}\nfunction updateSettings(s) {\n if (!s) return;\n state.settings = {\n minDelaySec: s.minDelaySec ?? state.settings.minDelaySec,\n maxDelaySec: s.maxDelaySec ?? state.settings.maxDelaySec,\n batchSize: s.batchSize ?? state.settings.batchSize,\n batchCooldownMin: s.batchCooldownMin ?? state.settings.batchCooldownMin,\n dailyLimit: s.dailyLimit ?? state.settings.dailyLimit,\n startHour: s.startHour ?? state.settings.startHour,\n endHour: s.endHour ?? state.settings.endHour,\n };\n}\n\n// ─── Dashboard Communication ───\nasync function reportToDashboard(logMessage) {\n try {\n const body = {\n botStatus: state.status,\n totalGroups: state.totalGroups,\n sentCount: state.sentCount,\n currentIndex: state.currentIndex,\n remaining: state.totalGroups - state.currentIndex,\n isPaused: state.isPaused,\n sentToday: state.sentToday,\n lastSentDate: state.lastSentDate,\n };\n if (state.qrCode) body.qrCode = state.qrCode;\n if (state.groups.length > 0) body.groups = state.groups.map(g => g.name || g);\n if (logMessage) body.log = logMessage;\n\n const res = await fetch(`${DASHBOARD_URL}/api/bot-update`, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (data.settings) updateSettings(data.settings);\n return data;\n } catch (err) {\n console.error('Failed to report to dashboard:', err.message);\n return { command: state.lastCommand, broadcastMessage: state.broadcastMessage };\n }\n}\n\nasync function pollCommand() {\n try {\n const res = await fetch(`${DASHBOARD_URL}/api/command`);\n const data = await res.json();\n if (data.settings) updateSettings(data.settings);\n return data;\n } catch (err) {\n return { command: 'idle', broadcastMessage: state.broadcastMessage, isPaused: state.isPaused };\n }\n}\n\nasync function ackCommand() {\n try {\n await fetch(`${DASHBOARD_URL}/api/command/ack`, {\n method: 'POST',\n headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({}),\n });\n } catch (err) { /* ignore */ }\n}\n\n// ─── WhatsApp Client (Termux-optimized Puppeteer config) ───\nconst client = new Client({\n authStrategy: new LocalAuth(),\n puppeteer: {\n headless: true,\n executablePath: chromiumPath,\n args: [\n '--no-sandbox',\n '--disable-setuid-sandbox',\n '--disable-dev-shm-usage',\n '--disable-gpu',\n '--single-process',\n '--no-zygote',\n '--disable-software-rasterizer',\n '--disable-extensions',\n '--disable-background-networking',\n '--disable-sync',\n '--disable-translate',\n '--mute-audio',\n '--hide-scrollbars',\n '--window-size=800,600',\n ],\n timeout: 60000,\n },\n});\n\nclient.on('loading_screen', (percent) => {\n console.log(`⏳ Loading: ${percent}%`);\n});\n\nclient.on('qr', async (qr) => {\n state.status = 'disconnected';\n console.log('\\n📱 QR Code generated!');\n console.log('Scan it on the dashboard or in WhatsApp Settings > Linked Devices\\n');\n try {\n state.qrCode = await QRCode.toDataURL(qr, { width: 256, margin: 2 });\n console.log('📤 Sending QR to dashboard...');\n await reportToDashboard('📱 QR Code generated — scan on dashboard');\n console.log('✅ QR sent to dashboard. Open the dashboard URL in your browser.');\n } catch (err) {\n console.error('❌ Failed to generate QR image:', err.message);\n // Fallback: print QR to terminal\n console.log('Raw QR string (paste into a QR generator):');\n console.log(qr);\n }\n});\n\nclient.on('ready', async () => {\n state.status = 'idle';\n state.qrCode = null;\n console.log('✅ WhatsApp connected!');\n\n const chats = await client.getChats();\n state.groups = chats.filter(chat => chat.isGroup);\n state.totalGroups = state.groups.length;\n console.log(`📊 Found ${state.totalGroups} groups.`);\n\n await reportToDashboard(`✅ Connected! Found ${state.totalGroups} groups.`);\n});\n\nclient.on('authenticated', () => {\n console.log('🔐 Authenticated successfully.');\n});\n\nclient.on('auth_failure', (msg) => {\n console.error('❌ Auth failure:', msg);\n state.status = 'disconnected';\n reportToDashboard('❌ Authentication failed. Please re-scan QR.');\n});\n\nclient.on('disconnected', (reason) => {\n console.log('⚠️ Disconnected:', reason);\n state.status = 'disconnected';\n reportToDashboard('⚠️ Disconnected from WhatsApp.');\n});\n\n// ─── Broadcast Engine ───\nasync function broadcastEngine() {\n if (state.isLoopRunning) return;\n state.isLoopRunning = true;\n state.isPaused = false;\n state.status = 'broadcasting';\n\n const today = new Date().toDateString();\n if (state.lastSentDate !== today) {\n state.sentToday = 0;\n state.lastSentDate = today;\n state.sentCount = 0;\n state.currentIndex = 0;\n }\n\n let index = state.currentIndex;\n await reportToDashboard(`▶️ Broadcasting started from group ${index + 1}`);\n\n while (index < state.totalGroups) {\n const cmd = await pollCommand();\n\n if (cmd.command === 'pause' || cmd.isPaused) {\n state.isPaused = true;\n state.status = 'paused';\n await reportToDashboard('⏸️ Broadcast paused');\n await ackCommand();\n while (state.isPaused) {\n await sleep(2000);\n const resumeCmd = await pollCommand();\n if (resumeCmd.command === 'resume' || (!resumeCmd.isPaused && resumeCmd.command !== 'pause')) {\n state.isPaused = false;\n state.status = 'broadcasting';\n await reportToDashboard('▶️ Broadcast resumed');\n await ackCommand();\n break;\n }\n if (resumeCmd.command === 'stop') break;\n }\n }\n\n if (cmd.command === 'stop') {\n state.status = 'idle';\n state.isLoopRunning = false;\n state.currentIndex = 0;\n state.sentCount = 0;\n await reportToDashboard('⏹️ Broadcast stopped');\n await ackCommand();\n return;\n }\n\n if (cmd.broadcastMessage) {\n state.broadcastMessage = cmd.broadcastMessage;\n }\n\n if (state.sentToday >= state.settings.dailyLimit) {\n state.status = 'finished';\n state.isLoopRunning = false;\n await reportToDashboard(`🚦 Daily limit reached (${state.settings.dailyLimit}).`);\n return;\n }\n\n while (!isWithinWorkingHours()) {\n state.status = 'idle';\n console.log('🌙 Outside working hours. Sleeping 30 mins...');\n await reportToDashboard('🌙 Outside working hours — waiting...');\n await sleep(1800000);\n const checkCmd = await pollCommand();\n if (checkCmd.command === 'stop') {\n state.status = 'idle';\n state.isLoopRunning = false;\n await ackCommand();\n return;\n }\n state.status = 'broadcasting';\n }\n\n const group = state.groups[index];\n if (!group) { index++; continue; }\n\n try {\n await client.sendPresenceAvailable();\n await group.sendState('typing');\n await sleep(randomDelay(3000, 8000));\n\n const groupName = group.name || 'Group';\n const personalizedMsg = state.broadcastMessage.replace(/{group}/g, groupName);\n await group.sendMessage(personalizedMsg);\n\n state.sentCount += 1;\n state.sentToday += 1;\n index += 1;\n state.currentIndex = index;\n\n console.log(`✅ [${index}/${state.totalGroups}] Sent to \"${groupName}\"`);\n await reportToDashboard(`✅ [${index}/${state.totalGroups}] Sent to \"${groupName}\"`);\n\n if (state.sentToday % state.settings.batchSize === 0) {\n console.log(`☕ Batch cooldown for ${state.settings.batchCooldownMin} mins.`);\n state.status = 'idle';\n await reportToDashboard(`☕ Batch cooldown — ${state.settings.batchCooldownMin} min pause`);\n await sleep(state.settings.batchCooldownMin * 60 * 1000);\n state.status = 'broadcasting';\n }\n\n const wait = randomDelay(state.settings.minDelaySec * 1000, state.settings.maxDelaySec * 1000);\n console.log(`⏳ Waiting ${(wait / 1000).toFixed(0)}s...`);\n await sleep(wait);\n\n } catch (err) {\n console.error(`❌ Failed on ${group.name}:`, err.message);\n await reportToDashboard(`❌ Failed on \"${group.name}\": ${err.message}`);\n await sleep(120000);\n }\n }\n\n state.status = 'finished';\n state.isLoopRunning = false;\n console.log('🎉 Broadcast finished!');\n await reportToDashboard('🎉 Broadcast finished!');\n}\n\n// ─── Command Poller ───\nasync function commandPoller() {\n while (true) {\n try {\n const cmd = await pollCommand();\n\n if (cmd.broadcastMessage && cmd.broadcastMessage !== state.broadcastMessage) {\n state.broadcastMessage = cmd.broadcastMessage;\n console.log('📝 Message updated:', state.broadcastMessage.substring(0, 50) + '...');\n }\n\n if (cmd.command === 'start' && !state.isLoopRunning && state.status !== 'disconnected') {\n console.log('▶️ Start command received!');\n state.broadcastMessage = cmd.broadcastMessage || state.broadcastMessage;\n await ackCommand();\n broadcastEngine();\n }\n\n if (cmd.command === 'stop' && !state.isLoopRunning) {\n state.status = 'idle';\n state.currentIndex = 0;\n state.sentCount = 0;\n await ackCommand();\n await reportToDashboard('⏹️ Stopped');\n }\n\n if (cmd.command === 'resume' && !state.isPaused) {\n await ackCommand();\n }\n\n state.lastCommand = cmd.command;\n } catch (err) { /* keep polling */ }\n await sleep(3000);\n }\n}\n\n// ─── Status Reporter ───\nasync function statusReporter() {\n while (true) {\n if (state.status !== 'disconnected' || state.qrCode) {\n await reportToDashboard(null);\n }\n await sleep(5000);\n }\n}\n\n// ─── Start ───\nconsole.log('🚀 Starting WhatsApp Broadcast Bot...');\nconsole.log(`📡 Dashboard: ${DASHBOARD_URL}`);\nconsole.log(`⚙️ Chromium: ${chromiumPath}`);\nconsole.log('⏳ Initializing WhatsApp client...\\n');\n\nclient.initialize();\ncommandPoller();\nstatusReporter();\n","children",[],[216],"fcac6981-df90-463a-bb43-14f41f259119","style.css","019f8924-06aa-7049-b41b-7aabce9e9645",22,["D",1784713295999],2,"* { box-sizing: border-box; margin: 0; padding: 0; }\nbody {\n font-family: 'Segoe UI', Tahoma, Geneva, Verdana, sans-serif;\n background: #0f172a;\n color: #e2e8f0;\n padding: 20px;\n min-height: 100vh;\n display: flex;\n justify-content: center;\n}\n.container {\n max-width: 800px;\n width: 100%;\n}\nh1 { margin-bottom: 24px; text-align: center; }\n.card {\n background: #1e293b;\n border-radius: 12px;\n padding: 20px;\n margin-bottom: 20px;\n box-shadow: 0 4px 6px rgba(0,0,0,0.3);\n}\n.card h2 { margin-bottom: 12px; font-size: 1.2rem; }\n.badge {\n display: inline-block;\n padding: 6px 16px;\n border-radius: 20px;\n font-weight: 600;\n font-size: 0.9rem;\n background: #475569;\n color: #94a3b8;\n}\n.badge.disconnected { background: #ef4444; color: #fff; }\n.badge.connected { background: #3b82f6; color: #fff; }\n.badge.idle { background: #64748b; color: #fff; }\n.badge.broadcasting { background: #22c55e; color: #fff; animation: pulse 1.5s infinite; }\n.badge.paused { background: #eab308; color: #000; }\n.badge.finished { background: #8b5cf6; color: #fff; }\n@keyframes pulse { 0% { opacity: 1; } 50% { opacity: 0.6; } 100% { opacity: 1; } }\n\n.status-bar { display: flex; justify-content: space-between; align-items: center; flex-wrap: wrap; gap: 10px; }\n.ping { font-size: 0.85rem; color: #94a3b8; }\n.ping.online { color: #22c55e; }\n.ping.offline { color: #ef4444; }\n\n.progress-bar-container {\n background: #0f172a;\n border-radius: 8px;\n height: 30px;\n position: relative;\n overflow: hidden;\n margin-bottom: 12px;\n}\n.progress-bar {\n background: linear-gradient(90deg, #22c55e, #3b82f6);\n height: 100%;\n border-radius: 8px;\n transition: width 0.5s ease;\n}\n.progress-label {\n position: absolute;\n top: 50%;\n left: 50%;\n transform: translate(-50%, -50%);\n font-size: 0.85rem;\n font-weight: 600;\n color: #e2e8f0;\n text-shadow: 0 1px 2px rgba(0,0,0,0.5);\n}\n\n.stats { display: flex; gap: 30px; margin-top: 10px; flex-wrap: wrap; }\n.stats div { background: #0f172a; padding: 8px 16px; border-radius: 8px; font-size: 0.9rem; }\n\ntextarea {\n width: 100%;\n padding: 10px;\n border-radius: 8px;\n border: 1px solid #334155;\n background: #0f172a;\n color: #e2e8f0;\n font-size: 1rem;\n resize: vertical;\n margin-bottom: 10px;\n font-family: inherit;\n}\n.btn {\n padding: 10px 24px;\n border: none;\n border-radius: 8px;\n font-weight: 600;\n cursor: pointer;\n transition: all 0.2s;\n font-size: 1rem;\n}\n.btn:hover { opacity: 0.8; transform: scale(0.97); }\n.btn:disabled { opacity: 0.4; cursor: not-allowed; transform: none; }\n.primary { background: #3b82f6; color: #fff; }\n.success { background: #22c55e; color: #000; }\n.warning { background: #eab308; color: #000; }\n.danger { background: #ef4444; color: #fff; }\n.secondary { background: #475569; color: #fff; }\n\n.button-group { display: flex; gap: 12px; flex-wrap: wrap; }\n\n#log-container {\n background: #0f172a;\n border-radius: 8px;\n padding: 12px;\n max-height: 250px;\n overflow-y: auto;\n font-family: 'Courier New', monospace;\n font-size: 0.85rem;\n}\n#log-container p { margin: 4px 0; border-bottom: 1px solid #1e293b; padding: 4px 0; }\n#log-container p.log-empty { color: #64748b; border: none; }\n#qr-container { display: flex; flex-direction: column; justify-content: center; align-items: center; min-height: 220px; }\n#qr-image { border: 4px solid #fff; border-radius: 12px; }\n\n.setup-card { background: #1e293b; }\n.setup-card ol { padding-left: 20px; line-height: 1.8; }\n.setup-card code { background: #0f172a; padding: 2px 8px; border-radius: 4px; font-size: 0.85rem; color: #38bdf8; }\n.dashboard-url { margin-top: 10px; font-size: 0.85rem; color: #94a3b8; }\n\n.settings-grid {\n display: grid;\n grid-template-columns: repeat(auto-fill, minmax(140px, 1fr));\n gap: 12px;\n margin-bottom: 14px;\n}\n.setting-item { display: flex; flex-direction: column; gap: 4px; }\n.setting-item label { font-size: 0.8rem; color: #94a3b8; }\n.setting-item input {\n width: 100%;\n padding: 8px;\n border-radius: 6px;\n border: 1px solid #334155;\n background: #0f172a;\n color: #e2e8f0;\n font-size: 0.95rem;\n}\n.setting-item input:focus { outline: none; border-color: #3b82f6; }\n",[],[226],"8c4bcfb0-aef6-44ba-9f36-a69271d9ca6f","script.js","019f8924-06aa-7049-b41b-75e1e29304e3",["D",1784713869204],6,"const API_BASE = '/api';\n\n// DOM refs\nconst qrImage = document.getElementById('qr-image');\nconst qrStatus = document.getElementById('qr-status');\nconst statusBadge = document.getElementById('status-badge');\nconst botPing = document.getElementById('bot-ping');\nconst progressText = document.getElementById('progress-text');\nconst progressBar = document.getElementById('progress-bar');\nconst sentCount = document.getElementById('sent-count');\nconst remainingCount = document.getElementById('remaining-count');\nconst sentToday = document.getElementById('sent-today');\nconst messageInput = document.getElementById('message-input');\nconst saveMsgBtn = document.getElementById('save-message-btn');\nconst startBtn = document.getElementById('start-btn');\nconst pauseBtn = document.getElementById('pause-btn');\nconst stopBtn = document.getElementById('stop-btn');\nconst resetBtn = document.getElementById('reset-btn');\nconst logContainer = document.getElementById('log-container');\nconst msgFeedback = document.getElementById('message-feedback');\nconst apiUrl = document.getElementById('api-url');\nconst setMinDelay = document.getElementById('set-min-delay');\nconst setMaxDelay = document.getElementById('set-max-delay');\nconst setBatchSize = document.getElementById('set-batch-size');\nconst setBatchCooldown = document.getElementById('set-batch-cooldown');\nconst setDailyLimit = document.getElementById('set-daily-limit');\nconst setStartHour = document.getElementById('set-start-hour');\nconst setEndHour = document.getElementById('set-end-hour');\nconst saveSettingsBtn = document.getElementById('save-settings-btn');\nconst settingsFeedback = document.getElementById('settings-feedback');\nconst modeApiBtn = document.getElementById('mode-api-btn');\nconst modeTermuxBtn = document.getElementById('mode-termux-btn');\nconst modeDesc = document.getElementById('mode-desc');\nconst apiSetup = document.getElementById('api-setup');\nconst termuxSetup = document.getElementById('termux-setup');\nconst waTestBtn = document.getElementById('wa-test-btn');\nconst waTestFeedback = document.getElementById('wa-test-feedback');\nconst contactsCard = document.getElementById('contacts-card');\nconst contactsInput = document.getElementById('contacts-input');\nconst saveContactsBtn = document.getElementById('save-contacts-btn');\nconst contactsFeedback = document.getElementById('contacts-feedback');\n\nlet lastLogCount = 0;\nlet currentMessage = '';\nlet currentMode = 'api';\nlet isSendLoopRunning = false;\n\n// Polling\nasync function fetchStatus() {\n try {\n const res = await fetch(`${API_BASE}/status`);\n const data = await res.json();\n updateUI(data);\n } catch (err) {\n botPing.textContent = '● Offline';\n botPing.className = 'ping offline';\n }\n}\n\nfunction updateUI(data) {\n currentMode = data.waMode || 'api';\n\n // Mode toggle UI\n if (currentMode === 'api') {\n modeApiBtn.className = 'btn success';\n modeTermuxBtn.className = 'btn secondary';\n apiSetup.style.display = '';\n termuxSetup.style.display = 'none';\n contactsCard.style.display = '';\n modeDesc.textContent = 'WhatsApp Business Cloud API — sends directly from Val Town, no QR code needed.';\n } else {\n modeApiBtn.className = 'btn secondary';\n modeTermuxBtn.className = 'btn success';\n apiSetup.style.display = 'none';\n termuxSetup.style.display = '';\n contactsCard.style.display = 'none';\n modeDesc.textContent = 'Termux Bot — runs on your phone, scans QR to connect.';\n }\n\n // Bot online check\n if (data.lastBotUpdate) {\n const age = Date.now() - new Date(data.lastBotUpdate).getTime();\n if (age < 30000) {\n botPing.textContent = '● Bot: Online';\n botPing.className = 'ping online';\n } else {\n botPing.textContent = `● Bot: Offline (${Math.floor(age/1000)}s)`;\n botPing.className = 'ping offline';\n }\n } else if (data.waConnected) {\n botPing.textContent = '● API: Connected';\n botPing.className = 'ping online';\n } else {\n botPing.textContent = '● Offline';\n botPing.className = 'ping offline';\n }\n\n // QR (termux mode only)\n if (data.qrCode && currentMode === 'termux') {\n qrImage.src = data.qrCode;\n qrImage.style.display = 'block';\n qrStatus.textContent = 'Scan this QR with WhatsApp';\n } else {\n qrImage.style.display = 'none';\n if (data.status !== 'disconnected') {\n qrStatus.textContent = '✅ WhatsApp connected!';\n } else {\n qrStatus.textContent = 'Waiting for bot to connect...';\n }\n }\n\n // Badge\n statusBadge.textContent = data.status.charAt(0).toUpperCase() + data.status.slice(1);\n statusBadge.className = 'badge ' + data.status;\n\n // Progress\n const current = data.currentIndex || 0;\n const total = data.totalGroups || 0;\n const pct = total > 0 ? Math.round((current / total) * 100) : 0;\n const label = currentMode === 'api' ? 'contacts' : 'groups';\n progressText.textContent = `${current} / ${total} ${label} (${pct}%)`;\n progressBar.style.width = pct + '%';\n sentCount.textContent = data.sentCount || 0;\n remainingCount.textContent = data.remaining || (total - current);\n sentToday.textContent = data.sentToday || data.sentCount || 0;\n\n // Message\n if (data.broadcastMessage && data.broadcastMessage !== currentMessage) {\n messageInput.value = data.broadcastMessage;\n currentMessage = data.broadcastMessage;\n }\n\n // Settings\n if (data.settings) {\n setMinDelay.value = data.settings.minDelaySec ?? 30;\n setMaxDelay.value = data.settings.maxDelaySec ?? 90;\n setBatchSize.value = data.settings.batchSize ?? 12;\n setBatchCooldown.value = data.settings.batchCooldownMin ?? 120;\n setDailyLimit.value = data.settings.dailyLimit ?? 50;\n setStartHour.value = data.settings.startHour ?? 9;\n setEndHour.value = data.settings.endHour ?? 21;\n }\n\n // Buttons\n const isConnected = currentMode === 'api' ? data.waConnected : data.status !== 'disconnected';\n const hasTargets = currentMode === 'api' ? (data.contacts && data.contacts.length > 0) : (data.totalGroups > 0);\n const isRunning = data.status === 'broadcasting' || data.status === 'paused';\n startBtn.disabled = !isConnected || !hasTargets || isRunning;\n pauseBtn.disabled = !isRunning;\n pauseBtn.textContent = data.isPaused ? '▶️ Resume' : '⏸️ Pause';\n stopBtn.disabled = !isRunning;\n\n // In API mode, auto-run send loop when broadcasting\n if (currentMode === 'api' && data.status === 'broadcasting' && !isSendLoopRunning) {\n isSendLoopRunning = true;\n sendLoop();\n }\n if (data.status !== 'broadcasting') {\n isSendLoopRunning = false;\n }\n\n // Logs\n if (data.logs && data.logs.length > 0) {\n if (data.logs.length !== lastLogCount) {\n lastLogCount = data.logs.length;\n renderLogs(data.logs);\n }\n } else if (lastLogCount !== 0) {\n lastLogCount = 0;\n logContainer.innerHTML = '

System ready.

';\n }\n}\n\nfunction renderLogs(logs) {\n logContainer.innerHTML = '';\n for (let i = logs.length - 1; i >= 0; i--) {\n const entry = logs[i];\n const p = document.createElement('p');\n p.textContent = `[${new Date(entry.time).toLocaleTimeString()}] ${entry.message}`;\n logContainer.appendChild(p);\n }\n logContainer.scrollTop = 0;\n}\n\n// API mode: client-side send loop\nasync function sendLoop() {\n if (!isSendLoopRunning) return;\n try {\n const res = await fetch(`${API_BASE}/send-next`, { method: 'POST' });\n const data = await res.json();\n if (data.action === 'sent') {\n // Message sent — wait min delay then try next\n const settings = {\n min: parseInt(setMinDelay.value) || 30,\n max: parseInt(setMaxDelay.value) || 90,\n };\n const wait = Math.floor(Math.random() * (settings.max - settings.min + 1)) + settings.min;\n addLogLocal(`⏳ Next send in ${wait}s...`);\n setTimeout(() => { if (isSendLoopRunning) sendLoop(); }, wait * 1000);\n } else if (data.action === 'waiting') {\n // Still in delay/cooldown — check again in 3s\n setTimeout(() => { if (isSendLoopRunning) sendLoop(); }, 3000);\n } else if (data.action === 'done' || data.action === 'error') {\n isSendLoopRunning = false;\n } else {\n setTimeout(() => { if (isSendLoopRunning) sendLoop(); }, 3000);\n }\n } catch (err) {\n setTimeout(() => { if (isSendLoopRunning) sendLoop(); }, 5000);\n }\n}\n\nasync function sendCommand(endpoint, payload = {}) {\n try {\n const res = await fetch(`${API_BASE}/${endpoint}`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(payload)\n });\n const data = await res.json();\n if (data.error) { addLogLocal(`❌ ${data.error}`); }\n else { addLogLocal(`✅ ${endpoint} OK`); }\n fetchStatus();\n } catch (err) { addLogLocal(`❌ ${err.message}`); }\n}\n\nasync function saveMessage() {\n const msg = messageInput.value.trim();\n if (!msg) { msgFeedback.textContent = '❌ Empty'; return; }\n try {\n const res = await fetch(`${API_BASE}/message`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ message: msg })\n });\n const data = await res.json();\n msgFeedback.textContent = data.success ? '✅ Saved!' : '❌ Failed';\n setTimeout(() => msgFeedback.textContent = '', 3000);\n currentMessage = msg;\n fetchStatus();\n } catch { msgFeedback.textContent = '❌ Error'; }\n}\n\nasync function saveSettings() {\n const payload = {\n minDelaySec: parseInt(setMinDelay.value) || 30,\n maxDelaySec: parseInt(setMaxDelay.value) || 90,\n batchSize: parseInt(setBatchSize.value) || 12,\n batchCooldownMin: parseInt(setBatchCooldown.value) || 120,\n dailyLimit: parseInt(setDailyLimit.value) || 50,\n startHour: parseInt(setStartHour.value) || 9,\n endHour: parseInt(setEndHour.value) || 21,\n };\n try {\n const res = await fetch(`${API_BASE}/settings`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify(payload)\n });\n const data = await res.json();\n settingsFeedback.textContent = data.success ? '✅ Saved!' : '❌ Failed';\n setTimeout(() => settingsFeedback.textContent = '', 3000);\n fetchStatus();\n } catch { settingsFeedback.textContent = '❌ Error'; }\n}\n\nasync function saveContacts() {\n const lines = contactsInput.value.trim().split('\\n').filter(l => l.trim());\n const contacts = lines.map(line => {\n const parts = line.split(',').map(s => s.trim());\n return { phone: parts[0] || '', name: parts[1] || parts[0] || '' };\n }).filter(c => c.phone);\n try {\n const res = await fetch(`${API_BASE}/contacts`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ contacts })\n });\n const data = await res.json();\n contactsFeedback.textContent = data.success ? `✅ ${data.count} saved!` : '❌ Failed';\n setTimeout(() => contactsFeedback.textContent = '', 3000);\n fetchStatus();\n } catch { contactsFeedback.textContent = '❌ Error'; }\n}\n\nasync function testWhatsAppAPI() {\n waTestFeedback.textContent = '⏳ Testing...';\n try {\n const res = await fetch(`${API_BASE}/wa-test`, { method: 'POST' });\n const data = await res.json();\n if (data.success) {\n waTestFeedback.textContent = '✅ Connected!';\n } else {\n waTestFeedback.textContent = `❌ ${data.error || 'Failed'}`;\n }\n setTimeout(() => waTestFeedback.textContent = '', 5000);\n fetchStatus();\n } catch (err) { waTestFeedback.textContent = `❌ ${err.message}`; }\n}\n\nasync function switchMode(mode) {\n try {\n await fetch(`${API_BASE}/wa-mode`, {\n method: 'POST', headers: { 'Content-Type': 'application/json' },\n body: JSON.stringify({ mode })\n });\n fetchStatus();\n } catch {}\n}\n\nasync function resetAll() {\n if (!confirm('Reset everything?')) return;\n try {\n await fetch(`${API_BASE}/reset`, { method: 'POST' });\n isSendLoopRunning = false;\n lastLogCount = 0;\n fetchStatus();\n } catch {}\n}\n\nfunction addLogLocal(text) {\n const p = document.createElement('p');\n p.textContent = `[${new Date().toLocaleTimeString()}] ${text}`;\n logContainer.prepend(p);\n if (logContainer.children.length > 100) logContainer.removeChild(logContainer.lastChild);\n}\n\n// Event listeners\nsaveMsgBtn.addEventListener('click', saveMessage);\nsaveSettingsBtn.addEventListener('click', saveSettings);\nsaveContactsBtn.addEventListener('click', saveContacts);\nwaTestBtn.addEventListener('click', testWhatsAppAPI);\nmodeApiBtn.addEventListener('click', () => switchMode('api'));\nmodeTermuxBtn.addEventListener('click', () => switchMode('termux'));\nstartBtn.addEventListener('click', () => sendCommand('start'));\npauseBtn.addEventListener('click', () => sendCommand('pause'));\nstopBtn.addEventListener('click', () => sendCommand('stop'));\nresetBtn.addEventListener('click', resetAll);\n\nsetInterval(fetchStatus, 2000);\nfetchStatus();\n",[],[235],"04a8c4ae-f1e6-41fc-abd9-4c3f1c16350b","main.tsx",26,["D",1784713827633],13,"http","import { staticHTTPServer } from \"https://esm.town/v/std/utils/index.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { Hono } from \"npm:hono@4.11.9\";\n\nconst app = new Hono();\nconst STATE_KEY = \"whatsapp_state_v2\";\n\nconst DEFAULT_SETTINGS = {\n minDelaySec: 30,\n maxDelaySec: 90,\n batchSize: 12,\n batchCooldownMin: 120,\n dailyLimit: 50,\n startHour: 9,\n endHour: 21,\n};\n\nconst DEFAULT_STATE = {\n command: \"idle\" as string,\n botStatus: \"disconnected\" as string,\n qrCode: null as string | null,\n broadcastMessage: \"👋 Hello {name}! This is your automated update.\",\n totalGroups: 0,\n sentCount: 0,\n currentIndex: 0,\n remaining: 0,\n isPaused: false,\n groups: [] as string[],\n contacts: [] as { phone: string; name: string }[],\n sentToday: 0,\n lastSentDate: null as string | null,\n logs: [] as { time: string; message: string }[],\n lastBotUpdate: null as string | null,\n lastSentAt: null as string | null,\n settings: DEFAULT_SETTINGS,\n waMode: \"api\" as string, // \"api\" or \"termux\"\n waConnected: false as boolean,\n};\n\nasync function getState() {\n const state = await blob.getJSON(STATE_KEY);\n return { ...DEFAULT_STATE, ...(state ?? {}) };\n}\n\nasync function setState(updates: Record) {\n const current = await getState();\n const newState = { ...current, ...updates };\n await blob.setJSON(STATE_KEY, newState);\n return newState;\n}\n\nasync function addLog(message: string) {\n const state = await getState();\n const logs = [...(state.logs ?? []), { time: new Date().toISOString(), message }];\n if (logs.length > 100) logs.shift();\n await setState({ logs });\n}\n\n// ─── GET /api/status ───\napp.get(\"/api/status\", async (c) => {\n const state = await getState();\n const s = { ...DEFAULT_SETTINGS, ...(state.settings ?? {}) };\n return c.json({\n status: state.botStatus,\n qrCode: state.qrCode,\n totalGroups: state.waMode === \"api\" ? state.contacts.length : state.totalGroups,\n sentCount: state.sentCount,\n remaining: state.waMode === \"api\" ? state.contacts.length - state.currentIndex : state.remaining,\n currentIndex: state.currentIndex,\n broadcastMessage: state.broadcastMessage,\n isPaused: state.isPaused,\n groups: state.groups,\n contacts: state.contacts,\n logs: state.logs,\n command: state.command,\n lastBotUpdate: state.lastBotUpdate,\n lastSentAt: state.lastSentAt,\n settings: s,\n waMode: state.waMode,\n waConnected: state.waConnected,\n });\n});\n\n// ─── POST /api/settings ───\napp.post(\"/api/settings\", async (c) => {\n const body = await c.req.json();\n const current = await getState();\n const cs = { ...DEFAULT_SETTINGS, ...(current.settings ?? {}) };\n const newSettings = {\n minDelaySec: body.minDelaySec ?? cs.minDelaySec,\n maxDelaySec: body.maxDelaySec ?? cs.maxDelaySec,\n batchSize: body.batchSize ?? cs.batchSize,\n batchCooldownMin: body.batchCooldownMin ?? cs.batchCooldownMin,\n dailyLimit: body.dailyLimit ?? cs.dailyLimit,\n startHour: body.startHour ?? cs.startHour,\n endHour: body.endHour ?? cs.endHour,\n };\n await setState({ settings: newSettings });\n await addLog(\"⚙️ Broadcast settings updated\");\n return c.json({ success: true, settings: newSettings });\n});\n\n// ─── POST /api/contacts — save contacts list ───\napp.post(\"/api/contacts\", async (c) => {\n const body = await c.req.json();\n const contacts = (body.contacts || []).map((c: { phone: string; name: string }) => ({\n phone: String(c.phone).replace(/\\D/g, \"\"),\n name: c.name || c.phone,\n }));\n await setState({ contacts });\n await addLog(`📋 Saved ${contacts.length} contacts`);\n return c.json({ success: true, count: contacts.length });\n});\n\n// ─── POST /api/message ───\napp.post(\"/api/message\", async (c) => {\n const body = await c.req.json();\n if (body.message !== undefined) {\n await setState({ broadcastMessage: body.message });\n await addLog(\"📝 Message updated\");\n return c.json({ success: true });\n }\n return c.json({ error: \"Message is required\" }, 400);\n});\n\n// ─── POST /api/wa-mode — switch between api/termux ───\napp.post(\"/api/wa-mode\", async (c) => {\n const body = await c.req.json();\n if (body.mode === \"api\" || body.mode === \"termux\") {\n await setState({ waMode: body.mode, botStatus: \"disconnected\", waConnected: false, qrCode: null });\n await addLog(`🔄 Switched to ${body.mode === \"api\" ? \"WhatsApp API\" : \"Termux Bot\"} mode`);\n return c.json({ success: true, mode: body.mode });\n }\n return c.json({ error: \"Invalid mode\" }, 400);\n});\n\n// ─── POST /api/wa-test — test WhatsApp API connection ───\napp.post(\"/api/wa-test\", async (c) => {\n const token = Deno.env.get(\"WHATSAPP_TOKEN\");\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n if (!token || !phoneId) {\n return c.json({ error: \"Missing WHATSAPP_TOKEN or WHATSAPP_PHONE_NUMBER_ID env vars\" }, 400);\n }\n try {\n const res = await fetch(`https://graph.facebook.com/v18.0/${phoneId}`, {\n headers: { Authorization: `Bearer ${token}` },\n });\n if (res.ok) {\n const data = await res.json();\n await setState({ waConnected: true, botStatus: \"idle\" });\n await addLog(\"✅ WhatsApp API connected successfully!\");\n return c.json({ success: true, data });\n } else {\n const err = await res.text();\n await addLog(`❌ WhatsApp API test failed: ${err}`);\n return c.json({ error: err }, 400);\n }\n } catch (err) {\n return c.json({ error: String(err) }, 500);\n }\n});\n\n// ─── POST /api/send-next — send next message via WhatsApp API ───\napp.post(\"/api/send-next\", async (c) => {\n const state = await getState();\n\n // Check we're in API mode and connected\n if (state.waMode !== \"api\") {\n return c.json({ action: \"skip\", reason: \"Not in API mode\" });\n }\n if (!state.waConnected && state.botStatus === \"disconnected\") {\n return c.json({ action: \"skip\", reason: \"Not connected\" });\n }\n if (state.command !== \"start\" && state.botStatus !== \"broadcasting\") {\n return c.json({ action: \"skip\", reason: \"Not broadcasting\" });\n }\n\n const contacts = state.contacts || [];\n const index = state.currentIndex || 0;\n\n if (index >= contacts.length) {\n await setState({ botStatus: \"finished\", command: \"idle\" });\n await addLog(\"🎉 Broadcast finished!\");\n return c.json({ action: \"done\", reason: \"All contacts sent\" });\n }\n\n // Check daily limit\n const settings = { ...DEFAULT_SETTINGS, ...(state.settings ?? {}) };\n const today = new Date().toDateString();\n let sentToday = state.sentToday || 0;\n if (state.lastSentDate !== today) {\n sentToday = 0;\n }\n if (sentToday >= settings.dailyLimit) {\n await setState({ botStatus: \"finished\", command: \"idle\", sentToday });\n await addLog(`🚦 Daily limit reached (${settings.dailyLimit})`);\n return c.json({ action: \"done\", reason: \"Daily limit reached\" });\n }\n\n // Check working hours\n const hour = new Date().getHours();\n if (hour < settings.startHour || hour >= settings.endHour) {\n return c.json({ action: \"waiting\", reason: \"Outside working hours\", waitSec: 60 });\n }\n\n // Check delay since last send\n if (state.lastSentAt) {\n const elapsed = (Date.now() - new Date(state.lastSentAt).getTime()) / 1000;\n const minDelay = settings.minDelaySec;\n if (elapsed < minDelay) {\n return c.json({\n action: \"waiting\",\n reason: `Delay: ${Math.ceil(minDelay - elapsed)}s remaining`,\n waitSec: Math.ceil(minDelay - elapsed),\n });\n }\n }\n\n // Check batch cooldown\n if (sentToday > 0 && sentToday % settings.batchSize === 0 && state.lastSentAt) {\n const elapsed = (Date.now() - new Date(state.lastSentAt).getTime()) / 1000;\n const cooldownSec = settings.batchCooldownMin * 60;\n if (elapsed < cooldownSec) {\n return c.json({\n action: \"waiting\",\n reason: `Batch cooldown: ${Math.ceil((cooldownSec - elapsed) / 60)}min remaining`,\n waitSec: Math.ceil(cooldownSec - elapsed),\n });\n }\n }\n\n // Send the message!\n const contact = contacts[index];\n const token = Deno.env.get(\"WHATSAPP_TOKEN\");\n const phoneId = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\");\n\n if (!token || !phoneId) {\n await setState({ botStatus: \"disconnected\", command: \"idle\" });\n await addLog(\"❌ Missing WHATSAPP_TOKEN or WHATSAPP_PHONE_NUMBER_ID\");\n return c.json({ action: \"error\", reason: \"Missing env vars\" });\n }\n\n try {\n const personalizedMsg = state.broadcastMessage.replace(/{name}/g, contact.name).replace(/{group}/g, contact.name);\n const res = await fetch(`https://graph.facebook.com/v18.0/${phoneId}/messages`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n messaging_product: \"whatsapp\",\n to: contact.phone,\n type: \"text\",\n text: { body: personalizedMsg },\n }),\n });\n\n if (res.ok) {\n const newIndex = index + 1;\n const newSentToday = sentToday + 1;\n await setState({\n currentIndex: newIndex,\n sentCount: newIndex,\n sentToday: newSentToday,\n lastSentDate: today,\n lastSentAt: new Date().toISOString(),\n botStatus: \"broadcasting\",\n });\n await addLog(`✅ [${newIndex}/${contacts.length}] Sent to ${contact.name} (${contact.phone})`);\n return c.json({ action: \"sent\", index: newIndex, total: contacts.length, name: contact.name });\n } else {\n const err = await res.text();\n await addLog(`❌ Failed to send to ${contact.name}: ${err}`);\n // Skip this contact and move on\n await setState({ currentIndex: index + 1, lastSentAt: new Date().toISOString() });\n return c.json({ action: \"error\", reason: err, index: index + 1 });\n }\n } catch (err) {\n await addLog(`❌ Send error: ${String(err)}`);\n return c.json({ action: \"error\", reason: String(err) });\n }\n});\n\n// ─── POST /api/start ───\napp.post(\"/api/start\", async (c) => {\n const state = await getState();\n if (state.waMode === \"api\") {\n if (!state.waConnected) {\n return c.json({ error: \"WhatsApp API not connected. Click Test API first.\" }, 400);\n }\n if (state.contacts.length === 0) {\n return c.json({ error: \"No contacts added.\" }, 400);\n }\n } else {\n if (state.botStatus === \"disconnected\") {\n return c.json({ error: \"Bot not connected.\" }, 400);\n }\n if (state.totalGroups === 0) {\n return c.json({ error: \"No groups found.\" }, 400);\n }\n }\n await setState({ command: \"start\", isPaused: false, botStatus: \"broadcasting\" });\n await addLog(\"▶️ Start command sent\");\n return c.json({ success: true, status: \"Started\" });\n});\n\n// ─── POST /api/pause ───\napp.post(\"/api/pause\", async (c) => {\n const state = await getState();\n const newPaused = !state.isPaused;\n await setState({\n command: newPaused ? \"pause\" : \"resume\",\n isPaused: newPaused,\n botStatus: newPaused ? \"paused\" : \"broadcasting\",\n });\n await addLog(newPaused ? \"⏸️ Paused\" : \"▶️ Resumed\");\n return c.json({ success: true, paused: newPaused });\n});\n\n// ─── POST /api/stop ───\napp.post(\"/api/stop\", async (c) => {\n await setState({\n command: \"stop\",\n isPaused: false,\n botStatus: \"idle\",\n currentIndex: 0,\n sentCount: 0,\n sentToday: 0,\n });\n await addLog(\"⏹️ Stopped\");\n return c.json({ success: true, status: \"Stopped\" });\n});\n\n// ─── POST /api/bot-update ───\napp.post(\"/api/bot-update\", async (c) => {\n const body = await c.req.json();\n const updates: Record = {};\n if (body.botStatus !== undefined) updates.botStatus = body.botStatus;\n if (body.qrCode !== undefined) updates.qrCode = body.qrCode;\n if (body.totalGroups !== undefined) updates.totalGroups = body.totalGroups;\n if (body.sentCount !== undefined) updates.sentCount = body.sentCount;\n if (body.currentIndex !== undefined) updates.currentIndex = body.currentIndex;\n if (body.remaining !== undefined) updates.remaining = body.remaining;\n if (body.isPaused !== undefined) updates.isPaused = body.isPaused;\n if (body.groups !== undefined) updates.groups = body.groups;\n if (body.sentToday !== undefined) updates.sentToday = body.sentToday;\n if (body.lastSentDate !== undefined) updates.lastSentDate = body.lastSentDate;\n if (body.log !== undefined) {\n const state = await getState();\n const logs = [...(state.logs ?? []), { time: new Date().toISOString(), message: body.log }];\n if (logs.length > 100) logs.shift();\n updates.logs = logs;\n }\n updates.lastBotUpdate = new Date().toISOString();\n await setState(updates);\n const state = await getState();\n return c.json({\n command: state.command,\n broadcastMessage: state.broadcastMessage,\n settings: { ...DEFAULT_SETTINGS, ...(state.settings ?? {}) },\n });\n});\n\n// ─── GET /api/command ───\napp.get(\"/api/command\", async (c) => {\n const state = await getState();\n return c.json({\n command: state.command,\n broadcastMessage: state.broadcastMessage,\n isPaused: state.isPaused,\n settings: { ...DEFAULT_SETTINGS, ...(state.settings ?? {}) },\n });\n});\n\n// ─── POST /api/command/ack ───\napp.post(\"/api/command/ack\", async (c) => {\n await setState({ command: \"idle\" });\n return c.json({ success: true });\n});\n\n// ─── POST /api/reset ───\napp.post(\"/api/reset\", async (c) => {\n await blob.setJSON(STATE_KEY, DEFAULT_STATE);\n await addLog(\"🔄 Full reset\");\n return c.json({ success: true });\n});\n\n// Wrap app.fetch\nexport default staticHTTPServer(import.meta.url, async (req) => {\n const res = await app.fetch(req);\n if (res.status === 404) return null;\n return res;\n});\n",[],[243],["D",1784713827635],[],[18],"f5fd06a8-6964-4747-9e8c-6db976a61b59","favicon.svg","019f8924-06aa-7049-b41b-69ec5951e242",["D",1784712267284],"",[],[255],"ca0fb2d9-7992-4e52-9af9-b0e8b1dcddd0","README.md","019f8924-06a9-7602-a484-0ad165f5485f",14,["D",1784712920188],"# 📢 WhatsApp Broadcast Dashboard\n\nA web-based dashboard for broadcasting messages to WhatsApp groups with intelligent safety rules.\n\n## Architecture\n\n- **Dashboard (Val Town)** — Web UI + API. Serves the dashboard page and stores state in blob storage.\n- **Bot (Termux)** — Runs `whatsapp-web.js` on your phone. Connects to WhatsApp, polls the dashboard for commands, and reports status back.\n\n```\n┌─────────────────┐ poll commands ┌──────────────────┐\n│ Val Town │ ◄──────────────────── │ Termux Bot │\n│ Dashboard │ ────────────────────► │ (whatsapp-web.js)│\n│ (this val) │ report status │ (your phone) │\n└─────────────────┘ └──────────────────┘\n```\n\n## Dashboard Features\n\n- 📱 Scan QR code directly in browser\n- ✏️ Write/edit broadcast message with `{group}` placeholder\n- ▶️ Start, ⏸️ Pause/Resume, ⏹️ Stop controls\n- 📊 Real-time progress (sent, remaining, progress bar)\n- 📋 Activity log\n- 🟢 Bot online/offline indicator\n\n## API Endpoints\n\n| Method | Path | Description |\n|--------|------|-------------|\n| GET | `/api/status` | Current state (polled by dashboard every 2s) |\n| POST | `/api/message` | Update broadcast message |\n| POST | `/api/start` | Start broadcasting |\n| POST | `/api/pause` | Toggle pause/resume |\n| POST | `/api/stop` | Stop and reset |\n| POST | `/api/bot-update` | Bot reports status + gets command |\n| GET | `/api/command` | Bot polls for commands |\n| POST | `/api/command/ack` | Bot acknowledges command |\n| POST | `/api/reset` | Full state reset |\n\n## Safety Rules (built into the bot)\n\n- ⏱️ Random delays: 30–90 seconds between messages\n- 📦 Batch cooldown: 2 hours after every 12 messages\n- 📅 Daily limit: 50 messages per day\n- 🕘 Working hours: 9 AM – 9 PM only\n- ⌨️ Typing simulation before each message\n- 💾 Progress persistence via Val Town blob storage\n\n## Setup\n\n### 1. Dashboard (already deployed)\n\nYour dashboard is live at the URL shown in `main.tsx`'s endpoint.\n\n### 2. Termux Bot\n\nInstall Termux from F-Droid (not Play Store), then run:\n\n```bash\npkg update && pkg upgrade -y\npkg install nodejs git python build-base -y\nnpm install whatsapp-web.js qrcode\n```\n\nDownload `termux-bot.js` from this val, then:\n\n```bash\nnode termux-bot.js\n```\n\n### 3. Connect\n\n1. Open the dashboard URL in your browser\n2. The bot will send a QR code — scan it with WhatsApp\n3. Write your message (use `{group}` for personalization)\n4. Hit **Start**\n\n## Files\n\n| File | Purpose |\n|------|---------|\n| `main.tsx` | HTTP handler — API routes + static file serving |\n| `index.html` | Dashboard UI |\n| `style.css` | Dark theme styling |\n| `script.js` | Frontend polling and controls |\n| `termux-bot.js` | Bot script for Termux (download and run on phone) |\n\n## ⚠️ Safety Reminder\n\n- Use a **spare/secondary** WhatsApp number\n- Keep daily limit low (20–30) for the first few days\n- If you see rate limit errors, **stop immediately** and increase delays\n",[],[262],["D",1784712267284],{"_11":12,"_155":74},{"_11":12,"_150":151,"_73":74,"_30":72,"_152":153,"_154":24},{"_41":139,"_13":16,"_35":38,"_140":103,"_141":65,"_142":66,"_143":107,"_144":145,"_146":147,"_148":14,"_149":12},"ctx",{"_54":-5,"_176":306,"_307":308,"_309":310,"_311":24,"_312":24,"_313":24,"_314":116,"_315":-5,"_316":-7,"_317":-7,"_318":26,"_319":24,"_320":24,"_321":-5,"_322":24,"_323":24,"_324":24,"_325":-5},"ENV",{"_277":278,"_279":280,"_281":16,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]

📢 WhatsApp Group Broadcaster

🔀 Mode

📱 WhatsApp API Setup

🔐 Link Device (Termux)

📊 Progress

📋 Contacts

✏️ Broadcast Message

⚙️ Broadcast Settings

🎮 Controls

📋 Activity Log

History · index.html