+++ /dev/null
-/*
- * ============LICENSE_START==========================================
- * Copyright (c) 2019 PANTHEON.tech s.r.o.
- * ===================================================================
- * 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.ccsdk.distribution.lighty;
-
-import com.google.common.collect.ImmutableSet;
-import io.lighty.core.controller.api.AbstractLightyModule;
-import java.util.Set;
-import org.onap.ccsdk.sli.adaptors.lighty.CcsdkAdaptorsLightyModule;
-import org.onap.ccsdk.sli.core.dblib.lighty.DblibModule;
-import org.onap.ccsdk.sli.core.lighty.common.CcsdkLightyUtils;
-import org.onap.ccsdk.sli.core.sli.lighty.SliModule;
-import org.onap.ccsdk.sli.core.sli.recording.Slf4jRecorder;
-import org.onap.ccsdk.sli.core.sliapi.lighty.SliApiModule;
-import org.onap.ccsdk.sli.core.slipluginutils.lighty.SliPluginUtilsModule;
-import org.onap.ccsdk.sli.northbound.lighty.CcsdkNorhboundLightyModule;
-import org.onap.ccsdk.sli.plugins.lighty.CcsdkPluginsLightyModule;
-import org.opendaylight.aaa.encrypt.AAAEncryptionService;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
-import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;
-import org.opendaylight.yangtools.yang.binding.YangModuleInfo;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * The implementation of the {@link io.lighty.core.controller.api.LightyModule} that groups all other LightyModules
- * from the CCSDK project so they can be all treated as one component (for example started/stopped at once).
- * For more information about the lighty.io visit the website https://lighty.io.
- */
-public class CcsdkLightyModule extends AbstractLightyModule {
-
- private static final Logger LOG = LoggerFactory.getLogger(CcsdkLightyModule.class);
-
- public static final Set<YangModuleInfo> YANG_MODELS = ImmutableSet.of(
- org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.core.sliapi.rev161110.$YangModuleInfoImpl.getInstance(),
- org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.lcm.rev180329.$YangModuleInfoImpl.getInstance(),
- org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.datachange.rev150519.$YangModuleInfoImpl.getInstance(),
- org.opendaylight.yang.gen.v1.org.onap.ccsdk.sli.northbound.asdcapi.common.rev170201.$YangModuleInfoImpl.getInstance(),
- org.opendaylight.yang.gen.v1.http.xmlns.onap.org.asdc.license.model._1._0.rev160427.$YangModuleInfoImpl.getInstance(),
- org.opendaylight.yang.gen.v1.org.onap.ccsdk.rev170201.$YangModuleInfoImpl.getInstance()
- );
-
- private final DataBroker dataBroker;
- private final NotificationPublishService notificationPublishService;
- private final RpcProviderRegistry rpcProviderRegistry;
- private final AAAEncryptionService aaaEncryptionService;
-
- private CcsdkAdaptorsLightyModule ccsdkAdaptorsLightyModule;
- private CcsdkNorhboundLightyModule ccsdkNorhboundLightyModule;
- private CcsdkPluginsLightyModule ccsdkPluginsLightyModule;
- private DblibModule dblibModule;
- private SliModule sliModule;
- private SliApiModule sliApiModule;
- private SliPluginUtilsModule sliPluginUtilsModule;
-
- public CcsdkLightyModule(DataBroker dataBroker, NotificationPublishService notificationPublishService,
- RpcProviderRegistry rpcProviderRegistry, AAAEncryptionService aaaEncryptionService) {
- this.dataBroker = dataBroker;
- this.notificationPublishService = notificationPublishService;
- this.rpcProviderRegistry = rpcProviderRegistry;
- this.aaaEncryptionService = aaaEncryptionService;
- }
-
- protected boolean initProcedure() {
- // FIXME modules from CcsdkCoreLightyModule need to be started separately (not through CcsdkCoreLightyModule
- // itself) because SliApiModule is dependent on the adaptors
- try {
- LOG.debug("Initializing CCSDK Lighty module...");
-
- this.dblibModule = new DblibModule(aaaEncryptionService);
- if (!CcsdkLightyUtils.startLightyModule(dblibModule)) {
- LOG.error("Unable to start DblibModule in CCSDK Core Lighty module!");
- return false;
- }
-
- this.ccsdkAdaptorsLightyModule = new CcsdkAdaptorsLightyModule(dblibModule.getDbLibService());
- if (!CcsdkLightyUtils.startLightyModule(ccsdkAdaptorsLightyModule)) {
- LOG.error("Unable to start CcsdkAdaptorsLightyModule in CCSDK Lighty module!");
- return false;
- }
-
- this.sliModule = new SliModule(dblibModule.getDbLibService(),
- ccsdkAdaptorsLightyModule.getAaaServiceModule().getAAIService(), new Slf4jRecorder(),
- ccsdkAdaptorsLightyModule.getAaaServiceModule().getAAIService(), null);
- if (!CcsdkLightyUtils.startLightyModule(sliModule)) {
- LOG.error("Unable to start SliModule in CCSDK Core Lighty module!");
- return false;
- }
-
- this.sliApiModule = new SliApiModule(dataBroker, notificationPublishService, rpcProviderRegistry, sliModule.getSvcLogicServiceImpl());
- if (!CcsdkLightyUtils.startLightyModule(sliApiModule)) {
- LOG.error("Unable to start SliApiModule in CCSDK Core Lighty module!");
- return false;
- }
-
- this.sliPluginUtilsModule = new SliPluginUtilsModule();
- if (!CcsdkLightyUtils.startLightyModule(sliPluginUtilsModule)) {
- LOG.error("Unable to start SliPluginUtilsModule in CCSDK Core Lighty module!");
- return false;
- }
-
- this.ccsdkPluginsLightyModule = new CcsdkPluginsLightyModule();
- if (!CcsdkLightyUtils.startLightyModule(ccsdkPluginsLightyModule)) {
- LOG.error("Unable to start CcsdkPluginsLightyModule in CCSDK Lighty module!");
- return false;
- }
-
- this.ccsdkNorhboundLightyModule =
- new CcsdkNorhboundLightyModule(sliModule.getSvcLogicServiceImpl(), dataBroker,
- notificationPublishService, rpcProviderRegistry);
- if (!CcsdkLightyUtils.startLightyModule(ccsdkNorhboundLightyModule)) {
- LOG.error("Unable to start CcsdkNorhboundLightyModule in CCSDK Lighty module!");
- return false;
- }
-
- LOG.debug("CCSDK Lighty module was initialized successfully");
- return true;
- } catch (Exception e) {
- LOG.error("Exception caught!", e);
- throw e;
- }
- }
-
- protected boolean stopProcedure() {
- LOG.debug("Stopping CCSDK Lighty module...");
-
- boolean stopSuccessful = true;
-
- if (!CcsdkLightyUtils.stopLightyModule(ccsdkPluginsLightyModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(ccsdkNorhboundLightyModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(ccsdkAdaptorsLightyModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(sliPluginUtilsModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(sliApiModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(sliModule)) {
- stopSuccessful = false;
- }
-
- if (!CcsdkLightyUtils.stopLightyModule(dblibModule)) {
- stopSuccessful = false;
- }
-
- if (stopSuccessful) {
- LOG.debug("CCSDK Lighty module was stopped successfully");
- } else {
- LOG.error("CCSDK Lighty module was not stopped successfully!");
- }
- return stopSuccessful;
- }
-
- public CcsdkAdaptorsLightyModule getCcsdkAdaptorsLightyModule() {
- return ccsdkAdaptorsLightyModule;
- }
-
- public CcsdkNorhboundLightyModule getCcsdkNorhboundLightyModule() {
- return ccsdkNorhboundLightyModule;
- }
-
- public CcsdkPluginsLightyModule getCcsdkPluginsLightyModule() {
- return ccsdkPluginsLightyModule;
- }
-
- public DblibModule getDblibModule() {
- return dblibModule;
- }
-
- public SliModule getSliModule() {
- return sliModule;
- }
-
- public SliApiModule getSliApiModule() {
- return sliApiModule;
- }
-
- public SliPluginUtilsModule getSliPluginUtilsModule() {
- return sliPluginUtilsModule;
- }
-}
Code Review / ccsdk / distribution.git / blobdiff