XYOracleNetwork/clients

import { forget } from '@xylabs/forget'
import type { EmptyObject } from '@xylabs/object'
import { Tail } from 'tail'
import type {
  ArgumentsCamelCase, CommandBuilder, CommandModule,
} from 'yargs'

import {
  errFile, outFile, restart, stop,
} from '../../../lib/index.js'
import type { BaseArguments } from '../../BaseArguments.js'

type Arguments = BaseArguments & {
  interactive?: boolean
}

export const aliases: ReadonlyArray<string> = []
export const builder: CommandBuilder = {
  interactive: {
    alias: ['i'],
    boolean: true,
    default: false,
  },
  // TODO: Support throughout this command
  // TODO: Make global flag?
  quiet: {
    alias: ['q'],
    boolean: true,
    default: false,
  },
}
export const command = 'start'
export const deprecated = false
export const describe = 'Start the local XYO Node'
export const handler = async (args: ArgumentsCamelCase<Arguments>) => {
  const interactive = args.interactive
  await restart()
  if (interactive) {
    const outInterface = new Tail(outFile)
    const errInterface = new Tail(errFile)
    outInterface.on('line', console.log)
    errInterface.on('line', console.error)
    const shutdown = async () => {
      outInterface.unwatch()
      errInterface.unwatch()
      await stop()
      // eslint-disable-next-line unicorn/no-process-exit
      process.exit()
    }
    process.on('SIGINT', () => forget(shutdown())) // CTRL+C
    process.on('SIGQUIT', () => forget(shutdown())) // Keyboard quit
    process.on('SIGTERM', () => forget(shutdown())) // `kill` command
  } else {
    // eslint-disable-next-line unicorn/no-process-exit
    process.exit()
  }
}

const mod: CommandModule<EmptyObject, BaseArguments> = {
  aliases,
  command,
  deprecated,
  describe,
  handler,
}

export default mod