Move constitution to component

src/main/kotlin/component/article/ArticleViewManager.kt

@@ -2,8 +2,8 @@ package fr.dcproject.component.article
 
 import fr.dcproject.component.citizen.CitizenI
 import fr.dcproject.component.views.ViewManager
+import fr.dcproject.component.views.entity.ViewAggregation
 import fr.dcproject.entity.VersionableRef
-import fr.dcproject.entity.ViewAggregation
 import fr.dcproject.utils.contentToString
 import fr.dcproject.utils.getJsonField
 import fr.dcproject.utils.toIso

src/main/kotlin/component/article/routes/GetOneArticle.kt

@@ -7,10 +7,11 @@ import fr.dcproject.component.article.ArticleViewManager
 import fr.dcproject.component.article.routes.GetOneArticle.ArticleRequest.Output
 import fr.dcproject.component.auth.citizenOrNull
 import fr.dcproject.component.opinion.dto.Opinionable
+import fr.dcproject.component.views.dto.Viewable
+import fr.dcproject.component.views.entity.ViewAggregation
 import fr.dcproject.component.vote.dto.Votable
 import fr.dcproject.dto.CreatedAt
 import fr.dcproject.dto.Versionable
-import fr.dcproject.dto.Viewable
 import fr.dcproject.security.assert
 import io.ktor.application.call
 import io.ktor.features.NotFoundException
