import os, sys, asyncio, re, signal from firepup650 import console from logs import log class Globals: ... G = Globals() G.uniqueClients = 0 G.serverLinks = 0 G.servers = {} G.clientsConnected = [] port = 65048 G.msgs = [] G.remoteID = "firepi" G.event = asyncio.Event() G.loop = asyncio.get_event_loop() G.interruptCount = 0 G.killList = {} G.outboundLinks = [] G.S2SLogs = [] saveLogs = True # Try to load a message log, if one exists try: G.msgs = __import__("cache").msgs log(f"Got {len(G.msgs)} lines from message cache") except ImportError: log("No server message cache.", level="WARN") except Exception: log( "Abnormal state! Failed to load cache even though the file exists!", level="WARN", ) try: for arg in sys.argv: if arg.startswith("--port") or arg.startswith("-p"): port = int(arg.lstrip("-port=")) elif arg in ["-n", "--no-cache"]: log("Explicitly erasing cached messages") G.msgs = [] elif arg in ["-?", "-h", "--help"]: print("TODO: Help menu soon") exit(0) elif arg in ["-l", "--no-logs"]: log("Explicitly disabling saving of logs!") saveLogs = False elif arg.startswith("--link"): G.outboundLinks.append((arg[6:], int(arg.split(":")[1]))) else: log(f"Unrecognized argument {arg}!", "WARN") except Exception: sys.tracebacklimit = 0 raise ValueError("Invalid arguments. Please refer to -? for usage.") from None def raw(string: str) -> str: s = string.strip() s = f"{s!r}"[1:-1].replace("\\\\", "\\") if '"' in s: return s.replace("\\'", "'") else: return s def fmt(msg: str, name: str = "", action: bool = False) -> str: if action: return f"* {name}{' '*(20-len(name))} {msg}" else: return f" {name}{' '*(20-len(name))}: {msg}" async def handle_client(reader, writer): try: global G writer.write(b"Please identify yourself. Nick limit is 20 chars.\n") await writer.drain() name = raw((await reader.read(20)).decode("utf8")) if len(name) > 20: name = name[ :19 ] # Really this is only possible if someone passes raw unicode as a nick, but let's clean it up anyways. try: await asyncio.wait_for( reader.read(), 0.01 ) # Silently consume the excess username data except asyncio.TimeoutError: pass if not name: writer.write(b"Nice try. Actually set a nick.\n") await writer.drain() writer.close() await writer.wait_closed() return if name in G.clientsConnected: writer.write(f"Nick ({name}) in use\n".encode("utf8")) await writer.drain() writer.close() await writer.wait_closed() return if not name.startswith("S2S-"): G.clientsConnected.extend([name]) msgIndex = 0 G.uniqueClients += 1 G.msgs.extend([log(f"{name} has connected to the server.")]) while 1: try: buffer = await asyncio.wait_for(reader.read(967), 0.1) request = raw(buffer.decode("utf8")) response = None if request.startswith("/mes "): response = log(f"* {name}'s {request[5:]}") elif request.startswith("/me "): response = log(f"* {name} {request[4:]}") elif request.startswith("/h"): writer.write(b"TODO: Command listing\n") await writer.drain() elif request.startswith("/quit"): break elif request.startswith("/afk"): if len(request) > 5: response = log(f"* {name} is afk to {request[4:]}") else: response = log(f"* {name} is afk") elif request.startswith("/back"): response = log(f"* {name} is back") elif request: response = log(f" {name}: {request}") if response: G.msgs.extend([response]) except asyncio.TimeoutError: pass if msgIndex < len(G.msgs): writer.writelines(G.msgs[msgIndex:]) await writer.drain() msgIndex = len(G.msgs) if name in G.killList and G.killList[name]: writer.write(b"Your client has been killed by the server\n") G.killList[name] = False break await writer.drain() writer.close() await writer.wait_closed() G.uniqueClients -= 1 G.msgs.append(log(f"{name} has disconnected from the server.")) G.clientsConnected.remove(name) else: # This is... probably a server? sName = name[4:] # Trim off the S2S label log(f"Server link! Link from {sName}") G.serverLinks += 1 G.servers[sName] = [] msgIndex = 0 writer.write("I Awaiting client listing.\n") while 1: client = raw((await reader.read(967)).decode("utf8")) if client == f"END OF CLIENT LISTING FROM {sName}": break if client in G.servers[sName] or client in G.clientsConnected: writer.write(b"K Client rejected: Already exists\n") await writer.drain() continue writer.write(b"I Added client.\n") await writer.drain() G.msgs.append(log(f"{client} has connected from {sName}")) G.servers[sName].append(client) G.clientsConnected.extend(G.servers[sName]) while 1: try: rawMsg = await asyncio.wait_for(reader.read(967), 0.1) buffer = raw(rawMsg.decode("utf8")) match buffer[0]: case "S": # Server notice G.msgs.extend([log(buffer[2:])]) writer.write(b"I Mmm... Blueberries\n") case "I": pass case "+": cName = buffer[2:] if cName not in G.clientsConnected: G.msgs.append( log(f"{cName} has connected from {sName}") ) G.servers[sName].append(cName) G.clientsConnected.append(cName) writer.write(b"I Mmm... Pineapples\n") else: writer.write(b"K Nick Collision") case "-": cName = buffer[2:] G.msgs.append(log(f"{cName} has disconnected from {sName}")) G.servers[sName].remove(cName) G.clientsConnected.remove(cName) writer.write(b"I Mmm... Bananas\n") case "M": cName = buffer[2:].split("|", 1)[0] message = buffer[2:].split("|", 1)[1] G.msgs.append(log(f" {cName}: {message}")) writer.write( b"I Get these damn heretic ghost clients out of my store so i can buy my cult candles in peace." ) case "A": cName = buffer[2:].split("|", 1)[0] message = buffer[2:].split("|", 1)[1] G.msgs.append(log(f"* {cName} {message}")) writer.write(b"I Mmm... Strawberries\n") case "Q": break case "K": cName = buffer[2:] G.killList[cName] = True writer.write(b"I Mmm... Blood\n") case _: writer.write( b"S Your server is doing drugs over here, sending me bullshit messages man - A fellow server\n" ) await writer.drain() except TimeoutError: pass await writer.drain() writer.close() await writer.wait_closed() for cName in G.servers[sName]: G.msgs.append(log(f"{cName}'s server is going down")) G.clientsConnected.remove(cName) G.serverLinks -= 1 G.servers.remove(sName) G.msgs.append(log(f"{sName} has de-linked from the network")) except (ConnectionResetError, BrokenPipeError): if not name.startswith("S2S-"): G.uniqueClients -= 1 G.msgs.append(log(f"{name} has disconnected from the server.")) G.clientsConnected.remove(name) else: for cName in G.servers[name[4:]]: G.msgs.append(log(f"{cName}'s server is going down")) try: G.clientsConnected.remove(cName) except Exception: # Crash during connection sequence? pass G.serverLinks -= 1 G.servers.remove(name[4:]) G.msgs.append(log(f"{name[4:]} has de-linked from the network")) async def connectServer(hostname: str, port: int): reader, writer = await asyncio.open_connection(hostname, port) await reader.read(1024) writer.write(f"S2S-{G.remoteID}\n".encode("utf8")) await writer.drain() await reader.read(1024) for client in G.clientsConnected: writer.write(f"{client}\n".encode("utf8")) await writer.drain() response = await reader.read(1024) if response.startswith("K"): G.killList[client] = True writer.write(f"END OF CLIENT LISTING FROM {G.remoteID}".encode("utf8")) await writer.drain() # recieve client list from the other server # copy the handling code from the S2S section above async def runServer(port: int): global G server = await asyncio.start_server(handle_client, "0.0.0.0", port) log(f"Listening on port {port}...") G.msgs.append(log("Server startup")) links = [] for hostname, portNum in G.outboundLinks: links.append(connectServer(hostname, portNum)) crash = False try: links.append(G.event.wait()) await asyncio.gather(*links) except Exception: crash = True G.msgs.append(log("Server crash", level="FATAL")[1:]) log("Shutting down from Exception") # TODO: Add format_exc here finally: if not crash: G.msgs.append(log("Server shutdown")) log("Kicking all clients as we go down") server.close() # server.abort_clients() if saveLogs: with open("cache.py", "w") as cache: cache.write(f"msgs = {G.msgs}\n") log("Saved logs, exiting now.") else: log("Not saving logs, exiting now.") class ServerInterruptException(KeyboardInterrupt): ... def interruptCatch(s, f): global G print() G.loop.call_soon_threadsafe(G.event.set) G.interruptCount += 1 sys.tracebacklimit = 0 raise ServerInterruptException from None signal.signal(signal.SIGINT, interruptCatch) asyncio.run(run_server(port))