Populate the release_phase response to the related APIs

database/query/profile_status.sql

@@ -82,7 +82,8 @@ SELECT
         WHEN ere.entity_type = 'artifact'::entities THEN ere.artifact_id
         WHEN ere.entity_type = 'repository'::entities THEN ere.repository_id
         WHEN ere.entity_type = 'pull_request'::entities THEN ere.pull_request_id
-    END::uuid as entity_id
+    END::uuid as entity_id,
+    rt.release_phase as rule_type_release_phase
 FROM latest_evaluation_statuses les
          INNER JOIN evaluation_rule_entities ere ON ere.id = les.rule_entity_id
          INNER JOIN eval_details ed ON ed.id = les.evaluation_history_id

database/query/rule_types.sql

@@ -7,7 +7,8 @@ INSERT INTO rule_type (
     definition,
     severity_value,
     subscription_id,
-    display_name
+    display_name,
+    release_phase
 ) VALUES (
     $1,
     $2,
@@ -16,7 +17,8 @@ INSERT INTO rule_type (
     sqlc.arg(definition)::jsonb,
     sqlc.arg(severity_value),
     sqlc.narg(subscription_id),
-    sqlc.arg(display_name)
+    sqlc.arg(display_name),
+    sqlc.arg(release_phase)
 ) RETURNING *;
 
 -- name: ListRuleTypesByProject :many
@@ -33,7 +35,7 @@ DELETE FROM rule_type WHERE id = $1;
 
 -- name: UpdateRuleType :one
 UPDATE rule_type
-    SET description = $2, definition = sqlc.arg(definition)::jsonb, severity_value = sqlc.arg(severity_value), display_name = sqlc.arg(display_name)
+    SET description = $2, definition = sqlc.arg(definition)::jsonb, severity_value = sqlc.arg(severity_value), display_name = sqlc.arg(display_name), release_phase = sqlc.arg(release_phase)
     WHERE id = $1
     RETURNING *;
 

internal/controlplane/handlers_evalstatus.go

@@ -32,6 +32,7 @@ import (
 	"github.com/stacklok/minder/internal/db"
 	"github.com/stacklok/minder/internal/engine/engcontext"
 	"github.com/stacklok/minder/internal/history"
+	"github.com/stacklok/minder/internal/ruletypes"
 	"github.com/stacklok/minder/internal/util"
 	minderv1 "github.com/stacklok/minder/pkg/api/protobuf/go/minder/v1"
 )
@@ -596,6 +597,11 @@ func buildRuleEvaluationStatusFromDBEvaluation(
 		nString = eval.RuleTypeName
 	}
 
+	rp, err := ruletypes.GetPBReleasePhaseFromDBReleaseStatus(&eval.RuleTypeReleasePhase)
+	if err != nil {
+		return nil, fmt.Errorf("converting release phase: %w", err)
+	}
+
 	return &minderv1.RuleEvaluationStatus{
 		RuleEvaluationId:       eval.RuleEvaluationID.String(),
 		RuleId:                 eval.RuleTypeID.String(),
@@ -615,6 +621,7 @@ func buildRuleEvaluationStatusFromDBEvaluation(
 		RuleTypeName:           eval.RuleTypeName,
 		Alert:                  buildEvalResultAlertFromLRERow(&eval),
 		Severity:               sev,
+		ReleasePhase:           rp,
 	}, nil
 }
 

internal/controlplane/handlers_profile.go

@@ -33,6 +33,7 @@ import (
 	"github.com/stacklok/minder/internal/engine/entities"
 	"github.com/stacklok/minder/internal/logger"
 	prof "github.com/stacklok/minder/internal/profiles"
+	"github.com/stacklok/minder/internal/ruletypes"
 	"github.com/stacklok/minder/internal/util"
 	minderv1 "github.com/stacklok/minder/pkg/api/protobuf/go/minder/v1"
 )
@@ -470,6 +471,11 @@ func (s *Server) getRuleEvalStatus(
 		}
 	}
 
+	releasePhase, err := ruletypes.GetPBReleasePhaseFromDBReleaseStatus(&dbRuleEvalStat.RuleTypeReleasePhase)
+	if err != nil {
+		l.Err(err).Msg("error getting release phase")
+	}
+
 	st := &minderv1.RuleEvaluationStatus{
 		ProfileId:           profileID,
 		RuleId:              dbRuleEvalStat.RuleTypeID.String(),
@@ -491,6 +497,7 @@ func (s *Server) getRuleEvalStatus(
 			LastUpdated: timestamppb.New(dbRuleEvalStat.AlertLastUpdated),
 		},
 		RemediationLastUpdated: timestamppb.New(dbRuleEvalStat.RemLastUpdated),
+		ReleasePhase:           releasePhase,
 	}
 
 	// If the alert is on and its metadata is valid, parse it and set the URL

internal/controlplane/handlers_profile_test.go

