3
0
mirror of https://github.com/jlu5/PyLink.git synced 2024-11-30 14:49:28 +01:00

relay: switch to IRCParser in 'link' and add a --force option to skip TS checks

Closes #416.
This commit is contained in:
James Lu 2017-02-21 21:52:01 -08:00
parent bf702575be
commit 93c9b6289c
2 changed files with 33 additions and 26 deletions

View File

@ -83,6 +83,7 @@ Remote versions of the `manage`, `list`, `sync`, and `clear` commands also exist
- `relay.linkacl` - Allows access to the `linkacl` command. **With the default permissions set, this is granted to all opers.** - `relay.linkacl` - Allows access to the `linkacl` command. **With the default permissions set, this is granted to all opers.**
- `relay.linkacl.view` - Allows access to the `view` command. **With the default permissions set, this is granted to all opers.** - `relay.linkacl.view` - Allows access to the `view` command. **With the default permissions set, this is granted to all opers.**
- `relay.link` - Allows access to the `link` command. **With the default permissions set, this is granted to all opers.** - `relay.link` - Allows access to the `link` command. **With the default permissions set, this is granted to all opers.**
- `relay.link.force` - Allows access to the `--force` option in the `link` command (skip TS and target network is connected checks).
- `relay.linked` - Allows access to the `link` command. **With the default permissions set, this is granted to all users.** - `relay.linked` - Allows access to the `link` command. **With the default permissions set, this is granted to all users.**
- `relay.purge` - Allows access to the `purge` command. - `relay.purge` - Allows access to the `purge` command.
- `relay.savedb` - Allows access to the `savedb` command. - `relay.savedb` - Allows access to the `savedb` command.

View File

@ -1668,24 +1668,25 @@ def purge(irc, source, args):
irc.reply("Done. Purged %s entries involving the network %s." % (count, network)) irc.reply("Done. Purged %s entries involving the network %s." % (count, network))
link_parser = utils.IRCParser()
link_parser.add_argument('remotenet')
link_parser.add_argument('channel')
link_parser.add_argument('localchannel', nargs='?')
link_parser.add_argument("-f", "--force", action='store_true')
def link(irc, source, args): def link(irc, source, args):
"""<remotenet> <channel> [<local channel>] """<remotenet> <channel> [<local channel>] [-f/--force]
Links the specified channel on \x02remotenet\x02 over PyLink Relay as \x02local channel\x02. Links the specified channel on \x02remotenet\x02 over PyLink Relay as \x02local channel\x02.
If \x02local channel\x02 is not specified, it defaults to the same name as \x02channel\x02.""" If \x02local channel\x02 is not specified, it defaults to the same name as \x02channel\x02.
try:
channel = irc.toLower(args[1])
remotenet = args[0]
except IndexError:
irc.error("Not enough arguments. Needs 2-3: remote netname, channel, local channel name (optional).")
return
try: If the --force option is given, this command will bypass checks for TS and whether the target
localchan = irc.toLower(args[2]) network is alive, and link the channel anyways."""
except IndexError: args = link_parser.parse_args(args)
localchan = channel
for c in (channel, localchan): localchan = irc.toLower(args.localchannel or args.channel)
remotenet = args.remotenet
for c in (args.channel, localchan):
if not utils.isChannel(c): if not utils.isChannel(c):
irc.error('Invalid channel %r.' % c) irc.error('Invalid channel %r.' % c)
return return
@ -1725,9 +1726,9 @@ def link(irc, source, args):
try: try:
with db_lock: with db_lock:
entry = db[(remotenet, channel)] entry = db[(remotenet, args.channel)]
except KeyError: except KeyError:
irc.error('No such relay %r exists.' % channel) irc.error('No such relay %r exists.' % args.channel)
return return
else: else:
if irc.name in entry['blocked_nets']: if irc.name in entry['blocked_nets']:
@ -1736,14 +1737,19 @@ def link(irc, source, args):
for link in entry['links']: for link in entry['links']:
if link[0] == irc.name: if link[0] == irc.name:
irc.error("Remote channel '%s%s' is already linked here " irc.error("Remote channel '%s%s' is already linked here "
"as %r." % (remotenet, channel, link[1])) "as %r." % (remotenet, args.channel, link[1]))
return return
if args.force:
permissions.checkPermissions(irc, source, ['relay.link.force'])
log.info("(%s) relay: Forcing link %s%s -> %s%s", irc.name, irc.name, localchan, remotenet,
args.channel)
else:
our_ts = irc.channels[localchan].ts our_ts = irc.channels[localchan].ts
their_ts = world.networkobjects[remotenet].channels[channel].ts their_ts = world.networkobjects[remotenet].channels[args.channel].ts
if (our_ts < their_ts) and irc.protoname != 'clientbot': if (our_ts < their_ts) and irc.protoname != 'clientbot':
log.debug('(%s) relay: Blocking link request %s%s -> %s%s due to bad TS (%s < %s)', irc.name, log.debug('(%s) relay: Blocking link request %s%s -> %s%s due to bad TS (%s < %s)', irc.name,
irc.name, localchan, remotenet, channel, our_ts, their_ts) irc.name, localchan, remotenet, args.channel, our_ts, their_ts)
irc.error("The channel creation date (TS) on %s (%s) is lower than the target " irc.error("The channel creation date (TS) on %s (%s) is lower than the target "
"channel's (%s); refusing to link. You should clear the local channel %s first " "channel's (%s); refusing to link. You should clear the local channel %s first "
"before linking, or use a different local channel." % (localchan, our_ts, their_ts, localchan)) "before linking, or use a different local channel." % (localchan, our_ts, their_ts, localchan))
@ -1751,7 +1757,7 @@ def link(irc, source, args):
entry['links'].add((irc.name, localchan)) entry['links'].add((irc.name, localchan))
log.info('(%s) relay: Channel %s linked to %s%s by %s.', irc.name, log.info('(%s) relay: Channel %s linked to %s%s by %s.', irc.name,
localchan, remotenet, channel, irc.getHostmask(source)) localchan, remotenet, args.channel, irc.getHostmask(source))
initialize_channel(irc, localchan) initialize_channel(irc, localchan)
irc.reply('Done.') irc.reply('Done.')
link = utils.add_cmd(link, featured=True) link = utils.add_cmd(link, featured=True)