feat: return Content-Type header with the mimeType of the file

content/package.json

@@ -41,6 +41,7 @@
     "bloom-filters": "^3.0.0",
     "dcl-catalyst-client": "^21.7.0",
     "eth-connect": "^6.2.4",
+    "file-type": "^15.0.1",
     "form-data": "^4.0.0",
     "fp-future": "^1.0.1",
     "joi": "^17.9.2",

content/src/controller/handlers/get-content-handler.ts

@@ -13,7 +13,7 @@ export async function getContentHandler(context: HandlerContextWithPath<'storage
 
   return {
     status: 200,
-    headers: createContentFileHeaders(content, hash),
+    headers: await createContentFileHeaders(content, hash),
     body: context.request.method.toUpperCase() === 'GET' ? await content.asRawStream() : undefined
   }
 }

content/src/controller/handlers/get-entity-image-handler.ts

@@ -26,7 +26,7 @@ export async function getEntityImageHandler(
 
   return {
     status: 200,
-    headers: createContentFileHeaders(content, hash),
+    headers: await createContentFileHeaders(content, hash),
     body: context.request.method.toUpperCase() === 'GET' ? await content.asRawStream() : undefined
   }
 }

content/src/controller/handlers/get-entity-thumbnail-handler.ts

@@ -29,7 +29,7 @@ export async function getEntityThumbnailHandler(
 
   return {
     status: 200,
-    headers: createContentFileHeaders(content, hash),
+    headers: await createContentFileHeaders(content, hash),
     body: context.request.method.toUpperCase() === 'GET' ? await content.asRawStream() : undefined
   }
 }

content/src/controller/utils.ts

@@ -1,5 +1,7 @@
 import { ContentItem } from '@dcl/catalyst-storage'
 import { InvalidRequestError, Pagination } from '../types'
+import { fromStream } from 'file-type'
+import { Readable } from 'stream'
 
 export function paginationObject(url: URL, maxPageSize: number = 1000): Pagination {
   const pageSize = url.searchParams.has('pageSize') ? parseInt(url.searchParams.get('pageSize')!, 10) : 100
@@ -37,9 +39,13 @@ export function asEnumValue<T extends { [key: number]: string }>(
   }
 }
 
-export function createContentFileHeaders(content: ContentItem, hashId: string): Record<string, string> {
+export async function createContentFileHeaders(content: ContentItem, hashId: string): Promise<Record<string, string>> {
+  const stream: Readable = await content.asRawStream()
+  const mime = await fromStream(stream)
+  const mimeType = mime?.mime || 'application/octet-stream'
+
   const headers: Record<string, string> = {
-    'Content-Type': 'application/octet-stream',
+    'Content-Type': mimeType,
     ETag: JSON.stringify(hashId), // by spec, the ETag must be a double-quoted string
     'Access-Control-Expose-Headers': 'ETag',
     'Cache-Control': 'public,max-age=31536000,s-maxage=31536000,immutable'

content/test/integration/controller/entity-metadata.spec.ts

@@ -90,7 +90,7 @@ describe('Integration - Get wearable image and thumbnail', () => {
 
       for (const response of responses) {
         expect(response.status).toEqual(200)
-        expect(response.headers.get('content-type')).toEqual('application/octet-stream')
+        expect(response.headers.get('content-type')).toEqual('image/png')
         expect(response.headers.get('ETag')).toBeTruthy()
         expect(response.headers.get('Cache-Control')).toBeTruthy()
       }
@@ -131,7 +131,7 @@ describe('Integration - Get wearable image and thumbnail', () => {
 
       for (const response of responses) {
         expect(response.status).toEqual(200)
-        expect(response.headers.get('content-type')).toEqual('application/octet-stream')
+        expect(response.headers.get('content-type')).toEqual('image/png')
         expect(response.headers.get('ETag')).toBeTruthy()
         expect(response.headers.get('Cache-Control')).toBeTruthy()
       }