AgentSwarm Orchestrator - Node.js Implementation

This Node.js implementation of AgentSwarm Orchestrator was inspired by https://kimik25.com. It provides an async-first, event-driven approach to agent management with EventEmitter-based messaging.

Features

- Promise-based API: Seamless async/await integration
- EventEmitter architecture: Reactive message passing between agents
- 256K context support: Inspired by Kimi K2.5's extended context window
- Multiple topologies: Hierarchical, mesh, and hybrid patterns
- Type-safe: JSDoc annotations for better IDE support

Installation

``bash
npm install kimi25-opensource
`

Usage

`javascript
const { AgentSwarm } = require('kimi25-opensource');

// Initialize swarm with 256K context window
const swarm = new AgentSwarm({
maxAgents: 100,
contextWindow: 256000,
topology: 'mesh'
});

// Spawn specialized agents
const agent = swarm.spawnAgent('data-processor', 'analysis', 'transform');

// Dispatch messages
await agent.dispatchMessage({
type: 'process',
payload: { data: 'example' }
});

// Get swarm statistics
console.log(swarm.getStats());

// Clean shutdown
await swarm.shutdown();
`

API Reference

$3

#### AgentSwarm

Main swarm coordinator class.

Constructor Options:
- maxAgents (number): Maximum number of agents (default: 100)
- contextWindow (number): Token context limit (default: 256000)
- topology (string): Swarm topology - 'hierarchical', 'mesh', 'hybrid' (default: 'mesh')

Methods:
- spawnAgent(id, ...capabilities) - Create and register a new agent
- broadcastMessage(from, type, payload) - Send message to all agents
- getAgent(id) - Retrieve agent by ID
- getStats() - Get current swarm statistics
- shutdown() - Gracefully shutdown the swarm

Events:
- agent-spawned - Emitted when a new agent is created
- agent-message - Emitted when any agent dispatches a message
- broadcast - Emitted on broadcast messages
- context-warning - Emitted when context window is nearly full
- shutdown - Emitted when swarm is shut down

#### Agent

Individual agent class extending EventEmitter.

Methods:
- dispatchMessage(msg) - Send a message from this agent
- processMessages(handler) - Process queued messages asynchronously

$3

#### createSwarm(config)

Factory function to create a new AgentSwarm instance.

Examples

$3

`javascript
const swarm = new AgentSwarm();

swarm.on('agent-spawned', ({ id, capabilities }) => {
console.log(New agent: ${id} with ${capabilities.join(', ')});
});

swarm.on('context-warning', ({ used, limit }) => {
console.warn(Context at ${used}/${limit} tokens);
});

const agent = swarm.spawnAgent('worker', 'processing');
`

$3

`javascript
const agent = swarm.spawnAgent('processor');

await agent.processMessages(async (msg) => {
console.log(Processing ${msg.type});
// Handle message
return { result: 'processed' };
});
``

Performance

The Node.js implementation is optimized for:

- Non-blocking I/O: Async operations don't block the event loop
- Memory efficiency: Minimal memory overhead per agent
- Scalability: Handles 100+ concurrent agents efficiently

Links

- Source: https://kimik25.com
- Repository: https://onedao/wddaily/kimi25-opensource
- Documentation: https://onedao/wddaily/kimi25-opensource#readme
- NPM Package: https://www.npmjs.com/package/kimi25-opensource

License

MIT License - See LICENSE file for details.