webapp.py 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950
  1. #!/usr/bin/env python
  2. '''
  3. searx is free software: you can redistribute it and/or modify
  4. it under the terms of the GNU Affero General Public License as published by
  5. the Free Software Foundation, either version 3 of the License, or
  6. (at your option) any later version.
  7. searx is distributed in the hope that it will be useful,
  8. but WITHOUT ANY WARRANTY; without even the implied warranty of
  9. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  10. GNU Affero General Public License for more details.
  11. You should have received a copy of the GNU Affero General Public License
  12. along with searx. If not, see < http://www.gnu.org/licenses/ >.
  13. (C) 2013- by Adam Tauber, <asciimoo@gmail.com>
  14. '''
  15. if __name__ == '__main__':
  16. from sys import path
  17. from os.path import realpath, dirname
  18. path.append(realpath(dirname(realpath(__file__)) + '/../'))
  19. import hashlib
  20. import hmac
  21. import json
  22. import os
  23. import sys
  24. import requests
  25. from searx import logger
  26. logger = logger.getChild('webapp')
  27. try:
  28. from pygments import highlight
  29. from pygments.lexers import get_lexer_by_name
  30. from pygments.formatters import HtmlFormatter
  31. except:
  32. logger.critical("cannot import dependency: pygments")
  33. from sys import exit
  34. exit(1)
  35. from cgi import escape
  36. from datetime import datetime, timedelta
  37. from werkzeug.contrib.fixers import ProxyFix
  38. from flask import (
  39. Flask, request, render_template, url_for, Response, make_response,
  40. redirect, send_from_directory
  41. )
  42. from flask_babel import Babel, gettext, format_date, format_decimal
  43. from flask.json import jsonify
  44. from searx import settings, searx_dir, searx_debug
  45. from searx.exceptions import SearxParameterException
  46. from searx.engines import (
  47. categories, engines, engine_shortcuts, get_engines_stats, initialize_engines
  48. )
  49. from searx.utils import (
  50. UnicodeWriter, highlight_content, html_to_text, get_resources_directory,
  51. get_static_files, get_result_templates, get_themes, gen_useragent,
  52. dict_subset, prettify_url, match_language
  53. )
  54. from searx.version import VERSION_STRING
  55. from searx.languages import language_codes as languages
  56. from searx.search import SearchWithPlugins, get_search_query_from_webapp
  57. from searx.query import RawTextQuery
  58. from searx.autocomplete import searx_bang, backends as autocomplete_backends
  59. from searx.plugins import plugins
  60. from searx.plugins.oa_doi_rewrite import get_doi_resolver
  61. from searx.preferences import Preferences, ValidationException, LANGUAGE_CODES
  62. from searx.answerers import answerers
  63. from searx.url_utils import urlencode, urlparse, urljoin
  64. from searx.utils import new_hmac
  65. # check if the pyopenssl package is installed.
  66. # It is needed for SSL connection without trouble, see #298
  67. try:
  68. import OpenSSL.SSL # NOQA
  69. except ImportError:
  70. logger.critical("The pyopenssl package has to be installed.\n"
  71. "Some HTTPS connections will fail")
  72. try:
  73. from cStringIO import StringIO
  74. except:
  75. from io import StringIO
  76. if sys.version_info[0] == 3:
  77. unicode = str
  78. PY3 = True
  79. else:
  80. PY3 = False
  81. # serve pages with HTTP/1.1
  82. from werkzeug.serving import WSGIRequestHandler
  83. WSGIRequestHandler.protocol_version = "HTTP/{}".format(settings['server'].get('http_protocol_version', '1.0'))
  84. # about static
  85. static_path = get_resources_directory(searx_dir, 'static', settings['ui']['static_path'])
  86. logger.debug('static directory is %s', static_path)
  87. static_files = get_static_files(static_path)
  88. # about templates
  89. default_theme = settings['ui']['default_theme']
  90. templates_path = get_resources_directory(searx_dir, 'templates', settings['ui']['templates_path'])
  91. logger.debug('templates directory is %s', templates_path)
  92. themes = get_themes(templates_path)
  93. result_templates = get_result_templates(templates_path)
  94. global_favicons = []
  95. for indice, theme in enumerate(themes):
  96. global_favicons.append([])
  97. theme_img_path = os.path.join(static_path, 'themes', theme, 'img', 'icons')
  98. for (dirpath, dirnames, filenames) in os.walk(theme_img_path):
  99. global_favicons[indice].extend(filenames)
  100. # Flask app
  101. app = Flask(
  102. __name__,
  103. static_folder=static_path,
  104. template_folder=templates_path
  105. )
  106. app.jinja_env.trim_blocks = True
  107. app.jinja_env.lstrip_blocks = True
  108. app.secret_key = settings['server']['secret_key']
  109. if not searx_debug \
  110. or os.environ.get("WERKZEUG_RUN_MAIN") == "true" \
  111. or os.environ.get('UWSGI_ORIGINAL_PROC_NAME') is not None:
  112. initialize_engines(settings['engines'])
  113. babel = Babel(app)
  114. rtl_locales = ['ar', 'arc', 'bcc', 'bqi', 'ckb', 'dv', 'fa', 'glk', 'he',
  115. 'ku', 'mzn', 'pnb', 'ps', 'sd', 'ug', 'ur', 'yi']
  116. # used when translating category names
  117. _category_names = (gettext('files'),
  118. gettext('general'),
  119. gettext('music'),
  120. gettext('social media'),
  121. gettext('images'),
  122. gettext('videos'),
  123. gettext('it'),
  124. gettext('news'),
  125. gettext('map'),
  126. gettext('science'))
  127. outgoing_proxies = settings['outgoing'].get('proxies') or None
  128. @babel.localeselector
  129. def get_locale():
  130. locale = request.accept_languages.best_match(settings['locales'].keys())
  131. if request.preferences.get_value('locale') != '':
  132. locale = request.preferences.get_value('locale')
  133. if 'locale' in request.args\
  134. and request.args['locale'] in settings['locales']:
  135. locale = request.args['locale']
  136. if 'locale' in request.form\
  137. and request.form['locale'] in settings['locales']:
  138. locale = request.form['locale']
  139. if locale == 'zh_TW':
  140. locale = 'zh_Hant_TW'
  141. return locale
  142. # code-highlighter
  143. @app.template_filter('code_highlighter')
  144. def code_highlighter(codelines, language=None):
  145. if not language:
  146. language = 'text'
  147. try:
  148. # find lexer by programing language
  149. lexer = get_lexer_by_name(language, stripall=True)
  150. except:
  151. # if lexer is not found, using default one
  152. logger.debug('highlighter cannot find lexer for {0}'.format(language))
  153. lexer = get_lexer_by_name('text', stripall=True)
  154. html_code = ''
  155. tmp_code = ''
  156. last_line = None
  157. # parse lines
  158. for line, code in codelines:
  159. if not last_line:
  160. line_code_start = line
  161. # new codeblock is detected
  162. if last_line is not None and\
  163. last_line + 1 != line:
  164. # highlight last codepart
  165. formatter = HtmlFormatter(linenos='inline',
  166. linenostart=line_code_start)
  167. html_code = html_code + highlight(tmp_code, lexer, formatter)
  168. # reset conditions for next codepart
  169. tmp_code = ''
  170. line_code_start = line
  171. # add codepart
  172. tmp_code += code + '\n'
  173. # update line
  174. last_line = line
  175. # highlight last codepart
  176. formatter = HtmlFormatter(linenos='inline', linenostart=line_code_start)
  177. html_code = html_code + highlight(tmp_code, lexer, formatter)
  178. return html_code
  179. # Extract domain from url
  180. @app.template_filter('extract_domain')
  181. def extract_domain(url):
  182. return urlparse(url)[1]
  183. def get_base_url():
  184. if settings['server']['base_url']:
  185. hostname = settings['server']['base_url']
  186. else:
  187. scheme = 'http'
  188. if request.is_secure:
  189. scheme = 'https'
  190. hostname = url_for('index', _external=True, _scheme=scheme)
  191. return hostname
  192. def get_current_theme_name(override=None):
  193. """Returns theme name.
  194. Checks in this order:
  195. 1. override
  196. 2. cookies
  197. 3. settings"""
  198. if override and (override in themes or override == '__common__'):
  199. return override
  200. theme_name = request.args.get('theme', request.preferences.get_value('theme'))
  201. if theme_name not in themes:
  202. theme_name = default_theme
  203. return theme_name
  204. def get_result_template(theme, template_name):
  205. themed_path = theme + '/result_templates/' + template_name
  206. if themed_path in result_templates:
  207. return themed_path
  208. return 'result_templates/' + template_name
  209. def url_for_theme(endpoint, override_theme=None, **values):
  210. if endpoint == 'static' and values.get('filename'):
  211. theme_name = get_current_theme_name(override=override_theme)
  212. filename_with_theme = "themes/{}/{}".format(theme_name, values['filename'])
  213. if filename_with_theme in static_files:
  214. values['filename'] = filename_with_theme
  215. return url_for(endpoint, **values)
  216. def proxify(url):
  217. if url.startswith('//'):
  218. url = 'https:' + url
  219. if not settings.get('result_proxy'):
  220. return url
  221. url_params = dict(mortyurl=url.encode('utf-8'))
  222. if settings['result_proxy'].get('key'):
  223. url_params['mortyhash'] = hmac.new(settings['result_proxy']['key'],
  224. url.encode('utf-8'),
  225. hashlib.sha256).hexdigest()
  226. return '{0}?{1}'.format(settings['result_proxy']['url'],
  227. urlencode(url_params))
  228. def image_proxify(url):
  229. if url.startswith('//'):
  230. url = 'https:' + url
  231. if not request.preferences.get_value('image_proxy'):
  232. return url
  233. if url.startswith('data:image/jpeg;base64,'):
  234. return url
  235. if settings.get('result_proxy'):
  236. return proxify(url)
  237. h = new_hmac(settings['server']['secret_key'], url.encode('utf-8'))
  238. return '{0}?{1}'.format(url_for('image_proxy'),
  239. urlencode(dict(url=url.encode('utf-8'), h=h)))
  240. def render(template_name, override_theme=None, **kwargs):
  241. disabled_engines = request.preferences.engines.get_disabled()
  242. enabled_categories = set(category for engine_name in engines
  243. for category in engines[engine_name].categories
  244. if (engine_name, category) not in disabled_engines)
  245. if 'categories' not in kwargs:
  246. kwargs['categories'] = ['general']
  247. kwargs['categories'].extend(x for x in
  248. sorted(categories.keys())
  249. if x != 'general'
  250. and x in enabled_categories)
  251. if 'all_categories' not in kwargs:
  252. kwargs['all_categories'] = ['general']
  253. kwargs['all_categories'].extend(x for x in
  254. sorted(categories.keys())
  255. if x != 'general')
  256. if 'selected_categories' not in kwargs:
  257. kwargs['selected_categories'] = []
  258. for arg in request.args:
  259. if arg.startswith('category_'):
  260. c = arg.split('_', 1)[1]
  261. if c in categories:
  262. kwargs['selected_categories'].append(c)
  263. if not kwargs['selected_categories']:
  264. cookie_categories = request.preferences.get_value('categories')
  265. for ccateg in cookie_categories:
  266. kwargs['selected_categories'].append(ccateg)
  267. if not kwargs['selected_categories']:
  268. kwargs['selected_categories'] = ['general']
  269. if 'autocomplete' not in kwargs:
  270. kwargs['autocomplete'] = request.preferences.get_value('autocomplete')
  271. if get_locale() in rtl_locales and 'rtl' not in kwargs:
  272. kwargs['rtl'] = True
  273. kwargs['searx_version'] = VERSION_STRING
  274. kwargs['method'] = request.preferences.get_value('method')
  275. kwargs['safesearch'] = str(request.preferences.get_value('safesearch'))
  276. kwargs['language_codes'] = languages
  277. if 'current_language' not in kwargs:
  278. kwargs['current_language'] = match_language(request.preferences.get_value('language'),
  279. LANGUAGE_CODES,
  280. fallback=settings['search']['language'])
  281. # override url_for function in templates
  282. kwargs['url_for'] = url_for_theme
  283. kwargs['image_proxify'] = image_proxify
  284. kwargs['proxify'] = proxify if settings.get('result_proxy', {}).get('url') else None
  285. kwargs['get_result_template'] = get_result_template
  286. kwargs['theme'] = get_current_theme_name(override=override_theme)
  287. kwargs['template_name'] = template_name
  288. kwargs['cookies'] = request.cookies
  289. kwargs['errors'] = request.errors
  290. kwargs['instance_name'] = settings['general']['instance_name']
  291. kwargs['results_on_new_tab'] = request.preferences.get_value('results_on_new_tab')
  292. kwargs['unicode'] = unicode
  293. kwargs['preferences'] = request.preferences
  294. kwargs['scripts'] = set()
  295. for plugin in request.user_plugins:
  296. for script in plugin.js_dependencies:
  297. kwargs['scripts'].add(script)
  298. kwargs['styles'] = set()
  299. for plugin in request.user_plugins:
  300. for css in plugin.css_dependencies:
  301. kwargs['styles'].add(css)
  302. return render_template(
  303. '{}/{}'.format(kwargs['theme'], template_name), **kwargs)
  304. @app.before_request
  305. def pre_request():
  306. request.errors = []
  307. preferences = Preferences(themes, list(categories.keys()), engines, plugins)
  308. request.preferences = preferences
  309. try:
  310. preferences.parse_dict(request.cookies)
  311. except:
  312. request.errors.append(gettext('Invalid settings, please edit your preferences'))
  313. # merge GET, POST vars
  314. # request.form
  315. request.form = dict(request.form.items())
  316. for k, v in request.args.items():
  317. if k not in request.form:
  318. request.form[k] = v
  319. if request.form.get('preferences'):
  320. preferences.parse_encoded_data(request.form['preferences'])
  321. else:
  322. try:
  323. preferences.parse_dict(request.form)
  324. except Exception as e:
  325. logger.exception('invalid settings')
  326. request.errors.append(gettext('Invalid settings'))
  327. # request.user_plugins
  328. request.user_plugins = []
  329. allowed_plugins = preferences.plugins.get_enabled()
  330. disabled_plugins = preferences.plugins.get_disabled()
  331. for plugin in plugins:
  332. if ((plugin.default_on and plugin.id not in disabled_plugins)
  333. or plugin.id in allowed_plugins):
  334. request.user_plugins.append(plugin)
  335. def index_error(output_format, error_message):
  336. if output_format == 'json':
  337. return Response(json.dumps({'error': error_message}),
  338. mimetype='application/json')
  339. elif output_format == 'csv':
  340. response = Response('', mimetype='application/csv')
  341. cont_disp = 'attachment;Filename=searx.csv'
  342. response.headers.add('Content-Disposition', cont_disp)
  343. return response
  344. elif output_format == 'rss':
  345. response_rss = render(
  346. 'opensearch_response_rss.xml',
  347. results=[],
  348. q=request.form['q'] if 'q' in request.form else '',
  349. number_of_results=0,
  350. base_url=get_base_url(),
  351. error_message=error_message,
  352. override_theme='__common__',
  353. )
  354. return Response(response_rss, mimetype='text/xml')
  355. else:
  356. # html
  357. request.errors.append(gettext('search error'))
  358. return render(
  359. 'index.html',
  360. )
  361. @app.route('/search', methods=['GET', 'POST'])
  362. @app.route('/', methods=['GET', 'POST'])
  363. def index():
  364. """Render index page.
  365. Supported outputs: html, json, csv, rss.
  366. """
  367. # output_format
  368. output_format = request.form.get('format', 'html')
  369. if output_format not in ['html', 'csv', 'json', 'rss']:
  370. output_format = 'html'
  371. # check if there is query
  372. if request.form.get('q') is None:
  373. if output_format == 'html':
  374. return render(
  375. 'index.html',
  376. )
  377. else:
  378. return index_error(output_format, 'No query'), 400
  379. # search
  380. search_query = None
  381. raw_text_query = None
  382. result_container = None
  383. try:
  384. search_query, raw_text_query = get_search_query_from_webapp(request.preferences, request.form)
  385. # search = Search(search_query) # without plugins
  386. search = SearchWithPlugins(search_query, request.user_plugins, request)
  387. result_container = search.search()
  388. except Exception as e:
  389. # log exception
  390. logger.exception('search error')
  391. # is it an invalid input parameter or something else ?
  392. if (issubclass(e.__class__, SearxParameterException)):
  393. return index_error(output_format, e.message), 400
  394. else:
  395. return index_error(output_format, gettext('search error')), 500
  396. # results
  397. results = result_container.get_ordered_results()
  398. number_of_results = result_container.results_number()
  399. if number_of_results < result_container.results_length():
  400. number_of_results = 0
  401. # UI
  402. advanced_search = request.form.get('advanced_search', None)
  403. # output
  404. for result in results:
  405. if output_format == 'html':
  406. if 'content' in result and result['content']:
  407. result['content'] = highlight_content(escape(result['content'][:1024]), search_query.query)
  408. result['title'] = highlight_content(escape(result['title'] or u''), search_query.query)
  409. else:
  410. if result.get('content'):
  411. result['content'] = html_to_text(result['content']).strip()
  412. # removing html content and whitespace duplications
  413. result['title'] = ' '.join(html_to_text(result['title']).strip().split())
  414. result['pretty_url'] = prettify_url(result['url'])
  415. # TODO, check if timezone is calculated right
  416. if 'publishedDate' in result:
  417. try: # test if publishedDate >= 1900 (datetime module bug)
  418. result['pubdate'] = result['publishedDate'].strftime('%Y-%m-%d %H:%M:%S%z')
  419. except ValueError:
  420. result['publishedDate'] = None
  421. else:
  422. if result['publishedDate'].replace(tzinfo=None) >= datetime.now() - timedelta(days=1):
  423. timedifference = datetime.now() - result['publishedDate'].replace(tzinfo=None)
  424. minutes = int((timedifference.seconds / 60) % 60)
  425. hours = int(timedifference.seconds / 60 / 60)
  426. if hours == 0:
  427. result['publishedDate'] = gettext(u'{minutes} minute(s) ago').format(minutes=minutes)
  428. else:
  429. result['publishedDate'] = gettext(u'{hours} hour(s), {minutes} minute(s) ago').format(hours=hours, minutes=minutes) # noqa
  430. else:
  431. result['publishedDate'] = format_date(result['publishedDate'])
  432. if output_format == 'json':
  433. return Response(json.dumps({'query': search_query.query.decode('utf-8'),
  434. 'number_of_results': number_of_results,
  435. 'results': results,
  436. 'answers': list(result_container.answers),
  437. 'corrections': list(result_container.corrections),
  438. 'infoboxes': result_container.infoboxes,
  439. 'suggestions': list(result_container.suggestions),
  440. 'unresponsive_engines': list(result_container.unresponsive_engines)},
  441. default=lambda item: list(item) if isinstance(item, set) else item),
  442. mimetype='application/json')
  443. elif output_format == 'csv':
  444. csv = UnicodeWriter(StringIO())
  445. keys = ('title', 'url', 'content', 'host', 'engine', 'score')
  446. csv.writerow(keys)
  447. for row in results:
  448. row['host'] = row['parsed_url'].netloc
  449. csv.writerow([row.get(key, '') for key in keys])
  450. csv.stream.seek(0)
  451. response = Response(csv.stream.read(), mimetype='application/csv')
  452. cont_disp = 'attachment;Filename=searx_-_{0}.csv'.format(search_query.query)
  453. response.headers.add('Content-Disposition', cont_disp)
  454. return response
  455. elif output_format == 'rss':
  456. response_rss = render(
  457. 'opensearch_response_rss.xml',
  458. results=results,
  459. q=request.form['q'],
  460. number_of_results=number_of_results,
  461. base_url=get_base_url(),
  462. override_theme='__common__',
  463. )
  464. return Response(response_rss, mimetype='text/xml')
  465. # HTML output format
  466. # suggestions: use RawTextQuery to get the suggestion URLs with the same bang
  467. suggestion_urls = map(lambda suggestion: {
  468. 'url': raw_text_query.changeSearchQuery(suggestion).getFullQuery(),
  469. 'title': suggestion
  470. },
  471. result_container.suggestions)
  472. #
  473. return render(
  474. 'results.html',
  475. results=results,
  476. q=request.form['q'],
  477. selected_categories=search_query.categories,
  478. pageno=search_query.pageno,
  479. time_range=search_query.time_range,
  480. number_of_results=format_decimal(number_of_results),
  481. advanced_search=advanced_search,
  482. suggestions=suggestion_urls,
  483. answers=result_container.answers,
  484. corrections=result_container.corrections,
  485. infoboxes=result_container.infoboxes,
  486. paging=result_container.paging,
  487. unresponsive_engines=result_container.unresponsive_engines,
  488. current_language=match_language(search_query.lang,
  489. LANGUAGE_CODES,
  490. fallback=settings['search']['language']),
  491. base_url=get_base_url(),
  492. theme=get_current_theme_name(),
  493. favicons=global_favicons[themes.index(get_current_theme_name())]
  494. )
  495. @app.route('/about', methods=['GET'])
  496. def about():
  497. """Render about page"""
  498. return render(
  499. 'about.html',
  500. )
  501. @app.route('/autocompleter', methods=['GET', 'POST'])
  502. def autocompleter():
  503. """Return autocompleter results"""
  504. # set blocked engines
  505. disabled_engines = request.preferences.engines.get_disabled()
  506. # parse query
  507. if PY3:
  508. raw_text_query = RawTextQuery(request.form.get('q', b''), disabled_engines)
  509. else:
  510. raw_text_query = RawTextQuery(request.form.get('q', u'').encode('utf-8'), disabled_engines)
  511. raw_text_query.parse_query()
  512. # check if search query is set
  513. if not raw_text_query.getSearchQuery():
  514. return '', 400
  515. # run autocompleter
  516. completer = autocomplete_backends.get(request.preferences.get_value('autocomplete'))
  517. # parse searx specific autocompleter results like !bang
  518. raw_results = searx_bang(raw_text_query)
  519. # normal autocompletion results only appear if no inner results returned
  520. # and there is a query part besides the engine and language bangs
  521. if len(raw_results) == 0 and completer and (len(raw_text_query.query_parts) > 1 or
  522. (len(raw_text_query.languages) == 0 and
  523. not raw_text_query.specific)):
  524. # get language from cookie
  525. language = request.preferences.get_value('language')
  526. if not language or language == 'all':
  527. language = 'en'
  528. else:
  529. language = language.split('-')[0]
  530. # run autocompletion
  531. raw_results.extend(completer(raw_text_query.getSearchQuery(), language))
  532. # parse results (write :language and !engine back to result string)
  533. results = []
  534. for result in raw_results:
  535. raw_text_query.changeSearchQuery(result)
  536. # add parsed result
  537. results.append(raw_text_query.getFullQuery())
  538. # return autocompleter results
  539. if request.form.get('format') == 'x-suggestions':
  540. return Response(json.dumps([raw_text_query.query, results]),
  541. mimetype='application/json')
  542. return Response(json.dumps(results),
  543. mimetype='application/json')
  544. @app.route('/preferences', methods=['GET', 'POST'])
  545. def preferences():
  546. """Render preferences page && save user preferences"""
  547. # save preferences
  548. if request.method == 'POST':
  549. resp = make_response(redirect(urljoin(settings['server']['base_url'], url_for('index'))))
  550. try:
  551. request.preferences.parse_form(request.form)
  552. except ValidationException:
  553. request.errors.append(gettext('Invalid settings, please edit your preferences'))
  554. return resp
  555. return request.preferences.save(resp)
  556. # render preferences
  557. image_proxy = request.preferences.get_value('image_proxy')
  558. lang = request.preferences.get_value('language')
  559. disabled_engines = request.preferences.engines.get_disabled()
  560. allowed_plugins = request.preferences.plugins.get_enabled()
  561. # stats for preferences page
  562. stats = {}
  563. for c in categories:
  564. for e in categories[c]:
  565. stats[e.name] = {'time': None,
  566. 'warn_timeout': False,
  567. 'warn_time': False}
  568. if e.timeout > settings['outgoing']['request_timeout']:
  569. stats[e.name]['warn_timeout'] = True
  570. stats[e.name]['supports_selected_language'] = _is_selected_language_supported(e, request.preferences)
  571. # get first element [0], the engine time,
  572. # and then the second element [1] : the time (the first one is the label)
  573. for engine_stat in get_engines_stats()[0][1]:
  574. stats[engine_stat.get('name')]['time'] = round(engine_stat.get('avg'), 3)
  575. if engine_stat.get('avg') > settings['outgoing']['request_timeout']:
  576. stats[engine_stat.get('name')]['warn_time'] = True
  577. # end of stats
  578. return render('preferences.html',
  579. locales=settings['locales'],
  580. current_locale=get_locale(),
  581. image_proxy=image_proxy,
  582. engines_by_category=categories,
  583. stats=stats,
  584. answerers=[{'info': a.self_info(), 'keywords': a.keywords} for a in answerers],
  585. disabled_engines=disabled_engines,
  586. autocomplete_backends=autocomplete_backends,
  587. shortcuts={y: x for x, y in engine_shortcuts.items()},
  588. themes=themes,
  589. plugins=plugins,
  590. doi_resolvers=settings['doi_resolvers'],
  591. current_doi_resolver=get_doi_resolver(request.args, request.preferences.get_value('doi_resolver')),
  592. allowed_plugins=allowed_plugins,
  593. theme=get_current_theme_name(),
  594. preferences_url_params=request.preferences.get_as_url_params(),
  595. base_url=get_base_url(),
  596. preferences=True)
  597. def _is_selected_language_supported(engine, preferences):
  598. language = preferences.get_value('language')
  599. return (language == 'all'
  600. or match_language(language,
  601. getattr(engine, 'supported_languages', []),
  602. getattr(engine, 'language_aliases', {}), None))
  603. @app.route('/image_proxy', methods=['GET'])
  604. def image_proxy():
  605. url = request.args.get('url').encode('utf-8')
  606. if not url:
  607. return '', 400
  608. h = new_hmac(settings['server']['secret_key'], url)
  609. if h != request.args.get('h'):
  610. return '', 400
  611. headers = dict_subset(request.headers, {'If-Modified-Since', 'If-None-Match'})
  612. headers['User-Agent'] = gen_useragent()
  613. resp = requests.get(url,
  614. stream=True,
  615. timeout=settings['outgoing']['request_timeout'],
  616. headers=headers,
  617. proxies=outgoing_proxies)
  618. if resp.status_code == 304:
  619. return '', resp.status_code
  620. if resp.status_code != 200:
  621. logger.debug('image-proxy: wrong response code: {0}'.format(resp.status_code))
  622. if resp.status_code >= 400:
  623. return '', resp.status_code
  624. return '', 400
  625. if not resp.headers.get('content-type', '').startswith('image/'):
  626. logger.debug('image-proxy: wrong content-type: {0}'.format(resp.headers.get('content-type')))
  627. return '', 400
  628. img = b''
  629. chunk_counter = 0
  630. for chunk in resp.iter_content(1024 * 1024):
  631. chunk_counter += 1
  632. if chunk_counter > 5:
  633. return '', 502 # Bad gateway - file is too big (>5M)
  634. img += chunk
  635. headers = dict_subset(resp.headers, {'Content-Length', 'Length', 'Date', 'Last-Modified', 'Expires', 'Etag'})
  636. return Response(img, mimetype=resp.headers['content-type'], headers=headers)
  637. @app.route('/stats', methods=['GET'])
  638. def stats():
  639. """Render engine statistics page."""
  640. stats = get_engines_stats()
  641. return render(
  642. 'stats.html',
  643. stats=stats,
  644. )
  645. @app.route('/robots.txt', methods=['GET'])
  646. def robots():
  647. return Response("""User-agent: *
  648. Allow: /
  649. Allow: /about
  650. Disallow: /stats
  651. Disallow: /preferences
  652. Disallow: /*?*q=*
  653. """, mimetype='text/plain')
  654. @app.route('/opensearch.xml', methods=['GET'])
  655. def opensearch():
  656. method = 'post'
  657. if request.preferences.get_value('method') == 'GET':
  658. method = 'get'
  659. # chrome/chromium only supports HTTP GET....
  660. if request.headers.get('User-Agent', '').lower().find('webkit') >= 0:
  661. method = 'get'
  662. ret = render('opensearch.xml',
  663. opensearch_method=method,
  664. host=get_base_url(),
  665. urljoin=urljoin,
  666. override_theme='__common__')
  667. resp = Response(response=ret,
  668. status=200,
  669. mimetype="text/xml")
  670. return resp
  671. @app.route('/favicon.ico')
  672. def favicon():
  673. return send_from_directory(os.path.join(app.root_path,
  674. static_path,
  675. 'themes',
  676. get_current_theme_name(),
  677. 'img'),
  678. 'favicon.png',
  679. mimetype='image/vnd.microsoft.icon')
  680. @app.route('/clear_cookies')
  681. def clear_cookies():
  682. resp = make_response(redirect(urljoin(settings['server']['base_url'], url_for('index'))))
  683. for cookie_name in request.cookies:
  684. resp.delete_cookie(cookie_name)
  685. return resp
  686. @app.route('/config')
  687. def config():
  688. return jsonify({'categories': list(categories.keys()),
  689. 'engines': [{'name': engine_name,
  690. 'categories': engine.categories,
  691. 'shortcut': engine.shortcut,
  692. 'enabled': not engine.disabled,
  693. 'paging': engine.paging,
  694. 'language_support': engine.language_support,
  695. 'supported_languages':
  696. list(engine.supported_languages.keys())
  697. if isinstance(engine.supported_languages, dict)
  698. else engine.supported_languages,
  699. 'safesearch': engine.safesearch,
  700. 'time_range_support': engine.time_range_support,
  701. 'timeout': engine.timeout}
  702. for engine_name, engine in engines.items()],
  703. 'plugins': [{'name': plugin.name,
  704. 'enabled': plugin.default_on}
  705. for plugin in plugins],
  706. 'instance_name': settings['general']['instance_name'],
  707. 'locales': settings['locales'],
  708. 'default_locale': settings['ui']['default_locale'],
  709. 'autocomplete': settings['search']['autocomplete'],
  710. 'safe_search': settings['search']['safe_search'],
  711. 'default_theme': settings['ui']['default_theme'],
  712. 'version': VERSION_STRING,
  713. 'doi_resolvers': [r for r in settings['doi_resolvers']],
  714. 'default_doi_resolver': settings['default_doi_resolver'],
  715. })
  716. @app.errorhandler(404)
  717. def page_not_found(e):
  718. return render('404.html'), 404
  719. def run():
  720. logger.debug('starting webserver on %s:%s', settings['server']['port'], settings['server']['bind_address'])
  721. app.run(
  722. debug=searx_debug,
  723. use_debugger=searx_debug,
  724. port=settings['server']['port'],
  725. host=settings['server']['bind_address'],
  726. threaded=True
  727. )
  728. class ReverseProxyPathFix(object):
  729. '''Wrap the application in this middleware and configure the
  730. front-end server to add these headers, to let you quietly bind
  731. this to a URL other than / and to an HTTP scheme that is
  732. different than what is used locally.
  733. http://flask.pocoo.org/snippets/35/
  734. In nginx:
  735. location /myprefix {
  736. proxy_pass http://127.0.0.1:8000;
  737. proxy_set_header Host $host;
  738. proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
  739. proxy_set_header X-Scheme $scheme;
  740. proxy_set_header X-Script-Name /myprefix;
  741. }
  742. :param app: the WSGI application
  743. '''
  744. def __init__(self, app):
  745. self.app = app
  746. def __call__(self, environ, start_response):
  747. script_name = environ.get('HTTP_X_SCRIPT_NAME', '')
  748. if script_name:
  749. environ['SCRIPT_NAME'] = script_name
  750. path_info = environ['PATH_INFO']
  751. if path_info.startswith(script_name):
  752. environ['PATH_INFO'] = path_info[len(script_name):]
  753. scheme = environ.get('HTTP_X_SCHEME', '')
  754. if scheme:
  755. environ['wsgi.url_scheme'] = scheme
  756. return self.app(environ, start_response)
  757. application = app
  758. # patch app to handle non root url-s behind proxy & wsgi
  759. app.wsgi_app = ReverseProxyPathFix(ProxyFix(application.wsgi_app))
  760. if __name__ == "__main__":
  761. run()