From 339f65ad177a26f0c75dab3da066638ffcd7c44d Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Tue, 11 Jun 2024 20:27:32 +0200 Subject: [PATCH] test: fix OCPP 2 server startup 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 | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/tests/ocpp-server/server.py b/tests/ocpp-server/server.py index 8bdba4bf..308994ed 100644 --- a/tests/ocpp-server/server.py +++ b/tests/ocpp-server/server.py @@ -2,13 +2,11 @@ import asyncio import logging from datetime import datetime, timezone from threading import Timer -from typing import Sequence import ocpp.v201 import websockets from ocpp.routing import on -from ocpp.v201 import call_result -from ocpp.v201.enums import RegistrationStatusType, ClearCacheStatusType +from ocpp.v201.enums import RegistrationStatusType, ClearCacheStatusType, Action # Setting up the logging configuration to display debug level messages. logging.basicConfig(level=logging.DEBUG) @@ -26,12 +24,12 @@ class RepeatTimer(Timer): # Define a ChargePoint class inheriting from the OCPP 2.0.1 ChargePoint class. class ChargePoint(ocpp.v201.ChargePoint): # Message handlers to receive OCPP messages. - @on('BootNotification') + @on(Action.BootNotification) async def on_boot_notification(self, charging_station, reason, **kwargs): logging.info("Received BootNotification") # Create and return a BootNotification response with the current time, # an interval of 10 seconds, and an accepted status. - return call_result.BootNotification( + return ocpp.v201.call_result.BootNotification( current_time=datetime.now(timezone.utc).isoformat(), interval=10, status=RegistrationStatusType.accepted @@ -81,7 +79,7 @@ async def main(): on_connect, '127.0.0.1', # Listen on loopback. 9000, # Port number. - subprotocols=Sequence['ocpp2.0', 'ocpp2.0.1'] # Specify OCPP 2.0.1 subprotocols. + subprotocols=['ocpp2.0', 'ocpp2.0.1'] # Specify OCPP 2.0.1 subprotocols. ) logging.info("WebSocket Server Started") # Wait for the server to close (runs indefinitely). -- 2.34.1