add blocks and wait? don't see this locally

nbd-wtf · Apr 1, 2024 · 15ec8d7 · 15ec8d7
1 parent 889f194
commit 15ec8d7
Showing 1 changed file with 33 additions and 10 deletions.
diff --git a/LNUnit/Setup/LNUnitBuilder.cs b/LNUnit/Setup/LNUnitBuilder.cs
@@ -649,17 +649,40 @@ public async Task RestartByAlias(string alias, uint waitBeforeKillSeconds = 1, b
                         await this.WaitUntilSyncedToChain(alias);
                         await this.WaitGraphReady(alias, this.LNDNodePool.TotalNodes);
                         //Set fees & htlcs, TLD
-                        var policyUpdateResponse = await node.LightningClient.UpdateChannelPolicyAsync(
-                            new PolicyUpdateRequest
+                        var policySet = false;
+                        var hitcount = 0;
+                        while (!policySet)
+                        {
+                            try
+                            {
+                                var policyUpdateResponse = await node.LightningClient.UpdateChannelPolicyAsync(
+                                    new PolicyUpdateRequest
+                                    {
+                                        BaseFeeMsat = c.BaseFeeMsat.GetValueOrDefault(),
+                                        ChanPoint = channelPoint,
+                                        FeeRatePpm = c.FeeRatePpm.GetValueOrDefault(),
+                                        MinHtlcMsat = c.MinHtlcMsat.GetValueOrDefault(),
+                                        MinHtlcMsatSpecified = c.MinHtlcMsat.HasValue,
+                                        MaxHtlcMsat = c.MaxHtlcMsat.GetValueOrDefault(),
+                                        TimeLockDelta = c.TimeLockDelta
+                                    });
+                                policySet = true;
+                            }
+                            catch (Grpc.Core.RpcException e) when (e.Status.StatusCode == StatusCode.Unknown &&
+                                                                   e.Status.Detail.EqualsIgnoreCase("channel from self node has no policy"))
                             {
-                                BaseFeeMsat = c.BaseFeeMsat.GetValueOrDefault(),
-                                ChanPoint = channelPoint,
-                                FeeRatePpm = c.FeeRatePpm.GetValueOrDefault(),
-                                MinHtlcMsat = c.MinHtlcMsat.GetValueOrDefault(),
-                                MinHtlcMsatSpecified = c.MinHtlcMsat.HasValue,
-                                MaxHtlcMsat = c.MaxHtlcMsat.GetValueOrDefault(),
-                                TimeLockDelta = c.TimeLockDelta
-                            });
+                                if (hitcount == 0)
+                                {
+                                    //generate blocks so we do a status update for sure.
+                                    await BitcoinRpcClient.GenerateAsync(145);
+
+                                }
+
+                                hitcount++;
+                                await Task.Delay(500); //give it some time
+                            }
+                        }
+
                     }
                 }