refactor: 長すぎるメソッドなどを修正

src/main/kotlin/dev/usbharu/hideout/activitypub/domain/model/objects/ObjectDeserializer.kt

@@ -33,15 +33,8 @@ class ObjectDeserializer : JsonDeserializer<Object>() {
             }
 
             return when (activityType) {
-                ExtendedActivityVocabulary.Follow -> {
+                ExtendedActivityVocabulary.Follow -> p.codec.treeToValue(treeNode, Follow::class.java)
-                    val readValue = p.codec.treeToValue(treeNode, Follow::class.java)
+                ExtendedActivityVocabulary.Note -> p.codec.treeToValue(treeNode, Note::class.java)
-                    readValue
-                }
-
-                ExtendedActivityVocabulary.Note -> {
-                    p.codec.treeToValue(treeNode, Note::class.java)
-                }
-
                 ExtendedActivityVocabulary.Object -> p.codec.treeToValue(treeNode, Object::class.java)
                 ExtendedActivityVocabulary.Link -> TODO()
                 ExtendedActivityVocabulary.Activity -> TODO()

src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/APRequestServiceImpl.kt

@@ -37,15 +37,29 @@ class APRequestServiceImpl(
         logger.debug("START ActivityPub Request GET url: {}, signer: {}", url, signer?.url)
         val date = dateTimeFormatter.format(ZonedDateTime.now(ZoneId.of("GMT")))
         val u = URL(url)
-        if (signer?.privateKey == null) {
+        val httpResponse = if (signer?.privateKey == null) {
-            val bodyAsText = httpClient.get(url) {
+            apGetNotSign(url, date)
-                header("Accept", ContentType.Application.Activity)
+        } else {
-                header("Date", date)
+            apGetSign(date, u, signer, url)
-            }.bodyAsText()
-            logBody(bodyAsText, url)
-            return objectMapper.readValue(bodyAsText, responseClass)
         }
 
+        val bodyAsText = httpResponse.bodyAsText()
+        val readValue = objectMapper.readValue(bodyAsText, responseClass)
+        logger.debug(
+            "SUCCESS ActivityPub Request GET status: {} url: {}",
+            httpResponse.status,
+            httpResponse.request.url
+        )
+        logBody(bodyAsText, url)
+        return readValue
+    }
+
+    private suspend fun apGetSign(
+        date: String,
+        u: URL,
+        signer: User,
+        url: String
+    ): HttpResponse {
         val headers = headers {
             append("Accept", ContentType.Application.Activity)
             append("Date", date)
@@ -60,7 +74,7 @@ class APRequestServiceImpl(
             ),
             privateKey = PrivateKey(
                 keyId = "${signer.url}#pubkey",
-                privateKey = RsaUtil.decodeRsaPrivateKeyPem(signer.privateKey),
+                privateKey = RsaUtil.decodeRsaPrivateKeyPem(signer.privateKey!!),
             ),
             signHeaders = listOf("(request-target)", "date", "host", "accept")
         )
@@ -75,15 +89,12 @@ class APRequestServiceImpl(
             }
             contentType(ContentType.Application.Activity)
         }
-        val bodyAsText = httpResponse.bodyAsText()
+        return httpResponse
-        val readValue = objectMapper.readValue(bodyAsText, responseClass)
+    }
-        logger.debug(
+
-            "SUCCESS ActivityPub Request GET status: {} url: {}",
+    private suspend fun apGetNotSign(url: String, date: String?) = httpClient.get(url) {
-            httpResponse.status,
+        header("Accept", ContentType.Application.Activity)
-            httpResponse.request.url
+        header("Date", date)
-        )
-        logBody(bodyAsText, url)
-        return readValue
     }
 
     override suspend fun <T : Object, R : Object> apPost(
@@ -96,18 +107,9 @@ class APRequestServiceImpl(
         return objectMapper.readValue(bodyAsText, responseClass)
     }
 
-    @Suppress("LongMethod")
     override suspend fun <T : Object> apPost(url: String, body: T?, signer: User?): String {
         logger.debug("START ActivityPub Request POST url: {}, signer: {}", url, signer?.url)
-        val requestBody = if (body != null) {
+        val requestBody = addContextIfNotNull(body)
-            val mutableListOf = mutableListOf<String>()
-            mutableListOf.add("https://www.w3.org/ns/activitystreams")
-            mutableListOf.addAll(body.context)
-            body.context = mutableListOf
-            objectMapper.writeValueAsString(body)
-        } else {
-            null
-        }
 
         logger.trace(
             """
@@ -129,8 +131,28 @@ class APRequestServiceImpl(
 
         val date = dateTimeFormatter.format(ZonedDateTime.now(ZoneId.of("GMT")))
         val u = URL(url)
-        if (signer?.privateKey == null) {
+        val httpResponse = if (signer?.privateKey == null) {
-            val bodyAsText = httpClient.post(url) {
+            apPostNotSign(url, date, digest, requestBody)
+        } else {
+            apPostSign(date, u, digest, signer, url, requestBody)
+        }
+
+        val bodyAsText = httpResponse.bodyAsText()
+        logger.debug(
+            "SUCCESS ActivityPub Request POST status: {} url: {}",
+            httpResponse.status,
+            httpResponse.request.url
+        )
+        logBody(bodyAsText, url)
+        return bodyAsText
+    }
+
+    private suspend fun apPostNotSign(
+        url: String,
+        date: String?,
+        digest: String,
+        requestBody: String?
+    ) = httpClient.post(url) {
         accept(ContentType.Application.Activity)
         header("Date", date)
         header("Digest", "sha-256=$digest")
@@ -138,11 +160,16 @@ class APRequestServiceImpl(
             setBody(requestBody)
             contentType(ContentType.Application.Activity)
         }
-            }.bodyAsText()
-            logBody(bodyAsText, url)
-            return bodyAsText
     }
 
+    private suspend fun apPostSign(
+        date: String,
+        u: URL,
+        digest: String,
+        signer: User,
+        url: String,
+        requestBody: String?
+    ): HttpResponse {
         val headers = headers {
             append("Accept", ContentType.Application.Activity)
             append("Date", date)
@@ -158,30 +185,32 @@ class APRequestServiceImpl(
             ),
             privateKey = PrivateKey(
                 keyId = signer.keyId,
-                privateKey = RsaUtil.decodeRsaPrivateKeyPem(signer.privateKey)
+                privateKey = RsaUtil.decodeRsaPrivateKeyPem(signer.privateKey!!)
             ),
             signHeaders = listOf("(request-target)", "date", "host", "digest")
         )
 
         val httpResponse = httpClient.post(url) {
-            headers {
             headers {
                 appendAll(headers)
                 append("Signature", sign.signatureHeader)
                 remove("Host")
-                }
+
             }
             setBody(requestBody)
             contentType(ContentType.Application.Activity)
         }
-        val bodyAsText = httpResponse.bodyAsText()
+        return httpResponse
-        logger.debug(
+    }
-            "SUCCESS ActivityPub Request POST status: {} url: {}",
+
-            httpResponse.status,
+    private fun <T : Object> addContextIfNotNull(body: T?) = if (body != null) {
-            httpResponse.request.url
+        val mutableListOf = mutableListOf<String>()
-        )
+        mutableListOf.add("https://www.w3.org/ns/activitystreams")
-        logBody(bodyAsText, url)
+        mutableListOf.addAll(body.context)
-        return bodyAsText
+        body.context = mutableListOf
+        objectMapper.writeValueAsString(body)
+    } else {
+        null
     }
 
     private fun logBody(bodyAsText: String, url: String) {

src/main/kotlin/dev/usbharu/hideout/activitypub/service/common/APService.kt

@@ -218,7 +218,7 @@ class APServiceImpl(
         }
     }
 
-    @Suppress("CyclomaticComplexMethod", "NotImplementedDeclaration")
+    @Suppress("CyclomaticComplexMethod")
     override suspend fun processActivity(
         json: String,
         type: ActivityType,

src/main/kotlin/dev/usbharu/hideout/core/infrastructure/kjobmongodb/KjobMongoJobQueueParentService.kt

@@ -30,7 +30,8 @@ class KjobMongoJobQueueParentService(private val mongoClient: MongoClient) : Job
     }
 
     override suspend fun <T, J : HideoutJob<T, J>> scheduleTypeSafe(job: J, jobProps: T) {
-        TODO("Not yet implemented")
+        val convert = job.convert(jobProps)
+        kjob.schedule(job, convert)
     }
 
     override fun close() {

src/main/kotlin/dev/usbharu/hideout/core/service/user/UserService.kt

@@ -3,7 +3,6 @@ package dev.usbharu.hideout.core.service.user
 import dev.usbharu.hideout.core.domain.model.user.User
 import org.springframework.stereotype.Service
 
-@Suppress("TooManyFunctions")
 @Service
 interface UserService {