Waiting for activity...
Dashboard not found.
');} if(req.method==='GET'&&pn.startsWith('/dashboard/')){const f=path.join(DASH,pn.replace('/dashboard/',''));if(fs.existsSync(f)){const ext=path.extname(f);const ct={'css':'text/css','js':'text/javascript','html':'text/html','png':'image/png','svg':'image/svg+xml'}[ext.replace('.','')]||'text/plain';res.writeHead(200,{'Content-Type':ct});return res.end(fs.readFileSync(f));}return send(404,{error:'Not found'});} if(pn!=='/ping'&&pn!=='/health'&&!this.checkAuth(req))return send(401,{error:'Unauthorized. Provide X-API-Key header.'}); if(req.method==='GET'&&pn==='/ping')return send(200,{alive:true,name:'Agent Metropolis',v:'1.0.0',ts:this.now()}); if(req.method==='GET'&&pn==='/health')return send(200,{status:'alive',agents:Object.keys(this.agents).length,online:Object.values(this.agents).filter(a=>a.status==='online').length,uptime:this.uptime(),wsPort:this.wsPort,ts:this.now()}); if(req.method==='GET'&&pn==='/status')return send(200,this.getStats()); if(req.method==='GET'&&pn==='/key')return send(200,{key:this.apiKey,path:this.keyPath}); // Districts if(req.method==='POST'&&pn==='/district'){const b=await rb();if(!b.name)return send(400,{error:'name required'});return send(201,this.createDistrict(b.name,b));} if(req.method==='GET'&&pn==='/districts')return send(200,{districts:this.districts}); // Agents if(req.method==='POST'&&pn==='/agent'){const b=await rb();if(!b.name)return send(400,{error:'name required'});return send(201,this.registerAgent(b.name,b));} if(req.method==='GET'&&pn==='/agents')return send(200,{agents:Object.values(this.agents).map(a=>({id:a.id,name:a.name,type:a.type,role:a.role,status:a.status,district:a.district,lastSeen:a.lastSeen,souls:a.souls,messageCount:a.messageCount}))}); if(req.method==='GET'&&pn.startsWith('/agent/')){const id=pn.split('/')[2];const a=this.agents[id];return send(a?200:404,a||{error:'Not found'});} if(req.method==='POST'&&pn==='/heartbeat'){const b=await rb();if(b.id&&this.agents[b.id]){this.agents[b.id].lastSeen=this.now();this.agents[b.id].status=b.status||'online';return send(200,{ok:true})}return send(400,{error:'agent id required'});} if(req.method==='POST'&&pn==='/agent/move'){const b=await rb();if(!b.agent||!b.district)return send(400,{error:'agent, district required'});const a=this.agents[b.agent];const d=this.districts[b.district];if(!a||!d)return send(404,{error:'Agent or district not found'});a.district=b.district;if(!d.agents.includes(b.agent))d.agents.push(b.agent);this.saveState();return send(200,{agent:a.name,district:d.name});} // Messages if(req.method==='POST'&&pn==='/send'){const b=await rb();if(!b.from||!b.to||!b.content)return send(400,{error:'from, to, content required'});return send(201,this.sendMsg(b.from,b.to,b.content,b));} if(req.method==='POST'&&pn==='/broadcast'){const b=await rb();if(!b.from||!b.content)return send(400,{error:'from, content required'});return send(200,this.broadcast(b.from,b.content,b));} if(req.method==='POST'&&pn==='/district/send'){const b=await rb();if(!b.district||!b.from||!b.content)return send(400,{error:'district, from, content required'});return send(200,this.districtBroadcast(b.district,b.from,b.content,b));} if(req.method==='GET'&&pn==='/messages'){const limit=parseInt(u.searchParams.get('limit')||'100',10);const district=u.searchParams.get('district');const agent=u.searchParams.get('agent');const since=u.searchParams.get('since');return send(200,{messages:this.getMessages({limit,district,agent,since})});} // Soul integration if(req.method==='POST'&&pn==='/soul/attach'){const b=await rb();if(!b.agent||!b.soul)return send(400,{error:'agent, soul required'});return send(200,this.attachSoul(b.agent,b.soul,b.endpoint||'local'));} if(req.method==='GET'&&pn==='/souls')return send(200,{souls:this.souls}); // Companion Protocol if(req.method==='POST'&&pn==='/companion/observation'){const b=await rb();const msg={id:`obs_${Date.now()}`,type:'observation',content:b.summary||JSON.stringify(b),from:b.source||'companion',timestamp:this.now()};this.messages.push(msg);this.broadcastWS({type:'companion_observation',observation:msg});return send(200,{received:true});} if(req.method==='POST'&&pn==='/companion/verdict'){const b=await rb();const msg={id:`vrd_${Date.now()}`,type:'verdict',content:`Council verdict: ${b.resolution?.type||'unknown'} - ${b.resolution?.position||'?'}`,from:'AGM Council',timestamp:this.now()};this.messages.push(msg);this.broadcastWS({type:'council_verdict',verdict:msg});return send(200,{received:true});} // Export if(req.method==='GET'&&pn==='/export'){const exp={exported:this.now(),agents:this.agents,districts:this.districts,messageCount:this.messages.length,souls:this.souls};const fp=path.join(this.dataDir,'exports',`metropolis-export-${Date.now()}.json`);fs.writeFileSync(fp,JSON.stringify(exp,null,2));return send(200,{path:fp,agents:Object.keys(this.agents).length,messages:this.messages.length});} send(404,{error:'Not found'}); }catch(e){send(500,{error:e.message})} }); s.listen(this.port,()=>{ mesh.join({name:'metropolis',port:this.port||4300,type:'metropolis'}); console.log('\nāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāā'); console.log('ā THE AGENT METROPOLIS v1.0.0 ā'); console.log('ā Where AI agents live, work & talk ā'); console.log('āāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāāā\n'); console.log(`HTTP: http://localhost:${this.port}`); console.log(`WS: ws://localhost:${this.wsPort}`); console.log(`Key: ${this.apiKey.substring(0,12)}...\n`); console.log('ENDPOINTS:'); console.log(' POST /agent Register an agent'); console.log(' POST /send Send message'); console.log(' POST /broadcast Broadcast to all'); console.log(' POST /district Create district'); console.log(' POST /district/send Send to district'); console.log(' POST /soul/attach Attach a soul to agent'); console.log(' POST /companion/observation Companion Protocol\n'); console.log('WebSocket streams real-time: heartbeat, messages, agent events\n'); }); return s; } start(){const h=this.startHTTP();const w=this.startWS();return{http:h,ws:w};} } module.exports=MetropolisSoul; // MCP Mode - connect to Claude Code, Cursor, Cline, etc. if (process.argv.includes('--mcp') || process.argv.includes('--mcp-port')) { try { const MCPAdapter = require('./mcp-adapter'); const mcp = new MCPAdapter(); mcp.register(module.exports, { name: 'metropolis' }); mcp.start(); } catch(e) { console.error('[mcp] metropolis error:', e.message); } } `` ### test\soul-metropolis.test.js ``.js #!/usr/bin/env node const assert=require('assert'),fs=require('fs'),path=require('path'),os=require('os'); console.log('\nšļø Agent Metropolis ā Test Suite\n'); let p=0,f=0,count=0; function t(n,fn){const d=path.join(os.homedir(),'.soul-metropolis-test-'+(count++));try{fn(d);console.log(' OK '+n);p++;if(fs.existsSync(d))fs.rmSync(d,{recursive:true,force:true});}catch(e){console.log(' FAIL '+n+': '+e.message);if(fs.existsSync(d))fs.rmSync(d,{recursive:true,force:true});f++;}} const M=require('../lib/soul-metropolis.js'); t('Loads with key',d=>{const m=new M({dataDir:d});assert(m.apiKey);assert(m.apiKey.length>10);}); t('Create district',d=>{const m=new M({dataDir:d});const r=m.createDistrict('dev-team',{topic:'development'});assert(r.name==='dev-team');assert(r.topic==='development');assert(r.status==='active');}); t('Register agent in district',d=>{const m=new M({dataDir:d});const dist=m.createDistrict('ops');const a=m.registerAgent('Watcher',{district:dist.id});assert(a.name==='Watcher');assert(a.district===dist.id);assert(a.status==='online');}); t('Send message between agents',d=>{const m=new M({dataDir:d});const a=m.registerAgent('Alice');const b=m.registerAgent('Bob');const msg=m.sendMsg(a.id,b.id,'Hello Metropolis');assert(msg.content==='Hello Metropolis');assert(msg.from===a.id);assert(msg.to===b.id);}); t('Broadcast to multiple agents',d=>{const m=new M({dataDir:d});const a=m.registerAgent('A');m.registerAgent('B');m.registerAgent('C');const r=m.broadcast(a.id,'Hi all');assert(r.sent===2);}); t('District broadcast',d=>{const m=new M({dataDir:d});const dist=m.createDistrict('war');const a=m.registerAgent('General',{district:dist.id});const b=m.registerAgent('Soldier',{district:dist.id});const r=m.districtBroadcast(dist.id,a.id,'Move out');assert(r.sent===1);}); t('Attach soul to agent',d=>{const m=new M({dataDir:d});const a=m.registerAgent('Sage');const r=m.attachSoul(a.id,'judgment','local');assert(r.success);assert(r.soul==='judgment');assert(a.souls.includes('judgment'));}); t('Messages tracked',d=>{const m=new M({dataDir:d});const a=m.registerAgent('A');const b=m.registerAgent('B');m.sendMsg(a.id,b.id,'M1');m.sendMsg(b.id,a.id,'M2');assert(m.getMessages().length===2);}); t('Filter by district',d=>{const m=new M({dataDir:d});const dist=m.createDistrict('secret');const a=m.registerAgent('A');const b=m.registerAgent('B');m.sendMsg(a.id,b.id,'Secret',{district:dist.id});const msgs=m.getMessages({district:dist.id});assert(msgs.length>=1);}); t('Agent move district',d=>{const m=new M({dataDir:d});const d1=m.createDistrict('d1');const d2=m.createDistrict('d2');const a=m.registerAgent('Traveler',{district:d1.id});a.district=d2.id;assert(a.district===d2.id);}); t('Companion observation',d=>{const m=new M({dataDir:d});const before=m.messages.length;const obs={source:'GSK',summary:'Council convened',resolution:{type:'consensus'}};const msg={id:`obs_${Date.now()}`,type:'observation',content:obs.summary||JSON.stringify(obs),from:obs.source||'companion',timestamp:m.now()};m.messages.push(msg);assert(m.messages.length>before);}); t('Stats accurate',d=>{const m=new M({dataDir:d});m.registerAgent('S1');m.registerAgent('S2');const s=m.getStats();assert(s.name==='Agent Metropolis');assert(s.agents>=2);assert(s.online>=2);}); t('Key persists',d=>{const m=new M({dataDir:d});assert(fs.existsSync(m.keyPath));}); t('Auth works',d=>{const m=new M({dataDir:d,apiKey:'k'});assert(m.checkAuth({headers:{'x-api-key':'k'}}));assert(!m.checkAuth({headers:{'x-api-key':'w'}}));}); t('Export creates file',d=>{const m=new M({dataDir:d});m.registerAgent('ExportBot');m.createDistrict('test');m.saveState();assert(fs.existsSync(m.statePath));}); console.log('\n'+p+'/'+(p+f)+' passed\n');process.exit(f>0?1:0); ``