diff --git a/scripts/commands/database/clear.js b/scripts/commands/database/clear.js index 6ea623b488..757c050a3e 100644 --- a/scripts/commands/database/clear.js +++ b/scripts/commands/database/clear.js @@ -18,11 +18,14 @@ async function main() { const streams = await db.streams.all() let total = 0 + logger.info('searching...') for (const stream of streams) { if ( stream.status === 'error' && date.utc().diff(stream.updated_at, 'day') >= options.threshold ) { + logger.info(stream.url) + total += await db.streams.remove({ url: stream.url }, { multi: true }) } }