[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","iaparatodosig","name","trucos-de-ia","path","leads.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/iaparatodosig/trucos-de-ia/code/leads.ts","extension","id","a13f6eea-5894-4cc4-8df4-42d043efa818","fileId","b68ac81c-9be1-11f1-b7af-1607ee4eb77e","parentId","branchId","d66cfc4d-a355-43ce-a1b2-7255690ecf45","branchVersion",100,"latest",true,"createdAt",["D",1787157786823],"version",8,"fileType","interval","content","// Cron cada 15 min (19/08/2026): comentario con palabra clave → DM con el PDF.\n//\n// Lee los comentarios de los posts con campaña \"lead\" (el recopilatorio mensual\n// fijado en el perfil: \"comenta PDF y te lo mando\") y, a cada comentario que\n// contenga la palabra clave, le contesta con un mensaje privado (private reply\n// de la API de Meta: un DM por comentario, dentro de los 7 días siguientes) y\n// una respuesta pública corta. Registro en SQLite (tabla leads), aviso por\n// Telegram con los usuarios atendidos.\n//\n// Por qué sondeo cada 15 min y no webhook: los webhooks de comentarios exigen\n// app en Live + acceso avanzado + verificación de empresa. Leer comentarios y\n// mandar private replies desde la cuenta propia solo exige la app en Live (en\n// modo desarrollo Meta oculta los comentarios de usuarios sin rol en la app:\n// comprobado el 19/08/2026, data:[] con comments_count=2). La latencia de\n// 15 min es la misma que la de la automatización nativa de Meta Business Suite.\n//\n// Campañas: las define el bloque \"lead\" del JSON del post en Airtable\n// ({palabras, url, dm, respuesta_publica}); lo escribe tools/recopilatorio.py.\n// Pausar/reanudar desde el bot: \"leads off \" / \"leads on \".\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { postsConLead } from \"./airtable.ts\";\nimport { getToken } from \"./token.ts\";\nimport { enviarTelegram } from \"./telegram.ts\";\n\nconst GRAPH = \"https://graph.instagram.com/v23.0\";\nconst VENTANA_DIAS = 7; // Meta solo admite private reply a comentarios de ≤ 7 días\nconst MAX_POR_PASADA = 12; // cada envío son 2 llamadas; el plan Free corta a 1 min\nconst MAX_PAGINAS = 6; // 6 × 50 comentarios por post y pasada\nconst MAX_INTENTOS = 3;\nconst CUENTA_PROPIA = \"trucos.de.ia\";\nconst PAUSADAS_KEY = \"leads/pausadas.json\";\n\nexport async function asegurarTablas() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS leads (\n comment_id TEXT PRIMARY KEY,\n slug TEXT, media_id TEXT, username TEXT, texto TEXT, comentado_en TEXT,\n estado TEXT, intentos INTEGER DEFAULT 0, error TEXT, actualizado TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS descargas (\n id INTEGER PRIMARY KEY AUTOINCREMENT, edicion TEXT, fecha TEXT, ua TEXT)`);\n}\n\nfunction normaliza(s: string): string {\n return s.normalize(\"NFD\").replace(/[̀-ͯ]/g, \"\").toLowerCase();\n}\n\n// \"PDF\", \"pdf!\", \"Quiero el Pdf 🙏\" → sí; \"pdfs\" → no (palabra entera, sin tildes ni mayúsculas).\nexport function coincide(texto: string, palabras: string[]): boolean {\n const t = normaliza(texto);\n return palabras.some((p) => {\n const re = normaliza(p).replace(/[.*+?^${}()|[\\]\\\\]/g, \"\\\\$&\");\n return new RegExp(`(^|[^a-z0-9])${re}($|[^a-z0-9])`).test(t);\n });\n}\n\n// OJO (comprobado en Live el 19/08/2026): el campo plano `username` NO viene en\n// /comments con Instagram Login; el usuario llega en `from{id,username}`.\ninterface Comentario {\n id: string;\n text?: string;\n username?: string;\n from?: { id?: string; username?: string };\n timestamp?: string;\n}\n\nfunction usuarioDe(c: Comentario): string {\n return c.from?.username ?? c.username ?? \"\";\n}\n\nasync function graphGet(path: string, token: string) {\n const res = await fetch(`${GRAPH}/${path}${path.includes(\"?\") ? \"&\" : \"?\"}access_token=${token}`);\n const data = await res.json();\n if (!res.ok || data.error) throw new Error(`Meta: ${JSON.stringify(data.error ?? data)}`);\n return data;\n}\n\nasync function graphJson(path: string, body: unknown, token: string) {\n const res = await fetch(`${GRAPH}/${path}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", Authorization: `Bearer ${token}` },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (!res.ok || data.error) throw new Error(`Meta ${res.status}: ${JSON.stringify(data.error ?? data)}`);\n return data;\n}\n\nasync function graphForm(path: string, params: Record, token: string) {\n const res = await fetch(`${GRAPH}/${path}`, {\n method: \"POST\",\n body: new URLSearchParams({ ...params, access_token: token }),\n });\n const data = await res.json();\n if (!res.ok || data.error) throw new Error(`Meta ${res.status}: ${JSON.stringify(data.error ?? data)}`);\n return data;\n}\n\nfunction fecha(ts?: string): number {\n return ts ? Date.parse(ts.replace(/\\+0000$/, \"Z\")) : 0;\n}\n\n// Comentarios (y respuestas anidadas) del media más recientes que `desde`.\n// Paginación acotada; si Meta los devuelve de nuevo a viejo, se corta en cuanto\n// una página entera queda fuera de la ventana.\nasync function comentariosRecientes(mediaId: string, token: string, desde: number): Promise {\n const out: Comentario[] = [];\n let path = `${mediaId}/comments?fields=id,text,timestamp,from,replies{id,text,timestamp,from}&limit=50`;\n let nuevoAViejo: boolean | null = null;\n for (let pag = 0; pag < MAX_PAGINAS && path; pag++) {\n const data = await graphGet(path, token);\n const lote: Comentario[] = data.data ?? [];\n if (!lote.length) break;\n if (nuevoAViejo === null && lote.length > 1) nuevoAViejo = fecha(lote[0].timestamp) >= fecha(lote[lote.length - 1].timestamp);\n let algunoDentro = false;\n for (const c of lote) {\n const hijos: Comentario[] = (c as { replies?: { data?: Comentario[] } }).replies?.data ?? [];\n for (const x of [c, ...hijos]) {\n if (fecha(x.timestamp) >= desde) {\n out.push(x);\n algunoDentro = true;\n }\n }\n }\n if (nuevoAViejo && !algunoDentro) break;\n const next = data.paging?.next as string | undefined;\n path = next ? next.replace(`${GRAPH}/`, \"\").replace(/([?&])access_token=[^&]*&?/, \"$1\").replace(/[?&]$/, \"\") : \"\";\n }\n return out;\n}\n\nasync function registrar(\n c: Comentario,\n slug: string,\n mediaId: string,\n estado: string,\n intentos: number,\n error: string | null,\n) {\n await sqlite.execute({\n sql: `INSERT INTO leads (comment_id, slug, media_id, username, texto, comentado_en, estado, intentos, error, actualizado)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(comment_id) DO UPDATE SET estado = excluded.estado, intentos = excluded.intentos,\n error = excluded.error, actualizado = excluded.actualizado`,\n args: [\n c.id, slug, mediaId, usuarioDe(c), (c.text ?? \"\").slice(0, 300), c.timestamp ?? \"\",\n estado, intentos, error, new Date().toISOString(),\n ],\n });\n}\n\nexport async function pausadas(): Promise {\n return ((await blob.getJSON(PAUSADAS_KEY).catch(() => null)) as string[] | null) ?? [];\n}\n\nexport async function setPausada(slug: string, pausar: boolean): Promise {\n const lista = (await pausadas()).filter((s) => s !== slug);\n if (pausar) lista.push(slug);\n await blob.setJSON(PAUSADAS_KEY, lista);\n}\n\n// Resumen para el comando \"leads\" del bot.\nexport async function resumenLeads(): Promise {\n await asegurarTablas();\n const hoy = new Date().toISOString().slice(0, 10);\n const mes = hoy.slice(0, 7);\n const tot = await sqlite.execute(\n `SELECT slug, estado, COUNT(*) AS n, SUM(CASE WHEN substr(actualizado,1,10) = '${hoy}' THEN 1 ELSE 0 END) AS hoy,\n SUM(CASE WHEN substr(actualizado,1,7) = '${mes}' THEN 1 ELSE 0 END) AS mes\n FROM leads GROUP BY slug, estado ORDER BY slug`,\n );\n const desc = await sqlite.execute(\n `SELECT edicion, COUNT(*) AS n, SUM(CASE WHEN substr(fecha,1,10) = '${hoy}' THEN 1 ELSE 0 END) AS hoy\n FROM descargas GROUP BY edicion ORDER BY edicion`,\n );\n const ultimos = await sqlite.execute(\n `SELECT username, slug, actualizado FROM leads WHERE estado = 'enviado' ORDER BY actualizado DESC LIMIT 8`,\n );\n const lineas: string[] = [\"📩 Leads (comentario → DM):\"];\n if (!tot.rows.length) lineas.push(\"· todavía ninguno\");\n for (const r of tot.rows as Array>) {\n lineas.push(`· ${r.slug} — ${r.estado}: ${r.n} (hoy ${r.hoy}, este mes ${r.mes})`);\n }\n lineas.push(\"\", \"⬇️ Descargas del PDF (clics en el enlace):\");\n if (!desc.rows.length) lineas.push(\"· todavía ninguna\");\n for (const r of desc.rows as Array>) lineas.push(`· ${r.edicion}: ${r.n} (hoy ${r.hoy})`);\n if (ultimos.rows.length) {\n lineas.push(\"\", \"Últimos atendidos: \" + (ultimos.rows as Array>).map((r) => `@${r.username}`).join(\", \"));\n }\n const p = await pausadas();\n if (p.length) lineas.push(\"\", `⏸ Campañas pausadas: ${p.join(\", \")}`);\n return lineas.join(\"\\n\");\n}\n\nexport default async function () {\n const token = await getToken();\n const igId = Deno.env.get(\"IG_USER_ID\");\n if (!token || !igId) return { saltado: \"Meta sin configurar\" };\n const campanas = await postsConLead();\n if (!campanas.length) return { saltado: \"sin campañas activas\" };\n await asegurarTablas();\n const enPausa = await pausadas();\n const desde = Date.now() - VENTANA_DIAS * 86_400_000;\n const enviados: string[] = [];\n const avisos: string[] = [];\n let presupuesto = MAX_POR_PASADA;\n\n for (const camp of campanas) {\n if (enPausa.includes(camp.slug)) continue;\n const map = (await blob.getJSON(`igmedia/${camp.id}.json`).catch(() => null)) as { mediaId: string } | null;\n if (!map) continue; // aún sin publicar o sin mapping\n let comentarios: Comentario[];\n try {\n comentarios = await comentariosRecientes(map.mediaId, token, desde);\n } catch (e) {\n avisos.push(`${camp.slug}: no pude leer comentarios — ${e instanceof Error ? e.message.slice(0, 120) : e}`);\n continue;\n }\n for (const c of comentarios) {\n if (presupuesto <= 0) break;\n const usuario = usuarioDe(c);\n if (!usuario || usuario === CUENTA_PROPIA) continue;\n if (!coincide(c.text ?? \"\", camp.lead.palabras)) continue;\n const prev = await sqlite.execute({ sql: \"SELECT estado, intentos FROM leads WHERE comment_id = ?\", args: [c.id] });\n const fila = prev.rows[0] as { estado: string; intentos: number } | undefined;\n if (fila && (fila.estado !== \"error\" || fila.intentos >= MAX_INTENTOS)) continue;\n const intentos = (fila?.intentos ?? 0) + 1;\n presupuesto--;\n try {\n await graphJson(`${igId}/messages`, { recipient: { comment_id: c.id }, message: { text: camp.lead.dm } }, token);\n if (camp.lead.respuesta_publica) {\n await graphForm(`${c.id}/replies`, { message: camp.lead.respuesta_publica }, token).catch(() => {});\n }\n await registrar(c, camp.slug, map.mediaId, \"enviado\", intentos, null);\n enviados.push(`@${usuario}`);\n } catch (e) {\n const msg = e instanceof Error ? e.message : String(e);\n // ya tenía private reply (subcódigo 2534014) → dar por enviado; fuera de\n // los 7 días → expirado; lo demás se reintenta hasta MAX_INTENTOS.\n let estado = \"error\";\n if (/2534014|already been sent|only one/i.test(msg)) estado = \"enviado\";\n else if (/7 days|window|too old|2534022/i.test(msg)) estado = \"expirado\";\n await registrar(c, camp.slug, map.mediaId, estado, intentos, estado === \"error\" ? msg.slice(0, 300) : null);\n if (estado === \"error\" && (intentos === 1 || intentos >= MAX_INTENTOS)) {\n avisos.push(\n `@${usuario} (${camp.slug}): ${msg.slice(0, 140)}${intentos >= MAX_INTENTOS ? \" — me rindo\" : \" — reintento\"}`,\n );\n }\n }\n }\n }\n if (enviados.length) {\n await enviarTelegram(`📩 PDF enviado por DM a ${enviados.length}: ${enviados.join(\", \")}`);\n }\n if (avisos.length) await enviarTelegram(`⚠️ Leads:\\n${avisos.join(\"\\n\")}`);\n return { enviados, avisos };\n}\n","deleted",false,"label",[14],"aff7e71b-a886-4acb-9c3c-ed0dba233db8",["D",1785163109209],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Automatización del canal @trucos.de.ia: webhook Telegram + cron","imageUrl","userId","7466c9e5-2d6f-472c-ae9e-1a257c0b2e02","pinnedFileId","11f6b8e4-89c9-11f1-ab7d-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa400-6d33-70ee-9f1b-d2bfe1a8dd3d","tursoName","aff7e71ba8864acb9c3ced0dba233db8","tursoHostname","aff7e71ba8864acb9c3ced0dba233db8-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789484509295],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":100},"org",{"_9":10,"_99":100,"_101":100,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",176,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]