Class ExtSimpleUpsert

src/ExtMsg.actor.cpp:1425–1443

};

struct ExtSimpleUpsert : ConcreteInsertOp<ExtSimpleUpsert> {
	bson::BSONObj selector;
	bson::BSONObj update;

	ExtSimpleUpsert(bson::BSONObj selector, bson::BSONObj update) : selector(selector), update(update) {}

	std::string describe() override { return "SimpleUpsert(" + selector.toString() + "," + update.toString() + ")"; }

	Future<Reference<IReadWriteContext>> insert(Reference<CollectionContext> cx) override {
		Optional<IdInfo> encodedIds = extractEncodedIds(selector);
		Optional<IdInfo> updateIds = extractEncodedIds(update);
		if (!encodedIds.present()) {
			encodedIds = updateIds;
		} else if (updateIds.present() && updateIds.get().keyEncoded != encodedIds.get().keyEncoded) {
			throw cant_modify_id();
		}
		return insertDocument(cx, update, encodedIds);
	}
};

Reference<IUpdateOp> operatorUpdate(bson::BSONObj const& msgUpdate) {
	return ref(new ExtOperatorUpdate(msgUpdate));