@Override public JsonUpdateWebServer deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode node = obj.readTree(jp).get(0); final Set<String> groupIds = deserializeGroupIdentifiers(node); return new JsonUpdateWebServer(node.get("webserverId").getValueAsText(), node.get("webserverName").getTextValue(), node.get("hostName").getTextValue(), node.get("portNumber").getValueAsText(), node.get("httpsPort").getValueAsText(), groupIds, node.get("statusPath").getTextValue(), node.get("apacheHttpdMediaId").getTextValue()); }
@Override public JsonCreateWebServer deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode node = obj.readTree(jp).get(0); final JsonNode apacheHttpdMediaId = node.get("apacheHttpdMediaId"); final JsonCreateWebServer jcws = new JsonCreateWebServer(node.get("webserverName").getTextValue(), node.get("hostName").getTextValue(), node.get("portNumber").asText(), node.get("httpsPort").asText(), deserializeGroupIdentifiers(node), node.get("statusPath").getTextValue(), apacheHttpdMediaId == null ? null : apacheHttpdMediaId.asText()); return jcws; }
@Override public Website deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { ObjectCodec oc = jp.getCodec(); JsonNode nodes = oc.readTree(jp); String websitePushID = nodes.get("websitePushID").getTextValue(); String websiteName = nodes.get("websiteName").getTextValue(); List<String> allowedDomains = new ArrayList<String>(); for (JsonNode node : nodes.get("allowedDomains")) { allowedDomains.add(node.getTextValue()); } String urlFormatString = nodes.get("urlFormatString").getTextValue(); String authenticationToken = nodes.get("authenticationToken").getTextValue(); String webServiceUrl = nodes.get("webServiceURL").getTextValue(); return new WebsiteBuilder() .setWebsiteName(websiteName) .setWebsitePushId(websitePushID) .setAllowedDomains(allowedDomains) .setUrlFormatString(urlFormatString) .setAuthenticationToken(authenticationToken) .setWebServiceUrl(webServiceUrl) .build(); }
public TreeTraversingParser(JsonNode paramJsonNode, ObjectCodec paramObjectCodec) { super(0); this._objectCodec = paramObjectCodec; if (paramJsonNode.isArray()) { this._nextToken = JsonToken.START_ARRAY; this._nodeCursor = new NodeCursor.Array(paramJsonNode, null); return; } if (paramJsonNode.isObject()) { this._nextToken = JsonToken.START_OBJECT; this._nodeCursor = new NodeCursor.Object(paramJsonNode, null); return; } this._nodeCursor = new NodeCursor.RootValue(paramJsonNode, null); }
@Override public FacebookUser deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { FacebookUser user = new FacebookUser(); ObjectCodec oc = jp.getCodec(); JsonNode node = oc.readTree(jp); user.setId(getNodeString(node.get("id"))); user.setName(getNodeString(node.get("username"))); user.setBirthday(getNodeString(node.get("birthday"))); user.setEmail(getNodeString(node.get("email"))); user.setGender(getNodeString(node.get("gender"))); user.setLink(getNodeString(node.get("link"))); user.setLocale(getNodeString(node.get("locale"))); return user; }
@Override public List<Rule> deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { ObjectCodec oc = jp.getCodec(); JsonNode jsonNode = oc.readTree(jp); Iterator<JsonNode> childrenNodesIter=jsonNode.getElements(); List<Rule> rules=new ArrayList<Rule>(); while(childrenNodesIter.hasNext()){ JsonNode childNode=childrenNodesIter.next(); rules.add(parseRule(jp,childNode)); } return rules; }
@Override public JsonControlJvm deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode rootNode = obj.readTree(jp); final JsonNode operation = rootNode.get("controlOperation"); return new JsonControlJvm(operation.getTextValue()); }
@Override public JsonUpdateGroup deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode node = obj.readTree(jp); return new JsonUpdateGroup(node.get("id").getTextValue(), node.get("name").getTextValue()); }
@Override public JsonJvms deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode rootNode = obj.readTree(jp); final Set<String> rawJvmIds = deserializeJvmIdentifiers(rootNode); return new JsonJvms(rawJvmIds); }
@Override public JsonControlGroup deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode rootNode = obj.readTree(jp); final JsonNode operation = rootNode.get("controlOperation"); return new JsonControlGroup(operation.getTextValue()); }
@Override public JsonControlWebServer deserialize(final JsonParser jp, final DeserializationContext ctxt) throws IOException { final ObjectCodec obj = jp.getCodec(); final JsonNode rootNode = obj.readTree(jp); final JsonNode operation = rootNode.get("controlOperation"); return new JsonControlWebServer(operation.getTextValue()); }
@Override public Config deserialize(JsonParser jsonParser, DeserializationContext context) throws IOException, JsonProcessingException { ObjectCodec oc = jsonParser.getCodec(); JsonNode node = oc.readTree(jsonParser); return new MapConfig(OBJECT_MAPPER.<Map<String, String>>readValue(node, new TypeReference<Map<String, String>>() { })); }
@Override public SystemStreamPartition deserialize(JsonParser jsonParser, DeserializationContext context) throws IOException, JsonProcessingException { ObjectCodec oc = jsonParser.getCodec(); JsonNode node = oc.readTree(jsonParser); String system = node.get("system").getTextValue(); String stream = node.get("stream").getTextValue(); Partition partition = new Partition(node.get("partition").getIntValue()); return new SystemStreamPartition(system, stream, partition); }
@Override public TaskConfig deserialize(JsonParser parser, DeserializationContext context) throws IOException { JsonNode jsonNode = parser.readValueAsTree(); TaskConfig config = new TaskConfig(); ObjectMapper mapper; ObjectCodec codec = parser.getCodec(); if (codec instanceof ObjectMapper) { mapper = (ObjectMapper) codec; } else { mapper = new ObjectMapper(); } if (jsonNode.has("steps")) { Iterator<JsonNode> steps = jsonNode.get("steps").getElements(); while (steps.hasNext()) { JsonNode next = steps.next(); if (isDtoType(next)) { config.add(mapper.readValue(next, TaskConfigStepDto.class)); } else { config.add(mapper.readValue(next, TaskConfigStep.class)); } } } return config; }
@Override public Object deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { logger.info("Deserialize..."); ObjectCodec oc = jp.getCodec(); JsonNode node = oc.readTree(jp); for (int i = 0; i < node.size(); i++) { JsonNode child = node.get(i); if (child == null) { logger.info(i + "th Child node is null"); continue; } //String if (child.isTextual()) { Iterator<String> it = child.getFieldNames(); while (it.hasNext()) { String field = it.next(); logger.info("in while loop " + field); if (field.startsWith("customfield")) { } } } } return null; }
@Override public Geometry deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException { ObjectCodec oc = jp.getCodec(); JsonNode root = oc.readTree(jp); return parseGeometry(root); }
@Override public WebPushLog deserialize(JsonParser jsonParser, DeserializationContext deserializationContext) throws IOException, JsonProcessingException { ObjectCodec oc = jsonParser.getCodec(); ArrayList<String> logMsgs = new ArrayList<String>(); for (JsonNode node: oc.readTree(jsonParser).get("logs")) { logMsgs.add(node.getTextValue()); } return new WebPushLog(logMsgs); }
public TokenBuffer(ObjectCodec paramObjectCodec) { this._objectCodec = paramObjectCodec; this._generatorFeatures = DEFAULT_PARSER_FEATURES; this._writeContext = JsonWriteContext.createRootContext(); Segment localSegment = new Segment(); this._last = localSegment; this._first = localSegment; this._appendOffset = 0; }
public Parser(TokenBuffer.Segment paramSegment, ObjectCodec paramObjectCodec) { super(); this._segment = paramSegment; this._segmentPtr = -1; this._codec = paramObjectCodec; this._parsingContext = JsonReadContext.createRootContext(-1, -1); }
public Utf8StreamParser(IOContext paramIOContext, int paramInt1, InputStream paramInputStream, ObjectCodec paramObjectCodec, BytesToNameCanonicalizer paramBytesToNameCanonicalizer, byte[] paramArrayOfByte, int paramInt2, int paramInt3, boolean paramBoolean) { super(paramIOContext, paramInt1, paramInputStream, paramArrayOfByte, paramInt2, paramInt3, paramBoolean); this._objectCodec = paramObjectCodec; this._symbols = paramBytesToNameCanonicalizer; if (!JsonParser.Feature.CANONICALIZE_FIELD_NAMES.enabledIn(paramInt1)) _throwInternal(); }
public JsonParser constructParser(int paramInt, ObjectCodec paramObjectCodec, BytesToNameCanonicalizer paramBytesToNameCanonicalizer, CharsToNameCanonicalizer paramCharsToNameCanonicalizer) throws IOException, JsonParseException { JsonEncoding localJsonEncoding = detectEncoding(); boolean bool1 = JsonParser.Feature.CANONICALIZE_FIELD_NAMES.enabledIn(paramInt); boolean bool2 = JsonParser.Feature.INTERN_FIELD_NAMES.enabledIn(paramInt); if ((localJsonEncoding == JsonEncoding.UTF8) && (bool1)) { BytesToNameCanonicalizer localBytesToNameCanonicalizer = paramBytesToNameCanonicalizer.makeChild(bool1, bool2); return new Utf8StreamParser(this._context, paramInt, this._in, paramObjectCodec, localBytesToNameCanonicalizer, this._inputBuffer, this._inputPtr, this._inputEnd, this._bufferRecyclable); } return new ReaderBasedParser(this._context, paramInt, constructReader(), paramObjectCodec, paramCharsToNameCanonicalizer.makeChild(bool1, bool2)); }
public WriterBasedGenerator(IOContext paramIOContext, int paramInt, ObjectCodec paramObjectCodec, Writer paramWriter) { super(paramInt, paramObjectCodec); this._ioContext = paramIOContext; this._writer = paramWriter; this._outputBuffer = paramIOContext.allocConcatBuffer(); this._outputEnd = this._outputBuffer.length; if (isEnabled(JsonGenerator.Feature.ESCAPE_NON_ASCII)) setHighestNonEscapedChar(127); }
public Utf8Generator(IOContext paramIOContext, int paramInt, ObjectCodec paramObjectCodec, OutputStream paramOutputStream) { super(paramInt, paramObjectCodec); this._ioContext = paramIOContext; this._outputStream = paramOutputStream; this._bufferRecyclable = true; this._outputBuffer = paramIOContext.allocWriteEncodingBuffer(); this._outputEnd = this._outputBuffer.length; this._outputMaxContiguous = (this._outputEnd >> 3); this._charBuffer = paramIOContext.allocConcatBuffer(); this._charBufferLength = this._charBuffer.length; if (isEnabled(JsonGenerator.Feature.ESCAPE_NON_ASCII)) setHighestNonEscapedChar(127); }
public Utf8Generator(IOContext paramIOContext, int paramInt1, ObjectCodec paramObjectCodec, OutputStream paramOutputStream, byte[] paramArrayOfByte, int paramInt2, boolean paramBoolean) { super(paramInt1, paramObjectCodec); this._ioContext = paramIOContext; this._outputStream = paramOutputStream; this._bufferRecyclable = paramBoolean; this._outputTail = paramInt2; this._outputBuffer = paramArrayOfByte; this._outputEnd = this._outputBuffer.length; this._outputMaxContiguous = (this._outputEnd >> 3); this._charBuffer = paramIOContext.allocConcatBuffer(); this._charBufferLength = this._charBuffer.length; if (isEnabled(JsonGenerator.Feature.ESCAPE_NON_ASCII)) setHighestNonEscapedChar(127); }
protected JsonGeneratorBase(int paramInt, ObjectCodec paramObjectCodec) { this._features = paramInt; this._writeContext = JsonWriteContext.createRootContext(); this._objectCodec = paramObjectCodec; this._cfgNumbersAsStrings = isEnabled(JsonGenerator.Feature.WRITE_NUMBERS_AS_STRINGS); }
public TokenBuffer$Parser(TokenBuffer.Segment paramSegment, ObjectCodec paramObjectCodec) { super(0); this._segment = paramSegment; this._segmentPtr = -1; this._codec = paramObjectCodec; this._parsingContext = JsonReadContext.createRootContext(-1, -1); }
public TokenBuffer(ObjectCodec paramObjectCodec) { this._objectCodec = paramObjectCodec; this._generatorFeatures = DEFAULT_PARSER_FEATURES; this._writeContext = JsonWriteContext.createRootContext(); TokenBuffer.Segment localSegment = new TokenBuffer.Segment(); this._last = localSegment; this._first = localSegment; this._appendOffset = 0; }
public ReaderBasedParser(IOContext paramIOContext, int paramInt, Reader paramReader, ObjectCodec paramObjectCodec, CharsToNameCanonicalizer paramCharsToNameCanonicalizer) { super(paramIOContext, paramInt); this._reader = paramReader; this._inputBuffer = paramIOContext.allocTokenBuffer(); this._objectCodec = paramObjectCodec; this._symbols = paramCharsToNameCanonicalizer; }
public Utf8StreamParser(IOContext paramIOContext, int paramInt1, InputStream paramInputStream, ObjectCodec paramObjectCodec, BytesToNameCanonicalizer paramBytesToNameCanonicalizer, byte[] paramArrayOfByte, int paramInt2, int paramInt3, boolean paramBoolean) { super(paramIOContext, paramInt1); this._inputStream = paramInputStream; this._objectCodec = paramObjectCodec; this._symbols = paramBytesToNameCanonicalizer; this._inputBuffer = paramArrayOfByte; this._inputPtr = paramInt2; this._inputEnd = paramInt3; this._bufferRecyclable = paramBoolean; if (!JsonParser.Feature.CANONICALIZE_FIELD_NAMES.enabledIn(paramInt1)) _throwInternal(); }
public final JsonParser constructParser(int paramInt, ObjectCodec paramObjectCodec, BytesToNameCanonicalizer paramBytesToNameCanonicalizer, CharsToNameCanonicalizer paramCharsToNameCanonicalizer) { JsonEncoding localJsonEncoding = detectEncoding(); boolean bool1 = JsonParser.Feature.CANONICALIZE_FIELD_NAMES.enabledIn(paramInt); boolean bool2 = JsonParser.Feature.INTERN_FIELD_NAMES.enabledIn(paramInt); if ((localJsonEncoding == JsonEncoding.UTF8) && (bool1)) { BytesToNameCanonicalizer localBytesToNameCanonicalizer = paramBytesToNameCanonicalizer.makeChild(bool1, bool2); return new Utf8StreamParser(this._context, paramInt, this._in, paramObjectCodec, localBytesToNameCanonicalizer, this._inputBuffer, this._inputPtr, this._inputEnd, this._bufferRecyclable); } return new ReaderBasedParser(this._context, paramInt, constructReader(), paramObjectCodec, paramCharsToNameCanonicalizer.makeChild(bool1, bool2)); }
