broker_bootstrap_classify_test.go RawHistoryFolder

1package app
2
3import (
4	"errors"
5	"testing"
6
7	"github.com/stretchr/testify/require"
8
9	"github.com/bnema/vev/internal/adapters/sshstdio"
10	"github.com/bnema/vev/internal/domain"
11	"github.com/bnema/vev/internal/ports"
12)
13
14func TestClassifyBootstrapFailureKeepsKindThroughTheDialChain(t *testing.T) {
15	cause := errors.New("exit status 255")
16	tests := []struct {
17		name   string
18		stderr string
19		nilErr bool
20		want   domain.RemoteFailureKind
21	}{
22		{name: "auth failure is typed", stderr: "user@example.test: Permission denied (publickey).", want: domain.RemoteFailureAuthentication},
23		{name: "unclassified stderr stays untyped", stderr: "connect: connection refused", want: domain.RemoteFailureNone},
24		{name: "nil sink stays untyped", nilErr: true, want: domain.RemoteFailureNone},
25	}
26	for _, tt := range tests {
27		t.Run(tt.name, func(t *testing.T) {
28			var sink *sshstdio.DiagnosticSink
29			if !tt.nilErr {
30				sink = sshstdio.NewDiagnosticSink(0)
31				_, _ = sink.Write([]byte(tt.stderr))
32			}
33			err := classifyBootstrapFailure(sink, cause)
34			// The pool wraps dial failures as a BrokerError cause.
35			wrapped := ports.BrokerError{Code: ports.BrokerErrorUnavailable, Cause: brokerQUICUnavailable("read bootstrap readiness", err)}
36
37			require.ErrorIs(t, wrapped, cause, "the original cause stays in the chain")
38			var typed domain.RemoteFailure
39			if tt.want == domain.RemoteFailureNone {
40				require.False(t, errors.As(wrapped, &typed))
41				return
42			}
43			require.True(t, errors.As(wrapped, &typed))
44			require.Equal(t, tt.want, typed.Kind)
45			require.Contains(t, err.Error(), cause.Error(), "the error text keeps the cause")
46		})
47	}
48}