-
Notifications
You must be signed in to change notification settings - Fork 9
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 #23 from stefanmedack/feature/save_play_back_position
Feature/save play back position
- Loading branch information
Showing
34 changed files
with
549 additions
and
82 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
128 changes: 128 additions & 0 deletions
128
app/src/androidTest/java/de/stefanmedack/ccctv/persistence/PlayPositionDaoTest.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,128 @@ | ||
| package de.stefanmedack.ccctv.persistence | ||
|
|
||
| import android.arch.persistence.room.EmptyResultSetException | ||
| import android.database.sqlite.SQLiteException | ||
| import android.support.test.runner.AndroidJUnit4 | ||
| import de.stefanmedack.ccctv.getSingleTestResult | ||
| import de.stefanmedack.ccctv.minimalEventEntity | ||
| import de.stefanmedack.ccctv.persistence.entities.PlayPosition | ||
| import org.amshove.kluent.shouldBeInstanceOf | ||
| import org.amshove.kluent.shouldEqual | ||
| import org.amshove.kluent.shouldNotEqual | ||
| import org.junit.Before | ||
| import org.junit.Test | ||
| import org.junit.runner.RunWith | ||
| import org.threeten.bp.OffsetDateTime | ||
|
|
||
| @RunWith(AndroidJUnit4::class) | ||
| class PlayPositionDaoTest : BaseDbTest() { | ||
|
|
||
| @Before | ||
| fun setup() { | ||
| initDbWithConferenceAndEvent(conferenceId = 3, eventId = 8) | ||
| } | ||
|
|
||
| @Test | ||
| fun get_played_events_from_empty_table_returns_empty_list() { | ||
|
|
||
| val emptyList = playPositionDao.getPlayedEvents().getSingleTestResult() | ||
|
|
||
| emptyList shouldEqual listOf() | ||
| } | ||
|
|
||
| @Test | ||
| fun insert_play_position_without_matching_event_throws_exception() { | ||
| val exception = try { | ||
| playPositionDao.insert(PlayPosition(eventId = 42)) | ||
| } catch (ex: SQLiteException) { | ||
| ex | ||
| } | ||
|
|
||
| exception shouldNotEqual null | ||
| exception shouldBeInstanceOf SQLiteException::class | ||
| } | ||
|
|
||
| @Test | ||
| fun insert_and_retrieve_played_event() { | ||
| playPositionDao.insert(PlayPosition(eventId = 8)) | ||
|
|
||
| val playedEvents = playPositionDao.getPlayedEvents().getSingleTestResult() | ||
|
|
||
| playedEvents.size shouldEqual 1 | ||
| playedEvents.first().id shouldEqual 8 | ||
| } | ||
|
|
||
| @Test | ||
| fun loading_played_events_filters_not_played_events() { | ||
| eventDao.insert(minimalEventEntity.copy(conferenceId = 3, id = 42)) | ||
| playPositionDao.insert(PlayPosition(eventId = 42)) | ||
|
|
||
| val playedEvents = playPositionDao.getPlayedEvents().getSingleTestResult() | ||
|
|
||
| playedEvents.size shouldEqual 1 | ||
| playedEvents.first().id shouldEqual 42 | ||
| } | ||
|
|
||
| @Test | ||
| fun loading_played_events_should_deliver_the_latest_played_events_first() { | ||
| for (i in 42..44) { | ||
| eventDao.insert(minimalEventEntity.copy(conferenceId = 3, id = i)) | ||
| } | ||
| playPositionDao.insert(PlayPosition(eventId = 42, createdAt = OffsetDateTime.now().minusDays(1))) | ||
| playPositionDao.insert(PlayPosition(eventId = 43, createdAt = OffsetDateTime.now())) | ||
| playPositionDao.insert(PlayPosition(eventId = 44, createdAt = OffsetDateTime.now().minusDays(2))) | ||
|
|
||
| val playedEvents = playPositionDao.getPlayedEvents().getSingleTestResult() | ||
|
|
||
| playedEvents[0].id shouldEqual 43 | ||
| playedEvents[1].id shouldEqual 42 | ||
| playedEvents[2].id shouldEqual 44 | ||
| } | ||
|
|
||
| @Test | ||
| fun loading_playback_seconds_errors_for_not_played_events() { | ||
|
|
||
| val seconds = playPositionDao.getPlaybackSeconds(8).test().errors() | ||
|
|
||
| seconds.first() shouldBeInstanceOf EmptyResultSetException::class.java | ||
| } | ||
|
|
||
| @Test | ||
| fun loading_playback_seconds_returns_same_seconds_for_played_events() { | ||
| playPositionDao.insert(PlayPosition(eventId = 8, seconds = 123)) | ||
|
|
||
| val seconds = playPositionDao.getPlaybackSeconds(8).getSingleTestResult() | ||
|
|
||
| seconds shouldEqual 123 | ||
| } | ||
|
|
||
| @Test | ||
| fun delete_play_position_removes_existing_play_position() { | ||
| playPositionDao.insert(PlayPosition(eventId = 8, seconds = 123)) | ||
| playPositionDao.getPlayedEvents().getSingleTestResult().size shouldEqual 1 | ||
| playPositionDao.getPlaybackSeconds(8).getSingleTestResult() shouldEqual 123 | ||
|
|
||
| playPositionDao.delete(PlayPosition(eventId = 8)) | ||
| playPositionDao.getPlayedEvents().getSingleTestResult().size shouldEqual 0 | ||
| playPositionDao.getPlaybackSeconds(8).test().errorCount() shouldEqual 1 | ||
| } | ||
|
|
||
| @Test | ||
| fun delete_play_position_without_matching_event_does_nothing() { | ||
| playPositionDao.delete(PlayPosition(eventId = 42)) | ||
| playPositionDao.delete(PlayPosition(eventId = 43)) | ||
| } | ||
|
|
||
| @Test | ||
| fun updating_a_played_event_does_not_change_play_position() { | ||
| val updatedEvent = minimalEventEntity.copy(conferenceId = 3, id = 8, title = "updated") | ||
| playPositionDao.insert(PlayPosition(eventId = 8)) | ||
| eventDao.insert(updatedEvent) | ||
|
|
||
| val playedEvents = playPositionDao.getPlayedEvents().getSingleTestResult() | ||
|
|
||
| playedEvents.size shouldEqual 1 | ||
| playedEvents.first() shouldEqual updatedEvent | ||
| } | ||
|
|
||
| } |
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
24 changes: 24 additions & 0 deletions
24
app/src/main/java/de/stefanmedack/ccctv/persistence/daos/PlayPositionDao.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,24 @@ | ||
| package de.stefanmedack.ccctv.persistence.daos | ||
|
|
||
| import android.arch.persistence.room.* | ||
| import de.stefanmedack.ccctv.persistence.entities.Event | ||
| import de.stefanmedack.ccctv.persistence.entities.PlayPosition | ||
| import io.reactivex.Flowable | ||
| import io.reactivex.Single | ||
|
|
||
| @Dao | ||
| interface PlayPositionDao { | ||
|
|
||
| @Query("SELECT events.* FROM Events INNER JOIN play_positions WHERE events.id = play_positions.event_id ORDER BY created_at DESC") | ||
| fun getPlayedEvents(): Flowable<List<Event>> | ||
|
|
||
| @Query("SELECT seconds FROM play_positions WHERE event_id = :eventId") | ||
| fun getPlaybackSeconds(eventId: Int) : Single<Int> | ||
|
|
||
| @Insert(onConflict = OnConflictStrategy.REPLACE) | ||
| fun insert(playPosition: PlayPosition) | ||
|
|
||
| @Delete | ||
| fun delete(playPosition: PlayPosition) | ||
|
|
||
| } |
Oops, something went wrong.