fix tests

This commit is contained in:
Giuseppe Guerra
2024-01-09 17:42:59 +01:00
parent 0d339c8ab6
commit 46a2420ed1
10 changed files with 22 additions and 21 deletions

View File

@@ -78,7 +78,7 @@ func TestAPIEndpoint_Metrics_QueryMetricsV2(t *testing.T) {
}, },
}, },
}, &fakeDatasources.FakeDataSourceService{}, pluginSettings.ProvideService(dbtest.NewFakeDB(), }, &fakeDatasources.FakeDataSourceService{}, pluginSettings.ProvideService(dbtest.NewFakeDB(),
secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}), secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures()),
) )
serverFeatureEnabled := SetupAPITestServer(t, func(hs *HTTPServer) { serverFeatureEnabled := SetupAPITestServer(t, func(hs *HTTPServer) {
hs.queryDataService = qds hs.queryDataService = qds
@@ -124,7 +124,7 @@ func TestAPIEndpoint_Metrics_PluginDecryptionFailure(t *testing.T) {
}, },
}, },
}, },
ds, pluginSettings.ProvideService(db, secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, ds, pluginSettings.ProvideService(db, secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures(),
) )
qds := query.ProvideService( qds := query.ProvideService(
cfg, cfg,
@@ -301,7 +301,7 @@ func TestDataSourceQueryError(t *testing.T) {
PluginList: []pluginstore.Plugin{pluginstore.ToGrafanaDTO(p)}, PluginList: []pluginstore.Plugin{pluginstore.ToGrafanaDTO(p)},
}, },
ds, pluginSettings.ProvideService(dbtest.NewFakeDB(), ds, pluginSettings.ProvideService(dbtest.NewFakeDB(),
secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}), secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures()),
) )
hs.QuotaService = quotatest.New(false, nil) hs.QuotaService = quotatest.New(false, nil)
}) })

View File

@@ -56,7 +56,7 @@ func TestCallResource(t *testing.T) {
textCtx := pluginsintegration.CreateIntegrationTestCtx(t, cfg, coreRegistry) textCtx := pluginsintegration.CreateIntegrationTestCtx(t, cfg, coreRegistry)
pcp := plugincontext.ProvideService(cfg, localcache.ProvideService(), textCtx.PluginStore, &datasources.FakeDataSourceService{}, pcp := plugincontext.ProvideService(cfg, localcache.ProvideService(), textCtx.PluginStore, &datasources.FakeDataSourceService{},
pluginSettings.ProvideService(db.InitTestDB(t), fakeSecrets.NewFakeSecretsService()), nil, &pCfg) pluginSettings.ProvideService(db.InitTestDB(t), fakeSecrets.NewFakeSecretsService()), nil, &pCfg, featuremgmt.WithFeatures())
srv := SetupAPITestServer(t, func(hs *HTTPServer) { srv := SetupAPITestServer(t, func(hs *HTTPServer) {
hs.Cfg = cfg hs.Cfg = cfg

View File

@@ -61,7 +61,7 @@ func framesPassThroughService(t *testing.T, frames data.Frames) (data.Frames, er
PluginList: []pluginstore.Plugin{ PluginList: []pluginstore.Plugin{
{JSONData: plugins.JSONData{ID: "test"}}, {JSONData: plugins.JSONData{ID: "test"}},
}}, }},
&datafakes.FakeDataSourceService{}, nil, pluginFakes.NewFakeLicensingService(), &config.Cfg{}), &datafakes.FakeDataSourceService{}, nil, pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures()),
tracer: tracing.InitializeTracerForTest(), tracer: tracing.InitializeTracerForTest(),
metrics: newMetrics(nil), metrics: newMetrics(nil),
} }

View File

