Merge pull request #26 from usbharu/feature/deliver-reaction

Feature/deliver reaction

build.gradle.kts

@@ -59,7 +59,7 @@ kotlin {
 }
 
 sourceSets.main {
-    java.srcDirs("build/generated/ksp/main/kotlin")
+    kotlin.srcDirs("$buildDir/generated/ksp/main")
 }
 
 dependencies {

package.json

@@ -14,7 +14,7 @@
     "@suid/vite-plugin": "^0.1.3",
     "rollup-plugin-visualizer": "^5.9.2",
     "typescript": "^5.0.4",
-    "vite": "^4.2.1",
+    "vite": "4.2.3",
     "vite-plugin-solid": "^2.7.0"
   },
   "scripts": {

src/main/kotlin/dev/usbharu/hideout/Application.kt

@@ -8,6 +8,8 @@ import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
 import dev.usbharu.hideout.config.Config
 import dev.usbharu.hideout.config.ConfigData
 import dev.usbharu.hideout.domain.model.job.DeliverPostJob
+import dev.usbharu.hideout.domain.model.job.DeliverReactionJob
+import dev.usbharu.hideout.domain.model.job.DeliverRemoveReactionJob
 import dev.usbharu.hideout.domain.model.job.ReceiveFollowJob
 import dev.usbharu.hideout.plugins.*
 import dev.usbharu.hideout.repository.IUserRepository
@@ -24,6 +26,7 @@ import dev.usbharu.hideout.service.core.IdGenerateService
 import dev.usbharu.hideout.service.core.TwitterSnowflakeIdGenerateService
 import dev.usbharu.hideout.service.job.JobQueueParentService
 import dev.usbharu.hideout.service.job.KJobJobQueueParentService
+import dev.usbharu.hideout.service.reaction.IReactionService
 import dev.usbharu.hideout.service.user.IUserAuthService
 import dev.usbharu.hideout.service.user.IUserService
 import dev.usbharu.kjob.exposed.ExposedKJob
@@ -102,6 +105,7 @@ fun Application.parent() {
     configureSerialization()
     register(inject<IUserService>().value)
     configureSecurity(
+
         inject<JwkProvider>().value,
         inject<IMetaService>().value
     )
@@ -112,6 +116,7 @@ fun Application.parent() {
         activityPubUserService = inject<ActivityPubUserService>().value,
         postService = inject<IPostApiService>().value,
         userApiService = inject<IUserApiService>().value,
+        reactionService = inject<IReactionService>().value,
         userAuthService = inject<IUserAuthService>().value,
         userRepository = inject<IUserRepository>().value,
         jwtService = inject<IJwtService>().value,
@@ -137,4 +142,16 @@ fun Application.worker() {
             activityPubService.processActivity(this, it)
         }
     }
+
+    kJob.register(DeliverReactionJob) {
+        execute {
+            activityPubService.processActivity(this, it)
+        }
+    }
+
+    kJob.register(DeliverRemoveReactionJob) {
+        execute {
+            activityPubService.processActivity(this, it)
+        }
+    }
 }

src/main/kotlin/dev/usbharu/hideout/domain/model/ap/Like.kt

@@ -11,13 +11,13 @@ open class Like : Object {
 
     protected constructor() : super()
     constructor(
-        type: List<String>,
+        type: List<String> = emptyList(),
         name: String?,
         actor: String?,
         id: String?,
         `object`: String?,
         content: String?,
-        tag: List<Object>
+        tag: List<Object> = emptyList()
     ) : super(
         type = add(type, "Like"),
         name = name,

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

@@ -7,7 +7,7 @@ import com.fasterxml.jackson.databind.JsonNode
 import dev.usbharu.hideout.service.activitypub.ExtendedActivityVocabulary
 
 class ObjectDeserializer : JsonDeserializer<Object>() {
-    @Suppress("LongMethod")
+    @Suppress("LongMethod", "CyclomaticComplexMethod")
     override fun deserialize(p: JsonParser?, ctxt: DeserializationContext?): Object {
         requireNotNull(p)
         val treeNode: JsonNode = requireNotNull(p.codec?.readTree(p))

src/main/kotlin/dev/usbharu/hideout/domain/model/hideout/dto/PostResponse.kt

@@ -5,7 +5,7 @@ import dev.usbharu.hideout.domain.model.hideout.entity.User
 import dev.usbharu.hideout.domain.model.hideout.entity.Visibility
 
 data class PostResponse(
-    val id: Long,
+    val id: String,
     val user: UserResponse,
     val overview: String? = null,
     val text: String? = null,
@@ -17,7 +17,7 @@ data class PostResponse(
     companion object {
         fun from(post: Post, user: User): PostResponse {
             return PostResponse(
-                id = post.id,
+                id = post.id.toString(),
                 user = UserResponse.from(user),
                 overview = post.overview,
                 text = post.text,

src/main/kotlin/dev/usbharu/hideout/domain/model/hideout/dto/ReactionResponse.kt

@@ -0,0 +1,10 @@
+package dev.usbharu.hideout.domain.model.hideout.dto
+
+data class ReactionResponse(
+    val reaction: String,
+    val isUnicodeEmoji: Boolean = true,
+    val iconUrl: String,
+    val accounts: List<Account>
+)
+
+data class Account(val screenName: String, val iconUrl: String, val url: String)

src/main/kotlin/dev/usbharu/hideout/domain/model/hideout/dto/UserResponse.kt

@@ -3,7 +3,7 @@ package dev.usbharu.hideout.domain.model.hideout.dto
 import dev.usbharu.hideout.domain.model.hideout.entity.User
 
 data class UserResponse(
-    val id: Long,
+    val id: String,
     val name: String,
     val domain: String,
     val screenName: String,
@@ -14,7 +14,7 @@ data class UserResponse(
     companion object {
         fun from(user: User): UserResponse {
             return UserResponse(
-                id = user.id,
+                id = user.id.toString(),
                 name = user.name,
                 domain = user.domain,
                 screenName = user.screenName,

src/main/kotlin/dev/usbharu/hideout/domain/model/hideout/form/Reaction.kt

@@ -0,0 +1,3 @@
+package dev.usbharu.hideout.domain.model.hideout.form
+
+data class Reaction(val reaction: String?)

src/main/kotlin/dev/usbharu/hideout/domain/model/job/HideoutJob.kt

@@ -15,3 +15,18 @@ object DeliverPostJob : HideoutJob("DeliverPostJob") {
     val actor = string("actor")
     val inbox = string("inbox")
 }
+
+object DeliverReactionJob : HideoutJob("DeliverReactionJob") {
+    val reaction = string("reaction")
+    val postUrl = string("postUrl")
+    val actor = string("actor")
+    val inbox = string("inbox")
+    val id = string("id")
+}
+
+object DeliverRemoveReactionJob : HideoutJob("DeliverRemoveReactionJob") {
+    val id = string("id")
+    val inbox = string("inbox")
+    val actor = string("actor")
+    val like = string("like")
+}

src/main/kotlin/dev/usbharu/hideout/plugins/Routing.kt

@@ -15,6 +15,7 @@ import dev.usbharu.hideout.service.api.IUserApiService
 import dev.usbharu.hideout.service.auth.HttpSignatureVerifyService
 import dev.usbharu.hideout.service.auth.IJwtService
 import dev.usbharu.hideout.service.core.IMetaService
+import dev.usbharu.hideout.service.reaction.IReactionService
 import dev.usbharu.hideout.service.user.IUserAuthService
 import dev.usbharu.hideout.service.user.IUserService
 import io.ktor.server.application.*
@@ -29,6 +30,7 @@ fun Application.configureRouting(
     activityPubUserService: ActivityPubUserService,
     postService: IPostApiService,
     userApiService: IUserApiService,
+    reactionService: IReactionService,
     userAuthService: IUserAuthService,
     userRepository: IUserRepository,
     jwtService: IJwtService,
@@ -41,7 +43,7 @@ fun Application.configureRouting(
         usersAP(activityPubUserService, userService)
         webfinger(userService)
         route("/api/internal/v1") {
-            posts(postService)
+            posts(postService, reactionService)
             users(userService, userApiService)
             auth(userAuthService, userRepository, jwtService)
         }

src/main/kotlin/dev/usbharu/hideout/repository/ReactionRepository.kt

@@ -6,4 +6,10 @@ interface ReactionRepository {
     suspend fun generateId(): Long
     suspend fun save(reaction: Reaction): Reaction
     suspend fun reactionAlreadyExist(postId: Long, userId: Long, emojiId: Long): Boolean
+    suspend fun findByPostId(postId: Long): List<Reaction>
+    suspend fun delete(reaction: Reaction): Reaction
+    suspend fun deleteById(id: Long)
+    suspend fun deleteByPostId(postId: Long)
+    suspend fun deleteByUserId(userId: Long)
+    suspend fun deleteByPostIdAndUserId(postId: Long, userId: Long)
 }

src/main/kotlin/dev/usbharu/hideout/repository/ReactionRepositoryImpl.kt

@@ -5,6 +5,7 @@ import dev.usbharu.hideout.service.core.IdGenerateService
 import kotlinx.coroutines.Dispatchers
 import org.jetbrains.exposed.dao.id.LongIdTable
 import org.jetbrains.exposed.sql.*
+import org.jetbrains.exposed.sql.SqlExpressionBuilder.eq
 import org.jetbrains.exposed.sql.transactions.experimental.newSuspendedTransaction
 import org.jetbrains.exposed.sql.transactions.transaction
 import org.koin.core.annotation.Single
@@ -57,6 +58,50 @@ class ReactionRepositoryImpl(
             }.empty().not()
         }
     }
+
+    override suspend fun findByPostId(postId: Long): List<Reaction> {
+        return query {
+            Reactions.select {
+                Reactions.postId.eq(postId)
+            }.map { it.toReaction() }
+        }
+    }
+
+    override suspend fun delete(reaction: Reaction): Reaction {
+        query {
+            Reactions.deleteWhere {
+                id.eq(reaction.id)
+                    .and(postId.eq(reaction.postId))
+                    .and(userId.eq(reaction.postId))
+                    .and(emojiId.eq(reaction.emojiId))
+            }
+        }
+        return reaction
+    }
+
+    override suspend fun deleteById(id: Long) {
+        query {
+            Reactions.deleteWhere { Reactions.id.eq(id) }
+        }
+    }
+
+    override suspend fun deleteByPostId(postId: Long) {
+        query {
+            Reactions.deleteWhere { Reactions.postId.eq(postId) }
+        }
+    }
+
+    override suspend fun deleteByUserId(userId: Long) {
+        query {
+            Reactions.deleteWhere { Reactions.userId.eq(userId) }
+        }
+    }
+
+    override suspend fun deleteByPostIdAndUserId(postId: Long, userId: Long) {
+        query {
+            Reactions.deleteWhere { Reactions.postId.eq(postId).and(Reactions.userId.eq(userId)) }
+        }
+    }
 }
 
 fun ResultRow.toReaction(): Reaction {

src/main/kotlin/dev/usbharu/hideout/routing/api/internal/v1/Posts.kt

@@ -1,9 +1,11 @@
 package dev.usbharu.hideout.routing.api.internal.v1
 
 import dev.usbharu.hideout.domain.model.hideout.form.Post
+import dev.usbharu.hideout.domain.model.hideout.form.Reaction
 import dev.usbharu.hideout.exception.ParameterNotExistException
 import dev.usbharu.hideout.plugins.TOKEN_AUTH
 import dev.usbharu.hideout.service.api.IPostApiService
+import dev.usbharu.hideout.service.reaction.IReactionService
 import dev.usbharu.hideout.util.InstantParseUtil
 import io.ktor.http.*
 import io.ktor.server.application.*
@@ -14,7 +16,7 @@ import io.ktor.server.response.*
 import io.ktor.server.routing.*
 
 @Suppress("LongMethod")
-fun Route.posts(postApiService: IPostApiService) {
+fun Route.posts(postApiService: IPostApiService, reactionService: IReactionService) {
     route("/posts") {
         authenticate(TOKEN_AUTH) {
             post {
@@ -26,6 +28,39 @@ fun Route.posts(postApiService: IPostApiService) {
                 call.response.header("Location", create.url)
                 call.respond(HttpStatusCode.OK)
             }
+            route("/{id}/reactions") {
+                get {
+                    val principal = call.principal<JWTPrincipal>() ?: throw IllegalStateException("no principal")
+                    val userId = principal.payload.getClaim("uid").asLong()
+                    val postId = (
+                        call.parameters["id"]?.toLong()
+                            ?: throw ParameterNotExistException("Parameter(id='postsId') does not exist.")
+                        )
+                    call.respond(reactionService.findByPostIdForUser(postId, userId))
+                }
+                post {
+                    val jwtPrincipal = call.principal<JWTPrincipal>() ?: throw IllegalStateException("no principal")
+                    val userId = jwtPrincipal.payload.getClaim("uid").asLong()
+                    val postId = call.parameters["id"]?.toLong()
+                        ?: throw ParameterNotExistException("Parameter(id='postsId') does not exist.")
+                    val reaction = try {
+                        call.receive<Reaction>()
+                    } catch (e: ContentTransformationException) {
+                        Reaction(null)
+                    }
+
+                    reactionService.sendReaction(reaction.reaction ?: "❤", userId, postId)
+                    call.respond(HttpStatusCode.NoContent)
+                }
+                delete {
+                    val jwtPrincipal = call.principal<JWTPrincipal>() ?: throw IllegalStateException("no principal")
+                    val userId = jwtPrincipal.payload.getClaim("uid").asLong()
+                    val postId = call.parameters["id"]?.toLong()
+                        ?: throw ParameterNotExistException("Parameter(id='postsId') does not exist.")
+                    reactionService.removeReaction(userId, postId)
+                    call.respond(HttpStatusCode.NoContent)
+                }
+            }
         }
         authenticate(TOKEN_AUTH, optional = true) {
             get {

src/main/kotlin/dev/usbharu/hideout/routing/api/internal/v1/Users.kt

@@ -81,7 +81,7 @@ fun Route.users(userService: IUserService, userApiService: IUserApiService) {
                         }
                         val acct = AcctUtil.parse(userParameter)
                         val targetUser = userApiService.findByAcct(acct)
-                        if (userService.followRequest(targetUser.id, userId)) {
+                        if (userService.followRequest(targetUser.id.toLong(), userId)) {
                             return@post call.respond(HttpStatusCode.OK)
                         } else {
                             return@post call.respond(HttpStatusCode.Accepted)

src/main/kotlin/dev/usbharu/hideout/service/activitypub/ActivityPubReactionService.kt

@@ -0,0 +1,13 @@
+package dev.usbharu.hideout.service.activitypub
+
+import dev.usbharu.hideout.domain.model.hideout.entity.Reaction
+import dev.usbharu.hideout.domain.model.job.DeliverReactionJob
+import dev.usbharu.hideout.domain.model.job.DeliverRemoveReactionJob
+import kjob.core.job.JobProps
+
+interface ActivityPubReactionService {
+    suspend fun reaction(like: Reaction)
+    suspend fun removeReaction(like: Reaction)
+    suspend fun reactionJob(props: JobProps<DeliverReactionJob>)
+    suspend fun removeReactionJob(props: JobProps<DeliverRemoveReactionJob>)
+}

src/main/kotlin/dev/usbharu/hideout/service/activitypub/ActivityPubReactionServiceImpl.kt

@@ -0,0 +1,93 @@
+package dev.usbharu.hideout.service.activitypub
+
+import com.fasterxml.jackson.module.kotlin.readValue
+import dev.usbharu.hideout.config.Config
+import dev.usbharu.hideout.domain.model.ap.Like
+import dev.usbharu.hideout.domain.model.ap.Undo
+import dev.usbharu.hideout.domain.model.hideout.entity.Reaction
+import dev.usbharu.hideout.domain.model.job.DeliverReactionJob
+import dev.usbharu.hideout.domain.model.job.DeliverRemoveReactionJob
+import dev.usbharu.hideout.exception.PostNotFoundException
+import dev.usbharu.hideout.plugins.postAp
+import dev.usbharu.hideout.repository.IPostRepository
+import dev.usbharu.hideout.service.job.JobQueueParentService
+import dev.usbharu.hideout.service.user.IUserService
+import io.ktor.client.*
+import kjob.core.job.JobProps
+import org.koin.core.annotation.Single
+import java.time.Instant
+
+@Single
+class ActivityPubReactionServiceImpl(
+    private val userService: IUserService,
+    private val jobQueueParentService: JobQueueParentService,
+    private val iPostRepository: IPostRepository,
+    private val httpClient: HttpClient
+) : ActivityPubReactionService {
+    override suspend fun reaction(like: Reaction) {
+        val followers = userService.findFollowersById(like.userId)
+        val user = userService.findById(like.userId)
+        val post =
+            iPostRepository.findOneById(like.postId) ?: throw PostNotFoundException("${like.postId} was not found.")
+        followers.forEach { follower ->
+            jobQueueParentService.schedule(DeliverReactionJob) {
+                props[it.actor] = user.url
+                props[it.reaction] = "❤"
+                props[it.inbox] = follower.inbox
+                props[it.postUrl] = post.url
+                props[it.id] = post.id.toString()
+            }
+        }
+    }
+
+    override suspend fun removeReaction(like: Reaction) {
+        val followers = userService.findFollowersById(like.userId)
+        val user = userService.findById(like.userId)
+        val post =
+            iPostRepository.findOneById(like.postId) ?: throw PostNotFoundException("${like.postId} was not found.")
+        followers.forEach { follower ->
+            jobQueueParentService.schedule(DeliverRemoveReactionJob) {
+                props[it.actor] = user.url
+                props[it.inbox] = follower.inbox
+                props[it.id] = post.id.toString()
+                props[it.like] = Config.configData.objectMapper.writeValueAsString(like)
+            }
+        }
+    }
+
+    override suspend fun reactionJob(props: JobProps<DeliverReactionJob>) {
+        val inbox = props[DeliverReactionJob.inbox]
+        val actor = props[DeliverReactionJob.actor]
+        val postUrl = props[DeliverReactionJob.postUrl]
+        val id = props[DeliverReactionJob.id]
+        val content = props[DeliverReactionJob.reaction]
+        httpClient.postAp(
+            urlString = inbox,
+            username = "$actor#pubkey",
+            jsonLd = Like(
+                name = "Like",
+                actor = actor,
+                `object` = postUrl,
+                id = "${Config.configData.url}/like/note/$id",
+                content = content
+            )
+        )
+    }
+
+    override suspend fun removeReactionJob(props: JobProps<DeliverRemoveReactionJob>) {
+        val inbox = props[DeliverRemoveReactionJob.inbox]
+        val actor = props[DeliverRemoveReactionJob.actor]
+        val like = Config.configData.objectMapper.readValue<Like>(props[DeliverRemoveReactionJob.like])
+        httpClient.postAp(
+            urlString = inbox,
+            username = "$actor#pubkey",
+            jsonLd = Undo(
+                name = "Undo Reaction",
+                actor = actor,
+                `object` = like,
+                id = "${Config.configData.url}/undo/note/${like.id}",
+                published = Instant.now()
+            )
+        )
+    }
+}

src/main/kotlin/dev/usbharu/hideout/service/activitypub/ActivityPubServiceImpl.kt

@@ -5,9 +5,7 @@ import com.fasterxml.jackson.module.kotlin.readValue
 import dev.usbharu.hideout.config.Config.configData
 import dev.usbharu.hideout.domain.model.ActivityPubResponse
 import dev.usbharu.hideout.domain.model.ap.Follow
-import dev.usbharu.hideout.domain.model.job.DeliverPostJob
+import dev.usbharu.hideout.domain.model.job.*
-import dev.usbharu.hideout.domain.model.job.HideoutJob
-import dev.usbharu.hideout.domain.model.job.ReceiveFollowJob
 import dev.usbharu.hideout.exception.JsonParseException
 import kjob.core.dsl.JobContextWithProps
 import kjob.core.job.JobProps
@@ -22,7 +20,8 @@ class ActivityPubServiceImpl(
     private val activityPubUndoService: ActivityPubUndoService,
     private val activityPubAcceptService: ActivityPubAcceptService,
     private val activityPubCreateService: ActivityPubCreateService,
-    private val activityPubLikeService: ActivityPubLikeService
+    private val activityPubLikeService: ActivityPubLikeService,
+    private val activityPubReactionService: ActivityPubReactionService
 ) : ActivityPubService {
 
     val logger: Logger = LoggerFactory.getLogger(this::class.java)
@@ -71,6 +70,10 @@ class ActivityPubServiceImpl(
             )
 
             DeliverPostJob -> activityPubNoteService.createNoteJob(job.props as JobProps<DeliverPostJob>)
+            DeliverReactionJob -> activityPubReactionService.reactionJob(job.props as JobProps<DeliverReactionJob>)
+            DeliverRemoveReactionJob -> activityPubReactionService.removeReactionJob(
+                job.props as JobProps<DeliverRemoveReactionJob>
+            )
         }
     }
 }

src/main/kotlin/dev/usbharu/hideout/service/reaction/IReactionService.kt

@@ -1,5 +1,10 @@
 package dev.usbharu.hideout.service.reaction
 
+import dev.usbharu.hideout.domain.model.hideout.dto.ReactionResponse
+
 interface IReactionService {
     suspend fun receiveReaction(name: String, domain: String, userId: Long, postId: Long)
+    suspend fun sendReaction(name: String, userId: Long, postId: Long)
+    suspend fun removeReaction(userId: Long, postId: Long)
+    suspend fun findByPostIdForUser(postId: Long, userId: Long): List<ReactionResponse>
 }

src/main/kotlin/dev/usbharu/hideout/service/reaction/ReactionServiceImpl.kt

@@ -1,11 +1,23 @@
 package dev.usbharu.hideout.service.reaction
 
+import dev.usbharu.hideout.domain.model.hideout.dto.Account
+import dev.usbharu.hideout.domain.model.hideout.dto.ReactionResponse
 import dev.usbharu.hideout.domain.model.hideout.entity.Reaction
 import dev.usbharu.hideout.repository.ReactionRepository
+import dev.usbharu.hideout.repository.Reactions
+import dev.usbharu.hideout.repository.Users
+import dev.usbharu.hideout.service.activitypub.ActivityPubReactionService
+import org.jetbrains.exposed.sql.ResultRow
+import org.jetbrains.exposed.sql.leftJoin
+import org.jetbrains.exposed.sql.select
+import org.jetbrains.exposed.sql.transactions.experimental.newSuspendedTransaction
 import org.koin.core.annotation.Single
 
 @Single
-class ReactionServiceImpl(private val reactionRepository: ReactionRepository) : IReactionService {
+class ReactionServiceImpl(
+    private val reactionRepository: ReactionRepository,
+    private val activityPubReactionService: ActivityPubReactionService
+) : IReactionService {
     override suspend fun receiveReaction(name: String, domain: String, userId: Long, postId: Long) {
         if (reactionRepository.reactionAlreadyExist(postId, userId, 0).not()) {
             reactionRepository.save(
@@ -13,4 +25,31 @@ class ReactionServiceImpl(private val reactionRepository: ReactionRepository) :
             )
         }
     }
+
+    override suspend fun sendReaction(name: String, userId: Long, postId: Long) {
+        if (reactionRepository.reactionAlreadyExist(postId, userId, 0)) {
+            // delete
+            reactionRepository.deleteByPostIdAndUserId(postId, userId)
+        } else {
+            val reaction = Reaction(reactionRepository.generateId(), 0, postId, userId)
+            reactionRepository.save(reaction)
+            activityPubReactionService.reaction(reaction)
+        }
+    }
+
+    override suspend fun removeReaction(userId: Long, postId: Long) {
+        reactionRepository.deleteByPostIdAndUserId(postId, userId)
+    }
+
+    override suspend fun findByPostIdForUser(postId: Long, userId: Long): List<ReactionResponse> {
+        return newSuspendedTransaction {
+            Reactions
+                .leftJoin(Users, onColumn = { Reactions.userId }, otherColumn = { id })
+                .select { Reactions.postId.eq(postId) }
+                .groupBy { resultRow: ResultRow -> ReactionResponse("❤", true, "", listOf()) }
+                .map { entry: Map.Entry<ReactionResponse, List<ResultRow>> ->
+                    entry.key.copy(accounts = entry.value.map { Account(it[Users.screenName], "", it[Users.url]) })
+                }
+        }
+    }
 }

src/main/resources/openapi/api.yaml

@@ -74,6 +74,71 @@ paths:
           $ref: "#/components/responses/NotFoundOrForbidden"
         429:
           $ref: "#/components/responses/TooManyRequests"
+  /posts/{postId}/reactions:
+    get:
+      summary: リアクションを数件返す
+      security:
+        - BearerAuth: [ ]
+      parameters:
+        - $ref: "#/components/parameters/postId"
+      responses:
+        200:
+          description: 成功
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/ReactionResponse"
+        401:
+          $ref: "#/components/responses/Unauthorized"
+        403:
+          $ref: "#/components/responses/Forbidden"
+        404:
+          $ref: "#/components/responses/NotFoundOrForbidden"
+        429:
+          $ref: "#/components/responses/TooManyRequests"
+
+    post:
+      summary: リアクションを付ける
+      security:
+        - BearerAuth: [ ]
+      parameters:
+        - $ref: "#/components/parameters/postId"
+      requestBody:
+        description: 付けるリアクション
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/Reaction"
+      responses:
+        200:
+          description: 成功
+        401:
+          $ref: "#/components/responses/Unauthorized"
+        403:
+          $ref: "#/components/responses/Forbidden"
+        404:
+          $ref: "#/components/responses/NotFoundOrForbidden"
+        429:
+          $ref: "#/components/responses/TooManyRequests"
+    delete:
+      summary: リアクションを削除する
+      security:
+        - BearerAuth: [ ]
+      parameters:
+        - $ref: "#/components/parameters/postId"
+      responses:
+        200:
+          description: 成功
+        401:
+          $ref: "#/components/responses/Unauthorized"
+        403:
+          $ref: "#/components/responses/Forbidden"
+        404:
+          $ref: "#/components/responses/NotFoundOrForbidden"
+        429:
+          $ref: "#/components/responses/TooManyRequests"
+
   /users/{userName}/posts:
     get:
       summary: 権限に応じてユーザーの投稿一覧を返す
@@ -290,8 +355,7 @@ components:
       description: 投稿ID
       required: true
       schema:
-        type: integer
+        type: string
-        format: int64
     userName:
       name: userName
       in: path
@@ -320,8 +384,7 @@ components:
         - createdAt
       properties:
         id:
-          type: number
+          type: string
-          format: int64
           readOnly: true
         name:
           type: string
@@ -337,7 +400,7 @@ components:
           type: string
           readOnly: true
         createdAt:
-          type: number
+          type: integer
           readOnly: true
     PostResponse:
       type: object
@@ -351,8 +414,7 @@ components:
         - sensitive
       properties:
         id:
-          type: integer
+          type: string
-          format: int64
           readOnly: true
         user:
           $ref: "#/components/schemas/UserResponse"
@@ -371,12 +433,10 @@ components:
           format: uri
           readOnly: true
         repostId:
-          type: integer
+          type: string
-          format: int64
           readOnly: true
         replyId:
-          type: integer
+          type: string
-          format: int64
           readOnly: true
         sensitive:
           type: boolean
@@ -391,11 +451,9 @@ components:
         visibility:
           $ref: "#/components/schemas/Visibility"
         repostId:
-          type: integer
+          type: string
-          format: int64
         replyId:
-          type: integer
+          type: string
-          format: int64
         sensitive:
           type: boolean
 
@@ -421,6 +479,36 @@ components:
         password:
           type: string
 
+    Reaction:
+      type: object
+      properties:
+        reaction:
+          type: string
+
+    ReactionResponse:
+      type: object
+      properties:
+        reaction:
+          type: string
+        isUnicodeEmoji:
+          type: boolean
+        iconUrl:
+          type: string
+        accounts:
+          type: array
+          items:
+            $ref: "#/components/schemas/Account"
+
+    Account:
+      type: object
+      properties:
+        screenName:
+          type: string
+        iconUrl:
+          type: string
+        url:
+          type: string
+
   securitySchemes:
     BearerAuth:
       type: http

src/main/web/organisms/Post.tsx

@@ -4,14 +4,22 @@ import {Avatar} from "../atoms/Avatar";
 import {Favorite, MoreVert, Reply, ScreenRotationAlt} from "@suid/icons-material";
 import {ShareScopeIndicator} from "../molecules/ShareScopeIndicator";
 import {PostResponse} from "../generated";
+import {useApi} from "../lib/ApiProvider";
 
 export const Post: Component<{ post: PostResponse }> = (props) => {
+
+    const api = useApi()
+
     const [anchorEl, setAnchorEl] = createSignal<null | HTMLElement>(null)
     const open = () => Boolean(anchorEl());
     const handleClose = () => {
         setAnchorEl(null);
     }
 
+    const handleFavorite = () => {
+        api().postsPostIdReactionsPost({reaction: "❤"}, props.post.id)
+    }
+
     return (
         <Card>
             <CardHeader avatar={<Avatar src={props.post.user.url + "/icon.jpg"}/>} title={props.post.user.screenName}
@@ -32,7 +40,7 @@ export const Post: Component<{ post: PostResponse }> = (props) => {
                 <IconButton>
                     <ScreenRotationAlt/>
                 </IconButton>
-                <IconButton>
+                <IconButton onclick={handleFavorite}>
                     <Favorite/>
                 </IconButton>
                 <Box sx={{marginLeft: "auto"}}>

src/test/kotlin/dev/usbharu/hideout/routing/api/internal/v1/PostsTest.kt

@@ -35,7 +35,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -45,7 +45,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -53,7 +53,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -78,7 +78,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -101,7 +101,7 @@ class PostsTest {
             on { getClaim(eq("uid")) } doReturn claim
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -111,7 +111,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -119,7 +119,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -127,7 +127,7 @@ class PostsTest {
                 url = "https://example.com/posts/2"
             ),
             PostResponse(
-                id = 1234567,
+                id = "1234567",
                 user = user,
                 text = "Followers only",
                 visibility = Visibility.FOLLOWERS,
@@ -159,7 +159,7 @@ class PostsTest {
             configureSerialization()
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -176,7 +176,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -185,7 +185,7 @@ class PostsTest {
             createdAt = Instant.now().toEpochMilli()
         )
         val post = PostResponse(
-            id = 12345,
+            id = "12345",
             user = user,
             text = "aaa",
             visibility = Visibility.PUBLIC,
@@ -200,7 +200,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -216,9 +216,9 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val post = PostResponse(
-            12345,
+            "12345",
             UserResponse(
-                id = 54321,
+                id = "54321",
                 name = "user1",
                 domain = "example.com",
                 screenName = "user 1",
@@ -251,7 +251,7 @@ class PostsTest {
             }
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -279,9 +279,9 @@ class PostsTest {
                 val argument = it.getArgument<dev.usbharu.hideout.domain.model.hideout.form.Post>(0)
                 val userId = it.getArgument<Long>(1)
                 PostResponse(
-                    id = 123L,
+                    id = "123",
                     user = UserResponse(
-                        id = 54321,
+                        id = "54321",
                         name = "user1",
                         domain = "example.com",
                         screenName = "user 1",
@@ -308,7 +308,7 @@ class PostsTest {
             }
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
             configureSerialization()
@@ -335,7 +335,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -345,7 +345,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -353,7 +353,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -379,7 +379,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -396,7 +396,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -406,7 +406,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -414,7 +414,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -440,7 +440,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -457,7 +457,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -467,7 +467,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -475,7 +475,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -501,7 +501,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -518,7 +518,7 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val user = UserResponse(
-            id = 54321,
+            id = "54321",
             name = "user1",
             domain = "example.com",
             screenName = "user 1",
@@ -528,7 +528,7 @@ class PostsTest {
         )
         val posts = listOf(
             PostResponse(
-                id = 12345,
+                id = "12345",
                 user = user,
                 text = "test1",
                 visibility = Visibility.PUBLIC,
@@ -536,7 +536,7 @@ class PostsTest {
                 url = "https://example.com/posts/1"
             ),
             PostResponse(
-                id = 123456,
+                id = "123456",
                 user = user,
                 text = "test2",
                 visibility = Visibility.PUBLIC,
@@ -562,7 +562,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -579,9 +579,9 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val post = PostResponse(
-            id = 123456,
+            id = "123456",
             user = UserResponse(
-                id = 54321,
+                id = "54321",
                 name = "user1",
                 domain = "example.com",
                 screenName = "user 1",
@@ -602,7 +602,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -619,9 +619,9 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val post = PostResponse(
-            id = 123456,
+            id = "123456",
             user = UserResponse(
-                id = 54321,
+                id = "54321",
                 name = "user1",
                 domain = "example.com",
                 screenName = "user 1",
@@ -642,7 +642,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -659,9 +659,9 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val post = PostResponse(
-            id = 123456,
+            id = "123456",
             user = UserResponse(
-                id = 54321,
+                id = "54321",
                 name = "user1",
                 domain = "example.com",
                 screenName = "user 1",
@@ -682,7 +682,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }
@@ -699,9 +699,9 @@ class PostsTest {
             config = ApplicationConfig("empty.conf")
         }
         val post = PostResponse(
-            id = 123456,
+            id = "123456",
             user = UserResponse(
-                id = 54321,
+                id = "54321",
                 name = "user1",
                 domain = "example.com",
                 screenName = "user 1",
@@ -722,7 +722,7 @@ class PostsTest {
             configureSecurity(mock(), mock())
             routing {
                 route("/api/internal/v1") {
-                    posts(postService)
+                    posts(postService, mock())
                 }
             }
         }

src/test/kotlin/dev/usbharu/hideout/routing/api/internal/v1/UsersTest.kt

@@ -25,7 +25,7 @@ import org.mockito.kotlin.*
 import utils.JsonObjectMapper
 import java.time.Instant
 import kotlin.test.assertEquals
-
+@Suppress("LargeClass")
 class UsersTest {
     @Test
     fun `users にGETするとユーザー一覧を取得できる`() = testApplication {
@@ -35,7 +35,7 @@ class UsersTest {
 
         val users = listOf(
             UserResponse(
-                12345,
+                "12345",
                 "test1",
                 "example.com",
                 "test",
@@ -44,7 +44,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                12343,
+                "12343",
                 "tes2",
                 "example.com",
                 "test",
@@ -149,7 +149,7 @@ class UsersTest {
             config = ApplicationConfig("empty.conf")
         }
         val userResponse = UserResponse(
-            1234,
+            "1234",
             "test1",
             "example.com",
             "test",
@@ -182,7 +182,7 @@ class UsersTest {
             config = ApplicationConfig("empty.conf")
         }
         val userResponse = UserResponse(
-            1234,
+            "1234",
             "test1",
             "example.com",
             "test",
@@ -215,7 +215,7 @@ class UsersTest {
             config = ApplicationConfig("empty.conf")
         }
         val userResponse = UserResponse(
-            1234,
+            "1234",
             "test1",
             "example.com",
             "test",
@@ -248,7 +248,7 @@ class UsersTest {
             config = ApplicationConfig("empty.conf")
         }
         val userResponse = UserResponse(
-            1234,
+            "1234",
             "test1",
             "example.com",
             "test",
@@ -283,7 +283,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -292,7 +292,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",
@@ -328,7 +328,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -337,7 +337,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",
@@ -373,7 +373,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -382,7 +382,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",
@@ -425,7 +425,7 @@ class UsersTest {
 
         val userApiService = mock<IUserApiService> {
             onBlocking { findByAcct(any()) } doReturn UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -475,7 +475,7 @@ class UsersTest {
 
         val userApiService = mock<IUserApiService> {
             onBlocking { findByAcct(any()) } doReturn UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -525,7 +525,7 @@ class UsersTest {
 
         val userApiService = mock<IUserApiService> {
             onBlocking { findById(any()) } doReturn UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -568,7 +568,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -577,7 +577,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",
@@ -613,7 +613,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -622,7 +622,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",
@@ -658,7 +658,7 @@ class UsersTest {
 
         val followers = listOf(
             UserResponse(
-                1235,
+                "1235",
                 "follower1",
                 "example.com",
                 "test",
@@ -667,7 +667,7 @@ class UsersTest {
                 Instant.now().toEpochMilli()
             ),
             UserResponse(
-                1236,
+                "1236",
                 "follower2",
                 "example.com",
                 "test",