Function bsonaggvalue_recv

pg_documentdb/src/aggregation/bson_aggregates.c:2696–2719

* bsonaggvalue_recv: Deserialize BsonAggValue from binary network data. * Parses pgbson bytes, extracts the value and optional collation string. */

 * Parses pgbson bytes, extracts the value and optional collation string.
 */
Datum
bsonaggvalue_recv(PG_FUNCTION_ARGS)
{
	StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);

	/* Parse the buffer as pgbson */
	pgbson *bson = PgbsonInitFromBuffer(buf->data, buf->len);

	/* Mark buffer as consumed */
	buf->cursor = buf->len;

	pgbsonelement element;
	const char *collationString =
		PgbsonToSinglePgbsonElementWithCollation(bson, &element);

	/* Allocate BsonAggValue and collation and deep-copy their values */
	BsonAggValue *state = (BsonAggValue *) palloc0(sizeof(BsonAggValue));
	SET_VARSIZE(state, sizeof(BsonAggValue));
	bson_value_copy(&element.bsonValue, &state->value);
	state->collationString = collationString != NULL ?
							 pstrdup(collationString) : NULL;

	PG_RETURN_POINTER(state);
}