-
-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #8 from groupeminaste/feature/posts
Posts
- Loading branch information
Showing
18 changed files
with
1,085 additions
and
81 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
20 changes: 18 additions & 2 deletions
20
extopy-backend/src/commonMain/kotlin/me/nathanfallet/extopy/controllers/posts/PostsRouter.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,20 @@ | ||
| package me.nathanfallet.extopy.controllers.posts | ||
|
|
||
| class PostsRouter { | ||
| } | ||
| import me.nathanfallet.extopy.models.posts.Post | ||
| import me.nathanfallet.extopy.models.posts.PostPayload | ||
| import me.nathanfallet.ktorx.controllers.IModelController | ||
| import me.nathanfallet.ktorx.models.api.APIMapping | ||
| import me.nathanfallet.ktorx.routers.api.APIModelRouter | ||
|
|
||
| class PostsRouter( | ||
| postsController: IModelController<Post, String, PostPayload, PostPayload>, | ||
| ) : APIModelRouter<Post, String, PostPayload, PostPayload>( | ||
| Post::class, | ||
| PostPayload::class, | ||
| PostPayload::class, | ||
| postsController, | ||
| mapping = APIMapping( | ||
| listEnabled = false | ||
| ), | ||
| prefix = "/api/v1" | ||
| ) |
98 changes: 98 additions & 0 deletions
98
...nd/src/commonMain/kotlin/me/nathanfallet/extopy/database/posts/DatabasePostsRepository.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| package me.nathanfallet.extopy.database.posts | ||
|
|
||
| import kotlinx.datetime.Clock | ||
| import me.nathanfallet.extopy.database.Database | ||
| import me.nathanfallet.extopy.database.users.Users | ||
| import me.nathanfallet.extopy.models.posts.Post | ||
| import me.nathanfallet.extopy.models.posts.PostPayload | ||
| import me.nathanfallet.extopy.models.users.UserContext | ||
| import me.nathanfallet.extopy.repositories.posts.IPostsRepository | ||
| import me.nathanfallet.usecases.context.IContext | ||
| import org.jetbrains.exposed.sql.* | ||
|
|
||
| class DatabasePostsRepository( | ||
| private val database: Database, | ||
| ) : IPostsRepository { | ||
|
|
||
| override suspend fun get(id: String, context: IContext?): Post? { | ||
| if (context !is UserContext) return null | ||
| return database.dbQuery { | ||
| customJoin(context.userId) | ||
| .select { Posts.id eq id } | ||
| .groupBy(Posts.id) | ||
| .map { Posts.toPost(it, Users.toUser(it)) } | ||
| .singleOrNull() | ||
| } | ||
| } | ||
|
|
||
| override suspend fun create(payload: PostPayload, context: IContext?): Post? { | ||
| if (context !is UserContext) return null | ||
| val id = database.dbQuery { | ||
| val id = Posts.generateId() | ||
| Posts.insert { | ||
| it[Posts.id] = id | ||
| it[userId] = context.userId | ||
| it[repliedToId] = payload.repliedToId | ||
| it[repostOfId] = payload.repostOfId | ||
| it[body] = payload.body | ||
| it[published] = Clock.System.now().toString() | ||
| it[edited] = null | ||
| it[expiration] = Clock.System.now().toString() | ||
| it[visibility] = "" | ||
| } | ||
| id | ||
| } | ||
| return get(id, context) | ||
| } | ||
|
|
||
| override suspend fun update(id: String, payload: PostPayload, context: IContext?): Boolean { | ||
| return database.dbQuery { | ||
| Posts.update({ Posts.id eq id }) { | ||
| it[body] = payload.body | ||
| it[edited] = Clock.System.now().toString() | ||
| } | ||
| } == 1 | ||
| } | ||
|
|
||
| override suspend fun delete(id: String, context: IContext?): Boolean { | ||
| return database.dbQuery { | ||
| Posts.deleteWhere { | ||
| Op.build { Posts.id eq id } | ||
| } | ||
| } == 1 | ||
| } | ||
|
|
||
| private fun customJoin(viewedBy: String): FieldSet { | ||
| return customJoinColumnSet(viewedBy).customPostsSlice() | ||
| } | ||
|
|
||
| private fun customJoinColumnSet(viewedBy: String): ColumnSet { | ||
| return Posts.join(Users, JoinType.INNER, Posts.userId, Users.id) | ||
| .join(LikesInPosts, JoinType.LEFT, Posts.id, LikesInPosts.postId) | ||
| .join(Posts.replies, JoinType.LEFT, Posts.id, Posts.replies[Posts.repliedToId]) | ||
| .join(Posts.reposts, JoinType.LEFT, Posts.id, Posts.reposts[Posts.repostOfId]) | ||
| .join( | ||
| LikesInPosts.likesIn, | ||
| JoinType.LEFT, | ||
| Posts.id, | ||
| LikesInPosts.likesIn[LikesInPosts.postId] | ||
| ) { LikesInPosts.likesIn[LikesInPosts.userId] eq viewedBy } | ||
| } | ||
|
|
||
| private fun ColumnSet.customPostsSlice(additionalFields: List<Expression<*>> = listOf()): FieldSet { | ||
| return slice( | ||
| Posts.columns + | ||
| Users.id + | ||
| Users.displayName + | ||
| Users.username + | ||
| Users.avatar + | ||
| Users.verified + | ||
| Posts.likesCount + | ||
| Posts.repliesCount + | ||
| Posts.repostsCount + | ||
| Posts.likesIn + | ||
| additionalFields | ||
| ) | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.