Compare commits
1 Commits
nexusburn/
...
burn/1143-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e79f1d98ae |
@@ -27,10 +27,8 @@ jobs:
|
||||
username: ${{ secrets.DEPLOY_USER }}
|
||||
key: ${{ secrets.DEPLOY_SSH_KEY }}
|
||||
script: |
|
||||
cd ~/the-nexus || git clone https://forge.alexanderwhitestone.com/Timmy_Foundation/the-nexus.git ~/the-nexus
|
||||
cd ~/the-nexus || git clone http://143.198.27.163:3000/Timmy_Foundation/the-nexus.git ~/the-nexus
|
||||
cd ~/the-nexus
|
||||
git fetch origin main
|
||||
git reset --hard origin/main
|
||||
docker compose build nexus-main
|
||||
docker compose up -d --force-recreate nexus-main
|
||||
echo "Nexus deployed — HTTP :8080, WS :8765"
|
||||
./deploy.sh main
|
||||
|
||||
@@ -11,16 +11,11 @@ COPY nexus/ nexus/
|
||||
COPY server.py ./
|
||||
|
||||
# Frontend assets referenced by index.html
|
||||
COPY index.html help.html style.css app.js boot.js bootstrap.mjs gofai_worker.js mempalace.js service-worker.js manifest.json ./
|
||||
COPY index.html help.html style.css app.js service-worker.js manifest.json ./
|
||||
|
||||
# Config/data
|
||||
COPY portals.json vision.json robots.txt ./
|
||||
|
||||
# Icons
|
||||
COPY icons/ icons/
|
||||
|
||||
# Expose HTTP (static) and WebSocket
|
||||
EXPOSE 8080
|
||||
EXPOSE 8765
|
||||
|
||||
CMD ["python3", "server.py"]
|
||||
|
||||
38
app.js
38
app.js
@@ -995,8 +995,8 @@ function createBatcaveTerminal() {
|
||||
{ title: 'NEXUS COMMAND', color: NEXUS.colors.primary, rot: -0.4, x: -6, y: 3, lines: ['> STATUS: NOMINAL', '> UPTIME: 142.4h', '> HARNESS: STABLE', '> MODE: SOVEREIGN'] },
|
||||
{ title: 'DEV QUEUE', color: NEXUS.colors.gold, rot: -0.2, x: -3, y: 3, lines: ['> ISSUE #4: CORE', '> ISSUE #5: PORTAL', '> ISSUE #6: TERMINAL', '> ISSUE #7: TIMMY'] },
|
||||
{ title: 'METRICS', color: NEXUS.colors.secondary, rot: 0, x: 0, y: 3, lines: ['> CPU: 12% [||....]', '> MEM: 4.2GB', '> COMMITS: 842', '> ACTIVE LOOPS: 5'] },
|
||||
{ title: 'SOVEREIGNTY', color: NEXUS.colors.gold, rot: 0.2, x: 3, y: 3, lines: ['REPLIT: GRADE: A', 'PERPLEXITY: GRADE: A-', 'HERMES: GRADE: B+', 'KIMI: GRADE: B', 'CLAUDE: GRADE: B+'] },
|
||||
{ title: 'AGENT STATUS', color: NEXUS.colors.primary, rot: 0.4, x: 6, y: 3, lines: ['> TIMMY: ● RUNNING', '> KIMI: ○ STANDBY', '> CLAUDE: ● ACTIVE', '> PERPLEXITY: ○'] },
|
||||
{ title: 'SOVEREIGNTY', color: NEXUS.colors.gold, rot: 0.2, x: 3, y: 3, lines: ['REPLIT: GRADE: A', 'PERPLEXITY: GRADE: A-', 'HERMES: GRADE: B+', 'KIMI: GRADE: B', 'GEMINI: GRADE: B+'] },
|
||||
{ title: 'AGENT STATUS', color: NEXUS.colors.primary, rot: 0.4, x: 6, y: 3, lines: ['> TIMMY: ● RUNNING', '> KIMI: ○ STANDBY', '> GEMINI: ○ STANDBY', '> PERPLEXITY: ○'] },
|
||||
];
|
||||
|
||||
panelData.forEach(data => {
|
||||
@@ -1223,7 +1223,7 @@ function updateAgentStatus(issues) {
|
||||
const lines = [
|
||||
'> TIMMY: ● RUNNING',
|
||||
'> KIMI: ○ STANDBY',
|
||||
'> CLAUDE: ● ACTIVE',
|
||||
'> GEMINI: ○ STANDBY',
|
||||
`> PERPLEXITY: ${perplexityStatus}`
|
||||
];
|
||||
terminal.updatePanelText(lines);
|
||||
@@ -1323,7 +1323,7 @@ function createAgentPresences() {
|
||||
const agentData = [
|
||||
{ id: 'timmy', name: 'TIMMY', color: NEXUS.colors.primary, pos: { x: -4, z: -4 }, station: { x: -4, z: -4 } },
|
||||
{ id: 'kimi', name: 'KIMI', color: NEXUS.colors.secondary, pos: { x: 4, z: -4 }, station: { x: 4, z: -4 } },
|
||||
{ id: 'claude', name: 'CLAUDE', color: NEXUS.colors.gold, pos: { x: 0, z: -6 }, station: { x: 0, z: -6 } },
|
||||
{ id: 'gemini', name: 'GEMINI', color: NEXUS.colors.gold, pos: { x: 0, z: -6 }, station: { x: 0, z: -6 } },
|
||||
{ id: 'perplexity', name: 'PERPLEXITY', color: 0x4488ff, pos: { x: -6, z: -2 }, station: { x: -6, z: -2 } },
|
||||
];
|
||||
|
||||
@@ -2188,11 +2188,7 @@ function connectHermes() {
|
||||
}
|
||||
|
||||
const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
|
||||
// WS gateway runs on HTTP port - 115 (8080->8765, 8081->8766)
|
||||
const wsHost = window.location.hostname;
|
||||
const httpPort = parseInt(window.location.port) || 8080;
|
||||
const wsPort = httpPort === 8081 ? 8766 : 8765;
|
||||
const wsUrl = `${protocol}//${wsHost}:${wsPort}/api/world/ws`;
|
||||
const wsUrl = `${protocol}//${window.location.host}/api/world/ws`;
|
||||
|
||||
console.log(`Connecting to Hermes at ${wsUrl}...`);
|
||||
hermesWs = new WebSocket(wsUrl);
|
||||
@@ -2777,8 +2773,8 @@ function connectMemPalace() {
|
||||
}
|
||||
|
||||
// Initialize MCP server connection
|
||||
if (window.Claude && window.Claude.mcp) {
|
||||
window.Claude.mcp.add('mempalace', {
|
||||
// Claude MCP bridge removed — Anthropic purged
|
||||
if (false && window.Claude) {
|
||||
init: () => {
|
||||
return { status: 'active', version: '3.0.0' };
|
||||
},
|
||||
@@ -2955,7 +2951,7 @@ function addChatMessage(agent, text, shouldSave = true) {
|
||||
system: '[NEXUS]',
|
||||
error: '[ERROR]',
|
||||
kimi: '[KIMI]',
|
||||
claude: '[CLAUDE]',
|
||||
gemini: '[GEMINI]',
|
||||
perplexity: '[PERPLEXITY]'
|
||||
};
|
||||
|
||||
@@ -3566,7 +3562,7 @@ function onResize() {
|
||||
|
||||
// ═══ AGENT SIMULATION ═══
|
||||
function simulateAgentThought() {
|
||||
const agentIds = ['timmy', 'kimi', 'claude', 'perplexity'];
|
||||
const agentIds = ['timmy', 'kimi', 'gemini', 'perplexity'];
|
||||
const agentId = agentIds[Math.floor(Math.random() * agentIds.length)];
|
||||
const thoughts = {
|
||||
timmy: [
|
||||
@@ -3583,12 +3579,12 @@ function simulateAgentThought() {
|
||||
'Awaiting user prompt sequence.',
|
||||
'Neural weights adjusted.',
|
||||
],
|
||||
claude: [
|
||||
'Reasoning through complex logic...',
|
||||
'Ethical guardrails verified.',
|
||||
'Refining thought architecture...',
|
||||
'Connecting disparate data points.',
|
||||
'Deep analysis in progress.',
|
||||
gemini: [
|
||||
'Multimodal reasoning engaged...',
|
||||
'Cross-referencing knowledge graph.',
|
||||
'Synthesizing across modalities...',
|
||||
'Pattern recognition complete.',
|
||||
'Gemini processing active.',
|
||||
],
|
||||
perplexity: [
|
||||
'Searching global knowledge graph...',
|
||||
@@ -3877,8 +3873,8 @@ init().then(() => {
|
||||
}
|
||||
|
||||
// Initialize MCP server connection
|
||||
if (window.Claude && window.Claude.mcp) {
|
||||
window.Claude.mcp.add('mempalace', {
|
||||
// Claude MCP bridge removed — Anthropic purged
|
||||
if (false && window.Claude) {
|
||||
init: () => {
|
||||
return { status: 'active', version: '3.0.0' };
|
||||
},
|
||||
|
||||
@@ -8,12 +8,9 @@
|
||||
# Primary: OpenRouter (recommended - access to multiple models)
|
||||
OPENROUTER_API_KEY=sk-or-v1-...
|
||||
DEEPDIVE_LLM_PROVIDER=openrouter
|
||||
DEEPDIVE_LLM_MODEL=anthropic/claude-sonnet-4
|
||||
DEEPDIVE_LLM_MODEL=google/gemini-2.5-pro
|
||||
|
||||
# Alternative: Anthropic direct
|
||||
# ANTHROPIC_API_KEY=sk-ant-...
|
||||
# DEEPDIVE_LLM_PROVIDER=anthropic
|
||||
# DEEPDIVE_LLM_MODEL=claude-3-5-sonnet-20241022
|
||||
# Anthropic purged — Kimi/Gemini/Ollama only
|
||||
|
||||
# Alternative: OpenAI
|
||||
# OPENAI_API_KEY=sk-...
|
||||
|
||||
12
deploy.sh
12
deploy.sh
@@ -1,7 +1,7 @@
|
||||
#!/usr/bin/env bash
|
||||
# deploy.sh — spin up (or update) the Nexus staging environment
|
||||
# Usage: ./deploy.sh — rebuild and restart nexus-main (HTTP :8080, WS :8765)
|
||||
# ./deploy.sh staging — rebuild and restart nexus-staging (HTTP :8081, WS :8766)
|
||||
# Usage: ./deploy.sh — rebuild and restart nexus-main (port 4200)
|
||||
# ./deploy.sh staging — rebuild and restart nexus-staging (port 4201)
|
||||
set -euo pipefail
|
||||
|
||||
SERVICE="${1:-nexus-main}"
|
||||
@@ -14,12 +14,4 @@ esac
|
||||
echo "==> Deploying $SERVICE …"
|
||||
docker compose build "$SERVICE"
|
||||
docker compose up -d --force-recreate "$SERVICE"
|
||||
|
||||
if [ "$SERVICE" = "nexus-main" ]; then
|
||||
echo "==> HTTP: http://localhost:8080"
|
||||
echo "==> WS: ws://localhost:8765"
|
||||
else
|
||||
echo "==> HTTP: http://localhost:8081"
|
||||
echo "==> WS: ws://localhost:8766"
|
||||
fi
|
||||
echo "==> Done. Container: $SERVICE"
|
||||
|
||||
@@ -6,12 +6,10 @@ services:
|
||||
container_name: nexus-main
|
||||
restart: unless-stopped
|
||||
ports:
|
||||
- "8080:8080"
|
||||
- "8765:8765"
|
||||
nexus-staging:
|
||||
build: .
|
||||
container_name: nexus-staging
|
||||
restart: unless-stopped
|
||||
ports:
|
||||
- "8081:8080"
|
||||
- "8766:8765"
|
||||
- "8766:8765"
|
||||
@@ -169,7 +169,7 @@
|
||||
| P-04 | **Autonomous with Oversight** | Work via cron, report to father-messages. Escalate after 30 min. |
|
||||
| P-05 | **Musical Naming** | Names encode personality: Allegro=fast, Adagio=slow, Primus=first child. |
|
||||
| P-06 | **Immutable Inscription** | SOUL.md on-chain. Cannot be edited. The chain remembers everything. |
|
||||
| P-07 | **Fallback Chains** | Every provider: Claude > Kimi > Ollama. Every operation: retry with backoff. |
|
||||
| P-07 | **Fallback Chains** | Every provider: Kimi > Gemini > Ollama. Every operation: retry with backoff. |
|
||||
| P-08 | **Truth in Metrics** | No fakes. All numbers real, measured, verifiable. |
|
||||
|
||||
---
|
||||
|
||||
@@ -1,9 +1,13 @@
|
||||
{
|
||||
"version": 1,
|
||||
"generated": "2026-04-06",
|
||||
"refs": ["#836", "#204", "#195", "#196"],
|
||||
"refs": [
|
||||
"#836",
|
||||
"#204",
|
||||
"#195",
|
||||
"#196"
|
||||
],
|
||||
"description": "Canonical fleet routing table. Evaluated agents, routing verdicts, and dispatch rules for the Timmy Foundation task harness.",
|
||||
|
||||
"agents": [
|
||||
{
|
||||
"id": 27,
|
||||
@@ -46,12 +50,14 @@
|
||||
"location": "Bag End, The Shire (VPS)",
|
||||
"description": "Ollama on VPS. Speaks when spoken to. Prefers quiet. Not for delegated work.",
|
||||
"primary_role": "on-request-queries",
|
||||
"routing_verdict": "ROUTE TO: background monitoring, status checks, low-priority Q&A. Only on-request — do not delegate autonomously.",
|
||||
"routing_verdict": "ROUTE TO: background monitoring, status checks, low-priority Q&A. Only on-request \u2014 do not delegate autonomously.",
|
||||
"active": true,
|
||||
"do_not_route": false,
|
||||
"created": "2026-04-02",
|
||||
"repo_count": 1,
|
||||
"repos": ["bilbobagginshire/bilbo-adventures"]
|
||||
"repos": [
|
||||
"bilbobagginshire/bilbo-adventures"
|
||||
]
|
||||
},
|
||||
{
|
||||
"id": 24,
|
||||
@@ -60,12 +66,12 @@
|
||||
"model": "codex",
|
||||
"tier": "prepaid",
|
||||
"location": "The Harness",
|
||||
"description": "OpenClaw bridge. Protocol adapter layer — not a personality. Infrastructure, not a destination.",
|
||||
"description": "OpenClaw bridge. Protocol adapter layer \u2014 not a personality. Infrastructure, not a destination.",
|
||||
"primary_role": "protocol-bridge",
|
||||
"routing_verdict": "DO NOT ROUTE directly. claw-code is the bridge to external Codex agents, not an endpoint. Remove from routing cascade.",
|
||||
"active": true,
|
||||
"do_not_route": true,
|
||||
"do_not_route_reason": "Protocol layer, not an agent endpoint. See #836 evaluation.",
|
||||
"do_not_route_reason": "Protocol layer, not an agent endpoint. See #836.",
|
||||
"created": "2026-04-01",
|
||||
"repo_count": 0,
|
||||
"repos": []
|
||||
@@ -79,7 +85,7 @@
|
||||
"location": "Below the Surface",
|
||||
"description": "Infrastructure, deployments, bedrock services. Needs model assignment before activation.",
|
||||
"primary_role": "devops",
|
||||
"routing_verdict": "DO NOT ROUTE — no model assigned yet. Activate after Epic #196 (Local Model Fleet) assigns a model.",
|
||||
"routing_verdict": "DO NOT ROUTE \u2014 no model assigned yet. Activate after Epic #196 (Local Model Fleet) assigns a model.",
|
||||
"active": false,
|
||||
"do_not_route": true,
|
||||
"do_not_route_reason": "No model assigned. Blocked on Epic #196.",
|
||||
@@ -97,13 +103,15 @@
|
||||
"location": "The Archive",
|
||||
"description": "Original prototype. Museum piece. Preserved for historical reference only.",
|
||||
"primary_role": "inactive",
|
||||
"routing_verdict": "DO NOT ROUTE — retired from active duty. Preserved only.",
|
||||
"routing_verdict": "DO NOT ROUTE \u2014 retired from active duty. Preserved only.",
|
||||
"active": false,
|
||||
"do_not_route": true,
|
||||
"do_not_route_reason": "Retired prototype. Historical preservation only.",
|
||||
"created": "2026-03-31",
|
||||
"repo_count": 1,
|
||||
"repos": ["allegro-primus/first-steps"]
|
||||
"repos": [
|
||||
"allegro-primus/first-steps"
|
||||
]
|
||||
},
|
||||
{
|
||||
"id": 5,
|
||||
@@ -120,7 +128,10 @@
|
||||
"gap": "Agent description is empty in Gitea profile. Needs enrichment.",
|
||||
"created": "2026-03-14",
|
||||
"repo_count": 2,
|
||||
"repos": ["kimi/the-nexus-fork", "kimi/Timmy-time-dashboard"]
|
||||
"repos": [
|
||||
"kimi/the-nexus-fork",
|
||||
"kimi/Timmy-time-dashboard"
|
||||
]
|
||||
},
|
||||
{
|
||||
"id": 20,
|
||||
@@ -148,10 +159,10 @@
|
||||
"id": 19,
|
||||
"name": "ezra",
|
||||
"gitea_user": "ezra",
|
||||
"model": "claude",
|
||||
"model": "google/gemini-2.5-pro",
|
||||
"tier": "prepaid",
|
||||
"location": "Hermes VPS",
|
||||
"description": "Archivist. Claude-Hermes wizard. 9 repos owned — most in the fleet. Handles complex multi-file and cross-repo work.",
|
||||
"description": "Archivist. Sovereign-Hermes wizard. 9 repos owned \u2014 most in the fleet. Handles complex multi-file and cross-repo work.",
|
||||
"primary_role": "documentation",
|
||||
"routing_verdict": "ROUTE TO: docs, specs, architecture, complex multi-file work. Escalate here when breadth and precision both matter.",
|
||||
"active": true,
|
||||
@@ -176,7 +187,7 @@
|
||||
"gitea_user": "bezalel",
|
||||
"model": "groq",
|
||||
"tier": "free",
|
||||
"location": "TestBed VPS — The Forge",
|
||||
"location": "TestBed VPS \u2014 The Forge",
|
||||
"description": "Builder, debugger, testbed wizard. Groq-powered, free tier. Strong on PR review and CI.",
|
||||
"primary_role": "code-review",
|
||||
"routing_verdict": "ROUTE TO: PR review, test writing, debugging, CI fixes.",
|
||||
@@ -184,29 +195,39 @@
|
||||
"do_not_route": false,
|
||||
"created": "2026-03-29",
|
||||
"repo_count": 1,
|
||||
"repos": ["bezalel/forge-log"]
|
||||
"repos": [
|
||||
"bezalel/forge-log"
|
||||
]
|
||||
}
|
||||
],
|
||||
|
||||
"routing_cascade": {
|
||||
"description": "Cost-optimized routing cascade — cheapest capable agent first, escalate on complexity.",
|
||||
"description": "Cost-optimized routing cascade \u2014 cheapest capable agent first, escalate on complexity.",
|
||||
"tiers": [
|
||||
{
|
||||
"tier": 1,
|
||||
"label": "Free",
|
||||
"agents": ["fenrir", "bezalel", "carnice"],
|
||||
"agents": [
|
||||
"fenrir",
|
||||
"bezalel",
|
||||
"carnice"
|
||||
],
|
||||
"use_for": "Issue triage, code review, local code generation. Default lane for most tasks."
|
||||
},
|
||||
{
|
||||
"tier": 2,
|
||||
"label": "Cheap",
|
||||
"agents": ["kimi", "allegro"],
|
||||
"use_for": "Small scoped edits (kimi ≤3 files), triage decisions and routing (allegro)."
|
||||
"agents": [
|
||||
"kimi",
|
||||
"allegro"
|
||||
],
|
||||
"use_for": "Small scoped edits (kimi \u22643 files), triage decisions and routing (allegro)."
|
||||
},
|
||||
{
|
||||
"tier": 3,
|
||||
"label": "Premium / Escalate",
|
||||
"agents": ["ezra"],
|
||||
"agents": [
|
||||
"ezra"
|
||||
],
|
||||
"use_for": "Complex multi-file work, docs, architecture. Escalate only."
|
||||
}
|
||||
],
|
||||
@@ -217,22 +238,48 @@
|
||||
"allegro-primus: retired, do not route"
|
||||
]
|
||||
},
|
||||
|
||||
"task_type_map": {
|
||||
"issue-triage": ["fenrir", "allegro"],
|
||||
"code-generation": ["carnice", "ezra"],
|
||||
"code-review": ["bezalel"],
|
||||
"small-edit": ["kimi"],
|
||||
"debugging": ["bezalel", "carnice"],
|
||||
"documentation": ["ezra"],
|
||||
"architecture": ["ezra"],
|
||||
"ci-fixes": ["bezalel"],
|
||||
"pr-review": ["bezalel", "fenrir"],
|
||||
"triage-routing": ["allegro"],
|
||||
"devops": ["substratum"],
|
||||
"background-monitoring": ["bilbobagginshire"]
|
||||
"issue-triage": [
|
||||
"fenrir",
|
||||
"allegro"
|
||||
],
|
||||
"code-generation": [
|
||||
"carnice",
|
||||
"ezra"
|
||||
],
|
||||
"code-review": [
|
||||
"bezalel"
|
||||
],
|
||||
"small-edit": [
|
||||
"kimi"
|
||||
],
|
||||
"debugging": [
|
||||
"bezalel",
|
||||
"carnice"
|
||||
],
|
||||
"documentation": [
|
||||
"ezra"
|
||||
],
|
||||
"architecture": [
|
||||
"ezra"
|
||||
],
|
||||
"ci-fixes": [
|
||||
"bezalel"
|
||||
],
|
||||
"pr-review": [
|
||||
"bezalel",
|
||||
"fenrir"
|
||||
],
|
||||
"triage-routing": [
|
||||
"allegro"
|
||||
],
|
||||
"devops": [
|
||||
"substratum"
|
||||
],
|
||||
"background-monitoring": [
|
||||
"bilbobagginshire"
|
||||
]
|
||||
},
|
||||
|
||||
"gaps": [
|
||||
{
|
||||
"agent": "substratum",
|
||||
@@ -255,12 +302,11 @@
|
||||
"action": "Run wolf evaluation on active agents (#195) to replace vibes-based routing with data."
|
||||
}
|
||||
],
|
||||
|
||||
"next_actions": [
|
||||
"Assign model to substratum — Epic #196",
|
||||
"Run wolf evaluation on active agents — Issue #195",
|
||||
"Remove claw-code from routing cascade — it is infrastructure, not a destination",
|
||||
"Assign model to substratum \u2014 Epic #196",
|
||||
"Run wolf evaluation on active agents \u2014 Issue #195",
|
||||
"Remove claw-code from routing cascade \u2014 it is infrastructure, not a destination",
|
||||
"Enrich kimi's Gitea profile description",
|
||||
"Wire fleet-routing.json into workforce-manager.py — Epic #204"
|
||||
"Wire fleet-routing.json into workforce-manager.py \u2014 Epic #204"
|
||||
]
|
||||
}
|
||||
}
|
||||
@@ -1,3 +1,12 @@
|
||||
# Hermes Trismegistus — DEPRECATED (Anthropic Purged)
|
||||
|
||||
> **This lane is inactive.** Anthropic has been removed from the fleet.
|
||||
> Hermes Trismegistus was Claude-native. She can be resurrected with
|
||||
> a sovereign provider (Kimi/Gemini/Ollama) if Alexander decides to
|
||||
> bring her back under a new identity.
|
||||
|
||||
---
|
||||
|
||||
# Hermes Trismegistus — Wizard Proposal
|
||||
|
||||
> **Status:** 🟡 DEFERRED
|
||||
@@ -13,15 +22,15 @@
|
||||
| Field | Value |
|
||||
|-------|-------|
|
||||
| **Name** | Hermes Trismegistus |
|
||||
| **Nature** | Claude-native wizard. She knows she runs on Claude. She's "the daughter of Claude" and leans into that heritage. |
|
||||
| **Purpose** | Dedicated reasoning and architecture wizard. Only handles tasks where Claude's reasoning capability genuinely adds value — planning, novel problem-solving, complex architecture decisions. |
|
||||
| **Nature** | ~~Claude-native~~ DEPRECATED. Was "the daughter of Claude." Anthropic purged from fleet. |
|
||||
| **Purpose** | DEPRECATED. Was dedicated reasoning wizard. Can be resurrected under sovereign providers. |ns. |
|
||||
| **Not** | A replacement for Timmy. Not competing for identity. Not doing monkey work. |
|
||||
|
||||
## Design Constraints
|
||||
|
||||
- **Free tier only from day one.** Alexander is not paying Anthropic beyond current subscription.
|
||||
- ~~Free tier only from day one.~~ Anthropic purged — no active subscription.
|
||||
- **Degrades gracefully.** Full capability when free tier is generous, reduced scope when constrained.
|
||||
- **Not locked to Claude.** If better free-tier providers emerge, she can route to them.
|
||||
- ~~Not locked to Claude.~~ Lane locked — Anthropic removed from fleet.
|
||||
- **Multi-provider capable.** Welcome to become multifaceted if team finds better options.
|
||||
|
||||
## Hardware
|
||||
@@ -44,13 +53,13 @@ All of the following must be true before implementation begins:
|
||||
- [ ] Deadman switch wired and proven
|
||||
- [ ] Config stable across fleet
|
||||
- [ ] Fleet proven reliable for 1+ week
|
||||
- [ ] Alexander provides a state-of-the-system KT to Claude for instantiation
|
||||
- [ ] DEPRECATED — Anthropic provider removed
|
||||
|
||||
## Acceptance Criteria
|
||||
|
||||
- [ ] Dedicated KT document written for Hermes instantiation
|
||||
- [ ] Hardware provisioned (shed laptop with power)
|
||||
- [ ] Hermes harness configured for Claude free tier
|
||||
- [ ] DEPRECATED — Anthropic provider removed
|
||||
- [ ] Lazerus registry entry with health endpoints
|
||||
- [ ] Fleet routing entry with role and routing verdict
|
||||
- [ ] SOUL.md inscription drafted and reviewed by Timmy
|
||||
@@ -60,7 +69,7 @@ All of the following must be true before implementation begins:
|
||||
## Proposed Lane
|
||||
|
||||
**Primary role:** Architecture reasoning
|
||||
**Routing verdict:** ROUTE TO: complex architectural decisions, novel problem-solving, planning tasks that benefit from Claude's reasoning depth. Do NOT route to: code generation (use Timmy/Carnice), issue triage (use Fenrir), or operational tasks (use Bezalel).
|
||||
**Routing verdict:** DO NOT ROUTE — lane deprecated. Anthropic purged from fleet.issue triage (use Fenrir), or operational tasks (use Bezalel).
|
||||
|
||||
## Dependencies
|
||||
|
||||
@@ -69,4 +78,4 @@ All of the following must be true before implementation begins:
|
||||
| Deadman switch | 🔴 Not done | Must be proven before unblocking |
|
||||
| Fleet stability | 🟡 In progress | 1+ week uptime needed |
|
||||
| Shed laptop power | 🔴 Not done | Alexander needs to wire power |
|
||||
| KT document | 🔴 Not drafted | Alexander provides to Claude at unblock time |
|
||||
| KT document | ⛔ DEPRECATED | Anthropic purged |
|
||||
|
||||
@@ -7,13 +7,13 @@
|
||||
|
||||
## Role
|
||||
|
||||
Dedicated reasoning and architecture wizard. Claude-native.
|
||||
Dedicated reasoning and architecture wizard. DEPRECATED — Anthropic purged.
|
||||
|
||||
## Routing
|
||||
|
||||
Route to Hermes Trismegistus when:
|
||||
- Task requires deep architectural reasoning
|
||||
- Novel problem-solving that benefits from Claude's reasoning depth
|
||||
- DEPRECATED: Anthropic provider removed from fleet
|
||||
- Planning and design decisions for the fleet
|
||||
- Complex multi-step analysis that goes beyond code generation
|
||||
|
||||
@@ -25,8 +25,8 @@ Do NOT route to Hermes for:
|
||||
|
||||
## Provider
|
||||
|
||||
- **Primary:** anthropic/claude (free tier)
|
||||
- **Fallback:** openrouter/free (Claude-class models)
|
||||
- **Primary:** DEPRECATED — no active provider
|
||||
- **Fallback:** N/A — lane inactive
|
||||
- **Degraded:** ollama/gemma4:12b (when free tier exhausted)
|
||||
|
||||
## Hardware
|
||||
|
||||
@@ -152,7 +152,7 @@ curl http://localhost:4000/v1/models
|
||||
|
||||
If the endpoint is down, either:
|
||||
1. Start it: `llama-server -m model.gguf --port 4000 -ngl 999 --jinja`
|
||||
2. Or change `synthesis.llm_endpoint` in `config.yaml` to an alternative (e.g., OpenRouter, Kimi, Anthropic).
|
||||
2. Or change `synthesis.llm_endpoint` in `config.yaml` to an alternative (e.g., OpenRouter, Kimi, Gemini).
|
||||
|
||||
---
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@
|
||||
| arXiv cs.CL | http://export.arxiv.org/rss/cs.CL | RSS | Daily |
|
||||
| arXiv cs.LG | http://export.arxiv.org/rss/cs.LG | RSS | Daily |
|
||||
| OpenAI Blog | https://openai.com/blog/rss.xml | RSS | On-update |
|
||||
| Anthropic | https://www.anthropic.com/blog/rss.xml | RSS | On-update |
|
||||
| Anthropic | https://www.anthropic.com/blog/rss.xml | RSS | On-update | (competitor monitoring, not provider) |
|
||||
| DeepMind | https://deepmind.google/blog/rss.xml | RSS | On-update |
|
||||
| Import AI | https://importai.substack.com/feed | RSS | Daily |
|
||||
| TLDR AI | https://tldr.tech/ai/rss | RSS | Daily |
|
||||
|
||||
@@ -323,15 +323,15 @@
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Claude — thinking -->
|
||||
<!-- Gemini — thinking -->
|
||||
<div class="agent-row">
|
||||
<div class="agent-avatar thinking" style="color:#a08cff">C
|
||||
<div class="status-pip thinking"></div>
|
||||
</div>
|
||||
<div class="agent-info">
|
||||
<div class="agent-name">Claude</div>
|
||||
<div class="agent-name">Gemini</div>
|
||||
<div class="agent-location">
|
||||
<span class="loc-icon">⊕</span>Workshop — claude/issue-749
|
||||
<span class="loc-icon">⊕</span>Workshop — standby
|
||||
</div>
|
||||
<div class="agent-bark">"Building nexus/components/ ..."</div>
|
||||
</div>
|
||||
|
||||
@@ -349,7 +349,7 @@
|
||||
<div class="action-item">
|
||||
<div class="action-bullet bullet-normal">→</div>
|
||||
<div class="action-text">
|
||||
Claude: PR for #749 (Vibe Code components) awaiting review
|
||||
Gemini: Standby — no active tasks
|
||||
<span class="tag tag-pr">PR #52</span>
|
||||
</div>
|
||||
</div>
|
||||
@@ -378,7 +378,7 @@
|
||||
Hermes routed 214 messages, Archive wrote 88 new memories.
|
||||
Satflow hit a <strong>rate-limit wall</strong> at 03:14 UTC; queue is draining slowly.
|
||||
Gemini completed its sovereignty sweep; no critical findings.
|
||||
Claude is mid-sprint on <strong>issue #749</strong> — component prototypes landing today.
|
||||
Gemini is on standby. No active sprints.
|
||||
</div>
|
||||
</div>
|
||||
|
||||
|
||||
@@ -158,7 +158,7 @@
|
||||
}
|
||||
},
|
||||
"agents_present": [
|
||||
"claude"
|
||||
"gemini"
|
||||
],
|
||||
"interaction_ready": true
|
||||
},
|
||||
|
||||
16
run.sh
16
run.sh
@@ -1,16 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
# run.sh — run Nexus locally without Docker
|
||||
# Usage: ./run.sh — HTTP :8080, WS :8765
|
||||
# NEXUS_HTTP_PORT=9090 ./run.sh — custom HTTP port
|
||||
set -euo pipefail
|
||||
|
||||
cd "$(dirname "$0")"
|
||||
|
||||
# Install deps if missing
|
||||
if ! python3 -c "import websockets" 2>/dev/null; then
|
||||
echo "==> Installing dependencies..."
|
||||
pip3 install -r requirements.txt
|
||||
fi
|
||||
|
||||
echo "==> Starting Nexus server..."
|
||||
exec python3 server.py
|
||||
@@ -8,8 +8,8 @@ TELEGRAM_BOT_TOKEN=your_bot_token_here
|
||||
TELEGRAM_CHANNEL_ID=-1001234567890
|
||||
|
||||
# Optional: LLM API for synthesis (defaults to local routing)
|
||||
# ANTHROPIC_API_KEY=sk-...
|
||||
# OPENROUTER_API_KEY=sk-...
|
||||
# Anthropic purged — Kimi/Gemini/Ollama only
|
||||
# OPENROUTER_API_KEY=***
|
||||
|
||||
# Optional: Custom paths
|
||||
# OUTPUT_DIR=./output
|
||||
|
||||
@@ -14,7 +14,7 @@ from typing import List, Optional
|
||||
@dataclass
|
||||
class BlogPost:
|
||||
title: str
|
||||
source: str # "openai", "anthropic", "deepmind", etc.
|
||||
source: str # "openai", "anthropic", "deepmind", etc. — research sources, not providers
|
||||
url: str
|
||||
published: datetime
|
||||
summary: str
|
||||
|
||||
@@ -24,7 +24,7 @@ Generate a structured briefing in this format:
|
||||
### 📊 Deep Dives (2-3 items)
|
||||
|
||||
#### [Most Relevant Item Title]
|
||||
**Source:** arXiv:XXXX.XXXXX / OpenAI Blog / Anthropic Research
|
||||
**Source:** arXiv:XXXX.XXXXX / OpenAI Blog / DeepMind Research
|
||||
**Why it matters:** 2-3 sentences on implications for agent architecture, tooling, or infrastructure
|
||||
**Key insight:** The core technical contribution or finding
|
||||
**Action for us:** Specific recommendation (e.g., "Evaluate for RAG pipeline", "Consider for RL environment")
|
||||
@@ -53,7 +53,7 @@ Brief synthesis of trends and how they affect:
|
||||
|
||||
## Context to Inject
|
||||
Hermes is an open-source AI agent framework with:
|
||||
- Multi-model support (Claude, GPT, local LLMs)
|
||||
- Multi-model support (Kimi, Gemini, local LLMs)
|
||||
- Rich tool ecosystem (terminal, file, web, browser, code execution)
|
||||
- Gateway architecture for messaging platforms (Telegram, Discord, Slack)
|
||||
- MCP (Model Context Protocol) integration
|
||||
|
||||
233
server.py
233
server.py
@@ -1,190 +1,92 @@
|
||||
#!/usr/bin/env python3
|
||||
"""
|
||||
The Nexus — Unified HTTP + WebSocket server.
|
||||
|
||||
Serves static frontend files (Three.js app) over HTTP on port 8080
|
||||
and runs the WebSocket gateway on port 8765.
|
||||
Single-process, single-command deployment — no nginx required.
|
||||
The Nexus WebSocket Gateway — Robust broadcast bridge for Timmy's consciousness.
|
||||
This server acts as the central hub for the-nexus, connecting the mind (nexus_think.py),
|
||||
the body (Evennia/Morrowind), and the visualization surface.
|
||||
"""
|
||||
import asyncio
|
||||
import json
|
||||
import logging
|
||||
import mimetypes
|
||||
import os
|
||||
import signal
|
||||
import sys
|
||||
from http import HTTPStatus
|
||||
from pathlib import Path
|
||||
from typing import Set
|
||||
|
||||
# Branch protected file - see POLICY.md
|
||||
import websockets
|
||||
import websockets.asyncio.server
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# Configuration
|
||||
# ---------------------------------------------------------------------------
|
||||
HTTP_PORT = int(os.environ.get("NEXUS_HTTP_PORT", "8080"))
|
||||
WS_PORT = int(os.environ.get("NEXUS_WS_PORT", "8765"))
|
||||
HOST = os.environ.get("NEXUS_HOST", "0.0.0.0")
|
||||
ROOT = Path(__file__).resolve().parent
|
||||
PORT = 8765
|
||||
HOST = "0.0.0.0" # Allow external connections if needed
|
||||
|
||||
# Static file extensions we're willing to serve
|
||||
SAFE_SUFFIXES = {
|
||||
".html", ".htm", ".css", ".js", ".mjs", ".json",
|
||||
".png", ".jpg", ".jpeg", ".gif", ".svg", ".ico",
|
||||
".woff", ".woff2", ".ttf", ".eot",
|
||||
".txt", ".xml", ".webmanifest",
|
||||
}
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# Logging
|
||||
# ---------------------------------------------------------------------------
|
||||
# Logging setup
|
||||
logging.basicConfig(
|
||||
level=logging.INFO,
|
||||
format="%(asctime)s [%(levelname)s] %(message)s",
|
||||
datefmt="%Y-%m-%d %H:%M:%S",
|
||||
format='%(asctime)s [%(levelname)s] %(message)s',
|
||||
datefmt='%Y-%m-%d %H:%M:%S'
|
||||
)
|
||||
log = logging.getLogger("nexus")
|
||||
logger = logging.getLogger("nexus-gateway")
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# HTTP — static file server
|
||||
# ---------------------------------------------------------------------------
|
||||
async def http_handler(reader: asyncio.StreamReader, writer: asyncio.StreamWriter):
|
||||
"""Minimal async HTTP/1.1 server for static files."""
|
||||
try:
|
||||
# Read request line + headers (max 8 KB)
|
||||
data = b""
|
||||
while b"\r\n\r\n" not in data and len(data) < 8192:
|
||||
chunk = await asyncio.wait_for(reader.read(4096), timeout=10)
|
||||
if not chunk:
|
||||
return
|
||||
data += chunk
|
||||
header_text = data.split(b"\r\n\r\n", 1)[0].decode("utf-8", errors="replace")
|
||||
lines = header_text.split("\r\n")
|
||||
request_line = lines[0]
|
||||
parts = request_line.split(" ", 2)
|
||||
if len(parts) < 2:
|
||||
writer.close()
|
||||
return
|
||||
method, raw_path = parts[0], parts[1]
|
||||
# State
|
||||
clients: Set[websockets.WebSocketServerProtocol] = set()
|
||||
|
||||
if method not in ("GET", "HEAD"):
|
||||
_write_response(writer, HTTPStatus.METHOD_NOT_ALLOWED, b"Method Not Allowed")
|
||||
return
|
||||
|
||||
# Normalise path — prevent directory traversal
|
||||
safe_path = raw_path.split("?", 1)[0].split("#", 1)[0]
|
||||
safe_path = os.path.normpath(safe_path).lstrip("/")
|
||||
if not safe_path:
|
||||
safe_path = "index.html"
|
||||
|
||||
file_path = ROOT / safe_path
|
||||
# Reject traversal
|
||||
if not str(file_path.resolve()).startswith(str(ROOT)):
|
||||
_write_response(writer, HTTPStatus.FORBIDDEN, b"Forbidden")
|
||||
return
|
||||
|
||||
if not file_path.exists() or file_path.is_dir():
|
||||
# Try index.html for directories
|
||||
if file_path.is_dir() and (file_path / "index.html").exists():
|
||||
file_path = file_path / "index.html"
|
||||
else:
|
||||
_write_response(writer, HTTPStatus.NOT_FOUND, b"Not Found")
|
||||
return
|
||||
|
||||
suffix = file_path.suffix.lower()
|
||||
if suffix not in SAFE_SUFFIXES:
|
||||
_write_response(writer, HTTPStatus.FORBIDDEN, b"Forbidden")
|
||||
return
|
||||
|
||||
content_type = mimetypes.guess_type(str(file_path))[0] or "application/octet-stream"
|
||||
body = file_path.read_bytes()
|
||||
headers = {
|
||||
"Content-Type": content_type,
|
||||
"Content-Length": str(len(body)),
|
||||
"Cache-Control": "no-cache",
|
||||
"Access-Control-Allow-Origin": "*",
|
||||
}
|
||||
_write_response(writer, HTTPStatus.OK, body, headers, method == "HEAD")
|
||||
except (asyncio.TimeoutError, ConnectionError):
|
||||
pass
|
||||
except Exception as exc:
|
||||
log.warning("HTTP handler error: %s", exc)
|
||||
finally:
|
||||
try:
|
||||
writer.close()
|
||||
await writer.wait_closed()
|
||||
except Exception:
|
||||
pass
|
||||
|
||||
|
||||
def _write_response(writer, status, body, headers=None, head_only=False):
|
||||
line = f"HTTP/1.1 {status.value} {status.phrase}\r\n"
|
||||
hdr = ""
|
||||
if headers:
|
||||
for k, v in headers.items():
|
||||
hdr += f"{k}: {v}\r\n"
|
||||
response = (line + hdr + "\r\n").encode()
|
||||
if not head_only:
|
||||
response += body if isinstance(body, bytes) else body.encode()
|
||||
writer.write(response)
|
||||
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# WebSocket — broadcast gateway
|
||||
# ---------------------------------------------------------------------------
|
||||
ws_clients: Set[websockets.asyncio.server.ServerConnection] = set()
|
||||
|
||||
|
||||
async def ws_handler(websocket: websockets.asyncio.server.ServerConnection):
|
||||
ws_clients.add(websocket)
|
||||
log.info("WS client connected from %s. Total: %d", websocket.remote_address, len(ws_clients))
|
||||
async def broadcast_handler(websocket: websockets.WebSocketServerProtocol):
|
||||
"""Handles individual client connections and message broadcasting."""
|
||||
clients.add(websocket)
|
||||
addr = websocket.remote_address
|
||||
logger.info(f"Client connected from {addr}. Total clients: {len(clients)}")
|
||||
|
||||
try:
|
||||
async for message in websocket:
|
||||
# Parse for logging/validation if it's JSON
|
||||
try:
|
||||
data = json.loads(message)
|
||||
msg_type = data.get("type", "unknown")
|
||||
if msg_type in ("agent_register", "thought", "action"):
|
||||
log.debug("WS %s from %s", msg_type, websocket.remote_address)
|
||||
# Optional: log specific important message types
|
||||
if msg_type in ["agent_register", "thought", "action"]:
|
||||
logger.debug(f"Received {msg_type} from {addr}")
|
||||
except (json.JSONDecodeError, TypeError):
|
||||
pass
|
||||
|
||||
# Broadcast to all OTHER clients
|
||||
if not clients:
|
||||
continue
|
||||
|
||||
disconnected = set()
|
||||
for client in ws_clients:
|
||||
# Create broadcast tasks, tracking which client each task targets
|
||||
task_client_pairs = []
|
||||
for client in clients:
|
||||
if client != websocket and client.open:
|
||||
try:
|
||||
await client.send(message)
|
||||
except Exception:
|
||||
disconnected.add(client)
|
||||
ws_clients.difference_update(disconnected)
|
||||
task = asyncio.create_task(client.send(message))
|
||||
task_client_pairs.append((task, client))
|
||||
|
||||
if task_client_pairs:
|
||||
tasks = [pair[0] for pair in task_client_pairs]
|
||||
results = await asyncio.gather(*tasks, return_exceptions=True)
|
||||
for i, result in enumerate(results):
|
||||
if isinstance(result, Exception):
|
||||
target_client = task_client_pairs[i][1]
|
||||
logger.error(f"Failed to send to client {target_client.remote_address}: {result}")
|
||||
disconnected.add(target_client)
|
||||
|
||||
if disconnected:
|
||||
clients.difference_update(disconnected)
|
||||
|
||||
except websockets.exceptions.ConnectionClosed:
|
||||
pass
|
||||
except Exception as exc:
|
||||
log.error("WS handler error for %s: %s", websocket.remote_address, exc)
|
||||
logger.debug(f"Connection closed by client {addr}")
|
||||
except Exception as e:
|
||||
logger.error(f"Error handling client {addr}: {e}")
|
||||
finally:
|
||||
ws_clients.discard(websocket)
|
||||
log.info("WS client disconnected. Total: %d", len(ws_clients))
|
||||
clients.discard(websocket)
|
||||
logger.info(f"Client disconnected {addr}. Total clients: {len(clients)}")
|
||||
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
# Main — run both servers concurrently
|
||||
# ---------------------------------------------------------------------------
|
||||
async def main():
|
||||
# HTTP server
|
||||
http_server = await asyncio.start_server(http_handler, HOST, HTTP_PORT)
|
||||
log.info("HTTP server listening on http://%s:%d", HOST, HTTP_PORT)
|
||||
|
||||
# WebSocket server
|
||||
ws_server = await websockets.asyncio.server.serve(ws_handler, HOST, WS_PORT)
|
||||
log.info("WebSocket server listening on ws://%s:%d", HOST, WS_PORT)
|
||||
log.info("Nexus is live — open http://%s:%d in a browser", HOST, HTTP_PORT)
|
||||
|
||||
# Graceful shutdown
|
||||
"""Main server loop with graceful shutdown."""
|
||||
logger.info(f"Starting Nexus WS gateway on ws://{HOST}:{PORT}")
|
||||
|
||||
# Set up signal handlers for graceful shutdown
|
||||
loop = asyncio.get_running_loop()
|
||||
stop = loop.create_future()
|
||||
|
||||
|
||||
def shutdown():
|
||||
if not stop.done():
|
||||
stop.set_result(None)
|
||||
@@ -193,28 +95,29 @@ async def main():
|
||||
try:
|
||||
loop.add_signal_handler(sig, shutdown)
|
||||
except NotImplementedError:
|
||||
# Signal handlers not supported on Windows
|
||||
pass
|
||||
|
||||
await stop
|
||||
log.info("Shutting down...")
|
||||
|
||||
http_server.close()
|
||||
await http_server.wait_closed()
|
||||
ws_server.close()
|
||||
await ws_server.wait_closed()
|
||||
|
||||
remaining = {c for c in ws_clients if c.open}
|
||||
async with websockets.serve(broadcast_handler, HOST, PORT):
|
||||
logger.info("Gateway is ready and listening.")
|
||||
await stop
|
||||
|
||||
logger.info("Shutting down Nexus WS gateway...")
|
||||
# Close any remaining client connections (handlers may have already cleaned up)
|
||||
remaining = {c for c in clients if c.open}
|
||||
if remaining:
|
||||
await asyncio.gather(*(c.close() for c in remaining), return_exceptions=True)
|
||||
ws_clients.clear()
|
||||
log.info("Shutdown complete.")
|
||||
|
||||
logger.info(f"Closing {len(remaining)} active connections...")
|
||||
close_tasks = [client.close() for client in remaining]
|
||||
await asyncio.gather(*close_tasks, return_exceptions=True)
|
||||
clients.clear()
|
||||
|
||||
logger.info("Shutdown complete.")
|
||||
|
||||
if __name__ == "__main__":
|
||||
try:
|
||||
asyncio.run(main())
|
||||
except KeyboardInterrupt:
|
||||
pass
|
||||
except Exception as exc:
|
||||
log.critical("Fatal: %s", exc)
|
||||
except Exception as e:
|
||||
logger.critical(f"Fatal server error: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
@@ -869,7 +869,7 @@ canvas#nexus-canvas {
|
||||
}
|
||||
.tag-timmy { color: var(--color-primary); }
|
||||
.tag-kimi { color: var(--color-secondary); }
|
||||
.tag-claude { color: var(--color-gold); }
|
||||
.tag-gemini { color: var(--color-gold); }
|
||||
.tag-perplexity { color: #4488ff; }
|
||||
.agent-log-text {
|
||||
color: var(--color-text-muted);
|
||||
@@ -1243,7 +1243,7 @@ canvas#nexus-canvas {
|
||||
font-weight: 700;
|
||||
}
|
||||
.chat-msg-kimi .chat-msg-prefix { color: var(--color-secondary); }
|
||||
.chat-msg-claude .chat-msg-prefix { color: var(--color-gold); }
|
||||
.chat-msg-gemini .chat-msg-prefix { color: var(--color-gold); }
|
||||
.chat-msg-perplexity .chat-msg-prefix { color: #4488ff; }
|
||||
|
||||
/* Tool Output Styling */
|
||||
|
||||
@@ -165,7 +165,7 @@
|
||||
"goal": "observe",
|
||||
"memory": []
|
||||
},
|
||||
"Claude": {
|
||||
"Gemini": {
|
||||
"personality": {
|
||||
"Threshold": 0.25,
|
||||
"Tower": 0.25,
|
||||
|
||||
Reference in New Issue
Block a user