Zoho CRM Integration

const express = require('express');
const axios = require('axios');
const app = express();
 
app.use(express.json());
 
// Zoho CRM webhook endpoint
app.post('/zoho/webhook', async (req, res) => {
try {
const { module, action, data } = req.body;
 
    console.log('Zoho webhook received:', { module, action });
 
    // Handle different modules and actions
    if (module === 'Leads' && action === 'create') {
      await handleNewLead(data);
    } else if (module === 'Deals' && action === 'update') {
      await handleDealUpdate(data);
    } else if (module === 'Events' && action === 'create') {
      await handleAppointment(data);
    }
 
    res.json({ success: true, message: 'Webhook processed' });
 
} catch (error) {
console.error('Webhook processing error:', error);
res.status(500).json({ success: false, error: error.message });
}
});
 
// Handle new lead
async function handleNewLead(lead) {
const phoneNumber = lead.Phone || lead.Mobile;
const firstName = lead.First_Name;
const lastName = lead.Last_Name;
 
if (!phoneNumber) {
console.log('No phone number found for lead');
return;
}
 
const message = `Hi ${firstName}, thank you for your interest! Our team will contact you shortly to discuss how we can help.`;
 
await sendSMS(phoneNumber, message);
}
 
// Handle deal stage update
async function handleDealUpdate(deal) {
if (deal.Stage === 'Closed Won') {
const contactPhone = deal.Contact_Phone || deal.Contact_Mobile;
const dealName = deal.Deal_Name;
const amount = deal.Amount;
 
    if (contactPhone) {
      const message = `Congratulations! Your deal "${dealName}" worth $${amount} has been confirmed. We're excited to work with you!`;
      await sendSMS(contactPhone, message);
    }
 
}
}
 
// Handle appointment
async function handleAppointment(event) {
const attendeePhone = event.Participant_Phone;
const eventTitle = event.Event_Title;
const startTime = new Date(event.Start_DateTime);
 
if (attendeePhone) {
const formattedTime = startTime.toLocaleString('en-US', {
dateStyle: 'medium',
timeStyle: 'short'
});
 
    const message = `Appointment confirmed: ${eventTitle} on ${formattedTime}. We look forward to meeting you!`;
    await sendSMS(attendeePhone, message);
 
}
}
 
// Send SMS using SMSLeopard API
async function sendSMS(phoneNumber, message) {
const apiKey = process.env.SMSLEOPARD_API_KEY;
const apiSecret = process.env.SMSLEOPARD_API_SECRET;
const sourceAddress = process.env.SENDER_ID;
 
const formattedPhone = formatPhoneNumber(phoneNumber);
 
try {
const response = await axios.post(
'https://api.smsleopard.com/v1/sms/send',
{
source: sourceAddress,
destination: [formattedPhone],
message: message
},
{
headers: {
'Content-Type': 'application/json',
'Authorization': `Bearer ${apiKey}:${apiSecret}`
}
}
);
 
    console.log('SMS sent successfully:', response.data);
    return response.data;
 
} catch (error) {
console.error('Error sending SMS:', error.response?.data || error.message);
throw error;
}
}
 
function formatPhoneNumber(phone) {
// Remove spaces and special characters
phone = phone.replace(/[\s\-\(\)]/g, '');
 
// Add country code if missing (example for Kenya)
if (phone.startsWith('0')) {
return '254' + phone.substring(1);
} else if (phone.startsWith('+')) {
return phone.substring(1);
}
 
return phone;
}
 
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
console.log(`Zoho webhook server running on port ${PORT}`);
});
 

const cron = require('node-cron');
 
// Send reminders 24 hours before appointments
cron.schedule('0 9 \* \* \*', async () => {
const tomorrow = new Date();
tomorrow.setDate(tomorrow.getDate() + 1);
 
// Fetch appointments from Zoho CRM API
const appointments = await fetchTomorrowAppointments(tomorrow);
 
for (const appointment of appointments) {
const message = `Reminder: You have an appointment tomorrow at ${appointment.time} for ${appointment.title}. See you then!`;
await sendSMS(appointment.phone, message);
}
});
 
async function fetchTomorrowAppointments(date) {
// Implement Zoho CRM API call to fetch appointments
// This is a placeholder - actual implementation depends on Zoho API
return [];
}