Merge pull request #174 from screwdriver-cd/annotation

fix(580): add annotations to pipeline model during sync

lib/pipeline.js

@@ -249,6 +249,7 @@ class PipelineModel extends BaseModel {
             // get list of jobs to create
             .then((parsedConfig) => {
                 this.workflow = parsedConfig.workflow;
+                this.annotations = parsedConfig.annotations;
 
                 return this.update()
                     .then(() => this.jobs)

package.json

@@ -50,7 +50,7 @@
     "compare-versions": "^3.0.0",
     "hoek": "^4.0.1",
     "iron": "^4.0.1",
-    "screwdriver-config-parser": "^3.0.1",
-    "screwdriver-data-schema": "^16.8.2"
+    "screwdriver-config-parser": "^3.6.0",
+    "screwdriver-data-schema": "^16.10.1"
   }
 }

test/data/parser.json

@@ -80,5 +80,8 @@
     "workflow": [
         "main",
         "publish"
-    ]
+    ],
+    "annotations": {
+        "beta.screwdriver.cd/executor" : "screwdriver-executor-vm"
+    }
 }

test/lib/pipeline.test.js

@@ -257,7 +257,7 @@ describe('Pipeline Model', () => {
             };
         });
 
-        it('store workflow to pipeline', () => {
+        it('stores workflow to pipeline', () => {
             jobs = [];
             jobFactoryMock.list.resolves(jobs);
             jobFactoryMock.create.withArgs(publishMock).resolves(publishMock);
@@ -268,6 +268,19 @@ describe('Pipeline Model', () => {
             });
         });
 
+        it('stores annotations to pipeline', () => {
+            jobs = [];
+            jobFactoryMock.list.resolves(jobs);
+            jobFactoryMock.create.withArgs(publishMock).resolves(publishMock);
+            jobFactoryMock.create.withArgs(mainMock).resolves(mainMock);
+
+            return pipeline.sync().then(() => {
+                assert.deepEqual(pipeline.annotations, {
+                    'beta.screwdriver.cd/executor': 'screwdriver-executor-vm'
+                });
+            });
+        });
+
         it('creates new jobs', () => {
             jobs = [];
             jobFactoryMock.list.resolves(jobs);