From 6a2b2f38d08b081e05395e48b7944e51dbd6ca35 Mon Sep 17 00:00:00 2001
From: bel <bel>
Date: Mon, 17 Jan 2022 20:10:10 -0700
Subject: [PATCH] on job send, record job+sentTS+matrixID in db

---
 main.go | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

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)