[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"routes/_app.x.$handle.$name",{"_105":104,"_38":51,"_114":95,"_33":59,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":64,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",26,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","4d29b862-3a90-439f-ab35-5eab61e70f26","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","e17ef9de-a7c2-11f1-9e2a-1607ee4eb77e","name","fileType","http","content","import { JWT } from \"npm:google-auth-library@9\";\n\nconst SPREADSHEET_ID = Deno.env.get(\"SPREADSHEET_ID\")!;\nconst WHATSAPP_ACCESS_TOKEN = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\")!;\nconst WHATSAPP_PHONE_NUMBER_ID = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\")!;\nconst WHATSAPP_VERIFY_TOKEN = Deno.env.get(\"WHATSAPP_VERIFY_TOKEN\")!;\n\nconst serviceAccount = JSON.parse(Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_KEY\")!);\nconst jwtClient = new JWT({\n email: serviceAccount.client_email,\n key: serviceAccount.private_key,\n scopes: [\"https://www.googleapis.com/auth/spreadsheets\"],\n});\n\n// ---------- Google Sheets helpers ----------\n\nasync function getSheetIdByName(sheetName: string): Promise {\n const data = await sheetsFetch(\"?fields=sheets.properties\");\n const sheet = data.sheets.find((s: { properties: { title: string } }) =>\n s.properties.title === sheetName\n );\n return sheet.properties.sheetId;\n}\n\nasync function getActiveCronogramaForCliente(clienteName: string) {\n const rows = await getValues(\"Cronograma!A:E\");\n console.log(\"getActiveCronograma - procurando:\", JSON.stringify(clienteName));\n console.log(\"getActiveCronograma - linhas:\", JSON.stringify(rows));\n const resultado: { rowNumber: number; dia: string; material: string }[] = [];\n for (let i = 1; i < rows.length; i++) {\n if (rows[i][0] === clienteName && rows[i][3] !== \"Não\") {\n resultado.push({\n rowNumber: i + 1,\n dia: rows[i][1],\n material: rows[i][2],\n });\n }\n }\n console.log(\"getActiveCronograma - resultado:\", JSON.stringify(resultado));\n return resultado;\n}\n\nasync function deleteRow(sheetName: string, rowNumber: number) {\n const sheetId = await getSheetIdByName(sheetName);\n await sheetsFetch(\":batchUpdate\", {\n method: \"POST\",\n body: JSON.stringify({\n requests: [\n {\n deleteDimension: {\n range: {\n sheetId,\n dimension: \"ROWS\",\n startIndex: rowNumber - 1,\n endIndex: rowNumber,\n },\n },\n },\n ],\n }),\n });\n}\n\nasync function sheetsFetch(path: string, options: RequestInit = {}) {\n const token = await jwtClient.authorize();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${SPREADSHEET_ID}${path}`,\n {\n ...options,\n headers: {\n ...(options.headers || {}),\n Authorization: `Bearer ${token.access_token}`,\n \"Content-Type\": \"application/json\",\n },\n },\n );\n const data = await res.json();\n if (!res.ok) {\n console.error(\n \"Erro na API do Google Sheets:\",\n res.status,\n JSON.stringify(data),\n );\n }\n return data;\n}\n\nasync function getValues(range: string) {\n const data = await sheetsFetch(`/values/${encodeURIComponent(range)}`);\n return data.values || [];\n}\n\nasync function appendRow(sheetName: string, values: (string | number)[]) {\n await sheetsFetch(\n `/values/${\n encodeURIComponent(sheetName)\n }:append?valueInputOption=USER_ENTERED`,\n {\n method: \"POST\",\n body: JSON.stringify({ values: [values] }),\n },\n );\n}\n\nasync function updateCell(\n sheetName: string,\n row: number,\n col: string,\n value: string,\n) {\n const range = `${sheetName}!${col}${row}`;\n await sheetsFetch(\n `/values/${encodeURIComponent(range)}?valueInputOption=USER_ENTERED`,\n {\n method: \"PUT\",\n body: JSON.stringify({ values: [[value]] }),\n },\n );\n}\n\n// Colunas da aba Agendamentos: A Data/Hora, B Telefone, C Etapa, D Cliente,\n// E Fornecedor, F Data pretendida, G Data confirmada, H Status, I Tipo de Coleta, J Material\nasync function findLatestRowForPhone(phone: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n for (let i = rows.length - 1; i >= 1; i--) {\n if (String(rows[i][1] || \"\").replace(/^'/, \"\").trim() === phone) {\n return {\n rowNumber: i + 1,\n etapa: rows[i][2] || \"\",\n cliente: rows[i][3] || \"\",\n };\n }\n }\n return null;\n}\n\nasync function getFornecedorForCliente(clienteName: string) {\n const rows = await getValues(\"Clientes!A:B\");\n for (let i = 1; i < rows.length; i++) {\n if (rows[i][0] === clienteName) return rows[i][1] || \"\";\n }\n return \"\";\n}\n\nasync function getCronogramaForCliente(clienteName: string) {\n const rows = await getValues(\"Cronograma!A:E\");\n console.log(\"Cronograma - linhas lidas:\", JSON.stringify(rows));\n console.log(\"Procurando cliente:\", JSON.stringify(clienteName));\n const linhas: string[] = [];\n for (let i = 1; i < rows.length; i++) {\n console.log(`Linha ${i}: cliente=\"${rows[i][0]}\" ativo=\"${rows[i][3]}\"`);\n if (rows[i][0] === clienteName && rows[i][3] !== \"Não\") {\n const dataCancelada = rows[i][4];\n const aviso = dataCancelada ? ` (⚠️ dia ${dataCancelada} cancelado)` : \"\";\n linhas.push(`• ${rows[i][1]}: ${rows[i][2]}${aviso}`);\n }\n }\n return linhas;\n}\n\nasync function getExtrasForCliente(clienteName: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n const linhas: string[] = [];\n for (let i = 1; i < rows.length; i++) {\n const cliente = rows[i][3];\n const status = rows[i][7];\n if (cliente === clienteName && status && status !== \"Cancelado\") {\n const material = rows[i][9] || \"-\";\n const data = rows[i][6] || rows[i][5] || \"a definir\";\n linhas.push(`• ${material} — data: ${data} — status: ${status}`);\n }\n }\n return linhas;\n}\n\nasync function getActiveRequestsForCliente(clienteName: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n const resultado: {\n rowNumber: number;\n material: string;\n data: string;\n status: string;\n }[] = [];\n for (let i = 1; i < rows.length; i++) {\n const cliente = rows[i][3];\n const status = rows[i][7];\n if (cliente === clienteName && status && status !== \"Cancelado\") {\n resultado.push({\n rowNumber: i + 1,\n material: rows[i][9] || \"-\",\n data: rows[i][5] || \"a definir\",\n status,\n });\n }\n }\n return resultado;\n}\n\nasync function messageAlreadyProcessed(messageId: string) {\n const rows = await getValues(\"Log!A:A\");\n return rows.some((r: string[]) => r[0] === messageId);\n}\n\n// ---------- WhatsApp helpers ----------\n\nasync function sendWhatsApp(payload: Record) {\n await fetch(\n `https://graph.facebook.com/v21.0/${WHATSAPP_PHONE_NUMBER_ID}/messages`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${WHATSAPP_ACCESS_TOKEN}`,\n },\n body: JSON.stringify(payload),\n },\n );\n}\n\nfunction sendMainMenu(to: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n header: { type: \"text\", text: \"Central de Coletas\" },\n body: { text: \"Olá! Como posso te ajudar hoje?\" },\n footer: { text: \"Toque para ver as opções\" },\n action: {\n button: \"Ver opções\",\n sections: [\n {\n title: \"Menu principal\",\n rows: [\n { id: \"menu_extra\", title: \"🚚 Coleta Extra\" },\n { id: \"menu_ver_programadas\", title: \"📅 Ver Programadas\" },\n { id: \"menu_cancelar\", title: \"❌ Cancelar Coleta\" },\n ],\n },\n ],\n },\n },\n });\n}\n\nasync function sendClienteList(to: string) {\n const rows = await getValues(\"Clientes!A:A\");\n const nomes = rows.slice(1).map((r: string[]) => r[0]).filter(Boolean);\n const linhas = nomes.map((nome: string, i: number) => `${i + 1}. ${nome}`)\n .join(\"\\n\");\n await sendText(\n to,\n `Perfeito! Digite o número da sua unidade/cliente:\\n\\n${linhas}`,\n );\n}\n\nasync function getClienteByNumero(numeroTexto: string): Promise {\n const rows = await getValues(\"Clientes!A:A\");\n const nomes = rows.slice(1).map((r: string[]) => r[0]).filter(Boolean);\n const idx = parseInt((numeroTexto || \"\").trim(), 10) - 1;\n if (isNaN(idx) || idx < 0 || idx >= nomes.length) return null;\n return nomes[idx];\n}\n\nfunction sendMaterialList(to: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: {\n text:\n \"Entendido. Agora selecione o principal tipo de material a ser recolhido:\",\n },\n action: {\n button: \"Selecionar material\",\n sections: [\n {\n title: \"Materiais\",\n rows: [\n { id: \"papel\", title: \"📄 Papel/Papelão\" },\n { id: \"plastico\", title: \"🧴 Plástico\" },\n { id: \"metal\", title: \"⚙️ Sucata Metálica\" },\n { id: \"madeira\", title: \"🪵 Madeira/Pallets\" },\n { id: \"rejeito\", title: \"🧹 Resíduo Geral\" },\n ],\n },\n ],\n },\n },\n });\n}\n\nfunction sendText(to: string, body: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"text\",\n text: { body },\n });\n}\n\n// ---------- Webhook principal ----------\n\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === WHATSAPP_VERIFY_TOKEN) {\n return new Response(challenge ?? \"\", {\n status: 200,\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n return new Response(\"Forbidden\", { status: 403 });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method Not Allowed\", { status: 405 });\n }\n\n try {\n const body = await req.json();\n const message = body?.entry?.[0]?.changes?.[0]?.value?.messages?.[0];\n\n // Ignora notificações de status (entregue/lida) e qualquer coisa sem mensagem de verdade\n if (!message?.from) {\n return new Response(\"OK\", { status: 200 });\n }\n\n const from = message.from as string;\n const messageId = message.id as string;\n\n // Deduplicação\n if (await messageAlreadyProcessed(messageId)) {\n return new Response(\"OK\", { status: 200 });\n }\n await appendRow(\"Log\", [messageId]);\n\n // Extrai o conteúdo relevante, dependendo do tipo de resposta\n const listReplyId = message.interactive?.list_reply?.id as\n | string\n | undefined;\n const listReplyTitle = message.interactive?.list_reply?.title as\n | string\n | undefined;\n const buttonReplyTitle = message.interactive?.button_reply?.title as\n | string\n | undefined;\n const textBody = message.text?.body as string | undefined;\n\n const existing = await findLatestRowForPhone(from);\n const etapa = existing?.etapa || \"\";\n\n if (!existing || etapa === \"concluída\") {\n const now = new Date().toISOString();\n await appendRow(\"Agendamentos\", [now, \"'\" + from, \"aguardando_menu\"]);\n await sendMainMenu(from);\n } else if (etapa === \"aguardando_menu\") {\n const row = existing.rowNumber;\n if (listReplyId === \"menu_extra\") {\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_cliente\");\n await sendClienteList(from);\n } else if (listReplyId === \"menu_ver_programadas\") {\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_cliente_programadas\",\n );\n await sendClienteList(from);\n } else if (listReplyId === \"menu_cancelar\") {\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_cliente_cancelar\",\n );\n await sendClienteList(from);\n }\n } else if (etapa === \"aguardando_cliente\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n } else {\n const fornecedor = await getFornecedorForCliente(cliente);\n await updateCell(\"Agendamentos\", row, \"D\", cliente);\n await updateCell(\"Agendamentos\", row, \"E\", fornecedor);\n await updateCell(\"Agendamentos\", row, \"I\", \"Coleta Extra\");\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_material\");\n await sendMaterialList(from);\n }\n } else if (etapa === \"aguardando_cliente_programadas\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n const fixas = await getCronogramaForCliente(cliente);\n const extras = await getExtrasForCliente(cliente);\n\n let texto = `📋 Coletas de *${cliente}*:\\n\\n`;\n texto += \"📅 Fixas (semanais):\\n\";\n texto += fixas.length\n ? fixas.join(\"\\n\")\n : \"Nenhuma coleta fixa cadastrada.\";\n texto += \"\\n\\n🚚 Extras solicitadas:\\n\";\n texto += extras.length\n ? extras.join(\"\\n\")\n : \"Nenhuma coleta extra em aberto.\";\n\n await sendText(from, texto);\n await deleteRow(\"Agendamentos\", row);\n } else if (etapa === \"aguardando_cliente_cancelar\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n const ativos = await getActiveRequestsForCliente(cliente);\n if (ativos.length === 0) {\n await sendText(\n from,\n `Não encontrei nenhuma coleta ativa para *${cliente}* pra cancelar.`,\n );\n await deleteRow(\"Agendamentos\", row);\n } else {\n const linhas = ativos\n .map((a, i) =>\n `${i + 1}. ${a.material} — data: ${a.data} — status: ${a.status}`\n )\n .join(\"\\n\");\n await updateCell(\"Agendamentos\", row, \"D\", cliente);\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_escolha_cancelamento\",\n );\n await sendText(\n from,\n `Qual coleta você quer cancelar? Digite o número:\\n\\n${linhas}`,\n );\n }\n } else if (etapa === \"aguardando_escolha_cancelamento\") {\n const row = existing.rowNumber;\n const cliente = existing.cliente || \"\";\n const extras = await getActiveRequestsForCliente(cliente);\n const programadas = await getActiveCronogramaForCliente(cliente);\n const idx = parseInt((textBody || \"\").trim(), 10) - 1;\n\n if (isNaN(idx) || idx < 0 || idx >= extras.length + programadas.length) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da coleta que quer cancelar.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n\n if (idx < extras.length) {\n const alvo = extras[idx];\n await updateCell(\"Agendamentos\", alvo.rowNumber, \"H\", \"Cancelado\");\n await deleteRow(\"Agendamentos\", row);\n await sendText(\n from,\n `Prontinho! A coleta extra de *${alvo.material}* (${alvo.data}) foi cancelada.`,\n );\n } else {\n const alvo = programadas[idx - extras.length];\n const data = proximaData(alvo.dia);\n await updateCell(\"Cronograma\", alvo.rowNumber, \"E\", data);\n await deleteRow(\"Agendamentos\", row);\n await sendText(\n from,\n `Prontinho! A coleta programada de ${alvo.dia} (${alvo.material}) do dia ${data} foi cancelada. As próximas semanas continuam programadas normalmente.`,\n );\n }\n } else if (etapa === \"aguardando_material\") {\n const row = existing.rowNumber;\n await updateCell(\"Agendamentos\", row, \"J\", listReplyTitle || \"\");\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_data\");\n await sendText(\n from,\n \"Última etapa: me diga a data pretendida para a coleta (ex: 15/09).\",\n );\n } else if (etapa === \"aguardando_data\") {\n const row = existing.rowNumber;\n const texto = textBody || \"\";\n if (/^\\d{1,2}\\/\\d{1,2}(\\/\\d{2,4})?$/.test(texto.trim())) {\n await updateCell(\"Agendamentos\", row, \"F\", texto);\n await updateCell(\"Agendamentos\", row, \"H\", \"Solicitado\");\n await updateCell(\"Agendamentos\", row, \"C\", \"concluída\");\n await sendText(\n from,\n \"Prontinho! Recebemos sua solicitação de coleta e nossa equipe vai confirmar a data com o fornecedor. Assim que tivermos a confirmação, te avisamos por aqui!\",\n );\n } else {\n await sendText(\n from,\n \"Não entendi essa data 😕 Pode mandar de novo no formato dia/mês? Exemplo: 15/09\",\n );\n }\n }\n\n return new Response(\"OK\", { status: 200 });\n } catch (err) {\n console.error(\"Erro no webhook:\", err);\n return new Response(\"Erro interno, mas confirmando recebimento\", {\n status: 200,\n });\n }\n}","import { JWT } from \"npm:google-auth-library@9\";\n\nconst SPREADSHEET_ID = Deno.env.get(\"SPREADSHEET_ID\")!;\nconst WHATSAPP_ACCESS_TOKEN = Deno.env.get(\"WHATSAPP_ACCESS_TOKEN\")!;\nconst WHATSAPP_PHONE_NUMBER_ID = Deno.env.get(\"WHATSAPP_PHONE_NUMBER_ID\")!;\nconst WHATSAPP_VERIFY_TOKEN = Deno.env.get(\"WHATSAPP_VERIFY_TOKEN\")!;\n\nconst serviceAccount = JSON.parse(Deno.env.get(\"GOOGLE_SERVICE_ACCOUNT_KEY\")!);\nconst jwtClient = new JWT({\n email: serviceAccount.client_email,\n key: serviceAccount.private_key,\n scopes: [\"https://www.googleapis.com/auth/spreadsheets\"],\n});\n\n// ---------- Google Sheets helpers ----------\n\nasync function getSheetIdByName(sheetName: string): Promise {\n const data = await sheetsFetch(\"?fields=sheets.properties\");\n const sheet = data.sheets.find((s: { properties: { title: string } }) =>\n s.properties.title === sheetName\n );\n return sheet.properties.sheetId;\n}\n\nasync function getActiveCronogramaForCliente(clienteName: string) {\n const rows = await getValues(\"Cronograma!A:E\");\n console.log(\"getActiveCronograma - procurando:\", JSON.stringify(clienteName));\n console.log(\"getActiveCronograma - linhas:\", JSON.stringify(rows));\n const resultado: { rowNumber: number; dia: string; material: string }[] = [];\n for (let i = 1; i < rows.length; i++) {\n if (rows[i][0] === clienteName && rows[i][3] !== \"Não\") {\n resultado.push({\n rowNumber: i + 1,\n dia: rows[i][1],\n material: rows[i][2],\n });\n }\n }\n console.log(\"getActiveCronograma - resultado:\", JSON.stringify(resultado));\n return resultado;\n}\n\nasync function deleteRow(sheetName: string, rowNumber: number) {\n const sheetId = await getSheetIdByName(sheetName);\n await sheetsFetch(\":batchUpdate\", {\n method: \"POST\",\n body: JSON.stringify({\n requests: [\n {\n deleteDimension: {\n range: {\n sheetId,\n dimension: \"ROWS\",\n startIndex: rowNumber - 1,\n endIndex: rowNumber,\n },\n },\n },\n ],\n }),\n });\n}\n\nasync function sheetsFetch(path: string, options: RequestInit = {}) {\n const token = await jwtClient.authorize();\n const res = await fetch(\n `https://sheets.googleapis.com/v4/spreadsheets/${SPREADSHEET_ID}${path}`,\n {\n ...options,\n headers: {\n ...(options.headers || {}),\n Authorization: `Bearer ${token.access_token}`,\n \"Content-Type\": \"application/json\",\n },\n },\n );\n const data = await res.json();\n if (!res.ok) {\n console.error(\n \"Erro na API do Google Sheets:\",\n res.status,\n JSON.stringify(data),\n );\n }\n return data;\n}\n\nasync function getValues(range: string) {\n const data = await sheetsFetch(`/values/${encodeURIComponent(range)}`);\n return data.values || [];\n}\n\nasync function appendRow(sheetName: string, values: (string | number)[]) {\n await sheetsFetch(\n `/values/${\n encodeURIComponent(sheetName)\n }:append?valueInputOption=USER_ENTERED`,\n {\n method: \"POST\",\n body: JSON.stringify({ values: [values] }),\n },\n );\n}\n\nasync function updateCell(\n sheetName: string,\n row: number,\n col: string,\n value: string,\n) {\n const range = `${sheetName}!${col}${row}`;\n await sheetsFetch(\n `/values/${encodeURIComponent(range)}?valueInputOption=USER_ENTERED`,\n {\n method: \"PUT\",\n body: JSON.stringify({ values: [[value]] }),\n },\n );\n}\n\n// Colunas da aba Agendamentos: A Data/Hora, B Telefone, C Etapa, D Cliente,\n// E Fornecedor, F Data pretendida, G Data confirmada, H Status, I Tipo de Coleta, J Material\nasync function findLatestRowForPhone(phone: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n for (let i = rows.length - 1; i >= 1; i--) {\n if (String(rows[i][1] || \"\").replace(/^'/, \"\").trim() === phone) {\n return {\n rowNumber: i + 1,\n etapa: rows[i][2] || \"\",\n cliente: rows[i][3] || \"\",\n };\n }\n }\n return null;\n}\n\nasync function getFornecedorForCliente(clienteName: string) {\n const rows = await getValues(\"Clientes!A:B\");\n for (let i = 1; i < rows.length; i++) {\n if (rows[i][0] === clienteName) return rows[i][1] || \"\";\n }\n return \"\";\n}\n\nasync function getCronogramaForCliente(clienteName: string) {\n const rows = await getValues(\"Cronograma!A:E\");\n console.log(\"Cronograma - linhas lidas:\", JSON.stringify(rows));\n console.log(\"Procurando cliente:\", JSON.stringify(clienteName));\n const linhas: string[] = [];\n for (let i = 1; i < rows.length; i++) {\n console.log(`Linha ${i}: cliente=\"${rows[i][0]}\" ativo=\"${rows[i][3]}\"`);\n if (rows[i][0] === clienteName && rows[i][3] !== \"Não\") {\n const dataCancelada = rows[i][4];\n const aviso = dataCancelada ? ` (⚠️ dia ${dataCancelada} cancelado)` : \"\";\n linhas.push(`• ${rows[i][1]}: ${rows[i][2]}${aviso}`);\n }\n }\n return linhas;\n}\n\nasync function getExtrasForCliente(clienteName: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n const linhas: string[] = [];\n for (let i = 1; i < rows.length; i++) {\n const cliente = rows[i][3];\n const status = rows[i][7];\n if (cliente === clienteName && status && status !== \"Cancelado\") {\n const material = rows[i][9] || \"-\";\n const data = rows[i][6] || rows[i][5] || \"a definir\";\n linhas.push(`• ${material} — data: ${data} — status: ${status}`);\n }\n }\n return linhas;\n}\n\nasync function getActiveRequestsForCliente(clienteName: string) {\n const rows = await getValues(\"Agendamentos!A:J\");\n const resultado: {\n rowNumber: number;\n material: string;\n data: string;\n status: string;\n }[] = [];\n for (let i = 1; i < rows.length; i++) {\n const cliente = rows[i][3];\n const status = rows[i][7];\n if (cliente === clienteName && status && status !== \"Cancelado\") {\n resultado.push({\n rowNumber: i + 1,\n material: rows[i][9] || \"-\",\n data: rows[i][5] || \"a definir\",\n status,\n });\n }\n }\n return resultado;\n}\n\nasync function messageAlreadyProcessed(messageId: string) {\n const rows = await getValues(\"Log!A:A\");\n return rows.some((r: string[]) => r[0] === messageId);\n}\n\n// ---------- WhatsApp helpers ----------\n\nasync function sendWhatsApp(payload: Record) {\n await fetch(\n `https://graph.facebook.com/v21.0/${WHATSAPP_PHONE_NUMBER_ID}/messages`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${WHATSAPP_ACCESS_TOKEN}`,\n },\n body: JSON.stringify(payload),\n },\n );\n}\n\nfunction sendMainMenu(to: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n header: { type: \"text\", text: \"Central de Coletas\" },\n body: { text: \"Olá! Como posso te ajudar hoje?\" },\n footer: { text: \"Toque para ver as opções\" },\n action: {\n button: \"Ver opções\",\n sections: [\n {\n title: \"Menu principal\",\n rows: [\n { id: \"menu_extra\", title: \"🚚 Coleta Extra\" },\n { id: \"menu_ver_programadas\", title: \"📅 Ver Programadas\" },\n { id: \"menu_cancelar\", title: \"❌ Cancelar Coleta\" },\n ],\n },\n ],\n },\n },\n });\n}\n\nasync function sendClienteList(to: string) {\n const rows = await getValues(\"Clientes!A:A\");\n const nomes = rows.slice(1).map((r: string[]) => r[0]).filter(Boolean);\n const linhas = nomes.map((nome: string, i: number) => `${i + 1}. ${nome}`)\n .join(\"\\n\");\n await sendText(\n to,\n `Perfeito! Digite o número da sua unidade/cliente:\\n\\n${linhas}`,\n );\n}\n\nasync function getClienteByNumero(numeroTexto: string): Promise {\n const rows = await getValues(\"Clientes!A:A\");\n const nomes = rows.slice(1).map((r: string[]) => r[0]).filter(Boolean);\n const idx = parseInt((numeroTexto || \"\").trim(), 10) - 1;\n if (isNaN(idx) || idx < 0 || idx >= nomes.length) return null;\n return nomes[idx];\n}\n\nfunction sendMaterialList(to: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: {\n text:\n \"Entendido. Agora selecione o principal tipo de material a ser recolhido:\",\n },\n action: {\n button: \"Selecionar material\",\n sections: [\n {\n title: \"Materiais\",\n rows: [\n { id: \"papel\", title: \"📄 Papel/Papelão\" },\n { id: \"plastico\", title: \"🧴 Plástico\" },\n { id: \"metal\", title: \"⚙️ Sucata Metálica\" },\n { id: \"madeira\", title: \"🪵 Madeira/Pallets\" },\n { id: \"rejeito\", title: \"🧹 Resíduo Geral\" },\n ],\n },\n ],\n },\n },\n });\n}\n\nfunction sendText(to: string, body: string) {\n return sendWhatsApp({\n messaging_product: \"whatsapp\",\n to,\n type: \"text\",\n text: { body },\n });\n}\n\n// ---------- Webhook principal ----------\n\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === WHATSAPP_VERIFY_TOKEN) {\n return new Response(challenge ?? \"\", {\n status: 200,\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n return new Response(\"Forbidden\", { status: 403 });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method Not Allowed\", { status: 405 });\n }\n\n try {\n const body = await req.json();\n const message = body?.entry?.[0]?.changes?.[0]?.value?.messages?.[0];\n\n // Ignora notificações de status (entregue/lida) e qualquer coisa sem mensagem de verdade\n if (!message?.from) {\n return new Response(\"OK\", { status: 200 });\n }\n\n const from = message.from as string;\n const messageId = message.id as string;\n\n // Deduplicação\n if (await messageAlreadyProcessed(messageId)) {\n return new Response(\"OK\", { status: 200 });\n }\n await appendRow(\"Log\", [messageId]);\n\n // Extrai o conteúdo relevante, dependendo do tipo de resposta\n const listReplyId = message.interactive?.list_reply?.id as\n | string\n | undefined;\n const listReplyTitle = message.interactive?.list_reply?.title as\n | string\n | undefined;\n const buttonReplyTitle = message.interactive?.button_reply?.title as\n | string\n | undefined;\n const textBody = message.text?.body as string | undefined;\n\n const existing = await findLatestRowForPhone(from);\n const etapa = existing?.etapa || \"\";\n\n if (!existing || etapa === \"concluída\") {\n const now = new Date().toISOString();\n await appendRow(\"Agendamentos\", [now, \"'\" + from, \"aguardando_menu\"]);\n await sendMainMenu(from);\n } else if (etapa === \"aguardando_menu\") {\n const row = existing.rowNumber;\n if (listReplyId === \"menu_extra\") {\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_cliente\");\n await sendClienteList(from);\n } else if (listReplyId === \"menu_ver_programadas\") {\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_cliente_programadas\",\n );\n await sendClienteList(from);\n } else if (listReplyId === \"menu_cancelar\") {\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_cliente_cancelar\",\n );\n await sendClienteList(from);\n }\n } else if (etapa === \"aguardando_cliente\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n } else {\n const fornecedor = await getFornecedorForCliente(cliente);\n await updateCell(\"Agendamentos\", row, \"D\", cliente);\n await updateCell(\"Agendamentos\", row, \"E\", fornecedor);\n await updateCell(\"Agendamentos\", row, \"I\", \"Coleta Extra\");\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_material\");\n await sendMaterialList(from);\n }\n } else if (etapa === \"aguardando_cliente_programadas\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n const fixas = await getCronogramaForCliente(cliente);\n const extras = await getExtrasForCliente(cliente);\n\n let texto = `📋 Coletas de *${cliente}*:\\n\\n`;\n texto += \"📅 Fixas (semanais):\\n\";\n texto += fixas.length\n ? fixas.join(\"\\n\")\n : \"Nenhuma coleta fixa cadastrada.\";\n texto += \"\\n\\n🚚 Extras solicitadas:\\n\";\n texto += extras.length\n ? extras.join(\"\\n\")\n : \"Nenhuma coleta extra em aberto.\";\n\n await sendText(from, texto);\n await deleteRow(\"Agendamentos\", row);\n } else if (etapa === \"aguardando_cliente_cancelar\") {\n const row = existing.rowNumber;\n const cliente = await getClienteByNumero(textBody || \"\");\n if (!cliente) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da unidade, como mostrado na lista.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n const extras = await getActiveRequestsForCliente(cliente);\n const programadas = await getActiveCronogramaForCliente(cliente);\n if (extras.length === 0 && programadas.length === 0) {\n await sendText(\n from,\n `Não encontrei nenhuma coleta ativa para *${cliente}* pra cancelar.`,\n );\n await deleteRow(\"Agendamentos\", row);\n } else {\n const linhasExtras = extras.map((a, i) =>\n `${i + 1}. ${a.material} — data: ${a.data} — status: ${a.status}`\n );\n const linhasProgramadas = programadas.map((p, i) =>\n `${extras.length + i + 1}. ${p.material} — ${p.dia} (fixa)`\n );\n const linhas = [...linhasExtras, ...linhasProgramadas].join(\"\\n\");\n await updateCell(\"Agendamentos\", row, \"D\", cliente);\n await updateCell(\n \"Agendamentos\",\n row,\n \"C\",\n \"aguardando_escolha_cancelamento\",\n );\n await sendText(\n from,\n `Qual coleta você quer cancelar? Digite o número:\\n\\n${linhas}`,\n );\n }\n } else if (etapa === \"aguardando_escolha_cancelamento\") {\n const row = existing.rowNumber;\n const cliente = existing.cliente || \"\";\n const extras = await getActiveRequestsForCliente(cliente);\n const programadas = await getActiveCronogramaForCliente(cliente);\n const idx = parseInt((textBody || \"\").trim(), 10) - 1;\n\n if (isNaN(idx) || idx < 0 || idx >= extras.length + programadas.length) {\n await sendText(\n from,\n \"Não entendi. Digite só o número da coleta que quer cancelar.\",\n );\n return new Response(\"OK\", { status: 200 });\n }\n\n if (idx < extras.length) {\n const alvo = extras[idx];\n await updateCell(\"Agendamentos\", alvo.rowNumber, \"H\", \"Cancelado\");\n await deleteRow(\"Agendamentos\", row);\n await sendText(\n from,\n `Prontinho! A coleta extra de *${alvo.material}* (${alvo.data}) foi cancelada.`,\n );\n } else {\n const alvo = programadas[idx - extras.length];\n const data = proximaData(alvo.dia);\n await updateCell(\"Cronograma\", alvo.rowNumber, \"E\", data);\n await deleteRow(\"Agendamentos\", row);\n await sendText(\n from,\n `Prontinho! A coleta programada de ${alvo.dia} (${alvo.material}) do dia ${data} foi cancelada. As próximas semanas continuam programadas normalmente.`,\n );\n }\n } else if (etapa === \"aguardando_material\") {\n const row = existing.rowNumber;\n await updateCell(\"Agendamentos\", row, \"J\", listReplyTitle || \"\");\n await updateCell(\"Agendamentos\", row, \"C\", \"aguardando_data\");\n await sendText(\n from,\n \"Última etapa: me diga a data pretendida para a coleta (ex: 15/09).\",\n );\n } else if (etapa === \"aguardando_data\") {\n const row = existing.rowNumber;\n const texto = textBody || \"\";\n if (/^\\d{1,2}\\/\\d{1,2}(\\/\\d{2,4})?$/.test(texto.trim())) {\n await updateCell(\"Agendamentos\", row, \"F\", texto);\n await updateCell(\"Agendamentos\", row, \"H\", \"Solicitado\");\n await updateCell(\"Agendamentos\", row, \"C\", \"concluída\");\n await sendText(\n from,\n \"Prontinho! Recebemos sua solicitação de coleta e nossa equipe vai confirmar a data com o fornecedor. Assim que tivermos a confirmação, te avisamos por aqui!\",\n );\n } else {\n await sendText(\n from,\n \"Não entendi essa data 😕 Pode mandar de novo no formato dia/mês? Exemplo: 15/09\",\n );\n }\n }\n\n return new Response(\"OK\", { status: 200 });\n } catch (err) {\n console.error(\"Erro no webhook:\", err);\n return new Response(\"Erro interno, mas confirmando recebimento\", {\n status: 200,\n });\n }\n}","createdAt",["D",1789477248287],"branchVersion","branchId","64baa4d8-4625-4d57-9b35-5d2a2b4f3eb8","id","cc432ec9-8b28-4901-bcb8-0c309a877cb8","teste",["D",1788459087365],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","7a9b14fb-5434-4708-95bc-70d1677dec71","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a06876-6500-703a-8dd7-d8fb51364f39","tursoName","cc432ec98b284901bcb80c309a877cb8","tursoHostname","cc432ec98b284901bcb80c309a877cb8-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501878689],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_113":109},"org",{"_105":104,"_106":107,"_108":109,"_19":61,"_110":111,"_112":31},"branch",{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"isOwned",29,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","gustavoteixeira","handle","displayName","GUSTAVO TEIXEIRA","avatar","https://lh3.googleusercontent.com/a/ACg8ocLRyaRj-8_CCO-4h557BVGQygbhfqFC_gqdtyUrP5mzGzxRWQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":160,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":37,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":161,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":162,"_89":163,"_91":164,"_93":31},"tree",[155],"files",[155],"counts",{"_143":68,"_144":145,"_146":68,"_147":148,"_149":150},"contents",[135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":136,"_38":34,"_36":37,"_137":-5,"_47":48,"_46":14,"_138":31,"_44":139,"_13":140,"_39":40,"_41":43,"_30":31,"_141":-5,"_33":142},"c014d9fa-5e2d-4af6-aab2-1d47795c544b","parentId","latest",["D",1789477248287],25,"label",[34],"pulls","branches",1,"forks","envVars",{"_151":153,"_154":68},"connections",{"_151":68,"_152":68},"count","unfilledCount",6,"emptyCount",{"_49":136,"_38":34,"_36":37,"_137":-5,"_47":48,"_46":14,"_138":31,"_44":156,"_13":140,"_39":40,"_41":43,"_30":31,"_141":-5,"_157":158,"_33":159},["D",1789477248287],"children",[],[34],["D",1788459087365],["D",1789501878689],{"_105":104,"_113":109},{"_105":104,"_106":107,"_108":109,"_19":61,"_110":111,"_112":31},{"_13":94,"_38":95,"_49":48,"_96":50,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":51,"_103":104},"ctx",{"_87":-5,"_132":198,"_199":200,"_201":202,"_203":31,"_204":31,"_205":31,"_206":64,"_207":-5,"_208":-7,"_209":-7,"_210":68,"_211":31,"_212":31,"_213":-5,"_214":31,"_215":31,"_216":31,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":95,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"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 · v26