Client Classes

using SsiSdk;

var config = new Config("YOUR_CLIENT_ID")
{
    ApiKey = "YOUR_API_KEY",
    ApiSecret = "YOUR_API_SECRET",
    PrivateKey = "YOUR_PRIVATE_KEY",
};

using var auth = new AuthClient(config);

var token = await auth.AuthenticateAsync("YOUR_OTP");
Console.WriteLine($"Đã xác thực, token hết hạn lúc (epoch giây): {token.ExpiresAt}");

// Yêu cầu gửi OTP (trả về OtpResponse { Message, TransactionId? })
OtpResponse otp = await auth.RequestOtpTypedAsync();
// RequestOtpAsync() trả về JsonElement thô

// Xác thực với OTP
var token = await auth.AuthenticateAsync("YOUR_OTP");

// Xác thực không cần OTP (chỉ dữ liệu thị trường)
var token = await auth.AuthenticateAsync();

// Làm mới token
var token = await auth.RefreshAsync();

// Đảm bảo xác thực (dùng token hiện có, refresh nếu hết hạn, hoặc xác thực lại)
var accessToken = await auth.EnsureAuthenticatedAsync("YOUR_OTP");

// Bước 1: gửi yêu cầu duyệt, nhận TransactionId
var otp = await auth.RequestOtpTypedAsync();

// Bước 2: SDK poll cho đến khi user bấm duyệt trên app Smart OTP
var accessToken = await auth.EnsureAuthenticatedAsync(
    transactionId: otp.TransactionId,
    pollIntervalMs: 5000,      // mặc định Config.OtpPollIntervalMs
    pollMaxRetries: 12);       // mặc định suy ra từ Config.OtpPollMaxWaitMs

auth.AccessToken;                    // access token hiện tại (string, rỗng nếu chưa có)
auth.TokenManager.Token;             // đối tượng Token đầy đủ
auth.TokenManager.IsTokenExpired;    // true/false
auth.SetToken(token);                // thiết lập token (cache); cũng có auth.TokenManager.SetToken
auth.RateLimit;                      // RateLimitInfo từ response gần nhất

using SsiSdk;

using var auth = new AuthClient(config);
await auth.AuthenticateAsync();

var data = new DataClient(auth);

var ohlc = await data.MarketData.GetOhlc1MinuteAsync("SSI");
var indexes = await data.MarketData.GetIndexesAsync();
var info = await data.MarketData.GetSecuritiesInfoAsync("SSI");

using SsiSdk;

using var auth = new AuthClient(config);
await auth.AuthenticateAsync("YOUR_OTP");

var trading = new TradingClient(auth);

// Tài khoản
var accounts = await trading.Account.GetAccountInfoAsync();

// Danh mục
var balance = await trading.Portfolio.GetEquityBalanceAsync("YOUR_ACCOUNT_NO");
var positions = await trading.Portfolio.GetEquityPositionsAsync("YOUR_ACCOUNT_NO");
var orders = await trading.Portfolio.GetTodayOrdersAsync("YOUR_ACCOUNT_NO");

// Giao dịch
var result = await trading.Trading.PlaceLimitOrderAsync(
    "YOUR_ACCOUNT_NO", "SSI", OrderSide.Buy, 100, 66000m);

using SsiSdk;
using SsiSdk.Models;

using var auth = new AuthClient(config);
await auth.AuthenticateAsync("YOUR_OTP");

using var stream = new StreamClient(auth);

// Đăng ký callback
stream.Streaming.SetOnData(msg =>
{
    switch (msg)
    {
        case TradeMessage trade:
            Console.WriteLine($"[TRADE] {trade.Symbol} | {trade.Price} | {trade.Quantity}");
            break;
        case QuoteMessage quote:
            Console.WriteLine($"[QUOTE] {quote.Symbol}");
            break;
    }
});

stream.Streaming.SetOnTrading(msg =>
{
    if (msg is OrderStatusMessage order)
        Console.WriteLine($"[ORDER] {order.Symbol} {order.Side} | {order.Status}");
});

// Kết nối và subscribe
await stream.ConnectAsync();

await stream.Streaming.SubscribeSymbolAsync(["SSI", "HPG"]);
await stream.Streaming.SubscribeOrderStatusAsync();

await stream.WaitAsync();

stream.IsConnected;         // true/false
stream.LastError;           // Exception? gần nhất
stream.ReconnectCount;      // số lần đã reconnect
stream.OnConnection = e => Console.WriteLine($"{e.State} (reconnect #{e.ReconnectCount})");
stream.Streaming.StopPingLoop();
await stream.DisconnectAsync();   // gọi khi không dùng using; cũng có Disconnect() đồng bộ

using SsiSdk;
using SsiSdk.Models;

var config = new Config("YOUR_CLIENT_ID")
{
    ApiKey = "YOUR_API_KEY",
    ApiSecret = "YOUR_API_SECRET",
    PrivateKey = "YOUR_PRIVATE_KEY",
};

using var auth = new AuthClient(config);
await auth.AuthenticateAsync("YOUR_OTP");

// Dữ liệu thị trường
var data = new DataClient(auth);
var ohlc = await data.MarketData.GetOhlc1MinuteAsync("SSI");
Console.WriteLine(ohlc);

// Giao dịch
var trading = new TradingClient(auth);
var accounts = await trading.Account.GetAccountInfoAsync();
Console.WriteLine(accounts);

// Streaming
using var stream = new StreamClient(auth);

stream.Streaming.SetOnData(msg =>
{
    if (msg is TradeMessage trade)
        Console.WriteLine($"[TRADE] {trade.Symbol} | {trade.Price} | {trade.Quantity}");
});

await stream.ConnectAsync();
await stream.Streaming.SubscribeSymbolAsync(["SSI", "HPG"]);
await stream.Streaming.SubscribeOrderStatusAsync();

await stream.WaitAsync(timeoutMs: 30000);