Function BuildResponseMessage

pg_documentdb/src/commands/find_and_modify.c:624–669

* BuildResponseMessage returns a bson object that can be sent to the client * based on given FindAndModifyResult. */

 * based on given FindAndModifyResult.
 */
static pgbson *
BuildResponseMessage(FindAndModifyResult *result)
{
	pgbson_writer lastErrorObjectWriter;
	PgbsonWriterInit(&lastErrorObjectWriter);

	PgbsonWriterAppendInt32(&lastErrorObjectWriter, "n", strlen("n"),
							result->lastErrorObject.n);

	if (result->isUpdateCommand)
	{
		PgbsonWriterAppendBool(&lastErrorObjectWriter, "updatedExisting",
							   strlen("updatedExisting"),
							   result->lastErrorObject.updatedExisting);

		if (result->lastErrorObject.upsertedObjectId != NULL)
		{
			pgbsonelement idElement;
			PgbsonToSinglePgbsonElement(result->lastErrorObject.upsertedObjectId,
										&idElement);
			PgbsonWriterAppendValue(&lastErrorObjectWriter, "upserted",
									strlen("upserted"),
									&idElement.bsonValue);
		}
	}

	pgbson_writer resultWriter;
	PgbsonWriterInit(&resultWriter);

	PgbsonWriterAppendDocument(&resultWriter, "lastErrorObject",
							   strlen("lastErrorObject"),
							   PgbsonWriterGetPgbson(&lastErrorObjectWriter));
	if (result->value == NULL)
	{
		PgbsonWriterAppendNull(&resultWriter, "value", strlen("value"));
	}
	else
	{
		PgbsonWriterAppendDocument(&resultWriter, "value", strlen("value"),
								   result->value);
	}

	PgbsonWriterAppendDouble(&resultWriter, "ok", strlen("ok"), result->ok);

	return PgbsonWriterGetPgbson(&resultWriter);
}