fh-amqp-js - npm Package Compare versions

Comparing version 0.1.2 to 0.2.0

fh-amqp-js.js

@@ -71,3 +71,4 @@ #!/usr/local/bin/node
   function subscribeFunc (json, headers, deliveryInfo) {
-    console.log(json);
+    //console.log("ARGS", headers, deliveryInfo);
+    console.log(deliveryInfo.routingKey + ": " + util.inspect(json));
   };
@@ -81,3 +82,3 @@
   }
-  appTopics = fhtopics.monit; 
+  appTopics = fhtopics.monit;
   var amqpManager = new fhamqpjs.AMQPManager(rc);
@@ -95,5 +96,5 @@ amqpManager.on("error", function(err){
             amqpManager.disconnect();
-        });   
-  });  
-  
+        });
+  });
+
 }
@@ -126,5 +127,5 @@
                 "details":{"message":util.format(eventDetails.eventMessage, message)}
-              };      
-          amqpMan.publishTopic(exchange,topic,msg,cb);    
+              };
+          amqpMan.publishTopic(exchange,topic,msg,cb);
     }else cb("no such topic");
 }

lib/amqpjs.js

@@ -18,3 +18,3 @@ var amqp = require('amqp');
   if (typeof cfg.clusterNodes === 'string') {
-    cfg.clusterNodes = cfg.clusterNodes.split(",");
+    cfg.clusterNodes = JSON.parse(cfg.clusterNodes);
   }
@@ -148,2 +148,2 @@
 exports.AMQPManager = AMQPManager;
-exports.fhevents = require('./fhevents.js');
+exports.EventTypes = require('./fhevents.js');

lib/fhevents.js

@@ -0,69 +1,135 @@
+// App related events
+exports.DYNOMAN_APP_START_FAILED = "fh.events.dynoman.app.start-failed";
+exports.DYNOMAN_APP_START_SUCCEEDED = "fh.events.dynoman.app.start-succeeded";
+exports.DYNOMAN_APP_STOP_FAILED = "fh.events.dynoman.app.stop-failed";
+exports.DYNOMAN_APP_STOP_SUCCEEDED = "fh.events.dynoman.app.stop-succeeded";
+exports.DYNOMAN_APP_STAGE_FAILED = "fh.events.dynoman.app.stage-failed";
+exports.DYNOMAN_APP_STAGE_SUCCEEDED = "fh.events.dynoman.app.stage-succeeded";
+exports.DYNOMAN_APP_DELETE_FAILED = "fh.events.dynoman.app.delete-failed";
+exports.DYNOMAN_APP_DELETE_SUCCEEDED = "fh.events.dynoman.app.delete-succeeded";
+exports.DYNOMAN_APP_SUSPEND_SUCCEEDED = "fh.events.dynoman.app.suspend-succeeded";
 
