flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2025-06-09 17:06:19 +00:00
Code Issues Releases Wiki Activity

Added FTX to console example

Browse Source
This commit is contained in:
Jan Korf 2022-01-20 21:08:51 +01:00
parent 3e23882572
commit 325389cdf8
4 changed files with 104 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
Examples/ConsoleClient/Exchanges/BinanceExchange.cs
View File

@ -22,6 +22,13 @@ namespace ConsoleClient.Exchanges
return result.AsDataless();
}
public async Task<Dictionary<string, decimal>> GetBalances()
{
using var client = new BinanceClient();
var result = await client.SpotApi.Account.GetAccountInfoAsync();
return result.Data.Balances.ToDictionary(b => b.Asset, b => b.Total);
}
public async Task<IEnumerable<OpenOrder>> GetOpenOrders()
{
using var client = new BinanceClient();

74
Examples/ConsoleClient/Exchanges/FTXExchange.cs Normal file
View File

@ -0,0 +1,74 @@
using ConsoleClient.Models;
using CryptoExchange.Net.Objects;
using CryptoExchange.Net.Sockets;
using FTX.Net.Clients;
using FTX.Net.Interfaces.Clients;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleClient.Exchanges
{
internal class FTXExchange : IExchange
{
private IFTXSocketClient _socketClient = new FTXSocketClient();
public async Task<WebCallResult> CancelOrder(string symbol, string id)
{
using var client = new FTXClient();
var result = await client.TradeApi.Trading.CancelOrderAsync(long.Parse(id));
return result.AsDataless();
}
public async Task<Dictionary<string, decimal>> GetBalances()
{
using var client = new FTXClient();
var result = await client.TradeApi.Account.GetBalancesAsync();
return result.Data.ToDictionary(d => d.Asset, d => d.Total);
}
public async Task<IEnumerable<OpenOrder>> GetOpenOrders()
{
using var client = new FTXClient();
var order = await client.TradeApi.Trading.GetOpenOrdersAsync();
return order.Data.Select(o => new OpenOrder
{
Symbol = o.Symbol,
OrderSide = o.Side.ToString(),
OrderStatus = o.Status.ToString(),
OrderTime = o.CreateTime,
OrderType = o.Type.ToString(),
Price = o.Price ?? 0,
Quantity = o.Quantity,
QuantityFilled = o.QuantityFilled ?? 0
});
}
public async Task<decimal> GetPrice(string symbol)
{
using var client = new FTXClient();
var result = await client.TradeApi.ExchangeData.GetSymbolAsync(symbol);
return result.Data.LastPrice ?? 0;
}
public async Task<WebCallResult<string>> PlaceOrder(string symbol, string side, string type, decimal quantity, decimal? price)
{
using var client = new FTXClient();
var result = await client.TradeApi.Trading.PlaceOrderAsync(
symbol,
side.ToLower() == "buy" ? FTX.Net.Enums.OrderSide.Buy : FTX.Net.Enums.OrderSide.Sell,
type == "market" ? FTX.Net.Enums.OrderType.Market : FTX.Net.Enums.OrderType.Limit,
quantity,
price: price);
return result.As(result.Data?.Id.ToString());
}
public async Task<UpdateSubscription> SubscribePrice(string symbol, Action<decimal> handler)
{
var sub = await _socketClient.Streams.SubscribeToTickerUpdatesAsync(symbol, data => handler(data.Data.LastPrice ?? 0));
return sub.Data;
}
}
}

1
Examples/ConsoleClient/Exchanges/IExchange.cs
View File

@ -13,6 +13,7 @@ namespace ConsoleClient.Exchanges
{
Task<decimal> GetPrice(string symbol);
Task<IEnumerable<OpenOrder>> GetOpenOrders();
Task<Dictionary<string, decimal>> GetBalances();
Task<WebCallResult> CancelOrder(string symbol, string id);
Task<WebCallResult<string>> PlaceOrder(string symbol, string side, string type, decimal quantity, decimal? price );
Task<UpdateSubscription> SubscribePrice(string symbol, Action<decimal> handler);

24
Examples/ConsoleClient/Program.cs
View File

@ -8,6 +8,8 @@ using Binance.Net.Objects;
using ConsoleClient.Exchanges;
using CryptoExchange.Net.Authentication;
using CryptoExchange.Net.Sockets;
using FTX.Net.Clients;
using FTX.Net.Objects;
using Microsoft.Extensions.Logging;
namespace ConsoleClient
@ -16,7 +18,8 @@ namespace ConsoleClient
{
static Dictionary<string, IExchange> _exchanges = new Dictionary<string, IExchange>
{
{ "Binance", new BinanceExchange() }
{ "Binance", new BinanceExchange() },
{ "FTX", new FTXExchange() }
};
static async Task Main(string[] args)
@ -26,10 +29,15 @@ namespace ConsoleClient
LogLevel = LogLevel.Trace,
ApiCredentials = new ApiCredentials("APIKEY", "APISECRET")
});
FTXClient.SetDefaultOptions(new FTXClientOptions
{
LogLevel = LogLevel.Trace,
ApiCredentials = new ApiCredentials("APIKEY", "APISECRET")
});
while (true)
{
Console.WriteLine("> Available commands: PlaceOrder, GetOpenOrders, CancelOrder, GetPrice, SubscribePrice");
Console.WriteLine("> Available commands: PlaceOrder, GetBalances, GetOpenOrders, CancelOrder, GetPrice, SubscribePrice");
var input = Console.ReadLine();
switch (input)
@ -37,6 +45,9 @@ namespace ConsoleClient
case "PlaceOrder":
await ProcessPlaceOrder();
break;
case "GetBalances":
await ProcessGetBalances();
break;
case "GetOpenOrders":
await ProcessGetOpenOrders();
break;
@ -75,6 +86,15 @@ namespace ConsoleClient
Console.WriteLine("Failed to place order: " + result.Error);
}
static async Task ProcessGetBalances()
{
var exchange = GetInput("Exchange?");
Console.WriteLine("Requesting balances...");
var balances = await _exchanges[exchange].GetBalances();
foreach (var balance in balances.Where(b => b.Value != 0))
Console.WriteLine($"> {balance.Key}: {balance.Value}");
}
static async Task ProcessGetOpenOrders()
{
var exchange = GetInput("Exchange?");