Add 'created after' filter to ListMeasurements and StreamMeasurements (…

…#1828)

MODULE.bazel

@@ -47,7 +47,7 @@ bazel_dep(
 )
 bazel_dep(
     name = "cross-media-measurement-api",
-    version = "0.66.0",
+    version = "0.67.0",
     repo_name = "wfa_measurement_proto",
 )
 bazel_dep(

src/main/kotlin/org/wfanet/measurement/kingdom/deploy/gcloud/spanner/queries/StreamMeasurements.kt

@@ -42,6 +42,7 @@ class StreamMeasurements(
     private const val UPDATED_AFTER = "updatedAfter"
     private const val UPDATED_BEFORE = "updatedBefore"
     private const val CREATED_BEFORE = "createdBefore"
+    private const val CREATED_AFTER = "createdAfter"
     private const val STATES_PARAM = "states"
     private const val DUCHY_ID_PARAM = "duchyId"
 
@@ -130,6 +131,11 @@ class StreamMeasurements(
         bind(CREATED_BEFORE to filter.createdBefore.toGcloudTimestamp())
       }
 
+      if (filter.hasCreatedAfter()) {
+        conjuncts.add("Measurements.CreateTime > @$CREATED_AFTER")
+        bind(CREATED_AFTER to filter.createdAfter.toGcloudTimestamp())
+      }
+
       if (filter.externalDuchyId.isNotEmpty()) {
         val duchyId: Long =
           DuchyIds.getInternalId(filter.externalDuchyId)

src/main/kotlin/org/wfanet/measurement/kingdom/service/api/v2alpha/MeasurementsService.kt

@@ -780,6 +780,10 @@ private fun ListMeasurementsRequest.toListMeasurementsPageToken(): ListMeasureme
         "Arguments must be kept the same when using a page token"
       }
 
+      grpcRequire(source.filter.createdAfter == this.createdAfter) {
+        "Arguments must be kept the same when using a page token"
+      }
+
       grpcRequire(source.filter.createdBefore == this.createdBefore) {
         "Arguments must be kept the same when using a page token"
       }
@@ -810,6 +814,7 @@ private fun ListMeasurementsRequest.toListMeasurementsPageToken(): ListMeasureme
       updatedBefore = source.filter.updatedBefore
       updatedAfter = source.filter.updatedAfter
       createdBefore = source.filter.createdBefore
+      createdAfter = source.filter.createdAfter
     }
   }
 }
@@ -824,6 +829,7 @@ private fun ListMeasurementsPageToken.toStreamMeasurementsRequest(): StreamMeasu
     filter = filter {
       externalMeasurementConsumerId = source.externalMeasurementConsumerId
       states += source.statesList.map { it.toInternalState() }.flatten()
+      createdAfter = source.createdAfter
       createdBefore = source.createdBefore
       updatedBefore = source.updatedBefore
       updatedAfter = source.updatedAfter

src/main/proto/wfa/measurement/api/v2alpha/page_token.proto

@@ -87,6 +87,7 @@ message ListMeasurementsPageToken {
   google.protobuf.Timestamp updated_after = 5;
   google.protobuf.Timestamp updated_before = 6;
   google.protobuf.Timestamp created_before = 7;
+  google.protobuf.Timestamp created_after = 8;
 }
 
 message ListRequisitionsPageToken {

src/main/proto/wfa/measurement/internal/kingdom/measurements_service.proto

@@ -91,6 +91,7 @@ message StreamMeasurementsRequest {
     string externalDuchyId = 7;
     google.protobuf.Timestamp updated_before = 8;
     google.protobuf.Timestamp created_before = 9;
+    google.protobuf.Timestamp created_after = 11;
 
     message After {
       google.protobuf.Timestamp update_time = 1;