[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_171":172,"_173":174},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_107":89,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",33,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","dailyHealthCheck.tsx","latestPath","fileId","12747520-89d5-11f1-8244-1607ee4eb77e","name","fileType","interval","content","/* Chequeo diario de salud + resumen por mail: trial reels de IG + YouTube Shorts.\n Corre 1 vez por dia (7am Madrid). SIEMPRE manda un mail con lo que sale hoy y\n lo que hay en cola. Si ademas encuentra problemas, loguea una fila de alerta\n en Notion \"Content Calendar\". Reusa COMPOSIO_API_KEY del publisher (main.tsx). */\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst COMPOSIO_KEY = Deno.env.get(\"COMPOSIO_API_KEY\");\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst IG_BASE = \"https://graph.instagram.com/v25.0\";\nconst QUEUE_URL =\n \"https://raw.githubusercontent.com/iamnahu1/ig-trial-reels-scheduler/main/queue.json\";\nconst YT_CONN = \"ca_QzaSUHFbLQFD\"; // Nahue Zorzoli (@iamnahu, 160k) bajo este proyecto Composio\nconst YT_UPLOADS_PLAYLIST = \"UUok4yfMRaZr372w-VPebU0A\";\nconst NOTION_CONTENT_CALENDAR_DS = \"cb49d0bf-304a-43b3-b9b4-0cacd7105edc\";\n\nconst HORA = (iso) =>\n new Date(iso).toLocaleString(\"es-ES\", {\n timeZone: \"Europe/Madrid\",\n day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\",\n });\n\nasync function proxy(conn, method, endpoint, body) {\n const p = { connected_account_id: conn, method, endpoint };\n if (body) p.body = body;\n const r = await fetch(\"https://backend.composio.dev/api/v3/tools/execute/proxy\", {\n method: \"POST\",\n headers: { \"x-api-key\": COMPOSIO_KEY, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(p),\n });\n return (await r.json()).data;\n}\n\nasync function checkInstagram(problems, resumen) {\n const q = await (await fetch(QUEUE_URL + \"?t=\" + Date.now())).json();\n const conn = q.connected_account_id;\n const now = Date.now();\n const done = (await blob.getJSON(\"ig_pub_done\")) ?? [];\n const pending = (await blob.getJSON(\"ig_pub_pending\")) ?? {};\n const heartbeat = await blob.getJSON(\"ig_pub_heartbeat\");\n\n if (!heartbeat?.last) {\n problems.push(\"IG: nunca corrió el publisher de trial reels (sin heartbeat).\");\n } else {\n const ageMin = (now - new Date(heartbeat.last).getTime()) / 60000;\n if (ageMin > 40) {\n problems.push(\n `IG: el publisher no corre hace ${Math.round(ageMin)} min (heartbeat: ${heartbeat.last}). Debería correr cada 15 min.`,\n );\n }\n }\n\n const en24h = [], en48h = [];\n for (const e of q.entries ?? []) {\n const id = e.id;\n if (!id || done.includes(id)) continue;\n const t = new Date(e.publish_after_utc).getTime();\n const overdueMin = (now - t) / 60000;\n\n if (overdueMin <= 0) {\n // todavia no vence: lo contamos para el resumen\n const hs = (t - now) / 3600000;\n if (hs <= 24) en24h.push(e);\n else if (hs <= 48) en48h.push(e);\n continue;\n }\n if (pending[id]) {\n if (overdueMin > 360) {\n const status = (await proxy(conn, \"GET\", `${IG_BASE}/${pending[id]}?fields=status_code`))\n ?.status_code;\n problems.push(\n `IG: trial reel \"${id}\" lleva ${Math.round(overdueMin / 60)}h esperando publicación (container ${status ?? \"desconocido\"}).`,\n );\n }\n continue;\n }\n if (overdueMin > 120) {\n problems.push(\n `IG: trial reel \"${id}\" venció hace ${Math.round(overdueMin / 60)}h y el publisher no lo tomó todavía.`,\n );\n }\n }\n\n resumen.igHoy = en24h.map((e) => `${HORA(e.publish_after_utc)} — ${e.id}${e.trial === false ? \" (reel normal)\" : \"\"}`);\n resumen.igManana = en48h.length;\n\n // ---- HUECO QUE FALTABA: la cola vacia ----\n // Avisa un dia ANTES de quedarse sin nada, no el mismo dia.\n if (!en24h.length) {\n problems.push(\n en48h.length\n ? `IG: HOY no sale ningún trial reel (el próximo recién en 24-48h, ${en48h.length} en cola).`\n : \"IG: la cola está VACÍA — no hay nada agendado ni para hoy ni para las próximas 48h. Hay que cargar una tanda nueva.\",\n );\n } else if (!en48h.length) {\n problems.push(\n `IG: hoy salen ${en24h.length}, pero MAÑANA no hay nada agendado. Cargá la próxima tanda hoy.`,\n );\n }\n}\n\nasync function checkYouTube(problems, resumen) {\n const items = await proxy(\n YT_CONN, \"GET\",\n `https://www.googleapis.com/youtube/v3/playlistItems?part=snippet&playlistId=${YT_UPLOADS_PLAYLIST}&maxResults=25`,\n );\n const videoIds = (items?.items ?? []).map((it) => it.snippet?.resourceId?.videoId).filter(Boolean);\n if (!videoIds.length) return;\n const details = await proxy(\n YT_CONN, \"GET\",\n `https://www.googleapis.com/youtube/v3/videos?part=status,snippet&id=${videoIds.join(\",\")}`,\n );\n const now = Date.now();\n const en24h = [], en48h = [];\n\n for (const v of details?.items ?? []) {\n const status = v.status;\n if (!status) continue;\n if (status.privacyStatus === \"private\" && status.publishAt) {\n const t = new Date(status.publishAt).getTime();\n if (now - t > 60 * 60 * 1000) {\n problems.push(\n `YouTube: \"${v.snippet?.title ?? v.id}\" (${v.id}) debía publicarse el ${status.publishAt} y sigue privado.`,\n );\n } else if (t > now) {\n const hs = (t - now) / 3600000;\n const linea = `${HORA(status.publishAt)} — ${v.snippet?.title ?? v.id}`;\n if (hs <= 24) en24h.push(linea);\n else if (hs <= 48) en48h.push(linea);\n }\n }\n }\n\n resumen.ytHoy = en24h;\n resumen.ytManana = en48h.length;\n\n // ---- HUECO QUE FALTABA ----\n // Los Shorts NO se agendan solos: cada tanda hay que subirla a mano.\n if (!en24h.length) {\n problems.push(\n en48h.length\n ? `YouTube: HOY no sale ningún Short (el próximo recién en 24-48h, ${en48h.length} en cola).`\n : \"YouTube: NO hay ningún Short agendado ni para hoy ni para las próximas 48h. Los Shorts no se suben solos, hay que cargar la tanda.\",\n );\n } else if (!en48h.length) {\n problems.push(\n `YouTube: hoy salen ${en24h.length}, pero MAÑANA no hay nada agendado. Cargá la próxima tanda hoy.`,\n );\n }\n}\n\nasync function logAlertToNotion(problems) {\n const today = new Date().toISOString().slice(0, 10);\n const body = {\n parent: { data_source_id: NOTION_CONTENT_CALENDAR_DS },\n properties: {\n Title: {\n title: [{ text: { content: `[ALERT] Health-check ${today} — ${problems.length} problema(s)` } }],\n },\n Status: { select: { name: \"Alert\" } },\n Type: { select: { name: \"Alert\" } },\n Date: { date: { start: new Date().toISOString() } },\n },\n children: problems.map((p) => ({\n object: \"block\",\n type: \"bulleted_list_item\",\n bulleted_list_item: { rich_text: [{ text: { content: p.slice(0, 1900) } }] },\n })),\n };\n const r = await fetch(\"https://api.notion.com/v1/pages\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": \"2025-09-03\",\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n });\n return { status: r.status, data: await r.json() };\n}\n\nfunction armarMail(resumen, problems) {\n const L = [];\n const bloque = (titulo, lineas, manana) => {\n L.push(titulo);\n if (lineas?.length) lineas.forEach((l) => L.push(\" \" + l));\n else L.push(\" (nada agendado)\");\n L.push(` Próximas 24-48h: ${manana ?? 0} más`);\n L.push(\"\");\n };\n if (problems.length) {\n L.push(`ATENCIÓN — ${problems.length} problema(s):`);\n problems.forEach((p) => L.push(\" - \" + p));\n L.push(\"\");\n } else {\n L.push(\"Todo en orden.\");\n L.push(\"\");\n }\n bloque(\"INSTAGRAM (trial reels) — próximas 24h:\", resumen.igHoy, resumen.igManana);\n bloque(\"YOUTUBE (shorts) — próximas 24h:\", resumen.ytHoy, resumen.ytManana);\n L.push(\"Horarios en hora de Madrid.\");\n return L.join(\"\\n\");\n}\n\nexport default async function () {\n const problems = [];\n const errors = [];\n const resumen = { igHoy: [], igManana: 0, ytHoy: [], ytManana: 0 };\n\n try {\n await checkInstagram(problems, resumen);\n } catch (e) {\n errors.push(\"IG check falló: \" + String(e));\n }\n try {\n await checkYouTube(problems, resumen);\n } catch (e) {\n errors.push(\"YouTube check falló: \" + String(e));\n }\n\n const allIssues = [...problems, ...errors];\n\n let notionResult = null;\n if (allIssues.length) {\n try {\n notionResult = await logAlertToNotion(allIssues);\n } catch (e) {\n errors.push(\"Notion falló: \" + String(e));\n }\n }\n\n // El mail sale SIEMPRE, haya problemas o no.\n let mailResult = null;\n try {\n const asunto = allIssues.length\n ? `[Contenido] ${allIssues.length} problema(s) — revisar`\n : `[Contenido] Todo en orden — ${resumen.igHoy.length} reels, ${resumen.ytHoy.length} shorts hoy`;\n await email({ subject: asunto, text: armarMail(resumen, allIssues) });\n mailResult = \"enviado\";\n } catch (e) {\n mailResult = \"falló: \" + String(e);\n }\n\n const result = {\n ranAt: new Date().toISOString(),\n problems: allIssues,\n resumen,\n notion: notionResult?.status ?? null,\n mail: mailResult,\n };\n await blob.setJSON(\"daily_healthcheck_last\", result);\n console.log(JSON.stringify(result, null, 2));\n return result;\n}\n","/* Chequeo de salud + resumen por mail: trial reels de IG + YouTube Shorts.\n SIEMPRE manda un mail con lo que sale hoy y lo que hay en cola.\n\n CAMBIO 2026-08-14 — las alertas ya NO van al Content Calendar y ya NO se\n duplican. Antes creaba una fila NUEVA en cada corrida aunque el problema\n fuera idéntico al de la hora anterior: llegó a 324 filas de alerta contra\n 428 de contenido real, o sea que el calendario quedó sepultado y la alerta\n dejó de funcionar como alerta (2 problemas reales estuvieron días marcados\n sin que nadie los viera). Ahora:\n - Van a su propia base \"🚨 System Alerts\", no al calendario.\n - UNA fila por problema. Si se repite, se actualiza \"Last seen\" y se\n incrementa \"Times seen\" en vez de crear otra.\n - Cuando el problema desaparece, la fila pasa sola a Resolved.\n El estado vive en el blob `healthcheck_alerts` = { firma: pageId }. */\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { email } from \"https://esm.town/v/std/email\";\nconst COMPOSIO_KEY = Deno.env.get(\"COMPOSIO_API_KEY\");\nconst NOTION_TOKEN = Deno.env.get(\"NOTION_TOKEN\");\nconst IG_BASE = \"https://graph.instagram.com/v25.0\";\nconst QUEUE_URL = \"https://raw.githubusercontent.com/iamnahu1/ig-trial-reels-scheduler/main/queue.json\";\nconst YT_CONN = \"ca_QzaSUHFbLQFD\"; // Nahue Zorzoli (@iamnahu, 160k) bajo este proyecto Composio\nconst YT_UPLOADS_PLAYLIST = \"UUok4yfMRaZr372w-VPebU0A\";\nconst NOTION_ALERTS_DS = \"a6f94080-b537-4cc7-91a6-503567d6e2d3\"; // 🚨 System Alerts\nconst ALERTS_BLOB = \"healthcheck_alerts\";\nconst HORA = (iso) => new Date(iso).toLocaleString(\"es-ES\", {\n timeZone: \"Europe/Madrid\",\n day: \"2-digit\", month: \"2-digit\", hour: \"2-digit\", minute: \"2-digit\",\n});\nasync function proxy(conn, method, endpoint, body) {\n const p = { connected_account_id: conn, method, endpoint };\n if (body)\n p.body = body;\n const r = await fetch(\"https://backend.composio.dev/api/v3/tools/execute/proxy\", {\n method: \"POST\",\n headers: { \"x-api-key\": COMPOSIO_KEY, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(p),\n });\n return (await r.json()).data;\n}\nasync function checkInstagram(problems, resumen) {\n const q = await (await fetch(QUEUE_URL + \"?t=\" + Date.now())).json();\n const conn = q.connected_account_id;\n const now = Date.now();\n const done = (await blob.getJSON(\"ig_pub_done\")) ?? [];\n const pending = (await blob.getJSON(\"ig_pub_pending\")) ?? {};\n const heartbeat = await blob.getJSON(\"ig_pub_heartbeat\");\n if (!heartbeat?.last) {\n problems.push(\"IG: nunca corrió el publisher de trial reels (sin heartbeat).\");\n }\n else {\n const ageMin = (now - new Date(heartbeat.last).getTime()) / 60000;\n if (ageMin > 40) {\n problems.push(`IG: el publisher no corre hace ${Math.round(ageMin)} min (heartbeat: ${heartbeat.last}). Debería correr cada 15 min.`);\n }\n }\n const en24h = [], en48h = [];\n for (const e of q.entries ?? []) {\n const id = e.id;\n if (!id || done.includes(id))\n continue;\n const t = new Date(e.publish_after_utc).getTime();\n const overdueMin = (now - t) / 60000;\n if (overdueMin <= 0) {\n const hs = (t - now) / 3600000;\n if (hs <= 24)\n en24h.push(e);\n else if (hs <= 48)\n en48h.push(e);\n continue;\n }\n if (pending[id]) {\n if (overdueMin > 360) {\n const status = (await proxy(conn, \"GET\", `${IG_BASE}/${pending[id]}?fields=status_code`))\n ?.status_code;\n problems.push(`IG: trial reel \"${id}\" lleva ${Math.round(overdueMin / 60)}h esperando publicación (container ${status ?? \"desconocido\"}).`);\n }\n continue;\n }\n if (overdueMin > 120) {\n problems.push(`IG: trial reel \"${id}\" venció hace ${Math.round(overdueMin / 60)}h y el publisher no lo tomó todavía.`);\n }\n }\n resumen.igHoy = en24h.map((e) => `${HORA(e.publish_after_utc)} — ${e.id}${e.trial === false ? \" (reel normal)\" : \"\"}`);\n resumen.igManana = en48h.length;\n if (!en24h.length) {\n problems.push(en48h.length\n ? `IG: HOY no sale ningún trial reel (el próximo recién en 24-48h, ${en48h.length} en cola).`\n : \"IG: la cola está VACÍA — no hay nada agendado ni para hoy ni para las próximas 48h. Hay que cargar una tanda nueva.\");\n }\n else if (!en48h.length) {\n problems.push(`IG: hoy salen ${en24h.length}, pero MAÑANA no hay nada agendado. Cargá la próxima tanda hoy.`);\n }\n}\nasync function checkYouTube(problems, resumen) {\n const items = await proxy(YT_CONN, \"GET\", `https://www.googleapis.com/youtube/v3/playlistItems?part=snippet&playlistId=${YT_UPLOADS_PLAYLIST}&maxResults=25`);\n const videoIds = (items?.items ?? []).map((it) => it.snippet?.resourceId?.videoId).filter(Boolean);\n if (!videoIds.length)\n return;\n const details = await proxy(YT_CONN, \"GET\", `https://www.googleapis.com/youtube/v3/videos?part=status,snippet&id=${videoIds.join(\",\")}`);\n const now = Date.now();\n const en24h = [], en48h = [];\n for (const v of details?.items ?? []) {\n const status = v.status;\n if (!status)\n continue;\n if (status.privacyStatus === \"private\" && status.publishAt) {\n const t = new Date(status.publishAt).getTime();\n if (now - t > 60 * 60 * 1000) {\n problems.push(`YouTube: \"${v.snippet?.title ?? v.id}\" (${v.id}) debía publicarse el ${status.publishAt} y sigue privado.`);\n }\n else if (t > now) {\n const hs = (t - now) / 3600000;\n const linea = `${HORA(status.publishAt)} — ${v.snippet?.title ?? v.id}`;\n if (hs <= 24)\n en24h.push(linea);\n else if (hs <= 48)\n en48h.push(linea);\n }\n }\n }\n resumen.ytHoy = en24h;\n resumen.ytManana = en48h.length;\n if (!en24h.length) {\n problems.push(en48h.length\n ? `YouTube: HOY no sale ningún Short (el próximo recién en 24-48h, ${en48h.length} en cola).`\n : \"YouTube: NO hay ningún Short agendado ni para hoy ni para las próximas 48h. Los Shorts no se suben solos, hay que cargar la tanda.\");\n }\n else if (!en48h.length) {\n problems.push(`YouTube: hoy salen ${en24h.length}, pero MAÑANA no hay nada agendado. Cargá la próxima tanda hoy.`);\n }\n}\n/* La firma es el problema SIN los números. Sin esto el dedupe no sirve para\n nada: \"venció hace 3h\" y \"venció hace 4h\" son el mismo problema y a la hora\n siguiente crearían una fila nueva igual. */\nconst firmaDe = (p) => p.replace(/\\d+/g, \"#\").slice(0, 220);\nconst fuenteDe = (p) => p.startsWith(\"IG:\") ? \"Instagram\" : p.startsWith(\"YouTube:\") ? \"YouTube\" : \"System\";\nasync function notion(path, method, body) {\n const r = await fetch(\"https://api.notion.com/v1/\" + path, {\n method,\n headers: {\n \"Authorization\": `Bearer ${NOTION_TOKEN}`,\n \"Notion-Version\": \"2025-09-03\",\n \"Content-Type\": \"application/json\",\n },\n body: body ? JSON.stringify(body) : undefined,\n });\n return { status: r.status, data: await r.json() };\n}\nasync function syncAlerts(problems) {\n const ahora = new Date().toISOString();\n const previas = (await blob.getJSON(ALERTS_BLOB)) ?? {};\n const vigentes = {};\n let creadas = 0, actualizadas = 0, resueltas = 0;\n for (const p of problems) {\n const firma = firmaDe(p);\n const anterior = previas[firma];\n if (anterior?.pageId) {\n const veces = (anterior.veces ?? 1) + 1;\n await notion(`pages/${anterior.pageId}`, \"PATCH\", {\n properties: {\n \"Last seen\": { date: { start: ahora } },\n \"Times seen\": { number: veces },\n \"Detail\": { rich_text: [{ text: { content: p.slice(0, 1900) } }] },\n },\n });\n vigentes[firma] = { pageId: anterior.pageId, veces, first: anterior.first ?? ahora };\n actualizadas++;\n }\n else {\n const r = await notion(\"pages\", \"POST\", {\n parent: { data_source_id: NOTION_ALERTS_DS },\n properties: {\n Alert: { title: [{ text: { content: p.slice(0, 120) } }] },\n Status: { select: { name: \"Open\" } },\n Source: { select: { name: fuenteDe(p) } },\n \"First seen\": { date: { start: ahora } },\n \"Last seen\": { date: { start: ahora } },\n \"Times seen\": { number: 1 },\n Detail: { rich_text: [{ text: { content: p.slice(0, 1900) } }] },\n },\n });\n const pageId = r.data?.id;\n if (pageId) {\n vigentes[firma] = { pageId, veces: 1, first: ahora };\n creadas++;\n }\n }\n }\n // Lo que estaba abierto y ya no aparece: se cierra solo.\n for (const [firma, info] of Object.entries(previas)) {\n if (vigentes[firma] || !info?.pageId)\n continue;\n await notion(`pages/${info.pageId}`, \"PATCH\", {\n properties: { Status: { select: { name: \"Resolved\" } }, \"Last seen\": { date: { start: ahora } } },\n });\n resueltas++;\n }\n await blob.setJSON(ALERTS_BLOB, vigentes);\n return { creadas, actualizadas, resueltas, abiertas: Object.keys(vigentes).length };\n}\nfunction armarMail(resumen, problems) {\n const L = [];\n const bloque = (titulo, lineas, manana) => {\n L.push(titulo);\n if (lineas?.length)\n lineas.forEach((l) => L.push(\" \" + l));\n else\n L.push(\" (nada agendado)\");\n L.push(` Próximas 24-48h: ${manana ?? 0} más`);\n L.push(\"\");\n };\n if (problems.length) {\n L.push(`ATENCIÓN — ${problems.length} problema(s):`);\n problems.forEach((p) => L.push(\" - \" + p));\n L.push(\"\");\n }\n else {\n L.push(\"Todo en orden.\");\n L.push(\"\");\n }\n bloque(\"INSTAGRAM (trial reels) — próximas 24h:\", resumen.igHoy, resumen.igManana);\n bloque(\"YOUTUBE (shorts) — próximas 24h:\", resumen.ytHoy, resumen.ytManana);\n L.push(\"Horarios en hora de Madrid.\");\n return L.join(\"\\n\");\n}\nexport default async function () {\n const problems = [];\n const errors = [];\n const resumen = { igHoy: [], igManana: 0, ytHoy: [], ytManana: 0 };\n try {\n await checkInstagram(problems, resumen);\n }\n catch (e) {\n errors.push(\"IG check falló: \" + String(e));\n }\n try {\n await checkYouTube(problems, resumen);\n }\n catch (e) {\n errors.push(\"YouTube check falló: \" + String(e));\n }\n const allIssues = [...problems, ...errors];\n /* Corre SIEMPRE, aunque no haya problemas: es lo que cierra las alertas\n viejas cuando el problema se arregló. */\n let alertResult = null;\n try {\n alertResult = await syncAlerts(allIssues);\n }\n catch (e) {\n errors.push(\"Notion falló: \" + String(e));\n }\n let mailResult = null;\n try {\n const asunto = allIssues.length\n ? `[Contenido] ${allIssues.length} problema(s) — revisar`\n : `[Contenido] Todo en orden — ${resumen.igHoy.length} reels, ${resumen.ytHoy.length} shorts hoy`;\n await email({ subject: asunto, text: armarMail(resumen, allIssues) });\n mailResult = \"enviado\";\n }\n catch (e) {\n mailResult = \"falló: \" + String(e);\n }\n const result = {\n ranAt: new Date().toISOString(),\n problems: allIssues,\n resumen,\n alerts: alertResult,\n mail: mailResult,\n };\n await blob.setJSON(\"daily_healthcheck_last\", result);\n console.log(JSON.stringify(result, null, 2));\n return result;\n}\n","createdAt",["D",1786698685192],"branchVersion","branchId","70413a23-ca0e-468f-bc3e-7580c99aa9ed","id","84def699-d13f-4b0e-8c5c-eab6257b03e9","ig-trial-publisher",["D",1784267546459],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","4f697cf8-1ced-486a-b318-a1e07ff932c5","pinnedFileId","eef34574-81a3-11f1-93b1-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f6e9c-868d-714a-870e-9003938a9e24","tursoName","84def699d13f4b0e8c5ceab6257b03e9","tursoHostname","84def699d13f4b0e8c5ceab6257b03e9-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789515657103],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":102},"org",{"_99":98,"_100":98,"_101":102,"_18":54,"_103":104,"_105":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",35,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","iamnahu1","handle","displayName","avatar","https://avatars.githubusercontent.com/u/299062365?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":166,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":167,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":168,"_83":169,"_85":170,"_87":25},"tree",[157,158],"files",[157,158],"counts",{"_145":62,"_146":147,"_148":62,"_149":150,"_151":152},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":141,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":58,"_38":142,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_27":144},{"_43":131,"_32":132,"_30":56,"_133":-5,"_41":42,"_40":134,"_135":58,"_38":136,"_13":137,"_33":34,"_35":138,"_24":25,"_139":-5,"_27":140},"27953e2c-9dbc-4b85-b711-11cc7ef17e6a","main.tsx","parentId",31,"latest",["D",1785518253021],6,"/* Open in Val Town: https://www.val.town/x/iamnahu1/ig-trial-publisher/code/main.tsx */\nimport { blob } from \"https://esm.town/v/std/blob\";\nexport default async function () {\n const KEY = Deno.env.get(\"COMPOSIO_API_KEY\");\n const BASE = \"https://graph.instagram.com/v25.0\";\n const QUEUE_URL = \"https://raw.githubusercontent.com/iamnahu1/ig-trial-reels-scheduler/main/queue.json\";\n // Free tier corta a los 60s de wall clock. Dejamos margen para cerrar y\n // escribir los blobs de estado antes de que nos maten.\n const DEADLINE_MS = 40_000;\n const t0 = Date.now();\n const outOfTime = () => Date.now() - t0 > DEADLINE_MS;\n async function proxy(conn, method, endpoint, body) {\n const p = { connected_account_id: conn, method, endpoint };\n if (body)\n p.body = body;\n const r = await fetch(\"https://backend.composio.dev/api/v3/tools/execute/proxy\", {\n method: \"POST\",\n headers: { \"x-api-key\": KEY, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(p),\n });\n return (await r.json()).data;\n }\n async function uguu(bytes) {\n const fd = new FormData();\n fd.append(\"files[]\", new Blob([bytes], { type: \"video/mp4\" }), \"v.mp4\");\n const up = await fetch(\"https://uguu.se/upload\", { method: \"POST\", body: fd });\n return (await up.json())?.files?.[0]?.url;\n }\n const log = [];\n try {\n const q = await (await fetch(QUEUE_URL + \"?t=\" + Date.now())).json();\n const now = Date.now();\n // Multi-cuenta: cada entrada puede traer su propia cuenta. Si no la trae,\n // hereda la del top-level (compatibilidad con todas las entradas viejas).\n const acctOf = (e) => ({\n conn: e.connected_account_id ?? q.connected_account_id,\n ig: e.ig_user_id ?? q.ig_user_id,\n expect: e.expect_username ?? q.expect_username ?? null,\n });\n // Guardrail: antes de crear o publicar, confirmar con la Graph API que la\n // conexion es la cuenta que la entrada dice esperar. Si no coincide, no se\n // toca nada. Esto es lo que evita publicar en el Instagram equivocado.\n const meCache = {};\n const cuentaOk = async (a, id) => {\n if (!a.conn) {\n log.push(`${id}: sin connected_account_id, skip`);\n return false;\n }\n if (!a.expect)\n return true;\n if (meCache[a.conn] === undefined) {\n const me = await proxy(a.conn, \"GET\", `${BASE}/me?fields=username,user_id`);\n meCache[a.conn] = me?.username ?? null;\n }\n if (meCache[a.conn] !== a.expect) {\n log.push(`${id}: CUENTA EQUIVOCADA (esperaba @${a.expect}, la conexion es @${meCache[a.conn]}) - NO se publica`);\n return false;\n }\n return true;\n };\n const done = (await blob.getJSON(\"ig_pub_done\")) ?? [];\n const pending = (await blob.getJSON(\"ig_pub_pending\")) ?? {};\n // blob_key de videos ya subidos a IG, pendientes de borrar (se borran\n // recien cuando el post esta PUBLISHED, no antes).\n const garbage = (await blob.getJSON(\"ig_pub_garbage\")) ?? {};\n const persist = async () => {\n await blob.setJSON(\"ig_pub_done\", done);\n await blob.setJSON(\"ig_pub_pending\", pending);\n await blob.setJSON(\"ig_pub_garbage\", garbage);\n };\n // Borra el video del blob una vez que el post ya salio. Si falla, no pasa\n // nada: se reintenta en la proxima corrida.\n const dropVideo = async (id) => {\n const key = garbage[id];\n if (!key)\n return;\n try {\n await blob.delete(key);\n }\n catch (_) { /* el blob ya no existe, seguimos */ }\n delete garbage[id];\n };\n // ---- Fase A: publicar containers pendientes que ya estan FINISHED ----\n // Barato (GET + POST por entrada), no lo limitamos por cantidad.\n for (const [id, raw] of Object.entries(pending)) {\n // Compat: las entradas viejas guardaban solo el creation_id (string).\n // Esas son de la cuenta del top-level.\n const p = typeof raw === \"string\"\n ? { cid: raw, conn: q.connected_account_id, ig: q.ig_user_id, expect: q.expect_username ?? null }\n : raw;\n const cid = p.cid;\n if (!(await cuentaOk(p, id)))\n continue;\n const status = (await proxy(p.conn, \"GET\", `${BASE}/${cid}?fields=status_code`))\n ?.status_code;\n if (status === \"FINISHED\") {\n const pub = await proxy(p.conn, \"POST\", `${BASE}/${p.ig}/media_publish`, {\n creation_id: cid,\n });\n done.push(id);\n delete pending[id];\n await dropVideo(id);\n log.push(`${id}: PUBLICADO ${pub?.id}`);\n }\n else if (status === \"PUBLISHED\") {\n done.push(id);\n delete pending[id];\n await dropVideo(id);\n log.push(`${id}: ya publicado`);\n }\n else if (status === \"ERROR\") {\n delete pending[id];\n log.push(`${id}: container ERROR (reintenta)`);\n }\n else {\n log.push(`${id}: procesando (${status})`);\n }\n if (outOfTime()) {\n log.push(\"fase A: sin tiempo, sigo en el proximo tick\");\n break;\n }\n }\n // ---- Fase B: procesar entradas vencidas ----\n // Crear un container implica bajar el video del blob, subirlo a uguu.se y\n // llamar a la Graph API: 15-25s cada uno. Con el limite de 60s del free\n // tier, hacemos COMO MAXIMO UNO por corrida. Con 96 ticks por dia sobra.\n let creadoEsteTick = false;\n for (const e of q.entries ?? []) {\n const id = e.id;\n if (!id || done.includes(id) || pending[id])\n continue;\n if (now < new Date(e.publish_after_utc).getTime())\n continue;\n const a = acctOf(e);\n if (!(await cuentaOk(a, id)))\n continue;\n const conn = a.conn, ig = a.ig;\n if (e.creation_id) {\n // Legacy: container ya creado por fuera. Es barato, no cuenta contra\n // el limite de uno por tick.\n const status = (await proxy(conn, \"GET\", `${BASE}/${e.creation_id}?fields=status_code`))?.status_code;\n if (status === \"PUBLISHED\") {\n done.push(id);\n log.push(`${id}: ya publicado`);\n }\n else if (status === \"FINISHED\") {\n const pub = await proxy(conn, \"POST\", `${BASE}/${ig}/media_publish`, {\n creation_id: e.creation_id,\n });\n done.push(id);\n log.push(`${id}: PUBLICADO ${pub?.id}`);\n }\n else {\n log.push(`${id}: container ${status}, skip`);\n }\n }\n else if (e.blob_key) {\n if (creadoEsteTick) {\n log.push(`${id}: en cola, va en el proximo tick`);\n continue;\n }\n if (outOfTime()) {\n log.push(`${id}: sin tiempo, va en el proximo tick`);\n continue;\n }\n let bytes;\n try {\n const res = await blob.get(e.blob_key);\n bytes = new Uint8Array(await res.arrayBuffer());\n }\n catch (_) {\n log.push(`${id}: blob \"${e.blob_key}\" no existe, REVISAR (no se publica)`);\n continue;\n }\n if (!bytes?.length) {\n log.push(`${id}: blob \"${e.blob_key}\" vacio, REVISAR`);\n continue;\n }\n const url = await uguu(bytes);\n if (!url) {\n // uguu.se caido o rate-limited. No tocamos nada: se reintenta solo.\n log.push(`${id}: uguu.se fallo, reintenta`);\n continue;\n }\n // trial por defecto; \"trial\": false en la entrada = reel normal.\n const body = {\n media_type: \"REELS\",\n video_url: url,\n caption: e.caption ?? \"\",\n };\n if (e.trial !== false) {\n body.trial_params = { graduation_strategy: \"MANUAL\" };\n }\n const cont = await proxy(conn, \"POST\", `${BASE}/${ig}/media`, body);\n if (cont?.id) {\n // Guardamos la cuenta junto al container: la fase A publica en el\n // proximo tick y tiene que saber por donde salir.\n pending[id] = { cid: cont.id, conn, ig, expect: a.expect };\n // El video se borra recien cuando el post este PUBLISHED (fase A).\n // Si borraramos aca y la corrida muriera antes de persistir, el reel\n // se perderia para siempre sin aviso.\n garbage[id] = e.blob_key;\n await persist();\n creadoEsteTick = true;\n log.push(`${id}: container creado ${cont.id}${e.trial === false ? \" (normal)\" : \" (trial)\"} @${a.expect ?? \"?\"}`);\n }\n else {\n log.push(`${id}: fallo crear container ${JSON.stringify(cont)}`);\n }\n }\n }\n await persist();\n }\n catch (err) {\n log.push(\"ERROR: \" + String(err));\n }\n try {\n await blob.setJSON(\"ig_pub_heartbeat\", {\n last: new Date().toISOString(),\n ms: Date.now() - t0,\n log,\n });\n }\n catch (err) {\n // El heartbeat es diagnostico: que falle no debe tumbar la corrida.\n log.push(\"heartbeat fallo: \" + String(err));\n }\n console.log(JSON.stringify(log));\n}\n","label",[132],"956f833a-960e-414f-9fe2-72165919c847",["D",1786698685192],4,[28],"pulls","branches",1,"forks","envVars",{"_153":155,"_156":62},"connections",{"_153":62,"_154":62},"count","unfilledCount",2,"emptyCount",{"_43":141,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_135":58,"_38":163,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_160":164,"_27":165},{"_43":131,"_32":132,"_30":56,"_133":-5,"_41":42,"_40":134,"_135":58,"_38":159,"_13":137,"_33":34,"_35":138,"_24":25,"_139":-5,"_160":161,"_27":162},["D",1785518253021],"children",[],[132],["D",1786698685192],[],[28],["D",1784267546459],["D",1789515657103],{"_99":98,"_106":102},{"_99":98,"_100":98,"_101":102,"_18":54,"_103":104,"_105":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_126":204,"_205":206,"_207":208,"_209":25,"_210":25,"_211":25,"_212":58,"_213":-5,"_214":-7,"_215":-7,"_216":62,"_217":25,"_218":25,"_219":-5,"_220":25,"_221":25,"_222":25,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":89,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v33