Add write support for m.emote events

closes #41

1 files changed, 468 insertions, 444 deletions

diff --git a/src/MatrixClient.cc b/src/MatrixClient.cc
index 430bacf9..e42b4184 100644
--- a/src/MatrixClient.cc
+++ b/src/MatrixClient.cc
@@ -35,709 +35,733 @@
 MatrixClient::MatrixClient(QString server, QObject *parent)
   : QNetworkAccessManager(parent)
 {
-	server_ = "https://" + server;
-	api_url_ = "/_matrix/client/r0";
-	token_ = "";
+        server_  = "https://" + server;
+        api_url_ = "/_matrix/client/r0";
+        token_   = "";
 
-	QSettings settings;
-	txn_id_ = settings.value("client/transaction_id", 1).toInt();
+        QSettings settings;
+        txn_id_ = settings.value("client/transaction_id", 1).toInt();
 
-	connect(this, SIGNAL(finished(QNetworkReply *)), this, SLOT(onResponse(QNetworkReply *)));
+        connect(this, SIGNAL(finished(QNetworkReply *)), this, SLOT(onResponse(QNetworkReply *)));
 }
 
 void
 MatrixClient::reset() noexcept
 {
-	next_batch_ = "";
-	server_ = "";
-	token_ = "";
+        next_batch_ = "";
+        server_     = "";
+        token_      = "";
 
-	txn_id_ = 0;
+        txn_id_ = 0;
 }
 
 void
 MatrixClient::onVersionsResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
-
-	int status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
-
-	if (status_code == 404) {
-		emit versionError("Versions endpoint was not found on the server. Possibly not a Matrix server");
-		return;
-	}
-
-	if (status_code >= 400) {
-		qWarning() << "API version error: " << reply->errorString();
-		emit versionError("An unknown error occured. Please try again.");
-		return;
-	}
-
-	auto data = reply->readAll();
-	auto json = QJsonDocument::fromJson(data);
-
-	VersionsResponse response;
-
-	try {
-		response.deserialize(json);
-		if (!response.isVersionSupported(0, 2, 0))
-			emit versionError("Server does not support required API version.");
-		else
-			emit versionSuccess();
-	} catch (DeserializationException &e) {
-		qWarning() << "Malformed JSON response" << e.what();
-		emit versionError("Malformed response. Possibly not a Matrix server");
-	}
+        reply->deleteLater();
+
+        int status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+
+        if (status_code == 404) {
+                emit versionError(
+                  "Versions endpoint was not found on the server. Possibly not a Matrix server");
+                return;
+        }
+
+        if (status_code >= 400) {
+                qWarning() << "API version error: " << reply->errorString();
+                emit versionError("An unknown error occured. Please try again.");
+                return;
+        }
+
+        auto data = reply->readAll();
+        auto json = QJsonDocument::fromJson(data);
+
+        VersionsResponse response;
+
+        try {
+                response.deserialize(json);
+                if (!response.isVersionSupported(0, 2, 0))
+                        emit versionError("Server does not support required API version.");
+                else
+                        emit versionSuccess();
+        } catch (DeserializationException &e) {
+                qWarning() << "Malformed JSON response" << e.what();
+                emit versionError("Malformed response. Possibly not a Matrix server");
+        }
 }
 
 void
 MatrixClient::onLoginResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
-
-	int status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
-
-	if (status_code == 403) {
-		emit loginError(tr("Wrong username or password"));
-		return;
-	}
-
-	if (status_code == 404) {
-		emit loginError(tr("Login endpoint was not found on the server"));
-		return;
-	}
-
-	if (status_code >= 400) {
-		qWarning() << "Login error: " << reply->errorString();
-		emit loginError(tr("An unknown error occured. Please try again."));
-		return;
-	}
-
-	auto data = reply->readAll();
-	auto json = QJsonDocument::fromJson(data);
-
-	LoginResponse response;
-
-	try {
-		response.deserialize(json);
-		emit loginSuccess(response.getUserId(), server_.host(), response.getAccessToken());
-	} catch (DeserializationException &e) {
-		qWarning() << "Malformed JSON response" << e.what();
-		emit loginError(tr("Malformed response. Possibly not a Matrix server"));
-	}
+        reply->deleteLater();
+
+        int status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+
+        if (status_code == 403) {
+                emit loginError(tr("Wrong username or password"));
+                return;
+        }
+
+        if (status_code == 404) {
+                emit loginError(tr("Login endpoint was not found on the server"));
+                return;
+        }
+
+        if (status_code >= 400) {
+                qWarning() << "Login error: " << reply->errorString();
+                emit loginError(tr("An unknown error occured. Please try again."));
+                return;
+        }
+
+        auto data = reply->readAll();
+        auto json = QJsonDocument::fromJson(data);
+
+        LoginResponse response;
+
+        try {
+                response.deserialize(json);
+                emit loginSuccess(response.getUserId(), server_.host(), response.getAccessToken());
+        } catch (DeserializationException &e) {
+                qWarning() << "Malformed JSON response" << e.what();
+                emit loginError(tr("Malformed response. Possibly not a Matrix server"));
+        }
 }
 
 void
 MatrixClient::onLogoutResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status != 200) {
-		qWarning() << "Logout error: " << reply->errorString();
-		return;
-	}
+        if (status != 200) {
+                qWarning() << "Logout error: " << reply->errorString();
+                return;
+        }
 
