gerrit.onap Code Review - ccsdk/features.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *     http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  *
  21  */
  22 package org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.elalto;
  23
  24 import java.util.HashMap;
  25 import java.util.Map;
  26 import org.onap.ccsdk.features.sdnr.wt.common.database.HtDatabaseClient;
  27 import org.onap.ccsdk.features.sdnr.wt.dataprovider.database.sqldb.SqlDBClient;
  28 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.ReleaseInformation;
  29 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.ComponentName;
  30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.DatabaseInfo;
  31 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.KeepDataSearchHitConverter;
  32 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.Release;
  33 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.SearchHitConverter;
  34
  35 public class ElAltoReleaseInformation extends ReleaseInformation {
  36
  37
  38     private Map<Release, Map<ComponentName, SearchHitConverter>> converters;
  39
  40     public ElAltoReleaseInformation() {
  41         super(Release.EL_ALTO, createDbInfos());
  42         this.converters = generateConverters();
  43     }
  44
  45     private static Map<ComponentName, DatabaseInfo> createDbInfos() {
  46         Map<ComponentName, DatabaseInfo> map = new HashMap<>();
  47         map.put(ComponentName.EVENTLOG, new DatabaseInfo("sdnevents", "eventlog", ""));
  48         map.put(ComponentName.FAULTCURRENT, new DatabaseInfo("sdnevents", "faultcurrent", ""));
  49         map.put(ComponentName.FAULTLOG, new DatabaseInfo("sdnevents", "faultlog", ""));
  50         map.put(ComponentName.INVENTORY, new DatabaseInfo("sdnevents", "inventoryequipment", ""));
  51         map.put(ComponentName.INVENTORYTOPLEVEL, new DatabaseInfo("sdnevents", "inventorytoplevel", ""));
  52         map.put(ComponentName.HISTORICAL_PERFORMANCE_15M,
  53                 new DatabaseInfo("sdnperformance", "historicalperformance15min", ""));
  54         map.put(ComponentName.HISTORICAL_PERFORMANCE_24H,
  55                 new DatabaseInfo("sdnperformance", "historicalperformance24h", ""));
  56         map.put(ComponentName.REQUIRED_NETWORKELEMENT, new DatabaseInfo("mwtn", "required-networkelement",
  57                 "{\"required-networkelement\": {\"date_detection\": false }}"));
  58         map.put(ComponentName.MEDIATOR_SERVER, new DatabaseInfo("mwtn", "mediator-server", ""));
  59         map.put(ComponentName.MAINTENANCE, new DatabaseInfo("mwtn", "maintenancemode", ""));
  60         return map;
  61     }
  62
  63     /**
  64      * @return components used in el alto
  65      */
  66
  67
  68     private static Map<Release, Map<ComponentName, SearchHitConverter>> generateConverters() {
  69         Map<Release, Map<ComponentName, SearchHitConverter>> c = new HashMap<>();
  70         Map<ComponentName, SearchHitConverter> frankfurtConverters = new HashMap<>();
  71         frankfurtConverters.put(ComponentName.EVENTLOG, new FrankfurtEventlogConverter());
  72         frankfurtConverters.put(ComponentName.FAULTCURRENT, new FrankfurtFaultcurrentConverter());
  73         frankfurtConverters.put(ComponentName.FAULTLOG, new FrankfurtFaultlogConverter());
  74         frankfurtConverters.put(ComponentName.INVENTORY, new KeepDataSearchHitConverter(ComponentName.INVENTORY));
  75         //obsolete in frankfurt
  76         //frankfurtConverters.put(ComponentName.INVENTORYTOPLEVEL, new KeepDataSearchHitConverter(ComponentName.INVENTORYTOPLEVEL));
  77         frankfurtConverters.put(ComponentName.HISTORICAL_PERFORMANCE_15M,
  78                 new KeepDataSearchHitConverter(ComponentName.HISTORICAL_PERFORMANCE_15M));
  79         frankfurtConverters.put(ComponentName.HISTORICAL_PERFORMANCE_24H,
  80                 new KeepDataSearchHitConverter(ComponentName.HISTORICAL_PERFORMANCE_24H));
  81         frankfurtConverters.put(ComponentName.MAINTENANCE, new FrankfurtMaintenanceConverter());
  82         frankfurtConverters.put(ComponentName.MEDIATOR_SERVER,
  83                 new KeepDataSearchHitConverter(ComponentName.MEDIATOR_SERVER));
  84         frankfurtConverters.put(ComponentName.REQUIRED_NETWORKELEMENT, new FrankfurtRequiredNetworkElementConverter());
  85         frankfurtConverters.put(ComponentName.CONNECTIONLOG, new FrankfurtConnectionlogConverter());
  86         c.put(Release.FRANKFURT_R1, frankfurtConverters);
  87         return c;
  88     }
  89
  90     @Override
  91     public SearchHitConverter getConverter(Release dst, ComponentName comp) {
  92         SearchHitConverter c = this.converters.containsKey(dst) ? this.converters.get(dst).get(comp) : null;
  93         if (c == null) {
  94             c = super.getConverter(dst, comp);
  95         }
  96         return c;
  97     }
  98
  99     @Override
 100     public boolean runPreInitCommands(HtDatabaseClient dbClient) {
 101         return true;
 102     }
 103
 104     @Override
 105     public boolean runPostInitCommands(HtDatabaseClient dbClient) {
 106         return true;
 107     }
 108
 109     @Override
 110     public boolean runPreInitCommands(SqlDBClient dbClient) {
 111         return false;
 112     }
 113
 114     @Override
 115     public boolean runPostInitCommands(SqlDBClient dbClient) {
 116         return false;
 117     }
 118 }