Skip to content

Commit

Permalink
refactor: 스케줄러 패키징
Browse files Browse the repository at this point in the history
  • Loading branch information
char-yb committed Sep 20, 2024
1 parent 4773ca2 commit 2c8446b
Show file tree
Hide file tree
Showing 6 changed files with 17 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ public class FcmController {
@PostMapping("/token")
public ResponseEntity<Void> fcmTokenStore(
@RequestBody @Validated FcmTokenRequest fcmTokenRequest) {
fcmTokenService.storeOrUpdateToken(fcmTokenRequest.token());
fcmTokenService.createFcmToken(fcmTokenRequest.token());
return ResponseEntity.ok().build();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ private void updateToken(FcmToken fcmToken, String token) {
}

@Transactional
public void storeOrUpdateToken(String token) {
public void createFcmToken(String token) {
if (token == null || token.isEmpty()) {
throw new CustomException(ErrorCode.INVALID_FCM_TOKEN);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,12 +17,12 @@ public class SqsConfig {

@Bean
public SqsClient sqsClient() {
AwsBasicCredentials awsCreds =
AwsBasicCredentials awsBasicCredentials =
AwsBasicCredentials.create(sqsProperties.accessKey(), sqsProperties.secretKey());

return SqsClient.builder()
.region(Region.of(sqsProperties.region()))
.credentialsProvider(StaticCredentialsProvider.create(awsCreds))
.credentialsProvider(StaticCredentialsProvider.create(awsBasicCredentials))
.build();
}
}
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package com.depromeet.stonebed.domain.fcm.application;
package com.depromeet.stonebed.scheduler.fcm;

import com.depromeet.stonebed.domain.fcm.application.FcmNotificationService;
import com.depromeet.stonebed.domain.fcm.application.FcmTokenService;
import com.depromeet.stonebed.domain.fcm.dao.FcmRepository;
import com.depromeet.stonebed.domain.fcm.domain.FcmToken;
import com.depromeet.stonebed.domain.member.domain.MemberStatus;
Expand All @@ -18,7 +20,7 @@
@Slf4j
@Service
@RequiredArgsConstructor
public class FcmScheduledService {
public class FcmScheduler {
private final FcmTokenService fcmTokenService;
private final FcmNotificationService fcmNotificationService;
private final FcmRepository fcmRepository;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,12 +1,13 @@
package com.depromeet.stonebed.domain.missionRecord.application;
package com.depromeet.stonebed.scheduler.missionRecord;

import com.depromeet.stonebed.domain.missionRecord.application.MissionRecordService;
import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

@Service
@RequiredArgsConstructor
public class MissionRecordScheduledService {
public class MissionRecordScheduler {
private final MissionRecordService missionRecordService;

@Scheduled(cron = "0 0 0 * * ?")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@
import com.depromeet.stonebed.domain.missionRecord.dao.MissionRecordRepository;
import com.depromeet.stonebed.domain.missionRecord.domain.MissionRecord;
import com.depromeet.stonebed.domain.missionRecord.domain.MissionRecordStatus;
import com.depromeet.stonebed.scheduler.fcm.FcmScheduler;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.List;
Expand All @@ -24,13 +25,13 @@

@ActiveProfiles("test")
@ExtendWith(MockitoExtension.class)
public class FcmScheduledServiceTest extends FixtureMonkeySetUp {
public class FcmSchedulerTest extends FixtureMonkeySetUp {
@Mock private FcmNotificationService fcmNotificationService;
@Mock private FcmRepository fcmRepository;
@Mock private FcmTokenService fcmTokenService;
@Mock private MissionRecordRepository missionRecordRepository;

@InjectMocks private FcmScheduledService fcmScheduledService;
@InjectMocks private FcmScheduler fcmScheduler;

@Test
void 비활성화된_토큰을_삭제하면_정상적으로_삭제된다() {
Expand All @@ -39,7 +40,7 @@ public class FcmScheduledServiceTest extends FixtureMonkeySetUp {
when(fcmRepository.findAllByUpdatedAtBefore(any(LocalDateTime.class))).thenReturn(tokens);

// when
fcmScheduledService.removeInactiveTokens();
fcmScheduler.removeInactiveTokens();

// then
ArgumentCaptor<LocalDateTime> captor = ArgumentCaptor.forClass(LocalDateTime.class);
Expand All @@ -59,7 +60,7 @@ public class FcmScheduledServiceTest extends FixtureMonkeySetUp {
when(fcmTokenService.getAllTokens()).thenReturn(tokens);

// when
fcmScheduledService.sendDailyNotification();
fcmScheduler.sendDailyNotification();

// then
verify(fcmNotificationService, times(1))
Expand Down Expand Up @@ -99,7 +100,7 @@ public class FcmScheduledServiceTest extends FixtureMonkeySetUp {
.collect(Collectors.toList());

// when
fcmScheduledService.sendReminderToIncompleteMissions();
fcmScheduler.sendReminderToIncompleteMissions();

// then
verify(fcmNotificationService, times(1))
Expand Down

0 comments on commit 2c8446b

Please sign in to comment.