Format code with go fmt

Apply formatting fixes from go fmt:
- Fix indentation in test cases and error handling
- Remove trailing whitespace
- Standardize code formatting across files

Signed-off-by: Ant Weiss <anton@otomato.io>

Author: antweiss

internal/pipeline/integration_test.go

@@ -414,31 +414,31 @@ func TestPromptTemplateExpansion(t *testing.T) {
 			event: interfaces.Event{
 				Type: "pod-restart",
 			},
-		expected: "Known: pod-restart, Unknown: <no value>",
-	},
-	{
-		name:     "Template with metadata access",
-		template: "Issue: {{.Metadata.issue}}, Project: {{.Metadata.project}}",
-		event: interfaces.Event{
-			Type: "resolve-issue",
-			Metadata: map[string]interface{}{
-				"issue":   "ECS-11",
-				"project": "KhookProject",
-			},
+			expected: "Known: pod-restart, Unknown: <no value>",
 		},
-		expected: "Issue: ECS-11, Project: KhookProject",
-	},
-	{
-		name:     "Template with nested metadata",
-		template: "Order {{.Metadata.orderId}} total: ${{.Metadata.amount}}",
-		event: interfaces.Event{
-			Type: "order-placed",
-			Metadata: map[string]interface{}{
-				"orderId": "ORD-123",
-				"amount":  99.99,
+		{
+			name:     "Template with metadata access",
+			template: "Issue: {{.Metadata.issue}}, Project: {{.Metadata.project}}",
+			event: interfaces.Event{
+				Type: "resolve-issue",
+				Metadata: map[string]interface{}{
+					"issue":   "ECS-11",
+					"project": "KhookProject",
+				},
 			},
+			expected: "Issue: ECS-11, Project: KhookProject",
 		},
-		expected: "Order ORD-123 total: $99.99",
+		{
+			name:     "Template with nested metadata",
+			template: "Order {{.Metadata.orderId}} total: ${{.Metadata.amount}}",
+			event: interfaces.Event{
+				Type: "order-placed",
+				Metadata: map[string]interface{}{
+					"orderId": "ORD-123",
+					"amount":  99.99,
+				},
+			},
+			expected: "Order ORD-123 total: $99.99",
 		},
 	}
 

internal/status/manager.go

@@ -83,20 +83,20 @@ func (m *Manager) UpdateHookStatus(ctx context.Context, hook *v1alpha2.Hook, act
 				time.Sleep(time.Millisecond * 100 * time.Duration(attempt+1))
 				continue
 			}
-		m.logger.Error(err, "Failed to update hook status",
-			"hook", hook.Name,
+			m.logger.Error(err, "Failed to update hook status",
+				"hook", hook.Name,
 				"namespace", hook.Namespace,
 				"attempt", attempt+1)
 			return fmt.Errorf("failed to update hook status after %d attempts: %w", attempt+1, err)
-	}
+		}
 
 		// Success
-	m.logger.Info("Successfully updated hook status",
-		"hook", hook.Name,
-		"namespace", hook.Namespace,
+		m.logger.Info("Successfully updated hook status",
+			"hook", hook.Name,
+			"namespace", hook.Namespace,
 			"lastUpdated", latestHook.Status.LastUpdated.Time,
 			"attempt", attempt+1)
-	return nil
+		return nil
 	}
 
 	return fmt.Errorf("failed to update hook status after %d attempts", maxRetries)

internal/workflow/coordinator.go

@@ -117,14 +117,14 @@ func (c *Coordinator) manageNamespaceWorkflow(
 
 	if state, exists := c.namespaceStates[namespace]; exists {
 		if state.Signature == signature {
-			c.logger.V(1).Info("No changes in hooks; keeping workflow running", 
+			c.logger.V(1).Info("No changes in hooks; keeping workflow running",
 				"namespace", namespace,
 				"currentSignature", signature,
 				"previousSignature", state.Signature)
 			return
 		}
 
-		c.logger.Info("Restarting namespace workflow due to hook changes", 
+		c.logger.Info("Restarting namespace workflow due to hook changes",
 			"namespace", namespace,
 			"oldSignature", state.Signature,
 			"newSignature", signature)

internal/workflow/workflow_manager.go

@@ -123,7 +123,7 @@ func (wm *WorkflowManager) runNamespaceWorkflow(
 		if err == context.Canceled {
 			wm.logger.Info("Namespace workflow stopped (context canceled)", "namespace", namespace)
 		} else {
-		wm.logger.Error(err, "Namespace workflow exited with error", "namespace", namespace)
+			wm.logger.Error(err, "Namespace workflow exited with error", "namespace", namespace)
 		}
 	} else {
 		wm.logger.Info("Namespace workflow finished", "namespace", namespace)

internal/workflow/workflow_manager_test.go

@@ -185,4 +185,3 @@ func TestCalculateSignatureChangesOnPromptUpdate(t *testing.T) {
 	// Signatures should be different
 	assert.NotEqual(t, sig1, sig2, "Signature should change when prompt is updated")
 }
-