Merge pull request #12 from OneFineStarstuff/genspark_ai_developer

AGI/ASI MVP scaffold: SSE chat, orchestrator, circuit breaker, provenance

Author: OneFineStarstuff

next-app/app/api/chat/stream/route.ts

@@ -0,0 +1,46 @@
+import { NextRequest } from 'next/server';
+
+export const runtime = 'nodejs';
+
+function* fakeStream(text: string) {
+  for (const ch of text) {
+    yield { delta: ch };
+  }
+}
+
+function streamForMessage(message: string) {
+  const ctrl = new AbortController();
+  const stream = new ReadableStream<Uint8Array>({
+    async start(controller) {
+      try {
+        const reply = `Echo: ${message}`;
+        const meta = { layer: 'surface', model: 'mock', version: '0.0.1', latencyMs: 42 };
+        controller.enqueue(encode(`event: meta\ndata: ${JSON.stringify(meta)}\n\n`));
+        for (const chunk of fakeStream(reply)) {
+          await new Promise(r => setTimeout(r, 10));
+          controller.enqueue(encode(`event: token\ndata: ${JSON.stringify(chunk)}\n\n`));
+        }
+        controller.enqueue(encode(`event: done\n\n`));
+        controller.close();
+      } catch (e) {
+        controller.enqueue(encode(`event: error\ndata: {"message":"stream_failed"}\n\n`));
+        controller.close();
+      }
+    },
+    cancel() { ctrl.abort(); }
+  });
+  return new Response(stream, { headers: { 'Content-Type': 'text/event-stream', 'Cache-Control': 'no-cache', Connection: 'keep-alive' } });
+}
+
+export async function POST(req: NextRequest) {
+  const { message } = await req.json();
+  return streamForMessage(message);
+}
+
+export async function GET(req: NextRequest) {
+  const { searchParams } = new URL(req.url);
+  const message = searchParams.get('q') ?? '';
+  return streamForMessage(message);
+}
+
+function encode(s: string) { return new TextEncoder().encode(s); }

next-app/app/api/intent/route.ts

@@ -0,0 +1,6 @@
+export const runtime = 'edge';
+export async function POST(req: Request) {
+  const { message } = await req.json();
+  const intent = /simulate|prove|optimize|model/i.test(message) ? 'analytical' : 'casual';
+  return new Response(JSON.stringify({ intent }), { headers: { 'content-type': 'application/json' } });
+}

next-app/app/chat/page.tsx

@@ -0,0 +1,74 @@
+"use client";
+import { useEffect, useRef, useState } from 'react';
+import { ProvenanceBadge } from '@/components/ProvenanceBadge';
+
+export default function ChatPage() {
+  const [input, setInput] = useState("");
+  const [messages, setMessages] = useState<{ role: 'user'|'assistant'; content: string; meta?: any }[]>([]);
+  const [streaming, setStreaming] = useState(false);
+  const [fallback, setFallback] = useState(false);
+  const eventSrc = useRef<EventSource | null>(null);
+
+  const send = async () => {
+    if (!input.trim() || streaming) return;
+    const userMsg = { role: 'user' as const, content: input };
+    setMessages(m => [...m, userMsg, { role: 'assistant', content: '' }]);
+    setInput("");
+    setStreaming(true);
+    const es = new EventSource(`/api/chat/stream?q=${encodeURIComponent(userMsg.content)}&s=${Date.now()}` , { withCredentials: false });
+    eventSrc.current = es;
+
+    es.addEventListener('token', (e: MessageEvent) => {
+      const data = JSON.parse(e.data);
+      setMessages(m => {
+        const copy = [...m];
+        const idx = copy.length - 1; // last assistant
+        copy[idx] = { ...copy[idx], content: (copy[idx].content || '') + data.delta };
+        return copy;
+      });
+    });
+
+    es.addEventListener('meta', (e: MessageEvent) => {
+      const meta = JSON.parse(e.data);
+      if (meta.fallback) setFallback(true);
+      setMessages(m => {
+        const copy = [...m];
+        const idx = copy.length - 1;
+        copy[idx] = { ...copy[idx], meta };
+        return copy;
+      });
+    });
+
+    es.addEventListener('done', () => { setStreaming(false); es.close(); eventSrc.current = null; });
+    es.addEventListener('error', () => { setStreaming(false); es.close(); eventSrc.current = null; });
+
+    // Using GET-only SSE with query payload; no POST body needed
+  };
+
+  useEffect(() => () => { eventSrc.current?.close(); }, []);
+
+  return (
+    <div className="space-y-4">
+      <h1 className="text-2xl font-semibold">Chat</h1>
+      <div className="rounded border bg-white p-3">
+        <div className="space-y-3" role="log" aria-live="polite">
+          {messages.map((m, i) => (
+            <div key={i} className={m.role === 'user' ? 'text-right' : 'text-left'}>
+              <div className={"inline-block max-w-[80%] rounded px-3 py-2 " + (m.role==='user'?'bg-amber-100':'bg-slate-100')}>
+                <div className="whitespace-pre-wrap">{m.content}</div>
+                {m.role==='assistant' && m.meta && (
+                  <div className="mt-1"><ProvenanceBadge meta={m.meta} /></div>
+                )}
+              </div>
+            </div>
+          ))}
+        </div>
+        <div className="mt-3 flex gap-2">
+          <input value={input} onChange={e=>setInput(e.target.value)} className="flex-1 rounded border px-3 py-2" placeholder="Type a message..." />
+          <button onClick={send} disabled={streaming} className="rounded bg-amber-600 px-4 py-2 text-white disabled:opacity-50">Send</button>
+          {fallback && <span className="text-xs text-slate-500">Fallback in use</span>}
+        </div>
+      </div>
+    </div>
+  );
+}

