Implement OrdersServiceProxy

Author: florinc

InterProcessCommunication/TradingApp/.Notes/PresentationScript.html

@@ -193,7 +193,7 @@ <h4 id="implement-proxies-to-call-the-services-as-a-rest-api">8. Implement proxi
 <ul>
 <li><code>ConsoleUi</code> loads service implementations AND / OR proxies
 <ul>
-<li>if we comment out the implementations only proxies are loaded =&gt; always inter-process communication</li>
+<li>if we comment out the load of the modules with implementation (in AppBoot bootstrapp) only proxies are loaded =&gt; always inter-process communication</li>
 <li><code>ConsoleUi</code> may act like a FE app if does not load service implementations.
 <ul>
 <li>It always calls services as inter-proc</li>
@@ -208,11 +208,12 @@ <h4 id="implement-proxies-to-call-the-services-as-a-rest-api">8. Implement proxi
 </li>
 <li>If for one service (interface) both the implementation and the proxy is deployed, then the last one AppBoot finds orverwrites the previous
 <ul>
-<li>non deterministic
+<li><strong>non deterministic!</strong>
 <ul>
 <li>even if the real implementation is deployed, it may not be used</li>
-<li>ex1: <code>ConsoleUi</code> loads the <code>QuotationServices.dll</code> and <code>PortfolioService</code> we would expect a <em>in-process</em> communication
+<li>ex1: (to have this demoed we might need to comment our the <code>PortfolioServiceProxy</code> othewise the non-deterministic behavior may make this tricky to demo)
 <ul>
+<li><code>ConsoleUi</code> loads the <code>QuotationServices.dll</code> and <code>PortfolioService.dll</code> we would expect a <em>in-process</em> communication</li>
 <li>but! the <code>PortfolioService</code> may get a proxy to call the <code>QuotationService</code> this result in a <em>inter-process</em> communitcation between <code>PortfolioSerivce</code> and <code>QuotationService</code></li>
 </ul>
 </li>

InterProcessCommunication/TradingApp/.Notes/PresentationScript.md

@@ -138,15 +138,16 @@ class QuotationService : IQuotationService
 
 **Points:**
  - `ConsoleUi` loads service implementations AND / OR proxies
-   - if we comment out the implementations only proxies are loaded => always inter-process communication
+   - if we comment out the load of the modules with implementation (in AppBoot bootstrapp) only proxies are loaded => always inter-process communication
    - `ConsoleUi` may act like a FE app if does not load service implementations. 
      - It always calls services as inter-proc
      - just through deployment `ConsoleUi` may call services *in-process* or *inter-process*
        - play w/ `PortfolioService` and w/ `QuotationService`
  - If for one service (interface) both the implementation and the proxy is deployed, then the last one AppBoot finds orverwrites the previous
-    - non deterministic
+    - **non deterministic!**
       - even if the real implementation is deployed, it may not be used 
-      - ex1: `ConsoleUi` loads the `QuotationServices.dll` and `PortfolioService` we would expect a *in-process* communication
+      - ex1: (to have this demoed we might need to comment our the `PortfolioServiceProxy` othewise the non-deterministic behavior may make this tricky to demo)
+        -  `ConsoleUi` loads the `QuotationServices.dll` and `PortfolioService.dll` we would expect a *in-process* communication
         -  but! the `PortfolioService` may get a proxy to call the `QuotationService` this result in a *inter-process* communitcation between `PortfolioSerivce` and `QuotationService`
       - ex2: 
         - `ConsoleUi` loads only proxies, the communication between `PortfolioSerivce` and `QuotationService` happens on the `ConsoleHost` only, in process!

InterProcessCommunication/TradingApp/ConsoleUi/App.config

@@ -6,5 +6,6 @@
   <appSettings>
     <add key="IPortfolioService_Address" value="http://localhost:9000/"/>
     <add key="IQuotationService_Address" value="http://localhost:9000/"/>
+    <add key="IOrdersService_Address" value="http://localhost:9000/"/>
   </appSettings>
 </configuration>

InterProcessCommunication/TradingApp/Infrastructure/Proxies/OrdersServiceProxy.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Net.Http;
+using System.Web;
+using Contracts.Sales.Services;
+using iQuarc.AppBoot;
+
+namespace Proxies
+{
+    [Service(typeof(IOrdersService))]
+    class OrdersServiceProxy : IOrdersService
+    {
+        public void PlaceSellLimitOrder(string securityCode, decimal sellingPrice, DateTime validUntil)
+        {
+            using (HttpClient client = HttpHelpers.CreateNewClient<IOrdersService>())
+            {
+                string path = HttpHelpers.GetServicePath<IOrdersService>("PlaceSellLimitOrder");
+                string uri = $"{path}?securityCode={securityCode}&sellingPrice={sellingPrice}&validUntil={validUntil}";
+                HttpResponseMessage response = client.PostAsync(uri, new StringContent(string.Empty)).Result;
+                if (!response.IsSuccessStatusCode)
+                    throw new HttpException((int)response.StatusCode, response.Content.ReadAsStringAsync().Result);
+            }
+        }
+
+        public void PlaceBuyLimitOrder(string securityCode, decimal buyingPrice, DateTime validUntil)
+        {
+            using (HttpClient client = HttpHelpers.CreateNewClient<IOrdersService>())
+            {
+                string path = HttpHelpers.GetServicePath<IOrdersService>("PlaceBuyLimitOrder");
+                string uri = $"{path}?securityCode={securityCode}&buyingPrice={buyingPrice}&validUntil={validUntil}";
+                HttpResponseMessage response = client.PostAsync(uri, new StringContent(string.Empty)).Result;
+                if (!response.IsSuccessStatusCode)
+                    throw new HttpException((int)response.StatusCode, response.Content.ReadAsStringAsync().Result);
+            }
+        }
+
+        public LimitOrder[] GetLimitOrders()
+        {
+            using (HttpClient client = HttpHelpers.CreateNewClient<IOrdersService>())
+            {
+                string path = HttpHelpers.GetServicePath<IOrdersService>("GetLimitOrders");
+                HttpResponseMessage response = client.GetAsync(path).Result;
+                if (response.IsSuccessStatusCode)
+                {
+                    LimitOrder[] value = response.Content.ReadAsAsync<LimitOrder[]>().Result;
+                    return value;
+                }
+
+                throw new HttpException((int)response.StatusCode, response.Content.ReadAsStringAsync().Result);
+            }
+        }
+    }
+}

InterProcessCommunication/TradingApp/Infrastructure/Proxies/Proxies.csproj

@@ -60,6 +60,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="HttpHelpers.cs" />
+    <Compile Include="OrdersServiceProxy.cs" />
     <Compile Include="PortfolioServiceProxy.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="ProxiesModule.cs" />