Method StartContainerSSH

e2e_framework_test.go:104–171

()

}

func (c *testContext) StartContainerSSH() {
	t := c.T
	t.Helper()
	c.lock.Lock()
	defer c.lock.Unlock()

	if c.lifecycle != nil {
		t.Fatalf("ContainerSSH is already running.")
	}

	t.Logf("Starting ContainerSSH...")

	c.authPort = test.GetNextPort(c.T, "auth server")
	c.authServer(c.T, c.users, c.authPort)
	c.cfg.Auth.PasswordAuth.Method = config.PasswordAuthMethodWebhook
	c.cfg.Auth.PasswordAuth.Webhook.URL = fmt.Sprintf("http://127.0.0.1:%d", c.authPort)
	c.cfg.Auth.PublicKeyAuth.Method = config.PubKeyAuthMethodWebhook
	c.cfg.Auth.PublicKeyAuth.Webhook.URL = fmt.Sprintf("http://127.0.0.1:%d", c.authPort)

	c.sshPort = test.GetNextPort(c.T, "ContainerSSH")
	c.cfg.SSH.Listen = fmt.Sprintf("127.0.0.1:%d", c.sshPort)
	if err := c.cfg.SSH.GenerateHostKey(); err != nil {
		t.Fatalf("Failed to generate host keys (%v)", err)
	}
	c.cfg.Log.T = c.T
	c.cfg.Log.Destination = config.LogDestinationTest

	cssh, lifecycle, err := containerssh.New(c.cfg, log.NewLoggerFactory())
	if err != nil {
		t.Fatalf("Failed to start ContainerSSH (%v)", err)
	}
	c.lifecycle = lifecycle
	running := make(chan struct{})
	stopped := make(chan struct{})
	crashed := make(chan struct{})
	lifecycle.OnRunning(
		func(s service.Service, l service.Lifecycle) {
			close(running)
		},
	)
	lifecycle.OnStopping(
		func(s service.Service, l service.Lifecycle, shutdownContext context.Context) {
			close(stopped)
		},
	)
	lifecycle.OnCrashed(
		func(s service.Service, l service.Lifecycle, err error) {
			close(crashed)
		},
	)
	go func() {
		_ = cssh.RunWithLifecycle(lifecycle)
	}()
	c.T.Cleanup(func() {
		lifecycle.Stop(context.Background())
	})

	select {