Call-Home provider migration to transport-api

[netconf.git] / netconf / callhome-protocol / src / test / java / org / opendaylight / netconf / callhome / protocol / MinaSshNettyChannelTest.java

diff --git a/netconf/callhome-protocol/src/test/java/org/opendaylight/netconf/callhome/protocol/MinaSshNettyChannelTest.java b/netconf/callhome-protocol/src/test/java/org/opendaylight/netconf/callhome/protocol/MinaSshNettyChannelTest.java
deleted file mode 100644 (file)
index ebe52ef..0000000
--- a/netconf/callhome-protocol/src/test/java/org/opendaylight/netconf/callhome/protocol/MinaSshNettyChannelTest.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/*
- * Copyright (c) 2016 Brocade Communication Systems and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.netconf.callhome.protocol;
-
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.doReturn;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-
-import io.netty.buffer.ByteBufAllocator;
-import io.netty.buffer.EmptyByteBuf;
-import io.netty.channel.ChannelHandler;
-import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelOutboundHandlerAdapter;
-import io.netty.channel.ChannelPromise;
-import org.junit.Before;
-import org.junit.Test;
-import org.opendaylight.netconf.callhome.protocol.CallHomeSessionContext.SshWriteAsyncHandlerAdapter;
-import org.opendaylight.netconf.shaded.sshd.client.channel.ClientChannel;
-import org.opendaylight.netconf.shaded.sshd.client.session.ClientSession;
-import org.opendaylight.netconf.shaded.sshd.common.io.IoInputStream;
-import org.opendaylight.netconf.shaded.sshd.common.io.IoOutputStream;
-import org.opendaylight.netconf.shaded.sshd.common.io.IoReadFuture;
-import org.opendaylight.netconf.shaded.sshd.common.io.IoWriteFuture;
-import org.opendaylight.netconf.shaded.sshd.common.util.buffer.Buffer;
-
-@Deprecated(since = "7.0.0", forRemoval = true)
-public class MinaSshNettyChannelTest {
-    private CallHomeSessionContext mockContext;
-    private ClientSession mockSession;
-    private ClientChannel mockChannel;
-    private MinaSshNettyChannel instance;
-
-    @Before
-    public void setup() throws Exception {
-        final var mockFuture = mock(IoReadFuture.class);
-        final var mockIn = mock(IoInputStream.class);
-        doReturn(mockFuture).when(mockIn).read(any(Buffer.class));
-        doReturn(mockFuture).when(mockFuture).addListener(any());
-        mockContext = mock(CallHomeSessionContext.class);
-        mockSession = mock(ClientSession.class);
-        mockChannel = mock(ClientChannel.class);
-        doReturn(mockIn).when(mockChannel).getAsyncOut();
-
-        final var mockOut = mock(IoOutputStream.class);
-        doReturn(mockOut).when(mockChannel).getAsyncIn();
-        doReturn(false).when(mockOut).isClosed();
-        doReturn(false).when(mockOut).isClosing();
-
-        final var mockWrFuture = mock(IoWriteFuture.class);
-        doReturn(mockWrFuture).when(mockOut).writeBuffer(any(Buffer.class));
-        doReturn(null).when(mockWrFuture).addListener(any());
-
-        instance = new MinaSshNettyChannel(mockContext, mockSession);
-    }
-
-    @Test
-    public void ourChannelHandlerShouldForwardWrites() throws Exception {
-        final var mockHandler = mock(ChannelHandler.class);
-        final var ctx = mock(ChannelHandlerContext.class);
-        doReturn(mockHandler).when(ctx).handler();
-        final var promise = mock(ChannelPromise.class);
-
-        // we would really like to just verify that the async handler write() was
-        // called but it is a final class, so no mocking. instead we set up the
-        // mock channel to have no async input, which will cause a failure later
-        // on the write promise that we use as a cheap way to tell that write()
-        // got called. ick.
-
-        doReturn(null).when(mockChannel).getAsyncIn();
-        doReturn(null).when(promise).setFailure(any(Throwable.class));
-
-        // Need to reconstruct instance to pick up null async in above
-        instance = new MinaSshNettyChannel(mockContext, mockSession);
-        instance.pipeline().addFirst(new SshWriteAsyncHandlerAdapter(mockChannel));
-
-        // when
-        final var outadapter = (ChannelOutboundHandlerAdapter) instance.pipeline().first();
-        final var mockAlloc = mock(ByteBufAllocator.class);
-        final var bytes = new EmptyByteBuf(mockAlloc);
-        outadapter.write(ctx, bytes, promise);
-
-        // then
-        verify(promise, times(1)).setFailure(any(Throwable.class));
-    }
-}