gogs
/
truckstop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

on job send, record job+sentTS+matrixID in db

master
bel 2022-01-17 20:10:10 -07:00
parent d4c1e20230
commit 6a2b2f38d0
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
main.go
View File

@ -339,9 +339,26 @@ func sendJob(job broker.Job) (bool, error) {
if len(payload) == 0 { if len(payload) == 0 {
return false, nil return false, nil
} }
if err := sender.Send(payload); err != nil { id, err := sender.SendTracked(payload)
if err != nil {
return false, err return false, err
} }
func() {
db := config.Get().DB()
b, err := json.Marshal(map[string]interface{}{
"Job": job,
"SentTS": time.Now().Unix(),
"MatrixID": id,
})
if err != nil {
logtr.Debugf("cannot marshal job+meta: %v", err)
return
}
if err := db.Set("sent_job_"+job.ID, b); err != nil {
logtr.Debugf("cannot db.set job+meta: %v", err)
return
}
}()
maps := config.Get().Maps maps := config.Get().Maps
pickup := fmt.Sprintf("%s,%s", url.QueryEscape(job.Pickup.City), job.Pickup.State) pickup := fmt.Sprintf("%s,%s", url.QueryEscape(job.Pickup.City), job.Pickup.State)
dropoff := fmt.Sprintf("%s,%s", url.QueryEscape(job.Dropoff.City), job.Dropoff.State) dropoff := fmt.Sprintf("%s,%s", url.QueryEscape(job.Dropoff.City), job.Dropoff.State)