| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 1 | package de.ids_mannheim.korap.web.service.full; |
| 2 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 3 | import java.io.IOException; |
| 4 | import java.util.ArrayList; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 5 | import java.util.List; |
| 6 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 7 | import javax.ws.rs.Consumes; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 8 | import javax.ws.rs.GET; |
| 9 | import javax.ws.rs.POST; |
| 10 | import javax.ws.rs.Path; |
| 11 | import javax.ws.rs.Produces; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 12 | import javax.ws.rs.core.MediaType; |
| 13 | import javax.ws.rs.core.Response; |
| 14 | |
| 15 | import org.slf4j.Logger; |
| 16 | import org.slf4j.LoggerFactory; |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 17 | import org.springframework.beans.factory.annotation.Autowired; |
| 18 | import org.springframework.stereotype.Controller; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 19 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 20 | import com.fasterxml.jackson.databind.JsonNode; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 21 | import com.sun.jersey.spi.container.ResourceFilters; |
| 22 | |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 23 | import de.ids_mannheim.korap.dao.AnnotationDao; |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 24 | import de.ids_mannheim.korap.dto.FoundryDto; |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 25 | import de.ids_mannheim.korap.dto.LayerDto; |
| 26 | import de.ids_mannheim.korap.dto.converter.AnnotationConverter; |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 27 | import de.ids_mannheim.korap.entity.AnnotationPair; |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 28 | import de.ids_mannheim.korap.exceptions.KustvaktException; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 29 | import de.ids_mannheim.korap.exceptions.StatusCodes; |
| margaretha | f68daa6 | 2017-09-21 02:11:24 +0200 | [diff] [blame] | 30 | import de.ids_mannheim.korap.filter.AuthFilter; |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 31 | import de.ids_mannheim.korap.utils.JsonUtils; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 32 | import de.ids_mannheim.korap.web.filter.DemoUserFilter; |
| 33 | import de.ids_mannheim.korap.web.filter.PiwikFilter; |
| 34 | import de.ids_mannheim.korap.web.utils.KustvaktResponseHandler; |
| 35 | |
| 36 | /** |
| 37 | * Provides services regarding annotation related information. |
| 38 | * |
| 39 | * @author margaretha |
| 40 | * |
| 41 | */ |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 42 | @Controller |
| 43 | @Path("annotation/") |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 44 | @ResourceFilters({ AuthFilter.class, DemoUserFilter.class, PiwikFilter.class }) |
| 45 | @Produces(MediaType.APPLICATION_JSON + ";charset=utf-8") |
| 46 | public class AnnotationService { |
| 47 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 48 | private static Logger jlog = |
| 49 | LoggerFactory.getLogger(AnnotationService.class); |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 50 | |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 51 | @Autowired |
| 52 | private AnnotationDao annotationDao; |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 53 | |
| 54 | @Autowired |
| 55 | private AnnotationConverter annotationConverter; |
| 56 | |
| 57 | |
| 58 | /** |
| 59 | * Returns information about all supported layers |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 60 | * |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 61 | * @return a json serialization of all supported layers |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 62 | */ |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 63 | @GET |
| 64 | @Path("layers") |
| 65 | public Response getLayers () { |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 66 | List<AnnotationPair> layers = annotationDao.getAllFoundryLayerPairs(); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 67 | jlog.debug("/layers " + layers.toString()); |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 68 | List<LayerDto> layerDto = annotationConverter.convertToLayerDto(layers); |
| 69 | String result = JsonUtils.toJSON(layerDto); |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 70 | return Response.ok(result).build(); |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 71 | } |
| 72 | |
| 73 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 74 | /** |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 75 | * Returns a list of foundry descriptions. |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 76 | * |
| 77 | * @param codes |
| 78 | * foundry-layer code or a Kleene-star |
| 79 | * @param language |
| 80 | * 2-letter language code (description language) |
| 81 | * @return a list of foundry, layer, value information in json |
| 82 | */ |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 83 | @POST |
| 84 | @Path("description") |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 85 | @Consumes(MediaType.APPLICATION_JSON) |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 86 | public Response getFoundryDescriptions (String json) { |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 87 | JsonNode node = JsonUtils.readTree(json); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 88 | if (node == null) { |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 89 | throw KustvaktResponseHandler.throwit(new KustvaktException( |
| 90 | StatusCodes.MISSING_ARGUMENT, "Missing a json string.", "")); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 91 | } |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 92 | |
| 93 | String language; |
| 94 | if (!node.has("language")) { |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 95 | language = "en"; |
| 96 | } |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 97 | else { |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 98 | language = node.get("language").asText(); |
| 99 | if (language == null || language.isEmpty()) { |
| 100 | language = "en"; |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 101 | } |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 102 | else if (!(language.equals("en") || language.equals("de"))) { |
| 103 | throw KustvaktResponseHandler.throwit( |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 104 | new KustvaktException(StatusCodes.UNSUPPORTED_VALUE, |
| 105 | "Unsupported value:", language)); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 106 | } |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 107 | } |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 108 | |
| 109 | List<String> codes; |
| 110 | try { |
| 111 | codes = JsonUtils.convert(node.get("codes"), List.class); |
| 112 | } |
| 113 | catch (IOException | NullPointerException e) { |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 114 | throw KustvaktResponseHandler.throwit(new KustvaktException( |
| 115 | StatusCodes.INVALID_ARGUMENT, "Bad argument:", json)); |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 116 | } |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 117 | if (codes == null) { |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 118 | throw KustvaktResponseHandler.throwit( |
| 119 | new KustvaktException(StatusCodes.MISSING_ATTRIBUTE, |
| 120 | "Missing attribute:", "codes")); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 121 | } |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 122 | else if (codes.isEmpty()) { |
| 123 | throw KustvaktResponseHandler.throwit(new KustvaktException( |
| 124 | StatusCodes.NO_VALUE_FOUND, "No result found.","codes:[]")); |
| 125 | } |
| 126 | |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 127 | List<AnnotationPair> annotationPairs = null; |
| 128 | String foundry = "", layer = ""; |
| 129 | if (codes.contains("*")) { |
| 130 | annotationPairs = |
| 131 | annotationDao.getAnnotationDescriptions(foundry, layer); |
| 132 | } |
| 133 | else { |
| 134 | String[] annotationCode; |
| 135 | annotationPairs = new ArrayList<AnnotationPair>(); |
| 136 | for (String code : codes) { |
| 137 | jlog.debug("code " + code); |
| 138 | annotationCode = code.split("/"); |
| 139 | if (annotationCode.length == 1) { |
| 140 | foundry = annotationCode[0]; |
| 141 | } |
| 142 | else if (annotationCode.length == 2) { |
| 143 | foundry = annotationCode[0]; |
| 144 | layer = annotationCode[1]; |
| 145 | } |
| 146 | else { |
| 147 | jlog.error("Annotation code is wrong: " + annotationCode); |
| 148 | throw KustvaktResponseHandler.throwit( |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 149 | new KustvaktException(StatusCodes.INVALID_ATTRIBUTE, |
| 150 | "Bad attribute:", code)); |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 151 | } |
| 152 | |
| 153 | annotationPairs.addAll(annotationDao |
| 154 | .getAnnotationDescriptions(foundry, layer)); |
| 155 | } |
| 156 | } |
| 157 | |
| 158 | if (annotationPairs != null && !annotationPairs.isEmpty()) { |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 159 | List<FoundryDto> dtos = annotationConverter |
| 160 | .convertToFoundryDto(annotationPairs, language); |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 161 | jlog.debug("/description " + annotationPairs.toString()); |
| margaretha | 50179c8 | 2017-07-20 15:36:05 +0200 | [diff] [blame] | 162 | String result = JsonUtils.toJSON(dtos); |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 163 | return Response.ok(result).build(); |
| 164 | } |
| margaretha | a14f1c2 | 2017-07-19 18:51:04 +0200 | [diff] [blame] | 165 | else { |
| margaretha | 8a71e3b | 2017-07-25 12:22:47 +0200 | [diff] [blame] | 166 | throw KustvaktResponseHandler.throwit(new KustvaktException( |
| 167 | StatusCodes.NO_VALUE_FOUND, "No result found.","")); |
| margaretha | e353dfa | 2017-07-18 19:23:29 +0200 | [diff] [blame] | 168 | } |
| margaretha | 38d530e | 2017-07-11 19:06:50 +0200 | [diff] [blame] | 169 | } |
| 170 | |
| 171 | } |
| 172 | |