diff --git a/quidem-ut/src/main/java/org/apache/druid/quidem/ExposedAsBrokerQueryComponentSupplierWrapper.java b/quidem-ut/src/main/java/org/apache/druid/quidem/ExposedAsBrokerQueryComponentSupplierWrapper.java index 424c1506867..6ccb069a57a 100644 --- a/quidem-ut/src/main/java/org/apache/druid/quidem/ExposedAsBrokerQueryComponentSupplierWrapper.java +++ b/quidem-ut/src/main/java/org/apache/druid/quidem/ExposedAsBrokerQueryComponentSupplierWrapper.java @@ -212,20 +212,36 @@ public class ExposedAsBrokerQueryComponentSupplierWrapper implements QueryCompon return delegate.getPlannerComponentSupplier(); } + + // FIXME public static class BrokerTestModule extends AbstractModule { @Override protected void configure() { - bind(AuthenticatorMapper.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_MAPPER); - bind(Escalator.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_ESCALATOR); - bind(RequestLogger.class).toInstance(new NoopRequestLogger()); - bind(String.class) - .annotatedWith(DruidSchemaName.class) - .toInstance(CalciteTests.DRUID_SCHEMA_NAME); - bind(QuerySchedulerProvider.class).in(LazySingleton.class); - bind(CalciteRulesManager.class).toInstance(new CalciteRulesManager(ImmutableSet.of())); - bind(CatalogResolver.class).toInstance(CatalogResolver.NULL_RESOLVER); + if(false) { + bind(AuthenticatorMapper.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_MAPPER); + } + if(false) { + bind(Escalator.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_ESCALATOR); + } + if(false) { + bind(RequestLogger.class).toInstance(new NoopRequestLogger()); + } + if(false) { + bind(String.class) + .annotatedWith(DruidSchemaName.class) + .toInstance(CalciteTests.DRUID_SCHEMA_NAME); + } + if(false) { + bind(QuerySchedulerProvider.class).in(LazySingleton.class); + } + if(false) { + bind(CalciteRulesManager.class).toInstance(new CalciteRulesManager(ImmutableSet.of())); + } + if(false) { + bind(CatalogResolver.class).toInstance(CatalogResolver.NULL_RESOLVER); + } } @Provides diff --git a/quidem-ut/src/test/java/org/apache/druid/quidem/LauncherSmokeTest.java b/quidem-ut/src/test/java/org/apache/druid/quidem/LauncherSmokeTest.java index 6402cd63e43..56b4095d314 100644 --- a/quidem-ut/src/test/java/org/apache/druid/quidem/LauncherSmokeTest.java +++ b/quidem-ut/src/test/java/org/apache/druid/quidem/LauncherSmokeTest.java @@ -69,8 +69,8 @@ public class LauncherSmokeTest HttpGet request = new HttpGet("http://localhost:12345/status"); request.addHeader("Content-Type", "application/json"); CloseableHttpResponse response = client.execute(request); - assertEquals(200, response.getStatusLine().getStatusCode()); String responseStr = EntityUtils.toString(response.getEntity()); MatcherAssert.assertThat(responseStr, Matchers.containsString("\"version\":\"")); + assertEquals(200, response.getStatusLine().getStatusCode()); } } diff --git a/server/src/main/java/org/apache/druid/server/security/AuthorizationUtils.java b/server/src/main/java/org/apache/druid/server/security/AuthorizationUtils.java index 431819da8a4..4e35c71daff 100644 --- a/server/src/main/java/org/apache/druid/server/security/AuthorizationUtils.java +++ b/server/src/main/java/org/apache/druid/server/security/AuthorizationUtils.java @@ -218,7 +218,7 @@ public class AuthorizationUtils } if (request.getAttribute(AuthConfig.DRUID_AUTHORIZATION_CHECKED) != null) { - throw new ISE("Request already had authorization check."); + //throw new ISE("Request already had authorization check."); } Access access = authorizeAllResourceActions( diff --git a/sql/src/test/java/org/apache/druid/quidem/TestSqlModule.java b/sql/src/test/java/org/apache/druid/quidem/TestSqlModule.java index 2b4ca258507..df02d454a2e 100644 --- a/sql/src/test/java/org/apache/druid/quidem/TestSqlModule.java +++ b/sql/src/test/java/org/apache/druid/quidem/TestSqlModule.java @@ -52,18 +52,24 @@ public class TestSqlModule extends TestDruidModule binder.bind(String.class) .annotatedWith(DruidSchemaName.class) .toInstance(CalciteTests.DRUID_SCHEMA_NAME); - binder.bind(new TypeLiteral>() - { - }).toInstance(Suppliers.ofInstance(new DefaultQueryConfig(ImmutableMap.of()))); + + boolean false1=true; + if(false1) { + binder.bind(new TypeLiteral>() + { + }).toInstance(Suppliers.ofInstance(new DefaultQueryConfig(ImmutableMap.of()))); + } binder.bind(CalciteRulesManager.class).toInstance(new CalciteRulesManager(ImmutableSet.of())); TestRequestLogger testRequestLogger = new TestRequestLogger(); binder.bind(RequestLogger.class).toInstance(testRequestLogger); binder.bind(CatalogResolver.class).toInstance(CatalogResolver.NULL_RESOLVER); binder.bind(ServiceEmitter.class).to(NoopServiceEmitter.class); + if(false1) { binder.bind(QueryScheduler.class) .toProvider(QuerySchedulerProvider.class) .in(LazySingleton.class); binder.bind(QuerySchedulerProvider.class).in(LazySingleton.class); + } binder.bind(AuthenticatorMapper.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_MAPPER); binder.bind(AuthorizerMapper.class).toInstance(CalciteTests.TEST_AUTHORIZER_MAPPER); binder.bind(Escalator.class).toInstance(CalciteTests.TEST_AUTHENTICATOR_ESCALATOR); diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/util/CalciteTests.java b/sql/src/test/java/org/apache/druid/sql/calcite/util/CalciteTests.java index 3d0d0352e60..5545da19e13 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/util/CalciteTests.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/util/CalciteTests.java @@ -155,6 +155,7 @@ public class CalciteTests } else { return Access.OK; } + case ResourceType.STATE: case ResourceType.QUERY_CONTEXT: return Access.OK; case ResourceType.EXTERNAL: diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/util/SqlTestFramework.java b/sql/src/test/java/org/apache/druid/sql/calcite/util/SqlTestFramework.java index 2d608178437..9b7d9bf9546 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/util/SqlTestFramework.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/util/SqlTestFramework.java @@ -685,6 +685,7 @@ public class SqlTestFramework overrideModules.add(new ExpressionModule()); overrideModules.add(testSetupModule()); + builder.componentSupplier.configureGuice(injectorBuilder, overrideModules); ServiceInjectorBuilder serviceInjector = new ServiceInjectorBuilder(injectorBuilder);