backend.cpp

#include "backend.h"

#if defined(Q_OS_LINUX)
    #include "platform/linux_x11/linux_system.h"
#elif defined(Q_OS_WIN)
    #include "platform/windows/windows_system.h"
#endif

ISystem* getSystemApi()
{
#if defined(Q_OS_LINUX)
    return new LinuxSystem();
#elif defined(Q_OS_WIN)
    return new WindowsSystem();
#else
    #error "Plataforma no soportada"
#endif
}

Backend::Backend(QObject &parent)
{
    systemApi = getSystemApi();
    networkManager = new QNetworkAccessManager(&parent);
    networkManager->setCookieJar(new PersistentCookieJar(networkManager));
    //setupProxy(networkManager);
}

QString handleError(QNetworkReply *reply)
{
    if (reply->error() == QNetworkReply::NoError)
        return NULL;

    QString body(reply->readAll());

    QJsonDocument responseJson = QJsonDocument::fromJson(body.toUtf8());
    QJsonObject errorJsonObject = responseJson["error"].toObject();

    if (!errorJsonObject.isEmpty())
    {
        QJsonValue errorType = errorJsonObject["type"];
        return errorType.toString();
    }

    return reply->errorString();
}

void Backend::handleReplyCallback(QNetworkReply *reply, const QJSValue &callback) const
{
    connect(reply, &QNetworkReply::finished, [=]() {
        QJSValue cbCopy(callback);
        QJSEngine *engine = qjsEngine(this);
        QString error = handleError(reply);

        cbCopy.call(QJSValueList {
            engine->toScriptValue(reply->readAll()),
            engine->toScriptValue(error)
        });

        reply->deleteLater();
    });
}

QNetworkReply* Backend::fetchCurrentUser() const
{
    QNetworkRequest request(QUrl(TIMEIT_BACKEND_URL "/current-user"));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->get(request);

    return reply;
}

void Backend::js_fetchCurrentUser(const QJSValue &callback) const
{
    QNetworkReply* reply = fetchCurrentUser();
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::deauthenticateUser() const
{
    QNetworkRequest request(QUrl(TIMEIT_BACKEND_URL "/deauthenticate"));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, QByteArray());

    return reply;
}

void Backend::js_deauthenticateUser(const QJSValue &callback) const
{
    QNetworkReply* reply = deauthenticateUser();
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::authenticateUser(const QString &emailAddress, const QString &password) const
{
    QUrlQuery formData;
    formData.addQueryItem("emailAddress", emailAddress);
    formData.addQueryItem("password", password);

    QNetworkRequest request(QUrl(TIMEIT_BACKEND_URL "/authenticate"));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, formData.toString(QUrl::FullyEncoded).toUtf8());

    return reply;
}

void Backend::js_authenticateUser(const QString &emailAddress, const QString &password, const QJSValue &callback) const
{
    QNetworkReply* reply = authenticateUser(emailAddress, password);
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::fetchProjectList() const
{
    QNetworkRequest request(QUrl(TIMEIT_BACKEND_URL "/projects"));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->get(request);

    return reply;
}

void Backend::js_fetchProjectList(const QJSValue &callback) const
{
    QNetworkReply* reply = fetchProjectList();
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::createSession(quint32 projectId) const
{
    QNetworkRequest request(QUrl(QString(TIMEIT_BACKEND_URL "/projects/%1/sessions").arg(projectId)));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, QByteArray());

    return reply;
}

void Backend::js_createSession(quint32 projectId, const QJSValue &callback) const
{
    QNetworkReply* reply = createSession(projectId);
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::endSession(quint32 sessionId) const
{
    QNetworkRequest request(QUrl(QString(TIMEIT_BACKEND_URL "/sessions/%1/end").arg(sessionId)));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, QByteArray());

    return reply;
}

void Backend::js_endSession(quint32 sessionId, const QJSValue &callback) const
{
    QNetworkReply* reply = endSession(sessionId);
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::sendNote(quint32 sessionId, const QString &noteText) const
{
    QUrlQuery formData;
    formData.addQueryItem("noteText", noteText);

    QNetworkRequest request(QUrl(QString(TIMEIT_BACKEND_URL "/sessions/%1/notes").arg(sessionId)));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, formData.toString(QUrl::FullyEncoded).toUtf8());

    return reply;
}

void Backend::js_sendNote(quint32 sessionId, const QString &noteText, const QJSValue &callback) const
{
    QNetworkReply* reply = sendNote(sessionId, noteText);
    handleReplyCallback(reply, callback);
}

QNetworkReply* Backend::sendAppEvent(quint32 sessionId, const ISystem::WindowProps &windowProps) const
{
    QUrlQuery formData;
    formData.addQueryItem("windowName", windowProps.windowName);
    formData.addQueryItem("windowClass", windowProps.windowClass);
    formData.addQueryItem("windowPid", QString::number(windowProps.windowPid));

    QNetworkRequest request(QUrl(QString(TIMEIT_BACKEND_URL "/sessions/%1/app_events").arg(sessionId)));
    request.setHeader(QNetworkRequest::ContentTypeHeader, "application/x-www-form-urlencoded");
    QNetworkReply *reply = networkManager->post(request, formData.toString(QUrl::FullyEncoded).toUtf8());

    return reply;
}

QNetworkReply* Backend::createAppEvent(quint32 sessionId) const
{
    ISystem::WindowProps windowProps = systemApi->getCurrentFocusedWindow();
    return sendAppEvent(sessionId, windowProps);
}

void Backend::js_createAppEvent(quint32 sessionId, const QJSValue &callback) const
{
    QNetworkReply* reply = createAppEvent(sessionId);
    handleReplyCallback(reply, callback);
}