mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2024-11-23 23:01:56 -06:00
Code Issues Packages Projects Releases Wiki Activity

Let us retry

Browse source
This commit is contained in:
Neil Alexander 2022-08-22 12:52:22 +01:00
parent db9ca401b0
commit cd81635cf4
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
roomserver/storage/shared/storage.go
View file

@ -1357,7 +1357,11 @@ func (d *Database) ForgetRoom(ctx context.Context, userID, roomID string, forget
func (d *Database) PurgeRoom(ctx context.Context, roomID string) error { func (d *Database) PurgeRoom(ctx context.Context, roomID string) error {
return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error { return d.Writer.Do(d.DB, nil, func(txn *sql.Tx) error {
roomNID, err := d.RoomsTable.SelectRoomNID(ctx, txn, roomID) roomNID, err := d.RoomsTable.SelectRoomNID(ctx, txn, roomID)
if err != nil { switch err {
case sql.ErrNoRows:
return nil // return nil anyway so we can generate output event for other components
case nil:
default:
return fmt.Errorf("failed to find room NID: %w", err) return fmt.Errorf("failed to find room NID: %w", err)
} }
if err := d.StateBlockTable.PurgeStateBlocks(ctx, txn, roomNID); err != nil { if err := d.StateBlockTable.PurgeStateBlocks(ctx, txn, roomNID); err != nil {