# Trigger car data update
curl -X POST "https://api.sgcarstrends.com/workflows/cars" \
  -H "Content-Type: application/json"

# Trigger COE data update
curl -X POST "https://api.sgcarstrends.com/workflows/coe" \
  -H "Content-Type: application/json"

# Trigger all workflows (requires authentication)
curl -X POST "https://api.sgcarstrends.com/workflows/trigger" \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json"

curl -X POST "https://api.sgcarstrends.com/workflows/linkedin/post" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "New car registration data available for January 2024",
    "link": "https://sgcarstrends.com/cars/2024-01"
  }'

curl -X POST "https://api.sgcarstrends.com/workflows/twitter/post" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "📊 January 2024 car registration data is now available! Check out the latest trends in Singapore'"'"'s automotive market.",
    "link": "https://sgcarstrends.com/cars/2024-01"
  }'

curl -X POST "https://api.sgcarstrends.com/workflows/discord/post" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "🚗 **New Data Available**\n\nJanuary 2024 car registration data has been updated!\n\n🔗 View details: https://sgcarstrends.com/cars/2024-01"
  }'

curl -X POST "https://api.sgcarstrends.com/workflows/telegram/post" \
  -H "Content-Type: application/json" \
  -d '{
    "message": "📈 New car registration data for January 2024 is available! Electric vehicle registrations continue to grow.",
    "link": "https://sgcarstrends.com/cars/2024-01"
  }'

// Function to trigger workflow and monitor result
async function triggerWorkflow(workflowType) {
  const endpoint = `https://api.sgcarstrends.com/workflows/${workflowType}`;
  
  try {
    const response = await fetch(endpoint, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
    });
    
    if (!response.ok) {
      throw new Error(`HTTP error! status: ${response.status}`);
    }
    
    const result = await response.json();
    console.log(`${workflowType} workflow result:`, result);
    
    return result;
  } catch (error) {
    console.error(`Failed to trigger ${workflowType} workflow:`, error);
    throw error;
  }
}

// Usage
await triggerWorkflow('cars');
await triggerWorkflow('coe');

curl "https://api.sgcarstrends.com/health" \
  -H "Content-Type: application/json"

async function robustWorkflowTrigger(workflowType, maxRetries = 3) {
  for (let attempt = 1; attempt <= maxRetries; attempt++) {
    try {
      const result = await triggerWorkflow(workflowType);
      return result;
    } catch (error) {
      console.log(`Attempt ${attempt} failed:`, error.message);
      
      if (attempt === maxRetries) {
        throw new Error(`Failed after ${maxRetries} attempts: ${error.message}`);
      }
      
      // Exponential backoff
      await new Promise(resolve => setTimeout(resolve, 1000 * Math.pow(2, attempt)));
    }
  }
}

function validateWorkflowResponse(response) {
  if (!response.success) {
    throw new Error(`Workflow failed: ${response.error}`);
  }
  
  if (!response.data) {
    throw new Error('No data returned from workflow');
  }
  
  return true;
}

// Test workflow without side effects
async function testWorkflow(workflowType) {
  const testEndpoint = `https://api-staging.sgcarstrends.com/workflows/${workflowType}`;
  
  const response = await fetch(testEndpoint, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'X-Test-Mode': 'true' // Custom header for test mode
    },
  });
  
  return await response.json();
}

// Custom workflow that combines multiple operations
async function customDataUpdateWorkflow() {
  try {
    console.log('Starting custom data update workflow...');
    
    // Step 1: Trigger car data update
    const carResult = await triggerWorkflow('cars');
    console.log('Car data update completed:', carResult.success);
    
    // Step 2: Trigger COE data update
    const coeResult = await triggerWorkflow('coe');
    console.log('COE data update completed:', coeResult.success);
    
    // Step 3: Post to social media if new data was processed
    if (carResult.data?.processed_new_data || coeResult.data?.processed_new_data) {
      await postToSocialMedia('New data available for January 2024!');
    }
    
    console.log('Custom workflow completed successfully');
    
  } catch (error) {
    console.error('Custom workflow failed:', error);
    
    // Send alert to Discord
    await fetch('https://api.sgcarstrends.com/workflows/discord/post', {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        message: `⚠️ Custom workflow failed: ${error.message}`
      })
    });
  }
}

async function postToSocialMedia(message) {
  const platforms = ['linkedin', 'twitter', 'discord', 'telegram'];
  
  const results = await Promise.allSettled(
    platforms.map(platform => 
      fetch(`https://api.sgcarstrends.com/workflows/${platform}/post`, {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ message })
      })
    )
  );
  
  results.forEach((result, index) => {
    if (result.status === 'fulfilled') {
      console.log(`${platforms[index]} post successful`);
    } else {
      console.error(`${platforms[index]} post failed:`, result.reason);
    }
  });
}