fix: cjit domain language + cjit activity timestamp

Author: ovitrif

app/src/androidTest/java/to/bitkit/services/BlocktankTest.kt

@@ -82,11 +82,11 @@ class BlocktankTest {
     }
 
     @Test
-    fun testCreateCjitOrder() = runBlocking {
+    fun testCreateCjitEntry() = runBlocking {
         // Test creating a CJIT order
         val channelSizeSat = 100_000uL // 100k sats
         val invoiceSat = 10_000uL // 10k sats for the invoice
-        val invoiceDescription = "Test CJIT order"
+        val invoiceDescription = "Test CJIT"
         val nodeId = "03e7156ae33b0a208d0744199163177e909e80176e55d97a2f221ede0f934dd9ad" // Example node ID
         val channelExpiryWeeks = 6u
         val options = CreateCjitOptions(source = "bitkit", discountCode = null)
@@ -122,7 +122,7 @@ class BlocktankTest {
         )
 
         // Test getting CJIT entries
-        val entries = service.blocktank.cjitOrders(
+        val entries = service.blocktank.cjitEntries(
             entryIds = listOf(cjitEntry.id),
             filter = null,
             refresh = true

app/src/main/java/to/bitkit/fcm/WakeNodeWorker.kt

@@ -148,8 +148,8 @@ class WakeNodeWorker @AssistedInject constructor(
                         val sats = channel.amountOnClose
                         self.bestAttemptContent?.title = "Received ⚡ $sats sats"
 
-                        val cjitOrder = channel.let { blocktankRepo.getCjitOrder(it) }
-                        if (cjitOrder != null) {
+                        val cjitEntry = channel.let { blocktankRepo.getCjitEntry(it) }
+                        if (cjitEntry != null) {
                             val amount = channel.amountOnClose.toLong()
 
                             // Save for UI to pick up
@@ -161,7 +161,7 @@ class WakeNodeWorker @AssistedInject constructor(
                                     sats = amount,
                                 )
                             )
-                            activityRepo.insertActivityFromChannel(cjitOrder = cjitOrder, channel = channel)
+                            activityRepo.insertActivityFromCjit(cjitEntry = cjitEntry, channel = channel)
                         }
                     }
                 } else if (self.notificationType == orderPaymentConfirmed) {

app/src/main/java/to/bitkit/repositories/ActivityRepo.kt

@@ -510,17 +510,17 @@ class ActivityRepo @Inject constructor(
     }
 
     /**
-     * Inserts a new activity
+     * Inserts a new activity for a fulfilled (channel ready) cjit channel order
      */
-    suspend fun insertActivityFromChannel(
-        cjitOrder: IcJitEntry?,
+    suspend fun insertActivityFromCjit(
+        cjitEntry: IcJitEntry?,
         channel: ChannelDetails,
     ): Result<Unit> = withContext(bgDispatcher) {
         runCatching {
-            requireNotNull(cjitOrder)
+            requireNotNull(cjitEntry)
 
             val amount = channel.amountOnClose
-            val now = nowTimestamp().toEpochMilli().toULong()
+            val now = nowTimestamp().epochSecond.toULong()
 
             return@withContext insertActivity(
                 Activity.Lightning(
@@ -530,7 +530,7 @@ class ActivityRepo @Inject constructor(
                         status = PaymentState.SUCCEEDED,
                         value = amount,
                         fee = 0U,
-                        invoice = cjitOrder.invoice.request,
+                        invoice = cjitEntry.invoice.request,
                         message = "",
                         timestamp = now,
                         preimage = null,

app/src/main/java/to/bitkit/repositories/BlocktankRepo.kt

@@ -97,7 +97,7 @@ class BlocktankRepo @Inject constructor(
         }
     }
 
-    suspend fun getCjitOrder(channel: ChannelDetails): IcJitEntry? = withContext(bgDispatcher) {
+    suspend fun getCjitEntry(channel: ChannelDetails): IcJitEntry? = withContext(bgDispatcher) {
         return@withContext _blocktankState.value.cjitEntries.firstOrNull { order ->
             order.channelSizeSat == channel.channelValueSats &&
                 order.lspNode.pubkey == channel.counterpartyNodeId
@@ -131,7 +131,7 @@ class BlocktankRepo @Inject constructor(
 
             // Sync instantly from cache
             val cachedOrders = coreService.blocktank.orders(refresh = false)
-            val cachedCjitEntries = coreService.blocktank.cjitOrders(refresh = false)
+            val cachedCjitEntries = coreService.blocktank.cjitEntries(refresh = false)
             _blocktankState.update { state ->
                 state.copy(
                     orders = cachedOrders,
@@ -142,7 +142,7 @@ class BlocktankRepo @Inject constructor(
 
             // Then refresh from server
             val orders = coreService.blocktank.orders(refresh = true)
-            val cjitEntries = coreService.blocktank.cjitOrders(refresh = true)
+            val cjitEntries = coreService.blocktank.cjitEntries(refresh = true)
             _blocktankState.update { state ->
                 state.copy(
                     orders = orders,

app/src/main/java/to/bitkit/services/CoreService.kt

@@ -584,7 +584,7 @@ class BlocktankService(
         }
     }
 
-    suspend fun cjitOrders(
+    suspend fun cjitEntries(
         entryIds: List<String>? = null,
         filter: CJitStateEnum? = null,
         refresh: Boolean = true,

app/src/main/java/to/bitkit/viewmodels/AppViewModel.kt

@@ -221,8 +221,8 @@ class AppViewModel @Inject constructor(
 
                         is Event.ChannelReady -> {
                             val channel = lightningRepo.getChannels()?.find { it.channelId == event.channelId }
-                            val cjitOrder = channel?.let { blocktankRepo.getCjitOrder(it) }
-                            if (cjitOrder != null) {
+                            val cjitEntry = channel?.let { blocktankRepo.getCjitEntry(it) }
+                            if (cjitEntry != null) {
                                 val amount = channel.amountOnClose.toLong()
                                 showNewTransactionSheet(
                                     NewTransactionSheetDetails(
@@ -232,7 +232,7 @@ class AppViewModel @Inject constructor(
                                     ),
                                     event = event
                                 )
-                                activityRepo.insertActivityFromChannel(cjitOrder = cjitOrder, channel = channel)
+                                activityRepo.insertActivityFromCjit(cjitEntry = cjitEntry, channel = channel)
                             } else {
                                 toast(
                                     type = Toast.ToastType.LIGHTNING,

app/src/test/java/to/bitkit/repositories/BlocktankRepoTest.kt

@@ -44,8 +44,8 @@ class BlocktankRepoTest : BaseUnitTest() {
         wheneverBlocking { coreService.blocktank.orders(refresh = false) }.thenReturn(emptyList())
         wheneverBlocking { coreService.blocktank.orders(refresh = true) }.thenReturn(emptyList())
 
-        wheneverBlocking { coreService.blocktank.cjitOrders(refresh = false) }.thenReturn(emptyList())
-        wheneverBlocking { coreService.blocktank.cjitOrders(refresh = true) }.thenReturn(emptyList())
+        wheneverBlocking { coreService.blocktank.cjitEntries(refresh = false) }.thenReturn(emptyList())
+        wheneverBlocking { coreService.blocktank.cjitEntries(refresh = true) }.thenReturn(emptyList())
     }
 
     private fun createSut(): BlocktankRepo {