forked from toolshed/abra
		
	fix: make more server new command more robust
See coop-cloud/organising#163.
This commit is contained in:
		| @ -1,29 +1,88 @@ | ||||
| package server | ||||
|  | ||||
| import ( | ||||
| 	"fmt" | ||||
| 	"context" | ||||
| 	"os/user" | ||||
|  | ||||
| 	"coopcloud.tech/abra/cli/internal" | ||||
| 	"coopcloud.tech/abra/pkg/client" | ||||
| 	"github.com/sirupsen/logrus" | ||||
| 	"github.com/urfave/cli/v2" | ||||
| ) | ||||
|  | ||||
| var serverAddCommand = &cli.Command{ | ||||
| 	Name:        "add", | ||||
| 	Usage:       "Add a new server, reachable on <server>.", | ||||
| 	Aliases:     []string{"a"}, | ||||
| 	ArgsUsage:   "<server> [<user>] [<port>]", | ||||
| 	Description: "[<user>], [<port>]    SSH connection details", | ||||
| 	Name:  "add", | ||||
| 	Usage: "Add a new server", | ||||
| 	Description: ` | ||||
| This command adds a new server that abra will communicate with, to deploy apps. | ||||
|  | ||||
| The <domain> argument must be a publicy accessible domain name which points to | ||||
| your server. You should have SSH access to this server, Abra will assume port | ||||
| 22 and will use your current system username to make an initial connection. You | ||||
| can use the <user> and <port> arguments to adjust this. | ||||
|  | ||||
| For example: | ||||
|  | ||||
|     abra server add varia.zone 12345 glodemodem | ||||
|  | ||||
| Abra will construct the following SSH connection string then: | ||||
|  | ||||
|     ssh://globemodem@varia.zone:12345 | ||||
|  | ||||
| All communication between Abra and the server will use this SSH connection. | ||||
|  | ||||
| `, | ||||
| 	Aliases:   []string{"a"}, | ||||
| 	ArgsUsage: "<domain> [<user>] [<port>]", | ||||
| 	Action: func(c *cli.Context) error { | ||||
| 		argLen := c.Args().Len() | ||||
| 		args := c.Args().Slice() | ||||
| 		if argLen < 3 { | ||||
| 			args = append(args, make([]string, 3-argLen)...) | ||||
| 		domainName := internal.ValidateDomain(c) | ||||
|  | ||||
| 		var username string | ||||
| 		var port string | ||||
|  | ||||
| 		username = c.Args().Get(1) | ||||
| 		if username == "" { | ||||
| 			systemUser, err := user.Current() | ||||
| 			if err != nil { | ||||
| 				logrus.Fatal(err) | ||||
| 			} | ||||
| 			username = systemUser.Username | ||||
| 		} | ||||
| 		if err := client.CreateContext(args[0], args[1], args[2]); err != nil { | ||||
|  | ||||
| 		port = c.Args().Get(2) | ||||
| 		if port == "" { | ||||
| 			port = "22" | ||||
| 		} | ||||
|  | ||||
| 		store := client.NewDefaultDockerContextStore() | ||||
| 		contexts, err := store.Store.List() | ||||
| 		if err != nil { | ||||
| 			logrus.Fatal(err) | ||||
| 		} | ||||
| 		fmt.Println(args[0]) | ||||
|  | ||||
| 		for _, context := range contexts { | ||||
| 			if context.Name == domainName { | ||||
| 				logrus.Fatalf("Server at '%s' already exists?", domainName) | ||||
| 			} | ||||
| 		} | ||||
|  | ||||
| 		if err := client.CreateContext(domainName, username, port); err != nil { | ||||
| 			logrus.Fatal(err) | ||||
| 		} | ||||
|  | ||||
| 		ctx := context.Background() | ||||
| 		cl, err := client.New(domainName) | ||||
| 		if err != nil { | ||||
| 			logrus.Fatal(err) | ||||
| 		} | ||||
|  | ||||
| 		if _, err := cl.Info(ctx); err != nil { | ||||
| 			logrus.Fatalf("Unable to make a connection to '%s'?", domainName) | ||||
| 			logrus.Debug(err) | ||||
| 		} | ||||
|  | ||||
| 		logrus.Infof("Server at '%s' has been added", domainName) | ||||
|  | ||||
| 		return nil | ||||
| 	}, | ||||
| } | ||||
|  | ||||
		Reference in New Issue
	
	Block a user