mirror of
				https://github.com/searxng/searxng.git
				synced 2025-11-03 19:17:07 -05:00 
			
		
		
		
	Two different threads ( = two different user queries) can call the request function in a row and then the response function. The namespace will be same since this is the same engine. To keep exactly the same value ``base_url`` must be stored in params and then retrieve using ``resp.search_params["base_url"]``. Suggested-by: @dalf https://github.com/searxng/searxng/pull/862#discussion_r799324861 Signed-off-by: Markus Heiser <markus.heiser@darmarit.de>
		
			
				
	
	
		
			90 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			90 lines
		
	
	
		
			2.5 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
# SPDX-License-Identifier: AGPL-3.0-or-later
 | 
						|
# lint: pylint
 | 
						|
"""SolidTorrents
 | 
						|
"""
 | 
						|
 | 
						|
from datetime import datetime
 | 
						|
from urllib.parse import urlencode
 | 
						|
import random
 | 
						|
 | 
						|
from lxml import html
 | 
						|
 | 
						|
from searx.utils import (
 | 
						|
    extract_text,
 | 
						|
    eval_xpath,
 | 
						|
    eval_xpath_getindex,
 | 
						|
    eval_xpath_list,
 | 
						|
    get_torrent_size,
 | 
						|
)
 | 
						|
 | 
						|
about = {
 | 
						|
    "website": 'https://www.solidtorrents.net/',
 | 
						|
    "wikidata_id": None,
 | 
						|
    "official_api_documentation": None,
 | 
						|
    "use_official_api": False,
 | 
						|
    "require_api_key": False,
 | 
						|
    "results": 'HTML',
 | 
						|
}
 | 
						|
 | 
						|
categories = ['files']
 | 
						|
paging = True
 | 
						|
 | 
						|
# base_url can be overwritten by a list of URLs in the settings.yml
 | 
						|
base_url = 'https://solidtorrents.net'
 | 
						|
 | 
						|
 | 
						|
def request(query, params):
 | 
						|
    if isinstance(base_url, list):
 | 
						|
        params['base_url'] = random.choice(base_url)
 | 
						|
    else:
 | 
						|
        params['base_url'] = base_url
 | 
						|
    search_url = params['base_url'] + '/search?{query}'
 | 
						|
    page = (params['pageno'] - 1) * 20
 | 
						|
    query = urlencode({'q': query, 'page': page})
 | 
						|
    params['url'] = search_url.format(query=query)
 | 
						|
    return params
 | 
						|
 | 
						|
 | 
						|
def response(resp):
 | 
						|
    results = []
 | 
						|
    dom = html.fromstring(resp.text)
 | 
						|
 | 
						|
    for result in eval_xpath(dom, '//div[contains(@class, "search-result")]'):
 | 
						|
        a = eval_xpath_getindex(result, './div/h5/a', 0, None)
 | 
						|
        if a is None:
 | 
						|
            continue
 | 
						|
        title = extract_text(a)
 | 
						|
        url = eval_xpath_getindex(a, '@href', 0, None)
 | 
						|
        categ = eval_xpath(result, './div//a[contains(@class, "category")]')
 | 
						|
        metadata = extract_text(categ)
 | 
						|
        stats = eval_xpath_list(result, './div//div[contains(@class, "stats")]/div', min_len=5)
 | 
						|
        n, u = extract_text(stats[1]).split()
 | 
						|
        filesize = get_torrent_size(n, u)
 | 
						|
        leech = extract_text(stats[2])
 | 
						|
        seed = extract_text(stats[3])
 | 
						|
        torrentfile = eval_xpath_getindex(result, './div//a[contains(@class, "dl-torrent")]/@href', 0, None)
 | 
						|
        magnet = eval_xpath_getindex(result, './div//a[contains(@class, "dl-magnet")]/@href', 0, None)
 | 
						|
 | 
						|
        params = {
 | 
						|
            'seed': seed,
 | 
						|
            'leech': leech,
 | 
						|
            'title': title,
 | 
						|
            'url': resp.search_params['base_url'] + url,
 | 
						|
            'filesize': filesize,
 | 
						|
            'magnetlink': magnet,
 | 
						|
            'torrentfile': torrentfile,
 | 
						|
            'metadata': metadata,
 | 
						|
            'template': "torrent.html",
 | 
						|
        }
 | 
						|
 | 
						|
        date_str = extract_text(stats[4])
 | 
						|
 | 
						|
        try:
 | 
						|
            params['publishedDate'] = datetime.strptime(date_str, '%b %d, %Y')
 | 
						|
        except ValueError:
 | 
						|
            pass
 | 
						|
 | 
						|
        results.append(params)
 | 
						|
 | 
						|
    return results
 |