-	emit loggedOut();
+        emit loggedOut();
 }
 
 void
 MatrixClient::onRegisterResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	auto data = reply->readAll();
-	auto json = QJsonDocument::fromJson(data);
+        auto data = reply->readAll();
+        auto json = QJsonDocument::fromJson(data);
 
-	if (status == 0 || status >= 400) {
-		if (json.isObject() && json.object().contains("error"))
-			emit registerError(json.object().value("error").toString());
-		else
-			emit registerError(reply->errorString());
+        if (status == 0 || status >= 400) {
+                if (json.isObject() && json.object().contains("error"))
+                        emit registerError(json.object().value("error").toString());
+                else
+                        emit registerError(reply->errorString());
 
-		return;
-	}
+                return;
+        }
 
-	RegisterResponse response;
+        RegisterResponse response;
 
-	try {
-		response.deserialize(json);
-		emit registerSuccess(response.getUserId(), response.getHomeServer(), response.getAccessToken());
-	} catch (DeserializationException &e) {
-		qWarning() << "Register" << e.what();
-		emit registerError("Received malformed response.");
-	}
+        try {
+                response.deserialize(json);
+                emit registerSuccess(
+                  response.getUserId(), response.getHomeServer(), response.getAccessToken());
+        } catch (DeserializationException &e) {
+                qWarning() << "Register" << e.what();
+                emit registerError("Received malformed response.");
+        }
 }
 
 void
 MatrixClient::onGetOwnProfileResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto data = reply->readAll();
-	auto json = QJsonDocument::fromJson(data);
+        auto data = reply->readAll();
+        auto json = QJsonDocument::fromJson(data);
 
-	ProfileResponse response;
+        ProfileResponse response;
 
-	try {
-		response.deserialize(json);
-		emit getOwnProfileResponse(response.getAvatarUrl(), response.getDisplayName());
-	} catch (DeserializationException &e) {
-		qWarning() << "Profile:" << e.what();
-	}
+        try {
+                response.deserialize(json);
+                emit getOwnProfileResponse(response.getAvatarUrl(), response.getDisplayName());
+        } catch (DeserializationException &e) {
+                qWarning() << "Profile:" << e.what();
+        }
 }
 
 void
 MatrixClient::onInitialSyncResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto data = reply->readAll();
+        auto data = reply->readAll();
 
-	if (data.isEmpty())
-		return;
+        if (data.isEmpty())
+                return;
 
-	auto json = QJsonDocument::fromJson(data);
+        auto json = QJsonDocument::fromJson(data);
 
-	SyncResponse response;
+        SyncResponse response;
 
-	try {
-		response.deserialize(json);
-	} catch (DeserializationException &e) {
-		qWarning() << "Sync malformed response" << e.what();
-		return;
-	}
+        try {
+                response.deserialize(json);
+        } catch (DeserializationException &e) {
+                qWarning() << "Sync malformed response" << e.what();
+                return;
+        }
 
-	emit initialSyncCompleted(response);
+        emit initialSyncCompleted(response);
 }
 
 void
 MatrixClient::onSyncResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		emit syncFailed(reply->errorString());
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                emit syncFailed(reply->errorString());
+                return;
+        }
 
-	auto data = reply->readAll();
+        auto data = reply->readAll();
 
-	if (data.isEmpty())
-		return;
+        if (data.isEmpty())
+                return;
 
-	auto json = QJsonDocument::fromJson(data);
+        auto json = QJsonDocument::fromJson(data);
 
