Added pushJ command

Author: rogerzr

interface.go

@@ -34,6 +34,10 @@ var (
 	pushMethod = push.Arg("method", "Method to call").Required().String()
 	pushParams = push.Arg("params", "parameters").StringMap()
 
+	pushJ       = app.Command("pushj", "Execute a task.push rpc call on Nexus. Params is a json dict like: { 'param': value }")
+	pushJMethod = pushJ.Arg("method", "Method to call").Required().String()
+	pushJParams = pushJ.Arg("json {param:value,...}", "{'param': 3, 'other': {'val': true}}").Required().String()
+
 	pull       = app.Command("pull", "Execute a task.pull rpc call on Nexus")
 	pullMethod = pull.Arg("prefix", "Method to call").Required().String()
 

main.go

@@ -134,6 +134,26 @@ func execCmd(nc *nexus.NexusConn, parsed string) {
 			}
 		}
 
+	case pushJ.FullCommand():
+		var params map[string]interface{}
+		if json.Unmarshal([]byte(*pushJParams), &params) != nil {
+			log.Println("Error parsing params json:", *pushJParams)
+			return
+		}
+
+		if ret, err := nc.TaskPush(*pushJMethod, params, time.Second*time.Duration(*timeout)); err != nil {
+			log.Println("Error:", err)
+			return
+		} else {
+			b, _ := json.MarshalIndent(ret, "", "  ")
+			log.Println("Result:")
+			if s, err := strconv.Unquote(string(b)); err == nil {
+				fmt.Println(s)
+			} else {
+				fmt.Println(string(b))
+			}
+		}
+
 	case pull.FullCommand():
 		log.Println("Pulling", *pullMethod)
 		ret, err := nc.TaskPull(*pullMethod, time.Second*time.Duration(*timeout))