import { DEFAULT_TIMESTAMP } from "./index"
import { events, tenancy, installation } from "@devlego/backend-core"
import { Installation } from "@devlego/types"
import * as global from "./global"
import env from "../../../environment"

const failGraceful = env.SELF_HOSTED

const handleError = (e: any, errors?: any) => {
  if (failGraceful) {
    if (errors) {
      errors.push(e)
    }
    return
  }
  throw e
}

/**
 * Date:
 * May 2022
 *
 * Description:
 * Backfill installation events.
 */

export const run = async () => {
  try {
    // need to use the default tenant to try to get the installation time
    await tenancy.doInTenant(tenancy.DEFAULT_TENANT_ID, async () => {
      const db = tenancy.getGlobalDB()
      let timestamp: string | number = DEFAULT_TIMESTAMP

      const installTimestamp = await global.getInstallTimestamp(db)
      if (installTimestamp) {
        timestamp = installTimestamp
      }

      const install: Installation = await installation.getInstall()
      await events.identification.identifyInstallationGroup(
        install.installId,
        timestamp
      )
    })
    await events.backfill.installationSucceeded()
  } catch (e) {
    handleError(e)
    await events.backfill.installationFailed(e)
  }
}