[autofix.ci] apply automated fixes

[e-mobility-charging-stations-simulator.git] / tests / ocpp-server / server.py

diff --git a/tests/ocpp-server/server.py b/tests/ocpp-server/server.py
index aa424b7f90c6d89b30a25fb66e1b32be5a5d7671..cba2009275f9fb5a9ae443c5e928f0a3f99cfc22 100644 (file)
--- a/tests/ocpp-server/server.py
+++ b/tests/ocpp-server/server.py
@@ -96,7 +96,9 @@ 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(status="Accepted")
 
@@ -147,6 +149,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()
@@ -154,14 +157,16 @@ async def send_ocpp_command(cp, command_name, delay=None, period=None):
                     match command_name:
                         case Action.ClearCache:
                             logging.info("ClearCache parser working")
-                            await charge_point.send_clear_cache()
+                            await cp.send_clear_cache()
                         case Action.GetBaseReport:
                             logging.info("GetBaseReport parser working")
                             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)
 
@@ -203,7 +208,9 @@ async def on_connect(websocket, path):
         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)