Migrate charging-import to a process

src/modules/charge-versions/controllers.js

@@ -0,0 +1,13 @@
+'use strict'
+
+const ProcessSteps = require('./process-steps.js')
+
+async function chargeVersions (_request, h) {
+ ProcessSteps.go()
+
+ return h.response().code(204)
+}
+
+module.exports = {
+ chargeVersions
+}

src/modules/charge-versions/process-steps.js

@@ -0,0 +1,46 @@
+'use strict'
+
+const { calculateAndLogTimeTaken, currentTimeInNanoseconds } = require('../../lib/general.js')
+
+const chargingQueries = require('./lib/queries/charging')
+const chargeVersionMetadataImportService = require('./services/charge-version-metadata-import.js')
+const importService = require('../../lib/services/import.js')
+const queryLoader = require('./lib/query-loader')
+const transformPermit = require('./lib/transform-permit/transform-permit.js')
+
+async function go () {
+ let processComplete = false
+
+ try {
+ global.GlobalNotifier.omg('charge-versions started')
+
+ const startTime = currentTimeInNanoseconds()
+
+ const licenceNumbers = await importService.getLicenceNumbers()
+
+ for (const licenceNumber of licenceNumbers) {
+ const licenceData = await transformPermit.getLicenceJson(licenceNumber)
+
+ await chargeVersionMetadataImportService.importChargeVersionMetadataForLicence(licenceData)
+ }
+
+ await queryLoader.loadQueries([
+ chargingQueries.importChargeVersions,
+ chargingQueries.importChargeElements,
+ chargingQueries.cleanupChargeElements,
+ chargingQueries.cleanupChargeVersions
+ ])
+
+ processComplete = true
+
+ calculateAndLogTimeTaken(startTime, 'charge-versions complete')
+ } catch (error) {
+ global.GlobalNotifier.oops('charge-versions failed')
+ }
+
+ return processComplete
+}
+
+module.exports = {
+ go
+}

src/modules/charge-versions/routes.js

@@ -0,0 +1,13 @@
+'use strict'
+
+const controllers = require('./controllers')
+
+const routes = [
+ {
+ method: 'post',
+ handler: controllers.chargeVersions,
+ path: '/charge-versions'
+ }
+]
+
+module.exports = routes

src/routes.js

@@ -1,4 +1,3 @@
-const chargingImportRoutes = require('./modules/charging-import/routes')
 const coreRoutes = require('./modules/core/routes')
 const healthRoutes = require('./modules/health/routes')
 const jobSummaryRoutes = require('./modules/jobs/routes')
@@ -12,10 +11,10 @@ const CrmRoutes = require('./modules/crm/routes.js')
 const ReturnVersionsRoutes = require('./modules/return-versions/routes.js')
 const ModLogsRoutes = require('./modules/mod-logs/routes.js')
 const ReferenceRoutes = require('./modules/reference/routes.js')
+const ChargeVersionsRoutes = require('./modules/charge-versions/routes.js')
 const NightlyImportRoutes = require('./modules/nightly-import/routes.js')
 
 module.exports = [
- ...chargingImportRoutes,
  ...coreRoutes,
  ...healthRoutes,
  ...jobSummaryRoutes,
@@ -28,5 +27,6 @@ module.exports = [
  ...ReturnVersionsRoutes,
  ...ModLogsRoutes,
  ...ReferenceRoutes,
+ ...ChargeVersionsRoutes,
  ...NightlyImportRoutes
 ]