Add deployment commands

Author: markpeek

cmd/gghelper/deploy.go

@@ -0,0 +1,71 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+)
+
+// CreateDeployment - command execution for createdeployment subcommand
+func CreateDeployment(args []string) {
+
+	var region, profile string
+
+	cmdFlags := flag.NewFlagSet("ask", flag.ExitOnError)
+
+	cmdFlags.StringVar(&region, "r", "", "region")
+	cmdFlags.StringVar(&profile, "p", "", "profile")
+	cmdFlags.Parse(args)
+
+	ggSession := CreateSession(profile, region)
+
+	ggSession.LoadGroupConfig("config.json")
+
+	err := ggSession.CreateDeployment()
+	if err != nil {
+		fmt.Printf("Error: %v\n", err)
+	}
+}
+
+// ListDeployment - command execution for listdeployment subcommand
+func ListDeployment(args []string) {
+
+	var region, profile string
+
+	cmdFlags := flag.NewFlagSet("ask", flag.ExitOnError)
+
+	cmdFlags.StringVar(&region, "r", "", "region")
+	cmdFlags.StringVar(&profile, "p", "", "profile")
+	cmdFlags.Parse(args)
+
+	ggSession := CreateSession(profile, region)
+
+	ggSession.LoadGroupConfig("config.json")
+
+	err := ggSession.ListDeployment()
+	if err != nil {
+		fmt.Printf("Error: %v\n", err)
+	}
+}
+
+// ResetDeployment - command execution for resetdeployment subcommand
+func ResetDeployment(args []string) {
+
+	var region, profile string
+	var force bool
+
+	cmdFlags := flag.NewFlagSet("ask", flag.ExitOnError)
+
+	cmdFlags.BoolVar(&force, "f", false, "force reset")
+	cmdFlags.StringVar(&region, "r", "", "region")
+	cmdFlags.StringVar(&profile, "p", "", "profile")
+	cmdFlags.Parse(args)
+
+	ggSession := CreateSession(profile, region)
+
+	ggSession.LoadGroupConfig("config.json")
+
+	err := ggSession.ResetDeployment(force)
+	if err != nil {
+		fmt.Printf("Error: %v\n", err)
+	}
+}

cmd/gghelper/gghelper.go

@@ -9,24 +9,33 @@ import (
 	"github.com/cloudtools/gghelper"
 )
 
