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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
| | #include <xapian.h>
#include "notmuch-private.h"
#include "sexp.h"
typedef struct {
const char *name;
Xapian::Query::op xapian_op;
Xapian::Query initial;
} _sexp_op_t;
static _sexp_op_t operations[] =
{
{ "and", Xapian::Query::OP_AND, Xapian::Query::MatchAll },
{ "not", Xapian::Query::OP_AND_NOT, Xapian::Query::MatchAll },
{ "or", Xapian::Query::OP_OR, Xapian::Query::MatchNothing },
{ }
};
typedef struct {
const char *name;
Xapian::Query::op xapian_op;
} _sexp_field_t;
static _sexp_field_t fields[] =
{
{ "attachment", Xapian::Query::OP_PHRASE },
{ "body", Xapian::Query::OP_PHRASE },
{ "from", Xapian::Query::OP_PHRASE },
{ "folder", Xapian::Query::OP_OR },
{ "id", Xapian::Query::OP_OR },
{ "is", Xapian::Query::OP_AND },
{ "mid", Xapian::Query::OP_OR },
{ "mimetype", Xapian::Query::OP_PHRASE },
{ "path", Xapian::Query::OP_OR },
{ "property", Xapian::Query::OP_AND },
{ "subject", Xapian::Query::OP_PHRASE },
{ "tag", Xapian::Query::OP_AND },
{ "thread", Xapian::Query::OP_OR },
{ "to", Xapian::Query::OP_PHRASE },
{ }
};
static Xapian::Query _sexp_to_xapian_query (sexp_t *sx);
static Xapian::Query
_sexp_combine_query (Xapian::Query::op operation,
Xapian::Query left,
sexp_t *sx)
{
/* if we run out elements, return accumulator */
if (! sx)
return left;
return _sexp_combine_query (operation,
Xapian::Query (operation,
left,
_sexp_to_xapian_query (sx)),
sx->next);
}
Xapian::Query
_notmuch_sexp_string_to_xapian_query (notmuch_database_t *notmuch, const char *querystr)
{
sexp_t *sx = NULL;
char *buf = talloc_strdup (notmuch, querystr);
sx = parse_sexp (buf, strlen (querystr));
return _sexp_to_xapian_query (sx);
}
static Xapian::Query
_sexp_combine_field (const char *prefix,
Xapian::Query::op operation,
sexp_t *sx)
{
std::vector<std::string> terms;
for (sexp_t *cur = sx; cur; cur = cur->next) {
std::string pref_str = prefix;
if (operation == Xapian::Query::OP_PHRASE) {
Xapian::Utf8Iterator p (cur->val);
Xapian::Utf8Iterator end;
while (p != end) {
Xapian::Utf8Iterator start;
while (p != end && ! Xapian::Unicode::is_wordchar (*p))
p++;
if (p == end)
break;
start = p;
while (p != end && Xapian::Unicode::is_wordchar (*p))
p++;
if (p != start) {
std::string word (start, p);
word = Xapian::Unicode::tolower (word);
terms.push_back (pref_str + word);
}
}
} else {
terms.push_back (pref_str + cur->val);
}
}
return Xapian::Query (operation, terms.begin (), terms.end ());
}
/* Here we expect the s-expression to be a proper list, with first
* element defining and operation, or as a special case the empty
* list */
static Xapian::Query
_sexp_to_xapian_query (sexp_t *sx)
{
const _sexp_op_t *op;
/* Currently we don't understand atoms */
assert (sx->ty == SEXP_LIST);
/* Empty list */
if (! sx->list)
return Xapian::Query::MatchAll;
for (op = operations; op && op->name; op++) {
if (strcasecmp (op->name, hd_sexp (sx)->val) == 0)
return _sexp_combine_query (op->xapian_op, op->initial, sx->list->next);
}
for (const _sexp_field_t *field = fields; field && field->name; field++) {
if (strcasecmp (field->name, hd_sexp (sx)->val) == 0)
return _sexp_combine_field (_find_prefix (field->name), field->xapian_op, sx->list->next);
}
INTERNAL_ERROR ("unimplemented prefix %s\n", sx->list->val);
}
|