Function startSPARC2API

scripts/sparc2/examples/sse-streaming.js:74–153

()

// Start the SPARC2 API server
async function startSPARC2API() {
  console.log('Finding available port for SPARC2 API server...');
  
  // Find an available port
  SPARC2_API_PORT = await findAvailablePort(SPARC2_API_PORT_START);
  console.log(`Starting SPARC2 API server on port ${SPARC2_API_PORT}...`);
  
  const denoProcess = spawn('deno', [
    'run',
    '--allow-read',
    '--allow-write',
    '--allow-env',
    '--allow-net',
    '--allow-run',
    SPARC2_CLI_PATH,
    'api',
    '--port', SPARC2_API_PORT.toString()
  ], {
    stdio: 'pipe',
    cwd: path.resolve(__dirname, '..') // Set working directory to SPARC2 root
  });

  denoProcess.stdout.on('data', (data) => {
    const message = data.toString().trim();
    console.log(`[SPARC2 API] ${message}`);
    
    // Broadcast log messages to all connected clients
    broadcastToAll({
      type: 'log',
      message
    });
  });

  denoProcess.stderr.on('data', (data) => {
    const message = data.toString().trim();
    console.log(`[SPARC2 API Error] ${message}`);
    
    // Broadcast error messages to all connected clients
    broadcastToAll({
      type: 'error',
      message
    });
  });

  // Wait for the API server to start
  return new Promise((resolve, reject) => {
    const maxAttempts = 30;
    let attempts = 0;
    
    const checkServer = () => {
      attempts++;
      http.get(`http://localhost:${SPARC2_API_PORT}/discover`, (res) => {
        if (res.statusCode === 200) {
          console.log(`SPARC2 API server is running on port ${SPARC2_API_PORT}`);
          resolve();
        } else if (attempts < maxAttempts) {
          setTimeout(checkServer, 1000);
        } else {