package de.mpiwg.itgroup.annotations.restlet; import java.util.ArrayList; import java.util.List; import org.json.JSONArray; import org.json.JSONException; import org.json.JSONObject; import org.neo4j.graphdb.Node; import org.restlet.data.Form; import org.restlet.data.Parameter; import org.restlet.data.Status; import org.restlet.ext.json.JsonRepresentation; import org.restlet.representation.Representation; import org.restlet.resource.Get; import org.restlet.resource.ServerResource; import de.mpiwg.itgroup.annotations.Annotation; import de.mpiwg.itgroup.annotations.NS; import de.mpiwg.itgroup.annotations.Person; import de.mpiwg.itgroup.annotations.Tag; import de.mpiwg.itgroup.annotations.neo4j.AnnotationStore; import de.mpiwg.itgroup.annotations.restlet.utils.JSONObjectComparator; /** * API for accessing tags in the Annotation store. * * @author dwinter * */ public class AnnotatorAnnotationsByTags extends AnnotatorResourceImpl { protected String getAllowedMethodsForHeader() { return "OPTIONS,GET"; } @Get("json") public Representation doGetJSON(Representation entity) { logger.debug("AnnotatorAnnotatonsBytag doGetJSON!"); setCorsHeaders(); // do authentication Person authUser = Person.createPersonWithId(this.checkAuthToken(entity)); logger.debug("request authenticated=" + authUser); String jsonId = (String) getRequest().getAttributes().get("id"); Form form = getRequest().getResourceRef().getQueryAsForm(); String sortBy=null; for (Parameter parameter : form) { if (parameter.getName().equals("sortBy")){ sortBy = parameter.getValue(); } } //String id = decodeJsonId(jsonId); String id = jsonId; logger.debug("annotation-id=" + id); AnnotationStore store = getAnnotationStore(); String tagUri=NS.MPIWG_TAGS_URL+id; List annotations = store.getAnnotationsByTag(tagUri); //JSONArray results = new JSONArray(); ArrayList results = new ArrayList(); for (Annotation annot : annotations) { //check permission if (!annot.isActionAllowed("read", authUser, store)) continue; JSONObject jo = createAnnotatorJson(annot,false); results.add(jo); } if (sortBy!=null){ JSONObjectComparator.sortAnnotations(results,sortBy); } JSONArray resultsJa = new JSONArray(); for (JSONObject result:results){ resultsJa.put(result); } // assemble result object JSONObject result = new JSONObject(); try { result.put("rows", resultsJa); result.put("total", resultsJa.length()); } catch (JSONException e) { setStatus(Status.SERVER_ERROR_INTERNAL, "JSON Error"); return null; } logger.debug("sending:"); logger.debug(result); return new JsonRepresentation(result); } }