Create model and associations for directory monitorings (#741)

* Create model and associations for directory monitorings

* add additional fields required

* remove duplicate

Author: FancMa01

Diff for: server/migrations/20240404150653-create-directorymonitoring.js

@@ -0,0 +1,102 @@
+"use strict";
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    await queryInterface.createTable("directorymonitoring", {
+      id: {
+        allowNull: false,
+        primaryKey: true,
+        type: Sequelize.UUID,
+        defaultValue: Sequelize.UUIDV4,
+      },
+      application_id: {
+        type: Sequelize.UUID,
+        references: {
+          model: "application",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      cluster_id: {
+        type: Sequelize.UUID,
+        references: {
+          model: "cluster",
+          key: "id",
+        },
+        onUpdate: "CASCADE",
+        onDelete: "CASCADE",
+      },
+      name: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+      },
+      cron: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+      },
+      type: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+        defaultValue: false,
+      },
+      active: {
+        allowNull: false,
+        type: Sequelize.DataTypes.BOOLEAN,
+        defaultValue: false,
+      },
+      directory: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+        defaultValue: 0,
+      },
+      metaData: {
+        type: Sequelize.JSON,
+        allowNull: true,
+      },
+      approved: {
+        allowNull: false,
+        type: Sequelize.DataTypes.BOOLEAN,
+        defaultValue: false,
+      },
+      approvalNote: {
+        allowNull: true,
+        type: Sequelize.DataTypes.STRING,
+      },
+      approvedBy: {
+        allowNull: true,
+        type: Sequelize.DataTypes.STRING,
+      },
+      approvedAt: {
+        allowNull: true,
+        type: Sequelize.DataTypes.DATE,
+      },
+      createdBy: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+      },
+      updatedBy: {
+        allowNull: false,
+        type: Sequelize.DataTypes.STRING,
+      },
+      updatedAt: {
+        allowNull: false,
+        type: Sequelize.DataTypes.DATE,
+      },
+      createdAt: {
+        allowNull: false,
+        type: Sequelize.DATE,
+      },
+      updatedAt: {
+        allowNull: false,
+        type: Sequelize.DATE,
+      },
+      deletedAt: {
+        allowNull: true,
+        type: Sequelize.DATE,
+      },
+    });
+  },
+  async down(queryInterface, Sequelize) {
+    await queryInterface.dropTable("directorymonitoring");
+  },
+};

Diff for: server/models/cluster.js

