test_server_sync.js

/**
 * Multi-Client Real-Time SSE Sync Verification Test Suite
 */

import http from 'http';

console.log('=== Running Alegio.js Real-Time SSE Multi-Client Sync Test ===\n');

// 1. Establish SSE Client B listener
const reqB = http.request('http://localhost:8085/api/stream', (res) => {
  console.log('✅ PASS: Client B connected to SSE Stream (HTTP 200)');
  
  res.on('data', (chunk) => {
    const raw = chunk.toString();
    const lines = raw.split('\n');
    lines.forEach(line => {
      if (line.startsWith('data: ')) {
        const payload = JSON.parse(line.replace('data: ', ''));
        if (payload.type === 'STATE_UPDATE') {
          console.log(`✅ PASS: Client B received real-time broadcast from ${payload.sender}:`);
          console.log(`         Updated '${payload.key}' data count = ${payload.data.length} items`);
          console.log('\n🎉 Multi-Client Real-Time SSE Sync Verification Successful!');
          process.exit(0);
        }
      }
    });
  });
});

reqB.end();

// 2. Client A posts a state mutation to /api/state after 500ms
setTimeout(() => {
  console.log('📡 Client A sending state mutation to /api/state...');
  const postData = JSON.stringify({
    key: 'todos_state',
    clientId: 'client_A_test',
    data: [
      { id: '1', title: 'Task 1', completed: true },
      { id: '2', title: 'Task 2 Realtime Test', completed: false }
    ]
  });

  const postReq = http.request('http://localhost:8085/api/state', {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Content-Length': Buffer.byteLength(postData)
    }
  }, (res) => {
    console.log('✅ PASS: Client A state mutation committed to Edge Server DB');
  });

  postReq.write(postData);
  postReq.end();
}, 500);