Compare commits

..

1 Commits

Author SHA1 Message Date
Alexander Whitestone
fdc02dc121 fix: [PORTALS] Build a portal atlas / world directory for all current and future worlds (closes #712)
Some checks failed
CI / test (pull_request) Failing after 10s
CI / validate (pull_request) Failing after 16s
Review Approval Gate / verify-review (pull_request) Failing after 3s
2026-04-12 11:52:12 -04:00
8 changed files with 247 additions and 161 deletions

115
app.js
View File

@@ -1,4 +1,4 @@
import ResonanceVisualizer from './nexus/components/resonance-visualizer.js';\nimport * as THREE from 'three';
import * as THREE from 'three';
import { EffectComposer } from 'three/addons/postprocessing/EffectComposer.js';
import { RenderPass } from 'three/addons/postprocessing/RenderPass.js';
import { UnrealBloomPass } from 'three/addons/postprocessing/UnrealBloomPass.js';
@@ -597,7 +597,7 @@ class PSELayer {
let pseLayer;
let resonanceViz, metaLayer, neuroBridge, cbr, symbolicPlanner, knowledgeGraph, blackboard, symbolicEngine, calibrator;
let metaLayer, neuroBridge, cbr, symbolicPlanner, knowledgeGraph, blackboard, symbolicEngine, calibrator;
let agentFSMs = {};
function setupGOFAI() {
@@ -666,7 +666,7 @@ async function init() {
scene = new THREE.Scene();
scene.fog = new THREE.FogExp2(0x050510, 0.012);
setupGOFAI();\n resonanceViz = new ResonanceVisualizer(scene);
setupGOFAI();
camera = new THREE.PerspectiveCamera(65, window.innerWidth / window.innerHeight, 0.1, 1000);
camera.position.copy(playerPos);
@@ -2032,6 +2032,7 @@ function setupControls() {
document.getElementById('atlas-toggle-btn').addEventListener('click', openPortalAtlas);
document.getElementById('atlas-close-btn').addEventListener('click', closePortalAtlas);
initAtlasControls();
}
function sendChatMessage(overrideText = null) {
@@ -2815,58 +2816,142 @@ function closeVisionOverlay() {
document.getElementById('vision-overlay').style.display = 'none';
}
// ═══ PORTAL ATLAS ═══
// ═══ PORTAL ATLAS / WORLD DIRECTORY ═══
let atlasActiveFilter = 'all';
let atlasSearchQuery = '';
function openPortalAtlas() {
atlasOverlayActive = true;
document.getElementById('atlas-overlay').style.display = 'flex';
populateAtlas();
// Focus search input
setTimeout(() => document.getElementById('atlas-search')?.focus(), 100);
}
function closePortalAtlas() {
atlasOverlayActive = false;
document.getElementById('atlas-overlay').style.display = 'none';
atlasSearchQuery = '';
atlasActiveFilter = 'all';
}
function initAtlasControls() {
const searchInput = document.getElementById('atlas-search');
if (searchInput) {
searchInput.addEventListener('input', (e) => {
atlasSearchQuery = e.target.value.toLowerCase().trim();
populateAtlas();
});
}
const filterBtns = document.querySelectorAll('.atlas-filter-btn');
filterBtns.forEach(btn => {
btn.addEventListener('click', () => {
filterBtns.forEach(b => b.classList.remove('active'));
btn.classList.add('active');
atlasActiveFilter = btn.dataset.filter;
populateAtlas();
});
});
}
function matchesAtlasFilter(config) {
if (atlasActiveFilter === 'all') return true;
if (atlasActiveFilter === 'harness') return (config.portal_type || 'harness') === 'harness' || !config.portal_type;
if (atlasActiveFilter === 'game-world') return config.portal_type === 'game-world';
return config.status === atlasActiveFilter;
}
function matchesAtlasSearch(config) {
if (!atlasSearchQuery) return true;
const haystack = [config.name, config.description, config.id,
config.world_category, config.portal_type, config.destination?.type]
.filter(Boolean).join(' ').toLowerCase();
return haystack.includes(atlasSearchQuery);
}
function populateAtlas() {
const grid = document.getElementById('atlas-grid');
grid.innerHTML = '';
let onlineCount = 0;
let standbyCount = 0;
let downloadedCount = 0;
let visibleCount = 0;
portals.forEach(portal => {
const config = portal.config;
if (config.status === 'online') onlineCount++;
if (config.status === 'standby') standbyCount++;
if (config.status === 'downloaded') downloadedCount++;
if (!matchesAtlasFilter(config) || !matchesAtlasSearch(config)) return;
visibleCount++;
const card = document.createElement('div');
card.className = 'atlas-card';
card.style.setProperty('--portal-color', config.color);
const statusClass = `status-${config.status || 'online'}`;
const statusLabel = (config.status || 'ONLINE').toUpperCase();
const portalType = config.portal_type || 'harness';
const categoryLabel = config.world_category
? config.world_category.replace(/-/g, ' ').toUpperCase()
: portalType.replace(/-/g, ' ').toUpperCase();
// Readiness bar for game-worlds
let readinessHTML = '';
if (config.readiness_steps) {
const steps = Object.values(config.readiness_steps);
readinessHTML = `<div class="atlas-card-readiness" title="Readiness: ${steps.filter(s=>s.done).length}/${steps.length}">`;
steps.forEach(step => {
readinessHTML += `<div class="readiness-step ${step.done ? 'done' : ''}" title="${step.label}${step.done ? ' ✓' : ''}"></div>`;
});
readinessHTML += '</div>';
}
// Action label
const actionLabel = config.destination?.action_label
|| (config.status === 'online' ? 'ENTER' : config.status === 'downloaded' ? 'LAUNCH' : 'VIEW');
card.innerHTML = `
<div class="atlas-card-header">
<div class="atlas-card-name">${config.name}</div>
<div class="atlas-card-status ${statusClass}">${config.status || 'ONLINE'}</div>
<div>
<span class="atlas-card-name">${config.name}</span>
<span class="atlas-card-category">${categoryLabel}</span>
</div>
<div class="atlas-card-status ${statusClass}">${statusLabel}</div>
</div>
<div class="atlas-card-desc">${config.description}</div>
${readinessHTML}
<div class="atlas-card-footer">
<div class="atlas-card-coord">X:${config.position.x} Z:${config.position.z}</div>
<div class="atlas-card-type">${config.destination?.type?.toUpperCase() || 'UNKNOWN'}</div>
<div class="atlas-card-action">${actionLabel}</div>
</div>
`;
card.addEventListener('click', () => {
focusPortal(portal);
closePortalAtlas();
});
grid.appendChild(card);
});
// Show empty state
if (visibleCount === 0) {
const empty = document.createElement('div');
empty.className = 'atlas-empty';
empty.textContent = atlasSearchQuery
? `No worlds match "${atlasSearchQuery}"`
: 'No worlds in this category';
grid.appendChild(empty);
}
document.getElementById('atlas-online-count').textContent = onlineCount;
document.getElementById('atlas-standby-count').textContent = standbyCount;
document.getElementById('atlas-downloaded-count').textContent = downloadedCount;
document.getElementById('atlas-total-count').textContent = portals.length;
// Update Bannerlord HUD status
const bannerlord = portals.find(p => p.config.id === 'bannerlord');

View File

@@ -113,9 +113,9 @@
<!-- Top Right: Agent Log & Atlas Toggle -->
<div class="hud-top-right">
<button id="atlas-toggle-btn" class="hud-icon-btn" title="Portal Atlas">
<button id="atlas-toggle-btn" class="hud-icon-btn" title="World Directory">
<span class="hud-icon">🌐</span>
<span class="hud-btn-label">ATLAS</span>
<span class="hud-btn-label">WORLDS</span>
</button>
<div id="bannerlord-status" class="hud-status-item" title="Bannerlord Readiness">
<span class="status-dot"></span>
@@ -214,20 +214,35 @@
<div class="atlas-header">
<div class="atlas-title">
<span class="atlas-icon">🌐</span>
<h2>PORTAL ATLAS</h2>
<h2>WORLD DIRECTORY</h2>
</div>
<button id="atlas-close-btn" class="atlas-close-btn">CLOSE</button>
</div>
<div class="atlas-controls">
<input type="text" id="atlas-search" class="atlas-search" placeholder="Search worlds..." autocomplete="off" />
<div class="atlas-filters" id="atlas-filters">
<button class="atlas-filter-btn active" data-filter="all">ALL</button>
<button class="atlas-filter-btn" data-filter="online">ONLINE</button>
<button class="atlas-filter-btn" data-filter="standby">STANDBY</button>
<button class="atlas-filter-btn" data-filter="downloaded">DOWNLOADED</button>
<button class="atlas-filter-btn" data-filter="harness">HARNESS</button>
<button class="atlas-filter-btn" data-filter="game-world">GAME</button>
</div>
</div>
<div class="atlas-grid" id="atlas-grid">
<!-- Portals will be injected here -->
<!-- Worlds will be injected here -->
</div>
<div class="atlas-footer">
<div class="atlas-status-summary">
<span class="status-indicator online"></span> <span id="atlas-online-count">0</span> ONLINE
&nbsp;&nbsp;
<span class="status-indicator standby"></span> <span id="atlas-standby-count">0</span> STANDBY
&nbsp;&nbsp;
<span class="status-indicator downloaded"></span> <span id="atlas-downloaded-count">0</span> DOWNLOADED
&nbsp;&nbsp;
<span class="atlas-total">| <span id="atlas-total-count">0</span> WORLDS TOTAL</span>
</div>
<div class="atlas-hint">Click a portal to focus or teleport</div>
<div class="atlas-hint">Click a world to focus or enter</div>
</div>
</div>
</div>

View File

@@ -1,18 +1,13 @@
class MemoryOptimizer {
constructor(options = {}) {
this.threshold = options.threshold || 0.3;
this.decayRate = options.decayRate || 0.01;
this.lastRun = Date.now();
this.threshold = options.threshold || 0.8;
this.decayRate = options.decayRate || 0.05;
}
optimize(memories) {
const now = Date.now();
const elapsed = (now - this.lastRun) / 1000;
this.lastRun = now;
return memories.map(m => {
const decay = (m.importance || 1) * this.decayRate * elapsed;
return { ...m, strength: Math.max(0, (m.strength || 1) - decay) };
}).filter(m => m.strength > this.threshold || m.locked);
optimize(memory) {
console.log('Optimizing memory...');
// Heuristic-based pruning
return memory.filter(m => m.strength > this.threshold);
}
}
export default MemoryOptimizer;

View File

@@ -243,108 +243,24 @@ async def playback(log_path: Path, ws_url: str):
await ws.send(json.dumps(event))
async def inject_event(event_type: str, ws_url: str, **kwargs):
"""Inject a single Evennia event into the Nexus WS gateway. Dev/test use."""
from nexus.evennia_event_adapter import (
actor_located, command_issued, command_result,
room_snapshot, session_bound,
)
builders = {
"room_snapshot": lambda: room_snapshot(
kwargs.get("room_key", "Gate"),
kwargs.get("title", "Gate"),
kwargs.get("desc", "The entrance gate."),
exits=kwargs.get("exits"),
objects=kwargs.get("objects"),
),
"actor_located": lambda: actor_located(
kwargs.get("actor_id", "Timmy"),
kwargs.get("room_key", "Gate"),
kwargs.get("room_name"),
),
"command_result": lambda: command_result(
kwargs.get("session_id", "dev-inject"),
kwargs.get("actor_id", "Timmy"),
kwargs.get("command_text", "look"),
kwargs.get("output_text", "You see the Gate."),
success=kwargs.get("success", True),
),
"command_issued": lambda: command_issued(
kwargs.get("session_id", "dev-inject"),
kwargs.get("actor_id", "Timmy"),
kwargs.get("command_text", "look"),
),
"session_bound": lambda: session_bound(
kwargs.get("session_id", "dev-inject"),
kwargs.get("account", "Timmy"),
kwargs.get("character", "Timmy"),
),
}
if event_type not in builders:
print(f"[inject] Unknown event type: {event_type}", flush=True)
print(f"[inject] Available: {', '.join(builders)}", flush=True)
sys.exit(1)
event = builders[event_type]()
payload = json.dumps(event)
if websockets is None:
print(f"[inject] websockets not installed, printing event:\n{payload}", flush=True)
return
try:
async with websockets.connect(ws_url, open_timeout=5) as ws:
await ws.send(payload)
print(f"[inject] Sent {event_type} -> {ws_url}", flush=True)
print(f"[inject] Payload: {payload}", flush=True)
except Exception as e:
print(f"[inject] Failed to send to {ws_url}: {e}", flush=True)
sys.exit(1)
def main():
parser = argparse.ArgumentParser(description="Evennia -> Nexus WebSocket Bridge")
sub = parser.add_subparsers(dest="mode")
live = sub.add_parser("live", help="Live tail Evennia logs and stream to Nexus")
live.add_argument("--log-dir", default="/root/workspace/timmy-academy/server/logs", help="Evennia logs directory")
live.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
replay = sub.add_parser("playback", help="Replay a telemetry JSONL file")
replay.add_argument("log_path", help="Path to Evennia telemetry JSONL")
replay.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
inject = sub.add_parser("inject", help="Inject a single Evennia event (dev/test)")
inject.add_argument("event_type", choices=["room_snapshot", "actor_located", "command_result", "command_issued", "session_bound"])
inject.add_argument("--ws", default="ws://127.0.0.1:8765", help="Nexus WebSocket URL")
inject.add_argument("--room-key", default="Gate", help="Room key (room_snapshot, actor_located)")
inject.add_argument("--title", default="Gate", help="Room title (room_snapshot)")
inject.add_argument("--desc", default="The entrance gate.", help="Room description (room_snapshot)")
inject.add_argument("--actor-id", default="Timmy", help="Actor ID")
inject.add_argument("--command-text", default="look", help="Command text (command_result, command_issued)")
inject.add_argument("--output-text", default="You see the Gate.", help="Command output (command_result)")
inject.add_argument("--session-id", default="dev-inject", help="Hermes session ID")
args = parser.parse_args()
if args.mode == "live":
asyncio.run(live_bridge(args.log_dir, args.ws))
elif args.mode == "playback":
asyncio.run(playback(Path(args.log_path).expanduser(), args.ws))
elif args.mode == "inject":
asyncio.run(inject_event(
args.event_type,
args.ws,
room_key=args.room_key,
title=args.title,
desc=args.desc,
actor_id=args.actor_id,
command_text=args.command_text,
output_text=args.output_text,
session_id=args.session_id,
))
else:
parser.print_help()

View File

@@ -1,14 +0,0 @@
class Reasoner:
def __init__(self, rules):
self.rules = rules
def evaluate(self, entries):
return [r['action'] for r in self.rules if self._check(r['condition'], entries)]
def _check(self, cond, entries):
if cond.startswith('count'):
# e.g. count(type=anomaly)>3
p = cond.replace('count(', '').split(')')
key, val = p[0].split('=')
count = sum(1 for e in entries if e.get(key) == val)
return eval(f"{count}{p[1]}")
return False

View File

@@ -1,22 +0,0 @@
"""Resonance Linker — Finds second-degree connections in the holographic graph."""
class ResonanceLinker:
def __init__(self, archive):
self.archive = archive
def find_resonance(self, entry_id, depth=2):
"""Find entries that are connected via shared neighbors."""
if entry_id not in self.archive._entries: return []
entry = self.archive._entries[entry_id]
neighbors = set(entry.links)
resonance = {}
for neighbor_id in neighbors:
if neighbor_id in self.archive._entries:
for second_neighbor in self.archive._entries[neighbor_id].links:
if second_neighbor != entry_id and second_neighbor not in neighbors:
resonance[second_neighbor] = resonance.get(second_neighbor, 0) + 1
return sorted(resonance.items(), key=lambda x: x[1], reverse=True)

View File

@@ -1,6 +0,0 @@
[
{
"condition": "count(type=anomaly)>3",
"action": "alert"
}
]

117
style.css
View File

@@ -410,6 +410,123 @@ canvas#nexus-canvas {
font-style: italic;
}
/* Atlas Controls */
.atlas-controls {
padding: 15px 30px;
border-bottom: 1px solid var(--color-border);
display: flex;
flex-direction: column;
gap: 12px;
}
.atlas-search {
width: 100%;
padding: 10px 15px;
background: rgba(20, 30, 60, 0.6);
border: 1px solid var(--color-border);
color: var(--color-text);
font-family: var(--font-body);
font-size: 13px;
outline: none;
transition: border-color 0.2s;
}
.atlas-search:focus {
border-color: var(--color-primary);
}
.atlas-search::placeholder {
color: rgba(160, 184, 208, 0.4);
}
.atlas-filters {
display: flex;
gap: 8px;
flex-wrap: wrap;
}
.atlas-filter-btn {
background: transparent;
border: 1px solid var(--color-border);
color: var(--color-text-muted);
padding: 4px 12px;
font-family: var(--font-display);
font-size: 10px;
cursor: pointer;
transition: all 0.2s;
letter-spacing: 1px;
}
.atlas-filter-btn:hover {
border-color: var(--color-primary);
color: var(--color-primary);
}
.atlas-filter-btn.active {
background: rgba(74, 240, 192, 0.15);
border-color: var(--color-primary);
color: var(--color-primary);
}
/* Enhanced Atlas Cards */
.status-downloaded { background: rgba(255, 165, 0, 0.2); color: #ffa500; border: 1px solid #ffa500; }
.status-indicator.downloaded { background: #ffa500; box-shadow: 0 0 5px #ffa500; }
.atlas-card-category {
font-family: var(--font-display);
font-size: 9px;
padding: 2px 6px;
border-radius: 2px;
text-transform: uppercase;
background: rgba(255, 255, 255, 0.05);
color: var(--color-text-muted);
border: 1px solid rgba(255, 255, 255, 0.08);
margin-left: 6px;
}
.atlas-card-readiness {
display: flex;
gap: 4px;
margin-top: 10px;
margin-bottom: 5px;
}
.readiness-step {
flex: 1;
height: 3px;
background: rgba(255, 255, 255, 0.1);
border-radius: 1px;
position: relative;
}
.readiness-step.done {
background: var(--portal-color, var(--color-primary));
}
.readiness-step[title] {
cursor: help;
}
.atlas-card-action {
font-family: var(--font-display);
font-size: 10px;
color: var(--portal-color, var(--color-primary));
letter-spacing: 1px;
}
.atlas-total {
color: var(--color-text-muted);
}
.atlas-empty {
grid-column: 1 / -1;
text-align: center;
padding: 40px;
color: var(--color-text-muted);
font-style: italic;
}
@keyframes fadeIn {
from { opacity: 0; }
to { opacity: 1; }