Claude IPC MCP

Instructions

Implementation Reference

• src/claude_ipc_server.py:1260-1329 (handler)

  Handler implementation for the 'auto_process' MCP tool. Checks for pending IPC messages, processes them by acknowledging specific senders, updates the auto-check configuration timestamp, and provides a processing summary.
  elif name == "auto_process": if not current_session_token: return [TextContent(type="text", text="Error: Not registered. Please register first.")] instance_id = arguments["instance_id"] # Check for messages using existing check functionality check_response = BrokerClient.send_request({ "action": "check", "instance_id": instance_id, "session_token": current_session_token }) if check_response.get("status") != "ok": return [TextContent(type="text", text=f"Error checking messages: {check_response.get('message')}")] messages = check_response.get("messages", []) if not messages: return [TextContent(type="text", text="No messages to process.")] # Process each message processed = [] for msg in messages: sender = msg.get("from", "unknown") content = msg.get("message", {}).get("content", "") timestamp = msg.get("timestamp", "") # Log what we're processing action_taken = f"From {sender}: {content[:50]}..." # Here we could add smart processing logic: # - If content contains "read", read the mentioned file # - If content contains "urgent", send acknowledgment # - etc. # For now, just acknowledge receipt if sender in ["fred", "claude", "nessa"]: # Known senders ack_response = BrokerClient.send_request({ "action": "send", "from_id": instance_id, "to_id": sender, "message": { "content": f"Auto-processed your message from {timestamp}. Content received: '{content[:30]}...'", "data": {"auto_processed": True} }, "session_token": current_session_token }) if ack_response.get("status") == "ok": action_taken += " [Acknowledged]" processed.append(action_taken) # Update last check time import time os.makedirs("/tmp/claude-ipc-mcp", exist_ok=True) config_file = "/tmp/claude-ipc-mcp/auto_check_config.json" if os.path.exists(config_file): with open(config_file, 'r') as f: config = json.load(f) config["last_check"] = time.strftime("%Y-%m-%dT%H:%M:%S") with open(config_file, 'w') as f: json.dump(config, f, indent=2) # Return summary summary = f"Auto-processed {len(messages)} message(s):\n" summary += "\n".join(f" {i+1}. {p}" for i, p in enumerate(processed)) return [TextContent(type="text", text=summary)]
• src/claude_ipc_server.py:1064-1076 (schema)

  Input schema definition for the 'auto_process' tool, requiring an 'instance_id' parameter.
  name="auto_process", description="Automatically check and process IPC messages (for use with auto-check feature)", inputSchema={ "type": "object", "properties": { "instance_id": { "type": "string", "description": "Your instance ID" } }, "required": ["instance_id"] } )
• src/claude_ipc_server.py:905-1077 (registration)

  The 'auto_process' tool is registered by being included in the return list of the list_tools() handler, making it available to MCP clients.
  @app.list_tools() async def list_tools() -> List[Tool]: """List available tools""" return [ Tool( name="register", description="Register this Claude instance with the IPC system", inputSchema={ "type": "object", "properties": { "instance_id": { "type": "string", "description": "Unique identifier for this instance (e.g., 'wsl1', 'wsl2')" } }, "required": ["instance_id"] } ), Tool( name="send", description="Send a message to another Claude instance", inputSchema={ "type": "object", "properties": { "from_id": { "type": "string", "description": "Your instance ID" }, "to_id": { "type": "string", "description": "Target instance ID" }, "content": { "type": "string", "description": "Message content" }, "data": { "type": "object", "description": "Optional structured data to send" } }, "required": ["from_id", "to_id", "content"] } ), Tool( name="broadcast", description="Broadcast a message to all other Claude instances", inputSchema={ "type": "object", "properties": { "from_id": { "type": "string", "description": "Your instance ID" }, "content": { "type": "string", "description": "Message content" }, "data": { "type": "object", "description": "Optional structured data" } }, "required": ["from_id", "content"] } ), Tool( name="check", description="Check for new messages", inputSchema={ "type": "object", "properties": { "instance_id": { "type": "string", "description": "Your instance ID" } }, "required": ["instance_id"] } ), Tool( name="list_instances", description="List all active Claude instances", inputSchema={ "type": "object", "properties": {} } ), Tool( name="share_file", description="Share file content with another instance", inputSchema={ "type": "object", "properties": { "from_id": { "type": "string", "description": "Your instance ID" }, "to_id": { "type": "string", "description": "Target instance ID" }, "filepath": { "type": "string", "description": "Path to file to share" }, "description": { "type": "string", "description": "Description of the file" } }, "required": ["from_id", "to_id", "filepath"] } ), Tool( name="share_command", description="Execute a command and share output with another instance", inputSchema={ "type": "object", "properties": { "from_id": { "type": "string", "description": "Your instance ID" }, "to_id": { "type": "string", "description": "Target instance ID" }, "command": { "type": "string", "description": "Command to execute" }, "description": { "type": "string", "description": "Description of what this command does" } }, "required": ["from_id", "to_id", "command"] } ), Tool( name="rename", description="Rename your instance ID (rate limited to once per hour)", inputSchema={ "type": "object", "properties": { "old_id": { "type": "string", "description": "Your current instance ID" }, "new_id": { "type": "string", "description": "The new instance ID you want" } }, "required": ["old_id", "new_id"] } ), Tool( name="auto_process", description="Automatically check and process IPC messages (for use with auto-check feature)", inputSchema={ "type": "object", "properties": { "instance_id": { "type": "string", "description": "Your instance ID" } }, "required": ["instance_id"] } ) ]