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  */
  27
  28 #if HAVE_CONFIG_H
  29 #       include "config.h"
  30 #endif
  31
  32 #include "parser/parser.h"
  33 #include "core/object.h"
  34 #include "core/store.h"
  35 #include "testutils.h"
  36
  37 #include <check.h>
  38 #include <limits.h>
  39
  40 /*
  41  * tests
  42  */
  43
  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 },
  56
  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 },
  65
  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 },
 116
 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 },
 167
 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 },
 182
 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 },
 227
 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 },
 239
 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 },
 271
 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          */
 287
 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 },
 293
 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 },
 342
 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 },
 360
 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 },
 374
 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 },
 405         { "LOOKUP metrics MATCHING "
 406           "timeseries IS TRUE",  -1,  1, SDB_AST_TYPE_LOOKUP, SDB_METRIC },
 407
 408         /* invalid numeric constants */
 409         { "LOOKUP hosts MATCHING "
 410           "attribute['foo'] = "
 411           "+-12e+3",             -1, -1, 0, 0 },
 412         { "LOOKUP hosts MATCHING "
 413           "attribute['foo'] = "
 414           "-12e-+3",             -1, -1, 0, 0 },
 415         { "LOOKUP hosts MATCHING "
 416           "attribute['foo'] = "
 417           "e+3",                 -1, -1, 0, 0 },
 418         { "LOOKUP hosts MATCHING "
 419           "attribute['foo'] = "
 420           "3e",                  -1, -1, 0, 0 },
 421         /* following SQL standard, we don't support hex numbers */
 422         { "LOOKUP hosts MATCHING "
 423           "attribute['foo'] = "
 424           "0x12",                -1, -1, 0, 0 },
 425
 426         /* invalid expressions */
 427         { "LOOKUP hosts MATCHING "
 428           "attr['foo'] = 1.23",  -1, -1, 0, 0 },
 429         { "LOOKUP hosts MATCHING "
 430           "attr['foo'] IS NULL", -1, -1, 0, 0 },
 431
 432         /* comments */
 433         { "/* some comment */",  -1,  0, 0, 0 },
 434         { "-- another comment",  -1,  0, 0, 0 },
 435
 436         /* syntax errors */
 437         { "INVALID",             -1, -1, 0, 0 },
 438         { "FETCH host",          -1, -1, 0, 0 },
 439         { "FETCH 'host'",        -1, -1, 0, 0 },
 440         { "LIST hosts; INVALID", -1, -1, 0, 0 },
 441         { "/* some incomplete",  -1, -1, 0, 0 },
 442
 443         /*
 444          * syntactically correct but semantically invalid commands
 445          */
 446
 447         /* invalid fields */
 448         { "LIST hosts FILTER "
 449           "field = 'a'",           -1, -1, 0, 0 },
 450         { "LIST services FILTER "
 451           "field = 'a'",           -1, -1, 0, 0 },
 452         { "LIST metrics FILTER "
 453           "field = 'a'",           -1, -1, 0, 0 },
 454         { "LIST hosts FILTER "
 455           "value = 'a'",           -1, -1, 0, 0 },
 456         { "LIST services FILTER "
 457           "value = 'a'",           -1, -1, 0, 0 },
 458         { "LIST metrics FILTER "
 459           "value = 'a'",           -1, -1, 0, 0 },
 460         { "LIST metrics FILTER "
 461           "name.1 = 'a'",          -1, -1, 0, 0 },
 462         { "LIST hosts FILTER "
 463           "timeseries IS TRUE",    -1, -1, 0, 0 },
 464         { "LIST services FILTER "
 465           "timeseries IS TRUE",    -1, -1, 0, 0 },
 466
 467         /* type mismatches */
 468         { "LOOKUP hosts MATCHING "
 469           "attribute['foo'] = "
 470           "1.23 + 'foo'",       -1,  -1, 0, 0 },
 471         { "LOOKUP hosts MATCHING "
 472           "1 IN backend ",      -1,  -1, 0, 0 },
 473         { "LOOKUP hosts MATCHING "
 474           "1 NOT IN backend ",  -1,  -1, 0, 0 },
 475         { "LOOKUP hosts MATCHING "
 476           "age > 0",             -1, -1, 0, 0 },
 477         { "LOOKUP hosts MATCHING "
 478           "NOT 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 != 0",            -1, -1, 0, 0 },
 485         { "LOOKUP hosts MATCHING "
 486           "age <= 0",            -1, -1, 0, 0 },
 487         { "LOOKUP hosts MATCHING "
 488           "age < 0",             -1, -1, 0, 0 },
 489         { "LOOKUP hosts MATCHING "
 490           "age + 1 > 0s",        -1, -1, 0, 0 },
 491         { "LOOKUP hosts MATCHING "
 492           "age - 1 > 0s",        -1, -1, 0, 0 },
 493
 494         /* datetime <mul/div> integer is allowed */
 495         { "LOOKUP hosts MATCHING "
 496           "age || 1 > 0s",       -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, 0, 0 },
 503         { "LOOKUP hosts MATCHING "
 504           "name / 1 = ''",       -1, -1, 0, 0 },
 505         { "LOOKUP hosts MATCHING "
 506           "name % 1 = ''",       -1, -1, 0, 0 },
 507         { "LOOKUP hosts MATCHING "
 508           "(name % 1) + 1 = ''", -1, -1, 0, 0 },
 509         { "LOOKUP hosts MATCHING "
 510           "1 + (name % 1) = ''", -1, -1, 0, 0 },
 511         { "LOOKUP hosts MATCHING "
 512           "'' = 1 + (name % 1)", -1, -1, 0, 0 },
 513         { "LOOKUP hosts MATCHING "
 514           "age > 0 AND "
 515           "age = 0s",            -1, -1, 0, 0 },
 516         { "LOOKUP hosts MATCHING "
 517           "age = 0s AND "
 518           "age > 0",             -1, -1, 0, 0 },
 519         { "LOOKUP services MATCHING "
 520           "host.name > 0",       -1, -1, 0, 0 },
 521         { "LOOKUP services MATCHING "
 522           "backend > 'b'",       -1, -1, 0, 0 },
 523         { "LOOKUP services MATCHING "
 524           "'b' > backend",       -1, -1, 0, 0 },
 525         { "LOOKUP services MATCHING "
 526           "attribute['a'] > backend",
 527                                  -1, -1, 0, 0 },
 528         { "LOOKUP services MATCHING "
 529           "backend > attribute['a']",
 530                                  -1, -1, 0, 0 },
 531         { "LOOKUP services MATCHING "
 532           "host.name + 1 = ''",  -1, -1, 0, 0 },
 533         { "LOOKUP hosts MATCHING "
 534           "'a' + 1 IN 'b'",      -1, -1, 0, 0 },
 535         { "LOOKUP hosts MATCHING "
 536           "'a' IN 'b' - 1",      -1, -1, 0, 0 },
 537         { "LOOKUP hosts MATCHING "
 538           "name + 1 IN 'b'",     -1, -1, 0, 0 },
 539         { "LOOKUP hosts MATCHING "
 540           "'a' IN name - 1",     -1, -1, 0, 0 },
 541         { "LOOKUP hosts MATCHING "
 542           "'b' IN 'abc'",        -1, -1, 0, 0 },
 543         { "LOOKUP hosts MATCHING "
 544           "1 IN age",            -1, -1, 0, 0 },
 545         { "LOOKUP hosts MATCHING "
 546           "name =~ 'a' + 1",     -1, -1, 0, 0 },
 547         { "LOOKUP hosts MATCHING "
 548           "name =~ name + 1",    -1, -1, 0, 0 },
 549         { "LOOKUP hosts MATCHING "
 550           "name + 1 =~ 'a'",     -1, -1, 0, 0 },
 551         { "LOOKUP hosts MATCHING "
 552           "name =~ 1",           -1, -1, 0, 0 },
 553         { "LOOKUP hosts MATCHING "
 554           "name + 1 IS NULL",    -1, -1, 0, 0 },
 555         { "LOOKUP hosts FILTER "
 556           "name + 1 IS NULL",    -1, -1, 0, 0 },
 557         { "LOOKUP hosts MATCHING "
 558           "name + 1 IS TRUE",    -1, -1, 0, 0 },
 559         { "LOOKUP hosts FILTER "
 560           "name + 1 IS TRUE",    -1, -1, 0, 0 },
 561         { "LOOKUP hosts MATCHING "
 562           "name + 1 IS FALSE",   -1, -1, 0, 0 },
 563         { "LOOKUP hosts FILTER "
 564           "name + 1 IS FALSE",   -1, -1, 0, 0 },
 565
 566         /* invalid iterators */
 567         { "LOOKUP hosts MATCHING "
 568           "ANY backend !~ backend",
 569                                 -1,  -1, 0, 0 },
 570         { "LOOKUP hosts MATCHING "
 571           "ANY backend = 1",    -1,  -1, 0, 0 },
 572         { "LOOKUP hosts MATCHING "
 573           "ANY 'patt' =~ 'p'",  -1,  -1, 0, 0 },
 574         { "LOOKUP hosts MATCHING "
 575           "ALL 1 || '2' < '3'", -1,  -1, 0, 0 },
 576         { "LOOKUP hosts MATCHING "
 577           "ALL name =~ 'a'",    -1,  -1, 0, 0 },
 578         /* this could work in theory but is not supported atm */
 579         { "LOOKUP hosts MATCHING "
 580           "ANY backend || 'a' = 'b'",
 581                                 -1,  -1, 0, 0 },
 582
 583         /* invalid LIST commands */
 584         { "LIST",                -1, -1, 0, 0 },
 585         { "LIST foo",            -1, -1, 0, 0 },
 586         { "LIST hosts MATCHING "
 587           "name = 'host'",       -1, -1, 0, 0 },
 588         { "LIST foo FILTER "
 589           "age > 60s",           -1, -1, 0, 0 },
 590
 591         /* invalid FETCH commands */
 592         { "FETCH host 'host' MATCHING "
 593           "name = 'host'",       -1, -1, 0, 0 },
 594         { "FETCH service 'host'",-1, -1, 0, 0 },
 595         { "FETCH metric 'host'", -1, -1, 0, 0 },
 596         { "FETCH host "
 597           "'host'.'localhost'",  -1, -1, 0, 0 },
 598         { "FETCH foo 'host'",    -1, -1, 0, 0 },
 599         { "FETCH foo 'host' FILTER "
 600           "age > 60s",           -1, -1, 0, 0 },
 601
 602         /* invalid LOOKUP commands */
 603         { "LOOKUP foo",          -1, -1, 0, 0 },
 604         { "LOOKUP foo MATCHING "
 605           "name = 'host'",       -1, -1, 0, 0 },
 606         { "LOOKUP foo FILTER "
 607           "age > 60s",           -1, -1, 0, 0 },
 608         { "LOOKUP foo MATCHING "
 609           "name = 'host' FILTER "
 610           "age > 60s",           -1, -1, 0, 0 },
 611         { "LOOKUP hosts MATCHING "
 612           "attribute['foo'] <= "
 613           "f || 'oo'",           -1, -1, 0, 0 },
 614         { "LOOKUP hosts MATCHING "
 615           "attribute['foo'] <= "
 616           "'f' || oo",           -1, -1, 0, 0 },
 617         { "LOOKUP hosts MATCHING "
 618           "ANY host.name = 'host'",   -1, -1, 0, 0 },
 619         { "LOOKUP hosts MATCHING "
 620           "ANY service.name > 1",     -1, -1, 0, 0 },
 621         { "LOOKUP hosts MATCHING "
 622           "service.name = 's'",       -1, -1, 0, 0 },
 623         { "LOOKUP services MATCHING "
 624           "ANY host.name = 'host'",   -1, -1, 0, 0 },
 625         { "LOOKUP services MATCHING "
 626           "ANY service.name = 'svc'", -1, -1, 0, 0 },
 627         { "LOOKUP services MATCHING "
 628           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
 629         { "LOOKUP services MATCHING "
 630           "metric.name = 'm'",        -1, -1, 0, 0 },
 631         { "LOOKUP metrics MATCHING "
 632           "ANY host.name = 'host'",   -1, -1, 0, 0 },
 633         { "LOOKUP metrics MATCHING "
 634           "ANY service.name = 'svc'", -1, -1, 0, 0 },
 635         { "LOOKUP metrics MATCHING "
 636           "ANY metric.name = 'm'",    -1, -1, 0, 0 },
 637         { "LOOKUP metrics MATCHING "
 638           "service.name = 'm'",       -1, -1, 0, 0 },
 639
 640         /* invalid STORE commands */
 641         { "STORE host "
 642           "'obj'.'host'",        -1, -1, 0, 0 },
 643         { "STORE host attribute "
 644           ".'key' 123",          -1, -1, 0, 0 },
 645         { "STORE host attribute "
 646           "'o'.'h'.'key' 123",   -1, -1, 0, 0 },
 647         { "STORE service 'svc'", -1, -1, 0, 0 },
 648         { "STORE service "
 649           "'host'.'svc' "
 650           "STORE 'typ' 'id' "
 651           "LAST UPDATE "
 652           "2015-02-01",          -1, -1, 0, 0 },
 653         { "STORE service attribute "
 654           "'svc'.'key' 123",     -1, -1, 0, 0 },
 655         { "STORE metric 'm'",    -1, -1, 0, 0 },
 656         { "STORE metric "
 657           "'host'.'metric' "
 658           "STORE 'typ'.'id' "
 659           "LAST UPDATE "
 660           "2015-02-01",          -1, -1, 0, 0 },
 661         { "STORE metric attribute "
 662           "'metric'.'key' 123",  -1, -1, 0, 0 },
 663 };
 664
 665 START_TEST(test_parse)
 666 {
 667         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
 668         sdb_llist_t *check;
 669         sdb_ast_node_t *node;
 670         sdb_store_query_t *q;
 671         _Bool ok;
 672
 673         check = sdb_parser_parse(parse_data[_i].query,
 674                         parse_data[_i].len, errbuf);
 675         if (parse_data[_i].expected < 0)
 676                 ok = check == 0;
 677         else
 678                 ok = sdb_llist_len(check) == (size_t)parse_data[_i].expected;
 679
 680         fail_unless(ok, "sdb_parser_parse(%s) = %p (len: %zu); expected: %d "
 681                         "(parse error: %s)", parse_data[_i].query, check,
 682                         sdb_llist_len(check), parse_data[_i].expected,
 683                         sdb_strbuf_string(errbuf));
 684
 685         if (! check) {
 686                 sdb_strbuf_destroy(errbuf);
 687                 return;
 688         }
 689
 690         if ((! parse_data[_i].expected_type)
 691                         || (parse_data[_i].expected <= 0)) {
 692                 sdb_llist_destroy(check);
 693                 sdb_strbuf_destroy(errbuf);
 694                 return;
 695         }
 696
 697         node = SDB_AST_NODE(sdb_llist_get(check, 0));
 698         fail_unless(node->type == parse_data[_i].expected_type,
 699                         "sdb_parser_parse(%s)->type = %i; expected: %d",
 700                         parse_data[_i].query, node->type,
 701                         parse_data[_i].expected_type);
 702
 703         if (node->type == SDB_AST_TYPE_FETCH) {
 704                 sdb_ast_fetch_t *f = SDB_AST_FETCH(node);
 705                 fail_unless(f->obj_type == parse_data[_i].expected_extra,
 706                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
 707                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(f->obj_type),
 708                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
 709         }
 710         else if (node->type == SDB_AST_TYPE_LIST) {
 711                 sdb_ast_list_t *l = SDB_AST_LIST(node);
 712                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
 713                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
 714                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
 715                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
 716         }
 717         else if (node->type == SDB_AST_TYPE_LOOKUP) {
 718                 sdb_ast_lookup_t *l = SDB_AST_LOOKUP(node);
 719                 fail_unless(l->obj_type == parse_data[_i].expected_extra,
 720                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
 721                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(l->obj_type),
 722                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
 723         }
 724         else if (node->type == SDB_AST_TYPE_STORE) {
 725                 sdb_ast_store_t *s = SDB_AST_STORE(node);
 726                 fail_unless(s->obj_type == parse_data[_i].expected_extra,
 727                                 "sdb_parser_parse(%s)->obj_type = %s; expected: %s",
 728                                 parse_data[_i].query, SDB_STORE_TYPE_TO_NAME(s->obj_type),
 729                                 SDB_STORE_TYPE_TO_NAME(parse_data[_i].expected_extra));
 730         }
 731
 732         /* TODO: this should move into front-end specific tests */
 733         q = sdb_store_query_prepare(node);
 734         fail_unless(q != NULL,
 735                         "sdb_store_query_prepare(AST<%s>) = NULL; expected: <query>",
 736                         parse_data[_i].query);
 737
 738         sdb_object_deref(SDB_OBJ(node));
 739         sdb_object_deref(SDB_OBJ(q));
 740         sdb_llist_destroy(check);
 741         sdb_strbuf_destroy(errbuf);
 742 }
 743 END_TEST
 744
 745 struct {
 746         int context;
 747         const char *expr;
 748         int len;
 749         int expected;
 750 } parse_conditional_data[] = {
 751         /* empty expressions */
 752         { SDB_HOST, NULL,                           -1, -1 },
 753         { SDB_HOST, "",                             -1, -1 },
 754
 755         /* match hosts by name */
 756         { SDB_HOST, "name < 'localhost'",           -1,  SDB_AST_LT },
 757         { SDB_HOST, "name <= 'localhost'",          -1,  SDB_AST_LE },
 758         { SDB_HOST, "name = 'localhost'",           -1,  SDB_AST_EQ },
 759         { SDB_HOST, "name != 'localhost'",          -1,  SDB_AST_NE },
 760         { SDB_HOST, "name >= 'localhost'",          -1,  SDB_AST_GE },
 761         { SDB_HOST, "name > 'localhost'",           -1,  SDB_AST_GT },
 762         { SDB_HOST, "name =~ 'host'",               -1,  SDB_AST_REGEX },
 763         { SDB_HOST, "name !~ 'host'",               -1,  SDB_AST_NREGEX },
 764         { SDB_HOST, "name = 'localhost' -- foo",    -1,  SDB_AST_EQ },
 765         { SDB_HOST, "name = 'host' <garbage>",      13,  SDB_AST_EQ },
 766         { SDB_HOST, "name &^ 'localhost'",          -1,  -1 },
 767         /* match by backend */
 768         { SDB_HOST, "ANY backend < 'be'",           -1,  SDB_AST_ANY },
 769         { SDB_HOST, "ANY backend <= 'be'",          -1,  SDB_AST_ANY },
 770         { SDB_HOST, "ANY backend = 'be'",           -1,  SDB_AST_ANY },
 771         { SDB_HOST, "ANY backend != 'be'",          -1,  SDB_AST_ANY },
 772         { SDB_HOST, "ANY backend >= 'be'",          -1,  SDB_AST_ANY },
 773         { SDB_HOST, "ANY backend > 'be'",           -1,  SDB_AST_ANY },
 774         { SDB_HOST, "ALL backend < 'be'",           -1,  SDB_AST_ALL },
 775         { SDB_HOST, "ALL backend <= 'be'",          -1,  SDB_AST_ALL },
 776         { SDB_HOST, "ALL backend = 'be'",           -1,  SDB_AST_ALL },
 777         { SDB_HOST, "ALL backend != 'be'",          -1,  SDB_AST_ALL },
 778         { SDB_HOST, "ALL backend >= 'be'",          -1,  SDB_AST_ALL },
 779         { SDB_HOST, "ALL backend > 'be'",           -1,  SDB_AST_ALL },
 780         { SDB_HOST, "ANY backend &^ 'be'",          -1,  -1 },
 781         /* match hosts by service */
 782         { SDB_HOST, "ANY service.name < 'name'",         -1,  SDB_AST_ANY },
 783         { SDB_HOST, "ANY service.name <= 'name'",        -1,  SDB_AST_ANY },
 784         { SDB_HOST, "ANY service.name = 'name'",         -1,  SDB_AST_ANY },
 785         { SDB_HOST, "ANY service.name != 'name'",        -1,  SDB_AST_ANY },
 786         { SDB_HOST, "ANY service.name >= 'name'",        -1,  SDB_AST_ANY },
 787         { SDB_HOST, "ANY service.name > 'name'",         -1,  SDB_AST_ANY },
 788         { SDB_HOST, "ANY service.name =~ 'pattern'",     -1,  SDB_AST_ANY },
 789         { SDB_HOST, "ANY service.name !~ 'pattern'",     -1,  SDB_AST_ANY },
 790         { SDB_HOST, "ANY service.name &^ 'name'",        -1,  -1 },
 791         { SDB_HOST, "ALL service.name < 'name'",         -1,  SDB_AST_ALL },
 792         { SDB_HOST, "ALL service.name <= 'name'",        -1,  SDB_AST_ALL },
 793         { SDB_HOST, "ALL service.name = 'name'",         -1,  SDB_AST_ALL },
 794         { SDB_HOST, "ALL service.name != 'name'",        -1,  SDB_AST_ALL },
 795         { SDB_HOST, "ALL service.name >= 'name'",        -1,  SDB_AST_ALL },
 796         { SDB_HOST, "ALL service.name > 'name'",         -1,  SDB_AST_ALL },
 797         { SDB_HOST, "ALL service.name =~ 'pattern'",     -1,  SDB_AST_ALL },
 798         { SDB_HOST, "ALL service.name !~ 'pattern'",     -1,  SDB_AST_ALL },
 799         { SDB_HOST, "ALL service.name &^ 'name'",        -1,  -1 },
 800         { SDB_HOST, "ANY service < 'name'",              -1,  -1 },
 801         /* match hosts by metric */
 802         { SDB_HOST, "ANY metric.name < 'name'",          -1,  SDB_AST_ANY },
 803         { SDB_HOST, "ANY metric.name <= 'name'",         -1,  SDB_AST_ANY },
 804         { SDB_HOST, "ANY metric.name = 'name'",          -1,  SDB_AST_ANY },
 805         { SDB_HOST, "ANY metric.name != 'name'",         -1,  SDB_AST_ANY },
 806         { SDB_HOST, "ANY metric.name >= 'name'",         -1,  SDB_AST_ANY },
 807         { SDB_HOST, "ANY metric.name > 'name'",          -1,  SDB_AST_ANY },
 808         { SDB_HOST, "ANY metric.name =~ 'pattern'",      -1,  SDB_AST_ANY },
 809         { SDB_HOST, "ANY metric.name !~ 'pattern'",      -1,  SDB_AST_ANY },
 810         { SDB_HOST, "ANY metric.name &^ 'pattern'",      -1,  -1 },
 811         { SDB_HOST, "ALL metric.name < 'name'",          -1,  SDB_AST_ALL },
 812         { SDB_HOST, "ALL metric.name <= 'name'",         -1,  SDB_AST_ALL },
 813         { SDB_HOST, "ALL metric.name = 'name'",          -1,  SDB_AST_ALL },
 814         { SDB_HOST, "ALL metric.name != 'name'",         -1,  SDB_AST_ALL },
 815         { SDB_HOST, "ALL metric.name >= 'name'",         -1,  SDB_AST_ALL },
 816         { SDB_HOST, "ALL metric.name > 'name'",          -1,  SDB_AST_ALL },
 817         { SDB_HOST, "ALL metric.name =~ 'pattern'",      -1,  SDB_AST_ALL },
 818         { SDB_HOST, "ALL metric.name !~ 'pattern'",      -1,  SDB_AST_ALL },
 819         { SDB_HOST, "ALL metric.name &^ 'pattern'",      -1,  -1 },
 820         { SDB_HOST, "ANY metric <= 'name'",              -1,  -1 },
 821         /* match hosts by attribute */
 822         { SDB_HOST, "ANY attribute.name < 'name'",       -1,  SDB_AST_ANY },
 823         { SDB_HOST, "ANY attribute.name <= 'name'",      -1,  SDB_AST_ANY },
 824         { SDB_HOST, "ANY attribute.name = 'name'",       -1,  SDB_AST_ANY },
 825         { SDB_HOST, "ANY attribute.name != 'name'",      -1,  SDB_AST_ANY },
 826         { SDB_HOST, "ANY attribute.name >= 'name'",      -1,  SDB_AST_ANY },
 827         { SDB_HOST, "ANY attribute.name > 'name'",       -1,  SDB_AST_ANY },
 828         { SDB_HOST, "ANY attribute.name =~ 'pattern'",   -1,  SDB_AST_ANY },
 829         { SDB_HOST, "ANY attribute.name !~ 'pattern'",   -1,  SDB_AST_ANY },
 830         { SDB_HOST, "ANY attribute.name &^ 'pattern'",   -1,  -1 },
 831         { SDB_HOST, "ALL attribute.name < 'name'",       -1,  SDB_AST_ALL },
 832         { SDB_HOST, "ALL attribute.name <= 'name'",      -1,  SDB_AST_ALL },
 833         { SDB_HOST, "ALL attribute.name = 'name'",       -1,  SDB_AST_ALL },
 834         { SDB_HOST, "ALL attribute.name != 'name'",      -1,  SDB_AST_ALL },
 835         { SDB_HOST, "ALL attribute.name >= 'name'",      -1,  SDB_AST_ALL },
 836         { SDB_HOST, "ALL attribute.name > 'name'",       -1,  SDB_AST_ALL },
 837         { SDB_HOST, "ALL attribute.name =~ 'pattern'",   -1,  SDB_AST_ALL },
 838         { SDB_HOST, "ALL attribute.name !~ 'pattern'",   -1,  SDB_AST_ALL },
 839         { SDB_HOST, "ALL attribute.name &^ 'pattern'",   -1,  -1 },
 840         { SDB_HOST, "ANY attribute !~ 'pattern'",        -1,  -1 },
 841
 842         /* composite expressions */
 843         { SDB_HOST, "name =~ 'pattern' AND "
 844           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_AND },
 845         { SDB_HOST, "name =~ 'pattern' OR "
 846           "ANY service.name =~ 'pattern'",  -1,  SDB_AST_OR },
 847         { SDB_HOST, "NOT name = 'host'",              -1,  SDB_AST_NOT },
 848         /* numeric expressions */
 849         { SDB_HOST, "attribute['foo'] < 123",         -1,  SDB_AST_LT },
 850         { SDB_HOST, "attribute['foo'] <= 123",        -1,  SDB_AST_LE },
 851         { SDB_HOST, "attribute['foo'] = 123",         -1,  SDB_AST_EQ },
 852         { SDB_HOST, "attribute['foo'] >= 123",        -1,  SDB_AST_GE },
 853         { SDB_HOST, "attribute['foo'] > 123",         -1,  SDB_AST_GT },
 854         /* datetime expressions */
 855         { SDB_HOST, "attribute['foo'] = "
 856           "2014-08-16",                     -1,  SDB_AST_EQ },
 857         { SDB_HOST, "attribute['foo'] = "
 858           "17:23",                          -1,  SDB_AST_EQ },
 859         { SDB_HOST, "attribute['foo'] = "
 860           "17:23:53",                       -1,  SDB_AST_EQ },
 861         { SDB_HOST, "attribute['foo'] = "
 862           "17:23:53.123",                   -1,  SDB_AST_EQ },
 863         { SDB_HOST, "attribute['foo'] = "
 864           "17:23:53.123456789",             -1,  SDB_AST_EQ },
 865         { SDB_HOST, "attribute['foo'] = "
 866           "2014-08-16 17:23",               -1,  SDB_AST_EQ },
 867         { SDB_HOST, "attribute['foo'] = "
 868           "2014-08-16 17:23:53",            -1,  SDB_AST_EQ },
 869         /* NULL / TRUE / FALSE */
 870         { SDB_HOST, "attribute['foo'] IS NULL",       -1,  SDB_AST_ISNULL },
 871         { SDB_HOST, "attribute['foo'] IS NOT NULL",   -1,  SDB_AST_NOT },
 872         { SDB_HOST, "attribute['foo'] IS TRUE",       -1,  SDB_AST_ISTRUE },
 873         { SDB_HOST, "attribute['foo'] IS NOT TRUE",   -1,  SDB_AST_NOT },
 874         { SDB_HOST, "attribute['foo'] IS FALSE",      -1,  SDB_AST_ISFALSE },
 875         { SDB_HOST, "attribute['foo'] IS NOT FALSE",  -1,  SDB_AST_NOT },
 876         /* array expressions */
 877         { SDB_HOST, "backend < ['a']",                -1,  SDB_AST_LT },
 878         { SDB_HOST, "backend <= ['a']",               -1,  SDB_AST_LE },
 879         { SDB_HOST, "backend = ['a']",                -1,  SDB_AST_EQ },
 880         { SDB_HOST, "backend != ['a']",               -1,  SDB_AST_NE },
 881         { SDB_HOST, "backend >= ['a']",               -1,  SDB_AST_GE },
 882         { SDB_HOST, "backend > ['a']",                -1,  SDB_AST_GT },
 883         { SDB_HOST, "backend &^ ['a']",               -1,  -1 },
 884
 885         /* object field comparison */
 886         { SDB_HOST, "name < 'a'",                     -1,  SDB_AST_LT },
 887         { SDB_HOST, "name <= 'a'",                    -1,  SDB_AST_LE },
 888         { SDB_HOST, "name = 'a'",                     -1,  SDB_AST_EQ },
 889         { SDB_HOST, "name != 'a'",                    -1,  SDB_AST_NE },
 890         { SDB_HOST, "name >= 'a'",                    -1,  SDB_AST_GE },
 891         { SDB_HOST, "name > 'a'",                     -1,  SDB_AST_GT },
 892         { SDB_HOST, "last_update < 2014-10-01",       -1,  SDB_AST_LT },
 893         { SDB_HOST, "last_update <= 2014-10-01",      -1,  SDB_AST_LE },
 894         { SDB_HOST, "last_update = 2014-10-01",       -1,  SDB_AST_EQ },
 895         { SDB_HOST, "last_update != 2014-10-01",      -1,  SDB_AST_NE },
 896         { SDB_HOST, "last_update >= 2014-10-01",      -1,  SDB_AST_GE },
 897         { SDB_HOST, "last_update > 2014-10-01",       -1,  SDB_AST_GT },
 898         { SDB_HOST, "Last_Update >= 24D",             -1,  SDB_AST_GE },
 899         { SDB_HOST, "age < 20s",                      -1,  SDB_AST_LT },
 900         { SDB_HOST, "age <= 20s",                     -1,  SDB_AST_LE },
 901         { SDB_HOST, "age = 20s",                      -1,  SDB_AST_EQ },
 902         { SDB_HOST, "age != 20s",                     -1,  SDB_AST_NE },
 903         { SDB_HOST, "age >= 20s",                     -1,  SDB_AST_GE },
 904         { SDB_HOST, "age > 20s",                      -1,  SDB_AST_GT },
 905         { SDB_HOST, "AGE <= 1m",                      -1,  SDB_AST_LE },
 906         { SDB_HOST, "age > 1M",                       -1,  SDB_AST_GT },
 907         { SDB_HOST, "age != 20Y",                     -1,  SDB_AST_NE },
 908         { SDB_HOST, "age <= 2 * interval",            -1,  SDB_AST_LE },
 909         { SDB_HOST, "interval < 20s",                 -1,  SDB_AST_LT },
 910         { SDB_HOST, "interval <= 20s",                -1,  SDB_AST_LE },
 911         { SDB_HOST, "interval = 20s",                 -1,  SDB_AST_EQ },
 912         { SDB_HOST, "interval != 20s",                -1,  SDB_AST_NE },
 913         { SDB_HOST, "interval >= 20s",                -1,  SDB_AST_GE },
 914         { SDB_HOST, "interval > 20s",                 -1,  SDB_AST_GT },
 915         { SDB_HOST, "'be' IN backend",                -1,  SDB_AST_IN },
 916         { SDB_HOST, "'be' NOT IN backend",            -1,  SDB_AST_NOT },
 917         { SDB_HOST, "['a','b'] IN backend",           -1,  SDB_AST_IN },
 918         { SDB_HOST, "['a','b'] NOT IN backend",       -1,  SDB_AST_NOT },
 919         { SDB_METRIC, "timeseries IS TRUE",           -1,  SDB_AST_ISTRUE },
 920         { SDB_METRIC, "timeseries IS FALSE",          -1,  SDB_AST_ISFALSE },
 921         { SDB_METRIC, "timeseries IS NOT TRUE",       -1,  SDB_AST_NOT },
 922         { SDB_METRIC, "timeseries IS NOT FALSE",      -1,  SDB_AST_NOT },
 923         { SDB_METRIC, "timeseries > 0",               -1,  -1 },
 924         { SDB_METRIC, "timeseries = TRUE",            -1,  -1 },
 925         { SDB_METRIC, "timeseries != FALSE",          -1,  -1 },
 926
 927         /* check operator precedence */
 928         { SDB_HOST, "name = 'name' OR "
 929           "ANY service.name = 'name' AND "
 930           "ANY attribute.name = 'name' OR "
 931           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
 932         { SDB_HOST, "name = 'name' AND "
 933           "ANY service.name = 'name' AND "
 934           "ANY attribute.name = 'name' OR "
 935           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
 936         { SDB_HOST, "name = 'name' AND "
 937           "ANY service.name = 'name' OR "
 938           "ANY attribute.name = 'name' AND "
 939           "attribute['foo'] = 'bar'",       -1,  SDB_AST_OR },
 940         { SDB_HOST, "(name = 'name' OR "
 941           "ANY service.name = 'name') AND "
 942           "(ANY attribute.name = 'name' OR "
 943           "attribute['foo'] = 'bar')",      -1,  SDB_AST_AND },
 944         { SDB_HOST, "NOT name = 'name' OR "
 945           "ANY service.name = 'name'",      -1,  SDB_AST_OR },
 946         { SDB_HOST, "NOT name = 'name' OR "
 947           "NOT ANY service.name = 'name'",  -1,  SDB_AST_OR },
 948         { SDB_HOST, "NOT (name = 'name' OR "
 949           "NOT ANY service.name = 'name')", -1,  SDB_AST_NOT },
 950
 951         /* syntax errors */
 952         { SDB_HOST, "LIST hosts",                     -1, -1 },
 953         { SDB_HOST, "foo &^ bar",                     -1, -1 },
 954         { SDB_HOST, "invalid",                        -1, -1 },
 955 };
 956
 957 START_TEST(test_parse_conditional)
 958 {
 959         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
 960         sdb_ast_node_t *node;
 961
 962         node = sdb_parser_parse_conditional(parse_conditional_data[_i].context,
 963                         parse_conditional_data[_i].expr, parse_conditional_data[_i].len, errbuf);
 964
 965         if (parse_conditional_data[_i].expected < 0) {
 966                 fail_unless(node == NULL,
 967                                 "sdb_parser_parse_conditional(%s, %s) = %p; expected: NULL",
 968                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
 969                                 parse_conditional_data[_i].expr, node);
 970                 sdb_object_deref(SDB_OBJ(node));
 971                 sdb_strbuf_destroy(errbuf);
 972                 return;
 973         }
 974
 975         fail_unless(node != NULL, "sdb_parser_parse_conditional(%s, %s) = NULL; "
 976                         "expected: <cond> (parse error: %s)",
 977                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
 978                         parse_conditional_data[_i].expr, sdb_strbuf_string(errbuf));
 979         if (node->type == SDB_AST_TYPE_OPERATOR)
 980                 fail_unless(SDB_AST_OP(node)->kind == parse_conditional_data[_i].expected,
 981                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
 982                                 "expected: %d",
 983                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
 984                                 parse_conditional_data[_i].expr,
 985                                 SDB_AST_OP(node)->kind, parse_conditional_data[_i].expected);
 986         else if (node->type == SDB_AST_TYPE_ITERATOR)
 987                 fail_unless(SDB_AST_ITER(node)->kind == parse_conditional_data[_i].expected,
 988                                 "sdb_parser_parse_conditional(%s, %s) returned conditional of type %d; "
 989                                 "expected: %d",
 990                                 SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
 991                                 parse_conditional_data[_i].expr,
 992                                 SDB_AST_ITER(node)->kind, parse_conditional_data[_i].expected);
 993
 994         fail_unless(node->data_type == -1,
 995                         "sdb_parser_parse_conditional(%s, %s) returned conditional "
 996                         "of data-type %s; expected: %s",
 997                         SDB_STORE_TYPE_TO_NAME(parse_conditional_data[_i].context),
 998                         parse_conditional_data[_i].expr,
 999                         SDB_TYPE_TO_STRING(node->data_type), SDB_TYPE_TO_STRING(-1));
1000
1001         sdb_object_deref(SDB_OBJ(node));
1002         sdb_strbuf_destroy(errbuf);
1003 }
1004 END_TEST
1005
1006 struct {
1007         int context;
1008         const char *expr;
1009         int len;
1010         int expected;
1011         int data_type;
1012 } parse_arith_data[] = {
1013         /* empty expressions */
1014         { SDB_HOST, NULL,                   -1, -1, -1 },
1015         { SDB_HOST, "",                     -1, -1, -1 },
1016
1017         /* constant expressions */
1018         { SDB_HOST, "'localhost'",          -1, SDB_AST_TYPE_CONST, SDB_TYPE_STRING },
1019         { SDB_HOST, "123",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_INTEGER },
1020         { SDB_HOST, "42.3",                 -1, SDB_AST_TYPE_CONST, SDB_TYPE_DECIMAL },
1021         { SDB_HOST, "2014-08-16",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1022         { SDB_HOST, "17:23",                -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1023         { SDB_HOST, "17:23:53",             -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1024         { SDB_HOST, "17:23:53.123",         -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1025         { SDB_HOST, "17:23:53.123456789",   -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1026         { SDB_HOST, "2014-08-16 17:23",     -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1027         { SDB_HOST, "2014-08-16 17:23:53",  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1028         { SDB_HOST, "10s",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1029         { SDB_HOST, "60m",                  -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1030         { SDB_HOST, "10Y 24D 1h",           -1, SDB_AST_TYPE_CONST, SDB_TYPE_DATETIME },
1031
1032         /* TODO: the analyzer and/or optimizer should turn these into constants */
1033         { SDB_HOST, "123 + 456",            -1, SDB_AST_ADD, SDB_TYPE_INTEGER },
1034         { SDB_HOST, "'foo' || 'bar'",       -1, SDB_AST_CONCAT, SDB_TYPE_STRING },
1035         { SDB_HOST, "456 - 123",            -1, SDB_AST_SUB, SDB_TYPE_INTEGER },
1036         { SDB_HOST, "1.2 * 3.4",            -1, SDB_AST_MUL, SDB_TYPE_DECIMAL },
1037         { SDB_HOST, "1.2 / 3.4",            -1, SDB_AST_DIV, SDB_TYPE_DECIMAL },
1038         { SDB_HOST, "5 % 2",                -1, SDB_AST_MOD, SDB_TYPE_INTEGER },
1039
1040         /* queryable fields */
1041         { SDB_HOST, "last_update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1042         { SDB_HOST, "AGE",                  -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1043         { SDB_HOST, "interval",             -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1044         { SDB_HOST, "Last_Update",          -1, SDB_AST_TYPE_VALUE, SDB_TYPE_DATETIME },
1045         { SDB_HOST, "backend",              -1, SDB_AST_TYPE_VALUE, SDB_TYPE_ARRAY | SDB_TYPE_STRING },
1046
1047         /* attributes */
1048         { SDB_HOST, "attribute['foo']",     -1, SDB_AST_TYPE_VALUE, -1 },
1049
1050         /* arithmetic expressions */
1051         { SDB_HOST, "age + age",            -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1052         { SDB_HOST, "age - age",            -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1053         { SDB_HOST, "age * age",            -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1054         { SDB_HOST, "age / age",            -1, SDB_AST_DIV, SDB_TYPE_DATETIME },
1055         { SDB_HOST, "age \% age",           -1, SDB_AST_MOD, SDB_TYPE_DATETIME },
1056
1057         /* operator precedence */
1058         { SDB_HOST, "age + age * age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1059         { SDB_HOST, "age * age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1060         { SDB_HOST, "age + age - age",      -1, SDB_AST_SUB, SDB_TYPE_DATETIME },
1061         { SDB_HOST, "age - age + age",      -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1062         { SDB_HOST, "(age + age) * age",    -1, SDB_AST_MUL, SDB_TYPE_DATETIME },
1063         { SDB_HOST, "age + (age * age)",    -1, SDB_AST_ADD, SDB_TYPE_DATETIME },
1064
1065         /* boolean expressions */
1066         { SDB_METRIC, "timeseries + 1",               -1, -1, -1 },
1067         { SDB_METRIC, "timeseries - 1",               -1, -1, -1 },
1068         { SDB_METRIC, "timeseries * 1",               -1, -1, -1 },
1069         { SDB_METRIC, "timeseries / 1",               -1, -1, -1 },
1070         { SDB_METRIC, "timeseries \% 1",              -1, -1, -1 },
1071         { SDB_METRIC, "timeseries CONCAT 1",          -1, -1, -1 },
1072         { SDB_METRIC, "timeseries + timeseries",      -1, -1, -1 },
1073         { SDB_METRIC, "timeseries - timeseries",      -1, -1, -1 },
1074         { SDB_METRIC, "timeseries * timeseries",      -1, -1, -1 },
1075         { SDB_METRIC, "timeseries / timeseries",      -1, -1, -1 },
1076         { SDB_METRIC, "timeseries \% timeseries",     -1, -1, -1 },
1077         { SDB_METRIC, "timeseries CONCAT timeseries", -1, -1, -1 },
1078
1079         /* syntax errors */
1080         { SDB_HOST, "LIST",                 -1, -1, -1 },
1081         { SDB_HOST, "foo &^ bar",           -1, -1, -1 },
1082         { SDB_HOST, "invalid",              -1, -1, -1 },
1083 };
1084
1085 START_TEST(test_parse_arith)
1086 {
1087         sdb_strbuf_t *errbuf = sdb_strbuf_create(64);
1088         sdb_ast_node_t *node;
1089
1090         node = sdb_parser_parse_arith(parse_arith_data[_i].context,
1091                         parse_arith_data[_i].expr, parse_arith_data[_i].len, errbuf);
1092
1093         if (parse_arith_data[_i].expected < 0) {
1094                 fail_unless(node == NULL,
1095                                 "sdb_parser_parse_arith(%s, %s) = %p; expected: NULL",
1096                                 SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1097                                 parse_arith_data[_i].expr, node);
1098                 sdb_object_deref(SDB_OBJ(node));
1099                 sdb_strbuf_destroy(errbuf);
1100                 return;
1101         }
1102
1103         fail_unless(node != NULL, "sdb_parser_parse_arith(%s, %s) = NULL; "
1104                         "expected: <expr> (parse error: %s)",
1105                         SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1106                         parse_arith_data[_i].expr, sdb_strbuf_string(errbuf));
1107         if (node->type == SDB_AST_TYPE_OPERATOR)
1108                 fail_unless(SDB_AST_OP(node)->kind == parse_arith_data[_i].expected,
1109                                 "sdb_parser_parse_arith(%s, %s) returned expression of type %d; "
1110                                 "expected: %d", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1111                                 parse_arith_data[_i].expr, SDB_AST_OP(node)->kind,
1112                                 parse_arith_data[_i].expected);
1113         else
1114                 fail_unless(node->type == parse_arith_data[_i].expected,
1115                                 "sdb_parser_parse_arith(%s, %s) returned expression of type %d; "
1116                                 "expected: %d", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1117                                 parse_arith_data[_i].expr, node->type,
1118                                 parse_arith_data[_i].expected);
1119
1120         fail_unless(node->data_type == parse_arith_data[_i].data_type,
1121                         "sdb_parser_parse_arith(%s, %s) returned expression of data-type %s; "
1122                         "expected: %s", SDB_STORE_TYPE_TO_NAME(parse_arith_data[_i].context),
1123                         parse_arith_data[_i].expr, SDB_TYPE_TO_STRING(node->data_type),
1124                         SDB_TYPE_TO_STRING(parse_arith_data[_i].data_type));
1125
1126         sdb_object_deref(SDB_OBJ(node));
1127         sdb_strbuf_destroy(errbuf);
1128 }
1129 END_TEST
1130
1131 TEST_MAIN("parser::parser")
1132 {
1133         TCase *tc = tcase_create("core");
1134         TC_ADD_LOOP_TEST(tc, parse);
1135         TC_ADD_LOOP_TEST(tc, parse_conditional);
1136         TC_ADD_LOOP_TEST(tc, parse_arith);
1137         ADD_TCASE(tc);
1138 }
1139 TEST_MAIN_END
1140
1141 /* vim: set tw=78 sw=4 ts=4 noexpandtab : */
1142