Webpilot

import asyncio
import json
import aiohttp
from typing import Callable, Any, List, Optional


class EventEmitter:
    def __init__(self, event_emitter: Optional[Callable[[dict], Any]] = None):
        self.event_emitter = event_emitter

    async def emit(self, event_type: str, data: dict):
        if self.event_emitter: