directplaypeer.h

// SPDX-FileCopyrightText: Copyright (C) 2014 swift Project Community / Contributors
// SPDX-License-Identifier: GPL-3.0-or-later OR LicenseRef-swift-pilot-client-1
 
#ifndef SWIFT_SIMPLUGIN_FS9_DIRECTPLAY_PEER_H
#define SWIFT_SIMPLUGIN_FS9_DIRECTPLAY_PEER_H
 
#include <dplay8.h>
 
#include <atomic>
#include <functional>
 
#include <QList>
#include <QObject>
#include <QScopedPointer>
 
#include "callbackwrapper.h"
#include "fs9.h"
#include "hostnode.h"
 
#include "misc/aviation/callsign.h"
#include "misc/logcategorylist.h"
 
namespace swift::simplugin::fs9
{
    HRESULT inline s_success_pending() { return DPNSUCCESS_PENDING; }
    bool inline isPending(HRESULT hr) { return hr == s_success_pending(); }
 
    class CDirectPlayPeer : public QObject
    {
        Q_OBJECT
 
    public:
        CDirectPlayPeer(const swift::misc::aviation::CCallsign &callsign, QObject *parent = nullptr);
 
        virtual ~CDirectPlayPeer() override;
 
        DPNID getPlayerUserId() const { return m_playerUser; }
 
        void setPlayerUserId(DPNID id) { m_playerUser = id; }
 
        static const QStringList &getLogCategories();
 
    public slots:
        HRESULT sendMessage(const QByteArray &data);
 
        void reset();
 
    signals:
        void customPacketReceived(const QByteArray &data);
 
        void connectionComplete();
 
    protected:
        HRESULT directPlayMessageHandler(DWORD messageId, void *msgBuffer);
 
        HRESULT initDirectPlay();
 
        bool isServiceProviderValid(const GUID *pGuidSP);
 
        HRESULT createDeviceAddress();
 
        HRESULT createHostAddress();
 
        const swift::misc::aviation::CCallsign m_callsign; 
 
        IDirectPlay8Peer *m_directPlayPeer = nullptr; 
        IDirectPlay8Address *m_deviceAddress = nullptr; 
 
        QList<CHostNode> m_hostNodeList; 
        quint32 m_packetIndex = 0; 
 
        // DirectPlay Player Id's
        std::atomic<DPNID> m_playerLocal = { 0 }; 
        // We need the Id of the users player, because we are sending packets only to him
        std::atomic<DPNID> m_playerUser = { 0 }; 
 
        using TCallbackWrapper =
            CallbackWrapper<CDirectPlayPeer, HRESULT, DWORD, void *>; 
        TCallbackWrapper m_callbackWrapper; 
 
    private:
        bool m_coInitializeSucceeded = false;
    };
} // namespace swift::simplugin::fs9
 
#endif // SWIFT_SIMPLUGIN_FS9_DIRECTPLAY_PEER_H