-	SyncResponse response;
+        SyncResponse response;
 
-	try {
-		response.deserialize(json);
-		emit syncCompleted(response);
-	} catch (DeserializationException &e) {
-		qWarning() << "Sync malformed response" << e.what();
-	}
+        try {
+                response.deserialize(json);
+                emit syncCompleted(response);
+        } catch (DeserializationException &e) {
+                qWarning() << "Sync malformed response" << e.what();
+        }
 }
 
 void
-MatrixClient::onSendTextMessageResponse(QNetworkReply *reply)
+MatrixClient::onSendRoomMessage(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto data = reply->readAll();
+        auto data = reply->readAll();
 
-	if (data.isEmpty())
-		return;
+        if (data.isEmpty())
+                return;
 
-	auto json = QJsonDocument::fromJson(data);
+        auto json = QJsonDocument::fromJson(data);
 
-	if (!json.isObject()) {
-		qDebug() << "Send message response is not a JSON object";
-		return;
-	}
+        if (!json.isObject()) {
+                qDebug() << "Send message response is not a JSON object";
+                return;
+        }
 
-	auto object = json.object();
+        auto object = json.object();
 
-	if (!object.contains("event_id")) {
-		qDebug() << "SendTextMessage: missing event_id from response";
-		return;
-	}
+        if (!object.contains("event_id")) {
+                qDebug() << "SendTextMessage: missing event_id from response";
+                return;
+        }
 
-	emit messageSent(object.value("event_id").toString(),
-			 reply->property("roomid").toString(),
-			 reply->property("txn_id").toInt());
+        emit messageSent(object.value("event_id").toString(),
+                         reply->property("roomid").toString(),
+                         reply->property("txn_id").toInt());
 }
 
 void
 MatrixClient::onRoomAvatarResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto img = reply->readAll();
+        auto img = reply->readAll();
 
-	if (img.size() == 0)
-		return;
+        if (img.size() == 0)
+                return;
 
-	auto roomid = reply->property("roomid").toString();
+        auto roomid = reply->property("roomid").toString();
 
-	QPixmap pixmap;
-	pixmap.loadFromData(img);
+        QPixmap pixmap;
+        pixmap.loadFromData(img);
 
-	emit roomAvatarRetrieved(roomid, pixmap);
+        emit roomAvatarRetrieved(roomid, pixmap);
 }
 
 void
 MatrixClient::onUserAvatarResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto data = reply->readAll();
+        auto data = reply->readAll();
 
-	if (data.size() == 0)
-		return;
+        if (data.size() == 0)
+                return;
 
-	auto roomid = reply->property("userid").toString();
+        auto roomid = reply->property("userid").toString();
 
-	QImage img;
-	img.loadFromData(data);
+        QImage img;
+        img.loadFromData(data);
 
-	emit userAvatarRetrieved(roomid, img);
+        emit userAvatarRetrieved(roomid, img);
 }
 void
 MatrixClient::onGetOwnAvatarResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto img = reply->readAll();
+        auto img = reply->readAll();
 
-	if (img.size() == 0)
-		return;
+        if (img.size() == 0)
+                return;
 
-	QPixmap pixmap;
-	pixmap.loadFromData(img);
+        QPixmap pixmap;
+        pixmap.loadFromData(img);
 
-	emit ownAvatarRetrieved(pixmap);
+        emit ownAvatarRetrieved(pixmap);
 }
 
 void
 MatrixClient::onImageResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto img = reply->readAll();
+        auto img = reply->readAll();
 
-	if (img.size() == 0)
-		return;
+        if (img.size() == 0)
+                return;
 
-	QPixmap pixmap;
-	pixmap.loadFromData(img);
+        QPixmap pixmap;
+        pixmap.loadFromData(img);
 
-	auto event_id = reply->property("event_id").toString();
+        auto event_id = reply->property("event_id").toString();
 
