diff --git a/searx/engines/duckduckgo.py b/searx/engines/duckduckgo.py index d871a629f5c502d69d5ed7958297fcdb3253a674..8878522f0bfba08b53650fb0e118746ecc63fe9e 100644 --- a/searx/engines/duckduckgo.py +++ b/searx/engines/duckduckgo.py @@ -1,24 +1,19 @@ # SPDX-License-Identifier: AGPL-3.0-or-later -# lint: pylint -"""DuckDuckGo Lite +""" + DuckDuckGo (Web) """ from json import loads - -from lxml.html import fromstring - -from searx.utils import ( - dict_subset, - eval_xpath, - eval_xpath_getindex, - extract_text, - match_language, -) +from urllib.parse import urlencode +from searx.utils import match_language, HTMLTextExtractor +from searx import logger +import re from searx.network import get +logger = logger.getChild('ddg engine') # about about = { - "website": 'https://lite.duckduckgo.com/lite', + "website": 'https://duckduckgo.com/', "wikidata_id": 'Q12805', "official_api_documentation": 'https://duckduckgo.com/api', "use_official_api": False, @@ -29,9 +24,11 @@ about = { # engine dependent config categories = ['general'] paging = True -supported_languages_url = 'https://duckduckgo.com/util/u588.js' +supported_languages_url = 'https://duckduckgo.com/util/u172.js' +number_of_results = 10 time_range_support = True - +safesearch = True +VQD_REGEX = r"vqd='(\d+-\d+-\d+)'" language_aliases = { 'ar-SA': 'ar-XA', 'es-419': 'es-XL', @@ -42,16 +39,13 @@ language_aliases = { 'zh-HK': 'tzh-HK' } -time_range_dict = { - 'day': 'd', - 'week': 'w', - 'month': 'm', - 'year': 'y' -} - # search-url -url = 'https://lite.duckduckgo.com/lite' -url_ping = 'https://duckduckgo.com/t/sl_l' +url = 'https://links.duckduckgo.com/d.js?' +url_ping = 'https://duckduckgo.com/t/sl_h' +time_range_dict = {'day': 'd', + 'week': 'w', + 'month': 'm', + 'year': 'y'} # match query's language to a region code that duckduckgo will accept @@ -66,109 +60,100 @@ def get_region_code(lang, lang_list=None): return lang_parts[1].lower() + '-' + lang_parts[0].lower() +def get_vqd(query, headers): + resp = get(f"https://duckduckgo.com/?q={query}&ia=web", headers=headers) + resp = re.findall(VQD_REGEX, resp.text) + return resp[0] + + def request(query, params): - params['url'] = url - params['method'] = 'POST' - - params['data']['q'] = query - - # The API is not documented, so we do some reverse engineering and emulate - # what https://lite.duckduckgo.com/lite/ does when you press "next Page" - # link again and again .. - - params['headers']['Content-Type'] = 'application/x-www-form-urlencoded' - - # initial page does not have an offset - if params['pageno'] == 2: - # second page does have an offset of 30 - offset = (params['pageno'] - 1) * 30 - params['data']['s'] = offset - params['data']['dc'] = offset + 1 - - elif params['pageno'] > 2: - # third and following pages do have an offset of 30 + n*50 - offset = 30 + (params['pageno'] - 2) * 50 - params['data']['s'] = offset - params['data']['dc'] = offset + 1 - - # initial page does not have additional data in the input form - if params['pageno'] > 1: - # request the second page (and more pages) needs 'o' and 'api' arguments - params['data']['o'] = 'json' - params['data']['api'] = 'd.js' - - # initial page does not have additional data in the input form - if params['pageno'] > 2: - # request the third page (and more pages) some more arguments - params['data']['nextParams'] = '' - params['data']['v'] = '' - params['data']['vqd'] = '' - - region_code = get_region_code(params['language'], supported_languages) - if region_code: - params['data']['kl'] = region_code - params['cookies']['kl'] = region_code - - params['data']['df'] = '' + params['method'] = 'GET' + + vqd = get_vqd(query, params["headers"]) + dl, ct = match_language(params["language"], supported_languages, language_aliases, 'wt-WT').split("-") + query_dict = { + "q": query, + 't': 'D', + 'l': params["language"], + 'kl': f"{ct}-{dl}", + 's': (params['pageno'] - 1) * number_of_results, + 'dl': dl, + 'ct': ct, + 'ss_mkt': get_region_code(params["language"], supported_languages), + 'df': params['time_range'], + 'vqd': vqd, + 'ex': -2, + 'sp': '1', + 'bpa': '1', + 'biaexp': 'b', + 'msvrtexp': 'b' + } + if params['safesearch'] == 2: # STRICT + del query_dict['t'] + query_dict['p'] = 1 + query_dict.update({ + 'videxp': 'a', + 'nadse': 'b', + 'eclsexp': 'a', + 'stiaexp': 'a', + 'tjsexp': 'b', + 'related': 'b', + 'msnexp': 'a' + }) + elif params['safesearch'] == 1: # MODERATE + query_dict['ex'] = -1 + query_dict.update({ + 'nadse': 'b', + 'eclsexp': 'b', + 'tjsexp': 'b' + }) + else: # OFF + query_dict['ex'] = -2 + query_dict.update({ + 'nadse': 'b', + 'eclsexp': 'b', + 'tjsexp': 'b' + }) + + params['allow_redirects'] = False + params["data"] = query_dict + params['cookies']['kl'] = params["data"]["kl"] if params['time_range'] in time_range_dict: params['data']['df'] = time_range_dict[params['time_range']] params['cookies']['df'] = time_range_dict[params['time_range']] - + params["url"] = url + urlencode(params["data"]) return params # get response from search-request def response(resp): - - headers_ping = dict_subset(resp.request.headers, ['User-Agent', 'Accept-Encoding', 'Accept', 'Cookie']) - get(url_ping, headers=headers_ping) - if resp.status_code == 303: return [] + # parse the response results = [] - doc = fromstring(resp.text) - - result_table = eval_xpath(doc, '//html/body/form/div[@class="filters"]/table') - if not len(result_table) >= 3: - # no more results - return [] - result_table = result_table[2] - - tr_rows = eval_xpath(result_table, './/tr') - # In the last