Function startTestServer

internal/bridge/mockserver_test.go:286–324

--------------------------------------------------------------------------- startTestServer spins up an in-memory gRPC server with bufconn and returns the mock server, a client, and a cleanup function. ---------------------------------------------------------------------------

(t *testing.T)

// ---------------------------------------------------------------------------

func startTestServer(t *testing.T) (*testServer, listenerrpc.ListenerRPCClient, func()) {
	t.Helper()

	srv := newTestServer()
	lis := bufconn.Listen(bufSize)

	gs := grpc.NewServer()
	listenerrpc.RegisterListenerRPCServer(gs, srv)

	go func() {
		if err := gs.Serve(lis); err != nil {
			// Ignore errors after cleanup.
		}
	}()

	dialer := func(ctx context.Context, _ string) (net.Conn, error) {
		return lis.DialContext(ctx)
	}

	conn, err := grpc.DialContext(
		context.Background(),
		"bufnet",
		grpc.WithContextDialer(dialer),
		grpc.WithTransportCredentials(insecure.NewCredentials()),
	)
	if err != nil {
		t.Fatalf("failed to dial bufconn: %v", err)
	}

	client := listenerrpc.NewListenerRPCClient(conn)

	cleanup := func() {
		conn.Close()
		gs.Stop()
		lis.Close()
	}

	return srv, client, cleanup
}

// ---------------------------------------------------------------------------
// newTestBridgeWithRPC creates a Bridge connected to a real gRPC client,