Initial commit.

Author: en0

HealthPlugin.js

@@ -0,0 +1,10 @@
+module.exports = function HealthPlugin(opts) {
+
+    this.add('role:health,cmd:ping,ver:1', ping_v1);
+
+    return { name: "HealthPlugin" }
+
+    function ping_v1(args, done) {
+        done({ ack: "pong" });
+    }
+}

MathPlugin.js

@@ -0,0 +1,34 @@
+const lodash = require('lodash');
+
+module.exports = function MathPlugin(opts) {
+
+    var seneca = this;
+
+    seneca.add('role:math,cmd:sum,ver:1', sum_v1);
+    seneca.add('role:math,cmd:product,ver:1', product_v1);
+
+    return { name: 'MathPlugin' };
+
+    // ------------------------------------------------------------------------
+
+    function sum_v1(args, done) {
+        validate(args);
+        done({ sum: args.a + args.b });
+    }
+
+    function product_v1(args, done) {
+        validate(args);
+        done({ product: args.a * args.b });
+    }
+
+    function validate(args) {
+        if(!lodash.has(args, 'a'))
+            throw new Error("Missing argument 'a'");
+        else if(typeof args.a !== 'number')
+            throw new Error("Wrong type for argument 'a'");
+        else if(!lodash.has(args, 'b'))
+            throw new Error("Missing argument 'b'");
+        else if(typeof args.b !== 'number')
+            throw new Error("Wrong type for argument 'b'");
+    }
+}

README.md

@@ -1,2 +1,30 @@
 # MathService
 Provide simple math services to the cluster
+
+## sum
+
+Example
+
+```node
+seneca.act('role:math,cmd:sum,ver:1', { a: 1, b: 2 }, (err, res) => {
+  /* 
+   * Result: {
+   *   sum: <NUMBER>
+   * }
+   */
+});
+```
+
+## product
+
+Example
+
+```node
+seneca.act('role:math,cmd:product,ver:1', { a: 1, b: 2 }, (err, res) => {
+  /* 
+   * Result: {
+   *   product: <NUMBER>
+   * }
+   */
+});
+```

index.js

@@ -0,0 +1,15 @@
+const Seneca = require('seneca');
+
+var app = Seneca();
+
+//app.add(plugins.MathPlugin, null);
+app.use("MathPlugin");
+app.use("HealthPlugin");
+
+console.log("OK");
+
+app.listen({
+    //type: 'tcp',
+    port: 3000,
+    pin: ['role:math','role:health']
+}, ()=>console.log("Ready"));