GitHub/PyLink
3
0
Fork 0
mirror of https://github.com/jlu5/PyLink.git synced 2024-12-28 13:42:37 +01:00
Code Issues Projects Releases Wiki Activity

relay: further fixes for persistent channels

Browse Source 
Also, merge the 'relay_local' and 'relay_remote' namespaces into one.
This commit is contained in:
James Lu 2018-05-05 12:52:00 -07:00
parent e9fe15bd7d
commit 8994811f54
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
plugins/relay.py
View File

@ -532,14 +532,14 @@ def initialize_channel(irc, channel):
relay_joins(irc, channel, c.users, c.ts)
if 'pylink' in world.services:
world.services['pylink'].add_persistent_channel(irc, 'relay_local', channel)
world.services['pylink'].add_persistent_channel(irc, 'relay', channel)
def remove_channel(irc, channel):
"""Destroys a relay channel by parting all of its users."""
if irc is None:
return
world.services['pylink'].remove_persistent_channel(channel, 'relay_local', try_part=False)
world.services['pylink'].remove_persistent_channel(irc, 'relay', channel, try_part=False)
relay = get_relay(irc, channel)
if relay and channel in irc.channels:
@ -720,6 +720,11 @@ def relay_joins(irc, channel, users, ts, targetirc=None, **kwargs):
if not u:
continue
# Join the service bot on the remote channel persistently.
rsbot = remoteirc.get_service_bot(u)
if rsbot:
rsbot.add_persistent_channel(irc, 'relay', channel, try_join=False)
if (remotechan not in remoteirc.channels) or u not in remoteirc.channels[remotechan].users:
# Note: only join users if they aren't already joined. This prevents op floods
# on charybdis from repeated SJOINs sent for one user.
@ -740,11 +745,6 @@ def relay_joins(irc, channel, users, ts, targetirc=None, **kwargs):
# proto.sjoin() takes its users as a list of (prefix mode characters, UID) pairs.
userpair = (prefixes, u)
# Join the service bot on the remote channel persistently.
rsbot = remoteirc.get_service_bot(u)
if rsbot:
rsbot.add_persistent_channel(irc, 'relay_remote', channel, try_join=False)
queued_users.append(userpair)
if queued_users:
@ -818,10 +818,10 @@ def relay_part(irc, *args, **kwargs):
return
# Remove any persistent channel entries from the remote end.
rsbot = remoteirc.get_service_bot(u)
rsbot = remoteirc.get_service_bot(remoteuser)
if rsbot:
try:
sbot.remove_persistent_channel(irc, 'relay_remote', channel, try_part=False)
sbot.remove_persistent_channel(irc, 'relay', channel, try_part=False)
except KeyError:
pass