Code

parser: Let the TIMESERIES command accept optional data-source names.
[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/memstore.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 "
224           "'host'.'metric' "
225           "STORE 'typ' 'id' 2015-02-01 13:37 "
226           "LAST UPDATE "
227           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
228         { "STORE metric attribute "
229           "'host'.'metric'.'key' "
230           "123",                 -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
231         { "STORE metric attribute "
232           "'host'.'metric'.'key' "
233           "123 "
234           "LAST UPDATE "
235           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
237         /* string constants */
238         { "LOOKUP hosts MATCHING "
239           "name = ''''",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
240         { "LOOKUP hosts MATCHING "
241           "name = '''foo'",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
242         { "LOOKUP hosts MATCHING "
243           "name = 'f''oo'",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
244         { "LOOKUP hosts MATCHING "
245           "name = 'foo'''",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
246         { "LOOKUP hosts MATCHING "
247           "name = '''",          -1, -1, 0, SDB_HOST },
249         /* numeric constants */
250         { "LOOKUP hosts MATCHING "
251           "attribute['foo'] = "
252           "1234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
253         { "LOOKUP hosts MATCHING "
254           "attribute['foo'] != "
255           "+234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
256         { "LOOKUP hosts MATCHING "
257           "attribute['foo'] < "
258           "-234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
259         { "LOOKUP hosts MATCHING "
260           "attribute['foo'] > "
261           "12.4",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
262         { "LOOKUP hosts MATCHING "
263           "attribute['foo'] <= "
264           "12. + .3",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
265         { "LOOKUP hosts MATCHING "
266           "attribute['foo'] <= "
267           "'f' || 'oo'",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
268         { "LOOKUP hosts MATCHING "
269           "attribute['foo'] >= "
270           ".4",                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
271         { "LOOKUP hosts MATCHING "
272           "attribute['foo'] = "
273           "+12e3",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
274         { "LOOKUP hosts MATCHING "
275           "attribute['foo'] = "
276           "+12e-3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
277         { "LOOKUP hosts MATCHING "
278           "attribute['foo'] = "
279           "-12e+3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
281         /* date, time, interval constants */
282         { "LOOKUP hosts MATCHING "
283           "attribute['foo'] = "
284           "1 Y 42D",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
285         { "LOOKUP hosts MATCHING "
286           "attribute['foo'] = "
287           "1s 42D",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
288         /*
289          * TODO: Something like 1Y42D should work as well but it doesn't since
290          * the scanner will tokenize it into {digit}{identifier} :-/
291          *
292         { "LOOKUP hosts MATCHING "
293           "attribute['foo'] = "
294           "1Y42D",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
295          */
297         /* array constants */
298         { "LOOKUP hosts MATCHING "
299           "backend = ['foo']",   -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
300         { "LOOKUP hosts MATCHING "
301           "backend = ['a','b']", -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
303         /* array iteration */
304         { "LOOKUP hosts MATCHING "
305           "'foo' IN backend",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
306         { "LOOKUP hosts MATCHING 'foo' "
307           "NOT IN backend",     -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
308         { "LOOKUP hosts MATCHING "
309           "['foo','bar'] "
310           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
311         /* attribute type is unknown */
312         { "LOOKUP hosts MATCHING "
313           "attribute['backend'] "
314           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
315         { "LOOKUP hosts MATCHING "
316           "ANY backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
317         { "LOOKUP hosts MATCHING "
318           "ANY backend <= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
319         { "LOOKUP hosts MATCHING "
320           "ANY backend = 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
321         { "LOOKUP hosts MATCHING "
322           "ANY backend != 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
323         { "LOOKUP hosts MATCHING "
324           "ANY backend >= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
325         { "LOOKUP hosts MATCHING "
326           "ANY backend > 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
327         { "LOOKUP hosts MATCHING "
328           "ANY backend =~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
329         { "LOOKUP hosts MATCHING "
330           "ANY backend !~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
331         { "LOOKUP hosts MATCHING "
332           "ALL backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
333         { "LOOKUP hosts MATCHING "
334           "ALL backend <= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
335         { "LOOKUP hosts MATCHING "
336           "ALL backend = 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
337         { "LOOKUP hosts MATCHING "
338           "ALL backend != 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
339         { "LOOKUP hosts MATCHING "
340           "ALL backend >= 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
341         { "LOOKUP hosts MATCHING "
342           "ALL backend > 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
343         { "LOOKUP hosts MATCHING "
344           "ALL backend =~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
345         { "LOOKUP hosts MATCHING "
346           "ALL backend !~ 'b'", -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
347         { "LOOKUP hosts MATCHING "
348           "ANY backend || 'a' = 'b'",
349                                 -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
350         /* attribute type is unknown */
351         { "LOOKUP hosts MATCHING "
352           "ANY backend = attribute['backend']",
353                                 -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
355         /* valid operand types */
356         { "LOOKUP hosts MATCHING "
357           "age * 1 > 0s",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
358         { "LOOKUP hosts MATCHING "
359           "age / 1 > 0s",        -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 },
364         { "LOOKUP hosts MATCHING "
365           "name != ''",          -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
366         { "LOOKUP hosts MATCHING "
367           "name = ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
368         { "LOOKUP hosts MATCHING "
369           "name <= ''",          -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
370         { "LOOKUP hosts MATCHING "
371           "name < ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
373         /* typed expressions */
374         { "LOOKUP services MATCHING "
375           "host.attribute['a'] = 'a'",
376                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
377         /* TODO: this should work but the analyzer currently sees ATTRIBUTE
378          * (instead of SERVICE-ATTRIBUTE) as the child type
379         { "LOOKUP services MATCHING "
380           "ANY attribute.service.name = 's'",
381                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
382          */
383         { "LOOKUP hosts MATCHING "
384           "ANY service.service.name = 's'",
385                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
387         /* NULL / TRUE / FALSE */
388         { "LOOKUP hosts MATCHING "
389           "attribute['foo'] "
390           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
391         { "LOOKUP hosts MATCHING "
392           "attribute['foo'] "
393           "IS NOT NULL",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
394         { "LOOKUP hosts MATCHING "
395           "NOT attribute['foo'] "
396           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
397         { "LOOKUP hosts MATCHING "
398           "ANY service.name IS NULL", -1, -1, 0, 0 },
399         { "LOOKUP hosts MATCHING "
400           "attribute['foo'] "
401           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
402         { "LOOKUP hosts MATCHING "
403           "attribute['foo'] "
404           "IS NOT TRUE",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
405         { "LOOKUP hosts MATCHING "
406           "NOT attribute['foo'] "
407           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
408         { "LOOKUP hosts MATCHING "
409           "attribute['foo'] "
410           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
411         { "LOOKUP hosts MATCHING "
412           "attribute['foo'] "
413           "IS NOT FALSE",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
414         { "LOOKUP hosts MATCHING "
415           "NOT attribute['foo'] "
416           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
417         { "LOOKUP metrics MATCHING "
418           "timeseries IS TRUE",  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
420         /* invalid numeric constants */
421         { "LOOKUP hosts MATCHING "
422           "attribute['foo'] = "
423           "+-12e+3",             -1, -1, 0, 0 },
424         { "LOOKUP hosts MATCHING "
425           "attribute['foo'] = "
426           "-12e-+3",             -1, -1, 0, 0 },
427         { "LOOKUP hosts MATCHING "
428           "attribute['foo'] = "
429           "e+3",                 -1, -1, 0, 0 },
430         { "LOOKUP hosts MATCHING "
431           "attribute['foo'] = "
432           "3e",                  -1, -1, 0, 0 },
433         /* following SQL standard, we don't support hex numbers */
434         { "LOOKUP hosts MATCHING "
435           "attribute['foo'] = "
436           "0x12",                -1, -1, 0, 0 },
438         /* invalid expressions */
439         { "LOOKUP hosts MATCHING "
440           "attr['foo'] = 1.23",  -1, -1, 0, 0 },
441         { "LOOKUP hosts MATCHING "
442           "attr['foo'] IS NULL", -1, -1, 0, 0 },
444         /* comments */
445         { "/* some comment */",  -1,  0, 0, 0 },
446         { "-- another comment",  -1,  0, 0, 0 },
448         /* syntax errors */
449         { "INVALID",             -1, -1, 0, 0 },
450         { "FETCH host",          -1, -1, 0, 0 },
451         { "FETCH 'host'",        -1, -1, 0, 0 },
452         { "LIST hosts; INVALID", -1, -1, 0, 0 },
453         { "/* some incomplete",  -1, -1, 0, 0 },
455         /*
456          * syntactically correct but semantically invalid commands
457          */
459         /* invalid fields */
460         { "LIST hosts FILTER "
461           "field = 'a'",           -1, -1, 0, 0 },
462         { "LIST services FILTER "
463           "field = 'a'",           -1, -1, 0, 0 },
464         { "LIST metrics FILTER "
465           "field = 'a'",           -1, -1, 0, 0 },
466         { "LIST hosts FILTER "
467           "value = 'a'",           -1, -1, 0, 0 },
468         { "LIST services FILTER "
469           "value = 'a'",           -1, -1, 0, 0 },
470         { "LIST metrics FILTER "
471           "value = 'a'",           -1, -1, 0, 0 },
472         { "LIST metrics FILTER "
473           "name.1 = 'a'",          -1, -1, 0, 0 },
474         { "LIST hosts FILTER "
475           "timeseries IS TRUE",    -1, -1, 0, 0 },
476         { "LIST services FILTER "
477           "timeseries IS TRUE",    -1, -1, 0, 0 },
479         /* type mismatches */
480         { "LOOKUP hosts MATCHING "
481           "attribute['foo'] = "
482           "1.23 + 'foo'",       -1,  -1, 0, 0 },
483         { "LOOKUP hosts MATCHING "
484           "1 IN backend ",      -1,  -1, 0, 0 },
485         { "LOOKUP hosts MATCHING "
486           "1 NOT IN backend ",  -1,  -1, 0, 0 },
487         { "LOOKUP hosts MATCHING "
488           "age > 0",             -1, -1, 0, 0 },
489         { "LOOKUP hosts MATCHING "
490           "NOT age > 0",         -1, -1, 0, 0 },
491         { "LOOKUP hosts MATCHING "
492           "age >= 0",            -1, -1, 0, 0 },
493         { "LOOKUP hosts MATCHING "
494           "age = 0",             -1, -1, 0, 0 },
495         { "LOOKUP hosts MATCHING "
496           "age != 0",            -1, -1, 0, 0 },
497         { "LOOKUP hosts MATCHING "
498           "age <= 0",            -1, -1, 0, 0 },
499         { "LOOKUP hosts MATCHING "
500           "age < 0",             -1, -1, 0, 0 },
501         { "LOOKUP hosts MATCHING "
502           "age + 1 > 0s",        -1, -1, 0, 0 },
503         { "LOOKUP hosts MATCHING "
504           "age - 1 > 0s",        -1, -1, 0, 0 },
506         /* datetime <mul/div> integer is allowed */
507         { "LOOKUP hosts MATCHING "
508           "age || 1 > 0s",       -1, -1, 0, 0 },
509         { "LOOKUP hosts MATCHING "
510           "name + 1 = ''",       -1, -1, 0, 0 },
511         { "LOOKUP hosts MATCHING "
512           "name - 1 = ''",       -1, -1, 0, 0 },
513         { "LOOKUP hosts MATCHING "
514           "name * 1 = ''",       -1, -1, 0, 0 },
515         { "LOOKUP hosts MATCHING "
516           "name / 1 = ''",       -1, -1, 0, 0 },
517         { "LOOKUP hosts MATCHING "
518           "name % 1 = ''",       -1, -1, 0, 0 },
519         { "LOOKUP hosts MATCHING "
520           "(name % 1) + 1 = ''", -1, -1, 0, 0 },
521         { "LOOKUP hosts MATCHING "
522           "1 + (name % 1) = ''", -1, -1, 0, 0 },
523         { "LOOKUP hosts MATCHING "
524           "'' = 1 + (name % 1)", -1, -1, 0, 0 },
525         { "LOOKUP hosts MATCHING "
526           "age > 0 AND "
527           "age = 0s",            -1, -1, 0, 0 },
528         { "LOOKUP hosts MATCHING "
529           "age = 0s AND "
530           "age > 0",             -1, -1, 0, 0 },
531         { "LOOKUP services MATCHING "
532           "host.name > 0",       -1, -1, 0, 0 },
533         { "LOOKUP services MATCHING "
534           "backend > 'b'",       -1, -1, 0, 0 },
535         { "LOOKUP services MATCHING "
536           "'b' > backend",       -1, -1, 0, 0 },
537         { "LOOKUP services MATCHING "
538           "attribute['a'] > backend",
539                                  -1, -1, 0, 0 },
540         { "LOOKUP services MATCHING "
541           "backend > attribute['a']",
542                                  -1, -1, 0, 0 },
543         { "LOOKUP services MATCHING "
544           "host.name + 1 = ''",  -1, -1, 0, 0 },
545         { "LOOKUP hosts MATCHING "
546           "'a' + 1 IN 'b'",      -1, -1, 0, 0 },
547         { "LOOKUP hosts MATCHING "
548           "'a' IN 'b' - 1",      -1, -1, 0, 0 },
549         { "LOOKUP hosts MATCHING "
550           "name + 1 IN 'b'",     -1, -1, 0, 0 },
551         { "LOOKUP hosts MATCHING "
552           "'a' IN name - 1",     -1, -1, 0, 0 },
553         { "LOOKUP hosts MATCHING "
554           "'b' IN 'abc'",        -1, -1, 0, 0 },
555         { "LOOKUP hosts MATCHING "
556           "1 IN age",            -1, -1, 0, 0 },
557         { "LOOKUP hosts MATCHING "
558           "name =~ 'a' + 1",     -1, -1, 0, 0 },
559         { "LOOKUP hosts MATCHING "
560           "name =~ name + 1",    -1, -1, 0, 0 },
561         { "LOOKUP hosts MATCHING "
562           "name + 1 =~ 'a'",     -1, -1, 0, 0 },
563         { "LOOKUP hosts MATCHING "
564           "name =~ 1",           -1, -1, 0, 0 },
565         { "LOOKUP hosts MATCHING "
566           "name + 1 IS NULL",    -1, -1, 0, 0 },
567         { "LOOKUP hosts FILTER "
568           "name + 1 IS NULL",    -1, -1, 0, 0 },
569         { "LOOKUP hosts MATCHING "
570           "name + 1 IS TRUE",    -1, -1, 0, 0 },
571         { "LOOKUP hosts FILTER "
572           "name + 1 IS TRUE",    -1, -1, 0, 0 },
573         { "LOOKUP hosts MATCHING "
574           "name + 1 IS FALSE",   -1, -1, 0, 0 },
575         { "LOOKUP hosts FILTER "
576           "name + 1 IS FALSE",   -1, -1, 0, 0 },
578         /* invalid iterators */
579         { "LOOKUP hosts MATCHING "
580           "ANY backend !~ backend",
581                                 -1,  -1, 0, 0 },
582         { "LOOKUP hosts MATCHING "
583           "ANY backend = 1",    -1,  -1, 0, 0 },
584         { "LOOKUP hosts MATCHING "
585           "ANY 'patt' =~ 'p'",  -1,  -1, 0, 0 },
586         { "LOOKUP hosts MATCHING "
587           "ALL 1 || '2' < '3'", -1,  -1, 0, 0 },
588         { "LOOKUP hosts MATCHING "
589           "ALL name =~ 'a'",    -1,  -1, 0, 0 },
590         { "LOOKUP hosts MATCHING ANY "
591           "host.name = 'h'",    -1, -1, 0, 0 },
592         { "LOOKUP services MATCHING ANY "
593           "host.name = 'h'",    -1, -1, 0, 0 },
594         { "LOOKUP metrics MATCHING ANY "
595           "host.name = 'h'",    -1, -1, 0, 0 },
596         { "LOOKUP hosts MATCHING ANY "
597           "name || 'a' = 'b'",  -1, -1, 0, 0 },
599         /* invalid LIST commands */
600         { "LIST",                -1, -1, 0, 0 },
601         { "LIST foo",            -1, -1, 0, 0 },
602         { "LIST hosts MATCHING "
603           "name = 'host'",       -1, -1, 0, 0 },
604         { "LIST foo FILTER "
605           "age > 60s",           -1, -1, 0, 0 },
607         /* invalid FETCH commands */
608         { "FETCH host 'host' MATCHING "
609           "name = 'host'",       -1, -1, 0, 0 },
610         { "FETCH service 'host'",-1, -1, 0, 0 },
611         { "FETCH metric 'host'", -1, -1, 0, 0 },
612         { "FETCH host "
613           "'host'.'localhost'",  -1, -1, 0, 0 },
614         { "FETCH foo 'host'",    -1, -1, 0, 0 },
615         { "FETCH foo 'host' FILTER "
616           "age > 60s",           -1, -1, 0, 0 },
618         /* invalid LOOKUP commands */
619         { "LOOKUP foo",          -1, -1, 0, 0 },
620         { "LOOKUP foo MATCHING "
621           "name = 'host'",       -1, -1, 0, 0 },
622         { "LOOKUP foo FILTER "
623           "age > 60s",           -1, -1, 0, 0 },
624         { "LOOKUP foo MATCHING "
625           "name = 'host' FILTER "
626           "age > 60s",           -1, -1, 0, 0 },
627         { "LOOKUP hosts MATCHING "
628           "attribute['foo'] <= "
629           "f || 'oo'",           -1, -1, 0, 0 },
630         { "LOOKUP hosts MATCHING "
631           "attribute['foo'] <= "
632           "'f' || oo",           -1, -1, 0, 0 },
633         { "LOOKUP hosts MATCHING "
634           "ANY host.name = 'host'",   -1, -1, 0, 0 },
635         { "LOOKUP hosts MATCHING "
636           "ANY service.name > 1",     -1, -1, 0, 0 },
637         { "LOOKUP hosts MATCHING "
638           "service.name = 's'",       -1, -1, 0, 0 },
639         { "LOOKUP services MATCHING "
640           "ANY host.name = 'host'",   -1, -1, 0, 0 },
641         { "LOOKUP services MATCHING "
642           "ANY service.name = 'svc'", -1, -1, 0, 0 },
643         { "LOOKUP services MATCHING "
644           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
645         { "LOOKUP services MATCHING "
646           "metric.name = 'm'",        -1, -1, 0, 0 },
647         { "LOOKUP metrics MATCHING "
648           "ANY host.name = 'host'",   -1, -1, 0, 0 },
649         { "LOOKUP metrics MATCHING "
650           "ANY service.name = 'svc'", -1, -1, 0, 0 },
651         { "LOOKUP metrics MATCHING "
652           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
653         { "LOOKUP metrics MATCHING "
654           "service.name = 'm'",       -1, -1, 0, 0 },
656         /* invalid STORE commands */
657         { "STORE host "
658           "'obj'.'host'",        -1, -1, 0, 0 },
659         { "STORE host attribute "
660           ".'key' 123",          -1, -1, 0, 0 },
661         { "STORE host attribute "
662           "'o'.'h'.'key' 123",   -1, -1, 0, 0 },
663         { "STORE service 'svc'", -1, -1, 0, 0 },
664         { "STORE service "
665           "'host'.'svc' "
666           "STORE 'typ' 'id' "
667           "LAST UPDATE "
668           "2015-02-01",          -1, -1, 0, 0 },
669         { "STORE service attribute "
670           "'svc'.'key' 123",     -1, -1, 0, 0 },
671         { "STORE metric 'm'",    -1, -1, 0, 0 },
672         { "STORE metric "
673           "'host'.'metric' "
674           "STORE 'typ'.'id' "
675           "LAST UPDATE "
676           "2015-02-01",          -1, -1, 0, 0 },
677         { "STORE metric attribute "
678           "'metric'.'key' 123",  -1, -1, 0, 0 },
679 };
681 START_TEST(test_parse)
683         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
684         sdb_llist_t *check;
685         sdb_ast_node_t *node;
686         sdb_memstore_query_t *q;
687         _Bool ok;
689         check = sdb_parser_parse(parse_data[_i].query,
690                         parse_data[_i].len, errbuf);
691         if (parse_data[_i].expected < 0)
692                 ok = check == 0;
693         else
694                 ok = sdb_llist_len(check) == (size_t)parse_data[_i].expected;
696         fail_unless(ok, "sdb_parser_parse(%s) = %p (len: %zu); expected: %d "
697                         "(parse error: %s)", parse_data[_i].query, check,
698                         sdb_llist_len(check), parse_data[_i].expected,
699                         sdb_strbuf_string(errbuf));
701         if (! check) {
702                 sdb_strbuf_destroy(errbuf);
703                 return;
704         }
706         if ((! parse_data[_i].expected_type)
707                         || (parse_data[_i].expected <= 0)) {
708                 sdb_llist_destroy(check);
709                 sdb_strbuf_destroy(errbuf);
710                 return;
711         }
713         node = SDB_AST_NODE(sdb_llist_get(check, 0));
714         fail_unless(node->type == parse_data[_i].expected_type,
715                         "sdb_parser_parse(%s)->type = %i; expected: %d",
716                         parse_data[_i].query, node->type,
717                         parse_data[_i].expected_type);
719         if (node->type == SDB_AST_TYPE_FETCH) {
720                 sdb_ast_fetch_t *f = SDB_AST_FETCH(node);
721                 fail_unless(f->obj_type == parse_data[_i].expected_extra,
722                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
723                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(f->obj_type),
724                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
725         }
726         else if (node->type == SDB_AST_TYPE_LIST) {
727                 sdb_ast_list_t *l = SDB_AST_LIST(node);
728                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
729                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
730                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
731                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
732         }
733         else if (node->type == SDB_AST_TYPE_LOOKUP) {
734                 sdb_ast_lookup_t *l = SDB_AST_LOOKUP(node);
735                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
736                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
737                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
738                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
739         }
740         else if (node->type == SDB_AST_TYPE_STORE) {
741                 sdb_ast_store_t *s = SDB_AST_STORE(node);
742                 fail_unless(s->obj_type == parse_data[_i].expected_extra,
743                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
744                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(s->obj_type),
745                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
746         }
748         /* TODO: this should move into front-end specific tests */
749         q = sdb_memstore_query_prepare(node);
750         fail_unless(q != NULL,
751                         "sdb_memstore_query_prepare(AST<%s>) = NULL; expected: <query>",
752                         parse_data[_i].query);
754         sdb_object_deref(SDB_OBJ(node));
755         sdb_object_deref(SDB_OBJ(q));
756         sdb_llist_destroy(check);
757         sdb_strbuf_destroy(errbuf);
759 END_TEST
761 struct {
762         int context;
763         const char *expr;
764         int len;
765         int expected;
766 } parse_conditional_data[] = {
767         /* empty expressions */
768         { SDB_HOST, NULL,                           -1, -1 },
769         { SDB_HOST, "",                             -1, -1 },
771         /* match hosts by name */
772         { SDB_HOST, "name < 'localhost'",           -1,  SDB_AST_LT },
773         { SDB_HOST, "name <= 'localhost'",          -1,  SDB_AST_LE },
774         { SDB_HOST, "name = 'localhost'",           -1,  SDB_AST_EQ },
775         { SDB_HOST, "name != 'localhost'",          -1,  SDB_AST_NE },
776         { SDB_HOST, "name >= 'localhost'",          -1,  SDB_AST_GE },
777         { SDB_HOST, "name > 'localhost'",           -1,  SDB_AST_GT },
778         { SDB_HOST, "name =~ 'host'",               -1,  SDB_AST_REGEX },
779         { SDB_HOST, "name !~ 'host'",               -1,  SDB_AST_NREGEX },
780         { SDB_HOST, "name = 'localhost' -- foo",    -1,  SDB_AST_EQ },
781         { SDB_HOST, "name = 'host' <garbage>",      13,  SDB_AST_EQ },
782         { SDB_HOST, "name &^ 'localhost'",          -1,  -1 },
783         /* match by backend */
784         { SDB_HOST, "ANY backend < 'be'",           -1,  SDB_AST_ANY },
785         { SDB_HOST, "ANY backend <= 'be'",          -1,  SDB_AST_ANY },
786         { SDB_HOST, "ANY backend = 'be'",           -1,  SDB_AST_ANY },
787         { SDB_HOST, "ANY backend != 'be'",          -1,  SDB_AST_ANY },
788         { SDB_HOST, "ANY backend >= 'be'",          -1,  SDB_AST_ANY },
789         { SDB_HOST, "ANY backend > 'be'",           -1,  SDB_AST_ANY },
790         { SDB_HOST, "ALL backend < 'be'",           -1,  SDB_AST_ALL },
791         { SDB_HOST, "ALL backend <= 'be'",          -1,  SDB_AST_ALL },
792         { SDB_HOST, "ALL backend = 'be'",           -1,  SDB_AST_ALL },
793         { SDB_HOST, "ALL backend != 'be'",          -1,  SDB_AST_ALL },
794         { SDB_HOST, "ALL backend >= 'be'",          -1,  SDB_AST_ALL },
795         { SDB_HOST, "ALL backend > 'be'",           -1,  SDB_AST_ALL },
796         { SDB_HOST, "ANY backend &^ 'be'",          -1,  -1 },
797         /* match hosts by service */
798         { SDB_HOST, "ANY service.name < 'name'",         -1,  SDB_AST_ANY },
799         { SDB_HOST, "ANY service.name <= 'name'",        -1,  SDB_AST_ANY },
800         { SDB_HOST, "ANY service.name = 'name'",         -1,  SDB_AST_ANY },
801         { SDB_HOST, "ANY service.name != 'name'",        -1,  SDB_AST_ANY },
802         { SDB_HOST, "ANY service.name >= 'name'",        -1,  SDB_AST_ANY },
803         { SDB_HOST, "ANY service.name > 'name'",         -1,  SDB_AST_ANY },
804         { SDB_HOST, "ANY service.name =~ 'pattern'",     -1,  SDB_AST_ANY },
805         { SDB_HOST, "ANY service.name !~ 'pattern'",     -1,  SDB_AST_ANY },
806         { SDB_HOST, "ANY service.name &^ 'name'",        -1,  -1 },
807         { SDB_HOST, "ALL service.name < 'name'",         -1,  SDB_AST_ALL },
808         { SDB_HOST, "ALL service.name <= 'name'",        -1,  SDB_AST_ALL },
809         { SDB_HOST, "ALL service.name = 'name'",         -1,  SDB_AST_ALL },
810         { SDB_HOST, "ALL service.name != 'name'",        -1,  SDB_AST_ALL },
811         { SDB_HOST, "ALL service.name >= 'name'",        -1,  SDB_AST_ALL },
812         { SDB_HOST, "ALL service.name > 'name'",         -1,  SDB_AST_ALL },
813         { SDB_HOST, "ALL service.name =~ 'pattern'",     -1,  SDB_AST_ALL },
814         { SDB_HOST, "ALL service.name !~ 'pattern'",     -1,  SDB_AST_ALL },
815         { SDB_HOST, "ALL service.name &^ 'name'",        -1,  -1 },
816         { SDB_HOST, "ANY service < 'name'",              -1,  -1 },
817         /* match hosts by metric */
818         { SDB_HOST, "ANY metric.name < 'name'",          -1,  SDB_AST_ANY },
819         { SDB_HOST, "ANY metric.name <= 'name'",         -1,  SDB_AST_ANY },
820         { SDB_HOST, "ANY metric.name = 'name'",          -1,  SDB_AST_ANY },
821         { SDB_HOST, "ANY metric.name != 'name'",         -1,  SDB_AST_ANY },
822         { SDB_HOST, "ANY metric.name >= 'name'",         -1,  SDB_AST_ANY },
823         { SDB_HOST, "ANY metric.name > 'name'",          -1,  SDB_AST_ANY },
824         { SDB_HOST, "ANY metric.name =~ 'pattern'",      -1,  SDB_AST_ANY },
825         { SDB_HOST, "ANY metric.name !~ 'pattern'",      -1,  SDB_AST_ANY },
826         { SDB_HOST, "ANY metric.name &^ 'pattern'",      -1,  -1 },
827         { SDB_HOST, "ALL metric.name < 'name'",          -1,  SDB_AST_ALL },
828         { SDB_HOST, "ALL metric.name <= 'name'",         -1,  SDB_AST_ALL },
829         { SDB_HOST, "ALL metric.name = 'name'",          -1,  SDB_AST_ALL },
830         { SDB_HOST, "ALL metric.name != 'name'",         -1,  SDB_AST_ALL },
831         { SDB_HOST, "ALL metric.name >= 'name'",         -1,  SDB_AST_ALL },
832         { SDB_HOST, "ALL metric.name > 'name'",          -1,  SDB_AST_ALL },
833         { SDB_HOST, "ALL metric.name =~ 'pattern'",      -1,  SDB_AST_ALL },
834         { SDB_HOST, "ALL metric.name !~ 'pattern'",      -1,  SDB_AST_ALL },
835         { SDB_HOST, "ALL metric.name &^ 'pattern'",      -1,  -1 },
836         { SDB_HOST, "ANY metric <= 'name'",              -1,  -1 },
837         /* match hosts by attribute */
838         { SDB_HOST, "ANY attribute.name < 'name'",       -1,  SDB_AST_ANY },
839         { SDB_HOST, "ANY attribute.name <= 'name'",      -1,  SDB_AST_ANY },
840         { SDB_HOST, "ANY attribute.name = 'name'",       -1,  SDB_AST_ANY },
841         { SDB_HOST, "ANY attribute.name != 'name'",      -1,  SDB_AST_ANY },
842         { SDB_HOST, "ANY attribute.name >= 'name'",      -1,  SDB_AST_ANY },
843         { SDB_HOST, "ANY attribute.name > 'name'",       -1,  SDB_AST_ANY },
844         { SDB_HOST, "ANY attribute.name =~ 'pattern'",   -1,  SDB_AST_ANY },
845         { SDB_HOST, "ANY attribute.name !~ 'pattern'",   -1,  SDB_AST_ANY },
846         { SDB_HOST, "ANY attribute.name &^ 'pattern'",   -1,  -1 },
847         { SDB_HOST, "ALL attribute.name < 'name'",       -1,  SDB_AST_ALL },
848         { SDB_HOST, "ALL attribute.name <= 'name'",      -1,  SDB_AST_ALL },
849         { SDB_HOST, "ALL attribute.name = 'name'",       -1,  SDB_AST_ALL },
850         { SDB_HOST, "ALL attribute.name != 'name'",      -1,  SDB_AST_ALL },
851         { SDB_HOST, "ALL attribute.name >= 'name'",      -1,  SDB_AST_ALL },
852         { SDB_HOST, "ALL attribute.name > 'name'",       -1,  SDB_AST_ALL },
853         { SDB_HOST, "ALL attribute.name =~ 'pattern'",   -1,  SDB_AST_ALL },
854         { SDB_HOST, "ALL attribute.name !~ 'pattern'",   -1,  SDB_AST_ALL },
855         { SDB_HOST, "ALL attribute.name &^ 'pattern'",   -1,  -1 },
856         { SDB_HOST, "ANY attribute !~ 'pattern'",        -1,  -1 },
858         /* composite expressions */
859         { SDB_HOST, "name =~ 'pattern' AND "
860           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_AND },
861         { SDB_HOST, "name =~ 'pattern' OR "
862           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_OR },
863         { SDB_HOST, "NOT name = 'host'",              -1,  SDB_AST_NOT },
864         /* numeric expressions */
865         { SDB_HOST, "attribute['foo'] < 123",         -1,  SDB_AST_LT },
866         { SDB_HOST, "attribute['foo'] <= 123",        -1,  SDB_AST_LE },
867         { SDB_HOST, "attribute['foo'] = 123",         -1,  SDB_AST_EQ },
868         { SDB_HOST, "attribute['foo'] >= 123",        -1,  SDB_AST_GE },
869         { SDB_HOST, "attribute['foo'] > 123",         -1,  SDB_AST_GT },
870         /* datetime expressions */
871         { SDB_HOST, "attribute['foo'] = "
872           "2014-08-16",                     -1,  SDB_AST_EQ },
873         { SDB_HOST, "attribute['foo'] = "
874           "17:23",                          -1,  SDB_AST_EQ },
875         { SDB_HOST, "attribute['foo'] = "
876           "17:23:53",                       -1,  SDB_AST_EQ },
877         { SDB_HOST, "attribute['foo'] = "
878           "17:23:53.123",                   -1,  SDB_AST_EQ },
879         { SDB_HOST, "attribute['foo'] = "
880           "17:23:53.123456789",             -1,  SDB_AST_EQ },
881         { SDB_HOST, "attribute['foo'] = "
882           "2014-08-16 17:23",               -1,  SDB_AST_EQ },
883         { SDB_HOST, "attribute['foo'] = "
884           "2014-08-16 17:23:53",            -1,  SDB_AST_EQ },
885         /* NULL / TRUE / FALSE */
886         { SDB_HOST, "attribute['foo'] IS NULL",       -1,  SDB_AST_ISNULL },
887         { SDB_HOST, "attribute['foo'] IS NOT NULL",   -1,  SDB_AST_NOT },
888         { SDB_HOST, "attribute['foo'] IS TRUE",       -1,  SDB_AST_ISTRUE },
889         { SDB_HOST, "attribute['foo'] IS NOT TRUE",   -1,  SDB_AST_NOT },
890         { SDB_HOST, "attribute['foo'] IS FALSE",      -1,  SDB_AST_ISFALSE },
891         { SDB_HOST, "attribute['foo'] IS NOT FALSE",  -1,  SDB_AST_NOT },
892         /* array expressions */
893         { SDB_HOST, "backend < ['a']",                -1,  SDB_AST_LT },
894         { SDB_HOST, "backend <= ['a']",               -1,  SDB_AST_LE },
895         { SDB_HOST, "backend = ['a']",                -1,  SDB_AST_EQ },
896         { SDB_HOST, "backend != ['a']",               -1,  SDB_AST_NE },
897         { SDB_HOST, "backend >= ['a']",               -1,  SDB_AST_GE },
898         { SDB_HOST, "backend > ['a']",                -1,  SDB_AST_GT },
899         { SDB_HOST, "backend &^ ['a']",               -1,  -1 },
901         /* object field comparison */
902         { SDB_HOST, "name < 'a'",                     -1,  SDB_AST_LT },
903         { SDB_HOST, "name <= 'a'",                    -1,  SDB_AST_LE },
904         { SDB_HOST, "name = 'a'",                     -1,  SDB_AST_EQ },
905         { SDB_HOST, "name != 'a'",                    -1,  SDB_AST_NE },
906         { SDB_HOST, "name >= 'a'",                    -1,  SDB_AST_GE },
907         { SDB_HOST, "name > 'a'",                     -1,  SDB_AST_GT },
908         { SDB_HOST, "last_update < 2014-10-01",       -1,  SDB_AST_LT },
909         { SDB_HOST, "last_update <= 2014-10-01",      -1,  SDB_AST_LE },
910         { SDB_HOST, "last_update = 2014-10-01",       -1,  SDB_AST_EQ },
911         { SDB_HOST, "last_update != 2014-10-01",      -1,  SDB_AST_NE },
912         { SDB_HOST, "last_update >= 2014-10-01",      -1,  SDB_AST_GE },
913         { SDB_HOST, "last_update > 2014-10-01",       -1,  SDB_AST_GT },
914         { SDB_HOST, "Last_Update >= 24D",             -1,  SDB_AST_GE },
915         { SDB_HOST, "age < 20s",                      -1,  SDB_AST_LT },
916         { SDB_HOST, "age <= 20s",                     -1,  SDB_AST_LE },
917         { SDB_HOST, "age = 20s",                      -1,  SDB_AST_EQ },
918         { SDB_HOST, "age != 20s",                     -1,  SDB_AST_NE },
919         { SDB_HOST, "age >= 20s",                     -1,  SDB_AST_GE },
920         { SDB_HOST, "age > 20s",                      -1,  SDB_AST_GT },
921         { SDB_HOST, "AGE <= 1m",                      -1,  SDB_AST_LE },
922         { SDB_HOST, "age > 1M",                       -1,  SDB_AST_GT },
923         { SDB_HOST, "age != 20Y",                     -1,  SDB_AST_NE },
924         { SDB_HOST, "age <= 2 * interval",            -1,  SDB_AST_LE },
925         { SDB_HOST, "interval < 20s",                 -1,  SDB_AST_LT },
926         { SDB_HOST, "interval <= 20s",                -1,  SDB_AST_LE },
927         { SDB_HOST, "interval = 20s",                 -1,  SDB_AST_EQ },
928         { SDB_HOST, "interval != 20s",                -1,  SDB_AST_NE },
929         { SDB_HOST, "interval >= 20s",                -1,  SDB_AST_GE },
930         { SDB_HOST, "interval > 20s",                 -1,  SDB_AST_GT },
931         { SDB_HOST, "'be' IN backend",                -1,  SDB_AST_IN },
932         { SDB_HOST, "'be' NOT IN backend",            -1,  SDB_AST_NOT },
933         { SDB_HOST, "['a','b'] IN backend",           -1,  SDB_AST_IN },
934         { SDB_HOST, "['a','b'] NOT IN backend",       -1,  SDB_AST_NOT },
935         { SDB_METRIC, "timeseries IS TRUE",           -1,  SDB_AST_ISTRUE },
936         { SDB_METRIC, "timeseries IS FALSE",          -1,  SDB_AST_ISFALSE },
937         { SDB_METRIC, "timeseries IS NOT TRUE",       -1,  SDB_AST_NOT },
938         { SDB_METRIC, "timeseries IS NOT FALSE",      -1,  SDB_AST_NOT },
939         { SDB_METRIC, "timeseries > 0",               -1,  -1 },
940         { SDB_METRIC, "timeseries = TRUE",            -1,  -1 },
941         { SDB_METRIC, "timeseries != FALSE",          -1,  -1 },
943         /* check operator precedence */
944         { SDB_HOST, "name = 'name' OR "
945           "ANY service.name = 'name' AND "
946           "ANY attribute.name = 'name' OR "
947           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
948         { SDB_HOST, "name = 'name' AND "
949           "ANY service.name = 'name' AND "
950           "ANY attribute.name = 'name' OR "
951           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
952         { SDB_HOST, "name = 'name' AND "
953           "ANY service.name = 'name' OR "
954           "ANY attribute.name = 'name' AND "
955           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
956         { SDB_HOST, "(name = 'name' OR "
957           "ANY service.name = 'name') AND "
958           "(ANY attribute.name = 'name' OR "
959           "attribute['foo'] = 'bar')",      -1,  SDB_AST_AND },
960         { SDB_HOST, "NOT name = 'name' OR "
961           "ANY service.name = 'name'",      -1,  SDB_AST_OR },
962         { SDB_HOST, "NOT name = 'name' OR "
963           "NOT ANY service.name = 'name'",  -1,  SDB_AST_OR },
964         { SDB_HOST, "NOT (name = 'name' OR "
965           "NOT ANY service.name = 'name')", -1,  SDB_AST_NOT },
967         /* syntax errors */
968         { SDB_HOST, "LIST hosts",                     -1, -1 },
969         { SDB_HOST, "foo &^ bar",                     -1, -1 },
970         { SDB_HOST, "invalid",                        -1, -1 },
971 };
973 START_TEST(test_parse_conditional)
975         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
976         sdb_ast_node_t *node;
978         node = sdb_parser_parse_conditional(parse_conditional_data[_i].context,
979                         parse_conditional_data[_i].expr, parse_conditional_data[_i].len, errbuf);
981         if (parse_conditional_data[_i].expected < 0) {
982                 fail_unless(node == NULL,
983                                 "sdb_parser_parse_conditional(%s, %s) = %p; expected: NULL",
984                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
985                                 parse_conditional_data[_i].expr, node);
986                 sdb_object_deref(SDB_OBJ(node));
987                 sdb_strbuf_destroy(errbuf);
988                 return;
989         }
991         fail_unless(node != NULL, "sdb_parser_parse_conditional(%s, %s) = NULL; "
992                         "expected: <cond> (parse error: %s)",
993                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
994                         parse_conditional_data[_i].expr, sdb_strbuf_string(errbuf));
995         if (node->type == SDB_AST_TYPE_OPERATOR)
996                 fail_unless(SDB_AST_OP(node)->kind == parse_conditional_data[_i].expected,
997                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
998                                 "expected: %d",
999                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
1000                                 parse_conditional_data[_i].expr,
1001                                 SDB_AST_OP(node)->kind, parse_conditional_data[_i].expected);
1002         else if (node->type == SDB_AST_TYPE_ITERATOR)
1003                 fail_unless(SDB_AST_ITER(node)->kind == parse_conditional_data[_i].expected,
1004                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
1005                                 "expected: %d",
1006                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
1007                                 parse_conditional_data[_i].expr,
1008                                 SDB_AST_ITER(node)->kind, parse_conditional_data[_i].expected);
1010         fail_unless(node->data_type == -1,
1011                         "sdb_parser_parse_conditional(%s, %s) returned conditional "
1012                         "of data-type %s; expected: %s",
1013                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
1014                         parse_conditional_data[_i].expr,
1015                         SDB_TYPE_TO_STRING(node->data_type), SDB_TYPE_TO_STRING(-1));
1017         sdb_object_deref(SDB_OBJ(node));
1018         sdb_strbuf_destroy(errbuf);
1020 END_TEST
1022 struct {
1023         int context;
1024         const char *expr;
1025         int len;
1026         int expected;
1027         int data_type;
1028 } parse_arith_data[] = {
1029         /* empty expressions */
1030         { SDB_HOST, NULL,                   -1, -1, -1 },
1031         { SDB_HOST, "",                     -1, -1, -1 },
1033         /* constant expressions */
1034         { SDB_HOST, "'localhost'",          -1, SDB_AST_TYPE_CONST, SDB_TYPE_STRING },
1035         { SDB_HOST, "123",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_INTEGER },
1036         { SDB_HOST, "42.3",                 -1, SDB_AST_TYPE_CONST, SDB_TYPE_DECIMAL },
1037         { SDB_HOST, "2014-08-16",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1038         { SDB_HOST, "17:23",                -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1039         { SDB_HOST, "17:23:53",             -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1040         { SDB_HOST, "17:23:53.123",         -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1041         { SDB_HOST, "17:23:53.123456789",   -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1042         { SDB_HOST, "2014-08-16 17:23",     -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1043         { SDB_HOST, "2014-08-16 17:23:53",  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1044         { SDB_HOST, "10s",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1045         { SDB_HOST, "60m",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1046         { SDB_HOST, "10Y 24D 1h",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1048         /* TODO: the analyzer and/or optimizer should turn these into constants */
1049         { SDB_HOST, "123 + 456",            -1, SDB_AST_ADD, SDB_TYPE_INTEGER },
1050         { SDB_HOST, "'foo' || 'bar'",       -1, SDB_AST_CONCAT, SDB_TYPE_STRING },
1051         { SDB_HOST, "456 - 123",            -1, SDB_AST_SUB, SDB_TYPE_INTEGER },
1052         { SDB_HOST, "1.2 * 3.4",            -1, SDB_AST_MUL, SDB_TYPE_DECIMAL },
1053         { SDB_HOST, "1.2 / 3.4",            -1, SDB_AST_DIV, SDB_TYPE_DECIMAL },
1054         { SDB_HOST, "5 % 2",                -1, SDB_AST_MOD, SDB_TYPE_INTEGER },
1056         /* queryable fields */
1057         { SDB_HOST, "last_update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1058         { SDB_HOST, "AGE",                  -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1059         { SDB_HOST, "interval",             -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1060         { SDB_HOST, "Last_Update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1061         { SDB_HOST, "backend",              -1, SDB_AST_TYPE_VALUE, SDB_TYPE_ARRAY | SDB_TYPE_STRING },
1063         /* attributes */
1064         { SDB_HOST, "attribute['foo']",     -1, SDB_AST_TYPE_VALUE, -1 },
1066         /* arithmetic expressions */
1067         { SDB_HOST, "age + age",            -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1068         { SDB_HOST, "age - age",            -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1069         { SDB_HOST, "age * age",            -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1070         { SDB_HOST, "age / age",            -1, SDB_AST_DIV, SDB_TYPE_DATETIME },
1071         { SDB_HOST, "age \% age",           -1, SDB_AST_MOD, SDB_TYPE_DATETIME },
1073         /* operator precedence */
1074         { SDB_HOST, "age + age * age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1075         { SDB_HOST, "age * age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1076         { SDB_HOST, "age + age - age",      -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1077         { SDB_HOST, "age - age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1078         { SDB_HOST, "(age + age) * age",    -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1079         { SDB_HOST, "age + (age * age)",    -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1081         /* boolean expressions */
1082         { SDB_METRIC, "timeseries + 1",               -1, -1, -1 },
1083         { SDB_METRIC, "timeseries - 1",               -1, -1, -1 },
1084         { SDB_METRIC, "timeseries * 1",               -1, -1, -1 },
1085         { SDB_METRIC, "timeseries / 1",               -1, -1, -1 },
1086         { SDB_METRIC, "timeseries \% 1",              -1, -1, -1 },
1087         { SDB_METRIC, "timeseries CONCAT 1",          -1, -1, -1 },
1088         { SDB_METRIC, "timeseries + timeseries",      -1, -1, -1 },
1089         { SDB_METRIC, "timeseries - timeseries",      -1, -1, -1 },
1090         { SDB_METRIC, "timeseries * timeseries",      -1, -1, -1 },
1091         { SDB_METRIC, "timeseries / timeseries",      -1, -1, -1 },
1092         { SDB_METRIC, "timeseries \% timeseries",     -1, -1, -1 },
1093         { SDB_METRIC, "timeseries CONCAT timeseries", -1, -1, -1 },
1095         /* syntax errors */
1096         { SDB_HOST, "LIST",                 -1, -1, -1 },
1097         { SDB_HOST, "foo &^ bar",           -1, -1, -1 },
1098         { SDB_HOST, "invalid",              -1, -1, -1 },
1099 };
1101 START_TEST(test_parse_arith)
1103         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
1104         sdb_ast_node_t *node;
1106         node = sdb_parser_parse_arith(parse_arith_data[_i].context,
1107                         parse_arith_data[_i].expr, parse_arith_data[_i].len, errbuf);
1109         if (parse_arith_data[_i].expected < 0) {
1110                 fail_unless(node == NULL,
1111                                 "sdb_parser_parse_arith(%s, %s) = %p; expected: NULL",
1112                                 SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1113                                 parse_arith_data[_i].expr, node);
1114                 sdb_object_deref(SDB_OBJ(node));
1115                 sdb_strbuf_destroy(errbuf);
1116                 return;
1117         }
1119         fail_unless(node != NULL, "sdb_parser_parse_arith(%s, %s) = NULL; "
1120                         "expected: <expr> (parse error: %s)",
1121                         SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1122                         parse_arith_data[_i].expr, sdb_strbuf_string(errbuf));
1123         if (node->type == SDB_AST_TYPE_OPERATOR)
1124                 fail_unless(SDB_AST_OP(node)->kind == 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, SDB_AST_OP(node)->kind,
1128                                 parse_arith_data[_i].expected);
1129         else
1130                 fail_unless(node->type == parse_arith_data[_i].expected,
1131                                 "sdb_parser_parse_arith(%s, %s) returned expression of type %d; "
1132                                 "expected: %d", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1133                                 parse_arith_data[_i].expr, node->type,
1134                                 parse_arith_data[_i].expected);
1136         fail_unless(node->data_type == parse_arith_data[_i].data_type,
1137                         "sdb_parser_parse_arith(%s, %s) returned expression of data-type %s; "
1138                         "expected: %s", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1139                         parse_arith_data[_i].expr, SDB_TYPE_TO_STRING(node->data_type),
1140                         SDB_TYPE_TO_STRING(parse_arith_data[_i].data_type));
1142         sdb_object_deref(SDB_OBJ(node));
1143         sdb_strbuf_destroy(errbuf);
1145 END_TEST
1147 TEST_MAIN("parser::parser")
1149         TCase *tc = tcase_create("core");
1150         TC_ADD_LOOP_TEST(tc, parse);
1151         TC_ADD_LOOP_TEST(tc, parse_conditional);
1152         TC_ADD_LOOP_TEST(tc, parse_arith);
1153         ADD_TCASE(tc);
1155 TEST_MAIN_END
1157 /* vim: set tw=78 sw=4 ts=4 noexpandtab : */