[Chat] Fixed Image Placeholder Being Shown When Fetching Failed

change-beta/@azure-communication-react-455295c1-27e3-4baf-8d45-b69527a8a67b.json

@@ -0,0 +1,9 @@
+{
+  "type": "patch",
+  "area": "fix",
+  "workstream": "Inline Image",
+  "comment": "Fixed the issue where image placeholder being shown when fetching failed",
+  "packageName": "@azure/communication-react",
+  "email": "[email protected]",
+  "dependentChangeType": "patch"
+}

change/@azure-communication-react-455295c1-27e3-4baf-8d45-b69527a8a67b.json

@@ -0,0 +1,9 @@
+{
+  "type": "patch",
+  "area": "fix",
+  "workstream": "Inline Image",
+  "comment": "Fixed the issue where image placeholder being shown when fetching failed",
+  "packageName": "@azure/communication-react",
+  "email": "[email protected]",
+  "dependentChangeType": "patch"
+}

packages/chat-stateful-client/src/ResourceDownloadQueue.test.ts

@@ -35,6 +35,15 @@ describe('ResourceDownloadQueue api functions', () => {
 
 /* @conditional-compile-remove(teams-inline-images-and-file-sharing) */
 describe('ResourceDownloadQueue api functions', () => {
+  // URL.createObjectURL is not available in jest-dom
+  // so we need to mock it in tests
+  if (typeof URL.createObjectURL === 'undefined') {
+    Object.defineProperty(window.URL, 'createObjectURL', {
+      value: () => {
+        return 'http://mocked-url';
+      }
+    });
+  }
   test('should add a message to the queue and contains message', () => {
     const context = new ChatContext();
     const tokenCredential = stubCommunicationTokenCredential();

packages/chat-stateful-client/src/ResourceDownloadQueue.ts

@@ -58,19 +58,14 @@ export class ResourceDownloadQueue {
         continue;
       }
 
-      try {
-        if (options) {
-          const singleUrl = options.singleUrl;
-          message = await this.downloadSingleUrl(message, singleUrl, operation);
-        } else {
-          message = await this.downloadAllPreviewUrls(message, operation);
-        }
-        this._context.setChatMessage(threadId, message);
-      } catch (error) {
-        console.log('Downloading Resource error: ', error);
-      } finally {
-        this.isActive = false;
+      if (options) {
+        const singleUrl = options.singleUrl;
+        message = await this.downloadSingleUrl(message, singleUrl, operation);
+      } else {
+        message = await this.downloadAllPreviewUrls(message, operation);
       }
+      this._context.setChatMessage(threadId, message);
+      this.isActive = false;
     }
   }
 
@@ -79,7 +74,7 @@ export class ResourceDownloadQueue {
     resourceUrl: string,
     operation: ImageRequest
   ): Promise<ChatMessageWithStatus> {
-    const blobUrl = await operation(resourceUrl, this._credential);
+    const blobUrl = await this.downloadResource(operation, resourceUrl);
     message = { ...message, resourceCache: { ...message.resourceCache, [resourceUrl]: blobUrl } };
     return message;
   }
@@ -95,14 +90,24 @@ export class ResourceDownloadQueue {
       }
       for (const attachment of attachments) {
         if (attachment.previewUrl && attachment.attachmentType === 'image') {
-          const blobUrl = await operation(attachment.previewUrl, this._credential);
+          const blobUrl = await this.downloadResource(operation, attachment.previewUrl);
           message.resourceCache[attachment.previewUrl] = blobUrl;
         }
       }
     }
 
     return message;
   }
+
+  private async downloadResource(operation: ImageRequest, url: string): Promise<string> {
+    let blobUrl = URL.createObjectURL(new Blob());
+    try {
+      blobUrl = await operation(url, this._credential);
+    } catch (error) {
+      console.log('Downloading Resource error: ', error);
+    }
+    return blobUrl;
+  }
 }
 /* @conditional-compile-remove(teams-inline-images-and-file-sharing) */
 /**
@@ -141,11 +146,28 @@ export const fetchImageSource = async (src: string, credential: CommunicationTok
     const headers = new Headers();
     headers.append('Authorization', `Bearer ${token}`);
     try {
-      return await fetch(url, { headers });
+      return await fetchWithTimeout(url, { headers });
     } catch (err) {
       throw new ChatError('ChatThreadClient.getMessage', err as Error);
     }
   }
+  async function fetchWithTimeout(
+    resource: string | URL | Request,
+    options: { timeout?: number; headers?: Headers }
+  ): Promise<Response> {
+    // default timeout is 30 seconds
+    const { timeout = 30000 } = options;
+
+    const controller = new AbortController();
+    const id = setTimeout(() => controller.abort(), timeout);
+
+    const response = await fetch(resource, {
+      ...options,
+      signal: controller.signal
+    });
+    clearTimeout(id);
+    return response;
+  }
   const accessToken = await credential.getToken();
   const response = await fetchWithAuthentication(src, accessToken.token);
   const blob = await response.blob();