-module.exports = {
-  "dynoman":{  
-    "fh.events.dynoman.app.start-failed":{
-      "eventClass":"APP_STATE",
-      "eventType":"START_FAILED",
-      "eventLevel":"ERROR"
-    },
-    "fh.events.dynoman.app.start-succeeded":{
-      "eventClass":"APP_STATE",
-      "eventType":"START_SUCCESSFUL",
-      "eventLevel":"INFO"
-    },
-    "fh.events.dynoman.app.stop-failed":{
-      "eventClass":"APP_STATE",
-      "eventType":"START_FAILED",
-      "eventLevel":"ERROR"
-    },
-    "fh.events.dynoman.app.stop-succeeded":{
-      "eventClass":"APP_STATE",
-      "eventType":"STOP_SUCCESSFUL",
-      "eventLevel":"INFO"
-    },
-    "fh.events.dynoman.app.stage-failed":{
-      "eventClass":"APP_STATE",
-      "eventType":"DEPLOY_FAILED",
-      "eventLevel":"ERROR"
-    },
-    "fh.events.dynoman.app.stage-succeeded":{
-      "eventClass":"APP_STATE",
-      "eventType":"DEPLOYED",
-      "eventLevel":"INFO"
-    },
+// Dyno related events
+exports.DYNOMAN_DYNO_CREATE_SUCCEEDED = "fh.events.dynoman.dyno.create-succeeded";
+exports.DYNOMAN_DYNO_DELETE_SUCCEEDED = "fh.events.dynoman.dyno.delete-succeeded";
+exports.DYNOMAN_DYNO_START_SUCCEEDED  = "fh.events.dynoman.dyno.start-succeeded";
+exports.DYNOMAN_DYNO_STOP_SUCCEEDED  = "fh.events.dynoman.dyno.stop-succeeded";
+exports.DYNOMAN_RESOURCES_CHANGED_SUCCEEDED = "fh.events.dynoman.dyno.resources-changed-succeeded";
 
-    "fh.events.dynoman.dyno.create-failed":{
+// Monit related events
+exports.MONIT_APP_TERMINATED = "fh.events.monit.app.terminated";
+exports.MONIT_APP_HIGH_CPU = "fh.events.monit.app.high-cpu";
+exports.MONIT_APP_HIGH_MEMORY = "fh.events.monit.app.high-memory";
 
-    },
-    "fh.events.dynoman.dyno.create-succeeded":{
+var dynoman = {};
+dynoman[exports.DYNOMAN_APP_START_FAILED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"START_FAILED",
+  "eventLevel":"ERROR"
+};
 
-    },
+dynoman[exports.DYNOMAN_APP_START_SUCCEEDED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"START_SUCCESSFUL",
+  "eventLevel":"INFO"
+};
 
-    "fh.events.dynoman.dyno.start-succeeded":{
+dynoman[exports.DYNOMAN_APP_STOP_FAILED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"START_FAILED",
+  "eventLevel":"ERROR"
+};
 
-    }
-  },
-  "monit":{
-    "fh.events.monit.app.terminated":{
-       "eventClass":"APP_STATE",
-       "eventType":"TERMINATED",
-       "eventLevel":"FATAL",
-       "eventMessage":"App failed to restart - %s"
-    },
-    "fh.events.monit.app.high-cpu" : {
-      "eventClass": "APP_STATE",
-      "eventType":"HIGH_CPU",
-      "eventLevel": "WARN",
-      "eventMessage": "App has high CPU usage - %s"
-    },
-    "fh.events.monit.app.high-memory": {
-      "eventClass": "APP_STATE",
-      "eventType":"HIGH_MEMORY",
-      "eventLevel": "WARN",
-      "eventMessage": "App has high memroy usage - %s"
-    } 
-  },
-  "nodeapp":{
-      
-  }  
+dynoman[exports.DYNOMAN_APP_STOP_SUCCEEDED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"STOP_SUCCESSFUL",
+  "eventLevel":"INFO"
 };
+
+dynoman[exports.DYNOMAN_APP_SUSPEND_SUCCEEDED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"SUSPEND_SUCCESSFUL",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_APP_STAGE_FAILED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"DEPLOY_FAILED",
+  "eventLevel":"ERROR"
+};
+
+dynoman[exports.DYNOMAN_APP_STAGE_SUCCEEDED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"DEPLOYED",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_APP_DELETE_FAILED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"DELETED",
+  "eventLevel":"ERROR"
+};
+
+dynoman[exports.DYNOMAN_APP_DELETE_SUCCEEDED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"DELETED",
+  "eventLevel":"INFO"
+};
+
+// Dyno Related event details
+dynoman[exports.DYNOMAN_DYNO_CREATE_SUCCEEDED] = {
+  "eventClass":"DYNO_STATE",
+  "eventType":"CREATED",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_DYNO_DELETE_SUCCEEDED] = {
+  "eventClass":"DYNO_STATE",
+  "eventType":"DELETED",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_DYNO_START_SUCCEEDED] = {
+  "eventClass":"DYNO_STATE",
+  "eventType":"START_SUCCESSFUL",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_DYNO_STOP_SUCCEEDED] = {
+  "eventClass":"DYNO_STATE",
+  "eventType":"STOP_SUCCESSFUL",
+  "eventLevel":"INFO"
+};
+
+dynoman[exports.DYNOMAN_RESOURCES_CHANGED_SUCCEEDED] = {
+  "eventClass":"DYNO_STATE",
+  "eventType":"RESOURCES_CHANGED_SUCCESSFUL",
+  "eventLevel":"INFO"
+};
+
+// Monit related event details
+var monit = {};
+
+monit[exports.MONIT_APP_TERMINATED] = {
+  "eventClass":"APP_STATE",
+  "eventType":"TERMINATED",
+  "eventLevel":"FATAL",
+  "eventMessage":"App failed to restart - %s"
+};
+
+monit[exports.MONIT_APP_HIGH_CPU] = {
+  "eventClass": "APP_STATE",
+  "eventType":"HIGH_CPU",
+  "eventLevel": "WARN",
+  "eventMessage": "App has high CPU usage - %s"
+};
+
+monit[exports.MONIT_APP_HIGH_MEMORY] = {
+  "eventClass": "APP_STATE",
+  "eventType":"HIGH_MEMORY",
+  "eventLevel": "WARN",
+  "eventMessage": "App has high memroy usage - %s"
+};
+
+exports.dynoman = dynoman;
+exports.monit = monit;

package.json

 {
   "name": "fh-amqp-js",
-  "version": "0.1.2",
+  "version": "0.2.0",
   "description": "FeedHenry AMQP Client",
@@ -5,0 +5,0 @@ "main": "./lib/amqpjs.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Native code

Supply chain risk

Contains native code (e.g., compiled binaries or shared libraries). Including native code can obscure malicious behavior.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No README

Quality

Package does not have a README. This may indicate a failed publish or a low quality package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

30429

increased by165.48%

Number of package files

14

increased by133.33%

Lines of code

531

increased by81.23%

Number of medium quality alerts

1

decreased by-50%

Number of lines in readme file

127

increased byInfinity%

Worsened metrics

Number of low supply chain risk alerts

3

increased by50%

Number of medium supply chain risk alerts

1

increased byInfinity%

No dependency changes