duplex.cpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (C) 2020 swift Project Community / Contributors
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-swift-pilot-client-1

 
#include "misc/sharedstate/dbus/duplex.h"
 
namespace swift::misc::shared_state::dbus
{
    IDuplex::IDuplex(QObject *parent) : QObject(parent)
    {
        connect(this, &IDuplex::replyReceived, this, [this](const QString &, const CVariant &param, quint32 token) {
            const auto it = m_submittedRequests.find(token);
            if (it == m_submittedRequests.end())
            {
                return;
            }
            it->setResult(param);
            m_submittedRequests.erase(it);
        });
    }
 
    QFuture<CVariant> IDuplex::submitRequest(const QString &channel, const CVariant &param)
    {
        const auto token = getToken();
        auto future = m_submittedRequests.insert(token, {})->future();
        submitRequest(channel, param, token);
        return future;
    }
 
    QFuture<CVariant> IDuplex::receiveRequest(const QString &channel, const swift::misc::CVariant &param)
    {
        const auto token = getToken();
        auto future = m_receivedRequests.insert(token, {})->future();
        emit requestReceived(channel, param, token, QPrivateSignal {});
        return future;
    }
 
    void IDuplex::reply(const swift::misc::CVariant &param, quint32 token)
    {
        const auto it = m_receivedRequests.find(token);
        if (it == m_receivedRequests.end())
        {
            return;
        }
        it->setResult(param);
        m_receivedRequests.erase(it);
    }
 
    quint32 IDuplex::getToken() { return m_token++; }
} // namespace swift::misc::shared_state::dbus