Merge pull request #436 from nanobox-io/feature/events

submit events to the production nanobox servers

Author: lyondhill

commands/commands.go

@@ -11,9 +11,9 @@ import (
 	"github.com/nanobox-io/nanobox/commands/registry"
 	"github.com/nanobox-io/nanobox/commands/server"
 	"github.com/nanobox-io/nanobox/models"
+	"github.com/nanobox-io/nanobox/processors"
 	"github.com/nanobox-io/nanobox/util/config"
 	"github.com/nanobox-io/nanobox/util/display"
-	"github.com/nanobox-io/nanobox/util/mixpanel"
 	"github.com/nanobox-io/nanobox/util/update"
 )
 
@@ -41,8 +41,9 @@ var (
 		Long:  ``,
 		PersistentPreRun: func(ccmd *cobra.Command, args []string) {
 
-			// report the command usage to mixpanel
-			mixpanel.Report(strings.Replace(ccmd.CommandPath(), "nanobox ", "", 1))
+			// report the command to nanobox
+			processors.SubmitLog(strings.Replace(ccmd.CommandPath(), "nanobox ", "", 1))
+			// mixpanel.Report(strings.Replace(ccmd.CommandPath(), "nanobox ", "", 1))
 
 			// alert the user if an update is needed
 			update.Check()

models/config.go

@@ -23,7 +23,8 @@ type Config struct {
 	DockerMachineNetworkSpace string `json:"docker-machine-network-space"`
 	NativeNetworkSpace        string `json:"native-network-space"`
 
-	LockPort int `json:"lock-port"`
+	Anonymous bool `json:"anonymous"`
+	LockPort  int `json:"lock-port"`
 }
 
 // Save persists the Config to the database

processors/configure_set.go

@@ -32,6 +32,8 @@ func ConfigureSet(key, val string) error {
 		config.LockPort, _ = strconv.Atoi(val)
 	case "ci-mode", "ci_mode":
 		config.CIMode = val == "true" || val == "t" || val == "1"
+	case "anonymous":
+		config.Anonymous = val == "true" || val == "t" || val == "1"
 	}
 
 	return config.Save()

processors/submit_log.go

@@ -0,0 +1,59 @@
+package processors
+
+import (
+	"fmt"
+	"strings"
+	"runtime"
+
+	"github.com/nanobox-io/nanobox/models"
+	"github.com/nanobox-io/nanobox/util"
+	"github.com/nanobox-io/nanobox/util/config"
+	"github.com/nanobox-io/nanobox/util/odin"
+)
+
+func SubmitLog(args string) error {
+	// if we are running as privilage we dont submit
+	if util.IsPrivileged() {
+		return nil
+	}
+
+	auth, _ := models.LoadAuth()
+	conf, _ := models.LoadConfig()
+	if conf.CIMode {
+		return nil
+	}
+	
+	if auth.Key == "" && !conf.Anonymous {
+		err :=  Login("", "", "")
+		if err != nil {
+			return err
+		}
+	}
+
+	app := ""
+
+	env, err := models.FindEnvByID(config.EnvID())
+	if strings.Contains(args, "deploy") || strings.Contains(args, "tunnel") || strings.Contains(args, "console") {
+		if err == nil {
+			remote, ok := env.Remotes["default"]
+			if ok {
+				app = remote.ID
+			}
+		}	
+	}
+
+	// tell nanobox 
+	go odin.SubmitEvent(
+		fmt.Sprintf("desktop%s", strings.Replace(args, " ", "/", -1)),
+		fmt.Sprintf("desktop command: nanobox %s", args),
+		app,
+		map[string]interface{}{
+			"os":         runtime.GOOS,
+			"provider":   conf.Provider,
+			"mount-type": conf.MountType,
+			"boxfile": env.UserBoxfile,
+		},
+	)
+
+	return nil
+}

scripts/build.sh

@@ -9,7 +9,7 @@ set -e
 printf "\nBuilding nanobox...\n"
 
 # build nanobox
-gox -ldflags "-X main.bugsnagToken=$BUGSNAG_TOKEN -X github.com/nanobox-io/nanobox/util/mixpanel.token=$MIXPANEL_TOKEN" -osarch "darwin/amd64 linux/amd64 windows/amd64" -output="./.build/v2/{{.OS}}/{{.Arch}}/nanobox"
+gox -ldflags "-X main.bugsnagToken=$BUGSNAG_TOKEN -X github.com/nanobox-io/nanobox/util/odin.apiKey=$API_KEY" -osarch "darwin/amd64 linux/amd64 windows/amd64" -output="./.build/v2/{{.OS}}/{{.Arch}}/nanobox"
 
 printf "\nBuilding nanobox updater...\n"
 

util/display/command_error.go

@@ -8,7 +8,11 @@ import (
 	"strings"
 
 	"github.com/nanobox-io/nanobox/commands/registry"
+	"github.com/nanobox-io/nanobox/models"
 	"github.com/nanobox-io/nanobox/util"
+	"github.com/nanobox-io/nanobox/util/config"
+	"github.com/nanobox-io/nanobox/util/odin"
+
 )
 
 var (
@@ -35,10 +39,34 @@ func CommandErr(err error) {
 
 	cause, context := parseCommandErr(err)
 
-	fmt.Println()
-	fmt.Printf("Error   : %s\n", cause)
-	fmt.Printf("Context : %s\n", context)
-	fmt.Println()
+	output := fmt.Sprintf(`
+Error   : %s
+Context : %s
+`, cause, context)
+
+	app := ""
+	env, err := models.FindEnvByID(config.EnvID())
+	if err == nil {
+		remote, ok := env.Remotes["default"]
+		if ok {
+			app = remote.ID
+		}
+	}
+
+	// submit error to nanobox
+	odin.SubmitEvent(
+		"desktop#error",
+		"an error occurred running nanobox desktop", 
+		app,
+		map[string]interface{}{
+			"error": cause,
+			"context": context,
+			"boxfile": env.UserBoxfile,
+		},
+	)
+
+	// display error to user
+	fmt.Println(output)
 
 	if runtime.GOOS == "windows" {
 		// The update process was spawned in a separate window, which will

util/odin/odin.go

@@ -28,6 +28,7 @@ const (
 var (
 	// set the default endpoint to nanobox
 	endpoint = "nanobox"
+	apiKey string
 )
 
 type (
@@ -154,6 +155,29 @@ func GetPreviousBuild(appID string) (string, error) {
 	return "", nil
 }
 
+func SubmitEvent(action, message, app string, meta map[string]interface{}) error {
+	params := url.Values{}
+	params.Set("api_key", apiKey)
+
+	request := struct {
+		Action string `json:"action"`
+		App   string `json:"eventable_id,omitempty"`
+		Meta  map[string]interface{} `json:"meta"`
+		Message string `json:"message"`
+	}{
+		Action: action,
+		App: app,
+		Meta: meta,
+		Message: message,
+	}
+
+	err := doRequest("POST", "events", params, map[string]interface{}{"event": request}, nil)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
 // doRequest ...
 func doRequest(method, path string, params url.Values, requestBody, responseBody interface{}) error {
 
@@ -183,7 +207,9 @@ func doRequest(method, path string, params url.Values, requestBody, responseBody
 	if params == nil {
 		params = url.Values{}
 	}
-	params.Set("auth_token", auth.Key)
+	if auth.Key != "" {
+		params.Set("auth_token", auth.Key)
+	}
 
 	// fetch the correct url from the endpoint
 	url := odinURL()