rogee/quyun
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: update

Browse Source
This commit is contained in:
yanghao05
2025-04-17 20:59:01 +08:00
parent 7ebbc01ae2
commit 2780d16edc
3 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/app/jobs/download_from_alioss.go
View File

@@ -9,6 +9,7 @@ import (
"quyun/app/models" "quyun/app/models"
"quyun/providers/ali" "quyun/providers/ali"
"quyun/providers/app"
"quyun/providers/job" "quyun/providers/job"
. "github.com/riverqueue/river" . "github.com/riverqueue/river"
@@ -42,6 +43,7 @@ type DownloadFromAliOSSWorker struct {
oss *ali.OSSClient oss *ali.OSSClient
job *job.Job job *job.Job
app *app.Config
} }
func (w *DownloadFromAliOSSWorker) NextRetry(job *Job[DownloadFromAliOSS]) time.Time { 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) 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 // check is path exist
st, err := os.Stat(dst) st, err := os.Stat(dst)

3
backend/app/jobs/download_from_alioss_test.go
View File

@@ -7,6 +7,7 @@ import (
"quyun/app/models" "quyun/app/models"
"quyun/app/service/testx" "quyun/app/service/testx"
"quyun/providers/ali" "quyun/providers/ali"
"quyun/providers/app"
"quyun/providers/job" "quyun/providers/job"
. "github.com/riverqueue/river" . "github.com/riverqueue/river"
@@ -23,6 +24,7 @@ type DownloadFromAliOSSSuiteInjectParams struct {
Initials []contracts.Initial `group:"initials"` // nolint:structcheck Initials []contracts.Initial `group:"initials"` // nolint:structcheck
Job *job.Job Job *job.Job
Oss *ali.OSSClient Oss *ali.OSSClient
App *app.Config
} }
type DownloadFromAliOSSSuite struct { type DownloadFromAliOSSSuite struct {
@@ -51,6 +53,7 @@ func (t *DownloadFromAliOSSSuite) Test_Work() {
worker := &DownloadFromAliOSSWorker{ worker := &DownloadFromAliOSSWorker{
oss: t.Oss, oss: t.Oss,
job: t.Job, job: t.Job,
app: t.App,
} }
err := worker.Work(context.Background(), job) err := worker.Work(context.Background(), job)

2
backend/app/jobs/extract_head_image_from_video.go
View File

@@ -6,6 +6,7 @@ import (
"quyun/app/models" "quyun/app/models"
"quyun/providers/ali" "quyun/providers/ali"
"quyun/providers/app"
"quyun/providers/job" "quyun/providers/job"
. "github.com/riverqueue/river" . "github.com/riverqueue/river"
@@ -38,6 +39,7 @@ type ExtractHeadImageFromVideoWorker struct {
oss *ali.OSSClient oss *ali.OSSClient
job *job.Job job *job.Job
app *app.Config
} }
func (w *ExtractHeadImageFromVideoWorker) NextRetry(job *Job[ExtractHeadImageFromVideo]) time.Time { func (w *ExtractHeadImageFromVideoWorker) NextRetry(job *Job[ExtractHeadImageFromVideo]) time.Time {