From d7637a4fcb242594ae7ea91eef0276957f929349 Mon Sep 17 00:00:00 2001
From: usbharu <64310155+usbharu@users.noreply.github.com>
Date: Sun, 10 Dec 2023 16:13:51 +0900
Subject: [PATCH] =?UTF-8?q?feat:=20RelationshipRepository=E3=81=A8Relation?=
 =?UTF-8?q?shipQueryService=E3=81=AE=E5=AE=9F=E8=A3=85=E3=82=92=E8=BF=BD?=
 =?UTF-8?q?=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../RelationshipRepositoryImpl.kt             | 85 +++++++++++++++++++
 .../RelationshipQueryServiceImpl.kt           | 16 ++++
 2 files changed, 101 insertions(+)
 create mode 100644 src/main/kotlin/dev/usbharu/hideout/core/domain/model/relationship/RelationshipRepositoryImpl.kt
 create mode 100644 src/main/kotlin/dev/usbharu/hideout/core/infrastructure/exposedquery/RelationshipQueryServiceImpl.kt

diff --git a/src/main/kotlin/dev/usbharu/hideout/core/domain/model/relationship/RelationshipRepositoryImpl.kt b/src/main/kotlin/dev/usbharu/hideout/core/domain/model/relationship/RelationshipRepositoryImpl.kt
new file mode 100644
index 00000000..bb0513e6
--- /dev/null
+++ b/src/main/kotlin/dev/usbharu/hideout/core/domain/model/relationship/RelationshipRepositoryImpl.kt
@@ -0,0 +1,85 @@
+package dev.usbharu.hideout.core.domain.model.relationship
+
+import dev.usbharu.hideout.core.infrastructure.exposedrepository.Users
+import org.jetbrains.exposed.dao.id.LongIdTable
+import org.jetbrains.exposed.sql.*
+import org.jetbrains.exposed.sql.SqlExpressionBuilder.eq
+import org.springframework.stereotype.Service
+
+@Service
+class RelationshipRepositoryImpl : RelationshipRepository {
+    override suspend fun save(relationship: Relationship): Relationship {
+        val singleOrNull =
+            Relationships
+                .select {
+                    (Relationships.userId eq relationship.userId)
+                        .and(Relationships.targetUserId eq relationship.targetUserId)
+                }
+                .singleOrNull()
+
+        if (singleOrNull == null) {
+            Relationships.insert {
+                it[userId] = relationship.userId
+                it[targetUserId] = relationship.targetUserId
+                it[following] = relationship.following
+                it[blocking] = relationship.blocking
+                it[muting] = relationship.blocking
+                it[followRequest] = relationship.followRequest
+                it[ignoreFollowRequestFromTarget] = relationship.ignoreFollowRequestFromTarget
+            }
+        } else {
+            Relationships
+                .update({
+                    (Relationships.userId eq relationship.userId)
+                        .and(Relationships.targetUserId eq relationship.targetUserId)
+                }) {
+                    it[following] = relationship.following
+                    it[blocking] = relationship.blocking
+                    it[muting] = relationship.blocking
+                    it[followRequest] = relationship.followRequest
+                    it[ignoreFollowRequestFromTarget] = relationship.ignoreFollowRequestFromTarget
+                }
+        }
+        return relationship
+    }
+
+    override suspend fun delete(relationship: Relationship) {
+        Relationships.deleteWhere {
+            (Relationships.userId eq relationship.userId)
+                .and(Relationships.targetUserId eq relationship.targetUserId)
+        }
+    }
+
+    override suspend fun findByUserIdAndTargetUserId(userId: Long, targetUserId: Long): Relationship? {
+        return Relationships.select {
+            (Relationships.userId eq userId)
+                .and(Relationships.targetUserId eq targetUserId)
+        }.singleOrNull()
+            ?.toRelationships()
+    }
+
+}
+
+fun ResultRow.toRelationships(): Relationship = Relationship(
+    this[Relationships.userId],
+    this[Relationships.targetUserId],
+    this[Relationships.following],
+    this[Relationships.blocking],
+    this[Relationships.muting],
+    this[Relationships.followRequest],
+    this[Relationships.ignoreFollowRequestFromTarget]
+)
+
+object Relationships : LongIdTable("relationships") {
+    val userId = long("user_id").references(Users.id)
+    val targetUserId = long("target_user_id").references(Users.id)
+    val following = bool("following")
+    val blocking = bool("blocking")
+    val muting = bool("muting")
+    val followRequest = bool("follow_request")
+    val ignoreFollowRequestFromTarget = bool("ignore_follow_request")
+
+    init {
+        uniqueIndex(userId, targetUserId)
+    }
+}
diff --git a/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/exposedquery/RelationshipQueryServiceImpl.kt b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/exposedquery/RelationshipQueryServiceImpl.kt
new file mode 100644
index 00000000..f1a122c9
--- /dev/null
+++ b/src/main/kotlin/dev/usbharu/hideout/core/infrastructure/exposedquery/RelationshipQueryServiceImpl.kt
@@ -0,0 +1,16 @@
+package dev.usbharu.hideout.core.infrastructure.exposedquery
+
+import dev.usbharu.hideout.core.domain.model.relationship.Relationship
+import dev.usbharu.hideout.core.domain.model.relationship.Relationships
+import dev.usbharu.hideout.core.domain.model.relationship.toRelationships
+import dev.usbharu.hideout.core.query.RelationshipQueryService
+import org.jetbrains.exposed.sql.and
+import org.jetbrains.exposed.sql.select
+import org.springframework.stereotype.Service
+
+@Service
+class RelationshipQueryServiceImpl : RelationshipQueryService {
+    override suspend fun findByTargetIdAndFollowing(targetId: Long, following: Boolean): List<Relationship> =
+        Relationships.select { Relationships.targetUserId eq targetId and (Relationships.following eq following) }
+            .map { it.toRelationships() }
+}