[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_319":320,"_321":322},"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",87,"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","diag-sofia.ts","latestPath","fileId","96a46c14-a3ee-11f1-b569-1607ee4eb77e","name","fileType","script","content","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","createdAt",["D",1788038054968],"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":315,"_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":316,"_79":317,"_81":318,"_83":24},"tree",[196,207,208,209,210,211,212],"files",[196,197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212],"counts",{"_186":61,"_187":176,"_188":61,"_189":190,"_191":192},"contents",[124,125,126,127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":179,"_31":180,"_29":181,"_134":-5,"_39":40,"_38":182,"_136":57,"_36":183,"_13":61,"_32":184,"_34":-5,"_23":24,"_140":-5,"_26":185},{"_41":171,"_31":172,"_29":173,"_134":-5,"_39":40,"_38":174,"_136":57,"_36":175,"_13":176,"_32":20,"_34":177,"_23":24,"_140":-5,"_26":178},{"_41":168,"_31":27,"_29":30,"_134":-5,"_39":40,"_38":14,"_136":57,"_36":169,"_13":61,"_32":33,"_34":35,"_23":24,"_140":-5,"_26":170},{"_41":160,"_31":161,"_29":162,"_134":-5,"_39":40,"_38":163,"_136":24,"_36":164,"_13":165,"_32":33,"_34":166,"_23":24,"_140":-5,"_26":167},{"_41":151,"_31":152,"_29":153,"_134":-5,"_39":40,"_38":154,"_136":57,"_36":155,"_13":156,"_32":157,"_34":158,"_23":24,"_140":-5,"_26":159},{"_41":142,"_31":143,"_29":144,"_134":-5,"_39":40,"_38":145,"_136":57,"_36":146,"_13":147,"_32":148,"_34":149,"_23":24,"_140":-5,"_26":150},{"_41":131,"_31":132,"_29":133,"_134":-5,"_39":40,"_38":135,"_136":57,"_36":137,"_13":138,"_32":33,"_34":139,"_23":24,"_140":-5,"_26":141},"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",[132],"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",[143],"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",[152],"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}",[161],"235a29f8-8f01-45e5-ab1b-87bab5ad14c0",["D",1788038054968],[27],"fe9efa43-9f08-4c3f-a4ef-2614e6ac8ec1","README.md","5aa39118-6b8b-11f1-9a66-1607ee4eb77e",30,["D",1786916091360],1,"# 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",[172],"a289f76a-008f-43ec-bd28-39fe0ce905d0","tmp","a1cefed1-8c8f-43bd-9d06-bed5d085dedc",63,["D",1787263007008],"directory",[180],"pulls","branches","forks","envVars",{"_193":147,"_195":61},"connections",{"_193":61,"_194":61},"count","unfilledCount","emptyCount",{"_41":179,"_31":180,"_29":181,"_134":-5,"_39":40,"_38":182,"_136":57,"_36":312,"_13":61,"_32":184,"_34":-5,"_23":24,"_140":-5,"_214":313,"_26":314},{"_41":304,"_31":305,"_29":306,"_134":181,"_39":40,"_38":307,"_136":57,"_36":308,"_13":176,"_32":148,"_34":309,"_23":24,"_140":-5,"_214":310,"_26":311},{"_41":295,"_31":296,"_29":297,"_134":181,"_39":40,"_38":298,"_136":57,"_36":299,"_13":300,"_32":33,"_34":301,"_23":24,"_140":-5,"_214":302,"_26":303},{"_41":288,"_31":289,"_29":55,"_134":181,"_39":40,"_38":290,"_136":57,"_36":291,"_13":61,"_32":148,"_34":292,"_23":24,"_140":-5,"_214":293,"_26":294},{"_41":280,"_31":281,"_29":282,"_134":181,"_39":40,"_38":283,"_136":57,"_36":284,"_13":61,"_32":148,"_34":285,"_23":24,"_140":-5,"_214":286,"_26":287},{"_41":272,"_31":273,"_29":274,"_134":181,"_39":40,"_38":275,"_136":57,"_36":276,"_13":61,"_32":148,"_34":277,"_23":24,"_140":-5,"_214":278,"_26":279},{"_41":264,"_31":265,"_29":266,"_134":181,"_39":40,"_38":267,"_136":57,"_36":268,"_13":61,"_32":148,"_34":269,"_23":24,"_140":-5,"_214":270,"_26":271},{"_41":256,"_31":257,"_29":258,"_134":181,"_39":40,"_38":259,"_136":57,"_36":260,"_13":61,"_32":148,"_34":261,"_23":24,"_140":-5,"_214":262,"_26":263},{"_41":248,"_31":249,"_29":250,"_134":181,"_39":40,"_38":251,"_136":57,"_36":252,"_13":61,"_32":148,"_34":253,"_23":24,"_140":-5,"_214":254,"_26":255},{"_41":240,"_31":241,"_29":242,"_134":181,"_39":40,"_38":243,"_136":57,"_36":244,"_13":61,"_32":148,"_34":245,"_23":24,"_140":-5,"_214":246,"_26":247},{"_41":232,"_31":233,"_29":234,"_134":181,"_39":40,"_38":235,"_136":57,"_36":236,"_13":176,"_32":148,"_34":237,"_23":24,"_140":-5,"_214":238,"_26":239},{"_41":171,"_31":172,"_29":173,"_134":-5,"_39":40,"_38":174,"_136":57,"_36":229,"_13":176,"_32":20,"_34":177,"_23":24,"_140":-5,"_214":230,"_26":231},{"_41":168,"_31":27,"_29":30,"_134":-5,"_39":40,"_38":14,"_136":57,"_36":226,"_13":61,"_32":33,"_34":35,"_23":24,"_140":-5,"_214":227,"_26":228},{"_41":160,"_31":161,"_29":162,"_134":-5,"_39":40,"_38":163,"_136":24,"_36":223,"_13":165,"_32":33,"_34":166,"_23":24,"_140":-5,"_214":224,"_26":225},{"_41":151,"_31":152,"_29":153,"_134":-5,"_39":40,"_38":154,"_136":57,"_36":220,"_13":156,"_32":157,"_34":158,"_23":24,"_140":-5,"_214":221,"_26":222},{"_41":142,"_31":143,"_29":144,"_134":-5,"_39":40,"_38":145,"_136":57,"_36":217,"_13":147,"_32":148,"_34":149,"_23":24,"_140":-5,"_214":218,"_26":219},{"_41":131,"_31":132,"_29":133,"_134":-5,"_39":40,"_38":135,"_136":57,"_36":213,"_13":138,"_32":33,"_34":139,"_23":24,"_140":-5,"_214":215,"_26":216},["D",1786934288897],"children",[],[132],["D",1787180036699],[],[143],["D",1788025007584],[],[152],["D",1787578022096],[],[161],["D",1788038054968],[],[27],["D",1786916091360],[],[172],"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",[],[180,233],"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",[],[180,241],"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",[],[180,249],"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",[],[180,257],"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",[],[180,265],"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",[],[180,273],"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",[],[180,281],"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",[],[180,289],"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",[],[180,296],"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",[],[180,305],["D",1787263007008],[197,198,199,200,201,202,203,204,205,206],[180],["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":352,"_353":354,"_355":356,"_357":24,"_358":24,"_359":24,"_360":57,"_361":-5,"_362":-7,"_363":-7,"_364":61,"_365":24,"_366":24,"_367":-5,"_368":24,"_369":24,"_370":24,"_371":-5},"ENV",{"_323":324,"_325":326,"_327":85,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337,"_338":339,"_340":341,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351},"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 · v87