feat: optimize error handling

- `reaper run` would continue on error
- update README.md

Author: LeslieLeung

README.md

@@ -99,3 +99,8 @@ For example compose file, see [docker-compose.yml](docker-compose.yml).
 ```bash
 docker compose up -d
 ```
+
+## Stargazers over time
+
+[![Stargazers over time](https://starchart.cc/LeslieLeung/reaper.svg)](https://starchart.cc/LeslieLeung/reaper)
+

README_zh.md

@@ -100,3 +100,7 @@ docker run --rm \
 docker compose up -d
 ```
 
+
+## Stargazers over time
+
+[![Stargazers over time](https://starchart.cc/LeslieLeung/reaper.svg)](https://starchart.cc/LeslieLeung/reaper)

cmd/rip/rip.go

@@ -48,5 +48,7 @@ func runRip(cmd *cobra.Command, args []string) {
 		ui.ErrorfExit("Storage %s not found in config", repo.Storage)
 	}
 
-	rip.Rip(repo, storages)
+	if err := rip.Rip(repo, storages); err != nil {
+		ui.ErrorfExit("Error running %s, %s", repo.Name, err)
+	}
 }

cmd/run/run.go

@@ -25,12 +25,16 @@ func runRun(cmd *cobra.Command, args []string) {
 		storages := make([]config.Storage, 0)
 		for _, storage := range repo.Storage {
 			if s, ok := storageMap[storage]; !ok {
-				ui.ErrorfExit("Storage %s not found in config", storage)
+				ui.Errorf("Storage %s not found in config", storage)
+				continue
 			} else {
 				storages = append(storages, s)
 			}
 		}
 		ui.Printf("Running %s", repo.Name)
-		rip.Rip(repo, storages)
+		if err := rip.Rip(repo, storages); err != nil {
+			ui.Errorf("Error running %s, %s", repo.Name, err)
+			// move on to next repo
+		}
 	}
 }

internal/rip/rip.go

@@ -14,18 +14,20 @@ import (
 	"time"
 )
 
-func Rip(repo config.Repository, storages []config.Storage) {
+func Rip(repo config.Repository, storages []config.Storage) error {
 	id := uuid.New().String()
 	// get current directory
 	currentDir, _ := os.Getwd()
 	// create a working directory
 	err := os.MkdirAll(path.Join(currentDir, ".reaper", id), 0774)
 	if err != nil {
-		ui.ErrorfExit("Error creating working directory, %s", err)
+		ui.Errorf("Error creating working directory, %s", err)
+		return err
 	}
 	err = os.Chmod(path.Join(currentDir, ".reaper", id), 0774)
 	if err != nil {
-		ui.ErrorfExit("Error changing permission of working directory, %s", err)
+		ui.Errorf("Error changing permission of working directory, %s", err)
+		return err
 	}
 
 	// clone the repo
@@ -35,36 +37,40 @@ func Rip(repo config.Repository, storages []config.Storage) {
 	})
 
 	if err != nil {
-		ui.ErrorfExit("Error cloning repository, %s", err)
+		ui.Errorf("Error cloning repository, %s", err)
+		return err
 	}
 
 	ui.Printf("Repository %s cloned", repo.Name)
 	files, err := archiver.FilesFromDisk(nil, map[string]string{
 		path.Join(currentDir, ".reaper", id): repo.Name,
-		// path.Join(currentDir, ".reaper", id): "repo.Name",
 		// TODO add file hash
 	})
 	if err != nil {
-		ui.ErrorfExit("Error reading files, %s", err)
+		ui.Errorf("Error reading files, %s", err)
+		return err
 	}
 
 	now := time.Now().Format("20060102150405")
 	base := repo.Name + "-" + now + ".tar.gz"
 	p := path.Join(currentDir, ".reaper", base)
 	out, err := os.Create(p)
 	if err != nil {
-		ui.ErrorfExit("Error creating archive, %s", err)
+		ui.Errorf("Error creating archive, %s", err)
+		return err
 	}
 	format := archiver.CompressedArchive{
 		Compression: archiver.Gz{},
 		Archival:    archiver.Tar{},
 	}
 	err = format.Archive(context.Background(), out, files)
 	if err != nil {
-		ui.ErrorfExit("Error creating archive, %s", err)
+		ui.Errorf("Error creating archive, %s", err)
+		return err
 	}
 	if err := out.Close(); err != nil {
-		ui.ErrorfExit("Error closing archive, %s", err)
+		ui.Errorf("Error closing archive, %s", err)
+		return err
 	}
 
 	// handle storages
@@ -74,7 +80,8 @@ func Rip(repo config.Repository, storages []config.Storage) {
 			fileBackend := storage.File{}
 			err := fileBackend.PutObjectFromPath(p, path.Join(s.Path, base))
 			if err != nil {
-				ui.ErrorfExit("Error storing file, %s", err)
+				ui.Errorf("Error storing file, %s", err)
+				return err
 			}
 			ui.Printf("File %s stored", path.Join(s.Path, base))
 		}
@@ -83,10 +90,13 @@ func Rip(repo config.Repository, storages []config.Storage) {
 	// cleanup
 	err = os.RemoveAll(path.Join(currentDir, ".reaper", id))
 	if err != nil {
-		ui.ErrorfExit("Error cleaning up working directory, %s", err)
+		ui.Errorf("Error cleaning up working directory, %s", err)
+		return err
 	}
 	err = os.Remove(p)
 	if err != nil {
-		ui.ErrorfExit("Error cleaning up archive, %s", err)
+		ui.Errorf("Error cleaning up archive, %s", err)
+		return err
 	}
+	return nil
 }