next-app/app/layout.tsx

@@ -0,0 +1,10 @@
+export const metadata = { title: 'AGI/ASI Interface', description: 'AI Readiness MVP' } satisfies import('next').Metadata;
+export default function RootLayout({ children }: { children: React.ReactNode }) {
+  return (
+    <html lang="en">
+      <body className="min-h-screen bg-gray-50 text-slate-900 antialiased" suppressHydrationWarning>
+        <div className="mx-auto max-w-5xl p-4">{children}</div>
+      </body>
+    </html>
+  );
+}

next-app/app/page.tsx

@@ -0,0 +1,9 @@
+export default function Home() {
+  return (
+    <main className="space-y-4">
+      <h1 className="text-2xl font-semibold">AGI/ASI Interface MVP</h1>
+      <p>Go to the chat to try streaming and provenance badges.</p>
+      <a className="text-amber-700 underline" href="/chat">Open Chat</a>
+    </main>
+  );
+}

next-app/components/ProvenanceBadge.tsx

@@ -0,0 +1,12 @@
+"use client";
+export function ProvenanceBadge({ meta }: { meta: { name?: string; model?: string; version?: string; layer?: string; latencyMs?: number } }) {
+  const label = `${meta.layer ?? 'surface'} • ${meta.name ?? meta.model ?? 'model'} ${meta.version ?? ''}`;
+  const color = (meta.layer ?? 'surface') === 'surface' ? '#38A169' : '#1A237E';
+  return (
+    <span role="status" aria-label={`Model ${label}`} className="inline-flex items-center gap-1 rounded border px-2 py-0.5 text-xs text-slate-700">
+      <span className="h-2 w-2 rounded-full" style={{ background: color }} />
+      {label}
+      {meta.latencyMs != null && <span className="text-slate-500">• {meta.latencyMs}ms</span>}
+    </span>
+  );
+}

next-app/lib/ai/circuitBreaker.ts

@@ -0,0 +1,12 @@
+type State = 'closed' | 'open' | 'half-open';
+export class CircuitBreaker {
+  private failures = 0; private state: State = 'closed'; private openedAt = 0;
+  constructor(private failureThreshold = 3, private recoveryMs = 15000) {}
+  canPass(): boolean {
+    if (this.state === 'open' && Date.now() - this.openedAt > this.recoveryMs) { this.state = 'half-open'; return true; }
+    return this.state !== 'open';
+  }
+  recordSuccess() { this.failures = 0; this.state = 'closed'; }
+  recordFailure() { this.failures++; if (this.failures >= this.failureThreshold) { this.state = 'open'; this.openedAt = Date.now(); } }
+  isOpen() { return this.state === 'open'; }
+}

next-app/lib/ai/orchestrator.ts

@@ -0,0 +1,42 @@
+import { CircuitBreaker } from './circuitBreaker';
+import type { ModelProvider, ModelResponse } from './types';
+
+type Intent = 'casual' | 'actionable' | 'analytical' | 'sensitive';
+export type RouteDecision = { intent: Intent; target: 'surface' | 'depth'; reason: string };
+
+export class Orchestrator {
+  private breakerDepth = new CircuitBreaker(3, 15000);
+  constructor(private surface: ModelProvider, private depth: ModelProvider, private intentDetect: (msg: string) => Intent) {}
+
+  route(input: string, override?: 'surface' | 'depth'): RouteDecision {
+    if (override) return { intent: this.intentDetect(input), target: override, reason: 'user_override' };
+    const intent = this.intentDetect(input);
+    const target = intent === 'analytical' ? 'depth' : 'surface';
+    return { intent, target, reason: 'policy' };
+  }
+
+  async respond(input: string, stream = true): Promise<ModelResponse> {
+    const decision = this.route(input);
+    const primary = decision.target === 'depth' ? this.depth : this.surface;
+    const fallback = decision.target === 'depth' ? this.surface : this.depth;
+
+    if (decision.target === 'depth' && !this.breakerDepth.canPass()) {
+      return this.surface.invoke(this.decorate(input, { fallback: 'depth_breaker_open' }));
+    }
+
+    try {
+      const res = stream && primary.supportsStreaming
+        ? await primary.stream(this.decorate(input, decision))
+        : await primary.invoke(this.decorate(input, decision));
+      if (decision.target === 'depth') this.breakerDepth.recordSuccess();
+      return res;
+    } catch (e) {
+      if (decision.target === 'depth') this.breakerDepth.recordFailure();
+      return fallback.invoke(this.decorate(input, { fallback: 'primary_failed' }));
+    }
+  }
+
+  private decorate(input: string, meta: Record<string, unknown>): string {
+    return `<!-- orchestration:${JSON.stringify(meta)} -->\n${input}`;
+  }
+}

next-app/lib/ai/types.ts

@@ -0,0 +1,5 @@
+export type ModelConfig = { temperature?: number; maxTokens?: number };
+export type StreamChunk = { id?: string; delta: string; done?: boolean };
+export type ProviderMeta = { name?: string; model?: string; layer?: 'surface' | 'depth'; version?: string; tokensIn?: number; tokensOut?: number; latencyMs?: number };
+export interface ModelResponse { text?: string; chunks?: AsyncIterable<StreamChunk>; meta: ProviderMeta }
+export interface ModelProvider { id: string; supportsStreaming: boolean; invoke(prompt: string): Promise<ModelResponse>; stream(prompt: string): Promise<ModelResponse> }

next-app/next.config.js

@@ -0,0 +1,6 @@
+/** @type {import('next').NextConfig} */
+const nextConfig = {
+  experimental: { serverActions: { allowedOrigins: ["*"] } },
+  reactStrictMode: true
+};
+module.exports = nextConfig;