From 42294d261d1cce82ec3e8be593671d00d257daba Mon Sep 17 00:00:00 2001 From: likeitneverwentaway Date: Sat, 8 Oct 2016 01:55:55 +0200 Subject: [PATCH] Fix typo, import loads from json --- headphones/searcher.py | 44 +++++++++++++++++++++--------------------- 1 file changed, 22 insertions(+), 22 deletions(-) diff --git a/headphones/searcher.py b/headphones/searcher.py index ff7e4736..6c7fe8cf 100644 --- a/headphones/searcher.py +++ b/headphones/searcher.py @@ -25,6 +25,7 @@ import datetime import subprocess import unicodedata import urlparse +from json import loads import os import re @@ -813,14 +814,14 @@ def send_to_downloader(data, bestqual, album): # Get torrent name from .torrent, this is usually used by the torrent client as the folder name torrent_name = helpers.replace_illegal_chars(folder_name) + '.torrent' download_path = os.path.join(headphones.CONFIG.TORRENTBLACKHOLE_DIR, torrent_name) - + # Blackhole for t411 if bestqual[2].lower().startswith("http://api.t411"): if headphones.CONFIG.MAGNET_LINKS == 2: try: url = bestqual[2].split('TOKEN')[0] token = bestqual[2].split('TOKEN')[1] - data = request.request_content(url, headers = {'Authorization':token}) + data = request.request_content(url, headers={'Authorization': token}) torrent_to_file(download_path, data) logger.info('Successfully converted magnet to torrent file') except Exception as e: @@ -1782,24 +1783,24 @@ def searchTorrent(album, new=False, losslessOnly=False, albumlength=None, username = headphones.CONFIG.TQUATTRECENTONZE_USER password = headphones.CONFIG.TQUATTRECENTONZE_PASSWORD API_URL = "http://api.t411.ch" - AUTH_URL= API_URL + '/auth' + AUTH_URL = API_URL + '/auth' DL_URL = API_URL + '/torrents/download/' provider = "t411" - t411_term = term.replace(" ","%20") + t411_term = term.replace(" ", "%20") SEARCH_URL = API_URL + '/torrents/search/' + t411_term + "?limit=15&cid=395&subcat=623" - headers_login = {'username': username, 'password' : password} - + headers_login = {'username': username, 'password': password} + # Requesting content logger.info('Parsing results from t411 using search term: %s' % term) - req = request.request_content(AUTH_URL, method='post',data = headers_login) - + req = request.request_content(AUTH_URL, method='post', data=headers_login) + if len(req.split('"')) == 9: - token =req.split('"')[7] - headers_auth = {'Authorization':token} + token = req.split('"')[7] + headers_auth = {'Authorization': token} logger.info('t411 - User %s logged in' % username) else: logger.info('t411 - Login error : %s' % req.split('"')[3]) - + # Quality if headphones.CONFIG.PREFERRED_QUALITY == 3 or losslessOnly: providerurl = "&term[16][]=529&term[16][]=1184" @@ -1809,12 +1810,12 @@ def searchTorrent(album, new=False, losslessOnly=False, albumlength=None, providerurl = fix_url(SEARCH_URL + "&term[16][]=685&term[16][]=527&term[16][]=1070&term[16][]=528&term[16][]=1167&term[16][]=1166&term[16][]=530&term[16][]=532&term[16][]=533&term[16][]=1085&term[16][]=534&term[16][]=535&term[16][]=1069&term[16][]=537&term[16][]=538") else: providerurl = fix_url(SEARCH_URL) - + # Tracker search - req = request.request_content(providerurl, headers = headers_auth) - req = json.loads(req) + req = request.request_content(providerurl, headers=headers_auth) + req = loads(req) total = req['total'] - + # Process feed if total == '0': logger.info("No results found from t411 for %s" % term) @@ -1829,26 +1830,25 @@ def searchTorrent(album, new=False, losslessOnly=False, albumlength=None, continue id = torrent['id'] size = int(torrent['size']) - data = request.request_content(DL_URL + id, headers = headers_auth) - - #Blackhole + data = request.request_content(DL_URL + id, headers=headers_auth) + + # Blackhole if headphones.CONFIG.TORRENT_DOWNLOADER == 0 and headphones.CONFIG.MAGNET_LINKS == 2: url = DL_URL + id + 'TOKEN' + token resultlist.append((title, size, url, provider, 'torrent', True)) - + # Build magnet else: metadata = bdecode(data) hashcontents = bencode(metadata['info']) digest = sha1(hashcontents).hexdigest() trackers = [metadata["announce"]][0] - url = 'magnet:?xt=urn:btih:%s&tr=%s' % (digest, trackers) + url = 'magnet:?xt=urn:btih:%s&tr=%s' % (digest, trackers) resultlist.append((title, size, url, provider, 'torrent', True)) - + except Exception as e: logger.error("Error converting magnet link: %s" % str(e)) return - # attempt to verify that this isn't a substring result # when looking for "Foo - Foo" we don't want "Foobar"