@@ -34,7 +35,7 @@ object GetOneArticle {
 
         class Output(
             article: ArticleForView,
-            views: fr.dcproject.entity.ViewAggregation = fr.dcproject.entity.ViewAggregation()
+            views: ViewAggregation = ViewAggregation()
         ) : CreatedAt by CreatedAt.Imp(article),
             Opinionable by Opinionable.Imp(article),
             Votable by Votable.Imp(article),

src/main/kotlin/component/constitution/Constitution.kt

@@ -0,0 +1,82 @@
+package fr.dcproject.component.constitution
+
+import fr.dcproject.component.article.ArticleForListing
+import fr.dcproject.component.article.ArticleI
+import fr.dcproject.component.citizen.CitizenSimple
+import fr.dcproject.component.citizen.CitizenWithUserI
+import fr.dcproject.component.constitution.ConstitutionSimple.TitleSimple
+import fr.dcproject.entity.TargetI
+import fr.dcproject.entity.TargetRef
+import fr.postgresjson.entity.EntityCreatedAt
+import fr.postgresjson.entity.EntityCreatedAtImp
+import fr.postgresjson.entity.EntityCreatedBy
+import fr.postgresjson.entity.EntityCreatedByImp
+import fr.postgresjson.entity.EntityDeletedAt
+import fr.postgresjson.entity.EntityDeletedAtImp
+import fr.postgresjson.entity.EntityVersioning
+import fr.postgresjson.entity.UuidEntity
+import fr.postgresjson.entity.UuidEntityVersioning
+import java.util.UUID
+
+class Constitution(
+    id: UUID = UUID.randomUUID(),
+    title: String,
+    anonymous: Boolean = true,
+    titles: MutableList<TitleSimple<ArticleForListing>> = mutableListOf(),
+    draft: Boolean = false,
+    lastVersion: Boolean = false,
+    override val createdBy: CitizenSimple
+) : ConstitutionSimple<CitizenSimple, TitleSimple<ArticleForListing>>(
+    id,
+    title = title,
+    anonymous = anonymous,
+    titles = titles,
+    draft = draft,
+    lastVersion = lastVersion,
+    createdBy = createdBy
+) {
+
+    class Title(
+        id: UUID = UUID.randomUUID(),
+        name: String,
+        rank: Int? = null,
+        override val articles: MutableList<ArticleForListing> = mutableListOf()
+    ) : TitleSimple<ArticleForListing>(id, name, rank)
+}
+
+open class ConstitutionSimple<Cr : CitizenWithUserI, T : TitleSimple<*>>(
+    id: UUID = UUID.randomUUID(),
+    val title: String,
+    val anonymous: Boolean = true,
+    val titles: MutableList<T> = mutableListOf(),
+    val draft: Boolean = false,
+    val lastVersion: Boolean = false,
+    override val createdBy: Cr,
+    versionId: UUID = UUID.randomUUID()
+) : ConstitutionRef(id),
+    EntityVersioning<UUID, Int> by UuidEntityVersioning(versionId = versionId, versionNumber = 0),
+    EntityCreatedAt by EntityCreatedAtImp(),
+    EntityCreatedBy<Cr> by EntityCreatedByImp(createdBy),
+    EntityDeletedAt by EntityDeletedAtImp() {
+
+    init {
+        titles.forEachIndexed { index, title ->
+            title.rank = index
+        }
+    }
+
+    open class TitleSimple<A : ArticleI>(
+        id: UUID = UUID.randomUUID(),
+        var name: String,
+        var rank: Int? = null,
+        open val articles: MutableList<A> = mutableListOf()
+    ) : TitleRef(id)
+}
+
+open class ConstitutionRef(id: UUID = UUID.randomUUID()) : ConstitutionS(id) {
+    open class TitleRef(
+        id: UUID = UUID.randomUUID()
+    ) : UuidEntity(id)
+}
+
+sealed class ConstitutionS(id: UUID = UUID.randomUUID()) : TargetRef(id), TargetI

src/main/kotlin/component/constitution/ConstitutionAccessControl.kt

@@ -0,0 +1,32 @@
+package fr.dcproject.component.constitution
+
+import fr.dcproject.component.citizen.CitizenI
+import fr.dcproject.security.AccessControl
+import fr.dcproject.security.AccessResponse
+
+class ConstitutionAccessControl : AccessControl() {
+    fun canCreate(subject: ConstitutionS, citizen: CitizenI?): AccessResponse = when {
+        citizen == null -> denied("You must be connected to create constitution", "constitution.create.notConnected")
+        else -> granted()
+    }
+
+    fun <S : ConstitutionSimple<*, *>> canView(subjects: List<S>, citizen: CitizenI?): AccessResponse =
+        canAll(subjects) { canView(it, citizen) }
+
+    fun canView(subject: ConstitutionSimple<*, *>, citizen: CitizenI?): AccessResponse = when {
+        subject.isDeleted() -> denied("You cannot view a deleted constitution", "constitution.view.deleted")
+        else -> granted()
+    }
+
+    fun canDelete(subject: ConstitutionSimple<*, *>, citizen: CitizenI?): AccessResponse = when {
+        citizen == null -> denied("You must be connected to delete constitution", "constitution.delete.notConnected")
+        subject.createdBy.id != citizen.id -> denied("You cannot delete the constitution of other citizen", "constitution.delete.otherCitizen")
+        else -> granted()
+    }
+
+    fun canUpdate(subject: ConstitutionSimple<*, *>, citizen: CitizenI?): AccessResponse = when {
+        citizen == null -> denied("You must be connected to update constitution", "constitution.update.notConnected")
+        subject.createdBy.id != citizen.id -> denied("You cannot update the constitution of other citizen", "constitution.update.otherCitizen")
+        else -> granted()
+    }
+}

src/main/kotlin/component/constitution/ConstitutionRepository.kt

@@ -0,0 +1,43 @@
+package fr.dcproject.component.constitution
+
+import fr.dcproject.component.article.ArticleRef
+import fr.dcproject.component.citizen.CitizenWithUserI
+import fr.dcproject.component.constitution.ConstitutionSimple.TitleSimple
+import fr.postgresjson.connexion.Paginated
+import fr.postgresjson.connexion.Requester
+import fr.postgresjson.repository.RepositoryI
+import fr.postgresjson.repository.RepositoryI.Direction
+import net.pearx.kasechange.toSnakeCase
+import java.util.UUID
+import fr.dcproject.component.constitution.Constitution as ConstitutionEntity
+
+class ConstitutionRepository(override var requester: Requester) : RepositoryI {
+    fun findById(id: UUID): ConstitutionEntity? {
+        val function = requester.getFunction("find_constitution_by_id")
+        return function.selectOne("id" to id)
+    }
+
+    fun find(
+        page: Int = 1,
+        limit: Int = 50,
+        sort: String? = null,
+        direction: Direction? = null,
+        search: String? = null
+    ): Paginated<ConstitutionEntity> {
+        return requester
+            .getFunction("find_constitutions")
+            .select(
+                page,
+                limit,
+                "sort" to sort?.toSnakeCase(),
+                "direction" to direction,
+                "search" to search
+            )
+    }
+
+    fun upsert(constitution: ConstitutionSimple<CitizenWithUserI, TitleSimple<ArticleRef>>): ConstitutionEntity? {
+        return requester
+            .getFunction("upsert_constitution")
+            .selectOne("resource" to constitution)
+    }
+}

src/main/kotlin/component/constitution/routes/CreateConstitution.kt

@@ -0,0 +1,82 @@
+package fr.dcproject.component.constitution.routes
+
+import fr.dcproject.component.article.ArticleRef
+import fr.dcproject.component.auth.citizen
+import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.citizen.Citizen
+import fr.dcproject.component.citizen.CitizenWithUserI
+import fr.dcproject.component.constitution.ConstitutionAccessControl
+import fr.dcproject.component.constitution.ConstitutionRepository
+import fr.dcproject.component.constitution.ConstitutionSimple
+import fr.dcproject.component.constitution.ConstitutionSimple.TitleSimple
+import fr.dcproject.component.constitution.routes.CreateConstitution.PostConstitutionRequest.Input
+import fr.dcproject.component.constitution.routes.CreateConstitution.PostConstitutionRequest.Input.Title
+import fr.dcproject.security.assert
+import fr.postgresjson.entity.UuidEntity
+import io.ktor.application.call
+import io.ktor.locations.KtorExperimentalLocationsAPI
+import io.ktor.locations.Location
+import io.ktor.locations.post
+import io.ktor.request.receive
+import io.ktor.response.respond
+import io.ktor.routing.Route
+import java.util.UUID
+
+@KtorExperimentalLocationsAPI
+object CreateConstitution {
+    @Location("/constitutions")
+    class PostConstitutionRequest {
+        class Input(
+            var title: String,
+            var anonymous: Boolean = true,
+            var titles: MutableList<Title> = mutableListOf(),
+            var draft: Boolean = false,
+            var lastVersion: Boolean = false,
+            var versionId: UUID = UUID.randomUUID()
+        ) {
+            init {
+                titles.forEachIndexed { index, title ->
+                    title.rank = index
+                }
+            }
+
+            class Title(
+                id: UUID = UUID.randomUUID(),
+                var name: String,
+                var rank: Int? = null,
+                var articles: MutableList<ArticleRef> = mutableListOf()
+            ) : UuidEntity(id)
+        }
+    }
+
+    private fun getNewConstitution(input: Input, citizen: Citizen) = input.run {
+        ConstitutionSimple<CitizenWithUserI, TitleSimple<ArticleRef>>(
+            id = UUID.randomUUID(),
+            title = title,
+            titles = titles.create(),
+            createdBy = citizen,
+            versionId = versionId
+        )
+    }
+
+    private fun List<Title>.create(): MutableList<TitleSimple<ArticleRef>> =
+        map { it.create() }.toMutableList()
+
+    private fun Title.create(): TitleSimple<ArticleRef> =
+        TitleSimple(
+            id,
+            name,
+            rank,
+            articles
+        )
+
+    fun Route.createConstitution(repo: ConstitutionRepository, ac: ConstitutionAccessControl) {
+        post<PostConstitutionRequest> {
+            getNewConstitution(call.receive(), citizen).let {
+                ac.assert { canCreate(it, citizenOrNull) }
+                repo.upsert(it)
+                call.respond(it)
+            }
+        }
+    }
+}

src/main/kotlin/component/constitution/routes/FindConstitutions.kt

@@ -0,0 +1,35 @@
+package fr.dcproject.component.constitution.routes
+
+import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.constitution.ConstitutionAccessControl
+import fr.dcproject.component.constitution.ConstitutionRepository
+import fr.dcproject.routes.PaginatedRequest
+import fr.dcproject.routes.PaginatedRequestI
+import fr.dcproject.security.assert
+import fr.postgresjson.repository.RepositoryI
+import io.ktor.application.call
+import io.ktor.locations.KtorExperimentalLocationsAPI
+import io.ktor.locations.Location
+import io.ktor.locations.get
+import io.ktor.response.respond
+import io.ktor.routing.Route
+
+@KtorExperimentalLocationsAPI
+object FindConstitutions {
+    @Location("/constitutions")
+    class FindConstitutionsRequest(
+        page: Int = 1,
+        limit: Int = 50,
+        val sort: String? = null,
+        val direction: RepositoryI.Direction? = null,
+        val search: String? = null
+    ) : PaginatedRequestI by PaginatedRequest(page, limit)
+
+    fun Route.findConstitutions(repo: ConstitutionRepository, ac: ConstitutionAccessControl) {
+        get<FindConstitutionsRequest> {
+            val constitutions = repo.find(it.page, it.limit, it.sort, it.direction, it.search)
+            ac.assert { canView(constitutions.result, citizenOrNull) }
+            call.respond(constitutions)
+        }
+    }
+}

src/main/kotlin/component/constitution/routes/GetConstitution.kt

@@ -0,0 +1,25 @@
+package fr.dcproject.component.constitution.routes
+
+import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.constitution.ConstitutionAccessControl
+import fr.dcproject.security.assert
+import io.ktor.application.call
+import io.ktor.locations.KtorExperimentalLocationsAPI
+import io.ktor.locations.Location
+import io.ktor.locations.get
+import io.ktor.response.respond
+import io.ktor.routing.Route
+import fr.dcproject.component.constitution.Constitution as ConstitutionEntity
+
+@KtorExperimentalLocationsAPI
+object GetConstitution {
+    @Location("/constitutions/{constitution}")
+    class GetConstitutionRequest(val constitution: ConstitutionEntity)
+
+    fun Route.getConstitution(ac: ConstitutionAccessControl) {
+        get<GetConstitutionRequest> {
+            ac.assert { canView(it.constitution, citizenOrNull) }
+            call.respond(it.constitution)
+        }
+    }
+}

src/main/kotlin/component/constitution/routes/install.kt

@@ -0,0 +1,18 @@
+package fr.dcproject.component.constitution.routes
+
+import fr.dcproject.component.constitution.routes.CreateConstitution.createConstitution
+import fr.dcproject.component.constitution.routes.FindConstitutions.findConstitutions
+import fr.dcproject.component.constitution.routes.GetConstitution.getConstitution
+import io.ktor.auth.authenticate
+import io.ktor.locations.KtorExperimentalLocationsAPI
+import io.ktor.routing.Routing
+import org.koin.ktor.ext.get
+
+@KtorExperimentalLocationsAPI
+fun Routing.installConstitutionRoutes() {
+    authenticate(optional = true) {
+        getConstitution(get())
+        findConstitutions(get(), get())
+        createConstitution(get(), get())
+    }
+}

src/main/kotlin/component/follow/FollowRepository.kt

@@ -4,7 +4,7 @@ import fr.dcproject.component.article.ArticleForView
 import fr.dcproject.component.article.ArticleRef
 import fr.dcproject.component.citizen.CitizenI
 import fr.dcproject.component.citizen.CitizenRef
-import fr.dcproject.entity.ConstitutionRef
+import fr.dcproject.component.constitution.ConstitutionRef
 import fr.dcproject.entity.TargetRef
 import fr.postgresjson.connexion.Paginated
 import fr.postgresjson.connexion.Requester
@@ -13,8 +13,8 @@ import fr.postgresjson.repository.RepositoryI
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
 import java.util.UUID
+import fr.dcproject.component.constitution.Constitution as ConstitutionEntity
 import fr.dcproject.component.follow.Follow as FollowEntity
-import fr.dcproject.entity.Constitution as ConstitutionEntity
 
 sealed class FollowRepository<IN : TargetRef, OUT : TargetRef>(override var requester: Requester) : RepositoryI {
     open fun findByCitizen(

src/main/kotlin/component/follow/routes/constitution/FollowConstitution.kt

@@ -2,10 +2,10 @@ package fr.dcproject.component.follow.routes.constitution
 
 import fr.dcproject.component.auth.citizen
 import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.constitution.ConstitutionRef
 import fr.dcproject.component.follow.FollowAccessControl
 import fr.dcproject.component.follow.FollowConstitutionRepository
 import fr.dcproject.component.follow.FollowForUpdate
-import fr.dcproject.entity.ConstitutionRef
 import fr.dcproject.security.assert
 import io.ktor.application.call
 import io.ktor.http.HttpStatusCode

src/main/kotlin/component/follow/routes/constitution/GetFollowConstitution.kt

@@ -2,9 +2,9 @@ package fr.dcproject.component.follow.routes.constitution
 
 import fr.dcproject.component.auth.citizen
 import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.constitution.ConstitutionRef
 import fr.dcproject.component.follow.FollowAccessControl
 import fr.dcproject.component.follow.FollowConstitutionRepository
-import fr.dcproject.entity.ConstitutionRef
 import fr.dcproject.security.assert
 import io.ktor.application.call
 import io.ktor.http.HttpStatusCode

src/main/kotlin/component/follow/routes/constitution/UnfollowConstitution.kt

@@ -2,10 +2,10 @@ package fr.dcproject.component.follow.routes.constitution
 
 import fr.dcproject.component.auth.citizen
 import fr.dcproject.component.auth.citizenOrNull
+import fr.dcproject.component.constitution.ConstitutionRef
 import fr.dcproject.component.follow.FollowAccessControl
 import fr.dcproject.component.follow.FollowConstitutionRepository
 import fr.dcproject.component.follow.FollowForUpdate
-import fr.dcproject.entity.ConstitutionRef
 import fr.dcproject.security.assert
 import io.ktor.application.call
 import io.ktor.http.HttpStatusCode

src/main/kotlin/component/views/ViewManager.kt

@@ -1,7 +1,7 @@
 package fr.dcproject.component.views
 
 import fr.dcproject.component.citizen.CitizenI
-import fr.dcproject.entity.ViewAggregation
+import fr.dcproject.component.views.entity.ViewAggregation
 import org.elasticsearch.client.Response
 import org.joda.time.DateTime
 

src/main/kotlin/component/views/dto/ViewAggregation.kt

@@ -0,0 +1,10 @@
+package fr.dcproject.component.views.dto
+
+import fr.dcproject.component.views.entity.ViewAggregation
+
+class ViewAggregation(
+    val total: Int,
+    val unique: Int
+) {
+    constructor(views: ViewAggregation) : this(views.total, views.unique)
+}

src/main/kotlin/component/views/dto/Viewable.kt

@@ -0,0 +1,9 @@
+package fr.dcproject.component.views.dto
+
+interface Viewable {
+    var views: ViewAggregation
+
+    class Imp(views: fr.dcproject.component.views.entity.ViewAggregation) : Viewable {
+        override var views: ViewAggregation = ViewAggregation(views.total, views.unique)
+    }
+}

src/main/kotlin/component/views/entity/ViewAggregation.kt

@@ -0,0 +1,13 @@
+package fr.dcproject.component.views.entity
+
+import fr.postgresjson.entity.EntityI
+import fr.postgresjson.entity.EntityUpdatedAt
+import fr.postgresjson.entity.EntityUpdatedAtImp
+
+class ViewAggregation(
+    val total: Int,
+    val unique: Int
+) : EntityI,
+    EntityUpdatedAt by EntityUpdatedAtImp() {
+    constructor() : this(0, 0)
+}

src/main/kotlin/component/vote/VoteRepositoryAbs.kt

@@ -4,9 +4,9 @@ import com.fasterxml.jackson.core.type.TypeReference
 import fr.dcproject.component.article.ArticleForView
 import fr.dcproject.component.citizen.CitizenRef
 import fr.dcproject.component.comment.generic.CommentForView
+import fr.dcproject.component.constitution.Constitution
 import fr.dcproject.component.vote.entity.VoteAggregation
 import fr.dcproject.component.vote.entity.VoteForUpdateI
-import fr.dcproject.entity.Constitution
 import fr.dcproject.entity.TargetI
 import fr.dcproject.entity.TargetRef
 import fr.postgresjson.connexion.Paginated

src/main/kotlin/component/vote/routes/VoteConstitution.kt

@@ -15,7 +15,7 @@ import io.ktor.locations.put
 import io.ktor.request.receive
 import io.ktor.response.respond
 import io.ktor.routing.Route
-import fr.dcproject.entity.Constitution as ConstitutionEntity
+import fr.dcproject.component.constitution.Constitution as ConstitutionEntity
 
 @KtorExperimentalLocationsAPI
 object VoteConstitution {