Require a subsystem for client connections

[netconf.git] / transport / transport-ssh / src / main / java / org / opendaylight / netconf / transport / ssh / SSHServer.java

diff --git a/transport/transport-ssh/src/main/java/org/opendaylight/netconf/transport/ssh/SSHServer.java b/transport/transport-ssh/src/main/java/org/opendaylight/netconf/transport/ssh/SSHServer.java
index bbbf4a933bc7e2b8fbccc3101aa6020ec7cff9c2..8631e105ae05a3aad4cebe5fba3f2b7260f3b0dc 100644 (file)
--- a/transport/transport-ssh/src/main/java/org/opendaylight/netconf/transport/ssh/SSHServer.java
+++ b/transport/transport-ssh/src/main/java/org/opendaylight/netconf/transport/ssh/SSHServer.java
@@ -23,11 +23,15 @@ import org.opendaylight.netconf.transport.tcp.TCPServer;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.ssh.server.rev230417.SshServerGrouping;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.tcp.client.rev230417.TcpClientGrouping;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.tcp.server.rev230417.TcpServerGrouping;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * A {@link TransportStack} acting as an SSH server.
  */
 public final class SSHServer extends SSHTransportStack {
+    private static final Logger LOG = LoggerFactory.getLogger(SSHServer.class);
+
     private SSHServer(final TransportChannelListener listener, final TransportSshServer sshServer) {
         super(listener, sshServer, sshServer.getSessionFactory());
     }
@@ -56,4 +60,12 @@ public final class SSHServer extends SSHTransportStack {
     void onKeyEstablished(final Session session) {
         // No-op
     }
+
+    @Override
+    void onAuthenticated(final Session session) {
+        final var sessionId = sessionId(session);
+        LOG.debug("Established transport on session {}", sessionId);
+        // FIXME: we should wait for the subsystem to be created and then finish
+        completeUnderlay(sessionId, underlay -> addTransportChannel(new SSHTransportChannel(underlay)));
+    }
 }
\ No newline at end of file