Method LoginViaSSH

e2e_framework_test.go:203–251

()

}

func (c *testContext) LoginViaSSH() {
	t := c.T
	t.Helper()
	c.lock.Lock()
	defer c.lock.Unlock()
	if c.sshConn != nil {
		t.Fatalf("Already logged in via SSH.")
	}

	t.Logf("Logging in via SSH...")

	cfg := ssh.ClientConfig{}
	cfg.SetDefaults()
	username := c.T.Name()
	user := c.users.AddUser(username)
	password := "test-login"
	user.SetPassword(password)
	cfg.Auth = append(cfg.Auth, ssh.Password(password))

	hostKeys, err := c.cfg.SSH.LoadHostKeys()
	if err != nil {
		t.Fatalf("Failed to read back the host keys (%v)", err)
	}
	hostKeyAlgorithms := make([]string, len(hostKeys))
	marshalledHostKeys := make([]string, len(hostKeys))
	for i, hostKey := range hostKeys {
		hostKeyAlgorithms[i] = hostKey.PublicKey().Type()
		marshalledHostKeys[i] = string(ssh.MarshalAuthorizedKey(hostKey.PublicKey()))
	}
	cfg.HostKeyAlgorithms = hostKeyAlgorithms
	cfg.HostKeyCallback = func(hostname string, remote net.Addr, key ssh.PublicKey) error {
		marshalledHostKey := string(ssh.MarshalAuthorizedKey(key))
		for _, hostKey := range marshalledHostKeys {
			if hostKey == marshalledHostKey {
				return nil
			}
		}
		return fmt.Errorf("invalid host key: %s", marshalledHostKey)
	}
	cfg.User = username

	sshConn, err := ssh.Dial("tcp", fmt.Sprintf("127.0.0.1:%d", c.sshPort), &cfg)
	if err != nil {
		t.Fatalf("Failed to log in via SSH (%v)", err)
	}
	c.sshConn = sshConn

	t.Logf("SSH login successful.")
}

func (c *testContext) StartSessionChannel() {
	t := c.T