Add mediator examples

BehavioralPatterns.sln

@@ -18,6 +18,8 @@ Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "CommandPattern", "src\Comma
 EndProject
 Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "IteratorPattern", "src\IteratorPattern\IteratorPattern.xproj", "{6F3B7F9A-4D9C-4506-A5F7-3FF5CF4376BD}"
 EndProject
+Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "MediatorPattern", "src\MediatorPattern\MediatorPattern.xproj", "{2A63BD0A-9D07-4755-9B16-5DDBEB075B80}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -40,6 +42,10 @@ Global
 		{6F3B7F9A-4D9C-4506-A5F7-3FF5CF4376BD}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{6F3B7F9A-4D9C-4506-A5F7-3FF5CF4376BD}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{6F3B7F9A-4D9C-4506-A5F7-3FF5CF4376BD}.Release|Any CPU.Build.0 = Release|Any CPU
+		{2A63BD0A-9D07-4755-9B16-5DDBEB075B80}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{2A63BD0A-9D07-4755-9B16-5DDBEB075B80}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{2A63BD0A-9D07-4755-9B16-5DDBEB075B80}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{2A63BD0A-9D07-4755-9B16-5DDBEB075B80}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -49,5 +55,6 @@ Global
 		{89536824-683F-4351-8789-406D7BDD922D} = {3820200F-354C-41E6-8F34-B301F5D621C2}
 		{454B2A43-8251-4667-8DE3-67E489908DB9} = {3820200F-354C-41E6-8F34-B301F5D621C2}
 		{6F3B7F9A-4D9C-4506-A5F7-3FF5CF4376BD} = {3820200F-354C-41E6-8F34-B301F5D621C2}
+		{2A63BD0A-9D07-4755-9B16-5DDBEB075B80} = {3820200F-354C-41E6-8F34-B301F5D621C2}
 	EndGlobalSection
 EndGlobal

src/BehavioralPatterns/Program.cs

@@ -2,6 +2,7 @@
 using ChainOfResponssibility.PurchaseExample;
 using CommandPattern;
 using IteratorPattern;
+using MediatorPattern;
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
@@ -28,6 +29,9 @@ namespace BehavioralPatterns
             IteratorPatternExamples.Run();
             Console.ReadKey();
 
+
+            MediatorPatternExamples.Run();
+
         }
     }
 }

src/BehavioralPatterns/project.json

@@ -11,6 +11,7 @@
     "ChainOfResponssibility": "1.0.0-*",
     "CommandPattern": "1.0.0-*",
     "IteratorPattern": "1.0.0-*",
