staging #59

Merged
esteban merged 6 commits from staging into production 2026-07-29 03:14:35 +00:00
3 changed files with 167 additions and 101 deletions
Showing only changes of commit f5cb6f794d - Show all commits

View File

@ -1,6 +1,5 @@
import type { APIRoute } from "astro";
import { prisma } from "../lib/prisma";
import { sendEmail } from "../lib/email";
export const prerender = false;
@ -65,11 +64,32 @@ export const POST: APIRoute = async ({ request }) => {
},
});
}
await sendEmail(
{ nombre, email, mensaje },
"daviddevelope24r@outlook.com",
"CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_INFO",
);
const emailApiKey = import.meta.env.EMAIL_API_KEY;
const emailResponse = await fetch("https://flows2.carpa.com/webhook/email/send", {
method: "POST",
headers: {
"Content-Type": "application/json",
"x-api-key": emailApiKey!,
},
body: JSON.stringify({
type: "CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_INFO",
data: {
nombre,
email,
mensaje,
senderName : "Centro del Reino de Paz y Justicia",
},
}),
});
if (!emailResponse.ok) {
console.error("Error enviando correo");
return new Response(
JSON.stringify({ error: "Error en servicio de correo" }),
{ status: 500 }
);
}
return new Response(null, {
status: 302,

View File

@ -1,6 +1,5 @@
import type { APIRoute } from "astro";
import { appendToSheet, emailExists } from "../lib/googleSheets";
import { sendEmail } from "../lib/email";
export const prerender = false;
export const POST: APIRoute = async ({ request }) => {
@ -52,12 +51,31 @@ export const POST: APIRoute = async ({ request }) => {
new Date().toLocaleString()
];
// 🔹 Enviar correo y guardar en Google Sheets
await Promise.all([
sendEmail({ nombres, apellidos }, email, "CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_POSTULACION"),
appendToSheet(valuesForSheets),
// 🔹 Enviar a tu backend real
const [emailResponse] = await Promise.all([
fetch("http://155.138.215.11:3050/email/send", {
method: "POST",
headers: {
"Content-Type": "application/json",
"x-api-key": emailApiKey!,
},
body: JSON.stringify({
type: "CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_POSTULACION",
data: dataSend,
}),
}),
appendToSheet(valuesForSheets) // Guardar en Google Sheets
]);
if (!emailResponse.ok) {
return new Response(null, {
status: 302,
headers: {
Location: "/",
},
});
}
// 🔹 Redirección elegante después de enviar
return new Response(null, {
status: 302,

View File

@ -1,110 +1,138 @@
import Cloudflare from "cloudflare";
// import Cloudflare from "cloudflare";
type TypeEmailData = "CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_INFO" | "CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_POSTULACION";
const TEMPLATE_URLS: Record<TypeEmailData, { subject: string; url: string }> = {
CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_POSTULACION: {
subject: "Confirmación de inscripción al voluntariado",
url: "https://pub-910ed90860804520b9202194cf43c0a6.r2.dev/centro_del_reino_paz_y_justicia_postulacion_user.html",
},
CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_INFO: {
subject: "Notificación de contacto institucional",
url: "https://pub-910ed90860804520b9202194cf43c0a6.r2.dev/centro_del_reino_paz_y_justicia_info.html",
},
};
export async function sendEmail(data: object, to: string, type: TypeEmailData) {
const emailApiKey = import.meta.env.EMAIL_API_KEY;
const TEMPLATE_CACHE = new Map<string, string>();
const dataFinal = {
...data,
email: to,
senderName: "Centro del Reino de Paz y Justicia",
};
async function fetchTemplate(type: TypeEmailData): Promise<string> {
const cached = TEMPLATE_CACHE.get(type);
if (cached) return cached;
const emailResponse = await fetch("https://flows2.carpa.com/webhook/email/send", {
method: "POST",
headers: {
"Content-Type": "application/json",
"x-api-key": emailApiKey!,
},
body: JSON.stringify({
type: type,
data: dataFinal,
}),
});
const { url } = TEMPLATE_URLS[type];
const res = await fetch(url);
if (!res.ok) {
throw new Error(`Error descargando template ${type}: HTTP ${res.status}`);
}
const responseBody = await emailResponse.text();
const html = await res.text();
TEMPLATE_CACHE.set(type, html);
return html;
if (!emailResponse.ok) {
console.error(`Error enviando correo (status ${emailResponse.status}): ${responseBody}`);
throw new Error(`Error en servicio de correo: ${emailResponse.status}`);
}
}
function renderTemplate(template: string, data: Record<string, string>): string {
let html = template;
for (const [key, value] of Object.entries(data)) {
html = html.replaceAll(new RegExp(`\\{\\{${key}\\}\\}`, "g"), value ?? "");
}
return html;
}
// ═══════════════════════════════════════════════════════════════
// CÓDIGO COMENTADO — Cloudflare (Email Workers)
// Descomentar para volver a Cloudflare en lugar de n8n/Brevo
// ═══════════════════════════════════════════════════════════════
function stripHtml(html: string): string {
return html.replace(/<[^>]*>/g, "").replace(/\s+/g, " ").trim();
}
// const TEMPLATE_URLS: Record<TypeEmailData, { subject: string; url: string }> = {
// CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_POSTULACION: {
// subject: "Confirmación de inscripción al voluntariado",
// url: "https://pub-910ed90860804520b9202194cf43c0a6.r2.dev/centro_del_reino_paz_y_justicia_postulacion_user.html",
// },
// CENTRO_DEL_REINO_PAZ_Y_JUSTICIA_INFO: {
// subject: "Notificación de contacto institucional",
// url: "https://pub-910ed90860804520b9202194cf43c0a6.r2.dev/centro_del_reino_paz_y_justicia_info.html",
// },
// };
export async function sendEmail(data: Record<string, string>, to: string, type: TypeEmailData) {
const apiToken = import.meta.env.CLOUDFLARE_API_TOKEN;
const accountId = import.meta.env.CLOUDFLARE_ACCOUNT_ID;
// const TEMPLATE_CACHE = new Map<string, string>();
const client = new Cloudflare({ apiToken });
const { subject } = TEMPLATE_URLS[type];
const rawHtml = await fetchTemplate(type);
const html = renderTemplate(rawHtml, data);
const text = stripHtml(html);
// async function fetchTemplate(type: TypeEmailData): Promise<string> {
// const cached = TEMPLATE_CACHE.get(type);
// if (cached) return cached;
const response = await client.emailSending.send({
account_id: accountId,
from: "welcome@mail.centrodelreinodepazyjusticia.com",
to,
subject,
html,
text,
});
// const { url } = TEMPLATE_URLS[type];
// const res = await fetch(url);
// if (!res.ok) {
// throw new Error(`Error descargando template ${type}: HTTP ${res.status}`);
// }
if (!response.delivered) {
console.error("Cloudflare email not delivered", response);
throw new Error("El correo no fue entregado");
}
}
// const html = await res.text();
// TEMPLATE_CACHE.set(type, html);
// return html;
// }
/*
ALTERNATIVA: Brevo (API v3)
Para volver a Brevo:
1. Instalar: pnpm add @getbrevo/brevo
2. Agregar a .env: BREVO_API_KEY=xxx
3. Cambiar "from" a tu dominio verificado en Brevo
4. En sendEmail(), comentar el bloque Cloudflare
y descomentar la llamada a sendEmailViaBrevo()
// function renderTemplate(template: string, data: Record<string, string>): string {
// let html = template;
// for (const [key, value] of Object.entries(data)) {
// html = html.replaceAll(new RegExp(`\\{\\{${key}\\}\\}`, "g"), value ?? "");
// }
// return html;
// }
import {
TransactionalEmailsApi,
SendSmtpEmail,
} from "@getbrevo/brevo";
// function stripHtml(html: string): string {
// return html.replace(/<[^>]*>/g, "").replace(/\s+/g, " ").trim();
// }
async function sendEmailViaBrevo(
data: Record<string, string>,
to: string,
type: TypeEmailData
) {
const apiKey = import.meta.env.BREVO_API_KEY;
const { subject } = TEMPLATE_URLS[type];
const rawHtml = await fetchTemplate(type);
const html = renderTemplate(rawHtml, data);
const text = stripHtml(html);
// export async function sendEmailCf(data: Record<string, string>, to: string, type: TypeEmailData) {
// const apiToken = import.meta.env.CLOUDFLARE_API_TOKEN;
// const accountId = import.meta.env.CLOUDFLARE_ACCOUNT_ID;
const api = new TransactionalEmailsApi();
api.setApiKey(0, apiKey);
// const client = new Cloudflare({ apiToken });
// const { subject } = TEMPLATE_URLS[type];
// const rawHtml = await fetchTemplate(type);
// const html = renderTemplate(rawHtml, data);
// const text = stripHtml(html);
const email = new SendSmtpEmail();
email.subject = subject;
email.sender = { name: "Centro del Reino de Paz y Justicia", email: "welcome@mail.centrodelreinodepazyjusticia.com" };
email.to = [{ email: to }];
email.htmlContent = html;
email.textContent = text;
// const response = await client.emailSending.send({
// account_id: accountId,
// from: "welcome@mail.centrodelreinodepazyjusticia.com",
// to,
// subject,
// html,
// text,
// });
const response = await api.sendTransacEmail(email);
console.log("Brevo email sent:", response.body?.messageId);
}
*/
// if (!response.delivered) {
// console.error("Cloudflare email not delivered", response);
// throw new Error("El correo no fue entregado");
// }
// }
// ═══════════════════════════════════════════════════════════════
// ALTERNATIVA: Brevo (SDK directo)
// Descomentar y usar sendEmailViaBrevo() en lugar de lo de arriba
// Requiere: pnpm add @getbrevo/brevo + BREVO_API_KEY en .env
// ═══════════════════════════════════════════════════════════════
// import {
// TransactionalEmailsApi,
// SendSmtpEmail,
// } from "@getbrevo/brevo";
// async function sendEmailViaBrevo(
// data: Record<string, string>,
// to: string,
// type: TypeEmailData
// ) {
// const apiKey = import.meta.env.BREVO_API_KEY;
// const { subject } = TEMPLATE_URLS[type];
// const rawHtml = await fetchTemplate(type);
// const html = renderTemplate(rawHtml, data);
// const text = stripHtml(html);
// const api = new TransactionalEmailsApi();
// api.setApiKey(0, apiKey);
// const email = new SendSmtpEmail();
// email.subject = subject;
// email.sender = { name: "Centro del Reino de Paz y Justicia", email: "welcome@mail.centrodelreinodepazyjusticia.com" };
// email.to = [{ email: to }];
// email.htmlContent = html;
// email.textContent = text;
// const response = await api.sendTransacEmail(email);
// console.log("Brevo email sent:", response.body?.messageId);
// }