Subversion Repositories Programming Utils

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.
 */
package org.apache.sshd;

import java.io.ByteArrayOutputStream;
import java.io.OutputStream;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.util.Collections;

import org.apache.sshd.client.kex.DHG1;
import org.apache.sshd.client.kex.DHG14;
import org.apache.sshd.client.kex.DHGEX;
import org.apache.sshd.client.kex.DHGEX256;
import org.apache.sshd.client.kex.ECDHP256;
import org.apache.sshd.client.kex.ECDHP384;
import org.apache.sshd.client.kex.ECDHP521;
import org.apache.sshd.common.KeyExchange;
import org.apache.sshd.common.NamedFactory;
import org.apache.sshd.common.util.SecurityUtils;
import org.apache.sshd.util.BaseTest;
import org.apache.sshd.util.BogusPasswordAuthenticator;
import org.apache.sshd.util.EchoShellFactory;
import org.apache.sshd.util.TeeOutputStream;
import org.apache.sshd.util.Utils;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertTrue;

/**
 * Test key exchange algorithms.
 *
 * @author <a href="mailto:dev@mina.apache.org">Apache MINA SSHD Project</a>
 */
public class KexTest extends BaseTest {

    private SshServer sshd;
    private int port;

    @Before
    public void setUp() throws Exception {
        port = Utils.getFreePort();

        sshd = SshServer.setUpDefaultServer();
        sshd.setPort(port);
        sshd.setKeyPairProvider(Utils.createTestHostKeyProvider());
        sshd.setShellFactory(new EchoShellFactory());
        sshd.setPasswordAuthenticator(new BogusPasswordAuthenticator());
        sshd.start();
    }

    @After
    public void tearDown() throws Exception {
        sshd.stop(true);
    }

    @Test
    public void testDHGEX256() throws Exception {
        testClient(new DHGEX256.Factory());
    }

    @Test
    public void testDHGEX() throws Exception {
        testClient(new DHGEX.Factory());
    }

    @Test
    public void testDHG14() throws Exception {
        if (SecurityUtils.isBouncyCastleRegistered()) {
            testClient(new DHG14.Factory());
        }
    }

    @Test
    public void testDHG1() throws Exception {
        testClient(new DHG1.Factory());
    }

    @Test
    public void testECDHP521() throws Exception {
        testClient(new ECDHP521.Factory());
    }

    @Test
    public void testECDHP384() throws Exception {
        testClient(new ECDHP384.Factory());
    }

    @Test
    public void testECDHP256() throws Exception {
        testClient(new ECDHP256.Factory());
    }

    private void testClient(NamedFactory<KeyExchange> kex) throws Exception {
        SshClient client = SshClient.setUpDefaultClient();
        ByteArrayOutputStream sent = new ByteArrayOutputStream();
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        try {
            client.setKeyExchangeFactories(Collections.singletonList(kex));
            client.start();
            ClientSession session = client.connect("smx", "localhost", port).await().getSession();
            session.addPasswordIdentity("smx");
            session.auth().verify();
            ClientChannel channel = session.createChannel(ClientChannel.CHANNEL_SHELL);

            PipedOutputStream pipedIn = new PipedOutputStream();
            channel.setIn(new PipedInputStream(pipedIn));
            OutputStream teeOut = new TeeOutputStream(sent, pipedIn);
            ByteArrayOutputStream err = new ByteArrayOutputStream();
            channel.setOut(out);
            channel.setErr(err);
            assertTrue(channel.open().await().isOpened());

            teeOut.write("this is my command\n".getBytes());
            teeOut.flush();

            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < 10; i++) {
                sb.append("0123456789");
            }
            sb.append("\n");
            teeOut.write(sb.toString().getBytes());

            teeOut.write("exit\n".getBytes());
            teeOut.flush();

            channel.waitFor(ClientChannel.CLOSED, 0);

            channel.close(false);
        } finally {
            client.stop();
        }

        assertArrayEquals(sent.toByteArray(), out.toByteArray());
    }
}