remove references to deleted sessions in the timers table

ayoisaiah · Dec 1, 2023 · 2b6e443 · 2b6e443
1 parent ce0dac3
commit 2b6e443
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/store/store.go b/store/store.go
@@ -101,6 +101,23 @@ func (c *Client) DeleteSessions(startTimes []time.Time) error {
 			if err != nil {
 				return err
 			}
+
+			// Delete any associated timers
+			cur := tx.Bucket([]byte(timerBucket)).Cursor()
+			for k, v := cur.First(); k != nil; k, v = cur.Next() {
+				var t models.Timer
+				err := json.Unmarshal(v, &t)
+				if err != nil {
+					return err
+				}
+
+				if t.SessionKey.Equal(startTimes[i]) {
+					err = cur.Delete()
+					if err != nil {
+						return err
+					}
+				}
+			}
 		}
 
 		return nil