Added basic event plugin manager

Author: pc9795

src/main/java/com/prashantchaubey/exceptionlessclient/configuration/ConfigurationManager.java

@@ -5,6 +5,8 @@
 import com.prashantchaubey.exceptionlessclient.lastreferenceidmanager.LastReferenceIdManagerIF;
 import com.prashantchaubey.exceptionlessclient.logging.LogIF;
 import com.prashantchaubey.exceptionlessclient.logging.NullLog;
+import com.prashantchaubey.exceptionlessclient.models.EventPluginContext;
+import com.prashantchaubey.exceptionlessclient.plugins.EventPluginIF;
 import com.prashantchaubey.exceptionlessclient.queue.EventQueueIF;
 import com.prashantchaubey.exceptionlessclient.services.EnvironmentInfoCollectorIF;
 import com.prashantchaubey.exceptionlessclient.services.ErrorParserIF;
@@ -19,6 +21,7 @@
 import lombok.Getter;
 
 import java.util.*;
+import java.util.function.BiConsumer;
 
 @Builder(builderClassName = "ConfigurationInternalBuilder")
 @Getter
@@ -40,6 +43,7 @@ public class ConfigurationManager {
   @Builder.Default private Configuration configuration = Configuration.defaultConfiguration();
   @Builder.Default private Set<String> defaultTags = new HashSet<>();
   @Builder.Default private Map<String, Object> defaultData = new HashMap<>();
+  @Builder.Default private List<EventPluginIF> plugins = new ArrayList<>();
 
   // lombok ignored fields
   private SettingsManager $settingsManager;
@@ -72,6 +76,44 @@ public void submitSessionHeartbeat(String sessionOrUserId) {
     submissionClient.sendHeartBeat(sessionOrUserId, false);
   }
 
+  public void addPlugin(EventPluginIF eventPlugin) {
+    if (plugins.stream().anyMatch(plugin -> plugin.getName().equals(eventPlugin.getName()))) {
+      log.info(
+          String.format(
+              "Can't add plugin, name: %s, priority: %s as a plugin with this name already configured",
+              eventPlugin.getName(), eventPlugin.getPriority()));
+    }
+    plugins.add(eventPlugin);
+  }
+
+  public void addPlugin(BiConsumer<EventPluginContext, ConfigurationManager> pluginAction) {
+    addPlugin(UUID.randomUUID().toString(), 0, pluginAction);
+  }
+
+  public void addPlugin(
+      String name,
+      int priority,
+      BiConsumer<EventPluginContext, ConfigurationManager> pluginAction) {
+    addPlugin(
+        new EventPluginIF() {
+          @Override
+          public int getPriority() {
+            return priority;
+          }
+
+          @Override
+          public String getName() {
+            return name;
+          }
+
+          @Override
+          public void run(
+              EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
+            pluginAction.accept(eventPluginContext, configurationManager);
+          }
+        });
+  }
+
   public static ConfigurationBuilder builder() {
     return new ConfigurationBuilder();
   }

src/main/java/com/prashantchaubey/exceptionlessclient/logging/Slf4jLog.java

@@ -2,17 +2,82 @@
 
 import com.prashantchaubey.exceptionlessclient.configuration.ConfigurationManager;
 import com.prashantchaubey.exceptionlessclient.models.EventPluginContext;
+import com.prashantchaubey.exceptionlessclient.plugins.preconfigured.*;
 import lombok.Builder;
 import lombok.Getter;
 
+import java.util.List;
 import java.util.function.Consumer;
 
-@Builder
+@Builder(builderClassName = "EventPluginInternalBuilder")
 @Getter
 public class EventPluginManager {
   private ConfigurationManager configurationManager;
 
   public void run(EventPluginContext eventPluginContext, Consumer<EventPluginContext> handler) {
-    // todo implement
+    List<EventPluginIF> plugins = configurationManager.getPlugins();
+    plugins.add(
+        new EventPluginIF() {
+          @Override
+          public int getPriority() {
+            return Integer.MAX_VALUE;
+          }
+
+          @Override
+          public String getName() {
+            return "handler";
+          }
+
+          @Override
+          public void run(
+              EventPluginContext eventPluginContext, ConfigurationManager configurationManager) {
+            handler.accept(eventPluginContext);
+          }
+        });
+
+    plugins.sort((o1, o2) -> o2.getPriority() - o1.getPriority());
+    plugins.forEach(
+        plugin -> {
+          if (eventPluginContext.getContext().isEventCancelled()) {
+            return;
+          }
+
+          try {
+            plugin.run(eventPluginContext, configurationManager);
+
+          } catch (Exception e) {
+            configurationManager
+                .getLog()
+                .error(
+                    String.format(
+                        "Error running plugin: %s: %s. Discarding event",
+                        plugin.getName(), e.getMessage()),
+                    e);
+            eventPluginContext.getContext().markAsCancelled();
+          }
+        });
+  }
+
+  public static EventPluginBuilder builder() {
+    return new EventPluginBuilder();
+  }
+
+  public static class EventPluginBuilder extends EventPluginInternalBuilder {
+    @Override
+    public EventPluginManager build() {
+      EventPluginManager manager = super.build();
+      manager.init();
+      return manager;
+    }
+  }
+
+  private void init() {
+    configurationManager.addPlugin(ConfigurationDefaultsPlugin.builder().build());
+    configurationManager.addPlugin(ErrorPlugin.builder().build());
+    configurationManager.addPlugin(DuplicateCheckerPlugin.builder().build());
+    configurationManager.addPlugin(EventExclusionPlugin.builder().build());
+    configurationManager.addPlugin(ModuleInfoPlugin.builder().build());
+    configurationManager.addPlugin(EnvironmentInfoPlugin.builder().build());
+    configurationManager.addPlugin(SubmissionMethodPlugin.builder().build());
   }
 }

src/main/java/com/prashantchaubey/exceptionlessclient/plugins/EventPluginManager.java

@@ -6,7 +6,11 @@
 import com.prashantchaubey.exceptionlessclient.models.enums.EventPropertyKey;
 import com.prashantchaubey.exceptionlessclient.models.services.EnvironmentInfoGetArgs;
 import com.prashantchaubey.exceptionlessclient.plugins.EventPluginIF;
+import lombok.Builder;
+import lombok.Getter;
 
+@Builder
+@Getter
 public class EnvironmentInfoPlugin implements EventPluginIF {
   @Override
   public int getPriority() {

src/main/java/com/prashantchaubey/exceptionlessclient/plugins/preconfigured/EnvironmentInfoPlugin.java

@@ -4,7 +4,11 @@
 import com.prashantchaubey.exceptionlessclient.models.EventPluginContext;
 import com.prashantchaubey.exceptionlessclient.models.services.error.Error;
 import com.prashantchaubey.exceptionlessclient.plugins.EventPluginIF;
+import lombok.Builder;
+import lombok.Getter;
 
+@Builder
+@Getter
 public class ModuleInfoPlugin implements EventPluginIF {
   @Override
   public int getPriority() {

src/main/java/com/prashantchaubey/exceptionlessclient/plugins/preconfigured/ModuleInfoPlugin.java

@@ -3,7 +3,11 @@
 import com.prashantchaubey.exceptionlessclient.configuration.ConfigurationManager;
 import com.prashantchaubey.exceptionlessclient.models.EventPluginContext;
 import com.prashantchaubey.exceptionlessclient.plugins.EventPluginIF;
+import lombok.Builder;
+import lombok.Getter;
 
+@Builder
+@Getter
 public class SubmissionMethodPlugin implements EventPluginIF {
   @Override
   public int getPriority() {

src/main/java/com/prashantchaubey/exceptionlessclient/plugins/preconfigured/SubmissionMethodPlugin.java

@@ -56,7 +56,7 @@ public SettingsResponse getSettings(long version) {
 
       return SettingsResponse.builder().success(true).settings(serverSettings).build();
     } catch (URISyntaxException | InterruptedException | IOException e) {
-      return SettingsResponse.builder().success(false).exception(e).build();
+      return SettingsResponse.builder().success(false).exception(e).message(e.getMessage()).build();
     }
   }
 }

src/main/java/com/prashantchaubey/exceptionlessclient/settings/DefaultSettingsClient.java

@@ -67,6 +67,10 @@ private void updateSettings() {
     log.info(String.format("Checking for updated settings  from: v%s", currentVersion));
 
     SettingsResponse response = settingsClient.getSettings(currentVersion);
-    // todo implement
+    if (!response.isSuccess()) {
+      log.warn(String.format("Unable to update settings: %s:", response.getMessage()));
+      return;
+    }
+    storageProvider.getSettings().save(response.getSettings());
   }
 }