diff options
Diffstat (limited to 'qpid/cpp/src/tests/Qmf2.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/Qmf2.cpp | 320 |
1 files changed, 320 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/Qmf2.cpp b/qpid/cpp/src/tests/Qmf2.cpp new file mode 100644 index 0000000000..66c774accd --- /dev/null +++ b/qpid/cpp/src/tests/Qmf2.cpp @@ -0,0 +1,320 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ +#include <iostream> +#include "qpid/types/Variant.h" +#include "qmf/QueryImpl.h" +#include "qmf/SchemaImpl.h" +#include "qmf/exceptions.h" + +#include "unit_test.h" + +using namespace qpid::types; +using namespace qmf; + +namespace qpid { +namespace tests { + +QPID_AUTO_TEST_SUITE(Qmf2Suite) + +QPID_AUTO_TEST_CASE(testQuery) +{ + Query query(QUERY_OBJECT, "class_name", "package_name", "[and, [eq, name, [quote, smith]], [lt, age, [quote, 27]]]"); + Query newQuery(new QueryImpl(QueryImplAccess::get(query).asMap())); + + BOOST_CHECK_EQUAL(newQuery.getTarget(), QUERY_OBJECT); + BOOST_CHECK_EQUAL(newQuery.getSchemaId().getName(), "class_name"); + BOOST_CHECK_EQUAL(newQuery.getSchemaId().getPackageName(), "package_name"); + + Variant::List pred(newQuery.getPredicate()); + BOOST_CHECK_EQUAL(pred.size(), size_t(3)); + + Variant::List::iterator iter(pred.begin()); + BOOST_CHECK_EQUAL(iter->asString(), "and"); + iter++; + BOOST_CHECK_EQUAL(iter->getType(), VAR_LIST); + iter++; + BOOST_CHECK_EQUAL(iter->getType(), VAR_LIST); + iter = iter->asList().begin(); + BOOST_CHECK_EQUAL(iter->asString(), "lt"); + iter++; + BOOST_CHECK_EQUAL(iter->asString(), "age"); + iter++; + BOOST_CHECK_EQUAL(iter->getType(), VAR_LIST); + iter = iter->asList().begin(); + BOOST_CHECK_EQUAL(iter->asString(), "quote"); + iter++; + BOOST_CHECK_EQUAL(iter->asUint32(), uint32_t(27)); + + Query query2(QUERY_OBJECT_ID); + Query newQuery2(new QueryImpl(QueryImplAccess::get(query2).asMap())); + BOOST_CHECK_EQUAL(newQuery2.getTarget(), QUERY_OBJECT_ID); + + Query query3(QUERY_SCHEMA); + Query newQuery3(new QueryImpl(QueryImplAccess::get(query3).asMap())); + BOOST_CHECK_EQUAL(newQuery3.getTarget(), QUERY_SCHEMA); + + Query query4(QUERY_SCHEMA_ID); + Query newQuery4(new QueryImpl(QueryImplAccess::get(query4).asMap())); + BOOST_CHECK_EQUAL(newQuery4.getTarget(), QUERY_SCHEMA_ID); + + DataAddr addr("name", "agent_name", 34); + Query query5(addr); + Query newQuery5(new QueryImpl(QueryImplAccess::get(query5).asMap())); + BOOST_CHECK_EQUAL(newQuery5.getTarget(), QUERY_OBJECT); + BOOST_CHECK_EQUAL(newQuery5.getDataAddr().getName(), "name"); + BOOST_CHECK_EQUAL(newQuery5.getDataAddr().getAgentName(), "agent_name"); + BOOST_CHECK_EQUAL(newQuery5.getDataAddr().getAgentEpoch(), uint32_t(34)); +} + +QPID_AUTO_TEST_CASE(testQueryPredicateErrors) +{ + Query query; + Variant::Map map; + + BOOST_CHECK_THROW(Query(QUERY_OBJECT, "INVALID"), QmfException); + query = Query(QUERY_OBJECT, "[unknown, one, two]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[eq, first]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[exists]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[eq, first, [quote, 1, 2, 3]]]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[eq, first, [unexpected, 3]]]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[eq, first, {}]]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[eq, first, second, third]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); + + query = Query(QUERY_OBJECT, "[and, first, second, third]"); + BOOST_CHECK_THROW(query.matchesPredicate(map), QmfException); +} + +QPID_AUTO_TEST_CASE(testQueryPredicate) +{ + Query query; + Variant::Map map; + + map["forty"] = 40; + map["fifty"] = 50; + map["minus_ten"] = -10; + map["pos_float"] = 100.05; + map["neg_float"] = -1000.33; + map["name"] = "jones"; + map["bool_t"] = true; + map["bool_f"] = false; + + BOOST_CHECK_THROW(Query(QUERY_OBJECT, "INVALID"), QmfException); + + query = Query(QUERY_OBJECT); + BOOST_CHECK_EQUAL(query.matchesPredicate(Variant::Map()), true); + + query = Query(QUERY_OBJECT, "[eq, forty, [quote, 40]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[eq, forty, [quote, 41]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[le, forty, fifty]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[and, [eq, forty, [quote, 40]], [eq, name, [quote, jones]]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[and, [eq, forty, [quote, 40]], [eq, name, [quote, smith]]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[or, [eq, forty, [quote, 40]], [eq, name, [quote, smith]]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[or, [eq, forty, [quote, 41]], [eq, name, [quote, smith]]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[not, [le, forty, [quote, 40]]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[le, forty, [quote, 40]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[ge, forty, [quote, 40]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[lt, forty, [quote, 45]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[lt, [quote, 45], forty]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[gt, forty, [quote, 45]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[gt, [quote, 45], forty]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[eq, bool_t, [quote, True]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[eq, bool_t, [quote, False]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[eq, bool_f, [quote, True]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[eq, bool_f, [quote, False]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[eq, minus_ten, [quote, -10]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[lt, minus_ten, [quote, -20]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[lt, [quote, -20], minus_ten]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[exists, name]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); + + query = Query(QUERY_OBJECT, "[exists, nonexfield]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), false); + + query = Query(QUERY_OBJECT, "[eq, pos_float, [quote, 100.05]]"); + BOOST_CHECK_EQUAL(query.matchesPredicate(map), true); +} + +QPID_AUTO_TEST_CASE(testSchema) +{ + Schema in(SCHEMA_TYPE_DATA, "package", "class"); + in.addProperty(SchemaProperty("prop1", SCHEMA_DATA_BOOL, "{desc:'Property One'}")); + in.addProperty(SchemaProperty("prop2", SCHEMA_DATA_INT, "{desc:'Property Two',unit:'Furlong'}")); + in.addProperty(SchemaProperty("prop3", SCHEMA_DATA_STRING, "{desc:'Property Three'}")); + + SchemaMethod method1("method1", "{desc:'Method One'}"); + method1.addArgument(SchemaProperty("arg1", SCHEMA_DATA_BOOL, "{desc:'Argument One',dir:IN}")); + method1.addArgument(SchemaProperty("arg2", SCHEMA_DATA_INT, "{desc:'Argument Two',dir:OUT}")); + method1.addArgument(SchemaProperty("arg3", SCHEMA_DATA_FLOAT, "{desc:'Argument Three',dir:INOUT}")); + in.addMethod(method1); + + SchemaMethod method2("method2", "{desc:'Method Two'}"); + method2.addArgument(SchemaProperty("arg21", SCHEMA_DATA_BOOL, "{desc:'Argument One',dir:IN}")); + method2.addArgument(SchemaProperty("arg22", SCHEMA_DATA_INT, "{desc:'Argument Two',dir:OUT}")); + method2.addArgument(SchemaProperty("arg23", SCHEMA_DATA_FLOAT, "{desc:'Argument Three',dir:INOUT}")); + in.addMethod(method2); + + BOOST_CHECK(!in.isFinalized()); + in.finalize(); + BOOST_CHECK(in.isFinalized()); + + Variant::Map map(SchemaImplAccess::get(in).asMap()); + Schema out(new SchemaImpl(map)); + + BOOST_CHECK(out.isFinalized()); + BOOST_CHECK_EQUAL(out.getSchemaId().getType(), SCHEMA_TYPE_DATA); + BOOST_CHECK_EQUAL(out.getSchemaId().getPackageName(), "package"); + BOOST_CHECK_EQUAL(out.getSchemaId().getName(), "class"); + BOOST_CHECK_EQUAL(out.getSchemaId().getHash(), in.getSchemaId().getHash()); + + BOOST_CHECK_EQUAL(out.getPropertyCount(), uint32_t(3)); + SchemaProperty prop; + + prop = out.getProperty(0); + BOOST_CHECK_EQUAL(prop.getName(), "prop1"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_BOOL); + BOOST_CHECK_EQUAL(prop.getDesc(), "Property One"); + + prop = out.getProperty(1); + BOOST_CHECK_EQUAL(prop.getName(), "prop2"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_INT); + BOOST_CHECK_EQUAL(prop.getDesc(), "Property Two"); + BOOST_CHECK_EQUAL(prop.getUnit(), "Furlong"); + BOOST_CHECK(!prop.isIndex()); + + prop = out.getProperty(2); + BOOST_CHECK_EQUAL(prop.getName(), "prop3"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_STRING); + BOOST_CHECK_EQUAL(prop.getDesc(), "Property Three"); + + BOOST_CHECK_THROW(out.getProperty(3), QmfException); + + BOOST_CHECK_EQUAL(out.getMethodCount(), uint32_t(2)); + SchemaMethod method; + + method = out.getMethod(0); + BOOST_CHECK_EQUAL(method.getName(), "method1"); + BOOST_CHECK_EQUAL(method.getDesc(), "Method One"); + BOOST_CHECK_EQUAL(method.getArgumentCount(), uint32_t(3)); + + prop = method.getArgument(0); + BOOST_CHECK_EQUAL(prop.getName(), "arg1"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_BOOL); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument One"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_IN); + + prop = method.getArgument(1); + BOOST_CHECK_EQUAL(prop.getName(), "arg2"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_INT); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument Two"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_OUT); + + prop = method.getArgument(2); + BOOST_CHECK_EQUAL(prop.getName(), "arg3"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_FLOAT); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument Three"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_IN_OUT); + + BOOST_CHECK_THROW(method.getArgument(3), QmfException); + + method = out.getMethod(1); + BOOST_CHECK_EQUAL(method.getName(), "method2"); + BOOST_CHECK_EQUAL(method.getDesc(), "Method Two"); + BOOST_CHECK_EQUAL(method.getArgumentCount(), uint32_t(3)); + + prop = method.getArgument(0); + BOOST_CHECK_EQUAL(prop.getName(), "arg21"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_BOOL); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument One"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_IN); + + prop = method.getArgument(1); + BOOST_CHECK_EQUAL(prop.getName(), "arg22"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_INT); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument Two"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_OUT); + + prop = method.getArgument(2); + BOOST_CHECK_EQUAL(prop.getName(), "arg23"); + BOOST_CHECK_EQUAL(prop.getType(), SCHEMA_DATA_FLOAT); + BOOST_CHECK_EQUAL(prop.getDesc(), "Argument Three"); + BOOST_CHECK_EQUAL(prop.getDirection(), DIR_IN_OUT); + + BOOST_CHECK_THROW(method.getArgument(3), QmfException); +} + +QPID_AUTO_TEST_SUITE_END() + +}} // namespace qpid::tests |