Function handleSSHHandshake

main.go:1269–1297

(conn net.Conn, sshConfig *ssh.ServerConfig, wg *sync.WaitGroup)

}

func handleSSHHandshake(conn net.Conn, sshConfig *ssh.ServerConfig, wg *sync.WaitGroup) {
	defer wg.Done()

	sshConn, chans, reqs, err := ssh.NewServerConn(conn, sshConfig)
	if err != nil {
		mudlog.Warn("SSH handshake failed", "remoteAddr", conn.RemoteAddr().String(), "error", err)
		return
	}
	defer sshConn.Close()

	// Discard all out-of-band requests (keepalive, etc.)
	go ssh.DiscardRequests(reqs)

	for newChan := range chans {
		if newChan.ChannelType() != "session" {
			newChan.Reject(ssh.UnknownChannelType, "unsupported channel type")
			continue
		}

		ch, chanReqs, err := newChan.Accept()
		if err != nil {
			mudlog.Warn("SSH channel accept failed", "error", err)
			return
		}

		wg.Add(1)
		go handleSSHConnection(connections.AddSSH(ch, sshConn.RemoteAddr()), chanReqs, wg)
	}
}

func handleSSHConnection(connDetails *connections.ConnectionDetails, reqs <-chan *ssh.Request, wg *sync.WaitGroup) {
	defer wg.Done()