summaryrefslogtreecommitdiff
path: root/internal/cli/sync_handlers.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2025-06-24 00:26:05 +0300
committerPaul Buetow <paul@buetow.org>2025-06-24 00:26:05 +0300
commit16113b76309dcbae1a91f8420a0bbf10863c9675 (patch)
tree243b2db64f1a64e2f89deda6eae0f052909709dc /internal/cli/sync_handlers.go
parente637f4fbb06b1c0661d2e77ce79d0d5149ac5c47 (diff)
refactor: break down large functions into smaller, focused ones
Major refactoring to improve code maintainability: 1. Split main.go (481 lines → 72 lines) into internal/cli package: - flags.go: Command-line flag definitions and parsing - handlers.go: General command handlers (version, config, list operations) - sync_handlers.go: Sync-specific handlers for all sync operations 2. Refactored sync.go to extract logic into separate files: - git_operations.go: Git command helpers (merge, push, fetch, etc.) - repository_setup.go: Repository initialization and remote configuration - branch_sync.go: Branch synchronization helpers 3. Reduced function sizes to meet 30-line guideline: - syncBranch: 104 lines → 26 lines - SyncRepository: 97 lines → 44 lines - main(): 465 lines → 63 lines - getAllBranches: 32 lines → 9 lines All functionality remains the same, but the code is now more modular, testable, and easier to understand. Each function has a single, clear responsibility. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'internal/cli/sync_handlers.go')
-rw-r--r--internal/cli/sync_handlers.go318
1 files changed, 318 insertions, 0 deletions
diff --git a/internal/cli/sync_handlers.go b/internal/cli/sync_handlers.go
new file mode 100644
index 0000000..d14255e
--- /dev/null
+++ b/internal/cli/sync_handlers.go
@@ -0,0 +1,318 @@
+package cli
+
+import (
+ "fmt"
+ "log"
+ "strings"
+
+ "codeberg.org/snonux/gitsyncer/internal/codeberg"
+ "codeberg.org/snonux/gitsyncer/internal/config"
+ "codeberg.org/snonux/gitsyncer/internal/github"
+ "codeberg.org/snonux/gitsyncer/internal/sync"
+)
+
+// HandleSync handles syncing a single repository
+func HandleSync(cfg *config.Config, flags *Flags) int {
+ // If create-github-repos is enabled, create the repo if needed
+ if flags.CreateGitHubRepos {
+ if err := createGitHubRepoIfNeeded(cfg, flags.SyncRepo); err != nil {
+ fmt.Printf("ERROR: %v\n", err)
+ return 1
+ }
+ }
+
+ syncer := sync.New(cfg, flags.WorkDir)
+ if err := syncer.SyncRepository(flags.SyncRepo); err != nil {
+ log.Fatal("Sync failed:", err)
+ return 1
+ }
+ return 0
+}
+
+// HandleSyncAll handles syncing all configured repositories
+func HandleSyncAll(cfg *config.Config, flags *Flags) int {
+ if len(cfg.Repositories) == 0 {
+ fmt.Println("No repositories configured. Add repositories to the config file.")
+ return 1
+ }
+
+ // Initialize GitHub client if needed
+ var githubClient *github.Client
+ if flags.CreateGitHubRepos {
+ githubClient = initGitHubClient(cfg)
+ }
+
+ syncer := sync.New(cfg, flags.WorkDir)
+ successCount := 0
+
+ for i, repo := range cfg.Repositories {
+ fmt.Printf("\n[%d/%d] Syncing %s...\n", i+1, len(cfg.Repositories), repo)
+
+ // Create GitHub repo if needed
+ if githubClient != nil {
+ if err := createRepoWithClient(githubClient, repo, fmt.Sprintf("Mirror of %s", repo)); err != nil {
+ fmt.Printf("ERROR: Failed to create GitHub repo %s: %v\n", repo, err)
+ fmt.Printf("Stopping sync due to error.\n")
+ return 1
+ }
+ }
+
+ if err := syncer.SyncRepository(repo); err != nil {
+ fmt.Printf("ERROR: Failed to sync %s: %v\n", repo, err)
+ fmt.Printf("Stopping sync due to error.\n")
+ return 1
+ }
+ successCount++
+ }
+
+ fmt.Printf("\nSuccessfully synced all %d repositories!\n", successCount)
+ return 0
+}
+
+// HandleSyncCodebergPublic handles syncing all public Codeberg repositories
+func HandleSyncCodebergPublic(cfg *config.Config, flags *Flags) int {
+ codebergOrg := cfg.FindCodebergOrg()
+ if codebergOrg == nil {
+ fmt.Println("No Codeberg organization found in configuration")
+ return 1
+ }
+
+ fmt.Printf("Fetching public repositories from Codeberg user/org: %s...\n", codebergOrg.Name)
+
+ client := codeberg.NewClient(codebergOrg.Name)
+
+ // Try fetching as organization first, then as user
+ repos, err := client.ListPublicRepos()
+ if err != nil {
+ fmt.Println("Trying as user account...")
+ repos, err = client.ListUserPublicRepos()
+ if err != nil {
+ log.Fatal("Failed to fetch repositories:", err)
+ }
+ }
+
+ repoNames := codeberg.GetRepoNames(repos)
+ fmt.Printf("Found %d public repositories on Codeberg\n", len(repoNames))
+
+ if len(repoNames) == 0 {
+ fmt.Println("No public repositories found")
+ return 0
+ }
+
+ // Show the repositories that will be synced
+ showReposToSync(repoNames)
+
+ if flags.DryRun {
+ fmt.Printf("\n[DRY RUN] Would sync %d repositories from Codeberg to GitHub\n", len(repoNames))
+ if flags.CreateGitHubRepos {
+ fmt.Println("Would create missing GitHub repositories")
+ }
+ if !flags.SyncGitHubPublic {
+ return 0
+ }
+ }
+
+ if !flags.DryRun {
+ return syncCodebergRepos(cfg, flags, repos, repoNames)
+ }
+
+ return 0
+}
+
+// HandleSyncGitHubPublic handles syncing all public GitHub repositories
+func HandleSyncGitHubPublic(cfg *config.Config, flags *Flags) int {
+ githubOrg := cfg.FindGitHubOrg()
+ if githubOrg == nil {
+ fmt.Println("No GitHub organization found in configuration")
+ return 1
+ }
+
+ fmt.Printf("Fetching public repositories from GitHub user/org: %s...\n", githubOrg.Name)
+
+ client := github.NewClient(githubOrg.GitHubToken, githubOrg.Name)
+ if !client.HasToken() {
+ fmt.Println("ERROR: GitHub token required to list repositories")
+ fmt.Println("Set GITHUB_TOKEN env var or create ~/.gitsyncer_github_token file")
+ return 1
+ }
+
+ repos, err := client.ListPublicRepos()
+ if err != nil {
+ log.Fatal("Failed to fetch repositories:", err)
+ }
+
+ repoNames := github.GetRepoNames(repos)
+ fmt.Printf("Found %d public repositories on GitHub\n", len(repoNames))
+
+ if len(repoNames) == 0 {
+ fmt.Println("No public repositories found")
+ return 0
+ }
+
+ // Show the repositories that will be synced
+ showReposToSync(repoNames)
+
+ if flags.DryRun {
+ fmt.Printf("\n[DRY RUN] Would sync %d repositories from GitHub to Codeberg\n", len(repoNames))
+ if flags.CreateCodebergRepos {
+ fmt.Println("Would create missing Codeberg repositories")
+ }
+ return 0
+ }
+
+ if !flags.DryRun {
+ return syncGitHubRepos(cfg, flags, repos, repoNames)
+ }
+
+ return 0
+}
+
+// Helper functions
+
+func createGitHubRepoIfNeeded(cfg *config.Config, repoName string) error {
+ githubOrg := cfg.FindGitHubOrg()
+ if githubOrg == nil {
+ return nil
+ }
+
+ fmt.Printf("Initializing GitHub client for organization: %s\n", githubOrg.Name)
+ githubClient := github.NewClient(githubOrg.GitHubToken, githubOrg.Name)
+ if !githubClient.HasToken() {
+ fmt.Println("Warning: No GitHub token found. Cannot create repository.")
+ return nil
+ }
+
+ fmt.Println("Checking/creating GitHub repository...")
+ return githubClient.CreateRepo(repoName, fmt.Sprintf("Mirror of %s", repoName), false)
+}
+
+func initGitHubClient(cfg *config.Config) *github.Client {
+ githubOrg := cfg.FindGitHubOrg()
+ if githubOrg == nil {
+ fmt.Println("Warning: --create-github-repos specified but no GitHub organization found in config")
+ return nil
+ }
+
+ fmt.Printf("Initializing GitHub client for organization: %s\n", githubOrg.Name)
+ githubClient := github.NewClient(githubOrg.GitHubToken, githubOrg.Name)
+ if !githubClient.HasToken() {
+ fmt.Println("Warning: No GitHub token found. Cannot create repositories.")
+ return nil
+ }
+
+ fmt.Println("GitHub client initialized successfully with token")
+ return githubClient
+}
+
+func createRepoWithClient(client *github.Client, repoName, description string) error {
+ fmt.Printf("Checking/creating GitHub repository %s...\n", repoName)
+ return client.CreateRepo(repoName, description, false)
+}
+
+func showReposToSync(repoNames []string) {
+ fmt.Println("\nRepositories to sync:")
+ for _, name := range repoNames {
+ fmt.Printf(" - %s\n", name)
+ }
+}
+
+func printFullSyncSeparator() {
+ fmt.Println("\n" + strings.Repeat("=", 70))
+ fmt.Println("=== Continuing with GitHub to Codeberg sync ===")
+ fmt.Println(strings.Repeat("=", 70) + "\n")
+}
+
+func syncCodebergRepos(cfg *config.Config, flags *Flags, repos []codeberg.Repository, repoNames []string) int {
+ // Initialize GitHub client if needed
+ var githubClient *github.Client
+ if flags.CreateGitHubRepos {
+ githubClient = initGitHubClient(cfg)
+ }
+
+ fmt.Printf("\nStarting sync of %d repositories...\n", len(repoNames))
+
+ syncer := sync.New(cfg, flags.WorkDir)
+ successCount := 0
+
+ // Create map for descriptions
+ repoMap := make(map[string]codeberg.Repository)
+ for _, repo := range repos {
+ repoMap[repo.Name] = repo
+ }
+
+ for i, repoName := range repoNames {
+ fmt.Printf("\n[%d/%d] Syncing %s...\n", i+1, len(repoNames), repoName)
+
+ // Create GitHub repo if needed
+ if githubClient != nil && flags.CreateGitHubRepos {
+ codebergRepo := repoMap[repoName]
+ description := codebergRepo.Description
+ if description == "" {
+ description = fmt.Sprintf("Mirror of %s from Codeberg", repoName)
+ }
+
+ fmt.Printf("Checking/creating GitHub repository %s...\n", repoName)
+ err := githubClient.CreateRepo(repoName, description, false)
+ if err != nil {
+ fmt.Printf("Warning: Failed to create GitHub repo %s: %v\n", repoName, err)
+ }
+ }
+
+ if err := syncer.SyncRepository(repoName); err != nil {
+ fmt.Printf("ERROR: Failed to sync %s: %v\n", repoName, err)
+ fmt.Printf("Stopping sync due to error.\n")
+ return 1
+ }
+ successCount++
+ }
+
+ fmt.Printf("\n=== Summary ===\n")
+ fmt.Printf("Successfully synced: %d repositories\n", successCount)
+
+ if !flags.SyncGitHubPublic {
+ return 0
+ }
+
+ // Print separator for full sync
+ printFullSyncSeparator()
+ return 0
+}
+
+func syncGitHubRepos(cfg *config.Config, flags *Flags, repos []github.Repository, repoNames []string) int {
+ // TODO: Add Codeberg API client for repo creation
+ if flags.CreateCodebergRepos {
+ fmt.Println("WARNING: --create-codeberg-repos is not yet implemented")
+ fmt.Println(" Repositories must exist on Codeberg before syncing")
+ }
+
+ fmt.Printf("\nStarting sync of %d repositories...\n", len(repoNames))
+
+ syncer := sync.New(cfg, flags.WorkDir)
+ successCount := 0
+
+ for i, repoName := range repoNames {
+ fmt.Printf("\n[%d/%d] Syncing %s...\n", i+1, len(repoNames), repoName)
+
+ if err := syncer.SyncRepository(repoName); err != nil {
+ fmt.Printf("ERROR: Failed to sync %s: %v\n", repoName, err)
+ fmt.Printf("Stopping sync due to error.\n")
+ return 1
+ }
+ successCount++
+ }
+
+ fmt.Printf("\n=== Summary ===\n")
+ fmt.Printf("Successfully synced: %d repositories\n", successCount)
+
+ return 0
+}
+
+// ShowFullSyncMessage displays the full sync mode message
+func ShowFullSyncMessage() {
+ fmt.Println("Full sync mode enabled:")
+ fmt.Println(" - Sync all public Codeberg repos to GitHub")
+ fmt.Println(" - Sync all public GitHub repos to Codeberg")
+ fmt.Println(" - Create missing GitHub repositories")
+ fmt.Println(" - Create missing Codeberg repositories (when implemented)")
+ fmt.Println()
+} \ No newline at end of file