bson.cpp

/**
 *  Copyright 2015 MongoDB, Inc.
 *
 *  Licensed 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 "hphp/runtime/vm/native-data.h"
#include "hphp/runtime/base/array-init.h"
#include "hphp/runtime/base/array-iterator.h"
#include "hphp/runtime/base/builtin-functions.h"
#include "hphp/runtime/base/execution-context.h"
#include "hphp/runtime/base/type-string.h"
#include "hphp/util/logger.h"

#include "bson.h"
#include "utils.h"
#include "mongodb.h"
#include <iostream>

#include "src/MongoDB/BSON/Binary.h"
#include "src/MongoDB/BSON/Decimal128.h"
#include "src/MongoDB/BSON/Javascript.h"
#include "src/MongoDB/BSON/ObjectID.h"
#include "src/MongoDB/BSON/Regex.h"
#include "src/MongoDB/BSON/Timestamp.h"
#include "src/MongoDB/BSON/UTCDateTime.h"

#include "src/MongoDB/Driver/CursorId.h"

extern "C" {
#include "libbson/src/bson/bson.h"
#include "libmongoc/src/mongoc/mongoc.h"
}

namespace HPHP {
/* {{{ HHVM → BSON */

/* {{{ static strings used for conversions */
const StaticString
	s_root("root"),
	s_document("document"),
	s_object("object"),
	s_stdClass("stdClass"),
	s_array("array"),
	s_types("types");
/* }}} */

int VariantToBsonConverter::_isPackedArray(const Array &a)
{
	int idx = 0, key_value = 0;

	for (ArrayIter iter(a); iter; ++iter) {
		Variant key(iter.first());

		if (!key.isInteger()) {
			return false;
		}

		key_value = key.toInt32(); 

		if (idx != key_value) {
			return false;
		}

		idx++;
	}
	return true;
}

VariantToBsonConverter::VariantToBsonConverter(const Variant& document, int flags)
{
	m_document = document;
	m_level = 0;
	m_flags = flags;
	m_out = Variant();
}

void VariantToBsonConverter::convert(bson_t *bson)
{
	if (m_document.isObject() || m_document.isArray()) {
		convertDocument(bson, NULL, m_document);
	} else {
		std::cout << "convert *unimplemented*: " << getDataTypeString(m_document.getType()).c_str() << "\n";
	}
}

const StaticString s_MongoBSONTypeWrapper_className("MongoDB\\BSON\\TypeWrapper");
const StaticString s_MongoBSONTypeWrapper_createFromBSONType("createFromBSONType");
const StaticString s_MongoBSONTypeWrapper_toBSONType("toBSONType");

void VariantToBsonConverter::convertElement(bson_t *bson, const char *key, Variant v)
{
	/* We need to check whether it is a type wrapped object (ie, the class
	 * implements TypeWrapper). If so, run the toBSONType() method on the
	 * object. The returned value then needs to be processed as normal. */
	if (v.isObject() && v.toObject().instanceof(s_MongoBSONTypeWrapper_className)) {
		Object obj = v.toObject();
		Class *cls = obj.get()->getVMClass();
		Func  *m   = cls->lookupMethod(s_MongoBSONTypeWrapper_toBSONType.get());
		TypedValue args[0] = {};
		Variant    result;
#if HIPPO_HHVM_VERSION >= 31700
		result = Variant::attach(
			g_context->invokeFuncFew(
				m, obj.get(),
				nullptr, 0, args
			)
		);
#else
		g_context->invokeFuncFew(
			result.asTypedValue(),
			m, obj.get(),
			nullptr, 0, args
		);
#endif
		v = result;
	}

	switch (v.getType()) {
		case KindOfUninit:
		case KindOfNull:
			convertNull(bson, key);
			break;
		case KindOfBoolean:
			convertBoolean(bson, key, v.toBoolean());
			break;
		case KindOfInt64:
			convertInt64(bson, key, v.toInt64());
			break;
		case KindOfDouble:
			convertDouble(bson, key, v.toDouble());
			break;
#if HIPPO_HHVM_VERSION >= 31200
		case KindOfPersistentString:
#else
		case KindOfStaticString:
#endif
		case KindOfString:
			convertString(bson, key, v.toString());
			break;
		case KindOfArray:
#if HIPPO_HHVM_VERSION >= 31100
		case KindOfPersistentArray:
#endif
		case KindOfObject:
			convertDocument(bson, key, v);
			break;
		case KindOfRef:
			convertElement(bson, key, *v.getRefData());
			break;
#if HIPPO_HHVM_VERSION >= 31700
		case KindOfPersistentVec:
		case KindOfPersistentDict:
		case KindOfPersistentKeyset:
		case KindOfVec:
		case KindOfDict:
		case KindOfKeyset:
#endif
		case KindOfResource: {
			StringBuffer buf;
			buf.printf(
				"Got unsupported type '%s'",
				HPHP::getDataTypeString(v.getType()).data()
			);

			Variant message = buf.detach();

			throw MongoDriver::Utils::throwUnexpectedValueException((char*) message.toString().c_str());
			return;
		}
#if HIPPO_HHVM_VERSION < 31900
		case KindOfClass:
			not_reached();
#endif
	}
}

