From cae35e56f15fa57c6d01041cbb780e2ae242ad93 Mon Sep 17 00:00:00 2001 From: fnkbsi <135032168+fnkbsi@users.noreply.github.com> Date: Sun, 12 Jan 2025 15:33:35 +0100 Subject: [PATCH] ChargePointServiceClient: rewrite the methods for remote start, stop and unlock for differentiation of internal and external tasks --- .../service/ChargePointServiceClient.java | 25 +++++++++++++++---- 1 file changed, 20 insertions(+), 5 deletions(-) diff --git a/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java b/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java index 7f632c385..dbbb60a66 100644 --- a/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java +++ b/src/main/java/de/rwth/idsg/steve/service/ChargePointServiceClient.java @@ -199,14 +199,18 @@ public final int updateFirmware(UpdateFirmwareParams params, @SafeVarargs public final int remoteStartTransaction(RemoteStartTransactionParams params, OcppCallback... callbacks) { - return remoteStartTransaction(params, "Steve", callbacks); - } - + RemoteStartTransactionTask task = new RemoteStartTransactionTask(params); + return addRemoteStartTask(task, callbacks); + } @SafeVarargs public final int remoteStartTransaction(RemoteStartTransactionParams params, String caller, OcppCallback... callbacks) { RemoteStartTransactionTask task = new RemoteStartTransactionTask(params, caller); + return addRemoteStartTask(task, callbacks); + } + private int addRemoteStartTask(RemoteStartTransactionTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); } @@ -221,14 +225,19 @@ public final int remoteStartTransaction(RemoteStartTransactionParams params, Str @SafeVarargs public final int remoteStopTransaction(RemoteStopTransactionParams params, OcppCallback... callbacks) { - return remoteStopTransaction(params, "Steve", callbacks); + RemoteStopTransactionTask task = new RemoteStopTransactionTask(params); + return addRemoteStopTask(task,callbacks); } @SafeVarargs public final int remoteStopTransaction(RemoteStopTransactionParams params, String caller, OcppCallback... callbacks) { RemoteStopTransactionTask task = new RemoteStopTransactionTask(params, caller); + return addRemoteStopTask(task,callbacks); + } + private int addRemoteStopTask(RemoteStopTransactionTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); } @@ -243,13 +252,19 @@ public final int remoteStopTransaction(RemoteStopTransactionParams params, Strin @SafeVarargs public final int unlockConnector(UnlockConnectorParams params, OcppCallback... callbacks) { - return unlockConnector(params, "Steve", callbacks); + UnlockConnectorTask task = new UnlockConnectorTask(params); + return addUnlockConnectorTask(task, callbacks); } + @SafeVarargs public final int unlockConnector(UnlockConnectorParams params, String caller, OcppCallback... callbacks) { UnlockConnectorTask task = new UnlockConnectorTask(params, caller); + return addUnlockConnectorTask(task, callbacks); + } + private int addUnlockConnectorTask(UnlockConnectorTask task, + OcppCallback... callbacks) { for (var callback : callbacks) { task.addCallback(callback); }