Add a feed annotation to a trigger when creating a trigger

Author: KeonHee

deploy/lib/deployTriggers.js

@@ -8,6 +8,12 @@ module.exports = {
       if (this.options.verbose) {
         this.serverless.cli.log(`Deploying Trigger: ${trigger.triggerName}`);
       }
+
+      const feed = this.getFeed(trigger)
+      if (feed) {
+        Object.assign(trigger, { annotations: [{ key: 'feed', value: feed }] });
+      }
+
       return ow.triggers.create(trigger)
        .then(() => {
           if (this.options.verbose) {
@@ -38,5 +44,9 @@ module.exports = {
     const trigger = { feed: undefined };
     return Object.keys(triggers)
       .map(t => Object.assign({}, triggers[t], trigger));
-  }
+  },
+
+  getFeed(trigger) {
+    return trigger.feed;
+  },
 };

deploy/tests/deployTriggers.js

@@ -16,10 +16,17 @@ describe('deployTriggers', () => {
     triggers: {
       myTrigger: {
         triggerName: 'myTrigger',
-        namepspace: 'myNamespace',
+        namespace: 'myNamespace',
         action: 'myAction',
         trigger: 'myTrigger',
       },
+      feedTrigger: {
+        triggerName: 'myTrigger',
+        namespace: 'myNamespace',
+        action: 'myAction',
+        trigger: 'myTrigger',
+        feed: '/whisk.system/alarms/alarm',
+      },
     },
   };
 
@@ -91,5 +98,17 @@ describe('deployTriggers', () => {
       })
     })
 
+    it('should deploy trigger with feed annotation to openwhisk', () => {
+      sandbox.stub(openwhiskDeploy.provider, 'client', () => {
+        const create = params => {
+          expect(params).to.be.deep.equal(mockTriggerObject.triggers.feedTrigger);
+          return Promise.resolve();
+        };
+
+        return Promise.resolve({ triggers: { create } });
+      });
+      return expect(openwhiskDeploy.deployTrigger(mockTriggerObject.triggers.feedTrigger))
+        .to.eventually.be.fulfilled;
+    });
   });
 });