diff options
Diffstat (limited to 'cmd-projects.go')
| -rw-r--r-- | cmd-projects.go | 209 |
1 files changed, 209 insertions, 0 deletions
diff --git a/cmd-projects.go b/cmd-projects.go new file mode 100644 index 0000000..9a113db --- /dev/null +++ b/cmd-projects.go @@ -0,0 +1,209 @@ +package main + +import ( + "fmt" + "strings" + + "github.com/iotbzh/xds-agent/lib/apiv1" + "github.com/urfave/cli" +) + +func initCmdProjects(cmdDef *[]cli.Command) { + *cmdDef = append(*cmdDef, cli.Command{ + Name: "projects", + Aliases: []string{"prj"}, + HideHelp: true, + Usage: "project commands group", + Subcommands: []cli.Command{ + { + Name: "add", + Aliases: []string{"a"}, + Usage: "Add a new project", + Action: projectsAdd, + Flags: []cli.Flag{ + cli.StringFlag{ + Name: "label", + Usage: "project label (free form string)", + }, + cli.StringFlag{ + Name: "path", + Usage: "project local path", + }, + cli.StringFlag{ + Name: "server-path", + Usage: "project server path (only used with pathmap type)", + }, + cli.StringFlag{ + Name: "type", + Usage: "project type (pathmap|pm, cloudsync|sc)", + }, + }, + }, + { + Name: "get", + Usage: "Get a property of a project", + Action: projectsGet, + Flags: []cli.Flag{ + cli.StringFlag{ + Name: "id", + Usage: "project id", + }, + }, + }, + { + Name: "list", + Aliases: []string{"ls"}, + Usage: "List existing projects", + Action: projectsList, + Flags: []cli.Flag{ + cli.BoolFlag{ + Name: "verbose, v", + Usage: "display verbose output", + }, + }, + }, + { + Name: "remove", + Aliases: []string{"rm"}, + Usage: "Remove an existing project", + Action: projectsRemove, + Flags: []cli.Flag{ + cli.StringFlag{ + Name: "id", + Usage: "project id", + }, + }, + }, + { + Name: "sync", + Aliases: []string{}, + Usage: "Force synchronization of project sources", + Action: projectsSync, + Flags: []cli.Flag{ + cli.StringFlag{ + Name: "id", + Usage: "project id", + }, + }, + }, + }, + }) +} + +func projectsList(ctx *cli.Context) error { + // Get projects list + prjs := []apiv1.ProjectConfig{} + if err := ProjectsListGet(&prjs); err != nil { + return cli.NewExitError(err.Error(), 1) + } + _displayProjects(prjs, ctx.Bool("verbose")) + return nil +} + +func projectsGet(ctx *cli.Context) error { + id := GetID(ctx) + if id == "" { + return cli.NewExitError("id parameter or option must be set", 1) + } + prjs := make([]apiv1.ProjectConfig, 1) + if err := HTTPCli.Get("/projects/"+id, &prjs[0]); err != nil { + return cli.NewExitError(err, 1) + } + _displayProjects(prjs, true) + return nil +} + +func _displayProjects(prjs []apiv1.ProjectConfig, verbose bool) { + // Display result + first := true + writer := NewTableWriter() + for _, folder := range prjs { + if verbose { + if !first { + fmt.Fprintln(writer) + } + fmt.Fprintln(writer, "ID:\t", folder.ID) + fmt.Fprintln(writer, "Label:\t", folder.Label) + fmt.Fprintln(writer, "Path type:\t", folder.Type) + fmt.Fprintln(writer, "Local Path:\t", folder.ClientPath) + if folder.Type != apiv1.TypeCloudSync { + fmt.Fprintln(writer, "Server Path:\t", folder.ServerPath) + } + fmt.Fprintln(writer, "Status:\t", folder.Status) + fmt.Fprintln(writer, "Is in Sync:\t", folder.IsInSync) + ds := folder.DefaultSdk + if ds == "" { + ds = "-" + } + fmt.Fprintln(writer, "Default Sdk:\t", ds) + + } else { + if first { + fmt.Fprintln(writer, "ID\t Label\t LocalPath") + } + fmt.Fprintln(writer, folder.ID, "\t", folder.Label, "\t", folder.ClientPath) + } + first = false + } + writer.Flush() +} + +func projectsAdd(ctx *cli.Context) error { + + // Decode project type + var ptype apiv1.ProjectType + switch strings.ToLower(ctx.String("type")) { + case "pathmap", "pm": + ptype = apiv1.TypePathMap + case "cloudsync", "cs": + ptype = apiv1.TypeCloudSync + default: + return cli.NewExitError("Unknown project type", 1) + } + + prj := apiv1.ProjectConfig{ + ServerID: XdsServerIDGet(), + Label: ctx.String("label"), + Type: ptype, + ClientPath: ctx.String("path"), + ServerPath: ctx.String("server-path"), + } + + Log.Infof("POST /project %v", prj) + newPrj := apiv1.ProjectConfig{} + err := HTTPCli.Post("/projects", prj, &newPrj) + if err != nil { + return cli.NewExitError(err, 1) + } + + fmt.Printf("New project '%s' (id %v) successfully created.\n", newPrj.Label, newPrj.ID) + + return nil +} + +func projectsRemove(ctx *cli.Context) error { + var res apiv1.ProjectConfig + id := GetID(ctx) + if id == "" { + return cli.NewExitError("id parameter or option must be set", 1) + } + + if err := HTTPCli.Delete("/projects/"+id, &res); err != nil { + return cli.NewExitError(err, 1) + } + + fmt.Println("Project ID " + res.ID + " successfully deleted.") + return nil +} + +func projectsSync(ctx *cli.Context) error { + id := GetID(ctx) + if id == "" { + return cli.NewExitError("id parameter or option must be set", 1) + } + if err := HTTPCli.Post("/projects/sync/"+id, "", nil); err != nil { + return cli.NewExitError(err, 1) + } + fmt.Println("Sync successfully resquested.") + return nil +} |