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

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2019 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.http;
  23
  24 import java.io.IOException;
  25 import javax.servlet.ServletException;
  26 import javax.servlet.http.HttpServletRequest;
  27 import javax.servlet.http.HttpServletResponse;
  28 import org.onap.ccsdk.features.sdnr.wt.common.http.BaseServlet;
  29 import org.onap.ccsdk.features.sdnr.wt.dataprovider.impl.MediatorServerDataProvider;
  30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMediatorserver;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 public class MsServlet extends BaseServlet {
  35
  36     /**
  37      *
  38      */
  39     private static Logger LOG = LoggerFactory.getLogger(MsServlet.class);
  40     private static final long serialVersionUID = -5361461082028405171L;
  41     private static final String OFFLINE_RESPONSE_MESSAGE = "MediatorServer interface is offline";
  42     private static boolean trustAll = false;
  43     private static MediatorServerDataProvider entryProvider;
  44
  45     public MsServlet() {
  46         super();
  47     }
  48
  49     @Override
  50     protected void doOptions(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  51         resp.setStatus(200);
  52     }
  53
  54     @Override
  55     protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
  56         super.doGet(req, resp);
  57     }
  58
  59     @Override
  60     protected String getOfflineResponse() {
  61         return OFFLINE_RESPONSE_MESSAGE;
  62     }
  63
  64     public void triggerReloadDatabaseEntries() {
  65         LOG.debug("external reload triggered");
  66         entryProvider.triggerReloadSync();
  67     }
  68
  69     @Override
  70     protected boolean isOff() {
  71         return false;
  72     }
  73
  74     @Override
  75     protected String getRemoteUrl(String uri) {
  76         String dbServerId = "0";
  77         if (uri == null)
  78             uri = "";
  79         if (uri.length() > 0) {
  80             uri = uri.substring("/ms/".length());
  81             int idx = uri.indexOf("/");
  82             dbServerId = uri.substring(0, idx);
  83             uri = uri.substring(idx);
  84         }
  85         LOG.debug("request for ms server with id={}", dbServerId);
  86         String url = this.getBaseUrl(dbServerId) + uri;
  87         LOG.debug("dest-url: {}", url);
  88         return url;
  89     }
  90
  91     protected String getBaseUrl(String dbServerId) {
  92         return entryProvider.getHostUrl(dbServerId);
  93     }
  94
  95     @Override
  96     protected boolean doTrustAll() {
  97         return trustAll;
  98     }
  99
 100     @Override
 101     protected void trustAll(boolean trust) {
 102         trustAll = trust;
 103     }
 104
 105     public void setDataProvider(HtDatabaseMediatorserver entryProvider2) {
 106         entryProvider = new MediatorServerDataProvider(entryProvider2);
 107     }
 108
 109     @Override
 110     protected boolean trustInsecure() {
 111         return trustAll;
 112     }
 113
 114     @Override
 115     protected boolean isCorsEnabled() {
 116         return false;
 117     }
 118
 119     public void triggerReloadSync() {
 120         if(entryProvider!=null) {
 121             entryProvider.triggerReloadSync();
 122         }
 123
 124     }
 125 }