When extractor tests

pkg/cli/evaluate.go

@@ -31,7 +31,7 @@ var evaluateChangeInCmd = &cobra.Command{
 		logs.Open(logsPath)
 		logs.SetCurrentPipelineFilePath(input)
 
-		ppl, err := pipelines.LoadFromYaml(input)
+		ppl, err := pipelines.LoadFromFile(input)
 		check(err)
 
 		err = ppl.EvaluateChangeIns()

pkg/pipelines/load.go

@@ -7,7 +7,7 @@ import (
 	"github.com/ghodss/yaml"
 )
 
-func LoadFromYaml(path string) (*Pipeline, error) {
+func LoadFromFile(path string) (*Pipeline, error) {
 	data, err := ioutil.ReadFile(path)
 	if err != nil {
 		return nil, err

pkg/pipelines/model.go

@@ -32,7 +32,7 @@ func (p *Pipeline) Blocks() []*gabs.Container {
 }
 
 func (p *Pipeline) Promotions() []*gabs.Container {
-	return p.raw.Search("blocks").Children()
+	return p.raw.Search("promotions").Children()
 }
 
 func (p *Pipeline) PathExists(path []string) bool {
@@ -43,8 +43,8 @@ func (p *Pipeline) GetStringFromPath(path []string) string {
 	return p.raw.Search(path...).Data().(string)
 }
 
-func (p *Pipeline) PriorityRules() []*gabs.Container {
-	return p.raw.Search("priority").Children()
+func (p *Pipeline) GlobalPriorityRules() []*gabs.Container {
+	return p.raw.Search("global_job_config", "priority").Children()
 }
 
 func (p *Pipeline) QueueRules() []*gabs.Container {

pkg/pipelines/model_test.go

@@ -0,0 +1,33 @@
+package pipelines
+
+import (
+	"testing"
+
+	assert "github.com/stretchr/testify/assert"
+)
+
+func Test__PipelineBlocks(t *testing.T) {
+	pipeline, err := LoadFromFile("../../test/fixtures/all_when_locations.yml")
+
+	assert.Nil(t, err)
+	assert.Equal(t, 2, len(pipeline.Blocks()))
+}
+
+func Test__PipelinePromotions(t *testing.T) {
+	pipeline, err := LoadFromFile("../../test/fixtures/all_when_locations.yml")
+
+	assert.Nil(t, err)
+	assert.Equal(t, 1, len(pipeline.Promotions()))
+}
+
+func Test__PipelineGlobalPriorityRules(t *testing.T) {
+	pipeline, err := LoadFromFile("../../test/fixtures/all_when_locations.yml")
+
+	assert.Nil(t, err)
+	assert.Equal(t, 2, len(pipeline.GlobalPriorityRules()))
+
+	pipeline2, err := LoadFromFile("../../test/fixtures/hello.yml")
+
+	assert.Nil(t, err)
+	assert.Equal(t, 0, len(pipeline2.GlobalPriorityRules()))
+}

pkg/pipelines/when_evaluator.go

@@ -198,8 +198,8 @@ func (e *whenEvaluator) ExtractFromPromotions() {
 }
 
 func (e *whenEvaluator) ExtractFromPriority() {
-	for index := range e.pipeline.PriorityRules() {
-		e.tryExtractingFromPath([]string{"priority", strconv.Itoa(index), "when"})
+	for index := range e.pipeline.GlobalPriorityRules() {
+		e.tryExtractingFromPath([]string{"global_job_config", "priority", strconv.Itoa(index), "when"})
 	}
 }
 

pkg/pipelines/when_evaluator_test.go

@@ -0,0 +1,19 @@
+package pipelines
+
+import (
+	"testing"
+
+	when "github.com/semaphoreci/spc/pkg/when"
+	assert "github.com/stretchr/testify/assert"
+)
+
+func Test__WhenEvaluatorExtractAll(t *testing.T) {
+	pipeline, err := LoadFromFile("../../test/fixtures/all_when_locations.yml")
+	assert.Nil(t, err)
+
+	e := newWhenEvaluator(pipeline)
+
+	assert.Equal(t, e, []when.WhenExpression{
+		{},
+	})
+}

test/fixtures/all_when_locations.yml

@@ -0,0 +1,37 @@
+version: v1.0
+
+global_job_config:
+  priority:
+    - value: 70
+      when: "branch = 'master'"
+    - value: 45
+      when: true
+
+blocks:
+  - name: Unit
+    run:
+      when: "change_in('lib')"
+    task:
+      jobs:
+        - name: Run
+          commands:
+            - echo "hello"
+
+  - name: E2E
+    run:
+      when: "change_in('lib')"
+    task:
+      jobs:
+        - name: Run
+          priority:
+            - value: 70
+              when: "branch = 'master'"
+            - value: 45
+              when: true
+          commands:
+            - echo "hello"
+
+promotions:
+  - name: Production
+    auto_promote:
+      when: "change_in('lib')"