diff options
| author | Chocobozzz <me@florianbigard.com> | 2021-07-30 16:51:27 +0200 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2021-08-02 10:39:51 +0200 |
| commit | d26836cd95e981d636006652927773c7943e77ce (patch) | |
| tree | 934a4a835bfddbf1c2c7da98d84ebd7623d60d49 /server/lib/job-queue | |
| parent | 2bee9db56ade2b3b1bb0efa8716840d87efdb93f (diff) | |
| download | PeerTube-d26836cd95e981d636006652927773c7943e77ce.tar.gz PeerTube-d26836cd95e981d636006652927773c7943e77ce.tar.zst PeerTube-d26836cd95e981d636006652927773c7943e77ce.zip | |
Refactor notifier
Diffstat (limited to 'server/lib/job-queue')
| -rw-r--r-- | server/lib/job-queue/handlers/video-import.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/job-queue/handlers/video-import.ts b/server/lib/job-queue/handlers/video-import.ts index 6e425d09c..5fd2039b1 100644 --- a/server/lib/job-queue/handlers/video-import.ts +++ b/server/lib/job-queue/handlers/video-import.ts | |||
| @@ -235,7 +235,7 @@ async function processFile (downloader: () => Promise<string>, videoImport: MVid | |||
| 235 | }) | 235 | }) |
| 236 | }) | 236 | }) |
| 237 | 237 | ||
| 238 | Notifier.Instance.notifyOnFinishedVideoImport(videoImportUpdated, true) | 238 | Notifier.Instance.notifyOnFinishedVideoImport({ videoImport: videoImportUpdated, success: true }) |
| 239 | 239 | ||
| 240 | if (video.isBlacklisted()) { | 240 | if (video.isBlacklisted()) { |
| 241 | const videoBlacklist = Object.assign(video.VideoBlacklist, { Video: video }) | 241 | const videoBlacklist = Object.assign(video.VideoBlacklist, { Video: video }) |
| @@ -263,7 +263,7 @@ async function processFile (downloader: () => Promise<string>, videoImport: MVid | |||
| 263 | } | 263 | } |
| 264 | await videoImport.save() | 264 | await videoImport.save() |
| 265 | 265 | ||
| 266 | Notifier.Instance.notifyOnFinishedVideoImport(videoImport, false) | 266 | Notifier.Instance.notifyOnFinishedVideoImport({ videoImport, success: false }) |
| 267 | 267 | ||
| 268 | throw err | 268 | throw err |
| 269 | } | 269 | } |