fix repo name (#2420)

* fix repo name

* use general sanitzation func for all labels

Author: motatoes

backend/service_clients/k8s.go

@@ -16,6 +16,8 @@ import (
 	"k8s.io/client-go/rest"
 )
 
+
+
 func newInClusterClient() (*kubernetes.Clientset, error) {
 	config, err := rest.InClusterConfig()
 	if err != nil {
@@ -121,7 +123,7 @@ func (k K8sJobClient) triggerJob(ctx context.Context, opt JobOptions) (*Backgrou
 		"app.kubernetes.io/managed-by": "digger-jobs",
 	}
 	for k, v := range opt.Labels {
-		labels[k] = v
+		labels[k] = sanitizeLabel(v)
 	}
 
 	job := &batchv1.Job{

backend/service_clients/k8s_helper.go

@@ -0,0 +1,22 @@
+package service_clients
+
+import (
+	"regexp"
+	"strings"
+)
+
+// Allowed: (([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?
+// This means: optional string that starts and ends with alphanumeric,
+// and may contain -, _, . in between.
+// this is because k8s does not allow labels that do not match this patter
+var allowedPattern = regexp.MustCompile(`^[A-Za-z0-9]([-A-Za-z0-9_.]*[A-Za-z0-9])?$`)
+var cleanupPattern = regexp.MustCompile(`[^A-Za-z0-9_.-]+`)
+
+
+func sanitizeLabel(input string) string {
+	// Remove all disallowed characters
+	cleaned := cleanupPattern.ReplaceAllString(input, "")
+	// Trim leading and trailing non-alphanumerics
+	cleaned = strings.Trim(cleaned, "-_.")
+	return cleaned
+}

backend/service_clients/k8s_helper_test.go

@@ -0,0 +1,43 @@
+package service_clients
+
+import (
+	"testing"
+)
+
+func TestSanitizeLabel(t *testing.T) {
+	tests := []struct {
+		name     string
+		input    string
+		expected string
+	}{
+		// Basic alphanumeric
+		{"SimpleAlphaNum", "abc123", "abc123"},
+		// Remove illegal characters
+		{"RemoveIllegalChars", "abc!@#123", "abc123"},
+		// Trim leading/trailing dots/dashes/underscores
+		{"TrimLeadingTrailing", "-._abc123-_.", "abc123"},
+		// Keep valid internal characters
+		{"KeepInternalSpecials", "ab-c_d.e", "ab-c_d.e"},
+		// Collapse only removes invalid chars, not valid ones
+		{"MixedValidInvalid", "a$bc.._123", "abc.._123"},
+		// Entirely invalid string
+		{"AllInvalid", "!@#$%^&*", ""},
+		// Leading dot only
+		{"LeadingDot", ".abc", "abc"},
+		// Trailing underscore only
+		{"TrailingUnderscore", "abc_", "abc"},
+		// Consecutive invalids
+		{"ConsecutiveInvalids", "a@@b##c", "abc"},
+		// Empty input
+		{"Empty", "", ""},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			got := sanitizeLabel(tt.input)
+			if got != tt.expected {
+				t.Errorf("sanitizeLabel(%q) = %q; want %q", tt.input, got, tt.expected)
+			}
+		})
+	}
+}