MessageTracker.h

#pragma once
 
#include "mc/_HeaderOutputPredefine.h"
 
// auto generated inclusion list
#include "mc/deps/nether_net/ESessionError.h"
#include "mc/deps/nether_net/NetworkID.h"
#include "mc/network/services/signaling/MessagePerformance.h"
#include "mc/network/services/signaling/player_messaging/NetworkID.h"
 
// auto generated forward declare list
// clang-format off
class ISignalingServiceTelemetry;
class MessagePerformance;
namespace JsonRpc { class JsonRpcError; }
namespace mce { class UUID; }
// clang-format on
 
class MessageTracker {
public:
    // MessageTracker inner types declare
    // clang-format off
    struct Destination;
    struct MessageStatus;
    // clang-format on
 
    // MessageTracker inner types define
    struct Destination : public ::std::variant<::NetherNet::NetworkID, ::PlayerMessaging::NetworkID> {};
 
    struct MessageStatus {
    public:
        // member variables
        // NOLINTBEGIN
        ::ll::UntypedStorage<8, 16> mUnke1b276;
        ::ll::UntypedStorage<8, 16> mUnkc4ec43;
        ::ll::UntypedStorage<8, 16> mUnkff686d;
        ::ll::UntypedStorage<8, 64> mUnk8f7071;
        ::ll::UntypedStorage<1, 1>  mUnk8a6cb0;
        // NOLINTEND
 
    public:
        // prevent constructor by default
        MessageStatus& operator=(MessageStatus const&);
        MessageStatus(MessageStatus const&);
        MessageStatus();
    };
 
public:
    // member variables
    // NOLINTBEGIN
    ::ll::UntypedStorage<8, 16> mUnk3969f8;
    ::ll::UntypedStorage<8, 80> mUnkc507e5;
    ::ll::UntypedStorage<8, 80> mUnk3dedd3;
    ::ll::UntypedStorage<8, 48> mUnkbcdda6;
    ::ll::UntypedStorage<8, 48> mUnkdc3254;
    ::ll::UntypedStorage<8, 8>  mUnkc75976;
    ::ll::UntypedStorage<8, 8>  mUnk11e362;
    // NOLINTEND
 
public:
    // prevent constructor by default
    MessageTracker& operator=(MessageTracker const&);
    MessageTracker(MessageTracker const&);
    MessageTracker();
 
public:
    // member functions
    // NOLINTBEGIN
    MCNAPI explicit MessageTracker(::gsl::not_null<::std::shared_ptr<::ISignalingServiceTelemetry>> telemetry);
 
    MCNAPI ::std::vector<::MessagePerformance> _clear();
 
    MCNAPI void _complete(
        ::NetherNet::ESessionError        result,
        ::mce::UUID                       key,
        ::MessageTracker::MessageStatus&& value,
        ::MessagePerformance::Status      status
    );
 
    MCNAPI void _continueTracking(::mce::UUID key, ::MessageTracker::MessageStatus&& value);
 
    MCNAPI void _tryGetValue(
        ::std::string const&                                                    messageId,
        ::std::function<void(::mce::UUID, ::MessageTracker::MessageStatus&&)>&& fn
    );
 
    MCNAPI void
    add(::std::string const& messageId, ::std::function<void(::NetherNet::ESessionError)>&& onComplete, bool isP2P);
 
    MCNAPI void messageAccepted(::std::string const& messageId);
 
    MCNAPI void messageDelivered(::std::string const& messageId);
 
    MCNAPI void messageError(::std::string const& messageId, ::JsonRpc::JsonRpcError const& error);
 
    MCNAPI void messageError(::std::string const& messageId, ::NetherNet::ESessionError error);
 
    MCNAPI void messageSent(
        ::std::optional<::MessageTracker::Destination> to,
        ::std::string const&                           message,
        ::std::string const&                           messageId,
        ::std::error_code                              error
    );
 
    MCNAPI bool queryAndUpdateIsMessageIgnored(::std::string const& messageId);
 
    MCNAPI ~MessageTracker();
    // NOLINTEND
 
public:
    // constructor thunks
    // NOLINTBEGIN
    MCNAPI void* $ctor(::gsl::not_null<::std::shared_ptr<::ISignalingServiceTelemetry>> telemetry);
    // NOLINTEND
 
public:
    // destructor thunk
    // NOLINTBEGIN
    MCNAPI void $dtor();
    // NOLINTEND
};