repo.go

package main

import (
	"fmt"
	"os"
	"path/filepath"
	"sort"
	"text/tabwriter"

	hd "github.com/mitchellh/go-homedir"
	cli "github.com/urfave/cli/v2"
	gx "github.com/whyrusleeping/gx/gxutil"
	. "github.com/whyrusleeping/stump"
)

func cfgPath(global bool) (string, error) {
	if global {
		home, err := hd.Dir()
		if err != nil {
			return "", fmt.Errorf("$HOME not set, cannot find global .gxrc")
		}
		return filepath.Join(home, gx.CfgFileName), nil
	}

	cwd, err := os.Getwd()
	if err != nil {
		return "", err
	}
	return filepath.Join(cwd, gx.CfgFileName), nil
}

var RepoCommand = cli.Command{
	Name:  "repo",
	Usage: "manage set of tracked repositories",
	Subcommands: []*cli.Command{
		&RepoAddCommand,
		&RepoRmCommand,
		&RepoListCommand,
		&RepoQueryCommand,
		&RepoUpdateCommand,
	},
}

var RepoAddCommand = cli.Command{
	Name:  "add",
	Usage: "add a naming repository",
	Flags: []cli.Flag{
		&cli.BoolFlag{
			Name:  "global",
			Usage: "add repository to global set",
		},
	},
	Action: func(c *cli.Context) error {
		global := c.Bool("global")
		cfp, err := cfgPath(global)
		if err != nil {
			return err
		}

		cfg, err := gx.LoadConfigFrom(cfp)
		if err != nil {
			return err
		}

		if c.NArg() != 2 {
			Fatal("Must specify name and repo-path")
		}
		name := c.Args().Get(0)
		rpath := c.Args().Get(1)

		// make sure we can fetch it
		_, err = pm.FetchRepo(rpath, false)
		if err != nil {
			return fmt.Errorf("finding repo: %s", err)
		}

		if global {
			cfg.Repos[name] = rpath
		} else {
			cfg.ExtraRepos[name] = rpath
		}

		return gx.WriteConfig(cfg, cfp)
	},
}

var RepoRmCommand = cli.Command{
	Name:  "rm",
	Usage: "remove a repo from tracking",
	Flags: []cli.Flag{
		&cli.BoolFlag{
			Name:  "global",
			Usage: "remove repository from global set",
		},
	},
	Action: func(c *cli.Context) error {
		global := c.Bool("global")
		cfp, err := cfgPath(global)
		if err != nil {
			return err
		}

		cfg, err := gx.LoadConfigFrom(cfp)
		if err != nil {
			return err
		}

		if !c.Args().Present() {
			return fmt.Errorf("specify repo to remove")
		}
		name := c.Args().First()

		if global {
			if _, ok := cfg.Repos[name]; !ok {
				return fmt.Errorf("no repo named %s", name)
			}
			delete(cfg.Repos, name)
		} else {
			if _, ok := cfg.ExtraRepos[name]; !ok {
				return fmt.Errorf("no repo named %s", name)
			}
			delete(cfg.ExtraRepos, name)
		}

		return gx.WriteConfig(cfg, cfp)
	},
}

var RepoListCommand = cli.Command{
	Name:  "list",
	Usage: "list tracked repos or packages in a repo",
	Action: func(c *cli.Context) error {
		cfg, err := gx.LoadConfig()
		if err != nil {
			return err
		}

		if !c.Args().Present() {
			tabPrintSortedMap(nil, cfg.GetRepos())
			return nil
		}

		rname := c.Args().First()
		r, ok := cfg.GetRepos()[rname]
		if !ok {
			return fmt.Errorf("no such repo: %s", rname)
		}

		repo, err := pm.FetchRepo(r, true)
		if err != nil {
			return err
		}

		tabPrintSortedMap(nil, repo)
		return nil
	},
}

func tabPrintSortedMap(headers []string, m map[string]string) {
	var names []string
	for k := range m {
		names = append(names, k)
	}

	sort.Strings(names)

	w := tabwriter.NewWriter(os.Stdout, 12, 4, 1, ' ', 0)
	if headers != nil {
		fmt.Fprintf(w, "%s\t%s\n", headers[0], headers[1])
	}

	for _, n := range names {
		fmt.Fprintf(w, "%s\t%s\n", n, m[n])
	}
	w.Flush()
}

var RepoQueryCommand = cli.Command{
	Name:  "query",
	Usage: "search for a package in repos",
	Action: func(c *cli.Context) error {
		if !c.Args().Present() {
			return fmt.Errorf("must specify search criteria")
		}

		searcharg := c.Args().First()

		out, err := pm.QueryRepos(searcharg)
		if err != nil {
			return err
		}

		if len(out) > 0 {
			tabPrintSortedMap([]string{"repo", "ref"}, out)
		} else {
			return fmt.Errorf("not found")
		}
		return nil
	},
}

var RepoUpdateCommand = cli.Command{
	Name:  "update",
	Usage: "update cached versions of repos",
	Action: func(c *cli.Context) error {
		cfg, err := gx.LoadConfig()
		if err != nil {
			return err
		}
		repos := cfg.GetRepos()

		var args []string
		if c.Args().Present() {
			args = c.Args().Slice()
		} else {
			for k := range repos {
				args = append(args, k)
			}
		}

		for _, r := range args {
			path, ok := repos[r]
			if !ok {
				return fmt.Errorf("unknown repo: %s", r)
			}

			val, ok, err := gx.CheckCacheFile(path)
			if err != nil {
				return fmt.Errorf("checking cache: %s", err)
			}

			nval, err := pm.ResolveRepoName(path, false)
			if err != nil {
				return fmt.Errorf("resolving repo: %s", err)
			}

			if ok {
				if nval == val {
					Log("%s: up to date", r)
				} else {
					Log("%s: updated from %s to %s", r, val, nval)
				}
			} else if !ok {
				Log("%s: %s", r, nval)
			}
		}
		return nil
	},
}