diff options
author | Chocobozzz <me@florianbigard.com> | 2021-05-26 09:44:16 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2021-05-26 09:44:16 +0200 |
commit | 53e7f82fe394eff220e1b76aa4d2b6018ed26267 (patch) | |
tree | 3537fa5e36753820c5aa13b4b154c875e33bc329 /server/models/redundancy | |
parent | ceb8f322118b24508abc6dd0bc6813a43610eff3 (diff) | |
download | PeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.tar.gz PeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.tar.zst PeerTube-53e7f82fe394eff220e1b76aa4d2b6018ed26267.zip |
Fix redundancy max size
Diffstat (limited to 'server/models/redundancy')
-rw-r--r-- | server/models/redundancy/video-redundancy.ts | 44 |
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 | ||