d398a6ced2
- CitrineOS core extracted (CSMS OCPP 2.0.1) - OpenOCPP extracted (firmware OCPP 1.6J/2.0.1) - ShapeShifter library installed (pip install -e) - ShapeShifter specification extracted - EVerest extracted TODO updated with progress
55 lines
2.1 KiB
C++
55 lines
2.1 KiB
C++
// SPDX-License-Identifier: Apache-2.0
|
|
// Copyright 2020 - 2026 Pionix GmbH and Contributors to EVerest
|
|
|
|
#include "powermeterImpl.hpp"
|
|
|
|
#include <everest_api_types/powermeter/API.hpp>
|
|
#include <everest_api_types/powermeter/codec.hpp>
|
|
#include <everest_api_types/powermeter/json_codec.hpp>
|
|
#include <everest_api_types/powermeter/wrapper.hpp>
|
|
#include <everest_api_types/utilities/AsyncApiRequestReply.hpp>
|
|
|
|
#include <generated/types/powermeter.hpp>
|
|
|
|
namespace module {
|
|
namespace main {
|
|
|
|
namespace API_types_ext = ev_API::V1_0::types::powermeter;
|
|
namespace types_int = types::powermeter;
|
|
using status = types_int::TransactionRequestStatus;
|
|
|
|
using namespace everest::lib::API;
|
|
|
|
void powermeterImpl::init() {
|
|
timeout_s = mod->config.cfg_request_reply_to_s;
|
|
}
|
|
|
|
void powermeterImpl::ready() {
|
|
}
|
|
|
|
template <class T, class ReqT>
|
|
auto powermeterImpl::generic_request_reply(T const& default_value, ReqT const& request, std::string const& topic) {
|
|
using ExtT = decltype(API_types_ext::to_external_api(std::declval<T>()));
|
|
auto result = everest::lib::API::request_reply_handler<ExtT>(mod->mqtt_v, mod->helper.get_topics(), request, topic,
|
|
timeout_s);
|
|
if (!result) {
|
|
return default_value;
|
|
}
|
|
return result.value();
|
|
}
|
|
|
|
types_int::TransactionStartResponse powermeterImpl::handle_start_transaction(types::powermeter::TransactionReq& value) {
|
|
static const types_int::TransactionStartResponse default_response{status::UNEXPECTED_ERROR, std::nullopt,
|
|
std::nullopt, std::nullopt};
|
|
return generic_request_reply(default_response, value, "start_transaction");
|
|
}
|
|
|
|
types_int::TransactionStopResponse powermeterImpl::handle_stop_transaction(std::string& transaction_id) {
|
|
static const types_int::TransactionStopResponse default_response{status::UNEXPECTED_ERROR, std::nullopt,
|
|
std::nullopt, std::nullopt};
|
|
return generic_request_reply(default_response, transaction_id, "stop_transaction");
|
|
}
|
|
|
|
} // namespace main
|
|
} // namespace module
|