NetAccess/initiator.cpp at master · smarusik/NetAccess · 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
#include "initiator.h"

Initiator::Initiator(QObject *parent):
    QObject(parent),
    anonymousToken(new Subject(DataType::ANONYMOUS_TOKEN)),
    accessToken(new Subject(DataType::ACCESS_TOKEN)),
    proxyAccessToken(new Subject(DataType::PROXY_ACCESS_TOKEN)),
    autoserverLocation(new Subject(DataType::AUTOSERVER_LOCATION))
{
    connect(anonymousToken, &Subject::data_ready,
            this, &Initiator::requestedDataReady,
            Qt::QueuedConnection);
    connect(anonymousToken, &Subject::error_occured,
            this, &Initiator::reportError,
            Qt::QueuedConnection);

    connect(accessToken, &Subject::data_ready,
            this, &Initiator::requestedDataReady,
            Qt::QueuedConnection);
    connect(accessToken, &Subject::error_occured,
            this, &Initiator::reportError,
            Qt::QueuedConnection);

    connect(proxyAccessToken, &Subject::data_ready,
            this, &Initiator::requestedDataReady,
            Qt::QueuedConnection);
    connect(proxyAccessToken, &Subject::error_occured,
            this, &Initiator::reportError,
            Qt::QueuedConnection);

    connect(autoserverLocation, &Subject::data_ready,
            this, &Initiator::requestedDataReady,
            Qt::QueuedConnection);
    connect(autoserverLocation, &Subject::error_occured,
            this, &Initiator::reportError,
            Qt::QueuedConnection);
}

void Initiator::anonymousTokenRq(QNetworkRequest rq, QByteArray payload)
{
    emit subjectUpdateRequested(anonymousToken, rq, payload);
}

void Initiator::accessTokenRq(QNetworkRequest rq, QByteArray payload)
{
    emit subjectUpdateRequested(accessToken,rq, payload);
}

void Initiator::proxyAccessTokenRq(QNetworkRequest rq, QByteArray payload)
{
    emit subjectUpdateRequested(proxyAccessToken,rq, payload);
}

void Initiator::autoserverLocationRq(QNetworkRequest rq, QByteArray payload)
{
    emit subjectUpdateRequested(autoserverLocation,rq, payload);
}