dbgate/api/src/proc/serverConnectionProcess.js

const engines = require('../engines');

let systemConnection;
let storedConnection;

async function handleRefreshDatabases() {
  const driver = engines(storedConnection);
  const databases = await driver.listDatabases(systemConnection);
  process.send({ msgtype: 'databases', databases });
}

async function handleConnect(connection) {
  storedConnection = connection;
  const driver = require(`../engines/${storedConnection.engine}/index`);
  systemConnection = await driver.connect(storedConnection);
  setInterval(handleRefreshDatabases, 30 * 1000);
}

const messageHandlers = {
  connect: handleConnect,
};

async function handleMessage({ msgtype, ...other }) {
  const handler = messageHandlers[msgtype];
  await handler(other);
}

process.on('message', async message => {
  try {
    await handleMessage(message);
  } catch (e) {
    process.send({ msgtype: 'error', error: e.message });
  }
});