create-test-result.js

const http = require('http');

// Get pending tasks
http.get('http://127.0.0.1:4000/api/v1/scraping/tasks/pending', {
  headers: { 'X-API-Key': 'sk-test-integration-1234567890' }
}, (res) => {
  let data = '';
  res.on('data', c => data += c);
  res.on('end', () => {
    const json = JSON.parse(data);
    if (json.tasks && json.tasks.length > 0) {
      const taskId = json.tasks[0].id;
      console.log('✅ Using task:', taskId);

      // Start task
      const startOpts = {
        hostname: '127.0.0.1',
        port: 4000,
        path: `/api/v1/scraping/tasks/${taskId}/start`,
        method: 'POST',
        headers: { 'X-API-Key': 'sk-test-integration-1234567890' }
      };

      const startReq = http.request(startOpts, (startRes) => {
        let startData = '';
        startRes.on('data', c => startData += c);
        startRes.on('end', () => {
          console.log('✅ Task started:', startData);

          // Submit result after 500ms
          setTimeout(() => {
            const resultData = JSON.stringify({
              taskId,
              platformId: 'tiktok',
              success: true,
              data: {
                items: [{
                  id: `tiktok-zachking-${Date.now()}`,
                  title: 'Zach King',
                  description: 'Bringing a little more wonder into the world',
                  url: 'https://www.tiktok.com/@zachking',
                  metadata: {
                    username: 'zachking',
                    displayName: 'Zach King',
                    bio: 'Bringing a little more wonder',
                    stats: {
                      followers: 84300000,
                      likes: 1200000000,
                      following: 166
                    },
                    engagement: { rate: 14.23 }
                  }
                }],
                pageInfo: { currentPage: 1, totalPages: 1 }
              },
              timestamp: new Date().toISOString(),
              executionTime: 1500
            });

            const resultOpts = {
              hostname: '127.0.0.1',
              port: 4000,
              path: `/api/v1/scraping/tasks/${taskId}/result`,
              method: 'POST',
              headers: {
                'Content-Type': 'application/json',
                'Content-Length': Buffer.byteLength(resultData),
                'X-API-Key': 'sk-test-integration-1234567890'
              }
            };

            const resultReq = http.request(resultOpts, (resultRes) => {
              let resultData = '';
              resultRes.on('data', c => resultData += c);
              resultRes.on('end', () => {
                console.log('✅ Result submitted:', resultData);
              });
            });

            resultReq.on('error', e => console.error('❌ Result error:', e));
            resultReq.write(resultData);
            resultReq.end();
          }, 500);
        });
      });

      startReq.on('error', e => console.error('❌ Start error:', e));
      startReq.end();
    } else {
      console.log('❌ No pending tasks found');
    }
  });
}).on('error', e => console.error('❌ Request error:', e));