| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1 | package de.ids_mannheim.korap.web.controller;// package |
| 2 | // de.ids_mannheim.korap.ext.web; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 3 | |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 4 | import java.util.ArrayList; |
| 5 | import java.util.HashMap; |
| 6 | import java.util.HashSet; |
| 7 | import java.util.Locale; |
| 8 | import java.util.Map; |
| 9 | import java.util.Set; |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 10 | import java.util.regex.Pattern; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 11 | |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 12 | import javax.annotation.PostConstruct; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 13 | import javax.ws.rs.DELETE; |
| 14 | import javax.ws.rs.GET; |
| 15 | import javax.ws.rs.POST; |
| 16 | import javax.ws.rs.Path; |
| 17 | import javax.ws.rs.PathParam; |
| 18 | import javax.ws.rs.Produces; |
| 19 | import javax.ws.rs.QueryParam; |
| 20 | import javax.ws.rs.core.Context; |
| Bodmo | ca3dcfb | 2017-05-24 16:36:00 +0200 | [diff] [blame] | 21 | import javax.ws.rs.core.HttpHeaders; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 22 | import javax.ws.rs.core.MediaType; |
| 23 | import javax.ws.rs.core.MultivaluedMap; |
| 24 | import javax.ws.rs.core.Response; |
| 25 | import javax.ws.rs.core.SecurityContext; |
| 26 | import javax.ws.rs.core.UriBuilder; |
| 27 | |
| 28 | import org.slf4j.Logger; |
| 29 | import org.slf4j.LoggerFactory; |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 30 | import org.springframework.beans.factory.annotation.Autowired; |
| 31 | import org.springframework.stereotype.Controller; |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 32 | import org.springframework.web.bind.annotation.RequestMapping; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 33 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 34 | import com.fasterxml.jackson.databind.JsonNode; |
| 35 | import com.sun.jersey.core.util.MultivaluedMapImpl; |
| 36 | import com.sun.jersey.spi.container.ResourceFilters; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 37 | |
| Michael Hanl | 00b64e0 | 2016-05-24 20:24:27 +0200 | [diff] [blame] | 38 | import de.ids_mannheim.korap.config.Attributes; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 39 | import de.ids_mannheim.korap.config.KustvaktConfiguration; |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 40 | import de.ids_mannheim.korap.config.KustvaktConfiguration.BACKENDS; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 41 | import de.ids_mannheim.korap.exceptions.KustvaktException; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 42 | import de.ids_mannheim.korap.exceptions.StatusCodes; |
| margaretha | f68daa6 | 2017-09-21 02:11:24 +0200 | [diff] [blame] | 43 | import de.ids_mannheim.korap.filter.AuthFilter; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 44 | import de.ids_mannheim.korap.interfaces.AuthenticationManagerIface; |
| 45 | import de.ids_mannheim.korap.query.serialize.MetaQueryBuilder; |
| 46 | import de.ids_mannheim.korap.query.serialize.QuerySerializer; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 47 | import de.ids_mannheim.korap.resource.rewrite.RewriteHandler; |
| 48 | import de.ids_mannheim.korap.resources.Corpus; |
| 49 | import de.ids_mannheim.korap.resources.KustvaktResource; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 50 | import de.ids_mannheim.korap.resources.ResourceFactory; |
| 51 | import de.ids_mannheim.korap.resources.VirtualCollection; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 52 | import de.ids_mannheim.korap.security.ac.ResourceFinder; |
| 53 | import de.ids_mannheim.korap.security.ac.ResourceHandler; |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 54 | import de.ids_mannheim.korap.user.DemoUser; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 55 | import de.ids_mannheim.korap.user.TokenContext; |
| 56 | import de.ids_mannheim.korap.user.User; |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 57 | import de.ids_mannheim.korap.user.User.CorpusAccess; |
| margaretha | 0ba34ef | 2017-02-21 14:19:05 +0100 | [diff] [blame] | 58 | import de.ids_mannheim.korap.utils.JsonUtils; |
| 59 | import de.ids_mannheim.korap.utils.KoralCollectionQueryBuilder; |
| 60 | import de.ids_mannheim.korap.utils.KustvaktLogger; |
| 61 | import de.ids_mannheim.korap.utils.StringUtils; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 62 | import de.ids_mannheim.korap.web.ClientsHandler; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 63 | import de.ids_mannheim.korap.web.SearchKrill; |
| Michael Hanl | 99cb963 | 2016-06-29 16:24:40 +0200 | [diff] [blame] | 64 | import de.ids_mannheim.korap.web.filter.DemoUserFilter; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 65 | import de.ids_mannheim.korap.web.filter.PiwikFilter; |
| 66 | import de.ids_mannheim.korap.web.utils.KustvaktResponseHandler; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 67 | |
| 68 | /** |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 69 | * EM: To Do: restructure codes regarding service and controller layers |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 70 | * @author hanl, margaretha |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 71 | * @date 29/01/2014 |
| margaretha | da6211e | 2017-06-22 18:35:18 +0200 | [diff] [blame] | 72 | * @lastUpdate 06/2017 |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 73 | */ |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 74 | @Controller |
| 75 | @Path("/") |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 76 | @RequestMapping("/") |
| margaretha | 1a6d020 | 2017-02-16 18:09:39 +0100 | [diff] [blame] | 77 | @ResourceFilters({ AuthFilter.class, DemoUserFilter.class, PiwikFilter.class }) |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 78 | @Produces(MediaType.APPLICATION_JSON + ";charset=utf-8") |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 79 | public class SearchController { |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 80 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 81 | private static Logger jlog = |
| 82 | LoggerFactory.getLogger(SearchController.class); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 83 | |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 84 | @Autowired |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 85 | private SearchKrill searchKrill; |
| 86 | private ResourceHandler resourceHandler; |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 87 | @Autowired |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 88 | private AuthenticationManagerIface controller; |
| 89 | private ClientsHandler graphDBhandler; |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 90 | @Autowired |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 91 | private KustvaktConfiguration config; |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 92 | @Autowired |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 93 | private RewriteHandler processor; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 94 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 95 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 96 | public SearchController () { |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 97 | this.resourceHandler = new ResourceHandler(); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 98 | UriBuilder builder = UriBuilder.fromUri("http://10.0.10.13").port(9997); |
| 99 | this.graphDBhandler = new ClientsHandler(builder.build()); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 100 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 101 | |
| margaretha | ade7d4a | 2017-07-20 19:53:35 +0200 | [diff] [blame] | 102 | @PostConstruct |
| 103 | private void doPostConstruct () { |
| 104 | this.processor.defaultRewriteConstraints(); |
| 105 | } |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 106 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 107 | /** |
| 108 | * retrieve resources dependent by type. determines based on the |
| 109 | * user's |
| 110 | * permission or resource owner if the user can access the |
| 111 | * resource. |
| 112 | * |
| 113 | * @param locale |
| 114 | * @param context |
| 115 | * @param type |
| 116 | * @return valid resources in json format |
| 117 | */ |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 118 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 119 | @GET |
| 120 | @Path("{type}") |
| 121 | public Response getResources (@Context Locale locale, |
| 122 | @Context SecurityContext context, @PathParam("type") String type) { |
| 123 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 124 | Set<KustvaktResource> resources = new HashSet<>(); |
| 125 | type = StringUtils.normalize(type); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 126 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 127 | try { |
| 128 | Class cl_type = ResourceFactory.getResourceClass(type); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 129 | if (cl_type == null) throw KustvaktResponseHandler.throwit( |
| 130 | StatusCodes.MISSING_ARGUMENT, |
| 131 | "Resource type not available!", ""); |
| Michael Hanl | 99cb963 | 2016-06-29 16:24:40 +0200 | [diff] [blame] | 132 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 133 | User user = controller.getUser(ctx.getUsername()); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 134 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 135 | resources = ResourceFinder.search(user, |
| 136 | ResourceFactory.getResourceClass(type)); |
| 137 | } |
| 138 | catch (KustvaktException e) { |
| 139 | throw KustvaktResponseHandler.throwit(e); |
| 140 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 141 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 142 | Set values = new HashSet(); |
| 143 | for (KustvaktResource resource : resources) |
| 144 | values.add(resource.toMap()); |
| 145 | return Response.ok(JsonUtils.toJSON(values)).build(); |
| 146 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 147 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 148 | |
| margaretha | f18298b | 2017-09-14 22:14:32 +0200 | [diff] [blame] | 149 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 150 | @GET |
| 151 | @Path("{type}/{id}/{child}") |
| 152 | public Response getResource (@Context SecurityContext context, |
| 153 | @Context Locale locale, @PathParam("type") String type, |
| 154 | @PathParam("id") String id, @PathParam("child") String child) { |
| 155 | return getResource(context, locale, type, |
| 156 | StringUtils.joinResources(id, child)); |
| 157 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 158 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 159 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 160 | /** |
| 161 | * @param context |
| 162 | * @param locale |
| 163 | * @param id |
| 164 | * @param type |
| 165 | * @return |
| 166 | */ |
| margaretha | f18298b | 2017-09-14 22:14:32 +0200 | [diff] [blame] | 167 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 168 | @GET |
| 169 | @Path("{type}/{id}") |
| 170 | public Response getResource (@Context SecurityContext context, |
| 171 | @Context Locale locale, @PathParam("type") String type, |
| 172 | @PathParam("id") String id) { |
| 173 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 174 | type = StringUtils.normalize(type); |
| 175 | KustvaktResource resource; |
| 176 | try { |
| 177 | Class cl_type = ResourceFactory.getResourceClass(type); |
| Michael Hanl | 9c484cf | 2016-06-06 20:33:19 +0200 | [diff] [blame] | 178 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 179 | if (ctx.isDemo()) { |
| 180 | Set set = ResourceFinder.searchPublicFiltered(cl_type, id); |
| 181 | resource = (KustvaktResource) set.toArray()[0]; |
| 182 | } |
| 183 | else { |
| 184 | User user = controller.getUser(ctx.getUsername()); |
| 185 | if (StringUtils.isInteger(id)) |
| 186 | resource = resourceHandler.findbyIntId(Integer.valueOf(id), |
| 187 | user); |
| 188 | else |
| 189 | resource = resourceHandler.findbyStrId(id, user, cl_type); |
| 190 | } |
| 191 | } |
| 192 | catch (KustvaktException e) { |
| 193 | // if (e.getStatusCode() != StatusCodes.ACCESS_DENIED) |
| 194 | throw KustvaktResponseHandler.throwit(e); |
| Michael Hanl | 99cb963 | 2016-06-29 16:24:40 +0200 | [diff] [blame] | 195 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 196 | // try { |
| 197 | // Set set = ResourceFinder.searchPublicFiltered(cl_type, id); |
| 198 | // resource = (KustvaktResource) set.toArray()[0]; |
| 199 | // } |
| 200 | // catch (KustvaktException e1) { |
| 201 | // throw KustvaktResponseHandler.throwit(e); |
| 202 | // } |
| 203 | } |
| 204 | return Response.ok(JsonUtils.toJSON(resource.toMap())).build(); |
| 205 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 206 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 207 | // @GET |
| 208 | // @Path("colloc") |
| 209 | // public Response getCollocationsAll(@Context SecurityContext ctx, |
| 210 | // @Context Locale locale, @QueryParam("props") String properties, |
| 211 | // @QueryParam("sfskip") Integer sfs, |
| 212 | // @QueryParam("sflimit") Integer limit, @QueryParam("q") String query, |
| 213 | // @QueryParam("ql") String ql, @QueryParam("context") Integer context, |
| 214 | // @QueryParam("foundry") String foundry, |
| 215 | // @QueryParam("paths") Boolean wPaths) { |
| 216 | // TokenContext tokenContext = (TokenContext) ctx.getUserPrincipal(); |
| 217 | // ColloQuery.ColloQueryBuilder builder; |
| 218 | // KoralCollectionQueryBuilder cquery = new KoralCollectionQueryBuilder(); |
| 219 | // String result; |
| 220 | // try { |
| 221 | // User user = controller.getUser(tokenContext.getUsername()); |
| 222 | // Set<VirtualCollection> resources = ResourceFinder |
| 223 | // .search(user, VirtualCollection.class); |
| 224 | // for (KustvaktResource c : resources) |
| 225 | // cquery.addResource(((VirtualCollection) c).getQuery()); |
| 226 | // |
| 227 | // builder = functions |
| 228 | // .buildCollocations(query, ql, properties, context, limit, |
| 229 | // sfs, foundry, new ArrayList<Dependency>(), wPaths, |
| 230 | // cquery); |
| 231 | // |
| 232 | // result = graphDBhandler |
| 233 | // .getResponse("distCollo", "q", builder.build().toJSON()); |
| 234 | // }catch (KustvaktException e) { |
| 235 | // throw KustvaktResponseHandler.throwit(e); |
| 236 | // }catch (JsonProcessingException e) { |
| 237 | // throw KustvaktResponseHandler.throwit(StatusCodes.ILLEGAL_ARGUMENT); |
| 238 | // } |
| 239 | // return Response.ok(result).build(); |
| 240 | // } |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 241 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 242 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 243 | // /** |
| 244 | // * @param locale |
| 245 | // * @param properties a json object string containing field, op and value |
| 246 | // for the query |
| 247 | // * @param query |
| 248 | // * @param context |
| 249 | // * @return |
| 250 | // */ |
| 251 | // @GET |
| 252 | // @Path("{type}/{id}/colloc") |
| 253 | // public Response getCollocations(@Context SecurityContext ctx, |
| 254 | // @Context Locale locale, @QueryParam("props") String properties, |
| 255 | // @QueryParam("sfskip") Integer sfs, |
| 256 | // @QueryParam("sflimit") Integer limit, @QueryParam("q") String query, |
| 257 | // @QueryParam("ql") String ql, @QueryParam("context") Integer context, |
| 258 | // @QueryParam("foundry") String foundry, |
| 259 | // @QueryParam("paths") Boolean wPaths, @PathParam("id") String id, |
| 260 | // @PathParam("type") String type) { |
| 261 | // ColloQuery.ColloQueryBuilder builder; |
| 262 | // type = StringUtils.normalize(type); |
| 263 | // id = StringUtils.decodeHTML(id); |
| 264 | // TokenContext tokenContext = (TokenContext) ctx.getUserPrincipal(); |
| 265 | // String result; |
| 266 | // try { |
| 267 | // KoralCollectionQueryBuilder cquery = new KoralCollectionQueryBuilder(); |
| 268 | // try { |
| 269 | // User user = controller.getUser(tokenContext.getUsername()); |
| 270 | // |
| 271 | // KustvaktResource resource = this.resourceHandler |
| 272 | // .findbyStrId(id, user, type); |
| 273 | // |
| 274 | // if (resource instanceof VirtualCollection) |
| 275 | // cquery.addResource( |
| 276 | // ((VirtualCollection) resource).getQuery()); |
| 277 | // else if (resource instanceof Corpus) |
| 278 | // cquery.addMetaFilter("corpusID", |
| 279 | // resource.getPersistentID()); |
| 280 | // else |
| 281 | // throw KustvaktResponseHandler |
| 282 | // .throwit(StatusCodes.ILLEGAL_ARGUMENT, |
| 283 | // "Type parameter not supported", type); |
| 284 | // |
| 285 | // }catch (KustvaktException e) { |
| 286 | // throw KustvaktResponseHandler.throwit(e); |
| 287 | // }catch (NumberFormatException ex) { |
| 288 | // throw KustvaktResponseHandler |
| 289 | // .throwit(StatusCodes.ILLEGAL_ARGUMENT); |
| 290 | // } |
| 291 | // |
| 292 | // builder = functions |
| 293 | // .buildCollocations(query, ql, properties, context, limit, |
| 294 | // sfs, foundry, new ArrayList<Dependency>(), wPaths, |
| 295 | // cquery); |
| 296 | // |
| 297 | // result = graphDBhandler |
| 298 | // .getResponse("distCollo", "q", builder.build().toJSON()); |
| 299 | // |
| 300 | // }catch (JsonProcessingException e) { |
| 301 | // throw KustvaktResponseHandler.throwit(StatusCodes.ILLEGAL_ARGUMENT); |
| 302 | // }catch (KustvaktException e) { |
| 303 | // throw KustvaktResponseHandler.throwit(e); |
| 304 | // } |
| 305 | // |
| 306 | // return Response.ok(result).build(); |
| 307 | // } |
| 308 | @POST |
| 309 | @Path("colloc") |
| 310 | public Response getCollocationBase (@QueryParam("q") String query) { |
| 311 | String result; |
| 312 | try { |
| 313 | result = graphDBhandler.getResponse("distCollo", "q", query); |
| 314 | } |
| 315 | catch (KustvaktException e) { |
| 316 | throw KustvaktResponseHandler.throwit(e); |
| 317 | } |
| 318 | return Response.ok(result).build(); |
| 319 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 320 | |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 321 | |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 322 | /* EM: potentially an unused service! */ |
| 323 | /** Builds a json query serialization from the given parameters. |
| 324 | * |
| 325 | * @param locale |
| 326 | * @param securityContext |
| 327 | * @param q query string |
| 328 | * @param ql query language |
| 329 | * @param v version |
| 330 | * @param context |
| 331 | * @param cutoff true if the number of results should be limited |
| 332 | * @param pageLength number of results per page |
| 333 | * @param pageIndex |
| 334 | * @param startPage |
| 335 | * @param cq collection query |
| 336 | * @return |
| 337 | */ |
| 338 | // ref query parameter removed! |
| 339 | // EM: change the HTTP method to from TRACE to GET |
| 340 | // EM: change path from search to query |
| 341 | @GET |
| 342 | @Path("query") |
| 343 | public Response serializeQuery (@Context Locale locale, |
| 344 | @Context SecurityContext securityContext, @QueryParam("q") String q, |
| 345 | @QueryParam("ql") String ql, @QueryParam("v") String v, |
| 346 | @QueryParam("context") String context, |
| 347 | @QueryParam("cutoff") Boolean cutoff, |
| 348 | @QueryParam("count") Integer pageLength, |
| 349 | @QueryParam("offset") Integer pageIndex, |
| 350 | @QueryParam("page") Integer startPage, |
| 351 | @QueryParam("cq") String cq) { |
| 352 | TokenContext ctx = (TokenContext) securityContext.getUserPrincipal(); |
| 353 | QuerySerializer ss = new QuerySerializer().setQuery(q, ql, v); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 354 | if (cq != null) ss.setCollection(cq); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 355 | |
| 356 | MetaQueryBuilder meta = new MetaQueryBuilder(); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 357 | if (pageIndex != null) meta.addEntry("startIndex", pageIndex); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 358 | if (pageIndex == null && startPage != null) |
| 359 | meta.addEntry("startPage", startPage); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 360 | if (pageLength != null) meta.addEntry("count", pageLength); |
| 361 | if (context != null) meta.setSpanContext(context); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 362 | meta.addEntry("cutOff", cutoff); |
| 363 | |
| 364 | ss.setMeta(meta.raw()); |
| 365 | String result = ss.toJSON(); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 366 | jlog.debug("Query: " + result); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 367 | return Response.ok(result).build(); |
| 368 | } |
| 369 | |
| 370 | |
| 371 | /** |
| 372 | * currently only supports either no reference at all in which |
| 373 | * case all corpora are retrieved or a corpus name like "WPD". |
| 374 | * No virtual collections supported! |
| 375 | * |
| 376 | * @param locale |
| 377 | * @param q |
| 378 | * @param ql |
| 379 | * @param v |
| 380 | * @param pageLength |
| 381 | * @param pageIndex |
| 382 | * @return |
| 383 | */ |
| 384 | |
| 385 | // todo: does cq have any sensible worth here? --> would say no! --> is |
| 386 | // useful in non type/id scenarios |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 387 | |
| 388 | /* EM: potentially an unused service! */ |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 389 | // EM: build query using the given virtual collection id |
| 390 | // EM: change the HTTP method to from TRACE to GET |
| 391 | // EM: change path from search to query |
| 392 | // EM: there is no need to check resource licenses since the service just serialize a query serialization |
| 393 | @GET |
| 394 | @Path("{type}/{id}/query") |
| 395 | public Response serializeQueryWithResource (@Context Locale locale, |
| 396 | @Context SecurityContext securityContext, @QueryParam("q") String q, |
| 397 | @QueryParam("ql") String ql, @QueryParam("v") String v, |
| 398 | @QueryParam("context") String context, |
| 399 | @QueryParam("cutoff") Boolean cutoff, |
| 400 | @QueryParam("count") Integer pageLength, |
| 401 | @QueryParam("offset") Integer pageIndex, |
| 402 | @QueryParam("page") Integer startPage, |
| 403 | @PathParam("type") String type, @PathParam("id") String id) { |
| 404 | TokenContext ctx = (TokenContext) securityContext.getUserPrincipal(); |
| 405 | type = StringUtils.normalize(type); |
| 406 | id = StringUtils.decodeHTML(id); |
| 407 | |
| 408 | QuerySerializer ss = new QuerySerializer().setQuery(q, ql, v); |
| 409 | |
| 410 | MetaQueryBuilder meta = new MetaQueryBuilder(); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 411 | if (pageIndex != null) meta.addEntry("startIndex", pageIndex); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 412 | if (pageIndex == null && startPage != null) |
| 413 | meta.addEntry("startPage", startPage); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 414 | if (pageLength != null) meta.addEntry("count", pageLength); |
| 415 | if (context != null) meta.setSpanContext(context); |
| 416 | if (cutoff != null) meta.addEntry("cutOff", cutoff); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 417 | |
| 418 | ss.setMeta(meta.raw()); |
| 419 | |
| 420 | KoralCollectionQueryBuilder cquery = new KoralCollectionQueryBuilder(); |
| 421 | cquery.setBaseQuery(ss.toJSON()); |
| 422 | |
| 423 | String query = ""; |
| 424 | // EM: is this necessary at all? |
| 425 | KustvaktResource resource = isCollectionIdValid(ctx.getName(), id); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 426 | if (resource != null) { |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 427 | if (resource instanceof VirtualCollection) { |
| 428 | JsonNode node = cquery.and().mergeWith(resource.getData()); |
| 429 | query = JsonUtils.toJSON(node); |
| 430 | } |
| 431 | else if (resource instanceof Corpus) { |
| 432 | cquery.and().with(Attributes.CORPUS_SIGLE, "=", |
| 433 | resource.getPersistentID()); |
| 434 | query = cquery.toJSON(); |
| 435 | } |
| 436 | } |
| 437 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 438 | jlog.debug("Query: " + query); |
| margaretha | 6c2a20f | 2017-07-24 15:33:01 +0200 | [diff] [blame] | 439 | return Response.ok(query).build(); |
| 440 | } |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 441 | |
| margaretha | da6211e | 2017-06-22 18:35:18 +0200 | [diff] [blame] | 442 | // EM: prototype |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 443 | private KustvaktResource isCollectionIdValid (String username, |
| 444 | String collectionId) { |
| 445 | |
| 446 | // try { |
| 447 | // if (ctx.isDemo()) { |
| 448 | // // EM: FIX ME: Is there public VCs? set default username |
| 449 | // for nonlogin user, change demo? |
| 450 | // Set set = ResourceFinder.searchPublicFiltered( |
| 451 | // ResourceFactory.getResourceClass(type), id); |
| 452 | // resource = (KustvaktResource) set.toArray()[0]; |
| 453 | // } |
| 454 | // else { |
| 455 | // // EM: FIX ME: search in user VC |
| 456 | // User user = controller.getUser(ctx.getUsername()); |
| 457 | // if (StringUtils.isInteger(id)) |
| 458 | // resource = this.resourceHandler |
| 459 | // .findbyIntId(Integer.valueOf(id), user); |
| 460 | // else |
| 461 | // resource = this.resourceHandler.findbyStrId(id, user, |
| 462 | // ResourceFactory.getResourceClass(type)); |
| 463 | // } |
| 464 | // } |
| 465 | // // todo: instead of throwing exception, build notification and rewrites |
| 466 | // // into result query |
| 467 | // catch (KustvaktException e) { |
| 468 | // jlog.error("Exception encountered: {}", e.string()); |
| 469 | // throw KustvaktResponseHandler.throwit(e); |
| 470 | // } |
| 471 | |
| margaretha | da6211e | 2017-06-22 18:35:18 +0200 | [diff] [blame] | 472 | return null; |
| 473 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 474 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 475 | |
| 476 | @POST |
| 477 | @Path("search") |
| 478 | public Response queryRaw (@Context SecurityContext context, |
| 479 | @Context Locale locale, @QueryParam("engine") String engine, |
| 480 | String jsonld) { |
| 481 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 482 | |
| 483 | // todo: should be possible to add the meta part to the query |
| 484 | // serialization |
| 485 | try { |
| 486 | User user = controller.getUser(ctx.getUsername()); |
| 487 | // jsonld = this.processor.processQuery(jsonld, user); |
| 488 | } |
| 489 | catch (KustvaktException e) { |
| 490 | throw KustvaktResponseHandler.throwit(e); |
| 491 | } |
| 492 | jlog.info("Serialized search: {}", jsonld); |
| 493 | |
| 494 | String result = searchKrill.search(jsonld); |
| 495 | // todo: logging |
| 496 | KustvaktLogger.QUERY_LOGGER.trace("The result set: {}", result); |
| 497 | return Response.ok(result).build(); |
| 498 | } |
| 499 | |
| 500 | |
| 501 | @GET |
| 502 | @Path("search") |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 503 | public Response search (@Context SecurityContext securityContext, |
| 504 | @Context HttpHeaders headers, @Context Locale locale, |
| 505 | @QueryParam("q") String q, @QueryParam("ql") String ql, |
| 506 | @QueryParam("v") String v, @QueryParam("context") String ctx, |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 507 | @QueryParam("cutoff") Boolean cutoff, |
| 508 | @QueryParam("count") Integer pageLength, |
| 509 | @QueryParam("offset") Integer pageIndex, |
| 510 | @QueryParam("page") Integer pageInteger, |
| 511 | @QueryParam("cq") String cq, @QueryParam("engine") String engine) { |
| Bodmo | b571b36 | 2017-05-03 16:22:11 +0200 | [diff] [blame] | 512 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 513 | TokenContext context = |
| 514 | (TokenContext) securityContext.getUserPrincipal(); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 515 | KustvaktConfiguration.BACKENDS eng = this.config.chooseBackend(engine); |
| 516 | User user; |
| 517 | try { |
| 518 | user = controller.getUser(context.getUsername()); |
| Bodmo | ca3dcfb | 2017-05-24 16:36:00 +0200 | [diff] [blame] | 519 | controller.setAccessAndLocation(user, headers); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 520 | // System.out.printf("Debug: /search/: location=%s, access='%s'.\n", user.locationtoString(), user.accesstoString()); |
| 521 | } |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 522 | catch (KustvaktException e) { |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 523 | jlog.error("Failed retrieving user in the search service: {}", |
| 524 | e.string()); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 525 | throw KustvaktResponseHandler.throwit(e); |
| 526 | } |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 527 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 528 | QuerySerializer serializer = new QuerySerializer(); |
| 529 | serializer.setQuery(q, ql, v); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 530 | if (cq != null) serializer.setCollection(cq); |
| margaretha | a89c3f9 | 2017-05-30 19:02:08 +0200 | [diff] [blame] | 531 | |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 532 | MetaQueryBuilder meta = createMetaQuery(pageIndex, pageInteger, ctx, |
| 533 | pageLength, cutoff); |
| 534 | serializer.setMeta(meta.raw()); |
| 535 | |
| 536 | String query; |
| 537 | try { |
| 538 | query = this.processor.processQuery(serializer.toJSON(), user); |
| 539 | jlog.info("the serialized query {}", query); |
| 540 | } |
| 541 | catch (KustvaktException e) { |
| 542 | throw KustvaktResponseHandler.throwit(e); |
| 543 | } |
| 544 | |
| 545 | String result = doSearch(eng, query, pageLength, meta); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 546 | jlog.debug("Query result: " + result); |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 547 | return Response.ok(result).build(); |
| 548 | } |
| 549 | |
| 550 | |
| 551 | private MetaQueryBuilder createMetaQuery (Integer pageIndex, |
| 552 | Integer pageInteger, String ctx, Integer pageLength, |
| 553 | Boolean cutoff) { |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 554 | MetaQueryBuilder meta = new MetaQueryBuilder(); |
| 555 | meta.addEntry("startIndex", pageIndex); |
| 556 | meta.addEntry("startPage", pageInteger); |
| 557 | meta.setSpanContext(ctx); |
| 558 | meta.addEntry("count", pageLength); |
| 559 | // todo: what happened to cutoff? |
| margaretha | 3fc0fd4 | 2017-05-02 18:08:31 +0200 | [diff] [blame] | 560 | meta.addEntry("cutOff", cutoff); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 561 | // meta.addMeta(pageIndex, pageInteger, pageLength, ctx, cutoff); |
| 562 | // fixme: should only apply to CQL queries per default! |
| 563 | // meta.addEntry("itemsPerResource", 1); |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 564 | return meta; |
| 565 | } |
| 566 | |
| 567 | |
| 568 | private String doSearch (BACKENDS eng, String query, Integer pageLength, |
| 569 | MetaQueryBuilder meta) { |
| 570 | String result; |
| 571 | if (eng.equals(KustvaktConfiguration.BACKENDS.NEO4J)) { |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 572 | result = searchNeo4J(query, pageLength, meta, false); |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 573 | } |
| 574 | else { |
| 575 | result = searchKrill.search(query); |
| 576 | } |
| 577 | KustvaktLogger.QUERY_LOGGER.trace("The result set: {}", result); |
| 578 | return result; |
| 579 | |
| 580 | } |
| 581 | |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 582 | |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 583 | private String searchNeo4J (String query, int pageLength, |
| 584 | MetaQueryBuilder meta, boolean raw) { |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 585 | |
| 586 | if (raw) { |
| 587 | throw KustvaktResponseHandler.throwit(StatusCodes.ILLEGAL_ARGUMENT, |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 588 | "raw not supported!", null); |
| 589 | } |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 590 | |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 591 | MultivaluedMap<String, String> map = new MultivaluedMapImpl(); |
| 592 | map.add("q", query); |
| 593 | map.add("count", String.valueOf(pageLength)); |
| 594 | map.add("lctxs", String.valueOf(meta.getSpanContext().getLeftSize())); |
| 595 | map.add("rctxs", String.valueOf(meta.getSpanContext().getRightSize())); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 596 | try { |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 597 | return this.graphDBhandler.getResponse(map, "distKwic"); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 598 | } |
| 599 | catch (KustvaktException e) { |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 600 | jlog.error("Failed searching in Neo4J: {}", e.string()); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 601 | throw KustvaktResponseHandler.throwit(e); |
| 602 | } |
| 603 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 604 | } |
| 605 | |
| margaretha | a89c3f9 | 2017-05-30 19:02:08 +0200 | [diff] [blame] | 606 | @Deprecated |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 607 | private String createQuery (User user, String type, String id, |
| 608 | KoralCollectionQueryBuilder builder) { |
| 609 | KustvaktResource resource = null; |
| 610 | try { |
| 611 | // EM: this doesn't look like very useful since the id is : |
| 612 | // 1. auto-generated |
| 613 | // 2. random |
| 614 | // 3. not really known. |
| 615 | if (user instanceof DemoUser) { |
| 616 | Set<KustvaktResource> set = null; |
| 617 | if (StringUtils.isInteger(id)) { |
| 618 | set = ResourceFinder.searchPublicFilteredIntId( |
| 619 | ResourceFactory.getResourceClass(type), |
| 620 | Integer.parseInt(id)); |
| 621 | } |
| 622 | else { |
| 623 | set = ResourceFinder.searchPublicFiltered( |
| 624 | ResourceFactory.getResourceClass(type), id); |
| 625 | } |
| 626 | resource = (KustvaktResource) set.toArray()[0]; |
| 627 | } |
| 628 | else if (StringUtils.isInteger(id)) { |
| 629 | resource = this.resourceHandler.findbyIntId(Integer.valueOf(id), |
| 630 | user); |
| 631 | } |
| 632 | else { |
| 633 | resource = this.resourceHandler.findbyStrId(id, user, |
| 634 | ResourceFactory.getResourceClass(type)); |
| 635 | } |
| 636 | } |
| 637 | catch (KustvaktException e) { |
| 638 | jlog.error("Failed retrieving resource: {}", e.string()); |
| 639 | throw KustvaktResponseHandler.throwit(e); |
| 640 | } |
| 641 | |
| 642 | if (resource instanceof VirtualCollection) { |
| 643 | // test this |
| 644 | //builder.setBaseQuery(resource.getData()); |
| 645 | return JsonUtils |
| 646 | .toJSON(builder.and().mergeWith(resource.getData())); |
| 647 | } |
| 648 | else if (resource instanceof Corpus) { |
| 649 | builder.and().with(Attributes.CORPUS_SIGLE, "=", |
| 650 | resource.getPersistentID()); |
| 651 | return builder.toJSON(); |
| 652 | } |
| 653 | else { |
| 654 | throw KustvaktResponseHandler.throwit(StatusCodes.ILLEGAL_ARGUMENT, |
| 655 | "Type parameter not supported", type); |
| 656 | } |
| 657 | } |
| 658 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 659 | /** |
| 660 | * @param context |
| 661 | * @param locale |
| 662 | * @param json |
| 663 | * @return |
| 664 | */ |
| 665 | // todo: rename |
| 666 | @POST |
| 667 | @Path("collection_raw") |
| 668 | public Response createRawCollection (@Context SecurityContext context, |
| 669 | @Context Locale locale, String json) { |
| 670 | TokenContext c = (TokenContext) context.getUserPrincipal(); |
| 671 | VirtualCollection cache = ResourceFactory.getCachedCollection(json); |
| 672 | User user; |
| 673 | try { |
| 674 | user = controller.getUser(c.getUsername()); |
| 675 | } |
| 676 | catch (KustvaktException e) { |
| 677 | jlog.error("Exception encountered: {}", e.string()); |
| 678 | throw KustvaktResponseHandler.throwit(e); |
| 679 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 680 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 681 | VirtualCollection tmp = resourceHandler.getCache(cache.getId(), |
| 682 | VirtualCollection.class); |
| 683 | if (tmp == null) { |
| 684 | String query; |
| 685 | try { |
| 686 | query = this.processor.processQuery(cache.getData(), user); |
| 687 | } |
| 688 | catch (KustvaktException e) { |
| 689 | throw KustvaktResponseHandler.throwit(e); |
| 690 | } |
| 691 | String stats = searchKrill.getStatistics(query); |
| 692 | cache.setStats(JsonUtils.readSimple(stats, Map.class)); |
| 693 | resourceHandler.cache(cache); |
| 694 | } |
| 695 | else |
| 696 | cache = tmp; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 697 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 698 | Map vals = new HashMap(); |
| 699 | vals.put("id", cache.getId()); |
| 700 | vals.put("statistics", cache.getStats()); |
| 701 | return Response.ok(JsonUtils.toJSON(vals)).build(); |
| 702 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 703 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 704 | |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 705 | // EM: this handles layer id containing a slash. |
| 706 | // Probably better to restrict the id not to contain any slash instead. |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 707 | @Deprecated |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 708 | @POST |
| 709 | @Path("{type}/{id}/{child}") |
| 710 | public Response updateResource (@Context SecurityContext context, |
| 711 | @Context Locale locale, @PathParam("type") String type, |
| 712 | @PathParam("id") String id, @PathParam("child") String child, |
| 713 | @QueryParam("name") String name, |
| 714 | @QueryParam("description") String description) { |
| 715 | return updateResource(context, locale, type, |
| 716 | StringUtils.joinResources(id, child), name, description); |
| 717 | } |
| 718 | |
| 719 | |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 720 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 721 | @POST |
| 722 | @Path("{type}/{id}") |
| 723 | public Response updateResource (@Context SecurityContext context, |
| 724 | @Context Locale locale, @PathParam("type") String type, |
| 725 | @PathParam("id") String id, @QueryParam("name") String name, |
| 726 | @QueryParam("description") String description) { |
| 727 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 728 | User user; |
| 729 | try { |
| 730 | user = controller.getUser(ctx.getUsername()); |
| 731 | KustvaktResource resource = this.resourceHandler.findbyStrId(id, |
| 732 | user, ResourceFactory.getResourceClass(type)); |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 733 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 734 | if (name != null && !name.isEmpty()) { |
| 735 | if (description == null) { |
| 736 | if (name.equals(resource.getName())) { |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 737 | throw new KustvaktException(StatusCodes.NOTHING_CHANGED, |
| 738 | "No change has found."); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 739 | } |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 740 | resource.setName(name); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 741 | } |
| 742 | else if (name.equals(resource.getName()) |
| 743 | && description.equals(resource.getDescription())) { |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 744 | throw new KustvaktException(StatusCodes.NOTHING_CHANGED, |
| 745 | "No change has found."); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 746 | } |
| 747 | else { |
| 748 | resource.setName(name); |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 749 | resource.setDescription(description); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 750 | } |
| 751 | } |
| 752 | else if (description != null && !description.isEmpty()) { |
| 753 | resource.setDescription(description); |
| 754 | } |
| 755 | else { |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 756 | throw new KustvaktException(StatusCodes.NOTHING_CHANGED, |
| 757 | "The given resource name and description are the same as already stored."); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 758 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 759 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 760 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 761 | this.resourceHandler.updateResources(user, resource); |
| 762 | } |
| margaretha | 7e16d6f | 2017-04-18 18:01:59 +0200 | [diff] [blame] | 763 | catch (KustvaktException e) { |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 764 | jlog.error("Exception encountered: {}", e.string()); |
| 765 | throw KustvaktResponseHandler.throwit(e); |
| 766 | } |
| 767 | return Response.ok().build(); |
| 768 | } |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 769 | |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 770 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 771 | // todo: change or deprecate |
| 772 | @POST |
| 773 | @Path("nv/{type}") |
| 774 | public Response storeResource (@Context SecurityContext context, |
| 775 | @Context Locale locale, @PathParam("type") String type, |
| 776 | @QueryParam("name") String name, |
| 777 | @QueryParam("description") String description, |
| 778 | // deprecate -> if you want to store a resource based on another, |
| 779 | // build the query first yourself or via a function |
| 780 | @QueryParam("ref") String reference, |
| 781 | @QueryParam("cache") Boolean cache, |
| 782 | @QueryParam("query") String query) { |
| 783 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 784 | cache = cache != null ? cache : false; |
| 785 | type = StringUtils.normalize(type); |
| 786 | reference = StringUtils.decodeHTML(reference); |
| 787 | Map vals = new HashMap(); |
| 788 | User user; |
| 789 | Class ctype; |
| 790 | try { |
| 791 | ctype = ResourceFactory.getResourceClass(type); |
| 792 | user = controller.getUser(ctx.getUsername()); |
| 793 | } |
| 794 | catch (KustvaktException e) { |
| 795 | jlog.error("Exception encountered: {}", e.string()); |
| 796 | throw KustvaktResponseHandler.throwit(e); |
| 797 | } |
| 798 | if (VirtualCollection.class.equals(ctype)) { |
| 799 | VirtualCollection cachetmp, collection; |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 800 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 801 | JsonNode base; |
| 802 | if (reference != null && !reference.equals("null")) { |
| 803 | try { |
| 804 | base = resourceHandler.findbyStrId(reference, user, |
| 805 | VirtualCollection.class).getData(); |
| 806 | } |
| 807 | catch (KustvaktException e) { |
| 808 | throw KustvaktResponseHandler.throwit(e); |
| 809 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 810 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 811 | } |
| 812 | else if (query != null) |
| 813 | base = JsonUtils.readTree(query); |
| 814 | else |
| 815 | // todo: throw exception response for no resource to save! |
| 816 | return null; |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 817 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 818 | KoralCollectionQueryBuilder cquery = |
| 819 | new KoralCollectionQueryBuilder(); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 820 | cquery.setBaseQuery(base); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 821 | |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 822 | try { |
| 823 | cachetmp = ResourceFactory.getCachedCollection(cquery.toJSON()); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 824 | |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 825 | // see if collection was cached! |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 826 | VirtualCollection tmp = resourceHandler |
| 827 | .getCache(cachetmp.getId(), VirtualCollection.class); |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 828 | // if not cached, fill with stats values |
| 829 | if (tmp == null) { |
| 830 | String stats = searchKrill.getStatistics(cquery.toJSON()); |
| 831 | cachetmp.setStats(JsonUtils.readSimple(stats, Map.class)); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 832 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 833 | |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 834 | if (!cache) { |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 835 | collection = ResourceFactory.getPermanentCollection( |
| 836 | cachetmp, name, description); |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 837 | vals = collection.toMap(); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 838 | resourceHandler.storeResources(user, collection); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 839 | } |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 840 | else { |
| 841 | resourceHandler.cache(cachetmp); |
| 842 | vals = cachetmp.toMap(); |
| 843 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 844 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 845 | } |
| margaretha | b786411 | 2017-06-29 16:36:13 +0200 | [diff] [blame] | 846 | catch (KustvaktException e) { |
| 847 | throw KustvaktResponseHandler.throwit(e); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 848 | } |
| 849 | } |
| 850 | return Response.ok(JsonUtils.toJSON(vals)).build(); |
| 851 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 852 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 853 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 854 | /** |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 855 | * EM: store a virtual collection in resource_store, but |
| 856 | * not in the policy_store table as well. |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 857 | * |
| 858 | * Retrieve cached entry first and then store collection |
| 859 | * |
| 860 | * @param context |
| 861 | * @param locale |
| 862 | * @param query |
| 863 | * @return |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 864 | * @throws KustvaktException |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 865 | */ |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 866 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 867 | @POST |
| 868 | @Path("{type}") |
| 869 | public Response storeResource (@Context SecurityContext context, |
| 870 | @Context Locale locale, @PathParam("type") String type, |
| 871 | @QueryParam("filter") Boolean filter, |
| 872 | @QueryParam("name") String name, |
| 873 | @QueryParam("description") String description, |
| 874 | @QueryParam("ref") String reference, |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 875 | @QueryParam("cache") Boolean cache, |
| 876 | @QueryParam("query") String query) throws KustvaktException { |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 877 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 878 | filter = filter != null ? filter : false; |
| 879 | cache = cache != null ? cache : false; |
| 880 | type = StringUtils.normalize(type); |
| 881 | reference = StringUtils.decodeHTML(reference); |
| 882 | Map vals = new HashMap(); |
| 883 | User user; |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 884 | Class<KustvaktResource> ctype; |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 885 | try { |
| 886 | ctype = ResourceFactory.getResourceClass(type); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 887 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 888 | user = controller.getUser(ctx.getUsername()); |
| 889 | } |
| 890 | catch (KustvaktException e) { |
| 891 | jlog.error("Exception encountered: {}", e.string()); |
| 892 | throw KustvaktResponseHandler.throwit(e); |
| 893 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 894 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 895 | if (VirtualCollection.class.equals(ctype)) { |
| 896 | VirtualCollection cachetmp, collection; |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 897 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 898 | KoralCollectionQueryBuilder cquery = |
| 899 | new KoralCollectionQueryBuilder(); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 900 | if (reference != null && !reference.equals("null")) { |
| 901 | try { |
| 902 | cquery.setBaseQuery(resourceHandler.findbyStrId(reference, |
| 903 | user, VirtualCollection.class).getData()); |
| Michael Hanl | 99cb963 | 2016-06-29 16:24:40 +0200 | [diff] [blame] | 904 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 905 | } |
| 906 | catch (KustvaktException e) { |
| 907 | throw KustvaktResponseHandler.throwit(e); |
| 908 | } |
| 909 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 910 | if (query != null && !query.isEmpty()) cquery.with(query); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 911 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 912 | cachetmp = ResourceFactory.getCachedCollection(cquery.toJSON()); |
| Michael Hanl | cedf721 | 2016-05-28 10:43:09 +0200 | [diff] [blame] | 913 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 914 | // see if vc was cached! |
| 915 | VirtualCollection tmp = resourceHandler.getCache(cachetmp.getId(), |
| 916 | VirtualCollection.class); |
| Michael Hanl | cedf721 | 2016-05-28 10:43:09 +0200 | [diff] [blame] | 917 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 918 | // if not cached, fill with stats values |
| 919 | if (tmp == null) { |
| 920 | String stats = searchKrill.getStatistics(cquery.toJSON()); |
| 921 | cachetmp.setStats(JsonUtils.readSimple(stats, Map.class)); |
| 922 | if (query != null && !query.isEmpty()) |
| 923 | cachetmp.setFields(cquery.toJSON()); |
| 924 | } |
| Michael Hanl | cedf721 | 2016-05-28 10:43:09 +0200 | [diff] [blame] | 925 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 926 | if (!cache && !User.UserFactory.isDemo(ctx.getUsername())) { |
| 927 | collection = ResourceFactory.getPermanentCollection(cachetmp, |
| 928 | name, description); |
| 929 | vals = collection.toMap(); |
| 930 | try { |
| 931 | resourceHandler.storeResources(user, collection); |
| 932 | } |
| 933 | catch (KustvaktException e) { |
| 934 | jlog.error("Exception encountered: {}", e.string()); |
| 935 | throw KustvaktResponseHandler.throwit(e); |
| 936 | } |
| 937 | } |
| 938 | else { |
| 939 | resourceHandler.cache(cachetmp); |
| 940 | vals = cachetmp.toMap(); |
| 941 | } |
| 942 | } |
| margaretha | 50b331e | 2017-04-25 18:05:16 +0200 | [diff] [blame] | 943 | else { |
| 944 | throw KustvaktResponseHandler.throwit( |
| 945 | new KustvaktException(StatusCodes.UNSUPPORTED_RESOURCE, |
| 946 | "Unsupported operation for the given resource type.", |
| 947 | type)); |
| 948 | } |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 949 | return Response.ok(JsonUtils.toJSON(vals)).build(); |
| 950 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 951 | |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 952 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 953 | @DELETE |
| 954 | @Path("{type}/{id}/{child}") |
| 955 | public Response deleteResourceChild (@Context SecurityContext context, |
| 956 | @Context Locale locale, @PathParam("type") String type, |
| 957 | @PathParam("id") String id, @PathParam("child") String child) { |
| 958 | return deleteResource(context, locale, type, |
| 959 | StringUtils.joinResources(id, child)); |
| 960 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 961 | |
| margaretha | 1a68351 | 2017-10-16 20:25:26 +0200 | [diff] [blame] | 962 | @Deprecated |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 963 | @DELETE |
| 964 | @Path("{type}/{id}") |
| 965 | public Response deleteResource (@Context SecurityContext context, |
| 966 | @Context Locale locale, @PathParam("type") String type, |
| 967 | @PathParam("id") String id) { |
| 968 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 969 | type = StringUtils.normalizeHTML(type); |
| 970 | id = StringUtils.decodeHTML(id); |
| 971 | try { |
| 972 | User user = controller.getUser(ctx.getUsername()); |
| 973 | KustvaktResource r = ResourceFactory.getResource(type); |
| 974 | r.setPersistentID(id); |
| 975 | // todo: eliminate the need to find the resource first! |
| 976 | resourceHandler.deleteResources(user, r); |
| 977 | } |
| 978 | catch (KustvaktException e) { |
| 979 | jlog.error("Exception encountered: {}", e.string()); |
| 980 | throw KustvaktResponseHandler.throwit(e); |
| 981 | } |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 982 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 983 | return Response.ok().build(); |
| 984 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 985 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 986 | @GET |
| margaretha | 61471cc | 2017-04-20 18:42:23 +0200 | [diff] [blame] | 987 | @Path("/corpus/{corpusId}/{docId}/{textId}/{matchId}/matchInfo") |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 988 | public Response getMatchInfo (@Context SecurityContext ctx, |
| 989 | @Context HttpHeaders headers, @Context Locale locale, |
| Bodmo | ca3dcfb | 2017-05-24 16:36:00 +0200 | [diff] [blame] | 990 | @PathParam("corpusId") String corpusId, |
| margaretha | 61471cc | 2017-04-20 18:42:23 +0200 | [diff] [blame] | 991 | @PathParam("docId") String docId, |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 992 | @PathParam("textId") String textId, |
| margaretha | 61471cc | 2017-04-20 18:42:23 +0200 | [diff] [blame] | 993 | @PathParam("matchId") String matchId, |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 994 | @QueryParam("foundry") Set<String> foundries, |
| 995 | @QueryParam("layer") Set<String> layers, |
| margaretha | 61471cc | 2017-04-20 18:42:23 +0200 | [diff] [blame] | 996 | @QueryParam("spans") Boolean spans) throws KustvaktException { |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 997 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 998 | TokenContext tokenContext = (TokenContext) ctx.getUserPrincipal(); |
| 999 | spans = spans != null ? spans : false; |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 1000 | |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1001 | String matchid = |
| 1002 | searchKrill.getMatchId(corpusId, docId, textId, matchId); |
| 1003 | if (layers == null || layers.isEmpty()) layers = new HashSet<>(); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1004 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1005 | boolean match_only = foundries == null || foundries.isEmpty(); |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1006 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1007 | User user; |
| 1008 | try { |
| 1009 | user = controller.getUser(tokenContext.getUsername()); |
| Bodmo | ca3dcfb | 2017-05-24 16:36:00 +0200 | [diff] [blame] | 1010 | controller.setAccessAndLocation(user, headers); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1011 | System.out.printf( |
| 1012 | "Debug: /getMatchInfo/: location=%s, access='%s'.\n", |
| 1013 | user.locationtoString(), user.accesstoString()); |
| 1014 | } |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1015 | catch (KustvaktException e) { |
| margaretha | 15f496c | 2017-04-21 17:36:09 +0200 | [diff] [blame] | 1016 | jlog.error("Failed getting user in the matchInfo service: {}", |
| 1017 | e.string()); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1018 | throw KustvaktResponseHandler.throwit(e); |
| 1019 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1020 | |
| margaretha | 4c3a6f9 | 2017-05-24 19:07:03 +0200 | [diff] [blame] | 1021 | CorpusAccess corpusAccess = user.getCorpusAccess(); |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1022 | Pattern p; |
| 1023 | switch (corpusAccess) { |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1024 | case PUB: |
| 1025 | p = config.getPublicLicensePattern(); |
| 1026 | break; |
| 1027 | case ALL: |
| 1028 | p = config.getAllLicensePattern(); |
| 1029 | break; |
| 1030 | default: // FREE |
| 1031 | p = config.getFreeLicensePattern(); |
| 1032 | break; |
| 1033 | } |
| 1034 | |
| margaretha | ebe869a | 2017-06-01 19:07:41 +0200 | [diff] [blame] | 1035 | String results; |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1036 | try { |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1037 | if (!match_only) { |
| 1038 | |
| 1039 | ArrayList<String> foundryList = new ArrayList<String>(); |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1040 | ArrayList<String> layerList = new ArrayList<String>(); |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1041 | |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1042 | // EM: now without user, just list all foundries and layers |
| 1043 | if (foundries.contains("*")) { |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1044 | foundryList = config.getFoundries(); |
| 1045 | layerList = config.getLayers(); |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1046 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1047 | else { |
| 1048 | foundryList.addAll(foundries); |
| 1049 | layerList.addAll(layers); |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1050 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1051 | |
| 1052 | results = searchKrill.getMatch(matchid, foundryList, layerList, |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1053 | spans, false, true, p); |
| 1054 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1055 | else { |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1056 | results = searchKrill.getMatch(matchid, p); |
| 1057 | } |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1058 | } |
| 1059 | catch (Exception e) { |
| margaretha | a76ed24 | 2017-05-24 17:48:22 +0200 | [diff] [blame] | 1060 | jlog.error("Exception in the MatchInfo service encountered!", e); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1061 | throw KustvaktResponseHandler.throwit(StatusCodes.ILLEGAL_ARGUMENT, |
| 1062 | e.getMessage(), ""); |
| 1063 | } |
| margaretha | d3c0fc9 | 2017-10-25 15:03:32 +0200 | [diff] [blame] | 1064 | jlog.debug("MatchInfo results: " + results); |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1065 | return Response.ok(results).build(); |
| 1066 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1067 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 1068 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1069 | // todo:?! |
| 1070 | @POST |
| 1071 | @Path("match/{id}") |
| 1072 | @Deprecated |
| 1073 | public Response save (@PathParam("{id}") String id, |
| 1074 | @QueryParam("d") String description, |
| 1075 | @Context SecurityContext context) { |
| 1076 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 1077 | // save match for user and later retrieval! |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1078 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1079 | // KustvaktResource match = new QueryMatch(id); |
| 1080 | // match.setDescription(description); |
| 1081 | // match.setCreated(TimeUtils.getNow().getMillis()); |
| 1082 | // try { |
| 1083 | // this.resourceHandler.storeResources(controller.getUser(ctx), match); |
| 1084 | // } catch (KustvaktException | NotAuthorizedException e) { |
| 1085 | // throw MappedHTTPResponse.throwit(e); |
| 1086 | // } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1087 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1088 | return Response.ok().build(); |
| 1089 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1090 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 1091 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1092 | @GET |
| 1093 | @Path("matches") |
| 1094 | @Deprecated |
| 1095 | public Response get (@Context SecurityContext context) { |
| 1096 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 1097 | // todo save match for user and later retrieval! |
| 1098 | // todo: retrieve matches in range! --choices: date, document, id |
| 1099 | // (matchid) |
| 1100 | return Response.ok().build(); |
| 1101 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1102 | |
| Michael Hanl | 8abaf9e | 2016-05-23 16:46:35 +0200 | [diff] [blame] | 1103 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1104 | @DELETE |
| 1105 | @Path("match/{id}") |
| 1106 | @Deprecated |
| 1107 | public Response remove (@PathParam("{id}") String id, |
| 1108 | @Context SecurityContext context) { |
| 1109 | TokenContext ctx = (TokenContext) context.getUserPrincipal(); |
| 1110 | // save match for user and later retrieval! |
| 1111 | try { |
| 1112 | this.resourceHandler.deleteResources( |
| 1113 | this.controller.getUser(ctx.getUsername()), id); |
| 1114 | } |
| 1115 | catch (KustvaktException e) { |
| 1116 | jlog.error("Exception encountered: {}", e.string()); |
| 1117 | throw KustvaktResponseHandler.throwit(e); |
| 1118 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1119 | |
| margaretha | fc2040a | 2017-04-18 12:07:23 +0200 | [diff] [blame] | 1120 | return Response.ok().build(); |
| 1121 | } |
| Michael Hanl | 1939065 | 2016-01-16 11:01:24 +0100 | [diff] [blame] | 1122 | |
| 1123 | } |