void VariantToBsonConverter::convertNull(bson_t *bson, const char *key)
{
	bson_append_null(bson, key, -1);
};

void VariantToBsonConverter::convertBoolean(bson_t *bson, const char *key, bool v)
{
	bson_append_bool(bson, key, -1, v);
};

void VariantToBsonConverter::convertInt64(bson_t *bson, const char *key, int64_t v)
{
	if (v > INT_MAX || v < INT_MIN) {
		bson_append_int64(bson, key, -1, v);
	} else {
		bson_append_int32(bson, key, -1, (int32_t) v);
	}
};

void VariantToBsonConverter::convertDouble(bson_t *bson, const char *key, double v)
{
	bson_append_double(bson, key, -1, v);
};

void VariantToBsonConverter::convertString(bson_t *bson, const char *key, String v)
{
	if (bson_utf8_validate(v.c_str(), v.size(), true)) {
		bson_append_utf8(bson, key, -1, v.c_str(), v.size());
	} else {
		throw MongoDriver::Utils::throwUnexpectedValueException("Got invalid UTF-8 value serializing '" + String(v.c_str()) + "'");
	}
}

char *VariantToBsonConverter::_getUnmangledPropertyName(String key)
{
	const char *ckey = key.c_str();

	if (ckey[0] == '\0' && key.length()) {
		const char *cls = ckey + 1;
		if (*cls == '*') { // protected
			return strdup(ckey + 3);
		} else {
			int l = strlen(cls);
			return strdup(cls + l + 1);
		}
	} else {
		return strdup(ckey);
	}
}

void VariantToBsonConverter::convertDocument(bson_t *bson, const char *property_name, Variant v)
{
	bson_t child;
	int unmangle = 0;
	Array document;

	/* if we are not at a top-level, we need to check (and convert) special
	 * BSON types too */
	if (v.isObject()) {
		if (convertSpecialObject(bson, property_name, v.toObject())) {
			return;
		}
		/* The "convertSpecialObject" method didn't understand this type, so we
		 * will continue treating this as a normal document */
	}

	document = v.toObject()->o_toIterArray(null_string, ObjectData::PreserveRefs);

	if (_isPackedArray(document) && !v.isObject()) {
		if (property_name != NULL) {
			bson_append_array_begin(bson, property_name, -1, &child);
		}
	} else {
		unmangle = 1;
		if (property_name != NULL) {
			bson_append_document_begin(bson, property_name, -1, &child);
		}
	}

	for (ArrayIter iter(document); iter; ++iter) {
		Variant key(iter.first());
		const Variant& data(iter.secondRef());
		String s_key = key.toString();

		if (m_level == 0 && (m_flags & HIPPO_BSON_ADD_ID)) {
			/* If we have an ID, we don't need to add it. But we also need to
			 * set m_out to the value! */
			if (strncmp(s_key.c_str(), "_id", s_key.length()) == 0) {
				m_flags &= ~HIPPO_BSON_ADD_ID;
				if (m_flags & HIPPO_BSON_RETURN_ID) {
					/* FIXME: Should we add a ref here? */
					m_out = data;
				}
			}
		}

		m_level++;
		if (unmangle) {
			const char *unmangledName;

			unmangledName = _getUnmangledPropertyName(s_key);
			if (strlen(s_key.c_str()) != s_key.size()) {
				free((void*) unmangledName);
				throw MongoDriver::Utils::throwUnexpectedValueException("BSON keys cannot contain null bytes. Unexpected null byte after \"" + String(s_key.c_str()) + "\".");
			}
			convertElement(property_name != NULL ? &child : bson, unmangledName, data);
			free((void*) unmangledName);
		} else {
			if (strlen(s_key.c_str()) != s_key.size()) {
				throw MongoDriver::Utils::throwUnexpectedValueException("BSON keys cannot contain null bytes. Unexpected null byte after \"" + String(s_key.c_str()) + "\".");
			}
			convertElement(property_name != NULL ? &child : bson, s_key.c_str(), data);
		}
		m_level--;
	}

	if (m_level == 0 && (m_flags & HIPPO_BSON_ADD_ID)) {
		bson_oid_t oid;

		bson_oid_init(&oid, NULL);
		bson_append_oid(bson, "_id", strlen("_id"), &oid);

		if (m_flags & HIPPO_BSON_RETURN_ID) {
			Object obj = createMongoBsonObjectIDObject(&oid);
			m_out = obj;
		}
	}

	if (property_name != NULL) {
		if (_isPackedArray(document)) {
			bson_append_array_end(bson, &child);
		} else {
			bson_append_document_end(bson, &child);
		}
	}
}

/* {{{ Serialization of types */
const StaticString s_MongoDriverBsonType_className("MongoDB\\BSON\\Type");
const StaticString s_MongoDriverBsonPersistable_className("MongoDB\\BSON\\Persistable");
const StaticString s_MongoDriverBsonSerializable_className("MongoDB\\BSON\\Serializable");
const StaticString s_MongoDriverBsonUnserializable_className("MongoDB\\BSON\\Unserializable");
const StaticString s_MongoDriverBsonSerializable_functionName("bsonSerialize");
const StaticString s_MongoDriverBsonUnserializable_functionName("bsonUnserialize");
const StaticString s_MongoDriverBsonODM_fieldName("__pclass");

