summaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin/src/main
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2023-05-23 15:55:14 +0200
committerTor Brede Vekterli <vekterli@yahooinc.com>2023-05-23 15:55:14 +0200
commit58ca50532a70115f34b81b3dfad56f72a38a46d3 (patch)
treef50ea4f99f7aa9bf3df6fb4a34dc8f839ae84ce7 /vespaclient-container-plugin/src/main
parentcdda3f7d16c59c8bd61b8779e15f67cecff3f588 (diff)
Properly handle open visitor timestamp ranges in request parameters
Diffstat (limited to 'vespaclient-container-plugin/src/main')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java10
1 files changed, 6 insertions, 4 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
index eb13bf634ee..e6d5ea48e8f 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java
@@ -1219,10 +1219,12 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler {
parameters.setPriority(DocumentProtocol.Priority.NORMAL_4);
getProperty(request, FROM_TIMESTAMP, unsignedLongParser).ifPresent(parameters::setFromTimestamp);
- getProperty(request, TO_TIMESTAMP, unsignedLongParser).ifPresent(parameters::setToTimestamp);
- if (Long.compareUnsigned(parameters.getFromTimestamp(), parameters.getToTimestamp()) > 0) {
- throw new IllegalArgumentException("toTimestamp must be greater than, or equal to, fromTimestamp");
- }
+ getProperty(request, TO_TIMESTAMP, unsignedLongParser).ifPresent(ts -> {
+ parameters.setToTimestamp(ts);
+ if (Long.compareUnsigned(parameters.getFromTimestamp(), parameters.getToTimestamp()) > 0) {
+ throw new IllegalArgumentException("toTimestamp must be greater than, or equal to, fromTimestamp");
+ }
+ });
StorageCluster storageCluster = resolveCluster(cluster, clusters);
parameters.setRoute(storageCluster.name());