refactor/Websocket 서버 구조 변경

Author: fru1tworld

packages/collaborative/src/app.module.ts

@@ -6,8 +6,6 @@ import { TypeOrmModule } from '@nestjs/typeorm';
 import { CollaborativeModule } from './collaborative/collaborative.module';
 import { getMongooseConfig } from './common/config/mongo.config';
 import { getTypeOrmConfig } from './common/config/typeorm.config';
-import { NoteModule } from './note/note.module';
-import { SpaceModule } from './space/space.module';
 import { YjsModule } from './yjs/yjs.module';
 import { RedisService } from './redis/redis.service';
 import { RedisModule } from './redis/redis.module';
@@ -28,9 +26,7 @@ import { ScheduleModule } from '@nestjs/schedule';
       inject: [ConfigService],
       useFactory: getTypeOrmConfig,
     }),
-    SpaceModule,
     YjsModule,
-    NoteModule,
     CollaborativeModule,
     RedisModule,
     ResourceMatricsModule,

packages/collaborative/src/collaborative/collaborative.module.ts

@@ -1,12 +1,18 @@
 import { Module } from '@nestjs/common';
+import { MongooseModule } from '@nestjs/mongoose';
 
-import { NoteModule } from '../note/note.module';
-import { SpaceModule } from '../space/space.module';
-import { CollaborativeService } from './collaborative.service';
-
+import { CollaborativeSpaceService } from './collaborative.space.service';
+import { CollaborativeNoteService } from './collaborative.note.service';
+import { NoteDocument, NoteSchema } from './schema/note.schema';
+import { SpaceDocument, SpaceSchema } from './schema/space.schema';
 @Module({
-  imports: [NoteModule, SpaceModule],
-  providers: [CollaborativeService],
-  exports: [CollaborativeService],
+  imports: [
+    MongooseModule.forFeature([
+      { name: NoteDocument.name, schema: NoteSchema },
+      { name: SpaceDocument.name, schema: SpaceSchema },
+    ]),
+  ],
+  providers: [CollaborativeSpaceService,CollaborativeNoteService],
+  exports: [CollaborativeSpaceService, CollaborativeNoteService]
 })
 export class CollaborativeModule {}

…s/collaborative/src/note/note.service.ts …laborative/collaborative.note.service.tspackages/collaborative/src/note/note.service.ts renamed to packages/collaborative/src/collaborative/collaborative.note.service.ts packages/collaborative/src/note/note.service.ts renamed to packages/collaborative/src/collaborative/collaborative.note.service.ts

@@ -3,11 +3,11 @@ import { InjectModel } from '@nestjs/mongoose';
 import { Model } from 'mongoose';
 
 import { ERROR_MESSAGES } from '../common/constants/error.message.constants';
-import { NoteDocument } from './note.schema';
+import { NoteDocument } from './schema/note.schema';
 
 @Injectable()
-export class NoteService {
-  private readonly logger = new Logger(NoteService.name);
+export class CollaborativeNoteService {
+  private readonly logger = new Logger(CollaborativeNoteService.name);
 
   constructor(
     @InjectModel(NoteDocument.name)
@@ -63,4 +63,58 @@ export class NoteService {
       throw new BadRequestException(ERROR_MESSAGES.NOTE.UPDATE_FAILED);
     }
   }
+
+  async updateByNote(id: string, note: string) {
+    try {
+      this.logger.log('노트 내용 업데이트 시작', {
+        method: 'updateByNote',
+        noteId: id,
+        length: note.length,
+      });
+
+      const updatedNote = await this.updateContent(id, note);
+
+      this.logger.log('노트 내용 업데이트 완료', {
+        method: 'updateByNote',
+        noteId: id,
+      });
+
+      return updatedNote;
+    } catch (error) {
+      this.logger.error('노트 내용 업데이트 실패', {
+        method: 'updateByNote',
+        noteId: id,
+        error: error.message,
+        stack: error.stack,
+      });
+      throw new BadRequestException(ERROR_MESSAGES.NOTE.UPDATE_FAILED);
+    }
+  }
+
+  async findByNote(id: string) {
+    try {
+      this.logger.log('노트 조회 시작', {
+        method: 'findByNote',
+        noteId: id,
+      });
+
+      const note = await this.findById(id);
+
+      this.logger.log('노트 조회 완료', {
+        method: 'findByNote',
+        noteId: id,
+        found: !!note,
+      });
+
+      return note;
+    } catch (error) {
+      this.logger.error('노트 조회 실패', {
+        method: 'findByNote',
+        noteId: id,
+        error: error.message,
+        stack: error.stack,
+      });
+      throw error;
+    }
+  }
 }

packages/collaborative/src/collaborative/collaborative.service.ts

@@ -0,0 +1,94 @@
+import { BadRequestException, Injectable, Logger } from '@nestjs/common';
+import { InjectModel } from '@nestjs/mongoose';
+import { Model } from 'mongoose';
+
+import { SpaceDocument } from './schema/space.schema';
+import { ERROR_MESSAGES } from 'src/common/constants/error.message.constants';
+
+@Injectable()
+export class CollaborativeSpaceService {
+  private readonly logger = new Logger(CollaborativeSpaceService.name);
+
+  constructor(
+    @InjectModel(SpaceDocument.name)
+    private readonly spaceModel: Model<SpaceDocument>,
+  ) {}
+
+  async updateBySpace(id: string, space: string) {
+    try {
+      this.logger.log('스페이스 정보 업데이트 시작', {
+        method: 'updateBySpace',
+        spaceId: id,
+        length: space.length,
+      });
+
+      let spaceJsonData;
+      try {
+        spaceJsonData = JSON.parse(space);
+      } catch (error) {
+        throw new Error(`유효하지 않은 스페이스 JSON 데이터: ${error.message}`);
+      }
+
+      const updateDto = {
+        edges: JSON.stringify(spaceJsonData.edges),
+        nodes: JSON.stringify(spaceJsonData.nodes),
+      };
+
+      const updatedSpace = await this.spaceModel
+        .findOneAndUpdate({ id }, { $set: updateDto }, { new: true })
+        .exec();
+
+      if (!updatedSpace) {
+        throw new Error(`ID가 ${id}인 스페이스를 찾을 수 없습니다.`);
+      }
+
+      this.logger.log('스페이스 정보 업데이트 완료', {
+        method: 'updateBySpace',
+        spaceId: id,
+        success: !!updatedSpace,
+      });
+
+      return updatedSpace;
+    } catch (error) {
+      this.logger.error('스페이스 정보 업데이트 실패', {
+        method: 'updateBySpace',
+        spaceId: id,
+        error: error.message,
+        stack: error.stack,
+      });
+      throw error;
+    }
+  }
+
+  async findBySpace(id: string) {
+    try {
+      this.logger.log('스페이스 정보 조회 시작', {
+        method: 'findBySpace',
+        spaceId: id,
+      });
+
+      const space = await this.spaceModel.findOne({ id }).exec();
+
+      if (!space) {
+        this.logger.error(`ID가 ${id}인 스페이스를 찾을 수 없습니다.`);
+        throw new BadRequestException(ERROR_MESSAGES.NOTE.NOT_FOUND);
+      }
+
+      this.logger.log('스페이스 정보 조회 완료', {
+        method: 'findBySpace',
+        spaceId: id,
+        found: !!space,
+      });
+
+      return space;
+    } catch (error) {
+      this.logger.error('스페이스 정보 조회 실패', {
+        method: 'findBySpace',
+        spaceId: id,
+        error: error.message,
+        stack: error.stack,
+      });
+      throw error;
+    }
+  }
+}