in lib/client-core/src/main/java/org/apache/olingo/client/core/serialization/JsonEntityDeserializer.java [58:243]
protected ResWrap<Entity> doDeserialize(final JsonParser parser) throws IOException {
final ObjectNode tree = parser.getCodec().readTree(parser);
if (tree.has(Constants.VALUE) && tree.get(Constants.VALUE).isArray()) {
throw new JsonParseException("Expected OData Entity, found EntitySet", parser.getCurrentLocation());
}
final Entity entity = new Entity();
final URI contextURL;
if (tree.hasNonNull(Constants.JSON_CONTEXT)) {
contextURL = URI.create(tree.get(Constants.JSON_CONTEXT).textValue());
tree.remove(Constants.JSON_CONTEXT);
} else if (tree.hasNonNull(Constants.JSON_METADATA)) {
contextURL = URI.create(tree.get(Constants.JSON_METADATA).textValue());
tree.remove(Constants.JSON_METADATA);
} else {
contextURL = null;
}
if (contextURL != null) {
entity.setBaseURI(URI.create(StringUtils.substringBefore(contextURL.toASCIIString(), Constants.METADATA)));
}
final String metadataETag;
if (tree.hasNonNull(Constants.JSON_METADATA_ETAG)) {
metadataETag = tree.get(Constants.JSON_METADATA_ETAG).textValue();
tree.remove(Constants.JSON_METADATA_ETAG);
} else {
metadataETag = null;
}
if (tree.hasNonNull(Constants.JSON_ETAG)) {
entity.setETag(tree.get(Constants.JSON_ETAG).textValue());
tree.remove(Constants.JSON_ETAG);
}
if (tree.hasNonNull(Constants.JSON_TYPE)) {
entity.setType(new EdmTypeInfo.Builder().setTypeExpression(tree.get(Constants.JSON_TYPE).textValue()).build()
.internal());
tree.remove(Constants.JSON_TYPE);
}
if (tree.hasNonNull(Constants.JSON_ID)) {
entity.setId(URI.create(tree.get(Constants.JSON_ID).textValue()));
tree.remove(Constants.JSON_ID);
}
if (tree.hasNonNull(Constants.JSON_READ_LINK)) {
final Link link = new Link();
link.setRel(Constants.SELF_LINK_REL);
link.setHref(tree.get(Constants.JSON_READ_LINK).textValue());
entity.setSelfLink(link);
tree.remove(Constants.JSON_READ_LINK);
}
if (tree.hasNonNull(Constants.JSON_EDIT_LINK)) {
final Link link = new Link();
if (serverMode) {
link.setRel(Constants.EDIT_LINK_REL);
}
link.setHref(tree.get(Constants.JSON_EDIT_LINK).textValue());
entity.setEditLink(link);
tree.remove(Constants.JSON_EDIT_LINK);
}
if (tree.hasNonNull(Constants.JSON_MEDIA_READ_LINK)) {
entity.setMediaContentSource(URI.create(tree.get(Constants.JSON_MEDIA_READ_LINK).textValue()));
tree.remove(Constants.JSON_MEDIA_READ_LINK);
}
if (tree.hasNonNull(Constants.JSON_MEDIA_EDIT_LINK)) {
entity.setMediaContentSource(URI.create(tree.get(Constants.JSON_MEDIA_EDIT_LINK).textValue()));
tree.remove(Constants.JSON_MEDIA_EDIT_LINK);
}
if (tree.hasNonNull(Constants.JSON_MEDIA_CONTENT_TYPE)) {
entity.setMediaContentType(tree.get(Constants.JSON_MEDIA_CONTENT_TYPE).textValue());
tree.remove(Constants.JSON_MEDIA_CONTENT_TYPE);
}
if (tree.hasNonNull(Constants.JSON_MEDIA_ETAG)) {
entity.setMediaETag(tree.get(Constants.JSON_MEDIA_ETAG).textValue());
tree.remove(Constants.JSON_MEDIA_ETAG);
}
final Set<String> toRemove = new HashSet<>();
final Map<String, List<Annotation>> annotations = new HashMap<>();
for (final Iterator<Map.Entry<String, JsonNode>> itor = tree.fields(); itor.hasNext();) {
final Map.Entry<String, JsonNode> field = itor.next();
final Matcher customAnnotation = CUSTOM_ANNOTATION.matcher(field.getKey());
links(field, entity, toRemove, tree, parser.getCodec());
if (field.getKey().endsWith(getJSONAnnotation(Constants.JSON_MEDIA_READ_LINK))) {
final Link link = new Link();
link.setTitle(getTitle(field));
link.setRel(Constants.NS_MEDIA_READ_LINK_REL + getTitle(field));
link.setType(Constants.MEDIA_EDIT_LINK_TYPE);
link.setHref(field.getValue().textValue());
entity.getMediaEditLinks().add(link);
if (tree.has(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_ETAG))) {
link.setMediaETag(tree.get(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_ETAG)).asText());
toRemove.add(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_ETAG));
}
if (tree.has(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_CONTENT_TYPE))) {
link.setType(tree.get(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_CONTENT_TYPE)).asText());
toRemove.add(link.getTitle() + getJSONAnnotation(Constants.JSON_MEDIA_CONTENT_TYPE));
}
toRemove.add(field.getKey());
toRemove.add(setInline(field.getKey(), getJSONAnnotation(Constants.JSON_MEDIA_READ_LINK), tree, parser
.getCodec(), link));
} else if (field.getKey().endsWith(getJSONAnnotation(Constants.JSON_MEDIA_EDIT_LINK))) {
final Link link = getOrCreateMediaLink(entity, getTitle(field));
link.setRel(Constants.NS_MEDIA_EDIT_LINK_REL + getTitle(field));
link.setHref(field.getValue().textValue());
toRemove.add(field.getKey());
toRemove.add(setInline(field.getKey(), getJSONAnnotation(Constants.JSON_MEDIA_EDIT_LINK), tree, parser
.getCodec(), link));
} else if (field.getKey().endsWith(getJSONAnnotation(Constants.JSON_MEDIA_CONTENT_TYPE))) {
final Link link = getOrCreateMediaLink(entity, getTitle(field));
link.setType(field.getValue().asText());
toRemove.add(field.getKey());
} else if (field.getKey().endsWith(getJSONAnnotation(Constants.JSON_MEDIA_ETAG))) {
final Link link = getOrCreateMediaLink(entity, getTitle(field));
link.setMediaETag(field.getValue().asText());
toRemove.add(field.getKey());
} else if (field.getKey().charAt(0) == '#') {
final Operation operation = new Operation();
operation.setMetadataAnchor(field.getKey());
final ObjectNode opNode = (ObjectNode) tree.get(field.getKey());
operation.setTitle(opNode.get(Constants.ATTR_TITLE).asText());
operation.setTarget(URI.create(opNode.get(Constants.ATTR_TARGET).asText()));
entity.getOperations().add(operation);
toRemove.add(field.getKey());
} else if (customAnnotation.matches() && !"odata".equals(customAnnotation.group(2))) {
final Annotation annotation = new Annotation();
annotation.setTerm(customAnnotation.group(2) + "." + customAnnotation.group(3));
try {
value(annotation, field.getValue(), parser.getCodec());
} catch (final EdmPrimitiveTypeException e) {
throw new IOException(e);
}
if (!annotations.containsKey(customAnnotation.group(1))) {
annotations.put(customAnnotation.group(1), new ArrayList<Annotation>());
}
annotations.get(customAnnotation.group(1)).add(annotation);
}
}
for (Link link : entity.getNavigationLinks()) {
if (annotations.containsKey(link.getTitle())) {
link.getAnnotations().addAll(annotations.get(link.getTitle()));
for (Annotation annotation : annotations.get(link.getTitle())) {
toRemove.add(link.getTitle() + "@" + annotation.getTerm());
}
}
}
for (Link link : entity.getMediaEditLinks()) {
if (annotations.containsKey(link.getTitle())) {
link.getAnnotations().addAll(annotations.get(link.getTitle()));
for (Annotation annotation : annotations.get(link.getTitle())) {
toRemove.add(link.getTitle() + "@" + annotation.getTerm());
}
}
if (tree.get(link.getTitle() + Constants.JSON_TYPE) != null) {
toRemove.add(link.getTitle() + Constants.JSON_TYPE);
}
}
tree.remove(toRemove);
try {
populate(entity, entity.getProperties(), tree, parser.getCodec());
} catch (final EdmPrimitiveTypeException e) {
throw new IOException(e);
}
return new ResWrap<>(contextURL, metadataETag, entity);
}