Code

analyzer: Support more flexible iterator expressions.
[sysdb.git] / t / unit / parser / parser_test.c
1 /*
2  * SysDB - t/unit/parser/parser_test.c
3  * Copyright (C) 2013-2015 Sebastian 'tokkee' Harl <sh@tokkee.org>
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  *
15  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
16  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
17  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
18  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR
19  * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
20  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
21  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
22  * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
23  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
24  * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
25  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26  */
28 #if HAVE_CONFIG_H
29 #       include "config.h"
30 #endif
32 #include "parser/parser.h"
33 #include "core/object.h"
34 #include "core/store.h"
35 #include "testutils.h"
37 #include <check.h>
38 #include <limits.h>
40 /*
41  * tests
42  */
44 struct {
45         const char *query;
46         int len;
47         int expected;
48         int expected_type;
49         int expected_extra; /* type-specific extra information */
50 } parse_data[] = {
51         /* empty commands */
52         { NULL,                  -1, -1, 0, 0 },
53         { "",                    -1,  0, 0, 0 },
54         { ";",                   -1,  0, 0, 0 },
55         { ";;",                  -1,  0, 0, 0 },
57         /* FETCH commands */
58         { "FETCH host 'host'",   -1,  1, SDB_AST_TYPE_FETCH, SDB_HOST },
59         { "FETCH host 'host' FILTER "
60           "age > 60s",           -1,  1, SDB_AST_TYPE_FETCH, SDB_HOST },
61         { "FETCH service "
62           "'host'.'service'",    -1,  1, SDB_AST_TYPE_FETCH, SDB_SERVICE },
63         { "FETCH metric "
64           "'host'.'metric'",     -1,  1, SDB_AST_TYPE_FETCH, SDB_METRIC },
66         /* LIST commands */
67         { "LIST hosts",            -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
68         { "LIST hosts -- foo",     -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
69         { "LIST hosts;",           -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
70         { "LIST hosts; INVALID",   11,  1, SDB_AST_TYPE_LIST, SDB_HOST },
71         { "LIST hosts FILTER "
72           "age > 60s",             -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
73         { "LIST services",         -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
74         { "LIST services FILTER "
75           "age > 60s",             -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
76         { "LIST metrics",          -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
77         { "LIST metrics FILTER "
78           "age > 60s",             -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
79         /* field access */
80         { "LIST hosts FILTER "
81           "name = 'a'",            -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
82         { "LIST hosts FILTER "
83           "last_update > 1s",      -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
84         { "LIST hosts FILTER "
85           "age > 120s",            -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
86         { "LIST hosts FILTER "
87           "interval > 10s",        -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
88         { "LIST hosts FILTER "
89           "backend = ['b']",       -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
90         { "LIST hosts FILTER ANY "
91           "attribute.value = 'a'", -1,  1, SDB_AST_TYPE_LIST, SDB_HOST },
92         { "LIST services FILTER "
93           "name = 'a'",            -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
94         { "LIST services FILTER "
95           "last_update > 1s",      -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
96         { "LIST services FILTER "
97           "age > 120s",            -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
98         { "LIST services FILTER "
99           "interval > 10s",        -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
100         { "LIST services FILTER "
101           "backend = ['b']",       -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
102         { "LIST services FILTER ANY "
103           "attribute.value = 'a'", -1,  1, SDB_AST_TYPE_LIST, SDB_SERVICE },
104         { "LIST metrics FILTER "
105           "name = 'a'",            -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
106         { "LIST metrics FILTER "
107           "last_update > 1s",      -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
108         { "LIST metrics FILTER "
109           "age > 120s",            -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
110         { "LIST metrics FILTER "
111           "interval > 10s",        -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
112         { "LIST metrics FILTER "
113           "backend = ['b']",       -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
114         { "LIST metrics FILTER ANY "
115           "attribute.value = 'a'", -1,  1, SDB_AST_TYPE_LIST, SDB_METRIC },
117         /* LOOKUP commands */
118         { "LOOKUP hosts",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
119         { "LOOKUP hosts MATCHING "
120           "name = 'host'",       -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
121         { "LOOKUP hosts MATCHING NOT "
122           "name = 'host'",       -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
123         { "LOOKUP hosts MATCHING "
124           "name =~ 'p' AND "
125           "ANY service.name =~ 'p'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
126         { "LOOKUP hosts MATCHING NOT "
127           "name =~ 'p' AND "
128           "ANY service.name =~ 'p'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
129         { "LOOKUP hosts MATCHING "
130           "name =~ 'p' AND "
131           "ANY service.name =~ 'p' OR "
132           "ANY service.name =~ 'r'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
133         { "LOOKUP hosts MATCHING NOT "
134           "name =~ 'p' AND "
135           "ANY service.name =~ 'p' OR "
136           "ANY service.name =~ 'r'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
137         { "LOOKUP hosts MATCHING "
138           "name =~ 'p' "
139           "FILTER age > 1D",         -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
140         { "LOOKUP hosts MATCHING "
141           "name =~ 'p' "
142           "FILTER age > 1D AND "
143           "interval < 240s" ,        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
144         { "LOOKUP hosts MATCHING "
145           "name =~ 'p' "
146           "FILTER NOT age>1D",       -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
147         { "LOOKUP hosts MATCHING "
148           "name =~ 'p' "
149           "FILTER age>"
150           "interval",                -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
151         { "LOOKUP hosts MATCHING "
152           "host.name =~ 'p'",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
153         { "LOOKUP services",         -1,   1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
154         { "LOOKUP services MATCHING ANY "
155           "attribute.name =~ 'a'",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
156         { "LOOKUP services MATCHING "
157           "host.name = 'p'",         -1,   1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
158         { "LOOKUP services MATCHING "
159           "service.name = 'p'",      -1,   1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
160         { "LOOKUP services MATCHING ANY "
161           "host.backend =~ 'b'",     -1,   1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
162         { "LOOKUP metrics",          -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
163         { "LOOKUP metrics MATCHING ANY "
164           "attribute.name =~ 'a'",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
165         { "LOOKUP metrics MATCHING "
166           "host.name = 'p'",         -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
167         { "LOOKUP metrics MATCHING "
168           "metric.name = 'p'",       -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
169         { "LOOKUP metrics MATCHING ANY "
170           "host.service.name = 'p'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
172         /* TIMESERIES commands */
173         { "TIMESERIES 'host'.'metric' "
174           "START 2014-01-01 "
175           "END 2014-12-31 "
176           "23:59:59",            -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
177         { "TIMESERIES 'host'.'metric' "
178           "START 2014-02-02 "
179           "14:02",               -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
180         /* the end time has to be greater than the start time;
181          * we'll be safe for about 200 years ;-) */
182         { "TIMESERIES 'host'.'metric' "
183           "END 2214-02-02",      -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
184         { "TIMESERIES "
185           "'host'.'metric'",     -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
187         /* STORE commands */
188         { "STORE host 'host'",   -1,  1, SDB_AST_TYPE_STORE, SDB_HOST },
189         { "STORE host 'host' "
190           "LAST UPDATE "
191           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_HOST },
192         { "STORE host attribute "
193           "'host'.'key' 123",    -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
194         { "STORE host attribute "
195           "'host'.'key' 123 "
196           "LAST UPDATE "
197           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
198         { "STORE service "
199           "'host'.'svc'",        -1,  1, SDB_AST_TYPE_STORE, SDB_SERVICE },
200         { "STORE service "
201           "'host'.'svc' "
202           "LAST UPDATE "
203           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_SERVICE },
204         { "STORE service attribute "
205           "'host'.'svc'.'key' "
206           "123",                 -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
207         { "STORE service attribute "
208           "'host'.'svc'.'key' "
209           "123 "
210           "LAST UPDATE "
211           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
212         { "STORE metric "
213           "'host'.'metric'",     -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
214         { "STORE metric "
215           "'host'.'metric' "
216           "LAST UPDATE "
217           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
218         { "STORE metric "
219           "'host'.'metric' "
220           "STORE 'typ' 'id' "
221           "LAST UPDATE "
222           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
223         { "STORE metric attribute "
224           "'host'.'metric'.'key' "
225           "123",                 -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
226         { "STORE metric attribute "
227           "'host'.'metric'.'key' "
228           "123 "
229           "LAST UPDATE "
230           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
232         /* string constants */
233         { "LOOKUP hosts MATCHING "
234           "name = ''''",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
235         { "LOOKUP hosts MATCHING "
236           "name = '''foo'",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
237         { "LOOKUP hosts MATCHING "
238           "name = 'f''oo'",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
239         { "LOOKUP hosts MATCHING "
240           "name = 'foo'''",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
241         { "LOOKUP hosts MATCHING "
242           "name = '''",          -1, -1, 0, SDB_HOST },
244         /* numeric constants */
245         { "LOOKUP hosts MATCHING "
246           "attribute['foo'] = "
247           "1234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
248         { "LOOKUP hosts MATCHING "
249           "attribute['foo'] != "
250           "+234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
251         { "LOOKUP hosts MATCHING "
252           "attribute['foo'] < "
253           "-234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
254         { "LOOKUP hosts MATCHING "
255           "attribute['foo'] > "
256           "12.4",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
257         { "LOOKUP hosts MATCHING "
258           "attribute['foo'] <= "
259           "12. + .3",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
260         { "LOOKUP hosts MATCHING "
261           "attribute['foo'] <= "
262           "'f' || 'oo'",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
263         { "LOOKUP hosts MATCHING "
264           "attribute['foo'] >= "
265           ".4",                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
266         { "LOOKUP hosts MATCHING "
267           "attribute['foo'] = "
268           "+12e3",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
269         { "LOOKUP hosts MATCHING "
270           "attribute['foo'] = "
271           "+12e-3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
272         { "LOOKUP hosts MATCHING "
273           "attribute['foo'] = "
274           "-12e+3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
276         /* date, time, interval constants */
277         { "LOOKUP hosts MATCHING "
278           "attribute['foo'] = "
279           "1 Y 42D",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
280         { "LOOKUP hosts MATCHING "
281           "attribute['foo'] = "
282           "1s 42D",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
283         /*
284          * TODO: Something like 1Y42D should work as well but it doesn't since
285          * the scanner will tokenize it into {digit}{identifier} :-/
286          *
287         { "LOOKUP hosts MATCHING "
288           "attribute['foo'] = "
289           "1Y42D",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
290          */
292         /* array constants */
293         { "LOOKUP hosts MATCHING "
294           "backend = ['foo']",   -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
295         { "LOOKUP hosts MATCHING "
296           "backend = ['a','b']", -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
298         /* array iteration */
299         { "LOOKUP hosts MATCHING "
300           "'foo' IN backend",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
301         { "LOOKUP hosts MATCHING 'foo' "
302           "NOT IN backend",     -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
303         { "LOOKUP hosts MATCHING "
304           "['foo','bar'] "
305           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
306         /* attribute type is unknown */
307         { "LOOKUP hosts MATCHING "
308           "attribute['backend'] "
309           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
310         { "LOOKUP hosts MATCHING "
311           "ANY backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
312         { "LOOKUP hosts MATCHING "
313           "ANY backend <= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
314         { "LOOKUP hosts MATCHING "
315           "ANY backend = 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
316         { "LOOKUP hosts MATCHING "
317           "ANY backend != 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
318         { "LOOKUP hosts MATCHING "
319           "ANY backend >= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
320         { "LOOKUP hosts MATCHING "
321           "ANY backend > 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
322         { "LOOKUP hosts MATCHING "
323           "ANY backend =~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
324         { "LOOKUP hosts MATCHING "
325           "ANY backend !~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
326         { "LOOKUP hosts MATCHING "
327           "ALL backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
328         { "LOOKUP hosts MATCHING "
329           "ALL backend <= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
330         { "LOOKUP hosts MATCHING "
331           "ALL backend = 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
332         { "LOOKUP hosts MATCHING "
333           "ALL backend != 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
334         { "LOOKUP hosts MATCHING "
335           "ALL backend >= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
336         { "LOOKUP hosts MATCHING "
337           "ALL backend > 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
338         { "LOOKUP hosts MATCHING "
339           "ALL backend =~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
340         { "LOOKUP hosts MATCHING "
341           "ALL backend !~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
342         /* attribute type is unknown */
343         { "LOOKUP hosts MATCHING "
344           "ANY backend = attribute['backend']",
345                                 -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
347         /* valid operand types */
348         { "LOOKUP hosts MATCHING "
349           "age * 1 > 0s",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
350         { "LOOKUP hosts MATCHING "
351           "age / 1 > 0s",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
352         { "LOOKUP hosts MATCHING "
353           "name > ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
354         { "LOOKUP hosts MATCHING "
355           "name >= ''",          -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
356         { "LOOKUP hosts MATCHING "
357           "name != ''",          -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
358         { "LOOKUP hosts MATCHING "
359           "name = ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
360         { "LOOKUP hosts MATCHING "
361           "name <= ''",          -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
362         { "LOOKUP hosts MATCHING "
363           "name < ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
365         /* typed expressions */
366         { "LOOKUP services MATCHING "
367           "host.attribute['a'] = 'a'",
368                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
369         /* TODO: this should work but the analyzer currently sees ATTRIBUTE
370          * (instead of SERVICE-ATTRIBUTE) as the child type
371         { "LOOKUP services MATCHING "
372           "ANY attribute.service.name = 's'",
373                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
374          */
375         { "LOOKUP hosts MATCHING "
376           "ANY service.service.name = 's'",
377                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
379         /* NULL / TRUE / FALSE */
380         { "LOOKUP hosts MATCHING "
381           "attribute['foo'] "
382           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
383         { "LOOKUP hosts MATCHING "
384           "attribute['foo'] "
385           "IS NOT NULL",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
386         { "LOOKUP hosts MATCHING "
387           "NOT attribute['foo'] "
388           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
389         { "LOOKUP hosts MATCHING "
390           "ANY service.name IS NULL", -1, -1, 0, 0 },
391         { "LOOKUP hosts MATCHING "
392           "attribute['foo'] "
393           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
394         { "LOOKUP hosts MATCHING "
395           "attribute['foo'] "
396           "IS NOT TRUE",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
397         { "LOOKUP hosts MATCHING "
398           "NOT attribute['foo'] "
399           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
400         { "LOOKUP hosts MATCHING "
401           "attribute['foo'] "
402           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
403         { "LOOKUP hosts MATCHING "
404           "attribute['foo'] "
405           "IS NOT FALSE",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
406         { "LOOKUP hosts MATCHING "
407           "NOT attribute['foo'] "
408           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
409         { "LOOKUP metrics MATCHING "
410           "timeseries IS TRUE",  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
412         /* invalid numeric constants */
413         { "LOOKUP hosts MATCHING "
414           "attribute['foo'] = "
415           "+-12e+3",             -1, -1, 0, 0 },
416         { "LOOKUP hosts MATCHING "
417           "attribute['foo'] = "
418           "-12e-+3",             -1, -1, 0, 0 },
419         { "LOOKUP hosts MATCHING "
420           "attribute['foo'] = "
421           "e+3",                 -1, -1, 0, 0 },
422         { "LOOKUP hosts MATCHING "
423           "attribute['foo'] = "
424           "3e",                  -1, -1, 0, 0 },
425         /* following SQL standard, we don't support hex numbers */
426         { "LOOKUP hosts MATCHING "
427           "attribute['foo'] = "
428           "0x12",                -1, -1, 0, 0 },
430         /* invalid expressions */
431         { "LOOKUP hosts MATCHING "
432           "attr['foo'] = 1.23",  -1, -1, 0, 0 },
433         { "LOOKUP hosts MATCHING "
434           "attr['foo'] IS NULL", -1, -1, 0, 0 },
436         /* comments */
437         { "/* some comment */",  -1,  0, 0, 0 },
438         { "-- another comment",  -1,  0, 0, 0 },
440         /* syntax errors */
441         { "INVALID",             -1, -1, 0, 0 },
442         { "FETCH host",          -1, -1, 0, 0 },
443         { "FETCH 'host'",        -1, -1, 0, 0 },
444         { "LIST hosts; INVALID", -1, -1, 0, 0 },
445         { "/* some incomplete",  -1, -1, 0, 0 },
447         /*
448          * syntactically correct but semantically invalid commands
449          */
451         /* invalid fields */
452         { "LIST hosts FILTER "
453           "field = 'a'",           -1, -1, 0, 0 },
454         { "LIST services FILTER "
455           "field = 'a'",           -1, -1, 0, 0 },
456         { "LIST metrics FILTER "
457           "field = 'a'",           -1, -1, 0, 0 },
458         { "LIST hosts FILTER "
459           "value = 'a'",           -1, -1, 0, 0 },
460         { "LIST services FILTER "
461           "value = 'a'",           -1, -1, 0, 0 },
462         { "LIST metrics FILTER "
463           "value = 'a'",           -1, -1, 0, 0 },
464         { "LIST metrics FILTER "
465           "name.1 = 'a'",          -1, -1, 0, 0 },
466         { "LIST hosts FILTER "
467           "timeseries IS TRUE",    -1, -1, 0, 0 },
468         { "LIST services FILTER "
469           "timeseries IS TRUE",    -1, -1, 0, 0 },
471         /* type mismatches */
472         { "LOOKUP hosts MATCHING "
473           "attribute['foo'] = "
474           "1.23 + 'foo'",       -1,  -1, 0, 0 },
475         { "LOOKUP hosts MATCHING "
476           "1 IN backend ",      -1,  -1, 0, 0 },
477         { "LOOKUP hosts MATCHING "
478           "1 NOT IN backend ",  -1,  -1, 0, 0 },
479         { "LOOKUP hosts MATCHING "
480           "age > 0",             -1, -1, 0, 0 },
481         { "LOOKUP hosts MATCHING "
482           "NOT age > 0",         -1, -1, 0, 0 },
483         { "LOOKUP hosts MATCHING "
484           "age >= 0",            -1, -1, 0, 0 },
485         { "LOOKUP hosts MATCHING "
486           "age = 0",             -1, -1, 0, 0 },
487         { "LOOKUP hosts MATCHING "
488           "age != 0",            -1, -1, 0, 0 },
489         { "LOOKUP hosts MATCHING "
490           "age <= 0",            -1, -1, 0, 0 },
491         { "LOOKUP hosts MATCHING "
492           "age < 0",             -1, -1, 0, 0 },
493         { "LOOKUP hosts MATCHING "
494           "age + 1 > 0s",        -1, -1, 0, 0 },
495         { "LOOKUP hosts MATCHING "
496           "age - 1 > 0s",        -1, -1, 0, 0 },
498         /* datetime <mul/div> integer is allowed */
499         { "LOOKUP hosts MATCHING "
500           "age || 1 > 0s",       -1, -1, 0, 0 },
501         { "LOOKUP hosts MATCHING "
502           "name + 1 = ''",       -1, -1, 0, 0 },
503         { "LOOKUP hosts MATCHING "
504           "name - 1 = ''",       -1, -1, 0, 0 },
505         { "LOOKUP hosts MATCHING "
506           "name * 1 = ''",       -1, -1, 0, 0 },
507         { "LOOKUP hosts MATCHING "
508           "name / 1 = ''",       -1, -1, 0, 0 },
509         { "LOOKUP hosts MATCHING "
510           "name % 1 = ''",       -1, -1, 0, 0 },
511         { "LOOKUP hosts MATCHING "
512           "(name % 1) + 1 = ''", -1, -1, 0, 0 },
513         { "LOOKUP hosts MATCHING "
514           "1 + (name % 1) = ''", -1, -1, 0, 0 },
515         { "LOOKUP hosts MATCHING "
516           "'' = 1 + (name % 1)", -1, -1, 0, 0 },
517         { "LOOKUP hosts MATCHING "
518           "age > 0 AND "
519           "age = 0s",            -1, -1, 0, 0 },
520         { "LOOKUP hosts MATCHING "
521           "age = 0s AND "
522           "age > 0",             -1, -1, 0, 0 },
523         { "LOOKUP services MATCHING "
524           "host.name > 0",       -1, -1, 0, 0 },
525         { "LOOKUP services MATCHING "
526           "backend > 'b'",       -1, -1, 0, 0 },
527         { "LOOKUP services MATCHING "
528           "'b' > backend",       -1, -1, 0, 0 },
529         { "LOOKUP services MATCHING "
530           "attribute['a'] > backend",
531                                  -1, -1, 0, 0 },
532         { "LOOKUP services MATCHING "
533           "backend > attribute['a']",
534                                  -1, -1, 0, 0 },
535         { "LOOKUP services MATCHING "
536           "host.name + 1 = ''",  -1, -1, 0, 0 },
537         { "LOOKUP hosts MATCHING "
538           "'a' + 1 IN 'b'",      -1, -1, 0, 0 },
539         { "LOOKUP hosts MATCHING "
540           "'a' IN 'b' - 1",      -1, -1, 0, 0 },
541         { "LOOKUP hosts MATCHING "
542           "name + 1 IN 'b'",     -1, -1, 0, 0 },
543         { "LOOKUP hosts MATCHING "
544           "'a' IN name - 1",     -1, -1, 0, 0 },
545         { "LOOKUP hosts MATCHING "
546           "'b' IN 'abc'",        -1, -1, 0, 0 },
547         { "LOOKUP hosts MATCHING "
548           "1 IN age",            -1, -1, 0, 0 },
549         { "LOOKUP hosts MATCHING "
550           "name =~ 'a' + 1",     -1, -1, 0, 0 },
551         { "LOOKUP hosts MATCHING "
552           "name =~ name + 1",    -1, -1, 0, 0 },
553         { "LOOKUP hosts MATCHING "
554           "name + 1 =~ 'a'",     -1, -1, 0, 0 },
555         { "LOOKUP hosts MATCHING "
556           "name =~ 1",           -1, -1, 0, 0 },
557         { "LOOKUP hosts MATCHING "
558           "name + 1 IS NULL",    -1, -1, 0, 0 },
559         { "LOOKUP hosts FILTER "
560           "name + 1 IS NULL",    -1, -1, 0, 0 },
561         { "LOOKUP hosts MATCHING "
562           "name + 1 IS TRUE",    -1, -1, 0, 0 },
563         { "LOOKUP hosts FILTER "
564           "name + 1 IS TRUE",    -1, -1, 0, 0 },
565         { "LOOKUP hosts MATCHING "
566           "name + 1 IS FALSE",   -1, -1, 0, 0 },
567         { "LOOKUP hosts FILTER "
568           "name + 1 IS FALSE",   -1, -1, 0, 0 },
570         /* invalid iterators */
571         { "LOOKUP hosts MATCHING "
572           "ANY backend !~ backend",
573                                 -1,  -1, 0, 0 },
574         { "LOOKUP hosts MATCHING "
575           "ANY backend = 1",    -1,  -1, 0, 0 },
576         { "LOOKUP hosts MATCHING "
577           "ANY 'patt' =~ 'p'",  -1,  -1, 0, 0 },
578         { "LOOKUP hosts MATCHING "
579           "ALL 1 || '2' < '3'", -1,  -1, 0, 0 },
580         { "LOOKUP hosts MATCHING "
581           "ALL name =~ 'a'",    -1,  -1, 0, 0 },
582         /* this could work in theory but is not supported atm */
583         { "LOOKUP hosts MATCHING "
584           "ANY backend || 'a' = 'b'",
585                                 -1,  -1, 0, 0 },
586         { "LOOKUP hosts MATCHING ANY "
587           "host.name = 'h'",    -1, -1, 0, 0 },
588         { "LOOKUP services MATCHING ANY "
589           "host.name = 'h'",    -1, -1, 0, 0 },
590         { "LOOKUP metrics MATCHING ANY "
591           "host.name = 'h'",    -1, -1, 0, 0 },
593         /* invalid LIST commands */
594         { "LIST",                -1, -1, 0, 0 },
595         { "LIST foo",            -1, -1, 0, 0 },
596         { "LIST hosts MATCHING "
597           "name = 'host'",       -1, -1, 0, 0 },
598         { "LIST foo FILTER "
599           "age > 60s",           -1, -1, 0, 0 },
601         /* invalid FETCH commands */
602         { "FETCH host 'host' MATCHING "
603           "name = 'host'",       -1, -1, 0, 0 },
604         { "FETCH service 'host'",-1, -1, 0, 0 },
605         { "FETCH metric 'host'", -1, -1, 0, 0 },
606         { "FETCH host "
607           "'host'.'localhost'",  -1, -1, 0, 0 },
608         { "FETCH foo 'host'",    -1, -1, 0, 0 },
609         { "FETCH foo 'host' FILTER "
610           "age > 60s",           -1, -1, 0, 0 },
612         /* invalid LOOKUP commands */
613         { "LOOKUP foo",          -1, -1, 0, 0 },
614         { "LOOKUP foo MATCHING "
615           "name = 'host'",       -1, -1, 0, 0 },
616         { "LOOKUP foo FILTER "
617           "age > 60s",           -1, -1, 0, 0 },
618         { "LOOKUP foo MATCHING "
619           "name = 'host' FILTER "
620           "age > 60s",           -1, -1, 0, 0 },
621         { "LOOKUP hosts MATCHING "
622           "attribute['foo'] <= "
623           "f || 'oo'",           -1, -1, 0, 0 },
624         { "LOOKUP hosts MATCHING "
625           "attribute['foo'] <= "
626           "'f' || oo",           -1, -1, 0, 0 },
627         { "LOOKUP hosts MATCHING "
628           "ANY host.name = 'host'",   -1, -1, 0, 0 },
629         { "LOOKUP hosts MATCHING "
630           "ANY service.name > 1",     -1, -1, 0, 0 },
631         { "LOOKUP hosts MATCHING "
632           "service.name = 's'",       -1, -1, 0, 0 },
633         { "LOOKUP services MATCHING "
634           "ANY host.name = 'host'",   -1, -1, 0, 0 },
635         { "LOOKUP services MATCHING "
636           "ANY service.name = 'svc'", -1, -1, 0, 0 },
637         { "LOOKUP services MATCHING "
638           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
639         { "LOOKUP services MATCHING "
640           "metric.name = 'm'",        -1, -1, 0, 0 },
641         { "LOOKUP metrics MATCHING "
642           "ANY host.name = 'host'",   -1, -1, 0, 0 },
643         { "LOOKUP metrics MATCHING "
644           "ANY service.name = 'svc'", -1, -1, 0, 0 },
645         { "LOOKUP metrics MATCHING "
646           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
647         { "LOOKUP metrics MATCHING "
648           "service.name = 'm'",       -1, -1, 0, 0 },
650         /* invalid STORE commands */
651         { "STORE host "
652           "'obj'.'host'",        -1, -1, 0, 0 },
653         { "STORE host attribute "
654           ".'key' 123",          -1, -1, 0, 0 },
655         { "STORE host attribute "
656           "'o'.'h'.'key' 123",   -1, -1, 0, 0 },
657         { "STORE service 'svc'", -1, -1, 0, 0 },
658         { "STORE service "
659           "'host'.'svc' "
660           "STORE 'typ' 'id' "
661           "LAST UPDATE "
662           "2015-02-01",          -1, -1, 0, 0 },
663         { "STORE service attribute "
664           "'svc'.'key' 123",     -1, -1, 0, 0 },
665         { "STORE metric 'm'",    -1, -1, 0, 0 },
666         { "STORE metric "
667           "'host'.'metric' "
668           "STORE 'typ'.'id' "
669           "LAST UPDATE "
670           "2015-02-01",          -1, -1, 0, 0 },
671         { "STORE metric attribute "
672           "'metric'.'key' 123",  -1, -1, 0, 0 },
673 };
675 START_TEST(test_parse)
677         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
678         sdb_llist_t *check;
679         sdb_ast_node_t *node;
680         sdb_store_query_t *q;
681         _Bool ok;
683         check = sdb_parser_parse(parse_data[_i].query,
684                         parse_data[_i].len, errbuf);
685         if (parse_data[_i].expected < 0)
686                 ok = check == 0;
687         else
688                 ok = sdb_llist_len(check) == (size_t)parse_data[_i].expected;
690         fail_unless(ok, "sdb_parser_parse(%s) = %p (len: %zu); expected: %d "
691                         "(parse error: %s)", parse_data[_i].query, check,
692                         sdb_llist_len(check), parse_data[_i].expected,
693                         sdb_strbuf_string(errbuf));
695         if (! check) {
696                 sdb_strbuf_destroy(errbuf);
697                 return;
698         }
700         if ((! parse_data[_i].expected_type)
701                         || (parse_data[_i].expected <= 0)) {
702                 sdb_llist_destroy(check);
703                 sdb_strbuf_destroy(errbuf);
704                 return;
705         }
707         node = SDB_AST_NODE(sdb_llist_get(check, 0));
708         fail_unless(node->type == parse_data[_i].expected_type,
709                         "sdb_parser_parse(%s)->type = %i; expected: %d",
710                         parse_data[_i].query, node->type,
711                         parse_data[_i].expected_type);
713         if (node->type == SDB_AST_TYPE_FETCH) {
714                 sdb_ast_fetch_t *f = SDB_AST_FETCH(node);
715                 fail_unless(f->obj_type == parse_data[_i].expected_extra,
716                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
717                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(f->obj_type),
718                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
719         }
720         else if (node->type == SDB_AST_TYPE_LIST) {
721                 sdb_ast_list_t *l = SDB_AST_LIST(node);
722                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
723                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
724                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
725                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
726         }
727         else if (node->type == SDB_AST_TYPE_LOOKUP) {
728                 sdb_ast_lookup_t *l = SDB_AST_LOOKUP(node);
729                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
730                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
731                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
732                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
733         }
734         else if (node->type == SDB_AST_TYPE_STORE) {
735                 sdb_ast_store_t *s = SDB_AST_STORE(node);
736                 fail_unless(s->obj_type == parse_data[_i].expected_extra,
737                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
738                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(s->obj_type),
739                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
740         }
742         /* TODO: this should move into front-end specific tests */
743         q = sdb_store_query_prepare(node);
744         fail_unless(q != NULL,
745                         "sdb_store_query_prepare(AST<%s>) = NULL; expected: <query>",
746                         parse_data[_i].query);
748         sdb_object_deref(SDB_OBJ(node));
749         sdb_object_deref(SDB_OBJ(q));
750         sdb_llist_destroy(check);
751         sdb_strbuf_destroy(errbuf);
753 END_TEST
755 struct {
756         int context;
757         const char *expr;
758         int len;
759         int expected;
760 } parse_conditional_data[] = {
761         /* empty expressions */
762         { SDB_HOST, NULL,                           -1, -1 },
763         { SDB_HOST, "",                             -1, -1 },
765         /* match hosts by name */
766         { SDB_HOST, "name < 'localhost'",           -1,  SDB_AST_LT },
767         { SDB_HOST, "name <= 'localhost'",          -1,  SDB_AST_LE },
768         { SDB_HOST, "name = 'localhost'",           -1,  SDB_AST_EQ },
769         { SDB_HOST, "name != 'localhost'",          -1,  SDB_AST_NE },
770         { SDB_HOST, "name >= 'localhost'",          -1,  SDB_AST_GE },
771         { SDB_HOST, "name > 'localhost'",           -1,  SDB_AST_GT },
772         { SDB_HOST, "name =~ 'host'",               -1,  SDB_AST_REGEX },
773         { SDB_HOST, "name !~ 'host'",               -1,  SDB_AST_NREGEX },
774         { SDB_HOST, "name = 'localhost' -- foo",    -1,  SDB_AST_EQ },
775         { SDB_HOST, "name = 'host' <garbage>",      13,  SDB_AST_EQ },
776         { SDB_HOST, "name &^ 'localhost'",          -1,  -1 },
777         /* match by backend */
778         { SDB_HOST, "ANY backend < 'be'",           -1,  SDB_AST_ANY },
779         { SDB_HOST, "ANY backend <= 'be'",          -1,  SDB_AST_ANY },
780         { SDB_HOST, "ANY backend = 'be'",           -1,  SDB_AST_ANY },
781         { SDB_HOST, "ANY backend != 'be'",          -1,  SDB_AST_ANY },
782         { SDB_HOST, "ANY backend >= 'be'",          -1,  SDB_AST_ANY },
783         { SDB_HOST, "ANY backend > 'be'",           -1,  SDB_AST_ANY },
784         { SDB_HOST, "ALL backend < 'be'",           -1,  SDB_AST_ALL },
785         { SDB_HOST, "ALL backend <= 'be'",          -1,  SDB_AST_ALL },
786         { SDB_HOST, "ALL backend = 'be'",           -1,  SDB_AST_ALL },
787         { SDB_HOST, "ALL backend != 'be'",          -1,  SDB_AST_ALL },
788         { SDB_HOST, "ALL backend >= 'be'",          -1,  SDB_AST_ALL },
789         { SDB_HOST, "ALL backend > 'be'",           -1,  SDB_AST_ALL },
790         { SDB_HOST, "ANY backend &^ 'be'",          -1,  -1 },
791         /* match hosts by service */
792         { SDB_HOST, "ANY service.name < 'name'",         -1,  SDB_AST_ANY },
793         { SDB_HOST, "ANY service.name <= 'name'",        -1,  SDB_AST_ANY },
794         { SDB_HOST, "ANY service.name = 'name'",         -1,  SDB_AST_ANY },
795         { SDB_HOST, "ANY service.name != 'name'",        -1,  SDB_AST_ANY },
796         { SDB_HOST, "ANY service.name >= 'name'",        -1,  SDB_AST_ANY },
797         { SDB_HOST, "ANY service.name > 'name'",         -1,  SDB_AST_ANY },
798         { SDB_HOST, "ANY service.name =~ 'pattern'",     -1,  SDB_AST_ANY },
799         { SDB_HOST, "ANY service.name !~ 'pattern'",     -1,  SDB_AST_ANY },
800         { SDB_HOST, "ANY service.name &^ 'name'",        -1,  -1 },
801         { SDB_HOST, "ALL service.name < 'name'",         -1,  SDB_AST_ALL },
802         { SDB_HOST, "ALL service.name <= 'name'",        -1,  SDB_AST_ALL },
803         { SDB_HOST, "ALL service.name = 'name'",         -1,  SDB_AST_ALL },
804         { SDB_HOST, "ALL service.name != 'name'",        -1,  SDB_AST_ALL },
805         { SDB_HOST, "ALL service.name >= 'name'",        -1,  SDB_AST_ALL },
806         { SDB_HOST, "ALL service.name > 'name'",         -1,  SDB_AST_ALL },
807         { SDB_HOST, "ALL service.name =~ 'pattern'",     -1,  SDB_AST_ALL },
808         { SDB_HOST, "ALL service.name !~ 'pattern'",     -1,  SDB_AST_ALL },
809         { SDB_HOST, "ALL service.name &^ 'name'",        -1,  -1 },
810         { SDB_HOST, "ANY service < 'name'",              -1,  -1 },
811         /* match hosts by metric */
812         { SDB_HOST, "ANY metric.name < 'name'",          -1,  SDB_AST_ANY },
813         { SDB_HOST, "ANY metric.name <= 'name'",         -1,  SDB_AST_ANY },
814         { SDB_HOST, "ANY metric.name = 'name'",          -1,  SDB_AST_ANY },
815         { SDB_HOST, "ANY metric.name != 'name'",         -1,  SDB_AST_ANY },
816         { SDB_HOST, "ANY metric.name >= 'name'",         -1,  SDB_AST_ANY },
817         { SDB_HOST, "ANY metric.name > 'name'",          -1,  SDB_AST_ANY },
818         { SDB_HOST, "ANY metric.name =~ 'pattern'",      -1,  SDB_AST_ANY },
819         { SDB_HOST, "ANY metric.name !~ 'pattern'",      -1,  SDB_AST_ANY },
820         { SDB_HOST, "ANY metric.name &^ 'pattern'",      -1,  -1 },
821         { SDB_HOST, "ALL metric.name < 'name'",          -1,  SDB_AST_ALL },
822         { SDB_HOST, "ALL metric.name <= 'name'",         -1,  SDB_AST_ALL },
823         { SDB_HOST, "ALL metric.name = 'name'",          -1,  SDB_AST_ALL },
824         { SDB_HOST, "ALL metric.name != 'name'",         -1,  SDB_AST_ALL },
825         { SDB_HOST, "ALL metric.name >= 'name'",         -1,  SDB_AST_ALL },
826         { SDB_HOST, "ALL metric.name > 'name'",          -1,  SDB_AST_ALL },
827         { SDB_HOST, "ALL metric.name =~ 'pattern'",      -1,  SDB_AST_ALL },
828         { SDB_HOST, "ALL metric.name !~ 'pattern'",      -1,  SDB_AST_ALL },
829         { SDB_HOST, "ALL metric.name &^ 'pattern'",      -1,  -1 },
830         { SDB_HOST, "ANY metric <= 'name'",              -1,  -1 },
831         /* match hosts by attribute */
832         { SDB_HOST, "ANY attribute.name < 'name'",       -1,  SDB_AST_ANY },
833         { SDB_HOST, "ANY attribute.name <= 'name'",      -1,  SDB_AST_ANY },
834         { SDB_HOST, "ANY attribute.name = 'name'",       -1,  SDB_AST_ANY },
835         { SDB_HOST, "ANY attribute.name != 'name'",      -1,  SDB_AST_ANY },
836         { SDB_HOST, "ANY attribute.name >= 'name'",      -1,  SDB_AST_ANY },
837         { SDB_HOST, "ANY attribute.name > 'name'",       -1,  SDB_AST_ANY },
838         { SDB_HOST, "ANY attribute.name =~ 'pattern'",   -1,  SDB_AST_ANY },
839         { SDB_HOST, "ANY attribute.name !~ 'pattern'",   -1,  SDB_AST_ANY },
840         { SDB_HOST, "ANY attribute.name &^ 'pattern'",   -1,  -1 },
841         { SDB_HOST, "ALL attribute.name < 'name'",       -1,  SDB_AST_ALL },
842         { SDB_HOST, "ALL attribute.name <= 'name'",      -1,  SDB_AST_ALL },
843         { SDB_HOST, "ALL attribute.name = 'name'",       -1,  SDB_AST_ALL },
844         { SDB_HOST, "ALL attribute.name != 'name'",      -1,  SDB_AST_ALL },
845         { SDB_HOST, "ALL attribute.name >= 'name'",      -1,  SDB_AST_ALL },
846         { SDB_HOST, "ALL attribute.name > 'name'",       -1,  SDB_AST_ALL },
847         { SDB_HOST, "ALL attribute.name =~ 'pattern'",   -1,  SDB_AST_ALL },
848         { SDB_HOST, "ALL attribute.name !~ 'pattern'",   -1,  SDB_AST_ALL },
849         { SDB_HOST, "ALL attribute.name &^ 'pattern'",   -1,  -1 },
850         { SDB_HOST, "ANY attribute !~ 'pattern'",        -1,  -1 },
852         /* composite expressions */
853         { SDB_HOST, "name =~ 'pattern' AND "
854           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_AND },
855         { SDB_HOST, "name =~ 'pattern' OR "
856           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_OR },
857         { SDB_HOST, "NOT name = 'host'",              -1,  SDB_AST_NOT },
858         /* numeric expressions */
859         { SDB_HOST, "attribute['foo'] < 123",         -1,  SDB_AST_LT },
860         { SDB_HOST, "attribute['foo'] <= 123",        -1,  SDB_AST_LE },
861         { SDB_HOST, "attribute['foo'] = 123",         -1,  SDB_AST_EQ },
862         { SDB_HOST, "attribute['foo'] >= 123",        -1,  SDB_AST_GE },
863         { SDB_HOST, "attribute['foo'] > 123",         -1,  SDB_AST_GT },
864         /* datetime expressions */
865         { SDB_HOST, "attribute['foo'] = "
866           "2014-08-16",                     -1,  SDB_AST_EQ },
867         { SDB_HOST, "attribute['foo'] = "
868           "17:23",                          -1,  SDB_AST_EQ },
869         { SDB_HOST, "attribute['foo'] = "
870           "17:23:53",                       -1,  SDB_AST_EQ },
871         { SDB_HOST, "attribute['foo'] = "
872           "17:23:53.123",                   -1,  SDB_AST_EQ },
873         { SDB_HOST, "attribute['foo'] = "
874           "17:23:53.123456789",             -1,  SDB_AST_EQ },
875         { SDB_HOST, "attribute['foo'] = "
876           "2014-08-16 17:23",               -1,  SDB_AST_EQ },
877         { SDB_HOST, "attribute['foo'] = "
878           "2014-08-16 17:23:53",            -1,  SDB_AST_EQ },
879         /* NULL / TRUE / FALSE */
880         { SDB_HOST, "attribute['foo'] IS NULL",       -1,  SDB_AST_ISNULL },
881         { SDB_HOST, "attribute['foo'] IS NOT NULL",   -1,  SDB_AST_NOT },
882         { SDB_HOST, "attribute['foo'] IS TRUE",       -1,  SDB_AST_ISTRUE },
883         { SDB_HOST, "attribute['foo'] IS NOT TRUE",   -1,  SDB_AST_NOT },
884         { SDB_HOST, "attribute['foo'] IS FALSE",      -1,  SDB_AST_ISFALSE },
885         { SDB_HOST, "attribute['foo'] IS NOT FALSE",  -1,  SDB_AST_NOT },
886         /* array expressions */
887         { SDB_HOST, "backend < ['a']",                -1,  SDB_AST_LT },
888         { SDB_HOST, "backend <= ['a']",               -1,  SDB_AST_LE },
889         { SDB_HOST, "backend = ['a']",                -1,  SDB_AST_EQ },
890         { SDB_HOST, "backend != ['a']",               -1,  SDB_AST_NE },
891         { SDB_HOST, "backend >= ['a']",               -1,  SDB_AST_GE },
892         { SDB_HOST, "backend > ['a']",                -1,  SDB_AST_GT },
893         { SDB_HOST, "backend &^ ['a']",               -1,  -1 },
895         /* object field comparison */
896         { SDB_HOST, "name < 'a'",                     -1,  SDB_AST_LT },
897         { SDB_HOST, "name <= 'a'",                    -1,  SDB_AST_LE },
898         { SDB_HOST, "name = 'a'",                     -1,  SDB_AST_EQ },
899         { SDB_HOST, "name != 'a'",                    -1,  SDB_AST_NE },
900         { SDB_HOST, "name >= 'a'",                    -1,  SDB_AST_GE },
901         { SDB_HOST, "name > 'a'",                     -1,  SDB_AST_GT },
902         { SDB_HOST, "last_update < 2014-10-01",       -1,  SDB_AST_LT },
903         { SDB_HOST, "last_update <= 2014-10-01",      -1,  SDB_AST_LE },
904         { SDB_HOST, "last_update = 2014-10-01",       -1,  SDB_AST_EQ },
905         { SDB_HOST, "last_update != 2014-10-01",      -1,  SDB_AST_NE },
906         { SDB_HOST, "last_update >= 2014-10-01",      -1,  SDB_AST_GE },
907         { SDB_HOST, "last_update > 2014-10-01",       -1,  SDB_AST_GT },
908         { SDB_HOST, "Last_Update >= 24D",             -1,  SDB_AST_GE },
909         { SDB_HOST, "age < 20s",                      -1,  SDB_AST_LT },
910         { SDB_HOST, "age <= 20s",                     -1,  SDB_AST_LE },
911         { SDB_HOST, "age = 20s",                      -1,  SDB_AST_EQ },
912         { SDB_HOST, "age != 20s",                     -1,  SDB_AST_NE },
913         { SDB_HOST, "age >= 20s",                     -1,  SDB_AST_GE },
914         { SDB_HOST, "age > 20s",                      -1,  SDB_AST_GT },
915         { SDB_HOST, "AGE <= 1m",                      -1,  SDB_AST_LE },
916         { SDB_HOST, "age > 1M",                       -1,  SDB_AST_GT },
917         { SDB_HOST, "age != 20Y",                     -1,  SDB_AST_NE },
918         { SDB_HOST, "age <= 2 * interval",            -1,  SDB_AST_LE },
919         { SDB_HOST, "interval < 20s",                 -1,  SDB_AST_LT },
920         { SDB_HOST, "interval <= 20s",                -1,  SDB_AST_LE },
921         { SDB_HOST, "interval = 20s",                 -1,  SDB_AST_EQ },
922         { SDB_HOST, "interval != 20s",                -1,  SDB_AST_NE },
923         { SDB_HOST, "interval >= 20s",                -1,  SDB_AST_GE },
924         { SDB_HOST, "interval > 20s",                 -1,  SDB_AST_GT },
925         { SDB_HOST, "'be' IN backend",                -1,  SDB_AST_IN },
926         { SDB_HOST, "'be' NOT IN backend",            -1,  SDB_AST_NOT },
927         { SDB_HOST, "['a','b'] IN backend",           -1,  SDB_AST_IN },
928         { SDB_HOST, "['a','b'] NOT IN backend",       -1,  SDB_AST_NOT },
929         { SDB_METRIC, "timeseries IS TRUE",           -1,  SDB_AST_ISTRUE },
930         { SDB_METRIC, "timeseries IS FALSE",          -1,  SDB_AST_ISFALSE },
931         { SDB_METRIC, "timeseries IS NOT TRUE",       -1,  SDB_AST_NOT },
932         { SDB_METRIC, "timeseries IS NOT FALSE",      -1,  SDB_AST_NOT },
933         { SDB_METRIC, "timeseries > 0",               -1,  -1 },
934         { SDB_METRIC, "timeseries = TRUE",            -1,  -1 },
935         { SDB_METRIC, "timeseries != FALSE",          -1,  -1 },
937         /* check operator precedence */
938         { SDB_HOST, "name = 'name' OR "
939           "ANY service.name = 'name' AND "
940           "ANY attribute.name = 'name' OR "
941           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
942         { SDB_HOST, "name = 'name' AND "
943           "ANY service.name = 'name' AND "
944           "ANY attribute.name = 'name' OR "
945           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
946         { SDB_HOST, "name = 'name' AND "
947           "ANY service.name = 'name' OR "
948           "ANY attribute.name = 'name' AND "
949           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
950         { SDB_HOST, "(name = 'name' OR "
951           "ANY service.name = 'name') AND "
952           "(ANY attribute.name = 'name' OR "
953           "attribute['foo'] = 'bar')",      -1,  SDB_AST_AND },
954         { SDB_HOST, "NOT name = 'name' OR "
955           "ANY service.name = 'name'",      -1,  SDB_AST_OR },
956         { SDB_HOST, "NOT name = 'name' OR "
957           "NOT ANY service.name = 'name'",  -1,  SDB_AST_OR },
958         { SDB_HOST, "NOT (name = 'name' OR "
959           "NOT ANY service.name = 'name')", -1,  SDB_AST_NOT },
961         /* syntax errors */
962         { SDB_HOST, "LIST hosts",                     -1, -1 },
963         { SDB_HOST, "foo &^ bar",                     -1, -1 },
964         { SDB_HOST, "invalid",                        -1, -1 },
965 };
967 START_TEST(test_parse_conditional)
969         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
970         sdb_ast_node_t *node;
972         node = sdb_parser_parse_conditional(parse_conditional_data[_i].context,
973                         parse_conditional_data[_i].expr, parse_conditional_data[_i].len, errbuf);
975         if (parse_conditional_data[_i].expected < 0) {
976                 fail_unless(node == NULL,
977                                 "sdb_parser_parse_conditional(%s, %s) = %p; expected: NULL",
978                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
979                                 parse_conditional_data[_i].expr, node);
980                 sdb_object_deref(SDB_OBJ(node));
981                 sdb_strbuf_destroy(errbuf);
982                 return;
983         }
985         fail_unless(node != NULL, "sdb_parser_parse_conditional(%s, %s) = NULL; "
986                         "expected: <cond> (parse error: %s)",
987                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
988                         parse_conditional_data[_i].expr, sdb_strbuf_string(errbuf));
989         if (node->type == SDB_AST_TYPE_OPERATOR)
990                 fail_unless(SDB_AST_OP(node)->kind == parse_conditional_data[_i].expected,
991                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
992                                 "expected: %d",
993                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
994                                 parse_conditional_data[_i].expr,
995                                 SDB_AST_OP(node)->kind, parse_conditional_data[_i].expected);
996         else if (node->type == SDB_AST_TYPE_ITERATOR)
997                 fail_unless(SDB_AST_ITER(node)->kind == parse_conditional_data[_i].expected,
998                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
999                                 "expected: %d",
1000                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
1001                                 parse_conditional_data[_i].expr,
1002                                 SDB_AST_ITER(node)->kind, parse_conditional_data[_i].expected);
1004         fail_unless(node->data_type == -1,
1005                         "sdb_parser_parse_conditional(%s, %s) returned conditional "
1006                         "of data-type %s; expected: %s",
1007                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
1008                         parse_conditional_data[_i].expr,
1009                         SDB_TYPE_TO_STRING(node->data_type), SDB_TYPE_TO_STRING(-1));
1011         sdb_object_deref(SDB_OBJ(node));
1012         sdb_strbuf_destroy(errbuf);
1014 END_TEST
1016 struct {
1017         int context;
1018         const char *expr;
1019         int len;
1020         int expected;
1021         int data_type;
1022 } parse_arith_data[] = {
1023         /* empty expressions */
1024         { SDB_HOST, NULL,                   -1, -1, -1 },
1025         { SDB_HOST, "",                     -1, -1, -1 },
1027         /* constant expressions */
1028         { SDB_HOST, "'localhost'",          -1, SDB_AST_TYPE_CONST, SDB_TYPE_STRING },
1029         { SDB_HOST, "123",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_INTEGER },
1030         { SDB_HOST, "42.3",                 -1, SDB_AST_TYPE_CONST, SDB_TYPE_DECIMAL },
1031         { SDB_HOST, "2014-08-16",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1032         { SDB_HOST, "17:23",                -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1033         { SDB_HOST, "17:23:53",             -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1034         { SDB_HOST, "17:23:53.123",         -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1035         { SDB_HOST, "17:23:53.123456789",   -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1036         { SDB_HOST, "2014-08-16 17:23",     -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1037         { SDB_HOST, "2014-08-16 17:23:53",  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1038         { SDB_HOST, "10s",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1039         { SDB_HOST, "60m",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1040         { SDB_HOST, "10Y 24D 1h",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1042         /* TODO: the analyzer and/or optimizer should turn these into constants */
1043         { SDB_HOST, "123 + 456",            -1, SDB_AST_ADD, SDB_TYPE_INTEGER },
1044         { SDB_HOST, "'foo' || 'bar'",       -1, SDB_AST_CONCAT, SDB_TYPE_STRING },
1045         { SDB_HOST, "456 - 123",            -1, SDB_AST_SUB, SDB_TYPE_INTEGER },
1046         { SDB_HOST, "1.2 * 3.4",            -1, SDB_AST_MUL, SDB_TYPE_DECIMAL },
1047         { SDB_HOST, "1.2 / 3.4",            -1, SDB_AST_DIV, SDB_TYPE_DECIMAL },
1048         { SDB_HOST, "5 % 2",                -1, SDB_AST_MOD, SDB_TYPE_INTEGER },
1050         /* queryable fields */
1051         { SDB_HOST, "last_update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1052         { SDB_HOST, "AGE",                  -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1053         { SDB_HOST, "interval",             -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1054         { SDB_HOST, "Last_Update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1055         { SDB_HOST, "backend",              -1, SDB_AST_TYPE_VALUE, SDB_TYPE_ARRAY | SDB_TYPE_STRING },
1057         /* attributes */
1058         { SDB_HOST, "attribute['foo']",     -1, SDB_AST_TYPE_VALUE, -1 },
1060         /* arithmetic expressions */
1061         { SDB_HOST, "age + age",            -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1062         { SDB_HOST, "age - age",            -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1063         { SDB_HOST, "age * age",            -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1064         { SDB_HOST, "age / age",            -1, SDB_AST_DIV, SDB_TYPE_DATETIME },
1065         { SDB_HOST, "age \% age",           -1, SDB_AST_MOD, SDB_TYPE_DATETIME },
1067         /* operator precedence */
1068         { SDB_HOST, "age + age * age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1069         { SDB_HOST, "age * age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1070         { SDB_HOST, "age + age - age",      -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1071         { SDB_HOST, "age - age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1072         { SDB_HOST, "(age + age) * age",    -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1073         { SDB_HOST, "age + (age * age)",    -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1075         /* boolean expressions */
1076         { SDB_METRIC, "timeseries + 1",               -1, -1, -1 },
1077         { SDB_METRIC, "timeseries - 1",               -1, -1, -1 },
1078         { SDB_METRIC, "timeseries * 1",               -1, -1, -1 },
1079         { SDB_METRIC, "timeseries / 1",               -1, -1, -1 },
1080         { SDB_METRIC, "timeseries \% 1",              -1, -1, -1 },
1081         { SDB_METRIC, "timeseries CONCAT 1",          -1, -1, -1 },
1082         { SDB_METRIC, "timeseries + timeseries",      -1, -1, -1 },
1083         { SDB_METRIC, "timeseries - timeseries",      -1, -1, -1 },
1084         { SDB_METRIC, "timeseries * timeseries",      -1, -1, -1 },
1085         { SDB_METRIC, "timeseries / timeseries",      -1, -1, -1 },
1086         { SDB_METRIC, "timeseries \% timeseries",     -1, -1, -1 },
1087         { SDB_METRIC, "timeseries CONCAT timeseries", -1, -1, -1 },
1089         /* syntax errors */
1090         { SDB_HOST, "LIST",                 -1, -1, -1 },
1091         { SDB_HOST, "foo &^ bar",           -1, -1, -1 },
1092         { SDB_HOST, "invalid",              -1, -1, -1 },
1093 };
1095 START_TEST(test_parse_arith)
1097         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
1098         sdb_ast_node_t *node;
1100         node = sdb_parser_parse_arith(parse_arith_data[_i].context,
1101                         parse_arith_data[_i].expr, parse_arith_data[_i].len, errbuf);
1103         if (parse_arith_data[_i].expected < 0) {
1104                 fail_unless(node == NULL,
1105                                 "sdb_parser_parse_arith(%s, %s) = %p; expected: NULL",
1106                                 SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1107                                 parse_arith_data[_i].expr, node);
1108                 sdb_object_deref(SDB_OBJ(node));
1109                 sdb_strbuf_destroy(errbuf);
1110                 return;
1111         }
1113         fail_unless(node != NULL, "sdb_parser_parse_arith(%s, %s) = NULL; "
1114                         "expected: <expr> (parse error: %s)",
1115                         SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1116                         parse_arith_data[_i].expr, sdb_strbuf_string(errbuf));
1117         if (node->type == SDB_AST_TYPE_OPERATOR)
1118                 fail_unless(SDB_AST_OP(node)->kind == parse_arith_data[_i].expected,
1119                                 "sdb_parser_parse_arith(%s, %s) returned expression of type %d; "
1120                                 "expected: %d", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1121                                 parse_arith_data[_i].expr, SDB_AST_OP(node)->kind,
1122                                 parse_arith_data[_i].expected);
1123         else
1124                 fail_unless(node->type == parse_arith_data[_i].expected,
1125                                 "sdb_parser_parse_arith(%s, %s) returned expression of type %d; "
1126                                 "expected: %d", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1127                                 parse_arith_data[_i].expr, node->type,
1128                                 parse_arith_data[_i].expected);
1130         fail_unless(node->data_type == parse_arith_data[_i].data_type,
1131                         "sdb_parser_parse_arith(%s, %s) returned expression of data-type %s; "
1132                         "expected: %s", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1133                         parse_arith_data[_i].expr, SDB_TYPE_TO_STRING(node->data_type),
1134                         SDB_TYPE_TO_STRING(parse_arith_data[_i].data_type));
1136         sdb_object_deref(SDB_OBJ(node));
1137         sdb_strbuf_destroy(errbuf);
1139 END_TEST
1141 TEST_MAIN("parser::parser")
1143         TCase *tc = tcase_create("core");
1144         TC_ADD_LOOP_TEST(tc, parse);
1145         TC_ADD_LOOP_TEST(tc, parse_conditional);
1146         TC_ADD_LOOP_TEST(tc, parse_arith);
1147         ADD_TCASE(tc);
1149 TEST_MAIN_END
1151 /* vim: set tw=78 sw=4 ts=4 noexpandtab : */