Lead Nurturing Workflow

				
					// Custom code for dynamic content selection in lead nurturing workflow
exports.main = (functionContext, sendResponse) => {
  // Get contact properties from the workflow
  const { contact_id, email, recent_conversion_page, industry, lead_score } = functionContext.parameters;
  
  // Initialize HubSpot client
  const hubspot = require('@hubspot/api-client');
  const hubspotClient = new hubspot.Client({
    accessToken: process.env.PRIVATE_APP_ACCESS_TOKEN
  });
  
  // Get contact's interaction history
  async function getContactInteractions() {
    try {
      // Get recent page views
      const pageViewsResponse = await hubspotClient.cms.audit_logs.getPageViewsForContact(contact_id);
      
      // Get email engagement
      const engagementResponse = await hubspotClient.crm.contacts.associationsApi.getAll(
        contact_id, 
        'engagement'
      );
      
      // Analyze content preferences based on interactions
      const contentPreferences = analyzeContentPreferences(pageViewsResponse.results, engagementResponse.results);
      
      // Determine next best content
      const nextBestContent = determineNextContent(contentPreferences, industry, lead_score);
      
      // Return the content recommendation
      sendResponse({
        statusCode: 200,
        body: {
          recommended_content_id: nextBestContent.id,
          content_type: nextBestContent.type,
          personalization_reason: nextBestContent.reason
        }
      });
    } catch (error) {
      // Handle errors
      sendResponse({
        statusCode: 500,
        body: {
          error: error.message
        }
      });
    }
  }
  
  // Helper function to analyze content preferences
  function analyzeContentPreferences(pageViews, engagements) {
    // Implementation would analyze which topics and content types
    // the contact has engaged with most frequently
    
    // Simplified example:
    const topicCounts = {
      product: 0,
      industry: 0,
      howTo: 0,
      caseStudy: 0
    };
    
    // Count topic engagements
    pageViews.forEach(view => {
      if (view.path.includes('/product')) topicCounts.product++;
      if (view.path.includes('/industry')) topicCounts.industry++;
      if (view.path.includes('/how-to')) topicCounts.howTo++;
      if (view.path.includes('/case-study')) topicCounts.caseStudy++;
    });
    
    // Find preferred topics (simplified)
    const preferredTopics = Object.entries(topicCounts)
      .sort((a, b) => b[1] - a[1])
      .slice(0, 2)
      .map(entry => entry[0]);
      
    return {
      preferredTopics,
      conversionSource: recent_conversion_page
    };
  }
  
  // Helper function to determine next best content
  function determineNextContent(preferences, industry, leadScore) {
    // Implementation would match preferences to available content
    // and consider the lead's position in the funnel (based on lead score)
    
    // Simplified example:
    let contentType;
    let contentId;
    let reason;
    
    // Early-stage leads get educational content
    if (leadScore < 50) {
      if (preferences.preferredTopics.includes('howTo')) {
        contentType = 'BLOG_POST';
        contentId = 'blog-12345';
        reason = 'Based on your interest in how-to guides';
      } else {
        contentType = 'WHITEPAPER';
        contentId = 'whitepaper-54321';
        reason = `Relevant to your ${industry} industry`;
      }
    } 
    // Mid-stage leads get case studies
    else if (leadScore < 80) {
      contentType = 'CASE_STUDY';
      contentId = 'case-study-67890';
      reason = `See how other ${industry} companies achieved success`;
    }
    // Late-stage leads get product-focused content
    else {
      contentType = 'PRODUCT_DEMO';
      contentId = 'demo-request';
      reason = 'Take the next step with a personalized demo';
    }
    
    return {
      type: contentType,
      id: contentId,
      reason: reason
    };
  }
  
  // Execute the main function
  getContactInteractions();
};