[FEAT] 투표자 API 구현 (#205)

Author: coli-geonwoo

src/main/java/com/debatetimer/config/ErrorDecoderConfig.java

@@ -0,0 +1,33 @@
+package com.debatetimer.config;
+
+import com.debatetimer.exception.decoder.H2ErrorDecoder;
+import com.debatetimer.exception.decoder.MySqlErrorDecoder;
+import com.debatetimer.exception.decoder.RepositoryErrorDecoder;
+import lombok.NoArgsConstructor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
+
+@NoArgsConstructor(access = lombok.AccessLevel.PRIVATE)
+public class ErrorDecoderConfig {
+
+    @Profile({"dev", "prod"})
+    @Configuration
+    public static class MySqlErrorDecoderConfig {
+
+        @Bean
+        public RepositoryErrorDecoder mySqlErrorDecoder() {
+            return new MySqlErrorDecoder();
+        }
+    }
+
+    @Profile({"test", "local"})
+    @Configuration
+    public static class H2ErrorDecoderConfig {
+
+        @Bean
+        public RepositoryErrorDecoder h2ErrorDecoder() {
+            return new H2ErrorDecoder();
+        }
+    }
+}

src/main/java/com/debatetimer/controller/poll/VoteController.java

@@ -0,0 +1,37 @@
+package com.debatetimer.controller.poll;
+
+import com.debatetimer.dto.poll.request.VoteRequest;
+import com.debatetimer.dto.poll.response.VoteCreateResponse;
+import com.debatetimer.dto.poll.response.VoterPollInfoResponse;
+import com.debatetimer.service.poll.VoteService;
+import jakarta.validation.Valid;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequiredArgsConstructor
+public class VoteController {
+
+    private final VoteService voteService;
+
+    @GetMapping("/api/polls/{pollId}/votes")
+    @ResponseStatus(HttpStatus.OK)
+    public VoterPollInfoResponse getVotersPollInfo(@PathVariable long pollId) {
+        return voteService.getVoterPollInfo(pollId);
+    }
+
+    @PostMapping("/api/polls/{pollId}/votes")
+    @ResponseStatus(HttpStatus.CREATED)
+    public VoteCreateResponse votePoll(
+            @PathVariable long pollId,
+            @RequestBody @Valid VoteRequest voteRequest
+    ) {
+        return voteService.vote(pollId, voteRequest);
+    }
+}

src/main/java/com/debatetimer/domain/member/Member.java

@@ -1,6 +1,6 @@
 package com.debatetimer.domain.member;
 
-import com.debatetimer.entity.customize.BaseTimeEntity;
+import com.debatetimer.entity.BaseTimeEntity;
 import jakarta.persistence.Column;
 import jakarta.persistence.Entity;
 import jakarta.persistence.GeneratedValue;

src/main/java/com/debatetimer/domain/poll/Poll.java

@@ -26,4 +26,8 @@ public Poll(Long id, long tableId, long memberId, PollStatus status,
                 String prosTeamName, String consTeamName, String agenda) {
         this(id, tableId, memberId, status, new TeamName(prosTeamName), new TeamName(consTeamName), new Agenda(agenda));
     }
+
+    public boolean isProgress() {
+        return status.isProgress();
+    }
 }

src/main/java/com/debatetimer/domain/poll/PollStatus.java

@@ -5,4 +5,8 @@ public enum PollStatus {
     PROGRESS,
     DONE,
     ;
+
+    public boolean isProgress() {
+        return this == PROGRESS;
+    }
 }

src/main/java/com/debatetimer/domain/poll/Vote.java

