generated from quarkiverse/quarkiverse-template
-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Allow deactivating the extension at runtime
- Loading branch information
Showing
9 changed files
with
307 additions
and
66 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
122 changes: 122 additions & 0 deletions
122
deployment/src/test/java/io/quarkiverse/unleash/NoOpUnleashTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,122 @@ | ||
| package io.quarkiverse.unleash; | ||
|
|
||
| import static org.junit.jupiter.api.Assertions.*; | ||
|
|
||
| import jakarta.enterprise.context.ApplicationScoped; | ||
| import jakarta.enterprise.inject.Instance; | ||
| import jakarta.inject.Inject; | ||
|
|
||
| import org.jboss.shrinkwrap.api.asset.StringAsset; | ||
| import org.junit.jupiter.api.Test; | ||
| import org.junit.jupiter.api.extension.RegisterExtension; | ||
|
|
||
| import io.getunleash.Unleash; | ||
| import io.getunleash.Variant; | ||
| import io.quarkiverse.unleash.runtime.NoOpUnleash; | ||
| import io.quarkus.test.QuarkusUnitTest; | ||
|
|
||
| public class NoOpUnleashTest { | ||
|
|
||
| @RegisterExtension | ||
| static final QuarkusUnitTest TEST = new QuarkusUnitTest().withApplicationRoot((jar) -> jar | ||
| .addAsResource(new StringAsset("quarkus.unleash.active=false"), "application.properties") | ||
| .addClass(TestBean.class)); | ||
|
|
||
| @Inject | ||
| TestBean testBean; | ||
|
|
||
| @Test | ||
| void testInjectedImplementation() { | ||
| assertEquals(NoOpUnleash.class, testBean.getUnleash().getClass()); | ||
| } | ||
|
|
||
| @Test | ||
| void testFeatureToggle() { | ||
| assertFalse(testBean.getAlpha().get()); | ||
| assertTrue(testBean.getBravo().get()); | ||
| } | ||
|
|
||
| @Test | ||
| void testFeatureVariant() { | ||
| assertNull(testBean.getCharlie().get()); | ||
| assertNull(testBean.getDelta().get()); | ||
| assertNull(testBean.getEcho().get()); | ||
| } | ||
|
|
||
| @Test | ||
| void testUnleashValues() { | ||
| assertFalse(testBean.isEnabled("foxtrot")); | ||
| assertTrue(testBean.isEnabled("golf", true)); | ||
| assertNull(testBean.getVariant("hotel")); | ||
| Variant variant = new Variant("india", "payload", true); | ||
| assertEquals(variant, testBean.getVariant("india", variant)); | ||
| } | ||
|
|
||
| @ApplicationScoped | ||
| static class TestBean { | ||
|
|
||
| @FeatureToggle(name = "alpha") | ||
| Instance<Boolean> alpha; | ||
|
|
||
| @FeatureToggle(name = "bravo", defaultValue = true) | ||
| Instance<Boolean> bravo; | ||
|
|
||
| @FeatureVariant(name = "charlie") | ||
| Instance<String> charlie; | ||
|
|
||
| @FeatureVariant(name = "delta") | ||
| Instance<Variant> delta; | ||
|
|
||
| @FeatureVariant(name = "echo") | ||
| Instance<Param> echo; | ||
|
|
||
| @Inject | ||
| Unleash unleash; | ||
|
|
||
| public Instance<Boolean> getAlpha() { | ||
| return alpha; | ||
| } | ||
|
|
||
| public Instance<Boolean> getBravo() { | ||
| return bravo; | ||
| } | ||
|
|
||
| public Instance<String> getCharlie() { | ||
| return charlie; | ||
| } | ||
|
|
||
| public Instance<Variant> getDelta() { | ||
| return delta; | ||
| } | ||
|
|
||
| public Instance<Param> getEcho() { | ||
| return echo; | ||
| } | ||
|
|
||
| public Unleash getUnleash() { | ||
| return unleash; | ||
| } | ||
|
|
||
| public boolean isEnabled(String toggleName) { | ||
| return unleash.isEnabled(toggleName); | ||
| } | ||
|
|
||
| public boolean isEnabled(String toggleName, boolean defaultSetting) { | ||
| return unleash.isEnabled(toggleName, defaultSetting); | ||
| } | ||
|
|
||
| public Variant getVariant(String toggleName) { | ||
| return unleash.getVariant(toggleName); | ||
| } | ||
|
|
||
| public Variant getVariant(String toggleName, Variant defaultValue) { | ||
| return unleash.getVariant(toggleName, defaultValue); | ||
| } | ||
| } | ||
|
|
||
| public static class Param { | ||
| public String text; | ||
| public Long value; | ||
| public Boolean enabled; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
86 changes: 86 additions & 0 deletions
86
runtime/src/main/java/io/quarkiverse/unleash/runtime/NoOpUnleash.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,86 @@ | ||
| package io.quarkiverse.unleash.runtime; | ||
|
|
||
| import java.util.Collections; | ||
| import java.util.List; | ||
| import java.util.Optional; | ||
| import java.util.function.BiPredicate; | ||
|
|
||
| import io.getunleash.EvaluatedToggle; | ||
| import io.getunleash.FeatureToggle; | ||
| import io.getunleash.MoreOperations; | ||
| import io.getunleash.Unleash; | ||
| import io.getunleash.UnleashContext; | ||
| import io.getunleash.Variant; | ||
|
|
||
| public class NoOpUnleash implements Unleash { | ||
|
|
||
| @Override | ||
| public boolean isEnabled(String toggleName, UnleashContext context, BiPredicate<String, UnleashContext> fallbackAction) { | ||
| if (fallbackAction != null) { | ||
| return fallbackAction.test(toggleName, context); | ||
| } else { | ||
| return false; | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public Variant getVariant(String toggleName, UnleashContext context) { | ||
| return null; | ||
| } | ||
|
|
||
| @Override | ||
| public Variant getVariant(String toggleName, UnleashContext context, Variant defaultValue) { | ||
| return defaultValue; | ||
| } | ||
|
|
||
| @Override | ||
| public Variant deprecatedGetVariant(String toggleName, UnleashContext context) { | ||
| return null; | ||
| } | ||
|
|
||
| @Override | ||
| public Variant deprecatedGetVariant(String toggleName, UnleashContext context, Variant defaultValue) { | ||
| return defaultValue; | ||
| } | ||
|
|
||
| @Override | ||
| public List<String> getFeatureToggleNames() { | ||
| return Collections.emptyList(); | ||
| } | ||
|
|
||
| @Override | ||
| public MoreOperations more() { | ||
| return more; | ||
| } | ||
|
|
||
| private final MoreOperations more = new MoreOperations() { | ||
|
|
||
| @Override | ||
| public List<String> getFeatureToggleNames() { | ||
| return Collections.emptyList(); | ||
| } | ||
|
|
||
| @Override | ||
| public Optional<FeatureToggle> getFeatureToggleDefinition(String toggleName) { | ||
| return Optional.empty(); | ||
| } | ||
|
|
||
| @Override | ||
| public List<EvaluatedToggle> evaluateAllToggles() { | ||
| return Collections.emptyList(); | ||
| } | ||
|
|
||
| @Override | ||
| public List<EvaluatedToggle> evaluateAllToggles(UnleashContext context) { | ||
| return Collections.emptyList(); | ||
| } | ||
|
|
||
| @Override | ||
| public void count(String toggleName, boolean enabled) { | ||
| } | ||
|
|
||
| @Override | ||
| public void countVariant(String toggleName, String variantName) { | ||
| } | ||
| }; | ||
| } |
24 changes: 24 additions & 0 deletions
24
runtime/src/main/java/io/quarkiverse/unleash/runtime/UnleashLifecycleManager.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,24 @@ | ||
| package io.quarkiverse.unleash.runtime; | ||
|
|
||
| import jakarta.enterprise.event.Observes; | ||
| import jakarta.enterprise.event.Shutdown; | ||
| import jakarta.enterprise.event.Startup; | ||
|
|
||
| import io.getunleash.Unleash; | ||
| import io.quarkus.logging.Log; | ||
|
|
||
| public class UnleashLifecycleManager { | ||
|
|
||
| // This method is used to eagerly create the Unleash bean instance at RUNTIME_INIT execution time. | ||
| void onStartup(@Observes Startup event, Unleash unleash) { | ||
| unleash.more(); | ||
| } | ||
|
|
||
| void onShutdown(@Observes Shutdown event, Unleash unleash) { | ||
| try { | ||
| unleash.shutdown(); | ||
| } catch (Exception ex) { | ||
| Log.error("Shutdown unleash client failed!", ex); | ||
| } | ||
| } | ||
| } |
40 changes: 36 additions & 4 deletions
40
runtime/src/main/java/io/quarkiverse/unleash/runtime/UnleashRecorder.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,15 +1,47 @@ | ||
| package io.quarkiverse.unleash.runtime; | ||
|
|
||
| import io.quarkus.arc.Arc; | ||
| import java.util.function.Supplier; | ||
|
|
||
| import org.jboss.logging.Logger; | ||
|
|
||
| import io.getunleash.Unleash; | ||
| import io.quarkus.runtime.ApplicationConfig; | ||
| import io.quarkus.runtime.RuntimeValue; | ||
| import io.quarkus.runtime.annotations.Recorder; | ||
|
|
||
| @Recorder | ||
| public class UnleashRecorder { | ||
|
|
||
| public void initializeProducers(UnleashRuntimeTimeConfig config, ApplicationConfig appConfig, boolean devMode) { | ||
| UnleashService producer = Arc.container().instance(UnleashService.class).get(); | ||
| producer.initialize(config, appConfig, devMode); | ||
| private static final Logger LOGGER = Logger.getLogger(UnleashRecorder.class); | ||
|
|
||
| private final ApplicationConfig applicationConfig; | ||
| private final RuntimeValue<UnleashRuntimeTimeConfig> unleashRuntimeConfig; | ||
|
|
||
| public UnleashRecorder(ApplicationConfig applicationConfig, RuntimeValue<UnleashRuntimeTimeConfig> unleashRuntimeConfig) { | ||
| this.applicationConfig = applicationConfig; | ||
| this.unleashRuntimeConfig = unleashRuntimeConfig; | ||
| } | ||
|
|
||
| public Supplier<Unleash> getSupplier() { | ||
| if (unleashRuntimeConfig.getValue().active) { | ||
| String app = unleashRuntimeConfig.getValue().appName.orElse(applicationConfig.name.orElse("default-app-name")); | ||
| return new Supplier<Unleash>() { | ||
| @Override | ||
| public Unleash get() { | ||
| Unleash unleash = UnleashCreator.createUnleash(unleashRuntimeConfig.getValue(), app); | ||
| LOGGER.infof("Unleash client application '{}' fetch feature toggle names: {}", app, | ||
| unleash.more().getFeatureToggleNames()); | ||
| return unleash; | ||
| } | ||
| }; | ||
| } else { | ||
| return new Supplier<Unleash>() { | ||
| @Override | ||
| public Unleash get() { | ||
| LOGGER.info("Unleash client is disabled from the extension configuration"); | ||
| return new NoOpUnleash(); | ||
| } | ||
| }; | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.