[{"_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",34,"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) v18 PT-EN HOD Groups\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// ============ IDIOMAS / PERGUNTAS ============\n\ntype Lang = \"pt\" | \"en\";\n\nconst COPY = {\n pt: {\n intro: (name?: string) =>\n `${name ? `Olá, ${name}!` : \"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 \"É uma pesquisa rápida: são apenas 3 perguntas, com notas de 1 a 5, e um comentário opcional.\\n\\n\" +\n \"As 3 perguntas serão enviadas agora. Você pode responder na ordem que preferir. 👇\",\n\n questions: [\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\n labels: [\n \"1. Muito abaixo\",\n \"2. Abaixo\",\n \"3. Atende\",\n \"4. Acima\",\n \"5. Supera\",\n ],\n\n select: \"Selecione uma opção abaixo:\",\n responseRecorded: \"✅ RESPOSTA REGISTRADA\",\n score: \"Nota\",\n recordedThanks: \"Obrigado! Esta pergunta já foi computada.\",\n fallbackQuestion: \"Pergunta\",\n fallbackRecorded: \"registrada\",\n\n optional: \"🎉 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 esta mensagem. \" +\n \"Suas notas já foram registradas. ✅\",\n\n finalThanks:\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 en: {\n intro: (name?: string) =>\n `${name ? `Hi ${name}!` : \"Hi!\"} Hope you’re doing well. 👋\\n\\n` +\n \"As part of our continuous improvement in Talent Acquisition, I’d like to get your monthly feedback \" +\n \"on how TA is supporting you and your leaders.\\n\\n\" +\n \"It’s a very quick pulse: just 3 questions, scored from 1 to 5, plus an optional comment.\\n\\n\" +\n \"The 3 questions will be sent now. You can answer them in any order. 👇\",\n\n questions: [\n {\n titulo: \"📊 TA Monthly Pulse | Question 1/3\",\n texto:\n \"Quality & Fit\\nHow do you rate the quality and fit of the candidates presented for your organization’s hiring needs?\",\n prefixo: \"q1\",\n nome: \"Quality & Fit\",\n },\n {\n titulo: \"📊 TA Monthly Pulse | Question 2/3\",\n texto:\n \"Partnership & Effectiveness\\nHow do you rate TA’s effectiveness in understanding your priorities, providing guidance, and supporting you and your leaders throughout the hiring process?\",\n prefixo: \"q2\",\n nome: \"Partnership & Effectiveness\",\n },\n {\n titulo: \"📊 TA Monthly Pulse | Question 3/3\",\n texto:\n \"Overall TA Experience\\nOverall, how do you rate Talent Acquisition’s support to your organization this month?\",\n prefixo: \"q3\",\n nome: \"Overall TA Experience\",\n },\n ],\n\n labels: [\n \"1. Far below expectations\",\n \"2. Below expectations\",\n \"3. Meets expectations\",\n \"4. Exceeds expectations\",\n \"5. Significantly exceeds expectations\",\n ],\n\n select: \"Select one option below:\",\n responseRecorded: \"✅ RESPONSE RECORDED\",\n score: \"Score\",\n recordedThanks: \"Thank you! Your answer has been recorded.\",\n fallbackQuestion: \"Question\",\n fallbackRecorded: \"recorded\",\n\n optional: \"🎉 Thank you for your responses!\\n\\n\" +\n \"💬 Optional: What is the ONE thing we could improve to better support you and your leaders?\\n\\n\" +\n \"Simply type your comment here. If you prefer not to add a comment, you can ignore this message. \" +\n \"Your scores have already been recorded. ✅\",\n\n finalThanks:\n \"✅ Comment recorded! Thank you very much for your feedback.\\n\\n\" +\n \"Your feedback will help us track our progress and continuously improve how TA partners with the business. 🚀\",\n },\n} as const;\n\nfunction normalizeLang(value: any): Lang {\n return value === \"en\" ? \"en\" : \"pt\";\n}\n\n// ============ HOD LISTS ============\n\ntype Hod = {\n name: string;\n email: string;\n lang: Lang;\n};\n\nconst DEFAULT_HODS: Hod[] = [\n { name: \"Felipe Lima\", email: \"felipe.lima@shopee.com\", lang: \"pt\" },\n { name: \"Tiago Freddi\", email: \"tiago.freddi@shopee.com\", lang: \"pt\" },\n { name: \"Haowen Zheng\", email: \"zhenghaowen@monee.com\", lang: \"en\" },\n { name: \"Leandro Franco\", email: \"leandro.franco@monee.com\", lang: \"pt\" },\n { name: \"Karina Hartung\", email: \"karina.hartung@shopee.com\", lang: \"pt\" },\n { name: \"Felipe Piringer\", email: \"felipe.piringer@shopee.com\", lang: \"pt\" },\n { name: \"Felipe Alves\", email: \"felipe.alves@shopee.com\", lang: \"pt\" },\n { name: \"Annie Tran\", email: \"annie.tran@shopee.com\", lang: \"en\" },\n { name: \"Weidong Sun\", email: \"weidong.sun@shopee.com\", lang: \"en\" },\n { name: \"Camila No\", email: \"camila.no@shopee.com\", lang: \"en\" },\n {\n name: \"Bangkok Tian (田曼谷)\",\n email: \"bangkok.tian@shopee.com\",\n lang: \"en\",\n },\n { name: \"Eric Watanabe\", email: \"eric.watanabe@shopee.com\", lang: \"pt\" },\n];\n\nasync function getHods(): Promise {\n try {\n const saved = await blob.getJSON(\"nps_hod_list\");\n if (Array.isArray(saved) && saved.length > 0) {\n return saved\n .map((h: any) => ({\n name: String(h.name || \"\").trim(),\n email: String(h.email || \"\").trim().toLowerCase(),\n lang: normalizeLang(h.lang),\n }))\n .filter((h: Hod) => h.email);\n }\n } catch {\n // Usa a lista padrão quando ainda não houver uma lista salva.\n }\n return DEFAULT_HODS;\n}\n\nasync function saveHods(hods: Hod[]): Promise {\n const clean = hods\n .map((h: any) => ({\n name: String(h.name || \"\").trim(),\n email: String(h.email || \"\").trim().toLowerCase(),\n lang: normalizeLang(h.lang),\n }))\n .filter((h: Hod) => h.email);\n\n await blob.setJSON(\"nps_hod_list\", clean);\n return clean;\n}\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\nasync function deleteResponseByIndex(index: number): Promise {\n const responses = await getResponses();\n\n if (!Number.isInteger(index) || index < 0 || index >= responses.length) {\n return false;\n }\n\n responses.splice(index, 1);\n await blob.setJSON(\"nps_responses\", responses);\n return true;\n}\n\nasync function deleteResponsesByEmail(email: string): Promise {\n const responses = await getResponses();\n const normalizedEmail = String(email || \"\").trim().toLowerCase();\n\n const filtered = responses.filter(\n (r) => String(r.email || \"\").trim().toLowerCase() !== normalizedEmail,\n );\n\n const deleted = responses.length - filtered.length;\n\n if (deleted > 0) {\n await blob.setJSON(\"nps_responses\", filtered);\n }\n\n return deleted;\n}\n\nasync function clearAllResponses(): Promise {\n const responses = await getResponses();\n const deleted = responses.length;\n await blob.setJSON(\"nps_responses\", []);\n return deleted;\n}\n\n// ================================================================\n// SEATALK MESSAGING — com wrapper \"message\" (fix do v3)\n// ================================================================\n\nasync function enviarPergunta(\n employeeCode: string,\n questionIndex: number,\n lang: Lang,\n) {\n const copy = COPY[lang];\n const p = copy.questions[questionIndex];\n\n const buttons = Array.from({ length: 5 }, (_, idx) => {\n const nota = idx + 1;\n return {\n button_type: \"callback\",\n text: copy.labels[idx],\n value: `${p.prefixo}_${nota}`,\n };\n });\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: copy.select,\n },\n },\n {\n element_type: \"button_group\",\n button_group: buttons.slice(0, 3),\n },\n {\n element_type: \"button\",\n button: buttons[3],\n },\n {\n element_type: \"button\",\n button: buttons[4],\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 hod_name: state.name || \"\",\n language: normalizeLang(state.lang),\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 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 (\n ![\"q1\", \"q2\", \"q3\"].includes(prefixo) ||\n !Number.isFinite(nota) ||\n nota < 1 ||\n nota > 5\n ) {\n console.log(\"Valor de botão inválido:\", value);\n return;\n }\n\n // Impede resposta duplicada.\n if (state[prefixo] !== null && state[prefixo] !== undefined) {\n return;\n }\n\n state[prefixo] = nota;\n await setState(employeeCode, state);\n\n const idx = parseInt(prefixo.replace(\"q\", \"\"), 10) - 1;\n const lang = normalizeLang(state.lang);\n const copy = COPY[lang];\n\n const cardMessageId = state[`${prefixo}_msg_id`] ||\n messageId;\n\n const updateResult = await atualizarCard(\n cardMessageId,\n `${copy.responseRecorded}\n\n${copy.questions[idx].nome}\n${copy.score}: ${nota}/5\n\n${copy.recordedThanks}`,\n );\n\n // Se o SeaTalk não conseguir atualizar o card, ainda damos\n // uma confirmação visível para o usuário.\n if (updateResult.code !== 0) {\n console.log(\n \"Falha ao atualizar card de confirmação:\",\n JSON.stringify(updateResult),\n );\n\n await enviarTexto(\n employeeCode,\n `✅ ${copy.fallbackQuestion} ${\n idx + 1\n }/3 ${copy.fallbackRecorded}: ${nota}/5`,\n );\n }\n\n const todasRespondidas = state.q1 !== null && state.q1 !== undefined &&\n state.q2 !== null && state.q2 !== undefined &&\n state.q3 !== null && state.q3 !== undefined;\n\n if (todasRespondidas && !state.response_saved) {\n state.response_saved = true;\n state.current_question = \"comment\";\n state.awaiting_comment = true;\n\n await setState(employeeCode, state);\n await gravarResposta(state);\n\n await enviarTexto(\n employeeCode,\n copy.optional,\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 const lang = normalizeLang(state.lang);\n\n await enviarTexto(\n employeeCode,\n COPY[lang].finalThanks,\n );\n}\n\n// ================================================================\n// TRIGGER NPS\n// ================================================================\n\nasync function triggerNPSByEmail(\n email: string,\n lang: Lang,\n name = \"\",\n): 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, lang, name);\n}\n\nasync function triggerNPSBulk(emails: string[], lang: Lang): 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, lang);\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 triggerNPSHodGroup(lang: Lang): Promise {\n const hods = (await getHods()).filter((h) => h.lang === lang);\n const results: any[] = [];\n\n for (let i = 0; i < hods.length; i++) {\n const hod = hods[i];\n try {\n const result = await triggerNPSByEmail(hod.email, lang, hod.name);\n results.push({\n name: hod.name,\n email: hod.email,\n success: !!result.success,\n employee_code: result.employee_code || \"\",\n error: result.error || \"\",\n });\n } catch (e: any) {\n results.push({\n name: hod.name,\n email: hod.email,\n success: false,\n employee_code: \"\",\n error: e?.message || String(e),\n });\n }\n\n if (i < hods.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 lang,\n results,\n };\n}\n\nasync function triggerNPSByCode(\n employeeCode: string,\n email: string,\n lang: Lang,\n): Promise {\n return await doTriggerNPS(employeeCode, email, lang, \"\");\n}\n\nasync function doTriggerNPS(\n employeeCode: string,\n email: string,\n lang: Lang,\n name = \"\",\n): Promise {\n await clearState(employeeCode);\n\n const copy = COPY[lang];\n\n const introResult = await enviarTexto(\n employeeCode,\n copy.intro(name),\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 const state: any = {\n employee_code: employeeCode,\n email: email || employeeCode,\n name,\n lang,\n current_question: \"all\",\n q1: null,\n q2: null,\n q3: null,\n comment: null,\n started_at: new Date().toISOString(),\n awaiting_comment: false,\n response_saved: false,\n q1_msg_id: null,\n q2_msg_id: null,\n q3_msg_id: null,\n };\n\n // Salva o estado antes do disparo para que cliques muito rápidos\n // já encontrem o usuário no webhook.\n await setState(employeeCode, state);\n\n // Envia Q1, Q2 e Q3 na ordem correta.\n // Não esperamos resposta do usuário entre elas; apenas aguardamos\n // cada envio ser aceito pela API antes de mandar o próximo.\n const errors: string[] = [];\n\n for (let idx = 0; idx < 3; idx++) {\n const res = await enviarPergunta(employeeCode, idx, lang);\n\n if (res.code === 0 && res.message_id) {\n state[`q${idx + 1}_msg_id`] = res.message_id;\n await setState(employeeCode, state);\n } else {\n errors.push(`Q${idx + 1}: ${JSON.stringify(res)}`);\n }\n }\n\n if (errors.length > 0) {\n return {\n success: false,\n error: `Falha em um ou mais cards: ${errors.join(\" | \")}`,\n employee_code: employeeCode,\n partial_success: true,\n };\n }\n\n return {\n success: true,\n email,\n employee_code: employeeCode,\n questions_sent: 3,\n messages_sent: 3,\n };\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 v18 PT/EN

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

\n\n

🚀 Enviar NPS

\n\n

\n \n \n \n

\n\n

\n Idioma do NPS / Survey language:\n

\n \n \n

\n\n \n\n \n

\n\n

👥 HOD Groups

\n Você pode editar nomes e e-mails aqui. Use uma linha por pessoa no formato: Nome | email\n

\n\n

🇧🇷 HODs em Português

\n \n

\n\n

🇬🇧 HODs in English

\n \n

\n\n

\n \n \n

\n\n

📋 Respostas

\n 📄 JSON\n ⬇️ CSV\n

\n\n

\n \n \n

\n\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 === \"hod_list\") {\n const hods = await getHods();\n return Response.json({ success: true, hods });\n }\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,HOD Name,Email,Idioma,Qualidade e Aderência / Quality & Fit,Parceria e Efetividade / Partnership & Effectiveness,Experiência Geral com TA / Overall TA Experience,Comentário / Comment\\n\";\n for (const r of responses) {\n const comment = (r.comment || \"\").replace(/\"/g, '\"\"');\n csv += `${r.date},\"${r.hod_name || \"\"}\",\"${r.email}\",\"${\n r.language || \"pt\"\n }\",${r.q1 ?? \"\"},${r.q2 ?? \"\"},${r.q3 ?? \"\"},\"${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 // --- Salvar listas de HODs ---\n if (data.action === \"save_hod_list\") {\n if (!Array.isArray(data.hods)) {\n return Response.json(\n { success: false, error: \"Lista de HODs inválida.\" },\n { status: 400 },\n );\n }\n const hods = await saveHods(data.hods);\n return Response.json({ success: true, total: hods.length, hods });\n }\n\n // --- Disparar para grupo de HODs por idioma ---\n if (data.action === \"trigger_nps_hod_group\") {\n const result = await triggerNPSHodGroup(normalizeLang(data.lang));\n return Response.json(result);\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(\n data.email.trim(),\n normalizeLang(data.lang),\n );\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(\n data.emails,\n normalizeLang(data.lang),\n );\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(\n code,\n data.email || \"\",\n normalizeLang(data.lang),\n );\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 // --- Excluir uma resposta específica ---\n if (data.action === \"delete_response\") {\n const index = Number(data.index);\n const deleted = await deleteResponseByIndex(index);\n\n if (!deleted) {\n return Response.json(\n { success: false, error: \"Resposta não encontrada.\" },\n { status: 400 },\n );\n }\n\n return Response.json({ success: true });\n }\n\n // --- Excluir todas as respostas de um e-mail ---\n if (data.action === \"delete_responses_by_email\") {\n const email = String(data.email || \"\").trim();\n\n if (!email) {\n return Response.json(\n { success: false, error: \"E-mail é obrigatório.\" },\n { status: 400 },\n );\n }\n\n const deleted = await deleteResponsesByEmail(email);\n return Response.json({ success: true, deleted });\n }\n\n // --- Limpar todas as respostas ---\n if (data.action === \"clear_all_responses\") {\n const deleted = await clearAllResponses();\n return Response.json({ success: true, deleted });\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) v18 PT-EN HOD Groups\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// ============ IDIOMAS / PERGUNTAS ============\n\ntype Lang = \"pt\" | \"en\";\n\nconst COPY = {\n pt: {\n intro: (name?: string) =>\n `${name ? `Olá, ${name}!` : \"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 \"É uma pesquisa rápida: são apenas 3 perguntas, com notas de 1 a 5, e um comentário opcional.\\n\\n\" +\n \"As 3 perguntas serão enviadas agora. Você pode responder na ordem que preferir. 👇\",\n\n questions: [\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\n labels: [\n \"1. Muito abaixo\",\n \"2. Abaixo\",\n \"3. Atende\",\n \"4. Acima\",\n \"5. Supera\",\n ],\n\n select: \"Selecione uma opção abaixo:\",\n responseRecorded: \"✅ RESPOSTA REGISTRADA\",\n score: \"Nota\",\n recordedThanks: \"Obrigado! Esta pergunta já foi computada.\",\n fallbackQuestion: \"Pergunta\",\n fallbackRecorded: \"registrada\",\n\n optional: \"🎉 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 esta mensagem. \" +\n \"Suas notas já foram registradas. ✅\",\n\n finalThanks:\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 en: {\n intro: (name?: string) =>\n `${name ? `Hi ${name}!` : \"Hi!\"} Hope you’re doing well. 👋\\n\\n` +\n \"As part of our continuous improvement in Talent Acquisition, I’d like to get your monthly feedback \" +\n \"on how TA is supporting you and your leaders.\\n\\n\" +\n \"It’s a very quick pulse: just 3 questions, scored from 1 to 5, plus an optional comment.\\n\\n\" +\n \"The 3 questions will be sent now. You can answer them in any order. 👇\",\n\n questions: [\n {\n titulo: \"📊 TA Monthly Pulse | Question 1/3\",\n texto:\n \"Quality & Fit\\nHow do you rate the quality and fit of the candidates presented for your organization’s hiring needs?\",\n prefixo: \"q1\",\n nome: \"Quality & Fit\",\n },\n {\n titulo: \"📊 TA Monthly Pulse | Question 2/3\",\n texto:\n \"Partnership & Effectiveness\\nHow do you rate TA’s effectiveness in understanding your priorities, providing guidance, and supporting you and your leaders throughout the hiring process?\",\n prefixo: \"q2\",\n nome: \"Partnership & Effectiveness\",\n },\n {\n titulo: \"📊 TA Monthly Pulse | Question 3/3\",\n texto:\n \"Overall TA Experience\\nOverall, how do you rate Talent Acquisition’s support to your organization this month?\",\n prefixo: \"q3\",\n nome: \"Overall TA Experience\",\n },\n ],\n\n labels: [\n \"1. Far below expectations\",\n \"2. Below expectations\",\n \"3. Meets expectations\",\n \"4. Exceeds expectations\",\n \"5. Significantly exceeds expectations\",\n ],\n\n select: \"Select one option below:\",\n responseRecorded: \"✅ RESPONSE RECORDED\",\n score: \"Score\",\n recordedThanks: \"Thank you! Your answer has been recorded.\",\n fallbackQuestion: \"Question\",\n fallbackRecorded: \"recorded\",\n\n optional: \"🎉 Thank you for your responses!\\n\\n\" +\n \"💬 Optional: What is the main thing we could improve to better support you and your leaders?\\n\\n\" +\n \"Simply type your comment here. If you prefer not to add a comment, you can ignore this message. \" +\n \"Your scores have already been recorded. ✅\",\n\n finalThanks:\n \"✅ Comment recorded! Thank you very much for your feedback.\\n\\n\" +\n \"Your feedback will help us track our progress and continuously improve how TA partners with the business. 🚀\",\n },\n} as const;\n\nfunction normalizeLang(value: any): Lang {\n return value === \"en\" ? \"en\" : \"pt\";\n}\n\n// ============ HOD LISTS ============\n\ntype Hod = {\n name: string;\n email: string;\n lang: Lang;\n};\n\nconst DEFAULT_HODS: Hod[] = [\n { name: \"Felipe Lima\", email: \"felipe.lima@shopee.com\", lang: \"pt\" },\n { name: \"Tiago Freddi\", email: \"tiago.freddi@shopee.com\", lang: \"pt\" },\n { name: \"Haowen Zheng\", email: \"zhenghaowen@monee.com\", lang: \"en\" },\n { name: \"Leandro Franco\", email: \"leandro.franco@monee.com\", lang: \"pt\" },\n { name: \"Karina Hartung\", email: \"karina.hartung@shopee.com\", lang: \"pt\" },\n { name: \"Felipe Piringer\", email: \"felipe.piringer@shopee.com\", lang: \"pt\" },\n { name: \"Felipe Alves\", email: \"felipe.alves@shopee.com\", lang: \"pt\" },\n { name: \"Annie Tran\", email: \"annie.tran@shopee.com\", lang: \"en\" },\n { name: \"Weidong Sun\", email: \"weidong.sun@shopee.com\", lang: \"en\" },\n { name: \"Camila No\", email: \"camila.no@shopee.com\", lang: \"en\" },\n {\n name: \"Bangkok Tian (田曼谷)\",\n email: \"bangkok.tian@shopee.com\",\n lang: \"en\",\n },\n { name: \"Eric Watanabe\", email: \"eric.watanabe@shopee.com\", lang: \"pt\" },\n];\n\nasync function getHods(): Promise {\n try {\n const saved = await blob.getJSON(\"nps_hod_list\");\n if (Array.isArray(saved) && saved.length > 0) {\n return saved\n .map((h: any) => ({\n name: String(h.name || \"\").trim(),\n email: String(h.email || \"\").trim().toLowerCase(),\n lang: normalizeLang(h.lang),\n }))\n .filter((h: Hod) => h.email);\n }\n } catch {\n // Usa a lista padrão quando ainda não houver uma lista salva.\n }\n return DEFAULT_HODS;\n}\n\nasync function saveHods(hods: Hod[]): Promise {\n const clean = hods\n .map((h: any) => ({\n name: String(h.name || \"\").trim(),\n email: String(h.email || \"\").trim().toLowerCase(),\n lang: normalizeLang(h.lang),\n }))\n .filter((h: Hod) => h.email);\n\n await blob.setJSON(\"nps_hod_list\", clean);\n return clean;\n}\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\nasync function deleteResponseByIndex(index: number): Promise {\n const responses = await getResponses();\n\n if (!Number.isInteger(index) || index < 0 || index >= responses.length) {\n return false;\n }\n\n responses.splice(index, 1);\n await blob.setJSON(\"nps_responses\", responses);\n return true;\n}\n\nasync function deleteResponsesByEmail(email: string): Promise {\n const responses = await getResponses();\n const normalizedEmail = String(email || \"\").trim().toLowerCase();\n\n const filtered = responses.filter(\n (r) => String(r.email || \"\").trim().toLowerCase() !== normalizedEmail,\n );\n\n const deleted = responses.length - filtered.length;\n\n if (deleted > 0) {\n await blob.setJSON(\"nps_responses\", filtered);\n }\n\n return deleted;\n}\n\nasync function clearAllResponses(): Promise {\n const responses = await getResponses();\n const deleted = responses.length;\n await blob.setJSON(\"nps_responses\", []);\n return deleted;\n}\n\n// ================================================================\n// SEATALK MESSAGING — com wrapper \"message\" (fix do v3)\n// ================================================================\n\nasync function enviarPergunta(\n employeeCode: string,\n questionIndex: number,\n lang: Lang,\n) {\n const copy = COPY[lang];\n const p = copy.questions[questionIndex];\n\n const buttons = Array.from({ length: 5 }, (_, idx) => {\n const nota = idx + 1;\n return {\n button_type: \"callback\",\n text: copy.labels[idx],\n value: `${p.prefixo}_${nota}`,\n };\n });\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: copy.select,\n },\n },\n {\n element_type: \"button_group\",\n button_group: buttons.slice(0, 3),\n },\n {\n element_type: \"button\",\n button: buttons[3],\n },\n {\n element_type: \"button\",\n button: buttons[4],\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 hod_name: state.name || \"\",\n language: normalizeLang(state.lang),\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 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 (\n ![\"q1\", \"q2\", \"q3\"].includes(prefixo) ||\n !Number.isFinite(nota) ||\n nota < 1 ||\n nota > 5\n ) {\n console.log(\"Valor de botão inválido:\", value);\n return;\n }\n\n // Impede resposta duplicada.\n if (state[prefixo] !== null && state[prefixo] !== undefined) {\n return;\n }\n\n state[prefixo] = nota;\n await setState(employeeCode, state);\n\n const idx = parseInt(prefixo.replace(\"q\", \"\"), 10) - 1;\n const lang = normalizeLang(state.lang);\n const copy = COPY[lang];\n\n const cardMessageId = state[`${prefixo}_msg_id`] ||\n messageId;\n\n const updateResult = await atualizarCard(\n cardMessageId,\n `${copy.responseRecorded}\n\n${copy.questions[idx].nome}\n${copy.score}: ${nota}/5\n\n${copy.recordedThanks}`,\n );\n\n // Se o SeaTalk não conseguir atualizar o card, ainda damos\n // uma confirmação visível para o usuário.\n if (updateResult.code !== 0) {\n console.log(\n \"Falha ao atualizar card de confirmação:\",\n JSON.stringify(updateResult),\n );\n\n await enviarTexto(\n employeeCode,\n `✅ ${copy.fallbackQuestion} ${\n idx + 1\n }/3 ${copy.fallbackRecorded}: ${nota}/5`,\n );\n }\n\n const todasRespondidas = state.q1 !== null && state.q1 !== undefined &&\n state.q2 !== null && state.q2 !== undefined &&\n state.q3 !== null && state.q3 !== undefined;\n\n if (todasRespondidas && !state.response_saved) {\n state.response_saved = true;\n state.current_question = \"comment\";\n state.awaiting_comment = true;\n\n await setState(employeeCode, state);\n await gravarResposta(state);\n\n await enviarTexto(\n employeeCode,\n copy.optional,\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 const lang = normalizeLang(state.lang);\n\n await enviarTexto(\n employeeCode,\n COPY[lang].finalThanks,\n );\n}\n\n// ================================================================\n// TRIGGER NPS\n// ================================================================\n\nasync function triggerNPSByEmail(\n email: string,\n lang: Lang,\n name = \"\",\n): 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, lang, name);\n}\n\nasync function triggerNPSBulk(emails: string[], lang: Lang): 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, lang);\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 triggerNPSHodGroup(lang: Lang): Promise {\n const hods = (await getHods()).filter((h) => h.lang === lang);\n const results: any[] = [];\n\n for (let i = 0; i < hods.length; i++) {\n const hod = hods[i];\n try {\n const result = await triggerNPSByEmail(hod.email, lang, hod.name);\n results.push({\n name: hod.name,\n email: hod.email,\n success: !!result.success,\n employee_code: result.employee_code || \"\",\n error: result.error || \"\",\n });\n } catch (e: any) {\n results.push({\n name: hod.name,\n email: hod.email,\n success: false,\n employee_code: \"\",\n error: e?.message || String(e),\n });\n }\n\n if (i < hods.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 lang,\n results,\n };\n}\n\nasync function triggerNPSByCode(\n employeeCode: string,\n email: string,\n lang: Lang,\n): Promise {\n return await doTriggerNPS(employeeCode, email, lang, \"\");\n}\n\nasync function doTriggerNPS(\n employeeCode: string,\n email: string,\n lang: Lang,\n name = \"\",\n): Promise {\n await clearState(employeeCode);\n\n const copy = COPY[lang];\n\n const introResult = await enviarTexto(\n employeeCode,\n copy.intro(name),\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 const state: any = {\n employee_code: employeeCode,\n email: email || employeeCode,\n name,\n lang,\n current_question: \"all\",\n q1: null,\n q2: null,\n q3: null,\n comment: null,\n started_at: new Date().toISOString(),\n awaiting_comment: false,\n response_saved: false,\n q1_msg_id: null,\n q2_msg_id: null,\n q3_msg_id: null,\n };\n\n // Salva o estado antes do disparo para que cliques muito rápidos\n // já encontrem o usuário no webhook.\n await setState(employeeCode, state);\n\n // Envia Q1, Q2 e Q3 na ordem correta.\n // Não esperamos resposta do usuário entre elas; apenas aguardamos\n // cada envio ser aceito pela API antes de mandar o próximo.\n const errors: string[] = [];\n\n for (let idx = 0; idx < 3; idx++) {\n const res = await enviarPergunta(employeeCode, idx, lang);\n\n if (res.code === 0 && res.message_id) {\n state[`q${idx + 1}_msg_id`] = res.message_id;\n await setState(employeeCode, state);\n } else {\n errors.push(`Q${idx + 1}: ${JSON.stringify(res)}`);\n }\n }\n\n if (errors.length > 0) {\n return {\n success: false,\n error: `Falha em um ou mais cards: ${errors.join(\" | \")}`,\n employee_code: employeeCode,\n partial_success: true,\n };\n }\n\n return {\n success: true,\n email,\n employee_code: employeeCode,\n questions_sent: 3,\n messages_sent: 3,\n };\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 v18 PT/EN

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

\n\n

🚀 Enviar NPS

\n\n

\n \n \n \n

\n\n

\n Idioma do NPS / Survey language:\n

\n \n \n

\n\n \n\n \n

\n\n

👥 HOD Groups

\n Você pode editar nomes e e-mails aqui. Use uma linha por pessoa no formato: Nome | email\n

\n\n

🇧🇷 HODs em Português

\n \n

\n\n

🇬🇧 HODs in English

\n \n

\n\n

\n \n \n

\n\n

📋 Respostas

\n 📄 JSON\n ⬇️ CSV\n

\n\n

\n \n \n

\n\n

Carregando...

Diff · v34