fix: parrallel map access

Author: Ragueel

pckg/uploadcontroller/controller.go

@@ -73,6 +73,10 @@ func (uploadController *UploadController) UploadFromConfig(ctx context.Context,
 					return func(ctx context.Context) (interface{}, error) {
 						trimmedFilePath := strings.TrimPrefix(path, conf.LocalRootPath)
 						uploadDestination := fmt.Sprintf("%s/%s", conf.UploadRootPath, trimmedFilePath)
+						// TODO: add better trim handling in case of name collisions
+						if conf.LocalRootPath == "." {
+							uploadDestination = fmt.Sprintf("%s/%s", conf.UploadRootPath, path)
+						}
 
 						return uploadController.uploadFile(ctx, path, uploadDestination)
 					}

pckg/uploader/ftp.go

@@ -8,11 +8,13 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"sync"
 
 	"github.com/jlaffaye/ftp"
 )
 
 type FtpUploader struct {
+	directoriesMutex      sync.RWMutex
 	PreCreatedDirectories map[string]bool
 	authConfig            config.AuthCredentials
 	connQueue             chan *ftp.ServerConn
@@ -21,6 +23,7 @@ type FtpUploader struct {
 
 func NewFtpUploader(ctx context.Context, authConfig config.AuthCredentials, connectionCount int) (*FtpUploader, error) {
 	uploader := FtpUploader{
+		directoriesMutex:      sync.RWMutex{},
 		allConnections:        make([]*ftp.ServerConn, 0),
 		connQueue:             make(chan *ftp.ServerConn, connectionCount),
 		PreCreatedDirectories: make(map[string]bool),
@@ -93,6 +96,9 @@ func (uploader *FtpUploader) createDirectoryIfNotExists(conn *ftp.ServerConn, up
 	directories := strings.Split(uploadFilePathDir, "/")
 
 	for i := range directories {
+		uploader.directoriesMutex.Lock()
+		defer uploader.directoriesMutex.Unlock()
+
 		remoteDir := filepath.Join(directories[:i+1]...)
 		if uploader.PreCreatedDirectories[remoteDir] {
 			continue