feat: irGenerator to cnfig

Countly · Sep 25, 2023 · 2fd128b · 2fd128b
1 parent d38cb1a
commit 2fd128b
Show file tree

Hide file tree

Showing 6 changed files with 32 additions and 10 deletions.
diff --git a/sdk-java/src/main/java/ly/count/sdk/java/Config.java b/sdk-java/src/main/java/ly/count/sdk/java/Config.java
@@ -12,8 +12,12 @@
 import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
-
-import ly.count.sdk.java.internal.*;
+import ly.count.sdk.java.internal.Byteable;
+import ly.count.sdk.java.internal.CoreFeature;
+import ly.count.sdk.java.internal.Log;
+import ly.count.sdk.java.internal.LogCallback;
+import ly.count.sdk.java.internal.ModuleBase;
+import ly.count.sdk.java.internal.Utils;
 
 /**
  * Countly configuration object.

diff --git a/sdk-java/src/main/java/ly/count/sdk/java/Countly.java b/sdk-java/src/main/java/ly/count/sdk/java/Countly.java
@@ -2,8 +2,12 @@
 
 import java.io.File;
 import java.util.Map;
-
-import ly.count.sdk.java.internal.*;
+import ly.count.sdk.java.internal.CtxCore;
+import ly.count.sdk.java.internal.Device;
+import ly.count.sdk.java.internal.InternalConfig;
+import ly.count.sdk.java.internal.Log;
+import ly.count.sdk.java.internal.ModuleBackendMode;
+import ly.count.sdk.java.internal.SDKCore;
 
 /**
  * Main Countly SDK API class.

diff --git a/sdk-java/src/main/java/ly/count/sdk/java/internal/ImmediateRequestGenerator.java b/sdk-java/src/main/java/ly/count/sdk/java/internal/ImmediateRequestGenerator.java
@@ -0,0 +1,5 @@
+package ly.count.sdk.java.internal;
+
+public interface ImmediateRequestGenerator {
+    ImmediateRequestI createImmediateRequestMaker();
+}
diff --git a/sdk-java/src/main/java/ly/count/sdk/java/internal/ImmediateRequestI.java b/sdk-java/src/main/java/ly/count/sdk/java/internal/ImmediateRequestI.java
@@ -1,5 +1,5 @@
 package ly.count.sdk.java.internal;
 
-interface ImmediateRequestI {
+public interface ImmediateRequestI {
     void doWork(String requestData, String customEndpoint, Transport cp, boolean requestShouldBeDelayed, boolean networkingIsEnabled, ImmediateRequestMaker.InternalImmediateRequestCallback callback, Log log);
 }
diff --git a/sdk-java/src/main/java/ly/count/sdk/java/internal/InternalConfig.java b/sdk-java/src/main/java/ly/count/sdk/java/internal/InternalConfig.java
@@ -13,7 +13,6 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
-
 import ly.count.sdk.java.Config;
 
 /**
@@ -34,6 +33,8 @@ public final class InternalConfig extends Config implements Storable {
      */
     private final List<DID> dids = new ArrayList<>();
 
+    ImmediateRequestGenerator immediateRequestGenerator = null;
+
     /**
      * Shouldn't be used!
      */

diff --git a/sdk-java/src/main/java/ly/count/sdk/java/internal/SDKCore.java b/sdk-java/src/main/java/ly/count/sdk/java/internal/SDKCore.java
@@ -1,10 +1,14 @@
 package ly.count.sdk.java.internal;
 
-import ly.count.sdk.java.Config;
-import org.json.JSONObject;
-
-import java.util.*;
+import java.util.ArrayDeque;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Queue;
+import java.util.TreeMap;
 import java.util.concurrent.Future;
+import ly.count.sdk.java.Config;
 
 public class SDKCore {
 
@@ -89,6 +93,10 @@ public boolean isTracking(Integer feat) {
     }
 
     public void init(CtxCore ctx) {
+        InternalConfig config = ctx.getConfig();
+        if (config.immediateRequestGenerator == null) {
+            config.immediateRequestGenerator = ImmediateRequestMaker::new;
+        }
         prepareMappings(ctx);
     }