diff --git a/backend/app/jobs/download_from_alioss.go b/backend/app/jobs/download_from_alioss.go index fd96c69..a3d1b6d 100644 --- a/backend/app/jobs/download_from_alioss.go +++ b/backend/app/jobs/download_from_alioss.go @@ -9,6 +9,7 @@ import ( "quyun/app/models" "quyun/providers/ali" + "quyun/providers/app" "quyun/providers/job" . "github.com/riverqueue/river" @@ -42,6 +43,7 @@ type DownloadFromAliOSSWorker struct { oss *ali.OSSClient job *job.Job + app *app.Config } func (w *DownloadFromAliOSSWorker) NextRetry(job *Job[DownloadFromAliOSS]) time.Time { @@ -60,7 +62,7 @@ func (w *DownloadFromAliOSSWorker) Work(ctx context.Context, job *Job[DownloadFr return JobCancel(err) } - dst := filepath.Join("/Users/rogee/Projects/self/quyun/backend/fixtures/oss/", media.Path) + dst := filepath.Join(w.app.StoragePath, media.Path) // check is path exist st, err := os.Stat(dst) diff --git a/backend/app/jobs/download_from_alioss_test.go b/backend/app/jobs/download_from_alioss_test.go index 123c578..6e7bd7c 100644 --- a/backend/app/jobs/download_from_alioss_test.go +++ b/backend/app/jobs/download_from_alioss_test.go @@ -7,6 +7,7 @@ import ( "quyun/app/models" "quyun/app/service/testx" "quyun/providers/ali" + "quyun/providers/app" "quyun/providers/job" . "github.com/riverqueue/river" @@ -23,6 +24,7 @@ type DownloadFromAliOSSSuiteInjectParams struct { Initials []contracts.Initial `group:"initials"` // nolint:structcheck Job *job.Job Oss *ali.OSSClient + App *app.Config } type DownloadFromAliOSSSuite struct { @@ -51,6 +53,7 @@ func (t *DownloadFromAliOSSSuite) Test_Work() { worker := &DownloadFromAliOSSWorker{ oss: t.Oss, job: t.Job, + app: t.App, } err := worker.Work(context.Background(), job) diff --git a/backend/app/jobs/extract_head_image_from_video.go b/backend/app/jobs/extract_head_image_from_video.go index a82455c..dfdbf80 100644 --- a/backend/app/jobs/extract_head_image_from_video.go +++ b/backend/app/jobs/extract_head_image_from_video.go @@ -6,6 +6,7 @@ import ( "quyun/app/models" "quyun/providers/ali" + "quyun/providers/app" "quyun/providers/job" . "github.com/riverqueue/river" @@ -38,6 +39,7 @@ type ExtractHeadImageFromVideoWorker struct { oss *ali.OSSClient job *job.Job + app *app.Config } func (w *ExtractHeadImageFromVideoWorker) NextRetry(job *Job[ExtractHeadImageFromVideo]) time.Time {