-	emit imageDownloaded(event_id, pixmap);
+        emit imageDownloaded(event_id, pixmap);
 }
 
 void
 MatrixClient::onMessagesResponse(QNetworkReply *reply)
 {
-	reply->deleteLater();
+        reply->deleteLater();
 
-	int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
+        int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
 
-	if (status == 0 || status >= 400) {
-		qWarning() << reply->errorString();
-		return;
-	}
+        if (status == 0 || status >= 400) {
+                qWarning() << reply->errorString();
+                return;
+        }
 
-	auto data = reply->readAll();
-	auto room_id = reply->property("room_id").toString();
+        auto data    = reply->readAll();
+        auto room_id = reply->property("room_id").toString();
 
-	RoomMessages msgs;
+        RoomMessages msgs;
 
-	try {
-		msgs.deserialize(QJsonDocument::fromJson(data));
-	} catch (const DeserializationException &e) {
-		qWarning() << "Room messages from" << room_id << e.what();
-		return;
-	}
+        try {
+                msgs.deserialize(QJsonDocument::fromJson(data));
+        } catch (const DeserializationException &e) {
+                qWarning() << "Room messages from" << room_id << e.what();
+                return;
+        }
 
-	emit messagesRetrieved(room_id, msgs);
+        emit messagesRetrieved(room_id, msgs);
 }
 
 void
 MatrixClient::onResponse(QNetworkReply *reply)
 {
-	switch (static_cast<Endpoint>(reply->property("endpoint").toInt())) {
-	case Endpoint::Versions:
-		onVersionsResponse(reply);
-		break;
-	case Endpoint::Login:
-		onLoginResponse(reply);
-		break;
-	case Endpoint::Logout:
-		onLogoutResponse(reply);
-		break;
-	case Endpoint::Register:
-		onRegisterResponse(reply);
-		break;
-	case Endpoint::GetOwnProfile:
-		onGetOwnProfileResponse(reply);
-		break;
-	case Endpoint::Image:
-		onImageResponse(reply);
-		break;
-	case Endpoint::InitialSync:
-		onInitialSyncResponse(reply);
-		break;
-	case Endpoint::Sync:
-		onSyncResponse(reply);
-		break;
-	case Endpoint::SendTextMessage:
-		onSendTextMessageResponse(reply);
-		break;
-	case Endpoint::RoomAvatar:
-		onRoomAvatarResponse(reply);
-		break;
-	case Endpoint::UserAvatar:
-		onUserAvatarResponse(reply);
-		break;
-	case Endpoint::GetOwnAvatar:
-		onGetOwnAvatarResponse(reply);
-		break;
-	case Endpoint::Messages:
-		onMessagesResponse(reply);
-		break;
-	default:
-		break;
-	}
+        switch (static_cast<Endpoint>(reply->property("endpoint").toInt())) {
+        case Endpoint::Versions:
+                onVersionsResponse(reply);
+                break;
+        case Endpoint::Login:
+                onLoginResponse(reply);
+                break;
+        case Endpoint::Logout:
+                onLogoutResponse(reply);
+                break;
+        case Endpoint::Register:
+                onRegisterResponse(reply);
+                break;
+        case Endpoint::GetOwnProfile:
+                onGetOwnProfileResponse(reply);
+                break;
+        case Endpoint::Image:
+                onImageResponse(reply);
+                break;
+        case Endpoint::InitialSync:
+                onInitialSyncResponse(reply);
+                break;
+        case Endpoint::Sync:
+                onSyncResponse(reply);
+                break;
+        case Endpoint::SendRoomMessage:
+                onSendRoomMessage(reply);
+                break;
+        case Endpoint::RoomAvatar:
+                onRoomAvatarResponse(reply);
+                break;
+        case Endpoint::UserAvatar:
+                onUserAvatarResponse(reply);
+                break;
+        case Endpoint::GetOwnAvatar:
+                onGetOwnAvatarResponse(reply);
+                break;
+        case Endpoint::Messages:
+                onMessagesResponse(reply);
+                break;
+        default:
+                break;
+        }
 }
 
 void
 MatrixClient::login(const QString &username, const QString &password) noexcept
 {
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/login");
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/login");
 
-	QNetworkRequest request(endpoint);
-	request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
+        QNetworkRequest request(endpoint);
+        request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
 
-	LoginRequest body(username, password);
+        LoginRequest body(username, password);
 
-	QNetworkReply *reply = post(request, body.serialize());
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::Login));
+        QNetworkReply *reply = post(request, body.serialize());
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::Login));
 }
 
 void
 MatrixClient::logout() noexcept
 {
-	QUrlQuery query;
-	query.addQueryItem("access_token", token_);
+        QUrlQuery query;
+        query.addQueryItem("access_token", token_);
 
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/logout");
-	endpoint.setQuery(query);
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/logout");
+        endpoint.setQuery(query);
 
-	QNetworkRequest request(endpoint);
-	request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
+        QNetworkRequest request(endpoint);
+        request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
 
-	QJsonObject body{};
-	QNetworkReply *reply = post(request, QJsonDocument(body).toJson(QJsonDocument::Compact));
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::Logout));
+        QJsonObject body{};
+        QNetworkReply *reply = post(request, QJsonDocument(body).toJson(QJsonDocument::Compact));
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::Logout));
 }
 
 void
 MatrixClient::registerUser(const QString &user, const QString &pass, const QString &server) noexcept
 {
-	setServer(server);
+        setServer(server);
 
-	QUrlQuery query;
-	query.addQueryItem("kind", "user");
+        QUrlQuery query;
+        query.addQueryItem("kind", "user");
 
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/register");
-	endpoint.setQuery(query);
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/register");
+        endpoint.setQuery(query);
 
-	QNetworkRequest request(QString(endpoint.toEncoded()));
-	request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
+        QNetworkRequest request(QString(endpoint.toEncoded()));
+        request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
 
-	RegisterRequest body(user, pass);
+        RegisterRequest body(user, pass);
 
-	QNetworkReply *reply = post(request, body.serialize());
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::Register));
+        QNetworkReply *reply = post(request, body.serialize());
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::Register));
 }
 
 void
 MatrixClient::sync() noexcept
 {
-	QJsonObject filter{ { "room", QJsonObject{ { "ephemeral", QJsonObject{ { "limit", 0 } } } } },
-			    { "presence", QJsonObject{ { "limit", 0 } } } };
+        QJsonObject filter{ { "room",
+                              QJsonObject{ { "ephemeral", QJsonObject{ { "limit", 0 } } } } },
+                            { "presence", QJsonObject{ { "limit", 0 } } } };
 
-	QUrlQuery query;
-	query.addQueryItem("set_presence", "online");
-	query.addQueryItem("filter", QJsonDocument(filter).toJson(QJsonDocument::Compact));
-	query.addQueryItem("timeout", "30000");
-	query.addQueryItem("access_token", token_);
+        QUrlQuery query;
+        query.addQueryItem("set_presence", "online");
+        query.addQueryItem("filter", QJsonDocument(filter).toJson(QJsonDocument::Compact));
+        query.addQueryItem("timeout", "30000");
+        query.addQueryItem("access_token", token_);
 
-	if (next_batch_.isEmpty()) {
-		qDebug() << "Sync requires a valid next_batch token. Initial sync should be performed.";
-		return;
-	}
+        if (next_batch_.isEmpty()) {
+                qDebug()
+                  << "Sync requires a valid next_batch token. Initial sync should be performed.";
+                return;
+        }
 
-	query.addQueryItem("since", next_batch_);
+        query.addQueryItem("since", next_batch_);
 
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/sync");
-	endpoint.setQuery(query);
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/sync");
+        endpoint.setQuery(query);
 
-	QNetworkRequest request(QString(endpoint.toEncoded()));
+        QNetworkRequest request(QString(endpoint.toEncoded()));
 
-	QNetworkReply *reply = get(request);
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::Sync));
+        QNetworkReply *reply = get(request);
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::Sync));
 }
 
 void
