apps/callhome-provider/src/main/java/org/opendaylight/netconf/callhome/mount/tls/NetconfCallHomeTlsService.java

   1 /*
   2  * Copyright (c) 2020 Pantheon Technologies, s.r.o. and others. All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.netconf.callhome.mount.tls;
   9
  10 import java.net.InetAddress;
  11 import java.net.UnknownHostException;
  12 import java.util.Optional;
  13 import javax.inject.Inject;
  14 import javax.inject.Singleton;
  15 import org.opendaylight.netconf.callhome.mount.CallHomeMountService;
  16 import org.opendaylight.netconf.callhome.server.CallHomeStatusRecorder;
  17 import org.opendaylight.netconf.callhome.server.tls.CallHomeTlsAuthProvider;
  18 import org.opendaylight.netconf.callhome.server.tls.CallHomeTlsServer;
  19 import org.opendaylight.netconf.client.NetconfClientSessionNegotiatorFactory;
  20 import org.opendaylight.netconf.common.NetconfTimer;
  21 import org.osgi.service.component.annotations.Activate;
  22 import org.osgi.service.component.annotations.Component;
  23 import org.osgi.service.component.annotations.Deactivate;
  24 import org.osgi.service.component.annotations.Reference;
  25 import org.osgi.service.metatype.annotations.AttributeDefinition;
  26 import org.osgi.service.metatype.annotations.Designate;
  27 import org.osgi.service.metatype.annotations.ObjectClassDefinition;
  28 import org.slf4j.Logger;
  29 import org.slf4j.LoggerFactory;
  30
  31 @Component(service = { }, configurationPid = "org.opendaylight.netconf.callhome.mount.tls.server")
  32 @Designate(ocd = NetconfCallHomeTlsService.Configuration.class)
  33 @Singleton
  34 public class NetconfCallHomeTlsService implements AutoCloseable {
  35
  36     @ObjectClassDefinition
  37     public @interface Configuration {
  38         @AttributeDefinition
  39         String host() default "0.0.0.0";
  40
  41         @AttributeDefinition(min = "1", max = "65535")
  42         int port() default 4335;
  43
  44         @AttributeDefinition
  45         int timeoutMillis() default 10_000;
  46
  47         @AttributeDefinition
  48         int maxConnections() default 64;
  49     }
  50
  51     private static final Logger LOG = LoggerFactory.getLogger(NetconfCallHomeTlsService.class);
  52
  53     private final CallHomeTlsServer server;
  54
  55     @Activate
  56     @Inject
  57     public NetconfCallHomeTlsService(
  58             final @Reference NetconfTimer timer,
  59             final @Reference CallHomeMountService mountService,
  60             final @Reference CallHomeTlsAuthProvider authProvider,
  61             final @Reference CallHomeStatusRecorder statusRecorder,
  62             final Configuration configuration) {
  63
  64         LOG.info("Starting Call-Home TLS server at {}:{}", configuration.host(), configuration.port());
  65         try {
  66             server = CallHomeTlsServer.builder()
  67                 .withAddress(InetAddress.getByName(configuration.host()))
  68                 .withPort(configuration.port())
  69                 .withTimeout(configuration.timeoutMillis())
  70                 .withMaxConnections(configuration.maxConnections())
  71                 .withAuthProvider(authProvider)
  72                 .withStatusRecorder(statusRecorder)
  73                 .withSessionContextManager(
  74                     mountService.createTlsSessionContextManager(authProvider, statusRecorder))
  75                 .withNegotiationFactory(new NetconfClientSessionNegotiatorFactory(timer, Optional.empty(),
  76                     configuration.timeoutMillis(), NetconfClientSessionNegotiatorFactory.DEFAULT_CLIENT_CAPABILITIES))
  77                 .build();
  78         } catch (UnknownHostException e) {
  79             throw new IllegalArgumentException("invalid host", e);
  80         }
  81         LOG.info("Call-Home TLS server started successfully");
  82     }
  83
  84     @Deactivate
  85     @Override
  86     public void close() throws Exception {
  87         server.close();
  88         LOG.info("Call-Home TLS server stopped");
  89     }
  90 }