verify-database.js

#!/usr/bin/env node

/**
 * Verify Database Integration
 * Tests that the contact form actually saves data to the database
 */

const http = require('http');
const { URL } = require('url');

const BASE_URL = 'http://localhost:3000';
const API_ENDPOINT = '/api/contact';

function makeRequest(url, method = 'GET', data = null) {
  return new Promise((resolve, reject) => {
    const urlObj = new URL(url);

    const options = {
      hostname: urlObj.hostname,
      port: urlObj.port || 80,
      path: urlObj.pathname + urlObj.search,
      method,
      headers: {
        'Content-Type': 'application/json',
        'User-Agent': 'Boreas-DB-Test/1.0',
        'x-forwarded-for': `10.0.0.${Math.floor(Math.random() * 254) + 1}`,
      }
    };

    if (data) {
      const jsonData = JSON.stringify(data);
      options.headers['Content-Length'] = Buffer.byteLength(jsonData);
    }

    const req = http.request(options, (res) => {
      let body = '';
      res.on('data', (chunk) => {
        body += chunk;
      });

      res.on('end', () => {
        try {
          const responseData = body ? JSON.parse(body) : {};
          resolve({
            statusCode: res.statusCode,
            headers: res.headers,
            body: responseData
          });
        } catch (error) {
          resolve({
            statusCode: res.statusCode,
            headers: res.headers,
            body: body,
            parseError: error.message
          });
        }
      });
    });

    req.on('error', reject);

    if (data) {
      req.write(JSON.stringify(data));
    }

    req.end();
  });
}

async function createTestLead() {
  console.log('🧪 Creating Test Lead for Database Verification...\n');

  const timestamp = Date.now();
  const testData = {
    name: "Database Test User",
    email: `db-test-${timestamp}@example.com`,
    whatsapp: "+525512345678",
    company: "Test Company DB",
    business_type: "clinic",
    city: "Guadalajara",
    message: "Testing database integration - timestamp: " + timestamp
  };

  console.log('📤 Creating lead with data:');
  console.log(JSON.stringify(testData, null, 2));

  try {
    const response = await makeRequest(`${BASE_URL}${API_ENDPOINT}`, 'POST', testData);

    console.log('\n📥 Response received:');
    console.log('Status Code:', response.statusCode);

    if (response.statusCode === 201) {
      console.log('✅ Lead created successfully!');
      console.log('Lead ID:', response.body.data.id);
      console.log('Lead Score:', response.body.data.lead_score);
      console.log('Message:', response.body.message);

      return {
        success: true,
        leadId: response.body.data.id,
        leadScore: response.body.data.lead_score,
        email: testData.email,
        timestamp: timestamp
      };
    } else {
      console.log('❌ Failed to create lead');
      console.log('Response:', JSON.stringify(response.body, null, 2));
      return { success: false };
    }

  } catch (error) {
    console.log('❌ Error creating lead:', error.message);
    return { success: false };
  }
}

async function testDuplicateDetection(email) {
  console.log('\n🔍 Testing Database Duplicate Detection...\n');

  const duplicateData = {
    name: "Duplicate Test User",
    email: email,
    whatsapp: "+525512345679",
    company: "Another Company",
    business_type: "salon",
    city: "Monterrey",
    message: "This should be detected as duplicate"
  };

  console.log('📤 Attempting to create duplicate with same email...');

  try {
    const response = await makeRequest(`${BASE_URL}${API_ENDPOINT}`, 'POST', duplicateData);

    console.log('Status Code:', response.statusCode);

    if (response.statusCode === 409 && response.body.error?.code === 'DUPLICATE_LEAD') {
      console.log('✅ Duplicate detection working!');
      console.log('Error message:', response.body.error.message);
      return true;
    } else {
      console.log('❌ Duplicate not detected or wrong response');
      console.log('Response:', JSON.stringify(response.body, null, 2));
      return false;
    }

  } catch (error) {
    console.log('❌ Error testing duplicate:', error.message);
    return false;
  }
}

async function main() {
  console.log('🗄️ Boreas Database Integration Test');
  console.log('===================================\n');

  // Create a test lead
  const leadResult = await createTestLead();

  if (!leadResult.success) {
    console.log('❌ Cannot test database - lead creation failed');
    process.exit(1);
  }

  console.log(`\n✅ Test lead created with ID: ${leadResult.leadId}`);

  // Test duplicate detection
  const duplicateTest = await testDuplicateDetection(leadResult.email);

  console.log('\n📊 Database Test Results:');
  console.log('========================');
  console.log(`Lead Creation: ${leadResult.success ? '✅' : '❌'}`);
  console.log(`Duplicate Detection: ${duplicateTest ? '✅' : '❌'}`);

  // Summary
  console.log('\n🎯 Database Integration Status:');
  if (leadResult.success && duplicateTest) {
    console.log('🎉 DATABASE INTEGRATION WORKING!');
    console.log('✅ Leads are being saved correctly');
    console.log('✅ Duplicate detection is functional');
    console.log('✅ Lead scoring is calculated');
    console.log('✅ All database operations successful');
    console.log('\n📋 Test Details:');
    console.log(`- Lead ID: ${leadResult.leadId}`);
    console.log(`- Lead Score: ${leadResult.leadScore} (clinic: 20 + form: 20 = 40)`);
    console.log(`- Email: ${leadResult.email}`);
    console.log(`- Timestamp: ${leadResult.timestamp}`);
  } else {
    console.log('⚠️ Database integration has issues');
    console.log('🔧 Check Supabase connection and table structure');
  }

  process.exit(leadResult.success && duplicateTest ? 0 : 1);
}

if (require.main === module) {
  main().catch(error => {
    console.error('❌ Database test failed:', error);
    process.exit(1);
  });
}