factory_dao_test.go

package workflow_test

import (
	"context"
	"fmt"
	"testing"

	"github.com/ovh/cds/engine/api/test"
	"github.com/ovh/cds/engine/api/workflow"
	"github.com/stretchr/testify/require"
)

func TestLoadAllWorkflows(t *testing.T) {
	db, _ := test.SetupPG(t)

	var opts = []workflow.WorkflowDAO{
		{},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				ProjectKey: "test",
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				WorkflowName: "test",
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				ApplicationRepository: "test",
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				FromRepository: "test",
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				VCSServer: "test",
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				GroupIDs: []int64{1, 2, 3, 4},
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				ProjectKey:            "test",
				WorkflowName:          "test",
				ApplicationRepository: "test",
				VCSServer:             "test",
				GroupIDs:              []int64{1, 2, 3, 4},
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{
				ProjectKey:            "test",
				ApplicationRepository: "test",
				GroupIDs:              []int64{1, 2, 3, 4},
			},
			Loaders: workflow.LoadAllWorkflowsOptionsLoaders{
				WithAsCodeUpdateEvents: true,
				WithEnvironments:       true,
				WithApplications:       true,
				WithIcon:               true,
				WithIntegrations:       true,
				WithPipelines:          true,
				WithTemplate:           true,
			},
		},
		{
			Filters: workflow.LoadAllWorkflowsOptionsFilters{},
			Loaders: workflow.LoadAllWorkflowsOptionsLoaders{
				WithAsCodeUpdateEvents: true,
				WithEnvironments:       true,
				WithApplications:       true,
				WithIcon:               true,
				WithIntegrations:       true,
				WithPipelines:          true,
				WithTemplate:           true,
				WithRuns:               10,
			},
		},
	}

	for i, opt := range opts {
		t.Run(fmt.Sprintf("test LoadAllWorkflows #%d", i), func(t *testing.T) {
			wss, err := opt.LoadAll(context.TODO(), db)
			for _, ws := range wss {
				require.NotEmpty(t, ws.ProjectKey)
			}
			require.NoError(t, err)
		})
	}
}