mirror of
https://github.com/NohamR/TransmissionBot.git
synced 2025-05-24 00:48:59 +00:00
2217e3688b
When auto-updating `summary`, reactions were not being removed for listing types of transfers of which there were none. Now that's fixed. e.g. if the number of downloading transfers goes from 1 to zero, the downloading reaction will be removed the next time the output is updated.
1042 lines
39 KiB
Python
1042 lines
39 KiB
Python
""""
|
||
Copyright © twilsonco 2020
|
||
Description:
|
||
This is a discord bot to manage torrent transfers through the Transmission transmissionrpc python library.
|
||
|
||
Version: 1.0
|
||
"""
|
||
|
||
import discord
|
||
import asyncio
|
||
import aiohttp
|
||
import json
|
||
import subprocess
|
||
from discord.ext.commands import Bot
|
||
from discord.ext import commands
|
||
from platform import python_version
|
||
import os
|
||
from os.path import expanduser, join
|
||
import re
|
||
import datetime
|
||
import pytz
|
||
import platform
|
||
import transmissionrpc
|
||
import logging
|
||
|
||
# BEGIN USER CONFIGURATION
|
||
|
||
BOT_PREFIX = 't/'
|
||
TOKEN = 'SECRET_TOKEN'
|
||
OWNERS = [OWNER_USER_IDS]
|
||
BLACKLIST = [USER_IDS]
|
||
WHITELIST = [USER_IDS]
|
||
CHANNEL_IDS=[CHANNEL_IDS]
|
||
LOGO_URL="https://iyanovich.files.wordpress.com/2009/04/transmission-logo.png"
|
||
|
||
TSCLIENT_CONFIG={
|
||
'host': "10.0.1.2",
|
||
'port': 9091,
|
||
'user': "USERNAME",
|
||
'password': "PASSWORD"
|
||
}
|
||
|
||
DRYRUN = False
|
||
REPEAT_FREQ = 2 # time in seconds to wait between reprinting repeated commands (in addition to the time requred to delete old message(s) and add reactions)
|
||
REPEAT_TIMEOUT = 3600 # time in seconds before a repeated command automatically stops
|
||
|
||
logging.basicConfig(format='%(asctime)s %(message)s',filename=join(expanduser("~"),'transmissionbot.log'))
|
||
|
||
# END USER CONFIGURATION
|
||
|
||
REPEAT_COMMAND = False
|
||
REPEAT_MSG_LIST = []
|
||
REPEAT_START_TIME = 0
|
||
|
||
client = Bot(command_prefix=BOT_PREFIX)
|
||
TSCLIENT = None
|
||
|
||
logger = logging.getLogger('transmission_bot')
|
||
logger.setLevel(logging.INFO)
|
||
DEFAULT_REASON="TransmissionBot"
|
||
|
||
# Begin transmissionrpc functions, lovingly taken from https://github.com/leighmacdonald/transmission_scripts
|
||
|
||
filter_names = ( # these are the filters accepted by transmissionrpc
|
||
"all",
|
||
"active",
|
||
"downloading",
|
||
"seeding",
|
||
"stopped",
|
||
"finished"
|
||
)
|
||
|
||
filter_names_extra = ( # these are extra filters I've added
|
||
"stalled",
|
||
"private",
|
||
"public",
|
||
"error",
|
||
'err_none',
|
||
'err_tracker_warn',
|
||
'err_tracker_error',
|
||
'err_local',
|
||
'verifying',
|
||
'queued',
|
||
"running" # running means a non-zero transfer rate, not to be confused with "active"
|
||
)
|
||
|
||
filter_names_full = filter_names + filter_names_extra
|
||
|
||
sort_names = (
|
||
"id",
|
||
"progress",
|
||
"name",
|
||
"size",
|
||
"ratio",
|
||
"speed",
|
||
"speed_up",
|
||
"speed_down",
|
||
"status",
|
||
"queue",
|
||
"age",
|
||
"activity"
|
||
)
|
||
|
||
class TSClient(transmissionrpc.Client):
|
||
""" Basic subclass of the standard transmissionrpc client which provides some simple
|
||
helper functionality.
|
||
"""
|
||
|
||
def get_torrents_by(self, sort_by=None, filter_by=None, reverse=False, filter_regex=None, id_list=None):
|
||
"""This method will call get_torrents and then perform any sorting or filtering
|
||
actions requested on the returned torrent set.
|
||
|
||
:param sort_by: Sort key which must exist in `Sort.names` to be valid;
|
||
:type sort_by: str
|
||
:param filter_by:
|
||
:type filter_by: str
|
||
:param reverse:
|
||
:return: Sorted and filter torrent list
|
||
:rtype: transmissionrpc.Torrent[]
|
||
"""
|
||
torrents = self.get_torrents()
|
||
if filter_regex:
|
||
regex = re.compile(filter_regex, re.IGNORECASE)
|
||
torrents = [tor for tor in torrents if regex.search(tor.name)]
|
||
if id_list:
|
||
torrents = [tor for tor in torrents if tor.id in id_list]
|
||
if filter_by:
|
||
for f in filter_by.split():
|
||
if f in filter_names:
|
||
torrents = filter_torrents_by(torrents, key=getattr(Filter, filter_by))
|
||
elif f == "verifying":
|
||
torrents = [t for t in torrents if "check" in t.status]
|
||
elif f == "queued":
|
||
torrents = [t for t in torrents if "load pending" in t.status]
|
||
elif f == "stalled":
|
||
torrents = [t for t in torrents if t.isStalled]
|
||
elif f == "private":
|
||
torrents = [t for t in torrents if t.isPrivate]
|
||
elif f == "public":
|
||
torrents = [t for t in torrents if not t.isPrivate]
|
||
elif f == "error":
|
||
torrents = [t for t in torrents if t.error != 0]
|
||
elif f == "running":
|
||
torrents = [t for t in torrents if t.rateDownload + t.rateUpload > 0]
|
||
else:
|
||
continue
|
||
if sort_by is None:
|
||
if "downloading" in filter_by or "seeding" in filter_by or "running" in filter_by:
|
||
sort_by = "speed"
|
||
elif "stopped" in filter_by or "finished" in filter_by:
|
||
sort_by = "ratio"
|
||
if sort_by:
|
||
torrents = sort_torrents_by(torrents, key=getattr(Sort, sort_by), reverse=reverse)
|
||
return torrents
|
||
|
||
def make_client():
|
||
""" Create a new transmission RPC client
|
||
|
||
If you want to parse more than the standard CLI arguments, like when creating a new customized
|
||
script, you can append your options to the argument parser.
|
||
|
||
:param args: Optional CLI args passed in.
|
||
:return:
|
||
"""
|
||
try:
|
||
return TSClient(
|
||
TSCLIENT_CONFIG['host'],
|
||
port=TSCLIENT_CONFIG['port'],
|
||
user=TSCLIENT_CONFIG['user'],
|
||
password=TSCLIENT_CONFIG['password']
|
||
)
|
||
except:
|
||
return None
|
||
|
||
class Filter(object):
|
||
"""A set of filtering operations that can be used against a list of torrent objects"""
|
||
|
||
# names = (
|
||
# "all",
|
||
# "active",
|
||
# "downloading",
|
||
# "seeding",
|
||
# "stopped",
|
||
# "finished"
|
||
# )
|
||
names = filter_names
|
||
|
||
@staticmethod
|
||
def all(t):
|
||
return t
|
||
|
||
@staticmethod
|
||
def active(t):
|
||
return t.rateUpload > 0 or t.rateDownload > 0
|
||
|
||
@staticmethod
|
||
def downloading(t):
|
||
return t.status == 'downloading'
|
||
|
||
@staticmethod
|
||
def seeding(t):
|
||
return t.status == 'seeding'
|
||
|
||
@staticmethod
|
||
def stopped(t):
|
||
return t.status == 'stopped'
|
||
|
||
@staticmethod
|
||
def finished(t):
|
||
return t.status == 'finished'
|
||
|
||
@staticmethod
|
||
def lifetime(t):
|
||
return t.date_added
|
||
|
||
|
||
def filter_torrents_by(torrents, key=Filter.all):
|
||
"""
|
||
|
||
:param key:
|
||
:param torrents:
|
||
:return: []transmissionrpc.Torrent
|
||
"""
|
||
filtered_torrents = []
|
||
for torrent in torrents:
|
||
if key(torrent):
|
||
filtered_torrents.append(torrent)
|
||
return filtered_torrents
|
||
|
||
class Sort(object):
|
||
""" Defines methods for sorting torrent sequences """
|
||
|
||
# names = (
|
||
# "id",
|
||
# "progress",
|
||
# "name",
|
||
# "size",
|
||
# "ratio",
|
||
# "speed",
|
||
# "speed_up",
|
||
# "speed_down",
|
||
# "status",
|
||
# "queue",
|
||
# "age",
|
||
# "activity"
|
||
# )
|
||
names = sort_names
|
||
|
||
@staticmethod
|
||
def activity(t):
|
||
return t.date_active
|
||
|
||
@staticmethod
|
||
def age(t):
|
||
return t.date_added
|
||
|
||
@staticmethod
|
||
def queue(t):
|
||
return t.queue_position
|
||
|
||
@staticmethod
|
||
def status(t):
|
||
return t.status
|
||
|
||
@staticmethod
|
||
def progress(t):
|
||
return t.progress
|
||
|
||
@staticmethod
|
||
def name(t):
|
||
return t.name.lower()
|
||
|
||
@staticmethod
|
||
def size(t):
|
||
return -t.totalSize
|
||
|
||
@staticmethod
|
||
def id(t):
|
||
return t.id
|
||
|
||
@staticmethod
|
||
def ratio(t):
|
||
return t.ratio
|
||
|
||
@staticmethod
|
||
def speed(t):
|
||
return t.rateUpload + t.rateDownload
|
||
|
||
@staticmethod
|
||
def speed_up(t):
|
||
return t.rateUpload
|
||
|
||
@staticmethod
|
||
def speed_down(t):
|
||
return t.rateDownload
|
||
|
||
|
||
def sort_torrents_by(torrents, key=Sort.name, reverse=False):
|
||
return sorted(torrents, key=key, reverse=reverse)
|
||
|
||
# def print_torrent_line(torrent, colourize=True):
|
||
# name = torrent.name
|
||
# progress = torrent.progress / 100.0
|
||
# print("[{}] [{}] {} {}[{}/{}]{} ra: {} up: {} dn: {} [{}]".format(
|
||
# white_on_blk(torrent.id),
|
||
# find_tracker(torrent),
|
||
# print_pct(torrent) if colourize else name.decode("latin-1"),
|
||
# white_on_blk(""),
|
||
# red_on_blk("{:.0%}".format(progress)) if progress < 1 else green_on_blk("{:.0%}".format(progress)),
|
||
# magenta_on_blk(natural_size(torrent.totalSize)),
|
||
# white_on_blk(""),
|
||
# red_on_blk(torrent.ratio) if torrent.ratio < 1.0 else green_on_blk(torrent.ratio),
|
||
# green_on_blk(natural_size(float(torrent.rateUpload)) + "/s") if torrent.rateUpload else "0.0 kB/s",
|
||
# green_on_blk(natural_size(float(torrent.rateDownload)) + "/s") if torrent.rateDownload else "0.0 kB/s",
|
||
# yellow_on_blk(torrent.status)
|
||
# ))
|
||
|
||
def remove_torrent(torrent, reason=DEFAULT_REASON, delete_files=False):
|
||
""" Remove a torrent from the client stopping it first if its in a started state.
|
||
|
||
:param client: Transmission RPC Client
|
||
:type client: transmissionrpc.Client
|
||
:param torrent: Torrent instance to remove
|
||
:type torrent: transmissionrpc.Torrent
|
||
:param reason: Reason for removal
|
||
:type reason: str
|
||
:param dry_run: Do a dry run without actually running any commands
|
||
:type dry_run: bool
|
||
:return:
|
||
"""
|
||
if torrent.status != "stopped":
|
||
if not DRYRUN:
|
||
TSCLIENT.stop_torrent(torrent.hashString)
|
||
if not DRYRUN:
|
||
TSCLIENT.remove_torrent(torrent.hashString, delete_data=delete_files)
|
||
logger.info("Removed: {} {}\n\tReason: {}\n\tDry run: {}, Delete files: {}".format(torrent.name, torrent.hashString, reason, DRYRUN,delete_files))
|
||
|
||
def remove_torrents(torrents, reason=DEFAULT_REASON, delete_files=False):
|
||
""" Remove a torrent from the client stopping it first if its in a started state.
|
||
|
||
:param client: Transmission RPC Client
|
||
:type client: transmissionrpc.Client
|
||
:param torrent: Torrent instance to remove
|
||
:type torrent: transmissionrpc.Torrent
|
||
:param reason: Reason for removal
|
||
:type reason: str
|
||
:param dry_run: Do a dry run without actually running any commands
|
||
:type dry_run: bool
|
||
:return:
|
||
"""
|
||
for torrent in torrents:
|
||
remove_torrent(torrent, reason=reason, delete_files=delete_files)
|
||
|
||
def stop_torrents(torrents=[], reason=DEFAULT_REASON):
|
||
""" Stop (pause) a list of torrents from the client.
|
||
|
||
:param client: Transmission RPC Client
|
||
:type client: transmissionrpc.Client
|
||
:param torrent: Torrent instance to remove
|
||
:type torrent: transmissionrpc.Torrent
|
||
:param reason: Reason for removal
|
||
:type reason: str
|
||
:param dry_run: Do a dry run without actually running any commands
|
||
:type dry_run: bool
|
||
:return:
|
||
"""
|
||
for torrent in (torrents if len(torrents) > 0 else TSCLIENT.get_torrents()):
|
||
if torrent.status not in ["stopped","finished"]:
|
||
if not DRYRUN:
|
||
TSCLIENT.stop_torrent(torrent.hashString)
|
||
logger.info("Paused: {} {}\n\tReason: {}\n\tDry run: {}".format(torrent.name, torrent.hashString, reason, DRYRUN))
|
||
|
||
def resume_torrents(torrents=[], reason=DEFAULT_REASON):
|
||
""" Stop (pause) a list of torrents from the client.
|
||
|
||
:param client: Transmission RPC Client
|
||
:type client: transmissionrpc.Client
|
||
:param torrent: Torrent instance to remove
|
||
:type torrent: transmissionrpc.Torrent
|
||
:param reason: Reason for removal
|
||
:type reason: str
|
||
:param dry_run: Do a dry run without actually running any commands
|
||
:type dry_run: bool
|
||
:return:
|
||
"""
|
||
for torrent in (torrents if len(torrents) > 0 else TSCLIENT.get_torrents()):
|
||
if torrent.status == "stopped":
|
||
if not DRYRUN:
|
||
TSCLIENT.start_torrent(torrent.hashString)
|
||
logger.info("Resumed: {} {}\n\tReason: {}\n\tDry run: {}".format(torrent.name, torrent.hashString, reason, DRYRUN))
|
||
|
||
def verify_torrents(torrents=[]):
|
||
""" Verify a list of torrents from the client.
|
||
|
||
:param client: Transmission RPC Client
|
||
:type client: transmissionrpc.Client
|
||
:param torrent: Torrent instance to remove
|
||
:type torrent: transmissionrpc.Torrent
|
||
:type reason: str
|
||
:param dry_run: Do a dry run without actually running any commands
|
||
:type dry_run: bool
|
||
:return:
|
||
"""
|
||
for torrent in (torrents if len(torrents) > 0 else TSCLIENT.get_torrents()):
|
||
if not DRYRUN:
|
||
TSCLIENT.verify_torrent(torrent.hashString)
|
||
logger.info("Verified: {} {}\n\tDry run: {}".format(torrent.name, torrent.hashString, DRYRUN))
|
||
|
||
def add_torrent(torStr):
|
||
tor = None
|
||
if torStr != "":
|
||
tor = TSCLIENT.add_torrent(torStr)
|
||
return tor
|
||
|
||
|
||
# Begin discord bot functions, adapted from https://github.com/kkrypt0nn/Python-Discord-Bot-Template
|
||
|
||
# async def status_task():
|
||
# while True:
|
||
# await client.change_presence(activity=discord.Game("{}help".format(BOT_PREFIX)))
|
||
# await asyncio.sleep(86400)
|
||
|
||
@client.event
|
||
async def on_ready():
|
||
global TSCLIENT
|
||
TSCLIENT = make_client()
|
||
if TSCLIENT is None:
|
||
print("Failed to create transmissionrpc client")
|
||
else:
|
||
# client.loop.create_task(status_task())
|
||
await client.change_presence(activity=discord.Game("{}help".format(BOT_PREFIX)))
|
||
print('Logged in as ' + client.user.name)
|
||
print("Discord.py API version:", discord.__version__)
|
||
print("Python version:", platform.python_version())
|
||
print("Running on:", platform.system(), platform.release(), "(" + os.name + ")")
|
||
print('-------------------')
|
||
|
||
def humanbytes(B):
|
||
'Return the given bytes as a human friendly KB, MB, GB, or TB string'
|
||
B = float(B)
|
||
KB = float(1024)
|
||
MB = float(KB ** 2) # 1,048,576
|
||
GB = float(KB ** 3) # 1,073,741,824
|
||
TB = float(KB ** 4) # 1,099,511,627,776
|
||
|
||
if B < KB:
|
||
return '{0} {1}'.format(B,'B')
|
||
elif KB <= B < MB:
|
||
return '{0:.2f} kB'.format(B/KB)
|
||
elif MB <= B < GB:
|
||
return '{0:.2f} MB'.format(B/MB)
|
||
elif GB <= B < TB:
|
||
return '{0:.2f} GB'.format(B/GB)
|
||
elif TB <= B:
|
||
return '{0:.2f} TB'.format(B/TB)
|
||
|
||
def tobytes(B):
|
||
'Return the number of bytes given by a string (a float followed by a space and the unit of prefix-bytes eg. "21.34 GB")'
|
||
numstr = B.lower().split(' ')
|
||
KB = (('kilo','kb','kb/s'),float(1024))
|
||
MB = (('mega','mb','mb/s'),float(KB[1] ** 2)) # 1,048,576
|
||
GB = (('giga','gb','gb/s'),float(KB[1] ** 3)) # 1,073,741,824
|
||
TB = (('tera','tb','tb/s'),float(KB[1] ** 4)) # 1,099,511,627,776
|
||
|
||
for prefix in (KB,MB,GB,TB):
|
||
if numstr[1] in prefix[0]:
|
||
return float(float(numstr[0]) * prefix[1])
|
||
|
||
# check that message author is allowed and message was sent in allowed channel
|
||
async def CommandPrecheck(context):
|
||
if len(CHANNEL_IDS) > 0 and context.message.channel.id not in CHANNEL_IDS:
|
||
await context.message.channel.send("I don't respond to commands in this channel...")
|
||
return False
|
||
elif context.message.author.id in BLACKLIST or (len(WHITELIST) > 0 and context.message.author.id not in WHITELIST):
|
||
await context.message.channel.send("You're not allowed to use this...")
|
||
return False
|
||
return True
|
||
|
||
@client.command(name='add', aliases=['a'], pass_context=True)
|
||
async def add(context, *, content):
|
||
if await CommandPrecheck(context):
|
||
if content == "":
|
||
await context.message.channel.send("Invalid string")
|
||
else:
|
||
await context.message.delete()
|
||
torStr = None
|
||
for t in content.strip().split(" "):
|
||
await context.message.channel.send('Adding torrent {}\n Please wait...'.format(t))
|
||
tor = add_torrent(t)
|
||
if torStr:
|
||
torStr += "\n{}" % tor.name
|
||
else:
|
||
torStr = tor.name
|
||
await context.message.channel.send('✅ Added torrent{}:\n{}'.format("s" if len(content.strip().split(" ")) > 1 else "", torStr))
|
||
|
||
# def torInfo(t):
|
||
# states = ('downloading', 'seeding', 'stopped', 'finished','all')
|
||
# stateEmoji = {i:j for i,j in zip(states,['🔻','🌱','⏸','🏁','↕️'])}
|
||
#
|
||
# downStr = humanbytes(t.progress * 0.01 * t.totalSize)
|
||
# upStr = "{} (Ratio: {:.2f})".format(humanbytes(t.uploadedEver), t.uploadRatio)
|
||
# runTime =
|
||
#
|
||
# if t.progress < 100.0:
|
||
# have = "{} of {} ({:.1f}){}{}".format(downStr,humanbytes(t.totalSize), t.progress, '' if t.haveUnchecked == 0 else ', {} Unverified'.format(humanbytes(t.haveUnchecked)), '' if t.corruptEver == 0 else ', {} Corrupt'.format(humanbytes(t.corruptEver)))
|
||
# avail = "{:.1f}%".format(t.desiredAvailable/t.leftUntilDone)
|
||
# else:
|
||
# have = "{} ({:d}){}{}".format(humanbytes(t.totalSize), t.progress, '' if t.haveUnchecked == 0 else ', {} Unverified'.format(humanbytes(t.haveUnchecked)), '' if t.corruptEver == 0 else ', {} Corrupt'.format(humanbytes(t.corruptEver)))
|
||
# avail = "100%"
|
||
#
|
||
# embed=discord.Embed(title=t.name,color=0xb51a00)
|
||
#
|
||
# return embed
|
||
|
||
torStates = ('downloading', 'seeding', 'stopped', 'verifying', 'queued', 'finished', #0-5
|
||
'stalled', 'active', 'running', #6-8
|
||
'private', 'public', #9-10
|
||
'error', 'err_none', 'err_tracker_warn', 'err_tracker_error', 'err_local', # 11-
|
||
)
|
||
torStateEmoji = ('🔻','🌱','⏸','🩺','🚧','🏁',
|
||
'🐢','🐇','🚀',
|
||
'🔒','🔓',
|
||
'‼️','✅','⚠️','🌐','🖥'
|
||
)
|
||
torStateFilters = {i:"--filter {}".format(j) for i,j in zip(torStateEmoji,torStates)}
|
||
torStateFilters['↕️']=''
|
||
|
||
def numTorInState(torrents, state):
|
||
rpc_states = ('downloading', 'seeding', 'stopped', 'finished')
|
||
if state in rpc_states:
|
||
return len([True for t in torrents if t.status == state])
|
||
elif state =='verifying': # these are also rpc statuses, but I want to combine them.
|
||
return len([True for t in torrents if 'check' in t.status])
|
||
elif state == 'queued':
|
||
return len([True for t in torrents if 'load pending' in t.status])
|
||
elif state == 'stalled':
|
||
return len([True for t in torrents if t.isStalled])
|
||
elif state == 'active':
|
||
return len([True for t in torrents if not t.isStalled]) - len([True for t in torrents if t.rateDownload + t.rateUpload > 0])
|
||
elif state == 'running':
|
||
return len([True for t in torrents if t.rateDownload + t.rateUpload > 0])
|
||
elif state == 'private':
|
||
return len([True for t in torrents if t.isPrivate])
|
||
elif state == 'public':
|
||
return len([True for t in torrents if not t.isPrivate])
|
||
elif state == 'error':
|
||
return len([True for t in torrents if t.error != 0])
|
||
elif state == 'err_none':
|
||
return len([True for t in torrents if t.error == 0])
|
||
elif state == 'err_twarn':
|
||
return len([True for t in torrents if t.error == 1])
|
||
elif state == 'err_terr':
|
||
return len([True for t in torrents if t.error == 2])
|
||
elif state == 'err_local':
|
||
return len([True for t in torrents if t.error == 3])
|
||
else:
|
||
return 0
|
||
|
||
def torSummary(torrents, repeat=False):
|
||
numInState = [numTorInState(torrents,s) for s in torStates]
|
||
numTot = len(torrents)
|
||
|
||
sumTot = sum([t.totalSize for t in torrents])
|
||
totSize = humanbytes(sumTot)
|
||
totUpRate = humanbytes(sum([t.rateUpload for t in torrents]))
|
||
totDownRate = humanbytes(sum([t.rateDownload for t in torrents]))
|
||
|
||
downList = [t.progress*0.01*t.totalSize for t in torrents]
|
||
upList = [t.ratio * j for t,j in zip(torrents,downList)]
|
||
|
||
sumDown = sum(downList)
|
||
sumUp = sum(upList)
|
||
|
||
totDown = humanbytes(sumDown)
|
||
totUp = humanbytes(sumUp)
|
||
|
||
totRatio = '{:.2f}'.format(sumUp / sumDown)
|
||
|
||
totDownRatio = '{:.2f}'.format(sumDown / sumTot * 100.0)
|
||
|
||
numTopRatios = min([len(torrents),5])
|
||
topRatios = "• Top {} ratio{}:".format(numTopRatios,"s" if numTopRatios != 1 else "")
|
||
sortByRatio = sorted(torrents,key=lambda t:float(t.ratio),reverse=True)
|
||
for i in range(numTopRatios):
|
||
topRatios += "\n {:.1f} {:.35}{}".format(float(sortByRatio[i].ratio),sortByRatio[i].name,"..." if len(sortByRatio[i].name) > 35 else "")
|
||
|
||
embed=discord.Embed(description="*React to see list of corresponding transfers*", color=0xb51a00)
|
||
embed.set_author(name="Torrent Summary 🌊", icon_url=LOGO_URL)
|
||
embed.add_field(name="⬇️ {}/s".format(totDownRate), value="⬆️ {}/s".format(totUpRate), inline=False)
|
||
embed.add_field(name="⏬ {} of {}".format(totDown,totSize), value="⏫ {} ⚖️ {}".format(totUp,totRatio), inline=False)
|
||
embed.add_field(name="↕️ {} transfer{}".format(numTot, 's' if numTot != 1 else ''), value=' '.join(['{} {}'.format(i,j) for i,j in zip(torStateEmoji[:6], numInState[:6])]), inline=False)
|
||
embed.add_field(name="{} Error{}".format(numInState[11], 's' if numInState[9] != 1 else ''), value='\n'.join(['{} {}'.format(i,"**{}**".format(j) if i != '✅' and j > 0 else j) for i,j in zip(torStateEmoji[12:], numInState[12:])]), inline=True)
|
||
embed.add_field(name="Activity", value='\n'.join(['{} {}'.format(i,j) for i,j in zip(torStateEmoji[6:9], numInState[6:9])]), inline=True)
|
||
embed.add_field(name="Tracker", value='\n'.join(['{} {}'.format(i,j) for i,j in zip(torStateEmoji[9:11], numInState[9:11])]), inline=True)
|
||
|
||
embed.set_footer(text=topRatios+"\n📜 Symbol legend{}".format('\nUpdating every {} second{}—❎ to stop'.format(REPEAT_FREQ,'s' if REPEAT_FREQ != 1 else '') if repeat else ', 🔄 to auto-update'))
|
||
# await context.message.channel.send(embed=embed)
|
||
return embed,numInState
|
||
|
||
@client.command(name='summary',aliases=['s'], pass_context=True)
|
||
async def summary(context, *, content="", repeat=False):
|
||
global REPEAT_COMMAND, REPEAT_MSG_LIST
|
||
if await CommandPrecheck(context):
|
||
if not repeat:
|
||
await context.message.delete()
|
||
stateEmoji = ('📜','❎' if repeat else '🔄','↕️') + torStateEmoji
|
||
ignoreEmoji = ('✅')
|
||
|
||
summaryData=torSummary(TSCLIENT.get_torrents(), repeat=repeat)
|
||
|
||
if repeat:
|
||
msg = REPEAT_MSG_LIST[0]
|
||
if context.message.channel.last_message_id != msg.id:
|
||
await msg.delete()
|
||
msg = await context.message.channel.send(embed=summaryData[0])
|
||
REPEAT_MSG_LIST = [msg]
|
||
else:
|
||
await msg.edit(embed=summaryData[0])
|
||
else:
|
||
msg = await context.message.channel.send(embed=summaryData[0])
|
||
|
||
# to get actual list of reactions, need to re-fetch the message from the server
|
||
cache_msg = await context.message.channel.fetch_message(msg.id)
|
||
msgRxns = [str(r.emoji) for r in cache_msg.reactions]
|
||
|
||
for i in stateEmoji[:2]:
|
||
if i not in msgRxns:
|
||
await msg.add_reaction(i)
|
||
for i in range(len(summaryData[1])):
|
||
if summaryData[1][i] > 0 and stateEmoji[i+3] not in ignoreEmoji and stateEmoji[i+3] not in msgRxns:
|
||
await msg.add_reaction(stateEmoji[i+3])
|
||
elif summaryData[1][i] == 0 and stateEmoji[i+3] in msgRxns:
|
||
await msg.clear_reaction(stateEmoji[i+3])
|
||
|
||
def check(reaction, user):
|
||
return user == context.message.author and reaction.message.id == msg.id and str(reaction.emoji) in stateEmoji
|
||
|
||
try:
|
||
reaction, user = await client.wait_for('reaction_add', timeout=60.0 if not repeat else REPEAT_FREQ, check=check)
|
||
except asyncio.TimeoutError:
|
||
pass
|
||
else:
|
||
if str(reaction.emoji) in stateEmoji[2:] and str(reaction.emoji) not in ignoreEmoji:
|
||
if repeat:
|
||
REPEAT_COMMAND = False
|
||
REPEAT_MSG_LIST = []
|
||
await context.message.channel.send("❎ Auto-update cancelled...")
|
||
await list_transfers(context, content=torStateFilters[str(reaction.emoji)])
|
||
elif str(reaction.emoji) == stateEmoji[0]:
|
||
await legend(context)
|
||
elif str(reaction.emoji) == stateEmoji[1]:
|
||
if repeat:
|
||
REPEAT_COMMAND = False
|
||
REPEAT_MSG_LIST = []
|
||
await context.message.channel.send("❎ Auto-update cancelled...")
|
||
else:
|
||
await msg.clear_reaction('🔄')
|
||
await repeat_command(summary, context=context, content=content, msg_list=[msg])
|
||
|
||
def strListToList(strList):
|
||
if not re.match('^[0-9\,\-]+$', strList):
|
||
return False
|
||
outList = []
|
||
for seg in strList.strip().split(","):
|
||
subseg = seg.split("-")
|
||
if len(subseg) == 1 and int(subseg[0]) not in outList:
|
||
outList.append(int(subseg[0]))
|
||
elif len(subseg) == 2:
|
||
subseg = sorted([int(i) for i in subseg])
|
||
outList += range(subseg[0],subseg[1]+1)
|
||
if len(outList) == 0:
|
||
return False
|
||
|
||
return outList
|
||
|
||
|
||
def torList(torrents, author_name="Torrent Transfers",title=None,description=None,repeat=False):
|
||
states = ('downloading', 'seeding', 'stopped', 'finished','checking','check pending','download pending','upload pending')
|
||
stateEmoji = {i:j for i,j in zip(states,['🔻','🌱','⏸','🏁','🩺','🩺','🚧','🚧'])}
|
||
errorStrs = ['✅','⚠️','🌐','🖥']
|
||
|
||
def torListLine(t):
|
||
down = humanbytes(t.progress * 0.01 * t.totalSize)
|
||
out = "{} {} {} {} ".format(stateEmoji[t.status],errorStrs[t.error],'🚀' if t.rateDownload + t.rateUpload > 0 else '🐢' if t.isStalled else '🐇', '🔒' if t.isPrivate else '🔓')
|
||
if t.status == 'downloading':
|
||
out += "{}/{} ⬇️ {}/s ⬆️ {}/s ⚖️ {:.2f}".format(down,humanbytes(t.totalSize),humanbytes(t.rateDownload),humanbytes(t.rateUpload),t.uploadRatio)
|
||
elif t.status == 'seeding':
|
||
out += "{} ⬆️ {}/s ⚖️ {:.2f}".format(humanbytes(t.totalSize),humanbytes(t.rateUpload),t.uploadRatio)
|
||
elif t.status == 'stopped':
|
||
out += "{}/{} ⚖️ {:.2f}".format(down,humanbytes(t.totalSize),t.uploadRatio)
|
||
elif t.status == 'finished':
|
||
out += "{} ⚖️ {:.2f}".format(humanbytes(t.totalSize),t.uploadRatio)
|
||
|
||
if t.error != 0:
|
||
out += "\n**Error:** *{}*".format(t.errorString)
|
||
|
||
return out
|
||
|
||
nameList = ["{}) {:.245}{}".format(t.id,t.name,"..." if len(t.name) > 245 else "") for t in torrents]
|
||
valList = [torListLine(t) for t in torrents]
|
||
|
||
n = 0
|
||
i = 0
|
||
embeds = []
|
||
if len(torrents) > 0:
|
||
while i < len(torrents):
|
||
embed=discord.Embed(title=title,description=description,color=0xb51a00)
|
||
for j in range(25):
|
||
embed.add_field(name=nameList[i],value=valList[i],inline=False)
|
||
i += 1
|
||
n += 1
|
||
if n >= 25:
|
||
n = 0
|
||
break
|
||
if i >= len(torrents):
|
||
break
|
||
embeds.append(embed)
|
||
else:
|
||
embeds.append(discord.Embed(title=title, description="No matching transfers found!", color=0xb51a00))
|
||
|
||
embeds[-1].set_author(name=author_name, icon_url=LOGO_URL)
|
||
embeds[-1].set_footer(text="📜 Symbol legend")
|
||
|
||
return embeds
|
||
|
||
def torGetListOpsFromStr(listOpStr):
|
||
filter_by = None
|
||
sort_by = None
|
||
splitcontent = listOpStr.split(" ")
|
||
|
||
if "--filter" in splitcontent:
|
||
ind = splitcontent.index("--filter")
|
||
if len(splitcontent) > ind + 1:
|
||
filter_by = splitcontent[ind+1]
|
||
del splitcontent[ind+1]
|
||
del splitcontent[ind]
|
||
elif "-f" in splitcontent:
|
||
ind = splitcontent.index("-f")
|
||
if len(splitcontent) > ind + 1:
|
||
filter_by = splitcontent[ind+1]
|
||
del splitcontent[ind+1]
|
||
del splitcontent[ind]
|
||
|
||
if "--sort" in splitcontent:
|
||
ind = splitcontent.index("--sort")
|
||
if len(splitcontent) > ind + 1:
|
||
sort_by = splitcontent[ind+1]
|
||
del splitcontent[ind+1]
|
||
del splitcontent[ind]
|
||
elif "-s" in splitcontent:
|
||
ind = splitcontent.index("-s")
|
||
if len(splitcontent) > ind + 1:
|
||
sort_by = splitcontent[ind+1]
|
||
del splitcontent[ind+1]
|
||
del splitcontent[ind]
|
||
|
||
filter_regex = " ".join(splitcontent).strip()
|
||
if filter_regex == "":
|
||
filter_regex = None
|
||
|
||
if filter_by is not None and filter_by not in filter_names_full:
|
||
return -1, None, None
|
||
if sort_by is not None and sort_by not in sort_names:
|
||
return None, -1, None
|
||
|
||
return filter_by, sort_by, filter_regex
|
||
|
||
async def repeat_command(command, context, content="", msg_list=[]):
|
||
global REPEAT_COMMAND, REPEAT_MSG_LIST
|
||
if REPEAT_COMMAND:
|
||
await context.message.channel.send("❎ Can't start auto-update when another command is already auto-updating...")
|
||
return
|
||
REPEAT_COMMAND = True
|
||
REPEAT_MSG_LIST = msg_list
|
||
start_time = datetime.datetime.now()
|
||
while REPEAT_COMMAND:
|
||
delta = datetime.datetime.now() - start_time
|
||
if delta.seconds >= REPEAT_TIMEOUT:
|
||
await context.message.channel.send("❎ Auto-update timed out...")
|
||
REPEAT_COMMAND = False
|
||
REPEAT_MSG_LIST = []
|
||
return
|
||
# for msg in REPEAT_MSG_LIST:
|
||
# await msg.delete()
|
||
await command(context=context, content=content, repeat=True)
|
||
return
|
||
|
||
@client.command(name='list', aliases=['l'], pass_context=True)
|
||
async def list_transfers(context, *, content="", repeat=False):
|
||
global REPEAT_COMMAND, REPEAT_MSG_LIST
|
||
if await CommandPrecheck(context):
|
||
filter_by, sort_by, filter_regex = torGetListOpsFromStr(content)
|
||
if filter_by == -1:
|
||
await context.message.channel.send("Invalid filter specified. Choose one of {}".format(str(filter_names_full)))
|
||
return
|
||
if sort_by == -1:
|
||
await context.message.channel.send("Invalid sort specified. Choose one of {}".format(str(sort_names)))
|
||
return
|
||
|
||
if not repeat:
|
||
await context.message.delete()
|
||
|
||
torrents = TSCLIENT.get_torrents_by(sort_by=sort_by, filter_by=filter_by, filter_regex=filter_regex)
|
||
|
||
embeds = torList(torrents, title="{} transfer{} matching '`{}`'".format(len(torrents),'' if len(torrents)==1 else 's',content))
|
||
|
||
embeds[-1].set_footer(text="📜 Symbol legend{}".format('\nUpdating every {} second{}—❎ to stop'.format(REPEAT_FREQ,'s' if REPEAT_FREQ != 1 else '') if repeat else ', 🔄 to auto-update'))
|
||
|
||
if repeat:
|
||
msgs = REPEAT_MSG_LIST
|
||
if context.message.channel.last_message_id != msgs[-1].id:
|
||
for m in msgs:
|
||
await m.delete()
|
||
msgs = []
|
||
for i,e in enumerate(embeds):
|
||
if i < len(msgs):
|
||
await msgs[i].edit(embed=e)
|
||
if i < len(embeds) and len(msgs[i].reactions) > 0:
|
||
await msgs[i].clear_reactions()
|
||
else:
|
||
msgs.append(await context.message.channel.send(embed=e))
|
||
if len(msgs) > len(embeds):
|
||
for i in range(len(msgs) - len(embeds)):
|
||
await msgs[-1].delete()
|
||
del msgs[-1]
|
||
REPEAT_MSG_LIST = msgs
|
||
rxnEmoji = ['📜','❎']
|
||
else:
|
||
msgs = [await context.message.channel.send(embed=e) for e in embeds]
|
||
rxnEmoji = ['📜','🔄']
|
||
|
||
msg = msgs[-1]
|
||
|
||
msgRxns = msg.reactions
|
||
for r in msgRxns:
|
||
if str(r.emoji) not in rxnEmoji:
|
||
await msg.clear_reaction(r)
|
||
|
||
msgRxns = [str(r.emoji) for r in msgRxns]
|
||
for e in rxnEmoji:
|
||
if e not in msgRxns:
|
||
await msg.add_reaction(e)
|
||
|
||
def check(reaction, user):
|
||
return user == context.message.author and reaction.message.id == msg.id and str(reaction.emoji) in rxnEmoji
|
||
|
||
try:
|
||
reaction, user = await client.wait_for('reaction_add', timeout=60.0 if not repeat else REPEAT_FREQ, check=check)
|
||
except asyncio.TimeoutError:
|
||
pass
|
||
else:
|
||
if str(reaction.emoji) == '📜':
|
||
await legend(context)
|
||
elif str(reaction.emoji) == rxnEmoji[-1]:
|
||
if repeat:
|
||
REPEAT_COMMAND = False
|
||
REPEAT_MSG_LIST = []
|
||
await context.message.channel.send("❎ Auto-update cancelled...")
|
||
else:
|
||
await msg.clear_reaction('🔄')
|
||
await repeat_command(list_transfers, context=context, content=content, msg_list=msgs)
|
||
|
||
@client.command(name='modify', aliases=['m'], pass_context=True)
|
||
async def modify(context, *, content=""):
|
||
if await CommandPrecheck(context):
|
||
allOnly = content.strip() == ""
|
||
torrents = []
|
||
if not allOnly:
|
||
id_list = strListToList(content)
|
||
filter_by = None
|
||
sort_by = None
|
||
filter_regex = None
|
||
if not id_list:
|
||
filter_by, sort_by, filter_regex = torGetListOpsFromStr(content)
|
||
if filter_by == -1:
|
||
await context.message.channel.send("Invalid filter specified. Choose one of {}".format(str(filter_names_full)))
|
||
return
|
||
if sort_by == -1:
|
||
await context.message.channel.send("Invalid sort specified. Choose one of {}".format(str(sort_names)))
|
||
return
|
||
|
||
await context.message.delete()
|
||
|
||
torrents = TSCLIENT.get_torrents_by(filter_by=filter_by, sort_by=sort_by, filter_regex=filter_regex, id_list=id_list)
|
||
|
||
if len(torrents) > 0:
|
||
ops = ["pause","resume","remove","removedelete","verify"]
|
||
opNames = ["pause","resume","remove","remove and delete","verify"]
|
||
opEmoji = ['⏸','▶️','❌','🗑','🩺']
|
||
opStr = "⏸pause ▶️resume ❌remove 🗑remove and delete 🩺verify"
|
||
embeds = torList(torrents,author_name="Click a reaction to choose modification".format(len(torrents), '' if len(torrents)==1 else 's'),title="{} transfer{} matching '`{}`' will be modified".format(len(torrents), '' if len(torrents)==1 else 's', content))
|
||
else:
|
||
embed=discord.Embed(title="Modify transfers",color=0xb51a00)
|
||
embed.set_author(name="No matching transfers found!", icon_url=LOGO_URL)
|
||
embeds = [embed]
|
||
else:
|
||
await context.message.delete()
|
||
ops = ["pauseall","resumeall"]
|
||
opNames = ["pause all","resume all"]
|
||
opEmoji = ['⏸','▶️']
|
||
opStr = "⏸ pause or ▶️ resume all"
|
||
embed=discord.Embed(title="React to choose modification",color=0xb51a00)
|
||
embed.set_author(name="All transfers will be affected!", icon_url=LOGO_URL)
|
||
embed.set_footer(text=opStr)
|
||
embeds = [embed]
|
||
msgs = [await context.message.channel.send(embed=e) for e in embeds]
|
||
|
||
if not allOnly and len(torrents) == 0:
|
||
return
|
||
|
||
opEmoji.append('📜')
|
||
|
||
for i in opEmoji:
|
||
await msgs[-1].add_reaction(i)
|
||
|
||
def check(reaction, user):
|
||
return user == context.message.author and str(reaction.emoji) in opEmoji
|
||
|
||
try:
|
||
reaction, user = await client.wait_for('reaction_add', timeout=60.0, check=check)
|
||
except asyncio.TimeoutError:
|
||
return
|
||
else:
|
||
if str(reaction.emoji) == opEmoji[-1]:
|
||
await legend(context)
|
||
elif str(reaction.emoji) in opEmoji[:-1]:
|
||
cmds = {i:j for i,j in zip(opEmoji,ops)}
|
||
cmdNames = {i:j for i,j in zip(opEmoji,opNames)}
|
||
cmd = cmds[str(reaction.emoji)]
|
||
cmdName = cmdNames[str(reaction.emoji)]
|
||
|
||
doContinue = True
|
||
if "remove" in cmds[str(reaction.emoji)]:
|
||
embed=discord.Embed(title="Are you sure you wish to remove{} {} transfer{}?".format(' and DELETE' if 'delete' in cmds[str(reaction.emoji)] else '', len(torrents), '' if len(torrents)==1 else 's'),description="**This action is irreversible!**",color=0xb51a00)
|
||
embed.set_footer(text="react ✅ to continue or ❌ to cancel")
|
||
msg = await context.message.channel.send(embed=embed)
|
||
|
||
for i in ['✅','❌']:
|
||
await msg.add_reaction(i)
|
||
|
||
def check1(reaction, user):
|
||
return user == context.message.author and str(reaction.emoji) in ['✅','❌']
|
||
try:
|
||
reaction, user = await client.wait_for('reaction_add', timeout=60.0, check=check1)
|
||
except asyncio.TimeoutError:
|
||
doContinue = False
|
||
else:
|
||
doContinue = str(reaction.emoji) == '✅'
|
||
if doContinue:
|
||
await context.message.channel.send("{} Trying to {} transfer{}, please wait...".format(str(reaction.emoji), cmdName, 's' if allOnly or len(torrents) > 1 else ''))
|
||
if "pause" in cmd:
|
||
stop_torrents(torrents)
|
||
elif "resume" in cmd:
|
||
resume_torrents(torrents)
|
||
elif "verify" in cmd:
|
||
verify_torrents(torrents)
|
||
else:
|
||
remove_torrents(torrents,delete_files="delete" in cmd)
|
||
|
||
ops = ["pause","resume","remove","removedelete","pauseall","resumeall","verify"]
|
||
opNames = ["paused","resumed","removed","removed and deleted","paused","resumed","queued for verification"]
|
||
opEmoji = ["⏸","▶️","❌","🗑","⏸","▶️","🩺"]
|
||
ops = {i:j for i,j in zip(ops,opNames)}
|
||
opEmoji = {i:j for i,j in zip(ops,opEmoji)}
|
||
await context.message.channel.send("{} Transfer{} {}".format(str(reaction.emoji),'s' if allOnly or len(torrents) > 1 else '', ops[cmd]))
|
||
else:
|
||
await context.message.channel.send("❌ Cancelled!")
|
||
|
||
@client.command(name='legend', pass_context=True)
|
||
async def legend(context):
|
||
embed = discord.Embed(title='Symbol legend', color=0xb51a00)
|
||
embed.add_field(name="Status", value="🔻—downloading\n🌱—seeding\n⏸—paused\n🩺—verifying\n🚧—queued\n🏁—finished\n↕️—any", inline=True)
|
||
embed.add_field(name="Error", value="✅—none\n⚠️—tracker warning\n🌐—tracker error\n🖥—local error", inline=True)
|
||
embed.add_field(name="Metrics", value="⬇️—download rate\n⬆️—upload rate\n⏬—total downloaded\n⏫—total uploaded\n⚖️—seed ratio", inline=True)
|
||
embed.add_field(name="Activity", value="🐢—stalled\n🐇—active\n🚀—running (rate>0)", inline=True)
|
||
embed.add_field(name="Tracker", value="🔒—private\n🔓—public", inline=True)
|
||
embed.add_field(name="Modifications", value="⏸—pause\n▶️—resume\n❌—remove\n🗑—remove and delete\n🩺—verify", inline=True)
|
||
await context.message.channel.send(embed=embed)
|
||
if REPEAT_COMMAND:
|
||
await asyncio.sleep(5)
|
||
return
|
||
|
||
client.remove_command('help')
|
||
|
||
@client.command(name='help', description='Help HUD.', brief='HELPOOOO!!!', pass_context=True)
|
||
async def help(context, *, content=""):
|
||
if await CommandPrecheck(context):
|
||
if content != "":
|
||
if content in ["l","list"]:
|
||
embed = discord.Embed(title='List transfers', color=0xb51a00)
|
||
embed.set_author(name="List current transfers with sorting, filtering, and search options", icon_url=LOGO_URL)
|
||
embed.add_field(name="Usage", value='`{0}list [--filter FILTER] [--sort SORT] [NAME]`'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Filtering", value='`--filter FILTER` or `-f FILTER`\n`FILTER` is one of `{}`'.format(str(filter_names_full)), inline=False)
|
||
embed.add_field(name="Sorting", value='`--sort SORT` or `-s SORT`\n`SORT` is one of `{}`'.format(str(sort_names)), inline=False)
|
||
embed.add_field(name="Searching by name", value='`NAME` is a regular expression used to search transfer names (no enclosing quotes; may contain spaces)', inline=False)
|
||
embed.add_field(name="Examples", value="*List all transfers:* `{0}list`\n*Search using phrase 'ubuntu':* `{0}l ubuntu`\n*List downloading transfers:* `{0}l -f downloading`\n*Sort transfers by age:* `{0}list --sort age`".format(BOT_PREFIX), inline=False)
|
||
await context.message.channel.send(embed=embed)
|
||
elif content in ["a","add"]:
|
||
embed = discord.Embed(title='Add transfer', description="If multiple torrents are added, separate them by spaces", color=0xb51a00)
|
||
embed.set_author(name="Add one or more specified torrents by magnet link or url to torrent file", icon_url=LOGO_URL)
|
||
embed.add_field(name="Usage", value='`{0}add TORRENT_FILE_URL_OR_MAGNET_LINK ...`\n`{0}a TORRENT_FILE_URL_OR_MAGNET_LINK ...`'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Examples", value="*Add download of ubuntu OS:* `{0}add https://releases.ubuntu.com/20.04/ubuntu-20.04.1-desktop-amd64.iso.torrent`".format(BOT_PREFIX), inline=False)
|
||
await context.message.channel.send(embed=embed)
|
||
elif content in ["m","modify"]:
|
||
embed = discord.Embed(title='Modify existing transfer(s)', color=0xb51a00)
|
||
embed.set_author(name="Pause, resume, remove, or remove and delete specified transfer(s)", icon_url=LOGO_URL)
|
||
embed.add_field(name="Usage", value='`{0}modify [LIST_OPTIONS] [TORRENT_ID_SPECIFIER]`'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Pause or resume ALL transfers", value="Simply run `{0}modify` to pause or resume all existing transfers".format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="By list options", value='`LIST_OPTIONS` is a valid set of options to the `{0}list` command (see `{0}help list` for details)'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="By ID specifier", value='`TORRENT_ID_SPECIFIER` is a valid transfer ID specifier—*e.g.* `1,3-5,9` to specify transfers 1, 3, 4, 5, and 9\n*Transfer IDs are the left-most number in the list of transfers (use* `{0}list` *to print full list)*'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Examples", value="`{0}modify`\n`{0}m seinfeld`\n`{0}m 23,34,36-42`\n`{0}m --filter downloading seinfeld`".format(BOT_PREFIX), inline=False)
|
||
await context.message.channel.send(embed=embed)
|
||
else:
|
||
embed = discord.Embed(title='List of commands:', color=0xb51a00)
|
||
embed.set_author(name='Transmission Bot: Manage torrent file transfers', icon_url=LOGO_URL)
|
||
embed.add_field(name="Print summary of transfers", value="*print summary from all transfers, with followup options to list transfers*\n*ex.* `{0}summary` or `{0}s`".format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="List torrent transfers", value="*list current transfers with sorting, filtering, and search options*\n*ex.* `{0}list [OPTIONS]` or `{0}l [OPTIONS]`".format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Add new torrent transfers", value="*add one or more specified torrents by magnet link or url to torrent file*\n*ex.* `{0}add TORRENT ...` or `{0}a TORRENT ...`".format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name="Modify existing transfers", value="*pause, resume, remove, or remove and delete specified transfers*\n*ex.* `{0}modify [TORRENT]` or `{0}m [TORRENT]`".format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name='Show legend', value='*prints legend showing the meaning of symbols used in the output of other commands*\n*ex.* `{0}legend`'.format(BOT_PREFIX), inline=False)
|
||
embed.add_field(name='Help - Gives this menu', value='*with optional details of specified command*\n*ex.* `{0}help` or `{0}help COMMAND`'.format(BOT_PREFIX), inline=False)
|
||
|
||
await context.message.channel.send(embed=embed)
|
||
|
||
@client.event
|
||
async def on_command_error(context, error):
|
||
if isinstance(error, commands.CommandOnCooldown):
|
||
await context.message.delete()
|
||
embed = discord.Embed(title="Error!", description='This command is on a {:.2f}s cooldown'.format(error.retry_after), color=0xb51a00)
|
||
message = await context.message.channel.send(embed=embed)
|
||
await asyncio.sleep(5)
|
||
await message.delete()
|
||
elif isinstance(error, commands.CommandNotFound):
|
||
await context.message.delete()
|
||
embed = discord.Embed(title="Error!", description="I don't know that command!", color=0xb51a00)
|
||
message = await context.message.channel.send(embed=embed)
|
||
await asyncio.sleep(2)
|
||
await help(context)
|
||
raise error
|
||
|
||
client.run(TOKEN)
|