Refactor operator into organized packages and fix stop session bug

- Restructure monolithic main.go into internal packages following backend pattern
  - internal/config: Configuration and K8s client initialization
  - internal/handlers: Event handlers for sessions, namespaces, and project settings
  - internal/services: Infrastructure services (PVC, content service)
  - internal/types: Resource type definitions
- Fix stop session bug: operator now properly terminates jobs when sessions marked as "Stopped"
- Preserve all existing functionality and behavior
- Update module name to ambient-code-operator
- Reduce main.go from 1000+ lines to 33 lines

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: sallyom

components/operator/go.mod

@@ -1,11 +1,10 @@
-module research-operator
+module ambient-code-operator
 
 go 1.24.0
 
 toolchain go1.24.7
 
 require (
-	github.com/stretchr/testify v1.10.0
 	k8s.io/api v0.34.0
 	k8s.io/apimachinery v0.34.0
 	k8s.io/client-go v0.34.0
@@ -29,7 +28,6 @@ require (
 	github.com/modern-go/reflect2 v1.0.3-0.20250322232337-35a7c28c31ee // indirect
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
-	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/spf13/pflag v1.0.6 // indirect
 	github.com/x448/float16 v0.8.4 // indirect
 	go.yaml.in/yaml/v2 v2.4.2 // indirect

components/operator/internal/config/config.go

@@ -0,0 +1,101 @@
+package config
+
+import (
+	"fmt"
+	"os"
+
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/client-go/dynamic"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+var (
+	K8sClient     *kubernetes.Clientset
+	DynamicClient dynamic.Interface
+)
+
+// Config holds the operator configuration
+type Config struct {
+	Namespace              string
+	BackendNamespace       string
+	AmbientCodeRunnerImage string
+	ContentServiceImage    string
+	ImagePullPolicy        corev1.PullPolicy
+}
+
+// LoadConfig loads configuration from environment variables
+func LoadConfig() *Config {
+	// Get namespace from environment or use default
+	namespace := os.Getenv("NAMESPACE")
+	if namespace == "" {
+		namespace = "default"
+	}
+
+	// Get backend namespace from environment or use operator namespace
+	backendNamespace := os.Getenv("BACKEND_NAMESPACE")
+	if backendNamespace == "" {
+		backendNamespace = namespace // Default to same namespace as operator
+	}
+
+	// Get ambient-code runner image from environment or use default
+	ambientCodeRunnerImage := os.Getenv("AMBIENT_CODE_RUNNER_IMAGE")
+	if ambientCodeRunnerImage == "" {
+		ambientCodeRunnerImage = "quay.io/ambient_code/vteam_claude_runner:latest"
+	}
+
+	// Image for per-namespace content service (defaults to backend image)
+	contentServiceImage := os.Getenv("CONTENT_SERVICE_IMAGE")
+	if contentServiceImage == "" {
+		contentServiceImage = "quay.io/ambient_code/vteam_backend:latest"
+	}
+
+	// Get image pull policy from environment or use default
+	imagePullPolicyStr := os.Getenv("IMAGE_PULL_POLICY")
+	if imagePullPolicyStr == "" {
+		imagePullPolicyStr = "Always"
+	}
+	imagePullPolicy := corev1.PullPolicy(imagePullPolicyStr)
+
+	return &Config{
+		Namespace:              namespace,
+		BackendNamespace:       backendNamespace,
+		AmbientCodeRunnerImage: ambientCodeRunnerImage,
+		ContentServiceImage:    contentServiceImage,
+		ImagePullPolicy:        imagePullPolicy,
+	}
+}
+
+// InitK8sClients initializes the Kubernetes clients
+func InitK8sClients() error {
+	var config *rest.Config
+	var err error
+
+	// Try in-cluster config first
+	if config, err = rest.InClusterConfig(); err != nil {
+		// If in-cluster config fails, try kubeconfig
+		kubeconfig := os.Getenv("KUBECONFIG")
+		if kubeconfig == "" {
+			kubeconfig = fmt.Sprintf("%s/.kube/config", os.Getenv("HOME"))
+		}
+
+		if config, err = clientcmd.BuildConfigFromFlags("", kubeconfig); err != nil {
+			return fmt.Errorf("failed to create Kubernetes config: %v", err)
+		}
+	}
+
+	// Create standard Kubernetes client
+	K8sClient, err = kubernetes.NewForConfig(config)
+	if err != nil {
+		return fmt.Errorf("failed to create Kubernetes client: %v", err)
+	}
+
+	// Create dynamic client for custom resources
+	DynamicClient, err = dynamic.NewForConfig(config)
+	if err != nil {
+		return fmt.Errorf("failed to create dynamic client: %v", err)
+	}
+
+	return nil
+}

components/operator/internal/handlers/namespaces.go

@@ -0,0 +1,59 @@
+package handlers
+
+import (
+	"context"
+	"log"
+	"time"
+
+	"ambient-code-operator/internal/config"
+	"ambient-code-operator/internal/services"
+
+	corev1 "k8s.io/api/core/v1"
+	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	"k8s.io/apimachinery/pkg/watch"
+)
+
+// WatchNamespaces watches for managed namespaces
+func WatchNamespaces() {
+	for {
+		watcher, err := config.K8sClient.CoreV1().Namespaces().Watch(context.TODO(), v1.ListOptions{
+			LabelSelector: "ambient-code.io/managed=true",
+		})
+		if err != nil {
+			log.Printf("Failed to create namespace watcher: %v", err)
+			time.Sleep(5 * time.Second)
+			continue
+		}
+
+		log.Println("Watching for managed namespaces...")
+
+		for event := range watcher.ResultChan() {
+			switch event.Type {
+			case watch.Added:
+				namespace := event.Object.(*corev1.Namespace)
+				log.Printf("Detected new managed namespace: %s", namespace.Name)
+
+				// Auto-create ProjectSettings for this namespace
+				if err := CreateDefaultProjectSettings(namespace.Name); err != nil {
+					log.Printf("Error creating default ProjectSettings for namespace %s: %v", namespace.Name, err)
+				}
+
+				// Ensure shared workspace PVC and content service exist
+				if err := services.EnsureProjectWorkspacePVC(namespace.Name); err != nil {
+					log.Printf("Failed to ensure workspace PVC in %s: %v", namespace.Name, err)
+				}
+				if err := services.EnsureContentService(namespace.Name); err != nil {
+					log.Printf("Failed to ensure content service in %s: %v", namespace.Name, err)
+				}
+			case watch.Error:
+				obj := event.Object.(*unstructured.Unstructured)
+				log.Printf("Watch error for namespaces: %v", obj)
+			}
+		}
+
+		log.Println("Namespace watch channel closed, restarting...")
+		watcher.Stop()
+		time.Sleep(2 * time.Second)
+	}
+}