Function newPeerConfigTestFixture

operator/pkg/bgp/peer_test.go:46–139

(t *testing.T, ctx context.Context, enableStatusReport bool)

}

func newPeerConfigTestFixture(t *testing.T, ctx context.Context, enableStatusReport bool) (*peerConfigTestFixture, func()) {
	f := &peerConfigTestFixture{}

	type watchSync struct {
		once    sync.Once
		watchCh chan any
	}

	rws := map[string]*watchSync{
		"ciliumbgppeerconfigs": {watchCh: make(chan any)},
	}

	if enableStatusReport {
		rws["secrets"] = &watchSync{watchCh: make(chan any)}
	}

	reactorFn := func(tracker k8sTesting.ObjectTracker) func(action k8sTesting.Action) (handled bool, ret watch.Interface, err error) {
		return func(action k8sTesting.Action) (handled bool, ret watch.Interface, err error) {
			w := action.(k8sTesting.WatchAction)
			gvr := w.GetResource()
			ns := w.GetNamespace()

			// Extract ListOptions for WatchList semantics (SendInitialEvents)
			var opts []meta_v1.ListOptions
			if watchAction, ok := action.(k8sTesting.WatchActionImpl); ok {
				opts = append(opts, watchAction.ListOptions)
			}

			watch, err := tracker.Watch(gvr, ns, opts...)
			if err != nil {
				return false, nil, err
			}
			rw, ok := rws[w.GetResource().Resource]
			if !ok {
				return false, watch, nil
			}
			rw.once.Do(func() { close(rw.watchCh) })
			return true, watch, nil
		}
	}

	// make sure watchers are initialized before the test starts
	watchersReadyFn := func() {
		for name, rw := range rws {
			select {
			case <-ctx.Done():
				require.Fail(t, fmt.Sprintf("Context expired while waiting for %s", name))
			case <-rw.watchCh:
			}
		}
	}

	hive := hive.New(
		cell.Module("test", "test",
			cell.Provide(
				k8sClient.NewFakeClientset,
				newSecretResource,
				k8s.CiliumBGPPeerConfigResource,