mirror of
https://gitlab.com/SIGBUS/nyaa.git
synced 2024-12-22 15:30:01 +00:00
Clean up info api script
And a tiny bit of the serverside endpoint.
This commit is contained in:
parent
570a06bd9e
commit
6592bec67c
|
@ -260,7 +260,7 @@ def ghetto_import():
|
||||||
|
|
||||||
|
|
||||||
# ####################################### INFO #######################################
|
# ####################################### INFO #######################################
|
||||||
ID_PATTERN = '^[1-9][0-9]*$'
|
ID_PATTERN = '^[0-9]+$'
|
||||||
INFO_HASH_PATTERN = '^[0-9a-fA-F]{40}$' # INFO_HASH as string
|
INFO_HASH_PATTERN = '^[0-9a-fA-F]{40}$' # INFO_HASH as string
|
||||||
|
|
||||||
|
|
||||||
|
@ -270,14 +270,14 @@ INFO_HASH_PATTERN = '^[0-9a-fA-F]{40}$' # INFO_HASH as string
|
||||||
def v2_api_info(torrent_id_or_hash):
|
def v2_api_info(torrent_id_or_hash):
|
||||||
torrent_id_or_hash = torrent_id_or_hash.lower().strip()
|
torrent_id_or_hash = torrent_id_or_hash.lower().strip()
|
||||||
|
|
||||||
matchID = re.match(ID_PATTERN, torrent_id_or_hash)
|
id_match = re.match(ID_PATTERN, torrent_id_or_hash)
|
||||||
matchHASH = re.match(INFO_HASH_PATTERN, torrent_id_or_hash)
|
hex_hash_match = re.match(INFO_HASH_PATTERN, torrent_id_or_hash)
|
||||||
|
|
||||||
torrent = None
|
torrent = None
|
||||||
|
|
||||||
if matchID:
|
if id_match:
|
||||||
torrent = models.Torrent.by_id(int(torrent_id_or_hash))
|
torrent = models.Torrent.by_id(int(torrent_id_or_hash))
|
||||||
elif matchHASH:
|
elif hex_hash_match:
|
||||||
# Convert the string representation of a torrent hash back into a binary representation
|
# Convert the string representation of a torrent hash back into a binary representation
|
||||||
a2b_hash = binascii.unhexlify(torrent_id_or_hash)
|
a2b_hash = binascii.unhexlify(torrent_id_or_hash)
|
||||||
torrent = models.Torrent.by_info_hash(a2b_hash)
|
torrent = models.Torrent.by_info_hash(a2b_hash)
|
||||||
|
@ -309,20 +309,23 @@ def v2_api_info(torrent_id_or_hash):
|
||||||
'url': flask.url_for('view_torrent', torrent_id=torrent.id, _external=True),
|
'url': flask.url_for('view_torrent', torrent_id=torrent.id, _external=True),
|
||||||
'id': torrent.id,
|
'id': torrent.id,
|
||||||
'name': torrent.display_name,
|
'name': torrent.display_name,
|
||||||
|
|
||||||
'creation_date': torrent.created_time.strftime('%Y-%m-%d %H:%M UTC'),
|
'creation_date': torrent.created_time.strftime('%Y-%m-%d %H:%M UTC'),
|
||||||
'hash_b32': torrent.info_hash_as_b32, # as used in magnet uri
|
'hash_b32': torrent.info_hash_as_b32, # as used in magnet uri
|
||||||
'hash_hex': torrent.info_hash_as_hex, # .hex(), #as shown in torrent client
|
'hash_hex': torrent.info_hash_as_hex, # .hex(), #as shown in torrent client
|
||||||
'magnet': torrent.magnet_uri,
|
'magnet': torrent.magnet_uri,
|
||||||
|
|
||||||
'main_category': torrent.main_category.name,
|
'main_category': torrent.main_category.name,
|
||||||
'main_category_id': torrent.main_category.id,
|
'main_category_id': torrent.main_category.id,
|
||||||
'sub_category': torrent.sub_category.name,
|
'sub_category': torrent.sub_category.name,
|
||||||
'sub_category_id': torrent.sub_category.id,
|
'sub_category_id': torrent.sub_category.id,
|
||||||
|
|
||||||
'information': torrent.information,
|
'information': torrent.information,
|
||||||
'description': torrent.description,
|
'description': torrent.description,
|
||||||
'stats': {'seeders': torrent.stats.seed_count, 'leechers': torrent.stats.leech_count, 'downloads': torrent.stats.download_count},
|
'stats': {'seeders': torrent.stats.seed_count, 'leechers': torrent.stats.leech_count, 'downloads': torrent.stats.download_count},
|
||||||
'filesize': torrent.filesize,
|
'filesize': torrent.filesize,
|
||||||
'files': files,
|
'files': files,
|
||||||
# reduce torrent flags to True/False
|
|
||||||
'is_trusted': torrent.trusted,
|
'is_trusted': torrent.trusted,
|
||||||
'is_complete': torrent.complete,
|
'is_complete': torrent.complete,
|
||||||
'is_remake': torrent.remake
|
'is_remake': torrent.remake
|
||||||
|
|
61
utils/api_info.py
Normal file → Executable file
61
utils/api_info.py
Normal file → Executable file
|
@ -13,10 +13,11 @@ SUKEBEI_HOST = 'https://sukebei.nyaa.si'
|
||||||
API_BASE = '/api'
|
API_BASE = '/api'
|
||||||
API_INFO = API_BASE + '/info'
|
API_INFO = API_BASE + '/info'
|
||||||
|
|
||||||
ID_PATTERN = '^[1-9][0-9]*$'
|
ID_PATTERN = '^[0-9]+$'
|
||||||
INFO_HASH_PATTERN = '^[0-9a-fA-F]{40}$'
|
INFO_HASH_PATTERN = '^[0-9a-fA-F]{40}$'
|
||||||
|
|
||||||
environment_epillog = '''You may also provide environment variables NYAA_API_HOST, NYAA_API_USERNAME and NYAA_API_PASSWORD for connection info.'''
|
environment_epillog = ('You may also provide environment variables NYAA_API_HOST, NYAA_API_USERNAME'
|
||||||
|
' and NYAA_API_PASSWORD for connection info.')
|
||||||
|
|
||||||
parser = argparse.ArgumentParser(
|
parser = argparse.ArgumentParser(
|
||||||
description='Query torrent info on Nyaa.si', epilog=environment_epillog)
|
description='Query torrent info on Nyaa.si', epilog=environment_epillog)
|
||||||
|
@ -30,10 +31,17 @@ conn_group.add_argument('-u', '--user', help='Username or email')
|
||||||
conn_group.add_argument('-p', '--password', help='Password')
|
conn_group.add_argument('-p', '--password', help='Password')
|
||||||
conn_group.add_argument('--host', help='Select another api host (for debugging purposes)')
|
conn_group.add_argument('--host', help='Select another api host (for debugging purposes)')
|
||||||
|
|
||||||
parser.add_argument('hash_or_id', help='Torrent by id or hash Required.')
|
resp_group = parser.add_argument_group('Response options')
|
||||||
|
|
||||||
parser.add_argument('--raw', default=False, action='store_true',
|
resp_group.add_argument('--raw', default=False, action='store_true',
|
||||||
help='Print only raw response (JSON)')
|
help='Print only raw response (JSON)')
|
||||||
|
resp_group.add_argument('-m', '--magnet', default=False,
|
||||||
|
action='store_true', help='Print magnet uri')
|
||||||
|
|
||||||
|
|
||||||
|
req_group = parser.add_argument_group('Required arguments')
|
||||||
|
req_group.add_argument('hash_or_id', metavar='HASH_OR_ID',
|
||||||
|
help='Torrent ID or hash (hex, 40 characters) to query for')
|
||||||
|
|
||||||
|
|
||||||
def easy_file_size(filesize):
|
def easy_file_size(filesize):
|
||||||
|
@ -44,6 +52,15 @@ def easy_file_size(filesize):
|
||||||
return '{0:.1f} {1}'.format(filesize, prefix)
|
return '{0:.1f} {1}'.format(filesize, prefix)
|
||||||
|
|
||||||
|
|
||||||
|
def _as_yes_no(value):
|
||||||
|
return 'Yes' if value else 'No'
|
||||||
|
|
||||||
|
|
||||||
|
INFO_TEMPLATE = ("Torrent #{id}: '{name}' ({formatted_filesize}) uploaded by {submitter}"
|
||||||
|
"\n {creation_date} [{main_category} - {sub_category}] [{flag_info}]")
|
||||||
|
FLAG_NAMES = ['Trusted', 'Complete', 'Remake']
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
args = parser.parse_args()
|
args = parser.parse_args()
|
||||||
|
|
||||||
|
@ -54,11 +71,16 @@ if __name__ == '__main__':
|
||||||
api_query = args.hash_or_id.lower().strip()
|
api_query = args.hash_or_id.lower().strip()
|
||||||
|
|
||||||
# Verify query is either a valid id or valid hash
|
# Verify query is either a valid id or valid hash
|
||||||
matchID = re.match(ID_PATTERN, api_query)
|
id_match = re.match(ID_PATTERN, api_query)
|
||||||
matchHASH = re.match(INFO_HASH_PATTERN, api_query)
|
hex_hash_match = re.match(INFO_HASH_PATTERN, api_query)
|
||||||
|
|
||||||
if not (matchID or matchHASH):
|
if not (id_match or hex_hash_match):
|
||||||
raise Exception('Query was not a valid id or valid hash.')
|
raise Exception("Given argument '{}' doesn't "
|
||||||
|
"seem like an ID or a hex hash.".format(api_query))
|
||||||
|
|
||||||
|
if id_match:
|
||||||
|
# Remove leading zeroes
|
||||||
|
api_query = api_query.lstrip('0')
|
||||||
|
|
||||||
api_info_url = api_host + API_INFO + '/' + api_query
|
api_info_url = api_host + API_INFO + '/' + api_query
|
||||||
|
|
||||||
|
@ -77,21 +99,24 @@ if __name__ == '__main__':
|
||||||
print(r.text)
|
print(r.text)
|
||||||
else:
|
else:
|
||||||
try:
|
try:
|
||||||
rj = r.json()
|
response = r.json()
|
||||||
except ValueError:
|
except ValueError:
|
||||||
print('Bad response:')
|
print('Bad response:')
|
||||||
print(r.text)
|
print(r.text)
|
||||||
exit(1)
|
exit(1)
|
||||||
|
|
||||||
errors = rj.get('errors')
|
errors = response.get('errors')
|
||||||
|
|
||||||
if errors:
|
if errors:
|
||||||
print('Info request failed:', errors)
|
print('Info request failed:', errors)
|
||||||
exit(1)
|
exit(1)
|
||||||
else:
|
else:
|
||||||
rj['filesize'] = easy_file_size(rj['filesize'])
|
formatted_filesize = easy_file_size(response.get('filesize', 0))
|
||||||
rj['is_trusted'] = 'Yes' if rj['is_trusted'] else 'No'
|
flag_info = ', '.join(n+': '+_as_yes_no(response['is_'+n.lower()]) for n in FLAG_NAMES)
|
||||||
rj['is_complete'] = 'Yes' if rj['is_complete'] else 'No'
|
|
||||||
rj['is_remake'] = 'Yes' if rj['is_remake'] else 'No'
|
info_str = INFO_TEMPLATE.format(formatted_filesize=formatted_filesize,
|
||||||
print("Torrent #{} '{}' uploaded by '{}' ({}) (Created on: {}) ({} - {}) (Trusted: {}, Complete: {}, Remake: {})\n{}".format(
|
flag_info=flag_info, **response)
|
||||||
rj['id'], rj['name'], rj['submitter'], rj['filesize'], rj['creation_date'], rj['main_category'], rj['sub_category'], rj['is_trusted'], rj['is_complete'], rj['is_remake'], rj['magnet']))
|
|
||||||
|
print(info_str)
|
||||||
|
if args.magnet:
|
||||||
|
print(response['magnet'])
|
||||||
|
|
Loading…
Reference in a new issue