/* {{{ MongoDriver\BSON\Binary */
void VariantToBsonConverter::_convertBinary(bson_t *bson, const char *key, Object v)
{
	String data = v.o_get(s_MongoBsonBinary_data, false, s_MongoBsonBinary_className).toString();
	int64_t type = v.o_get(s_MongoBsonBinary_type, false, s_MongoBsonBinary_className).toInt64();

	bson_append_binary(bson, key, -1, (bson_subtype_t) type, (const unsigned char*) data.c_str(), data.length());
}
/* }}} */

/* {{{ MongoDriver\BSON\Decimal128 */
void VariantToBsonConverter::_convertDecimal128(bson_t *bson, const char *key, Object v)
{
	MongoDBBsonDecimal128Data* data = Native::data<MongoDBBsonDecimal128Data>(v.get());

	bson_append_decimal128(bson, key, -1, &data->m_decimal);
}
/* }}} */

/* {{{ MongoDriver\BSON\Javascript */
void VariantToBsonConverter::_convertJavascript(bson_t *bson, const char *key, Object v)
{
	bson_t *scope_bson;
	String code = v.o_get(s_MongoBsonJavascript_code, false, s_MongoBsonJavascript_className).toString();
	auto scope = v.o_get(s_MongoBsonJavascript_scope, false, s_MongoBsonJavascript_className);

	if (scope.isObject() || scope.isArray()) {
		/* Convert scope to document */
		VariantToBsonConverter converter(scope, HIPPO_BSON_NO_FLAGS);
		scope_bson = bson_new();
		converter.convert(scope_bson);

		bson_append_code_with_scope(bson, key, -1, (const char*) code.c_str(), scope_bson);
	} else {
		bson_append_code(bson, key, -1, (const char*) code.c_str());
	}
}
/* }}} */

/* {{{ MongoDriver\BSON\MaxKey */
const StaticString s_MongoBsonMaxKey_className("MongoDB\\BSON\\MaxKey");
const StaticString s_MongoBsonMaxKey_shortName("MaxKey");

void VariantToBsonConverter::_convertMaxKey(bson_t *bson, const char *key, Object v)
{
	bson_append_maxkey(bson, key, -1);
}
/* }}} */

/* {{{ MongoDriver\BSON\MinKey */
const StaticString s_MongoBsonMinKey_className("MongoDB\\BSON\\MinKey");
const StaticString s_MongoBsonMinKey_shortName("MinKey");

void VariantToBsonConverter::_convertMinKey(bson_t *bson, const char *key, Object v)
{
	bson_append_minkey(bson, key, -1);
}
/* }}} */

/* {{{ MongoDriver\BSON\ObjectID */
void VariantToBsonConverter::_convertObjectID(bson_t *bson, const char *key, Object v)
{
    MongoDBBsonObjectIDData* data = Native::data<MongoDBBsonObjectIDData>(v.get());

	bson_append_oid(bson, key, -1, &data->m_oid);
}
/* }}} */

/* {{{ MongoDriver\BSON\Regex */

void VariantToBsonConverter::_convertRegex(bson_t *bson, const char *key, Object v)
{
	String regex = v.o_get(s_MongoBsonRegex_pattern, false, s_MongoBsonRegex_className).toString();
	String flags = v.o_get(s_MongoBsonRegex_flags, false, s_MongoBsonRegex_className).toString();

	bson_append_regex(bson, key, -1, regex.c_str(), flags.c_str());
}
/* }}} */

/* {{{ MongoDriver\BSON\Timestamp */
void VariantToBsonConverter::_convertTimestamp(bson_t *bson, const char *key, Object v)
{
	int32_t timestamp = v.o_get(s_MongoBsonTimestamp_timestamp, false, s_MongoBsonTimestamp_className).toInt32();
	int32_t increment = v.o_get(s_MongoBsonTimestamp_increment, false, s_MongoBsonTimestamp_className).toInt32();

	bson_append_timestamp(bson, key, -1, timestamp, increment);
}

/* {{{ MongoDriver\BSON\UTCDateTime */
void VariantToBsonConverter::_convertUTCDateTime(bson_t *bson, const char *key, Object v)
{
	int64_t milliseconds = v.o_get(s_MongoBsonUTCDateTime_milliseconds, false, s_MongoBsonUTCDateTime_className).toInt64();

	bson_append_date_time(bson, key, -1, milliseconds);
}
/* }}} */

/* {{{ MongoDriver\Driver\CursorId */
void VariantToBsonConverter::_convertCursorId(bson_t *bson, const char *key, Object v)
{
	MongoDBDriverCursorIdData* data = Native::data<MongoDBDriverCursorIdData>(v.get());

	bson_append_int64(bson, key, -1, data->id);
}
/* }}} */


