From 22c4f1fc7fe1dc966a280de7f66e2f9fe592fbd2 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Tue, 11 Jun 2024 21:29:49 +0200 Subject: [PATCH] test(ocpp-server): add TransactionEvent handler MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- tests/ocpp-server/server.py | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/tests/ocpp-server/server.py b/tests/ocpp-server/server.py index db438259..c8748763 100644 --- a/tests/ocpp-server/server.py +++ b/tests/ocpp-server/server.py @@ -7,6 +7,7 @@ import ocpp.v201 import websockets from ocpp.routing import on from ocpp.v201.enums import RegistrationStatusType, ClearCacheStatusType, AuthorizationStatusType, \ + TransactionEventType, \ Action # Setting up the logging configuration to display debug level messages. @@ -53,6 +54,22 @@ class ChargePoint(ocpp.v201.ChargePoint): return ocpp.v201.call_result.Authorize( id_token_info={'status': AuthorizationStatusType.accepted}) + @on(Action.TransactionEvent) + async def on_transaction_event(self, event_type, timestamp, trigger_reason, seq_no, + transaction_info, **kwargs): + match event_type: + case TransactionEventType.started: + logging.info("Received TransactionEvent Started") + return ocpp.v201.call_result.TransactionEvent( + id_token_info={'status': AuthorizationStatusType.accepted}) + case TransactionEventType.updated: + logging.info("Received TransactionEvent Updated") + return ocpp.v201.call_result.TransactionEvent( + total_cost=10) + case TransactionEventType.ended: + logging.info("Received TransactionEvent Ended") + return ocpp.v201.call_result.TransactionEvent() + @on(Action.MeterValues) async def on_meter_values(self, evse_id, meter_value, **kwargs): logging.info("Received MeterValues") -- 2.34.1