feat: Store Smart Wearables video preview (#675)

* feat: Add new column video in the item table

* feat: Add new endpoint to upload videos to distinguish max file sizes

* fix: Video is optional

migrations/1688635167925_add-video-to-items.ts

@@ -0,0 +1,10 @@
+import { MigrationBuilder } from 'node-pg-migrate'
+import { Item } from '../src/Item'
+
+const tableName = Item.tableName
+
+export const up = (pgm: MigrationBuilder) => {
+  pgm.addColumn(tableName, {
+    video: { type: 'TEXT', default: null, notNull: false },
+  })
+}

src/Item/Item.router.ts

@@ -1,5 +1,6 @@
 import { hashV1 } from '@dcl/hashing'
 import { server } from 'decentraland-server'
+import { env } from 'decentraland-commons'
 import { omit } from 'decentraland-commons/dist/utils'
 import { Router } from '../common/Router'
 import { HTTPError, STATUS_CODES } from '../common/HTTPError'
@@ -28,6 +29,7 @@ import {
   getPaginationParams,
 } from '../Pagination/utils'
 import { CurationStatus } from '../Curation'
+import { MulterFile } from '../S3/types'
 import { Item } from './Item.model'
 import { ItemAttributes } from './Item.types'
 import { areItemRepresentationsValid, upsertItemSchema } from './Item.schema'
@@ -48,6 +50,9 @@ import {
   URNAlreadyInUseError,
 } from './Item.errors'
 
+export const MAX_VIDEO_SIZE =
+  parseInt(env.get('AWS_MAX_VIDEO_SIZE', ''), 10) || 5e7 // 50MB
+
 export class ItemRouter extends Router {
   // To be removed once we move everything to the item service
   public collectionService = new CollectionService()
@@ -61,6 +66,11 @@ export class ItemRouter extends Router {
     return this.itemService.isOwnedOrManagedBy(id, ethAddress)
   }
 
+  private getFileStreamKey = async (file: MulterFile) => {
+    const hash = await hashV1(file.stream)
+    return new S3Content().getFileKey(hash)
+  }
+
   mount() {
     const withItemExists = withModelExists(Item, 'id')
     const withCollectionExist = withModelExists(Collection, 'id')
@@ -141,10 +151,22 @@ export class ItemRouter extends Router {
       withItemExists,
       withItemAuthorization,
       getUploader({
-        getFileStreamKey: async (file) => {
-          const hash = await hashV1(file.stream)
-          return new S3Content().getFileKey(hash)
-        },
+        getFileStreamKey: this.getFileStreamKey,
+      }).any(),
+      server.handleRequest(this.uploadItemFiles)
+    )
+
+    /**
+     * Upload the videos for an item
+     */
+    this.router.post(
+      '/items/:id/videos',
+      withAuthentication,
+      withItemExists,
+      withItemAuthorization,
+      getUploader({
+        maxFileSize: MAX_VIDEO_SIZE,
+        getFileStreamKey: this.getFileStreamKey,
       }).any(),
       server.handleRequest(this.uploadItemFiles)
     )

src/Item/Item.types.ts

@@ -22,6 +22,7 @@ export type ItemAttributes = {
   name: string
   description: string
   thumbnail: string
+  video?: string
   eth_address: string
   collection_id: string | null
   blockchain_item_id: string | null

src/S3/uploads.ts

@@ -68,7 +68,9 @@ class Storage implements multer.StorageEngine {
 
     const [key] = await Promise.all([
       this.getKey(file, req),
-      uploadFile(id, uploadStream, ACL.publicRead),
+      uploadFile(id, uploadStream, ACL.publicRead, {
+        ContentType: file.mimetype,
+      }),
     ])
 
     // move file to key