Add CoinbaseRestClientExchangeApi

Coinbase.Net.UnitTests/Endpoints/AdvancedTrade/Account/CreateDepositAddress.txt

@@ -10,6 +10,7 @@ true
     "updated_at": "2015-03-31T17:25:29-07:00",
     "network": "bitcoin",
     "resource": "address",
-    "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/dd3183eb-af1d-5f5d-a90d-cbff946435ff"
+    "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/dd3183eb-af1d-5f5d-a90d-cbff946435ff",
+    "destination_tag":"123"
   }
 }

Coinbase.Net.UnitTests/Endpoints/AdvancedTrade/Account/GetDepositAddress.txt

@@ -11,6 +11,7 @@ true
     "updated_at": "2015-03-31T17:25:29-07:00",
     "network": "bitcoin",
     "resource": "address",
-    "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/dd3183eb-af1d-5f5d-a90d-cbff946435ff/"
+    "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/dd3183eb-af1d-5f5d-a90d-cbff946435ff/",
+    "destination_tag":"123"
   }
 }

Coinbase.Net.UnitTests/Endpoints/AdvancedTrade/Account/GetDepositAddresses.txt

@@ -29,7 +29,8 @@ true
       "updated_at": "2015-01-31T20:49:02Z",
       "network": "bitcoin",
       "resource": "address",
-      "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/ac5c5f15-0b1d-54f5-8912-fecbf66c2a64"
+      "resource_path": "/v2/accounts/2bbf394c-193b-5b2a-9155-3b4732659ede/addresses/ac5c5f15-0b1d-54f5-8912-fecbf66c2a64",
+      "destination_tag":"123"
     }
   ]
 }

Coinbase.Net/Clients/CoinbaseRestClient.cs

@@ -7,6 +7,8 @@
 using CryptoExchange.Net.Clients;
 using Coinbase.Net.Interfaces.Clients.AdvancedTradeApi;
 using Coinbase.Net.Clients.AdvancedTradeApi;
+using Coinbase.Net.Clients.ExchangeApi;
+using Coinbase.Net.Interfaces.Clients.ExchangeApi;
 using Microsoft.Extensions.Options;
 using CryptoExchange.Net.Objects.Options;
 
@@ -19,7 +21,8 @@ public class CoinbaseRestClient : BaseRestClient, ICoinbaseRestClient
 
          /// <inheritdoc />
         public ICoinbaseRestClientAdvancedTradeApi AdvancedTradeApi { get; }
-
+         /// <inheritdoc />
+        public ICoinbaseRestClientExchangeApi ExchangeApi { get; }
 
         #endregion
 
@@ -45,6 +48,7 @@ public CoinbaseRestClient(HttpClient? httpClient, ILoggerFactory? loggerFactory,
             Initialize(options.Value);
 
             AdvancedTradeApi = AddApiClient(new CoinbaseRestClientAdvancedTradeApi(this, _logger, httpClient, options.Value));
+            ExchangeApi = AddApiClient(new CoinbaseRestClientExchangeApi(this, _logger, httpClient, options.Value));
         }
 
         #endregion

Coinbase.Net/Clients/ExchangeApi/CoinbaseRestClientExchangeApi.cs

