juanfont.headscale/cmd/headscale/cli/routes.go

package cli

import (
	"fmt"
	"log"
	"strings"

	"github.com/pterm/pterm"
	"github.com/spf13/cobra"
)

func init() {
	rootCmd.AddCommand(routesCmd)
	routesCmd.PersistentFlags().StringP("namespace", "n", "", "Namespace")
	err := routesCmd.MarkPersistentFlagRequired("namespace")
	if err != nil {
		log.Fatalf(err.Error())
	}

	enableRouteCmd.Flags().BoolP("all", "a", false, "Enable all routes advertised by the node")

	routesCmd.AddCommand(listRoutesCmd)
	routesCmd.AddCommand(enableRouteCmd)
}

var routesCmd = &cobra.Command{
	Use:   "routes",
	Short: "Manage the routes of Headscale",
}

var listRoutesCmd = &cobra.Command{
	Use:   "list NODE",
	Short: "List the routes exposed by this 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) {
		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)
		}

		availableRoutes, err := h.GetAdvertisedNodeRoutes(n, args[0])
		if err != nil {
			fmt.Println(err)
			return
		}

		if strings.HasPrefix(o, "json") {
			// TODO: Add enable/disabled information to this interface
			JsonOutput(availableRoutes, err, o)
			return
		}

		d := h.RoutesToPtables(n, args[0], *availableRoutes)

		err = pterm.DefaultTable.WithHasHeader().WithData(d).Render()
		if err != nil {
			log.Fatal(err)
		}
	},
}

var enableRouteCmd = &cobra.Command{
	Use:   "enable node-name route",
	Short: "Allows exposing a route declared by this node to the rest of the nodes",
	Args: func(cmd *cobra.Command, args []string) error {
		all, err := cmd.Flags().GetBool("all")
		if err != nil {
			log.Fatalf("Error getting namespace: %s", err)
		}

		if all {
			if len(args) < 1 {
				return fmt.Errorf("Missing parameters")
			}
			return nil
		} else {
			if len(args) < 2 {
				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")

		all, err := cmd.Flags().GetBool("all")
		if err != nil {
			log.Fatalf("Error getting namespace: %s", err)
		}

		h, err := getHeadscaleApp()
		if err != nil {
			log.Fatalf("Error initializing: %s", err)
		}

		if all {
			availableRoutes, err := h.GetAdvertisedNodeRoutes(n, args[0])
			if err != nil {
				fmt.Println(err)
				return
			}

			for _, availableRoute := range *availableRoutes {
				err = h.EnableNodeRoute(n, args[0], availableRoute.String())
				if err != nil {
					fmt.Println(err)
					return
				}

				if strings.HasPrefix(o, "json") {
					JsonOutput(availableRoute, err, o)
				} else {
					fmt.Printf("Enabled route %s\n", availableRoute)
				}
			}
		} else {
			err = h.EnableNodeRoute(n, args[0], args[1])

			if strings.HasPrefix(o, "json") {
				JsonOutput(args[1], err, o)
				return
			}

			if err != nil {
				fmt.Println(err)
				return
			}
			fmt.Printf("Enabled route %s\n", args[1])
		}
	},
}