[{"_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",{"_98":97,"_32":45,"_106":88,"_27":100,"_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":123,"_124":-5,"_125":-5,"_126":127},"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":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_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",13,"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","main.ts","latestPath","fileId","f324775a-7b89-11f1-92c3-1607ee4eb77e","name","fileType","http","content","// ============================================================\n// BOT DE RECORDATORIOS DE PAGOS (seguros, impuestos, etc.)\n// ============================================================\n// COMANDOS:\n// /añadir -> flujo: grupo (botones) -> importe -> fecha -> días de aviso\n// /lista -> ver todos tus pagos\n// /grupos -> ver tus grupos\n// /borrar -> eliminar un pago\n// /cancelar -> cancelar cualquier flujo en curso\n//\n// El cron (val aparte) es quien manda los avisos día a día y gestiona\n// los botones de \"ya renovado\" / \"posponer\". Este val solo:\n// 1) gestiona el alta de pagos (/añadir)\n// 2) responde a los botones que manda el cron cuando el usuario los pulsa\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nconst API = `https://api.telegram.org/bot${TOKEN}`;\n\n// Grupos que se crean automáticamente la primera vez que un usuario los necesita\nconst GRUPOS_POR_DEFECTO = [\"Impuesto\", \"Seguro\"];\n\n// ============================================================\n// HELPER ANTI-SORPRESAS: sqlite.execute a veces devuelve cada fila\n// como un ARRAY posicional (row[0], row[1]...) y a veces como un\n// OBJETO con las columnas como claves (row.nombre, row.importe...).\n// Esta función funciona en los dos casos, así el resto del código\n// no se rompe si el comportamiento cambia.\n//\n// Uso: val(row, 0, \"nombre\") -> intenta row[0], si no existe prueba row[\"nombre\"]\n// ============================================================\nfunction val(row: any, index: number, key: string) {\n if (Array.isArray(row)) return row[index];\n return row[key];\n}\n\n// ============================================================\n// BASE DE DATOS\n// ============================================================\nasync function initDb() {\n // ⚠️ Estamos en fase de pruebas: borramos la tabla vieja (con estructura\n // antigua, sin la columna dias_aviso) para que se recree con la estructura\n // completa de abajo. Esto borra los pagos que tuvieras guardados.\n // Quita esta línea cuando ya no quieras perder datos entre cambios de código.\n await sqlite.execute(`DROP TABLE IF EXISTS items`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS items (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER, -- a quién avisar\n grupo TEXT, -- ej: \"Seguro\", \"Impuesto\"\n nombre TEXT, -- ej: \"Coche\", \"Basura\"\n importe REAL, -- importe actual del pago\n fecha_pago TEXT, -- próxima fecha de vencimiento (formato ISO AAAA-MM-DD)\n dias_aviso INTEGER, -- con cuántos días de antelación avisar (0-365)\n pospuesto_hasta TEXT DEFAULT NULL, -- si el usuario pospuso el aviso, hasta cuándo callar (ISO)\n esperando_confirmacion INTEGER DEFAULT 0 -- 1 = ya se le preguntó \"¿se ha renovado?\" y espera respuesta\n )`);\n\n // Grupos propios de cada usuario\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS grupos (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n nombre TEXT,\n UNIQUE(chat_id, nombre)\n )`);\n\n // Sesión: en qué paso está cada usuario dentro de una conversación guiada.\n // paso puede ser:\n // esperando_grupo | esperando_nombre_grupo_nuevo | esperando_importe |\n // esperando_fecha | esperando_dias_aviso | esperando_importe_renovacion\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS sesiones (\n chat_id INTEGER PRIMARY KEY,\n paso TEXT,\n nombre TEXT,\n grupo TEXT,\n importe REAL,\n fecha_pago TEXT,\n item_id INTEGER -- se usa cuando estamos renovando un item concreto, no dando de alta uno nuevo\n )`);\n}\n\nasync function asegurarGruposPorDefecto(chatId: number) {\n const res = await sqlite.execute(`SELECT id FROM grupos WHERE chat_id = ?`, [\n chatId,\n ]);\n if (res.rows.length === 0) {\n for (const g of GRUPOS_POR_DEFECTO) {\n await sqlite.execute(\n `INSERT INTO grupos (chat_id, nombre) VALUES (?, ?) ON CONFLICT(chat_id, nombre) DO NOTHING`,\n [chatId, g],\n );\n }\n }\n}\n\nasync function getGrupos(chatId: number): Promise {\n const res = await sqlite.execute(\n `SELECT nombre FROM grupos WHERE chat_id = ? ORDER BY nombre`,\n [chatId],\n );\n return res.rows.map((row: any) => val(row, 0, \"nombre\"));\n}\n\nasync function crearGrupoSiNoExiste(chatId: number, nombre: string) {\n await sqlite.execute(\n `INSERT INTO grupos (chat_id, nombre) VALUES (?, ?) ON CONFLICT(chat_id, nombre) DO NOTHING`,\n [chatId, nombre],\n );\n}\n\n// ============================================================\n// TELEGRAM: funciones auxiliares\n// ============================================================\nasync function sendMessage(chatId: number, text: string, replyMarkup?: object) {\n await fetch(`${API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, reply_markup: replyMarkup }),\n });\n}\n\nasync function answerCallback(callbackId: string, text?: string) {\n await fetch(`${API}/answerCallbackQuery`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ callback_query_id: callbackId, text }),\n });\n}\n\n// Botones para elegir grupo al dar de alta un pago\nfunction botonesGrupos(grupos: string[]) {\n const filas = grupos.map((g) => [{ text: g, callback_data: `grupo:${g}` }]);\n filas.push([{ text: \"➕ Crear grupo nuevo\", callback_data: \"grupo_nuevo\" }]);\n return { inline_keyboard: filas };\n}\n\n// ============================================================\n// FECHAS: conversión DD/MM/AAAA <-> ISO, sumar años, calcular días\n// ============================================================\nfunction parseFechaEspanola(texto: string): string | null {\n const partes = texto.trim().split(\"/\");\n if (partes.length !== 3) return null;\n const [dStr, mStr, yStr] = partes;\n const d = Number(dStr), m = Number(mStr), y = Number(yStr);\n if (!d || !m || !y) return null;\n const fecha = new Date(y, m - 1, d);\n if (\n fecha.getDate() !== d || fecha.getMonth() !== m - 1 ||\n fecha.getFullYear() !== y\n ) return null;\n return `${y}-${String(m).padStart(2, \"0\")}-${String(d).padStart(2, \"0\")}`;\n}\n\nfunction formatFechaEspanola(iso: string): string {\n const [y, m, d] = iso.split(\"-\");\n return `${d}/${m}/${y}`;\n}\n\nfunction iconoGrupo(grupo: string): string {\n const g = grupo.toLowerCase();\n if (g.includes(\"seguro\")) return \"🛡️\";\n if (g.includes(\"impuesto\")) return \"🏛️\";\n if (g.includes(\"basura\")) return \"🗑️\";\n return \"📌\";\n}\n\nfunction diasHasta(iso: string): number {\n const hoy = new Date();\n hoy.setHours(0, 0, 0, 0);\n const [y, m, d] = iso.split(\"-\").map(Number);\n const fecha = new Date(y, m - 1, d);\n return Math.round((fecha.getTime() - hoy.getTime()) / (1000 * 60 * 60 * 24));\n}\n\n// ============================================================\n// SESIONES: leer/guardar/borrar el estado de la conversación\n// ============================================================\nasync function getSesion(chatId: number) {\n const res = await sqlite.execute(\n `SELECT paso, nombre, grupo, importe, fecha_pago, item_id FROM sesiones WHERE chat_id = ?`,\n [chatId],\n );\n const row = res.rows[0];\n if (!row) return null;\n // Usamos val(...) en vez de destructuring, así funciona tanto si\n // la fila viene como array como si viene como objeto.\n return {\n paso: val(row, 0, \"paso\") as string,\n nombre: val(row, 1, \"nombre\") as string | null,\n grupo: val(row, 2, \"grupo\") as string | null,\n importe: val(row, 3, \"importe\") as number | null,\n fecha_pago: val(row, 4, \"fecha_pago\") as string | null,\n item_id: val(row, 5, \"item_id\") as number | null,\n };\n}\n\nasync function guardarSesion(\n chatId: number,\n paso: string,\n campos: {\n nombre?: string | null;\n grupo?: string | null;\n importe?: number | null;\n fecha_pago?: string | null;\n item_id?: number | null;\n },\n) {\n await sqlite.execute(\n `INSERT INTO sesiones (chat_id, paso, nombre, grupo, importe, fecha_pago, item_id)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(chat_id) DO UPDATE SET\n paso = excluded.paso, nombre = excluded.nombre, grupo = excluded.grupo,\n importe = excluded.importe, fecha_pago = excluded.fecha_pago, item_id = excluded.item_id`,\n [\n chatId,\n paso,\n campos.nombre ?? null,\n campos.grupo ?? null,\n campos.importe ?? null,\n campos.fecha_pago ?? null,\n campos.item_id ?? null,\n ],\n );\n}\n\nasync function borrarSesion(chatId: number) {\n await sqlite.execute(`DELETE FROM sesiones WHERE chat_id = ?`, [chatId]);\n}\n\n// ============================================================\n// RENOVACIÓN: aplicar la renovación de un pago (importe nuevo + fecha +1 año)\n// ============================================================\nasync function aplicarRenovacion(itemId: number, importeNuevo: number) {\n const res = await sqlite.execute(\n `SELECT fecha_pago FROM items WHERE id = ?`,\n [itemId],\n );\n const row = res.rows[0];\n if (!row) return null;\n\n const fechaAnterior = val(row, 0, \"fecha_pago\") as string;\n const [y, m, d] = fechaAnterior.split(\"-\").map(Number);\n const nuevaFecha = new Date(y + 1, m - 1, d);\n const fechaNuevaIso = `${nuevaFecha.getFullYear()}-${\n String(nuevaFecha.getMonth() + 1).padStart(2, \"0\")\n }-${String(nuevaFecha.getDate()).padStart(2, \"0\")}`;\n\n await sqlite.execute(\n `UPDATE items SET importe = ?, fecha_pago = ?, pospuesto_hasta = NULL, esperando_confirmacion = 0 WHERE id = ?`,\n [importeNuevo, fechaNuevaIso, itemId],\n );\n\n return { fechaAnterior, fechaNuevaIso };\n}\n\n// ============================================================\n// HANDLER PRINCIPAL\n// ============================================================\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"🤖 Bot de recordatorios de pagos funcionando.\", {\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n if (!TOKEN) {\n return new Response(\"Falta TELEGRAM_BOT_TOKEN\", { status: 500 });\n }\n\n await initDb();\n const update = await req.json();\n\n // ------------------------------------------------------------\n // CASO A: el usuario ha pulsado un botón\n // ------------------------------------------------------------\n if (update.callback_query) {\n const cq = update.callback_query;\n const chatId = cq.message.chat.id;\n const data: string = cq.data;\n\n // --- Botón \"✅ Ya renovado\" ---\n // formato: \"renovado:\"\n if (data.startsWith(\"renovado:\")) {\n const itemId = Number(data.split(\":\")[1]);\n await answerCallback(cq.id, \"Vale\");\n await guardarSesion(chatId, \"esperando_importe_renovacion\", {\n item_id: itemId,\n });\n await sendMessage(\n chatId,\n \"Genial 🎉 ¿Por cuánto dinero se ha renovado? (ej: 480.20)\",\n );\n return new Response(\"ok\");\n }\n\n // --- Botón \"❌ Aún no\" ---\n // formato: \"aun_no:\"\n if (data.startsWith(\"aun_no:\")) {\n await answerCallback(cq.id, \"Vale, te lo seguiré preguntando\");\n await sendMessage(\n chatId,\n \"Entendido, te lo volveré a preguntar mañana si sigue sin renovarse.\",\n );\n return new Response(\"ok\");\n }\n\n // --- Botones de POSPONER (solo tienen sentido antes de vencer) ---\n // formato: \"posponer::semana\" | \"posponer::mes\" | \"posponer::nunca\"\n if (data.startsWith(\"posponer:\")) {\n const [, idStr, opcion] = data.split(\":\");\n const itemId = Number(idStr);\n\n const res = await sqlite.execute(\n `SELECT fecha_pago FROM items WHERE id = ?`,\n [itemId],\n );\n const row = res.rows[0];\n if (!row) {\n await answerCallback(cq.id, \"Este pago ya no existe.\");\n return new Response(\"ok\");\n }\n const fechaPago = val(row, 0, \"fecha_pago\") as string;\n\n let pospuestoHasta: string;\n let textoConfirmacion: string;\n const hoy = new Date();\n\n if (opcion === \"semana\") {\n const en7dias = new Date(hoy);\n en7dias.setDate(en7dias.getDate() + 7);\n pospuestoHasta = `${en7dias.getFullYear()}-${\n String(en7dias.getMonth() + 1).padStart(2, \"0\")\n }-${String(en7dias.getDate()).padStart(2, \"0\")}`;\n textoConfirmacion = \"Vale, te lo recuerdo de nuevo en 1 semana.\";\n } else if (opcion === \"mes\") {\n const en30dias = new Date(hoy);\n en30dias.setDate(en30dias.getDate() + 30);\n pospuestoHasta = `${en30dias.getFullYear()}-${\n String(en30dias.getMonth() + 1).padStart(2, \"0\")\n }-${String(en30dias.getDate()).padStart(2, \"0\")}`;\n textoConfirmacion = \"Vale, te lo recuerdo de nuevo en 1 mes.\";\n } else {\n pospuestoHasta = fechaPago;\n textoConfirmacion =\n \"Vale, no te aviso más hasta el próximo vencimiento.\";\n }\n\n await sqlite.execute(\n `UPDATE items SET pospuesto_hasta = ? WHERE id = ?`,\n [pospuestoHasta, itemId],\n );\n await answerCallback(cq.id, \"Anotado\");\n await sendMessage(chatId, textoConfirmacion);\n return new Response(\"ok\");\n }\n\n // --- Botones del ALTA (elegir grupo al hacer /añadir) ---\n const sesion = await getSesion(chatId);\n if (!sesion || sesion.paso !== \"esperando_grupo\") {\n await answerCallback(\n cq.id,\n \"Esto ya no está en curso, usa /añadir para empezar de nuevo.\",\n );\n return new Response(\"ok\");\n }\n\n if (data === \"grupo_nuevo\") {\n await answerCallback(cq.id);\n await guardarSesion(chatId, \"esperando_nombre_grupo_nuevo\", {\n nombre: sesion.nombre,\n });\n await sendMessage(\n chatId,\n \"¿Cómo quieres llamar al grupo nuevo? (ej: Comunidad, Suministros...)\",\n );\n } else if (data.startsWith(\"grupo:\")) {\n const grupoElegido = data.replace(\"grupo:\", \"\");\n await answerCallback(cq.id, `Grupo: ${grupoElegido}`);\n await guardarSesion(chatId, \"esperando_importe\", {\n nombre: sesion.nombre,\n grupo: grupoElegido,\n });\n await sendMessage(\n chatId,\n `Grupo \"${grupoElegido}\" ✅\\n¿Qué importe tiene \"${sesion.nombre}\"? (ej: 145.50)`,\n );\n }\n return new Response(\"ok\");\n }\n\n // ------------------------------------------------------------\n // CASO B: mensaje de texto\n // ------------------------------------------------------------\n const message = update.message;\n if (!message?.text) return new Response(\"ok\");\n\n const chatId = message.chat.id;\n const text = message.text.trim();\n\n if (text.startsWith(\"/\")) {\n await borrarSesion(chatId);\n await asegurarGruposPorDefecto(chatId);\n\n if (text === \"/start\") {\n await sendMessage(\n chatId,\n `👋 Hola! Soy tu bot de recordatorios de pagos.\\n\\nComandos:\\n/añadir — dar de alta un pago (ej: /añadir Coche)\\n/lista — ver todos tus pagos\\n/grupos — ver tus grupos\\n/borrar — eliminar uno\\n/cancelar — cancelar lo que esté en curso`,\n );\n } else if (text.startsWith(\"/añadir\")) {\n const nombre = text.replace(\"/añadir\", \"\").trim();\n if (!nombre) {\n await sendMessage(\n chatId,\n \"Formato: /añadir \\nEj: /añadir Coche\",\n );\n } else {\n const grupos = await getGrupos(chatId);\n await guardarSesion(chatId, \"esperando_grupo\", { nombre });\n await sendMessage(\n chatId,\n `¿A qué grupo pertenece \"${nombre}\"?`,\n botonesGrupos(grupos),\n );\n }\n } else if (text === \"/grupos\") {\n const grupos = await getGrupos(chatId);\n await sendMessage(\n chatId,\n `📂 Tus grupos:\\n${grupos.map((g) => `- ${g}`).join(\"\\n\")}`,\n );\n } else if (text === \"/lista\") {\n const res = await sqlite.execute(\n `SELECT id, grupo, nombre, importe, fecha_pago, dias_aviso FROM items WHERE chat_id = ? ORDER BY fecha_pago ASC`,\n [chatId],\n );\n if (res.rows.length === 0) {\n await sendMessage(\n chatId,\n \"No tienes ningún pago guardado todavía. Usa /añadir para crear el primero.\",\n );\n } else {\n const lineas = res.rows.map((row: any) => {\n const id = val(row, 0, \"id\");\n const grupo = val(row, 1, \"grupo\");\n const nombre = val(row, 2, \"nombre\");\n const importe = val(row, 3, \"importe\");\n const fechaIso = val(row, 4, \"fecha_pago\");\n const diasAviso = val(row, 5, \"dias_aviso\");\n const dias = diasHasta(fechaIso);\n const diasTexto = dias < 0\n ? `hace ${\n Math.abs(dias)\n } días (¡pendiente de confirmar renovación!)`\n : dias === 0\n ? \"¡hoy!\"\n : `en ${dias} días`;\n return `${iconoGrupo(grupo)} #${id} ${grupo} - ${nombre}: ${\n Number(importe).toFixed(2)\n }€ el ${\n formatFechaEspanola(fechaIso)\n } (${diasTexto}) · aviso: ${diasAviso}d antes`;\n });\n await sendMessage(chatId, `📋 Tus pagos:\\n\\n${lineas.join(\"\\n\")}`);\n }\n } else if (text.startsWith(\"/borrar\")) {\n const idStr = text.replace(\"/borrar\", \"\").trim();\n const id = Number(idStr);\n if (!id) {\n await sendMessage(\n chatId,\n \"Formato: /borrar \\nEj: /borrar 3 (usa /lista para ver los ids)\",\n );\n } else {\n await sqlite.execute(`DELETE FROM items WHERE id = ? AND chat_id = ?`, [\n id,\n chatId,\n ]);\n await sendMessage(chatId, `Eliminado el pago #${id} (si existía).`);\n }\n } else if (text === \"/cancelar\") {\n await sendMessage(chatId, \"Todo cancelado.\");\n } else {\n await sendMessage(\n chatId,\n \"No entiendo ese comando. Prueba /añadir, /lista, /grupos o /borrar.\",\n );\n }\n\n return new Response(\"ok\");\n }\n\n // ------------------------------------------------------------\n // Si NO es un comando, miramos en qué paso de conversación está el usuario\n // ------------------------------------------------------------\n const sesion = await getSesion(chatId);\n if (!sesion) {\n await sendMessage(\n chatId,\n \"No entiendo ese mensaje. Prueba /añadir, /lista o /borrar.\",\n );\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_nombre_grupo_nuevo\") {\n const nombreGrupo = text;\n await crearGrupoSiNoExiste(chatId, nombreGrupo);\n await guardarSesion(chatId, \"esperando_importe\", {\n nombre: sesion.nombre,\n grupo: nombreGrupo,\n });\n await sendMessage(\n chatId,\n `Grupo \"${nombreGrupo}\" creado ✅\\n¿Qué importe tiene \"${sesion.nombre}\"? (ej: 145.50)`,\n );\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_importe\") {\n const importe = parseFloat(text.replace(\",\", \".\"));\n if (isNaN(importe)) {\n await sendMessage(\n chatId,\n \"Eso no parece un número. Dime el importe, ej: 145.50\",\n );\n } else {\n await guardarSesion(chatId, \"esperando_fecha\", {\n nombre: sesion.nombre,\n grupo: sesion.grupo,\n importe,\n });\n await sendMessage(\n chatId,\n \"¿Qué día vence? Formato: DD/MM/AAAA (ej: 15/03/2026)\",\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_fecha\") {\n const fechaIso = parseFechaEspanola(text);\n if (!fechaIso) {\n await sendMessage(\n chatId,\n \"Fecha no válida. Usa el formato DD/MM/AAAA, ej: 15/03/2026\",\n );\n } else {\n await guardarSesion(chatId, \"esperando_dias_aviso\", {\n nombre: sesion.nombre,\n grupo: sesion.grupo,\n importe: sesion.importe,\n fecha_pago: fechaIso,\n });\n await sendMessage(\n chatId,\n \"¿Con cuántos días de antelación quieres que te avise? (un número entre 0 y 365, ej: 7)\",\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_dias_aviso\") {\n const diasAviso = parseInt(text, 10);\n if (isNaN(diasAviso) || diasAviso < 0 || diasAviso > 365) {\n await sendMessage(chatId, \"Dame un número entre 0 y 365, ej: 7\");\n } else {\n await sqlite.execute(\n `INSERT INTO items (chat_id, grupo, nombre, importe, fecha_pago, dias_aviso, pospuesto_hasta, esperando_confirmacion)\n VALUES (?, ?, ?, ?, ?, ?, NULL, 0)`,\n [\n chatId,\n sesion.grupo,\n sesion.nombre,\n sesion.importe,\n sesion.fecha_pago,\n diasAviso,\n ],\n );\n await borrarSesion(chatId);\n await sendMessage(\n chatId,\n `✅ Guardado: ${sesion.grupo} - ${sesion.nombre}, ${\n (sesion.importe as number).toFixed(2)\n }€, vence el ${\n formatFechaEspanola(sesion.fecha_pago as string)\n }.\\nTe avisaré ${diasAviso} día(s) antes.`,\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_importe_renovacion\") {\n const importeNuevo = parseFloat(text.replace(\",\", \".\"));\n if (isNaN(importeNuevo)) {\n await sendMessage(\n chatId,\n \"Eso no parece un número. Dime el importe nuevo, ej: 480.20\",\n );\n } else {\n const resultado = await aplicarRenovacion(\n sesion.item_id as number,\n importeNuevo,\n );\n await borrarSesion(chatId);\n if (!resultado) {\n await sendMessage(\n chatId,\n \"No he encontrado ese pago, puede que se haya borrado.\",\n );\n } else {\n await sendMessage(\n chatId,\n `✅ Renovado por ${importeNuevo.toFixed(2)}€. Próximo vencimiento: ${\n formatFechaEspanola(resultado.fechaNuevaIso)\n }.`,\n );\n }\n }\n return new Response(\"ok\");\n }\n\n return new Response(\"ok\");\n}","// ============================================================\n// BOT DE RECORDATORIOS DE PAGOS (seguros, impuestos, etc.)\n// ============================================================\n// COMANDOS:\n// /añadir -> flujo: grupo (botones) -> importe -> fecha -> días de aviso\n// /lista -> ver todos tus pagos\n// /grupos -> ver tus grupos\n// /borrar -> eliminar un pago\n// /cancelar -> cancelar cualquier flujo en curso\n//\n// El cron (val aparte) es quien manda los avisos día a día y gestiona\n// los botones de \"ya renovado\" / \"posponer\". Este val solo:\n// 1) gestiona el alta de pagos (/añadir)\n// 2) responde a los botones que manda el cron cuando el usuario los pulsa\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nconst API = `https://api.telegram.org/bot${TOKEN}`;\n\n// Grupos que se crean automáticamente la primera vez que un usuario los necesita\nconst GRUPOS_POR_DEFECTO = [\"Impuesto\", \"Seguro\"];\n\n// ============================================================\n// HELPER ANTI-SORPRESAS: sqlite.execute a veces devuelve cada fila\n// como un ARRAY posicional (row[0], row[1]...) y a veces como un\n// OBJETO con las columnas como claves (row.nombre, row.importe...).\n// Esta función funciona en los dos casos, así el resto del código\n// no se rompe si el comportamiento cambia.\n//\n// Uso: val(row, 0, \"nombre\") -> intenta row[0], si no existe prueba row[\"nombre\"]\n// ============================================================\nfunction val(row: any, index: number, key: string) {\n if (Array.isArray(row)) return row[index];\n return row[key];\n}\n\n// ============================================================\n// BASE DE DATOS\n// ============================================================\nasync function initDb() {\n // Creamos las tablas si no existen todavía (la primera vez).\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS items (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n grupo TEXT,\n nombre TEXT,\n importe REAL,\n fecha_pago TEXT\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS sesiones (\n chat_id INTEGER PRIMARY KEY,\n paso TEXT,\n nombre TEXT,\n grupo TEXT,\n importe REAL,\n fecha_pago TEXT\n )`);\n\n // Grupos propios de cada usuario (ej: Impuesto, Seguro, y los que cree cada uno)\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS grupos (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n chat_id INTEGER,\n nombre TEXT,\n UNIQUE(chat_id, nombre)\n )`);\n\n // Si la tabla ya existía de una versión anterior del código, puede que\n // le falten columnas nuevas. En vez de borrar la tabla (y perder datos),\n // intentamos añadir cada columna que necesitemos. Si ya existe, SQLite\n // da un error que simplemente ignoramos con el try/catch.\n const alters = [\n `ALTER TABLE items ADD COLUMN dias_aviso INTEGER DEFAULT 7`,\n `ALTER TABLE items ADD COLUMN pospuesto_hasta TEXT DEFAULT NULL`,\n `ALTER TABLE items ADD COLUMN esperando_confirmacion INTEGER DEFAULT 0`,\n `ALTER TABLE sesiones ADD COLUMN item_id INTEGER DEFAULT NULL`,\n ];\n for (const sql of alters) {\n try {\n await sqlite.execute(sql);\n } catch {\n // La columna ya existía, no pasa nada.\n }\n }\n}\n\nasync function asegurarGruposPorDefecto(chatId: number) {\n const res = await sqlite.execute(`SELECT id FROM grupos WHERE chat_id = ?`, [\n chatId,\n ]);\n if (res.rows.length === 0) {\n for (const g of GRUPOS_POR_DEFECTO) {\n await sqlite.execute(\n `INSERT INTO grupos (chat_id, nombre) VALUES (?, ?) ON CONFLICT(chat_id, nombre) DO NOTHING`,\n [chatId, g],\n );\n }\n }\n}\n\nasync function getGrupos(chatId: number): Promise {\n const res = await sqlite.execute(\n `SELECT nombre FROM grupos WHERE chat_id = ? ORDER BY nombre`,\n [chatId],\n );\n return res.rows.map((row: any) => val(row, 0, \"nombre\"));\n}\n\nasync function crearGrupoSiNoExiste(chatId: number, nombre: string) {\n await sqlite.execute(\n `INSERT INTO grupos (chat_id, nombre) VALUES (?, ?) ON CONFLICT(chat_id, nombre) DO NOTHING`,\n [chatId, nombre],\n );\n}\n\n// ============================================================\n// TELEGRAM: funciones auxiliares\n// ============================================================\nasync function sendMessage(chatId: number, text: string, replyMarkup?: object) {\n await fetch(`${API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, reply_markup: replyMarkup }),\n });\n}\n\nasync function answerCallback(callbackId: string, text?: string) {\n await fetch(`${API}/answerCallbackQuery`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ callback_query_id: callbackId, text }),\n });\n}\n\n// Botones para elegir grupo al dar de alta un pago\nfunction botonesGrupos(grupos: string[]) {\n const filas = grupos.map((g) => [{ text: g, callback_data: `grupo:${g}` }]);\n filas.push([{ text: \"➕ Crear grupo nuevo\", callback_data: \"grupo_nuevo\" }]);\n return { inline_keyboard: filas };\n}\n\n// ============================================================\n// FECHAS: conversión DD/MM/AAAA <-> ISO, sumar años, calcular días\n// ============================================================\nfunction parseFechaEspanola(texto: string): string | null {\n const partes = texto.trim().split(\"/\");\n if (partes.length !== 3) return null;\n const [dStr, mStr, yStr] = partes;\n const d = Number(dStr), m = Number(mStr), y = Number(yStr);\n if (!d || !m || !y) return null;\n const fecha = new Date(y, m - 1, d);\n if (\n fecha.getDate() !== d || fecha.getMonth() !== m - 1 ||\n fecha.getFullYear() !== y\n ) return null;\n return `${y}-${String(m).padStart(2, \"0\")}-${String(d).padStart(2, \"0\")}`;\n}\n\nfunction formatFechaEspanola(iso: string): string {\n const [y, m, d] = iso.split(\"-\");\n return `${d}/${m}/${y}`;\n}\n\nfunction iconoGrupo(grupo: string): string {\n const g = grupo.toLowerCase();\n if (g.includes(\"seguro\")) return \"🛡️\";\n if (g.includes(\"impuesto\")) return \"🏛️\";\n if (g.includes(\"basura\")) return \"🗑️\";\n return \"📌\";\n}\n\nfunction diasHasta(iso: string): number {\n const hoy = new Date();\n hoy.setHours(0, 0, 0, 0);\n const [y, m, d] = iso.split(\"-\").map(Number);\n const fecha = new Date(y, m - 1, d);\n return Math.round((fecha.getTime() - hoy.getTime()) / (1000 * 60 * 60 * 24));\n}\n\n// ============================================================\n// SESIONES: leer/guardar/borrar el estado de la conversación\n// ============================================================\nasync function getSesion(chatId: number) {\n const res = await sqlite.execute(\n `SELECT paso, nombre, grupo, importe, fecha_pago, item_id FROM sesiones WHERE chat_id = ?`,\n [chatId],\n );\n const row = res.rows[0];\n if (!row) return null;\n // Usamos val(...) en vez de destructuring, así funciona tanto si\n // la fila viene como array como si viene como objeto.\n return {\n paso: val(row, 0, \"paso\") as string,\n nombre: val(row, 1, \"nombre\") as string | null,\n grupo: val(row, 2, \"grupo\") as string | null,\n importe: val(row, 3, \"importe\") as number | null,\n fecha_pago: val(row, 4, \"fecha_pago\") as string | null,\n item_id: val(row, 5, \"item_id\") as number | null,\n };\n}\n\nasync function guardarSesion(\n chatId: number,\n paso: string,\n campos: {\n nombre?: string | null;\n grupo?: string | null;\n importe?: number | null;\n fecha_pago?: string | null;\n item_id?: number | null;\n },\n) {\n await sqlite.execute(\n `INSERT INTO sesiones (chat_id, paso, nombre, grupo, importe, fecha_pago, item_id)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n ON CONFLICT(chat_id) DO UPDATE SET\n paso = excluded.paso, nombre = excluded.nombre, grupo = excluded.grupo,\n importe = excluded.importe, fecha_pago = excluded.fecha_pago, item_id = excluded.item_id`,\n [\n chatId,\n paso,\n campos.nombre ?? null,\n campos.grupo ?? null,\n campos.importe ?? null,\n campos.fecha_pago ?? null,\n campos.item_id ?? null,\n ],\n );\n}\n\nasync function borrarSesion(chatId: number) {\n await sqlite.execute(`DELETE FROM sesiones WHERE chat_id = ?`, [chatId]);\n}\n\n// ============================================================\n// RENOVACIÓN: aplicar la renovación de un pago (importe nuevo + fecha +1 año)\n// ============================================================\nasync function aplicarRenovacion(itemId: number, importeNuevo: number) {\n const res = await sqlite.execute(\n `SELECT fecha_pago FROM items WHERE id = ?`,\n [itemId],\n );\n const row = res.rows[0];\n if (!row) return null;\n\n const fechaAnterior = val(row, 0, \"fecha_pago\") as string;\n const [y, m, d] = fechaAnterior.split(\"-\").map(Number);\n const nuevaFecha = new Date(y + 1, m - 1, d);\n const fechaNuevaIso = `${nuevaFecha.getFullYear()}-${\n String(nuevaFecha.getMonth() + 1).padStart(2, \"0\")\n }-${String(nuevaFecha.getDate()).padStart(2, \"0\")}`;\n\n await sqlite.execute(\n `UPDATE items SET importe = ?, fecha_pago = ?, pospuesto_hasta = NULL, esperando_confirmacion = 0 WHERE id = ?`,\n [importeNuevo, fechaNuevaIso, itemId],\n );\n\n return { fechaAnterior, fechaNuevaIso };\n}\n\n// ============================================================\n// HANDLER PRINCIPAL\n// ============================================================\nexport default async function (req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"🤖 Bot de recordatorios de pagos funcionando.\", {\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n if (!TOKEN) {\n return new Response(\"Falta TELEGRAM_BOT_TOKEN\", { status: 500 });\n }\n\n await initDb();\n const update = await req.json();\n\n // ------------------------------------------------------------\n // CASO A: el usuario ha pulsado un botón\n // ------------------------------------------------------------\n if (update.callback_query) {\n const cq = update.callback_query;\n const chatId = cq.message.chat.id;\n const data: string = cq.data;\n\n // --- Botón \"✅ Ya renovado\" ---\n // formato: \"renovado:\"\n if (data.startsWith(\"renovado:\")) {\n const itemId = Number(data.split(\":\")[1]);\n await answerCallback(cq.id, \"Vale\");\n await guardarSesion(chatId, \"esperando_importe_renovacion\", {\n item_id: itemId,\n });\n await sendMessage(\n chatId,\n \"Genial 🎉 ¿Por cuánto dinero se ha renovado? (ej: 480.20)\",\n );\n return new Response(\"ok\");\n }\n\n // --- Botón \"❌ Aún no\" ---\n // formato: \"aun_no:\"\n if (data.startsWith(\"aun_no:\")) {\n await answerCallback(cq.id, \"Vale, te lo seguiré preguntando\");\n await sendMessage(\n chatId,\n \"Entendido, te lo volveré a preguntar mañana si sigue sin renovarse.\",\n );\n return new Response(\"ok\");\n }\n\n // --- Botones de POSPONER (solo tienen sentido antes de vencer) ---\n // formato: \"posponer::semana\" | \"posponer::mes\" | \"posponer::nunca\"\n if (data.startsWith(\"posponer:\")) {\n const [, idStr, opcion] = data.split(\":\");\n const itemId = Number(idStr);\n\n const res = await sqlite.execute(\n `SELECT fecha_pago FROM items WHERE id = ?`,\n [itemId],\n );\n const row = res.rows[0];\n if (!row) {\n await answerCallback(cq.id, \"Este pago ya no existe.\");\n return new Response(\"ok\");\n }\n const fechaPago = val(row, 0, \"fecha_pago\") as string;\n\n let pospuestoHasta: string;\n let textoConfirmacion: string;\n const hoy = new Date();\n\n if (opcion === \"semana\") {\n const en7dias = new Date(hoy);\n en7dias.setDate(en7dias.getDate() + 7);\n pospuestoHasta = `${en7dias.getFullYear()}-${\n String(en7dias.getMonth() + 1).padStart(2, \"0\")\n }-${String(en7dias.getDate()).padStart(2, \"0\")}`;\n textoConfirmacion = \"Vale, te lo recuerdo de nuevo en 1 semana.\";\n } else if (opcion === \"mes\") {\n const en30dias = new Date(hoy);\n en30dias.setDate(en30dias.getDate() + 30);\n pospuestoHasta = `${en30dias.getFullYear()}-${\n String(en30dias.getMonth() + 1).padStart(2, \"0\")\n }-${String(en30dias.getDate()).padStart(2, \"0\")}`;\n textoConfirmacion = \"Vale, te lo recuerdo de nuevo en 1 mes.\";\n } else {\n pospuestoHasta = fechaPago;\n textoConfirmacion =\n \"Vale, no te aviso más hasta el próximo vencimiento.\";\n }\n\n await sqlite.execute(\n `UPDATE items SET pospuesto_hasta = ? WHERE id = ?`,\n [pospuestoHasta, itemId],\n );\n await answerCallback(cq.id, \"Anotado\");\n await sendMessage(chatId, textoConfirmacion);\n return new Response(\"ok\");\n }\n\n // --- Botones del ALTA (elegir grupo al hacer /añadir) ---\n const sesion = await getSesion(chatId);\n if (!sesion || sesion.paso !== \"esperando_grupo\") {\n await answerCallback(\n cq.id,\n \"Esto ya no está en curso, usa /añadir para empezar de nuevo.\",\n );\n return new Response(\"ok\");\n }\n\n if (data === \"grupo_nuevo\") {\n await answerCallback(cq.id);\n await guardarSesion(chatId, \"esperando_nombre_grupo_nuevo\", {\n nombre: sesion.nombre,\n });\n await sendMessage(\n chatId,\n \"¿Cómo quieres llamar al grupo nuevo? (ej: Comunidad, Suministros...)\",\n );\n } else if (data.startsWith(\"grupo:\")) {\n const grupoElegido = data.replace(\"grupo:\", \"\");\n await answerCallback(cq.id, `Grupo: ${grupoElegido}`);\n await guardarSesion(chatId, \"esperando_importe\", {\n nombre: sesion.nombre,\n grupo: grupoElegido,\n });\n await sendMessage(\n chatId,\n `Grupo \"${grupoElegido}\" ✅\\n¿Qué importe tiene \"${sesion.nombre}\"? (ej: 145.50)`,\n );\n }\n return new Response(\"ok\");\n }\n\n // ------------------------------------------------------------\n // CASO B: mensaje de texto\n // ------------------------------------------------------------\n const message = update.message;\n if (!message?.text) return new Response(\"ok\");\n\n const chatId = message.chat.id;\n const text = message.text.trim();\n\n if (text.startsWith(\"/\")) {\n await borrarSesion(chatId);\n await asegurarGruposPorDefecto(chatId);\n\n if (text === \"/start\") {\n await sendMessage(\n chatId,\n `👋 Hola! Soy tu bot de recordatorios de pagos.\\n\\nComandos:\\n/añadir — dar de alta un pago (ej: /añadir Coche)\\n/lista — ver todos tus pagos\\n/grupos — ver tus grupos\\n/borrar — eliminar uno\\n/cancelar — cancelar lo que esté en curso`,\n );\n } else if (text.startsWith(\"/añadir\")) {\n const nombre = text.replace(\"/añadir\", \"\").trim();\n if (!nombre) {\n await sendMessage(\n chatId,\n \"Formato: /añadir \\nEj: /añadir Coche\",\n );\n } else {\n const grupos = await getGrupos(chatId);\n await guardarSesion(chatId, \"esperando_grupo\", { nombre });\n await sendMessage(\n chatId,\n `¿A qué grupo pertenece \"${nombre}\"?`,\n botonesGrupos(grupos),\n );\n }\n } else if (text === \"/grupos\") {\n const grupos = await getGrupos(chatId);\n await sendMessage(\n chatId,\n `📂 Tus grupos:\\n${grupos.map((g) => `- ${g}`).join(\"\\n\")}`,\n );\n } else if (text === \"/lista\") {\n const res = await sqlite.execute(\n `SELECT id, grupo, nombre, importe, fecha_pago, dias_aviso FROM items WHERE chat_id = ? ORDER BY fecha_pago ASC`,\n [chatId],\n );\n if (res.rows.length === 0) {\n await sendMessage(\n chatId,\n \"No tienes ningún pago guardado todavía. Usa /añadir para crear el primero.\",\n );\n } else {\n const lineas = res.rows.map((row: any) => {\n const id = val(row, 0, \"id\");\n const grupo = val(row, 1, \"grupo\");\n const nombre = val(row, 2, \"nombre\");\n const importe = val(row, 3, \"importe\");\n const fechaIso = val(row, 4, \"fecha_pago\");\n const diasAviso = val(row, 5, \"dias_aviso\");\n const dias = diasHasta(fechaIso);\n const diasTexto = dias < 0\n ? `hace ${\n Math.abs(dias)\n } días (¡pendiente de confirmar renovación!)`\n : dias === 0\n ? \"¡hoy!\"\n : `en ${dias} días`;\n return `${iconoGrupo(grupo)} #${id} ${grupo} - ${nombre}: ${\n Number(importe).toFixed(2)\n }€ el ${\n formatFechaEspanola(fechaIso)\n } (${diasTexto}) · aviso: ${diasAviso}d antes`;\n });\n await sendMessage(chatId, `📋 Tus pagos:\\n\\n${lineas.join(\"\\n\")}`);\n }\n } else if (text.startsWith(\"/borrar\")) {\n const idStr = text.replace(\"/borrar\", \"\").trim();\n const id = Number(idStr);\n if (!id) {\n await sendMessage(\n chatId,\n \"Formato: /borrar \\nEj: /borrar 3 (usa /lista para ver los ids)\",\n );\n } else {\n await sqlite.execute(`DELETE FROM items WHERE id = ? AND chat_id = ?`, [\n id,\n chatId,\n ]);\n await sendMessage(chatId, `Eliminado el pago #${id} (si existía).`);\n }\n } else if (text === \"/cancelar\") {\n await sendMessage(chatId, \"Todo cancelado.\");\n } else {\n await sendMessage(\n chatId,\n \"No entiendo ese comando. Prueba /añadir, /lista, /grupos o /borrar.\",\n );\n }\n\n return new Response(\"ok\");\n }\n\n // ------------------------------------------------------------\n // Si NO es un comando, miramos en qué paso de conversación está el usuario\n // ------------------------------------------------------------\n const sesion = await getSesion(chatId);\n if (!sesion) {\n await sendMessage(\n chatId,\n \"No entiendo ese mensaje. Prueba /añadir, /lista o /borrar.\",\n );\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_nombre_grupo_nuevo\") {\n const nombreGrupo = text;\n await crearGrupoSiNoExiste(chatId, nombreGrupo);\n await guardarSesion(chatId, \"esperando_importe\", {\n nombre: sesion.nombre,\n grupo: nombreGrupo,\n });\n await sendMessage(\n chatId,\n `Grupo \"${nombreGrupo}\" creado ✅\\n¿Qué importe tiene \"${sesion.nombre}\"? (ej: 145.50)`,\n );\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_importe\") {\n const importe = parseFloat(text.replace(\",\", \".\"));\n if (isNaN(importe)) {\n await sendMessage(\n chatId,\n \"Eso no parece un número. Dime el importe, ej: 145.50\",\n );\n } else {\n await guardarSesion(chatId, \"esperando_fecha\", {\n nombre: sesion.nombre,\n grupo: sesion.grupo,\n importe,\n });\n await sendMessage(\n chatId,\n \"¿Qué día vence? Formato: DD/MM/AAAA (ej: 15/03/2026)\",\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_fecha\") {\n const fechaIso = parseFechaEspanola(text);\n if (!fechaIso) {\n await sendMessage(\n chatId,\n \"Fecha no válida. Usa el formato DD/MM/AAAA, ej: 15/03/2026\",\n );\n } else {\n await guardarSesion(chatId, \"esperando_dias_aviso\", {\n nombre: sesion.nombre,\n grupo: sesion.grupo,\n importe: sesion.importe,\n fecha_pago: fechaIso,\n });\n await sendMessage(\n chatId,\n \"¿Con cuántos días de antelación quieres que te avise? (un número entre 0 y 365, ej: 7)\",\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_dias_aviso\") {\n const diasAviso = parseInt(text, 10);\n if (isNaN(diasAviso) || diasAviso < 0 || diasAviso > 365) {\n await sendMessage(chatId, \"Dame un número entre 0 y 365, ej: 7\");\n } else {\n await sqlite.execute(\n `INSERT INTO items (chat_id, grupo, nombre, importe, fecha_pago, dias_aviso, pospuesto_hasta, esperando_confirmacion)\n VALUES (?, ?, ?, ?, ?, ?, NULL, 0)`,\n [\n chatId,\n sesion.grupo,\n sesion.nombre,\n sesion.importe,\n sesion.fecha_pago,\n diasAviso,\n ],\n );\n await borrarSesion(chatId);\n await sendMessage(\n chatId,\n `✅ Guardado: ${sesion.grupo} - ${sesion.nombre}, ${\n (sesion.importe as number).toFixed(2)\n }€, vence el ${\n formatFechaEspanola(sesion.fecha_pago as string)\n }.\\nTe avisaré ${diasAviso} día(s) antes.`,\n );\n }\n return new Response(\"ok\");\n }\n\n if (sesion.paso === \"esperando_importe_renovacion\") {\n const importeNuevo = parseFloat(text.replace(\",\", \".\"));\n if (isNaN(importeNuevo)) {\n await sendMessage(\n chatId,\n \"Eso no parece un número. Dime el importe nuevo, ej: 480.20\",\n );\n } else {\n const resultado = await aplicarRenovacion(\n sesion.item_id as number,\n importeNuevo,\n );\n await borrarSesion(chatId);\n if (!resultado) {\n await sendMessage(\n chatId,\n \"No he encontrado ese pago, puede que se haya borrado.\",\n );\n } else {\n await sendMessage(\n chatId,\n `✅ Renovado por ${importeNuevo.toFixed(2)}€. Próximo vencimiento: ${\n formatFechaEspanola(resultado.fechaNuevaIso)\n }.`,\n );\n }\n }\n return new Response(\"ok\");\n }\n\n return new Response(\"ok\");\n}","createdAt",["D",1783662324516],"branchVersion","branchId","7a30cb27-1ecc-4a50-9f06-b563b8aa5d82","id","d339095b-4749-467d-a45e-b7c644a6fae8","Pepito_Grillo",["D",1783596784491],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","@Pagos_futuros_bot","imageUrl","ab13a512-0ebf-4599-9be1-4e1ffb52a140","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f21ce-7c3c-7738-8f89-94c2ca47d7cd","tursoName","d339095b4749467da45eb7c644a6fae8","tursoHostname","d339095b4749467da45eb7c644a6fae8-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789524636084],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":100},"org",{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",20,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Finidi","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":166,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":167,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":168,"_82":169,"_84":170,"_86":25},"tree",[157,158],"files",[157,158],"counts",{"_146":61,"_147":148,"_149":61,"_150":151,"_152":153},"contents",[128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":123,"_38":141,"_13":142,"_33":143,"_35":144,"_24":25,"_135":-5,"_27":145},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":133,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_27":136},"8e9811ba-abc6-4cb9-b0d7-0e7a0b616259","parentId","latest",["D",1783662324516],6,"label",[28],"ae843c11-8473-4732-88e4-70979b8f36e4","cron.ts","7a31a7d6-7b8f-11f1-b1db-1607ee4eb77e",11,["D",1783660234363],5,"interval","// ============================================================\n// CRON: revisa todos los pagos guardados, una vez al día.\n//\n// Para cada pago:\n// - Si ya ha vencido (fecha_pago en el pasado): pregunta \"¿se ha\n// renovado?\" con botones Sí/Aún no. Se repite cada día hasta que\n// el usuario confirme la renovación (desde el val principal).\n// - Si falta <= dias_aviso días para vencer, y no está pospuesto:\n// manda el aviso con 4 botones (Ya renovado / 1 semana / 1 mes / Nunca).\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\nconst API = `https://api.telegram.org/bot${TOKEN}`;\n\n// ============================================================\n// Mismo helper que en main.ts: sqlite.execute puede devolver cada\n// fila como array (row[0]) o como objeto (row.columna). Esta función\n// funciona con los dos formatos, para no depender de cuál usa Val Town\n// en cada momento.\n// ============================================================\nfunction val(row: any, index: number, key: string) {\n if (Array.isArray(row)) return row[index];\n return row[key];\n}\n\nasync function sendMessage(chatId: number, text: string, replyMarkup?: object) {\n await fetch(`${API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, reply_markup: replyMarkup }),\n });\n}\n\nfunction formatFechaEspanola(iso: string): string {\n const [y, m, d] = iso.split(\"-\");\n return `${d}/${m}/${y}`;\n}\n\nfunction diasHasta(iso: string): number {\n const hoy = new Date();\n hoy.setHours(0, 0, 0, 0);\n const [y, m, d] = iso.split(\"-\").map(Number);\n const fecha = new Date(y, m - 1, d);\n return Math.round((fecha.getTime() - hoy.getTime()) / (1000 * 60 * 60 * 24));\n}\n\nfunction hoyIso(): string {\n const hoy = new Date();\n return `${hoy.getFullYear()}-${String(hoy.getMonth() + 1).padStart(2, \"0\")}-${\n String(hoy.getDate()).padStart(2, \"0\")\n }`;\n}\n\n// Botones para cuando el pago ya ha vencido\nfunction botonesVencido(itemId: number) {\n return {\n inline_keyboard: [[\n { text: \"✅ Sí, renovado\", callback_data: `renovado:${itemId}` },\n { text: \"❌ Aún no\", callback_data: `aun_no:${itemId}` },\n ]],\n };\n}\n\n// Botones para el aviso previo al vencimiento\nfunction botonesAvisoPrevio(itemId: number) {\n return {\n inline_keyboard: [\n [{ text: \"✅ Ya renovado\", callback_data: `renovado:${itemId}` }],\n [\n { text: \"🔁 1 semana\", callback_data: `posponer:${itemId}:semana` },\n { text: \"🔁 1 mes\", callback_data: `posponer:${itemId}:mes` },\n { text: \"🚫 Nunca\", callback_data: `posponer:${itemId}:nunca` },\n ],\n ],\n };\n}\n\nexport default async function () {\n const res = await sqlite.execute(\n `SELECT id, chat_id, grupo, nombre, importe, fecha_pago, dias_aviso, pospuesto_hasta FROM items`,\n );\n\n const hoy = hoyIso();\n\n for (const row of res.rows as any[]) {\n const id = val(row, 0, \"id\");\n const chatId = val(row, 1, \"chat_id\");\n const grupo = val(row, 2, \"grupo\");\n const nombre = val(row, 3, \"nombre\");\n const importe = val(row, 4, \"importe\");\n const fechaIso = val(row, 5, \"fecha_pago\");\n const diasAviso = val(row, 6, \"dias_aviso\");\n const pospuestoHasta = val(row, 7, \"pospuesto_hasta\");\n\n const dias = diasHasta(fechaIso);\n\n // --- CASO 1: ya ha vencido -> preguntamos si se ha renovado ---\n if (dias < 0) {\n await sendMessage(\n chatId,\n `📌 \"${grupo} - ${nombre}\" (${Number(importe).toFixed(2)}€) venció el ${\n formatFechaEspanola(fechaIso)\n }.\\n¿Se ha renovado ya?`,\n botonesVencido(id),\n );\n continue; // no hace falta mirar nada más de este item hoy\n }\n\n // --- CASO 2: todavía no ha vencido -> ¿toca avisar? ---\n if (dias > diasAviso) continue; // aún faltan más días de los que pediste\n if (pospuestoHasta && hoy < pospuestoHasta) continue; // el usuario pidió esperar\n\n const diasTexto = dias === 0 ? \"¡es hoy!\" : `en ${dias} día(s)`;\n await sendMessage(\n chatId,\n `⏰ \"${grupo} - ${nombre}\" (${\n Number(importe).toFixed(2)\n }€) vence ${diasTexto} (${formatFechaEspanola(fechaIso)}).`,\n botonesAvisoPrevio(id),\n );\n }\n\n return new Response(\"ok\");\n}",[138],"pulls","branches",1,"forks","envVars",{"_154":148,"_156":61},"connections",{"_154":61,"_155":61},"count","unfilledCount","emptyCount",{"_43":137,"_32":138,"_30":139,"_131":-5,"_41":42,"_40":140,"_132":123,"_38":163,"_13":142,"_33":143,"_35":144,"_24":25,"_135":-5,"_160":164,"_27":165},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":25,"_38":159,"_13":134,"_33":34,"_35":37,"_24":25,"_135":-5,"_160":161,"_27":162},["D",1783662324516],"children",[],[28],["D",1783660234363],[],[138],["D",1783596784491],["D",1789524636084],{"_98":97,"_105":100},{"_98":97,"_99":100,"_101":100,"_18":55,"_102":103,"_104":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_125":204,"_205":206,"_207":208,"_209":25,"_210":25,"_211":25,"_212":123,"_213":-5,"_214":-7,"_215":-7,"_216":61,"_217":25,"_218":25,"_219":-5,"_220":25,"_221":25,"_222":25,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":88,"_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 · v13