Merge pull request #512 from neuroscr/desktop-analytics

Desktop Analytics

js/background.js

@@ -230,6 +230,8 @@
     window.feeds = [];
     window.lokiMessageAPI = new window.LokiMessageAPI(ourKey);
     window.lokiPublicChatAPI = new window.LokiPublicChatAPI(ourKey);
+    // are there limits on tracking, is this unneeded?
+    // window.mixpanel.track("Desktop boot");
     window.lokiP2pAPI = new window.LokiP2pAPI(ourKey);
     window.lokiP2pAPI.on('pingContact', pubKey => {
       const isPing = true;

js/modules/loki_message_api.js

@@ -178,6 +178,7 @@ class LokiMessageAPI {
     try {
       // eslint-disable-next-line more/no-then
       success = await firstTrue(promises);
+      window.mixpanel.track('Sent Message Using Swarm API');
     } catch (e) {
       if (e instanceof textsecure.WrongDifficultyError) {
         // Force nonce recalculation
@@ -191,6 +192,7 @@ class LokiMessageAPI {
       throw e;
     }
     if (!success) {
+      window.mixpanel.track('Failed to Send Message Using Swarm API');
       throw new window.textsecure.EmptySwarmError(
         pubKey,
         'Ran out of swarm nodes to query'
@@ -255,6 +257,7 @@ class LokiMessageAPI {
       } catch (e) {
         log.warn('Loki send message:', e);
         if (e instanceof textsecure.WrongSwarmError) {
+          window.mixpanel.track('Migrated Snode');
           const { newSwarm } = e;
           await lokiSnodeAPI.updateSwarmNodes(params.pubKey, newSwarm);
           this.sendingData[params.timestamp].swarm = newSwarm;

js/modules/loki_mixpanel.js

@@ -0,0 +1,12 @@
+const Mixpanel = require('mixpanel');
+
+class LokiMixpanelAPI {
+  constructor() {
+    this.mixpanel = Mixpanel.init('736cd9a854a157591153efacd1164e9a');
+  }
+  track(label) {
+    this.mixpanel.track(label);
+  }
+}
+
+module.exports = LokiMixpanelAPI;

js/modules/loki_public_chat_api.js

@@ -1,5 +1,5 @@
 /* global log, textsecure, libloki, Signal, Whisper, Headers, ConversationController,
-clearTimeout, MessageController */
+clearTimeout, MessageController, window */
 const EventEmitter = require('events');
 const nodeFetch = require('node-fetch');
 const { URL, URLSearchParams } = require('url');
@@ -696,8 +696,12 @@ class LokiPublicChannelAPI {
       objBody: payload,
     });
     if (!res.err && res.response) {
+      window.mixpanel.track('Public Message Sent');
       return res.response.data.id;
     }
+    // there's no retry on desktop
+    // this is supposed to be after retries
+    window.mixpanel.track('Failed to Send Public Message');
     return false;
   }
 }

js/modules/loki_snode_api.js

@@ -118,6 +118,7 @@ class LokiSnodeAPI {
         port: snode.storage_port,
       }));
     } catch (e) {
+      window.mixpanel.track('Seed Node Failed');
       if (seedNodes.length === 0) {
         throw new window.textsecure.SeedNodeError(
           'Failed to contact seed node'
@@ -133,6 +134,7 @@ class LokiSnodeAPI {
     const filteredNodes = swarmNodes.filter(
       node => node.address !== nodeUrl && node.ip !== nodeUrl
     );
+    window.mixpanel.track('Unreachable Snode');
     await conversation.updateSwarmNodes(filteredNodes);
   }
 

js/views/inbox_view.js

@@ -292,6 +292,7 @@
       $target.toggleClass('section-toggle-visible');
     },
     async openConversation(id, messageId) {
+      const conversationExists = await ConversationController.get(id);
       const conversation = await ConversationController.getOrCreateAndWait(
         id,
         'private'
@@ -302,6 +303,19 @@
       }
 
       if (conversation) {
+        if (conversation.isRss()) {
+          window.mixpanel.track('RSS Feed Opened');
+        }
+        if (conversation.isPublic()) {
+          window.mixpanel.track('Loki Public Chat Opened');
+        }
+        if (conversation.isPrivate()) {
+          if (conversation.isMe()) {
+            window.mixpanel.track('Note To Self Opened');
+          } else if (conversationExists) {
+            window.mixpanel.track('Conversation Opened');
+          }
+        }
         conversation.updateProfileName();
       }
 

libtextsecure/account_manager.js

@@ -22,6 +22,9 @@
 (function() {
   window.textsecure = window.textsecure || {};
 
+  // set up mixpanel
+  window.mixpanel = window.mixpanel || new window.LokiMixpanelAPI();
+
   const ARCHIVE_AGE = 7 * 24 * 60 * 60 * 1000;
 
   function AccountManager(username, password) {
@@ -136,8 +139,10 @@
           ).toArrayBuffer();
           return libsignal.Curve.async.createKeyPair(privKey);
         };
+        window.mixpanel.track('Seed Restored');
       } else {
         generateKeypair = libsignal.KeyHelper.generateIdentityKeyPair;
+        window.mixpanel.track('Seed Created');
       }
       return this.queueTask(() =>
         generateKeypair().then(async identityKeyPair =>

package.json

@@ -85,6 +85,7 @@
     "libsodium-wrappers": "^0.7.4",
     "linkify-it": "2.0.3",
     "lodash": "4.17.11",
+    "mixpanel": "^0.10.2",
     "mkdirp": "0.5.1",
     "moment": "2.21.0",
     "mustache": "2.3.0",

preload.js

@@ -328,6 +328,10 @@ window.LokiPublicChatAPI = require('./js/modules/loki_public_chat_api');
 
 window.LokiRssAPI = require('./js/modules/loki_rss_api');
 
+const LokiMixpanelAPI = require('./js/modules/loki_mixpanel.js');
+
+window.mixpanel = new LokiMixpanelAPI();
+
 window.LocalLokiServer = require('./libloki/modules/local_loki_server');
 
 window.localServerPort = config.localServerPort;

ts/components/SearchResults.tsx

@@ -11,6 +11,8 @@ import { StartNewConversation } from './StartNewConversation';
 
 import { LocalizerType } from '../types/Util';
 
+declare var mixpanel: any;
+
 export type PropsData = {
   contacts: Array<ConversationListItemPropsType>;
   friends: Array<ConversationListItemPropsType>;
@@ -36,7 +38,7 @@ type Props = PropsData & PropsHousekeeping;
 export class SearchResults extends React.Component<Props> {
   public handleStartNewConversation = () => {
     const { regionCode, searchTerm, startNewConversation } = this.props;
-
+    mixpanel.track('New Conversation Started');
     startNewConversation(searchTerm, { regionCode });
   };
 

yarn.lock

@@ -4466,7 +4466,7 @@ https-browserify@^1.0.0:
   version "1.0.0"
   resolved "https://registry.yarnpkg.com/https-browserify/-/https-browserify-1.0.0.tgz#ec06c10e0a34c0f2faf199f7fd7fc78fffd03c73"
 
-https-proxy-agent@^2.2.1:
+https-proxy-agent@2.2.1, https-proxy-agent@^2.2.1:
   version "2.2.1"
   resolved "https://registry.yarnpkg.com/https-proxy-agent/-/https-proxy-agent-2.2.1.tgz#51552970fa04d723e04c56d04178c3f92592bbc0"
   integrity sha512-HPCTS1LW51bcyMYbxUIOO4HEOlQ1/1qRaFWcyxvwaqUS9TY88aoEuHUY33kuAh1YhVVaDQhLZsnPd+XNARWZlQ==
@@ -6022,6 +6022,13 @@ mixin-deep@^1.2.0:
     for-in "^1.0.2"
     is-extendable "^1.0.1"
 
+mixpanel@^0.10.2:
+  version "0.10.2"
+  resolved "https://registry.yarnpkg.com/mixpanel/-/mixpanel-0.10.2.tgz#10ff6cd76034b262d469094ad3d8c99039345376"
+  integrity sha512-+zbBQGd/Q5LLRooqJ2iyEDzKz2/ly4TipH5tE9te0BDMJpROxUMGffPulyHbh4FtMcbJuPmIUSIfy//JhhnlnA==
+  dependencies:
+    https-proxy-agent "2.2.1"
+
 mkdirp@0.5.0:
   version "0.5.0"
   resolved "https://registry.yarnpkg.com/mkdirp/-/mkdirp-0.5.0.tgz#1d73076a6df986cd9344e15e71fcc05a4c9abf12"