/** * Copyright (C) 2012 10gen Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the GNU Affero General Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #include #include #include #include "mongo/bson/bson_field.h" #include "mongo/db/field_parser.h" #include "mongo/db/jsobj.h" #include "mongo/unittest/unittest.h" #include "mongo/util/time_support.h" namespace { using mongo::BSONArray; using mongo::BSONField; using mongo::BSONObj; using mongo::BSONObjBuilder; using mongo::Date_t; using mongo::FieldParser; using mongo::OID; using std::string; using std::vector; using std::map; class ExtractionFixture: public mongo::unittest::Test { protected: BSONObj doc; bool valBool; BSONArray valArray; BSONObj valObj; Date_t valDate; string valString; OID valOID; long long valLong; static BSONField aBool; static BSONField anArray; static BSONField anObj; static BSONField aDate; static BSONField aString; static BSONField anOID; static BSONField aLong; void setUp() { valBool = true; valArray = BSON_ARRAY(1 << 2 << 3); valObj = BSON("a" << 1); valDate = 1ULL; valString = "a string"; valOID = OID::gen(); valLong = 1LL; doc = BSON(aBool(valBool) << anArray(valArray) << anObj(valObj) << aDate(valDate) << aString(valString) << anOID(valOID) << aLong(valLong)); } void tearDown() { } }; BSONField ExtractionFixture::aBool("aBool"); BSONField ExtractionFixture::anArray("anArray"); BSONField ExtractionFixture::anObj("anObj"); BSONField ExtractionFixture::aDate("aDate"); BSONField ExtractionFixture::aString("aString"); BSONField ExtractionFixture::anOID("anOID"); BSONField ExtractionFixture::aLong("aLong"); TEST_F(ExtractionFixture, GetBool) { BSONField notThere("otherBool", true); BSONField wrongType(anObj.name()); bool val; ASSERT_TRUE(FieldParser::extract(doc, aBool, &val)); ASSERT_EQUALS(val, valBool); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, true); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetBSONArray) { BSONField notThere("otherArray", BSON_ARRAY("a" << "b")); BSONField wrongType(aString.name()); BSONArray val; ASSERT_TRUE(FieldParser::extract(doc, anArray, &val)); ASSERT_EQUALS(val, valArray); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, BSON_ARRAY("a" << "b")); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetBSONObj) { BSONField notThere("otherObj", BSON("b" << 1)); BSONField wrongType(aString.name()); BSONObj val; ASSERT_TRUE(FieldParser::extract(doc, anObj, &val)); ASSERT_EQUALS(val, valObj); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, BSON("b" << 1)); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetDate) { BSONField notThere("otherDate", 99ULL); BSONField wrongType(aString.name()); Date_t val; ASSERT_TRUE(FieldParser::extract(doc, aDate, &val)); ASSERT_EQUALS(val, valDate); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, 99ULL); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetString) { BSONField notThere("otherString", "abc"); BSONField wrongType(aBool.name()); string val; ASSERT_TRUE(FieldParser::extract(doc, aString, &val)); ASSERT_EQUALS(val, valString); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, "abc"); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetOID) { OID defOID = OID::gen(); BSONField notThere("otherOID", defOID); BSONField wrongType(aString.name()); OID val; ASSERT_TRUE(FieldParser::extract(doc, anOID, &val)); ASSERT_EQUALS(val, valOID); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, defOID); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, GetLong) { BSONField notThere("otherLong", 0); BSONField wrongType(aString.name()); long long val; ASSERT_TRUE(FieldParser::extract(doc, aLong, &val)); ASSERT_EQUALS(val, valLong); ASSERT_TRUE(FieldParser::extract(doc, notThere, &val)); ASSERT_EQUALS(val, 0); ASSERT_FALSE(FieldParser::extract(doc, wrongType, &val)); } TEST_F(ExtractionFixture, IsFound) { bool bool_val; BSONField aBoolMissing("aBoolMissing"); ASSERT_EQUALS(FieldParser::extract(doc, aBool, &bool_val, NULL), FieldParser::FIELD_SET); ASSERT_EQUALS(FieldParser::extract(doc, aBoolMissing, &bool_val, NULL), FieldParser::FIELD_NONE); Date_t Date_t_val; BSONField aDateMissing("aDateMissing"); ASSERT_EQUALS(FieldParser::extract(doc, aDate, &Date_t_val, NULL), FieldParser::FIELD_SET); ASSERT_EQUALS(FieldParser::extract(doc, aDateMissing, &Date_t_val, NULL), FieldParser::FIELD_NONE); string string_val; BSONField aStringMissing("aStringMissing"); ASSERT_EQUALS(FieldParser::extract(doc, aString, &string_val, NULL), FieldParser::FIELD_SET); ASSERT_EQUALS(FieldParser::extract(doc, aStringMissing, &string_val, NULL), FieldParser::FIELD_NONE); OID OID_val; BSONField anOIDMissing("anOIDMissing"); ASSERT_EQUALS(FieldParser::extract(doc, anOID, &OID_val, NULL), FieldParser::FIELD_SET); ASSERT_EQUALS(FieldParser::extract(doc, anOIDMissing, &OID_val, NULL), FieldParser::FIELD_NONE); long long long_long_val; BSONField aLongMissing("aLongMissing"); ASSERT_EQUALS(FieldParser::extract(doc, aLong, &long_long_val, NULL), FieldParser::FIELD_SET); ASSERT_EQUALS(FieldParser::extract(doc, aLongMissing, &long_long_val, NULL), FieldParser::FIELD_NONE); } TEST(ComplexExtraction, GetStringVector) { // Test valid string vector extraction BSONField > vectorField("testVector"); BSONObjBuilder bob; bob << vectorField() << BSON_ARRAY("a" << "b" << "c"); BSONObj obj = bob.obj(); vector parsedVector; ASSERT(FieldParser::extract(obj, vectorField, &parsedVector)); ASSERT_EQUALS("a", parsedVector[0]); ASSERT_EQUALS("b", parsedVector[1]); ASSERT_EQUALS("c", parsedVector[2]); ASSERT_EQUALS(parsedVector.size(), static_cast(3)); } TEST(ComplexExtraction, GetObjectVector) { // Test valid BSONObj vector extraction BSONField > vectorField("testVector"); BSONObjBuilder bob; bob << vectorField() << BSON_ARRAY(BSON("a" << 1) << BSON("b" << 1) << BSON("c" << 1)); BSONObj obj = bob.obj(); vector parsedVector; ASSERT(FieldParser::extract(obj, vectorField, &parsedVector)); ASSERT_EQUALS(BSON("a" << 1), parsedVector[0]); ASSERT_EQUALS(BSON("b" << 1), parsedVector[1]); ASSERT_EQUALS(BSON("c" << 1), parsedVector[2]); ASSERT_EQUALS(parsedVector.size(), static_cast(3)); } TEST(ComplexExtraction, GetBadVector) { // Test invalid vector extraction BSONField > vectorField("testVector"); BSONObjBuilder bob; bob << vectorField() << BSON_ARRAY(BSON("a" << 1) << "XXX" << BSON("c" << 1)); BSONObj obj = bob.obj(); vector parsedVector; string errMsg; ASSERT(!FieldParser::extract(obj, vectorField, &parsedVector, &errMsg)); ASSERT_NOT_EQUALS(errMsg, ""); } TEST(ComplexExtraction, RoundTripVector) { // Test vector extraction after re-writing to BSON BSONField > vectorField("testVector"); BSONObj obj; { BSONObjBuilder bob; bob << vectorField() << BSON_ARRAY("a" << "b" << "c"); obj = bob.obj(); } vector parsedVector; ASSERT(FieldParser::extract(obj, vectorField, &parsedVector)); { BSONObjBuilder bob; bob.append(vectorField(), parsedVector); obj = bob.obj(); } parsedVector.clear(); ASSERT(FieldParser::extract(obj, vectorField, &parsedVector)); ASSERT_EQUALS("a", parsedVector[0]); ASSERT_EQUALS("b", parsedVector[1]); ASSERT_EQUALS("c", parsedVector[2]); ASSERT_EQUALS(parsedVector.size(), static_cast(3)); } TEST(ComplexExtraction, GetStringMap) { // Test valid string->string map extraction BSONField > mapField("testMap"); BSONObjBuilder bob; bob << mapField() << BSON("a" << "a" << "b" << "b" << "c" << "c"); BSONObj obj = bob.obj(); map parsedMap; ASSERT(FieldParser::extract(obj, mapField, &parsedMap)); ASSERT_EQUALS("a", parsedMap["a"]); ASSERT_EQUALS("b", parsedMap["b"]); ASSERT_EQUALS("c", parsedMap["c"]); ASSERT_EQUALS(parsedMap.size(), static_cast(3)); } TEST(ComplexExtraction, GetObjectMap) { // Test valid string->BSONObj map extraction BSONField > mapField("testMap"); BSONObjBuilder bob; bob << mapField() << BSON("a" << BSON("a" << "a") << "b" << BSON("b" << "b") << "c" << BSON("c" << "c")); BSONObj obj = bob.obj(); map parsedMap; ASSERT(FieldParser::extract(obj, mapField, &parsedMap)); ASSERT_EQUALS(BSON("a" << "a"), parsedMap["a"]); ASSERT_EQUALS(BSON("b" << "b"), parsedMap["b"]); ASSERT_EQUALS(BSON("c" << "c"), parsedMap["c"]); ASSERT_EQUALS(parsedMap.size(), static_cast(3)); } TEST(ComplexExtraction, GetBadMap) { // Test invalid map extraction BSONField > mapField("testMap"); BSONObjBuilder bob; bob << mapField() << BSON("a" << "a" << "b" << 123 << "c" << "c"); BSONObj obj = bob.obj(); map parsedMap; string errMsg; ASSERT(!FieldParser::extract(obj, mapField, &parsedMap, &errMsg)); ASSERT_NOT_EQUALS(errMsg, ""); } TEST(ComplexExtraction, RoundTripMap) { // Test map extraction after re-writing to BSON BSONField > mapField("testMap"); BSONObj obj; { BSONObjBuilder bob; bob << mapField() << BSON("a" << "a" << "b" << "b" << "c" << "c"); obj = bob.obj(); } map parsedMap; ASSERT(FieldParser::extract(obj, mapField, &parsedMap)); { BSONObjBuilder bob; bob.append(mapField(), parsedMap); obj = bob.obj(); } parsedMap.clear(); ASSERT(FieldParser::extract(obj, mapField, &parsedMap)); ASSERT_EQUALS("a", parsedMap["a"]); ASSERT_EQUALS("b", parsedMap["b"]); ASSERT_EQUALS("c", parsedMap["c"]); ASSERT_EQUALS(parsedMap.size(), static_cast(3)); } TEST(ComplexExtraction, GetNestedMap) { // Test extraction of complex nested vector and map BSONField > > nestedField("testNested"); BSONObj nestedMapObj = BSON("a" << "a" << "b" << "b" << "c" << "c"); BSONObjBuilder bob; bob << nestedField() << BSON_ARRAY(nestedMapObj << nestedMapObj << nestedMapObj); BSONObj obj = bob.obj(); vector > parsed; ASSERT(FieldParser::extract(obj, nestedField, &parsed)); ASSERT_EQUALS(parsed.size(), static_cast(3)); for (int i = 0; i < 3; i++) { map& parsedMap = parsed[i]; ASSERT_EQUALS("a", parsedMap["a"]); ASSERT_EQUALS("b", parsedMap["b"]); ASSERT_EQUALS("c", parsedMap["c"]); ASSERT_EQUALS(parsedMap.size(), static_cast(3)); } } TEST(ComplexExtraction, GetBadNestedMap) { // Test extraction of invalid complex nested vector and map BSONField > > nestedField("testNested"); BSONObj nestedMapObj = BSON("a" << "a" << "b" << 123 << "c" << "c"); BSONObjBuilder bob; bob << nestedField() << BSON_ARRAY(nestedMapObj << nestedMapObj << nestedMapObj); BSONObj obj = bob.obj(); vector > parsed; string errMsg; ASSERT(!FieldParser::extract(obj, nestedField, &parsed, &errMsg)); ASSERT_NOT_EQUALS(errMsg, ""); } } // unnamed namespace