Function DeserializeUpsertedResult

pg_documentdb/src/commands/update.c:3100–3150

static void
DeserializeUpsertedResult(bson_iter_t *responseIter, int updateIndex,
						  BatchUpdateResult *result)
{
	bson_iter_t writerErrorsIter;
	if (!bson_iter_recurse(responseIter, &writerErrorsIter))
	{
		ereport(ERROR, (errmsg("Could not recurse into the update upserted documents")));
	}

	/* It's an array of upserts */
	while (bson_iter_next(&writerErrorsIter))
	{
		bson_iter_t singleUpsert;
		if (!bson_iter_recurse(&writerErrorsIter, &singleUpsert))
		{
			ereport(ERROR, (errmsg("Could not recurse into the update upsert entity")));
		}

		int32_t index = -1;
		bson_value_t upsertId = { 0 };
		while (bson_iter_next(&singleUpsert))
		{
			const char *key = bson_iter_key(&singleUpsert);
			if (strcmp(key, "index") == 0)
			{
				index = (int32_t) bson_iter_as_int64(&singleUpsert);
			}
			else if (strcmp(key, "_id") == 0)
			{
				upsertId = *bson_iter_value(&singleUpsert);
			}
			else
			{
				ereport(ERROR, (errmsg("Unknown worker upserted field %s", key)));
			}
		}

		if (index < 0 || upsertId.value_type == BSON_TYPE_EOD)
		{
			ereport(ERROR, (errmsg("upserted should have index, and id")));
		}

		MemoryContext oldContext = MemoryContextSwitchTo(result->resultMemoryContext);
		UpsertResult *error = palloc(sizeof(UpsertResult));
		error->index = index + updateIndex;
		error->objectId = BsonValueToDocumentPgbson(&upsertId);
		result->upserted = lappend(result->upserted, error);
		MemoryContextSwitchTo(oldContext);
	}
}


static void