from re import match
from socket import AF_INET, SO_REUSEADDR, SOCK_STREAM, SOL_SOCKET, socket
from stat import S_IMODE, ST_MODE
+from sys import stderr
from syslog import LOG_PID, LOG_INFO, LOG_DAEMON, closelog, openlog, syslog
from telnetlib import DO, DONT, ECHO, EOR, GA, IAC, LINEMODE, SB, SE, SGA, WILL, WONT
from time import asctime, sleep
+from traceback import format_exception
+
+def excepthook(excepttype, value, traceback):
+ """Handle uncaught exceptions."""
+
+ # assemble the list of errors into a single string
+ message = "".join(format_exception(excepttype, value, traceback))
+
+ # try to log it, if possible
+ try: log(message, 9)
+ except: pass
+
+ # try to write it to stderr, if possible
+ try: stderr.write(message)
+ except: pass
+
+# redefine sys.excepthook with ours
+import sys
+sys.excepthook = excepthook
class Element:
"""An element of the universe."""
universe.files[self.origin].data.add_section(self.key)
def destroy(self):
"""Remove an element from the universe and destroy it."""
- log("Destroying: " + self.key + ".")
+ log("Destroying: " + self.key + ".", 2)
universe.files[self.origin].data.remove_section(self.key)
del universe.categories[self.category][self.subkey]
del universe.contents[self.key]
universe.files[self.origin].data.remove_option(self.key, facet)
def facets(self):
"""Return a list of non-inherited facets for this element."""
- return universe.files[self.origin].data.options(self.key)
+ if self.key in universe.files[self.origin].data.sections():
+ return universe.files[self.origin].data.options(self.key)
+ else: return []
def has_facet(self, facet):
"""Return whether the non-inherited facet exists."""
return facet in self.facets()
self.default_origins = {}
self.files = {}
self.private_files = []
+ self.loglist = []
self.userlist = []
self.terminate_world = False
self.reload_modules = False
if name: message = "User " + name
else: message = "An unnamed user"
message += " logged out."
- log(message)
+ log(message, 2)
self.deactivate_avatar()
self.connection.close()
self.remove()
if old_user.account.get("name") == self.account.get("name") and old_user is not self:
# make a note of it
- log("User " + self.account.get("name") + " reconnected--closing old connection to " + old_user.address + ".")
+ log("User " + self.account.get("name") + " reconnected--closing old connection to " + old_user.address + ".", 2)
old_user.send("$(eol)$(red)New connection from " + self.address + ". Terminating old connection...$(nrm)$(eol)", flush=True, add_prompt=False)
# close the old connection
def authenticate(self):
"""Flag the user as authenticated and disconnect duplicates."""
if not self.state is "authenticated":
- log("User " + self.account.get("name") + " logged in.")
+ log("User " + self.account.get("name") + " logged in.", 2)
self.authenticated = True
if self.account.subkey in universe.categories["internal"]["limits"].getlist("default_admins"):
self.account.set("administrator", "True")
if self.account and self.account.get("name"): logline += self.account.get("name") + ": "
else: logline += "unknown user: "
logline += repr(removed)
- log(logline)
+ log(logline, 4)
# filter out non-printables
line = filter(lambda x: " " <= x <= "~", line)
"""Send a message to all connected users."""
for each_user in universe.userlist: each_user.send("$(eol)" + message, add_prompt=add_prompt)
-def log(message):
+def log(message, level=0):
"""Log a message."""
- # the time in posix log timestamp format
+ # a couple references we need
+ file_name = universe.categories["internal"]["logging"].get("file")
+ max_log_lines = universe.categories["internal"]["logging"].getint("max_log_lines")
+ syslog_name = universe.categories["internal"]["logging"].get("syslog")
timestamp = asctime()[4:19]
- file_name = universe.categories["internal"]["logging"].get("file")
+ # turn the message into a list of lines
+ lines = filter(lambda x: x!="", [(x.rstrip()) for x in message.split("\n")])
+
+ # send the timestamp and line to a file
if file_name:
file_descriptor = file(file_name, "a")
- file_descriptor.write(timestamp + " " + message + "\n")
+ for line in lines: file_descriptor.write(timestamp + " " + line + "\n")
file_descriptor.flush()
file_descriptor.close()
- # send the timestamp and message to standard output
+ # send the timestamp and line to standard output
if universe.categories["internal"]["logging"].getboolean("stdout"):
- print(timestamp + " " + message)
+ for line in lines: print(timestamp + " " + line)
- # send the message to the system log
- syslog_name = universe.categories["internal"]["logging"].get("syslog")
+ # send the line to the system log
if syslog_name:
openlog(syslog_name, LOG_PID, LOG_INFO | LOG_DAEMON)
- syslog(message)
+ for line in lines: syslog(line)
closelog()
+ # display to connected administrators
+ for user in universe.userlist:
+ if user.state == "active" and user.account.getboolean("administrator") and user.account.getint("loglevel") <= level:
+ # iterate over every line in the message
+ full_message = ""
+ for line in lines:
+ full_message += "$(bld)$(red)" + timestamp + " " + line + "$(nrm)$(eol)"
+ user.send(full_message, flush=True)
+
+ # add to the recent log list
+ for line in lines:
+ while 0 < len(universe.loglist) >= max_log_lines: del universe.loglist[0]
+ universe.loglist.append(timestamp + " " + line)
+
def wrap_ansi_text(text, width):
"""Wrap text with arbitrary width while ignoring ANSI colors."""
else:
text = text.replace(macro, "")
if not is_input:
- log("Unexpected replacement macro " + macro + " encountered.")
+ log("Unexpected replacement macro " + macro + " encountered.", 6)
# replace the look-like-a-macro sequence
text = text.replace("$_(", "$(")
return None
# note that we got one
- log("Connection from " + address[0])
+ log("Connection from " + address[0], 2)
# disable blocking so we can proceed whether or not we can send/receive
connection.setblocking(0)
else:
user.account = Element("account:" + name, universe)
user.account.set("name", name)
- log("New user: " + name)
+ log("New user: " + name, 2)
user.state = "checking_new_account_name"
# if the user entered nothing for a name, then buhbye
# let everyone know
broadcast(message, add_prompt=False)
- log(message)
+ log(message, 8)
# set a flag to terminate the world
universe.terminate_world = True
# let the user know and log
user.send("Reloading all code modules, configs and data.")
- log("User " + user.account.get("name") + " reloaded the world.")
+ log("User " + user.account.get("name") + " reloaded the world.", 8)
# set a flag to reload
universe.reload_modules = True
message = repr(eval(" ".join(arguments[1:])))
except:
message = "Your expression raised an exception!"
+ elif arguments[0] == "log":
+ if match("^\d+$", arguments[1]) and int(arguments[1]) > 0:
+ linecount = int(arguments[1])
+ if linecount > len(universe.loglist): linecount = len(universe.loglist)
+ message = "There are " + str(len(universe.loglist)) + " log lines in memory."
+ message += " The most recent " + str(linecount) + " lines are:$(eol)$(eol)"
+ for line in universe.loglist[-linecount:]:
+ message += " " + line + "$(eol)"
+ else: message = "\"" + arguments[1] + "\" is not a positive integer greater than 0."
if not message:
if parameters: message = "I don't know what \"" + parameters + "\" is."
else: message = "What do you want to show?"
if filename not in universe.files:
message += " Warning: \"" + filename + "\" is not yet included in any other file and will not be read on startup unless this is remedied."
Element(element, universe, filename)
- log(logline)
+ log(logline, 6)
elif len(arguments) > 2: message = "You can only specify an element and a filename."
user.send(message)
else:
universe.contents[parameters].destroy()
message = "You destroy \"" + parameters + "\" within the universe."
- log(user.account.get("name") + " destroyed an element: " + parameters)
+ log(user.account.get("name") + " destroyed an element: " + parameters, 6)
user.send(message)
def command_set(user, parameters):
projects / mudpy.git / blobdiff