Function runExportEvents

src/scripts/export-events.ts:258–418

(args: string[] = process.argv.slice(2), options: ExportOptions = {})

}

export async function runExportEvents(args: string[] = process.argv.slice(2), options: ExportOptions = {}): Promise<number> {
  const useStructuredFormat = Boolean(options.format)
  const structuredFormat = resolveExportFormat(options.format)
  const cliOptions = useStructuredFormat ? undefined : parseCliArgs(args)

  if (!useStructuredFormat && cliOptions?.showHelp) {
    printUsage()
    return 0
  }

  const outputPath = useStructuredFormat
    ? resolveOutputPath(args[0], structuredFormat)
    : path.resolve(cliOptions?.outputFilePath ?? DEFAULT_OUTPUT_FILE_PATH)

  const db = getMasterDbClient()
  const abortController = new AbortController()
  let interruptedBySignal: NodeJS.Signals | undefined

  const onSignal = (signal: NodeJS.Signals) => {
    if (abortController.signal.aborted) {
      return
    }

    interruptedBySignal = signal
    process.exitCode = 130
    console.log(`${signal} received. Stopping export...`)
    abortController.abort()
  }

  process.on('SIGINT', onSignal).on('SIGTERM', onSignal)

  try {
    const firstEvent = await db('events').select('event_id').whereNull('deleted_at').first()

    if (abortController.signal.aborted) {
      return 130
    }

    if (!firstEvent) {
      if (options.json) {
        console.log(JSON.stringify({ exported: 0, outputPath, empty: true }, null, 2))
      } else {
        console.log('No events to export.')
      }
      return 0
    }

    if (useStructuredFormat) {
      console.log(`Exporting events to ${outputPath}`)
    } else if (cliOptions?.format) {
      console.log(`Exporting events to ${outputPath} using ${getCompressionLabel(cliOptions.format)} compression`)
    } else {
      console.log(`Exporting events to ${outputPath}`)
    }

    const startedAt = Date.now()
    const output = fs.createWriteStream(outputPath)