Function bsonaggvalue_in

pg_documentdb/src/aggregation/bson_aggregates.c:2582–2614

* bsonaggvalue_in: Parse text input to BsonAggValue. * Accepts both hex (BSONHEX...) and extended JSON formats, wrapped as {"": value} * with an optional "collation" field. */

 * with an optional "collation" field.
 */
Datum
bsonaggvalue_in(PG_FUNCTION_ARGS)
{
	char *inputStr = PG_GETARG_CSTRING(0);

	if (inputStr == NULL)
	{
		PG_RETURN_NULL();
	}

	pgbson *bson = NULL;
	if (IsBsonHexadecimalString(inputStr))
	{
		bson = PgbsonInitFromHexadecimalString(inputStr);
	}
	else
	{
		bson = PgbsonInitFromJson(inputStr);
	}

	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);
}


/*