aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/models/redundancy/video-redundancy.ts
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2021-05-26 09:44:16 +0200
committerChocobozzz <me@florianbigard.com>2021-05-26 09:44:16 +0200
commit53e7f82fe394eff220e1b76aa4d2b6018ed26267 (patch)
tree3537fa5e36753820c5aa13b4b154c875e33bc329 /server/models/redundancy/video-redundancy.ts
parentceb8f322118b24508abc6dd0bc6813a43610eff3 (diff)
downloadPeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.tar.gz
PeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.tar.zst
PeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.zip
Fix redundancy max size
Diffstat (limited to 'server/models/redundancy/video-redundancy.ts')
-rw-r--r--server/models/redundancy/video-redundancy.ts44
1 files changed, 0 insertions, 44 deletions
diff --git a/server/models/redundancy/video-redundancy.ts b/server/models/redundancy/video-redundancy.ts
index 53ebadeaf..a61c3578c 100644
--- a/server/models/redundancy/video-redundancy.ts
+++ b/server/models/redundancy/video-redundancy.ts
@@ -407,50 +407,6 @@ export class VideoRedundancyModel extends Model {
407 return VideoRedundancyModel.scope([ ScopeNames.WITH_VIDEO ]).findOne(query) 407 return VideoRedundancyModel.scope([ ScopeNames.WITH_VIDEO ]).findOne(query)
408 } 408 }
409 409
410 static async getTotalDuplicated (strategy: VideoRedundancyStrategy) {
411 const actor = await getServerActor()
412 const redundancyInclude = {
413 attributes: [],
414 model: VideoRedundancyModel,
415 required: true,
416 where: {
417 actorId: actor.id,
418 strategy
419 }
420 }
421
422 const queryFiles: FindOptions = {
423 include: [ redundancyInclude ]
424 }
425
426 const queryStreamingPlaylists: FindOptions = {
427 include: [
428 {
429 attributes: [],
430 model: VideoModel.unscoped(),
431 required: true,
432 include: [
433 {
434 required: true,
435 attributes: [],
436 model: VideoStreamingPlaylistModel.unscoped(),
437 include: [
438 redundancyInclude
439 ]
440 }
441 ]
442 }
443 ]
444 }
445
446 return Promise.all([
447 VideoFileModel.aggregate('size', 'SUM', queryFiles),
448 VideoFileModel.aggregate('size', 'SUM', queryStreamingPlaylists)
449 ]).then(([ r1, r2 ]) => {
450 return parseAggregateResult(r1) + parseAggregateResult(r2)
451 })
452 }
453
454 static async listLocalExpired () { 410 static async listLocalExpired () {
455 const actor = await getServerActor() 411 const actor = await getServerActor()
456 412