cityssm/faster-web-helper

import path from 'node:path'

import { dateToString, dateToTimePeriodString } from '@cityssm/utils-datetime'
import camelCase from 'camelcase'
import Debug from 'debug'
import exitHook from 'exit-hook'
import express from 'express'
import schedule from 'node-schedule'

import { getConfigProperty } from '../../helpers/functions.config.js'
import type { ModuleInitializerOptions } from '../types.js'

import { moduleName } from './helpers/moduleHelpers.js'
import runUpdateAssetNumbersTask, {
  taskName as updateAssetNumbersTaskName
} from './tasks/updateAssetNumbersTask.js'
import runUpdateItemNumbersTask, {
  taskName as updateItemNumbersTaskName
} from './tasks/updateItemNumbersTask.js'

const debug = Debug(`faster-web-helper:${camelCase(moduleName)}`)

const assetNumbersConfig = getConfigProperty(
  'modules.autocomplete.reports.w114'
)
const itemNumbersConfig = getConfigProperty('modules.autocomplete.reports.w200')

export default async function initializeAutocompleteModule(
  options: ModuleInitializerOptions
): Promise<void> {
  debug(`Initializing "${moduleName}"...`)

  /*
   * Set up static server
   */

  options.app.use(
    getConfigProperty('webServer.urlPrefix') + '/autocomplete',
    express.static(path.join('public', 'autocomplete'))
  )

  /*
   * Run startup tasks
   */

  if (getConfigProperty('modules.autocomplete.runOnStartup')) {
    debug(`Running "${updateItemNumbersTaskName}" on startup...`)

    if (assetNumbersConfig !== undefined) {
      await runUpdateAssetNumbersTask()
    }

    if (itemNumbersConfig !== undefined) {
      await runUpdateItemNumbersTask()
    }
  }

  /*
   * Schedule Jobs
   */

  let updateAssetNumbersJob: schedule.Job | undefined

  if (assetNumbersConfig !== undefined) {
    updateAssetNumbersJob = schedule.scheduleJob(
      updateAssetNumbersTaskName,
      assetNumbersConfig.schedule,
      runUpdateAssetNumbersTask
    )

    const updateAssetNumbersFirstRunDate = new Date(
      updateAssetNumbersJob.nextInvocation().getTime()
    )

    debug(
      `Scheduled to run "${updateAssetNumbersTaskName}" on ${dateToString(updateAssetNumbersFirstRunDate)} at ${dateToTimePeriodString(updateAssetNumbersFirstRunDate)}`
    )
  }

  let updateItemNumbersJob: schedule.Job | undefined

  if (itemNumbersConfig !== undefined) {
    updateItemNumbersJob = schedule.scheduleJob(
      updateItemNumbersTaskName,
      itemNumbersConfig.schedule,
      runUpdateItemNumbersTask
    )

    const updateItemNumbersFirstRunDate = new Date(
      updateItemNumbersJob.nextInvocation().getTime()
    )

    debug(
      `Scheduled to run "${updateItemNumbersTaskName}" on ${dateToString(updateItemNumbersFirstRunDate)} at ${dateToTimePeriodString(updateItemNumbersFirstRunDate)}`
    )
  }

  /*
   * Set up exit hook
   */

  exitHook(() => {
    if (updateAssetNumbersJob !== undefined) {
      updateAssetNumbersJob.cancel()
    }

    if (updateItemNumbersJob !== undefined) {
      updateItemNumbersJob.cancel()
    }
  })

  debug(`"${moduleName}" initialized.`)
}