.gitignore

@@ -1,3 +0,0 @@
-settings.json
-OBM
-logs

Makefile

@@ -1,2 +0,0 @@
-all:
-	cd src && go build && mv OBM ..

OBM.go

@@ -7,68 +7,12 @@ import (
 	"sync"
 	"time"
 
-	"unbewohnte/OBM/logger"
-	"unbewohnte/OBM/manager"
-	"unbewohnte/OBM/settings"
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/logger"
+	"github.com/Unbewohnte/OBM/manager"
+	"github.com/Unbewohnte/OBM/settings"
+	"github.com/Unbewohnte/OBM/util"
 )
 
-const orderMessage string = "Order: Replace -> Retrieve -> Remove\n"
-
-var (
-	cmdlnBeatmap = flag.String("beatmap", "", `Specifies a certain beatmap.
-	 If set to non "" - the program will search for given name and perform the magic
-	 provided in settings if successful`)
-	showOrder = flag.Bool("showOrder", false, "Prints an order in which functions are performed on a beatmap")
-)
-
-// a basic implementation of a concurrent worker
-func worker(jobs <-chan job, results chan result, WG *sync.WaitGroup) {
-	defer WG.Done()
-	for job := range jobs {
-		var successful, failed uint = 0, 0
-
-		// the order is: Replace->Retrieve->Remove (if all 3 options are enabled)
-		if job.replacementImagePath != "" {
-			s, f := job.beatmap.ReplaceBackgrounds(job.replacementImagePath)
-			successful += s
-			failed += f
-		}
-		if job.retrievementPath != "" {
-			s, f := job.beatmap.RetrieveBackgrounds(job.retrievementPath)
-			successful += s
-			failed += f
-		}
-		if job.remove == true {
-			s, f := job.beatmap.RemoveBackgrounds()
-			successful += s
-			failed += f
-		}
-
-		results <- result{
-			beatmapName:   job.beatmap.Name,
-			numberOfDiffs: uint(len(job.beatmap.Diffs)),
-			successful:    successful,
-			failed:        failed,
-		}
-	}
-
-}
-
-// the `starter` that `glues` workers and jobs together
-func workerPool(jobs chan job, results chan result, numOfWorkers int, WG *sync.WaitGroup) {
-	// check if there are less jobs than workers
-	if numOfWorkers > len(jobs) {
-		numOfWorkers = len(jobs)
-	}
-
-	// replacing backgrounds for each beatmap concurrently
-	for i := 0; i < numOfWorkers; i++ {
-		WG.Add(1)
-		go worker(jobs, results, WG)
-	}
-}
-
 type result struct {
 	beatmapName   string
 	numberOfDiffs uint

flags.go

@@ -0,0 +1,16 @@
+package main
+
+import (
+	"flag"
+)
+
+var (
+	orderMessage string = "Order: Replace -> Retrieve -> Remove\n"
+)
+
+var (
+	cmdlnBeatmap = flag.String("beatmap", "", `Specifies a certain beatmap.
+	 If set to non "" - the program will search for given name and perform the magic
+	 provided in settings if successful`)
+	showOrder = flag.Bool("showOrder", false, "Prints an order in which functions are performed on a beatmap")
+)

go.mod

@@ -0,0 +1,3 @@
+module github.com/Unbewohnte/OBM
+
+go 1.16

manager/beatmap.go

@@ -1,11 +1,12 @@
 package manager
 
 import (
+	"errors"
 	"fmt"
 	"os"
 	"path/filepath"
 
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/util"
 )
 
 // the main beatmap struct, contains necessary data for functions
@@ -21,10 +22,10 @@ func getSongsDir(baseOsuDir string) (string, error) {
 
 	stat, err := os.Stat(songsDir)
 	if err != nil {
-		return "", fmt.Errorf("could not process the given path : %s", err)
+		return "", errors.New(fmt.Sprintf("Could not process the given path : %s", err))
 	}
 	if !stat.IsDir() {
-		return "", fmt.Errorf("given Osu! directory is not a directory")
+		return "", errors.New("Given Osu! directory is not a directory !")
 	}
 
 	return songsDir, nil
@@ -34,7 +35,7 @@ func getSongsDir(baseOsuDir string) (string, error) {
 func getDiffs(path string) ([]string, error) {
 	files, err := os.ReadDir(path)
 	if err != nil {
-		return nil, fmt.Errorf("could not read a directory : %s", err)
+		return nil, errors.New(fmt.Sprintf("Could not read a directory : %s", err))
 	}
 
 	var diffs []string
@@ -64,7 +65,7 @@ func GetBeatmaps(baseOsuDir string) ([]Beatmap, error) {
 	}
 	contents, err := os.ReadDir(songsDir)
 	if err != nil {
-		return nil, fmt.Errorf("could not read a directory : %s", err)
+		return nil, errors.New(fmt.Sprintf("Could not read a directory : %s", err))
 	}
 
 	var beatmaps []Beatmap

manager/parse.go

@@ -1,12 +1,12 @@
 package manager
 
 import (
-	"fmt"
+	"errors"
 	"os"
 	"path/filepath"
 	"strings"
 
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/util"
 )
 
 // parses given .osu file and returns the filename of its background
@@ -24,13 +24,13 @@ func (BEATMAP *Beatmap) GetBackgroundName(diff string) (string, error) {
 	// get index of "[Events]" (this is where BG filename is stored)
 	eventsIndex := strings.Index(beatmapContents, "[Events]")
 	if eventsIndex == -1 {
-		return "", fmt.Errorf("could not retrieve index of \"[Events]\"")
+		return "", errors.New("Could not retrieve index of \"[Events]\"")
 	}
 	// get index of [TimingPoints] (this tag is right after the previous "[Events]" tag,
 	// so we can grab the whole "[Events]" tag contents)
 	timingPointsIndex := strings.Index(beatmapContents, "[TimingPoints]")
 	if timingPointsIndex == -1 {
-		return "", fmt.Errorf("could not retrieve index of \"[TimingPoints]\"")
+		return "", errors.New("Could not retrieve index of \"[TimingPoints]\"")
 	}
 	contentBetween := strings.Split(beatmapContents[eventsIndex:timingPointsIndex], ",")
 

manager/remove.go

@@ -5,7 +5,7 @@ import (
 	"os"
 	"path/filepath"
 
-	"unbewohnte/OBM/logger"
+	"github.com/Unbewohnte/OBM/logger"
 )
 
 // parses each difficulty for background info, removes found backgrounds

manager/replace.go

@@ -5,8 +5,8 @@ import (
 	"os"
 	"path/filepath"
 
-	"unbewohnte/OBM/logger"
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/logger"
+	"github.com/Unbewohnte/OBM/util"
 )
 
 // parses each beatmap`s .osu file for background info;

manager/retrieve.go

@@ -5,8 +5,8 @@ import (
 	"os"
 	"path/filepath"
 
-	"unbewohnte/OBM/logger"
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/logger"
+	"github.com/Unbewohnte/OBM/util"
 )
 
 // retrieves backgrounds from given beatmap folder (same as in `ReplaceBackgrounds`) and copies them to the retrievement path

settings/settings.go

@@ -2,11 +2,12 @@ package settings
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"os"
 
-	"unbewohnte/OBM/logger"
-	"unbewohnte/OBM/util"
+	"github.com/Unbewohnte/OBM/logger"
+	"github.com/Unbewohnte/OBM/util"
 )
 
 const (
@@ -17,7 +18,7 @@ const (
 func DoesExist() (bool, error) {
 	files, err := os.ReadDir(".")
 	if err != nil {
-		return false, fmt.Errorf("wasn`t able to read current directory %s", err)
+		return false, errors.New(fmt.Sprintf("Unable to read current directory %s", err))
 	}
 
 	for _, file := range files {
@@ -41,9 +42,8 @@ func Create() error {
 
 	file, err := os.Create(settingsFilename)
 	if err != nil {
-		return fmt.Errorf("could not create settings file : %s", err)
+		return errors.New(fmt.Sprintf("Unable to create settings file : %s", err))
 	}
-	defer file.Close()
 
 	// marshaling default settings
 	settingsJson, err := json.MarshalIndent(Settings{
@@ -67,10 +67,11 @@ func Create() error {
 		Workers: 100,
 	}, "", " ")
 	if err != nil {
-		return fmt.Errorf("could not marshal settings into file : %s", err)
+		return errors.New(fmt.Sprintf("Could not marshal settings into file : %s", err))
 	}
 
 	file.Write(settingsJson)
+	file.Close()
 
 	return nil
 }
@@ -89,7 +90,7 @@ func Get() Settings {
 	}
 
 	// if all features are disabled
-	if !settings.BackgroundReplacement.Enabled && !settings.BackgroundRetrievement.Enabled && !settings.BackgroundRemovement.Enabled {
+	if !settings.BackgroundReplacement.Enabled && !settings.BackgroundRetrievement.Enabled {
 		logger.LogInfo("No features enabled. Exiting...")
 		os.Exit(0)
 	}

src/go.mod

@@ -1,3 +0,0 @@
-module unbewohnte/OBM
-
-go 1.16

worker.go

@@ -0,0 +1,52 @@
+package main
+
+import (
+	"sync"
+)
+
+// a basic implementation of a concurrent worker
+func worker(jobs <-chan job, results chan result, WG *sync.WaitGroup) {
+	defer WG.Done()
+	for job := range jobs {
+		var successful, failed uint = 0, 0
+
+		// the order is: Replace->Retrieve->Remove (if all 3 options are enabled)
+		if job.replacementImagePath != "" {
+			s, f := job.beatmap.ReplaceBackgrounds(job.replacementImagePath)
+			successful += s
+			failed += f
+		}
+		if job.retrievementPath != "" {
+			s, f := job.beatmap.RetrieveBackgrounds(job.retrievementPath)
+			successful += s
+			failed += f
+		}
+		if job.remove == true {
+			s, f := job.beatmap.RemoveBackgrounds()
+			successful += s
+			failed += f
+		}
+
+		results <- result{
+			beatmapName:   job.beatmap.Name,
+			numberOfDiffs: uint(len(job.beatmap.Diffs)),
+			successful:    successful,
+			failed:        failed,
+		}
+	}
+
+}
+
+// the `starter` that `glues` workers and jobs together
+func workerPool(jobs chan job, results chan result, numOfWorkers int, WG *sync.WaitGroup) {
+	// check if there are less jobs than workers
+	if numOfWorkers > len(jobs) {
+		numOfWorkers = len(jobs)
+	}
+
+	// replacing backgrounds for each beatmap concurrently
+	for i := 0; i < numOfWorkers; i++ {
+		WG.Add(1)
+		go worker(jobs, results, WG)
+	}
+}