-
Notifications
You must be signed in to change notification settings - Fork 63
/
Copy pathresult.py
60 lines (47 loc) · 1.81 KB
/
result.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
from six.moves import xrange, zip as izip
from .document import Document
from ._util import to_string
class Result(object):
"""
Represents the result of a search query, and has an array of Document objects
"""
def __init__(self, res, hascontent, duration=0, has_payload=False, with_scores=False):
"""
- **snippets**: An optional dictionary of the form {field: snippet_size} for snippet formatting
"""
self.total = res[0]
self.duration = duration
self.docs = []
step = 1
if hascontent:
step = step + 1
if has_payload:
step = step + 1
if with_scores:
step = step + 1
offset = 2 if with_scores else 1
for i in xrange(1, len(res), step):
id = to_string(res[i])
payload = to_string(res[i+offset]) if has_payload else None
#fields_offset = 2 if has_payload else 1
fields_offset = offset+1 if has_payload else offset
score = float(res[i+1]) if with_scores else None
fields = {}
if hascontent:
fields = dict(
dict(izip(map(to_string, res[i + fields_offset][::2]),
map(to_string, res[i + fields_offset][1::2])))
) if hascontent else {}
try:
del fields['id']
except KeyError:
pass
try:
fields['json'] = fields['$']
del fields['$']
except KeyError:
pass
doc = Document(id, score=score, payload=payload, **fields) if with_scores else Document(id, payload=payload, **fields)
self.docs.append(doc)
def __repr__(self):
return 'Result{%d total, docs: %s}' % (self.total, self.docs)