+    "MediatorPattern": "1.0.0-*",
     "Microsoft.NETCore.App": {
       "type": "platform",
       "version": "1.0.0-rc2-3002702"

src/MediatorPattern/AirTrafficControl/AirTrafficControl.cs

@@ -0,0 +1,59 @@
+using MediatorPattern.AirTrafficControl;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.AirTrafficControl
+{
+    public class AirTrafficControl : IAirTrafficControlTower
+    {
+        List<Lane> lanes;
+        object lockLanes = new object();
+        public AirTrafficControl(List<Lane> lanes)
+        {
+            this.lanes = lanes;
+        }
+        public bool RequestLaneForMaintainance(MaintainerTeam team, Lane lane)
+        {
+            var requestedLane = lanes.FirstOrDefault(l => l.ID == lane.ID);
+
+            if (requestedLane == null)
+                return false;
+            lock (lockLanes)
+            {
+                if (requestedLane.IsAvailable)
+                {
+                    requestedLane.IsAvailable = false;
+                    Console.WriteLine("Lane {0} is now used by maintainers", lane.ID);
+                    return true;
+                }
+                else
+                {
+                    Console.WriteLine("Lane {0} cannot be used by maintainers because it's already in use", lane.ID);
+                    return false;
+                }
+            }
+        }
+
+        public Optional<Lane> RequestPermissionToLand(Plane plane)
+        {
+            lock (lockLanes)
+            {
+                var availableLane = lanes.FirstOrDefault(l => l.IsAvailable);
+
+                if (availableLane != null)
+                {
+                    availableLane.IsAvailable = false;
+                    Console.WriteLine("Approved landing for plane {0} on lane {1}", plane.ID, availableLane.ID);                    
+                    return Optional<Lane>.Of(availableLane);
+                }
+                else
+                {
+                    Console.WriteLine("Landing not approved for plane {0}", plane.ID);
+                    return Optional<Lane>.Empty;
+                }
+            }
+        }
+    }
+}

src/MediatorPattern/AirTrafficControl/AirTrafficControlExample.cs

@@ -0,0 +1,35 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.AirTrafficControl
+{
+    public class AirTrafficControlExample
+    {
+        public void Run()
+        {
+            Lane l1 = new Lane(1);
+            Lane l2 = new Lane(2);
+            Lane l3 = new Lane(3);
+            Lane l4 = new Lane(4, isAvailable: false);
+
+            IAirTrafficControlTower controlTower = new AirTrafficControl(new List<Lane> { l1, l2, l3, l4 });
+
+            MaintainerTeam m1 = new MaintainerTeam(controlTower);
+            m1.RequestLane(l1);
+
+            Plane p1a = new Plane("1a", controlTower);
+            Plane p1b = new Plane("1b", controlTower);
+            Plane p1c = new Plane("1c", controlTower);
+            Plane p1d = new Plane("1d", controlTower);
+
+            
+            p1a.RequestPermissionToLand();
+            p1b.RequestPermissionToLand();
+            p1c.RequestPermissionToLand();
+            p1d.RequestPermissionToLand();
+            
+        }
+    }
+}

src/MediatorPattern/AirTrafficControl/IAirTrafficControlTower.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.AirTrafficControl
+{
+    /// <summary>
+    /// Mediator
+    /// </summary>
+    public interface IAirTrafficControlTower
+    {
+
+        Optional<Lane> RequestPermissionToLand(Plane plane);
+
+        bool RequestLaneForMaintainance(MaintainerTeam team, Lane lane);        
+
+    }
+}

src/MediatorPattern/AirTrafficControl/Lane.cs

@@ -0,0 +1,14 @@
+namespace MediatorPattern.AirTrafficControl
+{
+    public class Lane
+    {
+        public Lane(int id, bool isAvailable = true)
+        {
+            ID = id;
+            IsAvailable = isAvailable;
+        }
+        public int ID { get; private set; }
+
+        public bool IsAvailable { get; set; }
+    }
+}

src/MediatorPattern/AirTrafficControl/MaintainerTeam.cs

@@ -0,0 +1,16 @@
+namespace MediatorPattern.AirTrafficControl
+{
+    public class MaintainerTeam
+    {
+        IAirTrafficControlTower airControlTower;
+        public MaintainerTeam(IAirTrafficControlTower airControlTower)
+        {
+            this.airControlTower = airControlTower;
+        }
+
+        public void RequestLane(Lane lane)
+        {
+            airControlTower.RequestLaneForMaintainance(this, lane);
+        }
+    }
+}

src/MediatorPattern/AirTrafficControl/Optional.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.AirTrafficControl
+{
+    public class Optional<T>
+    {
+        private Optional() { }
+        
+        public bool IsPresent { get; private set; }
+
+        private T value;
+
+        public T Value
+        {
+            get
+            {
+                if (!IsPresent)
+                    throw new InvalidOperationException("Could not get value from empty");
+                return value;
+            }
+            private set { this.value = value; }
+        }
+
+        public static Optional<T> Empty
+        {
+            get
+            {
+                return new Optional<T>() { IsPresent = false };
+            }
+        }
+
+        public static Optional<T> Of(T value)
+        {
+            return new Optional<T>() { IsPresent = true, Value = value };
+        }
+    }
+}

src/MediatorPattern/AirTrafficControl/Plane.cs

@@ -0,0 +1,25 @@
+using System;
+
+namespace MediatorPattern.AirTrafficControl
+{
+    public class Plane
+    {
+        public string ID { get; private set; }
+        IAirTrafficControlTower controlTower;
+        public Plane(string id, IAirTrafficControlTower controlTower)
+        {
+            this.controlTower = controlTower;
+            ID = id;
+        }
+
+        public void RequestPermissionToLand()
+        {
+            var lane = controlTower.RequestPermissionToLand(this);
+
+            if (lane.IsPresent)
+                Console.WriteLine("Landing");
+            else
+                Console.WriteLine("I will ask again in 5 minutes");
+        }
+    }
+}

src/MediatorPattern/MediatorPattern.xproj

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="14.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <VisualStudioVersion Condition="'$(VisualStudioVersion)' == ''">14.0</VisualStudioVersion>
+    <VSToolsPath Condition="'$(VSToolsPath)' == ''">$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)</VSToolsPath>
+  </PropertyGroup>
+
+  <Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.Props" Condition="'$(VSToolsPath)' != ''" />
+  <PropertyGroup Label="Globals">
+    <ProjectGuid>2a63bd0a-9d07-4755-9b16-5ddbeb075b80</ProjectGuid>
+    <RootNamespace>MediatorPattern</RootNamespace>
+    <BaseIntermediateOutputPath Condition="'$(BaseIntermediateOutputPath)'=='' ">.\obj</BaseIntermediateOutputPath>
+    <OutputPath Condition="'$(OutputPath)'=='' ">.\bin\</OutputPath>
+    <TargetFrameworkVersion>v4.6.1</TargetFrameworkVersion>
+  </PropertyGroup>
+
+  <PropertyGroup>
+    <SchemaVersion>2.0</SchemaVersion>
+  </PropertyGroup>
+  <Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.targets" Condition="'$(VSToolsPath)' != ''" />
+</Project>

