Bundle events

.gitignore

@@ -17,4 +17,5 @@ build/
 
 # App data
 app/src/main/assets/elements.json
-app/src/main/assets/reports.json
+app/src/main/assets/reports.json
+app/src/main/assets/events.json

app/build.gradle.kts

@@ -101,6 +101,9 @@ tasks.register("bundleData") {
 
         val reportsSrc = URL("https://static.btcmap.org/api/v2/reports.json")
         File(destDir, "reports.json").writeText(reportsSrc.readText())
+
+        val eventsSrc = URL("https://static.btcmap.org/api/v2/events.json")
+        File(destDir, "events.json").writeText(eventsSrc.readText())
     }
 }
 

app/src/main/kotlin/event/EventQueries.kt

@@ -133,6 +133,20 @@ class EventQueries(private val db: SQLiteOpenHelper) {
         }
     }
 
+    suspend fun selectCount(): Long {
+        return withContext(Dispatchers.IO) {
+            val cursor = db.readableDatabase.query(
+                """
+                SELECT count(*)
+                FROM event;
+                """
+            )
+
+            cursor.moveToNext()
+            cursor.getLong(0)
+        }
+    }
+
     private fun getLnUrl(description: String): String {
         val pattern = Pattern.compile("\\(lightning:[^)]*\\)", Pattern.CASE_INSENSITIVE)
         val matcher = pattern.matcher(description)

app/src/main/kotlin/event/EventsRepo.kt

@@ -1,19 +1,40 @@
 package event
 
+import android.content.Context
 import api.Api
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
 import java.time.Duration
 import java.time.ZoneOffset
 import java.time.ZonedDateTime
 
 class EventsRepo(
     private val api: Api,
     private val queries: EventQueries,
+    private val context: Context,
 ) {
 
     suspend fun selectAll(limit: Long) = queries.selectAll(limit)
 
     suspend fun selectByUserIdAsListItems(userId: Long) = queries.selectByUserId(userId)
 
+    suspend fun selectCount() = queries.selectCount()
+
+    suspend fun hasBundledEvents(): Boolean {
+        return withContext(Dispatchers.IO) {
+            context.resources.assets.list("")!!.contains("events.json")
+        }
+    }
+
+    suspend fun fetchBundledEvents() {
+        withContext(Dispatchers.IO) {
+            context.assets.open("events.json").use { bundledEvents ->
+                val events = bundledEvents.toEventsJson().map { it.toEvent() }
+                queries.insertOrReplace(events)
+            }
+        }
+    }
+
     suspend fun sync(): SyncReport {
         val startedAt = ZonedDateTime.now(ZoneOffset.UTC)
         val newEvents = mutableListOf<Event>()

app/src/main/kotlin/sync/Sync.kt

@@ -46,6 +46,10 @@ class Sync(
                         reportsRepo.fetchBundledReports()
                     }
 
+                    if (eventsRepo.selectCount() == 0L && eventsRepo.hasBundledEvents()) {
+                        eventsRepo.fetchBundledEvents()
+                    }
+
                     val elementsReport = async { elementsRepo.sync() }
                     val reportsReport = async { reportsRepo.sync() }
                     val areasReport = async { areasRepo.sync() }