refactor(api): enhance donation creation with rate limiting, Zod validation, and secure logging

- Add rate limiting to prevent abuse on /api/donations/create endpoint
- Replace manual input validation with Zod schema for better error handling and type safety
- Switch from console.log to secureLogger to comply with LGPD and avoid exposing sensitive data
- Remove sensitive request body logging in AbacatePay client for improved security
This commit is contained in:
Evandro Fonseca Junior committed 2025-10-26 23:01:19 -03:00
1 parent bb6b320d1f
commit a1800227a7
11 files changed
+876 -138

No files matched your search

+61 -12
View File
@@ -1,9 +1,32 @@
import { NextRequest, NextResponse } from "next/server";
import { abacatePay } from "@/lib/abacatepay";
import { markAsPaid } from "@/lib/payment-cache";
import {
checkRateLimit,
getClientIP,
createRateLimitResponse,
} from "@/lib/rate-limiter";
import { secureLogger } from "@/lib/secure-logger";
// Whitelist de IPs do AbacatePay (configurável via env)
const ABACATEPAY_IPS = process.env.ABACATEPAY_WHITELIST_IPS?.split(",") || [];
export async function POST(request: NextRequest) {
try {
// Rate limiting
const ip = getClientIP(request);
const rateLimit = checkRateLimit(ip, "/api/webhooks/abacatepay");
if (!rateLimit.allowed) {
return createRateLimitResponse(rateLimit.resetAt);
}
// Validar IP de origem (se configurado)
if (ABACATEPAY_IPS.length > 0 && !ABACATEPAY_IPS.includes(ip)) {
secureLogger.warn("Webhook rejeitado: IP não autorizado", { ip });
return NextResponse.json({ error: "IP não autorizado" }, { status: 403 });
}
const payload = await request.text();
// AbacatePay envia webhookSecret como query param
@@ -13,15 +36,34 @@ export async function POST(request: NextRequest) {
// Validar secret
if (!webhookSecret || !expectedSecret || webhookSecret !== expectedSecret) {
console.error("🔒 Webhook rejeitado: secret inválido ou ausente");
secureLogger.warn("Webhook rejeitado: secret inválido ou ausente");
return NextResponse.json({ error: "Secret inválido" }, { status: 401 });
}
console.log("✅ Webhook autenticado com sucesso");
secureLogger.info("Webhook autenticado com sucesso");
const event = JSON.parse(payload);
console.log("🔔 Webhook recebido:", JSON.stringify(event, null, 2));
secureLogger.debug("Webhook recebido", event);
// Validar timestamp do evento (prevenir replay attacks)
const eventTimestamp = event.timestamp || event.data?.pixQrCode?.createdAt;
if (eventTimestamp) {
const eventTime = new Date(eventTimestamp).getTime();
const now = Date.now();
const timeDiff = Math.abs(now - eventTime);
// Rejeitar eventos com mais de 5 minutos de diferença
if (timeDiff > 5 * 60 * 1000) {
secureLogger.warn("Webhook rejeitado: timestamp inválido", {
timeDiff: timeDiff / 1000 + "s",
});
return NextResponse.json(
{ error: "Timestamp inválido" },
{ status: 400 }
);
}
}
// Verificar se é evento de pagamento confirmado
const isPaidEvent =
@@ -35,11 +77,14 @@ export async function POST(request: NextRequest) {
const payment = event.data.payment;
if (!pixQrCode || pixQrCode.status !== "PAID") {
console.log("⚠️ Webhook recebido mas status não é PAID");
secureLogger.info("Webhook recebido mas status não é PAID");
return NextResponse.json({ success: true });
}
console.log("✅ Doação confirmada via webhook:", pixQrCode.id);
secureLogger.info("Doação confirmada via webhook", {
pixId: pixQrCode.id,
amount: pixQrCode.amount,
});
// Detectar se é doação anônima ou identificada
const isAnonymous = !pixQrCode.customer;
@@ -67,13 +112,15 @@ export async function POST(request: NextRequest) {
taxId: pixQrCode.customer.metadata.taxId,
};
console.log(
"📧 Email disponível para agradecimento:",
pixQrCode.customer.metadata.email
);
secureLogger.info("Email disponível para agradecimento", {
maskedEmail: pixQrCode.customer.metadata.email,
});
}
console.log("📝 Registro de pagamento:", donationRecord);
secureLogger.info(
"Registro de pagamento criado",
secureLogger.mask(donationRecord)
);
// Salvar no cache para frontend detectar via polling
markAsPaid(pixQrCode.id, donationRecord);
@@ -93,12 +140,14 @@ export async function POST(request: NextRequest) {
// TODO: Atualizar estatísticas
// await updateDonationStats(donationRecord.amount);
} else {
console.log("ℹ️ Evento de webhook (não é pagamento):", event.event);
secureLogger.info("Evento de webhook (não é pagamento)", {
event: event.event,
});
}
return NextResponse.json({ success: true });
} catch (error) {
console.error("Webhook error:", error);
secureLogger.error("Webhook error", error);
return NextResponse.json(
{ error: "Erro ao processar webhook" },
{ status: 500 }