Method call

src/ExtCmd.actor.cpp:178–210

struct GetlasterrorCmd {
	static const char* name;
	ACTOR static Future<Reference<ExtMsgReply>> call(Reference<ExtConnection> ec,
	                                                 Reference<ExtMsgQuery> query,
	                                                 Reference<ExtMsgReply> reply) {
		state bson::BSONObjBuilder bob;

		Future<WriteResult> lastWrite = ec->lastWrite;

		bob.appendNumber("connectionId", (long long)ec->connectionId);

		try {
			WriteResult res = wait(lastWrite);
			bob.appendNumber("n", (long long)res.n); //< FIXME: ???
			bob << "err" << BSONNULL << "ok" << 1.0;
			if (!res.upsertedOIDList.empty()) {
				bob.appendElements(DataValue::decode_key_part(res.upsertedOIDList[0]).wrap("upserted"));
			}
			if (res.type == WriteType::UPDATE) {
				bob << "updatedExisting" << (res.nModified > 0 && res.upsertedOIDList.empty());
			}
		} catch (Error& e) {
			bob.append("err", e.what());
			bob.append("code", e.code());
			bob.appendNumber("n", (long long)0);
			bob.append("ok", 1.0);
		}

		reply->addDocument(bob.obj());
		reply->setResponseFlags(8);

		ec->lastWrite = WriteResult();

		return reply;
	}
};
REGISTER_CMD(GetlasterrorCmd, "getlasterror");