Tag based gateway deployment

gateway/it/Makefile

@@ -20,8 +20,9 @@
 
 # Run integration tests (always with coverage)
 # Requires: make build-coverage-image (run once before tests)
+# Uses script to force unbuffered output on macOS
 test:
-	go test -v ./...
+	script -q /dev/null go test -v -count=1 ./...
 
 # Build all coverage-instrumented gateway components
 build-coverage:

gateway/it/config_manager.go

@@ -0,0 +1,71 @@
+package it
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"strings"
+	"sync"
+
+	"github.com/cucumber/godog"
+)
+
+const ConfigTagPrefix = "@config-"
+
+// GatewayConfigManager handles configuration switching for the gateway
+type GatewayConfigManager struct {
+	registry       *ConfigProfileRegistry
+	composeManager *ComposeManager
+	currentProfile string
+	mu             sync.Mutex
+}
+
+// NewGatewayConfigManager creates a new config manager
+func NewGatewayConfigManager(cm *ComposeManager) *GatewayConfigManager {
+	return &GatewayConfigManager{
+		registry:       NewConfigProfileRegistry(),
+		composeManager: cm,
+		currentProfile: "default", // Assume default on startup
+	}
+}
+
+// EnsureConfig checks the scenario tags and restarts the gateway if a different config is required
+func (m *GatewayConfigManager) EnsureConfig(ctx context.Context, sc *godog.Scenario) error {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+
+	requiredProfile := m.extractConfigTag(sc)
+	if requiredProfile == "" {
+		requiredProfile = "default"
+	}
+
+	if m.currentProfile == requiredProfile {
+		return nil // No restart needed
+	}
+
+	log.Printf("Switching gateway config from '%s' to '%s'...", m.currentProfile, requiredProfile)
+
+	profile, ok := m.registry.Get(requiredProfile)
+	if !ok {
+		return fmt.Errorf("unknown config profile: %s", requiredProfile)
+	}
+
+	// Restart gateway-controller with new env vars
+	if err := m.composeManager.RestartGatewayController(ctx, profile.EnvVars); err != nil {
+		return fmt.Errorf("failed to restart gateway with profile %s: %w", requiredProfile, err)
+	}
+
+	m.currentProfile = requiredProfile
+	log.Printf("Switched to '%s' profile successfully", requiredProfile)
+	return nil
+}
+
+// extractConfigTag finds the first tag starting with @config- and returns the suffix
+func (m *GatewayConfigManager) extractConfigTag(sc *godog.Scenario) string {
+	for _, tag := range sc.Tags {
+		if strings.HasPrefix(tag.Name, ConfigTagPrefix) {
+			return strings.TrimPrefix(tag.Name, ConfigTagPrefix)
+		}
+	}
+	return ""
+}

gateway/it/config_profiles.go

@@ -0,0 +1,74 @@
+package it
+
+// ConfigProfile defines a named configuration set for the gateway
+type ConfigProfile struct {
+	Name        string
+	EnvVars     map[string]string
+	Description string
+}
+
+// ConfigProfileRegistry manages the available configuration profiles
+type ConfigProfileRegistry struct {
+	profiles       map[string]*ConfigProfile
+	defaultProfile string
+}
+
+// NewConfigProfileRegistry creates a new registry with standard profiles
+func NewConfigProfileRegistry() *ConfigProfileRegistry {
+	registry := &ConfigProfileRegistry{
+		profiles:       make(map[string]*ConfigProfile),
+		defaultProfile: "default",
+	}
+
+	// Register standard profiles
+	registry.Register(&ConfigProfile{
+		Name: "default",
+		EnvVars: map[string]string{
+			"GATEWAY_LOGGING_LEVEL": "info",
+			"GATEWAY_STORAGE_TYPE":  "sqlite",
+		},
+		Description: "Standard configuration using SQLite and Info logging",
+	})
+
+	registry.Register(&ConfigProfile{
+		Name: "debug",
+		EnvVars: map[string]string{
+			"GATEWAY_LOGGING_LEVEL": "debug",
+			"GATEWAY_STORAGE_TYPE":  "sqlite",
+		},
+		Description: "Debug configuration enabling verbose logging",
+	})
+
+	registry.Register(&ConfigProfile{
+		Name: "memory",
+		EnvVars: map[string]string{
+			"GATEWAY_LOGGING_LEVEL": "info",
+			"GATEWAY_STORAGE_TYPE":  "memory",
+		},
+		Description: "In-memory storage configuration (non-persistent)",
+	})
+
+	registry.Register(&ConfigProfile{
+		Name: "tracing",
+		EnvVars: map[string]string{
+			"GATEWAY_LOGGING_LEVEL":   "info",
+			"GATEWAY_STORAGE_TYPE":    "memory",
+			"GATEWAY_TRACING_ENABLED": "true",
+		},
+		Description: "Configuration with OpenTelemetry tracing enabled",
+	})
+
+	return registry
+
+}
+
+// Register adds a profile to the registry
+func (r *ConfigProfileRegistry) Register(profile *ConfigProfile) {
+	r.profiles[profile.Name] = profile
+}
+
+// Get retrieves a profile by name
+func (r *ConfigProfileRegistry) Get(name string) (*ConfigProfile, bool) {
+	profile, ok := r.profiles[name]
+	return profile, ok
+}