diff --git a/main.py b/main.py new file mode 100644 index 0000000..e81f4b3 --- /dev/null +++ b/main.py @@ -0,0 +1,31 @@ +import asyncio + +clients = {} # task -> (reader, writer) + +def client_connected_handler(client_reader, client_writer): + # Start a new asyncio.Task to handle this specific client connection + task = asyncio.Task(handle_client(client_reader, client_writer)) + clients[task] = (client_reader, client_writer) + + def client_done(task): + # When the tasks that handles the specific client connection is done + del clients[task] + + # Add the client_done callback to be run when the future becomes done + task.add_done_callback(client_done) + +@asyncio.coroutine +def handle_client(client_reader, client_writer): + # Handle the requests for a specific client with a line oriented protocol + while True: + # Read a line + data = (yield from client_reader.readline()) + # Send it back to the client + client_writer.write(data) + +loop = asyncio.get_event_loop() +server = loop.run_until_complete(asyncio.start_server(client_connected_handler, 'localhost', 2222)) +try: + loop.run_forever() +finally: + loop.close() \ No newline at end of file diff --git a/mechs/smtp.py b/mechs/smtp.py new file mode 100644 index 0000000..e69de29