@@ -13,6 +13,10 @@ public class Vote {
     private final ParticipantName name;
     private final ParticipateCode code;
 
+    public Vote(long pollId, VoteTeam team, String name, String code) {
+        this(null, pollId, team, name, code);
+    }
+
     public Vote(Long id, long pollId, VoteTeam team, String name, String code) {
         this(id, pollId, team, new ParticipantName(name), new ParticipateCode(code));
     }

src/main/java/com/debatetimer/domainrepository/poll/PollDomainRepository.java

@@ -2,8 +2,6 @@
 
 import com.debatetimer.domain.poll.Poll;
 import com.debatetimer.entity.poll.PollEntity;
-import com.debatetimer.exception.custom.DTClientErrorException;
-import com.debatetimer.exception.errorcode.ClientErrorCode;
 import com.debatetimer.repository.poll.PollRepository;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
@@ -24,19 +22,20 @@ public Poll create(Poll poll) {
 
     @Transactional(readOnly = true)
     public Poll getByIdAndMemberId(long id, long memberId) {
-        return findPoll(id, memberId)
+        return pollRepository.getByIdAndMemberId(id, memberId)
+                .toDomain();
+    }
+
+    @Transactional(readOnly = true)
+    public Poll getById(long id) {
+        return pollRepository.getById(id)
                 .toDomain();
     }
 
     @Transactional
     public Poll finishPoll(long pollId, long memberId) {
-        PollEntity pollEntity = findPoll(pollId, memberId);
+        PollEntity pollEntity = pollRepository.getByIdAndMemberId(pollId, memberId);
         pollEntity.updateToDone();
         return pollEntity.toDomain();
     }
-
-    private PollEntity findPoll(long pollId, long memberId) {
-        return pollRepository.findByIdAndMemberId(pollId, memberId)
-                .orElseThrow(() -> new DTClientErrorException(ClientErrorCode.POLL_NOT_FOUND));
-    }
 }

src/main/java/com/debatetimer/domainrepository/poll/VoteDomainRepository.java

@@ -1,20 +1,30 @@
 package com.debatetimer.domainrepository.poll;
 
+import com.debatetimer.domain.poll.ParticipateCode;
+import com.debatetimer.domain.poll.Vote;
 import com.debatetimer.domain.poll.VoteInfo;
 import com.debatetimer.domain.poll.VoteTeam;
+import com.debatetimer.entity.poll.PollEntity;
 import com.debatetimer.entity.poll.VoteEntity;
+import com.debatetimer.exception.custom.DTClientErrorException;
+import com.debatetimer.exception.decoder.RepositoryErrorDecoder;
+import com.debatetimer.exception.errorcode.ClientErrorCode;
+import com.debatetimer.repository.poll.PollRepository;
 import com.debatetimer.repository.poll.VoteRepository;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
+import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Repository;
 
 @Repository
 @RequiredArgsConstructor
 public class VoteDomainRepository {
 
+    private final PollRepository pollRepository;
     private final VoteRepository voteRepository;
+    private final RepositoryErrorDecoder errorDecoder;
 
     public VoteInfo findVoteInfoByPollId(long pollId) {
         List<VoteEntity> pollVotes = voteRepository.findAllByPollId(pollId);
@@ -28,4 +38,22 @@ private VoteInfo countVotes(long pollId, List<VoteEntity> voteEntities) {
         long consCount = teamCount.getOrDefault(VoteTeam.CONS, 0L);
         return new VoteInfo(pollId, prosCount, consCount);
     }
+
+    public boolean isExists(long pollId, ParticipateCode code) {
+        return voteRepository.existsByPollIdAndParticipateCode(pollId, code.getValue());
+    }
+
+    public Vote save(Vote vote) {
+        try {
+            PollEntity pollEntity = pollRepository.getById(vote.getPollId());
+            VoteEntity voteEntity = new VoteEntity(vote, pollEntity);
+            return voteRepository.save(voteEntity)
+                    .toDomain();
+        } catch (DataIntegrityViolationException exception) {
+            if (errorDecoder.isUniqueConstraintViolation(exception)) {
+                throw new DTClientErrorException(ClientErrorCode.ALREADY_VOTED_PARTICIPANT);
+            }
+            throw exception;
+        }
+    }
 }

…poll/CustomizeTableDomainRepository.java …able/CustomizeTableDomainRepository.javasrc/main/java/com/debatetimer/domainrepository/poll/CustomizeTableDomainRepository.java renamed to src/main/java/com/debatetimer/domainrepository/table/CustomizeTableDomainRepository.java src/main/java/com/debatetimer/domainrepository/poll/CustomizeTableDomainRepository.java renamed to src/main/java/com/debatetimer/domainrepository/table/CustomizeTableDomainRepository.java

@@ -1,4 +1,4 @@
-package com.debatetimer.domainrepository.poll;
+package com.debatetimer.domainrepository.table;
 
 import com.debatetimer.domain.customize.CustomizeTable;
 import com.debatetimer.domain.member.Member;

src/main/java/com/debatetimer/dto/poll/request/VoteRequest.java

@@ -0,0 +1,13 @@
+package com.debatetimer.dto.poll.request;
+
+import com.debatetimer.domain.poll.VoteTeam;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+
+public record VoteRequest(
+        @NotBlank String name,
+        @NotBlank String participateCode,
+        @NotNull VoteTeam team
+) {
+
+}