mirror of
https://github.com/juanfont/headscale.git
synced 2024-12-24 16:58:05 +00:00
147 lines
3.3 KiB
Go
147 lines
3.3 KiB
Go
package cli
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
survey "github.com/AlecAivazis/survey/v2"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
func init() {
|
|
rootCmd.AddCommand(nodeCmd)
|
|
nodeCmd.PersistentFlags().StringP("namespace", "n", "", "Namespace")
|
|
err := nodeCmd.MarkPersistentFlagRequired("namespace")
|
|
if err != nil {
|
|
log.Fatalf(err.Error())
|
|
}
|
|
nodeCmd.AddCommand(listNodesCmd)
|
|
nodeCmd.AddCommand(registerNodeCmd)
|
|
nodeCmd.AddCommand(deleteNodeCmd)
|
|
}
|
|
|
|
var nodeCmd = &cobra.Command{
|
|
Use: "nodes",
|
|
Short: "Manage the nodes of Headscale",
|
|
}
|
|
|
|
var registerNodeCmd = &cobra.Command{
|
|
Use: "register machineID",
|
|
Short: "Registers a machine to your network",
|
|
Args: func(cmd *cobra.Command, args []string) error {
|
|
if len(args) < 1 {
|
|
return fmt.Errorf("Missing parameters")
|
|
}
|
|
return nil
|
|
},
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
n, err := cmd.Flags().GetString("namespace")
|
|
if err != nil {
|
|
log.Fatalf("Error getting namespace: %s", err)
|
|
}
|
|
o, _ := cmd.Flags().GetString("output")
|
|
|
|
h, err := getHeadscaleApp()
|
|
if err != nil {
|
|
log.Fatalf("Error initializing: %s", err)
|
|
}
|
|
m, err := h.RegisterMachine(args[0], n)
|
|
if strings.HasPrefix(o, "json") {
|
|
JsonOutput(m, err, o)
|
|
return
|
|
}
|
|
if err != nil {
|
|
fmt.Printf("Cannot register machine: %s\n", err)
|
|
return
|
|
}
|
|
fmt.Printf("Machine registered\n")
|
|
},
|
|
}
|
|
|
|
var listNodesCmd = &cobra.Command{
|
|
Use: "list",
|
|
Short: "List the nodes in a given namespace",
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
n, err := cmd.Flags().GetString("namespace")
|
|
if err != nil {
|
|
log.Fatalf("Error getting namespace: %s", err)
|
|
}
|
|
o, _ := cmd.Flags().GetString("output")
|
|
|
|
h, err := getHeadscaleApp()
|
|
if err != nil {
|
|
log.Fatalf("Error initializing: %s", err)
|
|
}
|
|
machines, err := h.ListMachinesInNamespace(n)
|
|
if strings.HasPrefix(o, "json") {
|
|
JsonOutput(machines, err, o)
|
|
return
|
|
}
|
|
|
|
if err != nil {
|
|
log.Fatalf("Error getting nodes: %s", err)
|
|
}
|
|
|
|
fmt.Printf("ID\tname\t\tlast seen\t\tephemeral\n")
|
|
for _, m := range *machines {
|
|
var ephemeral bool
|
|
if m.AuthKey != nil && m.AuthKey.Ephemeral {
|
|
ephemeral = true
|
|
}
|
|
var lastSeen time.Time
|
|
if m.LastSeen != nil {
|
|
lastSeen = *m.LastSeen
|
|
}
|
|
fmt.Printf("%d\t%s\t%s\t%t\n", m.ID, m.Name, lastSeen.Format("2006-01-02 15:04:05"), ephemeral)
|
|
}
|
|
|
|
},
|
|
}
|
|
|
|
var deleteNodeCmd = &cobra.Command{
|
|
Use: "delete ID",
|
|
Short: "Delete a node",
|
|
Args: func(cmd *cobra.Command, args []string) error {
|
|
if len(args) < 1 {
|
|
return fmt.Errorf("Missing parameters")
|
|
}
|
|
return nil
|
|
},
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
h, err := getHeadscaleApp()
|
|
if err != nil {
|
|
log.Fatalf("Error initializing: %s", err)
|
|
}
|
|
id, err := strconv.Atoi(args[0])
|
|
if err != nil {
|
|
log.Fatalf("Error converting ID to integer: %s", err)
|
|
}
|
|
m, err := h.GetMachineByID(uint64(id))
|
|
if err != nil {
|
|
log.Fatalf("Error getting node: %s", err)
|
|
}
|
|
|
|
confirm := false
|
|
prompt := &survey.Confirm{
|
|
Message: fmt.Sprintf("Do you want to remove the node %s?", m.Name),
|
|
}
|
|
err = survey.AskOne(prompt, &confirm)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if confirm {
|
|
err = h.DeleteMachine(m)
|
|
if err != nil {
|
|
log.Fatalf("Error deleting node: %s", err)
|
|
}
|
|
fmt.Printf("Node deleted\n")
|
|
} else {
|
|
fmt.Printf("Node not deleted\n")
|
|
}
|
|
},
|
|
}
|