WebSocket.h

#pragma once
 
#include "mc/_HeaderOutputPredefine.h"
 
// auto generated inclusion list
#include "mc/deps/core/http/StatusCode.h"
#include "mc/deps/core/threading/Async.h"
#include "mc/deps/core/threading/AsyncPromise.h"
#include "mc/platform/brstd/future.h"
 
// auto generated forward declare list
// clang-format off
struct XAsyncBlock;
namespace Bedrock::Http { class HeaderCollection; }
struct HC_WEBSOCKET_OBSERVER;
// clang-format on
 
namespace Bedrock::Http {
 
class WebSocket : public ::std::enable_shared_from_this<::Bedrock::Http::WebSocket> {
public:
    // member variables
    // NOLINTBEGIN
    ::ll::UntypedStorage<8, 80> mUnk59fcc6;
    ::ll::UntypedStorage<8, 8>  mUnk2d81af;
    ::ll::UntypedStorage<8, 8>  mUnk5cda29;
    // NOLINTEND
 
public:
    // prevent constructor by default
    WebSocket& operator=(WebSocket const&);
    WebSocket(WebSocket const&);
    WebSocket();
 
public:
    // virtual functions
    // NOLINTBEGIN
    virtual ~WebSocket() = default;
 
    virtual ::Bedrock::Threading::Async<::std::error_code> send(::std::string const& message) const;
 
    virtual void onMessage(::std::string_view incomingMessage);
 
    virtual void onBinaryMessage(::gsl::span<uchar const>);
 
    virtual void onClose(uint status);
    // NOLINTEND
 
public:
    // member functions
    // NOLINTBEGIN
    MCNAPI ::HC_WEBSOCKET_OBSERVER* _allocateSocket(::brstd::future<void> connectCompleted);
 
    MCNAPI ::Bedrock::Threading::Async<::nonstd::expected<::Bedrock::Http::StatusCode, ::std::error_code>>
    connect(::std::string const& uri, ::Bedrock::Http::HeaderCollection const& headers);
    // NOLINTEND
 
public:
    // static functions
    // NOLINTBEGIN
    MCNAPI static void _deallocateSocketAsync(::HC_WEBSOCKET_OBSERVER* handle);
 
    MCNAPI static void _onConnect(
        ::XAsyncBlock*                              asyncConnect,
        ::std::weak_ptr<::Bedrock::Http::WebSocket> weakThis,
        ::Bedrock::Threading::AsyncPromise<::nonstd::expected<::Bedrock::Http::StatusCode, ::std::error_code>>
                                 onComplete,
        ::HC_WEBSOCKET_OBSERVER* connectHandle
    );
 
    MCNAPI static void
    _onSend(::XAsyncBlock* asyncSend, ::Bedrock::Threading::AsyncPromise<::std::error_code> onComplete);
    // NOLINTEND
 
public:
    // virtual function thunks
    // NOLINTBEGIN
    MCNAPI ::Bedrock::Threading::Async<::std::error_code> $send(::std::string const& message) const;
 
    MCNAPI void $onMessage(::std::string_view incomingMessage);
 
    MCNAPI void $onBinaryMessage(::gsl::span<uchar const>);
 
    MCNAPI void $onClose(uint status);
 
 
    // NOLINTEND
 
public:
    // vftables
    // NOLINTBEGIN
    MCNAPI static void** $vftable();
    // NOLINTEND
};
 
} // namespace Bedrock::Http