func (s) TestRDSHandleResponseWithoutRDSWatch(t *testing.T) {
	fakeServer, cc, cleanup := startServerAndGetCC(t)
	defer cleanup()
	v2c, err := newV2Client(&testUpdateReceiver{
		f: func(xdsclient.ResourceType, map[string]interface{}, xdsclient.UpdateMetadata) {},
	}, cc, goodNodeProto, func(int) time.Duration { return 0 }, nil)
	if err != nil {
		t.Fatal(err)
	}
	defer v2c.Close()
	ctx, cancel := context.WithTimeout(context.Background(), defaultTestTimeout)
	defer cancel()
	doLDS(ctx, t, v2c, fakeServer)
	if v2c.handleRDSResponse(badResourceTypeInRDSResponse) == nil {
		t.Fatal("v2c.handleRDSResponse() succeeded, should have failed")
	}
	if v2c.handleRDSResponse(goodRDSResponse1) != nil {
		t.Fatal("v2c.handleRDSResponse() succeeded, should have failed")
	}
}
TestRDSHandleResponseWithoutRDSWatch tests the case where the v2Client
receives an RDS response without a registered RDS watcher.
package v2
import (
	"context"
	"testing"
	"time"
	xdspb "github.com/envoyproxy/go-control-plane/envoy/api/v2"
	"github.com/google/go-cmp/cmp/cmpopts"
	"google.golang.org/grpc/xds/internal/testutils/fakeserver"
	"google.golang.org/grpc/xds/internal/xdsclient"
)
func doLDS(ctx context.Context, t *testing.T, v2c xdsclient.APIClient, fakeServer *fakeserver.Server) {
	v2c.AddWatch(xdsclient.ListenerResource, goodLDSTarget1)
	if _, err := fakeServer.XDSRequestChan.Receive(ctx); err != nil {
		t.Fatalf("Timeout waiting for LDS request: %v", err)
	}
}
func (s) TestRDSHandleResponseWithRouting(t *testing.T) {
	tests := []struct {
		name          string
		rdsResponse   *xdspb.DiscoveryResponse
		wantErr       bool
		wantUpdate    map[string]xdsclient.RouteConfigUpdateErrTuple
		wantUpdateMD  xdsclient.UpdateMetadata
		wantUpdateErr bool
	}{
		{
			name:        "badly-marshaled-response",
			rdsResponse: badlyMarshaledRDSResponse,
			wantErr:     true,
			wantUpdate:  nil,
			wantUpdateMD: xdsclient.UpdateMetadata{
				Status: xdsclient.ServiceStatusNACKed,
				ErrState: &xdsclient.UpdateErrorMetadata{
					Err: cmpopts.AnyError,
				},
			},
			wantUpdateErr: false,
		},
		{
			name:        "no-route-config-in-response",
			rdsResponse: badResourceTypeInRDSResponse,
			wantErr:     true,
			wantUpdate:  nil,
			wantUpdateMD: xdsclient.UpdateMetadata{
				Status: xdsclient.ServiceStatusNACKed,
				ErrState: &xdsclient.UpdateErrorMetadata{
					Err: cmpopts.AnyError,
				},
			},
			wantUpdateErr: false,
		},
		{
			name:        "no-virtual-hosts-in-response",
			rdsResponse: noVirtualHostsInRDSResponse,
			wantErr:     false,
			wantUpdate: map[string]xdsclient.RouteConfigUpdateErrTuple{
				goodRouteName1: {Update: xdsclient.RouteConfigUpdate{
					VirtualHosts: nil,
					Raw:          marshaledNoVirtualHostsRouteConfig,
				}},
			},
			wantUpdateMD: xdsclient.UpdateMetadata{
				Status: xdsclient.ServiceStatusACKed,
			},
			wantUpdateErr: false,
		},
		{
			name:        "one-uninteresting-route-config",
			rdsResponse: goodRDSResponse2,
			wantErr:     false,
			wantUpdate: map[string]xdsclient.RouteConfigUpdateErrTuple{
				goodRouteName2: {Update: xdsclient.RouteConfigUpdate{
					VirtualHosts: []*xdsclient.VirtualHost{
						{
							Domains: []string{uninterestingDomain},
							Routes: []*xdsclient.Route{{Prefix: newStringP(""),
								WeightedClusters: map[string]xdsclient.WeightedCluster{uninterestingClusterName: {Weight: 1}},
								RouteAction:      xdsclient.RouteActionRoute}},
						},
						{
							Domains: []string{goodLDSTarget1},
							Routes: []*xdsclient.Route{{
								Prefix:           newStringP(""),
								WeightedClusters: map[string]xdsclient.WeightedCluster{goodClusterName2: {Weight: 1}},
								RouteAction:      xdsclient.RouteActionRoute}},
						},
					},
					Raw: marshaledGoodRouteConfig2,
				}},
			},
			wantUpdateMD: xdsclient.UpdateMetadata{
				Status: xdsclient.ServiceStatusACKed,
			},
			wantUpdateErr: false,
		},
		{
			name:        "one-good-route-config",
			rdsResponse: goodRDSResponse1,
			wantErr:     false,
			wantUpdate: map[string]xdsclient.RouteConfigUpdateErrTuple{
				goodRouteName1: {Update: xdsclient.RouteConfigUpdate{
					VirtualHosts: []*xdsclient.VirtualHost{
						{
							Domains: []string{uninterestingDomain},
							Routes: []*xdsclient.Route{{
								Prefix:           newStringP(""),
								WeightedClusters: map[string]xdsclient.WeightedCluster{uninterestingClusterName: {Weight: 1}},
								RouteAction:      xdsclient.RouteActionRoute}},
						},
						{
							Domains: []string{goodLDSTarget1},
							Routes: []*xdsclient.Route{{Prefix: newStringP(""),
								WeightedClusters: map[string]xdsclient.WeightedCluster{goodClusterName1: {Weight: 1}},
								RouteAction:      xdsclient.RouteActionRoute}},
						},
					},
					Raw: marshaledGoodRouteConfig1,
				}},
			},
			wantUpdateMD: xdsclient.UpdateMetadata{
				Status: xdsclient.ServiceStatusACKed,
			},
			wantUpdateErr: false,
		},
	}
	for _, test := range tests {
		t.Run(test.name, func(t *testing.T) {
			testWatchHandle(t, &watchHandleTestcase{
				rType:            xdsclient.RouteConfigResource,
				resourceName:     goodRouteName1,
				responseToHandle: test.rdsResponse,
				wantHandleErr:    test.wantErr,
				wantUpdate:       test.wantUpdate,
				wantUpdateMD:     test.wantUpdateMD,
				wantUpdateErr:    test.wantUpdateErr,
			})
		})
	}
}