public Object process()

in src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/KafkaAuditProcessor.java [59:77]

• 19 lines of code
• 7 McCabe index (conditional complexity)

  public Object process(ProceedingJoinPoint joinPoint, Operation operation) throws Throwable {
    var request = getArgumentByType(joinPoint, Request.class);
    switch (operation) {
      case CREATE:
        return prepareAndSendKafkaAudit(joinPoint, request, CREATE);
      case READ:
        return prepareAndSendKafkaAudit(joinPoint, request, READ);
      case UPDATE:
        return prepareAndSendKafkaAudit(joinPoint, request, UPDATE);
      case DELETE:
        return prepareAndSendKafkaAudit(joinPoint, request, DELETE);
      case SEARCH:
        return prepareAndSendKafkaAudit(joinPoint, request, SEARCH);
      case UPSERT:
        return prepareAndSendKafkaAudit(joinPoint, request, UPSERT);
      default:
        throw new AuditException("Unsupported audit operation");
    }
  }