-MatrixClient::sendTextMessage(const QString &roomid, const QString &msg) noexcept
+MatrixClient::sendRoomMessage(matrix::events::MessageEventType ty,
+                              const QString &roomid,
+                              const QString &msg) noexcept
 {
-	QUrlQuery query;
-	query.addQueryItem("access_token", token_);
-
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + QString("/rooms/%1/send/m.room.message/%2").arg(roomid).arg(txn_id_));
-	endpoint.setQuery(query);
-
-	QJsonObject body{ { "msgtype", "m.text" }, { "body", msg } };
-
-	QNetworkRequest request(QString(endpoint.toEncoded()));
-	request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
-
-	QNetworkReply *reply = put(request, QJsonDocument(body).toJson(QJsonDocument::Compact));
-
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::SendTextMessage));
-	reply->setProperty("txn_id", txn_id_);
-	reply->setProperty("roomid", roomid);
-
-	incrementTransactionId();
+        QUrlQuery query;
+        query.addQueryItem("access_token", token_);
+
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ +
+                         QString("/rooms/%1/send/m.room.message/%2").arg(roomid).arg(txn_id_));
+        endpoint.setQuery(query);
+
+        QString msgType("");
+
+        switch (ty) {
+        case matrix::events::MessageEventType::Text:
+                msgType = "m.text";
+                break;
+        case matrix::events::MessageEventType::Emote:
+                msgType = "m.emote";
+                break;
+        default:
+                msgType = "m.text";
+                break;
+        }
+
+        QJsonObject body{ { "msgtype", msgType }, { "body", msg } };
+
+        QNetworkRequest request(QString(endpoint.toEncoded()));
+        request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
+
+        QNetworkReply *reply = put(request, QJsonDocument(body).toJson(QJsonDocument::Compact));
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::SendRoomMessage));
+        reply->setProperty("txn_id", txn_id_);
+        reply->setProperty("roomid", roomid);
+
+        incrementTransactionId();
 }
 
 void
 MatrixClient::initialSync() noexcept
 {
-	QJsonArray excluded_presence = {
-		QString("m.presence"),
-	};
+        QJsonArray excluded_presence = {
+                QString("m.presence"),
+        };
 
-	QJsonObject filter{ { "room",
-			      QJsonObject{ { "timeline", QJsonObject{ { "limit", 20 } } },
-					   { "ephemeral", QJsonObject{ { "limit", 0 } } } } },
-			    { "presence", QJsonObject{ { "not_types", excluded_presence } } } };
+        QJsonObject filter{ { "room",
+                              QJsonObject{ { "timeline", QJsonObject{ { "limit", 20 } } },
+                                           { "ephemeral", QJsonObject{ { "limit", 0 } } } } },
+                            { "presence", QJsonObject{ { "not_types", excluded_presence } } } };
 
-	QUrlQuery query;
-	query.addQueryItem("full_state", "true");
-	query.addQueryItem("set_presence", "online");
-	query.addQueryItem("filter", QJsonDocument(filter).toJson(QJsonDocument::Compact));
-	query.addQueryItem("access_token", token_);
+        QUrlQuery query;
+        query.addQueryItem("full_state", "true");
+        query.addQueryItem("set_presence", "online");
+        query.addQueryItem("filter", QJsonDocument(filter).toJson(QJsonDocument::Compact));
+        query.addQueryItem("access_token", token_);
 
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/sync");
-	endpoint.setQuery(query);
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/sync");
+        endpoint.setQuery(query);
 
-	QNetworkRequest request(QString(endpoint.toEncoded()));
+        QNetworkRequest request(QString(endpoint.toEncoded()));
 
-	QNetworkReply *reply = get(request);
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::InitialSync));
+        QNetworkReply *reply = get(request);
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::InitialSync));
 }
 
 void
 MatrixClient::versions() noexcept
 {
-	QUrl endpoint(server_);
-	endpoint.setPath("/_matrix/client/versions");
+        QUrl endpoint(server_);
+        endpoint.setPath("/_matrix/client/versions");
 
-	QNetworkRequest request(endpoint);
+        QNetworkRequest request(endpoint);
 
-	QNetworkReply *reply = get(request);
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::Versions));
+        QNetworkReply *reply = get(request);
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::Versions));
 }
 
 void
 MatrixClient::getOwnProfile() noexcept
 {
-	// FIXME: Remove settings from the matrix client. The class should store the user's matrix ID.
-	QSettings settings;
-	auto userid = settings.value("auth/user_id", "").toString();
+        // FIXME: Remove settings from the matrix client. The class should store the user's matrix
+        // ID.
+        QSettings settings;
+        auto userid = settings.value("auth/user_id", "").toString();
 
-	QUrlQuery query;
-	query.addQueryItem("access_token", token_);
+        QUrlQuery query;
+        query.addQueryItem("access_token", token_);
 
-	QUrl endpoint(server_);
-	endpoint.setPath(api_url_ + "/profile/" + userid);
-	endpoint.setQuery(query);
+        QUrl endpoint(server_);
+        endpoint.setPath(api_url_ + "/profile/" + userid);
+        endpoint.setQuery(query);
 
-	QNetworkRequest request(QString(endpoint.toEncoded()));
+        QNetworkRequest request(QString(endpoint.toEncoded()));
 
-	QNetworkReply *reply = get(request);
-	reply->setProperty("endpoint", static_cast<int>(Endpoint::GetOwnProfile));
+        QNetworkReply *reply = get(request);
+        reply->setProperty("endpoint", static_cast<int>(Endpoint::GetOwnProfile));
 }
 
 void
 MatrixClient::fetchRoomAvatar(const QString &roomid, const QUrl &avatar_url)
 {
-	QList<QString> url_parts = avatar_url.toString().split("mxc://");
+        QList<QString> url_pa