/*- * ============LICENSE_START======================================================= * VID * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * ============LICENSE_END========================================================= */ package org.onap.vid.controller; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.commons.lang3.tuple.ImmutablePair; import org.apache.commons.lang3.tuple.Pair; import org.onap.portalsdk.core.controller.RestrictedBaseController; import org.onap.portalsdk.core.logging.logic.EELFLoggerDelegate; import org.onap.portalsdk.core.util.SystemProperties; import org.onap.vid.aai.AaiGetVnfResponse; import org.onap.vid.aai.AaiResponse; import org.onap.vid.aai.AaiResponseTranslator.PortMirroringConfigData; import org.onap.vid.aai.ServiceInstancesSearchResults; import org.onap.vid.aai.SubscriberFilteredResults; import org.onap.vid.aai.model.AaiGetInstanceGroupsByCloudRegion; import org.onap.vid.aai.model.AaiGetOperationalEnvironments.OperationalEnvironmentList; import org.onap.vid.aai.model.AaiGetPnfs.Pnf; import org.onap.vid.aai.model.AaiGetTenatns.GetTenantsResponse; import org.onap.vid.aai.util.AAIRestInterface; import org.onap.vid.model.VersionByInvariantIdsRequest; import org.onap.vid.roles.Role; import org.onap.vid.roles.RoleProvider; import org.onap.vid.roles.RoleValidator; import org.onap.vid.services.AaiService; import org.onap.vid.utils.Unchecked; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; import org.springframework.web.servlet.HandlerMapping; import org.springframework.web.servlet.ModelAndView; import javax.servlet.ServletContext; import javax.servlet.http.HttpServletRequest; import javax.ws.rs.DefaultValue; import javax.ws.rs.QueryParam; import javax.ws.rs.WebApplicationException; import javax.ws.rs.core.Response; import java.io.IOException; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; import static org.onap.vid.utils.Logging.getMethodName; /** * Controller to handle a&ai requests. */ @RestController public class AaiController extends RestrictedBaseController { /** * The from app id. */ private String fromAppId = "VidAaiController"; /** * The logger. */ private static final EELFLoggerDelegate LOGGER = EELFLoggerDelegate.getLogger(AaiController.class); /** * The model. */ private Map model = new HashMap<>(); /** * The servlet context. */ @Autowired private ServletContext servletContext; /** * aai service */ @Autowired private AaiService aaiService; @Autowired private RoleProvider roleProvider; @Autowired private AAIRestInterface aaiRestInterface; /** * Welcome method. * * @param request the request * @return ModelAndView The view */ @RequestMapping(value = {"/subscriberSearch"}, method = RequestMethod.GET) public ModelAndView welcome(HttpServletRequest request) { LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== AaiController welcome start"); return new ModelAndView(getViewName()); } @RequestMapping(value = {"/aai_get_aic_zones"}, method = RequestMethod.GET) public ResponseEntity getAicZones(HttpServletRequest request) throws IOException { LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== getAicZones controller start"); AaiResponse response = aaiService.getAaiZones(); return aaiResponseToResponseEntity(response); } @RequestMapping(value = {"/aai_get_aic_zone_for_pnf/{globalCustomerId}/{serviceType}/{serviceId}"}, method = RequestMethod.GET) public ResponseEntity getAicZoneForPnf(@PathVariable("globalCustomerId") String globalCustomerId ,@PathVariable("serviceType") String serviceType , @PathVariable("serviceId") String serviceId ,HttpServletRequest request) throws IOException { LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== getAicZoneForPnf controller start"); AaiResponse response = aaiService.getAicZoneForPnf(globalCustomerId , serviceType , serviceId); return aaiResponseToResponseEntity(response); } @RequestMapping(value = {"/aai_get_instance_groups_by_vnf_instance_id/{vnfInstanceId}"}, method = RequestMethod.GET) public ResponseEntity getInstanceGroupsByVnfInstanceId(@PathVariable("vnfInstanceId") String vnfInstanceId ,HttpServletRequest request) throws IOException { AaiResponse response = aaiService.getInstanceGroupsByVnfInstanceId(vnfInstanceId); return aaiResponseToResponseEntity(response); } /** * Get services from a&ai. * * @return ResponseEntity The response entity with the logged in user uuid. * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = {"/getuserID"}, method = RequestMethod.GET) public ResponseEntity getUserID(HttpServletRequest request) { String userId = ControllersUtils.extractUserId(request); return new ResponseEntity<>(userId, HttpStatus.OK); } /** * Get services from a&ai. * * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_get_services", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doGetServices(HttpServletRequest request) throws IOException { RoleValidator roleValidator = new RoleValidator(roleProvider.getUserRoles(request)); AaiResponse subscriberList = aaiService.getServices(roleValidator); return aaiResponseToResponseEntity(subscriberList); } @RequestMapping(value = {"/aai_get_version_by_invariant_id"}, method = RequestMethod.POST) public ResponseEntity getVersionByInvariantId(HttpServletRequest request, @RequestBody VersionByInvariantIdsRequest versions) { Response result = aaiService.getVersionByInvariantId(versions.versions); return new ResponseEntity<>(result.readEntity(String.class), HttpStatus.OK); } private ResponseEntity aaiResponseToResponseEntity(AaiResponse aaiResponseData) throws IOException { ResponseEntity responseEntity; ObjectMapper objectMapper = new ObjectMapper(); if (aaiResponseData.getHttpCode() == 200) { responseEntity = new ResponseEntity<>(objectMapper.writeValueAsString(aaiResponseData.getT()), HttpStatus.OK); } else { responseEntity = new ResponseEntity<>(aaiResponseData.getErrorMessage(), HttpStatus.valueOf(aaiResponseData.getHttpCode())); } return responseEntity; } /** * Lookup single service instance in a&ai. Get the service-subscription and customer, too, i guess? * * @param serviceInstanceId the service instance Id * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_get_service_instance/{service-instance-id}/{service-instance-type}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doGetServiceInstance(@PathVariable("service-instance-id") String serviceInstanceId, @PathVariable("service-instance-type") String serviceInstanceType) { Response resp = null; if (serviceInstanceType.equalsIgnoreCase("Service Instance Id")) { resp = doAaiGet( "search/nodes-query?search-node-type=service-instance&filter=service-instance-id:EQUALS:" + serviceInstanceId, false); } else { resp = doAaiGet( "search/nodes-query?search-node-type=service-instance&filter=service-instance-name:EQUALS:" + serviceInstanceId, false); } return convertResponseToResponseEntity(resp); } /** * Get services from a&ai. * * @param globalCustomerId the global customer id * @param serviceSubscriptionId the service subscription id * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_get_service_subscription/{global-customer-id}/{service-subscription-id}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doGetServices(@PathVariable("global-customer-id") String globalCustomerId, @PathVariable("service-subscription-id") String serviceSubscriptionId) { Response resp = doAaiGet("business/customers/customer/" + globalCustomerId + "/service-subscriptions/service-subscription/" + serviceSubscriptionId + "?depth=0", false); return convertResponseToResponseEntity(resp); } /** * Obtain the subscriber list from a&ai. * * @param fullSet the full set * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_get_subscribers", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doGetSubscriberList(HttpServletRequest request, @DefaultValue("n") @QueryParam("fullSet") String fullSet) throws IOException { return getFullSubscriberList(request); } /** * Obtain the Target Prov Status from the System.Properties file. * * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/get_system_prop_vnf_prov_status", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity getTargetProvStatus() { String p = SystemProperties.getProperty("aai.vnf.provstatus"); return new ResponseEntity<>(p, HttpStatus.OK); } /** * Obtain the Target Prov Status from the System.Properties file. * * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/get_operational_environments", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public AaiResponse getOperationalEnvironments(@RequestParam(value="operationalEnvironmentType", required = false) String operationalEnvironmentType, @RequestParam(value="operationalEnvironmentStatus", required = false) String operationalEnvironmentStatus) { LOGGER.debug(EELFLoggerDelegate.debugLogger, "start {}({}, {})", getMethodName(), operationalEnvironmentType, operationalEnvironmentStatus); AaiResponse response = aaiService.getOperationalEnvironments(operationalEnvironmentType,operationalEnvironmentStatus); if (response.getHttpCode() != 200) { String errorMessage = getAaiErrorMessage(response.getErrorMessage()); if(errorMessage != null) { response = new AaiResponse<>(response.getT(), errorMessage, response.getHttpCode()); } } LOGGER.debug(EELFLoggerDelegate.debugLogger, "end {}() => {}", getMethodName(), response); return response; } /** * Obtain the full subscriber list from a&ai. *

* g @return ResponseEntity The response entity * * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_get_full_subscribers", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity getFullSubscriberList(HttpServletRequest request) throws IOException { ObjectMapper objectMapper = new ObjectMapper(); ResponseEntity responseEntity; RoleValidator roleValidator = new RoleValidator(roleProvider.getUserRoles(request)); SubscriberFilteredResults subscriberList = aaiService.getFullSubscriberList(roleValidator); if (subscriberList.getHttpCode() == 200) { responseEntity = new ResponseEntity<>(objectMapper.writeValueAsString(subscriberList.getSubscriberList()), HttpStatus.OK); } else { responseEntity = new ResponseEntity<>(subscriberList.getErrorMessage(), HttpStatus.valueOf(subscriberList.getHttpCode())); } return responseEntity; } @RequestMapping(value = "/get_vnf_data_by_globalid_and_service_type/{globalCustomerId}/{serviceType}", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity getVnfDataByGlobalIdAndServiceType(HttpServletRequest request, @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType) throws IOException { AaiResponse resp = aaiService.getVNFData(globalCustomerId, serviceType); return aaiResponseToResponseEntity(resp); } /** * Refresh the subscriber list from a&ai. * * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_refresh_subscribers", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doRefreshSubscriberList() { return refreshSubscriberList(); } /** * Refresh the full subscriber list from a&ai. * * @return ResponseEntity The response entity * @throws IOException Signals that an I/O exception has occurred. */ @RequestMapping(value = "/aai_refresh_full_subscribers", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE) public ResponseEntity doRefreshFullSubscriberList() { return refreshSubscriberList(); } protected ResponseEntity refreshSubscriberList() { Response resp = getSubscribers(); return convertResponseToResponseEntity(resp); } /** * Get subscriber details from a&ai. * * @param subscriberId the subscriber id * @return ResponseEntity The response entity */ @RequestMapping(value = "/aai_sub_details/{subscriberId}", method = RequestMethod.GET) public ResponseEntity GetSubscriberDetails(HttpServletRequest request, @PathVariable("subscriberId") String subscriberId) throws IOException { ObjectMapper objectMapper = new ObjectMapper(); ResponseEntity responseEntity; List roles = roleProvider.getUserRoles(request); RoleValidator roleValidator = new RoleValidator(roles); AaiResponse subscriberData = aaiService.getSubscriberData(subscriberId, roleValidator); String httpMessage = subscriberData.getT() != null ? objectMapper.writeValueAsString(subscriberData.getT()) : subscriberData.getErrorMessage(); responseEntity = new ResponseEntity(httpMessage, HttpStatus.valueOf(subscriberData.getHttpCode())); return responseEntity; } /** * Get service instances that match the query from a&ai. * * @param subscriberId the subscriber id * @param instanceIdentifier the service instance name or id. * @param projects the projects that are related to the instance * @param owningEntities the owningEntities that are related to the instance * @return ResponseEntity The response entity */ @RequestMapping(value = "/search_service_instances", method = RequestMethod.GET) public ResponseEntity SearchServiceInstances(HttpServletRequest request, @RequestParam(value="subscriberId", required = false) String subscriberId, @RequestParam(value="serviceInstanceIdentifier", required = false) String instanceIdentifier, @RequestParam(value="project", required = false) List projects, @RequestParam(value="owningEntity", required = false) List owningEntities) throws IOException { ObjectMapper objectMapper = new ObjectMapper(); ResponseEntity responseEntity; List roles = roleProvider.getUserRoles(request); RoleValidator roleValidator = new RoleValidator(roles); AaiResponse searchResult = aaiService.getServiceInstanceSearchResults(subscriberId, instanceIdentifier, roleValidator, owningEntities, projects); String httpMessage = searchResult.getT() != null ? objectMapper.writeValueAsString(searchResult.getT()) : searchResult.getErrorMessage(); if(searchResult.getT().serviceInstances.isEmpty()){ responseEntity = new ResponseEntity(httpMessage, HttpStatus.NOT_FOUND); } else { responseEntity = new ResponseEntity(httpMessage, HttpStatus.valueOf(searchResult.getHttpCode())); } return responseEntity; } /** * Issue a named query to a&ai. * * @param namedQueryId the named query id * @param globalCustomerId the global customer id * @param serviceType the service type * @param serviceInstance the service instance * @return ResponseEntity The response entity */ @RequestMapping(value = "/aai_sub_viewedit/{namedQueryId}/{globalCustomerId}/{serviceType}/{serviceInstance}", method = RequestMethod.GET) public ResponseEntity viewEditGetComponentList( @PathVariable("namedQueryId") String namedQueryId, @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType, @PathVariable("serviceInstance") String serviceInstance) { String componentListPayload = getComponentListPutPayload(namedQueryId, globalCustomerId, serviceType, serviceInstance); Response resp = doAaiPost("search/named-query", componentListPayload, false); return convertResponseToResponseEntity(resp); } /** * Issue a named query to a&ai. * * @param namedQueryId the named query id * @param globalCustomerId the global customer id * @param serviceType the service type * @return ResponseEntity The response entity */ @RequestMapping(value = "/aai_get_models_by_service_type/{namedQueryId}/{globalCustomerId}/{serviceType}", method = RequestMethod.GET) public ResponseEntity viewEditGetComponentList( @PathVariable("namedQueryId") String namedQueryId, @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType) { String componentListPayload = getModelsByServiceTypePayload(namedQueryId, globalCustomerId, serviceType); Response resp = doAaiPost("search/named-query", componentListPayload, false); return convertResponseToResponseEntity(resp); } @RequestMapping(value = "/aai_get_vnf_instances/{globalCustomerId}/{serviceType}/{modelVersionId}/{modelInvariantId}/{cloudRegion}", method = RequestMethod.GET) public ResponseEntity getNodeTemplateInstances( @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType, @PathVariable("modelVersionId") String modelVersionId, @PathVariable("modelInvariantId") String modelInvariantId, @PathVariable("cloudRegion") String cloudRegion) { AaiResponse resp = aaiService.getNodeTemplateInstances(globalCustomerId, serviceType, modelVersionId, modelInvariantId, cloudRegion); return new ResponseEntity<>(resp.getT(), HttpStatus.valueOf(resp.getHttpCode())); } @RequestMapping(value = "/aai_get_network_collection_details/{serviceInstanceId}", method = RequestMethod.GET) public ResponseEntity getNetworkCollectionDetails(@PathVariable("serviceInstanceId") String serviceInstanceId) throws IOException { com.fasterxml.jackson.databind.ObjectMapper objectMapper = new com.fasterxml.jackson.databind.ObjectMapper(); AaiResponse resp = aaiService.getNetworkCollectionDetails(serviceInstanceId); String httpMessage = resp.getT() != null ? objectMapper.writeValueAsString(resp.getT()) : resp.getErrorMessage(); return new ResponseEntity<>(httpMessage, HttpStatus.valueOf(resp.getHttpCode())); } @RequestMapping(value = "/aai_get_instance_groups_by_cloudregion/{cloudOwner}/{cloudRegionId}/{networkFunction}", method = RequestMethod.GET) public ResponseEntity getInstanceGroupsByCloudRegion(@PathVariable("cloudOwner") String cloudOwner, @PathVariable("cloudRegionId") String cloudRegionId, @PathVariable("networkFunction") String networkFunction) throws IOException { com.fasterxml.jackson.databind.ObjectMapper objectMapper = new com.fasterxml.jackson.databind.ObjectMapper(); AaiResponse resp = aaiService.getInstanceGroupsByCloudRegion(cloudOwner, cloudRegionId, networkFunction); String httpMessage = resp.getT() != null ? objectMapper.writeValueAsString(resp.getT()) : resp.getErrorMessage(); return new ResponseEntity<>(httpMessage, HttpStatus.valueOf(resp.getHttpCode())); } @RequestMapping(value = "/aai_get_by_uri/**", method = RequestMethod.GET) public ResponseEntity getByUri(HttpServletRequest request) { String restOfTheUrl = (String) request.getAttribute( HandlerMapping.PATH_WITHIN_HANDLER_MAPPING_ATTRIBUTE); String formattedUri = restOfTheUrl.replaceFirst("/aai_get_by_uri/", "").replaceFirst("^aai/v[\\d]+/", ""); Response resp = doAaiGet(formattedUri, false); return convertResponseToResponseEntity(resp); } @RequestMapping(value = "/aai_get_configuration/{configuration_id}", method = RequestMethod.GET) public ResponseEntity getSpecificConfiguration(@PathVariable("configuration_id") String configurationId) { Response resp = doAaiGet("network/configurations/configuration/"+configurationId, false); return convertResponseToResponseEntity(resp); } @RequestMapping(value = "/aai_get_service_instance_pnfs/{globalCustomerId}/{serviceType}/{serviceInstanceId}", method = RequestMethod.GET) public List getServiceInstanceAssociatedPnfs( @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType, @PathVariable("serviceInstanceId") String serviceInstanceId) { return aaiService.getServiceInstanceAssociatedPnfs(globalCustomerId, serviceType, serviceInstanceId); } /** * PNF section */ @RequestMapping(value = "/aai_get_pnfs/pnf/{pnf_id}", method = RequestMethod.GET) public ResponseEntity getSpecificPnf(@PathVariable("pnf_id") String pnfId) { AaiResponse resp; ResponseEntity re; try { resp = aaiService.getSpecificPnf(pnfId); re = new ResponseEntity<>(resp.getT(), HttpStatus.valueOf(resp.getHttpCode())); } catch (Exception e){ return new ResponseEntity(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR); } return re; } /** * Obtain tenants for a given service type. * * @param globalCustomerId the global customer id * @param serviceType the service type * @return ResponseEntity The response entity */ @RequestMapping(value = "/aai_get_tenants/{global-customer-id}/{service-type}", method = RequestMethod.GET) public ResponseEntity viewEditGetTenantsFromServiceType(HttpServletRequest request, @PathVariable("global-customer-id") String globalCustomerId, @PathVariable("service-type") String serviceType) { ResponseEntity responseEntity; try { ObjectMapper objectMapper = new ObjectMapper(); List roles = roleProvider.getUserRoles(request); RoleValidator roleValidator = new RoleValidator(roles); AaiResponse response = aaiService.getTenants(globalCustomerId, serviceType, roleValidator); if (response.getHttpCode() == 200) { responseEntity = new ResponseEntity(objectMapper.writeValueAsString(response.getT()), HttpStatus.OK); } else { responseEntity = new ResponseEntity(response.getErrorMessage(), HttpStatus.valueOf(response.getHttpCode())); } } catch (Exception e) { responseEntity = new ResponseEntity("Unable to proccess getTenants reponse", HttpStatus.INTERNAL_SERVER_ERROR); } return responseEntity; } @RequestMapping(value = "/aai_get_pnf_instances/{globalCustomerId}/{serviceType}/{modelVersionId}/{modelInvariantId}/{cloudRegion}/{equipVendor}/{equipModel}", method = RequestMethod.GET) public ResponseEntity getPnfInstances( @PathVariable("globalCustomerId") String globalCustomerId, @PathVariable("serviceType") String serviceType, @PathVariable("modelVersionId") String modelVersionId, @PathVariable("modelInvariantId") String modelInvariantId, @PathVariable("cloudRegion") String cloudRegion, @PathVariable("equipVendor") String equipVendor, @PathVariable("equipModel") String equipModel) { AaiResponse resp = aaiService.getPNFData(globalCustomerId, serviceType, modelVersionId, modelInvariantId, cloudRegion, equipVendor, equipModel); return new ResponseEntity<>(resp.getT(), HttpStatus.valueOf(resp.getHttpCode())); } @RequestMapping(value = "/aai_getPortMirroringConfigsData", method = RequestMethod.GET) public Map getPortMirroringConfigsData( @RequestParam ("configurationIds") List configurationIds) { return configurationIds.stream() .map(id -> ImmutablePair.of(id, aaiService.getPortMirroringConfigData(id))) .collect(Collectors.toMap(Pair::getKey, Pair::getValue)); } @RequestMapping(value = "/aai_getPortMirroringSourcePorts", method = RequestMethod.GET) public Map getPortMirroringSourcePorts( @RequestParam ("configurationIds") List configurationIds) { return configurationIds.stream() .map(id -> ImmutablePair.of(id, aaiService.getPortMirroringSourcePorts(id))) .collect(Collectors.toMap(Pair::getKey, Pair::getValue)); } private ResponseEntity convertResponseToResponseEntity(Response resp) { ResponseEntity respEnt; if (resp == null) { respEnt = new ResponseEntity<>("Failed to fetch data from A&AI, check server logs for details.", HttpStatus.INTERNAL_SERVER_ERROR); } else { respEnt = new ResponseEntity<>(resp.readEntity(String.class), HttpStatus.valueOf(resp.getStatus())); } return respEnt; } /** * Gets the subscribers. * * @return the subscribers */ private Response getSubscribers() { String depth = "0"; Response resp = doAaiGet("business/customers?subscriber-type=INFRA&depth=" + depth, false); if (resp != null) { LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== getSubscribers() resp=" + resp.getStatusInfo().toString()); } return resp; } /** * Send a GET request to a&ai. * * @param uri the uri * @param xml the xml * @return String The response */ protected Response doAaiGet(String uri, boolean xml) { String methodName = "getSubscriberList"; String transId = UUID.randomUUID().toString(); LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== " + methodName + " start"); Response resp = null; try { resp = aaiRestInterface.RestGet(fromAppId, transId, Unchecked.toURI(uri), xml).getResponse(); } catch (WebApplicationException e) { final String message = e.getResponse().readEntity(String.class); LOGGER.info(EELFLoggerDelegate.errorLogger, "<== " + "." + methodName + message); LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== " + "." + methodName + message); } catch (Exception e) { LOGGER.info(EELFLoggerDelegate.errorLogger, "<== " + "." + methodName + e.toString()); LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== " + "." + methodName + e.toString()); } return resp; } /** * Send a POST request to a&ai. * * @param uri the uri * @param payload the payload * @param xml the xml * @return String The response */ protected Response doAaiPost(String uri, String payload, boolean xml) { String methodName = "getSubscriberList"; LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== " + methodName + " start"); Response resp = null; try { resp = aaiRestInterface.RestPost(fromAppId, uri, payload, xml); } catch (Exception e) { LOGGER.info(EELFLoggerDelegate.errorLogger, "<== " + "." + methodName + e.toString()); LOGGER.debug(EELFLoggerDelegate.debugLogger, "<== " + "." + methodName + e.toString()); } return resp; } /** * Gets the component list put payload. * * @param namedQueryId the named query id * @param globalCustomerId the global customer id * @param serviceType the service type * @param serviceInstance the service instance * @return the component list put payload */ private String getComponentListPutPayload(String namedQueryId, String globalCustomerId, String serviceType, String serviceInstance) { return " {" + " \"instance-filters\": {" + " \"instance-filter\": [" + " {" + " \"customer\": {" + " \"global-customer-id\": \"" + globalCustomerId + "\"" + " }," + " \"service-instance\": {" + " \"service-instance-id\": \"" + serviceInstance + "\"" + " }," + " \"service-subscription\": {" + " \"service-type\": \"" + serviceType + "\"" + " }" + " }" + " ]" + " }," + " \"query-parameters\": {" + " \"named-query\": {" + " \"named-query-uuid\": \"" + namedQueryId + "\"" + " }" + " }" + "}"; } private String getModelsByServiceTypePayload(String namedQueryId, String globalCustomerId, String serviceType) { // TODO Auto-generated method stub return " {" + " \"instance-filters\": {" + " \"instance-filter\": [" + " {" + " \"customer\": {" + " \"global-customer-id\": \"" + globalCustomerId + "\"" + " }," + " \"service-subscription\": {" + " \"service-type\": \"" + serviceType + "\"" + " }" + " }" + " ]" + " }," + " \"query-parameters\": {" + " \"named-query\": {" + " \"named-query-uuid\": \"" + namedQueryId + "\"" + " }" + " }" + "}"; } private String getAaiErrorMessage(String message) { try { org.json.JSONObject json = new org.json.JSONObject(message); json = json.getJSONObject("requestError").getJSONObject("serviceException"); return json.getString("messageId") + ": " + json.getString("text"); } catch (Exception e) { return null; } } }