diff options
Diffstat (limited to 'server/lib')
-rw-r--r-- | server/lib/activitypub/inbox-manager.ts | 1 | ||||
-rw-r--r-- | server/lib/avatar.ts | 2 | ||||
-rw-r--r-- | server/lib/hls.ts | 2 | ||||
-rw-r--r-- | server/lib/redis.ts | 2 |
4 files changed, 4 insertions, 3 deletions
diff --git a/server/lib/activitypub/inbox-manager.ts b/server/lib/activitypub/inbox-manager.ts index 19e112f91..6d9bf7cf0 100644 --- a/server/lib/activitypub/inbox-manager.ts +++ b/server/lib/activitypub/inbox-manager.ts | |||
@@ -41,6 +41,7 @@ class InboxManager { | |||
41 | 41 | ||
42 | addInboxMessage (options: QueueParam) { | 42 | addInboxMessage (options: QueueParam) { |
43 | this.inboxQueue.push(options) | 43 | this.inboxQueue.push(options) |
44 | .catch(err => logger.error('Cannot add options in inbox queue.', { options, err })) | ||
44 | } | 45 | } |
45 | 46 | ||
46 | static get Instance () { | 47 | static get Instance () { |
diff --git a/server/lib/avatar.ts b/server/lib/avatar.ts index e79cd1546..86f1e7bdb 100644 --- a/server/lib/avatar.ts +++ b/server/lib/avatar.ts | |||
@@ -65,7 +65,7 @@ const downloadImageQueue = queue<DownloadImageQueueTask, Error>((task, cb) => { | |||
65 | }, QUEUE_CONCURRENCY.AVATAR_PROCESS_IMAGE) | 65 | }, QUEUE_CONCURRENCY.AVATAR_PROCESS_IMAGE) |
66 | 66 | ||
67 | function pushAvatarProcessInQueue (task: DownloadImageQueueTask) { | 67 | function pushAvatarProcessInQueue (task: DownloadImageQueueTask) { |
68 | return new Promise((res, rej) => { | 68 | return new Promise<void>((res, rej) => { |
69 | downloadImageQueue.push(task, err => { | 69 | downloadImageQueue.push(task, err => { |
70 | if (err) return rej(err) | 70 | if (err) return rej(err) |
71 | 71 | ||
diff --git a/server/lib/hls.ts b/server/lib/hls.ts index 9ea83f337..ef489097a 100644 --- a/server/lib/hls.ts +++ b/server/lib/hls.ts | |||
@@ -111,7 +111,7 @@ function downloadPlaylistSegments (playlistUrl: string, destinationDir: string, | |||
111 | 111 | ||
112 | logger.info('Importing HLS playlist %s', playlistUrl) | 112 | logger.info('Importing HLS playlist %s', playlistUrl) |
113 | 113 | ||
114 | return new Promise<string>(async (res, rej) => { | 114 | return new Promise<void>(async (res, rej) => { |
115 | const tmpDirectory = join(CONFIG.STORAGE.TMP_DIR, await generateRandomString(10)) | 115 | const tmpDirectory = join(CONFIG.STORAGE.TMP_DIR, await generateRandomString(10)) |
116 | 116 | ||
117 | await ensureDir(tmpDirectory) | 117 | await ensureDir(tmpDirectory) |
diff --git a/server/lib/redis.ts b/server/lib/redis.ts index 257cce141..62641e313 100644 --- a/server/lib/redis.ts +++ b/server/lib/redis.ts | |||
@@ -263,7 +263,7 @@ class Redis { | |||
263 | } | 263 | } |
264 | 264 | ||
265 | private addToSet (key: string, value: string) { | 265 | private addToSet (key: string, value: string) { |
266 | return new Promise<string[]>((res, rej) => { | 266 | return new Promise<void>((res, rej) => { |
267 | this.client.sadd(this.prefix + key, value, err => err ? rej(err) : res()) | 267 | this.client.sadd(this.prefix + key, value, err => err ? rej(err) : res()) |
268 | }) | 268 | }) |
269 | } | 269 | } |