feat: add on_data_transfer handler to v201 chargepoint (#109)

* Fix union annotations for python<3.10 Signed-off-by: Kai-Uwe Hermann <[email protected]> --------- Signed-off-by: Valentin Dimov <[email protected]> Signed-off-by: Kai-Uwe Hermann <[email protected]> Co-authored-by: Kai-Uwe Hermann <[email protected]>
EVerest · Dec 5, 2023 · a054460 · a054460
1 parent 4a5ce95
commit a054460
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 0 deletions.
diff --git a/everest-testing/src/everest/testing/core_utils/_configuration/everest_environment_setup.py b/everest-testing/src/everest/testing/core_utils/_configuration/everest_environment_setup.py
@@ -1,5 +1,6 @@
 # SPDX-License-Identifier: Apache-2.0
 # Copyright 2020 - 2023 Pionix GmbH and Contributors to EVerest
+from __future__ import annotations
 
 import logging
 import shutil

diff --git a/...est-testing/src/everest/testing/core_utils/_configuration/libocpp_configuration_helper.py b/...est-testing/src/everest/testing/core_utils/_configuration/libocpp_configuration_helper.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 import json
 import sys
 from abc import ABC, abstractmethod

diff --git a/everest-testing/src/everest/testing/ocpp_utils/central_system.py b/everest-testing/src/everest/testing/ocpp_utils/central_system.py
@@ -1,5 +1,6 @@
 # SPDX-License-Identifier: Apache-2.0
 # Copyright 2020 - 2023 Pionix GmbH and Contributors to EVerest
+from __future__ import annotations
 
 import asyncio
 import ssl

diff --git a/everest-testing/src/everest/testing/ocpp_utils/charge_point_v201.py b/everest-testing/src/everest/testing/ocpp_utils/charge_point_v201.py
@@ -169,6 +169,10 @@ def on_get_certificate_status(self, **kwargs):
         return call_result.GetCertificateStatusPayload(status=GenericStatusType.accepted,
                                                        ocsp_result="")
 
+    @on(Action.DataTransfer)
+    def on_data_transfer(self, **kwargs):
+        return call_result.DataTransferPayload(status=GenericStatusType.accepted, data="")
+
     async def set_variables_req(self, **kwargs):
         payload = call.SetVariablesPayload(**kwargs)
         return await self.call(payload)