fix: use netappKey when downloading

Artonus · Feb 27, 2024 · e1d9c03 · e1d9c03
1 parent efbb407
commit e1d9c03
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/internal/data-service/s3.go b/internal/data-service/s3.go
@@ -46,11 +46,7 @@ func (s3Service *S3Service) Fetch(netAppKey, targetDir string) error {
 
 	for _, obj := range resp.Contents {
 		// Specify the local file path to save the object
-		pwd, pwdErr := os.Getwd()
-		if pwdErr != nil {
-			return pwdErr
-		}
-		localFilePath := filepath.Join(pwd, targetDir, *obj.Key)
+		localFilePath := filepath.Join(targetDir, netAppKey, *obj.Key)
 		errCreateDir := util.EnsurePathToFileExists(localFilePath)
 		if errCreateDir != nil {
 			return errCreateDir
@@ -90,7 +86,7 @@ func (s3Service *S3Service) Post(netAppKey, sourceDir string) error {
 	}
 
 	for _, file := range files {
-		filePath := filepath.Join(sourceDir, file.Name())
+		filePath := filepath.Join(sourceDir, netAppKey, file.Name())
 		fileData, openFileErr := os.Open(filePath)
 		if openFileErr != nil {
 			return openFileErr