|
| 1 | +package edu.harvard.iq.dataverse.engine.command.impl; |
| 2 | + |
| 3 | +import java.util.ArrayList; |
| 4 | +import java.util.Collections; |
| 5 | +import java.util.List; |
| 6 | +import java.util.Map; |
| 7 | +import java.util.Set; |
| 8 | + |
| 9 | +import edu.harvard.iq.dataverse.Dataset; |
| 10 | +import edu.harvard.iq.dataverse.Dataverse; |
| 11 | +import edu.harvard.iq.dataverse.authorization.Permission; |
| 12 | +import edu.harvard.iq.dataverse.engine.command.AbstractCommand; |
| 13 | +import edu.harvard.iq.dataverse.engine.command.CommandContext; |
| 14 | +import edu.harvard.iq.dataverse.engine.command.DataverseRequest; |
| 15 | +import edu.harvard.iq.dataverse.engine.command.exception.CommandException; |
| 16 | +import edu.harvard.iq.dataverse.search.SearchConstants; |
| 17 | +import edu.harvard.iq.dataverse.search.SearchException; |
| 18 | +import edu.harvard.iq.dataverse.search.SearchFields; |
| 19 | +import edu.harvard.iq.dataverse.search.SolrQueryResponse; |
| 20 | +import edu.harvard.iq.dataverse.search.SolrSearchResult; |
| 21 | +import edu.harvard.iq.dataverse.search.SortBy; |
| 22 | +import jakarta.json.Json; |
| 23 | +import jakarta.json.JsonArrayBuilder; |
| 24 | +import jakarta.json.JsonObject; |
| 25 | +import jakarta.json.JsonObjectBuilder; |
| 26 | + |
| 27 | +// No annotations here since permissions are dynamically decided |
| 28 | +public class GetDatasetReviewsCommand extends AbstractCommand<JsonObjectBuilder> { |
| 29 | + |
| 30 | + private final Dataset dataset; |
| 31 | + |
| 32 | + public GetDatasetReviewsCommand(DataverseRequest request, Dataset target) { |
| 33 | + super(request, target); |
| 34 | + dataset = target; |
| 35 | + } |
| 36 | + |
| 37 | + @Override |
| 38 | + public JsonObjectBuilder execute(CommandContext ctxt) throws CommandException { |
| 39 | + JsonObjectBuilder reviews = Json.createObjectBuilder(); |
| 40 | + List<Dataverse> dataverses = new ArrayList<>(); |
| 41 | + // Putting PID as URL in quotes to avoid hits we don't want |
| 42 | + String query = "itemReviewedUrl:\"" + dataset.getGlobalId().asURL() + "\""; |
| 43 | + List<String> filterQueries = new ArrayList<>(); |
| 44 | + // Limit to datasets (review datasets) |
| 45 | + filterQueries.add(SearchFields.TYPE + ":" + SearchConstants.DATASETS); |
| 46 | + String sortField = SearchFields.ID; |
| 47 | + String sortOrder = SortBy.ASCENDING; |
| 48 | + int paginationStart = 0; |
| 49 | + boolean dataRelatedToMe = false; |
| 50 | + // We only expect a handful of reviews. This should be plenty. |
| 51 | + int numResultsPerPage = 100; |
| 52 | + try { |
| 53 | + SolrQueryResponse solrQueryResponse = ctxt.search().getDefaultSearchService().search(getRequest(), |
| 54 | + dataverses, query, filterQueries, sortField, sortOrder, paginationStart, dataRelatedToMe, |
| 55 | + numResultsPerPage); |
| 56 | + JsonArrayBuilder itemsArrayBuilder = Json.createArrayBuilder(); |
| 57 | + List<SolrSearchResult> solrSearchResults = solrQueryResponse.getSolrSearchResults(); |
| 58 | + for (SolrSearchResult solrSearchResult : solrSearchResults) { |
| 59 | + // Construct a JSON object intentionally rather than simply returning the |
| 60 | + // solrSearchResult. This "get reviews" command may be powered by a |
| 61 | + // database query in the future and we'll want to preserve the contract |
| 62 | + // we're establishing here if we make the switch from Solr. |
| 63 | + JsonObjectBuilder searchResultBuilder = solrSearchResult.json(false, true, false); |
| 64 | + JsonObject searchResultObject = searchResultBuilder.build(); |
| 65 | + String title = searchResultObject.getString("name"); |
| 66 | + String citation = searchResultObject.getString("citation"); |
| 67 | + String citationHtml = searchResultObject.getString("citationHtml"); |
| 68 | + String pid = searchResultObject.getString("global_id"); |
| 69 | + String pidUrl = searchResultObject.getString("url"); |
| 70 | + long id = searchResultObject.getJsonNumber("entity_id").longValue(); |
| 71 | + JsonObjectBuilder review = Json.createObjectBuilder() |
| 72 | + .add("title", title) |
| 73 | + .add("persistentId", pid) |
| 74 | + .add("persistentIdUrl", pidUrl) |
| 75 | + .add("id", id) |
| 76 | + .add("citation", citation) |
| 77 | + .add("citationHtml", citationHtml); |
| 78 | + itemsArrayBuilder.add(review); |
| 79 | + } |
| 80 | + reviews.add("reviews", itemsArrayBuilder); |
| 81 | + } catch (SearchException ex) { |
| 82 | + throw new CommandException(ex.getMessage(), this); |
| 83 | + } |
| 84 | + return reviews; |
| 85 | + } |
| 86 | + |
| 87 | + @Override |
| 88 | + public Map<String, Set<Permission>> getRequiredPermissions() { |
| 89 | + return Collections.singletonMap("", |
| 90 | + dataset.isReleased() ? Collections.<Permission>emptySet() |
| 91 | + : Collections.singleton(Permission.ViewUnpublishedDataset)); |
| 92 | + } |
| 93 | + |
| 94 | +} |
0 commit comments