feat(scm): implement commit status provider

Signed-off-by: Ushira Dineth <[email protected]>

Author: ushiradineth

internal/scms/bitbucket/commit_status.go

@@ -0,0 +1,110 @@
+package bitbucket
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"strings"
+	"time"
+
+	"github.com/ktrysmt/go-bitbucket"
+	v1 "k8s.io/api/core/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+	"sigs.k8s.io/controller-runtime/pkg/log"
+
+	"github.com/argoproj-labs/gitops-promoter/api/v1alpha1"
+	"github.com/argoproj-labs/gitops-promoter/internal/metrics"
+	"github.com/argoproj-labs/gitops-promoter/internal/scms"
+	"github.com/argoproj-labs/gitops-promoter/internal/utils"
+)
+
+// CommitStatus implements the scms.CommitStatusProvider interface for Bitbucket.
+type CommitStatus struct {
+	client    *bitbucket.Client
+	k8sClient client.Client
+}
+
+var _ scms.CommitStatusProvider = &CommitStatus{}
+
+// NewBitbucketCommitStatusProvider creates a new instance of CommitStatus for Bitbucket.
+func NewBitbucketCommitStatusProvider(k8sClient client.Client, secret v1.Secret, domain string) (*CommitStatus, error) {
+	client, err := GetClient(secret)
+	if err != nil {
+		return nil, err
+	}
+
+	return &CommitStatus{client: client, k8sClient: k8sClient}, nil
+}
+
+// Set sets the commit status for a given commit SHA in the specified repository.
+func (cs *CommitStatus) Set(ctx context.Context, commitStatus *v1alpha1.CommitStatus) (*v1alpha1.CommitStatus, error) {
+	logger := log.FromContext(ctx)
+	logger.Info("Setting Commit Phase")
+
+	repo, err := utils.GetGitRepositoryFromObjectKey(ctx, cs.k8sClient, client.ObjectKey{
+		Namespace: commitStatus.Namespace,
+		Name:      commitStatus.Spec.RepositoryReference.Name,
+	})
+	if err != nil {
+		return nil, fmt.Errorf("failed to get repo: %w", err)
+	}
+
+	commitOptions := &bitbucket.CommitsOptions{
+		Owner:    repo.Spec.Bitbucket.Workspace,
+		RepoSlug: repo.Spec.Bitbucket.Repository,
+		Revision: commitStatus.Spec.Sha,
+	}
+
+	commitStatusOptions := &bitbucket.CommitStatusOptions{
+		State:       phaseToBuildState(commitStatus.Spec.Phase),
+		Key:         commitStatus.Spec.Name,
+		Url:         commitStatus.Spec.Url,
+		Description: commitStatus.Spec.Description,
+	}
+
+	start := time.Now()
+	result, err := cs.client.Repositories.Commits.CreateCommitStatus(
+		commitOptions,
+		commitStatusOptions,
+	)
+
+	// Parse error message to determine status code
+	statusCode := http.StatusCreated
+	if err != nil {
+		statusCode = http.StatusInternalServerError
+		if bbErr, ok := err.(*bitbucket.UnexpectedResponseStatusError); ok {
+			errMsg := bbErr.Error()
+			switch {
+			case strings.HasPrefix(errMsg, "401"):
+				statusCode = http.StatusUnauthorized
+			case strings.HasPrefix(errMsg, "404"):
+				statusCode = http.StatusNotFound
+			}
+		}
+	}
+
+	metrics.RecordSCMCall(repo, metrics.SCMAPICommitStatus, metrics.SCMOperationCreate, statusCode, time.Since(start), nil)
+
+	if err != nil {
+		return nil, fmt.Errorf("failed to create status: %w", err)
+	}
+
+	logger.V(4).Info("bitbucket response status", "status", statusCode)
+
+	// Parse the response
+	resultMap, ok := result.(map[string]interface{})
+	if !ok {
+		return nil, fmt.Errorf("unexpected response type from Bitbucket API: %T", result)
+	}
+
+	// Extract state
+	state, _ := resultMap["state"].(string)
+
+	commitStatus.Status.Phase = buildStateToPhase(state)
+	commitStatus.Status.Sha = commitStatus.Spec.Sha
+
+	// Bitbucket doesn't return an ID for commit statuses, use key as identifier
+	commitStatus.Status.Id = commitStatus.Spec.Name
+
+	return commitStatus, nil
+}

internal/scms/bitbucket/utils.go

@@ -0,0 +1,33 @@
+package bitbucket
+
+import (
+	"github.com/argoproj-labs/gitops-promoter/api/v1alpha1"
+)
+
+// phaseToBuildState converts a CommitStatusPhase to a Bitbucket build state.
+// Bitbucket states: SUCCESSFUL, FAILED, INPROGRESS, STOPPED
+// https://developer.atlassian.com/cloud/bitbucket/rest/api-group-commit-statuses/#api-repositories-workspace-repo-slug-commit-commit-statuses-build-post-request-body
+func phaseToBuildState(phase v1alpha1.CommitStatusPhase) string {
+	switch phase {
+	case v1alpha1.CommitPhaseSuccess:
+		return "SUCCESSFUL"
+	case v1alpha1.CommitPhasePending:
+		return "INPROGRESS"
+	default:
+		return "FAILED"
+	}
+}
+
+// buildStateToPhase converts a Bitbucket build state to a CommitStatusPhase.
+// Bitbucket states: SUCCESSFUL, FAILED, INPROGRESS, STOPPED
+// https://developer.atlassian.com/cloud/bitbucket/rest/api-group-commit-statuses/#api-repositories-workspace-repo-slug-commit-commit-statuses-build-post-request-body
+func buildStateToPhase(buildState string) v1alpha1.CommitStatusPhase {
+	switch buildState {
+	case "SUCCESSFUL":
+		return v1alpha1.CommitPhaseSuccess
+	case "INPROGRESS":
+		return v1alpha1.CommitPhasePending
+	default:
+		return v1alpha1.CommitPhaseFailure
+	}
+}