Make attachments more resilient, decrease websocket keepalive

Co-authored-by: Scott Nonnenberg <scott@signal.org>

ts/messageModifiers/AttachmentDownloads.ts

@@ -333,30 +333,35 @@ async function _runJob(job?: AttachmentDownloadJobType): Promise<void> {
       Errors.toLogFormat(error)
     );
 
-    // Remove `pending` flag from the attachment.
-    await _addAttachmentToMessage(
-      message,
-      {
-        ...attachment,
-        downloadJobId: id,
-      },
-      { type, index }
-    );
-    if (message) {
-      await saveMessage(message.attributes, {
-        ourUuid: window.textsecure.storage.user.getCheckedUuid().toString(),
-      });
+    try {
+      // Remove `pending` flag from the attachment.
+      await _addAttachmentToMessage(
+        message,
+        {
+          ...attachment,
+          downloadJobId: id,
+        },
+        { type, index }
+      );
+      if (message) {
+        await saveMessage(message.attributes, {
+          ourUuid: window.textsecure.storage.user.getCheckedUuid().toString(),
+        });
+      }
+
+      const failedJob = {
+        ...job,
+        pending: 0,
+        attempts: currentAttempt,
+        timestamp:
+          Date.now() + (RETRY_BACKOFF[currentAttempt] || RETRY_BACKOFF[3]),
+      };
+
+      await saveAttachmentDownloadJob(failedJob);
+    } finally {
+      delete _activeAttachmentDownloadJobs[id];
+      _maybeStartJob();
     }
-
-    const failedJob = {
-      ...job,
-      pending: 0,
-      attempts: currentAttempt,
-      timestamp:
-        Date.now() + (RETRY_BACKOFF[currentAttempt] || RETRY_BACKOFF[3]),
-    };
-
-    await saveAttachmentDownloadJob(failedJob);
   }
 }
 

ts/services/profiles.ts

@@ -485,6 +485,9 @@ async function doGetProfile(c: ConversationModel): Promise<void> {
         );
         c.set({ profileKeyCredential, profileKeyCredentialExpiration });
       } else {
+        log.warn(
+          'getProfile: Included credential request, but got no credential. Clearing profileKeyCredential.'
+        );
         c.unset('profileKeyCredential');
       }
     }

ts/test-electron/WebsocketResources_test.ts

@@ -230,8 +230,8 @@ describe('WebSocket-Resource', () => {
         assert.strictEqual(message.request?.path, '/');
         assert.strictEqual(
           Date.now(),
-          startTime + 60000,
-          'keepalive time should be one minute'
+          startTime + 30000 + 5000,
+          'keepalive time should be 35s'
         );
         done();
       });

ts/textsecure/WebsocketResources.ts

@@ -386,8 +386,8 @@ export type KeepAliveOptionsType = {
   disconnect?: boolean;
 };
 
-const KEEPALIVE_INTERVAL_MS = 55000; // 55 seconds + 5 seconds for closing the
-// socket above.
+// 30 seconds + 5 seconds for closing the socket above.
+const KEEPALIVE_INTERVAL_MS = 30 * durations.SECOND;
 const MAX_KEEPALIVE_INTERVAL_MS = 5 * durations.MINUTE;
 
 class KeepAlive {