Add buy/sell/cancel to BL3P (#475)

* Starting to handle requests

* Start add/remove orders implementation

* Implementation of proxies (unix like) to help debugging

* Add commands to buy/sell in console app

* Finished buy/sell implementation

* Fixes wait option

* Undo use of system.range

* Add call to cancel order and console option

* Fix json parsing

* Small fixes from PR review

* Fix json error and access modifiers

* Fix ws-orderbook for bl3p

* Add same proxy to WS

* Fix BL3P tests

Author: Johnny A. dos Santos

ExchangeSharp/API/Common/APIRequestMaker.cs

@@ -1,4 +1,4 @@
-/*
+/*
 MIT LICENSE
 
 Copyright 2017 Digital Ruby, LLC - http://www.digitalruby.com
@@ -14,7 +14,6 @@ The above copyright notice and this permission notice shall be included in all c
 using System.Collections.Generic;
 using System.IO;
 using System.Net;
-using System.Text;
 using System.Threading.Tasks;
 
 namespace ExchangeSharp
@@ -27,79 +26,93 @@ public sealed class APIRequestMaker : IAPIRequestMaker
     {
         private readonly IAPIRequestHandler api;
 
-        private class InternalHttpWebRequest : IHttpWebRequest
+        internal class InternalHttpWebRequest : IHttpWebRequest
         {
-            internal readonly HttpWebRequest request;
+            internal readonly HttpWebRequest Request;
+            internal static WebProxy Proxy;
+
+            static InternalHttpWebRequest()
+            {
+	            var httpProxy = Environment.GetEnvironmentVariable("http_proxy");
+	            httpProxy ??= Environment.GetEnvironmentVariable("HTTP_PROXY");
+
+	            if (string.IsNullOrEmpty(httpProxy))
+		            return;
+
+	            var uri = new Uri(httpProxy);
+	            Proxy = new WebProxy(uri);
+            }
 
             public InternalHttpWebRequest(Uri fullUri)
             {
-                request = (HttpWebRequest.Create(fullUri) as HttpWebRequest ?? throw new NullReferenceException("Failed to create HttpWebRequest"));
-                request.KeepAlive = false;
+                Request = (HttpWebRequest.Create(fullUri) as HttpWebRequest ?? throw new NullReferenceException("Failed to create HttpWebRequest"));
+                Request.Proxy = Proxy;
+                Request.KeepAlive = false;
             }
 
             public void AddHeader(string header, string value)
             {
                 switch (header.ToStringLowerInvariant())
                 {
                     case "content-type":
-                        request.ContentType = value;
+                        Request.ContentType = value;
                         break;
 
                     case "content-length":
-                        request.ContentLength = value.ConvertInvariant<long>();
+                        Request.ContentLength = value.ConvertInvariant<long>();
                         break;
 
                     case "user-agent":
-                        request.UserAgent = value;
+                        Request.UserAgent = value;
                         break;
 
                     case "accept":
-                        request.Accept = value;
+                        Request.Accept = value;
                         break;
 
                     case "connection":
-                        request.Connection = value;
+                        Request.Connection = value;
                         break;
 
                     default:
-                        request.Headers[header] = value;
+                        Request.Headers[header] = value;
                         break;
                 }
             }
 
             public Uri RequestUri
             {
-                get { return request.RequestUri; }
+                get { return Request.RequestUri; }
             }
 
             public string Method
             {
-                get { return request.Method; }
-                set { request.Method = value; }
+                get { return Request.Method; }
+                set { Request.Method = value; }
             }
 
             public int Timeout
             {
-                get { return request.Timeout; }
-                set { request.Timeout = value; }
+                get { return Request.Timeout; }
+                set { Request.Timeout = value; }
             }
 
             public int ReadWriteTimeout
             {
-                get { return request.ReadWriteTimeout; }
-                set { request.ReadWriteTimeout = value; }
+                get { return Request.ReadWriteTimeout; }
+                set { Request.ReadWriteTimeout = value; }
             }
 
             public async Task WriteAllAsync(byte[] data, int index, int length)
             {
-                using (Stream stream = await request.GetRequestStreamAsync())
+                using (Stream stream = await Request.GetRequestStreamAsync())
                 {
                     await stream.WriteAsync(data, 0, data.Length);
                 }
             }
         }
 
-        private class InternalHttpWebResponse : IHttpWebResponse
+        internal class InternalHttpWebResponse : IHttpWebResponse
         {
             private readonly HttpWebResponse response;
 
@@ -175,7 +188,7 @@ public async Task<string> MakeRequestAsync(string url, string? baseUrl = null, D
                 try
                 {
                     RequestStateChanged?.Invoke(this, RequestMakerState.Begin, uri.AbsoluteUri);// when start make a request we send the uri, this helps developers to track the http requests.
-                    response = await request.request.GetResponseAsync() as HttpWebResponse;
+                    response = await request.Request.GetResponseAsync() as HttpWebResponse;
                     if (response == null)
                     {
                         throw new APIException("Unknown response from server");
@@ -191,16 +204,19 @@ public async Task<string> MakeRequestAsync(string url, string? baseUrl = null, D
                 }
                 using (Stream responseStream = response.GetResponseStream())
                 using (StreamReader responseStreamReader = new StreamReader(responseStream))
-                responseString = responseStreamReader.ReadToEnd();
+                    responseString = responseStreamReader.ReadToEnd();
+
                 if (response.StatusCode != HttpStatusCode.OK)
                 {
-                    // 404 maybe return empty responseString
-                    if (string.IsNullOrWhiteSpace(responseString))
-                    {
+	                // 404 maybe return empty responseString
+	                if (string.IsNullOrWhiteSpace(responseString))
+	                {
                         throw new APIException(string.Format("{0} - {1}", response.StatusCode.ConvertInvariant<int>(), response.StatusCode));
-                    }
-                    throw new APIException(responseString);
+	                }
+
+	                throw new APIException(responseString);
                 }
+
                 api.ProcessResponse(new InternalHttpWebResponse(response));
                 RequestStateChanged?.Invoke(this, RequestMakerState.Finished, responseString);
             }

ExchangeSharp/API/Exchanges/BL3P/BL3PException.cs

@@ -0,0 +1,37 @@
+using System;
+using System.Runtime.Serialization;
+using ExchangeSharp.API.Exchanges.BL3P.Models;
+
+namespace ExchangeSharp.API.Exchanges.BL3P
+{
+	[Serializable]
+	internal class BL3PException : Exception
+	{
+		public string ErrorCode { get; }
+
+		internal BL3PException(BL3PResponsePayloadError error)
+			: this(error?.Message)
+		{
+			if (error == null)
+				throw new ArgumentNullException(nameof(error));
+			ErrorCode = error.ErrorCode;
+		}
+
+		public BL3PException(string message)
+			: base(message)
+		{
+		}
+
+		public BL3PException(string message, Exception inner)
+			: base(message, inner)
+		{
+		}
+
+		protected BL3PException(
+			SerializationInfo info,
+			StreamingContext context
+		) : base(info, context)
+		{
+		}
+	}
+}

ExchangeSharp/API/Exchanges/BL3P/Converters/BL3PResponseConverter.cs

@@ -0,0 +1,34 @@
+using ExchangeSharp.API.Exchanges.BL3P.Models;
+using ExchangeSharp.Dependencies.Converters;
+using Newtonsoft.Json;
+
+namespace ExchangeSharp.API.Exchanges.BL3P.Converters
+{
+	internal class BL3PResponseConverter<TSuccess> : JsonComplexObjectConverter<BL3PResponsePayload>
+		where TSuccess : BL3PResponsePayload, new()
+	{
+		protected override BL3PResponsePayload Create(JsonReader reader)
+		{
+			while (reader.Read())
+			{
+				if (reader.TokenType != JsonToken.PropertyName)
+				{
+					continue;
+				}
+
+				var prop = (string) reader.Value;
+
+				switch (prop)
+				{
+					// this is the first prop on an error object
+					case "code":
+						return new BL3PResponsePayloadError();
+					default:
+						return new TSuccess();
+				}
+			}
+
+			throw new JsonException("Could not locate key property in json.");
+		}
+	}
+}

ExchangeSharp/API/Exchanges/BL3P/Enums/BL3PCurrencyFee.cs

@@ -0,0 +1,8 @@
+namespace ExchangeSharp.API.Exchanges.BL3P.Enums
+{
+	public enum BL3PCurrencyFee : byte
+	{
+		BTC = 0,
+		EUR = 1
+	}
+}

ExchangeSharp/API/Exchanges/BL3P/Enums/BL3POrderStatus.cs

@@ -0,0 +1,11 @@
+namespace ExchangeSharp.API.Exchanges.BL3P.Enums
+{
+	internal enum BL3POrderStatus
+	{
+		Pending = 0,
+		Open,
+		Closed,
+		Cancelled,
+		Placed
+	}
+}

ExchangeSharp/API/Exchanges/BL3P/Enums/BL3POrderType.cs

@@ -0,0 +1,8 @@
+namespace ExchangeSharp.API.Exchanges.BL3P.Enums
+{
+	internal enum BL3POrderType
+	{
+		Bid,
+		Ask
+	}
+}

ExchangeSharp/API/Exchanges/BL3P/Enums/BL3PResponseType.cs

@@ -0,0 +1,9 @@
+namespace ExchangeSharp.API.Exchanges.BL3P.Enums
+{
+	internal enum BL3PResponseType
+	{
+		Unknown = 0,
+		Error,
+		Success
+	}
+}