import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
+import java.util.Set;
import java.util.stream.Collectors;
import javax.annotation.PostConstruct;
import javax.persistence.EntityNotFoundException;
import org.onap.logging.filter.spring.SpringClientPayloadFilter;
import org.onap.so.db.catalog.beans.BBNameSelectionReference;
import org.onap.so.db.catalog.beans.BuildingBlockDetail;
+import org.onap.so.db.catalog.beans.BuildingBlockRollback;
import org.onap.so.db.catalog.beans.CloudSite;
import org.onap.so.db.catalog.beans.CloudifyManager;
import org.onap.so.db.catalog.beans.CollectionNetworkResourceCustomization;
private static final String WORKFLOW = "/workflow";
private static final String BB_NAME_SELECTION_REFERENCE = "/bbNameSelectionReference";
private static final String PROCESSING_FLAGS = "/processingFlags";
+ private static final String BB_ROLLBACK = "/buildingBlockRollback";
private static final String SEARCH = "/search";
private String pnfResourceURI;
private String pnfResourceCustomizationURI;
private String workflowURI;
+ private String buildingBlockRollbacksURI;
private final Client<Service> serviceClient;
private final Client<ProcessingFlags> processingFlagsClient;
+ private final Client<BuildingBlockRollback> buildingBlockRollbackClient;
+
@Value("${mso.catalog.db.spring.endpoint:#{null}}")
private String endpoint;
pnfResourceURI = endpoint + PNF_RESOURCE + URI_SEPARATOR;
pnfResourceCustomizationURI = endpoint + PNF_RESOURCE_CUSTOMIZATION + URI_SEPARATOR;
workflowURI = endpoint + WORKFLOW + URI_SEPARATOR;
-
+ buildingBlockRollbacksURI = endpoint + BB_ROLLBACK + URI_SEPARATOR;
}
public CatalogDbClient() {
bbNameSelectionReferenceClient = clientFactory.create(BBNameSelectionReference.class);
processingFlagsClient = clientFactory.create(ProcessingFlags.class);
networkResourceClient = clientFactory.create(NetworkResource.class);
+ buildingBlockRollbackClient = clientFactory.create(BuildingBlockRollback.class);
}
public CatalogDbClient(String baseUri, String auth) {
bbNameSelectionReferenceClient = clientFactory.create(BBNameSelectionReference.class);
processingFlagsClient = clientFactory.create(ProcessingFlags.class);
networkResourceClient = clientFactory.create(NetworkResource.class);
+ buildingBlockRollbackClient = clientFactory.create(BuildingBlockRollback.class);
}
public NetworkCollectionResourceCustomization getNetworkCollectionResourceCustomizationByID(
getUri(UriBuilder.fromUri(findProcessingFlagsByFlag).queryParam(FLAG, flag).build().toString()));
}
+ // TODO: redo using buildingBlockRollbackClient
+ public List<BuildingBlockRollback> getBuildingBlockRollbackEntries() {
+ try {
+ HttpEntity<?> entity = getHttpEntity();
+ return restTemplate.exchange(
+ UriComponentsBuilder.fromUriString(endpoint + "/ecomp/mso/catalog/v1/buildingBlockRollback").build()
+ .encode().toString(),
+ HttpMethod.GET, entity, new ParameterizedTypeReference<List<BuildingBlockRollback>>() {}).getBody();
+ } catch (HttpClientErrorException e) {
+ logger.error("Error Calling catalog database", e);
+ throw e;
+ }
+ }
+
public String getEndpoint() {
return endpoint;
}