@@ -0,0 +1,93 @@
+using Coinbase.Net.Clients.MessageHandlers;
+using Coinbase.Net.Interfaces.Clients.ExchangeApi;
+using Coinbase.Net.Objects.Options;
+using CryptoExchange.Net.Authentication;
+using CryptoExchange.Net.Clients;
+using CryptoExchange.Net.Converters.MessageParsing.DynamicConverters;
+using CryptoExchange.Net.Converters.SystemTextJson;
+using CryptoExchange.Net.Interfaces;
+using CryptoExchange.Net.Objects;
+using CryptoExchange.Net.Objects.Errors;
+using CryptoExchange.Net.SharedApis;
+using Microsoft.Extensions.Logging;
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Coinbase.Net.Clients.ExchangeApi;
+
+/// <summary>
+/// Client providing access to the Coinbase Exchange rest Api
+/// </summary>
+internal class CoinbaseRestClientExchangeApi : RestApiClient, ICoinbaseRestClientExchangeApi
+{
+    #region fields 
+    internal static TimeSyncState _timeSyncState = new TimeSyncState("Exchange Api");
+
+    protected override IRestMessageHandler MessageHandler { get; } = new CoinbaseRestMessageHandler(CoinbaseErrors.Errors);
+    protected override ErrorMapping ErrorMapping => CoinbaseErrors.Errors;
+    #endregion
+
+    #region Api clients
+    /// <inheritdoc />
+    public ICoinbaseRestClientExchangeApiExchangeData ExchangeData { get; }
+    /// <inheritdoc />
+    public string ExchangeName => "Coinbase";
+    #endregion
+
+    #region constructor/destructor
+    internal CoinbaseRestClientExchangeApi(CoinbaseRestClient baseClient, ILogger logger, HttpClient? httpClient, CoinbaseRestOptions options)
+        : base(logger, httpClient, options.Environment.ExchangeRestClientAddress, options, options.ExchangeOptions)
+    {
+        ExchangeData = new CoinbaseRestClientExchangeApiExchangeData(this);
+
+        ArraySerialization = ArrayParametersSerialization.MultipleValues;
+
+        StandardRequestHeaders = new Dictionary<string, string>
+        {
+            { "User-Agent", "CryptoExchange.Net/" + baseClient.CryptoExchangeLibVersion }
+        };
+    }
+    #endregion
+
+    /// <inheritdoc />
+    protected override IStreamMessageAccessor CreateAccessor() => new SystemTextJsonStreamMessageAccessor(SerializerOptions.WithConverters(CoinbaseExchange._serializerContext));
+    /// <inheritdoc />
+    protected override IMessageSerializer CreateSerializer() => new SystemTextJsonMessageSerializer(SerializerOptions.WithConverters(CoinbaseExchange._serializerContext));
+
+    /// <inheritdoc />
+    protected override AuthenticationProvider CreateAuthenticationProvider(ApiCredentials credentials)
+        => new CoinbaseAuthenticationProvider(credentials);
+    internal Task<WebCallResult> SendAsync(RequestDefinition definition, ParameterCollection? parameters, CancellationToken cancellationToken, int? weight = null)
+        => SendToAddressAsync(BaseAddress, definition, parameters, cancellationToken, weight);
+    internal async Task<WebCallResult> SendToAddressAsync(string baseAddress, RequestDefinition definition, ParameterCollection? parameters, CancellationToken cancellationToken, int? weight = null)
+    {
+        return await base.SendAsync(baseAddress, definition, parameters, cancellationToken, null, weight).ConfigureAwait(false);
+    }
+
+    internal Task<WebCallResult<T>> SendAsync<T>(RequestDefinition definition, ParameterCollection? parameters, CancellationToken cancellationToken, int? weight = null) where T : class
+        => SendToAddressAsync<T>(BaseAddress, definition, parameters, cancellationToken, weight);
+
+    internal async Task<WebCallResult<T>> SendToAddressAsync<T>(string baseAddress, RequestDefinition definition, ParameterCollection? parameters, CancellationToken cancellationToken, int? weight = null) where T : class
+    {
+        return await base.SendAsync<T>(baseAddress, definition, parameters, cancellationToken, null, weight).ConfigureAwait(false);
+    }
+
+    /// <inheritdoc />
+    protected override Task<WebCallResult<DateTime>> GetServerTimestampAsync()
+        => ExchangeData.GetServerTimeAsync();
+
+    /// <inheritdoc />
+    public override TimeSyncInfo? GetTimeSyncInfo()
+        => new TimeSyncInfo(_logger, ApiOptions.AutoTimestamp ?? ClientOptions.AutoTimestamp, ApiOptions.TimestampRecalculationInterval ?? ClientOptions.TimestampRecalculationInterval, _timeSyncState);
+
+    /// <inheritdoc />
+    public override TimeSpan? GetTimeOffset()
+        => _timeSyncState.TimeOffset;
+
+    /// <inheritdoc />
+    public override string FormatSymbol(string baseAsset, string quoteAsset, TradingMode tradingMode, DateTime? deliverTime = null)
+        => CoinbaseExchange.FormatSymbol(baseAsset, quoteAsset, tradingMode, deliverTime);
+}

Coinbase.Net/Clients/ExchangeApi/CoinbaseRestClientExchangeApiExchangeData.cs

@@ -0,0 +1,56 @@
+using Coinbase.Net.Interfaces.Clients.ExchangeApi;
+using Coinbase.Net.Objects.Models;
+using CryptoExchange.Net.Objects;
+using System;
+using System.Net.Http;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Coinbase.Net.Clients.ExchangeApi;
+
+internal class CoinbaseRestClientExchangeApiExchangeData : ICoinbaseRestClientExchangeApiExchangeData
+{
+    private readonly CoinbaseRestClientExchangeApi _baseClient;
+    private static readonly RequestDefinitionCache _definitions = new RequestDefinitionCache();
+
+    internal CoinbaseRestClientExchangeApiExchangeData(CoinbaseRestClientExchangeApi baseClient)
+    {
+        _baseClient = baseClient;
+    }
+
+    #region Get Server Time
+
+    /// <inheritdoc />
+    public async Task<WebCallResult<DateTime>> GetServerTimeAsync(CancellationToken ct = default)
+    {
+        var request = _definitions.GetOrCreate(HttpMethod.Get, "time", CoinbaseExchange.RateLimiter.CoinbaseRestPublic, 1, false);
+        var result = await _baseClient.SendAsync<CoinbaseTime>(request, null, ct).ConfigureAwait(false);
+        return result.As(result.Data?.Time ?? default);
+    }
+
+    #endregion
+
+    #region Get Crypto ExAssets
+
+    /// <inheritdoc />
+    public async Task<WebCallResult<CoinbaseExAsset[]>> GetCoinbaseExAssetAsync(CancellationToken ct = default)
+    {
+        var parameters = new ParameterCollection();
+        var request = _definitions.GetOrCreate(HttpMethod.Get, "currencies", CoinbaseExchange.RateLimiter.CoinbaseRestPublic, 1, false);
+        var result = await _baseClient.SendAsync<CoinbaseExAsset[]> (request, parameters, ct).ConfigureAwait(false);
+        return result;
+    }
+
+    #endregion
+
+    #region Get Crypto ExSymbols
+    /// <inheritdoc />
+    public async Task<WebCallResult<CoinbaseExSymbol[]>> GetCoinbaseExSymbolAsync(CancellationToken ct = default)
+    {
+        var parameters = new ParameterCollection();
+        var request = _definitions.GetOrCreate(HttpMethod.Get, "products", CoinbaseExchange.RateLimiter.CoinbaseRestPublic, 1, false);
+        var result = await _baseClient.SendAsync<CoinbaseExSymbol[]>(request, parameters, ct).ConfigureAwait(false);
+        return result;
+    }
+    #endregion
+}