Created minimal LocalDataSource implementation

app/src/main/java/com/rtbishop/lookingsat/db/LocalDataSource.kt

@@ -0,0 +1,14 @@
+package com.rtbishop.lookingsat.db
+
+import com.rtbishop.lookingsat.repo.Transmitter
+
+class LocalDataSource(private val transmittersDao: TransmittersDao) {
+
+    suspend fun insert(transmitters: List<Transmitter>) {
+        transmittersDao.insert(transmitters)
+    }
+
+    suspend fun getTransmittersForSat(id: Int): List<Transmitter> {
+        return transmittersDao.getTransmittersForSat(id)
+    }
+}

app/src/main/java/com/rtbishop/lookingsat/db/TransmitterDao.kt

@@ -1,6 +0,0 @@
-package com.rtbishop.lookingsat.db
-
-import androidx.room.Dao
-
-@Dao
-interface TransmitterDao

app/src/main/java/com/rtbishop/lookingsat/db/TransmitterDatabase.kt

@@ -1,11 +0,0 @@
-package com.rtbishop.lookingsat.db
-
-import androidx.room.Database
-import androidx.room.RoomDatabase
-import com.rtbishop.lookingsat.repo.Transmitter
-
-@Database(entities = [Transmitter::class], version = 1, exportSchema = false)
-abstract class TransmitterDatabase : RoomDatabase() {
-
-    abstract fun transDao(): TransmitterDao
-}

app/src/main/java/com/rtbishop/lookingsat/db/TransmittersDao.kt

@@ -0,0 +1,17 @@
+package com.rtbishop.lookingsat.db
+
+import androidx.room.Dao
+import androidx.room.Insert
+import androidx.room.OnConflictStrategy
+import androidx.room.Query
+import com.rtbishop.lookingsat.repo.Transmitter
+
+@Dao
+interface TransmittersDao {
+
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    suspend fun insert(transmitters: List<Transmitter>)
+
+    @Query("SELECT * FROM transmitters WHERE noradCatId = :id")
+    suspend fun getTransmittersForSat(id: Int): List<Transmitter>
+}

app/src/main/java/com/rtbishop/lookingsat/db/TransmittersDatabase.kt

@@ -0,0 +1,28 @@
+package com.rtbishop.lookingsat.db
+
+import android.content.Context
+import androidx.room.Database
+import androidx.room.Room
+import androidx.room.RoomDatabase
+import com.rtbishop.lookingsat.repo.Transmitter
+
+@Database(entities = [Transmitter::class], version = 1, exportSchema = false)
+abstract class TransmittersDatabase : RoomDatabase() {
+
+    abstract fun transmittersDao(): TransmittersDao
+
+    companion object {
+
+        @Volatile
+        private var INSTANCE: TransmittersDatabase? = null
+
+        fun getInstance(context: Context): TransmittersDatabase =
+            INSTANCE ?: synchronized(this) {
+                INSTANCE ?: Room.databaseBuilder(
+                    context.applicationContext,
+                    TransmittersDatabase::class.java,
+                    "transmitters"
+                ).build()
+            }
+    }
+}