Feature/cli analytics

components/main.ts

@@ -1,13 +1,14 @@
-import { Command, CommandDescriptor, CommandList } from "interfaces/main";
-import { Component, IConfigReader, IInjector } from "merapi";
+import { Command, CommandDescriptor, CommandList, IHelper } from "interfaces/main";
+import { Component, IConfigReader, IInjector, Json, JsonObject } from "merapi";
 
 const commander = require("commander");
 
 export default class Main extends Component {
 
     constructor(
         private config : IConfigReader,
-        private injector : IInjector
+        private injector : IInjector,
+        private helper : IHelper
         ) {
         super();
     }
@@ -21,6 +22,10 @@ export default class Main extends Component {
         if (argv.length === 2 || validCommands.indexOf(argv[2]) === -1) {
             commander.parse([argv[0], argv[1], '-h']);
         }
+
+        this.sendNotificationTracking()
+        this.sendDataAnalytics(argv)
+        this.saveCommandSession(argv)
     }
 
     async compile(commands: CommandList, program: Command, currKey : string = "") {
@@ -91,4 +96,21 @@ export default class Main extends Component {
             handlerMethod(...args);
         }
     }
+
+    private sendDataAnalytics(argv:string[]) {
+        const command = Object.assign([], argv)
+
+        this.helper.sendGoogleAnalytics('commands', 'track', command.splice(2).join(' '))
+    }
+
+    private sendNotificationTracking() {
+        const status:Boolean = this.helper.checkNotificationStatus();
+        if (!status) console.log(`\nStarting from Kata CLI vv2.1.0, we added analytics to Kata CLI that will collect usage data every time you typed a command. To learn about what we collect and how we use it, visit https://privacy.kata.ai/kata-cli-analytics\n`)
+    }
+
+    private saveCommandSession(argv:string[]) {
+        const command = Object.assign([], argv)
+
+        this.helper.addCommandSession(command.splice(2).join(' '))
+    }
 }

components/projects/project.ts

@@ -111,6 +111,7 @@ export default class Project {
                     },
                 ]);
                 this.helper.setProp("projectId", project.id);
+                this.helper.setProp("projectName", project.name);
                 console.log(colors.green(`Project "${project.name}" (${project.id}) is successfully selected`));
                 return;
             }

components/scripts/helper.ts

@@ -8,6 +8,7 @@ const fs = require("fs");
 const os = require("os");
 const path = require("path");
 const inquirer = require("inquirer");
+const analytics = require('universal-analytics');
 
 function wrapError(error: any) {
     let errorMessage;
@@ -30,9 +31,12 @@ export const CatchError = Catch(Error, (error: any) => {
 
 
 export default class Helper extends Component {
+    private google:any;
 
     constructor(private config : IConfig) {
         super();
+
+        this.google = analytics(this.config.default('config.trackingId', 'UA-131926842-1'));
     }
 
     public getFiles(dir : string, ending : string) : string[] {
@@ -173,7 +177,13 @@ export default class Helper extends Component {
     }
 
     public wrapError(error : any) {
-        return wrapError(error);
+        const errorMessage:string = wrapError(error);
+
+        const commands:JsonObject[] = this.getCommandSession()
+        this.sendGoogleAnalytics('commands', 'debug', '', commands, errorMessage)
+        this.clearCommandSession()
+
+        return errorMessage
     }
 
     public difference(object : any, base : any) {
@@ -201,4 +211,77 @@ export default class Helper extends Component {
 
         console.log(jsonProp);
     }
+
+    public checkNotificationStatus(): Boolean {
+        const jsonPath = `${os.homedir()}/.katanotif`;
+
+        if (fs.existsSync(jsonPath)) {
+            return true
+        } else {
+            fs.writeFileSync(jsonPath, "true", "utf8");
+            return false
+        }
+    }
+
+    public addCommandSession(command:string): void {
+        const jsonPath = `${os.homedir()}/.katacommand`;
+        let jsonData:JsonObject[] = [];
+
+        if (fs.existsSync(jsonPath)) jsonData = JSON.parse(fs.readFileSync(jsonPath, "utf8"));
+
+        if (jsonData.length > 0) {
+            const lastData:JsonObject = jsonData[jsonData.length - 1]
+            const diff:number = Math.abs(Number(lastData.timestamp) - new Date().getTime()) / 36e5;
+
+            if (diff >= 1) jsonData = [] //Lebih dari 1 jam ?
+        }
+
+        jsonData.push({ timestamp: new Date().getTime(), command: command })
+
+        fs.writeFileSync(jsonPath, JSON.stringify(jsonData), "utf8");
+    }
+
+    public getCommandSession(): JsonObject[] {
+        const jsonPath = `${os.homedir()}/.katacommand`;
+        let jsonData:JsonObject[] = [];
+
+        if (fs.existsSync(jsonPath)) jsonData = JSON.parse(fs.readFileSync(jsonPath, "utf8"));
+
+        return jsonData
+    }
+
+    public clearCommandSession(): void {
+        const jsonPath = `${os.homedir()}/.katacommand`;
+
+        fs.writeFileSync(jsonPath, "[]", "utf8");
+    }
+
+    public sendGoogleAnalytics(event:string, action:string, command:string, lastSession?:JsonObject[], errorMessage?:string): void {
+        let firstLogin = this.getProp("first_login") as JsonObject;
+        let projectId = this.getProp("projectId") as string;
+        let projectName = this.getProp("projectName") as string;
+        const version = this.config.default("version", "1.0.0")
+
+        if (!firstLogin) firstLogin = { id: null, username: null, type: null }
+        if (!projectId) projectId = null
+        if (!projectName) projectName = null
+
+        const data:JsonObject = {
+            userId: firstLogin.id,
+            username: firstLogin.username,
+            currentUserType: firstLogin.type,
+            activeProjectId: projectId,
+            activeProjectName: projectName,
+            command: command,
+            versionCLI: version,
+            timestamp: new Date().getTime()
+        }
+
+        if (lastSession) data.lastSession = lastSession
+        if (errorMessage) data.errorMessage = errorMessage
+
+        this.google.event(event, action, JSON.stringify(data), (err:any) => {
+            if (err) console.log(this.wrapError(err));
+        })
+    }
 }

components/users/user.ts

@@ -109,7 +109,8 @@ export default class User extends Component {
             } else {
                 console.log("Please log in first");
             }
-
+
+            this.helper.clearCommandSession();
         } catch (e) {
             console.log(this.helper.wrapError(e));
         }

interfaces/main.ts

@@ -300,6 +300,11 @@ export interface IHelper {
     delete() : Boolean;
     wrapError(error : any) : string;
     difference(object: any, base: any): Object;
+    checkNotificationStatus() : Boolean;
+    addCommandSession(command:string): void;
+    getCommandSession(): JsonObject[];
+    clearCommandSession(): void;
+    sendGoogleAnalytics(event:string, action:string, data:string): void;
 }
 
 export interface ITester {

package.json

@@ -56,6 +56,7 @@
     "lodash": "^4.17.11",
     "merapi": "^0.17.1",
     "merapi-proxy": "^0.1.7",
+    "universal-analytics": "^0.4.20",
     "uuid": "^3.2.1",
     "zaun": "^2.0.3"
   },

service.yml

@@ -35,6 +35,7 @@ components:
 
 
 config:
+    trackingId: "UA-131926842-1"
     channels:
         type:
             - line