feat: command to add packages

Author: calmh

internal/add/add.go

@@ -0,0 +1,45 @@
+package add
+
+import (
+	"log/slog"
+	"os"
+	"path/filepath"
+
+	"pault.ag/go/debian/deb"
+)
+
+type CLI struct {
+	Source string `required:"" help:"Path to packages to add" type:"existingdir"`
+	Repo   string `required:"" help:"Path to repository directory" type:"existingdir"`
+}
+
+func (c *CLI) Run() error {
+	return filepath.Walk(c.Source, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+		if info.IsDir() {
+			return nil
+		}
+		if filepath.Ext(path) != ".deb" {
+			return nil
+		}
+
+		slog.Info("Scanning package", "path", path)
+		deb, cl, err := deb.LoadFile(path)
+		if err != nil {
+			return err
+		}
+		defer cl()
+
+		newPath := filepath.Join(c.Repo, "binary-"+deb.Control.Architecture.String(), filepath.Base(path))
+		slog.Info("Adding package", "path", newPath)
+		if err := os.MkdirAll(filepath.Dir(newPath), 0o700); err != nil {
+			return err
+		}
+		if err := os.Link(path, newPath); err != nil {
+			return err
+		}
+		return nil
+	})
+}

internal/publish/publish.go

@@ -6,9 +6,9 @@ import (
 )
 
 type CLI struct {
-	Dists        string `arg:"" required:"" help:"Path to dists directory" type:"existingdir"`
-	Keyring      string `required:"" help:"Path to GPG keyring" type:"existingfile"`
-	KeepVersions int    `help:"Number of versions to keep" default:"2"`
+	Dists        string `arg:"" required:"" help:"Path to dists directory" type:"existingdir" env:"EZAPT_DISTS"`
+	Keyring      string `required:"" help:"Path to GPG keyring" type:"existingfile" env:"EZAPT_KEYRING"`
+	KeepVersions int    `help:"Number of versions to keep" default:"2" env:"EZAPT_KEEP_VERSIONS"`
 }
 
 func (c *CLI) Run() error {

main.go

@@ -4,11 +4,13 @@ import (
 	"log/slog"
 
 	"github.com/alecthomas/kong"
+	"kastelo.dev/ezapt/internal/add"
 	"kastelo.dev/ezapt/internal/publish"
 )
 
 type CLI struct {
 	Publish publish.CLI `cmd:"" help:"Publish packages to a repository."`
+	Add     add.CLI     `cmd:"" help:"Add packages to a repository."`
 }
 
 func main() {