X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Ffiles-cache%2Fabstract-video-static-file-cache.ts;h=a7ac88525c80be00d6d7616e7607f8f195b914f6;hb=46f7cd6837311019acef6e2086c7b006e6dbe1b9;hp=84ed74c988d33fd41927e154ca05674bf35b5eb0;hpb=3acc50844047a37698f0618fa235c138e386a053;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/files-cache/abstract-video-static-file-cache.ts b/server/lib/files-cache/abstract-video-static-file-cache.ts index 84ed74c98..a7ac88525 100644 --- a/server/lib/files-cache/abstract-video-static-file-cache.ts +++ b/server/lib/files-cache/abstract-video-static-file-cache.ts @@ -1,10 +1,8 @@ -import { createWriteStream, remove } from 'fs-extra' +import { remove } from 'fs-extra' import { logger } from '../../helpers/logger' -import { VideoModel } from '../../models/video/video' -import { fetchRemoteVideoStaticFile } from '../activitypub' -import * as memoizee from 'memoizee' +import memoizee from 'memoizee' -type GetFilePathResult = { isOwned: boolean, path: string } | undefined +type GetFilePathResult = { isOwned: boolean, path: string, downloadName?: string } | undefined export abstract class AbstractVideoStaticFileCache { @@ -20,8 +18,8 @@ export abstract class AbstractVideoStaticFileCache { maxAge, max, promise: true, - dispose: (result: GetFilePathResult) => { - if (result.isOwned !== true) { + dispose: (result?: GetFilePathResult) => { + if (result && result.isOwned !== true) { remove(result.path) .then(() => logger.debug('%s removed from %s', result.path, this.constructor.name)) .catch(err => logger.error('Cannot remove %s from cache %s.', result.path, this.constructor.name, { err })) @@ -29,16 +27,4 @@ export abstract class AbstractVideoStaticFileCache { } }) } - - protected saveRemoteVideoFileAndReturnPath (video: VideoModel, remoteStaticPath: string, destPath: string) { - return new Promise((res, rej) => { - const req = fetchRemoteVideoStaticFile(video, remoteStaticPath, rej) - - const stream = createWriteStream(destPath) - - req.pipe(stream) - .on('error', (err) => rej(err)) - .on('finish', () => res(destPath)) - }) - } }