mirror of
https://github.com/evennia/evennia.git
synced 2026-03-23 00:06:30 +01:00
9407eb0ee4
As a side-effect of all of this, logging in more than once acts as behaves now. Also, this will allow things/rooms/exits (IE: not players) or un-logged in players to run commands or be forced to run them via @fo. All of this will bring us more in-line with MUX behavior.
98 lines
2.8 KiB
Python
98 lines
2.8 KiB
Python
"""
|
|
Session manager, handles connected players.
|
|
"""
|
|
import time
|
|
|
|
from src.config.models import ConfigValue
|
|
from src import logger
|
|
from src.util import functions_general
|
|
|
|
# Our list of connected sessions.
|
|
session_list = []
|
|
|
|
def add_session(session):
|
|
"""
|
|
Adds a session to the session list.
|
|
"""
|
|
session_list.insert(0, session)
|
|
logger.log_infomsg('Sessions active: %d' % (len(get_session_list(return_unlogged=True),)))
|
|
|
|
def get_session_list(return_unlogged=False):
|
|
"""
|
|
Lists the connected session objects.
|
|
"""
|
|
if return_unlogged:
|
|
return session_list
|
|
else:
|
|
return [sess for sess in session_list if sess.is_loggedin()]
|
|
|
|
def disconnect_all_sessions():
|
|
"""
|
|
Cleanly disconnect all of the connected sessions.
|
|
"""
|
|
for sess in get_session_list():
|
|
sess.handle_close()
|
|
|
|
def disconnect_duplicate_session(session):
|
|
"""
|
|
Disconnects any existing session under the same object. This is used in
|
|
connection recovery to help with record-keeping.
|
|
"""
|
|
session_list = get_session_list()
|
|
session_pobj = session.get_pobject()
|
|
for other_session in session_list:
|
|
other_pobject = other_session.get_pobject()
|
|
if session_pobj == other_pobject and other_session != session:
|
|
other_session.msg("Your account has been logged in from elsewhere, disconnecting.")
|
|
other_session.disconnectClient()
|
|
return True
|
|
return False
|
|
|
|
def check_all_sessions():
|
|
"""
|
|
Check all currently connected sessions and see if any are dead.
|
|
"""
|
|
idle_timeout = int(ConfigValue.objects.get_configvalue('idle_timeout'))
|
|
|
|
if len(session_list) <= 0:
|
|
return
|
|
|
|
if idle_timeout <= 0:
|
|
return
|
|
|
|
for sess in get_session_list(return_unlogged=True):
|
|
if (time.time() - sess.cmd_last) > idle_timeout:
|
|
sess.msg("Idle timeout exceeded, disconnecting.")
|
|
sess.handle_close()
|
|
|
|
def remove_session(session):
|
|
"""
|
|
Removes a session from the session list.
|
|
"""
|
|
try:
|
|
session_list.remove(session)
|
|
logger.log_infomsg('Sessions active: %d' % (len(get_session_list()),))
|
|
except ValueError:
|
|
#logger.log_errmsg("Unable to remove session: %s" % (session,))
|
|
pass
|
|
|
|
|
|
def sessions_from_object(targ_object):
|
|
"""
|
|
Returns a list of matching session objects, or None if there are no matches.
|
|
|
|
targobject: (Object) The object to match.
|
|
"""
|
|
return [prospect for prospect in session_list if prospect.get_pobject() == targ_object]
|
|
|
|
def announce_all(message, with_ann_prefix=True):
|
|
"""
|
|
Announces something to all connected players.
|
|
"""
|
|
if with_ann_prefix:
|
|
prefix = 'Announcement:'
|
|
else:
|
|
prefix = ''
|
|
|
|
for session in get_session_list():
|
|
session.msg('%s %s' % (prefix, message))
|