WebSocketClient.h

Go to the documentation of this file.

// Copyright (c) 2025 Dave R. Smith.
// Malena Framework — Licensed under PolyForm Noncommercial 1.0.0; commercial use requires a paid license. See LICENSE.
 
#ifndef MALENA_WEBSOCKETCLIENT_H
#define MALENA_WEBSOCKETCLIENT_H
 
#pragma once
 
#include <Malena/Core/malena_export.h>
#include <cstdint>
#include <functional>
#include <memory>
#include <string>
#include <vector>
#include <nlohmann/json.hpp>
 
namespace ml
{
    class MALENA_API WebSocketClient
    {
    public:
        using MessageCallback = std::function<void(const std::string& message)>;
        using BinaryCallback  = std::function<void(const std::vector<uint8_t>& data)>;
        using OpenCallback    = std::function<void()>;
        using CloseCallback   = std::function<void(int code, const std::string& reason)>;
        using ErrorCallback   = std::function<void(const std::string& error)>;
 
        WebSocketClient();
        ~WebSocketClient();
 
        WebSocketClient(const WebSocketClient&)            = delete;
        WebSocketClient& operator=(const WebSocketClient&) = delete;
 
        // ── Connection ───────────────────────────────────────────────────────

        void connect(const std::string& url);

        void disconnect();

        [[nodiscard]] bool isConnected() const;
 
        // ── Sending ──────────────────────────────────────────────────────────

        void send(const std::string& message);

        void sendBinary(const std::vector<uint8_t>& data);

        void send(const nlohmann::json& json)
        {
            send(json.dump());
        }
 
        // ── Callbacks ────────────────────────────────────────────────────────

        void onOpen(OpenCallback cb);

        void onMessage(MessageCallback cb);

        void onBinary(BinaryCallback cb);

        void onClose(CloseCallback cb);

        void onError(ErrorCallback cb);
 
        // ── Reconnection ─────────────────────────────────────────────────────

        void setReconnectDelay(int seconds);

        void setMaxReconnectAttempts(int n);
 
    private:
        struct Impl;
        std::unique_ptr<Impl> _impl;
    };
 
} // namespace ml
 
#endif // MALENA_WEBSOCKETCLIENT_H