Attach tags asynchronously

app/schemas/to.bitkit.data.AppDb/3.json

@@ -0,0 +1,90 @@
+{
+  "formatVersion": 1,
+  "database": {
+    "version": 3,
+    "identityHash": "e8c2a3893862c335833d1329bd45b666",
+    "entities": [
+      {
+        "tableName": "config",
+        "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`walletIndex` INTEGER NOT NULL, PRIMARY KEY(`walletIndex`))",
+        "fields": [
+          {
+            "fieldPath": "walletIndex",
+            "columnName": "walletIndex",
+            "affinity": "INTEGER",
+            "notNull": true
+          }
+        ],
+        "primaryKey": {
+          "autoGenerate": false,
+          "columnNames": [
+            "walletIndex"
+          ]
+        },
+        "indices": [],
+        "foreignKeys": []
+      },
+      {
+        "tableName": "tag_metadata",
+        "createSql": "CREATE TABLE IF NOT EXISTS `${TABLE_NAME}` (`id` TEXT NOT NULL, `paymentHash` TEXT, `txId` TEXT, `address` TEXT NOT NULL, `isReceive` INTEGER NOT NULL, `tags` TEXT NOT NULL, `createdAt` INTEGER NOT NULL, PRIMARY KEY(`id`))",
+        "fields": [
+          {
+            "fieldPath": "id",
+            "columnName": "id",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "paymentHash",
+            "columnName": "paymentHash",
+            "affinity": "TEXT",
+            "notNull": false
+          },
+          {
+            "fieldPath": "txId",
+            "columnName": "txId",
+            "affinity": "TEXT",
+            "notNull": false
+          },
+          {
+            "fieldPath": "address",
+            "columnName": "address",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "isReceive",
+            "columnName": "isReceive",
+            "affinity": "INTEGER",
+            "notNull": true
+          },
+          {
+            "fieldPath": "tags",
+            "columnName": "tags",
+            "affinity": "TEXT",
+            "notNull": true
+          },
+          {
+            "fieldPath": "createdAt",
+            "columnName": "createdAt",
+            "affinity": "INTEGER",
+            "notNull": true
+          }
+        ],
+        "primaryKey": {
+          "autoGenerate": false,
+          "columnNames": [
+            "id"
+          ]
+        },
+        "indices": [],
+        "foreignKeys": []
+      }
+    ],
+    "views": [],
+    "setupQueries": [
+      "CREATE TABLE IF NOT EXISTS room_master_table (id INTEGER PRIMARY KEY,identity_hash TEXT)",
+      "INSERT OR REPLACE INTO room_master_table (id,identity_hash) VALUES(42, 'e8c2a3893862c335833d1329bd45b666')"
+    ]
+  }
+}

app/src/main/java/to/bitkit/data/AppDb.kt

@@ -19,22 +19,22 @@ import dagger.assisted.AssistedInject
 import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.flow.Flow
 import to.bitkit.BuildConfig
-import to.bitkit.data.dao.InvoiceTagDao
+import to.bitkit.data.dao.TagMetadataDao
 import to.bitkit.data.entities.ConfigEntity
-import to.bitkit.data.entities.InvoiceTagEntity
+import to.bitkit.data.entities.TagMetadataEntity
 import to.bitkit.data.typeConverters.StringListConverter
 
 @Database(
     entities = [
         ConfigEntity::class,
-        InvoiceTagEntity::class,
+        TagMetadataEntity::class,
     ],
-    version = 2,
+    version = 3,
 )
 @TypeConverters(StringListConverter::class)
 abstract class AppDb : RoomDatabase() {
     abstract fun configDao(): ConfigDao
-    abstract fun invoiceTagDao(): InvoiceTagDao
+    abstract fun tagMetadataDao(): TagMetadataDao
 
     companion object {
         private const val DB_NAME = "${BuildConfig.APPLICATION_ID}.sqlite"

app/src/main/java/to/bitkit/data/dao/TagMetadataDao.kt

@@ -0,0 +1,60 @@
+package to.bitkit.data.dao
+
+import androidx.room.Dao
+import androidx.room.Delete
+import androidx.room.Insert
+import androidx.room.OnConflictStrategy
+import androidx.room.Query
+import to.bitkit.data.entities.TagMetadataEntity
+
+@Dao
+interface TagMetadataDao {
+
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    suspend fun saveTagMetadata(tagMetadata: TagMetadataEntity)
+
+    @Query("SELECT * FROM tag_metadata")
+    suspend fun getAll(): List<TagMetadataEntity>
+
+    // Search by payment hash (for invoices)
+    @Query("SELECT * FROM tag_metadata WHERE paymentHash = :paymentHash LIMIT 1")
+    suspend fun searchByPaymentHash(paymentHash: String): TagMetadataEntity?
+
+    // Search by transaction ID
+    @Query("SELECT * FROM tag_metadata WHERE txId = :txId LIMIT 1")
+    suspend fun searchByTxId(txId: String): TagMetadataEntity?
+
+    // Search by address
+    @Query("SELECT * FROM tag_metadata WHERE address = :address ORDER BY createdAt DESC LIMIT 1")
+    suspend fun searchByAddress(address: String): TagMetadataEntity?
+
+    // Search by primary key (id)
+    @Query("SELECT * FROM tag_metadata WHERE id = :id LIMIT 1")
+    suspend fun searchById(id: String): TagMetadataEntity?
+
+    // Get all receive transactions
+    @Query("SELECT * FROM tag_metadata WHERE isReceive = 1")
+    suspend fun getAllReceiveTransactions(): List<TagMetadataEntity>
+
+    // Get all send transactions
+    @Query("SELECT * FROM tag_metadata WHERE isReceive = 0")
+    suspend fun getAllSendTransactions(): List<TagMetadataEntity>
+
+    @Delete
+    suspend fun deleteTagMetadata(tagMetadata: TagMetadataEntity)
+
+    @Query("DELETE FROM tag_metadata WHERE paymentHash = :paymentHash")
+    suspend fun deleteByPaymentHash(paymentHash: String)
+
+    @Query("DELETE FROM tag_metadata WHERE txId = :txId")
+    suspend fun deleteByTxId(txId: String)
+
+    @Query("DELETE FROM tag_metadata WHERE id = :id")
+    suspend fun deleteById(id: String)
+
+    @Query("DELETE FROM tag_metadata")
+    suspend fun deleteAll()
+
+    @Query("DELETE FROM tag_metadata WHERE createdAt < :expirationTimeStamp")
+    suspend fun deleteExpired(expirationTimeStamp: Long)
+}

app/src/main/java/to/bitkit/data/entities/TagMetadataEntity.kt

@@ -0,0 +1,21 @@
+package to.bitkit.data.entities
+
+import androidx.room.Entity
+import androidx.room.PrimaryKey
+
+@Entity(tableName = "tag_metadata")
+/**
+ * @param id This will be paymentHash, txId, or address depending on context
+ * @param txId on-chain transaction id
+ * @param address on-chain address
+ * @param isReceive true for receive, false for send
+ * */
+data class TagMetadataEntity(
+    @PrimaryKey val id: String,
+    val paymentHash: String? = null,
+    val txId: String? = null,
+    val address: String,
+    val isReceive: Boolean,
+    val tags: List<String>,
+    val createdAt: Long,
+)