-
- boolean createInfoTypes(Rapp rApp, Set<String> infoTypes) {
- logger.debug("Creating DME info types {} for rApp {}", infoTypes, rApp.getRappId());
- try {
- Map<String, ProducerInfoTypeInfo> producerInfoTypeInfoMap = new HashMap<>();
- for (String infoType : infoTypes) {
- String infoTypePayload = rappCsarConfigurationHandler.getDmeInfoTypePayload(rApp, infoType);
- if (infoTypePayload != null && !infoTypePayload.isEmpty()) {
- producerInfoTypeInfoMap.put(infoType,
- objectMapper.readValue(infoTypePayload, ProducerInfoTypeInfo.class));
- }
- }
- return producerInfoTypeInfoMap.entrySet().stream().map(stringProducerInfoTypeInfoEntry -> {
- ResponseEntity<Object> objectResponseEntity = dataProducerRegistrationApiClient.putInfoTypeWithHttpInfo(
- stringProducerInfoTypeInfoEntry.getKey(), stringProducerInfoTypeInfoEntry.getValue());
- return objectResponseEntity.getStatusCode().is2xxSuccessful();
- }).reduce(true, (a, b) -> a && b);
- } catch (Exception e) {
- logger.warn("Error in creating info types {} for rApp {}", infoTypes, rApp.getRappId(), e);
- return false;
- }
- }
-
- boolean createInfoProducer(Rapp rApp, String producerResource) {
- logger.debug("Creating DME info producer {} for rApp {}", producerResource, rApp.getRappId());
- try {
- String infoProducerPayload = rappCsarConfigurationHandler.getDmeInfoProducerPayload(rApp, producerResource);
- ProducerRegistrationInfo producerRegistrationInfo =
- objectMapper.readValue(infoProducerPayload, ProducerRegistrationInfo.class);
-
- ResponseEntity<Object> objectResponseEntity =
- dataProducerRegistrationApiClient.putInfoProducerWithHttpInfo(producerResource,
- producerRegistrationInfo);
- return objectResponseEntity.getStatusCode().is2xxSuccessful();
- } catch (Exception e) {
- logger.warn("Error in creating info producer {} for rApp {}", producerResource, rApp.getRappId(), e);
- return false;
- }
- }
-
- boolean createInfoConsumer(Rapp rApp, String consumerResource) {
- logger.debug("Creating DME info consumer {} for rApp {}", consumerResource, rApp.getRappId());
- try {
- String infoJobPayload = rappCsarConfigurationHandler.getDmeInfoConsumerPayload(rApp, consumerResource);
- ConsumerJob consumerJob = objectMapper.readValue(infoJobPayload, ConsumerJob.class);
- ResponseEntity<Object> objectResponseEntity =
- dataConsumerApiClient.putIndividualInfoJobWithHttpInfo(consumerResource, consumerJob);
- return objectResponseEntity.getStatusCode().is2xxSuccessful();
- } catch (Exception e) {
- logger.warn("Error in creating info consumer {} for rApp {}", consumerResource, rApp.getRappId(), e);
- return false;
- }
- }
-
- boolean deleteInfoProducer(Rapp rApp, String producerResource) {
- logger.debug("Deleting DME info producer {} for rApp {}", producerResource, rApp.getRappId());
- try {
- ResponseEntity<Object> objectResponseEntity =
- dataProducerRegistrationApiClient.deleteInfoProducerWithHttpInfo(producerResource);
- return objectResponseEntity.getStatusCode().is2xxSuccessful();
- } catch (Exception e) {
- logger.warn("Error in deleting info producer {} for rApp {}", producerResource, rApp.getRappId(), e);
- return false;
- }
- }
-
- boolean deleteInfoConsumer(Rapp rApp, String consumerResource) {
- logger.debug("Deleting DME info consumer {} for rApp {}", consumerResource, rApp.getRappId());
- try {
- ResponseEntity<Object> objectResponseEntity =
- dataConsumerApiClient.deleteIndividualInfoJobWithHttpInfo(consumerResource);
- return objectResponseEntity.getStatusCode().is2xxSuccessful();
- } catch (Exception e) {
- logger.warn("Error in deleting info consumer {} for rApp {}", consumerResource, rApp.getRappId(), e);
- return false;
- }
- }