backend routes, models and and migration files for integration_mapping (

#702)

* backend routes, models and and migration files for integration_mapping

* update integration.js

* update integration_mapping

* remove integration creation

* add error messages, validation, and testing to all routes

* remove lines

server/job-scheduler.js

@@ -52,7 +52,8 @@ const {
 } = require("./jobSchedularMethods/orbitJobs.js");
 
 //import job directly to run it only once on server start
-const { createIntegrations } = require("./jobs/integrationCreation.js");
+//remove this
+// const { createIntegrations } = require("./jobs/integrationCreation.js");
 
 class JobScheduler {
   constructor() {
@@ -128,7 +129,7 @@ class JobScheduler {
       await this.createOrbitMegaphoneJob();
 
       //one off jobs on server start
-      await this.createIntegrations();
+      // await this.createIntegrations();
     })();
   }
 
@@ -345,9 +346,9 @@ class JobScheduler {
     return createOrbitMonitoringJob.call(this, { orbitMonitoring_id, cron });
   }
 
-  createIntegrations() {
-    return createIntegrations.call(this);
-  }
+  // createIntegrations() {
+  //   return createIntegrations.call(this);
+  // }
 }
 
 module.exports = new JobScheduler();

server/migrations/20240301202952-remove_integration_columns.js

@@ -0,0 +1,24 @@
+"use strict";
+
+module.exports = {
+  up: async (queryInterface, Sequelize) => {
+    await queryInterface.removeColumn("integrations", "config");
+    await queryInterface.removeColumn("integrations", "metadata");
+    await queryInterface.removeColumn("integrations", "active");
+  },
+
+  down: async (queryInterface, Sequelize) => {
+    await queryInterface.addColumn("integrations", "config", {
+      type: Sequelize.STRING,
+      allowNull: true,
+    });
+    await queryInterface.addColumn("integrations", "metadata", {
+      type: Sequelize.STRING,
+      allowNull: true,
+    });
+    await queryInterface.addColumn("integrations", "active", {
+      type: Sequelize.BOOLEAN,
+      defaultValue: true,
+    });
+  },
+};

server/migrations/20240301203455-create_integration_application_mapping.js

@@ -0,0 +1,49 @@
+"use strict";
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.createTable("integration_mapping", {
+      id: {
+        allowNull: false,
+        primaryKey: true,
+        type: Sequelize.UUID,
+        defaultValue: Sequelize.UUIDV4,
+      },
+      integration_id: {
+        type: Sequelize.UUID,
+        references: {
+          model: "integrations",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      application_id: {
+        type: Sequelize.UUID,
+        references: {
+          model: "application",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      metaData: {
+        type: Sequelize.JSON,
+        allowNull: true,
+      },
+      createdAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+        defaultValue: Sequelize.NOW,
+      },
+      updatedAt: {
+        type: Sequelize.DATE,
+        allowNull: false,
+        defaultValue: Sequelize.NOW,
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    await queryInterface.dropTable("integration_mapping");
+  },
+};

server/models/application.js

@@ -1,7 +1,7 @@
-'use strict';
+"use strict";
 module.exports = (sequelize, DataTypes) => {
   const application = sequelize.define(
-    'application',
+    "application",
     {
       id: {
         primaryKey: true,
@@ -101,8 +101,11 @@ module.exports = (sequelize, DataTypes) => {
       foreignKey: "application_id",
       onDelete: "CASCADE",
     });
+    application.hasMany(models.integration_mapping, {
+      foreignKey: "application_id",
+      onDelete: "CASCADE",
+    });
   };
 
-
   return application;
 };

server/models/integration_mapping.js

@@ -0,0 +1,58 @@
+"use strict";
+module.exports = (sequelize, DataTypes) => {
+  const IntegrationMapping = sequelize.define(
+    "integration_mapping",
+    {
+      id: {
+        type: DataTypes.UUID,
+        primaryKey: true,
+        defaultValue: DataTypes.UUIDV4,
+        allowNull: false,
+      },
+      integration_id: {
+        type: DataTypes.UUID,
+        references: {
+          model: "integrations",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      application_id: {
+        type: DataTypes.UUID,
+        references: {
+          model: "application",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      metaData: {
+        type: DataTypes.JSON,
+        allowNull: true,
+      },
+      createdAt: {
+        type: DataTypes.DATE,
+        allowNull: false,
+        defaultValue: DataTypes.NOW,
+      },
+      updatedAt: {
+        type: DataTypes.DATE,
+        allowNull: false,
+        defaultValue: DataTypes.NOW,
+      },
+    },
+    { freezeTableName: true }
+  );
+
+  IntegrationMapping.associate = (models) => {
+    IntegrationMapping.belongsTo(models.integrations, {
+      foreignKey: "integration_id",
+    });
+    IntegrationMapping.belongsTo(models.application, {
+      foreignKey: "application_id",
+    });
+  };
+
+  return IntegrationMapping;
+};