Class ExtIndexInsert

src/ExtMsg.actor.cpp:698–766

};

struct ExtIndexInsert : ConcreteInsertOp<ExtIndexInsert> {
	bson::BSONObj indexObj;
	std::string ns;
	UID build_id;

	ExtIndexInsert(bson::BSONObj indexObj, UID build_id, std::string ns)
	    : indexObj(indexObj), build_id(build_id), ns(ns) {}

	std::string describe() override { return "IndexInsert(" + indexObj.toString() + ")"; }

	ACTOR static Future<Reference<IReadWriteContext>> indexInsertActor(ExtIndexInsert* self,
	                                                                   Reference<CollectionContext> cx) {
		state Standalone<StringRef> encodedId;
		state Standalone<StringRef> valueEncodedId;
		state Optional<bson::BSONObj> idObj;
		state Reference<QueryContext> dcx;

		Optional<IdInfo> encodedIds = extractEncodedIds(self->indexObj);

		if (!encodedIds.present()) {
			encodedId = DataValue(bson::OID::gen()).encode_key_part();
			valueEncodedId = encodedId;
			idObj = Optional<bson::BSONObj>();
			dcx = cx->cx->getSubContext(encodedId);
		} else {
			encodedId = encodedIds.get().keyEncoded;
			valueEncodedId = encodedIds.get().valueEncoded;
			idObj = encodedIds.get().objValue;
			dcx = cx->cx->getSubContext(encodedId);
			Optional<DataValue> existing =
			    wait(dcx->get(DataValue(DocLayerConstants::ID_FIELD, DVTypeCode::STRING).encode_key_part()));
			if (existing.present())
				throw duplicated_key_field();
		}

		// FIXME: abstraction violation out of laziness
		Key prefix = StringRef(dcx->getPrefix().toString());
		dcx->getTransaction()->tr->addWriteConflictRange(KeyRangeRef(prefix, strinc(prefix)));

		dcx->set(LiteralStringRef(""), DataValue::subObject().encode_value());

		dcx->set(DataValue(DocLayerConstants::NS_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(self->ns).encode_value());
		dcx->set(
		    DataValue(DocLayerConstants::NAME_FIELD, DVTypeCode::STRING).encode_key_part(),
		    DataValue(self->indexObj.getStringField(DocLayerConstants::NAME_FIELD), DVTypeCode::STRING).encode_value());
		dcx->set(DataValue(DocLayerConstants::KEY_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(self->indexObj.getObjectField(DocLayerConstants::KEY_FIELD)).encode_value());
		dcx->set(DataValue(DocLayerConstants::STATUS_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(DocLayerConstants::INDEX_STATUS_BUILDING, DVTypeCode::STRING).encode_value());
		dcx->set(DataValue(DocLayerConstants::METADATA_VERSION_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(1).encode_value());
		dcx->set(DataValue(DocLayerConstants::BUILD_ID_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(self->build_id.toString()).encode_value());
		dcx->set(DataValue(DocLayerConstants::UNIQUE_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(self->indexObj.getBoolField(DocLayerConstants::UNIQUE_FIELD)).encode_value());
		dcx->set(DataValue(DocLayerConstants::BACKGROUND_FIELD, DVTypeCode::STRING).encode_key_part(),
		         DataValue(self->indexObj.getBoolField(DocLayerConstants::BACKGROUND_FIELD)).encode_value());