Rename method storeData to addSession.
This commit is contained in:
committed by
Benoit Marty
parent
a46b7c27a9
commit
06bcbb8bb8
@@ -13,7 +13,7 @@ import kotlinx.coroutines.flow.map
|
||||
interface SessionStore {
|
||||
fun isLoggedIn(): Flow<LoggedInState>
|
||||
fun sessionsFlow(): Flow<List<SessionData>>
|
||||
suspend fun storeData(sessionData: SessionData)
|
||||
suspend fun addSession(sessionData: SessionData)
|
||||
|
||||
/**
|
||||
* Will update the session data matching the userId, except the value of loginTimestamp.
|
||||
|
||||
@@ -49,7 +49,7 @@ class DatabaseSessionStore(
|
||||
}
|
||||
}
|
||||
|
||||
override suspend fun storeData(sessionData: SessionData) {
|
||||
override suspend fun addSession(sessionData: SessionData) {
|
||||
sessionDataMutex.withLock {
|
||||
database.sessionDataQueries.insertSessionData(sessionData.toDbModel())
|
||||
}
|
||||
|
||||
@@ -44,10 +44,10 @@ class DatabaseSessionStoreTest {
|
||||
}
|
||||
|
||||
@Test
|
||||
fun `storeData persists the SessionData into the DB`() = runTest {
|
||||
fun `addSession persists the SessionData into the DB`() = runTest {
|
||||
assertThat(database.sessionDataQueries.selectFirst().executeAsOneOrNull()).isNull()
|
||||
|
||||
databaseSessionStore.storeData(aSessionData.toApiModel())
|
||||
databaseSessionStore.addSession(aSessionData.toApiModel())
|
||||
|
||||
assertThat(database.sessionDataQueries.selectFirst().executeAsOneOrNull()).isEqualTo(aSessionData)
|
||||
assertThat(database.sessionDataQueries.selectAll().executeAsList().size).isEqualTo(1)
|
||||
|
||||
@@ -51,7 +51,7 @@ import org.junit.Test
|
||||
runCurrent()
|
||||
val listener = TestSessionListener()
|
||||
sut.addListener(listener)
|
||||
databaseSessionStore.storeData(sessionData.toApiModel())
|
||||
databaseSessionStore.addSession(sessionData.toApiModel())
|
||||
listener.assertEvents(TestSessionListener.Event.Created(sessionData.userId))
|
||||
sut.removeListener(listener)
|
||||
coroutineContext.cancelChildren()
|
||||
@@ -64,7 +64,7 @@ import org.junit.Test
|
||||
runCurrent()
|
||||
val listener = TestSessionListener()
|
||||
sut.addListener(listener)
|
||||
databaseSessionStore.storeData(sessionData.toApiModel())
|
||||
databaseSessionStore.addSession(sessionData.toApiModel())
|
||||
listener.assertEvents(TestSessionListener.Event.Created(sessionData.userId))
|
||||
databaseSessionStore.removeSession(sessionData.userId)
|
||||
listener.assertEvents(
|
||||
|
||||
@@ -37,7 +37,7 @@ class InMemorySessionStore(
|
||||
|
||||
override fun sessionsFlow(): Flow<List<SessionData>> = sessionDataListFlow.asStateFlow()
|
||||
|
||||
override suspend fun storeData(sessionData: SessionData) {
|
||||
override suspend fun addSession(sessionData: SessionData) {
|
||||
val currentList = sessionDataListFlow.value.toMutableList()
|
||||
currentList.removeAll { it.userId == sessionData.userId }
|
||||
currentList.add(sessionData)
|
||||
|
||||
Reference in New Issue
Block a user