Update core/system_bus.js

core/system_bus.js

@@ -1,49 +1,27 @@
-// core/system_bus.js
+import { classify } from "../ai/classifier.js";
+import { decide } from "./decision_engine.js";
+import { saveEvent } from "./memory.js";
 
-export function emit(eventType, payload) {
-    return route(eventType, payload);
-}
+export async function emit(eventType, payload) {
 
-function route(eventType, payload) {
+    if (eventType === "USER_INPUT") {
 
-    switch(eventType) {
+        const classification = classify(payload.text);
 
-        case "USER_INPUT":
-            return handleUserInput(payload);
+        const decision = decide(classification);
 
-        case "CLASSIFIED_INTENT":
-            return handleIntent(payload);
+        saveEvent({
+            input: payload.text,
+            classification,
+            decision
+        });
 
-        case "DECISION":
-            return handleDecision(payload);
-
-        default:
-            return {
-                status: "unknown_event",
-                payload
-            };
+        return {
+            message: decision.message
+        };
     }
-}
-
-// PLACEHOLDERS (werden später verbunden)
-function handleUserInput(data) {
-    return { next: "AI_CLASSIFICATION", data };
-}
-
-function handleIntent(data) {
-    return { next: "CORE_DECISION", data };
-}
 
-function handleDecision(data) {
-    return { next: "MEMORY_WRITE", data };
-}
-function normalize(eventType) {
-
-    const map = {
-        "FLOW": "system_flow",
-        "flow": "system_flow",
-        "Flow": "system_flow"
+    return {
+        message: "Unknown event"
     };
-
-    return map[eventType] || "unknown";
 }