-
Notifications
You must be signed in to change notification settings - Fork 369
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Attempt to recover the old book positions.
- Loading branch information
1 parent
7b4aa3c
commit 4317014
Showing
5 changed files
with
224 additions
and
92 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
147 changes: 147 additions & 0 deletions
147
scanner/src/main/kotlin/voice/app/scanner/BookParser.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,147 @@ | ||
| package voice.app.scanner | ||
|
|
||
| import android.app.Application | ||
| import android.net.Uri | ||
| import androidx.documentfile.provider.DocumentFile | ||
| import voice.common.BookId | ||
| import voice.data.Book | ||
| import voice.data.BookContent | ||
| import voice.data.Bookmark | ||
| import voice.data.Chapter | ||
| import voice.data.repo.BookContentRepo | ||
| import voice.data.repo.internals.dao.BookmarkDao | ||
| import voice.data.repo.internals.dao.LegacyBookDao | ||
| import voice.data.toUri | ||
| import voice.logging.core.Logger | ||
| import java.io.File | ||
| import java.time.Instant | ||
| import javax.inject.Inject | ||
|
|
||
| class BookParser | ||
| @Inject constructor( | ||
| private val contentRepo: BookContentRepo, | ||
| private val mediaAnalyzer: MediaAnalyzer, | ||
| private val legacyBookDao: LegacyBookDao, | ||
| private val application: Application, | ||
| private val bookmarkDao: BookmarkDao, | ||
| ) { | ||
|
|
||
| suspend fun getOrPut(chapters: List<Chapter>, file: DocumentFile): BookContent { | ||
| val id = BookId(file.uri) | ||
| return contentRepo.getOrPut(id) { | ||
| val analyzed = mediaAnalyzer.analyze(chapters.first().id.toUri()) | ||
|
|
||
| val filePath = file.uri.filePath() | ||
| val migrationMetaData = filePath?.let { | ||
| legacyBookDao.bookMetaData() | ||
| .find { metadata -> metadata.root.endsWith(it) } | ||
| } | ||
| val migrationSettings = migrationMetaData?.let { | ||
| legacyBookDao.settingsById(it.id) | ||
| } | ||
|
|
||
| if (migrationMetaData != null) { | ||
| val legacyChapters = legacyBookDao.chapters() | ||
| .filter { | ||
| it.bookId == migrationMetaData.id | ||
| } | ||
|
|
||
| val legacyBookmarks = legacyBookDao.bookmarksByFiles(legacyChapters.map { it.file }) | ||
| legacyBookmarks.forEach { legacyBookmark -> | ||
| val legacyChapter = legacyChapters.find { it.file == legacyBookmark.mediaFile } | ||
| if (legacyChapter != null) { | ||
| val matchingChapter = chapters.find { | ||
| val chapterFilePath = it.id.toUri().filePath() ?: return@find false | ||
| legacyChapter.file.absolutePath.endsWith(chapterFilePath) | ||
| } | ||
| if (matchingChapter != null) { | ||
| bookmarkDao.addBookmark( | ||
| Bookmark( | ||
| bookId = id, | ||
| addedAt = legacyBookmark.addedAt, | ||
| chapterId = matchingChapter.id, | ||
| id = Bookmark.Id.random(), | ||
| setBySleepTimer = legacyBookmark.setBySleepTimer, | ||
| time = legacyBookmark.time, | ||
| title = legacyBookmark.title, | ||
| ) | ||
| ) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| val (currentChapter, positionInChapter) = if (migrationSettings != null) { | ||
| val currentChapter = chapters.find { | ||
| val chapterFilePath = it.id.toUri().filePath() | ||
| if (chapterFilePath == null) { | ||
| false | ||
| } else { | ||
| migrationSettings.currentFile.absolutePath.endsWith(chapterFilePath) | ||
| } | ||
| } | ||
| if (currentChapter != null) { | ||
| currentChapter.id to migrationSettings.positionInChapter | ||
| } else { | ||
| chapters.first().id to 0L | ||
| } | ||
| } else { | ||
| chapters.first().id to 0L | ||
| } | ||
|
|
||
| BookContent( | ||
| id = id, | ||
| isActive = true, | ||
| addedAt = migrationMetaData?.addedAtMillis?.let(Instant::ofEpochMilli) | ||
| ?: Instant.now(), | ||
| author = analyzed?.author, | ||
| lastPlayedAt = migrationSettings?.lastPlayedAtMillis?.let(Instant::ofEpochMilli) | ||
| ?: Instant.EPOCH, | ||
| name = migrationMetaData?.name ?: analyzed?.bookName ?: file.bookName(), | ||
| playbackSpeed = migrationSettings?.playbackSpeed | ||
| ?: 1F, | ||
| skipSilence = migrationSettings?.skipSilence | ||
| ?: false, | ||
| chapters = chapters.map { it.id }, | ||
| positionInChapter = positionInChapter, | ||
| currentChapter = currentChapter, | ||
| cover = migrationSettings?.id?.let { | ||
| File(application.filesDir, id.toString()) | ||
| .takeIf { it.canRead() } | ||
| } | ||
| ).also { | ||
| validateIntegrity(it, chapters) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private fun DocumentFile.bookName(): String { | ||
| val fileName = name | ||
| return if (fileName == null) { | ||
| uri.toString() | ||
| .removePrefix("/storage/emulated/0/") | ||
| .removePrefix("/storage/emulated/") | ||
| .removePrefix("/storage/") | ||
| .also { | ||
| Logger.e("Could not parse fileName from $this. Fallback to $it") | ||
| } | ||
| } else { | ||
| if (isFile) { | ||
| fileName.substringBeforeLast(".") | ||
| } else { | ||
| fileName | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| internal fun validateIntegrity(content: BookContent, chapters: List<Chapter>) { | ||
| // the init block performs integrity validation | ||
| Book(content, chapters) | ||
| } | ||
|
|
||
| private fun Uri.filePath(): String? { | ||
| return pathSegments.lastOrNull() | ||
| ?.dropWhile { it != ':' } | ||
| ?.removePrefix(":") | ||
| } |
50 changes: 50 additions & 0 deletions
50
scanner/src/main/kotlin/voice/app/scanner/ChapterParser.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,50 @@ | ||
| package voice.app.scanner | ||
|
|
||
| import androidx.documentfile.provider.DocumentFile | ||
| import voice.data.Chapter | ||
| import voice.data.repo.ChapterRepo | ||
| import java.time.Instant | ||
| import javax.inject.Inject | ||
|
|
||
| class ChapterParser | ||
| @Inject constructor( | ||
| private val chapterRepo: ChapterRepo, | ||
| private val mediaAnalyzer: MediaAnalyzer, | ||
| ) { | ||
|
|
||
| suspend fun parse(documentFile: DocumentFile): List<Chapter> { | ||
| val result = mutableListOf<Chapter>() | ||
|
|
||
| suspend fun parseChapters(file: DocumentFile) { | ||
| val mimeType = file.type | ||
| if ( | ||
| file.isFile && | ||
| mimeType != null && | ||
| (mimeType.startsWith("audio/") || mimeType.startsWith("video/")) | ||
| ) { | ||
| val id = Chapter.Id(file.uri) | ||
| val chapter = chapterRepo.getOrPut(id, Instant.ofEpochMilli(file.lastModified())) { | ||
| val metaData = mediaAnalyzer.analyze(file.uri) ?: return@getOrPut null | ||
| Chapter( | ||
| id = id, | ||
| duration = metaData.duration, | ||
| fileLastModified = Instant.ofEpochMilli(file.lastModified()), | ||
| name = metaData.chapterName, | ||
| markData = metaData.chapters | ||
| ) | ||
| } | ||
| if (chapter != null) { | ||
| result.add(chapter) | ||
| } | ||
| } else if (file.isDirectory) { | ||
| file.listFiles() | ||
| .forEach { | ||
| parseChapters(it) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| parseChapters(file = documentFile) | ||
| return result.sorted() | ||
| } | ||
| } |
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