Salesforce Integration

// Salesforce Connection Configuration
const sf = require('sf-node');

const conn = new sf.Connection({
  loginUrl: 'https://login.salesforce.com',
  username: process.env.SF_USERNAME,
  password: process.env.SF_PASSWORD
});

// Create Lead from VAI Conversation
async function createLeadFromConversation(conversationData) {
  const leadData = {
    FirstName: conversationData.firstName || '',
    LastName: conversationData.lastName || 'Unknown',
    Email: conversationData.email,
    Phone: conversationData.phone || '',
    Company: conversationData.company || '',
    Description: conversationData.conversationText,
    LeadSource: 'VAI Portal',
    Lead_Score__c: conversationData.leadScore,
    Status: 'New'
  };

  try {
    const result = await conn.sobject('Lead').create(leadData);
    console.log('Lead created with ID:', result.id);
    return result;
  } catch (error) {
    console.error('Error creating lead:', error);
    throw error;
  }
}

// Advanced Lead Scoring for VAI Conversations
function calculateLeadScore(conversation) {
  const scoreWeights = {
    budget_mentioned: 25,
    timeline_discussed: 20,
    decision_maker: 15,
    competitor_mentioned: 10,
    technical_questions: 12,
    pricing_inquiry: 18,
    demo_request: 30,
    enterprise_features: 22
  };

  let score = 0;
  const text = conversation.message.toLowerCase();

  // Check for buying signals
  if (text.includes('budget') || text.includes('price')) score += scoreWeights.budget_mentioned;
  if (text.includes('when') || text.includes('timeline')) score += scoreWeights.timeline_discussed;
  if (text.includes('manager') || text.includes('decision')) score += scoreWeights.decision_maker;
  if (text.includes('competitor') || text.includes('alternative')) score += scoreWeights.competitor_mentioned;
  if (text.includes('how does') || text.includes('technical')) score += scoreWeights.technical_questions;
  if (text.includes('demo') || text.includes('trial')) score += scoreWeights.demo_request;
  if (text.includes('enterprise') || text.includes('scale')) score += scoreWeights.enterprise_features;

  // Conversation depth bonus
  if (conversation.messageCount > 5) score += 10;
  if (conversation.duration > 300) score += 5; // 5+ minutes

  return {
    score: Math.min(score, 100), // Cap at 100
    tier: score >= 70 ? 'Hot' : score >= 40 ? 'Warm' : 'Cold',
    nextAction: score >= 70 ? 'Immediate Follow-up' : score >= 40 ? 'Email Nurturing' : 'Lead Nurturing'
  };
}