summaryrefslogtreecommitdiffstats
path: root/cmd-projects.go
diff options
context:
space:
mode:
Diffstat (limited to 'cmd-projects.go')
-rw-r--r--cmd-projects.go209
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
+}