diff --git a/pom.xml b/pom.xml index 1275f01..49e7796 100644 --- a/pom.xml +++ b/pom.xml @@ -5,13 +5,13 @@ maven-parent org.gcube.tools - 1.0.0 + 1.1.0 org.gcube.socialnetworking social-data-search-client - 1.2.0-SNAPSHOT + 2.0.0 jar Social Data Search Client @@ -31,8 +31,8 @@ 18.0 social-networking distro - 1.7 - 1.7 + 1.8 + 1.8 UTF-8 UTF-8 @@ -49,16 +49,17 @@ + + org.gcube.social-networking + social-service-model + [1.2.0-SNAPSHOT, 2.0.0) + org.gcube.socialnetworking social-data-indexing-common [1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT) - - org.gcube.portal - social-networking-library - [1.0.0-SNAPSHOT, 2.0.0-SNAPSHOT) - + org.elasticsearch elasticsearch @@ -76,26 +77,13 @@ 1.0.3 compile + + + - com.netflix.astyanax - astyanax-core - provided - - - org.slf4j - log4j-over-slf4j - - - - - com.netflix.astyanax - astyanax-thrift - provided - - - com.netflix.astyanax - astyanax-cassandra - provided + org.codehaus.jackson + jackson-mapper-asl + 1.5.0 org.gcube.resources.discovery @@ -133,8 +121,8 @@ maven-compiler-plugin - 1.7 - 1.7 + 1.8 + 1.8 diff --git a/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClient.java b/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClient.java index 35c462b..56af5fd 100644 --- a/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClient.java +++ b/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClient.java @@ -3,7 +3,7 @@ package org.gcube.socialnetworking.social_data_search_client; import java.util.List; import java.util.Set; -import org.gcube.portal.databook.shared.EnhancedFeed; +import org.gcube.social_networking.socialnetworking.model.shared.EnhancedPost; import org.gcube.socialnetworking.social_data_indexing_common.utils.SearchableFields; /** @@ -13,28 +13,28 @@ import org.gcube.socialnetworking.social_data_indexing_common.utils.SearchableFi public interface ElasticSearchClient { /** - * Given a query, the method find matching enhanced feeds into the elasticsearch index and return + * Given a query, the method find matching enhanced post into the elasticsearch index and return * at most quantity hits starting from from. A multimatch query is performed against all * searchable fields. * @param query the query to match - * @param vreIDS specifies the vre(s) to which the returning feeds must belong + * @param vreIDS specifies the vre(s) to which the returning posts must belong * @param from start hits index * @param quantity max number of hits to return starting from from - * @return A list of matching enhanced feeds or nothing + * @return A list of matching enhanced posts or nothing */ - List search(String query, Set vreIDS, int from, int quantity); + List search(String query, Set vreIDS, int from, int quantity); /** - * Given a query, the method find matching enhanced feeds into the elasticsearch index and return + * Given a query, the method find matching enhanced posts into the elasticsearch index and return * at most quantity hits starting from from. The query is performed against one of the searchable fields. * @param query the query to match - * @param vreIDS specifies the vre(s) to which the returning feeds must belong + * @param vreIDS specifies the vre(s) to which the returning posts must belong * @param from start hits index * @param quantity max number of hits to return starting from from * @param field the field against which the query is performed - * @return A list of matching enhanced feeds or nothing + * @return A list of matching enhanced posts or nothing */ - List searchInField(String query, Set vreIDS, int from, int quantity, SearchableFields field); + List searchInField(String query, Set vreIDS, int from, int quantity, SearchableFields field); /** * Delete from the index a document with id docID. diff --git a/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClientImpl.java b/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClientImpl.java index dbd4920..5ff44bd 100644 --- a/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClientImpl.java +++ b/src/main/java/org/gcube/socialnetworking/social_data_search_client/ElasticSearchClientImpl.java @@ -20,7 +20,7 @@ import org.elasticsearch.index.query.MultiMatchQueryBuilder.Type; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.index.query.TermsQueryBuilder; import org.elasticsearch.search.SearchHit; -import org.gcube.portal.databook.shared.EnhancedFeed; +import org.gcube.social_networking.socialnetworking.model.shared.EnhancedPost; import org.gcube.socialnetworking.social_data_indexing_common.utils.ElasticSearchRunningCluster; import org.gcube.socialnetworking.social_data_indexing_common.utils.IndexFields; import org.gcube.socialnetworking.social_data_indexing_common.utils.SearchableFields; @@ -94,9 +94,9 @@ public class ElasticSearchClientImpl implements ElasticSearchClient{ } @Override - public List search(String query, Set vreIDS, int from, int quantity){ + public List search(String query, Set vreIDS, int from, int quantity){ - List toReturn = new ArrayList<>(); + List toReturn = new ArrayList<>(); if(from < 0 || quantity <= 0 || vreIDS.isEmpty()) return toReturn; @@ -146,11 +146,11 @@ public class ElasticSearchClientImpl implements ElasticSearchClient{ // rebuild objects for (SearchHit hit : results) { - EnhancedFeed enhFeed; + EnhancedPost enhPost; try { - enhFeed = mapper.readValue(hit.getSourceAsString(), EnhancedFeed.class); - toReturn.add(enhFeed); + enhPost = mapper.readValue(hit.getSourceAsString(), EnhancedPost.class); + toReturn.add(enhPost); } catch (IOException e) { logger.error(e.toString()); @@ -162,10 +162,10 @@ public class ElasticSearchClientImpl implements ElasticSearchClient{ } @Override - public List searchInField(String query, Set vreIDS, + public List searchInField(String query, Set vreIDS, int from, int quantity, SearchableFields field) { - List toReturn = new ArrayList<>(); + List toReturn = new ArrayList<>(); if(from < 0 || quantity <= 0 || field == null || vreIDS.isEmpty()) return toReturn; @@ -207,11 +207,11 @@ public class ElasticSearchClientImpl implements ElasticSearchClient{ // rebuild objects for (SearchHit hit : results) { - EnhancedFeed enhFeed; + EnhancedPost enhPost; try { - enhFeed = mapper.readValue(hit.getSourceAsString(), EnhancedFeed.class); - toReturn.add(enhFeed); + enhPost = mapper.readValue(hit.getSourceAsString(), EnhancedPost.class); + toReturn.add(enhPost); } catch (IOException e) { logger.error(e.toString()); diff --git a/src/test/java/org/gcube/socialnetworking/social_data_search_client/Tests.java b/src/test/java/org/gcube/socialnetworking/social_data_search_client/Tests.java index ced8fcc..3b9f059 100644 --- a/src/test/java/org/gcube/socialnetworking/social_data_search_client/Tests.java +++ b/src/test/java/org/gcube/socialnetworking/social_data_search_client/Tests.java @@ -5,7 +5,7 @@ import java.util.HashSet; import java.util.List; import java.util.Set; -import org.gcube.portal.databook.shared.EnhancedFeed; +import org.gcube.social_networking.socialnetworking.model.shared.EnhancedPost; import org.gcube.socialnetworking.social_data_indexing_common.utils.SearchableFields; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -34,7 +34,7 @@ public class Tests Set set = new HashSet(); set.add("/gcube/devNext/NextNext"); - List results = el.searchInField("Costantino Perciante", set, 0, 10, SearchableFields.POST_AUTHOR); + List results = el.searchInField("Costantino Perciante", set, 0, 10, SearchableFields.POST_AUTHOR); logger.debug("First result is " + results);