/**

* FCS Real-time Cryptocurrency Example - C#

*

* WebSocket client for real-time crypto prices.

* Run: dotnet run

*/

using System;

using System.Collections.Generic;

using System.Text.Json;

using FcsApi;

class Program

{

const string ApiKey = "fcs_socket_demo";

static readonly string[] Symbols = { "BINANCE:BTCUSDT", "BINANCE:ETHUSDT", "BINANCE:BNBUSDT", "BINANCE:SOLUSDT" };

const string Timeframe = "1D";

static readonly Dictionary<string, PriceData> Prices = new();

static void Main(string[] args)

{

Console.WriteLine("\nConnecting to FCS WebSocket...");

Console.WriteLine("Press Ctrl+C to stop\n");

using var client = new FcsClient(ApiKey);

client.OnConnected += () =>

{

Console.WriteLine("\n" + new string('=', 60));

Console.WriteLine(" FCS Real-time Crypto Prices - C# Example");

Console.WriteLine(new string('=', 60));

Console.WriteLine($" API Key: {ApiKey}");

Console.WriteLine($" Symbols: {string.Join(", ", Symbols)}");

Console.WriteLine($" Timeframe: {Timeframe}");

Console.WriteLine(new string('=', 60) + "\n");

foreach (var symbol in Symbols)

client.Join(symbol, Timeframe);

};

client.OnMessage += (data) =>

{

var type = data.TryGetProperty("type", out var t) ? t.GetString() : null;

if (type != "price") return;

if (!data.TryGetProperty("prices", out var prices)) return;

var symbol = data.TryGetProperty("symbol", out var s) ? s.GetString() : "";

var mode = prices.TryGetProperty("mode", out var m) ? m.GetString() : "";

if (mode == "initial" || mode == "candle")

{

var priceData = new PriceData

{

Open = GetValue(prices, "o"),

High = GetValue(prices, "h"),

Low = GetValue(prices, "l"),

Close = GetValue(prices, "c"),

Volume = GetValue(prices, "v"),

Ask = GetValue(prices, "a"),

Bid = GetValue(prices, "b")

};

Prices[symbol] = priceData;

PrintPrice(symbol, priceData);

}

else if (mode == "askbid")

{

var ask = GetValue(prices, "a");

var bid = GetValue(prices, "b");

Console.WriteLine($" {symbol}: Ask={ask} Bid={bid}");

}

};

client.OnClose += (code, msg) => Console.WriteLine($"\n[!] Connection closed: {code} - {msg}");

client.OnError += (error) => Console.WriteLine($"\n[!] Error: {error.Message}");

Console.CancelKeyPress += (sender, e) =>

{

e.Cancel = true;

Console.WriteLine("\n\nDisconnecting...");

client.Disconnect();

Console.WriteLine("Goodbye!");

Environment.Exit(0);

};

client.Connect();

client.RunForever();

}

static string GetValue(JsonElement el, string prop) =>

el.TryGetProperty(prop, out var v) ? v.ToString() : null;

static void PrintPrice(string symbol, PriceData p)

{

var name = symbol.Contains(":") ? symbol.Split(':')[1] : symbol;

Console.WriteLine($"\n [{name}]");

Console.WriteLine($" Price: ${p.Close}");

Console.WriteLine($" O: {p.Open} | H: {p.High} | L: {p.Low} | C: {p.Close}");

if (!string.IsNullOrEmpty(p.Volume))

Console.WriteLine($" Volume: {p.Volume}");

if (!string.IsNullOrEmpty(p.Ask) && !string.IsNullOrEmpty(p.Bid))

Console.WriteLine($" Ask: {p.Ask} | Bid: {p.Bid}");

}

class PriceData

{

public string Open { get; set; }

public string High { get; set; }

public string Low { get; set; }

public string Close { get; set; }

public string Volume { get; set; }

public string Ask { get; set; }

public string Bid { get; set; }

}

}