EmbyExplorerQt/restapi.cpp at master · SideFx/EmbyExplorerQt · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
//-----------------------------------------------------------------------------------------------------------
// Emby Explorer (Qt) (w) 2024-2025 by Jan Buchholz
// Simple REST API
// last change: 20251128
//-----------------------------------------------------------------------------------------------------------
#include "restapi.h"
#include <QEventLoop>
#include <QNetworkReply>
#include <QTimer>

RestApi::RestApi(QObject *parent) : QObject{parent} {
    netManager = new QNetworkAccessManager();
    netFactory = new QNetworkRequestFactory();
}

RestApi::~RestApi() {
    delete netFactory;
    delete netManager;
}

QByteArray RestApi::makeRestCallGET(restParameters para, QNetworkReply::NetworkError *e) {
    QByteArray r;
    QNetworkReply *reply;
    netFactory->setBaseUrl(para.url);
    netFactory->setCommonHeaders(para.headers);
    QNetworkRequest request = netFactory->createRequest();
    reply = netManager->get(request);
    QEventLoop loop;
    // finished
    QObject::connect(reply, &QNetworkReply::finished, &loop, [&]() {
        loop.quit();
    });
    auto* timer = new QTimer(reply);
    timer->setSingleShot(true);
    // timeout
    QObject::connect(timer, &QTimer::timeout, &loop, [&]() {
        loop.quit();
    });
    timer->start(5000);
    loop.exec();
    *e = reply->error();
    r = reply->readAll();
    delete reply;
    return r;
}


QByteArray RestApi::makeRestCallPOST(restParameters para, QNetworkReply::NetworkError *e) {
    QByteArray r;
    QNetworkReply *reply;
    netFactory->setBaseUrl(para.url);
    netFactory->setCommonHeaders(para.headers);
    QNetworkRequest request = netFactory->createRequest();
    reply = netManager->post(request, para.body);
    QEventLoop loop;
    // finished
    QObject::connect(reply, &QNetworkReply::finished, &loop, [&]() {
        loop.quit();
    });
    auto* timer = new QTimer(reply);
    timer->setSingleShot(true);
    // timeout
    QObject::connect(timer, &QTimer::timeout, &loop, [&]() {
        loop.quit();
    });
    timer->start(5000);
    loop.exec();
    *e = reply->error();
    r = reply->readAll();
    delete reply;
    return r;
}