Function startStatusServer

test/lifecycleProxyHealth.test.js:13–55

(mode, token)

const { writeSettings } = require('../src/proxy/server/settings');

function startStatusServer(mode, token) {
  const child = spawn(process.execPath, ['-e', `
const http = require('http');
const mode = process.env.TEST_PROXY_MODE;
const token = process.env.TEST_PROXY_TOKEN;
const server = http.createServer((req, res) => {
  if (mode === 'auth') {
    if (req.headers.authorization !== 'Bearer ' + token) {
      res.writeHead(401, { 'content-type': 'application/json' });
      res.end(JSON.stringify({ error: 'unauthorized' }));
      return;
    }
    res.writeHead(200, { 'content-type': 'application/json' });
    res.end(JSON.stringify({
      status: 'running',
      proxy_protocol_version: '1.0.0',
      schema_version: '1.0.0',
    }));
    return;
  }
  res.writeHead(200, { 'content-type': 'application/json' });
  res.end(JSON.stringify({ ok: true }));
});
server.listen(0, '127.0.0.1', () => {
  process.stdout.write('http://127.0.0.1:' + server.address().port + '\\n');
});
process.on('SIGTERM', () => server.close(() => process.exit(0)));
`], {
    env: { PATH: process.env.PATH, TEST_PROXY_MODE: mode, TEST_PROXY_TOKEN: token || '' },
    stdio: ['ignore', 'pipe', 'inherit'],
  });
  return new Promise((resolve, reject) => {
    let settled = false;
    child.once('error', reject);
    child.stdout.once('data', (chunk) => {
      settled = true;
      resolve({ child, url: String(chunk).trim() });
    });
    child.once('exit', (code) => {
      if (!settled) reject(new Error(`status server exited early: ${code}`));
    });
  });
}

function close(child) {
  return new Promise((resolve) => {