[incubator-openwhisk-package-kafka] branch master updated: Store namespace CRN in trigger DB (#301)

[japetrsn]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 594ca75  Store namespace CRN in trigger DB (#301)
594ca75 is described below

commit 594ca75a8aa00f615890daf959f15f5c1a8c66ea
Author: James Dubee <jwdu...@us.ibm.com>
AuthorDate: Tue Oct 23 13:27:05 2018 -0400

    Store namespace CRN in trigger DB (#301)
---
 action/messageHubFeed.js    | 1 +
 action/messageHubFeedWeb.js | 4 ++++
 2 files changed, 5 insertions(+)

diff --git a/action/messageHubFeed.js b/action/messageHubFeed.js
index 3217d56..b4b4197 100644
--- a/action/messageHubFeed.js
+++ b/action/messageHubFeed.js
@@ -24,6 +24,7 @@ function main(params) {
 
     if (massagedParams.isIamKey) {
         massagedParams.iamUrl = process.env.__OW_IAM_API_URL;
+        massagedParams.namespaceCRN = process.env.__OW_NAMESPACE_CRN;
     }
 
     if (params.lifecycleEvent === 'CREATE') {
diff --git a/action/messageHubFeedWeb.js b/action/messageHubFeedWeb.js
index 76baae7..66114a6 100644
--- a/action/messageHubFeedWeb.js
+++ b/action/messageHubFeedWeb.js
@@ -173,6 +173,10 @@ function validateParameters(rawParams) {
             if (rawParams.iamUrl) {
                 validatedParams.iamUrl = rawParams.iamUrl;
             }
+
+            if (rawParams.namespaceCRN) {
+                validatedParams.namespaceCRN = rawParams.namespaceCRN;
+            }
         }
 
         // kafka_brokers_sasl