src/MediatorPattern/MediatorPatternExamples.cs

@@ -0,0 +1,50 @@
+using MediatorPattern.AirTrafficControl;
+using MediatorPattern.StockExchange;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern
+{    
+    public class MediatorPatternExamples
+    {
+        public static void Run()
+        {
+            Console.WriteLine(GetPatternDescription());
+            Console.WriteLine(GetActors());
+
+            //GoToNextStep();
+
+            //StockExchangeExample stockExample = new StockExchangeExample();
+            //stockExample.Run();
+
+            GoToNextStep();
+            AirTrafficControlExample airTraficExample = new AirTrafficControlExample();
+            airTraficExample.Run();
+        }
+
+        static string GetPatternDescription()
+        {
+            return @"Pattern description:
+With the mediator pattern, communication between objects is encapsulated with a mediator object. 
+Objects no longer communicate directly with each other, but instead communicate through the mediator. 
+This reduces the dependencies between communicating objects, thereby lowering the coupling.";
+        }
+
+        static string GetActors()
+        {
+            return @"Actors:
+Mediator: interface of the mediator, that defines what messages does it mediate between colleagues.
+Concrete Mediator: implementation of the interface
+Colleague: objects that communicate through the mediator
+";
+        }
+
+        private static void GoToNextStep()
+        {
+            Console.ReadKey();
+            Console.Clear();
+        }
+    }
+}

src/MediatorPattern/Properties/AssemblyInfo.cs

@@ -0,0 +1,19 @@
+using System.Reflection;
+using System.Runtime.CompilerServices;
+using System.Runtime.InteropServices;
+
+// General Information about an assembly is controlled through the following
+// set of attributes. Change these attribute values to modify the information
+// associated with an assembly.
+[assembly: AssemblyConfiguration("")]
+[assembly: AssemblyCompany("Hewlett-Packard Company")]
+[assembly: AssemblyProduct("MediatorPattern")]
+[assembly: AssemblyTrademark("")]
+
+// Setting ComVisible to false makes the types in this assembly not visible
+// to COM components.  If you need to access a type in this assembly from
+// COM, set the ComVisible attribute to true on that type.
+[assembly: ComVisible(false)]
+
+// The following GUID is for the ID of the typelib if this project is exposed to COM
+[assembly: Guid("2a63bd0a-9d07-4755-9b16-5ddbeb075b80")]

src/MediatorPattern/StockExchange/Buyer.cs

@@ -0,0 +1,16 @@
+namespace MediatorPattern.StockExchange
+{
+    public class Buyer : Trader
+    {
+        IStockExchange stockExchange;
+        public Buyer(string name, string symbol, int count, double price, IStockExchange stockExchange) : base(name, symbol, count, price)
+        {
+            this.stockExchange = stockExchange;            
+        }
+
+        public bool BuyFromStockExchange()
+        {
+            return stockExchange.Buy(this, new StockRequest { Count = Count, Price = Price, Symbol = Symbol, Requester = Name });
+        }
+    }
+}

src/MediatorPattern/StockExchange/IStockExchange.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.StockExchange
+{
+    /// <summary>
+    /// Mediator
+    /// </summary>
+    public interface IStockExchange
+    {
+        bool Buy(Trader trader, StockRequest request);
+
+        bool Sell(Trader trader, StockRequest request);
+    }    
+}

src/MediatorPattern/StockExchange/Seller.cs

@@ -0,0 +1,21 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.StockExchange
+{
+    public class Seller : Trader
+    {
+        IStockExchange stockExchange;
+        public Seller(string name, string symbol, int count, double price, IStockExchange stockExchange) : base(name, symbol, count, price)
+        {
+            this.stockExchange = stockExchange;
+        }
+
+        public bool SellFromStockExchange()
+        {
+            return stockExchange.Sell(this, new StockRequest { Count = Count, Price = Price, Symbol = Symbol, Requester = Name });
+        }
+    }
+}

src/MediatorPattern/StockExchange/StockExchange.cs

