[incubator-openwhisk-package-alarms] branch master updated: Add HOST_MACHINE and HOST_INDEX env vars (remove ACTIVE) (#69)

[berstler]

This is an automated email from the ASF dual-hosted git repository.

berstler pushed a commit to branch master
in repository 
https://gitbox.apache.org/repos/asf/incubator-openwhisk-package-alarms.git


The following commit(s) were added to refs/heads/master by this push:
     new 5a7d68f  Add HOST_MACHINE and HOST_INDEX env vars (remove ACTIVE) (#69)
5a7d68f is described below

commit 5a7d68ff908ab038a253358738e5bc622e57dc24
Author: Jason Peterson <jason...@us.ibm.com>
AuthorDate: Tue Jun 27 14:50:36 2017 -0400

    Add HOST_MACHINE and HOST_INDEX env vars (remove ACTIVE) (#69)
---
 provider/lib/active.js                                            | 5 ++---
 provider/lib/utils.js                                             | 7 ++++---
 .../src/test/scala/system/redundancy/AlarmsRedundancyTests.scala  | 8 ++++----
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git a/provider/lib/active.js b/provider/lib/active.js
index 59e42fe..b5c7ea1 100644
--- a/provider/lib/active.js
+++ b/provider/lib/active.js
@@ -9,6 +9,7 @@ module.exports = function(logger, utils) {
       var response = {
           worker: utils.worker,
           host: utils.host,
+          hostMachine: utils.hostMachine,
           active: utils.host === utils.activeHost
       };
 
@@ -29,9 +30,7 @@ module.exports = function(logger, utils) {
                   .then(() => {
                       response.active = 'swapping';
                       utils.redisClient.publish(utils.redisHash, activeHost);
-                      var msg = 'Active host swap in progress';
-                      logger.info(method, msg);
-                      response.message = msg;
+                      logger.info(method, 'Active host swap in progress');
                       res.send(response);
                   })
                   .catch(err => {
diff --git a/provider/lib/utils.js b/provider/lib/utils.js
index 9b366e4..dcbdad5 100644
--- a/provider/lib/utils.js
+++ b/provider/lib/utils.js
@@ -1,8 +1,9 @@
 var _ = require('lodash');
 var request = require('request');
 var CronJob = require('cron').CronJob;
-var constants = require('./constants.js');
 var HttpStatus = require('http-status-codes');
+var constants = require('./constants.js');
+
 
 module.exports = function(
   logger,
@@ -14,7 +15,8 @@ module.exports = function(
     this.endpointAuth = process.env.ENDPOINT_AUTH;
     this.routerHost = process.env.ROUTER_HOST || 'localhost';
     this.worker = process.env.WORKER || "worker0";
-    this.host = process.env.ACTIVE !== undefined && 
process.env.ACTIVE.toLowerCase() === 'false' ? 'host1' : 'host0';
+    this.host = process.env.HOST_INDEX || 'host0';
+    this.hostMachine = process.env.HOST_MACHINE;
     this.activeHost = 'host0'; //default value on init (will be updated for 
existing redis)
     this.redisClient = redisClient;
     this.redisHash = triggerDB.config.db + '_' + this.worker;
@@ -24,7 +26,6 @@ module.exports = function(
     var retryAttempts = constants.RETRY_ATTEMPTS;
     var ddname = constants.DESIGN_DOC_NAME;
     var filter = constants.FILTER_FUNCTION;
-
     var utils = this;
 
     this.createTrigger = function(triggerIdentifier, newTrigger) {
diff --git a/tests/src/test/scala/system/redundancy/AlarmsRedundancyTests.scala 
b/tests/src/test/scala/system/redundancy/AlarmsRedundancyTests.scala
index 63d76d0..c55b3a7 100644
--- a/tests/src/test/scala/system/redundancy/AlarmsRedundancyTests.scala
+++ b/tests/src/test/scala/system/redundancy/AlarmsRedundancyTests.scala
@@ -27,8 +27,8 @@ import spray.json.{pimpAny, _}
 /**
  * These tests verify that an alarms redundancy (master/slave) configuration
  * works as expected.  They will only run properly in an environment with two
- * alarms containers running concurrently and env var ACTIVE set to true in
- * one container and false in the other.  This test also assumes that redis and
+ * alarms containers running concurrently and env var HOST_INDEX set to host0 
in
+ * one container and host1 in the other.  This test also assumes that redis and
  * the active endpoint authorization are configured.  For the auth set the
  * ENDPOINT_AUTH env var in your containers to match the testing.auth property
  * found in your whisk.properties.  To configure redis simply set the REDIS_URL
@@ -44,7 +44,7 @@ class AlarmsRedundancyTests
 
     val wskprops = WskProps()
     val wsk = new Wsk
-    var edgeHost = WhiskProperties.getEdgeHost()
+    var edgeHost = WhiskProperties.getEdgeHost
     val auth = WhiskProperties.getBasicAuth
     val user = auth.fst
     val password = auth.snd
@@ -145,7 +145,7 @@ class AlarmsRedundancyTests
                 get(endpointURL)
         assert(response.statusCode() == 200)
         var result = response.body.asString.parseJson.asJsObject
-        JsObject(result.fields - "message") shouldBe expectedResult
+        JsObject(result.fields - "hostMachine") shouldBe expectedResult
     }
 
     override def afterAll() {

-- 
To stop receiving notification emails like this one, please contact
['"commits@openwhisk.apache.org" <commits@openwhisk.apache.org>'].