@@ -42,7 +42,7 @@ func TestService(t *testing.T) {
PluginList: []pluginstore.Plugin{ PluginList: []pluginstore.Plugin{
{JSONData: plugins.JSONData{ID: "test"}}, {JSONData: plugins.JSONData{ID: "test"}},
}, },
}, &datafakes.FakeDataSourceService{}, nil, fakes.NewFakeLicensingService(), &config.Cfg{}) }, &datafakes.FakeDataSourceService{}, nil, fakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures())
s := Service{ s := Service{
cfg: setting.NewCfg(), cfg: setting.NewCfg(),
@@ -128,7 +128,7 @@ func TestDSQueryError(t *testing.T) {
PluginList: []pluginstore.Plugin{ PluginList: []pluginstore.Plugin{
{JSONData: plugins.JSONData{ID: "test"}}, {JSONData: plugins.JSONData{ID: "test"}},
}, },
}, &datafakes.FakeDataSourceService{}, nil, nil, &config.Cfg{}) }, &datafakes.FakeDataSourceService{}, nil, nil, &config.Cfg{}, featuremgmt.WithFeatures())
s := Service{ s := Service{
cfg: setting.NewCfg(), cfg: setting.NewCfg(),

View File

@@ -39,7 +39,7 @@ func TestInitializer_envVars(t *testing.T) {
"custom_env_var": "customVal", "custom_env_var": "customVal",
}, },
}, },
}, licensing) }, licensing, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
assert.Len(t, envVars, 6) assert.Len(t, envVars, 6)
@@ -67,7 +67,7 @@ func TestInitializer_skipHostEnvVars(t *testing.T) {
} }
t.Run("without FlagPluginsSkipHostEnvVars should not populate host env vars", func(t *testing.T) { t.Run("without FlagPluginsSkipHostEnvVars should not populate host env vars", func(t *testing.T) {
envVarsProvider := NewProvider(&config.Cfg{Features: featuremgmt.WithFeatures()}, nil) envVarsProvider := NewProvider(&config.Cfg{Features: featuremgmt.WithFeatures()}, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
// We want to test that the envvars.Provider does not add any of the host env vars. // We want to test that the envvars.Provider does not add any of the host env vars.
@@ -82,7 +82,7 @@ func TestInitializer_skipHostEnvVars(t *testing.T) {
JSONData: plugins.JSONData{ID: "test"}, JSONData: plugins.JSONData{ID: "test"},
SkipHostEnvVars: true, SkipHostEnvVars: true,
} }
envVarsProvider := NewProvider(&config.Cfg{}, nil) envVarsProvider := NewProvider(&config.Cfg{}, nil, featuremgmt.WithFeatures())
t.Run("should populate allowed host env vars", func(t *testing.T) { t.Run("should populate allowed host env vars", func(t *testing.T) {
// Set all allowed variables // Set all allowed variables
@@ -493,7 +493,7 @@ func TestInitializer_tracingEnvironmentVariables(t *testing.T) {
}, },
} { } {
t.Run(tc.name, func(t *testing.T) { t.Run(tc.name, func(t *testing.T) {
envVarsProvider := NewProvider(tc.cfg, nil) envVarsProvider := NewProvider(tc.cfg, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), tc.plugin) envVars := envVarsProvider.Get(context.Background(), tc.plugin)
tc.exp(t, envVars) tc.exp(t, envVars)
}) })
@@ -542,7 +542,7 @@ func TestInitializer_authEnvVars(t *testing.T) {
envVarsProvider := NewProvider(&config.Cfg{ envVarsProvider := NewProvider(&config.Cfg{
GrafanaAppURL: "https://myorg.com/", GrafanaAppURL: "https://myorg.com/",
}, nil) }, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
assert.Equal(t, "GF_VERSION=", envVars[0]) assert.Equal(t, "GF_VERSION=", envVars[0])
assert.Equal(t, "GF_APP_URL=https://myorg.com/", envVars[1]) assert.Equal(t, "GF_APP_URL=https://myorg.com/", envVars[1])
@@ -559,7 +559,7 @@ func TestInitalizer_awsEnvVars(t *testing.T) {
AWSAssumeRoleEnabled: true, AWSAssumeRoleEnabled: true,
AWSAllowedAuthProviders: []string{"grafana_assume_role", "keys"}, AWSAllowedAuthProviders: []string{"grafana_assume_role", "keys"},
AWSExternalId: "mock_external_id", AWSExternalId: "mock_external_id",
}, nil) }, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
assert.ElementsMatch(t, []string{"GF_VERSION=", "AWS_AUTH_AssumeRoleEnabled=true", "AWS_AUTH_AllowedAuthProviders=grafana_assume_role,keys", "AWS_AUTH_EXTERNAL_ID=mock_external_id"}, envVars) assert.ElementsMatch(t, []string{"GF_VERSION=", "AWS_AUTH_AssumeRoleEnabled=true", "AWS_AUTH_AllowedAuthProviders=grafana_assume_role,keys", "AWS_AUTH_EXTERNAL_ID=mock_external_id"}, envVars)
}) })
@@ -576,7 +576,7 @@ func TestInitializer_featureToggleEnvVar(t *testing.T) {
p := &plugins.Plugin{} p := &plugins.Plugin{}
envVarsProvider := NewProvider(&config.Cfg{ envVarsProvider := NewProvider(&config.Cfg{
Features: featuremgmt.WithFeatures(expectedFeatures[0], true, expectedFeatures[1], true), Features: featuremgmt.WithFeatures(expectedFeatures[0], true, expectedFeatures[1], true),
}, nil) }, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
assert.Equal(t, 2, len(envVars)) assert.Equal(t, 2, len(envVars))
@@ -621,7 +621,7 @@ func TestInitalizer_azureEnvVars(t *testing.T) {
UsernameAssertion: true, UsernameAssertion: true,
}, },
}, },
}, nil) }, nil, featuremgmt.WithFeatures())
envVars := envVarsProvider.Get(context.Background(), p) envVars := envVarsProvider.Get(context.Background(), p)
assert.ElementsMatch(t, []string{"GF_VERSION=", "GFAZPL_AZURE_CLOUD=AzureCloud", "GFAZPL_MANAGED_IDENTITY_ENABLED=true", assert.ElementsMatch(t, []string{"GF_VERSION=", "GFAZPL_AZURE_CLOUD=AzureCloud", "GFAZPL_MANAGED_IDENTITY_ENABLED=true",
"GFAZPL_MANAGED_IDENTITY_CLIENT_ID=mock_managed_identity_client_id", "GFAZPL_MANAGED_IDENTITY_CLIENT_ID=mock_managed_identity_client_id",

View File

@@ -1623,7 +1623,7 @@ func newLoader(t *testing.T, cfg *config.Cfg, reg registry.Service, proc process
finder.NewLocalFinder(false, featuremgmt.WithFeatures()), reg), finder.NewLocalFinder(false, featuremgmt.WithFeatures()), reg),
pipeline.ProvideBootstrapStage(cfg, signature.DefaultCalculator(cfg), assets), pipeline.ProvideBootstrapStage(cfg, signature.DefaultCalculator(cfg), assets),
pipeline.ProvideValidationStage(cfg, signature.NewValidator(signature.NewUnsignedAuthorizer(cfg)), angularInspector, sigErrTracker), pipeline.ProvideValidationStage(cfg, signature.NewValidator(signature.NewUnsignedAuthorizer(cfg)), angularInspector, sigErrTracker),
pipeline.ProvideInitializationStage(cfg, reg, lic, backendFactory, proc, &fakes.FakeAuthService{}, fakes.NewFakeRoleRegistry()), pipeline.ProvideInitializationStage(cfg, reg, lic, backendFactory, proc, &fakes.FakeAuthService{}, fakes.NewFakeRoleRegistry(), featuremgmt.WithFeatures()),
terminate) terminate)
} }
@@ -1656,7 +1656,7 @@ func newLoaderWithOpts(t *testing.T, cfg *config.Cfg, opts loaderDepOpts) *Loade
finder.NewLocalFinder(false, featuremgmt.WithFeatures()), reg), finder.NewLocalFinder(false, featuremgmt.WithFeatures()), reg),
pipeline.ProvideBootstrapStage(cfg, signature.DefaultCalculator(cfg), assets), pipeline.ProvideBootstrapStage(cfg, signature.DefaultCalculator(cfg), assets),
pipeline.ProvideValidationStage(cfg, signature.NewValidator(signature.NewUnsignedAuthorizer(cfg)), angularInspector, sigErrTracker), pipeline.ProvideValidationStage(cfg, signature.NewValidator(signature.NewUnsignedAuthorizer(cfg)), angularInspector, sigErrTracker),
pipeline.ProvideInitializationStage(cfg, reg, lic, backendFactoryProvider, proc, authServiceRegistry, fakes.NewFakeRoleRegistry()), pipeline.ProvideInitializationStage(cfg, reg, lic, backendFactoryProvider, proc, authServiceRegistry, fakes.NewFakeRoleRegistry(), featuremgmt.WithFeatures()),
terminate) terminate)
} }

