Added getting transactions from the Mempool.

Breeze/src/Breeze.Deamon/Program.cs

@@ -23,6 +23,7 @@ namespace Breeze.Deamon
 				.UseNodeSettings(nodeSettings)
 				.UseWallet()				
 				.UseBlockNotification()
+                .UseTransactionNotification()
 				.UseApi()
 				.Build();
 

Breeze/src/Breeze.Wallet/Notifications/TransactionObserver.cs

+using NBitcoin;
+using Stratis.Bitcoin;
+using Breeze.Wallet.Wrappers;
+
+namespace Breeze.Wallet.Notifications
+{
+    /// <summary>
+    /// Observer that receives notifications about the arrival of new <see cref="Transaction"/>s.
+    /// </summary>
+	public class TransactionObserver : SignalObserver<Transaction>
+	{
+	    private readonly ITrackerWrapper trackerWrapper;
+
+	    public TransactionObserver(ITrackerWrapper trackerWrapper)
+	    {
+	        this.trackerWrapper = trackerWrapper;
+	    }
+        
+        /// <summary>
+        /// Manages what happens when a new transaction is received.
+        /// </summary>
+        /// <param name="transaction">The new transaction</param>
+	    protected override void OnNextCore(Transaction transaction)
+	    {            
+            this.trackerWrapper.NotifyAboutTransaction(transaction);	        
+	    }
+	}
+}

Breeze/src/Breeze.Wallet/Notifications/TransactionSubscriber.cs

+using Stratis.Bitcoin;
+using System;
+using NBitcoin;
+
+namespace Breeze.Wallet.Notifications
+{
+    /// <summary>
+    /// Manages the subscription of the transaction observer to the transaction signaler.
+    /// </summary>
+	public class TransactionSubscriber
+	{
+		private readonly ISignaler<Transaction> signaler;
+		private readonly TransactionObserver observer;
+
+		public TransactionSubscriber(ISignaler<Transaction> signaler, TransactionObserver observer)
+		{
+			this.signaler = signaler;
+			this.observer = observer;			
+		}
+
+        /// <summary>
+        /// Subscribes the transaction observer to the transaction signaler.
+        /// </summary>
+        /// <returns>An <see cref="IDisposable"/></returns>
+		public IDisposable Subscribe()
+		{
+			return this.signaler.Subscribe(this.observer);
+		}		
+	}
+}

Breeze/src/Breeze.Wallet/WalletFeature.cs

@@ -26,6 +26,8 @@ namespace Breeze.Wallet
 		{
 			BlockSubscriber sub = new BlockSubscriber(signals.Blocks, new BlockObserver(chain, trackerWrapper));
 			sub.Subscribe();
+            TransactionSubscriber txSub = new TransactionSubscriber(signals.Transactions, new TransactionObserver(trackerWrapper));
+		    txSub.Subscribe();
 		}
 	}
 

Breeze/src/Breeze.Wallet/Wrappers/ITrackerWrapper.cs

@@ -6,6 +6,8 @@ namespace Breeze.Wallet.Wrappers
     {
         void NotifyAboutBlock(int height, Block block);
 
+        void NotifyAboutTransaction(Transaction transaction);
+
         uint256 GetLastProcessedBlock();
     }
 }

Breeze/src/Breeze.Wallet/Wrappers/TrackerWrapper.cs

@@ -24,8 +24,16 @@ namespace Breeze.Wallet.Wrappers
 
         public void NotifyAboutBlock(int height, Block block)
         {
-            //this.tracker.AddOrReplaceBlock(new Height(height), block);
-			Console.WriteLine($"height: {height}, block hash: {block.Header.GetHash()}");
+            // this.tracker.AddOrReplaceBlock(new Height(height), block);
+            Console.WriteLine($"block notification: height: {height}, block hash: {block.Header.GetHash()}");
         }
+
+        public void NotifyAboutTransaction(Transaction transaction)
+        {
+            // TODO what should the height be? is it necessary?
+            // this.tracker.ProcessTransaction(new SmartTransaction(transaction, new Height(0)));
+            Console.WriteLine($"transaction notification: tx hash {transaction.GetHash()}");
+        }
+
     }
 }