in src/main/java/com/epam/digital/data/platform/kafkaapi/core/commandhandler/AbstractCreateCommandHandler.java [49:62]
public EntityId save(Request<T> input) {
requestPreprocessor(input);
JwtClaimsDto userClaims = jwtInfoProvider.getUserClaims(input);
Map<String, Object> entityMap = entityConverter.entityToMap(input.getPayload());
entityMap.remove(tableDataProvider.pkColumnName());
Map<String, String> sysValues = entityConverter.buildSysValues(userClaims.getDrfo(), input);
String id =
dmlOperationHandler.save(
DmlOperationArgs.builder(tableDataProvider.tableName(), userClaims, sysValues)
.saveOperationArgs(entityMap)
.build());
return new EntityId(UUID.fromString(id));
}