View File

@@ -15,6 +15,7 @@ import (
"github.com/grafana/grafana/pkg/plugins/manager/registry" "github.com/grafana/grafana/pkg/plugins/manager/registry"
"github.com/grafana/grafana/pkg/services/datasources" "github.com/grafana/grafana/pkg/services/datasources"
fakeDatasources "github.com/grafana/grafana/pkg/services/datasources/fakes" fakeDatasources "github.com/grafana/grafana/pkg/services/datasources/fakes"
"github.com/grafana/grafana/pkg/services/featuremgmt"
"github.com/grafana/grafana/pkg/services/pluginsintegration/plugincontext" "github.com/grafana/grafana/pkg/services/pluginsintegration/plugincontext"
"github.com/grafana/grafana/pkg/services/pluginsintegration/pluginsettings" "github.com/grafana/grafana/pkg/services/pluginsintegration/pluginsettings"
pluginSettings "github.com/grafana/grafana/pkg/services/pluginsintegration/pluginsettings/service" pluginSettings "github.com/grafana/grafana/pkg/services/pluginsintegration/pluginsettings/service"
@@ -43,7 +44,7 @@ func TestGet(t *testing.T) {
db := &dbtest.FakeDB{ExpectedError: pluginsettings.ErrPluginSettingNotFound} db := &dbtest.FakeDB{ExpectedError: pluginsettings.ErrPluginSettingNotFound}
pcp := plugincontext.ProvideService(cfg, localcache.ProvideService(), pcp := plugincontext.ProvideService(cfg, localcache.ProvideService(),
pluginstore.New(preg, &pluginFakes.FakeLoader{}), pluginstore.New(preg, &pluginFakes.FakeLoader{}),
ds, pluginSettings.ProvideService(db, secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, ds, pluginSettings.ProvideService(db, secretstest.NewFakeSecretsService()), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures(),
) )
identity := &user.SignedInUser{OrgID: int64(1), Login: "admin"} identity := &user.SignedInUser{OrgID: int64(1), Login: "admin"}

View File

@@ -141,7 +141,7 @@ func buildQueryDataService(t *testing.T, cs datasources.CacheService, fpc *fakeP
}, },
}, },
}, ds, pluginSettings.ProvideService(store, fakeSecrets.NewFakeSecretsService()), fakes.NewFakeLicensingService(), }, ds, pluginSettings.ProvideService(store, fakeSecrets.NewFakeSecretsService()), fakes.NewFakeLicensingService(),
&config.Cfg{}) &config.Cfg{}, featuremgmt.WithFeatures())
return query.ProvideService( return query.ProvideService(
setting.NewCfg(), setting.NewCfg(),

View File

@@ -477,7 +477,7 @@ func setup(t *testing.T) *testContext {
{JSONData: plugins.JSONData{ID: "mysql"}}, {JSONData: plugins.JSONData{ID: "mysql"}},
}, },
}, fakeDatasourceService, }, fakeDatasourceService,
pluginSettings.ProvideService(sqlStore, secretsService), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, pluginSettings.ProvideService(sqlStore, secretsService), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures(),
) )
exprService := expr.ProvideService(&setting.Cfg{ExpressionsEnabled: true}, pc, pCtxProvider, exprService := expr.ProvideService(&setting.Cfg{ExpressionsEnabled: true}, pc, pCtxProvider,
&featuremgmt.FeatureManager{}, nil, tracing.InitializeTracerForTest()) &featuremgmt.FeatureManager{}, nil, tracing.InitializeTracerForTest())

View File

@@ -47,7 +47,7 @@ func TestHandleRequest(t *testing.T) {
pCtxProvider := plugincontext.ProvideService(sqlStore.Cfg, localcache.ProvideService(), &pluginstore.FakePluginStore{ pCtxProvider := plugincontext.ProvideService(sqlStore.Cfg, localcache.ProvideService(), &pluginstore.FakePluginStore{
PluginList: []pluginstore.Plugin{{JSONData: plugins.JSONData{ID: "test"}}}, PluginList: []pluginstore.Plugin{{JSONData: plugins.JSONData{ID: "test"}}},
}, dsService, pluginSettings.ProvideService(sqlStore, secretsService), pluginFakes.NewFakeLicensingService(), &config.Cfg{}) }, dsService, pluginSettings.ProvideService(sqlStore, secretsService), pluginFakes.NewFakeLicensingService(), &config.Cfg{}, featuremgmt.WithFeatures())
s := ProvideService(client, nil, dsService, pCtxProvider) s := ProvideService(client, nil, dsService, pCtxProvider)
ds := &datasources.DataSource{ID: 12, Type: "test", JsonData: simplejson.New()} ds := &datasources.DataSource{ID: 12, Type: "test", JsonData: simplejson.New()}