From d6929a5644374a8a73abeffbc098966e8ae5a329 Mon Sep 17 00:00:00 2001 From: Ted Unangst Date: Sat, 10 Aug 2019 19:15:49 -0400 Subject: [PATCH] handle two more db error conditions --- deliverator.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/deliverator.go b/deliverator.go index 014d9bd..6c6fbc6 100644 --- a/deliverator.go +++ b/deliverator.go @@ -128,7 +128,11 @@ func redeliverator() { for rows.Next() { var d Doover var dt string - rows.Scan(&d.ID, &dt) + err := rows.Scan(&d.ID, &dt) + if err != nil { + log.Printf("error scanning dooverid: %s", err) + continue + } d.When, _ = time.Parse(dbtimeformat, dt) doovers = append(doovers, d) } @@ -141,7 +145,11 @@ func redeliverator() { var username, rcpt string var msg []byte row := stmtLoadDoover.QueryRow(d.ID) - row.Scan(&goarounds, &username, &rcpt, &msg) + err := row.Scan(&goarounds, &username, &rcpt, &msg) + if err != nil { + log.Printf("error scanning doover: %s", err) + continue + } stmtZapDoover.Exec(d.ID) log.Printf("redeliverating %s try %d", rcpt, goarounds) deliverate(goarounds, username, rcpt, msg)