in src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/DatabaseAuditProcessor.java [61:76]
public Object process(ProceedingJoinPoint joinPoint, Operation operation) throws Throwable {
switch (operation) {
case CREATE:
return create(joinPoint);
case READ:
return findById(joinPoint);
case UPDATE:
return update(joinPoint);
case DELETE:
return delete(joinPoint);
case SEARCH:
return search(joinPoint);
default:
throw new AuditException("Unsupported audit operation");
}
}