feat: Add a GET all assets by spaceId wth roles check

mirror-web-server/migrations/themirror/20231129171842-add-isEquipable-property-to-assets.js

@@ -3,6 +3,7 @@ const Piscina = require('piscina')
 const os = require('os')
 const { ObjectId } = require('mongodb')
 
+// @ts-ignore
 const piscina = new Piscina({
   filename: path.resolve(
     __dirname,

mirror-web-server/src/asset/asset.controller.ts

@@ -784,4 +784,16 @@ export class AssetController {
       purchaseOptionId
     )
   }
+
+  @Get('/space/:spaceId')
+  @FirebaseTokenAuthGuard()
+  public async getAllAssetsBySpaceIdWithRolesCheck(
+    @UserToken('user_id') userId: UserId,
+    @Param('spaceId') spaceId: string
+  ) {
+    return await this.assetService.getAllAssetsBySpaceIdWithRolesCheck(
+      spaceId,
+      userId
+    )
+  }
 }

mirror-web-server/src/asset/asset.service.ts

@@ -24,6 +24,7 @@ import {
 import { FileUploadService } from '../util/file-upload/file-upload.service'
 import {
   AssetId,
+  SpaceId,
   UserId,
   aggregationMatchId
 } from '../util/mongo-object-id-helpers'
@@ -1342,6 +1343,26 @@ export class AssetService {
     return await this._updateAssetTagsByType(assetId, tagType, tags)
   }
 
+  async getAllAssetsBySpaceIdWithRolesCheck(spaceId: SpaceId, userId: UserId) {
+    const pipeline = [
+      { $match: { space: new ObjectId(spaceId) } },
+      {
+        $lookup: {
+          from: 'assets',
+          localField: 'asset',
+          foreignField: '_id',
+          as: 'assetInfo'
+        }
+      },
+      { $unwind: '$assetInfo' },
+      {
+        $replaceRoot: { newRoot: '$assetInfo' }
+      },
+      ...this.roleService.getRoleCheckAggregationPipeline(userId, ROLE.OBSERVER)
+    ]
+    return await this.spaceObjectModel.aggregate(pipeline).exec()
+  }
+
   private async _updateAssetTagsByType(
     assetId: AssetId,
     tagType: TAG_TYPES,

mirror-web-server/src/block/block.service.ts

@@ -31,6 +31,8 @@ export class BlockService {
   }
 
   remove(id: string): Promise<BlockDocument> {
-    return this.blockModel.findOneAndDelete({ _id: id }).exec()
+    return this.blockModel
+      .findOneAndDelete({ _id: id })
+      .exec() as any as Promise<BlockDocument>
   }
 }

mirror-web-server/src/roles/models/role.enum.ts

@@ -14,7 +14,7 @@ export enum ROLE {
   // can create/read, but not update/delete
   CONTRIBUTOR = 400,
 
-  // the user is a provider 
+  // the user is a provider
   PROVIDER = 150,
 
   // Entity, e.g. a Space, can be entered/observed

mirror-web-server/src/space/space.service.ts

@@ -905,7 +905,7 @@ export class SpaceService implements IRoleConsumer {
           } else {
             throw new NotFoundException()
           }
-        })
+        }) as any as Promise<SpaceDocument>
     } else {
       this.logger.log(
         `canRemoveWithRolesCheck failed for user: ${userId}`,

mirror-web-server/src/tag/tag.service.ts

@@ -143,6 +143,8 @@ export class TagService {
   }
 
   remove(id: string): Promise<TagDocument> {
-    return this.tagModel.findOneAndDelete({ _id: id }).exec()
+    return this.tagModel
+      .findOneAndDelete({ _id: id })
+      .exec() as any as Promise<TagDocument>
   }
 }