From 279873337707c9a302a988fa653d7f4f36701de1 Mon Sep 17 00:00:00 2001 From: David Robertson Date: Wed, 10 May 2023 11:22:46 +0100 Subject: [PATCH] Ensure future message deletes clear ack pos --- state/to_device_table.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/state/to_device_table.go b/state/to_device_table.go index 0000595..8035dd7 100644 --- a/state/to_device_table.go +++ b/state/to_device_table.go @@ -81,7 +81,12 @@ func (t *ToDeviceTable) DeleteMessagesUpToAndIncluding(userID, deviceID string, } func (t *ToDeviceTable) DeleteAllMessagesForDevice(userID, deviceID string) error { + // TODO: should these deletes take place in a transaction? _, err := t.db.Exec(`DELETE FROM syncv3_to_device_messages WHERE user_id = $1 AND device_id = $2`, userID, deviceID) + if err != nil { + return err + } + _, err = t.db.Exec(`DELETE FROM syncv3_to_device_ack_pos WHERE user_id = $1 AND device_id = $2`, userID, deviceID) return err }