@@ -175,7 +175,6 @@ class LightningRepo @Inject constructor(
175175 suspend fun start (
176176 walletIndex : Int = 0,
177177 timeout : Duration ? = null,
178- shouldRetry : Boolean = true,
179178 eventHandler : NodeEventHandler ? = null,
180179 customServer : ElectrumServer ? = null,
181180 customRgsServerUrl : String? = null,
@@ -200,7 +199,7 @@ class LightningRepo @Inject constructor(
200199 }
201200
202201 // Handle setup failures with retry logic
203- if (shouldRetry && retryAttempt < MAX_RETRY_ATTEMPTS && isRetryableError(setupError)) {
202+ if (retryAttempt < MAX_RETRY_ATTEMPTS && isRetryableError(setupError)) {
204203 Logger .warn(
205204 " Setup failed (attempt ${retryAttempt + 1 } /$MAX_RETRY_ATTEMPTS ), retrying..." ,
206205 setupError,
@@ -213,7 +212,6 @@ class LightningRepo @Inject constructor(
213212 return @withContext start(
214213 walletIndex = walletIndex,
215214 timeout = timeout,
216- shouldRetry = shouldRetry,
217215 eventHandler = eventHandler,
218216 customServer = customServer,
219217 customRgsServerUrl = customRgsServerUrl,
@@ -265,7 +263,7 @@ class LightningRepo @Inject constructor(
265263 it.copy(nodeLifecycleState = NodeLifecycleState .ErrorStarting (e))
266264 }
267265
268- if (shouldRetry && retryAttempt < MAX_RETRY_ATTEMPTS && isRetryableError(e)) {
266+ if (retryAttempt < MAX_RETRY_ATTEMPTS && isRetryableError(e)) {
269267 Logger .warn(
270268 " Start failed (attempt ${retryAttempt + 1 } /$MAX_RETRY_ATTEMPTS ), retrying..." ,
271269 e,
@@ -280,7 +278,6 @@ class LightningRepo @Inject constructor(
280278 return @withContext start(
281279 walletIndex = walletIndex,
282280 timeout = timeout,
283- shouldRetry = shouldRetry,
284281 eventHandler = eventHandler,
285282 customServer = customServer,
286283 customRgsServerUrl = customRgsServerUrl,
@@ -430,7 +427,6 @@ class LightningRepo @Inject constructor(
430427 start(
431428 eventHandler = cachedEventHandler,
432429 customServer = newServer,
433- shouldRetry = true , // Enable retry for server changes
434430 ).onFailure { startError ->
435431 Logger .warn(" Failed ldk-node config change, attempting recovery…" )
436432 restartWithPreviousConfig()
@@ -456,7 +452,6 @@ class LightningRepo @Inject constructor(
456452
457453 start(
458454 eventHandler = cachedEventHandler,
459- shouldRetry = true , // Enable retry for server changes
460455 customRgsServerUrl = newRgsUrl,
461456 ).onFailure { startError ->
462457 Logger .warn(" Failed ldk-node config change, attempting recovery…" )
@@ -482,7 +477,6 @@ class LightningRepo @Inject constructor(
482477
483478 start(
484479 eventHandler = cachedEventHandler,
485- shouldRetry = true , // Enable retry for recovery
486480 ).onSuccess {
487481 Logger .debug(" Successfully started node with previous config" )
488482 }.onFailure { e ->
0 commit comments