import {NgRedux} from "@angular-redux/store"; import {HttpClient} from '@angular/common/http'; import {Injectable} from '@angular/core'; import * as _ from 'lodash'; import 'rxjs/add/operator/catch'; import 'rxjs/add/operator/do'; import {of} from "rxjs"; import {AicZone} from "../../models/aicZone"; import {CategoryParams} from "../../models/categoryParams"; import {LcpRegion} from "../../models/lcpRegion"; import {LcpRegionsAndTenants} from "../../models/lcpRegionsAndTenants"; import {OwningEntity} from "../../models/owningEntity"; import {ProductFamily} from "../../models/productFamily"; import {Project} from "../../models/project"; import {SelectOption} from '../../models/selectOption'; import {ServiceType} from "../../models/serviceType"; import {Subscriber} from "../../models/subscriber"; import {Tenant} from "../../models/tenant"; import {Constants} from '../../utils/constants'; import {AppState} from "../../store/reducers"; import {GetAicZonesResponse} from "./responseInterfaces/getAicZonesResponseInterface"; import {GetCategoryParamsResponseInterface} from "./responseInterfaces/getCategoryParamsResponseInterface"; import {GetServicesResponseInterface} from "./responseInterfaces/getServicesResponseInterface"; import {GetSubDetailsResponse} from "./responseInterfaces/getSubDetailsResponseInterface"; import {GetSubscribersResponse} from "./responseInterfaces/getSubscribersResponseInterface"; import {Root} from "./model/crawledAaiService"; import {VnfInstance} from "../../models/vnfInstance"; import {VfModuleInstance} from "../../models/vfModuleInstance"; import {ServiceInstance} from "../../models/serviceInstance"; import {VfModuleMap} from "../../models/vfModulesMap"; import { updateAicZones, updateCategoryParameters, updateLcpRegionsAndTenants, updateServiceTypes, updateSubscribers, updateUserId } from "../../storeUtil/utils/general/general.actions"; import {updateModel, createServiceInstance} from "../../storeUtil/utils/service/service.actions"; import {FeatureFlagsService, Features} from "../featureFlag/feature-flags.service"; import {VnfMember} from "../../models/VnfMember"; import {setOptionalMembersVnfGroupInstance} from "../../storeUtil/utils/vnfGroup/vnfGroup.actions"; import {Observable} from "rxjs"; @Injectable() export class AaiService { constructor(private http: HttpClient, private store: NgRedux, private featureFlagsService:FeatureFlagsService) { } getServiceModelById = (serviceModelId: string): Observable => { if (_.has(this.store.getState().service.serviceHierarchy, serviceModelId)) { return of( JSON.parse(JSON.stringify(this.store.getState().service.serviceHierarchy[serviceModelId]))); } let pathQuery: string = Constants.Path.SERVICES_PATH + serviceModelId; return this.http.get(pathQuery).map(res => res) .do((res) => { this.store.dispatch(updateModel(res)); }); }; getUserId = (): Observable => { return this.http.get("../../getuserID", {responseType: 'text'}).do((res) => this.store.dispatch(updateUserId(res))); }; resolve = (root: Root, serviceInstance: ServiceInstance) => { if (root.type === 'service-instance') { serviceInstance.instanceName = root.name; serviceInstance.orchStatus = root.orchestrationStatus; serviceInstance.modelInavariantId = root.modelInvariantId; for (let i = 0; i < root.children.length; i++) { let child = root.children[i]; if (child.type === 'generic-vnf') { let vnf = new VnfInstance(); vnf.originalName = child.name; vnf.orchStatus = child.orchestrationStatus if (child.children.length > 0) { let vfModuleMap = new VfModuleMap(); for (let j = 0; j < child.children.length; j++) { let child = root.children[i]; if (child.type === 'vf-module') { let vfModule = new VfModuleInstance(); vfModule.instanceName = child.name; vfModule.orchStatus = child.orchestrationStatus; vfModuleMap.vfModules[child.name] = vfModule; } } vnf.vfModules = {"a": vfModuleMap}; } serviceInstance.vnfs[child.name] = vnf; } } } }; getCRAccordingToNetworkFunctionId = (networkCollectionFunction, cloudOwner, cloudRegionId) => { return this.http.get('../../aai_get_instance_groups_by_cloudregion/' + cloudOwner + '/' + cloudRegionId + '/' + networkCollectionFunction) .map(res => res).do((res) => console.log(res)); }; getCategoryParameters = (familyName): Observable => { familyName = familyName || Constants.Path.PARAMETER_STANDARDIZATION_FAMILY; let pathQuery: string = Constants.Path.GET_CATEGORY_PARAMETERS + "?familyName=" + familyName + "&r=" + Math.random(); return this.http.get(pathQuery) .map(this.categoryParametersResponseToProductAndOwningEntity) .do(res => { this.store.dispatch(updateCategoryParameters(res)) }); }; categoryParametersResponseToProductAndOwningEntity = (res: GetCategoryParamsResponseInterface): CategoryParams => { if (res && res.categoryParameters) { const owningEntityList = res.categoryParameters.owningEntity.map(owningEntity => new OwningEntity(owningEntity)); const projectList = res.categoryParameters.project.map(project => new Project(project)); const lineOfBusinessList = res.categoryParameters.lineOfBusiness.map(owningEntity => new SelectOption(owningEntity)); const platformList = res.categoryParameters.platform.map(platform => new SelectOption(platform)); return new CategoryParams(owningEntityList, projectList, lineOfBusinessList, platformList); } else { return new CategoryParams(); } }; getProductFamilies = (): Observable => { let pathQuery: string = Constants.Path.AAI_GET_SERVICES + Constants.Path.ASSIGN + Math.random(); return this.http.get(pathQuery).map(res => res.service.map(service => new ProductFamily(service))); }; getServices = (): Observable => { let pathQuery: string = Constants.Path.AAI_GET_SERVICES + Constants.Path.ASSIGN + Math.random(); return this.http.get(pathQuery); }; getSubscribers = (): Observable => { if (this.store.getState().service.subscribers) { return of( JSON.parse(JSON.stringify(this.store.getState().service.subscribers))); } let pathQuery: string = Constants.Path.AAI_GET_SUBSCRIBERS + Constants.Path.ASSIGN + Math.random(); return this.http.get(pathQuery).map(res => res.customer.map(subscriber => new Subscriber(subscriber))).do((res) => { this.store.dispatch(updateSubscribers(res)); }); }; getAicZones = (): Observable => { if (this.store.getState().service.aicZones) { return of( JSON.parse(JSON.stringify(this.store.getState().service.aicZones))); } let pathQuery: string = Constants.Path.AAI_GET_AIC_ZONES + Constants.Path.ASSIGN + Math.random(); return this.http.get(pathQuery).map(res => res.zone.map(aicZone => new AicZone(aicZone))).do((res) => { this.store.dispatch(updateAicZones(res)); }); }; getLcpRegionsAndTenants = (globalCustomerId, serviceType): Observable => { let pathQuery: string = Constants.Path.AAI_GET_TENANTS + globalCustomerId + Constants.Path.FORWARD_SLASH + serviceType + Constants.Path.ASSIGN + Math.random(); console.log("AaiService:getSubscriptionServiceTypeList: globalCustomerId: " + globalCustomerId); if (globalCustomerId != null) { return this.http.get(pathQuery) .map(this.tenantResponseToLcpRegionsAndTenants).do((res) => { this.store.dispatch(updateLcpRegionsAndTenants(res)); }); } }; tenantResponseToLcpRegionsAndTenants = (cloudRegionTenantList): LcpRegionsAndTenants => { const lcpRegionsTenantsMap = {}; const lcpRegionList = _.uniqBy(cloudRegionTenantList, 'cloudRegionID').map((cloudRegionTenant) => { const cloudOwner:string = cloudRegionTenant["cloudOwner"]; const cloudRegionId:string = cloudRegionTenant["cloudRegionID"]; const name:string = this.extractLcpRegionName(cloudRegionId, cloudOwner); const isPermitted:boolean = cloudRegionTenant["is-permitted"]; return new LcpRegion(cloudRegionId, name, isPermitted, cloudOwner); }); lcpRegionList.forEach(region => { lcpRegionsTenantsMap[region.id] = _.filter(cloudRegionTenantList, {'cloudRegionID': region.id}) .map((cloudRegionTenant) => { return new Tenant(cloudRegionTenant) }); const reducer = (accumulator, currentValue) => { accumulator.isPermitted = accumulator.isPermitted || currentValue.isPermitted; return accumulator; }; region.isPermitted = lcpRegionsTenantsMap[region.id].reduce(reducer).isPermitted; }); return new LcpRegionsAndTenants(lcpRegionList, lcpRegionsTenantsMap); }; public extractLcpRegionName(cloudRegionId: string, cloudOwner: string):string { return this.featureFlagsService.getFlagState(Features.FLAG_1810_CR_ADD_CLOUD_OWNER_TO_MSO_REQUEST) ? cloudRegionId+AaiService.formatCloudOwnerTrailer(cloudOwner) : cloudRegionId; }; public static formatCloudOwnerTrailer(cloudOwner: string):string { return " ("+ cloudOwner.trim().toLowerCase().replace(/^att-/, "").toUpperCase() + ")"; } getServiceTypes = (subscriberId): Observable => { console.log("AaiService:getSubscriptionServiceTypeList: globalCustomerId: " + subscriberId); if (_.has(this.store.getState().service.serviceTypes, subscriberId)) { return of( JSON.parse(JSON.stringify(this.store.getState().service.serviceTypes[subscriberId]))); } return this.getSubscriberDetails(subscriberId) .map(this.subDetailsResponseToServiceTypes) .do((res) => { this.store.dispatch(updateServiceTypes(res, subscriberId)); }); }; getSubscriberDetails = (subscriberId): Observable => { let pathQuery: string = Constants.Path.AAI_SUB_DETAILS_PATH + subscriberId + Constants.Path.ASSIGN + Math.random(); if (subscriberId != null) { return this.http.get(pathQuery); } }; subDetailsResponseToServiceTypes = (res: GetSubDetailsResponse): ServiceType[] => { if (res && res['service-subscriptions']) { const serviceSubscriptions = res['service-subscriptions']['service-subscription']; return serviceSubscriptions.map((subscription, index) => new ServiceType(String(index), subscription)) } else { return []; } }; public retrieveServiceInstanceTopology(serviceInstanceId : string, subscriberId: string, serviceType: string):Observable { let pathQuery: string = `${Constants.Path.AAI_GET_SERVICE_INSTANCE_TOPOLOGY_PATH}${subscriberId}/${serviceType}/${serviceInstanceId}`; return this.http.get(pathQuery); } public retrieveAndStoreServiceInstanceTopology(serviceInstanceId: string, subscriberId: string, serviceType: string, serviceModeId: string):Observable { return this.retrieveServiceInstanceTopology(serviceInstanceId, subscriberId, serviceType).do((service:ServiceInstance) => { this.store.dispatch(createServiceInstance(service, serviceModeId)); }); }; public retrieveServiceInstanceRetryTopology(jobId : string) :Observable { let pathQuery: string = `${Constants.Path.SERVICES_RETRY_TOPOLOGY}/${jobId}`; return this.http.get(pathQuery); // return of( // { // "action": "None", // "instanceName": "LXzQMx9clZl7D6ckJ", // "instanceId": "service-instance-id", // "orchStatus": "GARBAGE DATA", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "d27e42cf-087e-4d31-88ac-6c4b7585f800", // "modelVersionId": "6e59c5de-f052-46fa-aa7e-2fca9d674c44", // "modelName": "vf_vEPDG", // "modelType": "service", // "modelVersion": "5.0" // }, // "globalSubscriberId": "global-customer-id", // "subscriptionServiceType": "service-instance-type", // "owningEntityId": null, // "owningEntityName": null, // "tenantName": null, // "aicZoneId": null, // "aicZoneName": null, // "projectName": null, // "rollbackOnFailure": null, // "isALaCarte": false, // "vnfs": { // "1e918ade-3dc6-4cec-b952-3ff94ed82d1c": { // "action": "None", // "instanceName": "DgZuxjJy5LMIc3755", // "instanceId": "1e918ade-3dc6-4cec-b952-3ff94ed82d1c", // "orchStatus": null, // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "vnf-instance-model-invariant-id", // "modelVersionId": "vnf-instance-model-version-id", // "modelType": "vnf" // }, // "instanceType": "SXDBMhwdR9iO0g1Uv", // "provStatus": null, // "inMaint": false, // "uuid": "vnf-instance-model-version-id", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "1e918ade-3dc6-4cec-b952-3ff94ed82d1c", // "vfModules": {}, // "networks": { // "ff464c97-ea9c-4165-996a-fe400499af3e": { // "action": "None", // "instanceName": "ZI0quzIpu8TNXS7nl", // "instanceId": "ff464c97-ea9c-4165-996a-fe400499af3e", // "orchStatus": "Assigned", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "network-instance-model-invariant-id", // "modelVersionId": "network-instance-model-version-id", // "modelType": "network" // }, // "instanceType": "CONTRAIL30_BASIC", // "provStatus": "prov", // "inMaint": false, // "uuid": "network-instance-model-version-id", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "ff464c97-ea9c-4165-996a-fe400499af3e", // "isFailed": true // }, // "3e41d57c-8bb4-443e-af02-9f86487ba938": { // "action": "None", // "instanceName": "0i9asscqSLm7Poeb8", // "instanceId": "3e41d57c-8bb4-443e-af02-9f86487ba938", // "orchStatus": "Created", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "network-instance-model-invariant-id", // "modelVersionId": "network-instance-model-version-id", // "modelType": "network" // }, // "instanceType": "CONTRAIL30_BASIC", // "provStatus": "prov", // "inMaint": false, // "uuid": "network-instance-model-version-id", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "3e41d57c-8bb4-443e-af02-9f86487ba938", // "isFailed": true // } // }, // "isFailed": true // }, // "9a9b2705-c569-4f1b-9a67-13e9f86e6c55": { // "isFailed": true, // "action": "None", // "instanceName": "TFn0SYhrCUs7L3qWS", // "instanceId": "9a9b2705-c569-4f1b-9a67-13e9f86e6c55", // "orchStatus": null, // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelCustomizationName": "VF_vMee 0", // "modelInvariantId": "vnf-instance-model-invariant-id", // "modelVersionId": "d6557200-ecf2-4641-8094-5393ae3aae60", // "modelType": "vnf" // }, // "instanceType": "WIT68GUnH34VaGZgp", // "provStatus": null, // "inMaint": true, // "uuid": "d6557200-ecf2-4641-8094-5393ae3aae60", // "originalName": "VF_vMee 0", // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "9a9b2705-c569-4f1b-9a67-13e9f86e6c55", // "vfModules": { // "vf_vmee0..VfVmee..vmme_vlc..module-1": { // "2c1ca484-cbc2-408b-ab86-25a2c15ce280": { // "action": "None", // "instanceName": "ss820f_0918_db", // "instanceId": "2c1ca484-cbc2-408b-ab86-25a2c15ce280", // "orchStatus": "deleted", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelCustomizationName": "VfVmee..vmme_vlc..module-1", // "modelCustomizationId": "b200727a-1bf9-4e7c-bd06-b5f4c9d920b9", // "modelInvariantId": "09edc9ef-85d0-4b26-80de-1f569d49e750", // "modelVersionId": "522159d5-d6e0-4c2a-aa44-5a542a12a830", // "modelType": "vfModule" // }, // "instanceType": null, // "provStatus": null, // "inMaint": true, // "uuid": "522159d5-d6e0-4c2a-aa44-5a542a12a830", // "originalName": "VfVmee..vmme_vlc..module-1", // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "2c1ca484-cbc2-408b-ab86-25a2c15ce280", // "isBase": false, // "volumeGroupName": null, // "isFailed": true // } // }, // "dc229cd8-c132-4455-8517-5c1787c18b14": { // "3ef042c4-259f-45e0-9aba-0989bd8d1cc5": { // "action": "None", // "instanceName": "ss820f_0918_base", // "instanceId": "3ef042c4-259f-45e0-9aba-0989bd8d1cc5", // "orchStatus": "Assigned", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelCustomizationId": "8ad8670b-0541-4499-8101-275bbd0e8b6a", // "modelInvariantId": "1e463c9c-404d-4056-ba56-28fd102608de", // "modelVersionId": "dc229cd8-c132-4455-8517-5c1787c18b14", // "modelType": "vfModule" // }, // "instanceType": null, // "provStatus": null, // "inMaint": false, // "uuid": "dc229cd8-c132-4455-8517-5c1787c18b14", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "3ef042c4-259f-45e0-9aba-0989bd8d1cc5", // "isBase": true, // "volumeGroupName": null // } // } // }, // "networks": {} // } // }, // "networks": { // "e1edb09e-e68b-4ebf-adb8-e2587be56257": { // "action": "None", // "instanceName": "cNpGlYQDsmrUDK5iG", // "instanceId": "e1edb09e-e68b-4ebf-adb8-e2587be56257", // "orchStatus": "Created", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "network-instance-model-invariant-id", // "modelVersionId": "ddc3f20c-08b5-40fd-af72-c6d14636b986", // "modelType": "network" // }, // "instanceType": "CONTRAIL30_HIMELGUARD", // "provStatus": "preprov", // "inMaint": false, // "uuid": "ddc3f20c-08b5-40fd-af72-c6d14636b986", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "e1edb09e-e68b-4ebf-adb8-e2587be56257" // }, // "de4b5203-ad1c-4f2b-8843-5236fb8dc9ba": { // "action": "None", // "instanceName": "EI9QlSRVK0lon54Cb", // "instanceId": "de4b5203-ad1c-4f2b-8843-5236fb8dc9ba", // "orchStatus": "Assigned", // "productFamilyId": null, // "lcpCloudRegionId": null, // "tenantId": null, // "modelInfo": { // "modelInvariantId": "network-instance-model-invariant-id", // "modelVersionId": "ddc3f20c-08b5-40fd-af72-c6d14636b986", // "modelType": "network" // }, // "instanceType": "CONTRAIL30_BASIC", // "provStatus": "nvtprov", // "inMaint": false, // "uuid": "ddc3f20c-08b5-40fd-af72-c6d14636b986", // "originalName": null, // "legacyRegion": null, // "lineOfBusiness": null, // "platformName": null, // "trackById": "de4b5203-ad1c-4f2b-8843-5236fb8dc9ba", // "isFailed": true // } // }, // "vnfGroups": {}, // "validationCounter": 0, // "existingVNFCounterMap": { // "vnf-instance-model-version-id": 1, // "d6557200-ecf2-4641-8094-5393ae3aae60": 1 // }, // "existingNetworksCounterMap": { // "ddc3f20c-08b5-40fd-af72-c6d14636b986": 2 // }, // "existingVnfGroupCounterMap": {} // } // ); } public retrieveAndStoreServiceInstanceRetryTopology(jobId: string, serviceModeId : string):Observable { return this.retrieveServiceInstanceRetryTopology(jobId).do((service:ServiceInstance) => { this.store.dispatch(createServiceInstance(service, serviceModeId)); }); }; public getOptionalGroupMembers(serviceModelId: string, subscriberId: string, serviceType: string, serviceInvariantId: string, groupType: string, groupRole: string): Observable { let pathQuery: string = `${Constants.Path.AAI_GET_SERVICE_GROUP_MEMBERS_PATH}${subscriberId}/${serviceType}/${serviceInvariantId}/${groupType}/${groupRole}`; if(_.has(this.store.getState().service.serviceInstance[serviceModelId].optionalGroupMembersMap,pathQuery)){ return of( JSON.parse(JSON.stringify(this.store.getState().service.serviceInstance[serviceModelId].optionalGroupMembersMap[pathQuery]))); } return this.http.get(pathQuery) .do((res) => { this.store.dispatch(setOptionalMembersVnfGroupInstance(serviceModelId, pathQuery, res)) }); // let res = Observable.of((JSON.parse(JSON.stringify(this.loadMockMembers())))); // return res; } //TODO: make other places use this function extractSubscriberNameBySubscriberId(subscriberId: string) { let result: string = null; let filteredArray: any = _.filter(this.store.getState().service.subscribers, function (o: Subscriber) { return o.id === subscriberId }); if (filteredArray.length > 0) { result = filteredArray[0].name; } return result; } loadMockMembers(): any { return [ { "action":"None", "instanceName":"VNF1_INSTANCE_NAME", "instanceId":"VNF1_INSTANCE_ID", "orchStatus":null, "productFamilyId":null, "lcpCloudRegionId":"mtn23b", "tenantId":"3e9a20a3e89e45f884e09df0cc2d2d2a", "tenantName":"APPC-24595-T-IST-02C", "modelInfo":{ "modelInvariantId":"vnf-instance-model-invariant-id", "modelVersionId":"7a6ee536-f052-46fa-aa7e-2fca9d674c44", "modelVersion":"2.0", "modelName":"vf_vEPDG", "modelType":"vnf" }, "instanceType":"VNF1_INSTANCE_TYPE", "provStatus":null, "inMaint":false, "uuid":"7a6ee536-f052-46fa-aa7e-2fca9d674c44", "originalName":null, "legacyRegion":null, "lineOfBusiness":null, "platformName":null, "trackById":"7a6ee536-f052-46fa-aa7e-2fca9d674c44:002", "serviceInstanceId":"service-instance-id1", "serviceInstanceName":"service-instance-name" }, { "action":"None", "instanceName":"VNF2_INSTANCE_NAME", "instanceId":"VNF2_INSTANCE_ID", "orchStatus":null, "productFamilyId":null, "lcpCloudRegionId":"mtn23b", "tenantId":"3e9a20a3e89e45f884e09df0cc2d2d2a", "tenantName":"APPC-24595-T-IST-02C", "modelInfo":{ "modelInvariantId":"vnf-instance-model-invariant-id", "modelVersionId":"eb5f56bf-5855-4e61-bd00-3e19a953bf02", "modelVersion":"1.0", "modelName":"vf_vEPDG", "modelType":"vnf" }, "instanceType":"VNF2_INSTANCE_TYPE", "provStatus":null, "inMaint":true, "uuid":"eb5f56bf-5855-4e61-bd00-3e19a953bf02", "originalName":null, "legacyRegion":null, "lineOfBusiness":null, "platformName":null, "trackById":"eb5f56bf-5855-4e61-bd00-3e19a953bf02:003", "serviceInstanceId":"service-instance-id2", "serviceInstanceName":"service-instance-name" } ] } }