Listen on the socket systemd hands over, so a restart never answers 502 (#161)

OP OpenVibers committed 13 days ago · 44c52512f1 · 1 file, +4 −1

When the service is socket-activated (LISTEN_FDS=1 for this process), it listens on fd 3, the listener a
systemd .socket unit holds across restarts: requests that arrive during a deploy wait in the kernel's accept
queue and are served by the new process. Without the socket unit it listens on its port as before. The same
three lines Network, Media, Chat and Live use. 2026-10-31: a Codes deploy gave the owner a Cloudflare 502.

Changes

ddiff --git a/server/index.js b/server/index.js
iindex 2383c65..7546c09 100644
---- a/server/index.js
++++ b/server/index.js
@@@ -45,7 +45,10 @@ async function main() {
      const { app, ctx } = await createApp({ config, store: createStore(db), registry });
      const { authorities, tokens, outbox, keys, docs } = ctx;
  
--    const server = app.listen(config.port, config.host, () => {
++    // 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 server = app.listen(...(socketActivated ? [{ fd: 3 }] : [config.port, config.host]), () => {
          console.log(`[Services] ${config.nodeEnv} on http://${config.host}:${config.port} → ${config.baseUrl} (store ${db.store})`);
          console.log(`[Services] docs from openvibe-contracts v${docs.contractsVersion} and openvibe-sdk v${docs.sdkVersion}; authorities ${authorities.size()}: ${authorities.ids().join(', ') || 'none'} (+ services in process); authority tokens ${tokens.enabled ? `client ${config.oauth.clientId}` : 'off (OV_OAUTH_CLIENT_SECRET unset: authorities are reported partial)'}; events relay ${outbox.enabled ? `on → ${config.events.url}` : 'off (events wait in services_events_outbox)'}`);
      });

diff --git a/server/index.js b/server/index.js

index 2383c65..7546c09 100644

--- a/server/index.js

+++ b/server/index.js

@@ -45,7 +45,10 @@ async function main() {

const { app, ctx } = await createApp({ config, store: createStore(db), registry });

const { authorities, tokens, outbox, keys, docs } = ctx;

- const server = app.listen(config.port, config.host, () => {

+ // 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 server = app.listen(...(socketActivated ? [{ fd: 3 }] : [config.port, config.host]), () => {

console.log(`[Services] ${config.nodeEnv} on http://${config.host}:${config.port} → ${config.baseUrl} (store ${db.store})`);

console.log(`[Services] docs from openvibe-contracts v${docs.contractsVersion} and openvibe-sdk v${docs.sdkVersion}; authorities ${authorities.size()}: ${authorities.ids().join(', ') || 'none'} (+ services in process); authority tokens ${tokens.enabled ? `client ${config.oauth.clientId}` : 'off (OV_OAUTH_CLIENT_SECRET unset: authorities are reported partial)'}; events relay ${outbox.enabled ? `on → ${config.events.url}` : 'off (events wait in services_events_outbox)'}`);

});