public JobInstanceDataEvent deserialize()

in data-audit/data-audit-common-service/src/main/java/org/kie/kogito/app/audit/json/JsonJobDataEventDeserializer.java [49:69]


    public JobInstanceDataEvent deserialize(JsonParser jp, DeserializationContext ctxt)
            throws IOException, JsonProcessingException {
        JsonNode node = jp.getCodec().readTree(jp);
        LOGGER.debug("Deserialize process instance data event: {}", node);

        JobInstanceDataEvent event = new JobInstanceDataEvent(
                node.has("type") ? node.get("type").asText() : null,
                node.has("source") ? node.get("source").asText() : null,
                node.has("data") ? node.get("data").binaryValue() : null,
                node.has("kogitoprocinstanceid") ? node.get("kogitoprocinstanceid").asText() : null,
                node.has("kogitorootprociid") ? node.get("kogitorootprociid").asText() : null,
                node.has("kogitoprocid") ? node.get("kogitoprocid").asText() : null,
                node.has("kogitorootprocid") ? node.get("kogitorootprocid").asText() : null,
                node.has("kogitoidentity") ? node.get("kogitoidentity").asText() : null);

        event.setId(node.has("id") ? node.get("id").asText() : null);
        event.setKogitoIdentity(node.has("kogitoidentity") ? node.get("kogitoidentity").asText() : null);
        event.setTime(node.has("time") ? jp.getCodec().treeToValue(node.get("time"), OffsetDateTime.class) : null);

        return event;
    }