Skip to content

Commit

Permalink
Feat/sse (#106)
Browse files Browse the repository at this point in the history
* Fix: 오류 수정

* Fix: 구독 목록 불러오기 수정

* Fix: transactional readonly 삭제
  • Loading branch information
flowerdonk authored Aug 14, 2023
1 parent eb8511e commit b049ff3
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions src/main/java/com/anywayclear/service/SubscribeService.java
Original file line number Diff line number Diff line change
Expand Up @@ -34,15 +34,14 @@ public SubscribeService(SubscribeRepository subscribeRepository, MemberRepositor
}

@Transactional
public SseEmitter createSubscribe(String topicName, OAuth2User oAuth2User, String lastEventId, LocalDateTime now) {
public Long createSubscribe(String topicName, OAuth2User oAuth2User) {
String userId = (String) oAuth2User.getAttributes().get("userId");

Member consumer = memberRepository.findByUserId(userId).orElseThrow(() -> new CustomException(INVALID_MEMBER));
Member seller = memberRepository.findByUserId(topicName).orElseThrow(() -> new CustomException(INVALID_MEMBER));
Subscribe subscribe = new Subscribe(consumer, seller);
subscribeRepository.save(subscribe);

return alarmService.createEmitter(topicName, userId, lastEventId, now);
return subscribe.getId();
}

@Transactional
Expand Down Expand Up @@ -78,7 +77,7 @@ public IsSubResponse getIsSub(String consumerId, String sellerId) {
return new IsSubResponse(isSub);
}

@Transactional(readOnly = true)
@Transactional
public void deleteSubscribe(String sellerId, String consumerId) {
Member consumer = memberRepository.findByUserId(consumerId).orElseThrow(() -> new CustomException(INVALID_MEMBER));
Member seller = memberRepository.findByUserId(sellerId).orElseThrow(() -> new CustomException(INVALID_MEMBER));
Expand Down

0 comments on commit b049ff3

Please sign in to comment.