Payment Confirmed!
Dear ${application.first_name},
Your payment of €${application.payment_amount} for Valley of the Commons has been received.
Payment Details
| Type: |
Event Registration${accomLabel ? ' + Accommodation' : ''} |
${accomRow}
| Amount: |
€${application.payment_amount} |
| Mollie Reference: |
${application.mollie_payment_id} |
${bookingHtml}
Your application is now complete. Our team will review it and get back to you within 2-3 weeks.
If you have any questions, reply to this email and we'll get back to you.
With warmth,
The Valley of the Commons Team
Application ID: ${application.id}
`
};
};
async function logEmail(recipientEmail, recipientName, emailType, subject, messageId, metadata = {}) {
try {
await pool.query(
`INSERT INTO email_log (recipient_email, recipient_name, email_type, subject, message_id, metadata)
VALUES ($1, $2, $3, $4, $5, $6)`,
[recipientEmail, recipientName, emailType, subject, messageId, JSON.stringify(metadata)]
);
} catch (error) {
console.error('Failed to log email:', error);
}
}
// Webhook handler - called by Mollie when payment status changes
async function handleWebhook(req, res) {
try {
const paymentId = req.body.id;
if (!paymentId) {
return res.status(400).json({ error: 'Missing payment id' });
}
// Fetch payment status from Mollie
const payment = await mollieClient.payments.get(paymentId);
const applicationId = payment.metadata.applicationId;
// Map Mollie status to our status
let paymentStatus;
switch (payment.status) {
case 'paid':
paymentStatus = 'paid';
break;
case 'failed':
paymentStatus = 'failed';
break;
case 'canceled':
paymentStatus = 'canceled';
break;
case 'expired':
paymentStatus = 'expired';
break;
case 'pending':
paymentStatus = 'pending';
break;
case 'open':
paymentStatus = 'open';
break;
default:
paymentStatus = payment.status;
}
// Update application payment status
await pool.query(
`UPDATE applications
SET payment_status = $1::varchar,
payment_paid_at = CASE WHEN $1::varchar = 'paid' THEN CURRENT_TIMESTAMP ELSE payment_paid_at END
WHERE mollie_payment_id = $2::varchar`,
[paymentStatus, paymentId]
);
console.log(`Payment ${paymentId} for application ${applicationId}: ${paymentStatus}`);
// On payment success: assign bed + send confirmation emails
if (paymentStatus === 'paid') {
try {
const appResult = await pool.query(
'SELECT id, first_name, last_name, email, contribution_amount, payment_amount, mollie_payment_id, accommodation_type FROM applications WHERE mollie_payment_id = $1',
[paymentId]
);
if (appResult.rows.length > 0) {
const application = appResult.rows[0];
const accommodationType = payment.metadata.accommodationType || application.accommodation_type;
const selectedWeeks = payment.metadata.selectedWeeks || [];
// Attempt bed assignment if accommodation was selected
let bookingResult = null;
if (accommodationType) {
try {
const guestName = `${application.first_name} ${application.last_name}`;
bookingResult = await assignBooking(guestName, accommodationType, selectedWeeks);
console.log(`[Booking] ${guestName}: ${bookingResult.success ? 'Assigned' : 'Failed'} — ${JSON.stringify(bookingResult)}`);
} catch (bookingError) {
console.error('[Booking] Assignment error:', bookingError);
bookingResult = { success: false, reason: bookingError.message };
}
}
// Send payment confirmation email
if (process.env.SMTP_PASS) {
const confirmEmail = paymentConfirmationEmail(application, bookingResult);
const info = await smtp.sendMail({
from: process.env.EMAIL_FROM || 'Valley of the Commons