feat: use errgroup

go.mod

@@ -8,6 +8,7 @@ require (
 	github.com/make-go-great/copy-go v0.9.0
 	github.com/make-go-great/diff-go v0.0.5
 	github.com/urfave/cli/v2 v2.24.4
+	golang.org/x/sync v0.1.0
 )
 
 require (

go.sum

@@ -24,6 +24,8 @@ github.com/urfave/cli/v2 v2.24.4 h1:0gyJJEBYtCV87zI/x2nZCPyDxD51K6xM8SkwjHFCNEU=
 github.com/urfave/cli/v2 v2.24.4/go.mod h1:GHupkWPMM0M/sj1a2b4wUrWBPzazNrIjouW6fmdJLxc=
 github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 h1:bAn7/zixMGCfxrRTfdpNzjtPYqr8smhKouy9mxVdGPU=
 github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673/go.mod h1:N3UwUGtsrSj3ccvlPHLoLsHnpR27oXr4ZE984MbSER8=
+golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
+golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200223170610-d5e6a3e2c0ae/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

internal/config/config_real.go

@@ -8,6 +8,8 @@ import (
 	"os"
 	"path/filepath"
 
+	"golang.org/x/sync/errgroup"
+
 	"github.com/make-go-great/copy-go"
 	"github.com/make-go-great/diff-go"
 )
@@ -23,45 +25,86 @@ var _ Config = (*ConfigReal)(nil)
 
 // Install internal -> external
 func (c *ConfigReal) Install() error {
+	eg := new(errgroup.Group)
+
 	for _, app := range c.Apps {
 		for _, p := range app.Paths {
 			if p.External == "" {
 				continue
 			}
 
+			p := Path{
+				Internal: p.Internal,
+				External: p.External,
+				URL:      p.URL,
+			}
+
+			eg.Go(func() error {
 				if err := copy.Replace(p.Internal, p.External); err != nil {
 					return fmt.Errorf("copy: failed to replace [%s] -> [%s]: %w", p.Internal, p.External, err)
 				}
+
+				return nil
+			})
 		}
 	}
 
+	if err := eg.Wait(); err != nil {
+		return err
+	}
+
 	return nil
 }
 
 // Update external -> internal
 func (c *ConfigReal) Update() error {
+	eg := new(errgroup.Group)
+
 	for _, app := range c.Apps {
 		for _, p := range app.Paths {
 			if p.External == "" {
 				continue
 			}
 
+			p := Path{
+				Internal: p.Internal,
+				External: p.External,
+				URL:      p.URL,
+			}
+
+			eg.Go(func() error {
 				if err := copy.Replace(p.External, p.Internal); err != nil {
 					return fmt.Errorf("copy: failed to replace [%s] -> [%s]: %w", p.External, p.Internal, err)
 				}
+
+				return nil
+			})
 		}
 	}
 
+	if err := eg.Wait(); err != nil {
+		return err
+	}
+
 	return nil
 }
 
 func (c *ConfigReal) Download() error {
+	eg := new(errgroup.Group)
+
 	for _, app := range c.Apps {
 		for _, p := range app.Paths {
 			if p.URL == "" {
 				continue
 			}
 
+			p := Path{
+				Internal: p.Internal,
+				External: p.External,
+				URL:      p.URL,
+			}
+
+			eg.Go(func() error {
 				httpRsp, err := c.httpClient.Get(p.URL)
 				if err != nil {
 					return fmt.Errorf("http client: failed to get: %w", err)
@@ -84,6 +127,10 @@ func (c *ConfigReal) Download() error {
 				}
 
 				httpRsp.Body.Close()
+
+				return nil
+			})
+
 		}
 	}
 
@@ -150,8 +197,18 @@ func (c *ConfigReal) Diff() error {
 }
 
 func (c *ConfigReal) Validate() error {
+	eg := new(errgroup.Group)
+
 	for _, app := range c.Apps {
 		for _, p := range app.Paths {
+			app := app
+			p := Path{
+				Internal: p.Internal,
+				External: p.External,
+				URL:      p.URL,
+			}
+
+			eg.Go(func() error {
 				if p.Internal == "" {
 					return fmt.Errorf("empty internal app [%s]: %w", app, ErrConfigInvalid)
 				}
@@ -159,8 +216,15 @@ func (c *ConfigReal) Validate() error {
 				if p.External == "" && p.URL == "" {
 					return fmt.Errorf("empty external and url app [%s]: %w", app, ErrConfigInvalid)
 				}
+
+				return nil
+			})
 		}
 	}
 
+	if err := eg.Wait(); err != nil {
+		return err
+	}
+
 	return nil
 }