Code

4dcf684de06cc6c3b508fff98401883913bf7e6d
[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 metrics",          -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
161         { "LOOKUP metrics MATCHING ANY "
162           "attribute.name =~ 'a'",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
163         { "LOOKUP metrics MATCHING "
164           "host.name = 'p'",         -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
165         { "LOOKUP metrics MATCHING "
166           "metric.name = 'p'",       -1,   1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
168         /* TIMESERIES commands */
169         { "TIMESERIES 'host'.'metric' "
170           "START 2014-01-01 "
171           "END 2014-12-31 "
172           "23:59:59",            -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
173         { "TIMESERIES 'host'.'metric' "
174           "START 2014-02-02 "
175           "14:02",               -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
176         /* the end time has to be greater than the start time;
177          * we'll be safe for about 200 years ;-) */
178         { "TIMESERIES 'host'.'metric' "
179           "END 2214-02-02",      -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
180         { "TIMESERIES "
181           "'host'.'metric'",     -1,  1, SDB_AST_TYPE_TIMESERIES, 0 },
183         /* STORE commands */
184         { "STORE host 'host'",   -1,  1, SDB_AST_TYPE_STORE, SDB_HOST },
185         { "STORE host 'host' "
186           "LAST UPDATE "
187           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_HOST },
188         { "STORE host attribute "
189           "'host'.'key' 123",    -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
190         { "STORE host attribute "
191           "'host'.'key' 123 "
192           "LAST UPDATE "
193           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
194         { "STORE service "
195           "'host'.'svc'",        -1,  1, SDB_AST_TYPE_STORE, SDB_SERVICE },
196         { "STORE service "
197           "'host'.'svc' "
198           "LAST UPDATE "
199           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_SERVICE },
200         { "STORE service attribute "
201           "'host'.'svc'.'key' "
202           "123",                 -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
203         { "STORE service attribute "
204           "'host'.'svc'.'key' "
205           "123 "
206           "LAST UPDATE "
207           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
208         { "STORE metric "
209           "'host'.'metric'",     -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
210         { "STORE metric "
211           "'host'.'metric' "
212           "LAST UPDATE "
213           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
214         { "STORE metric "
215           "'host'.'metric' "
216           "STORE 'typ' 'id' "
217           "LAST UPDATE "
218           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_METRIC },
219         { "STORE metric attribute "
220           "'host'.'metric'.'key' "
221           "123",                 -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
222         { "STORE metric attribute "
223           "'host'.'metric'.'key' "
224           "123 "
225           "LAST UPDATE "
226           "2015-02-01",          -1,  1, SDB_AST_TYPE_STORE, SDB_ATTRIBUTE },
228         /* string constants */
229         { "LOOKUP hosts MATCHING "
230           "name = ''''",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
231         { "LOOKUP hosts MATCHING "
232           "name = '''foo'",      -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
233         { "LOOKUP hosts MATCHING "
234           "name = 'f''oo'",      -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 = '''",          -1, -1, 0, SDB_HOST },
240         /* numeric constants */
241         { "LOOKUP hosts MATCHING "
242           "attribute['foo'] = "
243           "1234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
244         { "LOOKUP hosts MATCHING "
245           "attribute['foo'] != "
246           "+234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
247         { "LOOKUP hosts MATCHING "
248           "attribute['foo'] < "
249           "-234",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
250         { "LOOKUP hosts MATCHING "
251           "attribute['foo'] > "
252           "12.4",                -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
253         { "LOOKUP hosts MATCHING "
254           "attribute['foo'] <= "
255           "12. + .3",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
256         { "LOOKUP hosts MATCHING "
257           "attribute['foo'] <= "
258           "'f' || 'oo'",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
259         { "LOOKUP hosts MATCHING "
260           "attribute['foo'] >= "
261           ".4",                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
262         { "LOOKUP hosts MATCHING "
263           "attribute['foo'] = "
264           "+12e3",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
265         { "LOOKUP hosts MATCHING "
266           "attribute['foo'] = "
267           "+12e-3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
268         { "LOOKUP hosts MATCHING "
269           "attribute['foo'] = "
270           "-12e+3",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
272         /* date, time, interval constants */
273         { "LOOKUP hosts MATCHING "
274           "attribute['foo'] = "
275           "1 Y 42D",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
276         { "LOOKUP hosts MATCHING "
277           "attribute['foo'] = "
278           "1s 42D",              -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
279         /*
280          * TODO: Something like 1Y42D should work as well but it doesn't since
281          * the scanner will tokenize it into {digit}{identifier} :-/
282          *
283         { "LOOKUP hosts MATCHING "
284           "attribute['foo'] = "
285           "1Y42D",               -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
286          */
288         /* array constants */
289         { "LOOKUP hosts MATCHING "
290           "backend = ['foo']",   -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
291         { "LOOKUP hosts MATCHING "
292           "backend = ['a','b']", -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
294         /* array iteration */
295         { "LOOKUP hosts MATCHING "
296           "'foo' IN backend",   -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
297         { "LOOKUP hosts MATCHING 'foo' "
298           "NOT IN backend",     -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
299         { "LOOKUP hosts MATCHING "
300           "['foo','bar'] "
301           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
302         /* attribute type is unknown */
303         { "LOOKUP hosts MATCHING "
304           "attribute['backend'] "
305           "IN backend ",        -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
306         { "LOOKUP hosts MATCHING "
307           "ANY backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
308         { "LOOKUP hosts MATCHING "
309           "ANY backend <= 'b'", -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           "ALL backend < 'b'",  -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
324         { "LOOKUP hosts MATCHING "
325           "ALL 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         /* attribute type is unknown */
339         { "LOOKUP hosts MATCHING "
340           "ANY backend = attribute['backend']",
341                                 -1,   1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
343         /* valid operand types */
344         { "LOOKUP hosts MATCHING "
345           "age * 1 > 0s",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
346         { "LOOKUP hosts MATCHING "
347           "age / 1 > 0s",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
348         { "LOOKUP hosts MATCHING "
349           "name > ''",           -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
350         { "LOOKUP hosts MATCHING "
351           "name >= ''",          -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 },
361         /* typed expressions */
362         { "LOOKUP services MATCHING "
363           "host.attribute['a'] = 'a'",
364                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
365         /* TODO: this should work but the analyzer currently sees ATTRIBUTE
366          * (instead of SERVICE-ATTRIBUTE) as the child type
367         { "LOOKUP services MATCHING "
368           "ANY attribute.service.name = 's'",
369                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_SERVICE },
370          */
371         { "LOOKUP hosts MATCHING "
372           "ANY service.service.name = 's'",
373                                  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
375         /* NULL / TRUE / FALSE */
376         { "LOOKUP hosts MATCHING "
377           "attribute['foo'] "
378           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
379         { "LOOKUP hosts MATCHING "
380           "attribute['foo'] "
381           "IS NOT NULL",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
382         { "LOOKUP hosts MATCHING "
383           "NOT attribute['foo'] "
384           "IS NULL",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
385         { "LOOKUP hosts MATCHING "
386           "ANY service.name IS NULL", -1, -1, 0, 0 },
387         { "LOOKUP hosts MATCHING "
388           "attribute['foo'] "
389           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
390         { "LOOKUP hosts MATCHING "
391           "attribute['foo'] "
392           "IS NOT TRUE",         -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
393         { "LOOKUP hosts MATCHING "
394           "NOT attribute['foo'] "
395           "IS TRUE",             -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
396         { "LOOKUP hosts MATCHING "
397           "attribute['foo'] "
398           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
399         { "LOOKUP hosts MATCHING "
400           "attribute['foo'] "
401           "IS NOT FALSE",        -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
402         { "LOOKUP hosts MATCHING "
403           "NOT attribute['foo'] "
404           "IS FALSE",            -1,  1, SDB_AST_TYPE_LOOKUP, SDB_HOST },
406         /* invalid numeric constants */
407         { "LOOKUP hosts MATCHING "
408           "attribute['foo'] = "
409           "+-12e+3",             -1, -1, 0, 0 },
410         { "LOOKUP hosts MATCHING "
411           "attribute['foo'] = "
412           "-12e-+3",             -1, -1, 0, 0 },
413         { "LOOKUP hosts MATCHING "
414           "attribute['foo'] = "
415           "e+3",                 -1, -1, 0, 0 },
416         { "LOOKUP hosts MATCHING "
417           "attribute['foo'] = "
418           "3e",                  -1, -1, 0, 0 },
419         /* following SQL standard, we don't support hex numbers */
420         { "LOOKUP hosts MATCHING "
421           "attribute['foo'] = "
422           "0x12",                -1, -1, 0, 0 },
424         /* invalid expressions */
425         { "LOOKUP hosts MATCHING "
426           "attr['foo'] = 1.23",  -1, -1, 0, 0 },
427         { "LOOKUP hosts MATCHING "
428           "attr['foo'] IS NULL", -1, -1, 0, 0 },
430         /* comments */
431         { "/* some comment */",  -1,  0, 0, 0 },
432         { "-- another comment",  -1,  0, 0, 0 },
434         /* syntax errors */
435         { "INVALID",             -1, -1, 0, 0 },
436         { "FETCH host",          -1, -1, 0, 0 },
437         { "FETCH 'host'",        -1, -1, 0, 0 },
438         { "LIST hosts; INVALID", -1, -1, 0, 0 },
439         { "/* some incomplete",  -1, -1, 0, 0 },
441         /*
442          * syntactically correct but semantically invalid commands
443          */
445         /* invalid fields */
446         { "LIST hosts FILTER "
447           "field = 'a'",           -1, -1, 0, 0 },
448         { "LIST services FILTER "
449           "field = 'a'",           -1, -1, 0, 0 },
450         { "LIST metrics FILTER "
451           "field = 'a'",           -1, -1, 0, 0 },
452         { "LIST hosts FILTER "
453           "value = 'a'",           -1, -1, 0, 0 },
454         { "LIST services FILTER "
455           "value = 'a'",           -1, -1, 0, 0 },
456         { "LIST metrics FILTER "
457           "value = 'a'",           -1, -1, 0, 0 },
458         { "LIST metrics FILTER "
459           "name.1 = 'a'",          -1, -1, 0, 0 },
461         /* type mismatches */
462         { "LOOKUP hosts MATCHING "
463           "attribute['foo'] = "
464           "1.23 + 'foo'",       -1,  -1, 0, 0 },
465         { "LOOKUP hosts MATCHING "
466           "1 IN backend ",      -1,  -1, 0, 0 },
467         { "LOOKUP hosts MATCHING "
468           "1 NOT IN backend ",  -1,  -1, 0, 0 },
469         { "LOOKUP hosts MATCHING "
470           "age > 0",             -1, -1, 0, 0 },
471         { "LOOKUP hosts MATCHING "
472           "NOT age > 0",         -1, -1, 0, 0 },
473         { "LOOKUP hosts MATCHING "
474           "age >= 0",            -1, -1, 0, 0 },
475         { "LOOKUP hosts MATCHING "
476           "age = 0",             -1, -1, 0, 0 },
477         { "LOOKUP hosts MATCHING "
478           "age != 0",            -1, -1, 0, 0 },
479         { "LOOKUP hosts MATCHING "
480           "age <= 0",            -1, -1, 0, 0 },
481         { "LOOKUP hosts MATCHING "
482           "age < 0",             -1, -1, 0, 0 },
483         { "LOOKUP hosts MATCHING "
484           "age + 1 > 0s",        -1, -1, 0, 0 },
485         { "LOOKUP hosts MATCHING "
486           "age - 1 > 0s",        -1, -1, 0, 0 },
488         /* datetime <mul/div> integer is allowed */
489         { "LOOKUP hosts MATCHING "
490           "age || 1 > 0s",       -1, -1, 0, 0 },
491         { "LOOKUP hosts MATCHING "
492           "name + 1 = ''",       -1, -1, 0, 0 },
493         { "LOOKUP hosts MATCHING "
494           "name - 1 = ''",       -1, -1, 0, 0 },
495         { "LOOKUP hosts MATCHING "
496           "name * 1 = ''",       -1, -1, 0, 0 },
497         { "LOOKUP hosts MATCHING "
498           "name / 1 = ''",       -1, -1, 0, 0 },
499         { "LOOKUP hosts MATCHING "
500           "name % 1 = ''",       -1, -1, 0, 0 },
501         { "LOOKUP hosts MATCHING "
502           "(name % 1) + 1 = ''", -1, -1, 0, 0 },
503         { "LOOKUP hosts MATCHING "
504           "1 + (name % 1) = ''", -1, -1, 0, 0 },
505         { "LOOKUP hosts MATCHING "
506           "'' = 1 + (name % 1)", -1, -1, 0, 0 },
507         { "LOOKUP hosts MATCHING "
508           "age > 0 AND "
509           "age = 0s",            -1, -1, 0, 0 },
510         { "LOOKUP hosts MATCHING "
511           "age = 0s AND "
512           "age > 0",             -1, -1, 0, 0 },
513         { "LOOKUP services MATCHING "
514           "host.name > 0",       -1, -1, 0, 0 },
515         { "LOOKUP services MATCHING "
516           "backend > 'b'",       -1, -1, 0, 0 },
517         { "LOOKUP services MATCHING "
518           "'b' > backend",       -1, -1, 0, 0 },
519         { "LOOKUP services MATCHING "
520           "attribute['a'] > backend",
521                                  -1, -1, 0, 0 },
522         { "LOOKUP services MATCHING "
523           "backend > attribute['a']",
524                                  -1, -1, 0, 0 },
525         { "LOOKUP services MATCHING "
526           "host.name + 1 = ''",  -1, -1, 0, 0 },
527         { "LOOKUP hosts MATCHING "
528           "'a' + 1 IN 'b'",      -1, -1, 0, 0 },
529         { "LOOKUP hosts MATCHING "
530           "'a' IN 'b' - 1",      -1, -1, 0, 0 },
531         { "LOOKUP hosts MATCHING "
532           "name + 1 IN 'b'",     -1, -1, 0, 0 },
533         { "LOOKUP hosts MATCHING "
534           "'a' IN name - 1",     -1, -1, 0, 0 },
535         { "LOOKUP hosts MATCHING "
536           "'b' IN 'abc'",        -1, -1, 0, 0 },
537         { "LOOKUP hosts MATCHING "
538           "1 IN age",            -1, -1, 0, 0 },
539         { "LOOKUP hosts MATCHING "
540           "name =~ 'a' + 1",     -1, -1, 0, 0 },
541         { "LOOKUP hosts MATCHING "
542           "name =~ name + 1",    -1, -1, 0, 0 },
543         { "LOOKUP hosts MATCHING "
544           "name + 1 =~ 'a'",     -1, -1, 0, 0 },
545         { "LOOKUP hosts MATCHING "
546           "name =~ 1",           -1, -1, 0, 0 },
547         { "LOOKUP hosts MATCHING "
548           "name + 1 IS NULL",    -1, -1, 0, 0 },
549         { "LOOKUP hosts FILTER "
550           "name + 1 IS NULL",    -1, -1, 0, 0 },
551         { "LOOKUP hosts MATCHING "
552           "name + 1 IS TRUE",    -1, -1, 0, 0 },
553         { "LOOKUP hosts FILTER "
554           "name + 1 IS TRUE",    -1, -1, 0, 0 },
555         { "LOOKUP hosts MATCHING "
556           "name + 1 IS FALSE",   -1, -1, 0, 0 },
557         { "LOOKUP hosts FILTER "
558           "name + 1 IS FALSE",   -1, -1, 0, 0 },
560         /* invalid iterators */
561         { "LOOKUP hosts MATCHING "
562           "ANY backend !~ backend",
563                                 -1,  -1, 0, 0 },
564         { "LOOKUP hosts MATCHING "
565           "ANY backend = 1",    -1,  -1, 0, 0 },
566         { "LOOKUP hosts MATCHING "
567           "ANY 'patt' =~ 'p'",  -1,  -1, 0, 0 },
568         { "LOOKUP hosts MATCHING "
569           "ALL 1 || '2' < '3'", -1,  -1, 0, 0 },
570         { "LOOKUP hosts MATCHING "
571           "ALL name =~ 'a'",    -1,  -1, 0, 0 },
572         /* this could work in theory but is not supported atm */
573         { "LOOKUP hosts MATCHING "
574           "ANY backend || 'a' = 'b'",
575                                 -1,  -1, 0, 0 },
577         /* invalid LIST commands */
578         { "LIST",                -1, -1, 0, 0 },
579         { "LIST foo",            -1, -1, 0, 0 },
580         { "LIST hosts MATCHING "
581           "name = 'host'",       -1, -1, 0, 0 },
582         { "LIST foo FILTER "
583           "age > 60s",           -1, -1, 0, 0 },
585         /* invalid FETCH commands */
586         { "FETCH host 'host' MATCHING "
587           "name = 'host'",       -1, -1, 0, 0 },
588         { "FETCH service 'host'",-1, -1, 0, 0 },
589         { "FETCH metric 'host'", -1, -1, 0, 0 },
590         { "FETCH host "
591           "'host'.'localhost'",  -1, -1, 0, 0 },
592         { "FETCH foo 'host'",    -1, -1, 0, 0 },
593         { "FETCH foo 'host' FILTER "
594           "age > 60s",           -1, -1, 0, 0 },
596         /* invalid LOOKUP commands */
597         { "LOOKUP foo",          -1, -1, 0, 0 },
598         { "LOOKUP foo MATCHING "
599           "name = 'host'",       -1, -1, 0, 0 },
600         { "LOOKUP foo FILTER "
601           "age > 60s",           -1, -1, 0, 0 },
602         { "LOOKUP foo MATCHING "
603           "name = 'host' FILTER "
604           "age > 60s",           -1, -1, 0, 0 },
605         { "LOOKUP hosts MATCHING "
606           "attribute['foo'] <= "
607           "f || 'oo'",           -1, -1, 0, 0 },
608         { "LOOKUP hosts MATCHING "
609           "attribute['foo'] <= "
610           "'f' || oo",           -1, -1, 0, 0 },
611         { "LOOKUP hosts MATCHING "
612           "ANY host.name = 'host'",   -1, -1, 0, 0 },
613         { "LOOKUP hosts MATCHING "
614           "ANY service.name > 1",     -1, -1, 0, 0 },
615         { "LOOKUP hosts MATCHING "
616           "service.name = 's'",       -1, -1, 0, 0 },
617         { "LOOKUP services MATCHING "
618           "ANY host.name = 'host'",   -1, -1, 0, 0 },
619         { "LOOKUP services MATCHING "
620           "ANY service.name = 'svc'", -1, -1, 0, 0 },
621         { "LOOKUP services MATCHING "
622           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
623         { "LOOKUP services MATCHING "
624           "metric.name = 'm'",        -1, -1, 0, 0 },
625         { "LOOKUP metrics MATCHING "
626           "ANY host.name = 'host'",   -1, -1, 0, 0 },
627         { "LOOKUP metrics MATCHING "
628           "ANY service.name = 'svc'", -1, -1, 0, 0 },
629         { "LOOKUP metrics MATCHING "
630           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
631         { "LOOKUP metrics MATCHING "
632           "service.name = 'm'",       -1, -1, 0, 0 },
634         /* invalid STORE commands */
635         { "STORE host "
636           "'obj'.'host'",        -1, -1, 0, 0 },
637         { "STORE host attribute "
638           ".'key' 123",          -1, -1, 0, 0 },
639         { "STORE host attribute "
640           "'o'.'h'.'key' 123",   -1, -1, 0, 0 },
641         { "STORE service 'svc'", -1, -1, 0, 0 },
642         { "STORE service "
643           "'host'.'svc' "
644           "STORE 'typ' 'id' "
645           "LAST UPDATE "
646           "2015-02-01",          -1, -1, 0, 0 },
647         { "STORE service attribute "
648           "'svc'.'key' 123",     -1, -1, 0, 0 },
649         { "STORE metric 'm'",    -1, -1, 0, 0 },
650         { "STORE metric "
651           "'host'.'metric' "
652           "STORE 'typ'.'id' "
653           "LAST UPDATE "
654           "2015-02-01",          -1, -1, 0, 0 },
655         { "STORE metric attribute "
656           "'metric'.'key' 123",  -1, -1, 0, 0 },
657 };
659 START_TEST(test_parse)
661         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
662         sdb_llist_t *check;
663         sdb_ast_node_t *node;
664         sdb_store_query_t *q;
665         _Bool ok;
667         check = sdb_parser_parse(parse_data[_i].query,
668                         parse_data[_i].len, errbuf);
669         if (parse_data[_i].expected < 0)
670                 ok = check == 0;
671         else
672                 ok = sdb_llist_len(check) == (size_t)parse_data[_i].expected;
674         fail_unless(ok, "sdb_parser_parse(%s) = %p (len: %zu); expected: %d "
675                         "(parse error: %s)", parse_data[_i].query, check,
676                         sdb_llist_len(check), parse_data[_i].expected,
677                         sdb_strbuf_string(errbuf));
679         if (! check) {
680                 sdb_strbuf_destroy(errbuf);
681                 return;
682         }
684         if ((! parse_data[_i].expected_type)
685                         || (parse_data[_i].expected <= 0)) {
686                 sdb_llist_destroy(check);
687                 sdb_strbuf_destroy(errbuf);
688                 return;
689         }
691         node = SDB_AST_NODE(sdb_llist_get(check, 0));
692         fail_unless(node->type == parse_data[_i].expected_type,
693                         "sdb_parser_parse(%s)->type = %i; expected: %d",
694                         parse_data[_i].query, node->type,
695                         parse_data[_i].expected_type);
697         if (node->type == SDB_AST_TYPE_FETCH) {
698                 sdb_ast_fetch_t *f = SDB_AST_FETCH(node);
699                 fail_unless(f->obj_type == parse_data[_i].expected_extra,
700                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
701                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(f->obj_type),
702                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
703         }
704         else if (node->type == SDB_AST_TYPE_LIST) {
705                 sdb_ast_list_t *l = SDB_AST_LIST(node);
706                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
707                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
708                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
709                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
710         }
711         else if (node->type == SDB_AST_TYPE_LOOKUP) {
712                 sdb_ast_lookup_t *l = SDB_AST_LOOKUP(node);
713                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
714                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
715                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
716                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
717         }
718         else if (node->type == SDB_AST_TYPE_STORE) {
719                 sdb_ast_store_t *s = SDB_AST_STORE(node);
720                 fail_unless(s->obj_type == parse_data[_i].expected_extra,
721                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
722                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(s->obj_type),
723                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
724         }
726         /* TODO: this should move into front-end specific tests */
727         q = sdb_store_query_prepare(node);
728         fail_unless(q != NULL,
729                         "sdb_store_query_prepare(AST<%s>) = NULL; expected: <query>",
730                         parse_data[_i].query);
732         sdb_object_deref(SDB_OBJ(node));
733         sdb_object_deref(SDB_OBJ(q));
734         sdb_llist_destroy(check);
735         sdb_strbuf_destroy(errbuf);
737 END_TEST
739 struct {
740         const char *expr;
741         int len;
742         int expected;
743 } parse_conditional_data[] = {
744         /* empty expressions */
745         { NULL,                           -1, -1 },
746         { "",                             -1, -1 },
748         /* match hosts by name */
749         { "name < 'localhost'",           -1,  SDB_AST_LT },
750         { "name <= 'localhost'",          -1,  SDB_AST_LE },
751         { "name = 'localhost'",           -1,  SDB_AST_EQ },
752         { "name != 'localhost'",          -1,  SDB_AST_NE },
753         { "name >= 'localhost'",          -1,  SDB_AST_GE },
754         { "name > 'localhost'",           -1,  SDB_AST_GT },
755         { "name =~ 'host'",               -1,  SDB_AST_REGEX },
756         { "name !~ 'host'",               -1,  SDB_AST_NREGEX },
757         { "name = 'localhost' -- foo",    -1,  SDB_AST_EQ },
758         { "name = 'host' <garbage>",      13,  SDB_AST_EQ },
759         { "name &^ 'localhost'",          -1,  -1 },
760         /* match by backend */
761         { "ANY backend < 'be'",           -1,  SDB_AST_ANY },
762         { "ANY backend <= 'be'",          -1,  SDB_AST_ANY },
763         { "ANY backend = 'be'",           -1,  SDB_AST_ANY },
764         { "ANY backend != 'be'",          -1,  SDB_AST_ANY },
765         { "ANY backend >= 'be'",          -1,  SDB_AST_ANY },
766         { "ANY backend > 'be'",           -1,  SDB_AST_ANY },
767         { "ALL backend < 'be'",           -1,  SDB_AST_ALL },
768         { "ALL backend <= 'be'",          -1,  SDB_AST_ALL },
769         { "ALL backend = 'be'",           -1,  SDB_AST_ALL },
770         { "ALL backend != 'be'",          -1,  SDB_AST_ALL },
771         { "ALL backend >= 'be'",          -1,  SDB_AST_ALL },
772         { "ALL backend > 'be'",           -1,  SDB_AST_ALL },
773         { "ANY backend &^ 'be'",          -1,  -1 },
774         /* match hosts by service */
775         { "ANY service.name < 'name'",         -1,  SDB_AST_ANY },
776         { "ANY service.name <= 'name'",        -1,  SDB_AST_ANY },
777         { "ANY service.name = 'name'",         -1,  SDB_AST_ANY },
778         { "ANY service.name != 'name'",        -1,  SDB_AST_ANY },
779         { "ANY service.name >= 'name'",        -1,  SDB_AST_ANY },
780         { "ANY service.name > 'name'",         -1,  SDB_AST_ANY },
781         { "ANY service.name =~ 'pattern'",     -1,  SDB_AST_ANY },
782         { "ANY service.name !~ 'pattern'",     -1,  SDB_AST_ANY },
783         { "ANY service.name &^ 'name'",        -1,  -1 },
784         { "ALL service.name < 'name'",         -1,  SDB_AST_ALL },
785         { "ALL service.name <= 'name'",        -1,  SDB_AST_ALL },
786         { "ALL service.name = 'name'",         -1,  SDB_AST_ALL },
787         { "ALL service.name != 'name'",        -1,  SDB_AST_ALL },
788         { "ALL service.name >= 'name'",        -1,  SDB_AST_ALL },
789         { "ALL service.name > 'name'",         -1,  SDB_AST_ALL },
790         { "ALL service.name =~ 'pattern'",     -1,  SDB_AST_ALL },
791         { "ALL service.name !~ 'pattern'",     -1,  SDB_AST_ALL },
792         { "ALL service.name &^ 'name'",        -1,  -1 },
793         { "ANY service < 'name'",              -1,  -1 },
794         /* match hosts by metric */
795         { "ANY metric.name < 'name'",          -1,  SDB_AST_ANY },
796         { "ANY metric.name <= 'name'",         -1,  SDB_AST_ANY },
797         { "ANY metric.name = 'name'",          -1,  SDB_AST_ANY },
798         { "ANY metric.name != 'name'",         -1,  SDB_AST_ANY },
799         { "ANY metric.name >= 'name'",         -1,  SDB_AST_ANY },
800         { "ANY metric.name > 'name'",          -1,  SDB_AST_ANY },
801         { "ANY metric.name =~ 'pattern'",      -1,  SDB_AST_ANY },
802         { "ANY metric.name !~ 'pattern'",      -1,  SDB_AST_ANY },
803         { "ANY metric.name &^ 'pattern'",      -1,  -1 },
804         { "ALL metric.name < 'name'",          -1,  SDB_AST_ALL },
805         { "ALL metric.name <= 'name'",         -1,  SDB_AST_ALL },
806         { "ALL metric.name = 'name'",          -1,  SDB_AST_ALL },
807         { "ALL metric.name != 'name'",         -1,  SDB_AST_ALL },
808         { "ALL metric.name >= 'name'",         -1,  SDB_AST_ALL },
809         { "ALL metric.name > 'name'",          -1,  SDB_AST_ALL },
810         { "ALL metric.name =~ 'pattern'",      -1,  SDB_AST_ALL },
811         { "ALL metric.name !~ 'pattern'",      -1,  SDB_AST_ALL },
812         { "ALL metric.name &^ 'pattern'",      -1,  -1 },
813         { "ANY metric <= 'name'",              -1,  -1 },
814         /* match hosts by attribute */
815         { "ANY attribute.name < 'name'",       -1,  SDB_AST_ANY },
816         { "ANY attribute.name <= 'name'",      -1,  SDB_AST_ANY },
817         { "ANY attribute.name = 'name'",       -1,  SDB_AST_ANY },
818         { "ANY attribute.name != 'name'",      -1,  SDB_AST_ANY },
819         { "ANY attribute.name >= 'name'",      -1,  SDB_AST_ANY },
820         { "ANY attribute.name > 'name'",       -1,  SDB_AST_ANY },
821         { "ANY attribute.name =~ 'pattern'",   -1,  SDB_AST_ANY },
822         { "ANY attribute.name !~ 'pattern'",   -1,  SDB_AST_ANY },
823         { "ANY attribute.name &^ 'pattern'",   -1,  -1 },
824         { "ALL attribute.name < 'name'",       -1,  SDB_AST_ALL },
825         { "ALL attribute.name <= 'name'",      -1,  SDB_AST_ALL },
826         { "ALL attribute.name = 'name'",       -1,  SDB_AST_ALL },
827         { "ALL attribute.name != 'name'",      -1,  SDB_AST_ALL },
828         { "ALL attribute.name >= 'name'",      -1,  SDB_AST_ALL },
829         { "ALL attribute.name > 'name'",       -1,  SDB_AST_ALL },
830         { "ALL attribute.name =~ 'pattern'",   -1,  SDB_AST_ALL },
831         { "ALL attribute.name !~ 'pattern'",   -1,  SDB_AST_ALL },
832         { "ALL attribute.name &^ 'pattern'",   -1,  -1 },
833         { "ANY attribute !~ 'pattern'",        -1,  -1 },
834         /* composite expressions */
835         { "name =~ 'pattern' AND "
836           "ANY service.name =~ 'pattern'",     -1,  SDB_AST_AND },
837         { "name =~ 'pattern' OR "
838           "ANY service.name =~ 'pattern'",     -1,  SDB_AST_OR },
839         { "NOT name = 'host'",                 -1,  SDB_AST_NOT },
840         /* numeric expressions */
841         { "attribute['foo'] < 123",         -1,  SDB_AST_LT },
842         { "attribute['foo'] <= 123",        -1,  SDB_AST_LE },
843         { "attribute['foo'] = 123",         -1,  SDB_AST_EQ },
844         { "attribute['foo'] >= 123",        -1,  SDB_AST_GE },
845         { "attribute['foo'] > 123",         -1,  SDB_AST_GT },
846         /* datetime expressions */
847         { "attribute['foo'] = "
848           "2014-08-16",                     -1,  SDB_AST_EQ },
849         { "attribute['foo'] = "
850           "17:23",                          -1,  SDB_AST_EQ },
851         { "attribute['foo'] = "
852           "17:23:53",                       -1,  SDB_AST_EQ },
853         { "attribute['foo'] = "
854           "17:23:53.123",                   -1,  SDB_AST_EQ },
855         { "attribute['foo'] = "
856           "17:23:53.123456789",             -1,  SDB_AST_EQ },
857         { "attribute['foo'] = "
858           "2014-08-16 17:23",               -1,  SDB_AST_EQ },
859         { "attribute['foo'] = "
860           "2014-08-16 17:23:53",            -1,  SDB_AST_EQ },
861         /* NULL / TRUE / FALSE */
862         { "attribute['foo'] IS NULL",       -1,  SDB_AST_ISNULL },
863         { "attribute['foo'] IS NOT NULL",   -1,  SDB_AST_NOT },
864         { "attribute['foo'] IS TRUE",       -1,  SDB_AST_ISTRUE },
865         { "attribute['foo'] IS NOT TRUE",   -1,  SDB_AST_NOT },
866         { "attribute['foo'] IS FALSE",      -1,  SDB_AST_ISFALSE },
867         { "attribute['foo'] IS NOT FALSE",  -1,  SDB_AST_NOT },
868         /* array expressions */
869         { "backend < ['a']",                -1,  SDB_AST_LT },
870         { "backend <= ['a']",               -1,  SDB_AST_LE },
871         { "backend = ['a']",                -1,  SDB_AST_EQ },
872         { "backend != ['a']",               -1,  SDB_AST_NE },
873         { "backend >= ['a']",               -1,  SDB_AST_GE },
874         { "backend > ['a']",                -1,  SDB_AST_GT },
875         { "backend &^ ['a']",               -1,  -1 },
877         /* object field comparison */
878         { "name < 'a'",                     -1,  SDB_AST_LT },
879         { "name <= 'a'",                    -1,  SDB_AST_LE },
880         { "name = 'a'",                     -1,  SDB_AST_EQ },
881         { "name != 'a'",                    -1,  SDB_AST_NE },
882         { "name >= 'a'",                    -1,  SDB_AST_GE },
883         { "name > 'a'",                     -1,  SDB_AST_GT },
884         { "last_update < 2014-10-01",       -1,  SDB_AST_LT },
885         { "last_update <= 2014-10-01",      -1,  SDB_AST_LE },
886         { "last_update = 2014-10-01",       -1,  SDB_AST_EQ },
887         { "last_update != 2014-10-01",      -1,  SDB_AST_NE },
888         { "last_update >= 2014-10-01",      -1,  SDB_AST_GE },
889         { "last_update > 2014-10-01",       -1,  SDB_AST_GT },
890         { "Last_Update >= 24D",             -1,  SDB_AST_GE },
891         { "age < 20s",                      -1,  SDB_AST_LT },
892         { "age <= 20s",                     -1,  SDB_AST_LE },
893         { "age = 20s",                      -1,  SDB_AST_EQ },
894         { "age != 20s",                     -1,  SDB_AST_NE },
895         { "age >= 20s",                     -1,  SDB_AST_GE },
896         { "age > 20s",                      -1,  SDB_AST_GT },
897         { "AGE <= 1m",                      -1,  SDB_AST_LE },
898         { "age > 1M",                       -1,  SDB_AST_GT },
899         { "age != 20Y",                     -1,  SDB_AST_NE },
900         { "age <= 2 * interval",            -1,  SDB_AST_LE },
901         { "interval < 20s",                 -1,  SDB_AST_LT },
902         { "interval <= 20s",                -1,  SDB_AST_LE },
903         { "interval = 20s",                 -1,  SDB_AST_EQ },
904         { "interval != 20s",                -1,  SDB_AST_NE },
905         { "interval >= 20s",                -1,  SDB_AST_GE },
906         { "interval > 20s",                 -1,  SDB_AST_GT },
907         { "'be' IN backend",                -1,  SDB_AST_IN },
908         { "'be' NOT IN backend",            -1,  SDB_AST_NOT },
909         { "['a','b'] IN backend",           -1,  SDB_AST_IN },
910         { "['a','b'] NOT IN backend",       -1,  SDB_AST_NOT },
912         /* check operator precedence */
913         { "name = 'name' OR "
914           "ANY service.name = 'name' AND "
915           "ANY attribute.name = 'name' OR "
916           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
917         { "name = 'name' AND "
918           "ANY service.name = 'name' AND "
919           "ANY attribute.name = 'name' OR "
920           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
921         { "name = 'name' AND "
922           "ANY service.name = 'name' OR "
923           "ANY attribute.name = 'name' AND "
924           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
925         { "(name = 'name' OR "
926           "ANY service.name = 'name') AND "
927           "(ANY attribute.name = 'name' OR "
928           "attribute['foo'] = 'bar')",      -1,  SDB_AST_AND },
929         { "NOT name = 'name' OR "
930           "ANY service.name = 'name'",      -1,  SDB_AST_OR },
931         { "NOT name = 'name' OR "
932           "NOT ANY service.name = 'name'",  -1,  SDB_AST_OR },
933         { "NOT (name = 'name' OR "
934           "NOT ANY service.name = 'name')", -1,  SDB_AST_NOT },
936         /* syntax errors */
937         { "LIST hosts",                     -1, -1 },
938         { "foo &^ bar",                     -1, -1 },
939         { "invalid",                        -1, -1 },
940 };
942 START_TEST(test_parse_conditional)
944         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
945         sdb_ast_node_t *node;
947         node = sdb_parser_parse_conditional(parse_conditional_data[_i].expr,
948                         parse_conditional_data[_i].len, errbuf);
950         if (parse_conditional_data[_i].expected < 0) {
951                 fail_unless(node == NULL,
952                                 "sdb_parser_parse_conditional(%s) = %p; expected: NULL",
953                                 parse_conditional_data[_i].expr, node);
954                 sdb_object_deref(SDB_OBJ(node));
955                 sdb_strbuf_destroy(errbuf);
956                 return;
957         }
959         fail_unless(node != NULL, "sdb_parser_parse_conditional(%s) = NULL; "
960                         "expected: <cond> (parse error: %s)",
961                         parse_conditional_data[_i].expr, sdb_strbuf_string(errbuf));
962         if (node->type == SDB_AST_TYPE_OPERATOR)
963                 fail_unless(SDB_AST_OP(node)->kind == parse_conditional_data[_i].expected,
964                                 "sdb_parser_parse_conditional(%s) returned conditional of type %d; "
965                                 "expected: %d", parse_conditional_data[_i].expr,
966                                 SDB_AST_OP(node)->kind, parse_conditional_data[_i].expected);
967         else if (node->type == SDB_AST_TYPE_ITERATOR)
968                 fail_unless(SDB_AST_ITER(node)->kind == parse_conditional_data[_i].expected,
969                                 "sdb_parser_parse_conditional(%s) returned conditional of type %d; "
970                                 "expected: %d", parse_conditional_data[_i].expr,
971                                 SDB_AST_ITER(node)->kind, parse_conditional_data[_i].expected);
973         fail_unless(node->data_type == -1,
974                         "sdb_parser_parse_conditional(%s) returned conditional of data-type %s; "
975                         "expected: %s", parse_conditional_data[_i].expr,
976                         SDB_TYPE_TO_STRING(node->data_type), SDB_TYPE_TO_STRING(-1));
978         sdb_object_deref(SDB_OBJ(node));
979         sdb_strbuf_destroy(errbuf);
981 END_TEST
983 struct {
984         const char *expr;
985         int len;
986         int expected;
987         int data_type;
988 } parse_arith_data[] = {
989         /* empty expressions */
990         { NULL,                   -1, -1, -1 },
991         { "",                     -1, -1, -1 },
993         /* constant expressions */
994         { "'localhost'",          -1, SDB_AST_TYPE_CONST, SDB_TYPE_STRING },
995         { "123",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_INTEGER },
996         { "42.3",                 -1, SDB_AST_TYPE_CONST, SDB_TYPE_DECIMAL },
997         { "2014-08-16",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
998         { "17:23",                -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
999         { "17:23:53",             -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1000         { "17:23:53.123",         -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1001         { "17:23:53.123456789",   -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1002         { "2014-08-16 17:23",     -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1003         { "2014-08-16 17:23:53",  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1004         { "10s",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1005         { "60m",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1006         { "10Y 24D 1h",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1008         /* TODO: the analyzer and/or optimizer should turn these into constants */
1009         { "123 + 456",            -1, SDB_AST_ADD, SDB_TYPE_INTEGER },
1010         { "'foo' || 'bar'",       -1, SDB_AST_CONCAT, SDB_TYPE_STRING },
1011         { "456 - 123",            -1, SDB_AST_SUB, SDB_TYPE_INTEGER },
1012         { "1.2 * 3.4",            -1, SDB_AST_MUL, SDB_TYPE_DECIMAL },
1013         { "1.2 / 3.4",            -1, SDB_AST_DIV, SDB_TYPE_DECIMAL },
1014         { "5 % 2",                -1, SDB_AST_MOD, SDB_TYPE_INTEGER },
1016         /* queryable fields */
1017         { "last_update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1018         { "AGE",                  -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1019         { "interval",             -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1020         { "Last_Update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1021         { "backend",              -1, SDB_AST_TYPE_VALUE, SDB_TYPE_ARRAY | SDB_TYPE_STRING },
1023         /* attributes */
1024         { "attribute['foo']",     -1, SDB_AST_TYPE_VALUE, -1 },
1026         /* arithmetic expressions */
1027         { "age + age",            -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1028         { "age - age",            -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1029         { "age * age",            -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1030         { "age / age",            -1, SDB_AST_DIV, SDB_TYPE_DATETIME },
1031         { "age \% age",           -1, SDB_AST_MOD, SDB_TYPE_DATETIME },
1033         /* operator precedence */
1034         { "age + age * age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1035         { "age * age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1036         { "age + age - age",      -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1037         { "age - age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1038         { "(age + age) * age",    -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1039         { "age + (age * age)",    -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1041         /* syntax errors */
1042         { "LIST",                 -1, -1, -1 },
1043         { "foo &^ bar",           -1, -1, -1 },
1044         { "invalid",              -1, -1, -1 },
1045 };
1047 START_TEST(test_parse_arith)
1049         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
1050         sdb_ast_node_t *node;
1052         node = sdb_parser_parse_arith(parse_arith_data[_i].expr,
1053                         parse_arith_data[_i].len, errbuf);
1055         if (parse_arith_data[_i].expected < 0) {
1056                 fail_unless(node == NULL,
1057                                 "sdb_parser_parse_arith(%s) = %p; expected: NULL",
1058                                 parse_arith_data[_i].expr, node);
1059                 sdb_object_deref(SDB_OBJ(node));
1060                 sdb_strbuf_destroy(errbuf);
1061                 return;
1062         }
1064         fail_unless(node != NULL, "sdb_parser_parse_arith(%s) = NULL; "
1065                         "expected: <expr> (parse error: %s)",
1066                         parse_arith_data[_i].expr, sdb_strbuf_string(errbuf));
1067         if (node->type == SDB_AST_TYPE_OPERATOR)
1068                 fail_unless(SDB_AST_OP(node)->kind == parse_arith_data[_i].expected,
1069                                 "sdb_parser_parse_arith(%s) returned expression of type %d; "
1070                                 "expected: %d", parse_arith_data[_i].expr,
1071                                 SDB_AST_OP(node)->kind, parse_arith_data[_i].expected);
1072         else
1073                 fail_unless(node->type == parse_arith_data[_i].expected,
1074                                 "sdb_parser_parse_arith(%s) returned expression of type %d; "
1075                                 "expected: %d", parse_arith_data[_i].expr, node->type,
1076                                 parse_arith_data[_i].expected);
1078         fail_unless(node->data_type == parse_arith_data[_i].data_type,
1079                         "sdb_parser_parse_arith(%s) returned expression of data-type %s; "
1080                         "expected: %s", parse_arith_data[_i].expr,
1081                         SDB_TYPE_TO_STRING(node->data_type),
1082                         SDB_TYPE_TO_STRING(parse_arith_data[_i].data_type));
1084         sdb_object_deref(SDB_OBJ(node));
1085         sdb_strbuf_destroy(errbuf);
1087 END_TEST
1089 TEST_MAIN("parser::parser")
1091         TCase *tc = tcase_create("core");
1092         TC_ADD_LOOP_TEST(tc, parse);
1093         TC_ADD_LOOP_TEST(tc, parse_conditional);
1094         TC_ADD_LOOP_TEST(tc, parse_arith);
1095         ADD_TCASE(tc);
1097 TEST_MAIN_END
1099 /* vim: set tw=78 sw=4 ts=4 noexpandtab : */