test-worker.js

// Test script for Ada SnapFix Worker
const fetch = require('node-fetch');

const WORKER_URL = process.env.WORKER_URL || 'http://localhost:3000';

async function testHealth() {
  try {
    console.log('🔍 Testing health endpoint...');
    const response = await fetch(`${WORKER_URL}/health`);
    const data = await response.json();
    
    if (response.ok) {
      console.log('✅ Health check passed:', data);
      return true;
    } else {
      console.log('❌ Health check failed:', data);
      return false;
    }
  } catch (error) {
    console.log('❌ Health check error:', error.message);
    return false;
  }
}

async function testBrowserService() {
  try {
    console.log('🔍 Testing browser service...');
    const response = await fetch(`${WORKER_URL}/browser`);
    const data = await response.json();
    
    if (response.ok && data.success) {
      console.log('✅ Browser service working:', data.message);
      return true;
    } else {
      console.log('❌ Browser service failed:', data);
      return false;
    }
  } catch (error) {
    console.log('❌ Browser service error:', error.message);
    return false;
  }
}

async function testSyncScan() {
  try {
    console.log('🔍 Testing sync scan...');
    const response = await fetch(`${WORKER_URL}/api/scan-sync`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        url: 'https://example.com'
      })
    });
    
    const data = await response.json();
    
    if (response.ok) {
      console.log('✅ Sync scan completed:', {
        url: data.url,
        totalIssues: data.totalIssues,
        scanType: data.metadata?.scanType
      });
      return true;
    } else {
      console.log('❌ Sync scan failed:', data);
      return false;
    }
  } catch (error) {
    console.log('❌ Sync scan error:', error.message);
    return false;
  }
}

async function testStreamingScan() {
  try {
    console.log('🔍 Testing streaming scan...');
    const response = await fetch(`${WORKER_URL}/api/scan`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'Accept': 'text/event-stream'
      },
      body: JSON.stringify({
        url: 'https://example.com'
      })
    });
    
    if (!response.ok) {
      console.log('❌ Streaming scan failed:', response.status);
      return false;
    }
    
    console.log('✅ Streaming scan started, receiving logs...');
    
    const reader = response.body.getReader();
    const decoder = new TextDecoder();
    let logCount = 0;
    let resultsReceived = false;
    
    while (true) {
      const { done, value } = await reader.read();
      if (done) break;
      
      const chunk = decoder.decode(value);
      const lines = chunk.split('\n');
      
      for (const line of lines) {
        if (line.startsWith('data: ')) {
          try {
            const data = JSON.parse(line.slice(6));
            
            if (data.type === 'results') {
              console.log('✅ Streaming scan completed:', {
                url: data.data.url,
                totalIssues: data.data.totalIssues,
                scanType: data.data.metadata?.scanType
              });
              resultsReceived = true;
            } else if (data.type === 'log') {
              logCount++;
              if (logCount <= 3) { // Show first 3 logs
                console.log(`📝 Log: ${data.message}`);
              }
            } else if (data.type === 'error') {
              console.log(`❌ Error: ${data.message}`);
            }
          } catch (parseError) {
            console.log('⚠️ Parse error:', parseError.message);
          }
        }
      }
    }
    
    return resultsReceived;
  } catch (error) {
    console.log('❌ Streaming scan error:', error.message);
    return false;
  }
}

async function runAllTests() {
  console.log('🚀 Starting Ada SnapFix Worker tests...\n');
  
  const tests = [
    { name: 'Health Check', fn: testHealth },
    { name: 'Browser Service', fn: testBrowserService },
    { name: 'Sync Scan', fn: testSyncScan },
    { name: 'Streaming Scan', fn: testStreamingScan }
  ];
  
  const results = [];
  
  for (const test of tests) {
    console.log(`\n--- ${test.name} ---`);
    const result = await test.fn();
    results.push({ name: test.name, passed: result });
    console.log(`--- ${result ? 'PASSED' : 'FAILED'} ---\n`);
  }
  
  console.log('📊 Test Results:');
  results.forEach(result => {
    console.log(`${result.passed ? '✅' : '❌'} ${result.name}`);
  });
  
  const passedCount = results.filter(r => r.passed).length;
  const totalCount = results.length;
  
  console.log(`\n🎯 Overall: ${passedCount}/${totalCount} tests passed`);
  
  if (passedCount === totalCount) {
    console.log('🎉 All tests passed! Worker is ready for production.');
  } else {
    console.log('⚠️ Some tests failed. Check the logs above for details.');
  }
}

// Run tests if this file is executed directly
if (require.main === module) {
  runAllTests().catch(console.error);
}

module.exports = {
  testHealth,
  testBrowserService,
  testSyncScan,
  testStreamingScan,
  runAllTests
};