[OPIK-2856] [BE] Refactor test code to use TraceResourceClient instead of direct URL_TEMPLATE calls (#3947)

* [NA] [BE] Upgrade MySQL container from Testcontainers

* Fix imports order

* [OPIK-2856] [BE] Implement UUIDv7 time-based filtering for traces

- Add InstantToUUIDMapper to convert Instant timestamps to UUIDv7 bounds
- Add InstantParamConverter to parse ISO-8601 and epoch millisecond time parameters
- Update TracesResource to accept from_time and to_time parameters on /traces and /traces/stats endpoints
- Update TraceDAO to apply UUID-based time filtering using BETWEEN clause on id column
- Update TraceSearchCriteria to include uuidFromTime and uuidToTime fields
- Add comprehensive integration tests for time filtering with boundary conditions
- All tests passing: 10/10 time filtering tests + validation tests

* [OPIK-2856] Address PR review comments: improve exception handling and type safety

- Fix InstantParamConverter to catch specific DateTimeParseException instead of generic Exception
- Add debug logging when falling back to epoch milliseconds parsing
- Refactor anonymous ParamConverter class to named InstantConverter inner class for clarity
- Suppress unchecked cast with @SuppressWarnings annotation
- Fix MySQLContainerUtils return type to use MySQLContainer<?> for type safety

* [OPIK-2856] Fix InstantToUUIDMapperTest to match implementation

- Update tests to reflect that toUpperBound uses next millisecond (+1ms) for inclusive BETWEEN queries
- Remove outdated assertions expecting same timestamp in both bounds
- Verify upper bound is lexicographically greater than lower bound
- All 13 tests now passing

* Remove setup duplicated code

* Revision 2: Address PR review comments - LOW priority fixes

- #7: Add INSTANCE singleton pattern for InstantConverter
- #8: Use StringUtils.isEmpty() for null-safe empty check
- Note: #2 and #3 already addressed in previous commit

* Revision 3: Use IdGenerator.getTimeOrderedEpoch() for UUID bounds

- Simplified InstantToUUIDMapper to use IdGenerator.getTimeOrderedEpoch() instead of convertOtelIdToUUIDv7
- Per UUIDv7 RFC, sub-millisecond 12 bits are optional with millisecond granularity
- Start/end interval semantics with ±1ms ensures correct BETWEEN query results
- This approach has been battle-tested for months without issues per reviewer recommendation
- Converted InstantToUUIDMapper to @singleton service for proper DI integration
- Updated TracesResource to inject InstantToUUIDMapper dependency
- Updated tests to properly mock IdGenerator dependency

* Fix tests

* [OPIK-2856] [BE] Split Get spans Tests

* Fix format

* Revision 2: Extract duplicated span creation logic into createSpanWithTimestamp helper method

* [OPIK-2856] [BE] Implement UUIDv7 time-based filtering for spans

* Revision 3: Extract workspace setup duplication into setupTestWorkspace helper method and fix transformTestParams call

* [OPIK-2856] Refactor TracesResourceTest to use TraceResourceClient instead of direct URL_TEMPLATE calls

- Replace all direct client.target(URL_TEMPLATE) calls with TraceResourceClient methods
- Add callFeedbackScoresWithCookie method to TraceResourceClient for session token authentication
- Add callRetrieveThreadResponseWithCookie method to TraceResourceClient for session token authentication
- Fix feedback batch endpoint by using callFeedbackScores and callFeedbackScoresWithCookie
- Add null checks for query parameters to prevent NPE errors
- Fix API key vs session token usage in authentication tests
- Rename get__whenApiKeyIsPresent__thenReturnTraceThread to get__whenSessionTokenIsPresent__thenReturnTraceThread in SessionTokenCookie class
- Add mockGetWorkspaceIdByName() calls for proper workspace mocking
- Preserve original test assertions and behavior
- All tests properly refactored to use resource client methods instead of direct HTTP calls

* [OPIK-2856] Remove duplicate methods from TraceResourceClient

- Remove callGetTraces() - duplicate of callGetTracesWithQueryParams()
- Remove callSearchTraces() - duplicate of callSearchTracesStream()
- Reduced code duplication and maintenance burden

* Fix tests

* Revision 2: Address Copilot review comments - remove redundant wrapper method and add clarifying comment

* Revision 3: Extract duplicated path splitting logic into helper method addPathSegments()

* Revision 4: Make getWebTarget() private and add callGetTraceThreadsWithSorting() public method

* Revision 7: Move addPathSegments() and addQueryParameters() helper methods to BaseCommentResourceClient

Author: thiagohora

apps/opik-backend/src/test/java/com/comet/opik/api/resources/utils/resources/BaseCommentResourceClient.java

@@ -6,12 +6,14 @@
 import com.comet.opik.podam.PodamFactoryUtils;
 import jakarta.ws.rs.HttpMethod;
 import jakarta.ws.rs.client.Entity;
+import jakarta.ws.rs.client.WebTarget;
 import jakarta.ws.rs.core.HttpHeaders;
 import jakarta.ws.rs.core.MediaType;
 import lombok.RequiredArgsConstructor;
 import ru.vyarus.dropwizard.guice.test.ClientSupport;
 import uk.co.jemos.podam.api.PodamFactory;
 
+import java.util.Map;
 import java.util.UUID;
 
 import static com.comet.opik.infrastructure.auth.RequestContext.WORKSPACE_HEADER;
@@ -105,4 +107,33 @@ public void deleteComments(BatchDelete request, String apiKey, String workspaceN
             assertThat(actualResponse.hasEntity()).isFalse();
         }
     }
