[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_228":229,"_230":231},"routes/_app.x.$handle.$name",{"_98":97,"_32":46,"_106":88,"_27":54,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":60,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",64,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","tmp/buscar_fundadores.ts","latestPath","fileId","0a0a72c0-9ce2-11f1-a8ba-1607ee4eb77e","name","buscar_fundadores.ts","fileType","script","content","// Temporal: buscar teléfonos de los 5 fundadores del test Club en GHL (Ladys)\nconst PIT = Deno.env.get(\"GHL_API_KEY\");\nconst LOCATION = \"o1V9sCKjH5Ywd9PRURj0\";\nconst nombres = [\"Sara Galaz\", \"Carla Vivanco\", \"Paola Duarte\", \"Alejandra Mora\", \"Mario Herrera\"];\n\nconst out: any[] = [];\nfor (const q of nombres) {\n const r = await fetch(\"https://services.leadconnectorhq.com/contacts/search\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${PIT}`,\n \"Version\": \"2021-07-28\",\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n },\n body: JSON.stringify({ locationId: LOCATION, query: q, pageLimit: 5 }),\n });\n const j = await r.json();\n const hits = (j.contacts || []).map((c: any) => ({\n buscado: q,\n nombre: `${c.firstName ?? \"\"} ${c.lastName ?? \"\"}`.trim() || c.contactName,\n tel: c.phone,\n email: c.email,\n id: c.id,\n }));\n out.push(hits.length ? hits : [{ buscado: q, nombre: \"SIN RESULTADO\", tel: null }]);\n}\nconsole.log(JSON.stringify(out.flat(), null, 2));\n","// Diagnóstico: status y respuesta cruda de la API GHL\nconst PIT = Deno.env.get(\"GHL_API_KEY\");\nconst LOCATION = \"o1V9sCKjH5Ywd9PRURj0\";\nconsole.log(\"PIT presente:\", !!PIT, PIT ? PIT.slice(0, 8) + \"...\" : \"\");\n\nconst r = await fetch(\"https://services.leadconnectorhq.com/contacts/search\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${PIT}`,\n \"Version\": \"2021-07-28\",\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n },\n body: JSON.stringify({ locationId: LOCATION, query: \"Sara\", pageLimit: 5 }),\n});\nconsole.log(\"status:\", r.status);\nconst txt = await r.text();\nconsole.log(\"body:\", txt.slice(0, 800));\n","createdAt",["D",1787263020078],"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",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"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",{"_44":45,"_32":46,"_39":224,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":225,"_82":226,"_84":227,"_86":25},"tree",[194,196,197,198,199,200],"files",[194,195,196,197,198,199,200],"counts",{"_184":64,"_185":174,"_186":64,"_187":188,"_189":190},"contents",[127,128,129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":177,"_32":178,"_30":179,"_136":-5,"_42":43,"_41":180,"_138":60,"_39":181,"_13":64,"_34":182,"_36":-5,"_24":25,"_142":-5,"_27":183},{"_44":169,"_32":170,"_30":171,"_136":-5,"_42":43,"_41":172,"_138":60,"_39":173,"_13":174,"_34":20,"_36":175,"_24":25,"_142":-5,"_27":176},{"_44":161,"_32":162,"_30":163,"_136":-5,"_42":43,"_41":164,"_138":25,"_39":165,"_13":166,"_34":35,"_36":167,"_24":25,"_142":-5,"_27":168},{"_44":152,"_32":153,"_30":154,"_136":-5,"_42":43,"_41":155,"_138":60,"_39":156,"_13":157,"_34":158,"_36":159,"_24":25,"_142":-5,"_27":160},{"_44":144,"_32":145,"_30":146,"_136":-5,"_42":43,"_41":147,"_138":25,"_39":148,"_13":149,"_34":35,"_36":150,"_24":25,"_142":-5,"_27":151},{"_44":133,"_32":134,"_30":135,"_136":-5,"_42":43,"_41":137,"_138":60,"_39":139,"_13":140,"_34":35,"_36":141,"_24":25,"_142":-5,"_27":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],"17e980a2-05f2-43b5-817a-df674519c027","tmp_sofia.ts","2763627c-9ccf-11f1-93b9-1607ee4eb77e",62,["D",1787255109686],4,"// Temporal: verifica el estado de SofIA despues del cambio.\nimport { DEFAULT_LOCATION_ID as LOC, getToken } from \"./ghl.ts\";\nconst BASE = \"https://services.leadconnectorhq.com\";\nconst AGENT = \"ym6ALxQLYUdZAB90neL8\";\nconst H = {\n Authorization: `Bearer ${getToken(LOC)}`,\n Version: \"2021-07-28\",\n Accept: \"application/json\",\n};\nconst j = await fetch(`${BASE}/conversation-ai/agents/${AGENT}`, { headers: H })\n .then((r) => r.json());\nconst c = j?.agent ?? j;\nconst acciones: Record = {};\nfor (const a of (c.actions ?? [])) acciones[a.type] = (acciones[a.type] ?? 0) + 1;\nconsole.log(JSON.stringify({\n modo: c.mode,\n esPrincipal: c.isPrimary,\n canales: c.channels,\n largoInstrucciones: c.instructions?.length,\n largoPersonalidad: c.personality?.length,\n largoObjetivo: c.goal?.length,\n bloquesDuplicados: [...(c.instructions ?? \"\").matchAll(/###/g)].length,\n acciones,\n basesConocimiento: c.knowledgeBaseIds,\n disparadoresKB: (c.knowledgeBaseTriggers ?? []).length,\n}, null, 1));\n",[145],"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",[153],"4e7e3acd-14cf-4356-b722-f114b5b34495","ghl.ts","ef203a54-6b8a-11f1-8fca-1607ee4eb77e",32,["D",1786934274100],12,"// 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\", \"GHL_TOKEN_LADYS\"],\n [TOPKREATIVA_LOCATION_ID]: [\"PIT_TOPKREATIVA\", \"GHL_TOKEN_TOPKREATIVA\"],\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}",[162],"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",[170],"a289f76a-008f-43ec-bd28-39fe0ce905d0","tmp","a1cefed1-8c8f-43bd-9d06-bed5d085dedc",63,["D",1787263007008],"directory",[178],"pulls","branches","forks","envVars",{"_191":157,"_193":64},"connections",{"_191":64,"_192":64},"count","unfilledCount","emptyCount",{"_44":177,"_32":178,"_30":179,"_136":-5,"_42":43,"_41":180,"_138":60,"_39":221,"_13":64,"_34":182,"_36":-5,"_24":25,"_142":-5,"_202":222,"_27":223},{"_44":217,"_32":33,"_30":31,"_136":179,"_42":43,"_41":14,"_138":25,"_39":218,"_13":174,"_34":35,"_36":38,"_24":25,"_142":-5,"_202":219,"_27":220},{"_44":169,"_32":170,"_30":171,"_136":-5,"_42":43,"_41":172,"_138":60,"_39":214,"_13":174,"_34":20,"_36":175,"_24":25,"_142":-5,"_202":215,"_27":216},{"_44":161,"_32":162,"_30":163,"_136":-5,"_42":43,"_41":164,"_138":25,"_39":211,"_13":166,"_34":35,"_36":167,"_24":25,"_142":-5,"_202":212,"_27":213},{"_44":152,"_32":153,"_30":154,"_136":-5,"_42":43,"_41":155,"_138":60,"_39":208,"_13":157,"_34":158,"_36":159,"_24":25,"_142":-5,"_202":209,"_27":210},{"_44":144,"_32":145,"_30":146,"_136":-5,"_42":43,"_41":147,"_138":25,"_39":205,"_13":149,"_34":35,"_36":150,"_24":25,"_142":-5,"_202":206,"_27":207},{"_44":133,"_32":134,"_30":135,"_136":-5,"_42":43,"_41":137,"_138":60,"_39":201,"_13":140,"_34":35,"_36":141,"_24":25,"_142":-5,"_202":203,"_27":204},["D",1786934288897],"children",[],[134],["D",1787255109686],[],[145],["D",1787180036699],[],[153],["D",1786934274100],[],[162],["D",1786916091360],[],[170],"50c90297-211a-4398-baab-96276fc496c4",["D",1787263020078],[],[178,33],["D",1787263007008],[195],[178],["D",1781837290695],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"ctx",{"_80":-5,"_124":261,"_262":263,"_264":265,"_266":25,"_267":25,"_268":25,"_269":60,"_270":-5,"_271":-7,"_272":-7,"_273":64,"_274":25,"_275":25,"_276":-5,"_277":25,"_278":25,"_279":25,"_280":-5},"ENV",{"_232":233,"_234":235,"_236":88,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260},"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 · v64