Method get_one_message

lib_acl_cpp/src/redis/redis_stream.cpp:467–516

}

bool redis_stream::get_one_message(const redis_result& rr,
	redis_stream_message& message)
{
	size_t size;
	const redis_result** children = rr.get_children(&size);
	if (size == 0 || children == NULL) {
		return false;
	}
	if (size != 2) {
		return false;
	}

	const redis_result* child = children[0];
	if (child->get_type() != REDIS_RESULT_STRING) {
		return false;
	}

	child->argv_to_string(message.id);

	child = children[1];
	children = child->get_children(&size);
	if (size == 0 || children == NULL) {
		return false;
	}

	if (size % 2 != 0) {
		return false;
	}

	for (size_t i = 0; i < size;) {
		const redis_result* name = children[i++];
		if (name->get_type() != REDIS_RESULT_STRING) {
			i++;
			continue;
		}

		const redis_result* value = children[i++];
		if (value->get_type() != REDIS_RESULT_STRING) {
			continue;
		}

		redis_stream_field field;
		name->argv_to_string(field.name);
		value->argv_to_string(field.value);

		message.fields.push_back(field);
	}

	return true;
}

//////////////////////////////////////////////////////////////////////////////