Merge pull request #23 from Instabug/feature/network_logging

🤝 Feature/network logging

Author: salmamali

android/src/main/java/com/instabug/reactlibrary/RNInstabugReactnativeModule.java

@@ -43,6 +43,7 @@
 import com.instabug.library.ui.onboarding.WelcomeMessage;
 import com.instabug.library.InstabugCustomTextPlaceHolder;
 import com.instabug.library.model.Report;
+import com.instabug.library.model.NetworkLog;
 import com.instabug.library.user.UserEventParam;
 import com.instabug.library.visualusersteps.State;
 
@@ -1983,6 +1984,27 @@ public void setEmailFieldRequiredForActions(boolean isEmailRequired, ReadableArr
         }
     }
 
+    /**
+     * Extracts HTTP connection properties. Request method, Headers, Date, Url and Response code
+     *
+     * @param jsonObject the JSON object containing all HTTP connection properties
+     * @throws JSONException
+     */
+    @ReactMethod
+    public void networkLog(String jsonObject) throws JSONException {
+        NetworkLog networkLog = new NetworkLog();
+        String date = System.currentTimeMillis()+"";
+        networkLog.setDate(date);
+        JSONObject newJSONObject = new JSONObject(jsonObject);
+        networkLog.setUrl(newJSONObject.getString("url"));
+        networkLog.setRequest(newJSONObject.getString("requestBody"));
+        networkLog.setResponse(newJSONObject.getString("responseBody"));
+        networkLog.setMethod(newJSONObject.getString("method"));
+        networkLog.setResponseCode(newJSONObject.getInt("responseCode"));
+        networkLog.setHeaders(newJSONObject.getString("headers"));
+        networkLog.insert();
+    }
+
     private InstabugCustomTextPlaceHolder.Key getStringToKeyConstant(String key) {
         switch (key) {
             case SHAKE_HINT:

index.js

@@ -5,13 +5,58 @@ import {
   Platform
 } from 'react-native';
 let { Instabug } = NativeModules;
+import interceptor from './utils/NetworkInterceptor.js';
 import InstabugUtils from './utils/InstabugUtils.js';
 import BugReporting from './modules/BugReporting.js';
 import Surveys from './modules/Surveys.js';
 import FeatureRequests from './modules/FeatureRequests.js';
 
 InstabugUtils.captureJsErrors();
 
+var jsonObject = {
+  url: '',
+  requestBody: '',
+  responseBody: '',
+  method: '',
+  responseCode: undefined,
+  headers: ''
+}
+
+// Register the interceptor for fetch requests
+ interceptor.register({
+  request: function (url, config) {
+    // Modify the url or config here
+    jsonObject.url = url;
+    if(!config || !config.method) {
+      //TO-DO: set method to GET!
+      jsonObject.method = 'GET';
+    }
+    if(config) {
+      if(config.body) {
+        jsonObject.requestBody = config.body;
+      } else {
+        jsonObject.requestBody = '';
+      }
+      if(config.method) {
+        jsonObject.method = config.method;
+      }
+      if(config.headers) {
+        jsonObject.headers = config.headers;
+      } else {
+        jsonObject.headers = '';
+      }
+    }
+    return [url, config];
+  },
+   response: function (response) {
+    // Modify the reponse object;
+    jsonObject.responseCode = response.status;
+    jsonObject.responseBody = response._bodyText;
+    Instabug.networkLog(JSON.stringify(jsonObject));
+    return response;
+  }
+});
+
 /**
  * Instabug
  * @exports Instabug

package.json

@@ -1,6 +1,6 @@
 {
   "name": "instabug-reactnative",
-  "version": "8.0.9",
+  "version": "8.0.10",
   "description": "React Native plugin for integrating the Instabug SDK",
   "main": "index.js",
   "repository": {

utils/NetworkInterceptor.js

@@ -0,0 +1,41 @@
+/*Configuration for intercepting the fetch request
+*/
+
+attach(global);
+var interceptorObject;
+
+function attach(env) {
+  env.fetch = (function (fetch) {
+    return function (...args) {
+      return interceptor(fetch, ...args);
+    };
+  })(env.fetch);
+}
+
+function interceptor(fetch, ...args) {
+  let promise = Promise.resolve(args);
+
+  // Register request interceptors
+  if (interceptorObject.request || interceptorObject.requestError) {
+    promise = promise.then(args => interceptorObject.request(...args), interceptorObject.requestError);
+  }
+
+  // Register fetch call
+  promise = promise.then(args => fetch(...args));
+
+  // Register response interceptors
+  if (interceptorObject.response || interceptorObject.responseError) {
+    promise = promise.then(interceptorObject.response, interceptorObject.responseError);
+  }
+
+  return promise;
+}
+
+module.exports = {
+  register: function (interceptor) {
+    interceptorObject = interceptor;
+    return () => {
+      interceptorObject = null;
+    };
+  }
+};