local_route_probe_test_helpers_test.go RawHistoryFolder

1package app
2
3import (
4	"errors"
5	"fmt"
6
7	"github.com/bnema/vev/internal/adapters/brokerconfig"
8	"github.com/bnema/vev/internal/adapters/daemonmux"
9	"github.com/bnema/vev/internal/ports"
10	"github.com/bnema/vev/internal/usecase/broker"
11)
12
13// newLocalRouteProbe fences one broker-owned local binding into a probe over a
14// dial seam. The binding's identity, policy, and route address must validate,
15// the ceilings must be a valid advertisement, the epoch must be the broker
16// process incarnation every local stream is scoped to, and a nil dial is
17// refused: a probe that cannot establish a carriage must not exist. It builds
18// its own endpoint connector; a caller that already owns the pooled connector
19// uses newLocalRouteProbeWithConnector instead, exactly as brokerLocalProbe
20// does in production.
21func newLocalRouteProbe(binding brokerconfig.LocalBinding, epoch ports.BrokerEpoch, dial localCarrierDialer, ceilings daemonmux.MuxCeilings) (*broker.LocalDaemonProbe, error) {
22	if dial == nil {
23		return nil, errors.New("broker local probe requires a dialer")
24	}
25	connector, err := daemonmux.NewEndpointConnector(daemonmux.RawCarrierDialer(dial), ceilings)
26	if err != nil {
27		return nil, fmt.Errorf("broker local probe: %w", err)
28	}
29	return newLocalRouteProbeWithConnector(binding, epoch, connector)
30}
31
32// newLocalRouteProbeWithConnector fences one broker-owned local binding into a
33// probe over an existing connector, delegating to the same
34// newDynamicLocalRouteProbe production constructor brokerLocalProbe uses.
35func newLocalRouteProbeWithConnector(binding brokerconfig.LocalBinding, epoch ports.BrokerEpoch, connector ports.BrokerEndpointConnector) (*broker.LocalDaemonProbe, error) {
36	return newDynamicLocalRouteProbe(binding.Route, binding.Policy, epoch, connector, func() (ports.BrokerDaemonIdentity, error) {
37		return binding.Identity, nil
38	})
39}