Skip to content

Commit

Permalink
SSE 안되는 부분 수정
Browse files Browse the repository at this point in the history
  • Loading branch information
박정민 committed Feb 9, 2024
1 parent 81be1e9 commit 9ae6076
Showing 1 changed file with 15 additions and 15 deletions.
30 changes: 15 additions & 15 deletions src/team/team.controller.ts
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,21 @@ export class TeamController {
return await this.teamService.joinTeam(user.id, teamCode);
}

@UseGuards(JwtAuthGuard)
@Sse(TeamStatusEvent.EVENT_NAME)
async sseTeamStatus(@User() user: UserEntity) {
// 1. 팀의 현재 상태를 가져오는 로직
const currentStatus = await this.teamService.getCurrentTeamStatus(
user.teamCode,
);

// 2. 현재 상태를 포함한 SSE 스트림 반환
return this.teamTrackingService.streamTeamStatus(user.teamCode).pipe(
startWith({ data: currentStatus }), // 현재 상태를 스트림의 첫 이벤트로 설정
map((status) => ({ data: status })), // 이후 업데이트를 스트림으로 전송
);
}

@Get('/:teamCode')
@UseGuards(JwtAuthGuard)
async findTeam(
Expand Down Expand Up @@ -91,21 +106,6 @@ export class TeamController {
return this.teamService.searchMember(user.teamCode, name);
}

@UseGuards(JwtAuthGuard)
@Sse(TeamStatusEvent.EVENT_NAME)
async sseTeamStatus(@User() user: UserEntity) {
// 1. 팀의 현재 상태를 가져오는 로직
const currentStatus = await this.teamService.getCurrentTeamStatus(
user.teamCode,
);

// 2. 현재 상태를 포함한 SSE 스트림 반환
return this.teamTrackingService.streamTeamStatus(user.teamCode).pipe(
startWith({ data: currentStatus }), // 현재 상태를 스트림의 첫 이벤트로 설정
map((status) => ({ data: status })), // 이후 업데이트를 스트림으로 전송
);
}

// 글을 수정하는 버튼을 눌렀을 떄에 발생하는 코드로
@Get('start-writing')
startWriting(
Expand Down

0 comments on commit 9ae6076

Please sign in to comment.