moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

db/events: delete FTS rows when deleting events

This commit is contained in:
Alex Gleason 2023-09-05 17:25:54 -05:00
parent a25d6c9755
commit a46381849f
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/db/events.ts
View File

@ -154,11 +154,18 @@ async function getFilters<K extends number>(
/** Delete events based on filters from the database. */ /** Delete events based on filters from the database. */
function deleteFilters<K extends number>(filters: DittoFilter<K>[]) { function deleteFilters<K extends number>(filters: DittoFilter<K>[]) {
if (!filters.length) return Promise.resolve([]); if (!filters.length) return Promise.resolve([]);
const query = getFiltersQuery(filters);
return db.deleteFrom('events') return db.transaction().execute(async (trx) => {
.where('id', 'in', () => query.clearSelect().select('id')) const query = getFiltersQuery(filters).clearSelect().select('id');
await trx.deleteFrom('events_fts')
.where('id', 'in', () => query)
.execute(); .execute();
return trx.deleteFrom('events')
.where('id', 'in', () => query)
.execute();
});
} }
/** Get number of events that would be returned by filters. */ /** Get number of events that would be returned by filters. */