Instance Scheduler Implementation with New UI and BOTs Audit Trail Implementation

server/app/cronjobs/catalyst-scheduler/catalystScheduler.js

@@ -22,7 +22,7 @@ catalystSync.executeScheduledInstances = function executeScheduledInstances() {
                                 logger.error(err);
                                 return;
                             }
-                            logger.debug("Instance Scheduler Results>>"+results);
+                            logger.debug("Instance Scheduler Completed");
                             return;
                         })
                     }

server/app/lib/utils/apiUtil.js

@@ -32,6 +32,61 @@ var ApiUtil = function() {
         }
         return errObj;
     }
+    this.createCronJobPattern= function(scheduler,startOn){
+        scheduler.repeatEvery = parseInt(scheduler.repeatEvery);
+        if(scheduler.repeats ==='Minutes'){
+            scheduler.pattern = '*/'+scheduler.repeatEvery+' * * * *';
+        }else if(scheduler.repeats ==='Hourly'){
+            scheduler.pattern = '0 */'+scheduler.repeatEvery+' * * *';
+        }else if(scheduler.repeats ==='Daily'){
+            var startOn = Date.parse(startOn);
+            var startHours= startOn.getHours();
+            var startMinutes= startOn.getMinutes();
+            scheduler.pattern = startMinutes+' '+startHours+' */'+scheduler.repeatEvery+' * *';
+        }else if(scheduler.repeats ==='Weekly') {
+            var startOn = Date.parse(startOn);
+            var startDay= startOn.getDay();
+            var startHours= startOn.getHours();
+            var startMinutes= startOn.getMinutes();
+            if(scheduler.repeatEvery === 2) {
+                scheduler.pattern = startMinutes+' '+startHours+' 8-14 * ' + startDay;
+            }else if(scheduler.repeatEvery === 3) {
+                scheduler.pattern = startMinutes+' '+startHours+' 15-21 * ' + startDay;
+            }else if(scheduler.repeatEvery === 4) {
+                scheduler.pattern = startMinutes+' '+startHours+' 22-28 * ' + startDay;
+            }else{
+                scheduler.pattern = startMinutes+' '+startHours+' * * ' + startDay;
+            }
+        }
+        if(scheduler.repeats ==='Monthly') {
+            var startOn = Date.parse(startOn);
+            var startDate= startOn.getDate();
+            var startMonth= startOn.getMonth();
+            var startDay= startOn.getDay();
+            var startHours= startOn.getHours();
+            var startMinutes= startOn.getMinutes();
+            if(scheduler.repeatEvery === 1) {
+                scheduler.pattern = startMinutes+' '+startHours+' '+startDate+' * *';
+            }else{
+                scheduler.pattern = startMinutes+' '+startHours+' '+startDate+' */'+scheduler.repeatEvery+' *';
+            }
+        }
+        if(scheduler.repeats ==='Yearly') {
+            var startOn = Date.parse(startOn);
+            var startDate= startOn.getDate();
+            var startYear= startOn.getFullYear();
+            var startMonth= startOn.getMonth();
+            var startHours= startOn.getHours();
+            var startMinutes= startOn.getMinutes();
+            scheduler.pattern ='0 '+startMinutes+' '+startHours+' '+startDate+' '+startMonth+' ? '+startYear/scheduler.repeatEvery;
+        }
+        var cronScheduler = {
+            "repeats": scheduler.repeats,
+            "repeatEvery": scheduler.repeatEvery,
+            "cronPattern":scheduler.pattern
+        }
+        return cronScheduler;
+    }
     this.paginationResponse=function(data,req, callback) {
         var response={};
         var sortField=req.mirrorSort;

server/app/model/audit-trail/audit-trail.js

@@ -0,0 +1,53 @@
+/*
+ Copyright [2016] [Relevance Lab]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+ */
+
+var logger = require('_pr/logger')(module);
+var mongoose = require('mongoose');
+var BaseAuditTrail = require('./base-audit-trail');
+var ObjectId = require('mongoose').Types.ObjectId;
+var mongoosePaginate = require('mongoose-paginate');
+
+var AuditTrailSchema = new BaseAuditTrail();
+AuditTrailSchema.plugin(mongoosePaginate);
+
+AuditTrailSchema.statics.getAuditTrailList = function(auditTrailQuery,callback){
+    AuditTrail.paginate(auditTrailQuery.queryObj, auditTrailQuery.options, function(err, auditTrailList) {
+        if (err) {
+            logger.error(err);
+            var error = new Error('Internal server error');
+            error.status = 500;
+            return callback(error);
+        }
+        return callback(null, auditTrailList);
+    });
+};
+
+AuditTrailSchema.statics.updateAuditTrail = function(auditId,auditObj,callback){
+    AuditTrail.update({_id:new ObjectId(auditId)},{$set:auditObj},{upsert:false}, function(err, updateAuditTrail) {
+        if (err) {
+            logger.error(err);
+            var error = new Error('Internal server error');
+            error.status = 500;
+            return callback(error);
+        }
+        return callback(null, updateAuditTrail);
+    });
+};
+
+
+var AuditTrail = mongoose.model('auditTrails', AuditTrailSchema);
+module.exports = AuditTrail;
+

server/app/model/audit-trail/base-audit-trail.js

@@ -0,0 +1,124 @@
+/*
+ Copyright [2016] [Relevance Lab]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+ */
+
+var mongoose = require('mongoose');
+var util = require('util');
+var Schema = mongoose.Schema;
+
+var AuditTrailSchema = function AuditTrail() {
+    Schema.apply(this, arguments);
+    this.add({
+        actionLogId: {
+            type: String,
+            trim:true
+        },
+        auditId: {
+            type: String,
+            trim:true,
+            required:true
+        },
+        masterDetails:{
+            orgName: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            orgId: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            bgName: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            bgId: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            projectName: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            projectId: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            envName: {
+                type: String,
+                trim:true,
+                required:true
+            },
+            envId: {
+                type: String,
+                trim:true,
+                required:true
+            }
+        },
+        auditType: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        auditCategory: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        user: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        startedOn: {
+            type: Number,
+            trim:true,
+            required:false
+        },
+        endedOn: {
+            type: Number,
+            trim:true,
+            required:false
+        },
+        providerType: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        action: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        status: {
+            type: String,
+            trim:true,
+            required:false
+        },
+        actionStatus: {
+            type: String,
+            trim:true,
+            required:false
+        }
+    });
+};
+util.inherits(AuditTrailSchema, Schema);
+
+module.exports = AuditTrailSchema;

server/app/model/audit-trail/bot-audit-trail.js

@@ -0,0 +1,78 @@
+/*
+ Copyright [2016] [Relevance Lab]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+ */
+
+var logger = require('_pr/logger')(module);
+var mongoose = require('mongoose');
+var BaseAuditTrail = require('./base-audit-trail.js');
+var AuditTrail = require('./audit-trail.js');
+var Schema = mongoose.Schema;
+var ObjectId = require('mongoose').Types.ObjectId;
+
+var BotAuditTrailSchema = new BaseAuditTrail({
+    auditTrailConfig: {
+        nodeIds: {
+            type: [String],
+            trim:true
+        },
+        executionType:{
+            type: String,
+            trim:true
+        },
+        name: {
+            type: String,
+            trim:true
+        },
+        type: {
+            type: String,
+            unique: true,
+            trim:true
+        },
+        description:{
+            type: String,
+            trim:true
+        },
+        category:{
+            type: String,
+            trim:true
+        },
+        nodeIdsWithActionLog:[Schema.Types.Mixed]
+    }
+});
+
+BotAuditTrailSchema.statics.createNew = function(auditTrail,callback){
+    var botAuditTrail = new BotAuditTrail(auditTrail);
+    botAuditTrail.save(function(err, data) {
+        if (err) {
+            logger.error("createNew Failed", err, data);
+            return;
+        }
+        callback(null,data);
+    });
+}
+BotAuditTrailSchema.statics.updateBotAuditTrail = function(auditId,auditTrailObj,callback){
+    BotAuditTrail.update({_id:new ObjectId(auditId)},{$set:auditTrailObj},{upsert:false}, function(err, updateAuditTrail) {
+        if (err) {
+            logger.error(err);
+            var error = new Error('Internal server error');
+            error.status = 500;
+            return callback(error);
+        }
+        return callback(null, updateAuditTrail);
+    });
+};
+
+var BotAuditTrail = AuditTrail.discriminator('botAuditTrail', BotAuditTrailSchema);
+module.exports = BotAuditTrail;

server/app/model/audit-trail/container-audit-trail.js

@@ -0,0 +1,67 @@
+var logger = require('_pr/logger')(module);
+var mongoose = require('mongoose');
+var BaseAuditTrail = require('./base-audit-trail.js');
+var AuditTrail = require('./audit-trail.js');
+var ObjectId = require('mongoose').Types.ObjectId;
+
+var ContainerAuditTrailSchema = new BaseAuditTrail({
+    auditTrailConfig: {
+        instanceIP: {
+            type: String,
+            trim:true
+        },
+        platformId: {
+            type: String,
+            trim:true
+        },
+        name: {
+            type: String,
+            unique: true,
+            trim:true
+        },
+        Image:{
+            type: String,
+            trim:true
+        },
+        ImageId:{
+            type: String,
+            trim:true
+        },
+        platform:{
+            type: String,
+            trim:true
+        },
+        os:{
+            type: String,
+            trim:true
+        }
+    }
+});
+
+ContainerAuditTrailSchema.statics.createNew = function(auditTrail,callback){
+    var containerAuditTrail = new ContainerAuditTrail(auditTrail);
+    containerAuditTrail.save(function(err, data) {
+        if (err) {
+            logger.error("createNew Failed", err, data);
+            return;
+        }
+        callback(null,data);
+    });
+};
+
+ContainerAuditTrailSchema.statics.updateContainerAuditTrail = function(auditId,auditTrailObj,callback){
+    ContainerAuditTrail.update({_id:new ObjectId(auditId)},{$set:auditTrailObj},{upsert:false}, function(err, updateAuditTrail) {
+        if (err) {
+            logger.error(err);
+            var error = new Error('Internal server error');
+            error.status = 500;
+            return callback(error);
+        }
+        return callback(null, updateAuditTrail);
+    });
+};
+
+var ContainerAuditTrail = AuditTrail.discriminator('containerAuditTrail', ContainerAuditTrailSchema);
+module.exports = ContainerAuditTrail;
+
+