index.js

process.on('SIGTERM', async () => {
  logger.info(`Received SIGTERM, quitting connections...`)

  const state = store.getState()

  _.forEach(state.ircClients, ircClient => {
    ircClient.quit()
  })

  await pollUntil(async () => {
    const state = store.getState()

    const isQueueEmpty =
      eventQueue.getQueueLength() === 0 && eventQueue.getPendingLength() === 0

    const didEveryoneQuit = _.every(
      state.ircClients,
      (ircClient, connectionId) => !state.isIrcClientConnected[connectionId],
    )

    if (!isQueueEmpty || !didEveryoneQuit) {
      throw Error('Not quiting just yet!')
    }
  })

  // Wait a second more just in case.
  setTimeout(() => {
    logger.info(`Connections quit, exiting...`)
    process.exit()
  }, 1000)
})