Method xpending_summary

lib_acl_cpp/src/redis/redis_stream.cpp:831–899

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

bool redis_stream::xpending_summary(const char* key, const char* group,
	redis_pending_summary& result)
{
	const char* argv[3];
	size_t lens[3];

	argv[0] = "XPENDING";
	lens[0] = sizeof("XPENDING") - 1;
	argv[1] = key;
	lens[1] = strlen(key);
	argv[2] = group;
	lens[2] = strlen(group);

	hash_slot(key);
	build_request(3, argv, lens);
	const redis_result* rr = run();
	if (rr == NULL || rr->get_type() != REDIS_RESULT_ARRAY) {
		return false;
	}

	size_t size;
	const redis_result** children = rr->get_children(&size);
	if (size < 4) {
		return false;
	}

	rr = children[0];
	if (rr->get_type() != REDIS_RESULT_INTEGER) {
		return false;
	}
	
	int n = rr->get_integer();
	if (n < 0) {
		return false;
	} else if (n == 0) {
		return true;
	}

	rr = children[1];
	if (rr->get_type() == REDIS_RESULT_STRING) {
		rr->argv_to_string(result.smallest_id);
	}

	rr = children[2];
	if (rr->get_type() == REDIS_RESULT_STRING) {
		rr->argv_to_string(result.greatest_id);
	}

	rr = children[3];
	if (rr->get_type() != REDIS_RESULT_ARRAY) {
		return false;
	}

	children = rr->get_children(&size);
	if (children == NULL || size == 0) {
		return false;
	}