@@ -68,6 +68,7 @@ func TestCreateProfile(t *testing.T) {
 		ProjectID:     dbproj.ID,
 		Definition:    []byte(`{"in_entity": "repository","ruleSchema":{}}`),
 		SeverityValue: db.SeverityLow,
+		ReleasePhase:  db.ReleaseStatusAlpha,
 	})
 	if err != nil {
 		t.Fatalf("Error creating rule type: %v", err)
@@ -401,6 +402,7 @@ func ruleTypeSequenceCreate(
 			ProjectID:     projectID,
 			Definition:    []byte(defstr),
 			SeverityValue: db.SeverityLow,
+			ReleasePhase:  db.ReleaseStatusAlpha,
 		})
 		if err != nil {
 			return err

internal/db/profiles_test.go

@@ -97,6 +97,7 @@ func createRandomRuleType(t *testing.T, projectID uuid.UUID) RuleType {
 		Guidance:      rand.RandomString(64, seed),
 		Definition:    json.RawMessage(`{"key": "value"}`),
 		SeverityValue: SeverityHigh,
+		ReleasePhase:  ReleaseStatusAlpha,
 	}
 
 	ruleType, err := testQueries.CreateRuleType(context.Background(), arg)

internal/ruletypes/service.go

@@ -139,6 +139,11 @@ func (_ *ruleTypeService) CreateRuleType(
 		return nil, err
 	}
 
+	releasePhase, err := GetDBReleaseStatusFromPBReleasePhase(ruleType.GetReleasePhase())
+	if err != nil {
+		return nil, err
+	}
+
 	ruleType = ruleType.WithDefaultDisplayName()
 	newDBRecord, err := qtx.CreateRuleType(ctx, db.CreateRuleTypeParams{
 		Name:           ruleTypeName,
@@ -149,6 +154,7 @@ func (_ *ruleTypeService) CreateRuleType(
 		Guidance:       ruleType.GetGuidance(),
 		SeverityValue:  *severity,
 		SubscriptionID: uuid.NullUUID{UUID: subscriptionID, Valid: subscriptionID != uuid.Nil},
+		ReleasePhase:   *releasePhase,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to create rule type: %w", err)
@@ -214,13 +220,19 @@ func (_ *ruleTypeService) UpdateRuleType(
 		return nil, err
 	}
 
+	releasePhase, err := GetDBReleaseStatusFromPBReleasePhase(ruleType.GetReleasePhase())
+	if err != nil {
+		return nil, err
+	}
+
 	ruleType = ruleType.WithDefaultDisplayName()
 	updatedRuleType, err := qtx.UpdateRuleType(ctx, db.UpdateRuleTypeParams{
 		ID:            oldRuleType.ID,
 		Description:   ruleType.GetDescription(),
 		Definition:    serializedRule,
 		SeverityValue: *severity,
 		DisplayName:   ruleType.GetDisplayName(),
+		ReleasePhase:  *releasePhase,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to update rule type: %w", err)
@@ -297,3 +309,34 @@ func validateRuleUpdate(existingRecord *db.RuleType, newRuleType *pb.RuleType) e
 
 	return nil
 }
+
+// GetDBReleaseStatusFromPBReleasePhase converts a protobuf release phase to a database release status
+func GetDBReleaseStatusFromPBReleasePhase(in pb.RuleTypeReleasePhase) (*db.ReleaseStatus, error) {
+	sev, err := in.InitializedStringValue()
+	if err != nil {
+		return nil, errors.Join(ErrRuleTypeInvalid, err)
+	}
+	var rel db.ReleaseStatus
+
+	if err := rel.Scan(sev); err != nil {
+		// errors from the `Scan` method appear to be caused entirely by bad
+		// input
+		return nil, errors.Join(ErrRuleTypeInvalid, err)
+	}
+
+	return &rel, nil
+}
+
+// GetPBReleasePhaseFromDBReleaseStatus converts a database release status to a protobuf release phase
+func GetPBReleasePhaseFromDBReleaseStatus(s *db.ReleaseStatus) (pb.RuleTypeReleasePhase, error) {
+	if s == nil {
+		return pb.RuleTypeReleasePhase_RULE_TYPE_RELEASE_PHASE_UNSPECIFIED, nil
+	}
+
+	var rel pb.RuleTypeReleasePhase
+	if err := rel.FromString(string(*s)); err != nil {
+		return pb.RuleTypeReleasePhase_RULE_TYPE_RELEASE_PHASE_UNSPECIFIED, err
+	}
+
+	return rel, nil
+}

internal/ruletypes/util.go

@@ -46,7 +46,6 @@ func RuleTypePBFromDB(rt *db.RuleType) (*minderv1.RuleType, error) {
 	project := rt.ProjectID.String()
 
 	var seval minderv1.Severity_Value
-
 	if err := seval.FromString(string(rt.SeverityValue)); err != nil {
 		seval = minderv1.Severity_VALUE_UNKNOWN
 	}
@@ -56,6 +55,11 @@ func RuleTypePBFromDB(rt *db.RuleType) (*minderv1.RuleType, error) {
 		displayName = rt.Name
 	}
 
+	var releasePhase minderv1.RuleTypeReleasePhase
+	if err := releasePhase.FromString(string(rt.ReleasePhase)); err != nil {
+		releasePhase = minderv1.RuleTypeReleasePhase_RULE_TYPE_RELEASE_PHASE_UNSPECIFIED
+	}
+
 	// TODO: (2024/03/28) this is for compatibility with old CLI versions that expect provider, remove this eventually
 	noProvider := ""
 	return &minderv1.RuleType{
@@ -72,5 +76,6 @@ func RuleTypePBFromDB(rt *db.RuleType) (*minderv1.RuleType, error) {
 		Severity: &minderv1.Severity{
 			Value: seval,
 		},
+		ReleasePhase: releasePhase,
 	}, nil
 }