SocketClient.hpp

// SPDX-FileCopyrightText: 2025 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Standard includes
#include <functional>
 
// Third-party includes
#include <nlohmann/json.hpp>
 
// Project includes
#include "Message.hpp"
#include <dfx-utilities/FileSystem.hpp>
#include <dfx-utilities/PrivateState.hpp>
 
namespace dfx::FdWatch
{
class Poller;
} // !namespace dfx::FdWatch
 
namespace dfx::Client
{
class SocketClient
{
    DFX_PRIVATE_STATE(SocketClient, DFX_CLIENT_LOGGER())
 
public:
    using Callback = std::move_only_function<void (Message)>;
 
public:
    SocketClient(FdWatch::Poller & poller, fs::path socketPath, int version = 1);
    DFX_PRIVATE_STATE_DECLARE_RULE_OF_5(SocketClient);
 
public:
    bool isConnected() const noexcept;
    void reconnect();
    void disconnect();

    bool willAutoReconnect() const noexcept;
    void setAutoReconnect(bool shouldReconnect);
 
public:
    void setMessageCallback(Callback cb);
 
public:
    std::string sendCommand(std::string_view cmd, nlohmann::json const & params, Callback cb = nullptr, std::string_view id = {});

    void sendNotification(nlohmann::json json);
 
public:
    static std::string generateRequestId();
};
} // !namespace dfx::Ctl::Shared