aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib
diff options
context:
space:
mode:
Diffstat (limited to 'server/lib')
-rw-r--r--server/lib/activitypub/inbox-manager.ts1
-rw-r--r--server/lib/avatar.ts2
-rw-r--r--server/lib/hls.ts2
-rw-r--r--server/lib/redis.ts2
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
67function pushAvatarProcessInQueue (task: DownloadImageQueueTask) { 67function 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 }