Merge branch 'master' of github.com:launchdarkly/java-client

# Conflicts:
#	.circleci/config.yml

Author: eli-darkly

build.gradle

@@ -41,6 +41,8 @@ libraries.unshaded = [
 ]
 
 libraries.testCompile = [
+    "com.squareup.okhttp3:mockwebserver:3.10.0",
+    "org.hamcrest:hamcrest-all:1.3",
     "org.easymock:easymock:3.4",
     "junit:junit:4.12"
 ]

src/main/java/com/launchdarkly/client/Components.java

@@ -0,0 +1,132 @@
+package com.launchdarkly.client;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.net.URI;
+
+/**
+ * Provides factories for the standard implementations of LaunchDarkly component interfaces.
+ * @since 4.0.0
+ */
+public abstract class Components {
+  private static final FeatureStoreFactory inMemoryFeatureStoreFactory = new InMemoryFeatureStoreFactory();
+  private static final EventProcessorFactory defaultEventProcessorFactory = new DefaultEventProcessorFactory();
+  private static final EventProcessorFactory nullEventProcessorFactory = new NullEventProcessorFactory();
+  private static final UpdateProcessorFactory defaultUpdateProcessorFactory = new DefaultUpdateProcessorFactory();
+  private static final UpdateProcessorFactory nullUpdateProcessorFactory = new NullUpdateProcessorFactory();
+  
+  /**
+   * Returns a factory for the default in-memory implementation of {@link FeatureStore}.
+   */
+  public static FeatureStoreFactory inMemoryFeatureStore() {
+    return inMemoryFeatureStoreFactory;
+  }
+  
+  /**
+   * Returns a factory with builder methods for creating a Redis-backed implementation of {@link FeatureStore},
+   * using {@link RedisFeatureStoreBuilder#DEFAULT_URI}.
+   */
+  public static RedisFeatureStoreBuilder redisFeatureStore() {
+    return new RedisFeatureStoreBuilder();
+  }
+  
+  /**
+   * Returns a factory with builder methods for creating a Redis-backed implementation of {@link FeatureStore},
+   * specifying the Redis URI.
+   */
+  public static RedisFeatureStoreBuilder redisFeatureStore(URI redisUri) {
+    return new RedisFeatureStoreBuilder(redisUri);
+  }
+  
+  /**
+   * Returns a factory for the default implementation of {@link EventProcessor}, which
+   * forwards all analytics events to LaunchDarkly (unless the client is offline or you have
+   * set {@link LDConfig.Builder#sendEvents(boolean)} to {@code false}).
+   */
+  public static EventProcessorFactory defaultEventProcessor() {
+    return defaultEventProcessorFactory;
+  }
+  
+  /**
+   * Returns a factory for a null implementation of {@link EventProcessor}, which will discard
+   * all analytics events and not send them to LaunchDarkly, regardless of any other configuration.
+   */
+  public static EventProcessorFactory nullEventProcessor() {
+    return nullEventProcessorFactory;
+  }
+  
+  /**
+   * Returns a factory for the default implementation of {@link UpdateProcessor}, which receives
+   * feature flag data from LaunchDarkly using either streaming or polling as configured (or does
+   * nothing if the client is offline, or in LDD mode).
+   */
+  public static UpdateProcessorFactory defaultUpdateProcessor() {
+    return defaultUpdateProcessorFactory;
+  }
+  
+  /**
+   * Returns a factory for a null implementation of {@link UpdateProcessor}, which does not
+   * connect to LaunchDarkly, regardless of any other configuration.
+   */
+  public static UpdateProcessorFactory nullUpdateProcessor() {
+    return nullUpdateProcessorFactory;
+  }
+  
+  private static final class InMemoryFeatureStoreFactory implements FeatureStoreFactory {
+    @Override
+    public FeatureStore createFeatureStore() {
+      return new InMemoryFeatureStore();
+    }
+  }
+  
+  private static final class DefaultEventProcessorFactory implements EventProcessorFactory {
+    @Override
+    public EventProcessor createEventProcessor(String sdkKey, LDConfig config) {
+      if (config.offline || !config.sendEvents) {
+        return new EventProcessor.NullEventProcessor();
+      } else {
+        return new DefaultEventProcessor(sdkKey, config);
+      }
+    }
+  }
+  
+  private static final class NullEventProcessorFactory implements EventProcessorFactory {
+    public EventProcessor createEventProcessor(String sdkKey, LDConfig config) {
+      return new EventProcessor.NullEventProcessor();
+    }
+  }
+  
+  private static final class DefaultUpdateProcessorFactory implements UpdateProcessorFactory {
+    // Note, logger uses LDClient class name for backward compatibility
+    private static final Logger logger = LoggerFactory.getLogger(LDClient.class);
+    
+    @Override
+    public UpdateProcessor createUpdateProcessor(String sdkKey, LDConfig config, FeatureStore featureStore) {
+      if (config.offline) {
+        logger.info("Starting LaunchDarkly client in offline mode");
+        return new UpdateProcessor.NullUpdateProcessor();
+      } else if (config.useLdd) {
+        logger.info("Starting LaunchDarkly in LDD mode. Skipping direct feature retrieval.");
+        return new UpdateProcessor.NullUpdateProcessor();
+      } else {
+        FeatureRequestor requestor = new FeatureRequestor(sdkKey, config);
+        if (config.stream) {
+          logger.info("Enabling streaming API");
+          return new StreamProcessor(sdkKey, config, requestor, featureStore);
+        } else {
+          logger.info("Disabling streaming API");
+          logger.warn("You should only disable the streaming API if instructed to do so by LaunchDarkly support");
+          return new PollingProcessor(config, requestor, featureStore);
+        }
+      }
+    }
+  }
+  
+  private static final class NullUpdateProcessorFactory implements UpdateProcessorFactory {
+    @Override
+    public UpdateProcessor createUpdateProcessor(String sdkKey, LDConfig config, FeatureStore featureStore) {
+      return new UpdateProcessor.NullUpdateProcessor();
+    }
+  }
+}