Multi-Agent Context Sharing

123456789101112
interface SharedContext {
  taskId: string;
  globalState: Record<string, unknown>;
  agentContributions: Map<string, AgentContext>;
  version: number;
  lastUpdated: Date;
  conflictResolution: 'last-write-wins' | 'merge' | 'authority';
}

class MultiAgentContextManager {
  private context: SharedContext;
  private locks: Map<string, string> = new Map();

123456789101112
interface ContextEntry<T> {
  key: string;
  value: T;
  version: VectorClock;
  lastModifiedBy: string;
  timestamp: number;
  ttl?: number;
}

class DistributedContextStore {
  private local: Map<string, ContextEntry<any>> = new Map();
  private peers: Map<string, PeerConnection> = new Map();

123456789101112
from dataclasses import dataclass
from typing import Dict, List, Callable, Any
from enum import Enum
import asyncio
import hashlib

class MessagePriority(Enum):
    LOW = 0
    NORMAL = 1
    HIGH = 2
    CRITICAL = 3

123456789101112
interface HandoffContext {
  sessionId: string;
  sourceAgent: string;
  targetAgent: string;
  timestamp: number;
  
  // Core context
  userIntent: string;
  conversationHistory: Message[];
  
  // Processed state
  extractedEntities: Entity[];

123456789101112
from dataclasses import dataclass
from enum import Enum
import asyncio
from typing import Callable, Dict, List, Optional
import json

class EventType(Enum):
    CONTEXT_UPDATED = "context.updated"
    TASK_ASSIGNED = "task.assigned"
    TASK_COMPLETED = "task.completed"
    HANDOFF_REQUESTED = "handoff.requested"
    HANDOFF_ACCEPTED = "handoff.accepted"

123456789101112
import { Redis } from 'ioredis';

interface LockOptions {
  ttlMs: number;
  retryDelayMs: number;
  maxRetries: number;
}

interface LockResult {
  acquired: boolean;
  lockId?: string;
  holder?: string;