diff --git a/apps/server/src/domains/room/application/ports/roomUseCasePorts.ts b/apps/server/src/domains/room/application/ports/roomUseCasePorts.ts index c381914..defacee 100644 --- a/apps/server/src/domains/room/application/ports/roomUseCasePorts.ts +++ b/apps/server/src/domains/room/application/ports/roomUseCasePorts.ts @@ -12,8 +12,8 @@ /** ルームユースケースが利用する出力ポート */ export interface RoomOutputPort { - publishRoomUpdate(roomId: roomTypes.Room["roomId"], room: roomTypes.Room): void; - publishJoinRejected(payload: roomTypes.JoinRoomRejectedPayload): void; + publishRoomUpdateToRoom(roomId: roomTypes.Room["roomId"], room: roomTypes.Room): void; + publishJoinRejectedToSocket(payload: roomTypes.JoinRoomRejectedPayload): void; } /** ルーム参加ユースケースが利用する参加操作ポート */ diff --git a/apps/server/src/domains/room/application/useCases/joinRoomUseCase.ts b/apps/server/src/domains/room/application/useCases/joinRoomUseCase.ts index 406bc68..8ab6699 100644 --- a/apps/server/src/domains/room/application/useCases/joinRoomUseCase.ts +++ b/apps/server/src/domains/room/application/useCases/joinRoomUseCase.ts @@ -35,7 +35,7 @@ const joinResult = roomManager.addPlayerToRoom(roomId, socketId, playerName); if (joinResult.status !== "joined") { - output.publishJoinRejected({ + output.publishJoinRejectedToSocket({ roomId, reason: joinResult.status, }); @@ -50,7 +50,7 @@ return joinResult; } - output.publishRoomUpdate(roomId, joinResult.room); + output.publishRoomUpdateToRoom(roomId, joinResult.room); return joinResult; }; diff --git a/apps/server/src/domains/room/application/useCases/roomDisconnectUseCase.ts b/apps/server/src/domains/room/application/useCases/roomDisconnectUseCase.ts index 2fe1be0..18b7aaf 100644 --- a/apps/server/src/domains/room/application/useCases/roomDisconnectUseCase.ts +++ b/apps/server/src/domains/room/application/useCases/roomDisconnectUseCase.ts @@ -9,7 +9,7 @@ type RoomDisconnectUseCaseParams = { roomManager: DisconnectRoomPort; socketId: string; - output: Pick; + output: Pick; }; /** 切断ソケットを各ルームから退出させ,更新ルームを配信する */ @@ -27,7 +27,7 @@ }); updatedRooms.forEach((room) => { - output.publishRoomUpdate(room.roomId, room); + output.publishRoomUpdateToRoom(room.roomId, room); logEvent("RoomUseCase", { event: "ROOM_UPDATE", result: "emitted", diff --git a/apps/server/src/network/handlers/room/createRoomEventPublisher.ts b/apps/server/src/network/handlers/room/createRoomEventPublisher.ts index d838bcc..6797199 100644 --- a/apps/server/src/network/handlers/room/createRoomEventPublisher.ts +++ b/apps/server/src/network/handlers/room/createRoomEventPublisher.ts @@ -20,10 +20,10 @@ common: CommonHandlerContext ): RoomEventPublisher => { return { - publishRoomUpdate: (roomId: RoomId, room: RoomUpdatePayload) => { + publishRoomUpdateToRoom: (roomId: RoomId, room: RoomUpdatePayload) => { common.emitToRoom(roomId, protocol.SocketEvents.ROOM_UPDATE, room); }, - publishJoinRejected: (payload: roomTypes.JoinRoomRejectedPayload) => { + publishJoinRejectedToSocket: (payload: roomTypes.JoinRoomRejectedPayload) => { common.emitToSocket(protocol.SocketEvents.ROOM_JOIN_REJECTED, payload); }, }; @@ -32,11 +32,11 @@ /** 切断時のルーム更新送信関数を生成する */ export const createRoomDisconnectPublisher = ( io: Server -): Pick => { +): Pick => { const emitToRoom = createEmitToRoom(io); return { - publishRoomUpdate: (roomId: RoomId, room: RoomUpdatePayload) => { + publishRoomUpdateToRoom: (roomId: RoomId, room: RoomUpdatePayload) => { emitToRoom(roomId, protocol.SocketEvents.ROOM_UPDATE, room); }, }; diff --git a/apps/server/src/network/handlers/room/registerRoomHandlers.ts b/apps/server/src/network/handlers/room/registerRoomHandlers.ts index ebca36a..21f501d 100644 --- a/apps/server/src/network/handlers/room/registerRoomHandlers.ts +++ b/apps/server/src/network/handlers/room/registerRoomHandlers.ts @@ -62,7 +62,7 @@ case "joined": socket.join(roomId); - roomPublisher.publishRoomUpdate(roomId, joinResult.room); + roomPublisher.publishRoomUpdateToRoom(roomId, joinResult.room); logEvent("RoomUseCase", { event: "ROOM_UPDATE", result: "emitted",