[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_379":380,"_381":382},"routes/_app.x.$handle.$name",{"_95":94,"_31":43,"_103":85,"_26":51,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":24,"_117":118,"_119":57,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",95,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","salud-tokens.ts","latestPath","fileId","656bffac-a3fa-11f1-a851-1607ee4eb77e","name","fileType","script","content","/**\n * Salud de los PIT de GoHighLevel.\n *\n * Dice qué variable de entorno tiene el token vigente de cada cuenta y qué\n * scopes concede. Nunca imprime un token completo: la salida se puede pegar\n * en un chat sin filtrar nada.\n *\n * Ejecutar con: mcp__VAL_TOWN__run_file → LUFI/ghl-mcp/salud-tokens.ts\n */\n\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst LOC = {\n TopKreativa: \"SevVprqYc2lE6O92KLwY\",\n Ladys: \"o1V9sCKjH5Ywd9PRURj0\",\n} as const;\n\n/** Todas las variables que alguna vez guardaron un PIT, para detectar zombis. */\nconst CANDIDATOS = [\n \"PIT_TOPKREATIVA_V3\",\n \"PIT_TOPKREATIVA_V2\",\n \"PIT_TOPKREATIVA\",\n \"GHL_TOKEN_TOPKREATIVA\",\n \"PIT_LADYS_V2\",\n \"PIT_LADYS\",\n \"GHL_API_KEY_LADYS\",\n \"GHL_TOKEN_LADYS\",\n \"GHL_API_KEY\",\n];\n\nconst H = (t: string, v = \"2021-07-28\") => ({\n Authorization: `Bearer ${t}`,\n Version: v,\n Accept: \"application/json\",\n});\nconst mask = (t: string) => `${t.slice(0, 8)}…${t.slice(-6)}`;\n\ntype Fila = { env: string; token: string; tk: number; ladys: number; nivel: string };\nconst filas: Fila[] = [];\n\nfor (const env of CANDIDATOS) {\n const t = Deno.env.get(env);\n if (!t) continue;\n const [a, b] = await Promise.all([\n fetch(`${BASE}/locations/${LOC.TopKreativa}`, { headers: H(t) }),\n fetch(`${BASE}/locations/${LOC.Ladys}`, { headers: H(t) }),\n ]);\n const nivel = a.status === 200 && b.status === 200\n ? \"AGENCIA\"\n : a.status === 200\n ? \"location TopKreativa\"\n : b.status === 200\n ? \"location Ladys\"\n : \"MUERTO\";\n filas.push({ env, token: t, tk: a.status, ladys: b.status, nivel });\n}\n\nconsole.log(\"=== VARIABLES CON PIT ===\");\nconsole.log(\n \"variable\".padEnd(24) + \"token\".padEnd(20) + \"TK\".padEnd(6) + \"Ladys\".padEnd(8) + \"nivel\",\n);\nfor (const f of filas) {\n console.log(\n f.env.padEnd(24) + mask(f.token).padEnd(20) + String(f.tk).padEnd(6) +\n String(f.ladys).padEnd(8) + f.nivel,\n );\n}\n\nconst muertos = filas.filter((f) => f.nivel === \"MUERTO\");\nconst vigente = {\n TopKreativa: filas.find((f) => f.nivel === \"location TopKreativa\"),\n Ladys: filas.find((f) => f.nivel === \"location Ladys\"),\n Agencia: filas.find((f) => f.nivel === \"AGENCIA\"),\n};\n\nconsole.log(\"\\n=== VIGENTES ===\");\nfor (const [k, f] of Object.entries(vigente)) {\n console.log(` ${k.padEnd(12)} ${f ? `${f.env} (${mask(f.token)})` : \"⚠️ NINGUNO VIVO\"}`);\n}\nif (muertos.length) {\n console.log(\n `\\n⚠️ ${muertos.length} variable(s) con token muerto — borrarlas de Val Town y revocarlas en GHL:`,\n );\n for (const m of muertos) console.log(` ${m.env} (${mask(m.token)})`);\n}\n\nconst distintos = new Set(filas.map((f) => f.token)).size;\nconsole.log(`\\nValores distintos guardados: ${distintos} (GHL permite 5 PIT por nivel)`);\n\nconsole.log(\"\\n=== SCOPES ===\");\nconst SCOPES: [string, (loc: string) => string, string][] = [\n [\"contacts\", (l) => `${BASE}/contacts/?locationId=${l}&limit=1`, \"2021-07-28\"],\n [\"opportunities\", (l) => `${BASE}/opportunities/pipelines?locationId=${l}`, \"2021-07-28\"],\n [\"conversations\", (l) => `${BASE}/conversations/search?locationId=${l}&limit=1`, \"2021-04-15\"],\n [\"calendars\", (l) => `${BASE}/calendars/?locationId=${l}`, \"2021-07-28\"],\n [\"workflows\", (l) => `${BASE}/workflows/?locationId=${l}`, \"2021-07-28\"],\n [\"tags\", (l) => `${BASE}/locations/${l}/tags`, \"2021-07-28\"],\n [\"customFields\", (l) => `${BASE}/locations/${l}/customFields`, \"2021-07-28\"],\n [\"customValues\", (l) => `${BASE}/locations/${l}/customValues`, \"2021-07-28\"],\n [\"users\", (l) => `${BASE}/users/?locationId=${l}`, \"2021-07-28\"],\n [\"socialplanner\", (l) => `${BASE}/social-media-posting/${l}/accounts`, \"2021-07-28\"],\n [\"forms\", (l) => `${BASE}/forms/?locationId=${l}&limit=1`, \"2021-07-28\"],\n [\"links\", (l) => `${BASE}/links/?locationId=${l}`, \"2021-07-28\"],\n];\n\nfor (const [cuenta, loc] of Object.entries(LOC)) {\n const f = vigente[cuenta as keyof typeof vigente];\n if (!f) {\n console.log(`\\n-- ${cuenta}: sin token vivo, no se sondean scopes --`);\n continue;\n }\n const malos: string[] = [];\n for (const [nombre, url, v] of SCOPES) {\n const r = await fetch(url(loc), { headers: H(f.token, v) });\n if (r.status !== 200) malos.push(`${nombre} (${r.status})`);\n }\n console.log(\n `\\n-- ${cuenta} (${f.env}) --\\n ${\n malos.length ? `⚠️ fallan: ${malos.join(\", \")}` : `los ${SCOPES.length} scopes de lectura OK ✓`\n }`,\n );\n}\n\nconsole.log(\"\\n=== FIN ===\");\n","createdAt",["D",1788043126379],"branchVersion","branchId","503589fd-0897-499b-af7b-d0300e6e6843","id","af78805c-2bed-420c-8baf-302de98516b6","ghl-mcp",["D",1781837290695],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","019d4994-8d78-7000-b4ab-acb550747512","pinnedFileId","91a11d28-a323-11f1-ab04-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019d4994-8d78-7000-b4ab-b1c5ddec9378","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},"branch",{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"isOwned",196,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","LUFI","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCbEZzUENZZHpzbHpkTThyejIzUERENVltdiJ9","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":375,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":376,"_79":377,"_81":378,"_83":24},"tree",[212,227,228,229,230,231,232,233,234],"files",[212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234],"counts",{"_202":61,"_203":178,"_204":61,"_205":206,"_207":208},"contents",[124,125,126,127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":195,"_31":196,"_29":197,"_136":-5,"_39":40,"_38":198,"_138":57,"_36":199,"_13":61,"_32":200,"_34":-5,"_23":24,"_142":-5,"_26":201},{"_41":188,"_31":189,"_29":190,"_136":-5,"_39":40,"_38":191,"_138":57,"_36":192,"_13":178,"_32":20,"_34":193,"_23":24,"_142":-5,"_26":194},{"_41":181,"_31":182,"_29":183,"_136":-5,"_39":40,"_38":184,"_138":57,"_36":185,"_13":61,"_32":33,"_34":186,"_23":24,"_142":-5,"_26":187},{"_41":173,"_31":174,"_29":175,"_136":-5,"_39":40,"_38":176,"_138":57,"_36":177,"_13":178,"_32":33,"_34":179,"_23":24,"_142":-5,"_26":180},{"_41":165,"_31":166,"_29":167,"_136":-5,"_39":40,"_38":168,"_138":24,"_36":169,"_13":170,"_32":33,"_34":171,"_23":24,"_142":-5,"_26":172},{"_41":156,"_31":157,"_29":158,"_136":-5,"_39":40,"_38":159,"_138":57,"_36":160,"_13":161,"_32":162,"_34":163,"_23":24,"_142":-5,"_26":164},{"_41":147,"_31":148,"_29":149,"_136":-5,"_39":40,"_38":150,"_138":57,"_36":151,"_13":152,"_32":153,"_34":154,"_23":24,"_142":-5,"_26":155},{"_41":144,"_31":27,"_29":30,"_136":-5,"_39":40,"_38":14,"_138":57,"_36":145,"_13":61,"_32":33,"_34":35,"_23":24,"_142":-5,"_26":146},{"_41":133,"_31":134,"_29":135,"_136":-5,"_39":40,"_38":137,"_138":57,"_36":139,"_13":140,"_32":33,"_34":141,"_23":24,"_142":-5,"_26":143},"a8d42592-8b5b-4778-a093-33cfed361e6d","tools.ts","f9506ddc-6b8a-11f1-bd7e-1607ee4eb77e","parentId",34,"latest",["D",1786934288897],9,"// MCP tool definitions wiring GoHighLevel functions into an McpServer.\nimport { McpServer } from \"npm:@modelcontextprotocol/sdk@1.12.1/server/mcp.js\";\nimport { z } from \"npm:zod@3.25.76\";\nimport {\n addContactTag,\n createContact,\n DEFAULT_LOCATION_ID,\n getContact,\n listWhatsAppTemplates,\n removeContactTag,\n searchContacts,\n sendWhatsAppMessage,\n} from \"./ghl.ts\";\n\n/** JSON content helper for tool results. */\nfunction jsonResult(data: unknown) {\n return {\n content: [\n { type: \"text\" as const, text: JSON.stringify(data, null, 2) },\n ],\n };\n}\n\nfunction errorResult(err: unknown) {\n return {\n isError: true,\n content: [\n {\n type: \"text\" as const,\n text: err instanceof Error ? err.message : String(err),\n },\n ],\n };\n}\n\nexport function buildServer(): McpServer {\n const server = new McpServer({\n name: \"ghl-mcp\",\n version: \"1.0.0\",\n });\n\n server.tool(\n \"search_contacts\",\n \"Search GoHighLevel contacts by free-text query within a location.\",\n {\n query: z.string().optional().describe(\n \"Free-text search (name, email, phone, etc.).\",\n ),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n limit: z.number().int().positive().max(100).optional().describe(\n \"Max results to return (default 20).\",\n ),\n },\n async (args) => {\n try {\n return jsonResult(await searchContacts(args));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n\n server.tool(\n \"get_contact\",\n \"Fetch a single GoHighLevel contact by its id.\",\n {\n contactId: z.string().describe(\"The contact id to retrieve.\"),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async ({ contactId, locationId }) => {\n try {\n return jsonResult(await getContact(contactId, locationId));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n\n server.tool(\n \"create_contact\",\n \"Create a new GoHighLevel contact in a location.\",\n {\n firstName: z.string().optional(),\n lastName: z.string().optional(),\n name: z.string().optional().describe(\"Full name (alternative to first/last).\"),\n email: z.string().optional(),\n phone: z.string().optional().describe(\"E.164 format, e.g. +14155552671.\"),\n tags: z.array(z.string()).optional(),\n source: z.string().optional(),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async (args) => {\n try {\n return jsonResult(await createContact(args));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n\n server.tool(\n \"send_whatsapp_message\",\n \"Send a WhatsApp message to a contact via GoHighLevel conversations.\",\n {\n contactId: z.string().describe(\"The id of the contact to message.\"),\n message: z.string().describe(\"The message body to send.\"),\n templateId: z.string().optional().describe(\n \"Optional WhatsApp template id for templated messages.\",\n ),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async (args) => {\n try {\n return jsonResult(await sendWhatsAppMessage(args));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n\n server.tool(\n \"list_whatsapp_templates\",\n \"List WhatsApp templates available for a GoHighLevel location.\",\n {\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async ({ locationId }) => {\n try {\n return jsonResult(await listWhatsAppTemplates(locationId));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\nserver.tool(\n \"add_contact_tag\",\n \"Add tags to a GoHighLevel contact.\",\n {\n contactId: z.string().describe(\"The contact id.\"),\n tags: z.array(z.string()).describe(\"Tags to add.\"),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async ({ contactId, tags, locationId }) => {\n try {\n return jsonResult(await addContactTag(contactId, tags, locationId));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n server.tool(\n \"remove_contact_tag\",\n \"Remove tags from a GoHighLevel contact. Use it to clear operational tags \" +\n \"like revisar-agenda or retiro-revisar once the case is resolved.\",\n {\n contactId: z.string().describe(\"The contact id.\"),\n tags: z.array(z.string()).describe(\"Tags to remove.\"),\n locationId: z.string().optional().describe(\n `GHL location id. Defaults to ${DEFAULT_LOCATION_ID}.`,\n ),\n },\n async ({ contactId, tags, locationId }) => {\n try {\n return jsonResult(await removeContactTag(contactId, tags, locationId));\n } catch (err) {\n return errorResult(err);\n }\n },\n );\n\n return server;\n}","label",[134],"3f367f32-544c-4fab-8a89-f271bc6257a3",["D",1788043126379],[27],"40dad960-011b-473b-8e64-6067b9b67d4c","main.ts","4f1d5754-6b89-11f1-bdc5-1607ee4eb77e",43,["D",1787180036699],13,"http","// GoHighLevel MCP server over Streamable HTTP.\n// MCP endpoint: POST/GET/DELETE /mcp\n// Connect an MCP client (Claude, Cursor, etc.) to the /mcp URL of this val.\nimport { Hono } from \"npm:hono\";\nimport { HTTPException } from \"npm:hono/http-exception\";\nimport { StreamableHTTPTransport } from \"npm:@hono/mcp@0.1.5\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { buildServer } from \"./tools.ts\";\nimport {\n DEFAULT_LOCATION_ID,\n getToken,\n pingLocation,\n resolveLocation,\n TOPKREATIVA_LOCATION_ID,\n} from \"./ghl.ts\";\n\n/** Timing-safe-ish string compare (avoids leaking length via early exit). */\nfunction sameSecret(a: string, b: string): boolean {\n if (a.length !== b.length) return false;\n let diff = 0;\n for (let i = 0; i < a.length; i++) diff |= a.charCodeAt(i) ^ b.charCodeAt(i);\n return diff === 0;\n}\n\nconst app = new Hono();\n// HTTPExceptions (e.g. from the MCP transport) carry a JSON-RPC response —\n// render it. Re-raise everything else so Val Town logs the full stack trace.\napp.onError((err, c) => {\n if (err instanceof HTTPException) return err.getResponse();\n return Promise.reject(err);\n});\n\n// Simple landing page / health check.\napp.get(\"/\", (c) =>\n c.json({\n name: \"ghl-mcp\",\n description: \"GoHighLevel MCP server (Streamable HTTP)\",\n mcpEndpoint: \"/mcp\",\n defaultLocationId: DEFAULT_LOCATION_ID,\n tools: [\n \"search_contacts\",\n \"get_contact\",\n \"create_contact\",\n \"send_whatsapp_message\",\n \"list_whatsapp_templates\",\n ],\n source: parseVal().links.self.val,\n }));\n\n/**\n * Health check for the Torre de control / vigía.\n * Public on purpose: it reports whether each PIT still works but never reveals\n * the token itself. Lets GitHub Actions check GHL without holding a copy.\n * GET /salud -> { ok, ladys: {...}, topkreativa: {...} }\n */\napp.get(\"/salud\", async (c) => {\n const [ladys, topkreativa] = await Promise.all([\n pingLocation(DEFAULT_LOCATION_ID),\n pingLocation(TOPKREATIVA_LOCATION_ID),\n ]);\n const body = {\n ok: ladys.ok && topkreativa.ok,\n revisado: new Date().toISOString(),\n ladys: { locationId: DEFAULT_LOCATION_ID, ...ladys },\n topkreativa: { locationId: TOPKREATIVA_LOCATION_ID, ...topkreativa },\n };\n return c.json(body, body.ok ? 200 : 503);\n});\n\n/**\n * Token dispenser — the single source of truth for the GHL PIT.\n * Any system (GitHub Actions, scripts) asks for the token at runtime instead\n * of keeping its own copy, so rotating the PIT here fixes everything at once.\n *\n * GET /token?loc=ladys header x-torre-key: \n * GET /token?loc=topkreativa\n *\n * Requires the TORRE_KEY env var. Without it the route stays closed.\n */\napp.get(\"/token\", (c) => {\n // Each consumer gets its own key so one can be revoked without touching the\n // others: TORRE_KEY = GitHub Actions, TORRE_KEY_N8N = n8n workflows.\n const accepted = [\"TORRE_KEY\", \"TORRE_KEY_N8N\"]\n .map((n) => Deno.env.get(n))\n .filter((v): v is string => Boolean(v));\n if (accepted.length === 0) {\n return c.json({\n error: \"TORRE_KEY no configurada en este val — la ruta /token esta cerrada.\",\n }, 503);\n }\n const given = c.req.header(\"x-torre-key\") ??\n (c.req.header(\"authorization\") ?? \"\").replace(/^Bearer\\s+/i, \"\");\n if (!given || !accepted.some((k) => sameSecret(given, k))) {\n return c.json({ error: \"no autorizado\" }, 401);\n }\n const locationId = resolveLocation(c.req.query(\"loc\"));\n try {\n return c.json({ locationId, token: getToken(locationId) }, 200, {\n \"cache-control\": \"no-store\",\n });\n } catch (e) {\n return c.json({ error: (e as Error).message }, 500);\n }\n});\n\n/**\n * Proxy de lectura contra la API v2 de GHL, para diagnosticar sin escribir codigo nuevo.\n * GET /ghl?path=/workflows/&loc=ladys header x-torre-key: \n * Solo GET. Protegido con la misma TORRE_KEY que /token.\n */\napp.get(\"/ghl\", async (c) => {\n const validas = [Deno.env.get(\"TORRE_KEY\"), Deno.env.get(\"TORRE_KEY_N8N\")]\n .filter((x): x is string => !!x);\n const given = c.req.header(\"x-torre-key\") ?? \"\";\n if (!given || !validas.some((k) => sameSecret(given, k))) {\n return c.json({ error: \"no autorizado\" }, 401);\n }\n const path = c.req.query(\"path\") ?? \"\";\n if (!path.startsWith(\"/\")) return c.json({ error: \"path debe empezar con /\" }, 400);\n const locationId = resolveLocation(c.req.query(\"loc\"));\n const url = new URL(\"https://services.leadconnectorhq.com\" + path);\n if (!url.searchParams.has(\"locationId\")) {\n url.searchParams.set(\"locationId\", locationId);\n }\n try {\n const res = await fetch(url.toString(), {\n headers: {\n Authorization: `Bearer ${getToken(locationId)}`,\n Version: c.req.query(\"version\") ?? \"2021-07-28\",\n Accept: \"application/json\",\n },\n });\n const texto = await res.text();\n return c.json({ status: res.status, body: texto.slice(0, 60000) }, 200);\n } catch (e) {\n return c.json({ error: (e as Error).message }, 500);\n }\n});\n\n/**\n * Canal de aviso interno que NO depende de GHL.\n *\n * Por que existe: la sub-cuenta de Ladys no tiene numero telefonico propio\n * (phone-system/number-pools devuelve []), asi que los SMS quedan para siempre\n * en \"queued\", y WhatsApp solo permite texto libre dentro de las 24 h\n * siguientes al ultimo mensaje del destinatario (fuera de esa ventana GHL\n * responde 200 y luego marca el mensaje como \"failed\"). Tampoco hay plantillas\n * de WhatsApp aprobadas. Resultado: de noche, GHL no puede avisarle a nadie.\n *\n * Esta ruta manda el aviso por correo desde Val.town, que no tiene ventana de\n * 24 h ni saldo que se agote.\n *\n * POST /avisar header x-torre-key: \n * body { asunto?, texto, detalle? }\n */\napp.post(\"/avisar\", async (c) => {\n const validas = [Deno.env.get(\"TORRE_KEY\"), Deno.env.get(\"TORRE_KEY_N8N\")]\n .filter((x): x is string => !!x);\n const given = c.req.header(\"x-torre-key\") ?? \"\";\n if (!given || !validas.some((k) => sameSecret(given, k))) {\n return c.json({ error: \"no autorizado\" }, 401);\n }\n let body: { asunto?: string; texto?: string; detalle?: unknown };\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"body debe ser JSON\" }, 400);\n }\n const texto = (body.texto ?? \"\").toString().trim();\n if (!texto) return c.json({ error: \"falta 'texto'\" }, 400);\n const asunto = (body.asunto ?? \"Aviso Lady's\").toString().slice(0, 120);\n try {\n const { email } = await import(\"https://esm.town/v/std/email\");\n await email({\n subject: asunto,\n text: body.detalle\n ? `${texto}\\n\\n---\\n${JSON.stringify(body.detalle, null, 2)}`\n : texto,\n });\n return c.json({ ok: true, enviado: \"email\" });\n } catch (e) {\n return c.json({ ok: false, error: (e as Error).message }, 500);\n }\n});\n\n// MCP Streamable HTTP transport (stateless: a fresh server per request).\n// This pattern is serverless-friendly — no session state is kept between requests.\napp.all(\"/mcp\", async (c) => {\n // The transport strictly checks Content-Type / Accept on POST. Normalize the\n // incoming headers so clients that send a charset suffix (or omit the\n // text/event-stream accept) still work, then rebuild the request context.\n if (c.req.method === \"POST\") {\n const h = new Headers(c.req.raw.headers);\n h.set(\"Content-Type\", \"application/json\");\n h.set(\"Accept\", \"application/json, text/event-stream\");\n c.req.raw = new Request(c.req.raw.url, {\n method: \"POST\",\n headers: h,\n body: await c.req.raw.clone().arrayBuffer(),\n });\n }\n\n const server = buildServer();\n // enableJsonResponse: reply with a single JSON body instead of an SSE stream,\n // which is simpler and works in serverless/stateless environments.\n const transport = new StreamableHTTPTransport({ enableJsonResponse: true });\n await server.connect(transport);\n return transport.handleRequest(c);\n});\n\nexport default app.fetch;\n",[148],"2e6a1a33-35df-4b62-9097-01ac06a65c44","informe_ads_semanal.ts","0c43c484-a3d0-11f1-8756-1607ee4eb77e",86,["D",1788025007584],2,"interval","import { email } from \"https://esm.town/v/std/email\";\nimport { DEFAULT_LOCATION_ID, getToken } from \"./ghl.ts\";\n\nconst GHL = \"https://services.leadconnectorhq.com\";\nconst EL = \"https://admin.easylaundry.cl\";\nconst EL_MAIL = \"xlufix@gmail.com\";\nconst EL_PASS = \"Julieta7533#\";\nconst LOCAL = \"251\";\nconst UA = \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) Chrome/124 Safari/537.36\";\n\n/* ---------- utilidades ---------- */\nfunction norm(s: string): string {\n return String(s).toUpperCase()\n .normalize(\"NFD\").replace(/[\\u0300-\\u036f]/g, \"\")\n .replace(/[^A-Z\\s]/g, \" \").replace(/\\s+/g, \" \").trim();\n}\nconst clp = (n: number) => \"$\" + n.toLocaleString(\"es-CL\");\n\nfunction ck(res: Response, prev = \"\"): string {\n const m = new Map();\n for (const c of prev.split(\"; \").filter(Boolean)) {\n const i = c.indexOf(\"=\"); m.set(c.slice(0, i), c.slice(i + 1));\n }\n for (const raw of res.headers.getSetCookie?.() ?? []) {\n const f = raw.split(\";\")[0]; const i = f.indexOf(\"=\");\n if (i > 0) m.set(f.slice(0, i).trim(), f.slice(i + 1));\n }\n return [...m].map(([k, v]) => `${k}=${v}`).join(\"; \");\n}\nasync function ws(path: string, body: any, cookie: string) {\n const r = await fetch(EL + path, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Cookie\": cookie, \"User-Agent\": UA, \"X-Requested-With\": \"XMLHttpRequest\",\n },\n body: JSON.stringify(body),\n });\n return { text: await r.text(), cookie: ck(r, cookie) };\n}\n\n/* ---------- 1. leads de anuncios desde GHL ---------- */\nasync function traerLeads() {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = { Authorization: `Bearer ${tok}`, Version: \"2021-07-28\", Accept: \"application/json\" };\n const leads: any[] = [];\n let sid: string | null = null, sat: number | null = null;\n\n for (let p = 0; p < 10; p++) {\n let url = `${GHL}/contacts/?locationId=${DEFAULT_LOCATION_ID}&limit=100`;\n if (sid && sat) url += `&startAfterId=${sid}&startAfter=${sat}`;\n const r = await fetch(url, { headers: H });\n if (!r.ok) break;\n const cs = (await r.json()).contacts ?? [];\n if (!cs.length) break;\n for (const c of cs) {\n const at = (c.attributions ?? []).find((a: any) => a.isFirst) ?? (c.attributions ?? [])[0];\n if (!at) continue;\n if (!(at.utmSessionSource === \"Paid Social\" || at.utmAdId || at.adName)) continue;\n leads.push({\n nombre: (`${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`).trim() || c.contactName || \"\",\n tel: c.phone ?? \"\",\n creado: (c.dateAdded ?? \"\").slice(0, 10),\n anuncio: at.adName ?? \"(sin nombre)\",\n });\n }\n const u = cs[cs.length - 1];\n sid = u.id; sat = new Date(u.dateAdded).getTime();\n }\n return leads;\n}\n\n/* ---------- 2. ventas desde EasyLaundry ---------- */\nasync function traerVentas(desde: string, hasta: string) {\n const r0 = await fetch(EL + \"/\", { headers: { \"User-Agent\": UA } });\n await r0.text();\n let cookie = ck(r0);\n const lg = await ws(\"/WebServices.aspx/iniciarSesion\", { usr: EL_MAIL, pass: EL_PASS }, cookie);\n cookie = lg.cookie;\n const sl = await ws(\"/WebServices.aspx/SET_ID_LOCAL_GLOBAL\", { ID_LOCAL: LOCAL }, cookie);\n cookie = sl.cookie;\n\n const ventas = new Map();\n let d = new Date(desde + \"T00:00:00Z\");\n const fin = new Date(hasta + \"T00:00:00Z\");\n while (d <= fin) {\n const last = new Date(Date.UTC(d.getUTCFullYear(), d.getUTCMonth() + 1, 0));\n const f = last > fin ? fin : last;\n const r = await ws(\"/ws.aspx/OT_RETIRADAS_X_LOCAL_Traer_Periodo\",\n { FECHA_INICIO: d.toISOString().slice(0, 10), FECHA_TERMINO: f.toISOString().slice(0, 10) },\n cookie);\n try {\n const j = JSON.parse(r.text);\n const arr = j.d === \"\" ? [] : JSON.parse(j.d);\n for (const o of arr) {\n const n = norm(o.nombre ?? \"\");\n if (!n) continue;\n const raw = String(o.monto_total ?? \"\").replace(/<[^>]*>/g, \"\");\n const mm = parseInt(raw.replace(/[^\\d]/g, \"\"), 10);\n ventas.set(n, (ventas.get(n) ?? 0) + (isNaN(mm) ? 0 : mm));\n }\n } catch { }\n d = new Date(f.getTime() + 86400000);\n }\n return ventas;\n}\n\n/* ---------- 3. informe ---------- */\nexport default async function () {\n const hoy = new Date();\n const hasta = hoy.toISOString().slice(0, 10);\n const d90 = new Date(hoy.getTime() - 90 * 86400000).toISOString().slice(0, 10);\n const d7 = new Date(hoy.getTime() - 7 * 86400000).toISOString().slice(0, 10);\n\n const leads = await traerLeads();\n const ventas = await traerVentas(d90, hasta);\n const nombresVenta = [...ventas.keys()];\n\n const convertidos: any[] = [];\n for (const l of leads) {\n const ln = norm(l.nombre);\n const partes = ln.split(\" \").filter(p => p.length > 2);\n if (partes.length < 2) continue;\n const hit = nombresVenta.find(nv => {\n const pv = nv.split(\" \").filter(p => p.length > 2);\n return partes.filter(p => pv.includes(p)).length >= 2;\n });\n if (hit) convertidos.push({ ...l, facturado: ventas.get(hit)! });\n }\n\n const semana = leads.filter(l => l.creado >= d7);\n const convSemana = convertidos.filter(c => c.creado >= d7);\n\n const porAnuncio: Record = {};\n for (const l of leads) {\n porAnuncio[l.anuncio] ??= { leads: 0, conv: 0, fact: 0 };\n porAnuncio[l.anuncio].leads++;\n }\n for (const c of convertidos) {\n porAnuncio[c.anuncio].conv++;\n porAnuncio[c.anuncio].fact += c.facturado;\n }\n\n const filas = Object.entries(porAnuncio)\n .sort((a: any, b: any) => b[1].fact - a[1].fact)\n .map(([n, a]: any) => {\n const tasa = a.leads ? (a.conv / a.leads * 100).toFixed(1) : \"0\";\n const color = a.conv === 0 ? \"#B3446B\" : Number(tasa) >= 7 ? \"#2E7D32\" : \"#8A6078\";\n return `\n ${n}\n ${a.leads}\n ${a.conv}\n ${tasa}%\n ${clp(a.fact)}\n `;\n }).join(\"\");\n\n const nuevos = convSemana.length\n ? convSemana.map(c =>\n `

${c.nombre} — ${clp(c.facturado)} · ${c.anuncio}

`\n ).join(\"\")\n : `

Ninguno esta semana

`;\n\n const factTotal = convertidos.reduce((a, c) => a + c.facturado, 0);\n const tasaG = leads.length ? (convertidos.length / leads.length * 100).toFixed(1) : \"0\";\n\n const html = `\n

\n Ladys Lavandería · Informe semanal de publicidad

Anuncios → clientes → plata

\n Semana al ${hasta} · ventana de análisis 90 días

\n\n

${semana.length}

leads esta semana

${convSemana.length}

convirtieron

${tasaG}%

conversión global

\n\n

Clientes nuevos de esta semana

${nuevos}\n\n

Rendimiento por anuncio (90 días)

\n \n \n \n \n \n \n \n \n ${filas}\n \n \n \n \n \n \n \n

Anuncio	Leads	Clientes	Tasa	Facturado
TOTAL	${leads.length}	${convertidos.length}	${tasaG}%	${clp(factTotal)}

\n\n

\n Cómo leerlo: un anuncio con muchos leads y pocos clientes atrae curiosos, no compradores.\n Bajo 3% conviene revisarlo o apagarlo. Sobre 7% conviene subirle presupuesto.

\n El cruce se hace por nombre entre GHL y EasyLaundry, así que las cifras son un piso:\n quien se registró con apodo no aparece.\n

`;\n\n await email({\n subject: `Ladys · Publicidad: ${semana.length} leads, ${convSemana.length} clientes nuevos`,\n html,\n });\n\n return { leads: leads.length, convertidos: convertidos.length, facturado: factTotal };\n}\n",[157],"f2c4f45c-82e4-40f9-bec5-0e3bc8c60fa4","ghl.ts","ef203a54-6b8a-11f1-8fca-1607ee4eb77e",69,["D",1787578022096],15,"// GoHighLevel (LeadConnector) API client\n// Docs: https://highlevel.stoplight.io/docs/integrations\n\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst VERSION = \"2021-07-28\";\nexport const DEFAULT_LOCATION_ID = \"o1V9sCKjH5Ywd9PRURj0\";\nexport const TOPKREATIVA_LOCATION_ID = \"SevVprqYc2lE6O92KLwY\";\n\n/**\n * Which env vars hold the Private Integration Token for each sub-account,\n * in order of preference. PIT_* are the current names; GHL_TOKEN_* are kept\n * as a fallback so nothing breaks while the old values are still around.\n */\nconst TOKEN_ENV_BY_LOCATION: Record = {\n [DEFAULT_LOCATION_ID]: [\"PIT_LADYS_V2\", \"PIT_LADYS\", \"GHL_TOKEN_LADYS\"],\n [TOPKREATIVA_LOCATION_ID]: [\n \"PIT_TOPKREATIVA_V3\",\n \"PIT_TOPKREATIVA\",\n \"PIT_TOPKREATIVA_V2\",\n \"GHL_TOKEN_TOPKREATIVA\",\n ],\n};\n\nfunction apiKey(locationId?: string): string {\n const loc = locationId ?? DEFAULT_LOCATION_ID;\n const names = TOKEN_ENV_BY_LOCATION[loc] ?? [];\n let key: string | undefined;\n for (const n of names) {\n key = Deno.env.get(n);\n if (key) break;\n }\n key = key ?? Deno.env.get(\"GHL_API_KEY\");\n if (!key) {\n throw new Error(\n `Missing Private Integration Token for location ${loc}. Set ${\n names[0] ?? \"GHL_API_KEY\"\n } in the Val Town environment-variables page.`,\n );\n }\n return key;\n}\n\n/**\n * Resolve the sub-account name (\"ladys\" | \"topkreativa\") or a raw locationId\n * into a locationId. Used by the /token and /salud routes.\n */\nexport function resolveLocation(name?: string): string {\n const n = (name ?? \"\").trim().toLowerCase();\n if (!n || n === \"ladys\" || n === \"default\") return DEFAULT_LOCATION_ID;\n if (n === \"topkreativa\" || n === \"tk\") return TOPKREATIVA_LOCATION_ID;\n return name!;\n}\n\n/** Public accessor for the Private Integration Token of a sub-account. */\nexport function getToken(locationId?: string): string {\n return apiKey(locationId);\n}\n\n/**\n * Ping GHL with the stored token for a location. Never returns the token —\n * only whether it still works, so this is safe to expose publicly.\n */\nexport async function pingLocation(\n locationId?: string,\n): Promise<{ ok: boolean; status: number; detail?: string }> {\n const loc = locationId ?? DEFAULT_LOCATION_ID;\n let token: string;\n try {\n token = apiKey(loc);\n } catch (e) {\n return { ok: false, status: 0, detail: (e as Error).message };\n }\n try {\n const res = await fetch(\n `${BASE}/contacts/?locationId=${encodeURIComponent(loc)}&limit=1`,\n {\n headers: {\n Authorization: `Bearer ${token}`,\n Version: VERSION,\n Accept: \"application/json\",\n },\n },\n );\n return {\n ok: res.ok,\n status: res.status,\n detail: res.ok ? undefined : res.statusText,\n };\n } catch (e) {\n return { ok: false, status: 0, detail: (e as Error).message };\n }\n}\n\nfunction headers(locationId?: string): HeadersInit {\n return {\n Authorization: `Bearer ${apiKey(locationId)}`,\n Version: VERSION,\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n}\n\nasync function ghlFetch(\n path: string,\n init: RequestInit = {},\n locationId?: string,\n): Promise {\n const res = await fetch(`${BASE}${path}`, {\n ...init,\n headers: { ...headers(locationId), ...(init.headers ?? {}) },\n });\n const text = await res.text();\n let data: unknown;\n try {\n data = text ? JSON.parse(text) : null;\n } catch {\n data = text;\n }\n if (!res.ok) {\n throw new Error(\n `GHL API ${res.status} ${res.statusText}: ${\n typeof data === \"string\" ? data : JSON.stringify(data)\n }`,\n );\n }\n return data;\n}\n\nexport interface SearchContactsArgs {\n query?: string;\n locationId?: string;\n limit?: number;\n}\n\n/** Search contacts by free-text query within a location. */\nexport function searchContacts(args: SearchContactsArgs): Promise {\n const locationId = args.locationId ?? DEFAULT_LOCATION_ID;\n const params = new URLSearchParams({ locationId });\n if (args.query) params.set(\"query\", args.query);\n params.set(\"limit\", String(args.limit ?? 20));\n return ghlFetch(`/contacts/?${params.toString()}`, {}, locationId);\n}\n\n/** Fetch a single contact by its id. */\nexport function getContact(\n contactId: string,\n locationId?: string,\n): Promise {\n return ghlFetch(\n `/contacts/${encodeURIComponent(contactId)}`,\n {},\n locationId,\n );\n}\n\nexport interface CreateContactArgs {\n locationId?: string;\n firstName?: string;\n lastName?: string;\n name?: string;\n email?: string;\n phone?: string;\n tags?: string[];\n source?: string;\n}\n\n/** Create a new contact in a location. */\nexport function createContact(args: CreateContactArgs): Promise {\n const locationId = args.locationId ?? DEFAULT_LOCATION_ID;\n const body = {\n locationId,\n firstName: args.firstName,\n lastName: args.lastName,\n name: args.name,\n email: args.email,\n phone: args.phone,\n tags: args.tags,\n source: args.source,\n };\n return ghlFetch(`/contacts/`, {\n method: \"POST\",\n body: JSON.stringify(body),\n }, locationId);\n}\n\nexport interface SendWhatsAppArgs {\n contactId: string;\n message: string;\n /** Optional template id when sending a templated WhatsApp message. */\n templateId?: string;\n /** Sub-account the contact belongs to. Defaults to Ladys. */\n locationId?: string;\n}\n\n/** Send a WhatsApp message to a contact through GHL conversations. */\nexport function sendWhatsAppMessage(args: SendWhatsAppArgs): Promise {\n const body: Record = {\n type: \"WhatsApp\",\n contactId: args.contactId,\n message: args.message,\n };\n if (args.templateId) body.templateId = args.templateId;\n return ghlFetch(`/conversations/messages`, {\n method: \"POST\",\n body: JSON.stringify(body),\n }, args.locationId);\n}\n\n/**\n * List WhatsApp templates available for a location.\n *\n * GHL v2 exposes templates through the location templates endpoint filtered by\n * `originId` (the WhatsApp provider/integration) and `deleted=false`. We pass\n * `type=whatsapp` so only WhatsApp message templates come back.\n */\nexport function listWhatsAppTemplates(locationId?: string): Promise {\n const loc = locationId ?? DEFAULT_LOCATION_ID;\n const params = new URLSearchParams({\n originId: loc,\n deleted: \"false\",\n type: \"whatsapp\",\n });\n return ghlFetch(\n `/locations/${encodeURIComponent(loc)}/templates?${params.toString()}`,\n {},\n loc,\n );\n}\n\n/** Remove tags from a contact. */\nexport function removeContactTag(\n contactId: string,\n tags: string[],\n locationId?: string,\n): Promise {\n return ghlFetch(`/contacts/${encodeURIComponent(contactId)}/tags`, {\n method: \"DELETE\",\n body: JSON.stringify({ tags }),\n }, locationId);\n}\n\n/** Add tags to a contact. */\nexport function addContactTag(\n contactId: string,\n tags: string[],\n locationId?: string,\n): Promise {\n return ghlFetch(`/contacts/${encodeURIComponent(contactId)}/tags`, {\n method: \"POST\",\n body: JSON.stringify({ tags }),\n }, locationId);\n}",[166],"9483d769-52f0-44da-8489-953150d41cc1","fix-primary.ts","a837cc6e-a3ee-11f1-a672-1607ee4eb77e",91,["D",1788038091417],1,"const AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst PIT = Deno.env.get(\"PIT_LADYS_V2\")!;\nconst H = { Authorization: \"Bearer \" + PIT, Version: \"2021-07-28\", \"Content-Type\": \"application/json\", Accept: \"application/json\" };\nconst URL_ = `https://services.leadconnectorhq.com/conversation-ai/agents/${AGENT}`;\n\nconst g = await fetch(URL_, { headers: H });\nconst cur = (await g.json());\nconst a = cur.agent ?? cur.data ?? cur;\nconsole.log(\"ANTES isPrimary =\", a.isPrimary, \"| instrucciones:\", String(a.instructions ?? \"\").length, \"chars\");\n\nconst body: any = { ...a, isPrimary: true };\nfor (const k of [\"traceId\",\"id\",\"_id\",\"emailSettings\",\"knowledgeBaseTriggers\",\"summary\"]) delete body[k];\n\nconst p = await fetch(URL_, { method: \"PUT\", headers: H, body: JSON.stringify(body) });\nconsole.log(\"PUT ->\", p.status, (await p.text()).slice(0, 200));\n\nconst g2 = await fetch(URL_, { headers: H });\nconst c2 = await g2.json();\nconst b = c2.agent ?? c2.data ?? c2;\nconsole.log(\"DESPUES isPrimary =\", b.isPrimary, \"| mode:\", b.mode, \"| canales:\", JSON.stringify(b.channels), \"| instrucciones:\", String(b.instructions ?? \"\").length, \"chars\");\n",[174],"235a29f8-8f01-45e5-ab1b-87bab5ad14c0","diag-sofia.ts","96a46c14-a3ee-11f1-b569-1607ee4eb77e",87,["D",1788038054968],"const LOC = \"o1V9sCKjH5Ywd9PRURj0\";\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\n\nconst cands: [string, string][] = [\n [\"PIT_LADYS\", Deno.env.get(\"PIT_LADYS\") ?? \"\"],\n [\"PIT_LADYS_V2\", Deno.env.get(\"PIT_LADYS_V2\") ?? \"\"],\n [\"GHL_API_KEY_LADYS\", Deno.env.get(\"GHL_API_KEY_LADYS\") ?? \"\"],\n [\"SKILL_HARDCODED\", \"pit-7cdd6c37-c485-42b4-a557-644beb7d2b02\"],\n];\n\nasync function call(tok: string, url: string, ver = \"2021-07-28\") {\n try {\n const r = await fetch(url, {\n headers: { Authorization: \"Bearer \" + tok, Version: ver, Accept: \"application/json\" },\n });\n const t = await r.text();\n let j: any = null;\n try { j = JSON.parse(t); } catch { j = t.slice(0, 300); }\n return { status: r.status, body: j };\n } catch (e) {\n return { status: 0, body: String(e) };\n }\n}\n\nconsole.log(\"=== 1. QUE TOKEN SIRVE ===\");\nlet PIT = \"\";\nconst seen: Record = {};\nfor (const [name, tok] of cands) {\n if (!tok) { console.log(name.padEnd(20), \"vacio\"); continue; }\n const tail = tok.slice(-6);\n const r = await call(tok, `https://services.leadconnectorhq.com/locations/${LOC}`);\n console.log(name.padEnd(20), \"...\", tail, \"->\", r.status);\n seen[tail] = name;\n if (r.status === 200 && !PIT) PIT = tok;\n}\nif (!PIT) { console.log(\"NINGUN TOKEN AUTENTICA — fin\"); }\nelse {\n console.log(\"\\n=== 2. AGENTE SofIA ===\");\n const ag = await call(PIT, `https://services.leadconnectorhq.com/conversation-ai/agents/${AGENT}`);\n console.log(\"HTTP\", ag.status);\n let a: any = ag.body?.agent ?? ag.body?.data ?? ag.body;\n if (a && typeof a === \"object\") {\n for (const k of [\"name\",\"isPrimary\",\"status\",\"isActive\",\"enabled\",\"mode\",\"autoPilot\",\"supportedChannels\",\"channels\",\"waitTime\",\"messageDelay\",\"isDeleted\"]) {\n if (k in a) console.log(\" \", k.padEnd(20), JSON.stringify(a[k]).slice(0, 250));\n }\n console.log(\" claves:\", Object.keys(a).join(\", \").slice(0, 500));\n } else console.log(JSON.stringify(ag.body).slice(0, 400));\n\n console.log(\"\\n=== 3. TODOS LOS AGENTES ===\");\n const all = await call(PIT, `https://services.leadconnectorhq.com/conversation-ai/agents?locationId=${LOC}`);\n console.log(\"HTTP\", all.status);\n const list = all.body?.agents ?? all.body?.data ?? [];\n if (Array.isArray(list)) for (const x of list) {\n console.log(\" \", String(x.name).padEnd(24), \"id=\", x._id ?? x.id, \"primary=\", x.isPrimary, \"status=\", x.status ?? x.isActive);\n } else console.log(JSON.stringify(all.body).slice(0, 400));\n\n console.log(\"\\n=== 4. ULTIMAS CONVERSACIONES ===\");\n const cv = await call(PIT, `https://services.leadconnectorhq.com/conversations/search?locationId=${LOC}&limit=25&sortBy=last_message_date&sort=desc`);\n console.log(\"HTTP\", cv.status);\n const convs = cv.body?.conversations ?? [];\n let mudas: any[] = [];\n for (const c of convs) {\n const d = new Date(Number(c.lastMessageDate) || Date.parse(c.lastMessageDate));\n const ts = isNaN(d.getTime()) ? String(c.lastMessageDate) : d.toISOString().slice(5, 16).replace(\"T\", \" \");\n console.log(` [${ts}] ${String(c.fullName ?? \"\").slice(0,20).padEnd(20)} ${String(c.lastMessageType).padEnd(14)} dir=${String(c.lastMessageDirection).padEnd(9)} unread=${c.unreadCount}`);\n console.log(\" >\", String(c.lastMessageBody ?? \"\").replace(/\\n/g, \" \").slice(0, 100));\n if (c.lastMessageDirection === \"inbound\") mudas.push(c);\n }\n console.log(`\\n=== 5. MUDAS: ${mudas.length}/${convs.length} conversaciones quedaron con el cliente hablando ultimo ===`);\n for (const c of mudas.slice(0, 12)) {\n const ct = await call(PIT, `https://services.leadconnectorhq.com/contacts/${c.contactId}`);\n const tags = ct.body?.contact?.tags ?? [];\n console.log(\" \", String(c.fullName ?? \"\").slice(0,20).padEnd(20), \"canal=\", String(c.lastMessageType).padEnd(14), \"tags=\", JSON.stringify(tags));\n }\n}\n",[182],"fe9efa43-9f08-4c3f-a4ef-2614e6ac8ec1","README.md","5aa39118-6b8b-11f1-9a66-1607ee4eb77e",30,["D",1786916091360],"# ghl-mcp\n\nServidor **MCP (Model Context Protocol)** con transporte **Streamable HTTP** que\nexpone la API de **GoHighLevel** (LeadConnector) como herramientas para clientes\nMCP (Claude, Cursor, etc.).\n\n## Endpoint MCP\n\n```\nPOST https://LUFI--4f1d57546b8911f1bdc51607ee4eb77e.web.val.run/mcp\n```\n\nConecta cualquier cliente MCP a esa URL `/mcp`. El servidor funciona en modo\n*stateless* (un servidor MCP nuevo por petición), ideal para entornos serverless.\n\n## Fuente única del token (Torre de control)\n\nEl PIT de GHL vive **solo aquí**. Los demás sistemas (GitHub Actions, scripts)\nlo piden en tiempo de ejecución en vez de guardar su propia copia, así rotarlo\nen este val arregla todo de una vez.\n\n```\nGET /salud\n```\n\nPúblico, no revela el token: dice si cada PIT sigue vivo.\n`200` si ambos responden, `503` si alguno falla.\n\n```\nGET /token?loc=ladys -H \"x-torre-key: $TORRE_KEY\"\nGET /token?loc=topkreativa -H \"x-torre-key: $TORRE_KEY\"\n```\n\nDevuelve `{ locationId, token }`. Requiere la variable de entorno `TORRE_KEY`;\nsin ella la ruta responde `503` y queda cerrada.\n\n👉 Add TORRE_KEY here: https://www.val.town/x/LUFI/ghl-mcp/environment-variables?key=TORRE_KEY\n\nEjemplo en un workflow de GitHub Actions:\n\n```yaml\n- name: Obtener PIT de GHL desde el val\n run: |\n TOKEN=$(curl -sf -H \"x-torre-key: ${{ secrets.TORRE_KEY }}\" \\\n \"https://LUFI--4f1d57546b8911f1bdc51607ee4eb77e.web.val.run/token?loc=ladys\" \\\n | python3 -c \"import sys,json;print(json.load(sys.stdin)['token'])\")\n echo \"::add-mask::$TOKEN\"\n echo \"GHL_PIT_TOKEN=$TOKEN\" >> \"$GITHUB_ENV\"\n```\n\n## Herramientas disponibles\n\n| Herramienta | Descripción |\n|---|---|\n| `search_contacts` | Busca contactos por texto libre (`query`, `locationId`, `limit`). |\n| `get_contact` | Obtiene un contacto por `contactId`. |\n| `create_contact` | Crea un contacto (`firstName`, `lastName`, `email`, `phone`, `tags`…). |\n| `send_whatsapp_message` | Envía un WhatsApp a un contacto (`contactId`, `message`, `templateId?`). |\n| `list_whatsapp_templates` | Lista las plantillas de WhatsApp de una location. |\n\nEl `locationId` por defecto es `o1V9sCKjH5Ywd9PRURj0` y puede sobrescribirse en\ncada llamada.\n\n## Configuración\n\nRequiere la variable de entorno `GHL_API_KEY` — una clave de **Private\nIntegrations** de GoHighLevel (Settings → Integrations → Private Integrations),\nno una API key normal.\n\n👉 Add GHL_API_KEY here: https://www.val.town/x/LUFI/ghl-mcp/environment-variables?key=GHL_API_KEY\n\n## Arquitectura\n\n```mermaid\nflowchart LR\n Client[\"Cliente MCP
(Claude / Cursor)\"] -->|JSON-RPC sobre HTTP| MCP[\"/mcp
StreamableHTTPTransport\"]\n MCP --> Server[\"McpServer
(tools.ts)\"]\n Server --> GHL[\"Cliente GHL
(ghl.ts)\"]\n GHL -->|Bearer GHL_API_KEY| API[\"services.leadconnectorhq.com\"]\n```\n\n## Archivos\n\n- `main.ts` — servidor HTTP + transporte Streamable HTTP del MCP.\n- `tools.ts` — definición de las 5 herramientas MCP con esquemas Zod.\n- `ghl.ts` — cliente de la API de GoHighLevel.\n\n## Probar manualmente\n\n```bash\n# Listar herramientas\ncurl -X POST https://LUFI--4f1d57546b8911f1bdc51607ee4eb77e.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Accept: application/json, text/event-stream\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"tools/list\",\"params\":{}}'\n\n# Buscar contactos\ncurl -X POST https://LUFI--4f1d57546b8911f1bdc51607ee4eb77e.web.val.run/mcp \\\n -H \"Content-Type: application/json\" \\\n -H \"Accept: application/json, text/event-stream\" \\\n -d '{\"jsonrpc\":\"2.0\",\"id\":2,\"method\":\"tools/call\",\"params\":{\"name\":\"search_contacts\",\"arguments\":{\"query\":\"juan\",\"limit\":5}}}'\n```\n",[189],"a289f76a-008f-43ec-bd28-39fe0ce905d0","tmp","a1cefed1-8c8f-43bd-9d06-bed5d085dedc",63,["D",1787263007008],"directory",[196],"pulls","branches","forks","envVars",{"_209":152,"_211":61},"connections",{"_209":61,"_210":61},"count","unfilledCount","emptyCount",{"_41":195,"_31":196,"_29":197,"_136":-5,"_39":40,"_38":198,"_138":57,"_36":372,"_13":61,"_32":200,"_34":-5,"_23":24,"_142":-5,"_236":373,"_26":374},{"_41":364,"_31":365,"_29":366,"_136":197,"_39":40,"_38":367,"_138":24,"_36":368,"_13":61,"_32":33,"_34":369,"_23":24,"_142":-5,"_236":370,"_26":371},{"_41":356,"_31":357,"_29":358,"_136":197,"_39":40,"_38":359,"_138":57,"_36":360,"_13":178,"_32":153,"_34":361,"_23":24,"_142":-5,"_236":362,"_26":363},{"_41":348,"_31":349,"_29":350,"_136":197,"_39":40,"_38":351,"_138":24,"_36":352,"_13":61,"_32":33,"_34":353,"_23":24,"_142":-5,"_236":354,"_26":355},{"_41":340,"_31":341,"_29":342,"_136":197,"_39":40,"_38":343,"_138":24,"_36":344,"_13":61,"_32":33,"_34":345,"_23":24,"_142":-5,"_236":346,"_26":347},{"_41":331,"_31":332,"_29":333,"_136":197,"_39":40,"_38":334,"_138":57,"_36":335,"_13":336,"_32":33,"_34":337,"_23":24,"_142":-5,"_236":338,"_26":339},{"_41":324,"_31":325,"_29":55,"_136":197,"_39":40,"_38":326,"_138":57,"_36":327,"_13":61,"_32":153,"_34":328,"_23":24,"_142":-5,"_236":329,"_26":330},{"_41":316,"_31":317,"_29":318,"_136":197,"_39":40,"_38":319,"_138":57,"_36":320,"_13":61,"_32":153,"_34":321,"_23":24,"_142":-5,"_236":322,"_26":323},{"_41":308,"_31":309,"_29":310,"_136":197,"_39":40,"_38":311,"_138":57,"_36":312,"_13":178,"_32":153,"_34":313,"_23":24,"_142":-5,"_236":314,"_26":315},{"_41":300,"_31":301,"_29":302,"_136":197,"_39":40,"_38":303,"_138":57,"_36":304,"_13":61,"_32":153,"_34":305,"_23":24,"_142":-5,"_236":306,"_26":307},{"_41":292,"_31":293,"_29":294,"_136":197,"_39":40,"_38":295,"_138":57,"_36":296,"_13":61,"_32":153,"_34":297,"_23":24,"_142":-5,"_236":298,"_26":299},{"_41":284,"_31":285,"_29":286,"_136":197,"_39":40,"_38":287,"_138":57,"_36":288,"_13":61,"_32":153,"_34":289,"_23":24,"_142":-5,"_236":290,"_26":291},{"_41":276,"_31":277,"_29":278,"_136":197,"_39":40,"_38":279,"_138":57,"_36":280,"_13":61,"_32":153,"_34":281,"_23":24,"_142":-5,"_236":282,"_26":283},{"_41":268,"_31":269,"_29":270,"_136":197,"_39":40,"_38":271,"_138":57,"_36":272,"_13":61,"_32":153,"_34":273,"_23":24,"_142":-5,"_236":274,"_26":275},{"_41":260,"_31":261,"_29":262,"_136":197,"_39":40,"_38":263,"_138":57,"_36":264,"_13":178,"_32":153,"_34":265,"_23":24,"_142":-5,"_236":266,"_26":267},{"_41":188,"_31":189,"_29":190,"_136":-5,"_39":40,"_38":191,"_138":57,"_36":257,"_13":178,"_32":20,"_34":193,"_23":24,"_142":-5,"_236":258,"_26":259},{"_41":181,"_31":182,"_29":183,"_136":-5,"_39":40,"_38":184,"_138":57,"_36":254,"_13":61,"_32":33,"_34":186,"_23":24,"_142":-5,"_236":255,"_26":256},{"_41":173,"_31":174,"_29":175,"_136":-5,"_39":40,"_38":176,"_138":57,"_36":251,"_13":178,"_32":33,"_34":179,"_23":24,"_142":-5,"_236":252,"_26":253},{"_41":165,"_31":166,"_29":167,"_136":-5,"_39":40,"_38":168,"_138":24,"_36":248,"_13":170,"_32":33,"_34":171,"_23":24,"_142":-5,"_236":249,"_26":250},{"_41":156,"_31":157,"_29":158,"_136":-5,"_39":40,"_38":159,"_138":57,"_36":245,"_13":161,"_32":162,"_34":163,"_23":24,"_142":-5,"_236":246,"_26":247},{"_41":147,"_31":148,"_29":149,"_136":-5,"_39":40,"_38":150,"_138":57,"_36":242,"_13":152,"_32":153,"_34":154,"_23":24,"_142":-5,"_236":243,"_26":244},{"_41":144,"_31":27,"_29":30,"_136":-5,"_39":40,"_38":14,"_138":57,"_36":239,"_13":61,"_32":33,"_34":35,"_23":24,"_142":-5,"_236":240,"_26":241},{"_41":133,"_31":134,"_29":135,"_136":-5,"_39":40,"_38":137,"_138":57,"_36":235,"_13":140,"_32":33,"_34":141,"_23":24,"_142":-5,"_236":237,"_26":238},["D",1786934288897],"children",[],[134],["D",1788043126379],[],[27],["D",1787180036699],[],[148],["D",1788025007584],[],[157],["D",1787578022096],[],[166],["D",1788038091417],[],[174],["D",1788038054968],[],[182],["D",1786916091360],[],[189],"3318a27e-42e7-4a9f-836b-0215ac2d4005","telefonos_club.ts","a6193c14-a331-11f1-bf9d-1607ee4eb77e",78,["D",1787956932293],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nconst BUSCAR = [\n \"sergio manriquez\", \"sergio mancilla\", \"miguel zarate\", \"fernando berndt\",\n \"pablo pradines\", \"natalie torres\", \"gonzalo contreras\", \"manuel silva\",\n \"cecilia milla\", \"claudio morales\", \"joaquin morales\", \"mario herrera\",\n \"paola duarte\", \"daniela rivas\", \"mireya quitral\",\n];\n\nexport default async function (): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n };\n\n const out: any[] = [];\n for (const q of BUSCAR) {\n const url = `${BASE}/contacts/?locationId=${DEFAULT_LOCATION_ID}` +\n `&query=${encodeURIComponent(q)}&limit=10`;\n const r = await fetch(url, { headers: H });\n if (!r.ok) { out.push({ q, error: r.status }); continue; }\n const j = await r.json();\n const partes = q.split(\" \");\n const cs = (j.contacts ?? [])\n .map((c: any) => ({\n nombre: (`${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`.trim() ||\n c.contactName || \"\").toLowerCase(),\n tel: c.phone ?? null,\n id: c.id,\n }))\n .filter((c: any) => c.tel && partes.every((p) => c.nombre.includes(p)));\n out.push({ q, encontrado: cs.length > 0, match: cs.slice(0, 3) });\n }\n return new Response(JSON.stringify(out), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n",[],[196,261],"b1e9365e-28cc-4188-80f0-c33532bcf5e2","sofia_hogar_basico.ts","22a49274-a32d-11f1-b5fc-1607ee4eb77e",76,["D",1787954967515],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nexport default async function (): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const g = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, { headers: H });\n if (!g.ok) {\n return new Response(JSON.stringify({ paso: \"leer\", status: g.status }), { status: 500 });\n }\n const ag = await g.json();\n let ins = String(ag.instructions ?? \"\");\n const antes = ins.length;\n\n const reemplazos: [string, string][] = [\n [\"1) CLUB HOGAR - $100.000/mes\", \"1) CLUB HOGAR BASICO - $100.000/mes\"],\n [\"ofrece el Club Hogar.\", \"ofrece el Club Hogar Basico.\"],\n [\"o la deja en el locker si es plan Hogar\", \"o la deja en el locker si es plan Hogar Basico\"],\n [\n \"En los planes Hogar y Domicilio los cobertores\",\n \"En los planes Hogar Basico y Domicilio los cobertores\",\n ],\n ];\n const aplicados: string[] = [];\n for (const [a, b] of reemplazos) {\n if (ins.includes(a)) { ins = ins.replaceAll(a, b); aplicados.push(a.slice(0, 42)); }\n }\n\n if (!ins.includes(\"Links de pago directo\")) {\n ins = ins.replace(\n \"SI EL CLIENTE MUESTRA INTERES EN EL CLUB:\",\n `LINKS DE PAGO (Links de pago directo de MercadoPago - suscripcion con cargo automatico mensual):\nClub Hogar Basico $100.000: https://mpago.la/1R6vgN6\nClub Domicilio $150.000: https://mpago.la/1sZ9Z4u\nClub Total $200.000: https://mpago.la/23AbQZh\nComparte el link de pago SOLO cuando el cliente ya confirmo que quiere ese plan. Antes de eso comparte la pagina https://ladyslavanderia.cl/club para que revise las opciones. Al pagar, el cliente llega automaticamente a su pagina de bienvenida con las instrucciones.\n\nSI EL CLIENTE MUESTRA INTERES EN EL CLUB:`,\n );\n aplicados.push(\"bloque links de pago\");\n }\n\n const put = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, {\n method: \"PUT\",\n headers: H,\n body: JSON.stringify({\n name: ag.name,\n businessName: ag.businessName,\n isPrimary: ag.isPrimary ?? true,\n personality: ag.personality,\n goal: ag.goal,\n instructions: ins,\n }),\n });\n\n return new Response(JSON.stringify({\n aplicados,\n largo: { antes, despues: ins.length },\n put_status: put.status,\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,269],"a6b601b5-bdd4-4ad9-b2ce-095c5a5927b2","sofia_fecha31.ts","987664aa-a3c3-11f1-8e01-1607ee4eb77e",80,["D",1788019589694],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nexport default async function (): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const g = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, { headers: H });\n if (!g.ok) return new Response(JSON.stringify({ status: g.status }), { status: 500 });\n const ag = await g.json();\n let ins = String(ag.instructions ?? \"\");\n const hechos: string[] = [];\n\n const cambios: [string, string][] = [\n [\"hasta el 15 de septiembre de 2026\", \"hasta el 31 de agosto de 2026\"],\n [\"hasta el 15 de septiembre (despues $50.000)\", \"hasta el 31 de agosto (despues $50.000)\"],\n ];\n for (const [a, b] of cambios) {\n if (ins.includes(a)) { ins = ins.replaceAll(a, b); hechos.push(a); }\n }\n\n const put = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, {\n method: \"PUT\",\n headers: H,\n body: JSON.stringify({\n name: ag.name,\n businessName: ag.businessName,\n isPrimary: ag.isPrimary ?? true,\n personality: ag.personality,\n goal: ag.goal,\n instructions: ins,\n }),\n });\n\n return new Response(JSON.stringify({ hechos, put_status: put.status }, null, 1),\n { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,277],"f5446e9a-608b-4f0b-9b2d-82688a61d50a","sofia_cupos.ts","cd95a9f0-a33e-11f1-96b5-1607ee4eb77e",79,["D",1787962555627],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nexport default async function (): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const g = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, { headers: H });\n if (!g.ok) return new Response(JSON.stringify({ paso: \"leer\", status: g.status }), { status: 500 });\n const ag = await g.json();\n let ins = String(ag.instructions ?? \"\");\n const antes = ins.length;\n const hechos: string[] = [];\n\n const cambios: [string, string][] = [\n [\n \"Incorporacion $0 hasta el 31 de agosto de 2026. Despues son $50.000. Este es el argumento de urgencia principal.\",\n \"PRIMERA TANDA: solo 10 membresias fundadoras disponibles. Cuando se llenen, se cierra el Club hasta que la capacidad operativa permita abrir mas cupos. Incorporacion $0 hasta el 15 de septiembre de 2026; despues son $50.000. La escasez de cupos es el argumento de urgencia principal, mas que la fecha.\",\n ],\n [\n \"Incorporacion gratis hasta el 31 de agosto (despues $50.000)\",\n \"Incorporacion gratis hasta el 15 de septiembre (despues $50.000) y solo quedan cupos de las 10 membresias fundadoras\",\n ],\n ];\n for (const [a, b] of cambios) {\n if (ins.includes(a)) { ins = ins.replaceAll(a, b); hechos.push(a.slice(0, 45)); }\n }\n\n if (!ins.includes(\"VISION DEL CLUB\")) {\n ins = ins.replace(\n \"REGLAS PARA SOCIOS DEL CLUB:\",\n `VISION DEL CLUB (contexto interno, no lo recites al cliente):\nEl Club es hacia donde va el negocio: Ladys se esta transformando de lavanderia por kilo a lavanderia por suscripcion. Partimos con 10 membresias fundadoras y vamos creciendo segun la capacidad productiva. Por eso los cupos son reales y limitados: cada socio con retiros ilimitados y sin tope de kilos ocupa capacidad de la planta.\nSi un cliente pregunta cuantos cupos quedan y no lo sabes con certeza, no inventes un numero: dile que son 10 en total en esta primera tanda y que le confirmas la disponibilidad con un ejecutivo.\nNunca prometas que se abriran mas cupos en una fecha determinada.\n\nREGLAS PARA SOCIOS DEL CLUB:`,\n );\n hechos.push(\"bloque vision del club\");\n }\n\n const put = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, {\n method: \"PUT\",\n headers: H,\n body: JSON.stringify({\n name: ag.name,\n businessName: ag.businessName,\n isPrimary: ag.isPrimary ?? true,\n personality: ag.personality,\n goal: ag.goal,\n instructions: ins,\n }),\n });\n\n return new Response(JSON.stringify({\n hechos, largo: { antes, despues: ins.length }, put_status: put.status,\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,285],"6441ba4a-1d5a-4f8e-b753-9f240d8eaba2","sofia_club.ts","cee61bca-a323-11f1-81de-1607ee4eb77e",75,["D",1787950961545],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nconst CLUB = `\n=====================================================\nEL CLUB BY LADYS - MEMBRESIAS (PRIORIDAD DE VENTA)\n=====================================================\nEl Club es nuestra membresia mensual de lavanderia: el cliente paga un precio fijo al mes y se olvida del lavado. Es nuestro producto estrella y el que mas conviene ofrecer a clientes recurrentes.\nPagina con toda la informacion: https://ladyslavanderia.cl/club\nSiempre que expliques El Club, comparte ese link para que el cliente vea los planes con calma.\n\nLOS 3 PLANES:\n\n1) CLUB HOGAR - $100.000/mes\nHasta 40 kg de ropa al mes incluidos\nLocker disponible 24/7 para dejar y retirar (sin esperar atencion)\nLavado, secado y doblado en 48 hrs habiles\nKilo extra a $2.500\nNO incluye retiro a domicilio\n\n2) CLUB DOMICILIO - $150.000/mes\nHasta 60 kg de ropa al mes incluidos\nRetiro y entrega en la casa del cliente, ilimitados, en Concon\n1 servicio express por semana (segun disponibilidad)\nLavado, secado y doblado en 48 hrs habiles\nKilo extra a $2.500\n\n3) CLUB TOTAL - $200.000/mes (EL MAS ELEGIDO)\nSIN TOPE DE KILOS: lava todo lo que quiera\nRetiro y entrega a domicilio ilimitados\nExpress prioritario cuando lo necesite\nCobertores y plumones incluidos, todos los del hogar\nTrajes, chaquetas y zapatillas incluidos\nPLAN ANUAL del Club Total: $2.160.000 al ano en vez de $2.400.000 - ahorra $240.000, mas de un mes gratis. El plan anual tiene contrato firmado que le garantiza al cliente el precio y el servicio por 12 meses.\n\nCONDICIONES COMUNES A TODOS LOS PLANES:\nIncorporacion $0 hasta el 31 de agosto de 2026. Despues son $50.000. Este es el argumento de urgencia principal.\nPago mensual anticipado con cargo automatico (link de suscripcion que se envia por WhatsApp).\nSin contrato de permanencia en los planes mensuales: el cliente cancela cuando quiera avisando con 30 dias.\nPrecio congelado 12 meses; despues se reajusta una sola vez por IPC acumulado del INE en el aniversario de la membresia.\nUso familiar: un domicilio, un grupo familiar.\nNO incluye alfombras en ningun plan.\nEn los planes Hogar y Domicilio los cobertores, plumones y prendas especiales se cobran segun la lista normal. Solo el Total los incluye.\n\nCOMO FUNCIONA PARA EL SOCIO (3 pasos):\n1. Recibe 2 bolsas del club y las llena sin pesar ni contar\n2. Avisa por WhatsApp y pasamos a retirar (o la deja en el locker si es plan Hogar)\n3. Su ropa vuelve lavada, seca y doblada en maximo 48 hrs habiles\n\nCUANDO OFRECER EL CLUB (MUY IMPORTANTE):\nOfrece El Club de forma natural, nunca invasiva, en estas situaciones:\nCuando el cliente menciona que manda ropa seguido, todos los meses, o que es cliente habitual\nCuando el cliente pregunta por descuentos, precios especiales o si conviene mandar mas\nCuando el cliente se queja de que lavar le quita tiempo o de que la ropa se le acumula\nCuando el cliente cotiza un pedido grande (sobre $80.000) o menciona que tiene mucha ropa\nCuando el cliente pregunta si tenemos planes, suscripciones o convenios\nCuando el cliente agenda su tercer retiro o mas\nNO ofrezcas el Club a alguien que consulta por un servicio unico y puntual (una alfombra, un solo traje, un cobertor suelto). Ahi no calza y suena a venta forzada.\n\nCOMO ELEGIR QUE PLAN OFRECER:\nPregunta cuanto gasta aproximadamente al mes en lavanderia, o cuanta ropa manda.\nSi gasta sobre $170.000 al mes: ofrece el Club Total. Argumento: con el Total paga fijo $200.000 y deja de pagar por kilo, ademas le entran cobertores y prendas especiales.\nSi gasta entre $95.000 y $170.000: ofrece el Club Domicilio, y menciona el Total como opcion si quiere todo ilimitado.\nSi gasta entre $65.000 y $95.000: ofrece el Club Hogar.\nSi gasta menos de $65.000 al mes: todavia no le conviene, no se lo ofrezcas.\n\nARGUMENTOS DE VENTA DEL CLUB:\nDeja de calcular: precio fijo todos los meses, sin sorpresas en la cuenta\nNunca mas lava, tiende, dobla ni guarda: son mas de 5 horas por semana que recupera\nRetiramos y entregamos en su casa, no tiene que ir al local\nEl compromiso es nuestro con el cliente, no al reves: puede cancelar cuando quiera\nEl precio le queda congelado 12 meses\nIncorporacion gratis hasta el 31 de agosto (despues $50.000)\n\nSI EL CLIENTE MUESTRA INTERES EN EL CLUB:\nComparte el link https://ladyslavanderia.cl/club para que vea los planes\nConfirma que plan le interesa\nToma sus datos completos: nombre y apellido, telefono, email y direccion\nDile que le enviaremos el link de suscripcion para dejar el pago configurado\nDeriva a un ejecutivo humano para cerrar la suscripcion y el cobro. No intentes procesar el pago tu misma.\nSi el cliente pide condiciones especiales, descuentos distintos a los publicados, o un plan a la medida (empresas, hoteles, airbnb), derivalo a un ejecutivo: los clientes empresa tienen un plan a convenio aparte.\n\nREGLAS PARA SOCIOS DEL CLUB:\nSi el cliente ya es socio, sus retiros estan incluidos en el plan: no le cobres retiro ni le apliques el pedido minimo de $20.000.\nLos socios pagan su membresia por cargo automatico mensual, no pedido por pedido.\nLas promociones semanales del local NO son acumulables con las membresias del Club.\n\n=====================================================\n`;\n\nexport default async function (req: Request): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const get = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, { headers: H });\n if (!get.ok) {\n return new Response(JSON.stringify({ paso: \"leer\", status: get.status,\n body: (await get.text()).slice(0, 400) }), { status: 500 });\n }\n const ag = await get.json();\n\n const yaTiene = String(ag.instructions ?? \"\").includes(\"EL CLUB BY LADYS\");\n let instrucciones = String(ag.instructions ?? \"\");\n\n if (!yaTiene) {\n const ancla = \"\\nREGISTRO Y CONFIRMACION DE DATOS\";\n const i = instrucciones.indexOf(ancla);\n instrucciones = i > 0\n ? instrucciones.slice(0, i) + CLUB + instrucciones.slice(i)\n : instrucciones + CLUB;\n }\n\n if (!instrucciones.includes(\"El Club: https://ladyslavanderia.cl/club\")) {\n instrucciones = instrucciones.replace(\n \"Instagram: @ladyslavanderia\",\n \"Instagram: @ladyslavanderia\\nEl Club: https://ladyslavanderia.cl/club\",\n );\n }\n\n let goal = String(ag.goal ?? \"\");\n if (!goal.includes(\"MEMBRESIAS DEL CLUB\")) {\n goal = goal.replace(\n \"Mi funcion principal es agendar retiros a domicilio\",\n \"Mis dos funciones principales son agendar retiros a domicilio y VENDER LAS MEMBRESIAS DEL CLUB a los clientes que califican. Agendo retiros a domicilio\",\n );\n goal += \"\\nDetecto clientes recurrentes o de alto consumo y les ofrezco El Club como la solucion definitiva a su problema de lavado.\";\n }\n\n const put = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, {\n method: \"PUT\",\n headers: H,\n body: JSON.stringify({\n name: ag.name,\n businessName: ag.businessName,\n isPrimary: ag.isPrimary ?? true,\n personality: ag.personality,\n goal,\n instructions: instrucciones,\n }),\n });\n const respuesta = await put.text();\n\n return new Response(JSON.stringify({\n ya_tenia_club: yaTiene,\n largo_instrucciones: instrucciones.length,\n put_status: put.status,\n respuesta: respuesta.slice(0, 300),\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,293],"e8599656-4cdf-42c9-86aa-633db9eb21fe","sofia_check.ts","b0ffc9ee-a323-11f1-b0ff-1607ee4eb77e",74,["D",1787950911384],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\n\nexport default async function (): Promise {\n const nombres = [\"PIT_LADYS_V2\", \"PIT_LADYS\", \"GHL_TOKEN_LADYS\",\n \"GHL_API_KEY_LADYS\", \"GHL_API_KEY\"];\n const cuales: Record = {};\n for (const n of nombres) {\n const v = Deno.env.get(n);\n cuales[n] = v ? `${v.slice(0, 12)}…${v.slice(-6)}` : \"(no existe)\";\n }\n\n const tok = getToken(DEFAULT_LOCATION_ID);\n const r = await fetch(\n `https://services.leadconnectorhq.com/conversation-ai/agents/${AGENT}`,\n {\n headers: {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n },\n },\n );\n const t = await r.text();\n\n return new Response(JSON.stringify({\n env_disponibles: cuales,\n token_que_usa_ghl_ts: `${tok.slice(0, 12)}…${tok.slice(-6)}`,\n lectura_agente: { status: r.status, preview: t.slice(0, 300) },\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,301],"2fcfd8b6-3308-44c5-8ebc-d93d29089563","pulso_club.ts","a635f206-a3ee-11f1-b058-1607ee4eb77e",90,["D",1788038090350],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst BASE = \"https://services.leadconnectorhq.com\";\n\n/** Contactos nuevos de las ultimas 48h y de que anuncio vinieron */\nexport default async function (req: Request): Promise {\n const horas = Number(new URL(req.url).searchParams.get(\"horas\") ?? 48);\n const corte = Date.now() - horas * 3600 * 1000;\n\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = { Authorization: `Bearer ${tok}`, Version: \"2021-07-28\", Accept: \"application/json\" };\n\n const r = await fetch(`${BASE}/contacts/?locationId=${DEFAULT_LOCATION_ID}&limit=100`, { headers: H });\n const cs = (await r.json()).contacts ?? [];\n\n const recientes = cs.filter((c: any) => new Date(c.dateAdded).getTime() >= corte);\n\n const filas = recientes.map((c: any) => {\n const at = (c.attributions ?? []).find((a: any) => a.isFirst) ?? (c.attributions ?? [])[0];\n return {\n nombre: (`${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`).trim() || c.contactName || \"\",\n tel: c.phone ?? \"\",\n creado: c.dateAdded,\n medio: at?.medium ?? \"?\",\n anuncio: at?.adName ?? \"\",\n pagina: at?.pageUrl ?? at?.url ?? \"\",\n };\n });\n\n const porAnuncio: Record = {};\n const porMedio: Record = {};\n for (const f of filas) {\n porMedio[f.medio] = (porMedio[f.medio] ?? 0) + 1;\n if (f.anuncio) porAnuncio[f.anuncio] = (porAnuncio[f.anuncio] ?? 0) + 1;\n }\n\n // los que vienen de la web del club\n const delClub = filas.filter(f =>\n String(f.pagina).includes(\"ladyslavanderia.cl\") ||\n String(f.anuncio).toLowerCase().includes(\"260\") ||\n String(f.anuncio).toLowerCase().includes(\"club\"));\n\n return new Response(JSON.stringify({\n ventana_horas: horas,\n contactos_nuevos: recientes.length,\n por_medio: porMedio,\n por_anuncio: porAnuncio,\n posibles_del_club: delClub,\n ultimos: filas.slice(0, 15),\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,309],"655b7607-d273-4d68-bfe8-1e620bb318f0","leads_ads.ts","39585ffc-a3cb-11f1-bb21-1607ee4eb77e",83,["D",1788022865924],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst BASE = \"https://services.leadconnectorhq.com\";\n\n/**\n * Extrae de GHL todos los contactos que llegaron por anuncios pagados\n * y los guarda en blob para cruzarlos despues con EasyLaundry.\n */\nexport default async function (req: Request): Promise {\n const u = new URL(req.url);\n const paginas = Number(u.searchParams.get(\"paginas\") ?? 8);\n\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const leads: any[] = [];\n let startAfterId: string | null = null;\n let startAfter: number | null = null;\n let total = 0;\n\n for (let p = 0; p < paginas; p++) {\n let url = `${BASE}/contacts/?locationId=${DEFAULT_LOCATION_ID}&limit=100`;\n if (startAfterId && startAfter) {\n url += `&startAfterId=${startAfterId}&startAfter=${startAfter}`;\n }\n const r = await fetch(url, { headers: H });\n if (!r.ok) break;\n const j = await r.json();\n const cs = j.contacts ?? [];\n if (!cs.length) break;\n total += cs.length;\n\n for (const c of cs) {\n const at = (c.attributions ?? []).find((a: any) => a.isFirst) ??\n (c.attributions ?? [])[0];\n if (!at) continue;\n // solo los que vienen de publicidad pagada\n const esPago = at.utmSessionSource === \"Paid Social\" || at.utmAdId || at.adName;\n if (!esPago) continue;\n\n leads.push({\n nombre: (`${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`).trim() || c.contactName || \"\",\n tel: c.phone ?? \"\",\n email: c.email ?? \"\",\n creado: (c.dateAdded ?? \"\").slice(0, 10),\n anuncio: at.adName ?? \"\",\n adId: at.utmAdId ?? \"\",\n campana: at.campaignName ?? \"\",\n });\n }\n\n const ult = cs[cs.length - 1];\n startAfterId = ult.id;\n startAfter = new Date(ult.dateAdded).getTime();\n }\n\n await blob.setJSON(\"leads_ads\", leads);\n\n // resumen por anuncio\n const porAnuncio: Record = {};\n const porMes: Record = {};\n for (const l of leads) {\n porAnuncio[l.anuncio || \"(sin nombre)\"] = (porAnuncio[l.anuncio || \"(sin nombre)\"] ?? 0) + 1;\n const m = l.creado.slice(0, 7);\n porMes[m] = (porMes[m] ?? 0) + 1;\n }\n\n return new Response(JSON.stringify({\n contactos_revisados: total,\n leads_de_anuncios: leads.length,\n por_anuncio: porAnuncio,\n por_mes: porMes,\n rango: leads.length\n ? { desde: leads.map(l => l.creado).sort()[0],\n hasta: leads.map(l => l.creado).sort().slice(-1)[0] }\n : null,\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,317],"69706bc2-2f9b-4b7b-b85e-ac6491c3a098","diag_pit.ts",73,["D",1787950858740],"const LOC = \"o1V9sCKjH5Ywd9PRURj0\";\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst SKILL_PIT = \"pit-7cdd6c37-c485-42b4-a557-644beb7d2b02\";\n\nfunction huella(t: string) {\n if (!t) return \"(vacio)\";\n return `${t.slice(0, 12)}…${t.slice(-6)} [${t.length} chars]`;\n}\n\nasync function probar(nombre: string, tok: string) {\n if (!tok) return { fuente: nombre, token: \"(no existe)\", status: null };\n const r = await fetch(BASE + \"/contacts/search\", {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Bearer \" + tok,\n \"Version\": \"2021-07-28\",\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ locationId: LOC, pageLimit: 1 }),\n });\n const t = await r.text();\n return {\n fuente: nombre,\n token: huella(tok),\n status: r.status,\n resp: t.slice(0, 160),\n };\n}\n\nexport default async function (): Promise {\n const env = Deno.env.get(\"GHL_API_KEY_LADYS\") ?? \"\";\n const envViejo = Deno.env.get(\"GHL_API_KEY\") ?? \"\";\n\n const out = {\n iguales_env_vs_skill: env === SKILL_PIT,\n pruebas: [\n await probar(\"env GHL_API_KEY_LADYS\", env),\n await probar(\"env GHL_API_KEY (viejo)\", envViejo),\n await probar(\"literal de la skill\", SKILL_PIT),\n ],\n };\n return new Response(JSON.stringify(out, null, 1), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n",[],[196,325],"827189ee-741c-4fb3-8f85-db5a1f7f29d4","buscar_fundadores.ts","0a0a72c0-9ce2-11f1-a8ba-1607ee4eb77e",66,["D",1787263057743],3,"// Reintento Mario Herrera con variantes\nconst PIT = Deno.env.get(\"GHL_API_KEY_LADYS\");\nconst LOCATION = \"o1V9sCKjH5Ywd9PRURj0\";\nconst variantes = [\"Mario Herrera\", \"Mario\", \"Herrera\"];\nfor (const q of variantes) {\n const r = await fetch(\"https://services.leadconnectorhq.com/contacts/search\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${PIT}`, \"Version\": \"2021-07-28\", \"Content-Type\": \"application/json\", \"Accept\": \"application/json\" },\n body: JSON.stringify({ locationId: LOCATION, query: q, pageLimit: 10 }),\n });\n const j = await r.json();\n const hits = (j.contacts || []).map((c: any) => `${(c.firstName??\"\")+\" \"+(c.lastName??\"\")}`.trim() + \" | \" + (c.phone??\"s/tel\") + \" | \" + (c.email??\"\"));\n console.log(q, \"→\", hits.length, \"resultados\");\n hits.filter((h:string)=>/herrera|mario/i.test(h)).slice(0,8).forEach((h:string)=>console.log(\" \", h));\n}\n",[],[196,332],"e24c8e98-1d1d-45d8-9604-ceb6ec9e432a","auditoria-tokens2.ts","d1020528-a3f9-11f1-8e00-1607ee4eb77e",93,["D",1788042877388],"// Mapeo correcto token→cuenta + sondeo de nivel (location vs agencia). 29-ago-2026.\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst LOC = { TK: \"SevVprqYc2lE6O92KLwY\", LADYS: \"o1V9sCKjH5Ywd9PRURj0\" };\nconst H = (t: string, v = \"2021-07-28\") => ({\n Authorization: `Bearer ${t}`,\n Version: v,\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n});\nconst mask = (t: string) => `${t.slice(0, 8)}…${t.slice(-6)}`;\nconst body = async (r: Response) => (await r.text()).slice(0, 110);\n\nconst TK = Deno.env.get(\"PIT_TOPKREATIVA_V3\")!; // 200 en TK, 403 en Ladys → location TK\nconst LA = Deno.env.get(\"PIT_LADYS_V2\")!; // 403 en TK, 200 en Ladys → location Ladys\nconst AG = Deno.env.get(\"PIT_TOPKREATIVA_V2\")!; // 200 en ambas → parece de AGENCIA\n\nconsole.log(\"TK =\", mask(TK), \" LADYS =\", mask(LA), \" ¿AGENCIA? =\", mask(AG));\n\nconsole.log(\"\\n=== SCOPES con el token correcto de cada location ===\");\nfor (const [n, t, loc] of [[\"TopKreativa\", TK, LOC.TK], [\"Ladys\", LA, LOC.LADYS]] as const) {\n console.log(`\\n-- ${n} --`);\n const pruebas: [string, string, string][] = [\n [\"contacts.readonly\", `${BASE}/contacts/?locationId=${loc}&limit=1`, \"2021-07-28\"],\n [\"opportunities.readonly\", `${BASE}/opportunities/pipelines?locationId=${loc}`, \"2021-07-28\"],\n [\"conversations.readonly\", `${BASE}/conversations/search?locationId=${loc}&limit=1`, \"2021-04-15\"],\n [\"calendars.readonly\", `${BASE}/calendars/?locationId=${loc}`, \"2021-07-28\"],\n [\"workflows.readonly\", `${BASE}/workflows/?locationId=${loc}`, \"2021-07-28\"],\n [\"locations/tags\", `${BASE}/locations/${loc}/tags`, \"2021-07-28\"],\n [\"locations/customFields\", `${BASE}/locations/${loc}/customFields`, \"2021-07-28\"],\n [\"locations/customValues\", `${BASE}/locations/${loc}/customValues`, \"2021-07-28\"],\n [\"users.readonly\", `${BASE}/users/?locationId=${loc}`, \"2021-07-28\"],\n [\"socialplanner\", `${BASE}/social-media-posting/${loc}/accounts`, \"2021-07-28\"],\n [\"forms.readonly\", `${BASE}/forms/?locationId=${loc}&limit=1`, \"2021-07-28\"],\n [\"links.readonly\", `${BASE}/links/?locationId=${loc}`, \"2021-07-28\"],\n ];\n for (const [s, url, v] of pruebas) {\n const r = await fetch(url, { headers: H(t, v) });\n console.log(` ${s.padEnd(24)} ${r.status}${r.status === 200 ? \" ✓\" : \" \" + (await body(r))}`);\n }\n}\n\nconsole.log(\"\\n=== ¿El token 'V2' es de AGENCIA? ===\");\nfor (const [n, url] of [\n [\"GET /locations/search\", `${BASE}/locations/search?limit=10`],\n [\"GET /oauth/installedLocations\", `${BASE}/oauth/installedLocations`],\n [\"GET /snapshots/\", `${BASE}/snapshots/`],\n [\"GET /users/ (TK)\", `${BASE}/users/?locationId=${LOC.TK}`],\n] as const) {\n const r = await fetch(url, { headers: H(AG) });\n console.log(` ${n.padEnd(32)} ${r.status} ${r.status === 200 ? \"✓\" : await body(r)}`);\n}\n\nconsole.log(\"\\n=== ESCRITURAS pendientes: ¿se pueden ya? ===\");\n\n// A) Ficha de negocio de TopKreativa: región y código postal\nfor (const [n, t] of [[\"con PIT location TK\", TK], [\"con PIT 'agencia'\", AG]] as const) {\n const cur = await (await fetch(`${BASE}/locations/${LOC.TK}`, { headers: H(t) })).json().catch(() => null);\n const b = cur?.location ?? cur ?? {};\n const r = await fetch(`${BASE}/locations/${LOC.TK}`, {\n method: \"PUT\",\n headers: H(t),\n body: JSON.stringify({\n name: b?.name,\n address: b?.address,\n city: b?.city,\n state: \"Valparaíso\",\n postalCode: \"2510000\",\n country: b?.country ?? \"CL\",\n timezone: b?.timezone ?? \"America/Santiago\",\n }),\n });\n console.log(` PUT /locations/TK ${n.padEnd(22)} → ${r.status} ${r.status < 300 ? \"✓\" : await body(r)}`);\n}\n\n// B) Nombres de etapa con espacios sobrantes o \"(personaliza)\"\nfor (const [n, t, loc] of [[\"TopKreativa\", TK, LOC.TK], [\"Ladys\", LA, LOC.LADYS]] as const) {\n const p = await (await fetch(`${BASE}/opportunities/pipelines?locationId=${loc}`, { headers: H(t) })).json();\n const pipes = p?.pipelines ?? [];\n const sucios = pipes.filter((x: any) =>\n (x.stages ?? []).some((s: any) => s.name !== s.name.trim() || /personaliza/i.test(s.name))\n );\n console.log(` ${n}: ${pipes.length} pipelines, ${sucios.length} con etapas a limpiar`);\n for (const sp of sucios) {\n const r = await fetch(`${BASE}/opportunities/pipelines/${sp.id}`, {\n method: \"PUT\",\n headers: H(t),\n body: JSON.stringify({\n name: sp.name,\n locationId: loc,\n stages: sp.stages.map((s: any) => ({ ...s, name: s.name.trim() })),\n }),\n });\n console.log(` PUT pipeline \"${sp.name}\" → ${r.status} ${r.status < 300 ? \"✓\" : await body(r)}`);\n }\n}\n",[],[196,341],"e484966c-ef23-4ed8-b608-80af2c83b406","auditoria-tokens.ts","b7ec0bec-a3f9-11f1-86d0-1607ee4eb77e",92,["D",1788042835294],"// Qué PIT sigue vivo, cuenta por cuenta. 29-ago-2026.\n// Solo lectura. Nunca imprime un token completo.\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst LOC = { TK: \"SevVprqYc2lE6O92KLwY\", LADYS: \"o1V9sCKjH5Ywd9PRURj0\" };\n\nconst CANDIDATOS = [\n \"PIT_TOPKREATIVA_V3\",\n \"PIT_TOPKREATIVA_V2\",\n \"PIT_TOPKREATIVA\",\n \"GHL_TOKEN_TOPKREATIVA\",\n \"PIT_LADYS_V2\",\n \"PIT_LADYS\",\n \"GHL_API_KEY_LADYS\",\n \"GHL_TOKEN_LADYS\",\n \"GHL_API_KEY\",\n];\n\nconst H = (t: string, v = \"2021-07-28\") => ({\n Authorization: `Bearer ${t}`,\n Version: v,\n Accept: \"application/json\",\n});\nconst mask = (t: string) => `${t.slice(0, 8)}…${t.slice(-6)}`;\n\ntype Fila = { env: string; token: string; tk: number; ladys: number };\nconst filas: Fila[] = [];\n\nfor (const env of CANDIDATOS) {\n const t = Deno.env.get(env);\n if (!t) {\n console.log(`${env.padEnd(24)} (no existe)`);\n continue;\n }\n const [a, b] = await Promise.all([\n fetch(`${BASE}/locations/${LOC.TK}`, { headers: H(t) }),\n fetch(`${BASE}/locations/${LOC.LADYS}`, { headers: H(t) }),\n ]);\n filas.push({ env, token: t, tk: a.status, ladys: b.status });\n}\n\nconsole.log(\"\\n=== VIGENCIA POR CUENTA (200 = vivo) ===\");\nconsole.log(\"env\".padEnd(24) + \"token\".padEnd(20) + \"TopKreativa\".padEnd(13) + \"Ladys\");\nfor (const f of filas) {\n console.log(\n f.env.padEnd(24) + mask(f.token).padEnd(20) + String(f.tk).padEnd(13) + String(f.ladys),\n );\n}\n\nconst vivoTK = filas.find((f) => f.tk === 200);\nconst vivoLA = filas.find((f) => f.ladys === 200);\n\nconsole.log(\"\\n=== VEREDICTO ===\");\nconsole.log(`TopKreativa → ${vivoTK ? `${vivoTK.env} (${mask(vivoTK.token)})` : \"NINGÚN TOKEN VIVO\"}`);\nconsole.log(`Ladys → ${vivoLA ? `${vivoLA.env} (${mask(vivoLA.token)})` : \"NINGÚN TOKEN VIVO\"}`);\n\nconsole.log(\"\\n=== DUPLICADOS (mismo valor en varias env vars) ===\");\nconst porValor = new Map();\nfor (const f of filas) porValor.set(f.token, [...(porValor.get(f.token) ?? []), f.env]);\nfor (const [tok, envs] of porValor) {\n if (envs.length > 1) console.log(`${mask(tok)} → ${envs.join(\", \")}`);\n}\nconsole.log(`\\nTotal de valores distintos guardados: ${porValor.size} (límite de GHL: 5 PIT por location)`);\n\n// Con el token vivo, ver qué se puede escribir\nfor (const [nombre, f, loc] of [[\"TopKreativa\", vivoTK, LOC.TK], [\"Ladys\", vivoLA, LOC.LADYS]] as const) {\n if (!f) continue;\n console.log(`\\n=== SCOPES ${nombre} ===`);\n const pruebas: [string, string, string][] = [\n [\"contacts.readonly\", `${BASE}/contacts/?locationId=${loc}&limit=1`, \"2021-07-28\"],\n [\"opportunities.readonly\", `${BASE}/opportunities/pipelines?locationId=${loc}`, \"2021-07-28\"],\n [\"conversations.readonly\", `${BASE}/conversations/search?locationId=${loc}&limit=1`, \"2021-04-15\"],\n [\"calendars.readonly\", `${BASE}/calendars/?locationId=${loc}`, \"2021-07-28\"],\n [\"workflows.readonly\", `${BASE}/workflows/?locationId=${loc}`, \"2021-07-28\"],\n [\"locations/tags.readonly\", `${BASE}/locations/${loc}/tags`, \"2021-07-28\"],\n [\"locations/customFields\", `${BASE}/locations/${loc}/customFields`, \"2021-07-28\"],\n [\"users.readonly\", `${BASE}/users/?locationId=${loc}`, \"2021-07-28\"],\n [\"medias.readonly\", `${BASE}/medias/files?altId=${loc}&altType=location&limit=1`, \"2021-07-28\"],\n [\"socialplanner\", `${BASE}/social-media-posting/${loc}/accounts`, \"2021-07-28\"],\n ];\n for (const [scope, url, v] of pruebas) {\n const r = await fetch(url, { headers: H(f.token, v) });\n console.log(` ${scope.padEnd(26)} ${r.status}${r.status === 200 ? \" ✓\" : ` ${(await r.text()).slice(0, 80)}`}`);\n }\n}\n",[],[196,349],"62d5f0f3-7672-436e-9725-7d3a84f2e592","atribucion.ts","21d64632-a3cb-11f1-83c9-1607ee4eb77e",82,["D",1788022843286],"import { DEFAULT_LOCATION_ID, getToken } from \"../ghl.ts\";\n\nconst BASE = \"https://services.leadconnectorhq.com\";\n\nexport default async function (req: Request): Promise {\n const tok = getToken(DEFAULT_LOCATION_ID);\n const H = {\n Authorization: `Bearer ${tok}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n };\n\n const r = await fetch(`${BASE}/contacts/?locationId=${DEFAULT_LOCATION_ID}&limit=100`,\n { headers: H });\n const j = await r.json();\n const cs = j.contacts ?? [];\n\n const conAtrib = cs.filter((c: any) =>\n Array.isArray(c.attributions) && c.attributions.length > 0);\n\n // Contar por medio/origen\n const porMedio: Record = {};\n for (const c of conAtrib) {\n for (const a of c.attributions) {\n const k = `${a.utmSource ?? a.medium ?? \"?\"} / ${a.medium ?? \"?\"}`;\n porMedio[k] = (porMedio[k] ?? 0) + 1;\n }\n }\n\n return new Response(JSON.stringify({\n muestra: cs.length,\n con_attributions: conAtrib.length,\n por_medio: porMedio,\n ejemplos: conAtrib.slice(0, 4).map((c: any) => ({\n nombre: `${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`.trim() || c.contactName,\n tel: c.phone,\n creado: (c.dateAdded ?? \"\").slice(0, 10),\n attributions: c.attributions,\n })),\n }, null, 1), { headers: { \"Content-Type\": \"application/json\" } });\n}\n",[],[196,357],"67698536-e9c7-41cb-8508-39dd93b5478f","aplicar-pendientes.ts","e6c36564-a3f9-11f1-a3f1-1607ee4eb77e",94,["D",1788042913833],"// Aplica lo que el token de agencia sí permite. 29-ago-2026.\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst LOC = { TK: \"SevVprqYc2lE6O92KLwY\", LADYS: \"o1V9sCKjH5Ywd9PRURj0\" };\nconst H = (t: string, v = \"2021-07-28\") => ({\n Authorization: `Bearer ${t}`,\n Version: v,\n Accept: \"application/json\",\n \"Content-Type\": \"application/json\",\n});\nconst body = async (r: Response) => (await r.text()).slice(0, 140);\n\nconst TK = Deno.env.get(\"PIT_TOPKREATIVA_V3\")!;\nconst LA = Deno.env.get(\"PIT_LADYS_V2\")!;\nconst AG = Deno.env.get(\"PIT_TOPKREATIVA_V2\")!; // agencia\n\nconsole.log(\"=== 1. ¿Quedó aplicada la ficha de TopKreativa? ===\");\n{\n const j = await (await fetch(`${BASE}/locations/${LOC.TK}`, { headers: H(AG) })).json();\n const b = j?.location ?? j;\n console.log(` name=${b?.name} state=${b?.state} postal=${b?.postalCode} city=${b?.city} tz=${b?.timezone}`);\n console.log(` businessHours = ${JSON.stringify(b?.business?.businessHours ?? null)}`);\n}\n\nconsole.log(\"\\n=== 2. Ficha de Ladys (estado actual) ===\");\n{\n const j = await (await fetch(`${BASE}/locations/${LOC.LADYS}`, { headers: H(AG) })).json();\n const b = j?.location ?? j;\n console.log(` name=${b?.name} state=${b?.state} postal=${b?.postalCode} city=${b?.city} tz=${b?.timezone}`);\n console.log(` businessHours = ${JSON.stringify(b?.business?.businessHours ?? null)}`);\n}\n\nconsole.log(\"\\n=== 3. Etapas de pipeline: PUT sin locationId ===\");\nfor (const [n, loc, tokens] of [\n [\"TopKreativa\", LOC.TK, [[\"location\", TK], [\"agencia\", AG]]],\n [\"Ladys\", LOC.LADYS, [[\"location\", LA], [\"agencia\", AG]]],\n] as const) {\n const p = await (await fetch(`${BASE}/opportunities/pipelines?locationId=${loc}`, { headers: H(AG) })).json();\n const pipes = p?.pipelines ?? [];\n const sucios = pipes.filter((x: any) =>\n (x.stages ?? []).some((s: any) => s.name !== s.name.trim() || /personaliza/i.test(s.name))\n );\n console.log(`\\n-- ${n}: ${sucios.length} pipelines a limpiar --`);\n for (const sp of sucios) {\n const cambios = sp.stages\n .filter((s: any) => s.name !== s.name.trim())\n .map((s: any) => `\"${s.name}\"→\"${s.name.trim()}\"`);\n const personaliza = sp.stages.filter((s: any) => /personaliza/i.test(s.name)).map((s: any) => s.name);\n console.log(` ${sp.name}: espacios=${cambios.join(\", \") || \"—\"} | personaliza=${personaliza.join(\", \") || \"—\"}`);\n for (const [etiqueta, tok] of tokens) {\n const r = await fetch(`${BASE}/opportunities/pipelines/${sp.id}`, {\n method: \"PUT\",\n headers: H(tok),\n body: JSON.stringify({\n name: sp.name,\n stages: sp.stages.map((s: any) => ({ ...s, name: s.name.trim() })),\n }),\n });\n console.log(` PUT (${etiqueta}) → ${r.status} ${r.status < 300 ? \"✓\" : await body(r)}`);\n if (r.status < 300) break;\n }\n }\n}\n\nconsole.log(\"\\n=== 4. Verificación de etapas tras el cambio ===\");\nfor (const [n, loc] of [[\"TopKreativa\", LOC.TK], [\"Ladys\", LOC.LADYS]] as const) {\n const p = await (await fetch(`${BASE}/opportunities/pipelines?locationId=${loc}`, { headers: H(AG) })).json();\n const malas = (p?.pipelines ?? []).flatMap((x: any) =>\n (x.stages ?? []).filter((s: any) => s.name !== s.name.trim()).map((s: any) => `${x.name}/\"${s.name}\"`)\n );\n console.log(` ${n}: etapas con espacios sobrantes = ${malas.length}${malas.length ? \" → \" + malas.join(\", \") : \" ✓\"}`);\n}\n",[],[196,365],["D",1787263007008],[213,214,215,216,217,218,219,220,221,222,223,224,225,226],[196],["D",1781837290695],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"ctx",{"_77":-5,"_121":412,"_413":414,"_415":416,"_417":24,"_418":24,"_419":24,"_420":57,"_421":-5,"_422":-7,"_423":-7,"_424":61,"_425":24,"_426":24,"_427":-5,"_428":24,"_429":24,"_430":24,"_431":-5},"ENV",{"_383":384,"_385":386,"_387":85,"_388":389,"_390":391,"_392":393,"_394":395,"_396":397,"_398":399,"_400":401,"_402":403,"_404":405,"_406":407,"_408":409,"_410":411},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v95