Rasmus Karlsson
a372bae80d
This is done in a way which should simplify abstracting it to other types of accounts if needed in the future Remove comment about removing singletons - we're keeping them (and probably restoring some) IrcManager now updates its "account" reference automatically through the AccountManager.Twitch.userChanged-signal Remove unused IrcManager getUser-method IrcManager::beginConnecting is no longer called asynchronously. This might want to be reverted in a more controlled asynchronous manner. User Accounts are now stored as Shared Pointers instead of using references/copies everywhere
120 lines
3.5 KiB
C++
120 lines
3.5 KiB
C++
#pragma once
|
|
|
|
#include "accountmanager.hpp"
|
|
#include "credentials.hpp"
|
|
#include "util/networkmanager.hpp"
|
|
|
|
#include <QEventLoop>
|
|
#include <QJsonArray>
|
|
#include <QJsonDocument>
|
|
#include <QJsonObject>
|
|
#include <QJsonValue>
|
|
#include <QNetworkAccessManager>
|
|
#include <QNetworkReply>
|
|
#include <QNetworkRequest>
|
|
#include <QString>
|
|
#include <QTimer>
|
|
|
|
#include <QDebug>
|
|
|
|
#include <functional>
|
|
|
|
namespace chatterino {
|
|
namespace util {
|
|
|
|
static QJsonObject parseJSONFromReply(QNetworkReply *reply)
|
|
{
|
|
if (reply->error() != QNetworkReply::NetworkError::NoError) {
|
|
return QJsonObject();
|
|
}
|
|
|
|
QByteArray data = reply->readAll();
|
|
QJsonDocument jsonDoc(QJsonDocument::fromJson(data));
|
|
|
|
if (jsonDoc.isNull()) {
|
|
return QJsonObject();
|
|
}
|
|
|
|
return jsonDoc.object();
|
|
}
|
|
|
|
namespace twitch {
|
|
|
|
static void get(QString url, const QObject *caller,
|
|
std::function<void(QJsonObject &)> successCallback)
|
|
{
|
|
util::NetworkRequest req(url);
|
|
req.setCaller(caller);
|
|
req.setRawHeader("Client-ID", getDefaultClientID());
|
|
req.setRawHeader("Accept", "application/vnd.twitchtv.v5+json");
|
|
req.get([=](QNetworkReply *reply) {
|
|
auto node = parseJSONFromReply(reply);
|
|
successCallback(node);
|
|
});
|
|
}
|
|
|
|
static void getUserID(QString username, const QObject *caller,
|
|
std::function<void(QString)> successCallback)
|
|
{
|
|
get("https://api.twitch.tv/kraken/users?login=" + username, caller,
|
|
[=](const QJsonObject &root) {
|
|
if (!root.value("users").isArray()) {
|
|
qDebug() << "API Error while getting user id, users is not an array";
|
|
return;
|
|
}
|
|
|
|
auto users = root.value("users").toArray();
|
|
if (users.size() != 1) {
|
|
qDebug() << "API Error while getting user id, users array size is not 1";
|
|
return;
|
|
}
|
|
if (!users[0].isObject()) {
|
|
qDebug() << "API Error while getting user id, first user is not an object";
|
|
return;
|
|
}
|
|
auto firstUser = users[0].toObject();
|
|
auto id = firstUser.value("_id");
|
|
if (!id.isString()) {
|
|
qDebug() << "API Error: while getting user id, first user object `_id` key is not "
|
|
"a string";
|
|
return;
|
|
}
|
|
successCallback(id.toString());
|
|
});
|
|
}
|
|
static void put(QUrl url, std::function<void(QJsonObject)> successCallback)
|
|
{
|
|
auto manager = new QNetworkAccessManager();
|
|
QNetworkRequest request(url);
|
|
|
|
auto &accountManager = AccountManager::getInstance();
|
|
auto currentTwitchUser = accountManager.Twitch.getCurrent();
|
|
QByteArray oauthToken;
|
|
if (currentTwitchUser) {
|
|
oauthToken = currentTwitchUser->getOAuthToken().toUtf8();
|
|
} else {
|
|
// XXX(pajlada): Bail out?
|
|
}
|
|
|
|
request.setRawHeader("Client-ID", getDefaultClientID());
|
|
request.setRawHeader("Accept", "application/vnd.twitchtv.v5+json");
|
|
request.setRawHeader("Authorization", "OAuth " + oauthToken);
|
|
|
|
NetworkManager::urlPut(std::move(request), [=](QNetworkReply *reply) {
|
|
if (reply->error() == QNetworkReply::NetworkError::NoError) {
|
|
QByteArray data = reply->readAll();
|
|
QJsonDocument jsonDoc(QJsonDocument::fromJson(data));
|
|
if (!jsonDoc.isNull()) {
|
|
QJsonObject rootNode = jsonDoc.object();
|
|
|
|
successCallback(rootNode);
|
|
}
|
|
}
|
|
reply->deleteLater();
|
|
});
|
|
}
|
|
|
|
} // namespace twitch
|
|
} // namespace util
|
|
} // namespace chatterino
|