diff options
Diffstat (limited to 'dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen')
14 files changed, 1277 insertions, 0 deletions
diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/DcaeInventory.yaml b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/DcaeInventory.yaml new file mode 100644 index 0000000..6584d46 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/DcaeInventory.yaml @@ -0,0 +1,93 @@ +operations: + DcaeInventory@getDcaeServiceTypes: {} + DcaeInventory@deleteDcaeServiceTypesType: {} + DcaeInventory@getDcaeServiceTypesType: {} + DcaeInventory@createDcaeServiceTypesTypeName: {} + DcaeInventory@getDcaeServices: {} + DcaeInventory@getDcaeServicesGroupbyPropertyName: {} + DcaeInventory@deleteDcaeServicesService: {} + DcaeInventory@getDcaeServicesService: {} + DcaeInventory@createDcaeServicesService: {} + DcaeInventory@poll: {} +messages: + dummy: {} + REQUEST-FAILED-getDcaeServiceTypes: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-deleteDcaeServiceTypesType: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-getDcaeServiceTypesType: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-createDcaeServiceTypesTypeName: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-getDcaeServices: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-getDcaeServicesGroupbyPropertyName: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-deleteDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-getDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-createDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REQUEST-FAILED-poll: + errorCode: 4001W + messageFormat: '{0}' + description: Operation Failed with Exception + REMOTE-CALL-FAILED-getDcaeServiceTypes: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-deleteDcaeServiceTypesType: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-getDcaeServiceTypesType: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-createDcaeServiceTypesTypeName: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-getDcaeServices: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-getDcaeServicesGroupbyPropertyName: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-deleteDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-getDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-createDcaeServicesService: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception + REMOTE-CALL-FAILED-poll: + errorCode: 4001W + messageFormat: '{0}' + description: Remote Operation Failed with Exception diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerConsole.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerConsole.java index 0ad6540..6a838b2 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerConsole.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerConsole.java @@ -33,6 +33,8 @@ import org.openecomp.ncomp.sirius.manager.ManagementServerError; +import org.openecomp.dcae.controller.platform.servers.controller.inventory.DcaeDcaeInventoryConsole; + import org.openecomp.dcae.controller.platform.servers.controller.gui.DcaeGuiClientApiConsole; @@ -43,6 +45,7 @@ public class DcaeDcaePlatformControllerConsole extends Console { DcaeControllerClusterConsole cluster; DcaeControllerVirtualMachineServiceConsole cont; + DcaeDcaeInventoryConsole inventory; DcaeGuiClientApiConsole gui; @@ -53,6 +56,7 @@ public class DcaeDcaePlatformControllerConsole extends Console { cluster = new DcaeControllerClusterConsole(filename,name); cont = new DcaeControllerVirtualMachineServiceConsole(filename,name); + inventory = new DcaeDcaeInventoryConsole(filename,name); gui = new DcaeGuiClientApiConsole(filename,name); } diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerServer.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerServer.java index a8f99eb..e8f5040 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerServer.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/DcaeDcaePlatformControllerServer.java @@ -45,6 +45,8 @@ import org.openecomp.dcae.controller.platform.servers.controller.DcaeControllerF import org.openecomp.dcae.controller.platform.servers.controller.DcaeControllerFactory; +import org.openecomp.dcae.controller.platform.servers.controller.inventory.DcaeInventoryFactory; + import org.openecomp.dcae.controller.platform.servers.controller.gui.DcaeModelFactory; @@ -68,6 +70,9 @@ public class DcaeDcaePlatformControllerServer implements ISiriusServer, IRequest String contPath; ManagementServer contServer; + String inventoryPath; + ManagementServer inventoryServer; + String guiPath; ManagementServer guiServer; @@ -102,6 +107,12 @@ public class DcaeDcaePlatformControllerServer implements ISiriusServer, IRequest + EFactory inventoryFactory = new DcaeInventoryFactory(this); + inventoryPath = serverPath + "/inventory"; + inventoryServer = new ManagementServer(inventoryFactory, "DcaeInventory", inventoryPath, "inventory.properties"); + inventoryServer.start(); + webServer.add("/inventory",inventoryServer); + EFactory guiFactory = new DcaeModelFactory(this); guiPath = serverPath + "/gui"; guiServer = new ManagementServer(guiFactory, "GuiClientApi", guiPath, "gui.properties"); diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventory.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventory.java new file mode 100644 index 0000000..3d41661 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventory.java @@ -0,0 +1,368 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit. No need to extend this class. +package org.openecomp.dcae.controller.platform.servers.controller.inventory; + + + + + +import java.io.InputStream; + +import org.openecomp.ncomp.sirius.manager.IRequestHandler; +import org.openecomp.ncomp.sirius.manager.ISwaggerHandler; +import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; +import org.openecomp.ncomp.sirius.manager.ISiriusProvider; +import org.openecomp.ncomp.sirius.manager.ManagementServer; +import org.openecomp.ncomp.sirius.manager.SwaggerUtils; +import org.openecomp.ncomp.sirius.function.FunctionUtils; +import org.openecomp.ncomp.component.ApiRequestStatus; + +import org.apache.log4j.Logger; + +import org.openecomp.ncomp.sirius.manager.logging.NcompLogger; +import org.openecomp.logger.StatusCodeEnum; +import org.openecomp.logger.EcompException; + +import org.eclipse.emf.common.util.EList; +import org.eclipse.emf.ecore.EObject; +import org.json.JSONObject; + +import java.util.Date; + +import org.openecomp.dcae.controller.platform.servers.controller.inventory.logging.DcaeInventoryOperationEnum; +import org.openecomp.dcae.controller.platform.servers.controller.inventory.logging.DcaeInventoryMessageEnum; + + + + +import org.openecomp.dcae.controller.inventory.impl.DcaeInventoryImpl; + + + +public class DcaeDcaeInventory extends DcaeInventoryImpl implements ISiriusProvider { + public static final Logger logger = Logger.getLogger(DcaeDcaeInventory.class); + static final NcompLogger ecomplogger = NcompLogger.getNcompLogger(); + public DcaeDcaeInventoryProvider controller; + ISiriusServer server; + + public DcaeDcaeInventory(ISiriusServer server) { + this.server = server; + this.controller = new DcaeDcaeInventoryProvider(server,this); + } + + public org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults getDcaeServiceTypes(java.lang.String typeName, java.lang.Boolean onlyLatest, java.lang.Boolean onlyActive, java.lang.String vnfType, java.lang.String serviceId, java.lang.String serviceLocation, java.lang.String asdcServiceId, java.lang.String asdcResourceId, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypes", ApiRequestStatus.START, duration_,typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypes,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypes,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.getDcaeServiceTypes(typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypes", ApiRequestStatus.ERROR, duration_,typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypes, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypes,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypes, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypes", ApiRequestStatus.OKAY, duration_,typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + return res; + } + + public org.openecomp.dcae.controller.inventory.ApiResponseMessage deleteDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.ApiResponseMessage res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServiceTypesType", ApiRequestStatus.START, duration_,typeId); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServiceTypesType,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServiceTypesType,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.deleteDcaeServiceTypesType(typeId); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServiceTypesType", ApiRequestStatus.ERROR, duration_,typeId); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServiceTypesType, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServiceTypesType,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServiceTypesType, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServiceTypesType", ApiRequestStatus.OKAY, duration_,typeId); + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType getDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypesType", ApiRequestStatus.START, duration_,typeId); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypesType,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypesType,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.getDcaeServiceTypesType(typeId); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypesType", ApiRequestStatus.ERROR, duration_,typeId); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypesType, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypesType,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServiceTypesType, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServiceTypesType", ApiRequestStatus.OKAY, duration_,typeId); + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType createDcaeServiceTypesTypeName(org.openecomp.dcae.controller.inventory.DCAEServiceTypeRequest body) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServiceTypesTypeName", ApiRequestStatus.START, duration_,body); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServiceTypesTypeName,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServiceTypesTypeName,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.createDcaeServiceTypesTypeName(body); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServiceTypesTypeName", ApiRequestStatus.ERROR, duration_,body); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServiceTypesTypeName, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServiceTypesTypeName,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServiceTypesTypeName, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServiceTypesTypeName", ApiRequestStatus.OKAY, duration_,body); + return res; + } + + public org.openecomp.dcae.controller.inventory.DcaeServiceResults getDcaeServices(java.lang.String typeId, java.lang.String vnfId, java.lang.String vnfType, java.lang.String vnfLocation, java.lang.String componentType, java.lang.Boolean shareable, java.lang.String created, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceResults res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServices", ApiRequestStatus.START, duration_,typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServices,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServices,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.getDcaeServices(typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServices", ApiRequestStatus.ERROR, duration_,typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServices, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServices,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServices, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServices", ApiRequestStatus.OKAY, duration_,typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults getDcaeServicesGroupbyPropertyName(java.lang.String propertyName) { + org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesGroupbyPropertyName", ApiRequestStatus.START, duration_,propertyName); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesGroupbyPropertyName,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesGroupbyPropertyName,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.getDcaeServicesGroupbyPropertyName(propertyName); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesGroupbyPropertyName", ApiRequestStatus.ERROR, duration_,propertyName); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesGroupbyPropertyName, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesGroupbyPropertyName,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesGroupbyPropertyName, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesGroupbyPropertyName", ApiRequestStatus.OKAY, duration_,propertyName); + return res; + } + + public void deleteDcaeServicesService(java.lang.String serviceId) { + + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServicesService", ApiRequestStatus.START, duration_,serviceId); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServicesService,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServicesService,"self:" + ManagementServer.object2ref(this)); + try { + controller.deleteDcaeServicesService(serviceId); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServicesService", ApiRequestStatus.ERROR, duration_,serviceId); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_deleteDcaeServicesService, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "deleteDcaeServicesService", ApiRequestStatus.OKAY, duration_,serviceId); + + } + + public org.openecomp.dcae.controller.inventory.DCAEService getDcaeServicesService(java.lang.String serviceId) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesService", ApiRequestStatus.START, duration_,serviceId); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesService,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesService,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.getDcaeServicesService(serviceId); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesService", ApiRequestStatus.ERROR, duration_,serviceId); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_getDcaeServicesService, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "getDcaeServicesService", ApiRequestStatus.OKAY, duration_,serviceId); + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEService createDcaeServicesService(java.lang.String serviceId, org.openecomp.dcae.controller.inventory.DCAEServiceRequest body) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServicesService", ApiRequestStatus.START, duration_,serviceId,body); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServicesService,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServicesService,"self:" + ManagementServer.object2ref(this)); + try { + res = controller.createDcaeServicesService(serviceId,body); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServicesService", ApiRequestStatus.ERROR, duration_,serviceId,body); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_createDcaeServicesService, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "createDcaeServicesService", ApiRequestStatus.OKAY, duration_,serviceId,body); + return res; + } + + public void poll() { + + long duration_ = 0; + if (server != null) + server.getServer().recordApi(null, this, "poll", ApiRequestStatus.START, duration_); + Date now_ = new Date(); + ecomplogger.recordAuditEventStartIfNeeded(DcaeInventoryOperationEnum.DcaeInventory_poll,server,this); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_poll,"self:" + ManagementServer.object2ref(this)); + try { + controller.poll(); + } + catch (Exception e) { + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "poll", ApiRequestStatus.ERROR, duration_); + System.err.println("ERROR: " + e); + ecomplogger.warn(DcaeInventoryMessageEnum.REQUEST_FAILED_poll, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REQUEST_FAILED_poll,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR, DcaeInventoryMessageEnum.REQUEST_FAILED_poll, e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + duration_ = new Date().getTime()-now_.getTime(); + if (server != null) + server.getServer().recordApi(null, this, "poll", ApiRequestStatus.OKAY, duration_); + + } + + + + + + + + + public static void ecoreSetup() { + DcaeDcaeInventoryProvider.ecoreSetup(); + } + public DcaeDcaeInventoryProvider getSiriusProvider() { + return controller; + } +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryClient.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryClient.java new file mode 100644 index 0000000..7d39e55 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryClient.java @@ -0,0 +1,258 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit. No need to extend this class. +package org.openecomp.dcae.controller.platform.servers.controller.inventory; + +import org.openecomp.ncomp.sirius.manager.AbstractClient; +import org.openecomp.ncomp.sirius.manager.HighAvailabilityClient; +import org.openecomp.ncomp.sirius.manager.GenericHttpClient; + +import org.apache.log4j.Logger; + +import org.openecomp.logger.EcompLogger; +import org.openecomp.logger.StatusCodeEnum; +import org.openecomp.logger.EcompException; + +import org.eclipse.emf.common.util.EList; +import org.eclipse.emf.ecore.EClass; + +import org.openecomp.dcae.controller.inventory.impl.DcaeInventoryImpl; +import org.openecomp.dcae.controller.inventory.InventoryPackage; +import org.openecomp.dcae.controller.platform.servers.controller.inventory.logging.DcaeInventoryOperationEnum; +import org.openecomp.dcae.controller.platform.servers.controller.inventory.logging.DcaeInventoryMessageEnum; + + +import org.openecomp.dcae.controller.platform.servers.controller.DcaeDcaePlatformController; + + + + +@SuppressWarnings("unchecked") +public class DcaeDcaeInventoryClient extends DcaeInventoryImpl { + public static final Logger logger = Logger.getLogger(DcaeDcaeInventoryClient.class); + static final EcompLogger ecomplogger = EcompLogger.getEcompLogger(); + public AbstractClient client; + + public DcaeDcaeInventoryClient(String file, String name) { + DcaeDcaePlatformController.ecoreSetup(); + client = new GenericHttpClient(file,name); + client.add("/inventory", this); + client.setVersion("ONAP-R2"); + } + + public DcaeDcaeInventoryClient(String file, String name1, String name2) { + HighAvailabilityClient client1 = new HighAvailabilityClient(file,name1,name2); + client = client1.all; // requests should be forwarded to all. + client.add("/inventory", this); + client.setVersion("ONAP-R2"); + } + + public DcaeDcaeInventoryClient(AbstractClient c) { + client = c; + client.add("/resources", this); + client.setVersion("ONAP-R2"); + } + + + + @Override + public org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults getDcaeServiceTypes(java.lang.String typeName, java.lang.Boolean onlyLatest, java.lang.Boolean onlyActive, java.lang.String vnfType, java.lang.String serviceId, java.lang.String serviceLocation, java.lang.String asdcServiceId, java.lang.String asdcResourceId, java.lang.Integer offset) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypes,client.getRemote()); + org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults res; + try { + res = (org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults) client.operationPath("/inventory", c, "getDcaeServiceTypes", null, typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypes, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypes,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypes,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.ApiResponseMessage deleteDcaeServiceTypesType(java.lang.String typeId) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServiceTypesType,client.getRemote()); + org.openecomp.dcae.controller.inventory.ApiResponseMessage res; + try { + res = (org.openecomp.dcae.controller.inventory.ApiResponseMessage) client.operationPath("/inventory", c, "deleteDcaeServiceTypesType", null, typeId); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServiceTypesType, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServiceTypesType,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServiceTypesType,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.DCAEServiceType getDcaeServiceTypesType(java.lang.String typeId) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServiceTypesType,client.getRemote()); + org.openecomp.dcae.controller.inventory.DCAEServiceType res; + try { + res = (org.openecomp.dcae.controller.inventory.DCAEServiceType) client.operationPath("/inventory", c, "getDcaeServiceTypesType", null, typeId); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypesType, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypesType,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServiceTypesType,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.DCAEServiceType createDcaeServiceTypesTypeName(org.openecomp.dcae.controller.inventory.DCAEServiceTypeRequest body) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServiceTypesTypeName,client.getRemote()); + org.openecomp.dcae.controller.inventory.DCAEServiceType res; + try { + res = (org.openecomp.dcae.controller.inventory.DCAEServiceType) client.operationPath("/inventory", c, "createDcaeServiceTypesTypeName", null, body); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServiceTypesTypeName, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServiceTypesTypeName,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServiceTypesTypeName,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.DcaeServiceResults getDcaeServices(java.lang.String typeId, java.lang.String vnfId, java.lang.String vnfType, java.lang.String vnfLocation, java.lang.String componentType, java.lang.Boolean shareable, java.lang.String created, java.lang.Integer offset) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServices,client.getRemote()); + org.openecomp.dcae.controller.inventory.DcaeServiceResults res; + try { + res = (org.openecomp.dcae.controller.inventory.DcaeServiceResults) client.operationPath("/inventory", c, "getDcaeServices", null, typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServices, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServices,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServices,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults getDcaeServicesGroupbyPropertyName(java.lang.String propertyName) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesGroupbyPropertyName,client.getRemote()); + org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults res; + try { + res = (org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults) client.operationPath("/inventory", c, "getDcaeServicesGroupbyPropertyName", null, propertyName); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesGroupbyPropertyName, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesGroupbyPropertyName,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesGroupbyPropertyName,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public void deleteDcaeServicesService(java.lang.String serviceId) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_deleteDcaeServicesService,client.getRemote()); + + try { + client.operationPath("/inventory", c, "deleteDcaeServicesService", null, serviceId); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_deleteDcaeServicesService,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + + } + + @Override + public org.openecomp.dcae.controller.inventory.DCAEService getDcaeServicesService(java.lang.String serviceId) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_getDcaeServicesService,client.getRemote()); + org.openecomp.dcae.controller.inventory.DCAEService res; + try { + res = (org.openecomp.dcae.controller.inventory.DCAEService) client.operationPath("/inventory", c, "getDcaeServicesService", null, serviceId); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_getDcaeServicesService,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public org.openecomp.dcae.controller.inventory.DCAEService createDcaeServicesService(java.lang.String serviceId, org.openecomp.dcae.controller.inventory.DCAEServiceRequest body) { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_createDcaeServicesService,client.getRemote()); + org.openecomp.dcae.controller.inventory.DCAEService res; + try { + res = (org.openecomp.dcae.controller.inventory.DCAEService) client.operationPath("/inventory", c, "createDcaeServicesService", null, serviceId,body); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServicesService, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServicesService,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_createDcaeServicesService,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + return res; + } + + @Override + public void poll() { + EClass c = InventoryPackage.eINSTANCE.getDcaeInventory(); + ecomplogger.recordMetricEventStart(DcaeInventoryOperationEnum.DcaeInventory_poll,client.getRemote()); + + try { + client.operationPath("/inventory", c, "poll", null); + } + catch (Exception e) { + ecomplogger.warn(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_poll, e.toString()); + EcompException e1 = EcompException.create(DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_poll,e,e.getMessage()); + ecomplogger.recordMetricEventEnd(StatusCodeEnum.ERROR,DcaeInventoryMessageEnum.REMOTE_CALL_FAILED_poll,e.getMessage()); + throw e1; + } + ecomplogger.recordMetricEventEnd(); + + } + +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryConsole.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryConsole.java new file mode 100644 index 0000000..6ff8ba7 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryConsole.java @@ -0,0 +1,167 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit but extend this class as needed +package org.openecomp.dcae.controller.platform.servers.controller.inventory; + + +import org.apache.log4j.Logger; +import org.eclipse.emf.common.util.EList; + +import org.openecomp.ncomp.sirius.manager.console.Console; +import org.openecomp.ncomp.sirius.manager.AbstractClient; +import org.openecomp.ncomp.sirius.manager.ManagementServerError; + + + + +public class DcaeDcaeInventoryConsole extends Console { + public static final Logger logger = Logger.getLogger(DcaeDcaeInventoryConsole.class); + protected DcaeDcaeInventoryClient controller; + + + + + public DcaeDcaeInventoryConsole(String filename, String name) { + super(filename, name); + controller = new DcaeDcaeInventoryClient(filename,name); + client = controller.client; + + } + + public DcaeDcaeInventoryConsole(AbstractClient c) { + controller = new DcaeDcaeInventoryClient(c); + client = controller.client; + } + + + public org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults getDcaeServiceTypes(java.lang.String typeName, java.lang.Boolean onlyLatest, java.lang.Boolean onlyActive, java.lang.String vnfType, java.lang.String serviceId, java.lang.String serviceLocation, java.lang.String asdcServiceId, java.lang.String asdcResourceId, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults res = null; + try { + res = controller.getDcaeServiceTypes(typeName,onlyLatest,onlyActive,vnfType,serviceId,serviceLocation,asdcServiceId,asdcResourceId,offset); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.ApiResponseMessage deleteDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.ApiResponseMessage res = null; + try { + res = controller.deleteDcaeServiceTypesType(typeId); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType getDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + try { + res = controller.getDcaeServiceTypesType(typeId); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType createDcaeServiceTypesTypeName(org.openecomp.dcae.controller.inventory.DCAEServiceTypeRequest body) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + try { + res = controller.createDcaeServiceTypesTypeName(body); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.DcaeServiceResults getDcaeServices(java.lang.String typeId, java.lang.String vnfId, java.lang.String vnfType, java.lang.String vnfLocation, java.lang.String componentType, java.lang.Boolean shareable, java.lang.String created, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceResults res = null; + try { + res = controller.getDcaeServices(typeId,vnfId,vnfType,vnfLocation,componentType,shareable,created,offset); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults getDcaeServicesGroupbyPropertyName(java.lang.String propertyName) { + org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults res = null; + try { + res = controller.getDcaeServicesGroupbyPropertyName(propertyName); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public void deleteDcaeServicesService(java.lang.String serviceId) { + + try { + controller.deleteDcaeServicesService(serviceId); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + + } + + public org.openecomp.dcae.controller.inventory.DCAEService getDcaeServicesService(java.lang.String serviceId) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + try { + res = controller.getDcaeServicesService(serviceId); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public org.openecomp.dcae.controller.inventory.DCAEService createDcaeServicesService(java.lang.String serviceId, org.openecomp.dcae.controller.inventory.DCAEServiceRequest body) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + try { + res = controller.createDcaeServicesService(serviceId,body); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + return res; + } + + public void poll() { + + try { + controller.poll(); + } + catch (ManagementServerError e) { + System.err.println("ERROR: " + e.getJson().toString(2)); + } + + } + +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryProviderTemplate.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryProviderTemplate.java new file mode 100644 index 0000000..bfdb66b --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeDcaeInventoryProviderTemplate.java @@ -0,0 +1,123 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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.openecomp.dcae.controller.platform.servers.controller.inventory; + + + + + +import java.io.InputStream; + +import org.openecomp.ncomp.sirius.manager.IRequestHandler; +import org.openecomp.ncomp.sirius.manager.ISiriusPlugin; +import org.openecomp.ncomp.sirius.manager.ISiriusServer; +import org.openecomp.ncomp.sirius.function.FunctionUtils; + +import org.apache.log4j.Logger; +import org.eclipse.emf.common.util.EList; +import org.json.JSONObject; + + + +import org.openecomp.ncomp.sirius.manager.BasicAdaptorProvider; + + +import org.openecomp.dcae.controller.inventory.impl.DcaeInventoryImpl; +import org.openecomp.dcae.controller.inventory.DcaeInventory; + + +public class DcaeDcaeInventoryProviderTemplate extends BasicAdaptorProvider { + private static final Logger logger = Logger.getLogger(DcaeDcaeInventoryProviderTemplate.class); + DcaeInventory o; + + public DcaeDcaeInventoryProviderTemplate(ISiriusServer controller, DcaeInventory o) { + super(controller, o); + this.o = o; + } + + public org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults getDcaeServiceTypes(java.lang.String typeName, java.lang.Boolean onlyLatest, java.lang.Boolean onlyActive, java.lang.String vnfType, java.lang.String serviceId, java.lang.String serviceLocation, java.lang.String asdcServiceId, java.lang.String asdcResourceId, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceTypeResults res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.ApiResponseMessage deleteDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.ApiResponseMessage res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType getDcaeServiceTypesType(java.lang.String typeId) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceType createDcaeServiceTypesTypeName(org.openecomp.dcae.controller.inventory.DCAEServiceTypeRequest body) { + org.openecomp.dcae.controller.inventory.DCAEServiceType res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DcaeServiceResults getDcaeServices(java.lang.String typeId, java.lang.String vnfId, java.lang.String vnfType, java.lang.String vnfLocation, java.lang.String componentType, java.lang.Boolean shareable, java.lang.String created, java.lang.Integer offset) { + org.openecomp.dcae.controller.inventory.DcaeServiceResults res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults getDcaeServicesGroupbyPropertyName(java.lang.String propertyName) { + org.openecomp.dcae.controller.inventory.DCAEServiceGroupByResults res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public void deleteDcaeServicesService(java.lang.String serviceId) { + + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DCAEService getDcaeServicesService(java.lang.String serviceId) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public org.openecomp.dcae.controller.inventory.DCAEService createDcaeServicesService(java.lang.String serviceId, org.openecomp.dcae.controller.inventory.DCAEServiceRequest body) { + org.openecomp.dcae.controller.inventory.DCAEService res = null; + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + public void poll() { + + // TODO IMPLEMENT + throw new UnsupportedOperationException(); + } + + + + + + +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeInventoryFactory.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeInventoryFactory.java new file mode 100644 index 0000000..2967515 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/DcaeInventoryFactory.java @@ -0,0 +1,54 @@ + +/*- + * ============LICENSE_START========================================== + * OPENECOMP - DCAE + * =================================================================== + * 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============================================ + */ + +// Autogenerated +// Do not edit. No need to extend this class. +package org.openecomp.dcae.controller.platform.servers.controller.inventory; + +import org.eclipse.emf.ecore.EPackage; +import org.apache.log4j.Logger; + +import org.openecomp.ncomp.sirius.manager.ISiriusServer; + +import org.openecomp.dcae.controller.inventory.DcaeInventory; +import org.openecomp.dcae.controller.inventory.InventoryPackage; +import org.openecomp.dcae.controller.inventory.impl.InventoryFactoryImpl; + +import org.openecomp.dcae.controller.platform.servers.controller.DcaeDcaePlatformControllerServer; + + + +public class DcaeInventoryFactory extends InventoryFactoryImpl { + public static final Logger logger = Logger.getLogger(DcaeInventoryFactory.class); + ISiriusServer server = null; + @Override + public EPackage getEPackage() { return InventoryPackage.eINSTANCE; } + public DcaeInventoryFactory(ISiriusServer server) { + this.server = server; + } + @Override + public DcaeInventory createDcaeInventory() { + return new DcaeDcaeInventory(server); + } + + + +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventory.properties b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventory.properties new file mode 100644 index 0000000..911d8ac --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventory.properties @@ -0,0 +1,126 @@ + +dummy=\ + dummy-null|\ + null|\ + null|\ + null + +REQUEST_FAILED_getDcaeServiceTypes=\ + REQUEST-FAILED-getDcaeServiceTypes-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_deleteDcaeServiceTypesType=\ + REQUEST-FAILED-deleteDcaeServiceTypesType-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_getDcaeServiceTypesType=\ + REQUEST-FAILED-getDcaeServiceTypesType-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_createDcaeServiceTypesTypeName=\ + REQUEST-FAILED-createDcaeServiceTypesTypeName-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_getDcaeServices=\ + REQUEST-FAILED-getDcaeServices-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_getDcaeServicesGroupbyPropertyName=\ + REQUEST-FAILED-getDcaeServicesGroupbyPropertyName-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_deleteDcaeServicesService=\ + REQUEST-FAILED-deleteDcaeServicesService-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_getDcaeServicesService=\ + REQUEST-FAILED-getDcaeServicesService-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_createDcaeServicesService=\ + REQUEST-FAILED-createDcaeServicesService-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REQUEST_FAILED_poll=\ + REQUEST-FAILED-poll-4001W|\ + {0}|\ + null|\ + Operation Failed with Exception + +REMOTE_CALL_FAILED_getDcaeServiceTypes=\ + REMOTE-CALL-FAILED-getDcaeServiceTypes-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_deleteDcaeServiceTypesType=\ + REMOTE-CALL-FAILED-deleteDcaeServiceTypesType-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_getDcaeServiceTypesType=\ + REMOTE-CALL-FAILED-getDcaeServiceTypesType-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_createDcaeServiceTypesTypeName=\ + REMOTE-CALL-FAILED-createDcaeServiceTypesTypeName-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_getDcaeServices=\ + REMOTE-CALL-FAILED-getDcaeServices-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_getDcaeServicesGroupbyPropertyName=\ + REMOTE-CALL-FAILED-getDcaeServicesGroupbyPropertyName-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_deleteDcaeServicesService=\ + REMOTE-CALL-FAILED-deleteDcaeServicesService-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_getDcaeServicesService=\ + REMOTE-CALL-FAILED-getDcaeServicesService-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_createDcaeServicesService=\ + REMOTE-CALL-FAILED-createDcaeServicesService-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception + +REMOTE_CALL_FAILED_poll=\ + REMOTE-CALL-FAILED-poll-4001W|\ + {0}|\ + null|\ + Remote Operation Failed with Exception diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryMessageEnum.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryMessageEnum.java new file mode 100644 index 0000000..460ac99 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryMessageEnum.java @@ -0,0 +1,34 @@ + +package org.openecomp.dcae.controller.platform.servers.controller.inventory.logging; + +import com.att.eelf.i18n.EELFResourceManager; +import org.openecomp.logger.EcompMessageEnum; + +public enum DcaeInventoryMessageEnum implements EcompMessageEnum { + + dummy, + REQUEST_FAILED_getDcaeServiceTypes, + REQUEST_FAILED_deleteDcaeServiceTypesType, + REQUEST_FAILED_getDcaeServiceTypesType, + REQUEST_FAILED_createDcaeServiceTypesTypeName, + REQUEST_FAILED_getDcaeServices, + REQUEST_FAILED_getDcaeServicesGroupbyPropertyName, + REQUEST_FAILED_deleteDcaeServicesService, + REQUEST_FAILED_getDcaeServicesService, + REQUEST_FAILED_createDcaeServicesService, + REQUEST_FAILED_poll, + REMOTE_CALL_FAILED_getDcaeServiceTypes, + REMOTE_CALL_FAILED_deleteDcaeServiceTypesType, + REMOTE_CALL_FAILED_getDcaeServiceTypesType, + REMOTE_CALL_FAILED_createDcaeServiceTypesTypeName, + REMOTE_CALL_FAILED_getDcaeServices, + REMOTE_CALL_FAILED_getDcaeServicesGroupbyPropertyName, + REMOTE_CALL_FAILED_deleteDcaeServicesService, + REMOTE_CALL_FAILED_getDcaeServicesService, + REMOTE_CALL_FAILED_createDcaeServicesService, + REMOTE_CALL_FAILED_poll; + + static { + EELFResourceManager.loadMessageBundle("org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventory"); + } +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryOperationEnum.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryOperationEnum.java new file mode 100644 index 0000000..920dfb4 --- /dev/null +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/inventory/logging/DcaeInventoryOperationEnum.java @@ -0,0 +1,31 @@ + +package org.openecomp.dcae.controller.platform.servers.controller.inventory.logging; + +import org.openecomp.entity.EcompOperationEnum; + +public enum DcaeInventoryOperationEnum implements EcompOperationEnum { + + DcaeInventory_getDcaeServiceTypes("DcaeInventory@getDcaeServiceTypes"), + DcaeInventory_deleteDcaeServiceTypesType("DcaeInventory@deleteDcaeServiceTypesType"), + DcaeInventory_getDcaeServiceTypesType("DcaeInventory@getDcaeServiceTypesType"), + DcaeInventory_createDcaeServiceTypesTypeName("DcaeInventory@createDcaeServiceTypesTypeName"), + DcaeInventory_getDcaeServices("DcaeInventory@getDcaeServices"), + DcaeInventory_getDcaeServicesGroupbyPropertyName("DcaeInventory@getDcaeServicesGroupbyPropertyName"), + DcaeInventory_deleteDcaeServicesService("DcaeInventory@deleteDcaeServicesService"), + DcaeInventory_getDcaeServicesService("DcaeInventory@getDcaeServicesService"), + DcaeInventory_createDcaeServicesService("DcaeInventory@createDcaeServicesService"), + DcaeInventory_poll("DcaeInventory@poll") ; + + + private String n; + + private DcaeInventoryOperationEnum(String n) { + this.n = n; + } + + @Override + public String toString() { + return n; + } + +} diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeController.properties b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeController.properties index 883027d..213a999 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeController.properties +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeController.properties @@ -11,6 +11,12 @@ POLICY_POLLING_FAILED=\ Contact Tier 4. This is a software bug.|\ Police Polling on the service level fails. +INVENTORY_POLLING_FAILED=\ + INVENTORY-POLLING-FAILED-5001W|\ + {0}|\ + Contact Tier 4. This is a software bug.|\ + INVENTORY Polling on the service level fails. + DATABUS_POLLING_FAILED=\ DATABUS-POLLING-FAILED-5001W|\ {0}|\ diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerMessageEnum.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerMessageEnum.java index 4233931..8abcc71 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerMessageEnum.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerMessageEnum.java @@ -8,6 +8,7 @@ public enum DcaeControllerMessageEnum implements EcompMessageEnum { HEALTHCHECK_SERVICE_FAILED, POLICY_POLLING_FAILED, + INVENTORY_POLLING_FAILED, DATABUS_POLLING_FAILED, DATABUS_UNABLE_TO_ADD_STREAM, CLUSTER_DATA_REPLICATION_FAILED; diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerOperationEnum.java b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerOperationEnum.java index 9285d2c..6604bc8 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerOperationEnum.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/sirius-gen/org/openecomp/dcae/controller/platform/servers/controller/logging/DcaeControllerOperationEnum.java @@ -8,6 +8,7 @@ public enum DcaeControllerOperationEnum implements EcompOperationEnum { HEALTHCHECK("HEALTHCHECK"), POLICY_POLLING("POLICY_POLLING"), DATABUS_POLLING("DATABUS_POLLING"), + INVENTORY_POLLING("INVENTORY_POLLING"), CLUSTER_DATA_REPLICATION("CLUSTER_DATA_REPLICATION") ; |