/* {{{ Special objects that implement MongoDB\BSON\Serializable */
void VariantToBsonConverter::_convertSerializable(bson_t *bson, const char *key, Object v)
{
	Variant result;
	Array   properties;
	Class *cls;
	Func *m;

	cls = v.get()->getVMClass();
	m = cls->lookupMethod(s_MongoDriverBsonSerializable_functionName.get());

#if HIPPO_HHVM_VERSION >= 31700
	result = Variant::attach(
		g_context->invokeFuncFew(
			m,
			v.get(),
			nullptr
		)
	);
#else
	g_context->invokeFuncFew(
		result.asTypedValue(),
		m,
		v.get(),
		nullptr
	);
#endif

	if ( ! (
			result.isArray() || 
			(result.isObject() && result.toObject().instanceof(s_stdClass))
		)
	) {
		StringBuffer buf;
		buf.printf(
			"Expected %s::%s() to return an array or stdClass, %s given",
			cls->nameStr().c_str(),
			s_MongoDriverBsonSerializable_functionName.data(),
			result.isObject() ? result.toObject()->getVMClass()->nameStr().c_str() : HPHP::getDataTypeString(result.getType()).data()
		);
		Variant full_name = buf.detach();

		throw MongoDriver::Utils::throwUnexpectedValueException((char*) full_name.toString().c_str());
	}

	/* Convert to array so that we can handle it well */
	properties = result.toArray();

	if (v.instanceof(s_MongoDriverBsonPersistable_className)) {
		const char *class_name = cls->nameStr().c_str();
		Object obj = createMongoBsonBinaryObject(
			(const uint8_t *) class_name,
			strlen(class_name),
			(bson_subtype_t) 0x80
		);
		properties.add(String(s_MongoDriverBsonODM_fieldName), obj);
	}

	convertDocument(bson, key, result.isObject() ? Variant(Variant(properties).toObject()) : Variant(properties));
}
/* }}} */

/* }}} */

bool VariantToBsonConverter::convertSpecialObject(bson_t *bson, const char *key, Object v)
{
	if (v.instanceof(s_MongoDriverBsonType_className)) {
		if (v.instanceof(s_MongoDriverBsonSerializable_className)) {
			_convertSerializable(bson, key, v);
			return true;
		}

		if (m_level == 0) {
			throw MongoDriver::Utils::throwUnexpectedValueException("MongoDB\\BSON\\Type instance " + String(v->getClassName())+ " cannot be serialized as a root element");
		}

		if (v.instanceof(s_MongoBsonBinary_className)) {
			_convertBinary(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonDecimal128_className)) {
			_convertDecimal128(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonJavascript_className)) {
			_convertJavascript(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonMaxKey_className)) {
			_convertMaxKey(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonMinKey_className)) {
			_convertMinKey(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonObjectID_className)) {
			_convertObjectID(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonRegex_className)) {
			_convertRegex(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonTimestamp_className)) {
			_convertTimestamp(bson, key, v);
			return true;
		}
		if (v.instanceof(s_MongoBsonUTCDateTime_className)) {
			_convertUTCDateTime(bson, key, v);
			return true;
		}

		throw MongoDriver::Utils::throwUnexpectedValueException("Unexpected MongoDB\\BSON\\Type instance: " + String(v->getClassName()));
	}

	if (v.instanceof(s_MongoDriverCursorId_className)) {
		_convertCursorId(bson, key, v);
		return true;
	}

	return false;
}
/* }}} */
/* }}} */

/* {{{ BSON → HHVM */
BsonToVariantConverter::BsonToVariantConverter(const unsigned char *data, int data_len, hippo_bson_conversion_options_t options)
{
	m_reader = bson_reader_new_from_data(data, data_len);
	m_options = options;
}

/* {{{ TypeWrapping */
Variant wrapObject(String class_name, Object typeObject)
{
	Variant result = invoke_static_method(class_name, s_MongoBSONTypeWrapper_createFromBSONType, Array::Create(typeObject));

	return result;
}
/* }}} */

/* {{{ Visitors */
void hippo_bson_visit_corrupt(const bson_iter_t *iter __attribute__((unused)), void *data)
{
	Logger::Verbose("[HIPPO] Corrupt BSON data detected!");

	throw MongoDriver::Utils::throwUnexpectedValueException("Detected corrupt BSON data");
}

bool hippo_bson_visit_double(const bson_iter_t *iter __attribute__((unused)), const char *key, double v_double, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(v_double));
	return false;
}

bool hippo_bson_visit_utf8(const bson_iter_t *iter __attribute__((unused)), const char *key, size_t v_utf8_len, const char *v_utf8, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(String::FromCStr(v_utf8)));
	return false;
}

bool hippo_bson_visit_document(const bson_iter_t *iter __attribute__((unused)), const char *key, const bson_t *v_document, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	Variant document_v;

	state->options.current_compound_type = HIPPO_BSONTYPE_DOCUMENT;

	BsonToVariantConverter converter(bson_get_data(v_document), v_document->len, state->options);
	converter.convert(&document_v);

	state->zchild.add(String::FromCStr(key), document_v);

	return false;
}

bool hippo_bson_visit_array(const bson_iter_t *iter __attribute__((unused)), const char *key, const bson_t *v_array, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	Variant array_v;

	state->options.current_compound_type = HIPPO_BSONTYPE_ARRAY;

	BsonToVariantConverter converter(bson_get_data(v_array), v_array->len, state->options);
	converter.convert(&array_v);

	state->zchild.add(String::FromCStr(key), array_v);

	return false;
}

