Improved media flush feedback.
This commit is contained in:
parent
af493bad49
commit
39477e4561
|
@ -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);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue