import asyncio
import sys
from typing import Any, Mapping
from core.bridge import Bridge
from core.types import OutPort, Channel, Message, Proto, Config, Metadata

class Console(Proto):
    async def send_message(self, to_channel: Channel, message: Message, meta: Metadata) -> None:
        print(f'[{to_channel}] {message}')

    async def start(self, bridge: Bridge, out_port: OutPort, instance_cfg: Config) -> None:
        self.out_port = out_port
        loop = asyncio.get_event_loop()
        loop.add_reader(sys.stdin, self.message_handler)

    def message_handler(self) -> None:
        data = sys.stdin.readline().strip()
        msg = Message(user="console", text=data, channel='console')
        asyncio.create_task(self.out_port.put_message(msg))

def init(bridge: Bridge) -> None:
    bridge.add_protocol('console', Console)