feat: modify oss

backend/app/jobs/download_from_alioss.go

@@ -84,7 +84,7 @@ func (w *DownloadFromAliOSSWorker) Work(ctx context.Context, job *Job[DownloadFr
 	}
 
 	log.Infof("Starting download for file: %s", media.Path)
-	if err := w.oss.Download(ctx, media.Path, dst); err != nil {
+	if err := w.oss.Download(ctx, media.Path, dst, ali.WithInternal(true)); err != nil {
 		log.Errorf("Error downloading file: %v", err)
 		return err
 	}

backend/app/jobs/provider.gen.go

@@ -93,12 +93,10 @@ func Provide(opts ...opt.Option) error {
 		__job *job.Job,
 		app *app.Config,
 		job *job.Job,
-		oss *ali.OSSClient,
 	) (contracts.Initial, error) {
 		obj := &VideoCutWorker{
 			app: app,
 			job: job,
-			oss: oss,
 		}
 		if err := river.AddWorkerSafely(__job.Workers, obj); err != nil {
 			return nil, err

backend/app/jobs/video_cut.go

@@ -8,7 +8,6 @@ import (
 	"quyun/app/models"
 	"quyun/database/fields"
 	"quyun/pkg/utils"
-	"quyun/providers/ali"
 	"quyun/providers/app"
 	"quyun/providers/job"
 
@@ -40,7 +39,6 @@ var _ Worker[VideoCut] = (*VideoCutWorker)(nil)
 type VideoCutWorker struct {
 	WorkerDefaults[VideoCut]
 
-	oss *ali.OSSClient
 	job *job.Job
 	app *app.Config
 }

backend/app/jobs/video_extract_head_image.go

@@ -101,7 +101,7 @@ func (w *VideoExtractHeadImageWorker) Work(ctx context.Context, job *Job[VideoEx
 	}
 
 	// upload to oss
-	if err := w.oss.Upload(ctx, output, imageMedia.Path); err != nil {
+	if err := w.oss.Upload(ctx, output, imageMedia.Path, ali.WithInternal(true)); err != nil {
 		log.Errorf("Error uploading image to OSS: %v", err)
 		return JobCancel(err)
 	}

backend/app/jobs/video_store_short.go

@@ -101,7 +101,7 @@ func (w *VideoStoreShortWorker) Work(ctx context.Context, job *Job[VideoStoreSho
 	}
 
 	// upload to oss
-	if err := w.oss.Upload(ctx, job.Args.FilePath, filePath); err != nil {
+	if err := w.oss.Upload(ctx, job.Args.FilePath, filePath, ali.WithInternal(true)); err != nil {
 		log.Errorf("Error uploading file to OSS: %v", err)
 		return JobCancel(err)
 	}