opendaylight/netconf/netconf-ssh/src/test/java/org/opendaylight/controller/netconf/netty/SSHTest.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. 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
   9 package org.opendaylight.controller.netconf.netty;
  10
  11 import static org.junit.Assert.assertEquals;
  12 import static org.junit.Assert.assertFalse;
  13 import static org.junit.Assert.assertTrue;
  14 import static org.mockito.Matchers.anyString;
  15 import static org.mockito.Mockito.doReturn;
  16 import static org.mockito.Mockito.mock;
  17
  18 import com.google.common.base.Stopwatch;
  19 import io.netty.bootstrap.Bootstrap;
  20 import io.netty.channel.ChannelInitializer;
  21 import io.netty.channel.EventLoopGroup;
  22 import io.netty.channel.nio.NioEventLoopGroup;
  23 import io.netty.channel.socket.nio.NioSocketChannel;
  24 import io.netty.util.HashedWheelTimer;
  25 import java.net.InetSocketAddress;
  26 import java.util.concurrent.TimeUnit;
  27 import org.junit.After;
  28 import org.junit.Before;
  29 import org.junit.Test;
  30 import org.opendaylight.controller.netconf.netty.EchoClientHandler.State;
  31 import org.opendaylight.controller.netconf.nettyutil.handler.ssh.authentication.LoginPassword;
  32 import org.opendaylight.controller.netconf.nettyutil.handler.ssh.client.AsyncSshHandler;
  33 import org.opendaylight.controller.netconf.ssh.NetconfSSHServer;
  34 import org.opendaylight.controller.netconf.ssh.authentication.AuthProvider;
  35 import org.opendaylight.controller.netconf.ssh.authentication.AuthProviderImpl;
  36 import org.opendaylight.controller.netconf.ssh.authentication.PEMGenerator;
  37 import org.opendaylight.controller.netconf.util.osgi.NetconfConfigUtil;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40
  41 public class SSHTest {
  42     public static final Logger logger = LoggerFactory.getLogger(SSHTest.class);
  43     public static final String AHOJ = "ahoj\n";
  44     private EventLoopGroup nettyGroup;
  45     HashedWheelTimer hashedWheelTimer;
  46
  47     @Before
  48     public void setUp() throws Exception {
  49         hashedWheelTimer = new HashedWheelTimer();
  50         nettyGroup = new NioEventLoopGroup();
  51     }
  52
  53     @After
  54     public void tearDown() throws Exception {
  55         hashedWheelTimer.stop();
  56         nettyGroup.shutdownGracefully();
  57     }
  58
  59     @Test
  60     public void test() throws Exception {
  61         new Thread(new EchoServer(), "EchoServer").start();
  62         AuthProvider authProvider = mock(AuthProviderImpl.class);
  63         doReturn(PEMGenerator.generate().toCharArray()).when(authProvider).getPEMAsCharArray();
  64         doReturn(true).when(authProvider).authenticated(anyString(), anyString());
  65         doReturn("auth").when(authProvider).toString();
  66
  67         NetconfSSHServer netconfSSHServer = NetconfSSHServer.start(10831, NetconfConfigUtil.getNetconfLocalAddress(),
  68                 authProvider, new NioEventLoopGroup());
  69
  70         InetSocketAddress address = netconfSSHServer.getLocalSocketAddress();
  71         final EchoClientHandler echoClientHandler = connectClient(address);
  72         Stopwatch stopwatch = new Stopwatch().start();
  73         while(echoClientHandler.isConnected() == false && stopwatch.elapsed(TimeUnit.SECONDS) < 5) {
  74             Thread.sleep(100);
  75         }
  76         assertTrue(echoClientHandler.isConnected());
  77         logger.info("connected, writing to client");
  78         echoClientHandler.write(AHOJ);
  79         // check that server sent back the same string
  80         stopwatch = stopwatch.reset().start();
  81         while (echoClientHandler.read().endsWith(AHOJ) == false && stopwatch.elapsed(TimeUnit.SECONDS) < 5) {
  82             Thread.sleep(100);
  83         }
  84         try {
  85             String read = echoClientHandler.read();
  86             assertTrue(read + " should end with " + AHOJ, read.endsWith(AHOJ));
  87         } finally {
  88             logger.info("Closing socket");
  89             netconfSSHServer.close();
  90             netconfSSHServer.join();
  91         }
  92     }
  93
  94     public EchoClientHandler connectClient(InetSocketAddress address) {
  95         final EchoClientHandler echoClientHandler = new EchoClientHandler();
  96         ChannelInitializer<NioSocketChannel> channelInitializer = new ChannelInitializer<NioSocketChannel>() {
  97             @Override
  98             public void initChannel(NioSocketChannel ch) throws Exception {
  99                 ch.pipeline().addFirst(AsyncSshHandler.createForNetconfSubsystem(new LoginPassword("a", "a")));
 100                 ch.pipeline().addLast(echoClientHandler);
 101             }
 102         };
 103         Bootstrap b = new Bootstrap();
 104
 105         b.group(nettyGroup)
 106                 .channel(NioSocketChannel.class)
 107                 .handler(channelInitializer);
 108
 109         // Start the client.
 110         b.connect(address).addListener(echoClientHandler);
 111         return echoClientHandler;
 112     }
 113
 114     @Test
 115     public void testClientWithoutServer() throws Exception {
 116         InetSocketAddress address = new InetSocketAddress(12345);
 117         final EchoClientHandler echoClientHandler = connectClient(address);
 118         Stopwatch stopwatch = new Stopwatch().start();
 119         while(echoClientHandler.getState() == State.CONNECTING && stopwatch.elapsed(TimeUnit.SECONDS) < 5) {
 120             Thread.sleep(100);
 121         }
 122         assertFalse(echoClientHandler.isConnected());
 123         assertEquals(State.CONNECTION_CLOSED, echoClientHandler.getState());
 124     }
 125
 126 }