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;
}