feature/persistence exercise

README.md

@@ -8,7 +8,8 @@
 3. Copied-in code/dependencies
 - Reused the extension functions from past projects
 - Reused Dagger module structure from past projects
-- Reused AbsItemsAdapter + AbsViewHolder from past projects
+- Reused AbsItemsAdapter + AbsViewHolder
+ from past projects
 
 4. Tablet/phone focus
 - Phone

app/build.gradle

@@ -80,6 +80,15 @@ dependencies {
     implementation "com.squareup.okhttp3:logging-interceptor:$okHttpVersion"
     implementation "com.squareup.okio:okio:2.8.0"
 
+    // room
+    implementation "androidx.room:room-runtime:$roomVersion"
+    implementation "androidx.room:room-rxjava2:$roomVersion"
+    annotationProcessor "androidx.room:room-compiler:$roomVersion"
+    kapt "androidx.room:room-compiler:$roomVersion"
+//    implementation "androidx.room:room-runtime:$roomVersion"
+//    kapt "androidx.room:room-compiler:$roomVersion"
+//    implementation "android.arch.persistence.room:rxjava2:$roomVersion"
+
     // material components
     implementation "com.google.android.material:material:$materialComponentsVersion"
 

app/src/main/java/com/treyherman/employeedirectory/AppComponent.kt

@@ -10,6 +10,7 @@ import javax.inject.Singleton
         AndroidSupportInjectionModule::class,
         NetworkModule::class,
         AppModule::class,
+        PersistenceModule::class,
         AndroidModule::class,
         InjectorModule::class
     ]

app/src/main/java/com/treyherman/employeedirectory/PersistenceModule.kt

@@ -0,0 +1,29 @@
+package com.treyherman.employeedirectory
+
+import android.content.Context
+import androidx.room.Room
+import com.treyherman.employeedirectory.persistence.EmployeeDirectoryDatabase
+import com.treyherman.employeedirectory.persistence.dao.EmployeeDao
+import dagger.Module
+import dagger.Provides
+import javax.inject.Singleton
+
+@Module
+class PersistenceModule {
+    companion object {
+        private const val DATABASE_NAME = "employee_database"
+    }
+
+    @Provides
+    @Singleton
+    fun provideEmployeeDirectoryDatabase(context: Context): EmployeeDirectoryDatabase {
+        return Room.databaseBuilder(context, EmployeeDirectoryDatabase::class.java, DATABASE_NAME)
+            .fallbackToDestructiveMigration()
+            .build()
+    }
+
+    @Provides
+    fun provideEmployeeDao(database: EmployeeDirectoryDatabase): EmployeeDao {
+        return database.employeeDao()
+    }
+}

app/src/main/java/com/treyherman/employeedirectory/extension/RxJavaExtensions.kt

@@ -1,5 +1,6 @@
 package com.treyherman.employeedirectory.extension
 
+import io.reactivex.Observable
 import io.reactivex.Single
 import io.reactivex.android.schedulers.AndroidSchedulers
 import io.reactivex.schedulers.Schedulers
@@ -15,3 +16,11 @@ fun <T> Single<T>.subscribeOnComputation(): Single<T> {
 fun <T> Single<T>.observeOnMain(): Single<T> {
     return this.observeOn(AndroidSchedulers.mainThread())
 }
+
+fun <T> Observable<T>.subscribeOnIO(): Observable<T> {
+    return this.subscribeOn(Schedulers.io())
+}
+
+fun <T> Observable<T>.observeOnMain(): Observable<T> {
+    return this.observeOn(AndroidSchedulers.mainThread())
+}

app/src/main/java/com/treyherman/employeedirectory/persistence/EmployeeDirectoryDatabase.kt

@@ -0,0 +1,11 @@
+package com.treyherman.employeedirectory.persistence
+
+import androidx.room.Database
+import androidx.room.RoomDatabase
+import com.treyherman.employeedirectory.persistence.dao.EmployeeDao
+import com.treyherman.employeedirectory.persistence.model.EmployeeEntity
+
+@Database(entities = [EmployeeEntity::class], version = 1)
+abstract class EmployeeDirectoryDatabase : RoomDatabase() {
+    abstract fun employeeDao(): EmployeeDao
+}

app/src/main/java/com/treyherman/employeedirectory/persistence/dao/EmployeeDao.kt

@@ -0,0 +1,19 @@
+package com.treyherman.employeedirectory.persistence.dao
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.OnConflictStrategy
+import androidx.room.Query
+import com.treyherman.employeedirectory.persistence.model.EmployeeEntity
+import io.reactivex.Completable
+import io.reactivex.Observable
+
+@Dao
+interface EmployeeDao {
+
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    fun insertEmployeesCompletable(employees: List<EmployeeEntity>): Completable
+
+    @Query("SELECT * FROM EmployeeEntity")
+    fun localEmployeesStream(): Observable<List<EmployeeEntity>>
+}

app/src/main/java/com/treyherman/employeedirectory/persistence/model/EmployeeEntity.kt

@@ -0,0 +1,17 @@
+package com.treyherman.employeedirectory.persistence.model
+
+import androidx.room.Entity
+import androidx.room.PrimaryKey
+
+@Entity
+data class EmployeeEntity(
+    @PrimaryKey val uuid: String,
+    val fullName: String,
+    val phoneNumber: String?,
+    val emailAddress: String,
+    val biography: String?,
+    val photoUrlSmall: String?,
+    val photoUrlLarge: String?,
+    val team: String,
+    val employeeType: String
+)

app/src/main/java/com/treyherman/employeedirectory/rest/model/response/employee/EmployeeResponse.kt

@@ -9,7 +9,7 @@ data class EmployeeResponse(
     val photoUrlSmall: String?,
     val photoUrlLarge: String?,
     val team: String,
-    private val employeeType: String
+    val employeeType: String
 ) {
     val type
         get() = Type.enumValueFromString(employeeType)