in data-audit/kogito-addons-data-audit-jpa/kogito-addons-data-audit-jpa-common/src/main/java/org/kie/kogito/app/audit/jpa/JPADataAuditStore.java [129:166]
public void storeProcessInstanceDataEvent(DataAuditContext context, ProcessInstanceNodeDataEvent event) {
ProcessInstanceNodeLog log = new ProcessInstanceNodeLog();
setProcessCommonAttributes(log, event);
log.setConnection(event.getData().getConnectionNodeDefinitionId());
log.setNodeDefinitionId(event.getData().getNodeDefinitionId());
log.setNodeType(event.getData().getNodeType());
log.setNodeInstanceId(event.getData().getNodeInstanceId());
log.setNodeName(event.getData().getNodeName());
switch (event.getData().getEventType()) {
case ProcessInstanceNodeEventBody.EVENT_TYPE_ENTER:
log.setEventType(NodeLogType.ENTER);
break;
case ProcessInstanceNodeEventBody.EVENT_TYPE_EXIT:
log.setEventType(NodeLogType.EXIT);
break;
case ProcessInstanceNodeEventBody.EVENT_TYPE_ABORTED:
log.setEventType(NodeLogType.ABORTED);
break;
case ProcessInstanceNodeEventBody.EVENT_TYPE_SKIPPED:
log.setEventType(NodeLogType.SKIPPED);
break;
case ProcessInstanceNodeEventBody.EVENT_TYPE_OBSOLETE:
log.setEventType(NodeLogType.OBSOLETE);
break;
case ProcessInstanceNodeEventBody.EVENT_TYPE_ERROR:
log.setEventType(NodeLogType.ERROR);
break;
}
log.setWorkItemId(event.getData().getWorkItemId());
EntityManager entityManager = context.getContext();
entityManager.persist(log);
}