Add ability to schedule video publication

[github/Chocobozzz/PeerTube.git] / server / lib / cache / videos-preview-cache.ts

diff --git a/server/lib/cache/videos-preview-cache.ts b/server/lib/cache/videos-preview-cache.ts
index 0eb43efcc03dc10c7aab65a929b1e64bfa2f1734..d09d55e111704db11c16f490d40ece8819d630f9 100644 (file)
--- a/server/lib/cache/videos-preview-cache.ts
+++ b/server/lib/cache/videos-preview-cache.ts
@@ -1,7 +1,8 @@
 import * as asyncLRU from 'async-lru'
 import { createWriteStream } from 'fs'
 import { join } from 'path'
-import { logger, unlinkPromise } from '../../helpers'
+import { unlinkPromise } from '../../helpers/core-utils'
+import { logger } from '../../helpers/logger'
 import { CACHE, CONFIG } from '../../initializers'
 import { VideoModel } from '../../models/video/video'
 import { fetchRemoteVideoPreview } from '../activitypub'
@@ -52,21 +53,18 @@ class VideosPreviewCache {
 
     if (video.isOwned()) throw new Error('Cannot load preview of owned video.')
 
-    const res = await this.saveRemotePreviewAndReturnPath(video)
-
-    return res
+    return this.saveRemotePreviewAndReturnPath(video)
   }
 
   private saveRemotePreviewAndReturnPath (video: VideoModel) {
-    const req = fetchRemoteVideoPreview(video)
-
     return new Promise<string>((res, rej) => {
+      const req = fetchRemoteVideoPreview(video, rej)
       const path = join(CACHE.DIRECTORIES.PREVIEWS, video.getPreviewName())
       const stream = createWriteStream(path)
 
       req.pipe(stream)
-         .on('finish', () => res(path))
-         .on('error', (err) => rej(err))
+        .on('error', (err) => rej(err))
+        .on('finish', () => res(path))
     })
   }
 }