feat: add organization resync API

src/controllers/organization.controller.js

@@ -219,3 +219,43 @@ export const unsubscribeToOrganization = async (req, res) => {
     }
   }
 };
+
+export const resyncOrganization = async (req, res) => {
+  let transaction;
+  try {
+    await assertIfReadOnlyMode();
+    await assertWalletIsSynced();
+    await assertHomeOrgExists();
+
+    transaction = await sequelize.transaction();
+
+    await Organization.update(
+      { registryHash: '0' },
+      { where: { orgUid: req.body.orgUid } },
+    );
+
+    await Promise.all([
+      ...Object.keys(ModelKeys).map(
+        async (key) =>
+          await ModelKeys[key].destroy({ where: { orgUid: req.body.orgUid } }),
+      ),
+      Audit.destroy({ where: { orgUid: req.body.orgUid } }),
+    ]);
+
+    await transaction.commit();
+
+    return res.json({
+      message:
+        'Resyncing organization completed',
+    });
+  } catch (error) {
+    res.status(400).json({
+      message: 'Error resyncing organization',
+      error: error.message,
+    });
+
+    if (transaction) {
+      await transaction.rollback();
+    }
+  }
+};

src/routes/v1/resources/organization.js

@@ -5,10 +5,11 @@ import joiExpress from 'express-joi-validation';
 
 import { OrganizationController } from '../../../controllers';
 import {
+  importOrganizationSchema,
   newOrganizationSchema,
-  unsubscribeOrganizationSchema,
+  resyncOrganizationSchema,
   subscribeOrganizationSchema,
-  importOrganizationSchema,
+  unsubscribeOrganizationSchema,
 } from '../../../validations';
 
 const validator = joiExpress.createValidator({ passError: true });
@@ -66,4 +67,12 @@ OrganizationRouter.put(
   },
 );
 
+OrganizationRouter.put(
+  '/resync',
+  validator.body(resyncOrganizationSchema),
+  (req, res) => {
+    return OrganizationController.resyncOrganization(req, res);
+  },
+);
+
 export { OrganizationRouter };

src/validations/organizations.validations.js

@@ -18,3 +18,7 @@ export const unsubscribeOrganizationSchema = Joi.object({
 export const subscribeOrganizationSchema = Joi.object({
   orgUid: Joi.string().required(),
 });
+
+export const resyncOrganizationSchema = Joi.object({
+  orgUid: Joi.string().required(),
+});

tests/resources/organization.spec.js

@@ -60,4 +60,19 @@ describe('Orgainzation Resource CRUD', function () {
       );
     }).timeout(TEST_WAIT_TIME * 10);
   });
+
+  describe('PUT - Resyncs an organization', function () {
+    it('resyncs organization', async function () {
+      // add a project to the staging table
+      await testFixtures.createNewProject();
+
+      const response = await supertest(app).put(`/v1/organizations/resync`).send({
+        orgUid: '1',
+      });
+
+      expect(response.body.message).to.equal(
+        'Resyncing organization completed',
+      );
+    }).timeout(TEST_WAIT_TIME * 10);
+  });
 });