Path	Lines of Code
build.groovy	2
code-review.groovy	2
create-release.groovy	2
settings.xml	66
src/it/java/com/epam/digital/data/platform/kafkaapi/core/Main.java	10
src/it/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/CommandHandlerIT.java	78
src/it/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/TestEntityFileCommandHandlerIT.java	79
src/it/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/TestEntityWithAutoGeneratedValueCommandHandlerIT.java	80
src/it/java/com/epam/digital/data/platform/kafkaapi/core/config/Config.java	20
src/it/java/com/epam/digital/data/platform/kafkaapi/core/config/TestConfiguration.java	24
src/it/java/com/epam/digital/data/platform/kafkaapi/core/config/TestDatabase.java	22
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityCreateCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityDeleteCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityFileCreateCommandHandler.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityFileDeleteCommandHandler.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityFileUpdateCommandHandler.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityM2MCreateCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityM2MDeleteCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityM2MUpdateCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityUpdateCommandHandler.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityUpsertCommandHandler.java	16
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityWithAutoGeneratedValueCreateCommandHandler.java	30
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityWithAutoGeneratedValueDeleteCommandHandler.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/commandhandler/TestEntityWithAutoGeneratedValueUpdateCommandHandler.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/listener/TestEntityAsyncDataLoadKafkaListener.java	23
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/PagingTestEntitySearchConditions.java	32
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntity.java	48
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityCreateList.java	15
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityFile.java	26
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityFileArray.java	27
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityFileSearchConditions.java	10
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityM2M.java	26
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntitySearchConditions.java	32
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TestEntityWithAutoGeneratedValue.java	25
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/model/TypGender.java	9
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/queryhandler/TestEntityFileArrayQueryHandler.java	35
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/queryhandler/TestEntityFileQueryHandler.java	34
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/queryhandler/TestEntityM2MQueryHandler.java	33
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/queryhandler/TestEntityQueryHandler.java	38
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/searchhandler/PagingTestEntitySearchHandler.java	66
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/searchhandler/TestEntityFileSearchHandler.java	40
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/searchhandler/TestEntitySearchHandler.java	49
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/sequencedata/TestEntityWithAutoGeneratedValueSequenceDataProvider.java	20
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/service/TestEntityCsvProcessor.java	18
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/tabledata/TestEntityFileArrayTableDataProvider.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/tabledata/TestEntityFileTableDataProvider.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/tabledata/TestEntityM2MTableDataProvider.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/tabledata/TestEntityTableDataProvider.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/impl/tabledata/TestEntityWithAutoGeneratedValueTableDataProvider.java	14
src/it/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListenerIT.java	184
src/it/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/QueryHandlerIT.java	44
src/it/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/TestEntityFileArrayQueryHandlerIT.java	53
src/it/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/TestEntityFileQueryHandlerIT.java	51
src/it/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/TestEntityM2MQueryHandlerIT.java	49
src/it/java/com/epam/digital/data/platform/kafkaapi/core/searchhandler/SearchHandlerIT.java	71
src/it/java/com/epam/digital/data/platform/kafkaapi/core/searchhandler/TestEntityFileSearchHandlerIT.java	45
src/it/java/com/epam/digital/data/platform/kafkaapi/core/util/DaoTestUtils.java	84
src/it/java/com/epam/digital/data/platform/kafkaapi/core/util/SearchHandlerTestUtil.java	9
src/it/java/com/epam/digital/data/platform/kafkaapi/core/util/SecurityUtils.java	38
src/it/resources/init_db.sql	158
src/main/java/com/epam/digital/data/platform/kafkaapi/core/aspect/AuditAspect.java	35
src/main/java/com/epam/digital/data/platform/kafkaapi/core/aspect/ExecutionTimeLoggingAspect.java	44
src/main/java/com/epam/digital/data/platform/kafkaapi/core/aspect/KafkaResponseListenerAspect.java	11
src/main/java/com/epam/digital/data/platform/kafkaapi/core/aspect/LivenessStateCheckAspect.java	24
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/AuditProcessor.java	22
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/AuditSourceInfoProvider.java	5
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/AuditableDatabaseOperation.java	11
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/AuditableListener.java	11
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/DatabaseAuditProcessor.java	116
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/DatabaseEventsFacade.java	50
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/KafkaAuditProcessor.java	74
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/KafkaEventsFacade.java	52
src/main/java/com/epam/digital/data/platform/kafkaapi/core/audit/MdcAuditSourceInfoProvider.java	20
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractCreateCommandHandler.java	41
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractDeleteCommandHandler.java	34
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractUpdateCommandHandler.java	42
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractUpsertCommandHandler.java	33
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/CreateCommandHandler.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/DeleteCommandHandler.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/UpdateCommandHandler.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/UpsertCommandHandler.java	8
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/model/DmlOperationArgs.java	97
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/util/DmlOperation.java	13
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/util/DmlOperationHandler.java	85
src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/util/EntityConverter.java	116
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/CephFormDataStorageConfig.java	51
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/CsvConfig.java	38
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/GenericConfig.java	41
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/KafkaConfig.java	17
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/KeycloakConfigProperties.java	22
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/SleuthConfig.java	24
src/main/java/com/epam/digital/data/platform/kafkaapi/core/config/ThirdPartySystemsConfig.java	51
src/main/java/com/epam/digital/data/platform/kafkaapi/core/converter/jooq/FileConverter.java	52
src/main/java/com/epam/digital/data/platform/kafkaapi/core/converter/jooq/FileListConverter.java	88
src/main/java/com/epam/digital/data/platform/kafkaapi/core/dbserializer/LineSerializer.java	34
src/main/java/com/epam/digital/data/platform/kafkaapi/core/dbserializer/PointSerializer.java	30
src/main/java/com/epam/digital/data/platform/kafkaapi/core/dbserializer/PolygonSerializer.java	35
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/AuditException.java	6
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/ChecksumInconsistencyException.java	6
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/ConstraintViolationException.java	10
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/CsvDtoValidationException.java	12
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/CsvFileEncodingException.java	6
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/CsvFileParsingException.java	6
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/ExternalCommunicationException.java	11
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/FileNotExistsException.java	13
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/ForbiddenOperationException.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/JwtExpiredException.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/JwtValidationException.java	10
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/PatternException.java	10
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/ProcedureErrorException.java	10
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/RequestProcessingException.java	30
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/SequenceGeneratorException.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/exception/SqlErrorException.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/AsyncDataLoadKafkaListener.java	215
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericCreateCommandListener.java	50
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericDeleteCommandListener.java	50
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericQueryListener.java	58
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericSearchListener.java	53
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericUpdateCommandListener.java	50
src/main/java/com/epam/digital/data/platform/kafkaapi/core/listener/GenericUpsertCommandListener.java	51
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/AsyncDataLoadRequest.java	15
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/AsyncDataLoadResponse.java	16
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/AsyncDataLoadResult.java	7
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/FieldsAccessCheckDto.java	22
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/Sequence.java	23
src/main/java/com/epam/digital/data/platform/kafkaapi/core/model/ValidationResult.java	19
src/main/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/AbstractQueryHandler.java	67
src/main/java/com/epam/digital/data/platform/kafkaapi/core/queryhandler/QueryHandler.java	8
src/main/java/com/epam/digital/data/platform/kafkaapi/core/searchhandler/AbstractSearchHandler.java	75
src/main/java/com/epam/digital/data/platform/kafkaapi/core/searchhandler/SearchHandler.java	8
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/AbstractCsvProcessor.java	63
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/AbstractSequenceProvider.java	55
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/AccessPermissionService.java	50
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/CsvProcessor.java	6
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/DigitalSignatureService.java	104
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/FileService.java	51
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/InputValidationService.java	24
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/JwtInfoProvider.java	30
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/JwtValidationService.java	116
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/MdcTraceProvider.java	11
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/ResponseMessageCreator.java	69
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/SequenceGenerator.java	39
src/main/java/com/epam/digital/data/platform/kafkaapi/core/service/TraceProvider.java	4
src/main/java/com/epam/digital/data/platform/kafkaapi/core/tabledata/TableDataProvider.java	5
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/ExceptionMessage.java	8
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/FileUtil.java	39
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/Header.java	20
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/JooqDataTypes.java	17
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/JwtClaimsUtils.java	9
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/Operation.java	4
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/PageableUtils.java	16
src/main/java/com/epam/digital/data/platform/kafkaapi/core/util/SQLExceptionResolverUtil.java	42