cityssm/faster-web-helper

import { parseW114ExcelReport } from '@cityssm/faster-report-parser/xlsx'
import { WorkTechAPI } from '@cityssm/worktech-api'
import camelCase from 'camelcase'
import Debug from 'debug'

import { getConfigProperty } from '../../../helpers/functions.config.js'
import { downloadFilesToTemp } from '../../../helpers/functions.sftp.js'
import { moduleName } from '../helpers/moduleHelpers.js'

export const taskName = 'Active Equipment Task'

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

const worktech = new WorkTechAPI(getConfigProperty('worktech'))

const assetListConfig = getConfigProperty(
  'modules.worktechUpdate.reports.w114'
)

export default async function runActiveEquipmentTask(): Promise<void> {
  if (assetListConfig === undefined) {
    return
  }

  debug(`Running "${taskName}"...`)

  const tempAssetListReportFiles = await downloadFilesToTemp(assetListConfig.ftpPath)

  /*
   * Loop through files
   */

  debug(`${tempAssetListReportFiles.length} file(s) to process...`)

  for (const reportFile of tempAssetListReportFiles) {
    try {
      const report = parseW114ExcelReport(reportFile)

      for (const fasterEquipment of report.data) {
        const worktechEquipment = await worktech.getEquipmentByEquipmentId(fasterEquipment.assetNumber)

        if (worktechEquipment === undefined) {
          // add equipment
        }
      }

    } catch (error) {
      debug(error)
    }
  }
}