reservation.hpp

// SPDX-License-Identifier: Apache-2.0
// Copyright Pionix GmbH and Contributors to EVerest
 
#include <ocpp/v2/message_handler.hpp>
 
#pragma once
 
namespace ocpp::v2 {
struct FunctionalBlockContext;
class EvseInterface;
 
struct ReserveNowRequest;
struct CancelReservationRequest;
 
typedef std::function<ReserveNowStatusEnum(const ReserveNowRequest& request)> ReserveNowCallback;
typedef std::function<bool(const int32_t reservationId)> CancelReservationCallback;
typedef std::function<ocpp::ReservationCheckStatus(const int32_t evse_id, const CiString<36> idToken,
                                                   const std::optional<CiString<36>> groupIdToken)>
    IsReservationForTokenCallback;
 
class ReservationInterface : public MessageHandlerInterface {
public:
    virtual ~ReservationInterface() = default;
    virtual void on_reservation_status(const int32_t reservation_id, const ReservationUpdateStatusEnum status) = 0;
    virtual ocpp::ReservationCheckStatus
    is_evse_reserved_for_other(const EvseInterface& evse, const IdToken& id_token,
                               const std::optional<IdToken>& group_id_token) const = 0;
    virtual void on_reserved(const int32_t evse_id, const int32_t connector_id) = 0;
    virtual void on_reservation_cleared(const int32_t evse_id, const int32_t connector_id) = 0;
};
 
class Reservation : public ReservationInterface {
private: // Members
    const FunctionalBlockContext& context;
 
    ReserveNowCallback reserve_now_callback;
    CancelReservationCallback cancel_reservation_callback;
    IsReservationForTokenCallback is_reservation_for_token_callback;
 
public:
    Reservation(const FunctionalBlockContext& functional_block_context, ReserveNowCallback reserve_now_callback,
                CancelReservationCallback cancel_reservation_callback,
                const IsReservationForTokenCallback is_reservation_for_token_callback);
    virtual void handle_message(const ocpp::EnhancedMessage<MessageType>& message) override;
 
    virtual void on_reservation_status(const int32_t reservation_id, const ReservationUpdateStatusEnum status) override;
    virtual ocpp::ReservationCheckStatus
    is_evse_reserved_for_other(const EvseInterface& evse, const IdToken& id_token,
                               const std::optional<IdToken>& group_id_token) const override;
    virtual void on_reserved(const int32_t evse_id, const int32_t connector_id) override;
    virtual void on_reservation_cleared(const int32_t evse_id, const int32_t connector_id) override;
 
private: // Functions
    void handle_reserve_now_request(Call<ReserveNowRequest> call);
    void handle_cancel_reservation_callback(Call<CancelReservationRequest> call);
    void send_reserve_now_rejected_response(const MessageId& unique_id, const std::string& status_info);
};
 
} // namespace ocpp::v2