Remove unused listActivitiesPaginated interceptor

Author: GregoryTravis

temporal-sdk/src/main/java/io/temporal/client/ActivityListPage.java

@@ -5,7 +5,6 @@
 import io.temporal.client.ActivityExecutionDescription;
 import io.temporal.client.ActivityExecutionMetadata;
 import io.temporal.client.ActivityFailedException;
-import io.temporal.client.ActivityListPage;
 import io.temporal.client.StartActivityOptions;
 import io.temporal.common.Experimental;
 import java.lang.reflect.Type;
@@ -89,16 +88,6 @@ public interface ActivityClientCallsInterceptor {
    */
   ListActivitiesOutput listActivities(ListActivitiesInput input);
 
-  /**
-   * Returns a single page of activity execution metadata matching the Visibility query in {@code
-   * input}. The returned {@link ActivityListPage} includes a token that can be passed back in a
-   * subsequent call to retrieve the next page.
-   *
-   * @param input Visibility query string, optional next-page token, and pagination options
-   * @return output containing the page of results and a next-page token ({@code null} if last page)
-   */
-  ListActivitiesPaginatedOutput listActivitiesPaginated(ListActivitiesPaginatedInput input);
-
   /**
    * Returns the count of activity executions matching the Visibility query in {@code input}.
    *
@@ -383,39 +372,6 @@ public Stream<ActivityExecutionMetadata> getStream() {
     }
   }
 
-  @Experimental
-  final class ListActivitiesPaginatedInput {
-    private final String query;
-    private final @Nullable byte[] nextPageToken;
-
-    public ListActivitiesPaginatedInput(String query, @Nullable byte[] nextPageToken) {
-      this.query = query;
-      this.nextPageToken = nextPageToken;
-    }
-
-    public String getQuery() {
-      return query;
-    }
-
-    @Nullable
-    public byte[] getNextPageToken() {
-      return nextPageToken;
-    }
-  }
-
-  @Experimental
-  final class ListActivitiesPaginatedOutput {
-    private final ActivityListPage page;
-
-    public ListActivitiesPaginatedOutput(ActivityListPage page) {
-      this.page = page;
-    }
-
-    public ActivityListPage getPage() {
-      return page;
-    }
-  }
-
   @Experimental
   final class CountActivitiesInput {
     private final String query;

temporal-sdk/src/main/java/io/temporal/common/interceptors/ActivityClientCallsInterceptor.java

@@ -47,11 +47,6 @@ public ListActivitiesOutput listActivities(ListActivitiesInput input) {
     return next.listActivities(input);
   }
 
-  @Override
-  public ListActivitiesPaginatedOutput listActivitiesPaginated(ListActivitiesPaginatedInput input) {
-    return next.listActivitiesPaginated(input);
-  }
-
   @Override
   public CountActivitiesOutput countActivities(CountActivitiesInput input) {
     return next.countActivities(input);

temporal-sdk/src/main/java/io/temporal/common/interceptors/ActivityClientCallsInterceptorBase.java

@@ -4,7 +4,6 @@
 import static io.temporal.internal.common.WorkflowExecutionUtils.makeUserMetaData;
 
 import com.google.common.collect.Iterators;
-import com.google.protobuf.ByteString;
 import io.grpc.Deadline;
 import io.grpc.Status;
 import io.grpc.StatusRuntimeException;
@@ -336,27 +335,6 @@ public ListActivitiesOutput listActivities(ListActivitiesInput input) {
             Spliterators.spliteratorUnknownSize(wrappedIterator, CHARACTERISTICS), false));
   }
 
-  @Override
-  public ListActivitiesPaginatedOutput listActivitiesPaginated(ListActivitiesPaginatedInput input) {
-    ListActivityExecutionsRequest.Builder req =
-        ListActivityExecutionsRequest.newBuilder().setNamespace(clientOptions.getNamespace());
-    if (input.getQuery() != null) {
-      req.setQuery(input.getQuery());
-    }
-    if (input.getNextPageToken() != null) {
-      req.setNextPageToken(ByteString.copyFrom(input.getNextPageToken()));
-    }
-    ListActivityExecutionsResponse response = genericClient.listActivities(req.build());
-    List<ActivityExecutionMetadata> activities = new ArrayList<>();
-    for (io.temporal.api.activity.v1.ActivityExecutionListInfo info :
-        response.getExecutionsList()) {
-      activities.add(ActivityExecutionMetadata.fromListInfo(info));
-    }
-    byte[] nextToken =
-        response.getNextPageToken().isEmpty() ? null : response.getNextPageToken().toByteArray();
-    return new ListActivitiesPaginatedOutput(new ActivityListPage(activities, nextToken));
-  }
-
   @Override
   public CountActivitiesOutput countActivities(CountActivitiesInput input) {
     CountActivityExecutionsRequest.Builder req =

temporal-sdk/src/main/java/io/temporal/internal/client/RootActivityClientInvoker.java

@@ -7,7 +7,6 @@
 import io.temporal.client.ActivityExecutionDescription;
 import io.temporal.client.ActivityExecutionMetadata;
 import io.temporal.client.ActivityFailedException;
-import io.temporal.client.ActivityListPage;
 import io.temporal.client.StartActivityOptions;
 import io.temporal.common.interceptors.ActivityClientCallsInterceptor.*;
 import java.time.Duration;
@@ -147,17 +146,4 @@ public void testCountActivitiesDelegatesToNext() {
     assertSame(output, result);
     verify(next).countActivities(input);
   }
-
-  @Test
-  public void testListActivitiesPaginatedDelegatesToNext() {
-    ActivityListPage page = new ActivityListPage(Collections.emptyList(), null);
-    ListActivitiesPaginatedOutput output = new ListActivitiesPaginatedOutput(page);
-    when(next.listActivitiesPaginated(any(ListActivitiesPaginatedInput.class))).thenReturn(output);
-
-    ListActivitiesPaginatedInput input = new ListActivitiesPaginatedInput("query", null);
-    ListActivitiesPaginatedOutput result = base.listActivitiesPaginated(input);
-
-    assertSame(output, result);
-    verify(next).listActivitiesPaginated(input);
-  }
 }