@@ -0,0 +1,89 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.StockExchange
+{
+    public class StockExchange : IStockExchange
+    {
+        Dictionary<string, List<Trader>> sellers;
+        Dictionary<string, List<Trader>> buyers;
+
+        public StockExchange()
+        {
+            sellers = new Dictionary<string, List<Trader>>();
+            buyers = new Dictionary<string, List<Trader>>();
+            
+        }
+        protected void AddSeller(Trader trader)
+        {
+            AddTrader(trader, sellers);
+        }
+
+        protected void AddBuyer(Trader trader)
+        {
+            AddTrader(trader, buyers);
+        }        
+
+        public bool Buy(Trader trader, StockRequest request)
+        {
+            if (!sellers.ContainsKey(request.Symbol))
+            {
+                AddBuyer(trader);
+                Console.WriteLine("There are no sellers for {0}", request.Symbol);
+                return false;
+            }
+
+            List<Trader> sellersOfStock = sellers[request.Symbol];
+
+            var couldBuyStocks = sellersOfStock.Any(s => s.AcceptSell(request));
+
+            if (!couldBuyStocks)
+            {
+                AddBuyer(trader);
+                Console.WriteLine("No one seller sells it at this price, try a higher price");
+            }
+            else
+            {
+                Console.WriteLine("Actions bought");
+            }
+
+            return couldBuyStocks;
+        }
+
+        public bool Sell(Trader trader, StockRequest request)
+        {
+            if (!buyers.ContainsKey(request.Symbol))
+            {
+                AddSeller(trader);
+                Console.WriteLine("There are no buyers for {0}", request.Symbol);
+                return false;
+            }
+
+            var couldSellStocks = buyers[request.Symbol].Any(b => b.AcceptBuy(request));
+
+            if (!couldSellStocks)
+            {
+                AddSeller(trader);
+                Console.WriteLine("No one seller buys it at this price, try a lower price");
+            }
+                
+
+            return couldSellStocks;
+        }
+
+        private void AddTrader(Trader trader, Dictionary<string, List<Trader>> traderList)
+        {
+            if (!traderList.ContainsKey(trader.Symbol))
+            {
+                traderList.Add(trader.Symbol, new List<Trader> { trader });
+            }
+            else
+            {
+                traderList[trader.Symbol].Add(trader);
+            }
+        }
+    }
+}
+

src/MediatorPattern/StockExchange/StockExchangeExample.cs

@@ -0,0 +1,24 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.StockExchange
+{
+    public class StockExchangeExample
+    {
+        public void Run()
+        {
+            IStockExchange stockExchange = new StockExchange();
+            Buyer aaplBuyer = new Buyer("El Ciupi AAPL", "AAPL", 100, 15.0, stockExchange);
+            var buyResult = aaplBuyer.BuyFromStockExchange();
+
+            Seller aaplSeller = new Seller("capo di APPL", "AAPL", 100, 16.0, stockExchange);
+            var sellResult = aaplSeller.SellFromStockExchange();
+
+            aaplSeller = new Seller("capo di APPL", "AAPL", 100, 14.0, stockExchange);
+            sellResult = aaplSeller.SellFromStockExchange();
+
+        }
+    }
+}

src/MediatorPattern/StockExchange/StockRequest.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace MediatorPattern.StockExchange
+{
+    public class StockRequest
+    {
+        public string Symbol { get; set; }
+
+        public int Count { get; set; }
+
+        public double Price { get; set; }
+
+        public string Requester { get; set; }
+    }
+}

src/MediatorPattern/StockExchange/Trader.cs

@@ -0,0 +1,47 @@
+using System;
+
+namespace MediatorPattern.StockExchange
+{
+    /// <summary>
+    /// Colleague
+    /// </summary>
+    public class Trader
+    {
+        public string Name { get; private set; }
+        public Trader(string name, string symbol, int count, double price)
+        {
+            Name = name;
+            Symbol = symbol;
+            Count = count;
+            Price = price;
+        }
+        public string Symbol { get; private set; }
+
+        public int Count { get; private set; }
+
+        public double Price { get; private set; }
+
+        public virtual bool AcceptSell(StockRequest request)
+        {
+            if(request.Price >= Price)
+            {
+                Console.WriteLine("{0} will sell {1} actions of {2} at the price of {3} to {4}",
+                    Name, request.Count, request.Symbol, request.Price, request.Requester);
+                return true;
+            }
+            return false;
+        }
+
+        public virtual bool AcceptBuy(StockRequest request)
+        {
+            if(request.Price <= Price)
+            {
+                Console.WriteLine("{0} will buy {1} actions of {2} at the price of {3} from {4}",
+                    Name, request.Count, request.Symbol, request.Price, request.Requester);
+                return true;
+            }
+
+            return false;
+        }
+    }
+}

src/MediatorPattern/project.json

@@ -0,0 +1,13 @@
+{
+  "version": "1.0.0-*",
+
+  "dependencies": {
+    "NETStandard.Library": "1.5.0-rc2-24027"
+  },
+
+  "frameworks": {
+    "netstandard1.5": {
+      "imports": "dnxcore50"
+    }
+  }
+}