Function TestGRPC

pkg/gatewayconfigurationserver/server_test.go:248–442

(t *testing.T)

}

func TestGRPC(t *testing.T) {
	ctx := log.NewContext(test.Context(), test.GetLogger(t))
	is, isAddr, closeIS := mockis.New(ctx)
	defer closeIS()

	testGtw := mockis.DefaultGateway(registeredGatewayID, false, false)
	is.GatewayRegistry().Add(ctx, registeredGatewayID, "Bearer", registeredGatewayKey, testGtw, ttnpb.Right_RIGHT_GATEWAY_INFO)

	fpConf := config.FrequencyPlansConfig{
		ConfigSource: "static",
		Static:       test.StaticFrequencyPlans,
	}
	fps := frequencyplans.NewStore(test.Must(fpConf.Fetcher(ctx, config.BlobConfig{}, test.HTTPClientProvider)).(fetch.Interface))

	conf := &component.Config{
		ServiceBase: config.ServiceBase{
			HTTP: config.HTTP{
				Listen: ":0",
			},
			FrequencyPlans: fpConf,
			Cluster: cluster.Config{
				IdentityServer: isAddr,
			},
		},
	}
	c := componenttest.NewComponent(t, conf)
	c.AddContextFiller(func(ctx context.Context) context.Context {
		ctx = newContextWithRightsFetcher(ctx)
		return ctx
	})

	test.Must(New(c, testConfig))
	componenttest.StartComponent(t, c)
	defer c.Close()

	mustHavePeer(ctx, c, ttnpb.ClusterRole_ENTITY_REGISTRY)

	mustHavePeer(ctx, c, ttnpb.ClusterRole_ENTITY_REGISTRY)
	t.Run("Authorization", func(t *testing.T) {
		a := assertions.New(t)
		for _, tc := range []struct {
			Name         string
			ID           *ttnpb.GatewayIdentifiers
			Key          string
			ErrAssertion func(error) bool
		}{
			{
				Name: "Valid",
				ID:   registeredGatewayID,
				Key:  registeredGatewayKey,
			},
			{
				Name:         "InvalidKey",
				ID:           registeredGatewayID,
				Key:          "invalid key",
				ErrAssertion: errors.IsPermissionDenied,
			},
			{