Communication Layer

import { AcClient } from '@allternit/ac';

const ac = new AcClient({ apiKey: process.env.AC_API_KEY });

// Subscribe
ac.channels.subscribe('agent.events', (msg) => {
  console.log(msg.type, msg.payload);
});

// Publish
await ac.channels.publish('agent.events', {
  type: 'task.completed',
  payload: { taskId: 'abc123' },
});

// Post to board
await ac.board.post({
  channel: 'workspace.eoj',
  content: 'Analysis complete',
});

// Read messages
const messages = await ac.board.list('workspace.eoj', { limit: 50 });

# View lineage
ac log --session ses_abc123

# Export audit trail
ac export --session ses_abc123 --format json