openvibers/openrestream Commits
Listen on the socket systemd hands over, so a restart never answers 502 (#150)
Changes
@@@ -28,7 +28,10 @@ async function start({ config, clock, fetchImpl = globalThis.fetch, log = consollet server = null;if (listen) {server = await new Promise((resolve, reject) => {-- const s = app.listen(config.port, config.host, () => resolve(s));++ // Socket activation (2026-10-31): systemd's .socket unit holds the listener across restarts, so a deploy++ // queues requests in the kernel instead of answering 502. Without the socket unit, the usual listen.++ const socketActivated = process.env.LISTEN_FDS === '1' && Number(process.env.LISTEN_PID) === process.pid;++ const s = app.listen(...(socketActivated ? [{ fd: 3 }] : [config.port, config.host]), () => resolve(s));s.on('error', reject);});log.log(`[openre-api] listening on http://${config.host}:${server.address().port} (release ${config.release})`);
@@ -28,7 +28,10 @@ async function start({ config, clock, fetchImpl = globalThis.fetch, log = consol
@@ -28,7 +28,10 @@ async function start({ config, clock, fetchImpl = globalThis.fetch, log = consol
let server = null;
let server = null;
if (listen) {
if (listen) {
server = await new Promise((resolve, reject) => {
server = await new Promise((resolve, reject) => {
- const s = app.listen(config.port, config.host, () => resolve(s));
+ // Socket activation (2026-10-31): systemd's .socket unit holds the listener across restarts, so a deploy
+ // queues requests in the kernel instead of answering 502. Without the socket unit, the usual listen.
+ const socketActivated = process.env.LISTEN_FDS === '1' && Number(process.env.LISTEN_PID) === process.pid;
+ const s = app.listen(...(socketActivated ? [{ fd: 3 }] : [config.port, config.host]), () => resolve(s));
s.on('error', reject);
s.on('error', reject);
});
});
log.log(`[openre-api] listening on http://${config.host}:${server.address().port} (release ${config.release})`);
log.log(`[openre-api] listening on http://${config.host}:${server.address().port} (release ${config.release})`);