Use `throwOnTimeout` option for PQueue

Co-authored-by: Fedor Indutny <79877362+indutny-signal@users.noreply.github.com>

ts/ConversationController.ts

@@ -781,7 +781,11 @@ export class ConversationController {
           `ConversationController: Removing ${temporaryConversations.length} temporary conversations`
         );
       }
-      const queue = new PQueue({ concurrency: 3, timeout: 1000 * 60 * 2 });
+      const queue = new PQueue({
+        concurrency: 3,
+        timeout: 1000 * 60 * 2,
+        throwOnTimeout: true,
+      });
       queue.addAll(
         temporaryConversations.map(item => async () => {
           await removeConversation(item.id, {

ts/SignalProtocolStore.ts

@@ -516,7 +516,11 @@ export class SignalProtocolStore extends EventsMixin {
   }
 
   private _createSenderKeyQueue(): PQueue {
-    return new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+    return new PQueue({
+      concurrency: 1,
+      timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
+    });
   }
 
   private _getSenderKeyQueue(senderId: QualifiedAddress): PQueue {
@@ -663,7 +667,11 @@ export class SignalProtocolStore extends EventsMixin {
   }
 
   private _createSessionQueue(): PQueue {
-    return new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+    return new PQueue({
+      concurrency: 1,
+      timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
+    });
   }
 
   private _getSessionQueue(id: QualifiedAddress): PQueue {

ts/components/emoji/lib.ts

@@ -100,7 +100,11 @@ const makeImagePath = (src: string) => {
   return `${ROOT_PATH}node_modules/emoji-datasource-apple/img/apple/64/${src}`;
 };
 
-const imageQueue = new PQueue({ concurrency: 10, timeout: 1000 * 60 * 2 });
+const imageQueue = new PQueue({
+  concurrency: 10,
+  timeout: 1000 * 60 * 2,
+  throwOnTimeout: true,
+});
 const images = new Set();
 
 export const preloadImages = async (): Promise<void> => {

ts/routineProfileRefresh.ts

@@ -75,7 +75,11 @@ export async function routineProfileRefresh({
     }
   }
 
-  const refreshQueue = new PQueue({ concurrency: 5, timeout: 1000 * 60 * 2 });
+  const refreshQueue = new PQueue({
+    concurrency: 5,
+    timeout: 1000 * 60 * 2,
+    throwOnTimeout: true,
+  });
   for (const conversation of conversationsToRefresh) {
     refreshQueue.add(() => refreshConversation(conversation));
   }

ts/textsecure/MessageReceiver.ts

@@ -200,17 +200,27 @@ export default class MessageReceiver
     }
     this.serverTrustRoot = Bytes.fromBase64(serverTrustRoot);
 
-    this.incomingQueue = new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+    this.incomingQueue = new PQueue({
-    this.appQueue = new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+      concurrency: 1,
+      timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
+    });
+    this.appQueue = new PQueue({
+      concurrency: 1,
+      timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
+    });
 
     // All envelopes start in encryptedQueue and progress to decryptedQueue
     this.encryptedQueue = new PQueue({
       concurrency: 1,
       timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
     });
     this.decryptedQueue = new PQueue({
       concurrency: 1,
       timeout: 1000 * 60 * 2,
+      throwOnTimeout: true,
     });
 
     this.decryptAndCacheBatcher = createBatcher<CacheAddItemType>({

ts/textsecure/WebAPI.ts

@@ -2015,7 +2015,11 @@ export function initialize({
       });
 
       // Upload stickers
-      const queue = new PQueue({ concurrency: 3, timeout: 1000 * 60 * 2 });
+      const queue = new PQueue({
+        concurrency: 3,
+        timeout: 1000 * 60 * 2,
+        throwOnTimeout: true,
+      });
       await Promise.all(
         stickers.map(async (sticker: ServerAttachmentType, index: number) => {
           const stickerParams = makePutParams(

ts/util/batcher.ts

@@ -44,7 +44,11 @@ export function createBatcher<ItemType>(
   let batcher: BatcherType<ItemType>;
   let timeout: NodeJS.Timeout | null;
   let items: Array<ItemType> = [];
-  const queue = new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+  const queue = new PQueue({
+    concurrency: 1,
+    timeout: 1000 * 60 * 2,
+    throwOnTimeout: true,
+  });
 
   function _kickBatchOff() {
     if (timeout) {

ts/util/callingTones.ts

@@ -7,6 +7,7 @@ import { Sound } from './Sound';
 const ringtoneEventQueue = new PQueue({
   concurrency: 1,
   timeout: 1000 * 60 * 2,
+  throwOnTimeout: true,
 });
 
 class CallingTones {

ts/util/sendToGroup.ts

@@ -649,6 +649,7 @@ export async function _waitForAll<T>({
   const queue = new PQueue({
     concurrency: maxConcurrency,
     timeout: 2 * 60 * 1000,
+    throwOnTimeout: true,
   });
   return queue.addAll(tasks);
 }

ts/util/waitBatcher.ts

@@ -62,7 +62,11 @@ export function createWaitBatcher<ItemType>(
   let waitBatcher: BatcherType<ItemType>;
   let timeout: NodeJS.Timeout | null;
   let items: Array<ItemHolderType<ItemType>> = [];
-  const queue = new PQueue({ concurrency: 1, timeout: 1000 * 60 * 2 });
+  const queue = new PQueue({
+    concurrency: 1,
+    timeout: 1000 * 60 * 2,
+    throwOnTimeout: true,
+  });
 
   async function _kickBatchOff() {
     const itemsRef = items;