-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
346 changed files
with
21,987 additions
and
267 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
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
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
267 changes: 267 additions & 0 deletions
267
app/src/main/java/dev/dimension/flare/data/database/cache/mapper/Misskey.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,267 @@ | ||
| package dev.dimension.flare.data.database.cache.mapper | ||
|
|
||
| import androidx.room.withTransaction | ||
| import dev.dimension.flare.data.database.cache.CacheDatabase | ||
| import dev.dimension.flare.data.database.cache.model.DbPagingTimeline | ||
| import dev.dimension.flare.data.database.cache.model.DbPagingTimelineWithStatus | ||
| import dev.dimension.flare.data.database.cache.model.DbStatus | ||
| import dev.dimension.flare.data.database.cache.model.DbStatusWithReference | ||
| import dev.dimension.flare.data.database.cache.model.DbStatusWithUser | ||
| import dev.dimension.flare.data.database.cache.model.DbUser | ||
| import dev.dimension.flare.data.database.cache.model.StatusContent | ||
| import dev.dimension.flare.data.database.cache.model.UserContent | ||
| import dev.dimension.flare.data.network.misskey.api.model.Note | ||
| import dev.dimension.flare.data.network.misskey.api.model.Notification | ||
| import dev.dimension.flare.data.network.misskey.api.model.User | ||
| import dev.dimension.flare.data.network.misskey.api.model.UserLite | ||
| import dev.dimension.flare.model.MicroBlogKey | ||
| import dev.dimension.flare.model.PlatformType | ||
| import dev.dimension.flare.model.ReferenceType | ||
| import java.util.UUID | ||
| import kotlinx.datetime.toInstant | ||
|
|
||
| context(CacheDatabase, List<Note>) | ||
| suspend fun save( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| sortIdProvider: (Note) -> Long = { it.createdAt.toInstant().toEpochMilliseconds() } | ||
| ) { | ||
| val data = toDbPagingTimeline(accountKey, pagingKey, emojis, sortIdProvider) | ||
| with(data) { | ||
| saveDbPagingTimelineWithStatus() | ||
| } | ||
| } | ||
|
|
||
|
|
||
| context(CacheDatabase, List<Notification>) | ||
| suspend fun saveNotification( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ) { | ||
| val data = toDb(accountKey, pagingKey, emojis) | ||
| with(data) { | ||
| saveDbPagingTimelineWithStatus() | ||
| } | ||
| } | ||
|
|
||
| context(CacheDatabase, List<DbPagingTimelineWithStatus>) | ||
| suspend fun saveDbPagingTimelineWithStatus() { | ||
| withTransaction { | ||
| ( | ||
| mapNotNull { it.status.status.user } + flatMap { it.status.references } | ||
| .mapNotNull { it.status.user } | ||
| ).let { allUsers -> | ||
| val exsitingUsers = userDao() | ||
| .findByKeys(allUsers.map { it.userKey }) | ||
| .filter { | ||
| it.content is UserContent.Misskey | ||
| }.map { | ||
| val content = it.content as UserContent.Misskey | ||
| val user = allUsers.find { user -> | ||
| user.userKey == it.userKey | ||
| } | ||
|
|
||
| if (user != null && user.content is UserContent.MisskeyLite) { | ||
| it.copy( | ||
| content = content.copy( | ||
| data = content.data.copy( | ||
| name = user.content.data.name, | ||
| username = user.content.data.username, | ||
| avatarUrl = user.content.data.avatarUrl, | ||
| ) | ||
| ) | ||
| ) | ||
| } else { | ||
| it | ||
| } | ||
| } | ||
|
|
||
| val result = (allUsers + exsitingUsers).distinctBy { it.userKey } | ||
| userDao().insertAll(result) | ||
| } | ||
| ( | ||
| map { it.status.status.data } + flatMap { it.status.references } | ||
| .map { it.status.data } | ||
| ).let { | ||
| statusDao().insertAll(it) | ||
| } | ||
| flatMap { it.status.references }.map { it.reference }.let { | ||
| statusReferenceDao().insertAll(it) | ||
| } | ||
| pagingTimelineDao().insertAll(map { it.timeline }) | ||
| } | ||
| } | ||
|
|
||
| fun List<Notification>.toDb( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): List<DbPagingTimelineWithStatus> { | ||
| return this.map { | ||
| it.toDbPagingTimeline(accountKey, pagingKey, emojis) | ||
| } | ||
| } | ||
|
|
||
| private fun Notification.toDbPagingTimeline( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbPagingTimelineWithStatus { | ||
| val status = this.toDbStatusWithReference(accountKey, emojis) | ||
| val sortId = this.createdAt.toInstant().toEpochMilliseconds() | ||
| return DbPagingTimelineWithStatus( | ||
| timeline = DbPagingTimeline( | ||
| _id = UUID.randomUUID().toString(), | ||
| accountKey = accountKey, | ||
| statusKey = MicroBlogKey( | ||
| this.id, | ||
| accountKey.host | ||
| ), | ||
| pagingKey = pagingKey, | ||
| sortId = sortId | ||
| ), | ||
| status = status | ||
| ) | ||
| } | ||
|
|
||
| private fun Notification.toDbStatusWithReference( | ||
| accountKey: MicroBlogKey, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbStatusWithReference { | ||
| val status = this.toDbStatusWithUser(accountKey, emojis) | ||
| val retweet = this.note?.toDbStatusWithUser(accountKey, emojis) | ||
| return DbStatusWithReference( | ||
| status = status, | ||
| references = listOfNotNull( | ||
| retweet?.toDbStatusReference(status.data.statusKey, ReferenceType.MisskeyNotification) | ||
| ) | ||
| ) | ||
| } | ||
|
|
||
| private fun Notification.toDbStatusWithUser( | ||
| accountKey: MicroBlogKey, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbStatusWithUser { | ||
| val user = this.user?.toDbUser(accountKey.host, emojis) | ||
| val status = this.toDbStatus(accountKey, emojis) | ||
| return DbStatusWithUser( | ||
| data = status, | ||
| user = user | ||
| ) | ||
| } | ||
|
|
||
| private fun Notification.toDbStatus( | ||
| accountKey: MicroBlogKey, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbStatus { | ||
| val user = this.user?.toDbUser(accountKey.host, emojis) | ||
| return DbStatus( | ||
| statusKey = MicroBlogKey( | ||
| this.id, | ||
| accountKey.host | ||
| ), | ||
| platformType = PlatformType.Misskey, | ||
| userKey = user?.userKey, | ||
| content = StatusContent.MisskeyNotification(this, emojis), | ||
| accountKey = accountKey | ||
| ) | ||
| } | ||
|
|
||
| private fun List<Note>.toDbPagingTimeline( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emoji: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| sortIdProvider: (Note) -> Long = { it.createdAt.toInstant().toEpochMilliseconds() } | ||
| ): List<DbPagingTimelineWithStatus> { | ||
| return this.map { | ||
| it.toDbPagingTimeline(accountKey, pagingKey, emoji, sortIdProvider) | ||
| } | ||
| } | ||
|
|
||
|
|
||
| private fun Note.toDbPagingTimeline( | ||
| accountKey: MicroBlogKey, | ||
| pagingKey: String, | ||
| emoji: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| sortIdProvider: (Note) -> Long = { it.createdAt.toInstant().toEpochMilliseconds() } | ||
| ): DbPagingTimelineWithStatus { | ||
| val status = this.toDbStatusWithReference(accountKey, emoji) | ||
| val sortId = sortIdProvider(this) | ||
| return DbPagingTimelineWithStatus( | ||
| timeline = DbPagingTimeline( | ||
| _id = UUID.randomUUID().toString(), | ||
| accountKey = accountKey, | ||
| statusKey = status.status.data.statusKey, | ||
| pagingKey = pagingKey, | ||
| sortId = sortId | ||
| ), | ||
| status = status | ||
| ) | ||
| } | ||
|
|
||
| private fun Note.toDbStatusWithReference( | ||
| accountKey: MicroBlogKey, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbStatusWithReference { | ||
| val status = this.toDbStatusWithUser(accountKey, emojis) | ||
| val retweet = this.renote?.toDbStatusWithUser(accountKey, emojis) | ||
| val reply = this.reply?.toDbStatusWithUser(accountKey, emojis) | ||
| return DbStatusWithReference( | ||
| status = status, | ||
| references = listOfNotNull( | ||
| retweet?.toDbStatusReference(status.data.statusKey, ReferenceType.Retweet), | ||
| reply?.toDbStatusReference(status.data.statusKey, ReferenceType.Reply) | ||
| ) | ||
| ) | ||
| } | ||
|
|
||
| private fun Note.toDbStatusWithUser( | ||
| accountKey: MicroBlogKey, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ): DbStatusWithUser { | ||
| val user = user.toDbUser(accountKey.host, emojis) | ||
| val status = DbStatus( | ||
| statusKey = MicroBlogKey( | ||
| id = id, | ||
| host = user.userKey.host | ||
| ), | ||
| platformType = PlatformType.Misskey, | ||
| content = StatusContent.Misskey(this, emojis), | ||
| userKey = user.userKey, | ||
| accountKey = accountKey | ||
| ) | ||
| return DbStatusWithUser( | ||
| data = status, | ||
| user = user | ||
| ) | ||
| } | ||
|
|
||
| private fun UserLite.toDbUser( | ||
| host: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ) = DbUser( | ||
| userKey = MicroBlogKey( | ||
| id = id, | ||
| host = host, | ||
| ), | ||
| platformType = dev.dimension.flare.model.PlatformType.Misskey, | ||
| name = name ?: "", | ||
| handle = username, | ||
| content = UserContent.MisskeyLite(this, emojis) | ||
| ) | ||
|
|
||
| fun User.toDbUser( | ||
| host: String, | ||
| emojis: List<dev.dimension.flare.data.network.misskey.api.model.EmojiSimple>, | ||
| ) = DbUser( | ||
| userKey = MicroBlogKey( | ||
| id = id, | ||
| host = host, | ||
| ), | ||
| platformType = dev.dimension.flare.model.PlatformType.Misskey, | ||
| name = name ?: "", | ||
| handle = username, | ||
| content = UserContent.Misskey(this, emojis) | ||
| ) |
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.