bool hippo_bson_visit_binary(const bson_iter_t *iter __attribute__((unused)), const char *key, bson_subtype_t v_subtype, size_t v_binary_len, const uint8_t *v_binary, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	Object obj;

	obj = createMongoBsonBinaryObject(v_binary, v_binary_len, v_subtype);

	if (! state->options.types.binary_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.binary_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_oid(const bson_iter_t *iter __attribute__((unused)), const char *key, const bson_oid_t *v_oid, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	Object obj = createMongoBsonObjectIDObject(v_oid);

	if (! state->options.types.objectid_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.objectid_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_bool(const bson_iter_t *iter __attribute__((unused)), const char *key, bool v_bool, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(v_bool));
	return false;
}

bool hippo_bson_visit_date_time(const bson_iter_t *iter __attribute__((unused)), const char *key, int64_t msec_since_epoch, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_datetime;

	c_datetime = Unit::lookupClass(s_MongoBsonUTCDateTime_className.get());
	assert(c_datetime);
	Object obj = Object{c_datetime};

	obj->o_set(s_MongoBsonUTCDateTime_milliseconds, Variant(msec_since_epoch), s_MongoBsonUTCDateTime_className);

	if (! state->options.types.utcdatetime_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.utcdatetime_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_null(const bson_iter_t *iter __attribute__((unused)), const char *key, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(Variant::NullInit()));
	return false;
}

bool hippo_bson_visit_regex(const bson_iter_t *iter __attribute__((unused)), const char *key, const char *v_regex, const char *v_options, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_regex;

	c_regex = Unit::lookupClass(s_MongoBsonRegex_className.get());
	assert(c_regex);
	Object obj = Object{c_regex};

	/* Call __construct on the object */
	static Class* c_class = Unit::getClass(s_MongoBsonRegex_className.get(), true);

#if HIPPO_HHVM_VERSION >= 31700
	g_context->invokeFunc(
		c_class->getCtor(),
		HPHP::make_packed_array(v_regex, v_options),
		obj.get()
	);
#else
	HPHP::TypedValue ret;
	g_context->invokeFunc(
		&ret,
		c_class->getCtor(),
		HPHP::make_packed_array(v_regex, v_options),
		obj.get()
	);
#endif

	if (! state->options.types.regex_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.regex_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_code(const bson_iter_t *iter __attribute__((unused)), const char *key, size_t v_code_len, const char *v_code, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_code;
	String s;
	unsigned char *data_s;

	s = String(v_code_len, ReserveString);
	data_s = (unsigned char*) s.bufferSlice().data();
	memcpy(data_s, v_code, v_code_len);
	s.setSize(v_code_len);

	c_code = Unit::lookupClass(s_MongoBsonJavascript_className.get());
	assert(c_code);
	Object obj = Object{c_code};

	obj->o_set(s_MongoBsonJavascript_code, s, s_MongoBsonJavascript_className);

	if (! state->options.types.javascript_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.javascript_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_codewscope(const bson_iter_t *iter __attribute__((unused)), const char *key, size_t v_code_len, const char *v_code, const bson_t *v_scope, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_code;
	String s;
	unsigned char *data_s;
	Variant scope_v;

	/* code */
	s = String(v_code_len, ReserveString);
	data_s = (unsigned char*) s.bufferSlice().data();
	memcpy(data_s, v_code, v_code_len);
	s.setSize(v_code_len);

	/* scope */
	BsonToVariantConverter converter(bson_get_data(v_scope), v_scope->len, state->options);
	converter.convert(&scope_v);

	/* create object */
	c_code = Unit::lookupClass(s_MongoBsonJavascript_className.get());
	assert(c_code);
	Object obj = Object{c_code};

	/* set properties */
	obj->o_set(s_MongoBsonJavascript_code, s, s_MongoBsonJavascript_className);
	obj->o_set(s_MongoBsonJavascript_scope, scope_v, s_MongoBsonJavascript_className);

	/* add to array */
	if (! state->options.types.javascript_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.javascript_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_int32(const bson_iter_t *iter __attribute__((unused)), const char *key, int32_t v_int32, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(v_int32));
	return false;
}

bool hippo_bson_visit_timestamp(const bson_iter_t *iter __attribute__((unused)), const char *key, uint32_t v_timestamp, uint32_t v_increment, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_timestamp;

	c_timestamp = Unit::lookupClass(s_MongoBsonTimestamp_className.get());
	assert(c_timestamp);
	Object obj = Object{c_timestamp};

	obj->o_set(s_MongoBsonTimestamp_timestamp, Variant((uint64_t) v_timestamp), s_MongoBsonTimestamp_className);
	obj->o_set(s_MongoBsonTimestamp_increment, Variant((uint64_t) v_increment), s_MongoBsonTimestamp_className);

	if (! state->options.types.timestamp_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.timestamp_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_int64(const bson_iter_t *iter __attribute__((unused)), const char *key, int64_t v_int64, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;

	state->zchild.add(String::FromCStr(key), Variant(v_int64));
	return false;
}

bool hippo_bson_visit_maxkey(const bson_iter_t *iter __attribute__((unused)), const char *key, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_objectId;

	c_objectId = Unit::lookupClass(s_MongoBsonMaxKey_className.get());
	assert(c_objectId);
	Object obj = Object{c_objectId};

	if (! state->options.types.maxkey_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.maxkey_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

bool hippo_bson_visit_minkey(const bson_iter_t *iter __attribute__((unused)), const char *key, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_objectId;

	c_objectId = Unit::lookupClass(s_MongoBsonMinKey_className.get());
	assert(c_objectId);
	Object obj = Object{c_objectId};

	if (! state->options.types.minkey_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.minkey_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}

void hippo_bson_visit_unsupported_type(const bson_iter_t *iter __attribute__((unused)), const char *key, uint32_t v_type_code, void *data)
{
	char *message;

	message = (char*) malloc( 29 + 2 + 15 + strlen(key) + 35 + 1);
	sprintf(message, "Detected unknown BSON type 0x%02hhx for fieldname \"%s\". Are you using the latest driver?", v_type_code, key);

	throw MongoDriver::Utils::throwUnexpectedValueException(message);
}

bool hippo_bson_visit_decimal128(const bson_iter_t *iter __attribute__((unused)), const char *key, const bson_decimal128_t *v_decimal128, void *data)
{
	hippo_bson_state *state = (hippo_bson_state*) data;
	static Class* c_decimal128;

	c_decimal128 = Unit::lookupClass(s_MongoBsonDecimal128_className.get());
	assert(c_decimal128);
	Object obj = Object{c_decimal128};

	MongoDBBsonDecimal128Data* obj_data = Native::data<MongoDBBsonDecimal128Data>(obj);
	memcpy(&obj_data->m_decimal, v_decimal128, sizeof(bson_decimal128_t));

	if (! state->options.types.decimal128_class_name.empty()) {
		/* We have a type wrapped class, so wrap it */
		Variant result = wrapObject(state->options.types.decimal128_class_name, obj);
		state->zchild.add(String::FromCStr(key), result);
	} else {
		state->zchild.add(String::FromCStr(key), Variant(obj));
	}

	return false;
}


static const bson_visitor_t hippo_bson_visitors = {
	NULL /* hippo_phongo_bson_visit_before*/,
	NULL /*hippo_phongo_bson_visit_after*/,
	hippo_bson_visit_corrupt,
	hippo_bson_visit_double,
	hippo_bson_visit_utf8,
	hippo_bson_visit_document,
	hippo_bson_visit_array,
	hippo_bson_visit_binary,
	NULL /*hippo_bson_visit_undefined*/,
	hippo_bson_visit_oid,
	hippo_bson_visit_bool,
	hippo_bson_visit_date_time,
	hippo_bson_visit_null,
	hippo_bson_visit_regex,
	NULL /*hippo_bson_visit_dbpointer*/,
	hippo_bson_visit_code,
	NULL /*hippo_bson_visit_symbol*/,
	hippo_bson_visit_codewscope,
	hippo_bson_visit_int32,
	hippo_bson_visit_timestamp,
	hippo_bson_visit_int64,
	hippo_bson_visit_maxkey,
	hippo_bson_visit_minkey,
	hippo_bson_visit_unsupported_type,
	hippo_bson_visit_decimal128,
	{ NULL }
};
/* }}} */


bool BsonToVariantConverter::convert(Variant *v)
{
	bson_iter_t   iter;
	bool          eof = false;
	bool          havePclass;
	const bson_t *b;
	int type_descriminator;
	String named_class;

	m_state.zchild = NULL;

	/* Determine which descriminator to use */
	switch (m_options.current_compound_type) {
		case HIPPO_BSONTYPE_ARRAY:
			type_descriminator = m_options.array_type;
			named_class = m_options.array_class_name;
			break;

		case HIPPO_BSONTYPE_ROOT:
			type_descriminator = m_options.root_type;
			named_class = m_options.root_class_name;
			break;

		case HIPPO_BSONTYPE_DOCUMENT:
			type_descriminator = m_options.document_type;
			named_class = m_options.document_class_name;
			break;
	}

	if (!(b = bson_reader_read(m_reader, &eof))) {
		throw MongoDriver::Utils::throwUnexpectedValueException("Could not read document from BSON reader");
		return false;
	}

	if (!bson_iter_init(&iter, b)) {
		bson_reader_destroy(m_reader);
		throw MongoDriver::Utils::throwUnexpectedValueException("Could not initialize BSON iterator");
		return false;
	}

	m_state.zchild = Array::Create();
	m_state.options = m_options;

	if (bson_iter_visit_all(&iter, &hippo_bson_visitors, &m_state) || iter.err_off) {
		bson_reader_destroy(m_reader);

		throw MongoDriver::Utils::throwUnexpectedValueException("Detected corrupt BSON data");
	}

	/* Set "root" to false */
	havePclass = false;

	if (
		(
			type_descriminator == HIPPO_TYPEMAP_DEFAULT ||
			type_descriminator == HIPPO_TYPEMAP_NAMEDCLASS
		) &&
		m_state.zchild.exists(s_MongoDriverBsonODM_fieldName) &&
		m_state.zchild[s_MongoDriverBsonODM_fieldName].isObject() &&
		m_state.zchild[s_MongoDriverBsonODM_fieldName].toObject().instanceof(s_MongoBsonBinary_className) &&
		m_state.zchild[s_MongoDriverBsonODM_fieldName].toObject().o_get(s_MongoBsonBinary_type, false, s_MongoBsonBinary_className).toInt64() == 0x80
	) {
		havePclass = true;
	}

	if (type_descriminator == HIPPO_TYPEMAP_NAMEDCLASS) {
		static Class* c_class;
		static Class* c_unserializable_interface;
		static Class* c_persistable_interface;
		Object obj;
		bool useTypeMap = true;
		c_unserializable_interface = Unit::lookupClass(s_MongoDriverBsonUnserializable_className.get());
		c_persistable_interface = Unit::lookupClass(s_MongoDriverBsonPersistable_className.get());

		/* If we have a __pclass, and the class exists, and the class
		 * implements MongoDB\BSON\Persitable, we use that class name. */
		if (havePclass) {
			String class_name = m_state.zchild[s_MongoDriverBsonODM_fieldName].toObject().o_get(
				s_MongoBsonBinary_data, false, s_MongoBsonBinary_className
			).toString();

			/* Lookup class and instantiate object, but if we can't find the class,
			 * make it a stdClass */
			c_class = Unit::getClass(class_name.get(), true);
			if (c_class && isNormalClass(c_class) && c_class->classof(c_persistable_interface)) {
				/* Instantiate */
				obj = Object{c_class};
				useTypeMap = false;
				*v = Variant(obj);
			}
		}

		if (useTypeMap) {
			c_class = Unit::getClass(named_class.get(), true);
			if (c_class && isNormalClass(c_class) && c_class->classof(c_unserializable_interface)) {
				/* Instantiate */
				obj = Object{c_class};
				useTypeMap = false;
				*v = Variant(obj);
			}
		}

		/* If the type map didn't match with a suitable class, we bail out */
		if (useTypeMap) {
			throw MongoDriver::Utils::throwInvalidArgumentException("The typemap does not provide a class that implements MongoDB\\BSON\\Unserializable");
		}

		{
			/* Setup arguments for bsonUnserialize call */
			TypedValue args[1] = { *(Variant(m_state.zchild)).asCell() };

			/* Call bsonUnserialize on the object */
			Func *m = c_class->lookupMethod(s_MongoDriverBsonUnserializable_functionName.get());

#if HIPPO_HHVM_VERSION >= 31700
			g_context->invokeFuncFew(
				m,
				obj.get(),
				nullptr,
				1, args
			);
#else
			Variant result;

			g_context->invokeFuncFew(
				result.asTypedValue(),
				m,
				obj.get(),
				nullptr,
				1, args
			);
#endif

			*v = Variant(obj);
		}
	} else if (havePclass) {
		static Class* c_class;

		String class_name = m_state.zchild[s_MongoDriverBsonODM_fieldName].toObject().o_get(
			s_MongoBsonBinary_data, false, s_MongoBsonBinary_className
		).toString();
		TypedValue args[1] = { *(Variant(m_state.zchild)).asCell() };

		/* Lookup class and instantiate object, but if we can't find the class,
		 * make it a stdClass */
		c_class = Unit::getClass(class_name.get(), true);
		if (!c_class) {
			*v = Variant(Variant(m_state.zchild).toObject());
			return true;
		}

		/* If the class is not a "normal" class, make it a stdClass object */
		if (!isNormalClass(c_class) || isAbstract(c_class)) {
			*v = Variant(Variant(m_state.zchild).toObject());
			return true;
		}

		/* Instantiate */
		Object obj = Object{c_class};

		/* If the class does not implement Persistable, make it a stdClass */
		if (!obj->instanceof(s_MongoDriverBsonPersistable_className)) {
			*v = Variant(Variant(m_state.zchild).toObject());
			return true;
		}

		/* Call bsonUnserialize on the object */
		Func *m = c_class->lookupMethod(s_MongoDriverBsonUnserializable_functionName.get());

#if HIPPO_HHVM_VERSION >= 31700
		g_context->invokeFuncFew(
			m,
			obj.get(),
			nullptr,
			1, args
		);
#else
		Variant result;
		g_context->invokeFuncFew(
			result.asTypedValue(),
			m,
			obj.get(),
			nullptr,
			1, args
		);
#endif

		*v = Variant(obj);
	} else if (type_descriminator == HIPPO_TYPEMAP_DEFAULT) {
		if (m_options.current_compound_type == HIPPO_BSONTYPE_ARRAY) {
			*v = Variant(Variant(m_state.zchild).toArray());
		} else if (m_options.current_compound_type == HIPPO_BSONTYPE_ROOT) {
			*v = Variant(Variant(m_state.zchild).toObject());
		} else if (m_options.current_compound_type == HIPPO_BSONTYPE_DOCUMENT) {
			*v = Variant(Variant(m_state.zchild).toObject());
		}
	} else if (type_descriminator == HIPPO_TYPEMAP_STDCLASS) {
		*v = Variant(Variant(m_state.zchild).toObject());
	} else if (type_descriminator == HIPPO_TYPEMAP_ARRAY) {
		*v = Variant(m_state.zchild);
	} else {
		assert(NULL);
	}

	if (bson_reader_read(m_reader, &eof) || !eof) {
		bson_reader_destroy(m_reader);
		throw MongoDriver::Utils::throwUnexpectedValueException("Reading document did not exhaust input buffer");
		return false;
	}

	bson_reader_destroy(m_reader);
	return true;
}
/* }}} */

/* {{{ TypeMap helper functions */
#define CASECMP(a,b) (bstrcasecmp((a).data(), (a).size(), (b).data(), (b).size()) == 0)

static void validateClass(String class_name)
{
	static Class* c_class;
	static Class* c_unserializable_interface = Unit::lookupClass(s_MongoDriverBsonUnserializable_className.get());

	c_class = Unit::getClass(class_name.get(), true);

	if (!c_class) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " does not exist");
	}
	if (c_class && (!isNormalClass(c_class) || isAbstract(c_class))) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " is not instantiatable");
	}
	if (c_class && !c_class->classof(c_unserializable_interface)) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " does not implement MongoDB\\BSON\\Unserializable");
	}
}

static void validateTypeWrapperClass(String class_name)
{
	static Class* c_class;
	static Class* c_unserializable_interface = Unit::lookupClass(s_MongoBSONTypeWrapper_className.get());

	c_class = Unit::getClass(class_name.get(), true);

	if (!c_class) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " does not exist");
	}
	if (c_class && (!isNormalClass(c_class) || isAbstract(c_class))) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " is not instantiatable");
	}
	if (c_class && !c_class->classof(c_unserializable_interface)) {
		throw MongoDriver::Utils::throwInvalidArgumentException("Class " + class_name + " does not implement MongoDB\\BSON\\TypeWrapper");
	}
}

void parseTypeMap(hippo_bson_conversion_options_t *options, const Array &typemap)
{
	if (typemap.exists(s_root) && typemap[s_root].isString()) {
		String root_type;

		root_type = typemap[s_root].toString();

		if (CASECMP(root_type, s_object) || CASECMP(root_type, s_stdClass)) {
			options->root_type = HIPPO_TYPEMAP_STDCLASS;
		} else if (CASECMP(root_type, s_array)) {
			options->root_type = HIPPO_TYPEMAP_ARRAY;
		} else {
			validateClass(root_type); /* Might throw an exception */

			options->root_type = HIPPO_TYPEMAP_NAMEDCLASS;
			options->root_class_name = root_type;
		}
	}

	if (typemap.exists(s_document) && typemap[s_document].isString()) {
		String document_type;

		document_type = typemap[s_document].toString();

		if (CASECMP(document_type, s_object) || CASECMP(document_type, s_stdClass)) {
			options->document_type = HIPPO_TYPEMAP_STDCLASS;
		} else if (CASECMP(document_type, s_array)) {
			options->document_type = HIPPO_TYPEMAP_ARRAY;
		} else {
			validateClass(document_type); /* Might throw an exception */

			options->document_type = HIPPO_TYPEMAP_NAMEDCLASS;
			options->document_class_name = document_type;
		}
	}

	if (typemap.exists(s_array) && typemap[s_array].isString()) {
		String array_type;

		array_type = typemap[s_array].toString();

		if (CASECMP(array_type, s_object) || CASECMP(array_type, s_stdClass)) {
			options->array_type = HIPPO_TYPEMAP_STDCLASS;
		} else if (CASECMP(array_type, s_array)) {
			options->array_type = HIPPO_TYPEMAP_ARRAY;
		} else {
			validateClass(array_type); /* Might throw an exception */

			options->array_type = HIPPO_TYPEMAP_NAMEDCLASS;
			options->array_class_name = array_type;
		}
	}

	if (typemap.exists(s_types)) {
		if (!typemap[s_types].isArray()) {
			throw MongoDriver::Utils::throwInvalidArgumentException("The 'types' key in the type map should be an array");
		}

		for (ArrayIter iter(typemap[s_types]); iter; ++iter) {
			Variant key(iter.first());
			String s_key = key.toString();

			const Variant& data(iter.secondRef());
			if (!data.isString()) {
				throw MongoDriver::Utils::throwInvalidArgumentException("The typemap for type '" + s_key + "' should be a string");
			}
			String s_type_class = data.toString();

			/* Depending on the key, set the right option (or throw an exception) */
			if (CASECMP(s_key, s_MongoBsonBinary_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.binary_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonDecimal128_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.decimal128_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonJavascript_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.javascript_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonMaxKey_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.maxkey_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonMinKey_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.minkey_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonObjectID_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.objectid_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonRegex_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.regex_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonTimestamp_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.timestamp_class_name = s_type_class;

			} else if (CASECMP(s_key, s_MongoBsonUTCDateTime_shortName)) {
				validateTypeWrapperClass(s_type_class);
				options->types.utcdatetime_class_name = s_type_class;

			} else {
				throw MongoDriver::Utils::throwInvalidArgumentException("The type '" + s_key + "' is not supported in the type map");
			}
		}
	}
}

/* }}} */

} /* namespace HPHP */