From 81d437ac1e16104f32fef3c0d694a215fb7129a5 Mon Sep 17 00:00:00 2001
From: Kegan Dougal <kegan@matrix.org>
Date: Thu, 19 Jan 2017 15:47:55 +0000
Subject: [PATCH] POST reports to localhost for now. Also send live console
 logs

---
 src/vector/index.js     |  2 +-
 src/vector/rageshake.js | 75 +++++++++++++++++++++++++++++++++++------
 2 files changed, 66 insertions(+), 11 deletions(-)

diff --git a/src/vector/index.js b/src/vector/index.js
index d773db85b..d1d457e98 100644
--- a/src/vector/index.js
+++ b/src/vector/index.js
@@ -39,7 +39,7 @@ require('draft-js/dist/Draft.css');
 const rageshake = require("./rageshake");
 rageshake.init().then(() => {
     console.log("Initialised rageshake");
-    rageshake.sendBugReport();
+    rageshake.cleanup();
 }, (err) => {
     console.error("Failed to initialise rageshake: " + err);
 });
diff --git a/src/vector/rageshake.js b/src/vector/rageshake.js
index 6093515d5..1f3dbc7d4 100644
--- a/src/vector/rageshake.js
+++ b/src/vector/rageshake.js
@@ -14,6 +14,8 @@ See the License for the specific language governing permissions and
 limitations under the License.
 */
 
+import request from "browser-request";
+
 // This module contains all the code needed to log the console, persist it to disk and submit bug reports. Rationale is as follows:
 //  - Monkey-patching the console is preferable to having a log library because we can catch logs by other libraries more easily,
 //    without having to all depend on the same log framework / pass the logger around.
@@ -321,20 +323,27 @@ function selectQuery(store, keyRange, resultMapper) {
 
 
 let store = null;
-let inited = false;
+let logger = null;
+let initPromise = null;
 module.exports = {
 
     /**
      * Configure rage shaking support for sending bug reports.
      * Modifies globals.
+     * @return {Promise} Resolves when set up.
      */
     init: function() {
-        if (inited || !window.indexedDB) {
-            return;
+        if (initPromise) {
+            return initPromise;
         }
-        store = new IndexedDBLogStore(window.indexedDB, new ConsoleLogger());
-        inited = true;
-        return store.connect();
+        logger = new ConsoleLogger();
+        if (window.indexedDB) {
+            store = new IndexedDBLogStore(window.indexedDB, logger);
+            initPromise = store.connect();
+            return initPromise;
+        }
+        initPromise = Promise.resolve();
+        return initPromise;
     },
 
     /**
@@ -343,20 +352,66 @@ module.exports = {
      */
     flush: function() {
         if (!store) {
-            return;
+            return Promise.resolve();
         }
         return store.flush();
     },
 
+    /**
+     * Clean up old logs.
+     * @return Promise Resolves if cleaned logs.
+     */
+    cleanup: function() {
+        if (!store) {
+            return Promise.resolve();
+        }
+        return store.consume(false);
+    },
+
     /**
      * Send a bug report.
      * @param {string} userText Any additional user input.
      * @return {Promise} Resolved when the bug report is sent.
      */
     sendBugReport: function(userText) {
-        return store.consume(false).then((logs) => {
-            // Send logs grouped by ID
-            console.log(logs);
+        if (!logger) {
+            return Promise.reject(new Error("No console logger, did you forget to call init()?"));
+        }
+        // If in incognito mode, store is null, but we still want bug report sending to work going off
+        // the in-memory console logs.
+        let promise = Promise.resolve([]);
+        if (store) {
+            promise = store.consume(false); //  TODO Swap to true to remove all logs
+        }
+        return promise.then((logs) => {
+            // and add the most recent console logs which won't be in the store yet.
+            const consoleLogs = logger.flush(); // remove logs from console
+            const currentId = store ? store.id : "-";
+            logs.unshift({
+                lines: consoleLogs,
+                id: currentId,
+            });
+            return new Promise((resolve, reject) => {
+                request({
+                    method: "POST",
+                    url: "http://localhost:1337",
+                    body: {
+                        logs: logs,
+                        text: userText || "User did not supply any additional text.",
+                    },
+                    json: true,
+                }, (err, res) => {
+                    if (err) {
+                        reject(err);
+                        return;
+                    }
+                    if (res.status < 200 || res.status >= 400) {
+                        reject(new Error(`HTTP ${res.status}`));
+                        return;
+                    }
+                    resolve();
+                })
+            });
         });
     }
 };