feat: option to commit units seperate from projects

src/controllers/staging.controller.js

@@ -42,7 +42,7 @@ export const commit = async (req, res) => {
     await assertHomeOrgExists();
     await assetNoPendingCommits();
 
-    await Staging.pushToDataLayer();
+    await Staging.pushToDataLayer(_.get(req, 'query.table', null));
     res.json({ message: 'Staging Table committed to full node' });
   } catch (error) {
     res.status(400).json({

src/models/staging/staging.model.js

@@ -152,8 +152,17 @@ class Staging extends Model {
     return [insertRecords, updateRecords, deleteChangeList];
   };
 
-  static async pushToDataLayer() {
-    const stagedRecords = await Staging.findAll({ raw: true });
+  static async pushToDataLayer(tableToPush) {
+    let stagedRecords;
+    if (tableToPush) {
+      stagedRecords = await Staging.findAll({
+        where: { table: tableToPush },
+        raw: true,
+      });
+    } else {
+      stagedRecords = await Staging.findAll({ raw: true });
+    }
+
     const unitsChangeList = await Unit.generateChangeListFromStagedData(
       stagedRecords,
     );

src/validations/staging.validations.js

@@ -2,4 +2,5 @@ import Joi from 'joi';
 
 export const stagingDeleteSchema = Joi.object({
   uuid: Joi.string().required(),
+  table: Joi.string().valid('projects', 'units').optional(),
 });

tests/resources/staging.spec.js

@@ -10,6 +10,8 @@ describe('Staging Resource CRUD', function () {
     it('Staging record is removed when Insert records propagate through the datalayer', function () {});
     it('Staging record is removed when Update records propagate through the datalayer', function () {});
     it('Staging record is removed when Delete records propagate through the datalayer', function () {});
+    it('can commit just the project staging records optionally', function () {});
+    it('can commit just the unit staging records optionally', function () {});
   });
 
   describe('DELETE - Delete a single staging record', function () {