-
-/*
- * ============LICENSE_START=======================================================
- * PROJECT
- * ================================================================================
- * 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.onap.dcae.restapi;
-
-import java.io.IOException;
-import java.net.URL;
-
-import javax.servlet.ServletException;
-
-import org.apache.tomcat.util.codec.binary.Base64;
-import org.onap.dcae.commonFunction.CommonStartup;
-import org.onap.dcae.commonFunction.VESLogger;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import com.att.nsa.apiServer.CommonServlet;
-import com.att.nsa.configs.ConfigDbException;
-import com.att.nsa.drumlin.service.framework.DrumlinErrorHandler;
-import com.att.nsa.drumlin.service.framework.context.DrumlinRequestContext;
-import com.att.nsa.drumlin.service.framework.routing.DrumlinRequestRouter;
-import com.att.nsa.drumlin.service.framework.routing.playish.DrumlinPlayishRoutingFileSource;
-import com.att.nsa.drumlin.service.standards.HttpStatusCodes;
-import com.att.nsa.drumlin.till.nv.rrNvReadable;
-import com.att.nsa.drumlin.till.nv.rrNvReadable.loadException;
-import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;
-import com.att.nsa.security.NsaAuthenticator;
-
-import com.att.nsa.security.authenticators.SimpleAuthenticator;
-import com.att.nsa.security.db.simple.NsaSimpleApiKey;
-
-
-public class RestfulCollectorServlet extends CommonServlet
-{
- String authid=null;
- String authpwd=null;
- public String authlist;
-
- public RestfulCollectorServlet ( rrNvReadable settings ) throws loadException, missingReqdSetting
- {
- super ( settings, "collector", false );
- authlist = settings.getString(CommonStartup.KSETTING_AUTHLIST,null);
- }
-
-
-
-
- /**
- * This is called once at server start. Use it to init any shared objects and setup the route mapping.
- */
- @Override
- protected void servletSetup () throws rrNvReadable.missingReqdSetting, rrNvReadable.invalidSettingValue, ServletException
- {
- super.servletSetup ();
-
- try
- {
- // the base class provides a bunch of things like API authentication and ECOMP compliant
- // logging. The Restful Collector likely doesn't need API authentication, so for now,
- // we init the base class services with an in-memory (and empty!) config DB.
- commonServletSetup ( ConfigDbType.MEMORY );
-
- VESLogger.setUpEcompLogging();
-
- // setup the servlet routing and error handling
- final DrumlinRequestRouter drr = getRequestRouter ();
-
- // you can tell the request router what to do when a particular kind of exception is thrown.
- drr.setHandlerForException( IllegalArgumentException.class, new DrumlinErrorHandler()
- {
- @Override
- public void handle ( DrumlinRequestContext ctx, Throwable cause )
- {
- sendJsonReply ( ctx, HttpStatusCodes.k400_badRequest, cause.getMessage() );
- }
- });
-
- // load the routes from the config file
- final URL routes = findStream ( "routes.conf" );
- if ( routes == null ) throw new rrNvReadable.missingReqdSetting ( "No routing configuration." );
- final DrumlinPlayishRoutingFileSource drs = new DrumlinPlayishRoutingFileSource ( routes );
- drr.addRouteSource ( drs );
-
- if (CommonStartup.authflag > 0) {
- NsaAuthenticator<NsaSimpleApiKey> NsaAuth;
- NsaAuth = AuthlistHandler(authlist);
-
- this.getSecurityManager().addAuthenticator(NsaAuth);
- }
-
- log.info ( "Restful Collector Servlet is up." );
- }
- catch ( SecurityException e )
- {
- throw new ServletException ( e );
- }
- catch ( IOException e )
- {
- throw new ServletException ( e );
- }
- catch ( ConfigDbException e )
- {
- throw new ServletException ( e );
- }
- }
-
- public NsaAuthenticator<NsaSimpleApiKey> AuthlistHandler (String authlist)
- {
- NsaAuthenticator<NsaSimpleApiKey> NsaAuth = new SimpleAuthenticator ();
- if (authlist != null)
- {
- String authpair[] = authlist.split("\\|");
- for (String pair: authpair) {
- String lineid[] = pair.split(",");
- String listauthid = lineid[0];
- String listauthpwd = new String(Base64.decodeBase64(lineid[1]));
- ((SimpleAuthenticator) NsaAuth).add(listauthid,listauthpwd);
- }
-
- }
- else if (authid != null)
- {
- ((SimpleAuthenticator) NsaAuth).add(authid,authpwd);
- }
- else
- {
- //add a default test account
- ((SimpleAuthenticator) NsaAuth).add("admin","collectorpasscode");
- }
- return NsaAuth;
-
- }
-
-
- private static final long serialVersionUID = 1L;
- private static final Logger log = LoggerFactory.getLogger ( RestfulCollectorServlet.class );
-}
+\r
+/*\r
+ * ============LICENSE_START=======================================================\r
+ * PROJECT\r
+ * ================================================================================\r
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
+ * ================================================================================\r
+ * Licensed under the Apache License, Version 2.0 (the "License");\r
+ * you may not use this file except in compliance with the License.\r
+ * You may obtain a copy of the License at\r
+ * \r
+ * http://www.apache.org/licenses/LICENSE-2.0\r
+ * \r
+ * Unless required by applicable law or agreed to in writing, software\r
+ * distributed under the License is distributed on an "AS IS" BASIS,\r
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+ * See the License for the specific language governing permissions and\r
+ * limitations under the License.\r
+ * ============LICENSE_END=========================================================\r
+ */\r
+\r
+package org.onap.dcae.restapi;\r
+\r
+import java.io.IOException;\r
+import java.net.URL;\r
+\r
+import javax.servlet.ServletException;\r
+\r
+import org.apache.tomcat.util.codec.binary.Base64;\r
+import org.onap.dcae.commonFunction.CommonStartup;\r
+import org.onap.dcae.commonFunction.VESLogger;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
+\r
+import com.att.nsa.apiServer.CommonServlet;\r
+import com.att.nsa.configs.ConfigDbException;\r
+import com.att.nsa.drumlin.service.framework.routing.DrumlinRequestRouter;\r
+import com.att.nsa.drumlin.service.framework.routing.playish.DrumlinPlayishRoutingFileSource;\r
+import com.att.nsa.drumlin.service.standards.HttpStatusCodes;\r
+import com.att.nsa.drumlin.till.nv.rrNvReadable;\r
+import com.att.nsa.drumlin.till.nv.rrNvReadable.loadException;\r
+import com.att.nsa.drumlin.till.nv.rrNvReadable.missingReqdSetting;\r
+import com.att.nsa.security.NsaAuthenticator;\r
+\r
+import com.att.nsa.security.authenticators.SimpleAuthenticator;\r
+import com.att.nsa.security.db.simple.NsaSimpleApiKey;\r
+\r
+public class RestfulCollectorServlet extends CommonServlet\r
+{\r
+\r
+ private static final long serialVersionUID = 1L;\r
+ private static final Logger log = LoggerFactory.getLogger ( RestfulCollectorServlet.class );\r
+\r
+ private static String authCredentialsList;\r
+\r
+ public RestfulCollectorServlet ( rrNvReadable settings ) throws loadException, missingReqdSetting\r
+ {\r
+ super ( settings, "collector", false );\r
+ authCredentialsList = settings.getString(CommonStartup.KSETTING_AUTHLIST, null);\r
+ }\r
+\r
+\r
+\r
+\r
+ /**\r
+ * This is called once at server start. Use it to init any shared objects and setup the route mapping.\r
+ */\r
+ @Override\r
+ protected void servletSetup () throws rrNvReadable.missingReqdSetting, rrNvReadable.invalidSettingValue, ServletException\r
+ {\r
+ super.servletSetup ();\r
+\r
+ try {\r
+ // the base class provides a bunch of things like API authentication and ECOMP compliant\r
+ // logging. The Restful Collector likely doesn't need API authentication, so for now,\r
+ // we init the base class services with an in-memory (and empty!) config DB.\r
+ commonServletSetup ( ConfigDbType.MEMORY );\r
+\r
+ VESLogger.setUpEcompLogging();\r
+\r
+ // setup the servlet routing and error handling\r
+ final DrumlinRequestRouter drr = getRequestRouter ();\r
+\r
+ // you can tell the request router what to do when a particular kind of exception is thrown.\r
+ drr.setHandlerForException(IllegalArgumentException.class,\r
+ (ctx, cause) -> sendJsonReply (ctx, HttpStatusCodes.k400_badRequest, cause.getMessage() ));\r
+\r
+ // load the routes from the config file\r
+ final URL routes = findStream ( "routes.conf" );\r
+ if ( routes == null ) throw new rrNvReadable.missingReqdSetting ( "No routing configuration." );\r
+ final DrumlinPlayishRoutingFileSource drs = new DrumlinPlayishRoutingFileSource ( routes );\r
+ drr.addRouteSource ( drs );\r
+\r
+ if (CommonStartup.authflag > 0) {\r
+ NsaAuthenticator<NsaSimpleApiKey> NsaAuth;\r
+ NsaAuth = createAuthenticator(authCredentialsList);\r
+\r
+ this.getSecurityManager().addAuthenticator(NsaAuth);\r
+ }\r
+\r
+ log.info ( "Restful Collector Servlet is up." );\r
+ }\r
+ catch ( SecurityException | IOException | ConfigDbException e ) {\r
+ throw new ServletException ( e );\r
+ }\r
+ }\r
+\r
+ public NsaAuthenticator<NsaSimpleApiKey> createAuthenticator(String authCredentials) {\r
+ NsaAuthenticator<NsaSimpleApiKey> authenticator = new SimpleAuthenticator();\r
+ if (authCredentials != null) {\r
+ String authpair[] = authCredentials.split("\\|");\r
+ for (String pair : authpair) {\r
+ String lineid[] = pair.split(",");\r
+ String listauthid = lineid[0];\r
+ String listauthpwd = new String(Base64.decodeBase64(lineid[1]));\r
+ ((SimpleAuthenticator) authenticator).add(listauthid, listauthpwd);\r
+ }\r
+\r
+ } else {\r
+ ((SimpleAuthenticator) authenticator).add("admin", "collectorpasscode");\r
+ }\r
+ return authenticator;\r
+ }\r
+\r
+}\r
+\r
Code Review / dcaegen2 / collectors / ves.git / blobdiff