diff --git a/src/media.js b/src/media.js index f4c02bad..9e5894b9 100755 --- a/src/media.js +++ b/src/media.js @@ -1028,7 +1028,9 @@ async function deleteS3Objects(allMedia) { return statuses; } -async function flushOrphanedMedia() { +async function flushOrphanedMedia(stage = 1) { + logger.info(`Flushing orphaned media, stage ${stage}`); + const orphanedMedia = await knex('media') .where('is_sfw', false) .whereNotExists( @@ -1062,6 +1064,8 @@ async function flushOrphanedMedia() { .returning(['media.id', 'media.is_s3', 'media.path', 'media.thumbnail', 'media.lazy']) .delete(); + logger.info(`Found ${orphanedMedia.length} orphaned media entries in stage ${stage}`); + await fs.writeFile(`log/deletedmedia_${format(new Date(), 'yyyy-MM-dd_hh:mm:ss')}.log`, JSON.stringify(orphanedMedia, null, 4)); if (argv.flushMediaFiles) { @@ -1088,7 +1092,7 @@ async function flushOrphanedMedia() { } if (orphanedMedia.length > 0 && orphanedMedia.length >= config.media.flushWindow) { - await flushOrphanedMedia(); + await flushOrphanedMedia(stage + 1); } }