sync: preserve legacy identity during queue resets

app/src/main/kotlin/com/subtracks/data/repo/QueueRepository.kt

@@ -704,13 +704,13 @@ class QueueRepository(
                                 val positionMs = if (remappedCurrent != null && previousSongId == updatedSongId) row.positionMs else 0L
                                 dao.clear()
                                 dao.insert(
-                                    withOriginEntryIds(entries).mapIndexed { index, entry ->
+                                    withOriginEntryIds(entries, assignFragmentIds = false).mapIndexed { index, entry ->
                                         entry.copy(id = 0, position = index.toLong())
                                     },
                                 )
                                 dao.clearUpNext()
                                 dao.insertUpNext(
-                                    withOriginEntryIds(upNext).mapIndexed { index, entry ->
+                                    withOriginEntryIds(upNext, assignFragmentIds = false).mapIndexed { index, entry ->
                                         UpNextEntry.from(entry).copy(id = 0, position = index.toLong())
                                     },
                                 )
@@ -831,7 +831,7 @@ class QueueRepository(
     }
 
     private fun QueueEntry.shouldAssignOriginEntryId(assignFragmentIds: Boolean) =
-        originEntryId == null && (assignFragmentIds || isWholeOrigin())
+        originEntryId == null && (assignFragmentIds || isWholeOrigin() || id == 0L)
 
     private fun withOriginEntryIds(
         entries: List<QueueEntry>,

app/src/test/kotlin/com/subtracks/data/db/MigrationsTest.kt

@@ -11,6 +11,7 @@ import com.subtracks.data.model.PlaylistSong
 import com.subtracks.data.model.QueueKind
 import com.subtracks.data.model.QueueOrigin
 import com.subtracks.data.repo.QueueRepository
+import com.subtracks.data.repo.QueueResetPreparation
 import com.subtracks.data.repo.removeAt
 import com.subtracks.data.repo.replace
 import kotlinx.coroutines.test.runTest
@@ -592,7 +593,10 @@ class MigrationsTest {
                 repository.setCursor(2)
                 val point = repository.captureResetPoint()
                 var resets = 0
-                repository.setResetListener { resets++ }
+                repository.setResetListener {
+                    resets++
+                    QueueResetPreparation(it.snapshot)
+                }
                 db.libraryDao().deletePlaylistSongsFrom(1, "p1", 0)
                 db.libraryDao().upsertPlaylistSongs(
                     listOf(

app/src/test/kotlin/com/subtracks/data/repo/QueueRepositoryTest.kt

@@ -474,6 +474,9 @@ class QueueRepositoryTest {
             repository.removeAt(snapshot, 0)
 
             assertEquals(listOf("s2", "s3"), resolveAll(repository.snapshot()))
+        }
+
+    @Test
     fun aMatchingOriginStillPublishesWhenItsEntriesDoNotChange() =
         runTest {
             seedLibrary()