parent
fab413327c
commit
340c9ab9de
8 changed files with 341 additions and 78 deletions
|
|
@ -18,10 +18,13 @@
|
|||
#pragma once
|
||||
|
||||
#include <QFileInfo>
|
||||
#include <QJsonDocument>
|
||||
#include <QNetworkAccessManager>
|
||||
#include <QNetworkReply>
|
||||
#include <QNetworkRequest>
|
||||
#include <QUrl>
|
||||
#include <mtx.hpp>
|
||||
#include <mtx/errors.hpp>
|
||||
|
||||
class DownloadMediaProxy : public QObject
|
||||
{
|
||||
|
|
@ -33,6 +36,15 @@ signals:
|
|||
void avatarDownloaded(const QImage &img);
|
||||
};
|
||||
|
||||
class StateEventProxy : public QObject
|
||||
{
|
||||
Q_OBJECT
|
||||
|
||||
signals:
|
||||
void stateEventSent();
|
||||
void stateEventError(const QString &msg);
|
||||
};
|
||||
|
||||
Q_DECLARE_METATYPE(mtx::responses::Sync)
|
||||
|
||||
/*
|
||||
|
|
@ -48,6 +60,10 @@ public:
|
|||
// Client API.
|
||||
void initialSync() noexcept;
|
||||
void sync() noexcept;
|
||||
template<class EventBody, mtx::events::EventType EventT>
|
||||
std::shared_ptr<StateEventProxy> sendStateEvent(const EventBody &body,
|
||||
const QString &roomId,
|
||||
const QString &stateKey = "");
|
||||
void sendRoomMessage(mtx::events::MessageType ty,
|
||||
int txnId,
|
||||
const QString &roomid,
|
||||
|
|
@ -221,3 +237,50 @@ init();
|
|||
MatrixClient *
|
||||
client();
|
||||
}
|
||||
|
||||
template<class EventBody, mtx::events::EventType EventT>
|
||||
std::shared_ptr<StateEventProxy>
|
||||
MatrixClient::sendStateEvent(const EventBody &body, const QString &roomId, const QString &stateKey)
|
||||
{
|
||||
QUrl endpoint(server_);
|
||||
endpoint.setPath(clientApiUrl_ + QString("/rooms/%1/state/%2/%3")
|
||||
.arg(roomId)
|
||||
.arg(QString::fromStdString(to_string(EventT)))
|
||||
.arg(stateKey));
|
||||
|
||||
QNetworkRequest request(QString(endpoint.toEncoded()));
|
||||
request.setHeader(QNetworkRequest::ContentTypeHeader, "application/json");
|
||||
setupAuth(request);
|
||||
|
||||
auto proxy = std::shared_ptr<StateEventProxy>(new StateEventProxy,
|
||||
[](auto proxy) { proxy->deleteLater(); });
|
||||
|
||||
auto serializedBody = nlohmann::json(body).dump();
|
||||
auto reply = put(request, QByteArray(serializedBody.data(), serializedBody.size()));
|
||||
connect(reply, &QNetworkReply::finished, this, [reply, proxy]() {
|
||||
reply->deleteLater();
|
||||
|
||||
int status = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute).toInt();
|
||||
auto data = reply->readAll();
|
||||
|
||||
if (status == 0 || status >= 400) {
|
||||
try {
|
||||
mtx::errors::Error res = nlohmann::json::parse(data);
|
||||
emit proxy->stateEventError(QString::fromStdString(res.error));
|
||||
} catch (const std::exception &e) {
|
||||
emit proxy->stateEventError(QString::fromStdString(e.what()));
|
||||
}
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
mtx::responses::EventId res = nlohmann::json::parse(data);
|
||||
emit proxy->stateEventSent();
|
||||
} catch (const std::exception &e) {
|
||||
emit proxy->stateEventError(QString::fromStdString(e.what()));
|
||||
}
|
||||
});
|
||||
|
||||
return proxy;
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue