handshake_test.go RawHistoryFolder

1package client
2
3import (
4	"context"
5	"errors"
6	"testing"
7
8	"github.com/stretchr/testify/require"
9
10	"github.com/bnema/vev/internal/ports"
11	"github.com/bnema/vev/internal/protocol"
12)
13
14type failedContextDialer struct {
15	ctx context.Context
16}
17
18func (d *failedContextDialer) Dial(ctx context.Context) (ports.ClientConnection, error) {
19	d.ctx = ctx
20	return nil, errors.New("dial failed")
21}
22
23// boundedDial is retained only for this old timeout-contract test; the
24// autonomous supervisor opens through the broker instead.
25func boundedDial(ctx context.Context, dialer ports.ClientDialer) (ports.ClientConnection, error) {
26	bounded, _, finish := newBoundedContext(ctx, systemClock{}, protocol.HandshakeTimeout)
27	defer finish()
28	return dialer.Dial(bounded)
29}
30
31func TestBoundedDialCancelsPrivateContextAfterFailure(t *testing.T) {
32	dialer := &failedContextDialer{}
33	_, err := boundedDial(context.Background(), dialer)
34	require.ErrorContains(t, err, "dial failed")
35	require.NotNil(t, dialer.ctx)
36	require.ErrorIs(t, dialer.ctx.Err(), context.Canceled)
37}