diff --git a/main.go b/main.go index 3f36cf7..72e1141 100644 --- a/main.go +++ b/main.go @@ -339,9 +339,26 @@ func sendJob(job broker.Job) (bool, error) { if len(payload) == 0 { return false, nil } - if err := sender.Send(payload); err != nil { + id, err := sender.SendTracked(payload) + if err != nil { 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 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)