+func printUsage() {
+	fmt.Println("usage: gghelper <command> [<args>]")
+	fmt.Println("Commands: ")
+	fmt.Println(" createcore       - create a new Greengrass core")
+	fmt.Println(" createdeployment - create a new Greengrass core")
+	fmt.Println(" creategroup      - create a new Greengrass group")
+	fmt.Println(" createsub        - create a new Greengrass subscription")
+	fmt.Println(" deleteregion     - delete all greengrass/iot resources in a region")
+	fmt.Println(" lambda           - submit a lambda function")
+	fmt.Println(" listdeployment   - list greengrass deployment")
+	fmt.Println(" listgroup        - list greengrass group")
+	fmt.Println(" listlambda       - list greengrass view of lambda functions")
+	fmt.Println(" listsub          - list greengrass subscriptions")
+	fmt.Println(" resetdeployment  - reset greengrass deployments")
+}
+
 func main() {
 	if len(os.Args) == 1 {
-		fmt.Println("usage: gghelper <command> [<args>]")
-		fmt.Println("Commands: ")
-		fmt.Println(" createcore    create a new Greengrass core")
-		fmt.Println(" creategroup   create a new Greengrass group")
-		fmt.Println(" createsub     create a new Greengrass subscription")
-		fmt.Println(" deleteregion  delete all greengrass/iot resources in a region")
-		fmt.Println(" lambda        submit a lambda function")
-		fmt.Println(" listgroup     list greengrass group")
-		fmt.Println(" listlambda    list greengrass view of lambda functions")
-		fmt.Println(" listsub       list greengrass subscriptions")
+		printUsage()
 		return
 	}
 
 	switch os.Args[1] {
 	case "createcore":
 		CreateCore(os.Args[2:])
+	case "createdeployment", "createdeploy", "deploy":
+		CreateDeployment(os.Args[2:])
 	case "creategroup":
 		CreateGroup(os.Args[2:])
 	case "createsub":
@@ -35,14 +44,19 @@ func main() {
 		DeleteRegion(os.Args[2:])
 	case "lambda":
 		Lambda(os.Args[2:])
+	case "listdeployment", "listdeploy":
+		ListDeployment(os.Args[2:])
 	case "listgroup":
 		ListGroup(os.Args[2:])
 	case "listlambda":
 		ListLambda(os.Args[2:])
 	case "listsub":
 		ListSub(os.Args[2:])
+	case "resetdeployment", "resetdeploy":
+		ResetDeployment(os.Args[2:])
 	default:
 		fmt.Printf("%q is not valid command.\n", os.Args[1])
+		printUsage()
 		os.Exit(2)
 	}
 }

deploy.go

@@ -0,0 +1,68 @@
+package gghelper
+
+import (
+	"fmt"
+
+	"github.com/aws/aws-sdk-go/service/greengrass"
+)
+
+// CreateDeployment - Create a deployment
+func (ggSession *GreengrassSession) CreateDeployment() error {
+	deployments, err := ggSession.greengrass.ListDeployments(&greengrass.ListDeploymentsInput{
+		GroupId: &ggSession.config.Group.ID,
+	})
+	if err != nil {
+		return err
+	}
+	fmt.Printf("deployments: %v\n", deployments)
+
+	newDeployment := "NewDeployment"
+	create, err := ggSession.greengrass.CreateDeployment(&greengrass.CreateDeploymentInput{
+		DeploymentType: &newDeployment,
+		GroupId:        &ggSession.config.Group.ID,
+		GroupVersionId: &ggSession.config.Group.Version,
+	})
+	if err != nil {
+		return err
+	}
+	fmt.Printf("%v\n", create)
+
+	return nil
+}
+
+// ListDeployment - lists the current deployment status
+func (ggSession *GreengrassSession) ListDeployment() error {
+	deployments, err := ggSession.greengrass.ListDeployments(&greengrass.ListDeploymentsInput{
+		GroupId: &ggSession.config.Group.ID,
+	})
+	if err != nil {
+		return err
+	}
+	fmt.Printf("deployments: %v\n", deployments)
+
+	for _, d := range deployments.Deployments {
+		deployment, err := ggSession.greengrass.GetDeploymentStatus(&greengrass.GetDeploymentStatusInput{
+			DeploymentId: d.DeploymentId,
+			GroupId:      &ggSession.config.Group.ID,
+		})
+		if err != nil {
+			return err
+		}
+		fmt.Printf("deployment: %v\n", deployment)
+	}
+
+	return nil
+}
+
+// ResetDeployment - reset deployments status
+func (ggSession *GreengrassSession) ResetDeployment(force bool) error {
+	reset, err := ggSession.greengrass.ResetDeployments(&greengrass.ResetDeploymentsInput{
+		GroupId: &ggSession.config.Group.ID,
+	})
+	if err != nil {
+		return err
+	}
+	fmt.Printf("deployment reset: %v\n", reset)
+
+	return nil
+}

group.go

@@ -80,11 +80,15 @@ func (ggSession *GreengrassSession) updateGroup() error {
 		input.SubscriptionDefinitionVersionArn = &ggSession.config.SubscriptionDefinition.VersionArn
 	}
 
-	_, err := ggSession.greengrass.CreateGroupVersion(input)
+	groupVersion, err := ggSession.greengrass.CreateGroupVersion(input)
 	if err != nil {
 		fmt.Printf("updateGroup error: %v\n", err)
 		return err
 	}
+
+	ggSession.config.Group.Arn = *groupVersion.Arn
+	ggSession.config.Group.Version = *groupVersion.Version
+
 	fmt.Printf("Updated group version\n")
 
 	return nil

groupconfig.go

@@ -16,7 +16,9 @@ type function struct {
 }
 
 type group struct {
-	ID string `json:"id"`
+	Arn     string `json:"arn"`
+	ID      string `json:"id"`
+	Version string `json:"version"`
 }
 
 type thing struct {