saving events

matthewoates · matthewoates · commit 45a791836c65 · 2019-05-10T17:44:04.000-07:00
diff --git a/src/main/java/com/moesif/api/controllers/APIController.java b/src/main/java/com/moesif/api/controllers/APIController.java
@@ -6,6 +6,7 @@
 package com.moesif.api.controllers;
 
 import java.util.*;
+import java.util.logging.Logger;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 
@@ -19,6 +20,9 @@
 import com.moesif.api.controllers.syncwrapper.APICallBackCatcher;
 
 public class APIController extends BaseController implements IAPIController {
+    private static final Logger logger = Logger.getLogger(APIController.class.toString());
+    private static final boolean debug = false; // TODO
+
     //private static variables for the singleton pattern
     private static Object syncObject = new Object();
     private static APIController instance = null;
@@ -461,6 +465,87 @@ public void run() {
         //execute async using thread pool
         APIHelper.getScheduler().execute(_responseTask);
     }
+
+    public AppConfigModel getCachedAndLoadAppConfig() {
+        // TODO: download new one if necessary
+        return getDefaultAppConfig();
+    }
+
+    public AppConfigModel getDefaultAppConfig() {
+        return new AppConfigBuilder()
+            .sampleRate(100)
+            .etag("default")
+            .build();
+    }
+
+    private EventModel buildEvent(
+            EventRequestModel eventRequestModel,
+            EventResponseModel eventResponseModel,
+            String userId,
+            String sessionToken,
+            String tags,
+            Object metadata) {
+        EventBuilder eb = new EventBuilder();
+        eb.request(eventRequestModel);
+        eb.response(eventResponseModel);
+        if (userId != null) {
+            eb.userId(userId);
+        }
+        if (sessionToken != null) {
+            eb.sessionToken(sessionToken);
+        }
+        if (tags != null) {
+            eb.tags(tags);
+        }
+
+        if (metadata != null) {
+            eb.metadata(metadata);
+        }
+
+        EventModel event = eb.build();
+
+        // actually send the event here.
+        APICallBack<Object> callBack = new APICallBack<Object>() {
+            public void onSuccess(HttpContext context, Object response) {
+                if (debug) {
+                    logger.info("send to Moesif success");
+                }
+            }
+
+            public void onFailure(HttpContext context, Throwable error) {
+                if (debug) {
+                    logger.info("send to Moesif error ");
+                    logger.info( error.toString());
+                }
+            }
+        };
+
+        return event;
+    }
+
+    public boolean trySendEvent(EventModel event) {
+        AppConfigModel appConfig = getCachedAndLoadAppConfig();
+
+        boolean willSend = appConfig.getSampleRate() >= Math.random() * 100;
+
+        if (willSend) {
+            Map<String, String> eventApiResponse = null;
+
+            try {
+                eventApiResponse = createEvent(event);
+            } catch (Throwable e) {
+                if (debug) {
+                    logger.warning("Send to Moesif failed " + e.toString());
+                }
+            }
+
+            if (eventApiResponse != null) {
+
+            }
+        }
+
+        return willSend;
+    }
     
     /**
      * Update a Single Company
@@ -588,7 +673,6 @@ public void run() {
         APIHelper.getScheduler().execute(_responseTask);
     }
 
-
     private APICallBack<HttpResponse> createHttpResponseCallback(final APICallBack<Object> callBack) {
 
         return new APICallBack<HttpResponse>() {
diff --git a/src/main/java/com/moesif/api/models/AppConfigBuilder.java b/src/main/java/com/moesif/api/models/AppConfigBuilder.java
@@ -29,4 +29,12 @@ public AppConfigBuilder etag(String etag) {
       AppConfigModel.setEtag(etag);
       return this;
     }
+
+    /**
+     * Build the instance with the given values
+     * @return The built UserModel
+     */
+    public AppConfigModel build() {
+        return AppConfigModel;
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -29,4 +29,12 @@ public AppConfigBuilder etag(String etag) {`
`29`	`29`	`AppConfigModel.setEtag(etag);`
`30`	`30`	`return this;`
`31`	`31`	`}`
	`32`	`+`
	`33`	`+ /**`
	`34`	`+ * Build the instance with the given values`
	`35`	`+ * @return The built UserModel`
	`36`	`+ */`
	`37`	`+ public AppConfigModel build() {`
	`38`	`+ return AppConfigModel;`
	`39`	`+ }`
`32`	`40`	`}`