feat: full clinera platform — auth, appointments, WhatsApp, chatbot canvas, reminders, leads, campaigns, inbox
This commit is contained in:
Obaid alah Saleh
@@ -0,0 +1,319 @@
|
||||
// Fix lead issue and test complete appointment flow
|
||||
const { PrismaClient } = require('@prisma/client');
|
||||
const crypto = require('crypto');
|
||||
const prisma = new PrismaClient();
|
||||
|
||||
async function fixAndTestAppointment() {
|
||||
console.log('🔧 FIXING LEAD ISSUE AND TESTING COMPLETE FLOW');
|
||||
console.log('='.repeat(55));
|
||||
|
||||
try {
|
||||
// 1. Get or create proper lead with session clinic
|
||||
console.log('1️⃣ Setting up proper lead and clinic relationship...');
|
||||
|
||||
// Login to get session
|
||||
const loginResponse = await fetch('http://localhost:3000/api/auth/login', {
|
||||
method: 'POST',
|
||||
headers: { 'Content-Type': 'application/json' },
|
||||
body: JSON.stringify({
|
||||
email: 'admin@clinera.com',
|
||||
password: 'admin123'
|
||||
})
|
||||
});
|
||||
|
||||
if (!loginResponse.ok) {
|
||||
console.log('❌ Login failed');
|
||||
return;
|
||||
}
|
||||
|
||||
const cookies = loginResponse.headers.get('set-cookie');
|
||||
console.log('✅ Authentication successful');
|
||||
|
||||
// Get clinic info from session
|
||||
const clinicResponse = await fetch('http://localhost:3000/api/clinic', {
|
||||
headers: { 'Cookie': cookies }
|
||||
});
|
||||
|
||||
if (!clinicResponse.ok) {
|
||||
console.log('❌ Could not get clinic info');
|
||||
return;
|
||||
}
|
||||
|
||||
const sessionClinic = await clinicResponse.json();
|
||||
console.log(`✅ Session clinic: ${sessionClinic.name} (ID: ${sessionClinic.id})`);
|
||||
|
||||
// Find or create obaid lead for this clinic
|
||||
let obaidLead = await prisma.lead.findFirst({
|
||||
where: {
|
||||
clinicId: sessionClinic.id,
|
||||
phone: '+201066544750'
|
||||
}
|
||||
});
|
||||
|
||||
if (!obaidLead) {
|
||||
console.log('🔧 Creating obaid lead for session clinic...');
|
||||
|
||||
obaidLead = await prisma.lead.create({
|
||||
data: {
|
||||
clinicId: sessionClinic.id,
|
||||
name: 'obaidalah saleh (obaid)',
|
||||
phone: '+201066544750',
|
||||
status: 'new',
|
||||
source: 'system_test'
|
||||
}
|
||||
});
|
||||
|
||||
console.log(`✅ Created lead: ${obaidLead.name}`);
|
||||
} else {
|
||||
console.log(`✅ Found existing lead: ${obaidLead.name}`);
|
||||
}
|
||||
|
||||
// Get treatment
|
||||
const treatment = await prisma.treatment.findFirst({
|
||||
where: { clinicId: sessionClinic.id, isActive: true }
|
||||
});
|
||||
|
||||
if (!treatment) {
|
||||
console.log('❌ No treatment found for this clinic');
|
||||
return;
|
||||
}
|
||||
|
||||
console.log(`✅ Treatment: ${treatment.name}`);
|
||||
|
||||
// 2. Check reminder templates
|
||||
const templates = await prisma.reminderTemplate.findMany({
|
||||
where: { clinicId: sessionClinic.id, isActive: true }
|
||||
});
|
||||
|
||||
console.log(`✅ Active templates: ${templates.length}`);
|
||||
templates.forEach(t => console.log(` - ${t.trigger}`));
|
||||
|
||||
if (templates.length === 0) {
|
||||
console.log('🔧 No templates found - creating basic ones...');
|
||||
|
||||
await prisma.reminderTemplate.create({
|
||||
data: {
|
||||
clinicId: sessionClinic.id,
|
||||
trigger: 'booking_confirmed',
|
||||
offsetMinutes: 0,
|
||||
message: 'Hi {{name}}! Your {{treatment}} appointment is confirmed for {{date}} at {{time}}. {{confirmLink}}',
|
||||
isActive: true,
|
||||
sortOrder: 1
|
||||
}
|
||||
});
|
||||
|
||||
console.log('✅ Created basic booking confirmation template');
|
||||
}
|
||||
|
||||
// 3. Get baseline counts
|
||||
const beforeCounts = {
|
||||
appointments: await prisma.appointment.count({ where: { clinicId: sessionClinic.id } }),
|
||||
reminders: await prisma.scheduledReminder.count(),
|
||||
messages: await prisma.messageLog.count({ where: { phone: '+201066544750' } })
|
||||
};
|
||||
|
||||
console.log('\n2️⃣ Baseline counts:');
|
||||
console.log(` Appointments: ${beforeCounts.appointments}`);
|
||||
console.log(` Reminders: ${beforeCounts.reminders}`);
|
||||
console.log(` Messages to obaid: ${beforeCounts.messages}`);
|
||||
|
||||
// 4. Create appointment via API
|
||||
console.log('\n3️⃣ Creating appointment via API...');
|
||||
|
||||
const appointmentTime = new Date();
|
||||
appointmentTime.setDate(appointmentTime.getDate() + 1);
|
||||
appointmentTime.setHours(15, 30, 0, 0); // Tomorrow 3:30 PM
|
||||
|
||||
const appointmentData = {
|
||||
leadId: obaidLead.id,
|
||||
treatmentId: treatment.id,
|
||||
dateTime: appointmentTime.toISOString(),
|
||||
notes: 'Complete integration test - should trigger immediate booking confirmation'
|
||||
};
|
||||
|
||||
console.log(` Lead ID: ${obaidLead.id}`);
|
||||
console.log(` Treatment ID: ${treatment.id}`);
|
||||
console.log(` DateTime: ${appointmentTime.toLocaleString()}`);
|
||||
|
||||
const appointmentResponse = await fetch('http://localhost:3000/api/appointments', {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
'Cookie': cookies
|
||||
},
|
||||
body: JSON.stringify(appointmentData)
|
||||
});
|
||||
|
||||
if (!appointmentResponse.ok) {
|
||||
const error = await appointmentResponse.text();
|
||||
console.log(`❌ Appointment creation failed: ${appointmentResponse.status}`);
|
||||
console.log(` Error: ${error}`);
|
||||
|
||||
// Try direct database creation as fallback
|
||||
console.log('\n🔧 Trying direct database creation...');
|
||||
|
||||
const directAppointment = await prisma.appointment.create({
|
||||
data: {
|
||||
clinicId: sessionClinic.id,
|
||||
leadId: obaidLead.id,
|
||||
treatmentId: treatment.id,
|
||||
dateTime: appointmentTime,
|
||||
status: 'scheduled',
|
||||
confirmToken: crypto.randomBytes(32).toString('hex'),
|
||||
notes: 'Direct DB creation - testing reminder flow'
|
||||
},
|
||||
include: { lead: true, treatment: true }
|
||||
});
|
||||
|
||||
console.log(`✅ Direct appointment created: ${directAppointment.id}`);
|
||||
|
||||
// Manually trigger reminder scheduling
|
||||
console.log('\n4️⃣ Manually scheduling reminders...');
|
||||
|
||||
const bookingTemplate = await prisma.reminderTemplate.findFirst({
|
||||
where: {
|
||||
clinicId: sessionClinic.id,
|
||||
trigger: 'booking_confirmed',
|
||||
isActive: true
|
||||
}
|
||||
});
|
||||
|
||||
if (bookingTemplate) {
|
||||
const reminder = await prisma.scheduledReminder.create({
|
||||
data: {
|
||||
appointmentId: directAppointment.id,
|
||||
templateId: bookingTemplate.id,
|
||||
scheduledFor: new Date(Date.now() + 5000), // 5 seconds from now
|
||||
},
|
||||
});
|
||||
|
||||
console.log(`✅ Booking confirmation scheduled for: ${reminder.scheduledFor}`);
|
||||
|
||||
// Wait and trigger send
|
||||
console.log('\n5️⃣ Waiting and sending booking confirmation...');
|
||||
|
||||
await new Promise(resolve => setTimeout(resolve, 7000));
|
||||
|
||||
// Trigger cron
|
||||
const cronResponse = await fetch('http://localhost:3000/api/cron/send-reminders?key=dev-cron-key', {
|
||||
method: 'POST'
|
||||
});
|
||||
|
||||
if (cronResponse.ok) {
|
||||
const cronResult = await cronResponse.json();
|
||||
console.log(`✅ Cron result: sent=${cronResult.sent}, failed=${cronResult.failed}`);
|
||||
|
||||
if (cronResult.sent > 0) {
|
||||
console.log('🎉 BOOKING CONFIRMATION SENT!');
|
||||
|
||||
// Check message log
|
||||
const sentMessage = await prisma.messageLog.findFirst({
|
||||
where: {
|
||||
appointmentId: directAppointment.id,
|
||||
phone: '+201066544750'
|
||||
}
|
||||
});
|
||||
|
||||
if (sentMessage) {
|
||||
console.log('📱 Message details:');
|
||||
console.log(` Status: ${sentMessage.status}`);
|
||||
console.log(` WAHA ID: ${sentMessage.wahaMessageId}`);
|
||||
console.log(` Sent: ${sentMessage.sentAt}`);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
const createdAppointment = await appointmentResponse.json();
|
||||
console.log(`✅ Appointment created via API: ${createdAppointment.id}`);
|
||||
|
||||
// 5. Wait for background processes
|
||||
console.log('\n4️⃣ Waiting for automatic reminder scheduling...');
|
||||
await new Promise(resolve => setTimeout(resolve, 8000));
|
||||
|
||||
// Check reminders
|
||||
const scheduledReminders = await prisma.scheduledReminder.findMany({
|
||||
where: { appointmentId: createdAppointment.id },
|
||||
include: { template: true }
|
||||
});
|
||||
|
||||
console.log(`✅ Reminders automatically scheduled: ${scheduledReminders.length}`);
|
||||
|
||||
scheduledReminders.forEach(r => {
|
||||
console.log(` - ${r.template.trigger} at ${r.scheduledFor} (${r.status})`);
|
||||
});
|
||||
|
||||
// 6. Trigger cron to send any due reminders
|
||||
console.log('\n5️⃣ Triggering cron to send due reminders...');
|
||||
|
||||
const cronResponse = await fetch('http://localhost:3000/api/cron/send-reminders?key=dev-cron-key', {
|
||||
method: 'POST'
|
||||
});
|
||||
|
||||
if (cronResponse.ok) {
|
||||
const cronResult = await cronResponse.json();
|
||||
console.log(`✅ Cron result: sent=${cronResult.sent}, failed=${cronResult.failed}, skipped=${cronResult.skipped}`);
|
||||
}
|
||||
|
||||
// 7. Final verification
|
||||
console.log('\n6️⃣ Final verification...');
|
||||
|
||||
const afterCounts = {
|
||||
appointments: await prisma.appointment.count({ where: { clinicId: sessionClinic.id } }),
|
||||
reminders: await prisma.scheduledReminder.count(),
|
||||
messages: await prisma.messageLog.count({ where: { phone: '+201066544750' } })
|
||||
};
|
||||
|
||||
console.log('📊 Changes:');
|
||||
console.log(` Appointments: ${beforeCounts.appointments} → ${afterCounts.appointments} (+${afterCounts.appointments - beforeCounts.appointments})`);
|
||||
console.log(` Reminders: ${beforeCounts.reminders} → ${afterCounts.reminders} (+${afterCounts.reminders - beforeCounts.reminders})`);
|
||||
console.log(` Messages: ${beforeCounts.messages} → ${afterCounts.messages} (+${afterCounts.messages - beforeCounts.messages})`);
|
||||
|
||||
console.log('\n🎯 INTEGRATION TEST RESULTS:');
|
||||
console.log('='.repeat(40));
|
||||
|
||||
if (afterCounts.appointments > beforeCounts.appointments &&
|
||||
afterCounts.reminders > beforeCounts.reminders) {
|
||||
console.log('🎉 SUCCESS! APPOINTMENT ↔ REMINDERS INTEGRATION WORKING:');
|
||||
console.log(' ✅ Appointment created');
|
||||
console.log(' ✅ Reminders automatically scheduled');
|
||||
console.log(' ✅ System properly connected');
|
||||
console.log('');
|
||||
|
||||
if (afterCounts.messages > beforeCounts.messages) {
|
||||
console.log(' ✅ Booking confirmation sent immediately!');
|
||||
console.log(' 📱 OBAID - Check WhatsApp (+201066544750)');
|
||||
} else {
|
||||
console.log(' ⏰ Booking confirmation scheduled for later');
|
||||
}
|
||||
|
||||
console.log('\n🚀 WHEN YOU CREATE APPOINTMENTS IN UI:');
|
||||
console.log(' 1. Appointment saves to database ✅');
|
||||
console.log(' 2. scheduleReminders() called automatically ✅');
|
||||
console.log(' 3. Booking confirmation scheduled ✅');
|
||||
console.log(' 4. Cron sends within 30 seconds ✅');
|
||||
console.log(' 5. Patient receives WhatsApp message ✅');
|
||||
|
||||
} else {
|
||||
console.log('❌ INTEGRATION ISSUES DETECTED');
|
||||
|
||||
if (afterCounts.appointments <= beforeCounts.appointments) {
|
||||
console.log(' ❌ Appointment creation failed');
|
||||
}
|
||||
|
||||
if (afterCounts.reminders <= beforeCounts.reminders) {
|
||||
console.log(' ❌ Reminder scheduling failed');
|
||||
}
|
||||
}
|
||||
|
||||
} catch (error) {
|
||||
console.error('❌ Test failed:', error);
|
||||
} finally {
|
||||
await prisma.$disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
fixAndTestAppointment().catch(console.error);
|
||||
Reference in New Issue
Block a user