Function runCleanDb

src/clean-db.ts:218–267

(args: string[] = process.argv.slice(2))

}

export const runCleanDb = async (args: string[] = process.argv.slice(2)): Promise<number> => {
  const options = parseCleanDbOptions(args)

  if (options.help) {
    console.log(HELP_TEXT)
    return 0
  }

  if (process.env.NODE_ENV === 'production') {
    console.warn('WARNING: NODE_ENV=production detected. This operation permanently deletes data.')
  }

  const dbClient = getMasterDbClient()

  try {
    if (options.dryRun) {
      const matchingEvents = await getMatchingEventsCount(dbClient, options)
      console.log(`Dry run: ${matchingEvents} events would be deleted.`)
      return 0
    }

    if (!options.force) {
      if (!process.stdin.isTTY) {
        throw new Error('Interactive confirmation is unavailable. Re-run with --force.')
      }

      const confirmed = await askForConfirmation()
      if (!confirmed) {
        console.log('Aborted. Confirmation text did not match DELETE.')
        return 1
      }
    }

    if (options.all) {
      const deletedEventTags = await runAllDelete(dbClient)
      if (deletedEventTags) {
        console.log('Deleted all rows from events and event_tags with TRUNCATE.')
      } else {
        console.log('Deleted all events with TRUNCATE.')
      }
      return 0
    }

    const deletedRows = await runSelectiveDelete(dbClient, options)
    console.log(`Deleted ${deletedRows} events. VACUUM ANALYZE completed.`)
    return 0
  } finally {
    await dbClient.destroy()
  }
}

if (require.main === module) {
  runCleanDb()