aljaz/breez-sdk-liquid
1
0
Fork 0
mirror of https://github.com/aljazceru/breez-sdk-liquid.git synced 2026-01-06 15:44:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

Prevent missing notifications due to concurrent SDK instances (#697)

Browse Source 
* Prevent missing notifications due to concurrent SDK instances

* Expose swap claim tx id and use it to derive WaitingConfirmation in plugins

* Use id type as get payment request variant
This commit is contained in:
Daniel Granhão
2025-02-03 17:33:07 +00:00
committed by GitHub
parent c42bebb49d
commit 0c9d2b8cbe
16 changed files with 560 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
lib/bindings/langs/swift/Sources/BreezSDKLiquid/Task/SwapUpdated.swift
View File

@@ -9,12 +9,15 @@ struct SwapUpdatedRequest: Codable {
class SwapUpdatedTask : TaskProtocol {
fileprivate let TAG = "SwapUpdatedTask"
private let pollingInterval: TimeInterval = 5.0
internal var payload: String
internal var contentHandler: ((UNNotificationContent) -> Void)?
internal var bestAttemptContent: UNMutableNotificationContent?
internal var logger: ServiceLogger
internal var request: SwapUpdatedRequest? = nil
internal var notified: Bool = false
private var pollingTimer: Timer?
init(payload: String, logger: ServiceLogger, contentHandler: ((UNNotificationContent) -> Void)? = nil, bestAttemptContent: UNMutableNotificationContent? = nil) {
self.payload = payload
@@ -31,6 +34,52 @@ class SwapUpdatedTask : TaskProtocol {
self.onShutdown()
throw e
}
startPolling(liquidSDK: liquidSDK)
}
func startPolling(liquidSDK: BindingLiquidSdk) {
pollingTimer = Timer.scheduledTimer(withTimeInterval: pollingInterval, repeats: true) { [weak self] _ in
guard let self = self else { return }
do {
guard let request = self.request else {
self.stopPolling(withError: NSError(domain: "SwapUpdatedTask", code: -1, userInfo: [NSLocalizedDescriptionKey: "Missing swap updated request"]))
return
}
if let payment = try liquidSDK.getPayment(req: .swapId(swapId: request.id)) {
switch payment.status {
case .complete:
onEvent(e: SdkEvent.paymentSucceeded(details: payment))
self.stopPolling()
case .waitingFeeAcceptance:
onEvent(e: SdkEvent.paymentWaitingFeeAcceptance(details: payment))
self.stopPolling()
case .pending:
if paymentClaimIsBroadcasted(details: payment.details) {
onEvent(e: SdkEvent.paymentWaitingConfirmation(details: payment))
self.stopPolling()
}
default:
break
}
}
} catch {
self.stopPolling(withError: error)
}
}
pollingTimer?.fire()
}
private func stopPolling(withError error: Error? = nil) {
pollingTimer?.invalidate()
pollingTimer = nil
if let error = error {
logger.log(tag: TAG, line: "Polling stopped with error: \(error)", level: "ERROR")
onShutdown()
}
}
public func onEvent(e: SdkEvent) {
@@ -59,9 +108,9 @@ class SwapUpdatedTask : TaskProtocol {
func getSwapId(details: PaymentDetails?) -> String? {
if let details = details {
switch details {
case let .bitcoin(swapId, _, _, _, _, _, _):
case let .bitcoin(swapId, _, _, _, _, _, _, _):
return swapId
case let .lightning(swapId, _, _, _, _, _, _, _, _, _, _):
case let .lightning(swapId, _, _, _, _, _, _, _, _, _, _, _):
return swapId
default:
break
@@ -70,6 +119,17 @@ class SwapUpdatedTask : TaskProtocol {
return nil
}
func paymentClaimIsBroadcasted(details: PaymentDetails) -> Bool {
switch details {
case let .bitcoin(_, _, _, _, _, claimTxId, _, _):
return claimTxId != nil
case let .lightning( _, _, _, _, _, _, _, _, _, claimTxId, _, _):
return claimTxId != nil
default:
return false
}
}
func onShutdown() {
let notificationTitle = ResourceHelper.shared.getString(key: Constants.SWAP_CONFIRMED_NOTIFICATION_FAILURE_TITLE, fallback: Constants.DEFAULT_SWAP_CONFIRMED_NOTIFICATION_FAILURE_TITLE)
let notificationBody = ResourceHelper.shared.getString(key: Constants.SWAP_CONFIRMED_NOTIFICATION_FAILURE_TEXT, fallback: Constants.DEFAULT_SWAP_CONFIRMED_NOTIFICATION_FAILURE_TEXT)