restapi.cpp

//-----------------------------------------------------------------------------------------------------------
// Emby Explorer (Qt) (w) 2024-2025 by Jan Buchholz
// Simple REST API
// last change: 2026-05-23
//-----------------------------------------------------------------------------------------------------------
#include "restapi.h"
#include <QEventLoop>
#include <QNetworkReply>
#include <QTimer>

RestApi::RestApi(QObject *parent) : QObject{parent}, netManager(new QNetworkAccessManager(this)) {}

RestApi::~RestApi() {}

QByteArray RestApi::makeRestCallGET(restParameters para, QNetworkReply::NetworkError *e) {
    QNetworkRequestFactory factory;
    factory.setBaseUrl(para.url);
    factory.setCommonHeaders(para.headers);
    QNetworkRequest request = factory.createRequest();
    QNetworkReply* reply = netManager->get(request);
    return performSyncRequest(reply, e);
}


QByteArray RestApi::makeRestCallPOST(restParameters para, QNetworkReply::NetworkError *e) {
    QNetworkRequestFactory factory;
    factory.setBaseUrl(para.url);
    factory.setCommonHeaders(para.headers);
    QNetworkRequest request = factory.createRequest();
    QNetworkReply* reply = netManager->post(request, para.body);
    return performSyncRequest(reply, e);
}

QByteArray RestApi::performSyncRequest(QNetworkReply* reply, QNetworkReply::NetworkError* e) {
    QEventLoop loop;
    QObject::connect(reply, &QNetworkReply::finished, &loop, &QEventLoop::quit);
    auto* timer = new QTimer(reply);
    timer->setSingleShot(true);
    QObject::connect(timer, &QTimer::timeout, &loop, &QEventLoop::quit);
    timer->start(5000);
    loop.exec();
    // ---Timeout?---
    if (!timer->isActive()) {
        *e = QNetworkReply::TimeoutError;
    } else {
        *e = reply->error();
    }
    QByteArray r = reply->readAll();
    reply->deleteLater();
    return r;
}