refactor: rename stage struct

internal/fs.go

@@ -24,7 +24,7 @@
 ) {
 	defer wg.Done()
 
-	if err := CheckContextActivity(ctx); err != nil {
+	if err := CheckContext(ctx); err != nil {
 		errCh <- err
 		return
 	}
@@ -51,7 +51,7 @@
 	jobs := make(chan struct{}, 10)
 
 	err := filepath.Walk(from, func(path string, info os.FileInfo, err error) error {
-		if ctxErr := CheckContextActivity(ctx); ctxErr != nil {
+		if ctxErr := CheckContext(ctx); ctxErr != nil {
 			errCh <- ctxErr
 			return ctxErr
 		}
@@ -117,7 +117,7 @@
 ) {
 	defer wg.Done()
 
-	if err := CheckContextActivity(ctx); err != nil {
+	if err := CheckContext(ctx); err != nil {
 		errCh <- err
 		return
 	}
@@ -153,7 +153,7 @@
 		}
 	}(in)
 
-	if err := CheckContextActivity(ctx); err != nil {
+	if err := CheckContext(ctx); err != nil {
 		errCh <- err
 		return
 	}
@@ -185,7 +185,7 @@
 			}
 		}(out)
 
-		if err := CheckContextActivity(ctx); err != nil {
+		if err := CheckContext(ctx); err != nil {
 			errCh <- err
 			return
 		}
@@ -196,7 +196,7 @@
 			return
 		}
 
-		if err := CheckContextActivity(ctx); err != nil {
+		if err := CheckContext(ctx); err != nil {
 			errCh <- err
 			return
 		}

internal/helpers.go

@@ -2,6 +2,7 @@
 
 import (
 	"bytes"
+	"context"
 	"errors"
 	"fmt"
 	"log"
@@ -237,7 +238,7 @@
 
 	for _, item := range module.Stages {
 		wg.Add(1)
-		go func(wg *sync.WaitGroup, item Item) {
+		go func(wg *sync.WaitGroup, item Stage) {
 			defer wg.Done()
 			checkPaths(item, errCh)
 		}(&wg, item)
@@ -258,7 +259,16 @@
 	return nil
 }
 
-func checkPaths(item Item, ch chan<- error) {
+func CheckContext(ctx context.Context) error {
+	select {
+	case <-ctx.Done():
+		return fmt.Errorf("context canceled: %w", ctx.Err())
+	default:
+		return nil
+	}
+}
+
+func checkPaths(item Stage, ch chan<- error) {
 	for _, path := range item.From {
 		err := CheckPath(path)
 		if err != nil {

internal/module.go

@@ -14,7 +14,7 @@ const (
 	ReplaceIfNewer FileExistsAction = "replace_if_newer"
 )
 
-type Item struct {
+type Stage struct {
 	Name               string           `yaml:"name"`
 	To                 string           `yaml:"to"`
 	ActionIfFileExists FileExistsAction `yaml:"actionIfFileExists"`
@@ -29,7 +29,7 @@ type Module struct {
 	Repository     string   `yaml:"repository,omitempty"`
 	BuildDirectory string   `yaml:"buildDirectory,omitempty"`
 	LogDirectory   string   `yaml:"logDirectory,omitempty"`
-	Stages         []Item   `yaml:"stages"`
+	Stages         []Stage  `yaml:"stages"`
 	Ignore         []string `yaml:"ignore"`
 }
 

internal/module_builder.go

@@ -12,7 +12,7 @@
 )
 
 func (m *Module) Build() error {
-	if err := CheckContextActivity(m.Ctx); err != nil {
+	if err := CheckContext(m.Ctx); err != nil {
 		return err
 	}
 
@@ -154,7 +154,7 @@
 	errCh := make(chan error, len(m.Stages))
 
 	for _, item := range m.Stages {
-		if err := CheckContextActivity(m.Ctx); err != nil {
+		if err := CheckContext(m.Ctx); err != nil {
 			return err
 		}
 
@@ -193,12 +193,12 @@
 	wg *sync.WaitGroup,
 	errCh chan<- error,
 	ignore *[]string,
-	item Item,
+	item Stage,
 	buildDirectory string,
 ) {
 	defer wg.Done()
 
-	if err := CheckContextActivity(ctx); err != nil {
+	if err := CheckContext(ctx); err != nil {
 		errCh <- err
 		return
 	}
@@ -210,7 +210,7 @@
 	}
 
 	for _, from := range item.From {
-		if err := CheckContextActivity(ctx); err != nil {
+		if err := CheckContext(ctx); err != nil {
 			errCh <- err
 			return
 		}

internal/validators.go

@@ -1,7 +1,6 @@
 package internal
 
 import (
-	"context"
 	"errors"
 	"fmt"
 	"os"
@@ -39,12 +38,3 @@ func ValidateVersion(version string) error {
 
 	return fmt.Errorf("invalid module version %s", version)
 }
-
-func CheckContextActivity(ctx context.Context) error {
-	select {
-	case <-ctx.Done():
-		return fmt.Errorf("context canceled: %w", ctx.Err())
-	default:
-		return nil
-	}
-}