1 files changed, 108 insertions, 0 deletions
diff --git a/src/github.h b/src/github.h
new file mode 100644
index 00000000..0085fd5a
--- /dev/null
+++ b/src/github.h
@@ -0,0 +1,108 @@
+#pragma once
+
+#include <QJsonArray>
+#include <QJsonDocument>
+#include <QJsonObject>
+#include <QNetworkAccessManager>
+#include <QNetworkCookieJar>
+#include <QNetworkReply>
+#include <QTimer>
+#include <functional>
+
+class GitHubException : public std::exception
+{
+public:
+  GitHubException(const QJsonObject& errorObj) : std::exception()
+  {
+    initMessage(errorObj);
+  }
+
+  virtual ~GitHubException() throw() override {}
+
+  virtual const char* what() const throw() { return m_Message.constData(); }
+
+private:
+  void initMessage(const QJsonObject& obj)
+  {
+    if (obj.contains("http_status")) {
+      m_Message = QString("HTTP Status %1: %2")
+                      .arg(obj.value("http_status").toInt())
+                      .arg(obj.value("reason").toString())
+                      .toUtf8();
+    } else if (obj.contains("parse_error")) {
+      m_Message = QString("Parsing failed: %1")
+                      .arg(obj.value("parse_error").toString())
+                      .toUtf8();
+    } else if (obj.contains("network_error")) {
+      m_Message = QString("Network failed: %1")
+                      .arg(obj.value("network_error").toString())
+                      .toUtf8();
+    } else {
+      m_Message = "Unknown error";
+    }
+  }
+
+  QByteArray m_Message;
+};
+
+class GitHub : public QObject
+{
+
+  Q_OBJECT
+
+public:
+  enum class Method
+  {
+    GET,
+    POST
+  };
+
+  struct Repository
+  {
+    Repository(const QString& owner, const QString& project)
+        : owner(owner), project(project)
+    {}
+    QString owner;
+    QString project;
+  };
+
+public:
+  GitHub(const char* clientId = nullptr);
+  ~GitHub();
+
+  QJsonArray releases(const Repository& repo);
+  void releases(const Repository& repo,
+                const std::function<void(const QJsonArray&)>& callback);
+
+private:
+  QJsonDocument request(Method method, const QString& path, const QByteArray& data,
+                        bool relative);
+  void request(Method method, const QString& path, const QByteArray& data,
+               const std::function<void(const QJsonDocument&)>& callback,
+               bool relative);
+
+  QJsonDocument handleReply(QNetworkReply* reply);
+  QNetworkReply* genReply(Method method, const QString& path, const QByteArray& data,
+                          bool relative);
+
+private:
+  struct Request
+  {
+    Method method = Method::GET;
+    QByteArray data;
+    std::function<void(const QJsonDocument&)> callback;
+    QTimer* timer        = nullptr;
+    QNetworkReply* reply = nullptr;
+  };
+
+  QNetworkAccessManager* m_AccessManager;
+
+  // remember the replies that are in flight and delete them in the destructor
+  std::vector<QNetworkReply*> m_replies;
+
+  void onFinished(const Request& req);
+  void onError(const Request& req, QNetworkReply::NetworkError error);
+  void onTimeout(const Request& req);
+
+  void deleteReply(QNetworkReply* reply);
+};