validate-webhooks.js

// Simple validation script for webhook implementation
// This can be run with Node.js to validate the webhook structure

const fs = require('fs');
const path = require('path');

console.log('🔍 Validating Webhook Implementation...\n');

// Check if webhook route file exists
const webhookRoutePath = path.join(__dirname, 'src/routes/webhooks.ts');
if (fs.existsSync(webhookRoutePath)) {
  console.log('✅ Webhook route file exists');
} else {
  console.log('❌ Webhook route file missing');
  process.exit(1);
}

// Check if webhook service has flat payload support
const webhookServicePath = path.join(__dirname, 'src/services/webhook.ts');
if (fs.existsSync(webhookServicePath)) {
  const serviceContent = fs.readFileSync(webhookServicePath, 'utf8');
  if (serviceContent.includes('FlatWebhookPayload') && serviceContent.includes('buildFlatPayload')) {
    console.log('✅ Webhook service has flat payload support');
  } else {
    console.log('❌ Webhook service missing flat payload functionality');
    process.exit(1);
  }
} else {
  console.log('❌ Webhook service file missing');
  process.exit(1);
}

// Check if documentation exists
const zapierDocPath = path.join(__dirname, 'docs/ZAPIER_WEBHOOK_SETUP.md');
const makeDocPath = path.join(__dirname, 'docs/MAKE_COM_WEBHOOK_SETUP.md');

if (fs.existsSync(zapierDocPath)) {
  console.log('✅ Zapier documentation exists');
} else {
  console.log('❌ Zapier documentation missing');
}

if (fs.existsSync(makeDocPath)) {
  console.log('✅ Make.com documentation exists');
} else {
  console.log('❌ Make.com documentation missing');
}

// Check if tests exist
const webhookTestPath = path.join(__dirname, 'src/routes/__tests__/webhooks.test.ts');
const webhookServiceTestPath = path.join(__dirname, 'src/services/__tests__/webhook-flat.test.ts');

if (fs.existsSync(webhookTestPath)) {
  console.log('✅ Webhook route tests exist');
} else {
  console.log('❌ Webhook route tests missing');
}

if (fs.existsSync(webhookServiceTestPath)) {
  console.log('✅ Webhook service tests exist');
} else {
  console.log('❌ Webhook service tests missing');
}

// Check if main index.ts imports webhook routes
const indexPath = path.join(__dirname, 'src/index.ts');
if (fs.existsSync(indexPath)) {
  const indexContent = fs.readFileSync(indexPath, 'utf8');
  if (indexContent.includes('webhookRoutes') && indexContent.includes('/api/webhooks')) {
    console.log('✅ Webhook routes are registered in main app');
  } else {
    console.log('❌ Webhook routes not registered in main app');
    process.exit(1);
  }
} else {
  console.log('❌ Main index.ts file missing');
  process.exit(1);
}

// Validate webhook schema structure
const webhookRouteContent = fs.readFileSync(webhookRoutePath, 'utf8');
const requiredFields = [
  'event_id',
  'event_type', 
  'timestamp',
  'transaction_id',
  'reference_number',
  'transaction_type',
  'amount',
  'currency',
  'phone_number',
  'provider',
  'stellar_address',
  'status'
];

let missingFields = [];
requiredFields.forEach(field => {
  if (!webhookRouteContent.includes(field)) {
    missingFields.push(field);
  }
});

if (missingFields.length === 0) {
  console.log('✅ All required webhook fields are defined');
} else {
  console.log(`❌ Missing webhook fields: ${missingFields.join(', ')}`);
  process.exit(1);
}

// Check for required endpoints
const requiredEndpoints = [
  'GET /schema',
  'GET /sample', 
  'POST /',
  'POST /test'
];

let missingEndpoints = [];
requiredEndpoints.forEach(endpoint => {
  if (!webhookRouteContent.includes(endpoint)) {
    missingEndpoints.push(endpoint);
  }
});

if (missingEndpoints.length === 0) {
  console.log('✅ All required webhook endpoints are implemented');
} else {
  console.log(`❌ Missing webhook endpoints: ${missingEndpoints.join(', ')}`);
  process.exit(1);
}

console.log('\n🎉 Webhook implementation validation completed successfully!');
console.log('\n📋 Summary of implemented features:');
console.log('  • Flat webhook payload structure for no-code tools');
console.log('  • Schema discovery endpoint (/api/webhooks/schema)');
console.log('  • Sample payload endpoint (/api/webhooks/sample)');
console.log('  • Test endpoint for debugging (/api/webhooks/test)');
console.log('  • HMAC-SHA256 signature verification');
console.log('  • Comprehensive Zapier and Make.com documentation');
console.log('  • Full test coverage');
console.log('  • Integration with existing webhook service');

console.log('\n🚀 Ready for no-code integration with Zapier and Make.com!');