+
+    /**
+     * Helper method to add path segments to a WebTarget.
+     * Splits the pathSuffix by "/" and adds each non-empty part as a path segment.
+     */
+    protected WebTarget addPathSegments(WebTarget target, String pathSuffix) {
+        if (pathSuffix != null && !pathSuffix.isEmpty()) {
+            String[] pathParts = pathSuffix.split("/");
+            for (String part : pathParts) {
+                if (!part.isEmpty()) {
+                    target = target.path(part);
+                }
+            }
+        }
+        return target;
+    }
+
+    /**
+     * Helper method to add query parameters to a WebTarget.
+     * Iterates through the queryParams map and adds each entry as a query parameter.
+     */
+    protected WebTarget addQueryParameters(WebTarget target, Map<String, String> queryParams) {
+        if (queryParams != null) {
+            for (Map.Entry<String, String> entry : queryParams.entrySet()) {
+                target = target.queryParam(entry.getKey(), entry.getValue());
+            }
+        }
+        return target;
+    }
 }

apps/opik-backend/src/test/java/com/comet/opik/api/resources/utils/resources/SpanResourceClient.java

@@ -2,6 +2,7 @@
 
 import com.comet.opik.api.DeleteFeedbackScore;
 import com.comet.opik.api.FeedbackScore;
+import com.comet.opik.api.FeedbackScoreBatchContainer;
 import com.comet.opik.api.FeedbackScoreBatchContainer.FeedbackScoreBatch;
 import com.comet.opik.api.ProjectStats;
 import com.comet.opik.api.Span;
@@ -11,6 +12,7 @@
 import com.comet.opik.api.filter.SpanFilter;
 import com.comet.opik.api.sorting.SortingField;
 import com.comet.opik.domain.SpanType;
+import com.comet.opik.infrastructure.auth.RequestContext;
 import com.comet.opik.infrastructure.llm.openai.OpenaiModelName;
 import com.comet.opik.utils.JsonUtils;
 import com.fasterxml.jackson.core.type.TypeReference;
@@ -128,6 +130,47 @@ public void feedbackScores(List<FeedbackScoreBatchItem> score, String apiKey, St
         }
     }
 
+    public Response callFeedbackScoresWithContainer(FeedbackScoreBatchContainer request, String apiKey,
+            String workspaceName) {
+        return client.target(RESOURCE_PATH.formatted(baseURI))
+                .path("feedback-scores")
+                .request()
+                .header(HttpHeaders.AUTHORIZATION, apiKey)
+                .header(WORKSPACE_HEADER, workspaceName)
+                .put(Entity.json(request));
+    }
+
+    public Response callGetSpansWithQueryParams(String apiKey, String workspaceName, Map<String, String> queryParams) {
+        WebTarget target = addQueryParameters(client.target(RESOURCE_PATH.formatted(baseURI)), queryParams);
+
+        return target
+                .request()
+                .header(HttpHeaders.AUTHORIZATION, apiKey)
+                .header(WORKSPACE_HEADER, workspaceName)
+                .get();
+    }
+
+    public Response callGetSpansWithQueryParamsAndCookie(String sessionToken, String workspaceName,
+            Map<String, String> queryParams) {
+        WebTarget target = addQueryParameters(client.target(RESOURCE_PATH.formatted(baseURI)), queryParams);
+
+        return target
+                .request()
+                .cookie(RequestContext.SESSION_COOKIE, sessionToken)
+                .header(WORKSPACE_HEADER, workspaceName)
+                .get();
+    }
+
+    public Response callFeedbackScoresWithContainerAndCookie(FeedbackScoreBatchContainer request, String sessionToken,
+            String workspaceName) {
+        return client.target(RESOURCE_PATH.formatted(baseURI))
+                .path("feedback-scores")
+                .request()
+                .cookie(RequestContext.SESSION_COOKIE, sessionToken)
+                .header(WORKSPACE_HEADER, workspaceName)
+                .put(Entity.json(request));
+    }
+
     public void feedbackScore(UUID entityId, FeedbackScore score, String workspaceName, String apiKey) {
         try (var actualResponse = client.target(RESOURCE_PATH.formatted(baseURI))
                 .path(entityId.toString())