recoll.py 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. """
  2. Recoll (local search engine)
  3. @using-api yes
  4. @results JSON
  5. @stable yes
  6. @parse url, content, size, abstract, author, mtype, subtype, time, \
  7. filename, label, type, embedded
  8. """
  9. from datetime import date, timedelta
  10. from json import loads
  11. from urllib.parse import urlencode, quote
  12. # engine dependent config
  13. time_range_support = True
  14. # parameters from settings.yml
  15. base_url = None
  16. search_dir = ''
  17. mount_prefix = None
  18. dl_prefix = None
  19. # embedded
  20. embedded_url = '<{ttype} controls height="166px" ' +\
  21. 'src="{url}" type="{mtype}"></{ttype}>'
  22. # helper functions
  23. def get_time_range(time_range):
  24. sw = {
  25. 'day': 1,
  26. 'week': 7,
  27. 'month': 30,
  28. 'year': 365
  29. }
  30. offset = sw.get(time_range, 0)
  31. if not offset:
  32. return ''
  33. return (date.today() - timedelta(days=offset)).isoformat()
  34. # do search-request
  35. def request(query, params):
  36. search_after = get_time_range(params['time_range'])
  37. search_url = base_url + 'json?{query}&highlight=0'
  38. params['url'] = search_url.format(query=urlencode({
  39. 'query': query,
  40. 'after': search_after,
  41. 'dir': search_dir}))
  42. return params
  43. # get response from search-request
  44. def response(resp):
  45. results = []
  46. response_json = loads(resp.text)
  47. if not response_json:
  48. return []
  49. for result in response_json.get('results', []):
  50. title = result['label']
  51. url = result['url'].replace('file://' + mount_prefix, dl_prefix)
  52. content = '{}'.format(result['snippet'])
  53. # append result
  54. item = {'url': url,
  55. 'title': title,
  56. 'content': content,
  57. 'template': 'files.html'}
  58. if result['size']:
  59. item['size'] = int(result['size'])
  60. for parameter in ['filename', 'abstract', 'author', 'mtype', 'time']:
  61. if result[parameter]:
  62. item[parameter] = result[parameter]
  63. # facilitate preview support for known mime types
  64. if 'mtype' in result and '/' in result['mtype']:
  65. (mtype, subtype) = result['mtype'].split('/')
  66. item['mtype'] = mtype
  67. item['subtype'] = subtype
  68. if mtype in ['audio', 'video']:
  69. item['embedded'] = embedded_url.format(
  70. ttype=mtype,
  71. url=quote(url.encode('utf8'), '/:'),
  72. mtype=result['mtype'])
  73. if mtype in ['image'] and subtype in ['bmp', 'gif', 'jpeg', 'png']:
  74. item['img_src'] = url
  75. results.append(item)
  76. if 'nres' in response_json:
  77. results.append({'number_of_results': response_json['nres']})
  78. return results