CLI start command to work with files

cmd/device-hub-cli/cmd_create.go

@@ -4,71 +4,60 @@ package main
 
 import (
 	"context"
-	"strings"
 
-	"github.com/fiorix/protoc-gen-cobra/iocodec"
 	"github.com/spf13/cobra"
-	"github.com/thingful/device-hub/describe"
-	"github.com/thingful/device-hub/endpoint"
-	"github.com/thingful/device-hub/listener"
 	"github.com/thingful/device-hub/proto"
-	"github.com/thingful/device-hub/registry"
 )
 
 var createCommand = &cobra.Command{
 	Use:   "create",
 	Short: "Create listener, endpoint and profile resources",
 	RunE: func(cmd *cobra.Command, args []string) error {
 
-		/* TODO : add ability to generate examples */
-		sample := proto.CreateRequest{
-			Configuration: map[string]string{},
+		conn, client, err := dial()
+		if err != nil {
+			return err
 		}
+		defer conn.Close()
 
-		err := roundTrip(sample, func(cli proto.HubClient, in iocodec.Decoder, out iocodec.Encoder) error {
-
-			v := proto.CreateRequest{}
-
-			err := in.Decode(&v)
-
-			if err != nil {
-				return err
-			}
-
-			// validate the policy file before sending it over the wire
-			var params describe.Parameters
-
-			register := registry.Default
-
-			endpoint.Register(register)
-			listener.Register(register)
-
-			switch strings.ToLower(v.Type) {
-
-			case "listener":
-				params, err = register.DescribeListener(v.Kind)
-			case "endpoint":
-				params, err = register.DescribeEndpoint(v.Kind)
-			}
-
+		for _, r := range _resources.R {
+			req := proto.CreateRequest{}
+			err := r.Raw.Decode(&req)
 			if err != nil {
 				return err
 			}
-
-			_, err = describe.NewValues(v.Configuration, params)
-
-			if err != nil {
-				return err
+			if r.Data["type"] != "process" {
+
+				err := describeValidate(req)
+				if err != nil {
+					return err
+				}
+				resp, err := client.Create(context.Background(), &req)
+				if err != nil {
+					return err
+				}
+
+				err = _encoder.Encode(resp)
+				if err != nil {
+					return err
+				}
+
+			} else {
+
+				var conf processConf
+				err := r.Raw.Decode(&conf)
+				if err != nil {
+					return err
+				}
+
+				err = startCall(conf, client)
+				if err != nil {
+					return err
+				}
 			}
-			resp, err := cli.Create(context.Background(), &v)
 
-			if err != nil {
-				return err
-			}
-
-			return out.Encode(resp)
+		}
 
-		})
-		return err
+		return nil
 	},
 }

cmd/device-hub-cli/cmd_delete.go

@@ -5,7 +5,6 @@ package main
 import (
 	"context"
 
-	"github.com/fiorix/protoc-gen-cobra/iocodec"
 	"github.com/spf13/cobra"
 	"github.com/thingful/device-hub/proto"
 )
@@ -15,28 +14,45 @@ var deleteCommand = &cobra.Command{
 	Short: "Delete listener, profile and endpoint resources",
 	RunE: func(cmd *cobra.Command, args []string) error {
 
-		sample := proto.DeleteRequest{}
+		conn, client, err := dial()
+		if err != nil {
+			return err
+		}
+		defer conn.Close()
 
-		err := roundTrip(sample, func(cli proto.HubClient, in iocodec.Decoder, out iocodec.Encoder) error {
-
-			v := proto.DeleteRequest{}
-
-			err := in.Decode(&v)
+		_resources.Reverse()
+		for _, r := range _resources.R {
+			req := proto.DeleteRequest{}
+			err := r.Raw.Decode(&req)
 			if err != nil {
 				return err
 			}
-
-			resp, err := cli.Delete(context.Background(), &v)
-
-			if err != nil {
-				return err
+			if r.Data["type"] != "process" {
+				resp, err := client.Delete(context.Background(), &req)
+				if err != nil {
+					return err
+				}
+
+				err = _encoder.Encode(resp)
+				if err != nil {
+					return err
+				}
+
+			} else {
+				var conf processConf
+				err := r.Raw.Decode(&conf)
+				if err != nil {
+					return err
+				}
+				err = stopCall(conf.URI, client)
+				if err != nil {
+					return err
+				}
 			}
 
-			return out.Encode(resp)
-
-		})
+		}
 
-		return err
+		return nil
 
 	},
 }