websocket.hpp

// SPDX-License-Identifier: Apache-2.0
// Copyright 2020 - 2023 Pionix GmbH and Contributors to EVerest
#ifndef OCPP_WEBSOCKET_HPP
#define OCPP_WEBSOCKET_HPP
 
#include <ocpp/common/evse_security.hpp>
#include <ocpp/common/ocpp_logging.hpp>
 
#include <ocpp/common/websocket/websocket_base.hpp>
 
namespace ocpp {
class Websocket {
private:
    // unique_ptr holds address of base - requires WebSocketBase to have a virtual destructor
    std::unique_ptr<WebsocketBase> websocket;
    std::function<void(OcppProtocolVersion protocol)> connected_callback;
    std::function<void()> disconnected_callback;
    std::function<void(const WebsocketCloseReason reason)> stopped_connecting_callback;
    std::function<void(const std::string& message)> message_callback;
    std::shared_ptr<MessageLogging> logging;
 
public:
    explicit Websocket(const WebsocketConnectionOptions& connection_options,
                       std::shared_ptr<EvseSecurity> evse_security, std::shared_ptr<MessageLogging> logging);
    ~Websocket();
 
    bool start_connecting();
 
    void set_connection_options(const WebsocketConnectionOptions& connection_options);
 
    void disconnect(const WebsocketCloseReason code);
 
    // \brief reconnects the websocket after the delay
    void reconnect(long delay);
 
    bool is_connected();
 
    void register_connected_callback(const std::function<void(OcppProtocolVersion protocol)>& callback);
 
    void register_disconnected_callback(const std::function<void()>& callback);
 
    void register_stopped_connecting_callback(const std::function<void(const WebsocketCloseReason)>& callback);
 
    void register_message_callback(const std::function<void(const std::string& message)>& callback);
 
    void register_connection_failed_callback(const std::function<void(ConnectionFailedReason)>& callback);
 
    bool send(const std::string& message);
 
    void set_websocket_ping_interval(int32_t interval_s);
 
    void set_authorization_key(const std::string& authorization_key);
};
 
} // namespace ocpp
#endif // OCPP_WEBSOCKET_HPP