Function startHub

internal/nodeagent/integration_test.go:67–79

startHub 用 bufconn 起一个 nodehub.Hub，PeerExtractor 总是返回 "n1"。

(t *testing.T, ph nodehub.PushHandler)

// startHub 用 bufconn 起一个 nodehub.Hub，PeerExtractor 总是返回 "n1"。
func startHub(t *testing.T, ph nodehub.PushHandler) (*nodehub.Hub, func(context.Context, string) (net.Conn, error), func()) {
	t.Helper()
	lis := bufconn.Listen(1 << 20)
	srv := grpc.NewServer()
	hub := nodehub.New(nodehub.Options{
		PushHandler:   ph,
		PeerExtractor: func(_ context.Context) (string, error) { return "n1", nil },
	})
	nodev1.RegisterNodeAgentServer(srv, hub)
	go func() { _ = srv.Serve(lis) }()
	dialer := func(ctx context.Context, _ string) (net.Conn, error) { return lis.DialContext(ctx) }
	return hub, dialer, func() { srv.Stop() }
}

// TestIntegration_HelloAndCall 验证 hello 含 config_hash + hub.Call → dispatcher 路由。
func TestIntegration_HelloAndCall(t *testing.T) {