Function VerifySSHConnectionCtx

utils/ssh.go:449–481

VerifySSHConnectionCtx ensures a fresh SSH connection succeeds before we hand control off to the system SSH binary.

(ctx context.Context, ip, keyFile string, port int)

// VerifySSHConnectionCtx ensures a fresh SSH connection succeeds before we hand
// control off to the system SSH binary.
func VerifySSHConnectionCtx(ctx context.Context, ip, keyFile string, port int) error {
	const (
		maxAttempts = 3
		retryDelay  = 2 * time.Second
	)

	var lastErr error
	for attempt := 1; attempt <= maxAttempts; attempt++ {
		client, err := RobustSSHConnectCtx(ctx, ip, keyFile, port, 30)
		if err == nil {
			_, cmdErr := ExecuteSSHCommand(client, "true")
			client.Close()
			if cmdErr == nil {
				return nil
			}
			lastErr = cmdErr
		} else {
			lastErr = err
		}

		if attempt < maxAttempts {
			if err := sleepWithContext(ctx, retryDelay); err != nil {
				return fmt.Errorf("SSH connection cancelled")
			}
		}
	}

	if lastErr == nil {
		lastErr = fmt.Errorf("unknown verification error")
	}

	return fmt.Errorf("SSH verification failed: %w", lastErr)
}

func ExecuteSSHCommand(client *SSHClient, command string) (string, error) {
	if client == nil || client.client == nil {