feat: add support for collabs room

src/rooms/rooms.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { RoomsController } from './rooms.controller';
+
+describe('RoomsController', () => {
+  let controller: RoomsController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [RoomsController],
+    }).compile();
+
+    controller = module.get<RoomsController>(RoomsController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

src/rooms/rooms.controller.ts

@@ -0,0 +1,49 @@
+import {
+  Body,
+  Controller,
+  Get,
+  Header,
+  Logger,
+  NotFoundException,
+  Param,
+  Put,
+  Res,
+} from '@nestjs/common';
+import { Response } from 'express';
+import { StorageNamespace, StorageService } from 'src/storage/storage.service';
+import { Readable } from 'stream';
+
+@Controller('rooms')
+export class RoomsController {
+  private readonly logger = new Logger(RoomsController.name);
+  namespace = StorageNamespace.ROOMS;
+
+  constructor(private storageService: StorageService) {}
+
+  @Get(':id')
+  @Header('content-type', 'application/octet-stream')
+  async findOne(@Param() params, @Res() res: Response): Promise<void> {
+    const data = await this.storageService.get(params.id, this.namespace);
+    this.logger.debug(`Get room ${params.id}`);
+
+    if (!data) {
+      throw new NotFoundException();
+    }
+
+    const stream = new Readable();
+    stream.push(data);
+    stream.push(null);
+    stream.pipe(res);
+  }
+
+  @Put(':id')
+  async create(@Param() params, @Body() payload: Buffer) {
+    const id = params.id;
+    await this.storageService.set(id, payload, this.namespace);
+    this.logger.debug(`Created scene ${id}`);
+
+    return {
+      id,
+    };
+  }
+}