我复刻了一个Manus

{ "mcpServers": {    "playwright": {      "command": "npx",      "args": ["@playwright/mcp@latest"]    },   "manus_server": {      "command": "python",      "args": ["manus_server.py"]    }  }}

async def process_user_message(message: str, websocket: WebSocket):    """    这是核心处理函数，你需要在这里集成你的 Agent 交互逻辑。    接收用户消息，调用 Agent，并将结果通过 WebSocket 发回前端。    """    try:        manus_agent.add_message(role='user', content=message)        await SendStatus("Manus 正在处理...", websocket).send()        while True:            last_message_chunk = await generate_and_send_message_chunk(websocket, manus_agent.generate)            tool_executed = last_message_chunk.include_tool            if not tool_executed:                break            send_tool = SendTool(last_message_chunk, websocket)            await send_tool.send_tool()            result = await manus_agent.judge_and_execute(last_message_chunk)            await asyncio.sleep(0.5)            await send_tool.send_result()            manus_agent.add_message(role='system', content=result)        # --- 结束 ---        logging.info("Finished processing user message.")    except Exception as e:        logging.error(f"Error in agent logic: {e}", exc_info=True)        await websocket.send_text(json.dumps({"type": "error", "content": f"Agent 处理出错: {e}"}))

def get_or_create_docker_container(        container_name: str = CONTAINER_NAME,        image_name: str = 'python:3.12.10',        local_workspace_dir=DEFAULT_TASK_DIRECTORY,        container_workspace_dir: str | None = CONTAINER_WORKSPACE_DIR,        docker_client: docker.DockerClient | None = client,        keep_alive_command: str = DEFAULT_KEEP_ALIVE_COMMAND,        auto_remove: bool = False  # Set to True to automatically remove container on exit (useful for temp tasks)):    client = docker_client    container = None    try:        # 1. Try to get the existing container        print(f"Checking for existing container '{container_name}'...")        container = client.containers.get(container_name)        print(f"Found existing container: {container.name} (ID: {container.short_id})")        # 2. Ensure the found container is running        if container.status != 'running':            print(f"Container '{container_name}' is not running (status: {container.status}). Starting...")            try:                container.start()                # Wait a moment for the container to fully start                time.sleep(2)                container.reload()  # Refresh container state                if container.status != 'running':                    # If start failed, raise an error                    logs = container.logs(tail=10).decode('utf-8', errors='ignore')                    raise RuntimeError(                        f"Failed to start existing container '{container_name}'. "                        f"Current status: {container.status}.\nLast logs:\n{logs}"                    )                print(f"Container '{container_name}' started successfully.")            except Exception as e:                print(f"ERROR: Unexpected error while starting container '{container_name}': {e}")                raise        else:            print(f"Container '{container_name}' is already running.")    except NotFound:        # 3. If container Not Found, create it        print(f"Container '{container_name}' not found. Creating new container...")        # Prepare volumes if specified        volumes = {}        if local_workspace_dir and container_workspace_dir:            host_path = Path(local_workspace_dir).resolve()  # Use absolute path            host_path.mkdir(parents=True, exist_ok=True)  # Ensure host dir exists            print(f"Ensuring local directory exists: {host_path}")            volumes[str(host_path)] = {'bind': container_workspace_dir, 'mode': 'rw'}            print(f"Mapping local '{host_path}' to container '{container_workspace_dir}'")        # Check/Pull Image        print(f"Checking/pulling image: {image_name}...")        client.images.get(image_name)        # Create and start the container        print(f"Creating and starting container '{container_name}' from image '{image_name}'...")        container_config = {            "image": image_name,            "name": container_name,            "command": keep_alive_command,            "volumes": volumes if volumes else None,            "working_dir": container_workspace_dir if container_workspace_dir else None,            "detach": True,            "tty": True,            "stdin_open": True,            "auto_remove": auto_remove,            # Add restart policy if desired, e.g., restart_policy={"Name": "unless-stopped"}        }        # Remove None values from config        container_config = {k: v for k, v in container_config.items() if v is not None}        container = client.containers.run(**container_config)        # Wait a moment and verify        time.sleep(2)        container.reload()        if container.status == 'running':            print(f"Successfully created and started container: {container.name} (ID: {container.short_id})")        else:            logs = container.logs(tail=10).decode('utf-8', errors='ignore')            raise RuntimeError(                f"Created container '{container_name}' failed to start. "                f"Current status: {container.status}.\nLast logs:\n{logs}"            )    # Final verification (should be redundant if logic above is correct, but safe)    if not container or container.status != 'running':        # This path should ideally not be reached if errors were raised correctly above        raise RuntimeError(f"Failed to obtain a running container instance for '{container_name}'.")    print(f"Container '{container.name}' is ready and running.")    print("-" * 30)    return container

@mcp.tool()def execute_command(command: str) -> str:    """执行命令并返回结果"""    workdir = CONTAINER_WORKSPACE_DIR    exit_code, output = container.exec_run(["/bin/sh", "-c", command], workdir=workdir, stream=False, demux=False)    output_str = output.decode('utf-8').strip() if output else ""    return f"{output_str}"