NRPT-407: migration to add issuing agency and role to historical NRCED records

api/migrations/20210316214525-addIssuingAgencyAndRoleToHistoricalNRCED.js

@@ -0,0 +1,155 @@
+'use strict';
+
+const { ApplicationAgencies } = require('../src/utils/constants/misc');
+
+const LegislationActs = {
+  ACT_Agri_Land_Commission: 'Agricultural Land Commission Act',
+  ACT_Dike_Maintenance: 'Dike Maintenance Act',
+  ACT_Env_Management: 'Environmental Management Act',
+  ACT_Fish_Seafood: 'Fish and Seafood Act',
+  ACT_Fisheries: 'Fisheries Act (Canada)',
+  ACT_Food_Safety: 'Food Safety Act',
+  ACT_Int_Pest_Management: 'Integrated Pest Management Act',
+  ACT_Mines: 'Mines Act',
+  ACT_Oil_Gas_Activities: 'Oil and Gas Activities Act',
+  ACT_Park: 'Park Act',
+  ACT_Water: 'Water Act',
+  ACT_Water_Sustainability: 'Water Sustainability Act',
+  ACT_Wildlife: 'Wildlife Act'
+};
+
+var dbm;
+var type;
+var seed;
+let recordCount = 0;
+
+/**
+ * We receive the dbmigrate dependency from dbmigrate initially.
+ * This enables us to not have to rely on NODE_PATH.
+ */
+exports.setup = function(options, seedLink) {
+  dbm = options.dbmigrate;
+  type = dbm.dataType;
+  seed = seedLink;
+};
+
+exports.up = async function(db) {
+  console.log('**** Adding Issuing Agency to historical NRCED records ****');
+  const mClient = await db.connection.connect(db.connectionString, { native_parser: true });
+
+  try {
+    const nrpti = await mClient.collection('nrpti');
+
+    const ocersRecords = await nrpti.find({ sourceSystemRef: 'ocers-csv' }).toArray();
+
+    for (const record of ocersRecords) {
+      recordCount += 1;
+
+      switch (record.recordType) {
+        case 'Ticket':
+          switch (record.legislation.act) {
+            case LegislationActs.ACT_Food_Safety:
+            case LegislationActs.ACT_Fish_Seafood:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_AGRI);
+              break;
+            default:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_COS);
+              break;
+          }
+          break;
+
+        case 'Administrative Sanction':
+          await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_FLNRO);
+          break;
+
+        case 'Administrative Penalty':
+          switch (record.legislation.act) {
+            case LegislationActs.ACT_Env_Management:
+            case LegislationActs.ACT_Int_Pest_Management:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_EPD);
+              break;
+            case LegislationActs.ACT_Oil_Gas_Activities:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_OGC);
+              break;
+            case LegislationActs.ACT_Mines:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_EMLI);
+              break;
+            case LegislationActs.ACT_Agri_Land_Commission:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ALC);
+              break;
+          }
+          break;
+
+        case 'Court Conviction':
+          await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_COS);
+          break;
+
+        case 'Restorative Justice':
+          switch (record.legislation.act) {
+            case LegislationActs.ACT_Env_Management:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_EPD);
+              break;
+            case LegislationActs.ACT_Wildlife:
+            case LegislationActs.ACT_Fisheries:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_COS);
+              break;
+            case LegislationActs.ACT_Park:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_BCPARKS);
+              break;
+          }
+          break;
+
+        case 'Order':
+          switch (record.legislation.act) {
+            case LegislationActs.ACT_Water:
+            case LegislationActs.ACT_Water_Sustainability:
+            case LegislationActs.ACT_Dike_Maintenance:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_FLNRO);
+              break;
+            case LegislationActs.ACT_Agri_Land_Commission:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ALC);
+              break;
+            case LegislationActs.ACT_Park:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_BCPARKS);
+              break;
+            case LegislationActs.ACT_Env_Management:
+            case LegislationActs.ACT_Int_Pest_Management:
+              await updateRecord(nrpti, record._id, ApplicationAgencies.AGENCY_ENV_EPD);
+              break;
+          }
+          break;
+      }
+    }
+  } catch (error) {
+    console.log('Error on migration: ', error);
+    mClient.close();
+  } finally {
+    console.log(
+      `**** Issuing Agency (historical NRCED docs) migration complete, ${recordCount} records updated. *****`
+    );
+    mClient.close();
+  }
+
+  async function updateRecord(db, record_id, agency) {
+    try {
+      await db.updateOne(
+        { _id: record_id },
+        {
+          $set: {
+            issuingAgency: agency
+          }
+        }
+      );
+    } catch (error) {
+      console.log('Migration error: ', error);
+    }
+  }
+};
+
+exports.down = function(db) {
+  return null;
+};
+
+exports._meta = {
+  version: 1
+};

api/src/utils/constants/misc.js

@@ -18,6 +18,22 @@ const ApplicationRoles = {
 
 exports.ApplicationRoles = ApplicationRoles;
 
+const ApplicationAgencies = {
+  AGENCY_ALC: 'Agricultural Land Commission',
+  AGENCY_WF: 'BC Wildfire Service',
+  AGENCY_ENV_COS: 'Conservation Officer Service (COS)',
+  AGENCY_EMLI: 'EMLI',
+  AGENCY_ENV_BCPARKS: 'BC Parks',
+  AGENCY_OGC: 'BC Oil and Gas Commission',
+  AGENCY_ENV_EPD: 'Environmental Protection Division',
+  AGENCY_LNG: 'LNG Secretariat',
+  AGENCY_AGRI: 'Ministry of Agriculture',
+  AGENCY_FLNRO: 'Ministry of Forests, Lands, Natural Resource Operations and Rural Development',
+  AGENCY_FLNR_NRO: 'Natural Resource Officers (NRO)'
+};
+
+exports.ApplicationAgencies = ApplicationAgencies;
+
 exports.ApplicationAdminRoles = [
   ApplicationRoles.ADMIN,
   ApplicationRoles.ADMIN_NRCED,