Multi-Platform Integration with Zapier

// Zapier Webhook Integration with Intelligent Routing
const handleZapierWebhook = async (req, res) => {
  const { trigger_type, data, source_app } = req.body;

  try {
    // Intelligent routing based on data type and source
    const routingConfig = {
      'salesforce': {
        'lead': ['hubspot', 'slack', 'email'],
        'opportunity': ['slack', 'analytics', 'reporting']
      },
      'hubspot': {
        'contact': ['salesforce', 'mailchimp', 'analytics'],
        'deal': ['salesforce', 'slack', 'reporting']
      }
    };

    const targets = routingConfig[source_app]?.[trigger_type] || [];

    // Transform data for each target platform
    const transformations = await Promise.all(
      targets.map(target => transformDataForPlatform(data, target))
    );

    // Send to Zapier webhooks for each target
    const zapierPromises = transformations.map(async (transformed, index) => {
      const webhookUrl = process.env[`ZAPIER_${targets[index].toUpperCase()}_WEBHOOK`];

      return fetch(webhookUrl, {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({
          trigger_id: generateTriggerID(),
          timestamp: new Date().toISOString(),
          source: source_app,
          target: targets[index],
          data: transformed
        })
      });
    });

    await Promise.all(zapierPromises);

    res.json({
      success: true,
      processed: targets.length,
      trigger_id: generateTriggerID()
    });

  } catch (error) {
    console.error('Zapier integration error:', error);
    res.status(500).json({ error: 'Integration failed' });
  }
};