ricerca globale: stessa sessione

This commit is contained in:
marco
2019-12-18 19:48:44 +01:00
parent 7245a82ae8
commit 1c0b862082
2 changed files with 8 additions and 3 deletions
+2 -1
View File
@@ -420,7 +420,8 @@ def downloadpage(url, **opt):
# session = requests.session()
if opt.get('session', False):
session = opt['session'] # same session to speed up search
session = opt['session'] # same session to speed up search
logger.info('same session')
else:
from lib import cloudscraper
session = cloudscraper.create_scraper()
+6 -2
View File
@@ -174,6 +174,9 @@ def channel_search(item):
channel_list = get_channels(item)
from lib import cloudscraper
session = cloudscraper.create_scraper()
searching += channel_list
cnt = 0
@@ -182,7 +185,7 @@ def channel_search(item):
config.set_setting('tmdb_active', False)
with futures.ThreadPoolExecutor() as executor:
c_results = [executor.submit(get_channel_results, ch, item) for ch in channel_list]
c_results = [executor.submit(get_channel_results, ch, item, session) for ch in channel_list]
for res in futures.as_completed(c_results):
cnt += 1
@@ -264,7 +267,7 @@ def channel_search(item):
return valid + results
def get_channel_results(ch, item):
def get_channel_results(ch, item, session):
max_results = 10
results = list()
@@ -277,6 +280,7 @@ def get_channel_results(ch, item):
if search_action:
for search_ in search_action:
search_.session = session
try:
results.extend(module.search(search_, item.text))
except: