Skip to content

Commit b3982a7

Browse files
committed
add request id to task results page
1 parent a9f687b commit b3982a7

File tree

6 files changed

+26
-4
lines changed

6 files changed

+26
-4
lines changed

src/main/java/de/rwth/idsg/steve/ocpp/CommunicationTask.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232

3333
import jakarta.xml.ws.AsyncHandler;
3434
import java.util.ArrayList;
35+
import java.util.Collections;
3536
import java.util.HashMap;
3637
import java.util.List;
3738
import java.util.Map;
@@ -51,6 +52,7 @@ public abstract class CommunicationTask<S extends ChargePointSelection, RESPONSE
5152
private final String operationName;
5253
private final TaskOrigin origin;
5354
private final String caller;
55+
private final Map<String, String> customDetails; // task-specific details
5456
protected final S params;
5557

5658
private final Map<String, OcppVersion> versionMap;
@@ -70,19 +72,24 @@ public abstract class CommunicationTask<S extends ChargePointSelection, RESPONSE
7072
private final ArrayList<OcppCallback<RESPONSE>> callbackList = new ArrayList<>(2);
7173

7274
public CommunicationTask(S params) {
73-
this(params, TaskOrigin.INTERNAL, "SteVe");
75+
this(params, Collections.emptyMap());
76+
}
77+
78+
public CommunicationTask(S params, Map<String, String> customDetails) {
79+
this(params, TaskOrigin.INTERNAL, "SteVe", customDetails);
7480
}
7581

7682
/**
7783
* Do not expose the constructor, make it package-private
7884
*/
79-
CommunicationTask(S params, TaskOrigin origin, String caller) {
85+
CommunicationTask(S params, TaskOrigin origin, String caller, Map<String, String> customDetails) {
8086
List<ChargePointSelect> cpsList = params.getChargePointSelectList();
8187

8288
this.resultSize = cpsList.size();
8389
this.origin = origin;
8490
this.caller = caller;
8591
this.params = params;
92+
this.customDetails = customDetails;
8693

8794
resultMap = new HashMap<>(resultSize);
8895
versionMap = new HashMap<>(resultSize);

src/main/java/de/rwth/idsg/steve/ocpp/Ocpp15AndAboveTask.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import de.rwth.idsg.steve.web.dto.ocpp.ChargePointSelection;
2424

2525
import jakarta.xml.ws.AsyncHandler;
26+
import java.util.Map;
2627

2728
/**
2829
* @author Sevket Goekay <sevketgokay@gmail.com>
@@ -34,6 +35,10 @@ public Ocpp15AndAboveTask(S params) {
3435
super(params);
3536
}
3637

38+
public Ocpp15AndAboveTask(S params, Map<String, String> customDetails) {
39+
super(params, customDetails);
40+
}
41+
3742
@Deprecated
3843
@Override
3944
public <T extends RequestType> T getOcpp12Request() {

src/main/java/de/rwth/idsg/steve/ocpp/Ocpp16AndAboveTask.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import de.rwth.idsg.steve.web.dto.ocpp.ChargePointSelection;
2424

2525
import jakarta.xml.ws.AsyncHandler;
26+
import java.util.Map;
2627

2728
/**
2829
* @author Sevket Goekay <sevketgokay@gmail.com>
@@ -34,6 +35,10 @@ public Ocpp16AndAboveTask(S params) {
3435
super(params);
3536
}
3637

38+
public Ocpp16AndAboveTask(S params, Map<String, String> customDetails) {
39+
super(params, customDetails);
40+
}
41+
3742
@Deprecated
3843
@Override
3944
public <T extends RequestType> T getOcpp15Request() {

src/main/java/de/rwth/idsg/steve/ocpp/task/GetLogTask.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,13 +26,14 @@
2626
import ocpp._2022._02.security.LogParametersType;
2727

2828
import jakarta.xml.ws.AsyncHandler;
29+
import java.util.Map;
2930

3031
public class GetLogTask extends Ocpp16AndAboveTask<GetLogParams, String> {
3132

3233
private final int requestId;
3334

3435
public GetLogTask(GetLogParams params, int requestId) {
35-
super(params);
36+
super(params, Map.of("Job/Request ID", String.valueOf(requestId)));
3637
this.requestId = requestId;
3738
}
3839

src/main/java/de/rwth/idsg/steve/ocpp/task/SignedUpdateFirmwareTask.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,13 +26,14 @@
2626
import ocpp._2022._02.security.SignedUpdateFirmwareResponse;
2727

2828
import jakarta.xml.ws.AsyncHandler;
29+
import java.util.Map;
2930

3031
public class SignedUpdateFirmwareTask extends Ocpp16AndAboveTask<SignedUpdateFirmwareParams, String> {
3132

3233
private final int requestId;
3334

3435
public SignedUpdateFirmwareTask(SignedUpdateFirmwareParams params, int requestId) {
35-
super(params);
36+
super(params, Map.of("Job/Request ID", String.valueOf(requestId)));
3637
this.requestId = requestId;
3738
}
3839

src/main/webapp/WEB-INF/views/taskResult.jsp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,9 @@
3333
<table id='details' class='cpd'>
3434
<thead><tr><th>Task Details</th><th></th></tr></thead>
3535
<tr><td>Operation name</td><td>${task.operationName}</td></tr>
36+
<c:forEach var="entry" items="${task.customDetails}">
37+
<tr><td>${entry.key}</td><td>${entry.value}</td></tr>
38+
</c:forEach>
3639
<tr><td>Origin</td><td>${task.origin} (${task.caller})</td></tr>
3740
<tr><td>Start timestamp</td><td>${task.startTimestamp}</td></tr>
3841
<tr><td>End timestamp</td><td>${task.endTimestamp}</td></tr>

0 commit comments

Comments
 (0)