Function runTest

test/data-integrity.test.js:57–149

()

}

async function runTest() {
    const TEST_SIZE = 64 * 1024; // 64KB - enough to span multiple TCP segments
    const testData = generateTestData(TEST_SIZE);
    const expectedHash = crypto.createHash('md5').update(testData).digest('hex');
    
    console.log(`Test data: ${TEST_SIZE} bytes, MD5: ${expectedHash}`);
    
    // Start a simple HTTP server that serves the test data
    const server = http.createServer((req, res) => {
        if (req.url === '/test') {
            console.log('[Server] Serving test data...');
            res.writeHead(200, {
                'Content-Type': 'application/octet-stream',
                'Content-Length': testData.length.toString()
            });
            res.end(testData);
        } else if (req.url === '/small') {
            // Small response for quick verification
            res.writeHead(200, { 'Content-Type': 'text/plain' });
            res.end('OK');
        } else {
            res.writeHead(404);
            res.end('Not Found');
        }
    });
    
    await new Promise((resolve) => server.listen(0, '0.0.0.0', resolve));
    const port = server.address().port;
    console.log(`[Server] Listening on port ${port}`);
    
    // Get host IP that VM can reach (192.168.127.1 in VM = localhost on host)
    const vmServerUrl = `http://192.168.127.1:${port}`;
    
    try {
        // Start VM
        const vm = new AgentVM({ network: true, debug: false });
        await vm.start();
        console.log('[VM] Started');
        
        // Verify basic connectivity first
        console.log('[Test] Checking basic connectivity...');
        const pingResult = await vm.exec(`curl -s -m 5 ${vmServerUrl}/small`);
        if (pingResult.stdout !== 'OK') {
            throw new Error(`Basic connectivity failed: ${pingResult.stdout} ${pingResult.stderr}`);
        }
        console.log('[Test] Basic connectivity OK');
        
        // Now test with larger data
        console.log('[Test] Downloading test data...');
        
        // Download and save to file, then compute hash
        const dlResult = await vm.exec(`
            curl -s -m 30 -o /tmp/test.bin ${vmServerUrl}/test && \
            md5sum /tmp/test.bin && \
            wc -c /tmp/test.bin
        `);
        
        console.log('[Test] Download result:', dlResult);