From: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com> Date: Wed, 26 Jun 2024 07:49:40 +0000 (+0000) Subject: [autofix.ci] apply automated fixes X-Git-Tag: v1.3.7~17^2~7 X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=1f71f83fc5e112fd25fd9ce83af436fcba71ed68;p=e-mobility-charging-stations-simulator.git [autofix.ci] apply automated fixes --- diff --git a/tests/ocpp-server/server.py b/tests/ocpp-server/server.py index 45a7668f..c6ea6e13 100644 --- a/tests/ocpp-server/server.py +++ b/tests/ocpp-server/server.py @@ -1,8 +1,8 @@ import argparse import asyncio -from functools import partial import logging from datetime import datetime, timezone +from functools import partial from threading import Timer import ocpp.v201 @@ -97,11 +97,13 @@ class ChargePoint(ocpp.v201.ChargePoint): return ocpp.v201.call_result.MeterValues() @on(Action.GetBaseReport) - async def on_get_base_report(self, request_id: int, report_base: ReportBaseType, **kwargs): + async def on_get_base_report( + self, request_id: int, report_base: ReportBaseType, **kwargs + ): logging.info("Received %s", Action.GetBaseReport) return ocpp.v201.call_result.GetBaseReport( - id_token_info={"status": ReportBaseType.accepted} - ) + id_token_info={"status": ReportBaseType.accepted} + ) # Request handlers to emit OCPP messages. async def send_clear_cache(self): @@ -135,7 +137,6 @@ class ChargePoint(ocpp.v201.ChargePoint): logging.info("send_get_base_report done.") - # Function to send OCPP command async def send_ocpp_command(cp, command_name, delay=None, period=None): # If delay is not None, sleep for delay seconds @@ -144,6 +145,7 @@ async def send_ocpp_command(cp, command_name, delay=None, period=None): # If period is not None, send command repeatedly with period interval if period: + async def send_command_repeatedly(): while True: command_name = await cp.receive_command() @@ -157,8 +159,10 @@ async def send_ocpp_command(cp, command_name, delay=None, period=None): await cp.send_get_base_report() case _: logging.warning(f"Unsupported command {command_name}") - except Exception as e: - logging.exception(f"Failure while processing command {command_name}") + except Exception: + logging.exception( + f"Failure while processing command {command_name}" + ) finally: await asyncio.sleep(period) @@ -200,7 +204,9 @@ async def on_connect(websocket, path, args): await cp.start() # Check if request argument is specified if args.request: - asyncio.create_task(send_ocpp_command(cp, args.request, args.delay, args.period)) + asyncio.create_task( + send_ocpp_command(cp, args.request, args.delay, args.period) + ) except ConnectionClosed: logging.info("ChargePoint %s closed connection", cp.id) @@ -218,7 +224,7 @@ async def main(): args = parser.parse_args() - on_connect_bound = partial(on_connect, args=args) # Add args to on_connect + on_connect_bound = partial(on_connect, args=args) # Add args to on_connect # Create the WebSocket server and specify the handler for new connections. server = await websockets.serve(