@@ -336,7 +336,7 @@ class ActivityRepo @Inject constructor(
336336 ) = withContext(context = bgDispatcher) {
337337 runCatching {
338338 if (db.tagMetadataDao().getAll().isEmpty()) return @withContext
339-
339+ Logger .debug( " syncTagsMetaData called " )
340340 newPayments.forEach { payment ->
341341 when (val kind = payment.kind) {
342342 is PaymentKind .Bolt11 -> {
@@ -348,6 +348,7 @@ class ActivityRepo @Inject constructor(
348348 txType = if (tagMetadata.isReceive) PaymentType .RECEIVED else PaymentType .SENT ,
349349 tags = tagMetadata.tags
350350 ).onSuccess {
351+ Logger .debug(" Tags synced with success! $tagMetadata " , context = TAG )
351352 db.tagMetadataDao().deleteByPaymentHash(paymentHash = paymentHash)
352353 }
353354 }
@@ -358,18 +359,23 @@ class ActivityRepo @Inject constructor(
358359 PaymentDirection .INBOUND -> {
359360 // TODO Temporary solution while whe ldk-node doesn't return the txId directly
360361 runCatching { addressChecker.getTransaction(kind.txid) }.onSuccess { txDetails ->
361- txDetails.vout.firstOrNull()?.scriptpubkey_address?.let {
362- db.tagMetadataDao().searchByAddress(it)
363- }?.let { tagMetadata ->
364- addTagsToTransaction(
365- paymentHashOrTxId = kind.txid,
366- type = ActivityFilter .ONCHAIN ,
367- txType = PaymentType .RECEIVED ,
368- tags = tagMetadata.tags
369- ).onSuccess {
370- db.tagMetadataDao().deleteByTxId(kind.txid)
362+ txDetails.vout.forEach { vOut ->
363+ vOut.scriptpubkey_address?.let {
364+ db.tagMetadataDao().searchByAddress(it)
365+ }?.let { tagMetadata ->
366+ addTagsToTransaction(
367+ paymentHashOrTxId = kind.txid,
368+ type = ActivityFilter .ONCHAIN ,
369+ txType = PaymentType .RECEIVED ,
370+ tags = tagMetadata.tags
371+ ).onSuccess {
372+ Logger .debug(" Tags synced with success! $tagMetadata " , context = TAG )
373+ db.tagMetadataDao().deleteByTxId(kind.txid)
374+ }
371375 }
372376 }
377+ }.onFailure {
378+ Logger .warn(" Failed getting transaction detail" , context = TAG )
373379 }
374380 }
375381
@@ -381,6 +387,7 @@ class ActivityRepo @Inject constructor(
381387 txType = PaymentType .SENT ,
382388 tags = tagMetadata.tags
383389 ).onSuccess {
390+ Logger .debug(" Tags synced with success! $tagMetadata " , context = TAG )
384391 db.tagMetadataDao().deleteByTxId(kind.txid)
385392 }
386393 }
0 commit comments