Class ExtReplaceUpdate

src/ExtMsg.actor.cpp:1355–1393

};

struct ExtReplaceUpdate : ConcreteUpdateOp<ExtReplaceUpdate> {
	bson::BSONObj replaceWith;

	explicit ExtReplaceUpdate(bson::BSONObj const& replaceWith) : replaceWith(replaceWith) {}

	Future<Void> update(Reference<IReadWriteContext> document) override { return replacementActor(this, document); }

	std::string describe() override { return "ReplaceWith(" + replaceWith.toString() + ")"; }

	ACTOR static Future<Void> replacementActor(ExtReplaceUpdate* self, Reference<IReadWriteContext> document) {
		state Standalone<StringRef> keyEncodedId = wait(document->getKeyEncodedId());
		Optional<IdInfo> encodedIds = extractEncodedIds(self->replaceWith);
		if (encodedIds.present() && encodedIds.get().keyEncoded != keyEncodedId) {
			throw replace_with_id();
		}

		Optional<DataValue> iddv2 =
		    wait(document->get(DataValue(DocLayerConstants::ID_FIELD, DVTypeCode::STRING).encode_key_part()));
		document->clearDescendants();

		if (iddv2.get().getBSONType() == bson::BSONType::Object) {
			DataValue iddv = DataValue::decode_key_part(keyEncodedId);
			if (iddv.getBSONType() == bson::BSONType::Object) {
				insertElementRecursive(iddv.wrap(DocLayerConstants::ID_FIELD).getField(DocLayerConstants::ID_FIELD),
				                       document);
			}
		} else {
			document->set(DataValue(DocLayerConstants::ID_FIELD, DVTypeCode::STRING).encode_key_part(),
			              iddv2.get().encode_value());
		}

		for (auto i = self->replaceWith.begin(); i.more();) {
			auto e = i.next();
			insertElementRecursive(e, document);
		}
		document->set(StringRef(), DataValue::subObject().encode_value());
		return Void();
	}
};

struct ExtOperatorUpsert : ConcreteInsertOp<ExtOperatorUpsert> {
	bson::BSONObj selector;