From 8885fd37cce841fd08dda6d9367b35506f276735 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 25 Feb 2024 07:50:59 -0500 Subject: [PATCH] refactor: use job terminology for consistency --- api/s5/s5.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/api/s5/s5.go b/api/s5/s5.go index 24a4b10..f8146f1 100644 --- a/api/s5/s5.go +++ b/api/s5/s5.go @@ -805,12 +805,12 @@ func (s *S5API) accountPin(jc jape.Context) { jobName := fmt.Sprintf("pin-import-%s", cid64) - if task := s.cron.GetJobByName(jobName); task == nil { - task := s.cron.RetryableJob( + if job := s.cron.GetJobByName(jobName); job == nil { + job := s.cron.RetryableJob( cron.RetryableJobParams{ Name: jobName, Tags: nil, - Function: s.pinImportCronTask, + Function: s.pinImportCronJob, Args: []interface{}{cid64, next.Location().BytesURL(), next.Location().OutboardBytesURL(), userID}, Attempt: 0, Limit: 10, @@ -819,7 +819,7 @@ func (s *S5API) accountPin(jc jape.Context) { }, ) - _, err = s.cron.CreateJob(task) + _, err = s.cron.CreateJob(job) if err != nil { s.sendErrorResponse(jc, NewS5Error(ErrKeyInternalError, err)) return @@ -1472,7 +1472,7 @@ func (s *S5API) newFile(protocol *s5.S5Protocol, hash []byte) *S5File { }) } -func (s *S5API) pinImportCronTask(cid string, url string, proofUrl string, userId uint) error { +func (s *S5API) pinImportCronJob(cid string, url string, proofUrl string, userId uint) error { ctx := context.Background() // Parse CID early to avoid unnecessary operations if it fails.