I copied a 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): """ This is the core processing function, you need to integrate your Agent interaction logic here. Receive user messages, call Agent, and send the results back to the front end through WebSocket. """ try: manus_agent.add_message(role='user', content=message) await SendStatus("Manus is processing...", 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) # --- End --- 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 processing error: {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, eg, 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 containersleep(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 containersleep(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: """Execute the command and return the result""" 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}"