■ ■ ■ ■ ■ ■
internal/client/handlers/jumphost.go
| skipped 9 lines |
10 | 10 | | "golang.org/x/crypto/ssh" |
11 | 11 | | ) |
12 | 12 | | |
13 | | - | func JumpHandler(sshPriv ssh.Signer) internal.ChannelHandler { |
| 13 | + | func JumpHandler(sshPriv ssh.Signer, serverConn ssh.Conn) internal.ChannelHandler { |
14 | 14 | | |
15 | 15 | | return func(_ *internal.User, newChannel ssh.NewChannel, log logger.Logger) { |
16 | 16 | | connection, requests, err := newChannel.Accept() |
| skipped 31 lines |
48 | 48 | | } |
49 | 49 | | defer conn.Close() |
50 | 50 | | |
51 | | - | clientLog := logger.NewLog(conn.RemoteAddr().String()) |
| 51 | + | clientLog := logger.NewLog(serverConn.RemoteAddr().String()) |
52 | 52 | | clientLog.Info("New SSH connection, version %s", conn.ClientVersion()) |
53 | 53 | | |
54 | | - | user, err := internal.CreateUser(conn) |
| 54 | + | user, err := internal.CreateUser(serverConn) |
55 | 55 | | if err != nil { |
56 | 56 | | log.Error("Unable to add user %s\n", err) |
57 | 57 | | return |
| skipped 48 lines |