fix(worker): lint err

worker/internal/services/file.go

@@ -25,7 +25,7 @@ func GenStandardFile(filePath string, mimeType string) (GenStandardFileReturn, e
 	if err != nil {
 		return GenStandardFileReturn{}, err
 	}
-	defer file.Close()
+	defer file.Close() //nolint:errcheck
 
 	fileInfo, err := file.Stat()
 	if err != nil {
@@ -53,7 +53,7 @@ func GenStandardFile(filePath string, mimeType string) (GenStandardFileReturn, e
 	if err != nil {
 		return GenStandardFileReturn{}, err
 	}
-	models.SetRedisFileInfo(fileId, models.RedisFileInfo{
+	if err := models.SetRedisFileInfo(fileId, models.RedisFileInfo{
 		FileInfo: models.FileInfo{
 			FileSize: fileSize,
 			FileHash: fileHash,
@@ -62,7 +62,9 @@ func GenStandardFile(filePath string, mimeType string) (GenStandardFileReturn, e
 		FileType:  models.FileTypeUpload,
 		CreatedAt: time.Now().Unix(),
 		Expire:    expire,
-	})
+	}); err != nil {
+		return GenStandardFileReturn{}, err
+	}
 	return GenStandardFileReturn{
 		FileId: fileId,
 		FileInfo: models.FileInfo{

worker/internal/tasks/file.go

@@ -43,6 +43,8 @@ func RemoveFile(ctx context.Context, task *asynq.Task) error {
 	if err := rdb.Do(rctx, rdb.B().Hdel().Key("015:fileInfoMap").Field(payload.FileId).Build()).Error(); err != nil {
 		return err
 	}
-	os.RemoveAll(filePath)
+	if err := os.RemoveAll(filePath); err != nil {
+		return err
+	}
 	return nil
 }

worker/internal/tasks/image.go

@@ -38,11 +38,11 @@ func CompressImage(ctx context.Context, task *asynq.Task) error {
 	}
 	compressedFileInfo, err := services.GenStandardFile(compressedPath, originalFileInfo.MimeType)
 	if err != nil {
-		defer os.Remove(compressedPath)
+		defer os.Remove(compressedPath) //nolint:errcheck
 		return err
 	}
 
-	models.SetRedisTaskInfo(task.ResultWriter().TaskID(), map[string]any{
+	if err := models.SetRedisTaskInfo(task.ResultWriter().TaskID(), map[string]any{
 		"status": "success",
 		"result": []any{
 			map[string]any{
@@ -56,7 +56,9 @@ func CompressImage(ctx context.Context, task *asynq.Task) error {
 				},
 			},
 		},
-	})
+	}); err != nil {
+		return err
+	}
 
 	return nil
 }
@@ -84,16 +86,16 @@ func ConvertImage(ctx context.Context, task *asynq.Task) error {
 	}
 	mimeType := mime.TypeByExtension(fmt.Sprintf(".%s", payload.TargetExt))
 	if mimeType == "" {
-		defer os.Remove(convertedPath)
+		defer os.Remove(convertedPath) //nolint:errcheck
 		return ErrUnknown
 	}
 	convertedFileInfo, err := services.GenStandardFile(convertedPath, mimeType)
 	if err != nil {
-		defer os.Remove(convertedPath)
+		defer os.Remove(convertedPath) //nolint:errcheck
 		return err
 	}
 
-	models.SetRedisTaskInfo(task.ResultWriter().TaskID(), map[string]any{
+	if err := models.SetRedisTaskInfo(task.ResultWriter().TaskID(), map[string]any{
 		"status": "success",
 		"result": []any{
 			map[string]any{
@@ -107,7 +109,9 @@ func ConvertImage(ctx context.Context, task *asynq.Task) error {
 				},
 			},
 		},
-	})
+	}); err != nil {
+		return err
+	}
 
 	return nil
 }

worker/internal/tasks/share.go

@@ -42,10 +42,14 @@ func RemoveShare(ctx context.Context, task *asynq.Task) error {
 		if err := rdb.Do(ctx, rdb.B().Hdel().Key("015:fileInfoMap").Field(payload.FileId).Build()).Error(); err != nil {
 			return err
 		}
-		os.RemoveAll(filePath)
+		if err := os.RemoveAll(filePath); err != nil {
+			return err
+		}
 		return nil
 	}
-	models.SetRedisFileShareRelational(payload.FileId, shareIDs)
+	if err := models.SetRedisFileShareRelational(payload.FileId, shareIDs); err != nil {
+		return err
+	}
 	return nil
 }
 

worker/main.go

@@ -19,7 +19,7 @@ func main() {
 	} else {
 		logger, _ = zap.NewDevelopment()
 	}
-	defer logger.Sync()
+	defer logger.Sync() //nolint:errcheck
 	zap.ReplaceGlobals(logger)
 
 	srv := asynq.NewServer(