@@ -1,32 +1,51 @@
-'use strict';
+"use strict";
 module.exports = (sequelize, DataTypes) => {
-  const cluster = sequelize.define('cluster', {
-    id: {
-      primaryKey: true,
-      type: DataTypes.UUID,
-      defaultValue: DataTypes.UUIDV4,
-      allowNull: false,
-      autoIncrement: false
+  const cluster = sequelize.define(
+    "cluster",
+    {
+      id: {
+        primaryKey: true,
+        type: DataTypes.UUID,
+        defaultValue: DataTypes.UUIDV4,
+        allowNull: false,
+        autoIncrement: false,
+      },
+      name: DataTypes.STRING,
+      thor_host: DataTypes.STRING,
+      thor_port: DataTypes.STRING,
+      roxie_host: DataTypes.STRING,
+      roxie_port: DataTypes.STRING,
+      username: DataTypes.STRING,
+      hash: DataTypes.STRING,
+      timezone_offset: DataTypes.INTEGER,
+      metaData: { type: DataTypes.JSON, defaultValue: {} },
     },
-    name: DataTypes.STRING,
-    thor_host: DataTypes.STRING,
-    thor_port: DataTypes.STRING,
-    roxie_host: DataTypes.STRING,
-    roxie_port: DataTypes.STRING,
-    username: DataTypes.STRING,
-    hash: DataTypes.STRING,
-    timezone_offset: DataTypes.INTEGER,
-    metaData: {type: DataTypes.JSON, defaultValue : {}},
-  }, {paranoid: true, freezeTableName: true});
-  cluster.associate = function(models) {
+    { paranoid: true, freezeTableName: true }
+  );
+  cluster.associate = function (models) {
     // associations can be defined here
-    cluster.hasMany(models.dataflow, {foreignKey: 'clusterId' });
-    cluster.hasMany(models.job,{ foreignKey:'cluster_id', });
-    cluster.hasMany(models.job_execution, {foreignKey: 'clusterId' });
-    cluster.hasMany(models.dataflow_cluster_credentials,{ foreignKey:'cluster_id', });
-    cluster.hasMany(models.visualizations, {foreignKey: 'clusterId', onDelete: 'CASCADE'});
-    cluster.hasMany(models.fileTemplate, {foreignKey: 'cluster_id', onDelete: 'CASCADE'});
-    cluster.hasMany(models.fileMonitoring, {foreignKey: 'cluster_id', onDelete: 'CASCADE'});
+    cluster.hasMany(models.dataflow, { foreignKey: "clusterId" });
+    cluster.hasMany(models.job, { foreignKey: "cluster_id" });
+    cluster.hasMany(models.job_execution, { foreignKey: "clusterId" });
+    cluster.hasMany(models.dataflow_cluster_credentials, {
+      foreignKey: "cluster_id",
+    });
+    cluster.hasMany(models.visualizations, {
+      foreignKey: "clusterId",
+      onDelete: "CASCADE",
+    });
+    cluster.hasMany(models.fileTemplate, {
+      foreignKey: "cluster_id",
+      onDelete: "CASCADE",
+    });
+    cluster.hasMany(models.fileMonitoring, {
+      foreignKey: "cluster_id",
+      onDelete: "CASCADE",
+    });
+    cluster.hasMany(models.directoryMonitoring, {
+      foreignKey: "cluster_id",
+      onDelete: "CASCADE",
+    });
   };
   return cluster;
-};
+};

Diff for: server/models/directoryMonitoring.js

@@ -0,0 +1,91 @@
+"use strict";
+module.exports = (sequelize, DataTypes) => {
+  const directoryMonitoring = sequelize.define(
+    "directoryMonitoring",
+    {
+      id: {
+        primaryKey: true,
+        type: DataTypes.UUID,
+        defaultValue: DataTypes.UUIDV4,
+        allowNull: false,
+        autoIncrement: false,
+      },
+      application_id: {
+        allowNull: false,
+        type: DataTypes.UUID,
+      },
+      cluster_id: {
+        allowNull: false,
+        type: DataTypes.UUID,
+      },
+      name: {
+        allowNull: false,
+        type: DataTypes.STRING,
+        unique: true,
+      },
+      cron: {
+        allowNull: true,
+        type: DataTypes.STRING,
+      },
+      type: {
+        allowNull: false,
+        type: DataTypes.STRING,
+      },
+      active: {
+        allowNull: false,
+        type: DataTypes.BOOLEAN,
+      },
+      directory: {
+        allowNull: false,
+        type: DataTypes.STRING,
+      },
+      metaData: {
+        type: DataTypes.JSON,
+        allowNull: true,
+      },
+      approved: {
+        allowNull: false,
+        type: DataTypes.BOOLEAN,
+      },
+      approvalNote: {
+        allowNull: true,
+        type: DataTypes.STRING,
+      },
+      approvedBy: {
+        allowNull: true,
+        type: DataTypes.STRING,
+      },
+      approvedAt: {
+        allowNull: true,
+        type: DataTypes.DATE,
+      },
+      createdBy: {
+        allowNull: false,
+        type: DataTypes.STRING,
+      },
+      updatedBy: {
+        allowNull: false,
+        type: DataTypes.STRING,
+      },
+      updatedAt: {
+        allowNull: false,
+        type: DataTypes.DATE,
+      },
+      metaData: {
+        type: DataTypes.JSON,
+        allowNull: true,
+      },
+    },
+    { paranoid: true, freezeTableName: true }
+  );
+  directoryMonitoring.associate = function (models) {
+    // Define association here
+    directoryMonitoring.belongsTo(models.application, {
+      foreignKey: "application_id",
+    });
+    directoryMonitoring.belongsTo(models.cluster, {
+      foreignKey: "cluster_id",
+    });
+  };
+  return directoryMonitoring;
+};