pipeline_test.go

package circleci

import (
	"context"
	"fmt"
	"net/http"
	"testing"

	"github.com/google/go-cmp/cmp"
)

func Test_pipelines_List(t *testing.T) {
	client, mux, _, teardown := setup()
	defer teardown()

	mux.HandleFunc("/pipeline/", func(w http.ResponseWriter, r *http.Request) {
		testMethod(t, r, "GET")
		testHeader(t, r, "Accept", "application/json")
		testHeader(t, r, "Circle-Token", client.token)
		testQuery(t, r, "org-slug", "org1")
		testQuery(t, r, "mine", "true")
		fmt.Fprint(w, `{"items": [{"id": "1", "trigger": {"type": "explicit"}}], "next_page_token": "1"}`)
	})

	ctx := context.Background()
	pl, err := client.Pipelines.List(ctx, PipelineListOptions{
		OrgSlug: String("org1"),
		Mine:    Bool(true),
	})
	if err != nil {
		t.Errorf("Pipelines.List got error: %v", err)
	}

	want := &PipelineList{
		Items: []*Pipeline{
			{
				ID: "1",
				Trigger: &Trigger{
					Type: "explicit",
				},
			},
		},
		NextPageToken: "1",
	}

	if !cmp.Equal(pl, want) {
		t.Errorf("Pipelines.List got %+v, want %+v", pl, want)
	}
}

func Test_pipelines_Continue(t *testing.T) {
	client, mux, _, teardown := setup()
	defer teardown()

	mux.HandleFunc("/pipeline/continue", func(w http.ResponseWriter, r *http.Request) {
		testMethod(t, r, "POST")
		testHeader(t, r, "Accept", "application/json")
		testHeader(t, r, "Circle-Token", client.token)
		testBody(t, r, `{"continuation-key":"key1","configuration":"cfg1","parameters":{"deploy_prod":true}}`+"\n")
		fmt.Fprint(w, `{"message": "string"}`)
	})

	ctx := context.Background()
	err := client.Pipelines.Continue(ctx, PipelineContinueOptions{
		ContinuationKey: String("key1"),
		Configuration:   String("cfg1"),
		Parameters: map[string]interface{}{
			"deploy_prod": true,
		},
	})
	if err != nil {
		t.Errorf("Pipelines.Continue got error: %v", err)
	}
}

func Test_pipelines_Get(t *testing.T) {
	client, mux, _, teardown := setup()
	defer teardown()

	pipelineID := "pipeline1"

	mux.HandleFunc(fmt.Sprintf("/pipeline/%s", pipelineID), func(w http.ResponseWriter, r *http.Request) {
		testMethod(t, r, "GET")
		testHeader(t, r, "Accept", "application/json")
		testHeader(t, r, "Circle-Token", client.token)
		fmt.Fprint(w, `{"id": "1"}`)
	})

	ctx := context.Background()
	p, err := client.Pipelines.Get(ctx, pipelineID)
	if err != nil {
		t.Errorf("Pipeline.Get got error: %v", err)
	}

	want := &Pipeline{
		ID: "1",
	}

	if !cmp.Equal(p, want) {
		t.Errorf("Pipeline.Get got %+v, want %+v", p, want)
	}
}

func Test_pipelines_GetConfig(t *testing.T) {
	client, mux, _, teardown := setup()
	defer teardown()

	pipelineID := "pipeline1"

	mux.HandleFunc(fmt.Sprintf("/pipeline/%s/config", pipelineID), func(w http.ResponseWriter, r *http.Request) {
		testMethod(t, r, "GET")
		testHeader(t, r, "Accept", "application/json")
		testHeader(t, r, "Circle-Token", client.token)
		fmt.Fprint(w, `{"source": "a", "compiled": "b"}`)
	})

	ctx := context.Background()
	p, err := client.Pipelines.GetConfig(ctx, pipelineID)
	if err != nil {
		t.Errorf("Pipeline.GetConfig got error: %v", err)
	}

	want := &PipelineConfig{
		Source:   "a",
		Compiled: "b",
	}

	if !cmp.Equal(p, want) {
		t.Errorf("Pipeline.GetConfig got %+v, want %+v", p, want)
	}
}

func Test_pipelines_ListWorkflows(t *testing.T) {
	client, mux, _, teardown := setup()
	defer teardown()

	pipelineID := "pipeline1"

	mux.HandleFunc(fmt.Sprintf("/pipeline/%s/workflow", pipelineID), func(w http.ResponseWriter, r *http.Request) {
		testMethod(t, r, "GET")
		testHeader(t, r, "Accept", "application/json")
		testHeader(t, r, "Circle-Token", client.token)
		testQuery(t, r, "page-token", "1")
		fmt.Fprint(w, `{"items": [{"pipeline_id": "pipeline1", "pipeline_number": 0}], "next_page_token": "2"}`)
	})

	ctx := context.Background()
	p, err := client.Pipelines.ListWorkflows(ctx, pipelineID, PipelineListWorkflowsOptions{
		PageToken: String("1"),
	})
	if err != nil {
		t.Errorf("Pipeline.ListWorkflows got error: %v", err)
	}

	want := &WorkflowList{
		Items: []*Workflow{
			{
				PipelineID: pipelineID,
			},
		},
		NextPageToken: "2",
	}

	if !cmp.Equal(p, want) {
		t.Errorf("Pipeline.ListWorkflows got %+v, want %+v", p, want)
	}
}