Merge pull request #966 from lontivero/save-mempool

Save mempool rpc call

Author: NicolasDorier

NBitcoin.Tests/RPCClientTests.cs

@@ -193,6 +193,25 @@ public void CanGetMemPool()
 			}
 		}
 
+		[Fact]
+		public void CanSaveMemPool()
+		{
+			using (var builder = NodeBuilderEx.Create())
+			{
+				var node = builder.CreateNode();
+				var rpc = node.CreateRPCClient();
+				builder.StartAll();
+				node.Generate(101);
+
+				var mempoolFilePath = Path.Combine(node.Folder, "data", "regtest", "mempool.dat");
+				File.Delete(mempoolFilePath);
+				Assert.False(File.Exists(mempoolFilePath));
+				rpc.SendToAddress(new Key().PubKey.GetAddress(ScriptPubKeyType.Legacy, rpc.Network), Money.Coins(1.0m), "hello", "world");
+				rpc.SaveMempool();
+				Assert.True(File.Exists(mempoolFilePath));
+			}
+		}
+
 		[Fact]
 		public async Task RPCBatchingCanFallbackIfAccessForbidden()
 		{

NBitcoin/RPC/RPCClient.cs

@@ -57,6 +57,7 @@ blockchain		gettxoutproof
 		blockchain		verifytxoutproof
 		blockchain		gettxoutsetinfo				Yes
 		blockchain		verifychain
+		blockchain		savemempool					Yes
 
 		------------------ Mining
 		mining			 getblocktemplate
@@ -1690,6 +1691,16 @@ public async Task<MempoolEntry> GetMempoolEntryAsync(uint256 txid, bool throwIfN
 			};
 		}
 
+		public async Task SaveMempoolAsync()
+		{
+			await SendCommandAsync(RPCOperations.savemempool).ConfigureAwait(false);
+		} 
+
+		public void SaveMempool()
+		{
+			SaveMempoolAsync().GetAwaiter().GetResult();
+		} 
+
 		private FeeRate AbsurdlyHighFee { get; } = new FeeRate(10_000M);
 
 		public MempoolAcceptResult TestMempoolAccept(Transaction transaction, bool allowHighFees = false)

NBitcoin/RPC/RPCOperations.cs

@@ -122,5 +122,6 @@ public enum RPCOperations
 		loadwallet,
 		unloadwallet,
 		addpeeraddress,
+		savemempool,
 	}
 }