EA-4015 handle profile

europeana · Dec 2, 2024 · ac9dc4b · ac9dc4b
1 parent 8812fe6
commit ac9dc4b
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 4 deletions.
diff --git a/set-client/src/main/java/eu/europeana/set/client/connection/BaseApiConnection.java b/set-client/src/main/java/eu/europeana/set/client/connection/BaseApiConnection.java
@@ -8,8 +8,10 @@
 import eu.europeana.set.common.http.HttpConnection;
 import eu.europeana.set.definitions.model.UserSet;
 import eu.europeana.set.definitions.model.impl.BaseUserSet;
+import eu.europeana.set.definitions.model.vocabulary.ProfileConstants;
 import eu.europeana.set.definitions.model.vocabulary.WebUserSetFields;
 import jakarta.ws.rs.core.UriBuilder;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
 import org.apache.hc.core5.http.HttpStatus;
 import org.apache.hc.core5.http.ParseException;
@@ -146,20 +148,35 @@ private UserSet parseSetApiResponse(CloseableHttpResponse response, List<Integer
     /**
      * Fetches the user Set search api response
      *
+     * Check profile for the deserialization
+     * META - empty page (no items) ,  ITEMS_META - only set descriptions, not item descriptions , ITEMS - items set as set ids
+     * ITEMS_META is the default profile value
      * @param url
      * @param authorizationHeaderValue
      * @return
      * @throws SetApiClientException
      */
-    protected List<? extends UserSet> getSearchUserSetResponse(String url, String authorizationHeaderValue) throws SetApiClientException {
+    protected List< ? extends UserSet> getSearchUserSetResponse(String url, String authorizationHeaderValue, String profile) throws SetApiClientException {
         try {
             LOGGER.trace("Call to UserSet API (SEARCH): {} ", url);
             CloseableHttpResponse response = getHttpConnection().get(url, "application/json", authorizationHeaderValue);
             String responseBody = EntityUtils.toString(response.getEntity());
+            System.out.println(responseBody);
             if (response.getCode() == HttpStatus.SC_OK) {
-                TypeReference<ResultsPageImpl<BaseUserSet>> typeRef = new TypeReference<>() {
-                };
+               if (StringUtils.equals(profile, ProfileConstants.VALUE_PARAM_ITEMS)) {
+                    TypeReference<ResultsPageImpl<String>> typeRef = new TypeReference<>() {};
+                    List<String> setIds  = mapper.readValue(responseBody, typeRef).getItems();
+                    List<UserSet> userSets = new ArrayList<>();
+                   for (String id: setIds) {
+                       BaseUserSet userSet = new BaseUserSet();
+                       userSet.setIdentifier(StringUtils.substringAfterLast(id, "/"));
+                       userSets.add(userSet);
+                   }
+                   return userSets;
+                }
+                TypeReference<ResultsPageImpl<BaseUserSet>> typeRef = new TypeReference<>() {};
                 return mapper.readValue(responseBody, typeRef).getItems();
+
             } else {
                 AbstractUserSetApiResponse errorResponse = mapper.readValue(responseBody, AbstractUserSetApiResponse.class);
                 if (LOGGER.isDebugEnabled()) {

diff --git a/set-client/src/main/java/eu/europeana/set/client/connection/UserSetApiConnection.java b/set-client/src/main/java/eu/europeana/set/client/connection/UserSetApiConnection.java
@@ -108,6 +108,6 @@ public List<? extends UserSet> searchUserSet(String query, String[] qf, String s
                                                String profile) throws SetApiClientException {
 
     StringBuilder urlBuilder = getUserSetServiceUri().append(buildSearchUrl(query, qf, sort, page, pageSize, facet, facetLimit, profile));
-    return getSearchUserSetResponse(urlBuilder.toString(), regularUserAuthorizationValue);
+    return getSearchUserSetResponse(urlBuilder.toString(), regularUserAuthorizationValue, profile);
   }
 }