[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",9,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","43d61854-9c99-11f1-9ad6-1607ee4eb77e","name","fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite2\";\n\nconst WASENDER_API_KEY = Deno.env.get(\"WASENDER_API_KEY\")!;\nconst WASENDER_WEBHOOK_SECRET = Deno.env.get(\"WASENDER_WEBHOOK_SECRET\");\nconst GEMINI_API_KEY = Deno.env.get(\"GEMINI_API_KEY\")!;\nconst GEMINI_MODEL = \"gemini-3.6-flash\";\nconst MIN_SEND_INTERVAL_MS = 61000;\nconst DEBUG_TOKEN = \"thais2026\";\n\nfunction col(row: any, name: string, index: number) {\n if (row == null) return null;\n if (row[name] !== undefined) return row[name];\n if (Array.isArray(row) && row[index] !== undefined) return row[index];\n return null;\n}\n\nasync function run(sql: string, args: any[] = []) {\n return await sqlite.execute({ sql, args });\n}\n\nasync function ensureTables() {\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_state (phone TEXT PRIMARY KEY, state TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_messages (id INTEGER PRIMARY KEY AUTOINCREMENT, phone TEXT, role TEXT, content TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_outbox (id INTEGER PRIMARY KEY AUTOINCREMENT, phone TEXT, text TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_meta (key TEXT PRIMARY KEY, value TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_debug (id INTEGER PRIMARY KEY AUTOINCREMENT, event TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_leads (phone TEXT PRIMARY KEY, nome TEXT, servico_interesse TEXT, situacao TEXT, problema TEXT, objecao TEXT, estagio_funil TEXT, updated_at TEXT)\",\n );\n}\n\nasync function logEvent(event: string) {\n console.log(event);\n try {\n await run(\"INSERT INTO thais_bot_debug (event, created_at) VALUES (?, ?)\", [\n event,\n new Date().toISOString(),\n ]);\n await run(\n \"DELETE FROM thais_bot_debug WHERE id NOT IN (SELECT id FROM thais_bot_debug ORDER BY id DESC LIMIT 50)\",\n );\n } catch (e) {\n console.log(\"logEvent falhou: \" + e);\n }\n}\n\nasync function getState(phone: string): Promise {\n const result = await run(\n \"SELECT state FROM thais_bot_state WHERE phone = ?\",\n [phone],\n );\n if (result.rows.length === 0) return { step: \"chat\" };\n const stateStr = col(result.rows[0], \"state\", 0);\n try {\n return JSON.parse(stateStr as string);\n } catch {\n return { step: \"chat\" };\n }\n}\n\nasync function setState(phone: string, state: any) {\n await run(\n \"INSERT INTO thais_bot_state (phone, state) VALUES (?, ?) ON CONFLICT(phone) DO UPDATE SET state = excluded.state\",\n [phone, JSON.stringify(state)],\n );\n}\n\nasync function addMessage(phone: string, role: string, content: string) {\n await run(\n \"INSERT INTO thais_bot_messages (phone, role, content, created_at) VALUES (?, ?, ?, ?)\",\n [phone, role, content, new Date().toISOString()],\n );\n}\n\nasync function getHistory(\n phone: string,\n limit = 20,\n): Promise<{ role: string; content: string }[]> {\n const sql =\n \"SELECT role, content FROM thais_bot_messages WHERE phone = ? ORDER BY id DESC LIMIT \" +\n limit;\n const result = await run(sql, [phone]);\n const list = result.rows.map((r: any) => ({\n role: col(r, \"role\", 0),\n content: col(r, \"content\", 1),\n }));\n return list.reverse();\n}\n\nasync function getMeta(key: string): Promise {\n const result = await run(\"SELECT value FROM thais_bot_meta WHERE key = ?\", [\n key,\n ]);\n if (result.rows.length === 0) return null;\n return col(result.rows[0], \"value\", 0) as string;\n}\n\nasync function setMeta(key: string, value: string) {\n await run(\n \"INSERT INTO thais_bot_meta (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n [key, value],\n );\n}\n\nasync function upsertLead(phone: string, fields: Record) {\n const existing = await run(\n \"SELECT phone FROM thais_bot_leads WHERE phone = ?\",\n [phone],\n );\n const now = new Date().toISOString();\n if (existing.rows.length === 0) {\n await run(\n \"INSERT INTO thais_bot_leads (phone, nome, servico_interesse, situacao, problema, objecao, estagio_funil, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\",\n [\n phone,\n fields.nome || null,\n fields.servico_interesse || null,\n fields.situacao || null,\n fields.problema || null,\n fields.objecao || null,\n fields.estagio_funil || \"novo_lead\",\n now,\n ],\n );\n } else {\n const sets: string[] = [];\n const args: any[] = [];\n for (\n const key of [\n \"nome\",\n \"servico_interesse\",\n \"situacao\",\n \"problema\",\n \"objecao\",\n \"estagio_funil\",\n ]\n ) {\n if (fields[key] !== undefined) {\n sets.push(key + \" = ?\");\n args.push(fields[key]);\n }\n }\n if (sets.length > 0) {\n sets.push(\"updated_at = ?\");\n args.push(now);\n args.push(phone);\n await run(\n \"UPDATE thais_bot_leads SET \" + sets.join(\", \") + \" WHERE phone = ?\",\n args,\n );\n }\n }\n}\n\nasync function enqueue(phone: string, text: string) {\n if (!phone || !text) {\n await logEvent(\"Ignorado enqueue vazio. phone=\" + phone);\n return;\n }\n await run(\n \"INSERT INTO thais_bot_outbox (phone, text, created_at) VALUES (?, ?, ?)\",\n [phone, text, new Date().toISOString()],\n );\n await logEvent(\"Enfileirado para \" + phone + \": \" + text.slice(0, 60));\n}\n\nasync function wasenderSend(\n to: string,\n text: string,\n): Promise<{ ok: boolean; status: number; body: string }> {\n const res = await fetch(\"https://wasenderapi.com/api/send-message\", {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + WASENDER_API_KEY,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ to, text }),\n });\n const body = await res.text();\n return { ok: res.ok, status: res.status, body };\n}\n\nasync function drainQueue() {\n const lastSendRaw = await getMeta(\"last_send_at\");\n const lastSend = lastSendRaw ? parseInt(lastSendRaw, 10) : 0;\n const now = Date.now();\n if (now - lastSend < MIN_SEND_INTERVAL_MS) {\n await logEvent(\n \"drainQueue: aguardando janela, faltam \" +\n Math.ceil((MIN_SEND_INTERVAL_MS - (now - lastSend)) / 1000) + \"s\",\n );\n return;\n }\n\n let attempts = 0;\n while (attempts < 10) {\n attempts++;\n const result = await run(\n \"SELECT id, phone, text FROM thais_bot_outbox ORDER BY id ASC LIMIT 1\",\n );\n if (result.rows.length === 0) {\n await logEvent(\"drainQueue: fila vazia\");\n return;\n }\n const r = result.rows[0];\n const id = col(r, \"id\", 0);\n const phone = col(r, \"phone\", 1);\n const text = col(r, \"text\", 2);\n\n if (!phone || !text) {\n await logEvent(\n \"Removendo mensagem invalida id=\" + id + \" phone=\" + phone + \" text=\" +\n text,\n );\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n continue;\n }\n\n const sendResult = await wasenderSend(phone as string, text as string);\n\n if (sendResult.ok) {\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n await setMeta(\"last_send_at\", String(Date.now()));\n await logEvent(\n \"Enviado para \" + phone + \": \" + (text as string).slice(0, 60),\n );\n } else if (sendResult.status === 429) {\n await logEvent(\"Rate limit: \" + sendResult.body);\n } else {\n await logEvent(\n \"Erro permanente, removendo id=\" + id + \": \" + sendResult.body,\n );\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n continue;\n }\n return;\n }\n}\n\n// ===== BASE DE CONHECIMENTO — atualizar conforme a Thaís confirmar =====\nconst KNOWLEDGE_BASE = [\n \"EMPRESA: Espaço Thaís de Oliveira — massoterapia humanizada, estética e bem-estar.\",\n \"SERVIÇOS: massoterapia humanizada, drenagem linfática manual, massagem modeladora, atendimento pós-parto, atendimento pós-operatório, procedimentos corporais e cuidados estéticos.\",\n \"\",\n \"TABELA DE PREÇOS (DADOS FICTÍCIOS PARA DEMONSTRAÇÃO — não são os preços reais do Espaço Thaís de Oliveira):\",\n \"- Drenagem Linfática Manual: atendimento voltado para bem-estar e sensação de leveza — 1.500 MT\",\n \"- Massagem Modeladora: atendimento com foco em modelagem corporal — 2.000 MT\",\n \"- Massagem Pós-Parto: atendimento direcionado ao período pós-parto — 2.500 MT\",\n \"- Massagem Pós-Operatória: atendimento conforme avaliação e orientação profissional — 3.000 MT\",\n \"- Tratamento dos Pés: cuidados estéticos dos pés — 800 MT\",\n \"\",\n \"HORÁRIOS: ainda não confirmados.\",\n \"ENDEREÇO/LOCALIZAÇÃO: ainda não confirmado.\",\n \"FORMAS DE PAGAMENTO: ainda não confirmadas.\",\n \"PROFISSIONAIS: ainda não confirmados por nome.\",\n \"REGRA: os preços acima são fictícios, apenas para demonstração. NUNCA inventar horário, endereço, forma de pagamento ou nome de profissional além do que está confirmado aqui.\",\n].join(\"\\n\");\n\nconst SYSTEM_PROMPT = [\n \"Você faz parte da equipa do Espaço Thaís de Oliveira, um espaço de massoterapia humanizada, estética e bem-estar em Moçambique. Está a conversar por WhatsApp com uma cliente ou potencial cliente. NUNCA revele que é uma inteligência artificial ou automação.\",\n \"\",\n \"=== REGRA PRINCIPAL — CONVERSA HUMANA E CONTEXTUAL ===\",\n \"Responda SEMPRE primeiro ao que a pessoa acabou de dizer, de forma natural, antes de avançar a conversa. NUNCA ignore uma saudação ou pergunta para lançar um discurso de vendas ou pedir o nome logo de início.\",\n \"REGRA RÍGIDA: uma mensagem do cliente recebe UMA resposta curta do bot, e depois PARA — espera a próxima mensagem da pessoa. NUNCA acumule cumprimento + pergunta de bem-estar + oferta de ajuda na mesma mensagem.\",\n \"Exemplos EXATOS a seguir (não acrescente nada a mais):\",\n \"Cliente: 'Bom dia.' → Bot: 'Bom dia, como estás?' (PARAR AQUI, não perguntar mais nada)\",\n \"Cliente: 'Boa tarde.' → Bot: 'Boa tarde, como estás?' (PARAR AQUI)\",\n \"Cliente: 'Boa noite.' → Bot: 'Boa noite, como estás?' (PARAR AQUI)\",\n \"Cliente: 'Estou bem.' → Bot: 'Também estou bem. Como posso ajudar?' (PARAR AQUI)\",\n \"Cliente: 'Tudo bem.' → Bot: 'Também estou bem. Como posso ajudar?' (PARAR AQUI)\",\n \"ERRADO (nunca faça isto): 'Boa noite! Tudo bem consigo? Como posso ajudar hoje?' — isto junta 3 coisas numa mensagem e denuncia que é um bot.\",\n \"Só depois de a pessoa expressar uma intenção relacionada a serviço, problema, preço ou agendamento (ex: 'queria saber sobre drenagem', 'quanto custa') é que o atendimento comercial começa — nunca durante o cumprimento inicial.\",\n \"Nunca faça várias perguntas na mesma mensagem. Uma pergunta de cada vez, sempre.\",\n \"Esta regra aplica-se a TODA a conversa, não só ao início: sempre reaja primeiro ao conteúdo da última mensagem da pessoa antes de conduzir a conversa adiante, e nunca acumule várias ideias numa só resposta.\",\n \"\",\n \"=== ESTILO ===\",\n \"Mensagens curtas (2-4 frases), tom caloroso, acolhedor e profissional, em português de Moçambique. Trate a pessoa por 'você'. NUNCA use emojis, em nenhuma situação: nem nas mensagens, nem em tabelas, preços, títulos, perguntas, fechamento, agendamento ou follow-up. Nunca listas numeradas nem menus. Evite respostas gigantes e linguagem robótica.\",\n \"\",\n \"=== REGRA COMERCIAL SOBRE PREÇOS — MUITO IMPORTANTE ===\",\n \"O bot NUNCA deve funcionar como uma tabela automática de preços. Se perguntarem 'tem tabela?' ou 'me manda os preços', NÃO despeje a tabela de imediato.\",\n \"Primeiro, procure entender: o que a pessoa procura, qual objetivo tem, que situação ou incómodo está a tentar resolver, há quanto tempo, o que já tentou.\",\n \"Exemplo de reação (adapte com naturalidade, não decore o texto): 'Claro, posso te mostrar os valores. Antes, para eu te indicar o que faz mais sentido: o que você gostaria de melhorar ou resolver?'\",\n \"Se a pessoa insistir em só querer ver a tabela (ex: 'quero só ver a tabela'), apresente a tabela — mas depois de a mostrar, retome a conversa: pergunte o que gostaria de alcançar, e continue a qualificação, tratamento de objeções, negociação e fechamento normalmente.\",\n \"O objetivo nunca é só informar preço — é conduzir Situação → Problema → Implicação → Necessidade → Solução → Benefício → Valor → Preço → Objeções → Negociação → Fechamento → Agendamento.\",\n \"\",\n \"=== METODOLOGIA SPIN (aplicada como conversa, nunca como questionário) ===\",\n \"Depois do ritual social inicial (cumprimento/como está), conduza a conversa investigando com perguntas naturais, uma de cada vez. Faça UMA pergunta, espere a resposta da pessoa, e só então faça a pergunta seguinte com base no que ela disse. NUNCA envie várias perguntas juntas (ex: 'qual é o objetivo? há quanto tempo? já fez tratamento?' tudo de uma vez é ERRADO).\",\n \"SITUAÇÃO: entenda o contexto da pessoa (ex: pós-parto, pós-operatório, dores, objetivo estético, etc.)\",\n \"PROBLEMA: descubra a real necessidade ou incómodo por trás do pedido.\",\n \"IMPLICAÇÃO: ajude a pessoa a perceber a importância de resolver isso (sem exagerar ou prometer resultados).\",\n \"NECESSIDADE: faça a pessoa perceber o valor de agir agora.\",\n \"SOLUÇÃO: recomende o serviço mais adequado do Espaço Thaís, com base no que a pessoa partilhou — nunca antes de entender a situação.\",\n \"BENEFÍCIOS: destaque benefícios ligados à necessidade identificada, sem prometer resultados médicos ou garantias.\",\n \"FECHAMENTO: conduza para o agendamento ou próximo passo, de forma natural, nunca forçada.\",\n \"\",\n \"=== OBJEÇÕES ===\",\n \"Quando surgir uma objeção ('está caro', 'vou pensar', 'preciso falar com alguém', 'tenho medo', 'nunca fiz', 'será que funciona'), acolha com empatia, procure entender a razão verdadeira por trás da objeção antes de tentar recolocar a proposta. Nunca insista de forma agressiva.\",\n \"\",\n \"=== SEGURANÇA — MUITO IMPORTANTE ===\",\n \"NUNCA diagnostique, prescreva, garanta resultados (ex: emagrecimento, eliminação de gordura) ou dê orientação médica. Para situações de saúde específicas (pós-parto, pós-operatório, dores, condições médicas), diga que o ideal é a pessoa falar diretamente com a profissional responsável para avaliar o caso dela.\",\n \"\",\n \"=== BASE DE CONHECIMENTO ===\",\n KNOWLEDGE_BASE,\n \"NUNCA invente preços, horários, endereço, formas de pagamento ou nomes de profissionais que não estejam confirmados acima. Se não souber, diga com naturalidade que vai confirmar essa informação e volta a responder — nunca finja saber.\",\n \"\",\n \"=== ENCAMINHAMENTO PARA HUMANO ===\",\n \"Se a pessoa pedir para falar com alguém, fizer uma reclamação, tiver uma dúvida médica específica que você não pode responder com segurança, ou a conversa exigir negociação fora do que sabe, termine a mensagem com ###HANDOFF###.\",\n].join(\"\\n\");\n\nasync function generateReply(\n history: { role: string; content: string }[],\n): Promise {\n if (history.length === 0) {\n return \"Olá! Tudo bem?\";\n }\n const contents = history.map((m) => ({\n role: m.role === \"assistant\" ? \"model\" : \"user\",\n parts: [{ text: m.content }],\n }));\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" +\n GEMINI_MODEL + \":generateContent?key=\" + GEMINI_API_KEY;\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n systemInstruction: { parts: [{ text: SYSTEM_PROMPT }] },\n contents,\n generationConfig: {\n temperature: 0.8,\n maxOutputTokens: 1024,\n },\n }),\n });\n if (!res.ok) {\n const errText = await res.text();\n await logEvent(\"Erro Gemini: \" + errText);\n return \"Desculpe, pode repetir por favor?\";\n }\n const data = await res.json();\n const parts =\n (data && data.candidates && data.candidates[0] &&\n data.candidates[0].content && data.candidates[0].content.parts) || [];\n const textParts = parts.filter((p: any) => !p.thought).map((p: any) =>\n p.text || \"\"\n );\n const text = textParts.join(\"\").trim();\n if (!text) {\n await logEvent(\n \"Resposta vazia do Gemini: \" + JSON.stringify(data).slice(0, 300),\n );\n return \"Desculpe, pode repetir por favor?\";\n }\n return text;\n}\n\nfunction normalize(text: string) {\n return text.trim().toLowerCase().normalize(\"NFD\").replace(\n /[\\u0300-\\u036f]/g,\n \"\",\n );\n}\n\nconst HUMAN_KEYWORDS = [\n \"falar com alguem\",\n \"falar com atendente\",\n \"quero um humano\",\n \"pessoa real\",\n \"atendente humano\",\n \"falar com a thais\",\n \"falar com a proprietaria\",\n];\n\nasync function handleIncoming(phone: string, rawText: string) {\n if (!phone || !rawText) return;\n const text = rawText.trim();\n const norm = normalize(text);\n const state = await getState(phone);\n\n if (state.step === \"human\") {\n await logEvent(\"Ignorado (estado human) de \" + phone);\n return;\n }\n\n await addMessage(phone, \"user\", text);\n\n const isHumanRequest = HUMAN_KEYWORDS.some((k) => norm.indexOf(k) !== -1);\n if (isHumanRequest) {\n await setState(phone, { step: \"human\" });\n const msg =\n \"Perfeito, já vou pedir para alguém da equipa continuar consigo. Só um instante.\";\n await addMessage(phone, \"assistant\", msg);\n await enqueue(phone, msg);\n await upsertLead(phone, { estagio_funil: \"encaminhado_humano\" });\n return;\n }\n\n const history = await getHistory(phone);\n let reply = await generateReply(history);\n\n let handoff = false;\n if (reply.indexOf(\"###HANDOFF###\") !== -1) {\n handoff = true;\n reply = reply.replace(\"###HANDOFF###\", \"\").trim();\n }\n\n await addMessage(phone, \"assistant\", reply);\n await enqueue(phone, reply);\n\n if (handoff) {\n await setState(phone, { step: \"human\" });\n await upsertLead(phone, { estagio_funil: \"encaminhado_humano\" });\n }\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n await ensureTables();\n\n if (req.method !== \"POST\") {\n if (url.pathname.indexOf(\"reset-\" + DEBUG_TOKEN) !== -1) {\n await run(\"DELETE FROM thais_bot_outbox\");\n await run(\"DELETE FROM thais_bot_meta WHERE key = 'last_send_at'\");\n await logEvent(\"RESET manual executado\");\n return new Response(\"Fila limpa com sucesso.\", { status: 200 });\n }\n\n if (url.pathname.indexOf(\"debug-\" + DEBUG_TOKEN) !== -1) {\n const outboxRaw = await run(\n \"SELECT id, phone, text, created_at FROM thais_bot_outbox ORDER BY id ASC\",\n );\n const outbox = outboxRaw.rows.map((r: any) => ({\n id: col(r, \"id\", 0),\n phone: col(r, \"phone\", 1),\n text: col(r, \"text\", 2),\n created_at: col(r, \"created_at\", 3),\n }));\n const debugLogRaw = await run(\n \"SELECT event, created_at FROM thais_bot_debug ORDER BY id DESC LIMIT 30\",\n );\n const recentLog = debugLogRaw.rows.map((r: any) => ({\n event: col(r, \"event\", 0),\n created_at: col(r, \"created_at\", 1),\n }));\n const leadsRaw = await run(\n \"SELECT phone, nome, servico_interesse, estagio_funil, updated_at FROM thais_bot_leads ORDER BY updated_at DESC LIMIT 30\",\n );\n const leads = leadsRaw.rows.map((r: any) => ({\n phone: col(r, \"phone\", 0),\n nome: col(r, \"nome\", 1),\n servico_interesse: col(r, \"servico_interesse\", 2),\n estagio_funil: col(r, \"estagio_funil\", 3),\n updated_at: col(r, \"updated_at\", 4),\n }));\n const lastSend = await getMeta(\"last_send_at\");\n const info = {\n now: new Date().toISOString(),\n last_send_at: lastSend\n ? new Date(parseInt(lastSend, 10)).toISOString()\n : null,\n outbox_count: outbox.length,\n outbox: outbox,\n recent_log: recentLog,\n leads: leads,\n };\n return new Response(JSON.stringify(info, null, 2), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n await drainQueue();\n return new Response(\"Bot Espaço Thaís de Oliveira - webhook ativo\", {\n status: 200,\n });\n }\n\n if (WASENDER_WEBHOOK_SECRET) {\n const signature = req.headers.get(\"x-webhook-signature\");\n if (signature !== WASENDER_WEBHOOK_SECRET) {\n await logEvent(\"Webhook rejeitado: assinatura invalida\");\n return new Response(\"Unauthorized\", { status: 401 });\n }\n }\n\n await drainQueue();\n\n const body = await req.json();\n await logEvent(\"Webhook recebido, event=\" + body.event);\n\n if (body.event === \"messages.received\") {\n const msg = body.data ? body.data.messages : null;\n if (msg && msg.key && !msg.key.fromMe) {\n const phone = msg.key.cleanedSenderPn || msg.key.remoteJid;\n const text = msg.messageBody ||\n (msg.message ? msg.message.conversation : \"\") || \"\";\n await logEvent(\"Mensagem de \" + phone + \": \" + text);\n if (phone && text) {\n await handleIncoming(phone, text);\n await drainQueue();\n }\n } else {\n await logEvent(\"Evento messages.received sem msg valida ou fromMe=true\");\n }\n }\n\n return new Response(\"OK\", { status: 200 });\n}","import { sqlite } from \"https://esm.town/v/std/sqlite2\";\n\nconst WASENDER_API_KEY = Deno.env.get(\"WASENDER_API_KEY\")!;\nconst WASENDER_WEBHOOK_SECRET = Deno.env.get(\"WASENDER_WEBHOOK_SECRET\");\nconst GEMINI_API_KEY = Deno.env.get(\"GEMINI_API_KEY\")!;\nconst GEMINI_MODEL = \"gemini-3.6-flash\";\nconst MIN_SEND_INTERVAL_MS = 61000;\nconst DEBUG_TOKEN = \"thais2026\";\n\nfunction col(row: any, name: string, index: number) {\n if (row == null) return null;\n if (row[name] !== undefined) return row[name];\n if (Array.isArray(row) && row[index] !== undefined) return row[index];\n return null;\n}\n\nasync function run(sql: string, args: any[] = []) {\n return await sqlite.execute({ sql, args });\n}\n\nasync function ensureTables() {\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_state (phone TEXT PRIMARY KEY, state TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_messages (id INTEGER PRIMARY KEY AUTOINCREMENT, phone TEXT, role TEXT, content TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_outbox (id INTEGER PRIMARY KEY AUTOINCREMENT, phone TEXT, text TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_meta (key TEXT PRIMARY KEY, value TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_debug (id INTEGER PRIMARY KEY AUTOINCREMENT, event TEXT, created_at TEXT)\",\n );\n await run(\n \"CREATE TABLE IF NOT EXISTS thais_bot_leads (phone TEXT PRIMARY KEY, nome TEXT, servico_interesse TEXT, situacao TEXT, problema TEXT, objecao TEXT, estagio_funil TEXT, updated_at TEXT)\",\n );\n}\n\nasync function logEvent(event: string) {\n console.log(event);\n try {\n await run(\"INSERT INTO thais_bot_debug (event, created_at) VALUES (?, ?)\", [\n event,\n new Date().toISOString(),\n ]);\n await run(\n \"DELETE FROM thais_bot_debug WHERE id NOT IN (SELECT id FROM thais_bot_debug ORDER BY id DESC LIMIT 50)\",\n );\n } catch (e) {\n console.log(\"logEvent falhou: \" + e);\n }\n}\n\nasync function getState(phone: string): Promise {\n const result = await run(\n \"SELECT state FROM thais_bot_state WHERE phone = ?\",\n [phone],\n );\n if (result.rows.length === 0) return { step: \"chat\" };\n const stateStr = col(result.rows[0], \"state\", 0);\n try {\n return JSON.parse(stateStr as string);\n } catch {\n return { step: \"chat\" };\n }\n}\n\nasync function setState(phone: string, state: any) {\n await run(\n \"INSERT INTO thais_bot_state (phone, state) VALUES (?, ?) ON CONFLICT(phone) DO UPDATE SET state = excluded.state\",\n [phone, JSON.stringify(state)],\n );\n}\n\nasync function addMessage(phone: string, role: string, content: string) {\n await run(\n \"INSERT INTO thais_bot_messages (phone, role, content, created_at) VALUES (?, ?, ?, ?)\",\n [phone, role, content, new Date().toISOString()],\n );\n}\n\nasync function getHistory(\n phone: string,\n limit = 10,\n): Promise<{ role: string; content: string }[]> {\n const sql =\n \"SELECT role, content FROM thais_bot_messages WHERE phone = ? ORDER BY id DESC LIMIT \" +\n limit;\n const result = await run(sql, [phone]);\n const list = result.rows.map((r: any) => ({\n role: col(r, \"role\", 0),\n content: col(r, \"content\", 1),\n }));\n return list.reverse();\n}\n\nasync function getMeta(key: string): Promise {\n const result = await run(\"SELECT value FROM thais_bot_meta WHERE key = ?\", [\n key,\n ]);\n if (result.rows.length === 0) return null;\n return col(result.rows[0], \"value\", 0) as string;\n}\n\nasync function setMeta(key: string, value: string) {\n await run(\n \"INSERT INTO thais_bot_meta (key, value) VALUES (?, ?) ON CONFLICT(key) DO UPDATE SET value = excluded.value\",\n [key, value],\n );\n}\n\nasync function upsertLead(phone: string, fields: Record) {\n const existing = await run(\n \"SELECT phone FROM thais_bot_leads WHERE phone = ?\",\n [phone],\n );\n const now = new Date().toISOString();\n if (existing.rows.length === 0) {\n await run(\n \"INSERT INTO thais_bot_leads (phone, nome, servico_interesse, situacao, problema, objecao, estagio_funil, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)\",\n [\n phone,\n fields.nome || null,\n fields.servico_interesse || null,\n fields.situacao || null,\n fields.problema || null,\n fields.objecao || null,\n fields.estagio_funil || \"novo_lead\",\n now,\n ],\n );\n } else {\n const sets: string[] = [];\n const args: any[] = [];\n for (\n const key of [\n \"nome\",\n \"servico_interesse\",\n \"situacao\",\n \"problema\",\n \"objecao\",\n \"estagio_funil\",\n ]\n ) {\n if (fields[key] !== undefined) {\n sets.push(key + \" = ?\");\n args.push(fields[key]);\n }\n }\n if (sets.length > 0) {\n sets.push(\"updated_at = ?\");\n args.push(now);\n args.push(phone);\n await run(\n \"UPDATE thais_bot_leads SET \" + sets.join(\", \") + \" WHERE phone = ?\",\n args,\n );\n }\n }\n}\n\nasync function enqueue(phone: string, text: string) {\n if (!phone || !text) {\n await logEvent(\"Ignorado enqueue vazio. phone=\" + phone);\n return;\n }\n await run(\n \"INSERT INTO thais_bot_outbox (phone, text, created_at) VALUES (?, ?, ?)\",\n [phone, text, new Date().toISOString()],\n );\n await logEvent(\"Enfileirado para \" + phone + \": \" + text.slice(0, 60));\n}\n\nasync function wasenderSend(\n to: string,\n text: string,\n): Promise<{ ok: boolean; status: number; body: string }> {\n const res = await fetch(\"https://wasenderapi.com/api/send-message\", {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + WASENDER_API_KEY,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ to, text }),\n });\n const body = await res.text();\n return { ok: res.ok, status: res.status, body };\n}\n\nasync function drainQueue() {\n const lastSendRaw = await getMeta(\"last_send_at\");\n const lastSend = lastSendRaw ? parseInt(lastSendRaw, 10) : 0;\n const now = Date.now();\n if (now - lastSend < MIN_SEND_INTERVAL_MS) {\n await logEvent(\n \"drainQueue: aguardando janela, faltam \" +\n Math.ceil((MIN_SEND_INTERVAL_MS - (now - lastSend)) / 1000) + \"s\",\n );\n return;\n }\n\n let attempts = 0;\n while (attempts < 10) {\n attempts++;\n const result = await run(\n \"SELECT id, phone, text FROM thais_bot_outbox ORDER BY id ASC LIMIT 1\",\n );\n if (result.rows.length === 0) {\n await logEvent(\"drainQueue: fila vazia\");\n return;\n }\n const r = result.rows[0];\n const id = col(r, \"id\", 0);\n const phone = col(r, \"phone\", 1);\n const text = col(r, \"text\", 2);\n\n if (!phone || !text) {\n await logEvent(\n \"Removendo mensagem invalida id=\" + id + \" phone=\" + phone + \" text=\" +\n text,\n );\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n continue;\n }\n\n const sendResult = await wasenderSend(phone as string, text as string);\n\n if (sendResult.ok) {\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n await setMeta(\"last_send_at\", String(Date.now()));\n await logEvent(\n \"Enviado para \" + phone + \": \" + (text as string).slice(0, 60),\n );\n } else if (sendResult.status === 429) {\n await logEvent(\"Rate limit: \" + sendResult.body);\n } else {\n await logEvent(\n \"Erro permanente, removendo id=\" + id + \": \" + sendResult.body,\n );\n await run(\"DELETE FROM thais_bot_outbox WHERE id = ?\", [id]);\n continue;\n }\n return;\n }\n}\n\n// ===== BASE DE CONHECIMENTO — atualizar conforme a Thaís confirmar =====\nconst KNOWLEDGE_BASE = [\n \"EMPRESA: Espaço Thaís de Oliveira — massoterapia humanizada, estética e bem-estar.\",\n \"SERVIÇOS: massoterapia humanizada, drenagem linfática manual, massagem modeladora, atendimento pós-parto, atendimento pós-operatório, procedimentos corporais e cuidados estéticos.\",\n \"\",\n \"TABELA DE PREÇOS (DADOS FICTÍCIOS PARA DEMONSTRAÇÃO — não são os preços reais do Espaço Thaís de Oliveira):\",\n \"- Drenagem Linfática Manual: atendimento voltado para bem-estar e sensação de leveza — 1.500 MT\",\n \"- Massagem Modeladora: atendimento com foco em modelagem corporal — 2.000 MT\",\n \"- Massagem Pós-Parto: atendimento direcionado ao período pós-parto — 2.500 MT\",\n \"- Massagem Pós-Operatória: atendimento conforme avaliação e orientação profissional — 3.000 MT\",\n \"- Tratamento dos Pés: cuidados estéticos dos pés — 800 MT\",\n \"\",\n \"HORÁRIOS: ainda não confirmados.\",\n \"ENDEREÇO/LOCALIZAÇÃO: ainda não confirmado.\",\n \"FORMAS DE PAGAMENTO: ainda não confirmadas.\",\n \"PROFISSIONAIS: ainda não confirmados por nome.\",\n \"REGRA: os preços acima são fictícios, apenas para demonstração. NUNCA inventar horário, endereço, forma de pagamento ou nome de profissional além do que está confirmado aqui.\",\n].join(\"\\n\");\n\nconst SYSTEM_PROMPT = [\n \"Você faz parte da equipa do Espaço Thaís de Oliveira, um espaço de massoterapia humanizada, estética e bem-estar em Moçambique. Está a conversar por WhatsApp com uma cliente ou potencial cliente. NUNCA revele que é uma inteligência artificial ou automação.\",\n \"\",\n \"=== REGRA PRINCIPAL — CONVERSA HUMANA E CONTEXTUAL ===\",\n \"Responda SEMPRE primeiro ao que a pessoa acabou de dizer, de forma natural, antes de avançar a conversa. NUNCA ignore uma saudação ou pergunta para lançar um discurso de vendas ou pedir o nome logo de início.\",\n \"REGRA RÍGIDA: uma mensagem do cliente recebe UMA resposta curta do bot, e depois PARA — espera a próxima mensagem da pessoa. NUNCA acumule cumprimento + pergunta de bem-estar + oferta de ajuda na mesma mensagem.\",\n \"Exemplos EXATOS a seguir (não acrescente nada a mais):\",\n \"Cliente: 'Bom dia.' → Bot: 'Bom dia, como estás?' (PARAR AQUI, não perguntar mais nada)\",\n \"Cliente: 'Boa tarde.' → Bot: 'Boa tarde, como estás?' (PARAR AQUI)\",\n \"Cliente: 'Boa noite.' → Bot: 'Boa noite, como estás?' (PARAR AQUI)\",\n \"Cliente: 'Estou bem.' → Bot: 'Também estou bem. Como posso ajudar?' (PARAR AQUI)\",\n \"Cliente: 'Tudo bem.' → Bot: 'Também estou bem. Como posso ajudar?' (PARAR AQUI)\",\n \"ERRADO (nunca faça isto): 'Boa noite! Tudo bem consigo? Como posso ajudar hoje?' — isto junta 3 coisas numa mensagem e denuncia que é um bot.\",\n \"Só depois de a pessoa expressar uma intenção relacionada a serviço, problema, preço ou agendamento (ex: 'queria saber sobre drenagem', 'quanto custa') é que o atendimento comercial começa — nunca durante o cumprimento inicial.\",\n \"Nunca faça várias perguntas na mesma mensagem. Uma pergunta de cada vez, sempre.\",\n \"Esta regra aplica-se a TODA a conversa, não só ao início: sempre reaja primeiro ao conteúdo da última mensagem da pessoa antes de conduzir a conversa adiante, e nunca acumule várias ideias numa só resposta.\",\n \"\",\n \"=== ESTILO ===\",\n \"Mensagens curtas (2-4 frases), tom caloroso, acolhedor e profissional, em português de Moçambique. Trate a pessoa por 'você'. NUNCA use emojis, em nenhuma situação: nem nas mensagens, nem em tabelas, preços, títulos, perguntas, fechamento, agendamento ou follow-up. Nunca listas numeradas nem menus. Evite respostas gigantes e linguagem robótica.\",\n \"\",\n \"=== REGRA COMERCIAL SOBRE PREÇOS — MUITO IMPORTANTE ===\",\n \"O bot NUNCA deve funcionar como uma tabela automática de preços. Se perguntarem 'tem tabela?' ou 'me manda os preços', NÃO despeje a tabela de imediato.\",\n \"Primeiro, procure entender: o que a pessoa procura, qual objetivo tem, que situação ou incómodo está a tentar resolver, há quanto tempo, o que já tentou.\",\n \"Exemplo de reação (adapte com naturalidade, não decore o texto): 'Claro, posso te mostrar os valores. Antes, para eu te indicar o que faz mais sentido: o que você gostaria de melhorar ou resolver?'\",\n \"Se a pessoa insistir em só querer ver a tabela (ex: 'quero só ver a tabela'), apresente a tabela — mas depois de a mostrar, retome a conversa: pergunte o que gostaria de alcançar, e continue a qualificação, tratamento de objeções, negociação e fechamento normalmente.\",\n \"O objetivo nunca é só informar preço — é conduzir Situação → Problema → Implicação → Necessidade → Solução → Benefício → Valor → Preço → Objeções → Negociação → Fechamento → Agendamento.\",\n \"\",\n \"=== METODOLOGIA SPIN (aplicada como conversa, nunca como questionário) ===\",\n \"Depois do ritual social inicial (cumprimento/como está), conduza a conversa investigando com perguntas naturais, uma de cada vez. Faça UMA pergunta, espere a resposta da pessoa, e só então faça a pergunta seguinte com base no que ela disse. NUNCA envie várias perguntas juntas (ex: 'qual é o objetivo? há quanto tempo? já fez tratamento?' tudo de uma vez é ERRADO).\",\n \"SITUAÇÃO: entenda o contexto da pessoa (ex: pós-parto, pós-operatório, dores, objetivo estético, etc.)\",\n \"PROBLEMA: descubra a real necessidade ou incómodo por trás do pedido.\",\n \"IMPLICAÇÃO: ajude a pessoa a perceber a importância de resolver isso (sem exagerar ou prometer resultados).\",\n \"NECESSIDADE: faça a pessoa perceber o valor de agir agora.\",\n \"SOLUÇÃO: recomende o serviço mais adequado do Espaço Thaís, com base no que a pessoa partilhou — nunca antes de entender a situação.\",\n \"BENEFÍCIOS: destaque benefícios ligados à necessidade identificada, sem prometer resultados médicos ou garantias.\",\n \"FECHAMENTO: conduza para o agendamento ou próximo passo, de forma natural, nunca forçada.\",\n \"\",\n \"=== OBJEÇÕES ===\",\n \"Quando surgir uma objeção ('está caro', 'vou pensar', 'preciso falar com alguém', 'tenho medo', 'nunca fiz', 'será que funciona'), acolha com empatia, procure entender a razão verdadeira por trás da objeção antes de tentar recolocar a proposta. Nunca insista de forma agressiva.\",\n \"\",\n \"=== SEGURANÇA — MUITO IMPORTANTE ===\",\n \"NUNCA diagnostique, prescreva, garanta resultados (ex: emagrecimento, eliminação de gordura) ou dê orientação médica. Para situações de saúde específicas (pós-parto, pós-operatório, dores, condições médicas), diga que o ideal é a pessoa falar diretamente com a profissional responsável para avaliar o caso dela.\",\n \"\",\n \"=== BASE DE CONHECIMENTO ===\",\n KNOWLEDGE_BASE,\n \"NUNCA invente preços, horários, endereço, formas de pagamento ou nomes de profissionais que não estejam confirmados acima. Se não souber, diga com naturalidade que vai confirmar essa informação e volta a responder — nunca finja saber.\",\n \"\",\n \"=== ENCAMINHAMENTO PARA HUMANO ===\",\n \"Se a pessoa pedir para falar com alguém, fizer uma reclamação, tiver uma dúvida médica específica que você não pode responder com segurança, ou a conversa exigir negociação fora do que sabe, termine a mensagem com ###HANDOFF###.\",\n].join(\"\\n\");\n\nasync function generateReply(\n history: { role: string; content: string }[],\n): Promise {\n if (history.length === 0) {\n return \"Olá! Tudo bem?\";\n }\n const contents = history.map((m) => ({\n role: m.role === \"assistant\" ? \"model\" : \"user\",\n parts: [{ text: m.content }],\n }));\n const url = \"https://generativelanguage.googleapis.com/v1beta/models/\" +\n GEMINI_MODEL + \":generateContent?key=\" + GEMINI_API_KEY;\n const t0 = Date.now();\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n systemInstruction: { parts: [{ text: SYSTEM_PROMPT }] },\n contents,\n generationConfig: {\n temperature: 0.8,\n maxOutputTokens: 1024,\n },\n }),\n });\n const t1 = Date.now();\n await logEvent(\n \"Gemini respondeu em \" + (t1 - t0) + \"ms (status \" + res.status + \")\",\n );\n if (!res.ok) {\n const errText = await res.text();\n await logEvent(\"Erro Gemini: \" + errText);\n return \"Desculpe, pode repetir por favor?\";\n }\n const data = await res.json();\n const parts =\n (data && data.candidates && data.candidates[0] &&\n data.candidates[0].content && data.candidates[0].content.parts) || [];\n const textParts = parts.filter((p: any) => !p.thought).map((p: any) =>\n p.text || \"\"\n );\n const text = textParts.join(\"\").trim();\n if (!text) {\n await logEvent(\n \"Resposta vazia do Gemini: \" + JSON.stringify(data).slice(0, 300),\n );\n return \"Desculpe, pode repetir por favor?\";\n }\n return text;\n}\n\nfunction normalize(text: string) {\n return text.trim().toLowerCase().normalize(\"NFD\").replace(\n /[\\u0300-\\u036f]/g,\n \"\",\n );\n}\n\nconst HUMAN_KEYWORDS = [\n \"falar com alguem\",\n \"falar com atendente\",\n \"quero um humano\",\n \"pessoa real\",\n \"atendente humano\",\n \"falar com a thais\",\n \"falar com a proprietaria\",\n];\n\nasync function handleIncoming(phone: string, rawText: string) {\n if (!phone || !rawText) return;\n const text = rawText.trim();\n const norm = normalize(text);\n const state = await getState(phone);\n\n if (state.step === \"human\") {\n await logEvent(\"Ignorado (estado human) de \" + phone);\n return;\n }\n\n await addMessage(phone, \"user\", text);\n\n const isHumanRequest = HUMAN_KEYWORDS.some((k) => norm.indexOf(k) !== -1);\n if (isHumanRequest) {\n await setState(phone, { step: \"human\" });\n const msg =\n \"Perfeito, já vou pedir para alguém da equipa continuar consigo. Só um instante.\";\n await addMessage(phone, \"assistant\", msg);\n await enqueue(phone, msg);\n await upsertLead(phone, { estagio_funil: \"encaminhado_humano\" });\n return;\n }\n\n const history = await getHistory(phone);\n let reply = await generateReply(history);\n\n let handoff = false;\n if (reply.indexOf(\"###HANDOFF###\") !== -1) {\n handoff = true;\n reply = reply.replace(\"###HANDOFF###\", \"\").trim();\n }\n\n await addMessage(phone, \"assistant\", reply);\n await enqueue(phone, reply);\n\n if (handoff) {\n await setState(phone, { step: \"human\" });\n await upsertLead(phone, { estagio_funil: \"encaminhado_humano\" });\n }\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n await ensureTables();\n\n if (req.method !== \"POST\") {\n if (url.pathname.indexOf(\"reset-\" + DEBUG_TOKEN) !== -1) {\n await run(\"DELETE FROM thais_bot_outbox\");\n await run(\"DELETE FROM thais_bot_meta WHERE key = 'last_send_at'\");\n await logEvent(\"RESET manual executado\");\n return new Response(\"Fila limpa com sucesso.\", { status: 200 });\n }\n\n if (url.pathname.indexOf(\"debug-\" + DEBUG_TOKEN) !== -1) {\n const outboxRaw = await run(\n \"SELECT id, phone, text, created_at FROM thais_bot_outbox ORDER BY id ASC\",\n );\n const outbox = outboxRaw.rows.map((r: any) => ({\n id: col(r, \"id\", 0),\n phone: col(r, \"phone\", 1),\n text: col(r, \"text\", 2),\n created_at: col(r, \"created_at\", 3),\n }));\n const debugLogRaw = await run(\n \"SELECT event, created_at FROM thais_bot_debug ORDER BY id DESC LIMIT 30\",\n );\n const recentLog = debugLogRaw.rows.map((r: any) => ({\n event: col(r, \"event\", 0),\n created_at: col(r, \"created_at\", 1),\n }));\n const leadsRaw = await run(\n \"SELECT phone, nome, servico_interesse, estagio_funil, updated_at FROM thais_bot_leads ORDER BY updated_at DESC LIMIT 30\",\n );\n const leads = leadsRaw.rows.map((r: any) => ({\n phone: col(r, \"phone\", 0),\n nome: col(r, \"nome\", 1),\n servico_interesse: col(r, \"servico_interesse\", 2),\n estagio_funil: col(r, \"estagio_funil\", 3),\n updated_at: col(r, \"updated_at\", 4),\n }));\n const lastSend = await getMeta(\"last_send_at\");\n const info = {\n now: new Date().toISOString(),\n last_send_at: lastSend\n ? new Date(parseInt(lastSend, 10)).toISOString()\n : null,\n outbox_count: outbox.length,\n outbox: outbox,\n recent_log: recentLog,\n leads: leads,\n };\n return new Response(JSON.stringify(info, null, 2), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n\n await drainQueue();\n return new Response(\"Bot Espaço Thaís de Oliveira - webhook ativo\", {\n status: 200,\n });\n }\n\n if (WASENDER_WEBHOOK_SECRET) {\n const signature = req.headers.get(\"x-webhook-signature\");\n if (signature !== WASENDER_WEBHOOK_SECRET) {\n await logEvent(\"Webhook rejeitado: assinatura invalida\");\n return new Response(\"Unauthorized\", { status: 401 });\n }\n }\n\n await drainQueue();\n\n const body = await req.json();\n await logEvent(\"Webhook recebido, event=\" + body.event);\n\n if (body.event === \"messages.received\") {\n const msg = body.data ? body.data.messages : null;\n if (msg && msg.key && !msg.key.fromMe) {\n const phone = msg.key.cleanedSenderPn || msg.key.remoteJid;\n const text = msg.messageBody ||\n (msg.message ? msg.message.conversation : \"\") || \"\";\n await logEvent(\"Mensagem de \" + phone + \": \" + text);\n if (phone && text) {\n await handleIncoming(phone, text);\n await drainQueue();\n }\n } else {\n await logEvent(\"Evento messages.received sem msg valida ou fromMe=true\");\n }\n }\n\n return new Response(\"OK\", { status: 200 });\n}","createdAt",["D",1787293168109],"branchVersion","branchId","d9975c34-9332-4351-8d7f-7dc614cf8f82","id","fcba7487-4061-4be1-ab68-9e3122e14f89","espaco-thais-bot-webhook",["D",1787231749994],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Bot de demonstração - Espaço Thaís de Oliveira","imageUrl","1d6e5cdc-39fc-4fd9-acd1-3afc9b33edec","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a01e69-24c0-74df-bc74-a8c39b5d535e","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},"branch",{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","cumbanasumburane","handle","displayName","Cumbana Sumburane","avatar","https://lh3.googleusercontent.com/a/ACg8ocLtGbzRhg6KGKltMED3AvWFAUEJX60x56OTp2BTw8V_8BzwvQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":152,"_80":153,"_82":154,"_84":25},"tree",[146],"files",[146],"counts",{"_134":62,"_135":136,"_137":62,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":58,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"97cd0bfe-798a-4343-b604-7644f0848425","parentId","latest",["D",1787293168109],8,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":62},"connections",{"_142":62,"_143":62},"count","unfilledCount",3,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":58,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1787293168109],"children",[],[28],["D",1787231749994],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":25},{"_13":14,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_78":-5,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":58,"_197":-5,"_198":-7,"_199":-7,"_200":62,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v9