[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_159":160,"_161":162},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"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":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",24,"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","new-file-6242.ts","latestPath","fileId","7185fec4-a20f-11f1-9638-1607ee4eb77e","name","fileType","http","content","// ================================================================\n// NPS Talent Acquisition — SeaTalk Bot (Val.town) v8\n// ================================================================\n//\n// CHANGELOG v5:\n// - FIX: endpoint correto /contacts/v2/get_employee_code_with_email\n// (confirmado pelo script Python que funciona)\n// - FIX: body do lookup usa \"emails\" (array)\n// - FIX: parse da resposta lê results[0].employee_code ou employees[0].employee_code\n// - KEEP: wrapper \"message\" nas chamadas de envio (fix do v3)\n//\n// ================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ============ CONFIGURAÇÕES ============\nconst APP_ID = \"NDEyNTQ1NzIzMjM3\";\nconst APP_SECRET = \"CgpIsQoDs7T68cw8pX_MbnAl4kLlvIZN\";\nconst SEATALK_API = \"https://openapi.seatalk.io\";\n\n// (Opcional) URL do Apps Script pra gravar no Google Sheets\nconst APPS_SCRIPT_URL = \"\";\n\n// ============ PERGUNTAS ============\nconst PERGUNTAS = [\n {\n titulo: \"📊 Avaliação TA — Pergunta 1/3\",\n texto:\n \"Qualidade e Aderência\\nComo você avalia a qualidade e a aderência dos candidatos apresentados às necessidades da sua área?\",\n prefixo: \"q1\",\n nome: \"Qualidade e Aderência\",\n },\n {\n titulo: \"📊 Avaliação TA — Pergunta 2/3\",\n texto:\n \"Parceria e Efetividade\\nComo você avalia a efetividade de Talent Acquisition em compreender as prioridades, orientar e apoiar você e seus líderes ao longo dos processos seletivos?\",\n prefixo: \"q2\",\n nome: \"Parceria e Efetividade\",\n },\n {\n titulo: \"📊 Avaliação TA — Pergunta 3/3\",\n texto:\n \"Experiência Geral com TA\\nDe forma geral, como você avalia o suporte de Talent Acquisition à sua área neste mês?\",\n prefixo: \"q3\",\n nome: \"Experiência Geral com TA\",\n },\n];\n\nconst ESCALA =\n \"1 — Muito abaixo · 2 — Abaixo · 3 — Atende · 4 — Acima · 5 — Supera\";\n\n// ================================================================\n// ACCESS TOKEN\n// ================================================================\n\nlet tokenCache = { token: \"\", expiresAt: 0 };\n\nasync function getAccessToken(): Promise {\n if (tokenCache.token && Date.now() < tokenCache.expiresAt) {\n return tokenCache.token;\n }\n\n const res = await fetch(`${SEATALK_API}/auth/app_access_token`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ app_id: APP_ID, app_secret: APP_SECRET }),\n });\n\n const data = await res.json();\n if (data.code !== 0) {\n throw new Error(`Erro ao obter token SeaTalk: ${JSON.stringify(data)}`);\n }\n\n tokenCache = {\n token: data.app_access_token,\n expiresAt: Date.now() + ((data.expire || 7200) - 120) * 1000,\n };\n\n return tokenCache.token;\n}\n\nasync function seatalkPost(endpoint: string, body: any): Promise {\n const token = await getAccessToken();\n const res = await fetch(`${SEATALK_API}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${token}`,\n },\n body: JSON.stringify(body),\n });\n return res.json();\n}\n\n// ================================================================\n// BUSCAR EMPLOYEE CODE POR EMAIL — v5: endpoint confirmado\n// ================================================================\n//\n// Endpoint: POST /contacts/v2/get_employee_code_with_email\n// Body: { \"emails\": [\"email@shopee.com\"] }\n// Response: { \"code\": 0, \"results\": [{ \"email\": \"...\", \"employee_code\": \"...\" }] }\n// ou: { \"code\": 0, \"employees\": [{ \"employee_code\": \"...\" }] }\n//\n\nconst emailCache: Record = {};\n\nasync function getEmployeeCodeByEmail(email: string): Promise {\n // Cache em memória\n if (emailCache[email]) return emailCache[email];\n\n // Cache persistente\n try {\n const cached = await blob.getJSON(\n `email_cache_${email.replace(/[@.]/g, \"_\")}`,\n );\n if (cached?.employee_code) {\n emailCache[email] = cached.employee_code;\n return cached.employee_code;\n }\n } catch { /* sem cache */ }\n\n // Tenta o endpoint correto primeiro, depois fallbacks\n const attempts = [\n {\n endpoint: \"/contacts/v2/get_employee_code_with_email\",\n body: { emails: [email] },\n },\n { endpoint: \"/contacts/v2/get_employee_code\", body: { emails: [email] } },\n { endpoint: \"/contacts/v2/employees/get_by_email\", body: { email } },\n ];\n\n const errors: string[] = [];\n\n for (const attempt of attempts) {\n try {\n const res = await seatalkPost(attempt.endpoint, attempt.body);\n console.log(`Lookup ${attempt.endpoint}:`, JSON.stringify(res));\n\n // Parse flexível: cobre múltiplos formatos de resposta\n let code: string | undefined;\n\n // Formato 1: { results: [{ employee_code: \"...\" }] }\n if (res.results && Array.isArray(res.results) && res.results.length > 0) {\n const result = res.results[0];\n if (result.employee_code) {\n code = result.employee_code;\n }\n }\n\n // Formato 2: { employees: [{ employee_code: \"...\" }] }\n if (\n !code && res.employees && Array.isArray(res.employees) &&\n res.employees.length > 0\n ) {\n const emp = res.employees[0];\n if (emp.employee_code) {\n code = emp.employee_code;\n }\n }\n\n // Formato 3: { employee_code: \"...\" }\n if (!code && res.employee_code) {\n code = res.employee_code;\n }\n\n // Formato 4: { employee: { employee_code: \"...\" } }\n if (!code && res.employee?.employee_code) {\n code = res.employee.employee_code;\n }\n\n if (res.code === 0 && code) {\n // Salva no cache\n emailCache[email] = code;\n await blob.setJSON(`email_cache_${email.replace(/[@.]/g, \"_\")}`, {\n employee_code: code,\n email,\n cached_at: new Date().toISOString(),\n });\n console.log(\n `✅ Employee code encontrado: ${code} (via ${attempt.endpoint})`,\n );\n return code;\n }\n\n errors.push(\n `${attempt.endpoint}: code=${res.code}, msg=${\n res.msg || \"sem mensagem\"\n }`,\n );\n } catch (e: any) {\n errors.push(`${attempt.endpoint}: ${e.message}`);\n }\n }\n\n throw new Error(\n `Não foi possível encontrar o employee_code para ${email}. ` +\n `Tentativas: ${errors.join(\" | \")}. ` +\n `Verifique se: (1) o email está correto, (2) o bot tem permissão de \"Get Employee Code with Email\" no SeaTalk Open Platform.`,\n );\n}\n\n// ================================================================\n// STATE MANAGEMENT (Val.town Blob)\n// ================================================================\n\nasync function getState(employeeCode: string): Promise {\n try {\n return await blob.getJSON(`nps_state_${employeeCode}`);\n } catch {\n return null;\n }\n}\n\nasync function setState(employeeCode: string, state: any): Promise {\n await blob.setJSON(`nps_state_${employeeCode}`, state);\n}\n\nasync function clearState(employeeCode: string): Promise {\n try {\n await blob.delete(`nps_state_${employeeCode}`);\n } catch { /* ignore */ }\n}\n\n// ================================================================\n// RESPONSES STORAGE (Val.town Blob)\n// ================================================================\n\nasync function getResponses(): Promise {\n try {\n const data = await blob.getJSON(\"nps_responses\");\n return Array.isArray(data) ? data : [];\n } catch {\n return [];\n }\n}\n\nasync function addResponse(record: any): Promise {\n const responses = await getResponses();\n responses.push(record);\n await blob.setJSON(\"nps_responses\", responses);\n}\n\nasync function updateLastComment(\n email: string,\n comment: string,\n): Promise {\n const responses = await getResponses();\n for (let i = responses.length - 1; i >= 0; i--) {\n if (responses[i].email === email && !responses[i].comment) {\n responses[i].comment = comment;\n break;\n }\n }\n await blob.setJSON(\"nps_responses\", responses);\n}\n\n// ================================================================\n// SEATALK MESSAGING — com wrapper \"message\" (fix do v3)\n// ================================================================\n\nasync function enviarPergunta(employeeCode: string, questionIndex: number) {\n const p = PERGUNTAS[questionIndex];\n\n const buttons = Array.from({ length: 5 }, (_, idx) => {\n const nota = idx + 1;\n return {\n button_type: \"callback\",\n text: String(nota),\n value: `${p.prefixo}_${nota}`,\n };\n });\n\n // SeaTalk aceita no máximo 3 botões por button_group.\n // Além disso, button_group deve receber o ARRAY diretamente,\n // e não { buttons: [...] }.\n const grupo1 = buttons.slice(0, 3);\n const grupo2 = buttons.slice(3, 5);\n\n return seatalkPost(\"/messaging/v2/single_chat\", {\n employee_code: employeeCode,\n message: {\n tag: \"interactive_message\",\n interactive_message: {\n elements: [\n {\n element_type: \"title\",\n title: { text: p.titulo },\n },\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: p.texto,\n },\n },\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: ESCALA,\n },\n },\n {\n element_type: \"button_group\",\n button_group: grupo1,\n },\n {\n element_type: \"button_group\",\n button_group: grupo2,\n },\n ],\n },\n },\n usable_platform: \"all\",\n });\n}\n\nasync function atualizarCard(messageId: string, texto: string) {\n return seatalkPost(\"/messaging/v2/update_message\", {\n message_id: messageId,\n message: {\n tag: \"interactive_message\",\n interactive_message: {\n elements: [\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: texto,\n },\n },\n ],\n },\n },\n });\n}\n\nasync function enviarTexto(employeeCode: string, texto: string) {\n return seatalkPost(\"/messaging/v2/single_chat\", {\n employee_code: employeeCode,\n message: {\n tag: \"text\",\n text: { content: texto },\n },\n });\n}\n\n// ================================================================\n// GRAVAR RESPOSTA\n// ================================================================\n\nasync function gravarResposta(state: any): Promise {\n const now = new Date();\n const brDate = new Date(now.getTime() - 3 * 60 * 60 * 1000);\n const date = brDate.toISOString().split(\"T\")[0];\n\n const record = {\n date,\n email: state.email || state.employee_code,\n q1: state.q1,\n q2: state.q2,\n q3: state.q3,\n comment: state.comment || \"\",\n timestamp: now.toISOString(),\n };\n\n await addResponse(record);\n\n if (APPS_SCRIPT_URL) {\n try {\n await fetch(APPS_SCRIPT_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ action: \"write_nps\", ...record }),\n redirect: \"follow\",\n });\n } catch (e: any) {\n console.log(\"Sheets write failed:\", e.message);\n }\n }\n}\n\n// ================================================================\n// HANDLER: CLIQUE NO BOTÃO\n// ================================================================\n\nasync function handleButtonClick(event: any): Promise {\n // Payload atual do SeaTalk:\n // event.clicker.employee_code + event.button_value.\n // Mantemos fallbacks para compatibilidade com payloads antigos/testes locais.\n const employeeCode = event.clicker?.employee_code ||\n event.employee_code;\n\n const value = event.button_value ||\n event.value;\n\n const messageId = event.message_id;\n\n if (!employeeCode || !value || !messageId) {\n console.log(\n \"Clique interativo com payload incompleto:\",\n JSON.stringify(event),\n );\n return;\n }\n\n const state = await getState(employeeCode);\n if (!state) return;\n\n const parts = value.split(\"_\");\n const prefixo = parts[0];\n const nota = parseInt(parts[1], 10);\n\n if (state[prefixo] !== null && state[prefixo] !== undefined) return;\n\n state[prefixo] = nota;\n\n const idx = parseInt(prefixo.replace(\"q\", \"\"), 10) - 1;\n await atualizarCard(\n messageId,\n `✅ ${PERGUNTAS[idx].nome}: ${nota}/5 — Registrado!`,\n );\n\n if (prefixo === \"q1\") {\n state.current_question = 1;\n const res = await enviarPergunta(employeeCode, 1);\n if (res.code === 0 && res.message_id) state.q2_msg_id = res.message_id;\n await setState(employeeCode, state);\n } else if (prefixo === \"q2\") {\n state.current_question = 2;\n const res = await enviarPergunta(employeeCode, 2);\n if (res.code === 0 && res.message_id) state.q3_msg_id = res.message_id;\n await setState(employeeCode, state);\n } else if (prefixo === \"q3\") {\n state.current_question = \"comment\";\n state.awaiting_comment = true;\n await setState(employeeCode, state);\n\n await gravarResposta(state);\n\n await enviarTexto(\n employeeCode,\n \"🎉 Obrigado pelas respostas!\\n\\n\" +\n \"💬 Comentário opcional: Qual é a principal coisa que Talent Acquisition poderia \" +\n \"melhorar para apoiar ainda melhor você e seus líderes?\\n\\n\" +\n \"Basta digitar aqui. Se preferir não comentar, pode ignorar — suas notas já foram registradas! ✅\",\n );\n }\n}\n\n// ================================================================\n// HANDLER: MENSAGEM DE TEXTO (COMENTÁRIO)\n// ================================================================\n\nasync function handleTextMessage(event: any): Promise {\n const employeeCode = event.employee_code;\n const msg = event.message || {};\n const texto = msg?.text?.content || msg?.content || \"\";\n\n if (!texto) return;\n\n const state = await getState(employeeCode);\n if (!state || !state.awaiting_comment) return;\n\n state.comment = texto;\n state.awaiting_comment = false;\n state.current_question = \"done\";\n\n const email = state.email || state.employee_code;\n await updateLastComment(email, texto);\n\n if (APPS_SCRIPT_URL) {\n try {\n await fetch(APPS_SCRIPT_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n action: \"update_comment\",\n email,\n comment: texto,\n }),\n redirect: \"follow\",\n });\n } catch (e: any) {\n console.log(\"Comment update failed:\", e.message);\n }\n }\n\n await clearState(employeeCode);\n\n await enviarTexto(\n employeeCode,\n \"✅ Comentário registrado! Muito obrigado pelo seu feedback.\\n\\n\" +\n \"Ele é essencial para continuarmos evoluindo a parceria de TA com o negócio. 🚀\",\n );\n}\n\n// ================================================================\n// TRIGGER NPS\n// ================================================================\n\nasync function triggerNPSByEmail(email: string): Promise {\n let employeeCode: string;\n try {\n employeeCode = await getEmployeeCodeByEmail(email);\n } catch (e: any) {\n return { success: false, error: e.message };\n }\n\n return await doTriggerNPS(employeeCode, email);\n}\n\nasync function triggerNPSBulk(emails: string[]): Promise {\n const uniqueEmails = [\n ...new Set(\n emails\n .map((e) => String(e || \"\").trim().toLowerCase())\n .filter(Boolean),\n ),\n ];\n\n const results: any[] = [];\n\n for (let i = 0; i < uniqueEmails.length; i++) {\n const email = uniqueEmails[i];\n\n try {\n const result = await triggerNPSByEmail(email);\n results.push({\n email,\n success: !!result.success,\n employee_code: result.employee_code || \"\",\n error: result.error || \"\",\n });\n } catch (e: any) {\n results.push({\n email,\n success: false,\n employee_code: \"\",\n error: e?.message || String(e),\n });\n }\n\n // Pequeno intervalo entre envios para evitar rajadas na API.\n if (i < uniqueEmails.length - 1) {\n await new Promise((r) => setTimeout(r, 700));\n }\n }\n\n const sent = results.filter((r) => r.success).length;\n const failed = results.length - sent;\n\n return {\n success: failed === 0,\n total: results.length,\n sent,\n failed,\n results,\n };\n}\n\nasync function triggerNPSByCode(\n employeeCode: string,\n email: string,\n): Promise {\n return await doTriggerNPS(employeeCode, email);\n}\n\nasync function doTriggerNPS(employeeCode: string, email: string): Promise {\n await clearState(employeeCode);\n\n const introResult = await enviarTexto(\n employeeCode,\n \"Olá! 👋\\n\\n\" +\n \"Como parte da nossa evolução contínua em Talent Acquisition, gostaria de contar com a sua percepção \" +\n \"sobre como estamos apoiando você e os líderes da sua estrutura.\\n\\n\" +\n \"Será rápido — apenas 3 perguntas (escala de 1 a 5) e um comentário opcional.\\n\\n\" +\n \"Vou enviar as perguntas agora! 👇\",\n );\n\n if (introResult.code !== 0) {\n return {\n success: false,\n error: `Erro ao enviar mensagem: ${JSON.stringify(introResult)}`,\n employee_code: employeeCode,\n };\n }\n\n await new Promise((r) => setTimeout(r, 1500));\n\n const state: any = {\n employee_code: employeeCode,\n email: email || employeeCode,\n current_question: 0,\n q1: null,\n q2: null,\n q3: null,\n comment: null,\n started_at: new Date().toISOString(),\n awaiting_comment: false,\n };\n\n const res = await enviarPergunta(employeeCode, 0);\n if (res.code === 0 && res.message_id) {\n state.q1_msg_id = res.message_id;\n } else {\n return {\n success: false,\n error: `Erro ao enviar Q1: ${JSON.stringify(res)}`,\n employee_code: employeeCode,\n };\n }\n\n await setState(employeeCode, state);\n\n return { success: true, email, employee_code: employeeCode };\n}\n\n// ================================================================\n// PÁGINA DE ADMIN (HTML)\n// ================================================================\n\nfunction adminPage(): string {\n return `\n\n\n \n \n NPS TA - Admin\n \n\n\n

📊 NPS Talent Acquisition v8

Envie pesquisas de satisfação via SeaTalk e acompanhe os resultados.

\n\n

🚀 Enviar NPS

\n\n

\n \n \n \n

\n\n \n\n \n

\n\n

📋 Respostas

\n 📄 JSON\n ⬇️ CSV\n

Carregando...

\n\n \n\n`;\n}\n\n// ================================================================\n// MAIN HANDLER\n// ================================================================\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // ======== GET ========\n if (req.method === \"GET\") {\n const action = url.searchParams.get(\"action\");\n\n if (action === \"responses\") {\n const responses = await getResponses();\n return Response.json(responses, {\n headers: { \"Access-Control-Allow-Origin\": \"*\" },\n });\n }\n\n if (action === \"csv\") {\n const responses = await getResponses();\n let csv =\n \"Data,Email,Qualidade e Aderência,Parceria e Efetividade,Experiência Geral com TA,Comentário\\n\";\n for (const r of responses) {\n const comment = (r.comment || \"\").replace(/\"/g, '\"\"');\n csv += `${r.date},\"${r.email}\",${r.q1 ?? \"\"},${r.q2 ?? \"\"},${\n r.q3 ?? \"\"\n },\"${comment}\"\\n`;\n }\n return new Response(csv, {\n headers: {\n \"Content-Type\": \"text/csv; charset=utf-8\",\n \"Content-Disposition\": 'attachment; filename=\"nps_ta_respostas.csv\"',\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n // Lookup de email (retorna employee_code)\n if (action === \"lookup\") {\n const email = url.searchParams.get(\"email\") || \"\";\n if (!email) {\n return Response.json({ error: \"Falta o parâmetro email\" }, {\n status: 400,\n });\n }\n try {\n const code = await getEmployeeCodeByEmail(email);\n return Response.json({ success: true, email, employee_code: code });\n } catch (e: any) {\n return Response.json({ success: false, error: e.message });\n }\n }\n\n // Teste de token (debug)\n if (action === \"test_token\") {\n try {\n const token = await getAccessToken();\n return Response.json({\n success: true,\n token_prefix: token.substring(0, 20) + \"...\",\n });\n } catch (e: any) {\n return Response.json({ success: false, error: e.message });\n }\n }\n\n // Limpar cache de email (debug)\n if (action === \"clear_cache\") {\n const email = url.searchParams.get(\"email\") || \"\";\n if (email) {\n delete emailCache[email];\n try {\n await blob.delete(`email_cache_${email.replace(/[@.]/g, \"_\")}`);\n } catch {}\n return Response.json({\n success: true,\n message: `Cache limpo para ${email}`,\n });\n }\n return Response.json({ error: \"Falta o parâmetro email\" }, {\n status: 400,\n });\n }\n\n return new Response(adminPage(), {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n }\n\n // ======== OPTIONS (CORS) ========\n if (req.method === \"OPTIONS\") {\n return new Response(null, {\n headers: {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n },\n });\n }\n\n // ======== POST ========\n if (req.method === \"POST\") {\n try {\n const data = await req.json();\n\n // --- Verificação do webhook ---\n if (data.event_type === \"event_verification\") {\n const challenge = data.event?.seatalk_challenge;\n console.log(\"Webhook verification:\", challenge);\n return Response.json({ seatalk_challenge: challenge });\n }\n\n // --- Disparar NPS por email ---\n if (data.action === \"trigger_nps_email\") {\n if (!data.email) {\n return Response.json({\n success: false,\n error: \"Email é obrigatório\",\n });\n }\n const result = await triggerNPSByEmail(data.email.trim());\n return Response.json(result);\n }\n\n // --- Disparar NPS em massa ---\n if (data.action === \"trigger_nps_bulk\") {\n if (!Array.isArray(data.emails) || data.emails.length === 0) {\n return Response.json({\n success: false,\n error: \"A lista de emails é obrigatória\",\n });\n }\n\n // Limite de segurança por requisição.\n if (data.emails.length > 100) {\n return Response.json({\n success: false,\n error: \"Máximo de 100 emails por envio em massa.\",\n });\n }\n\n const result = await triggerNPSBulk(data.emails);\n return Response.json(result);\n }\n\n // --- Disparar NPS por employee_code ---\n if (data.action === \"trigger_nps_code\" || data.action === \"trigger_nps\") {\n const code = data.employee_code;\n if (!code) {\n return Response.json({\n success: false,\n error: \"employee_code é obrigatório\",\n });\n }\n const result = await triggerNPSByCode(code, data.email || \"\");\n return Response.json(result);\n }\n\n // --- Clique em botão interativo ---\n if (data.event_type === \"interactive_message_click\") {\n await handleButtonClick(data.event || data);\n return Response.json({ code: 0 });\n }\n\n // --- Mensagem de texto do subscriber ---\n if (data.event_type === \"message_from_bot_subscriber\") {\n await handleTextMessage(data.event || data);\n return Response.json({ code: 0 });\n }\n\n console.log(\"Evento desconhecido:\", data.event_type || data.action);\n return Response.json({ code: 0 });\n } catch (err: any) {\n console.error(\"Erro no POST:\", err.message, err.stack);\n return Response.json({ error: err.message }, { status: 500 });\n }\n }\n\n return new Response(\"Method not allowed\", { status: 405 });\n}","// ================================================================\n// NPS Talent Acquisition — SeaTalk Bot (Val.town) v8\n// ================================================================\n//\n// CHANGELOG v5:\n// - FIX: endpoint correto /contacts/v2/get_employee_code_with_email\n// (confirmado pelo script Python que funciona)\n// - FIX: body do lookup usa \"emails\" (array)\n// - FIX: parse da resposta lê results[0].employee_code ou employees[0].employee_code\n// - KEEP: wrapper \"message\" nas chamadas de envio (fix do v3)\n//\n// ================================================================\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ============ CONFIGURAÇÕES ============\nconst APP_ID = \"NDEyNTQ1NzIzMjM3\";\nconst APP_SECRET = \"CgplsQoDs7T68cw8pX_MbnAI4kLlvIZN\";\nconst SEATALK_API = \"https://openapi.seatalk.io\";\n\n// (Opcional) URL do Apps Script pra gravar no Google Sheets\nconst APPS_SCRIPT_URL = \"\";\n\n// ============ PERGUNTAS ============\nconst PERGUNTAS = [\n {\n titulo: \"📊 Avaliação TA — Pergunta 1/3\",\n texto:\n \"Qualidade e Aderência\\nComo você avalia a qualidade e a aderência dos candidatos apresentados às necessidades da sua área?\",\n prefixo: \"q1\",\n nome: \"Qualidade e Aderência\",\n },\n {\n titulo: \"📊 Avaliação TA — Pergunta 2/3\",\n texto:\n \"Parceria e Efetividade\\nComo você avalia a efetividade de Talent Acquisition em compreender as prioridades, orientar e apoiar você e seus líderes ao longo dos processos seletivos?\",\n prefixo: \"q2\",\n nome: \"Parceria e Efetividade\",\n },\n {\n titulo: \"📊 Avaliação TA — Pergunta 3/3\",\n texto:\n \"Experiência Geral com TA\\nDe forma geral, como você avalia o suporte de Talent Acquisition à sua área neste mês?\",\n prefixo: \"q3\",\n nome: \"Experiência Geral com TA\",\n },\n];\n\nconst ESCALA =\n \"1 — Muito abaixo · 2 — Abaixo · 3 — Atende · 4 — Acima · 5 — Supera\";\n\n// ================================================================\n// ACCESS TOKEN\n// ================================================================\n\nlet tokenCache = { token: \"\", expiresAt: 0 };\n\nasync function getAccessToken(): Promise {\n if (tokenCache.token && Date.now() < tokenCache.expiresAt) {\n return tokenCache.token;\n }\n\n const res = await fetch(`${SEATALK_API}/auth/app_access_token`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ app_id: APP_ID, app_secret: APP_SECRET }),\n });\n\n const data = await res.json();\n if (data.code !== 0) {\n throw new Error(`Erro ao obter token SeaTalk: ${JSON.stringify(data)}`);\n }\n\n tokenCache = {\n token: data.app_access_token,\n expiresAt: Date.now() + ((data.expire || 7200) - 120) * 1000,\n };\n\n return tokenCache.token;\n}\n\nasync function seatalkPost(endpoint: string, body: any): Promise {\n const token = await getAccessToken();\n const res = await fetch(`${SEATALK_API}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${token}`,\n },\n body: JSON.stringify(body),\n });\n return res.json();\n}\n\n// ================================================================\n// BUSCAR EMPLOYEE CODE POR EMAIL — v5: endpoint confirmado\n// ================================================================\n//\n// Endpoint: POST /contacts/v2/get_employee_code_with_email\n// Body: { \"emails\": [\"email@shopee.com\"] }\n// Response: { \"code\": 0, \"results\": [{ \"email\": \"...\", \"employee_code\": \"...\" }] }\n// ou: { \"code\": 0, \"employees\": [{ \"employee_code\": \"...\" }] }\n//\n\nconst emailCache: Record = {};\n\nasync function getEmployeeCodeByEmail(email: string): Promise {\n // Cache em memória\n if (emailCache[email]) return emailCache[email];\n\n // Cache persistente\n try {\n const cached = await blob.getJSON(\n `email_cache_${email.replace(/[@.]/g, \"_\")}`,\n );\n if (cached?.employee_code) {\n emailCache[email] = cached.employee_code;\n return cached.employee_code;\n }\n } catch { /* sem cache */ }\n\n // Tenta o endpoint correto primeiro, depois fallbacks\n const attempts = [\n {\n endpoint: \"/contacts/v2/get_employee_code_with_email\",\n body: { emails: [email] },\n },\n { endpoint: \"/contacts/v2/get_employee_code\", body: { emails: [email] } },\n { endpoint: \"/contacts/v2/employees/get_by_email\", body: { email } },\n ];\n\n const errors: string[] = [];\n\n for (const attempt of attempts) {\n try {\n const res = await seatalkPost(attempt.endpoint, attempt.body);\n console.log(`Lookup ${attempt.endpoint}:`, JSON.stringify(res));\n\n // Parse flexível: cobre múltiplos formatos de resposta\n let code: string | undefined;\n\n // Formato 1: { results: [{ employee_code: \"...\" }] }\n if (res.results && Array.isArray(res.results) && res.results.length > 0) {\n const result = res.results[0];\n if (result.employee_code) {\n code = result.employee_code;\n }\n }\n\n // Formato 2: { employees: [{ employee_code: \"...\" }] }\n if (\n !code && res.employees && Array.isArray(res.employees) &&\n res.employees.length > 0\n ) {\n const emp = res.employees[0];\n if (emp.employee_code) {\n code = emp.employee_code;\n }\n }\n\n // Formato 3: { employee_code: \"...\" }\n if (!code && res.employee_code) {\n code = res.employee_code;\n }\n\n // Formato 4: { employee: { employee_code: \"...\" } }\n if (!code && res.employee?.employee_code) {\n code = res.employee.employee_code;\n }\n\n if (res.code === 0 && code) {\n // Salva no cache\n emailCache[email] = code;\n await blob.setJSON(`email_cache_${email.replace(/[@.]/g, \"_\")}`, {\n employee_code: code,\n email,\n cached_at: new Date().toISOString(),\n });\n console.log(\n `✅ Employee code encontrado: ${code} (via ${attempt.endpoint})`,\n );\n return code;\n }\n\n errors.push(\n `${attempt.endpoint}: code=${res.code}, msg=${\n res.msg || \"sem mensagem\"\n }`,\n );\n } catch (e: any) {\n errors.push(`${attempt.endpoint}: ${e.message}`);\n }\n }\n\n throw new Error(\n `Não foi possível encontrar o employee_code para ${email}. ` +\n `Tentativas: ${errors.join(\" | \")}. ` +\n `Verifique se: (1) o email está correto, (2) o bot tem permissão de \"Get Employee Code with Email\" no SeaTalk Open Platform.`,\n );\n}\n\n// ================================================================\n// STATE MANAGEMENT (Val.town Blob)\n// ================================================================\n\nasync function getState(employeeCode: string): Promise {\n try {\n return await blob.getJSON(`nps_state_${employeeCode}`);\n } catch {\n return null;\n }\n}\n\nasync function setState(employeeCode: string, state: any): Promise {\n await blob.setJSON(`nps_state_${employeeCode}`, state);\n}\n\nasync function clearState(employeeCode: string): Promise {\n try {\n await blob.delete(`nps_state_${employeeCode}`);\n } catch { /* ignore */ }\n}\n\n// ================================================================\n// RESPONSES STORAGE (Val.town Blob)\n// ================================================================\n\nasync function getResponses(): Promise {\n try {\n const data = await blob.getJSON(\"nps_responses\");\n return Array.isArray(data) ? data : [];\n } catch {\n return [];\n }\n}\n\nasync function addResponse(record: any): Promise {\n const responses = await getResponses();\n responses.push(record);\n await blob.setJSON(\"nps_responses\", responses);\n}\n\nasync function updateLastComment(\n email: string,\n comment: string,\n): Promise {\n const responses = await getResponses();\n for (let i = responses.length - 1; i >= 0; i--) {\n if (responses[i].email === email && !responses[i].comment) {\n responses[i].comment = comment;\n break;\n }\n }\n await blob.setJSON(\"nps_responses\", responses);\n}\n\n// ================================================================\n// SEATALK MESSAGING — com wrapper \"message\" (fix do v3)\n// ================================================================\n\nasync function enviarPergunta(employeeCode: string, questionIndex: number) {\n const p = PERGUNTAS[questionIndex];\n\n const buttons = Array.from({ length: 5 }, (_, idx) => {\n const nota = idx + 1;\n return {\n button_type: \"callback\",\n text: String(nota),\n value: `${p.prefixo}_${nota}`,\n };\n });\n\n // SeaTalk aceita no máximo 3 botões por button_group.\n // Além disso, button_group deve receber o ARRAY diretamente,\n // e não { buttons: [...] }.\n const grupo1 = buttons.slice(0, 3);\n const grupo2 = buttons.slice(3, 5);\n\n return seatalkPost(\"/messaging/v2/single_chat\", {\n employee_code: employeeCode,\n message: {\n tag: \"interactive_message\",\n interactive_message: {\n elements: [\n {\n element_type: \"title\",\n title: { text: p.titulo },\n },\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: p.texto,\n },\n },\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: ESCALA,\n },\n },\n {\n element_type: \"button_group\",\n button_group: grupo1,\n },\n {\n element_type: \"button_group\",\n button_group: grupo2,\n },\n ],\n },\n },\n usable_platform: \"all\",\n });\n}\n\nasync function atualizarCard(messageId: string, texto: string) {\n return seatalkPost(\"/messaging/v2/update_message\", {\n message_id: messageId,\n message: {\n tag: \"interactive_message\",\n interactive_message: {\n elements: [\n {\n element_type: \"description\",\n description: {\n format: 2,\n text: texto,\n },\n },\n ],\n },\n },\n });\n}\n\nasync function enviarTexto(employeeCode: string, texto: string) {\n return seatalkPost(\"/messaging/v2/single_chat\", {\n employee_code: employeeCode,\n message: {\n tag: \"text\",\n text: { content: texto },\n },\n });\n}\n\n// ================================================================\n// GRAVAR RESPOSTA\n// ================================================================\n\nasync function gravarResposta(state: any): Promise {\n const now = new Date();\n const brDate = new Date(now.getTime() - 3 * 60 * 60 * 1000);\n const date = brDate.toISOString().split(\"T\")[0];\n\n const record = {\n date,\n email: state.email || state.employee_code,\n q1: state.q1,\n q2: state.q2,\n q3: state.q3,\n comment: state.comment || \"\",\n timestamp: now.toISOString(),\n };\n\n await addResponse(record);\n\n if (APPS_SCRIPT_URL) {\n try {\n await fetch(APPS_SCRIPT_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ action: \"write_nps\", ...record }),\n redirect: \"follow\",\n });\n } catch (e: any) {\n console.log(\"Sheets write failed:\", e.message);\n }\n }\n}\n\n// ================================================================\n// HANDLER: CLIQUE NO BOTÃO\n// ================================================================\n\nasync function handleButtonClick(event: any): Promise {\n // Payload atual do SeaTalk:\n // event.clicker.employee_code + event.button_value.\n // Mantemos fallbacks para compatibilidade com payloads antigos/testes locais.\n const employeeCode = event.clicker?.employee_code ||\n event.employee_code;\n\n const value = event.button_value ||\n event.value;\n\n const messageId = event.message_id;\n\n if (!employeeCode || !value || !messageId) {\n console.log(\n \"Clique interativo com payload incompleto:\",\n JSON.stringify(event),\n );\n return;\n }\n\n const state = await getState(employeeCode);\n if (!state) return;\n\n const parts = value.split(\"_\");\n const prefixo = parts[0];\n const nota = parseInt(parts[1], 10);\n\n if (state[prefixo] !== null && state[prefixo] !== undefined) return;\n\n state[prefixo] = nota;\n\n const idx = parseInt(prefixo.replace(\"q\", \"\"), 10) - 1;\n await atualizarCard(\n messageId,\n `✅ ${PERGUNTAS[idx].nome}: ${nota}/5 — Registrado!`,\n );\n\n if (prefixo === \"q1\") {\n state.current_question = 1;\n const res = await enviarPergunta(employeeCode, 1);\n if (res.code === 0 && res.message_id) state.q2_msg_id = res.message_id;\n await setState(employeeCode, state);\n } else if (prefixo === \"q2\") {\n state.current_question = 2;\n const res = await enviarPergunta(employeeCode, 2);\n if (res.code === 0 && res.message_id) state.q3_msg_id = res.message_id;\n await setState(employeeCode, state);\n } else if (prefixo === \"q3\") {\n state.current_question = \"comment\";\n state.awaiting_comment = true;\n await setState(employeeCode, state);\n\n await gravarResposta(state);\n\n await enviarTexto(\n employeeCode,\n \"🎉 Obrigado pelas respostas!\\n\\n\" +\n \"💬 Comentário opcional: Qual é a principal coisa que Talent Acquisition poderia \" +\n \"melhorar para apoiar ainda melhor você e seus líderes?\\n\\n\" +\n \"Basta digitar aqui. Se preferir não comentar, pode ignorar — suas notas já foram registradas! ✅\",\n );\n }\n}\n\n// ================================================================\n// HANDLER: MENSAGEM DE TEXTO (COMENTÁRIO)\n// ================================================================\n\nasync function handleTextMessage(event: any): Promise {\n const employeeCode = event.employee_code;\n const msg = event.message || {};\n const texto = msg?.text?.content || msg?.content || \"\";\n\n if (!texto) return;\n\n const state = await getState(employeeCode);\n if (!state || !state.awaiting_comment) return;\n\n state.comment = texto;\n state.awaiting_comment = false;\n state.current_question = \"done\";\n\n const email = state.email || state.employee_code;\n await updateLastComment(email, texto);\n\n if (APPS_SCRIPT_URL) {\n try {\n await fetch(APPS_SCRIPT_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n action: \"update_comment\",\n email,\n comment: texto,\n }),\n redirect: \"follow\",\n });\n } catch (e: any) {\n console.log(\"Comment update failed:\", e.message);\n }\n }\n\n await clearState(employeeCode);\n\n await enviarTexto(\n employeeCode,\n \"✅ Comentário registrado! Muito obrigado pelo seu feedback.\\n\\n\" +\n \"Ele é essencial para continuarmos evoluindo a parceria de TA com o negócio. 🚀\",\n );\n}\n\n// ================================================================\n// TRIGGER NPS\n// ================================================================\n\nasync function triggerNPSByEmail(email: string): Promise {\n let employeeCode: string;\n try {\n employeeCode = await getEmployeeCodeByEmail(email);\n } catch (e: any) {\n return { success: false, error: e.message };\n }\n\n return await doTriggerNPS(employeeCode, email);\n}\n\nasync function triggerNPSBulk(emails: string[]): Promise {\n const uniqueEmails = [\n ...new Set(\n emails\n .map((e) => String(e || \"\").trim().toLowerCase())\n .filter(Boolean),\n ),\n ];\n\n const results: any[] = [];\n\n for (let i = 0; i < uniqueEmails.length; i++) {\n const email = uniqueEmails[i];\n\n try {\n const result = await triggerNPSByEmail(email);\n results.push({\n email,\n success: !!result.success,\n employee_code: result.employee_code || \"\",\n error: result.error || \"\",\n });\n } catch (e: any) {\n results.push({\n email,\n success: false,\n employee_code: \"\",\n error: e?.message || String(e),\n });\n }\n\n // Pequeno intervalo entre envios para evitar rajadas na API.\n if (i < uniqueEmails.length - 1) {\n await new Promise((r) => setTimeout(r, 700));\n }\n }\n\n const sent = results.filter((r) => r.success).length;\n const failed = results.length - sent;\n\n return {\n success: failed === 0,\n total: results.length,\n sent,\n failed,\n results,\n };\n}\n\nasync function triggerNPSByCode(\n employeeCode: string,\n email: string,\n): Promise {\n return await doTriggerNPS(employeeCode, email);\n}\n\nasync function doTriggerNPS(employeeCode: string, email: string): Promise {\n await clearState(employeeCode);\n\n const introResult = await enviarTexto(\n employeeCode,\n \"Olá! 👋\\n\\n\" +\n \"Como parte da nossa evolução contínua em Talent Acquisition, gostaria de contar com a sua percepção \" +\n \"sobre como estamos apoiando você e os líderes da sua estrutura.\\n\\n\" +\n \"Será rápido — apenas 3 perguntas (escala de 1 a 5) e um comentário opcional.\\n\\n\" +\n \"Vou enviar as perguntas agora! 👇\",\n );\n\n if (introResult.code !== 0) {\n return {\n success: false,\n error: `Erro ao enviar mensagem: ${JSON.stringify(introResult)}`,\n employee_code: employeeCode,\n };\n }\n\n await new Promise((r) => setTimeout(r, 1500));\n\n const state: any = {\n employee_code: employeeCode,\n email: email || employeeCode,\n current_question: 0,\n q1: null,\n q2: null,\n q3: null,\n comment: null,\n started_at: new Date().toISOString(),\n awaiting_comment: false,\n };\n\n const res = await enviarPergunta(employeeCode, 0);\n if (res.code === 0 && res.message_id) {\n state.q1_msg_id = res.message_id;\n } else {\n return {\n success: false,\n error: `Erro ao enviar Q1: ${JSON.stringify(res)}`,\n employee_code: employeeCode,\n };\n }\n\n await setState(employeeCode, state);\n\n return { success: true, email, employee_code: employeeCode };\n}\n\n// ================================================================\n// PÁGINA DE ADMIN (HTML)\n// ================================================================\n\nfunction adminPage(): string {\n return `\n\n\n \n \n NPS TA - Admin\n \n\n\n

📊 NPS Talent Acquisition v8

Envie pesquisas de satisfação via SeaTalk e acompanhe os resultados.

\n\n

🚀 Enviar NPS

\n\n

\n \n \n \n

\n\n \n\n \n

\n\n

📋 Respostas

\n 📄 JSON\n ⬇️ CSV\n

Carregando...

Diff · v24