diff --git a/packages/api/src/resolvers/article/index.ts b/packages/api/src/resolvers/article/index.ts index e258d2932..0fd905bf7 100644 --- a/packages/api/src/resolvers/article/index.ts +++ b/packages/api/src/resolvers/article/index.ts @@ -970,10 +970,10 @@ export const emptyTrashResolver = authorized< }) await batchDelete({ - state: LibraryItemState.Deleted, user: { id: uid, }, + state: LibraryItemState.Deleted, }) return { diff --git a/packages/api/src/services/library_item.ts b/packages/api/src/services/library_item.ts index 6d2626f90..4ed0136a6 100644 --- a/packages/api/src/services/library_item.ts +++ b/packages/api/src/services/library_item.ts @@ -1392,30 +1392,6 @@ export const batchDelete = async (criteria: FindOptionsWhere) => { return authTrx(async (t) => t.query(sql)) } -export const batchDeleteAllTrash = async () => { - const sql = ` - DO $$ - DECLARE - user_record RECORD; - user_cursor CURSOR FOR SELECT id FROM omnivore.user WHERE status = 'ACTIVE'; -- Adjust the condition as needed - BEGIN - OPEN user_cursor; - - LOOP - FETCH NEXT FROM user_cursor INTO user_record; - EXIT WHEN NOT FOUND; - - DELETE FROM omnivore.library_item WHERE user_id = user_record.id AND state = 'DELETED' AND deleted_at < '2023-01-01'; - - RETURN NEXT; - END LOOP; - - CLOSE user_cursor; - END $$;` - - return authTrx(async (t) => t.query(sql)) -} - export const findLibraryItemIdsByLabelId = async ( labelId: string, userId: string