[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_117":-5,"_20":118,"_22":119,"_120":121,"_122":123,"_25":124,"_24":-5,"_125":-5,"_126":-5,"_127":53,"_128":129,"_130":53,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","ngonz630","name","untitled-1775","branchName","main","version","path","","project",{"_33":62,"_13":14,"_45":63,"_64":-5,"_65":53,"_66":67,"_68":67,"_69":-5,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":95,"_96":97,"_98":99,"_100":53},"tree",[57],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_18":56},"id","4e7af5dd-1cfe-46cd-9b89-5b3e8fbf90e3","main.ts","fileId","4e6463f0-43fe-11f1-b436-42b51c65c3df","parentId","branchId","4e609c98-43fe-11f1-b436-42b51c65c3df","branchVersion",36,"latest",true,"createdAt",["D",1789426211306],33,"fileType","email","content","// ============================================================================\n// alertas_bcs_email_trigger.ts (v6 - VERSIÓN COMPLETA)\n//\n// Tipos implementados:\n// - WSDL (BREB)\n// - REPLICAS\n// - CRITICOS\n// - TABLESPACES\n// - REVISION_FILESYSTEM (ignorado por diseño)\n// - OSB Digital\n// - PROCESSES\n// - WTC\n// - OTHERWISE (fallback)\n//\n// Secrets: SLACK_BOT_TOKEN, SLACK_CHANNEL\n// ============================================================================\n\ninterface ValTownEmail {\n from: string;\n to: string[];\n cc?: string | string[];\n bcc?: string | string[];\n subject?: string;\n text?: string;\n html?: string;\n attachments: File[];\n}\n\nconst SLACK_BOT_TOKEN = Deno.env.get(\"SLACK_BOT_TOKEN\")!;\nconst SLACK_CHANNEL = Deno.env.get(\"SLACK_CHANNEL\") ?? \"alertas_bcs\";\n\n// ----- Utilidades -----\n\nfunction fechaColombia(): string {\n const offsetMs = -5 * 60 * 60 * 1000;\n const local = new Date(Date.now() + offsetMs);\n const yyyy = String(local.getUTCFullYear());\n const mm = String(local.getUTCMonth() + 1).padStart(2, \"0\");\n const dd = String(local.getUTCDate()).padStart(2, \"0\");\n const hh = String(local.getUTCHours()).padStart(2, \"0\");\n const mi = String(local.getUTCMinutes()).padStart(2, \"0\");\n const ss = String(local.getUTCSeconds()).padStart(2, \"0\");\n return yyyy + \"-\" + mm + \"-\" + dd + \" \" + hh + \":\" + mi + \":\" + ss;\n}\n\nfunction pad(texto: string, tam: number): string {\n const s = String(texto !== undefined && texto !== null ? texto : \"\");\n if (s.length >= tam) return s.slice(0, tam);\n return s + \" \".repeat(tam - s.length);\n}\n\nfunction numCompacto(s: string): string {\n const n = parseFloat(s);\n if (isNaN(n)) return s;\n if (Number.isInteger(n)) return String(n);\n return String(Math.round(n));\n}\n\nfunction nuevoCorrelationId(): string {\n return crypto.randomUUID().slice(0, 8);\n}\n\nfunction htmlALimpio(html: string): string {\n return html\n .replace(//gi, \"\\n\")\n .replace(/<\\/(p|div|tr|li)>/gi, \"\\n\")\n .replace(/<\\/td>/gi, \" \")\n .replace(//gi, \"\")\n .replace(/<[^>]*>/g, \"\")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/--MIME\\.Bound--/g, \"\");\n}\n\n/**\n * Devuelve tanto el texto limpio (para clasificacion y parsers de texto)\n * como el HTML crudo (para parsers que necesitan estructura, ej. WTC).\n */\ninterface BodyInfo {\n text: string;\n html: string;\n source: string;\n}\n\nfunction obtenerBody(email: ValTownEmail): BodyInfo {\n const textRaw = (email.text || \"\").trim();\n const htmlRaw = (email.html || \"\").trim();\n\n let text: string;\n let source: string;\n if (textRaw.length > 20) {\n text = textRaw;\n source = \"text\";\n } else if (htmlRaw.length > 0) {\n text = htmlALimpio(htmlRaw);\n source = \"html_converted\";\n } else {\n text = textRaw;\n source = \"text_short\";\n }\n\n return { text: text, html: htmlRaw, source: source };\n}\n\n// ----- Clasificacion -----\n\ntype TipoAlerta =\n | \"WSDL\"\n | \"REPLICAS\"\n | \"CRITICOS\"\n | \"TABLESPACES\"\n | \"REVISION_FILESYSTEM\"\n | \"OSB\"\n | \"PROCESSES\"\n | \"WTC\"\n | \"CONCURRENCIA\"\n | \"ARCHIVELOGS\"\n | \"DATABASE_DOWN\"\n | \"OTHERWISE\";\n\nfunction clasificar(body: string): TipoAlerta {\n const b = body.toLowerCase();\n\n if (/wsdl/.test(b)) return \"WSDL\";\n if (/replicas/.test(b)) return \"REPLICAS\";\n if (/criticos/.test(b)) return \"CRITICOS\";\n if (/tablespaces/.test(b)) return \"TABLESPACES\";\n\n // 🔥 FIX IMPORTANTE\n if (/revision\\s+de\\s+filesystem/.test(b)) return \"REVISION_FILESYSTEM\";\n\n if (/osb digital/.test(b)) return \"OSB\";\n if (/parametro\\s+processes/.test(b)) return \"PROCESSES\";\n if (/wtc/.test(b)) return \"WTC\";\n if (/concurrencia/i.test(b)) return \"CONCURRENCIA\";\n if (\n /archivelogs|revision_archivelogs|monitoreo directo de filesystems y diskgroups/i\n .test(b)\n ) return \"ARCHIVELOGS\";\n if (\n /base\\s+de\\s+datos\\s+en\\s+down|instancia\\s+\\w+\\s+en\\s+estado\\s+down/i.test(\n b,\n )\n ) return \"DATABASE_DOWN\";\n\n return \"OTHERWISE\";\n}\n\n// ----- Tipos del payload Slack -----\n\ninterface SlackBlock {\n type: string;\n [k: string]: unknown;\n}\n\ninterface SlackPayload {\n channel: string;\n text?: string;\n blocks: SlackBlock[];\n}\n\n// ============================================================================\n// Parser CRITICOS\n// ============================================================================\n\ninterface FilaTablespaceCritico {\n name: string;\n totalMb: string;\n freeMb: string;\n freeGb: string;\n usedPct: string;\n}\n\nfunction extraerFilasTablespaceCritico(\n texto: string,\n): FilaTablespaceCritico[] {\n const regex =\n /([A-Z][A-Z0-9_]{2,50})\\s+(\\d+(?:\\.\\d+)?|\\.\\d+)\\s+(\\d+(?:\\.\\d+)?|\\.\\d+)\\s+(\\d+(?:\\.\\d+)?|\\.\\d+)\\s+(\\d+(?:\\.\\d+)?|\\.\\d+)/g;\n\n const nombresExcluidos = new Set([\n \"TABLESPACE_NAME\",\n \"TOTAL_MB\",\n \"FREE_MB\",\n \"FREE_GB\",\n \"USED_PCT\",\n \"NAME\",\n \"BASE\",\n \"DATOS\",\n \"MONITOREO\",\n \"TABLESPACES\",\n \"CRITICOS\",\n \"CRITERIO\",\n ]);\n\n const filas: FilaTablespaceCritico[] = [];\n\n let match: RegExpExecArray | null;\n\n while ((match = regex.exec(texto)) !== null) {\n if (nombresExcluidos.has(match[1])) {\n continue;\n }\n\n filas.push({\n name: match[1],\n totalMb: match[2],\n freeMb: match[3],\n freeGb: match[4],\n usedPct: match[5],\n });\n }\n\n return filas;\n}\n\nfunction extraerTablaOriginal(seccion: string): string {\n const lineas = seccion\n .split(/\\r?\\n/)\n .map(function (l) {\n return l.replace(/\\r/g, \"\");\n });\n\n const inicio = lineas.findIndex(function (l) {\n return l.indexOf(\"TABLESPACE_NAME\") >= 0;\n });\n\n if (inicio < 0) {\n return \"\";\n }\n\n const filas: string[] = [];\n\n for (let i = inicio; i < lineas.length; i++) {\n const linea = lineas[i];\n\n if (!linea.trim()) {\n continue;\n }\n\n filas.push(linea);\n }\n\n return filas.join(\"\\n\");\n}\n\nfunction parsearCriticos(\n body: string,\n correlationId: string,\n): SlackPayload {\n const fechaCOL = fechaColombia();\n\n const seccionesDB = body\n .split(\"BASE DE DATOS:\")\n .filter(function (s) {\n return (\n s.length > 50 &&\n s.indexOf(\"MONITOREO TABLESPACES ORACLE\") < 0\n );\n })\n .map(function (seccion) {\n const primeraLinea = seccion.split(\"\\n\")[0] || \"Unknown\";\n\n const nombreBD = primeraLinea\n .trim()\n .split(\" (\")[0];\n\n const tablas = extraerFilasTablespaceCritico(seccion);\n\n return {\n db: nombreBD,\n tablas: tablas,\n };\n })\n .filter(function (s) {\n return s.tablas.length > 0;\n });\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 ALERTA URGENTE!!: TABLESPACES\",\n emoji: true,\n },\n },\n\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"Se ha detectado ocupación crítica en los Tablespaces.\",\n },\n },\n\n {\n type: \"divider\",\n },\n ];\n\n for (const item of seccionesDB) {\n // Base de datos\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"📍 *BASE DE DATOS:* `\" + item.db + \"`\",\n },\n });\n\n // Tablespaces\n for (const tabla of item.tablas) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"🔴 *\" + tabla.name + \"*\",\n },\n fields: [\n {\n type: \"mrkdwn\",\n text: \"*🚨 Ocupación*\\n`\" +\n tabla.usedPct +\n \"%`\",\n },\n {\n type: \"mrkdwn\",\n text: \"*💾 Total*\\n`\" +\n tabla.totalMb +\n \" MB`\",\n },\n {\n type: \"mrkdwn\",\n text: \"*🟢 Libre*\\n`\" +\n tabla.freeMb +\n \" MB`\",\n },\n {\n type: \"mrkdwn\",\n text: \"*📦 Libre GB*\\n`\" +\n tabla.freeGb +\n \" GB`\",\n },\n ],\n });\n\n blocks.push({\n type: \"divider\",\n });\n }\n }\n\n blocks.push({\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: \"📅 *\" +\n fechaCOL +\n \"* | 🆔 *CID:* `\" +\n correlationId +\n \"`\",\n },\n ],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🚨 ALERTA CRÍTICA: TABLESPACES\",\n blocks: blocks,\n };\n}\n// ============================================================================\n// Parser TABLESPACES (sin CRITICOS)\n// ============================================================================\n\ninterface FilaTablespaceNormal {\n name: string;\n size: string;\n free: string;\n used: string;\n status: string;\n}\n\ninterface SeccionTablespaceNormal {\n db: string;\n tablas: FilaTablespaceNormal[];\n error: string | null;\n}\n\nfunction extraerFilasTablespacesNormales(\n texto: string,\n): FilaTablespaceNormal[] {\n const regex =\n /-\\s+([A-Z][A-Z0-9_]+)\\s*\\|\\s*Size:\\s*([\\d.]+)\\s*MB\\s*\\|\\s*Free:\\s*([\\d.]+)\\s*MB\\s*\\|\\s*%\\s*ocupado:\\s*(\\d+)\\s*\\|\\s*%\\s*Free:\\s*\\d+\\s*\\|\\s*Estatus:\\s*(\\w+)/gi;\n const filas: FilaTablespaceNormal[] = [];\n let match;\n while ((match = regex.exec(texto)) !== null) {\n filas.push({\n name: match[1],\n size: numCompacto(match[2]),\n free: numCompacto(match[3]),\n used: match[4] + \"%\",\n status: match[5],\n });\n }\n return filas;\n}\n\nfunction parsearTablespacesNormales(\n body: string,\n correlationId: string,\n): SlackPayload {\n const fechaCOL = fechaColombia();\n\n const secciones: SeccionTablespaceNormal[] = body\n .split(\"Base de datos:\")\n .filter(function (s) {\n return s.trim().length > 5 &&\n s.indexOf(\"MONITOREO TABLESPACES ORACLE\") < 0;\n })\n .map(function (seccion) {\n const primeraLinea = (seccion.split(\"\\n\")[0] || \"\").trim();\n const idxError = primeraLinea.indexOf(\": ERROR:\");\n let nombreBD: string;\n let error: string | null = null;\n if (idxError >= 0) {\n nombreBD = primeraLinea.slice(0, idxError).trim();\n error = \"⚠️ Error de conexión / Acceso Denegado\";\n } else {\n nombreBD = primeraLinea;\n }\n const tablas = extraerFilasTablespacesNormales(seccion);\n if (tablas.length === 0 && !error && seccion.indexOf(\"ERROR:\") >= 0) {\n error = \"⚠️ Error de conexión / Acceso Denegado\";\n }\n return { db: nombreBD, tablas: tablas, error: error };\n })\n .filter(function (s) {\n return s.tablas.length > 0 || s.error !== null;\n });\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"📊 MONITOREO TABLESPACES ORACLE\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"Se ha generado el reporte de ocupación de los siguientes nodos:\",\n },\n },\n ];\n\n for (const item of secciones) {\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"📍 *BD:* `\" + item.db + \"`\" },\n });\n\n if (item.error) {\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"> \" + item.error },\n });\n } else {\n const filasFormateadas = item.tablas.map(function (t) {\n return pad(t.name.toUpperCase(), 14) + \" | \" + pad(t.used, 4) + \" | \" +\n pad(t.free, 7) + \" | \" + t.size + \" MB\";\n });\n const tabla = \"TS_NAME | USE% | FREE | SIZE\\n\" +\n \"---------------|------|---------|------\\n\" +\n filasFormateadas.join(\"\\n\");\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"```\\n\" + tabla + \"\\n```\" },\n });\n }\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *\" + fechaCOL + \"* | 🆔 *CID:* `\" + correlationId + \"`\",\n }],\n });\n\n if (blocks.length > 50) {\n console.warn(\n \"[\" + correlationId + \"] Mensaje excede 50 bloques (\" + blocks.length +\n \"), truncando.\",\n );\n const truncated = blocks.slice(0, 48);\n truncated.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_⚠️ Reporte truncado, hay más BDs en el correo original._\",\n },\n });\n return {\n channel: SLACK_CHANNEL,\n text: \"📊 MONITOREO TABLESPACES ORACLE\",\n blocks: truncated,\n };\n }\n\n return {\n channel: SLACK_CHANNEL,\n text: \"📊 MONITOREO TABLESPACES ORACLE\",\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser WSDL (BREB)\n// ============================================================================\n\nfunction parsearWsdl(body: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // Extraer todas las IPs:PUERTO unicas\n const regex = /(\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}:\\d{1,5})/g;\n const ipsSet = new Set();\n let match;\n while ((match = regex.exec(body)) !== null) {\n ipsSet.add(match[1]);\n }\n const ips = Array.from(ipsSet);\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"⚡ ALERTA DE SISTEMA BREB\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"🚨 *ATENCIÓN:* \\nSe detectaron errores de conexión en los siguientes servicios:\",\n },\n },\n { type: \"divider\" },\n ];\n\n if (ips.length === 0) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_No se pudieron extraer nodos del correo. Revisar logs._\",\n },\n });\n } else {\n for (const nodo of ips) {\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \" • *Nodo:* \" + nodo },\n });\n }\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *Fecha:* \" + fechaCOL + \" | 🛠️ *Módulo:* Integración Breb\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"⚡ ALERTA BREB: SERVICIOS AFECTADOS\",\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser REPLICAS\n// ============================================================================\n\nfunction parsearReplicas(\n bodyTexto: string,\n correlationId: string,\n): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // Filtra cualquier linea que contenga una IP. Mismo criterio que el DW de Mule.\n const tieneIp = /\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}/;\n const lineasConIp = bodyTexto.split(\"\\n\")\n .map(function (l) {\n return l.trim();\n })\n .filter(function (l) {\n return l.length > 0 && tieneIp.test(l);\n });\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🗂️ MONITOREO DE RÉPLICAS\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"🚨 *ATENCIÓN:* \\nSe han detectado réplicas de base de datos con retraso o errores de conexión:\",\n },\n },\n { type: \"divider\" },\n ];\n\n if (lineasConIp.length === 0) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_No se pudieron extraer réplicas del correo. Revisar logs._\",\n },\n });\n } else {\n for (const linea of lineasConIp) {\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \" • *Estado:* \" + linea },\n });\n }\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *Fecha:* \" + fechaCOL + \" | 🔍 *Estado:* Revisión Requerida\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🗂️ ALERTA: RÉPLICAS RETRASADAS - \" + fechaCOL,\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser OSB\n// ============================================================================\n\ninterface AlertaOsb {\n host: string;\n fs: string;\n uso: string;\n tam: string;\n usado: string;\n libre: string;\n}\n\nfunction parsearOsb(body: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n\n const regex =\n /HOST=([^\\s<]+)\\s+FS=([^\\s<]+)\\s+USO=(\\d+%)\\s+TAM=([^\\s<]+)\\s+USADO=([^\\s<]+)\\s+LIBRE=([^\\s<]+)/g;\n const alertas: AlertaOsb[] = [];\n let match;\n while ((match = regex.exec(body)) !== null) {\n alertas.push({\n host: match[1],\n fs: match[2],\n uso: match[3],\n tam: match[4],\n usado: match[5],\n libre: match[6],\n });\n }\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 ALERTA: FILESYSTEM OSB\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"Se detectó alta ocupación en los siguientes servidores:\",\n },\n },\n { type: \"divider\" },\n ];\n\n if (alertas.length === 0) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_No se pudieron extraer alertas del correo. Revisar logs._\",\n },\n });\n } else {\n const filasFormateadas = alertas.map(function (a) {\n return pad(a.host, 13) + \" | \" + pad(a.uso, 4) + \" | \" + pad(a.libre, 5) +\n \" | \" + a.tam;\n });\n const tabla = \"HOST | USO | LIBRE | TAM\\n\" +\n \"--------------|------|-------|-----\\n\" +\n filasFormateadas.join(\"\\n\");\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"```\\n\" + tabla + \"\\n```\" },\n });\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"📍 *Ruta común:* `\" + alertas[0].fs + \"`\",\n },\n });\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *\" + fechaCOL + \"* | 🆔 *CID:* `\" + correlationId + \"`\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🚨 ALERTA: FILESYSTEM OSB\",\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser PROCESSES\n// ============================================================================\n\ninterface AlertaProcesses {\n db: string;\n ip: string;\n limit: string;\n sesiones: string;\n uso: string;\n}\n\nfunction parsearProcesses(body: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // Patron: DB - IP - PROCESSES: X, #SESIONES: Y, USADO: Z%\n const regex =\n /(\\w+)\\s+-\\s+(\\d+\\.\\d+\\.\\d+\\.\\d+)\\s+-\\s+PROCESSES:\\s+(\\d+),\\s+#SESIONES:\\s+(\\d+),\\s+USADO:\\s+(\\d+)%/g;\n const alertas: AlertaProcesses[] = [];\n let match;\n while ((match = regex.exec(body)) !== null) {\n alertas.push({\n db: match[1],\n ip: match[2],\n limit: match[3],\n sesiones: match[4],\n uso: match[5] + \"%\",\n });\n }\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 PARAMETRO PROCESSES EXCEDIDO\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"Las siguientes bases de datos excedieron el *85%* del parámetro `processes`:\",\n },\n },\n { type: \"divider\" },\n ];\n\n if (alertas.length === 0) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_No se pudieron extraer alertas del correo. Revisar logs._\",\n },\n });\n } else {\n const filasFormateadas = alertas.map(function (a) {\n return pad(a.db.toUpperCase(), 11) + \" | \" + pad(a.uso, 4) + \" | \" +\n pad(a.sesiones, 4) + \" | \" + pad(a.limit, 5) + \" | \" + a.ip;\n });\n const tabla = \"DB NAME | USO | SESS | LIMIT | IP\\n\" +\n \"------------|------|------|-------|------------\\n\" +\n filasFormateadas.join(\"\\n\");\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"```\\n\" + tabla + \"\\n```\" },\n });\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *\" + fechaCOL + \"* | 🆔 CID: `\" + correlationId + \"`\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🚨 PARAMETRO PROCESSES EXCEDIDO\",\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser WTC (necesita HTML crudo, no texto plano)\n// ============================================================================\n\ninterface FilaWtc {\n server: string;\n detail: string;\n status: string;\n}\n\nfunction parsearWtc(htmlRaw: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // Extraer nombre del servidor (boz...)\n const serverMatch = htmlRaw.match(/[bB]oz[^\\s<–]+/);\n const serverName = serverMatch ? serverMatch[0] : \"Unknown\";\n\n // Extraer filas de la tabla. Las que tienen son el header y se ignoran\n // porque dentro NO contienen .\n const filaRegex = /([\\s\\S]*?)<\\/tr>/g;\n const celdaRegex = /([\\s\\S]*?)<\\/td>/g;\n const filas: FilaWtc[] = [];\n\n let filaMatch;\n while ((filaMatch = filaRegex.exec(htmlRaw)) !== null) {\n const filaHtml = filaMatch[1];\n if (filaHtml.indexOf(\"\") < 0) continue; // skip header con \n\n const celdas: string[] = [];\n let celdaMatch;\n // Reset lastIndex porque celdaRegex es global\n celdaRegex.lastIndex = 0;\n while ((celdaMatch = celdaRegex.exec(filaHtml)) !== null) {\n const limpio = celdaMatch[1]\n .replace(/<[^>]*>/g, \"\")\n .replace(/[\\r\\n\\t]/g, \"\")\n .trim();\n celdas.push(limpio);\n }\n\n // Estructura del email: server (0) | LDOM/RDOM (1) | detail (2) | status (3)\n filas.push({\n server: celdas[0] || \"N/A\",\n detail: celdas[2] || \"N/A\",\n status: celdas[3] || \"N/A\",\n });\n }\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 WTC STATUS - \" + serverName,\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"Se detectaron servicios fuera de línea en Core Linux:\",\n },\n },\n { type: \"divider\" },\n ];\n\n if (filas.length === 0) {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"_No se pudieron extraer filas de la tabla. Revisar logs._\",\n },\n });\n } else {\n const filasFormateadas = filas.map(function (f) {\n return pad(f.server, 10) + \" | \" + pad(f.status.toUpperCase(), 6) +\n \" | \" + f.detail;\n });\n const tabla = \"SERVIDOR | ESTADO | DETALLE\\n\" +\n \"-----------|--------|---------\\n\" +\n filasFormateadas.join(\"\\n\");\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"```\\n\" + tabla + \"\\n```\" },\n });\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *\" + fechaCOL + \"* | 🆔 *CID:* `\" + correlationId + \"`\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🚨 WTC STATUS - \" + serverName,\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser CONCURRENCIA ORACLE\n// ============================================================================\n\nfunction parsearConcurrencia(\n body: string,\n correlationId: string,\n): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // 1. Extraer la Base de Datos y su IP\n const dbMatch = body.match(\n /BASE DE DATOS:\\s*([A-Z0-9_]+\\s*-\\s*\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3})/i,\n );\n const nombreBD = dbMatch ? dbMatch[1].trim() : \"Desconocida\";\n\n // 2. Extraer los datos del bloqueador principal (Sección 7 del correo)\n // Busca la línea de datos numérica debajo de los guiones de BLOQUEADOR_SID...\n const datosBloqueadorRegex =\n /BLOQUEADOR_SID\\s+SESIONES_BLOQUEADAS\\s+MAX_SEGUNDOS_ESPERA\\s*-+\\s*([\\d\\s]+)/i;\n const matchDatos = body.match(datosBloqueadorRegex);\n\n let tablaBloqueo = \"\";\n if (matchDatos && matchDatos[1]) {\n // Normalizamos los espacios del resultado (ej: \"4577 2 20 6560 1 11\")\n const valores = matchDatos[1].trim().split(/\\s+/);\n if (valores.length >= 3) {\n const sid = pad(valores[0], 14);\n const sesBloq = pad(valores[1], 10);\n const maxSeg = valores[2];\n\n tablaBloqueo = \"BLOQUEADOR_SID | SES_BLOQ | MAX_SEG_ESP\\n\" +\n \"---------------|------------|------------\\n\" +\n sid + \" | \" + sesBloq + \" | \" + maxSeg;\n }\n }\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"💥 ALERTA: CONCURRENCIA CRÍTICA ORACLE\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"🚨 *ATENCIÓN:* Se han detectado problemas de concurrencia y bloqueo de filas (`TX ROW LOCK`).\",\n },\n },\n { type: \"divider\" },\n {\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"📍 *BASE DE DATOS:* `\" + nombreBD + \"`\" },\n },\n ];\n\n // Si se logró extraer la tabla resumida de bloqueos, la añadimos\n if (tablaBloqueo) {\n blocks.push({\n type: \"section\",\n text: { type: \"mrkdwn\", text: \"```\\n\" + tablaBloqueo + \"\\n```\" },\n });\n } else {\n blocks.push({\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"_Ver detalles de las sesiones con esperas activas directamente en el correo original._\",\n },\n });\n }\n\n blocks.push({ type: \"divider\" });\n blocks.push({\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"📅 *\" + fechaCOL + \"* | 🆔 *CID:* `\" + correlationId + \"`\",\n }],\n });\n\n return {\n channel: SLACK_CHANNEL,\n text: \"💥 ALERTA: CONCURRENCIA CRÍTICA ORACLE - \" + nombreBD,\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser ARCHIVELOGS\n// ============================================================================\nfunction parsearArchivelogs(body: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n\n // Extraer únicamente las líneas que contienen alertas o advertencias\n const lineas = body.split(\"\\n\");\n const lineasCriticas = lineas.filter((linea) =>\n /\\[ALERTA\\]|\\[WARN\\]|\\[ERROR\\]/i.test(linea)\n );\n\n // Si por alguna razón no se encuentran líneas formateadas, se toma un extracto del cuerpo\n const contenidoReporte = lineasCriticas.length > 0\n ? lineasCriticas.join(\"\\n\")\n : lineas.slice(0, 15).join(\"\\n\");\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 ALERTA CRÍTICA: ESPACIO EN ARCHIVELOGS / ASM\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"*Se ha superado el umbral crítico de almacenamiento (>=95%) en uno o más servidores:*\",\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text: \"```\\n\" + contenidoReporte + \"\\n```\",\n },\n },\n { type: \"divider\" },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: `🕒 *Fecha:* ${fechaCOL} | 🆔 *CID:* \\`${correlationId}\\``,\n },\n ],\n },\n ];\n\n return {\n channel: SLACK_CHANNEL,\n text: \"🚨 ALERTA CRÍTICA: ESPACIO EN ARCHIVELOGS / ASM\",\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser DATABASE_DOWN\n// ============================================================================\nfunction parsearDatabaseDown(\n body: string,\n correlationId: string,\n): SlackPayload {\n const fechaCOL = fechaColombia(); //\n\n // Extraer la instancia / base de datos afectada (ej. \"bdwcc1\")\n const matchInstancia =\n body.match(/INSTANCIA\\s+([^\\s]+)\\s+EN\\0* ESTADO\\s+DOWN/i) ||\n body.match(/INSTANCIA\\s+([^\\s]+)\\s+EN\\s+ESTADO\\s+DOWN/i);\n\n const instanciaAfectada = matchInstancia\n ? matchInstancia[1]\n : \"No especificada\";\n\n const blocks: SlackBlock[] = [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"🚨 ALERTA: BASE DE DATOS EN DOWN\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n `*Atención:* Se ha detectado una caída en el servicio de base de datos.\\n\\n` +\n `• *Instancia en Down:* \\`${instanciaAfectada}\\`\\n` +\n `• *Estado:* \\`DOWN / INOPERATIVA\\``,\n },\n },\n { type: \"divider\" },\n {\n type: \"context\",\n elements: [\n {\n type: \"mrkdwn\",\n text: \"📅 \" + fechaCOL + \" | 🆔 CID: \" + correlationId, //[cite: 1]\n },\n ],\n },\n ];\n\n return {\n channel: SLACK_CHANNEL,\n text: `🚨 ALERTA: Base de datos en down (${instanciaAfectada})`,\n blocks: blocks,\n };\n}\n\n// ============================================================================\n// Parser fallback OTHERWISE\n// ============================================================================\n\nfunction parsearOtherwise(_body: string, correlationId: string): SlackPayload {\n const fechaCOL = fechaColombia();\n return {\n channel: SLACK_CHANNEL,\n text: \"⚠️ Mensaje No Catalogado\",\n blocks: [\n {\n type: \"header\",\n text: {\n type: \"plain_text\",\n text: \"⚠️ Mensaje No Catalogado\",\n emoji: true,\n },\n },\n {\n type: \"section\",\n text: {\n type: \"mrkdwn\",\n text:\n \"*Detalle:* Se ha recibido una carga inesperada. Revisar logs para más info.\",\n },\n },\n {\n type: \"section\",\n fields: [{ type: \"mrkdwn\", text: \"*Fecha (COL):*\\n\" + fechaCOL }],\n },\n { type: \"divider\" },\n {\n type: \"context\",\n elements: [{\n type: \"mrkdwn\",\n text: \"🆔 *CID:* `\" + correlationId + \"`\",\n }],\n },\n ],\n };\n}\n\n// ----- Envio a Slack -----\n\nasync function enviarASlack(payload: SlackPayload): Promise {\n const res = await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Authorization\": \"Bearer \" + SLACK_BOT_TOKEN,\n },\n body: JSON.stringify(payload),\n });\n const data = await res.json();\n if (!data.ok) {\n throw new Error(\"Slack API error: \" + (data.error || \"unknown\"));\n }\n}\n\n// ----- Handler principal -----\n\nexport default async function (email: ValTownEmail): Promise {\n const correlationId = nuevoCorrelationId();\n const bodyInfo = obtenerBody(email);\n const body = bodyInfo.text;\n\n console.log(\n \"[\" + correlationId + \"] Email recibido - from: \" + email.from +\n ', subject: \"' + (email.subject || \"(sin asunto)\") + '\"',\n );\n console.log(\n \"[\" + correlationId + \"] Body source: \" + bodyInfo.source +\n \" | text length: \" + body.length + \" | html length: \" +\n bodyInfo.html.length,\n );\n\n if (!body) {\n console.warn(\"[\" + correlationId + \"] Email sin body, ignorado.\");\n return;\n }\n\n const tipo = clasificar(body);\n console.log(\"[\" + correlationId + \"] Clasificado como \" + tipo);\n\n let payload: SlackPayload;\n switch (tipo) {\n case \"WSDL\":\n payload = parsearWsdl(body, correlationId);\n break;\n case \"REPLICAS\":\n payload = parsearReplicas(body, correlationId);\n break;\n case \"CRITICOS\":\n payload = parsearCriticos(body, correlationId);\n break;\n case \"TABLESPACES\":\n payload = parsearTablespacesNormales(body, correlationId);\n break;\n case \"OSB\":\n payload = parsearOsb(body, correlationId);\n break;\n case \"CONCURRENCIA\":\n payload = parsearConcurrencia(body, correlationId);\n break;\n case \"ARCHIVELOGS\":\n payload = parsearArchivelogs(body, correlationId);\n break;\n case \"PROCESSES\":\n payload = parsearProcesses(body, correlationId);\n break;\n case \"DATABASE_DOWN\": // <--- Registro del nuevo caso\n payload = parsearDatabaseDown(body, correlationId);\n break;\n case \"WTC\":\n // WTC necesita el HTML crudo. Si no hay HTML, usar body como fallback.\n payload = parsearWtc(bodyInfo.html || body, correlationId);\n break;\n case \"OTHERWISE\":\n console.warn(\n \"[\" + correlationId +\n \"] ⚠️ Mensaje No Catalogado detectado. Se registra en log y se omite envío a Slack.\",\n );\n return;\n case \"REVISION_FILESYSTEM\":\n console.log(\n \"[\" + correlationId + \"] REVISION_FILESYSTEM ignorado por diseño.\",\n );\n return;\n }\n\n await enviarASlack(payload);\n console.log(\"[\" + correlationId + \"] Enviado a Slack OK.\");\n}","deleted",false,"label","alertasbcs",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":58,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_59":60,"_18":61},["D",1789426211306],"children",[],[35],"4e5fbae4-43fe-11f1-b436-42b51c65c3df",["D",1777489494083],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","b4eac2d9-bfc8-49fb-bf55-f572e687e3df","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019dda9d-d473-7219-b4d1-17c01ad548ee","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_116":112},"org",{"_11":12,"_109":110,"_111":112,"_71":72,"_113":114,"_115":53},"branch",{"_17":42,"_13":16,"_33":40,"_101":62,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Nicolás Gonalez","avatar","https://lh3.googleusercontent.com/a/ACg8ocJz_2kzp0V5Gx--jXN4yLrj7SsIcZ1MeEoPxGXYW9dC7CP1TaT1=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":62,"_13":14,"_45":151,"_64":-5,"_65":53,"_66":67,"_68":67,"_69":-5,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":152,"_96":153,"_98":154,"_100":53},[148],"files",[148],"counts",{"_137":78,"_138":139,"_140":78,"_31":141,"_142":143},[135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_18":136},[35],"pulls","branches",1,"forks",{"_144":146,"_147":78},"connections",{"_144":78,"_145":78},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":58,"_17":47,"_48":49,"_50":51,"_52":53,"_54":55,"_59":149,"_18":150},[],[35],["D",1777489494083],{"_11":12,"_116":112},{"_11":12,"_109":110,"_111":112,"_71":72,"_113":114,"_115":53},{"_17":42,"_13":16,"_33":40,"_101":62,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"ctx",{"_94":-5,"_132":188,"_189":190,"_191":192,"_193":53,"_194":53,"_195":53,"_196":44,"_197":-5,"_198":-7,"_199":-7,"_200":78,"_201":53,"_202":53,"_203":-5,"_204":53,"_205":53,"_206":53,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":16,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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"]

Code