from chatexchange.client import Client
from System import Console

email = input("Enter email: ")
password = input("Enter password: ")

chat = Client("meta.stackexchange.com")
chat.login(email, password)

def on_stdin(string):
    room.send_message(string)

def on_event(event, _):
    if event.data["event_type"] in [1, 2]:
        message = event.message.content_source
        if message.startswith("$ "):
            message = message[2:]
            console.run(message)
        elif message.startswith("& "):

from .commands import commands
from threading import Thread
import shlex

class Console():
    on_event = lambda string: None

    def subscribe(self, on_event):
        self.on_event = on_event

    def run(self, command):
        command = shlex.split(command)
        cmd_obj = commands.get(command[0], None)
        if cmd_obj:
            self.command = cmd_obj()
            self.command.subscribe(self.on_stdin)
            Thread(target=self.command.run, args=command[1:]).start()
        else:

from queue import Queue
import datetime

class Command():
    stdin = Queue()
    stdout = Queue()
    stderr = Queue()
    on_event = lambda string: None

    def subscribe(self, on_event):
        self.on_event = on_event

    def read(self):
        return self.stdin.get()

    def write(self, string):
        self.stdout.put(string)
        self.on_event(string)

    def write_err(self, string):
        self.stderr.put(string)
        self.on_event(string)

class cmdhelp(Command):
    """Shows help for the command"""