fix: Add missing PipelinesSkipped status (kube-cicd/pipelines-feedbac…

…k-tekton#29)

pkgs/config/provider.go

@@ -3,14 +3,15 @@ package config
 import (
 	"context"
 	"fmt"
+	"strings"
+
 	"github.com/kube-cicd/pipelines-feedback-core/internal/config"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/contract"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/logging"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/store"
 	"github.com/pkg/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	v1 "k8s.io/client-go/kubernetes/typed/core/v1"
-	"strings"
 )
 
 type ConfigurationProviderInterface interface {

pkgs/contract/pipeline.go

@@ -59,6 +59,7 @@ func (pi PipelineInfo) GetStatus() Status {
 	succeeded := 0
 	running := 0
 	cancelled := 0
+	skipped := 0
 	allStages := len(pi.stages)
 
 	for _, stage := range pi.stages {
@@ -80,6 +81,9 @@ func (pi PipelineInfo) GetStatus() Status {
 		if stage.Status == PipelineCancelled {
 			cancelled += 1
 		}
+		if stage.Status == PipelineSkipped {
+			skipped += 1
+		}
 	}
 	if cancelled > 0 {
 		return PipelineCancelled
@@ -93,6 +97,9 @@ func (pi PipelineInfo) GetStatus() Status {
 	if allStages == succeeded {
 		return PipelineSucceeded
 	}
+	if skipped > 0 {
+		return PipelineSucceeded
+	}
 	return PipelineErrored
 }
 

pkgs/contract/wiring/di.go

@@ -15,7 +15,7 @@ type WithInitialization interface {
 }
 
 type ServiceContext struct {
-	Recorder     *record.EventRecorder
+	Recorder     record.EventRecorder
 	KubeConfig   *rest.Config
 	Config       config.ConfigurationProviderInterface
 	Log          *logging.InternalLogger

pkgs/controller/generic_controller.go

@@ -3,6 +3,9 @@ package controller
 import (
 	"context"
 	"fmt"
+	"strings"
+	"time"
+
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/config"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/contract"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/contract/wiring"
@@ -18,8 +21,6 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/event"
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
-	"strings"
-	"time"
 )
 
 type GenericController struct {
@@ -204,7 +205,7 @@ func (gc *GenericController) InjectDependencies(recorder record.EventRecorder, k
 	gc.kubeConfig = kubeConfig
 	gc.logger = logger
 	sc := wiring.ServiceContext{
-		Recorder:     &recorder,
+		Recorder:     recorder,
 		KubeConfig:   kubeConfig,
 		Config:       configProvider,
 		Log:          logger.ForkWithFields(context.TODO(), map[string]interface{}{}),

pkgs/fake/config.go

@@ -1,8 +1,12 @@
 package fake
 
 import (
+	"context"
+
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/apis/pipelinesfeedback.keskad.pl/v1alpha1"
 	"github.com/kube-cicd/pipelines-feedback-core/pkgs/config"
+	"github.com/kube-cicd/pipelines-feedback-core/pkgs/contract"
+	"github.com/kube-cicd/pipelines-feedback-core/pkgs/logging"
 )
 
 // NullValidator is an empty implementation used in unit tests
@@ -18,3 +22,22 @@ func (nv *NullValidator) ValidateConfig(data v1alpha1.Data) error {
 
 func (nv *NullValidator) Add(schema config.Schema) {
 }
+
+type FakeConfigurationProvider struct {
+}
+
+func (f *FakeConfigurationProvider) FetchContextual(component string, namespace string, pipeline contract.PipelineInfo) config.Data {
+	return config.NewData(component, map[string]string{}, &NullValidator{}, logging.CreateLogger(true))
+}
+
+func (f *FakeConfigurationProvider) FetchGlobal(component string) config.Data {
+	return config.NewData(component, map[string]string{}, &NullValidator{}, logging.CreateLogger(true))
+}
+
+func (f *FakeConfigurationProvider) FetchSecretKey(ctx context.Context, name string, namespace string, key string, cache bool) (string, error) {
+	return "", nil
+}
+
+func (f *FakeConfigurationProvider) FetchFromFieldOrSecret(ctx context.Context, data *config.Data, namespace string, fieldKey string, referenceKey string, referenceSecretNameKey string) (string, error) {
+	return "", nil
+}