format and more waits

nbd-wtf · Mar 29, 2024 · 1d14518 · 1d14518
1 parent 4b69113
commit 1d14518
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/LNUnit.Tests/AbcLightningFixture.cs b/LNUnit.Tests/AbcLightningFixture.cs
@@ -635,8 +635,9 @@ public async Task SendMany_Onchain()
 
         alice.LightningClient.SendMany(sendManyRequest);
 
-        Builder.NewBlock(10); //fast forward in time
+        await Builder.NewBlock(10); //fast forward in time
 
+        await Builder.WaitUntilSyncedToChain("alice");
         //verify last address got funds
         var unspend = alice.LightningClient.ListUnspent(new ListUnspentRequest() { });
         var confirmedAddresses = new List<string>();

diff --git a/LNUnit/Setup/LNUnitBuilder.cs b/LNUnit/Setup/LNUnitBuilder.cs
@@ -406,7 +406,7 @@ await GetTarStreamFromFS(n.DockerContainerId,
         IsBuilt = true;
     }
 
-    private static async Task WaitUntilSyncedToChain(LNDNodeConnection node)
+    public static async Task WaitUntilSyncedToChain(LNDNodeConnection node)
     {
         var info = new GetInfoResponse();
         while (!info.SyncedToChain)
@@ -416,6 +416,10 @@ private static async Task WaitUntilSyncedToChain(LNDNodeConnection node)
         }
     }
 
+    public async Task WaitUntilSyncedToChain(string alias)
+    {
+        await WaitUntilSyncedToChain(await GetNodeFromAlias(alias));
+    }
 
     public async Task<LNDSettings> GetLNDSettingsFromContainer(string containerId, string lndRoot = "/home/lnd/.lnd")
     {
@@ -642,7 +646,8 @@ public async Task RestartByAlias(string alias, uint waitBeforeKillSeconds = 1, b
                         c.ChannelPoint = channelPoint;
                         //Move things along so it is confirmed
                         await BitcoinRpcClient.GenerateAsync(10);
-
+                        await this.WaitUntilSyncedToChain(alias);
+                        await this.WaitGraphReady(alias, this.LNDNodePool.TotalNodes);
                         //Set fees & htlcs, TLD
                         var policyUpdateResponse = await node.LightningClient.UpdateChannelPolicyAsync(
                             new PolicyUpdateRequest