|
1 | | -package com.jumrukovski.quotescompose.data.repository |
| 1 | +package com.jumrukovski.quotescompose.data.repository.local |
2 | 2 |
|
3 | | -import com.jumrukovski.quotescompose.data.db.LocalDB |
4 | 3 | import com.jumrukovski.quotescompose.data.mapper.mapToQuote |
5 | 4 | import com.jumrukovski.quotescompose.data.mapper.mapToQuoteEntity |
6 | 5 | import com.jumrukovski.quotescompose.data.mapper.mapToQuotes |
| 6 | +import com.jumrukovski.quotescompose.data.source.local.LocalDataSource |
7 | 7 | import com.jumrukovski.quotescompose.di.Dispatcher |
8 | 8 | import com.jumrukovski.quotescompose.di.QuotesDispatchers |
9 | 9 | import com.jumrukovski.quotescompose.domain.model.Quote |
10 | | -import com.jumrukovski.quotescompose.domain.repository.LocalRepository |
| 10 | +import com.jumrukovski.quotescompose.domain.repository.local.LocalRepository |
11 | 11 | import javax.inject.Inject |
12 | 12 | import kotlinx.coroutines.CoroutineDispatcher |
13 | 13 | import kotlinx.coroutines.flow.Flow |
14 | 14 | import kotlinx.coroutines.withContext |
15 | 15 |
|
16 | 16 | class LocalRepositoryImpl @Inject constructor( |
17 | | - private val localDB: LocalDB, |
| 17 | + private val localDataSource: LocalDataSource, |
18 | 18 | @Dispatcher(QuotesDispatchers.IO) private val ioDispatcher: CoroutineDispatcher |
19 | 19 | ) : LocalRepository { |
20 | 20 |
|
21 | 21 | override suspend fun getAllFavouriteQuotes(): Flow<List<Quote>> = |
22 | 22 | withContext(ioDispatcher) { |
23 | | - localDB.quoteDao().getAllFavouriteQuotes().mapToQuotes() |
| 23 | + localDataSource.quoteDao().getAllFavouriteQuotes().mapToQuotes() |
24 | 24 | } |
25 | 25 |
|
26 | 26 | override suspend fun getFavouriteQuote(id: Int): Flow<Quote?> = |
27 | 27 | withContext(ioDispatcher) { |
28 | | - localDB.quoteDao().getFavouriteQuote(id).mapToQuote() |
| 28 | + localDataSource.quoteDao().getFavouriteQuote(id).mapToQuote() |
29 | 29 | } |
30 | 30 |
|
31 | 31 | override suspend fun addFavouriteQuote(quote: Quote) { |
32 | 32 | withContext(ioDispatcher) { |
33 | 33 | val entity = quote.mapToQuoteEntity() |
34 | | - localDB.quoteDao().addFavouriteQuote(entity) |
| 34 | + localDataSource.quoteDao().addFavouriteQuote(entity) |
35 | 35 | } |
36 | 36 | } |
37 | 37 |
|
38 | 38 | override suspend fun removeFavouriteQuote(quote: Quote) { |
39 | 39 | withContext(ioDispatcher) { |
40 | 40 | val entity = quote.mapToQuoteEntity() |
41 | | - localDB.quoteDao().deleteFavouriteQuote(entity) |
| 41 | + localDataSource.quoteDao().deleteFavouriteQuote(entity) |
42 | 42 | } |
43 | 43 | } |
44 | 44 | } |
0 commit comments