Merge branch 'feat/polygon-lasso-4905851647628508372'

Author: robertpelloni

backend-go/api/fleet.go

@@ -0,0 +1,26 @@
+package api
+
+import (
+	"encoding/json"
+	"net/http"
+
+	"bobsgameonlinejava/backend-go/autonomous"
+)
+
+func HandleFleetSummary(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+
+	// Get ongoing active debate telemetry
+	debatesJSON := autonomous.GetFleetDebateSummary()
+
+	var debates []interface{}
+	json.Unmarshal(debatesJSON, &debates)
+
+	summary := map[string]interface{}{
+		"status": "ONLINE",
+		"active_jobs": 0, // Placeholder
+		"council_debates": debates,
+	}
+
+	json.NewEncoder(w).Encode(summary)
+}

backend-go/autonomous/debate.go

@@ -0,0 +1,73 @@
+package autonomous
+
+import (
+	"encoding/json"
+	"log"
+	"time"
+)
+
+type AgentMessage struct {
+	Role      string    `json:"role"`
+	Content   string    `json:"content"`
+	Timestamp time.Time `json:"timestamp"`
+	Tokens    int       `json:"tokens"`
+}
+
+type DebateSession struct {
+	ID        string         `json:"id"`
+	Topic     string         `json:"topic"`
+	Status    string         `json:"status"` // "ongoing", "resolved", "escalated"
+	Messages  []AgentMessage `json:"messages"`
+	StartTime time.Time      `json:"startTime"`
+	EndTime   time.Time      `json:"endTime,omitempty"`
+}
+
+var ActiveDebates = make(map[string]*DebateSession)
+
+func InitiateDebate(topic string) *DebateSession {
+	session := &DebateSession{
+		ID:        "debate_" + time.Now().Format("20060102150405"),
+		Topic:     topic,
+		Status:    "ongoing",
+		StartTime: time.Now(),
+		Messages:  []AgentMessage{},
+	}
+	ActiveDebates[session.ID] = session
+	log.Printf("[COUNCIL SUPERVISOR] Initiated debate session: %s on topic: %s", session.ID, topic)
+	return session
+}
+
+func AddDebateMessage(sessionID, role, content string, tokens int) {
+	if session, exists := ActiveDebates[sessionID]; exists {
+		msg := AgentMessage{
+			Role:      role,
+			Content:   content,
+			Timestamp: time.Now(),
+			Tokens:    tokens,
+		}
+		session.Messages = append(session.Messages, msg)
+		log.Printf("[DEBATE %s] %s: %s (%d tokens)", sessionID, role, content, tokens)
+	}
+}
+
+func ResolveDebate(sessionID string) {
+	if session, exists := ActiveDebates[sessionID]; exists {
+		session.Status = "resolved"
+		session.EndTime = time.Now()
+		log.Printf("[COUNCIL SUPERVISOR] Resolved debate session: %s", sessionID)
+	}
+}
+
+func GetFleetDebateSummary() []byte {
+	summary := []map[string]interface{}{}
+	for _, session := range ActiveDebates {
+		summary = append(summary, map[string]interface{}{
+			"id":       session.ID,
+			"topic":    session.Topic,
+			"status":   session.Status,
+			"messages": len(session.Messages),
+		})
+	}
+	bytes, _ := json.Marshal(summary)
+	return bytes
+}

backend-go/autonomous/supervisor.go

@@ -0,0 +1,35 @@
+package autonomous
+
+import (
+	"log"
+	"math/rand"
+	"time"
+)
+
+type Plan struct {
+	ID    string
+	Risk  string // "LOW", "HIGH"
+	Topic string
+}
+
+func EvaluatePlan(plan Plan) {
+	if plan.Risk == "HIGH" {
+		log.Printf("[COUNCIL SUPERVISOR] High-risk plan detected: %s. Initiating multi-agent debate.", plan.ID)
+
+		session := InitiateDebate(plan.Topic)
+
+		// Simulate Security Architect
+		tokensArch := rand.Intn(100) + 50
+		AddDebateMessage(session.ID, "Security Architect", "I have reviewed the plan. The anomaly vectors look safe, but we must verify the CI hooks.", tokensArch)
+		time.Sleep(100 * time.Millisecond) // Simulated latency
+
+		// Simulate Senior Engineer
+		tokensEng := rand.Intn(100) + 50
+		AddDebateMessage(session.ID, "Senior Engineer", "Agreed. The hooks are isolated from the main orchestrator loop. Proceeding with execution.", tokensEng)
+		time.Sleep(100 * time.Millisecond)
+
+		ResolveDebate(session.ID)
+	} else {
+		log.Printf("[COUNCIL SUPERVISOR] Low-risk plan %s auto-approved.", plan.ID)
+	}
+}

backend-go/main.go

@@ -17,6 +17,7 @@ func main() {
 	http.HandleFunc("/api/system/status", api.HandleSystemStatus)
 	http.HandleFunc("/api/system/ws", api.HandleWebSocket)
 	http.HandleFunc("/api/system/autofix", api.HandleAutofix)
+	http.HandleFunc("/api/fleet/summary", api.HandleFleetSummary)
 
 	port := os.Getenv("PORT")
 	if port == "" {

backend-go/services/shadow_pilot.go

@@ -1,13 +1,25 @@
 package services
 
 import (
+	"fmt"
 	"log"
 	"os/exec"
+	"time"
+
+	"bobsgameonlinejava/backend-go/autonomous"
 )
 
 func LogAnomaly(message string, details map[string]interface{}) {
 	log.Printf("[SHADOW PILOT ANOMALY] %s: %v", message, details)
 
+	// Evaluate via autonomous debate
+	plan := autonomous.Plan{
+		ID:    fmt.Sprintf("fix_%d", time.Now().Unix()),
+		Risk:  "HIGH",
+		Topic: "Resolve: " + message,
+	}
+	autonomous.EvaluatePlan(plan)
+
 	// Trigger CI auto-fix logic locally
 	cmd := exec.Command("go", "run", "autofix/autofix.go", "--diff-source=native-diff-monitor", "--apply-heuristics")
 	cmd.Dir = ".." // Run from backend-go