mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-21 04:53:14 -06:00
Code Issues Packages Projects Releases Wiki Activity

Delete relay json along with queue entry

Browse source
This commit is contained in:
Devon Hudson 2022-12-15 10:41:06 -07:00
parent ad53326ce8
commit ab57b30883
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
relayapi/storage/shared/storage.go
View file

@ -88,6 +88,7 @@ func (d *Database) CleanAsyncTransactions(
for i, receipt := range receipts { for i, receipt := range receipts {
nids[i] = receipt.GetNID() nids[i] = receipt.GetNID()
} }
err := d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { err := d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
err := d.RelayQueue.DeleteQueueEntries(ctx, txn, userID.Domain(), nids) err := d.RelayQueue.DeleteQueueEntries(ctx, txn, userID.Domain(), nids)
return err return err
@ -96,6 +97,14 @@ func (d *Database) CleanAsyncTransactions(
return fmt.Errorf("d.deleteQueueEntries: %w", err) return fmt.Errorf("d.deleteQueueEntries: %w", err)
} }
err = d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
err := d.RelayQueueJSON.DeleteQueueJSON(ctx, txn, nids)
return err
})
if err != nil {
return fmt.Errorf("d.deleteQueueJSON: %w", err)
}
return nil return nil
} }