feat: add recreate cmd and separate public to public-{source,target}

Author: isometry

.goreleaser.yml

@@ -0,0 +1,54 @@
+version: 2
+before:
+  hooks:
+    - go mod tidy
+builds:
+  - main: .
+    binary: gitea-mirror
+    env:
+      - CGO_ENABLED=0
+    mod_timestamp: "{{ .CommitTimestamp }}"
+    flags:
+      - -trimpath
+    ldflags:
+      - >-
+        -s -w
+        -X main.version={{.Version}}
+        -X main.commit={{.ShortCommit}}
+        -X main.date={{.Date}}
+    goos:
+      - windows
+      - linux
+      - darwin
+    goarch:
+      - amd64
+      - arm64
+archives:
+  - formats:
+      - zip
+    name_template: "{{ .ProjectName }}_{{ .Version }}_{{ .Os }}_{{ .Arch }}"
+snapshot:
+  version_template: "{{ .Tag }}-next"
+checksum:
+  name_template: "{{ .ProjectName }}_{{ .Version }}_SHA256SUMS"
+  algorithm: sha256
+release:
+  draft: false
+changelog:
+  sort: asc
+  filters:
+    exclude:
+      - "^docs:"
+      - "^test:"
+brews:
+  - repository:
+      owner: isometry
+      name: homebrew-tap
+      token: "{{ .Env.HOMEBREW_TAP_GITHUB_TOKEN }}"
+    directory: Formula
+    description: Manage Gitea mirror lifecycle
+    homepage: https://just.breathe.io/project/gitea-mirror/
+    test: |
+      system "#{bin}/gitea-mirror --help"
+    install: |
+      bin.install "gitea-mirror"

cmd/recreate.go

@@ -0,0 +1,68 @@
+package cmd
+
+import (
+	"fmt"
+
+	"github.com/spf13/cobra"
+
+	"github.com/nexthink-oss/gitea-mirror/pkg/gitea"
+	"github.com/nexthink-oss/gitea-mirror/pkg/github"
+	"github.com/nexthink-oss/gitea-mirror/pkg/server"
+	"github.com/nexthink-oss/gitea-mirror/pkg/util"
+)
+
+func cmdRecreate() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "recreate [<repository> ...]",
+		Short: "Recreate Gitea mirrors",
+		RunE:  RecreateMirrors,
+	}
+
+	return cmd
+}
+
+func RecreateMirrors(cmd *cobra.Command, args []string) (err error) {
+	var ctx = cmd.Context()
+	var source server.Server
+
+	if config.Source.Token == "" {
+		if err := util.PromptForToken("Source API token", &config.Source.Token); err != nil {
+			return fmt.Errorf("Source API token: %w", err)
+		}
+	}
+
+	if config.Target.Token == "" {
+		if err := util.PromptForToken("Target API token", &config.Target.Token); err != nil {
+			return fmt.Errorf("Target API token: %w", err)
+		}
+	}
+
+	switch config.Source.Type {
+	case "github":
+		source = github.NewController(ctx, &config.Source)
+	case "gitea":
+		source, err = gitea.NewController(ctx, &config.Source)
+		if err != nil {
+			return fmt.Errorf("NewController(%s): %w", config.Source.Url, err)
+		}
+	}
+
+	target, err := gitea.NewController(ctx, &config.Target)
+	if err != nil {
+		return fmt.Errorf("NewController(%s): %w", config.Target.Url, err)
+	}
+
+	for repo := range config.FilteredRepositories(args) {
+		if err = target.DeleteMirror(&repo); err != nil {
+			fmt.Println(repo.Failure(fmt.Errorf("deleting: %w", err)))
+			continue
+		}
+		if _, err = target.CreateMirror(source, &repo); err != nil {
+			fmt.Println(repo.Failure(fmt.Errorf("creating: %w", err)))
+		} else {
+			fmt.Println(repo.Success())
+		}
+	}
+
+	return nil
+}

cmd/root.go

@@ -30,6 +30,7 @@ func New() *cobra.Command {
 	cmd.AddCommand(
 		cmdConfig(),
 		cmdCreate(),
+		cmdRecreate(),
 		cmdDelete(),
 		cmdStatus(),
 		cmdSync(),

pkg/config/config.go

@@ -33,16 +33,18 @@ type Forge interface {
 }
 
 type Defaults struct {
-	Owner    string        `mapstructure:"owner"`
-	Interval time.Duration `mapstructure:"interval"`
-	Public   bool          `mapstructure:"public"`
+	Owner        string        `mapstructure:"owner"`
+	Interval     time.Duration `mapstructure:"interval"`
+	PublicSource bool          `mapstructure:"public-source"`
+	PublicTarget bool          `mapstructure:"public-target"`
 }
 
 type Repository struct {
-	Owner    string         `mapstructure:"owner" yaml:"owner,omitempty"`
-	Name     string         `mapstructure:"name"`
-	Interval *time.Duration `mapstructure:"interval" yaml:"interval,omitempty"`
-	Public   *bool          `mapstructure:"public" yaml:"public,omitempty"`
+	Owner        string         `mapstructure:"owner" yaml:"owner,omitempty"`
+	Name         string         `mapstructure:"name"`
+	Interval     *time.Duration `mapstructure:"interval" yaml:"interval,omitempty"`
+	PublicSource *bool          `mapstructure:"public-source" yaml:"public-source,omitempty"`
+	PublicTarget *bool          `mapstructure:"public-target" yaml:"public-target,omitempty"`
 }
 
 type RepositorySet map[string]struct{}
@@ -88,8 +90,11 @@ func LoadConfig(names []string) (*Config, error) {
 		if r.Interval == nil {
 			config.Repositories[i].Interval = &config.Defaults.Interval
 		}
-		if r.Public == nil {
-			config.Repositories[i].Public = &config.Defaults.Public
+		if r.PublicSource == nil {
+			config.Repositories[i].PublicSource = &config.Defaults.PublicSource
+		}
+		if r.PublicTarget == nil {
+			config.Repositories[i].PublicTarget = &config.Defaults.PublicTarget
 		}
 	}
 

pkg/gitea/mirror.go

@@ -30,12 +30,17 @@ func (c *Controller) CreateMirror(source server.Server, r *config.Repository) (*
 		return nil, err
 	}
 
+	var authToken string
+	if !*r.PublicSource {
+		authToken = source.GetToken()
+	}
+
 	options := gitea.MigrateRepoOption{
 		RepoOwner:      r.Owner,
 		RepoName:       r.Name,
-		Private:        !*r.Public,
+		Private:        !*r.PublicTarget,
 		CloneAddr:      cloneURL,
-		AuthToken:      source.GetToken(),
+		AuthToken:      authToken,
 		Mirror:         true,
 		MirrorInterval: r.Interval.String(),
 	}
@@ -46,7 +51,7 @@ func (c *Controller) CreateMirror(source server.Server, r *config.Repository) (*
 }
 
 func (c *Controller) UpdateMirror(r *config.Repository) (*gitea.Repository, error) {
-	private := !*r.Public
+	private := !*r.PublicTarget
 	interval := r.Interval.String()
 	options := gitea.EditRepoOption{
 		Private:        &private,