moved delete station in to helper folder

lib/functions/dts-process.js

@@ -5,16 +5,7 @@ const invokeLambda = require('../helpers/invoke-lambda')
 const Joi = require('joi')
 const axios = require('axios')
 const { HTTP_NOT_FOUND } = require('../constants')
-
-async function deleteStation (stationId) {
-  try {
-    await pg('station_display_time_series').where({ station_id: stationId }).delete()
-    logger.info(`Deleted data for RLOI id ${stationId}`)
-  } catch (error) {
-    logger.error(`Error deleting data for station ${stationId}`, error)
-    throw error
-  }
-}
+const deleteStation = require('../helpers/imtd-api').deleteStation
 
 async function insertStation (stationDataArray) {
   try {

lib/helpers/imtd-api.js

@@ -0,0 +1,14 @@
+const logger = require('./logging')
+const pg = require('./db')
+
+async function deleteStation (stationId) {
+  try {
+    await pg('station_display_time_series').where({ station_id: stationId }).delete()
+    logger.info(`Deleted data for RLOI id ${stationId}`)
+  } catch (error) {
+    logger.error(`Error deleting data for station ${stationId}`, error)
+    throw error
+  }
+}
+
+module.exports = { deleteStation }

test/unit/functions/dts-process.js

@@ -155,10 +155,10 @@ experiment('DTS processing', () => {
     await handler()
 
     const logInfoCalls = logger.info.getCalls()
+    console.log('NW: ', logInfoCalls)
 
-    expect(logInfoCalls.length).to.equal(4)
+    expect(logInfoCalls.length).to.equal(3)
     expect(logInfoCalls[2].args[0]).to.equal('Station 1001 not found (HTTP Status: 404)')
-    expect(logInfoCalls[3].args[0]).to.equal('Deleted data for RLOI id 1001')
 
     const logErrorCalls = logger.error.getCalls()
     expect(logErrorCalls.length).to.equal(0)