Merge pull request #7 from Nexters/feat/init-tuk-batch

배치모듈 환경세팅

Author: JunRain2

.github/workflows/ci.yml

@@ -35,6 +35,10 @@ jobs:
           restore-keys: |
             ${{ runner.os }}-gradle-
 
+      - name: Copy config file
+        run: echo "${{ secrets.FIREBASE_ADMINSDK }}" | base64 --decode > ./tuk-batch/src/main/resources/firebase-adminsdk.json
+
+
       - name: Build with Gradle
         uses: gradle/gradle-build-action@67421db6bd0bf253fb4bd25b31ebb98943c375e1
         with:

.gitignore

@@ -39,4 +39,5 @@ out/
 ### Kotlin ###
 .kotlin
 
-*.env
+*.env
+firebase-adminsdk.json

gradle.properties

@@ -4,4 +4,6 @@ googleApiClientVersion=2.0.0
 jjwtVersion=0.12.6
 mockitoKotlinVersion=5.4.0
 springMockkVersion=4.0.2
-nimbusJwtVersion=10.3
+nimbusJwtVersion=10.3
+quartzVersion=2.5.0
+firebaseVersion=9.5.0

settings.gradle.kts

@@ -1,3 +1,3 @@
 rootProject.name = "tuk-server"
 
-include("tuk-api")
+include("tuk-api", "tuk-batch")

tuk-batch/build.gradle.kts

@@ -0,0 +1,29 @@
+dependencies {
+    implementation("org.springframework.boot:spring-boot-starter-web")
+    implementation("org.springframework.boot:spring-boot-starter-actuator")
+    implementation("org.springframework.boot:spring-boot-starter-data-jpa")
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin")
+    implementation("org.jetbrains.kotlin:kotlin-reflect")
+
+    // quartz
+    implementation("org.springframework.boot:spring-boot-starter-quartz:${project.properties["quartzVersion"]}")
+
+    // firebase
+    implementation("com.google.firebase:firebase-admin:${project.properties["firebaseVersion"]}")  // FCM Admin SDK
+
+    // mysql
+    runtimeOnly("com.mysql:mysql-connector-j:${properties["mysqlVersion"]}")
+
+    // test
+    testImplementation("org.springframework.boot:spring-boot-starter-test")
+    testImplementation("org.jetbrains.kotlin:kotlin-test-junit5")
+    testRuntimeOnly("org.junit.platform:junit-platform-launcher")
+    testRuntimeOnly("com.mysql:mysql-connector-j")
+    testImplementation("org.mockito.kotlin:mockito-kotlin:${project.properties["mockitoKotlinVersion"]}")
+    testImplementation("com.ninja-squad:springmockk:${project.properties["springMockkVersion"]}")
+}
+
+tasks.withType<Test> {
+    useJUnitPlatform()
+    systemProperty("spring.profiles.active", "test")
+}

tuk-batch/src/main/kotlin/nexters/tuk/TukBatchApplication.kt

@@ -0,0 +1,11 @@
+package nexters.tuk
+
+import org.springframework.boot.autoconfigure.SpringBootApplication
+import org.springframework.boot.runApplication
+
+@SpringBootApplication
+class TukBatchApplication
+
+fun main(args: Array<String>) {
+    runApplication<TukBatchApplication>(*args)
+}

tuk-batch/src/main/kotlin/nexters/tuk/application/meeting/MeetingNotificationService.kt

@@ -0,0 +1,24 @@
+package nexters.tuk.application.meeting
+
+import nexters.tuk.application.meeting.dto.request.MeetingCommand
+import nexters.tuk.application.notification.MeetingNotifier
+import nexters.tuk.application.scheduler.MeetingNotificationScheduler
+import org.springframework.stereotype.Service
+
+@Service
+class MeetingNotificationService(
+    private val meetingNotifier: MeetingNotifier,
+    private val meetingNotificationScheduler: MeetingNotificationScheduler
+) {
+    fun handleMeetingNotification(command: MeetingCommand.Notification) {
+        when (command) {
+            is MeetingCommand.Notification.Tuk -> {
+                meetingNotificationScheduler.scheduleTukNotification(command)
+            }
+
+            is MeetingCommand.Notification.Invitation -> {
+                meetingNotifier.sendInvitationNotification(command)
+            }
+        }
+    }
+}

tuk-batch/src/main/kotlin/nexters/tuk/application/meeting/dto/request/MeetingCommand.kt

@@ -0,0 +1,8 @@
+package nexters.tuk.application.meeting.dto.request
+
+class MeetingCommand {
+    sealed class Notification {
+        data class Tuk(val meetingId: Long, val intervalDays: Long) : Notification()
+        data class Invitation(val meetingId: Long, val purpose: String) : Notification()
+    }
+}

tuk-batch/src/main/kotlin/nexters/tuk/application/member/MemberService.kt

@@ -0,0 +1,10 @@
+package nexters.tuk.application.member
+
+import org.springframework.stereotype.Service
+
+@Service
+class MemberService {
+    fun findTokensByMeetingId(meetingId: Long): List<String> {
+        TODO("Not yet implemented")
+    }
+}

tuk-batch/src/main/kotlin/nexters/tuk/application/notification/MeetingNotifier.kt

@@ -0,0 +1,26 @@
+package nexters.tuk.application.notification
+
+import nexters.tuk.application.meeting.dto.request.MeetingCommand
+import nexters.tuk.application.member.MemberService
+import org.springframework.stereotype.Service
+
+
+@Service
+class MeetingNotifier(
+    private val memberService: MemberService,
+    private val notificationSender: NotificationSender
+) {
+    fun sendTukNotification(command: MeetingCommand.Notification.Tuk) {
+        val tokens = memberService.findTokensByMeetingId(command.meetingId)
+        val tukMessage = TukNotificationMessage(command.meetingId, command.intervalDays)
+
+        notificationSender.notifyMembers(tokens, tukMessage)
+    }
+
+    fun sendInvitationNotification(command: MeetingCommand.Notification.Invitation) {
+        val tokens = memberService.findTokensByMeetingId(command.meetingId)
+        val invitationMessage = InvitationNotificationMessage(command.meetingId, command.purpose)
+
+        notificationSender.notifyMembers(tokens, invitationMessage)
+    }
+}