API حرفه‌ای برای ساخت، اتصال و ترید خودکار

# قیمت لحظه‌ای بیت‌کوین به تتر
curl "https://api.exir.io/v2/ticker?symbol=btc-usdt"

const res = await fetch(
  "https://api.exir.io/v2/ticker?symbol=btc-usdt"
);
const ticker = await res.json();
console.log(ticker.last);

import requests

res = requests.get(
    "https://api.exir.io/v2/ticker",
    params={"symbol": "btc-usdt"},
)
print(res.json()["last"])

// قیمت لحظه‌ای بیت‌کوین به تتر
$res = file_get_contents("https://api.exir.io/v2/ticker?symbol=btc-usdt");
$ticker = json_decode($res, true);
echo $ticker["last"];

using System.Text.Json;

using var http = new HttpClient();
var json = await http.GetStringAsync(
    "https://api.exir.io/v2/ticker?symbol=btc-usdt");
var ticker = JsonDocument.Parse(json).RootElement;
Console.WriteLine(ticker.GetProperty("last"));

// npm install exir-node-lib
const Exir = require('exir-node-lib');

const client = new Exir({
  apiKey: '<API_KEY>',
  apiSecret: '<API_SECRET>',
});

const main = async () => {
  // موجودی کیف پول
  const balance = await client.getBalance();
  console.log('balance:', balance);

  // ثبت سفارش limit
  const order = await client.createOrder('btc-usdt', 'buy', 0.001, 'limit', 50000);
  console.log('created order:', order);

  // دریافت همان سفارش با شناسه
  const fetched = await client.getOrder(order.id);
  console.log('order:', fetched);

  // WebSocket: اشتراک در همه کانال‌های خصوصی (ping را خود کتابخانه می‌فرستد)
  // wallet: موجودی، order: وضعیت سفارش‌ها، usertrade: اجرای معاملات،
  // deposit / withdrawal: وضعیت واریز و برداشت
  client.connect(['wallet', 'order', 'usertrade', 'deposit', 'withdrawal']);
  client.ws.on('message', (raw) => {
    const message = JSON.parse(raw);
    if (!message.topic) return; // پیام‌های سیستمی مثل pong
    console.log(message.topic, message.action, message.data);
  });
};

main().catch(console.error);

# pip install requests websocket-client
import hashlib
import hmac
import json
import threading
import time
import requests
import websocket

API_KEY = '<API_KEY>'
API_SECRET = '<API_SECRET>'
BASE_URL = 'https://api.exir.io'


def sign(payload):
    return hmac.new(API_SECRET.encode(), payload.encode(), hashlib.sha256).hexdigest()


def auth_headers(method, path, body=''):
    expires = str(int(time.time()) + 60)
    return {
        'api-key': API_KEY,
        'api-signature': sign(method + path + expires + body),
        'api-expires': expires,
        'Content-Type': 'application/json',
    }


# موجودی کیف پول
balance = requests.get(
    BASE_URL + '/v2/user/balance',
    headers=auth_headers('GET', '/v2/user/balance'),
).json()
print('balance:', balance)

# ثبت سفارش limit
body = json.dumps(
    {'symbol': 'btc-usdt', 'side': 'buy', 'size': 0.001, 'type': 'limit', 'price': 50000},
    separators=(',', ':'),
)
order = requests.post(
    BASE_URL + '/v2/order',
    headers=auth_headers('POST', '/v2/order', body),
    data=body,
).json()
print('created order:', order)

# دریافت همان سفارش با شناسه
path = '/v2/order?order_id=' + order['id']
print('order:', requests.get(BASE_URL + path, headers=auth_headers('GET', path)).json())

# WebSocket: اشتراک در کانال wallet
expires = str(int(time.time()) + 60)
ws_url = (
    'wss://api.exir.io/stream'
    f'?api-key={API_KEY}&api-signature={sign("CONNECT/stream" + expires)}&api-expires={expires}'
)

def keep_alive(ws):
    # هر ۳۰ ثانیه یک ping بفرستید تا اتصال باز بماند
    while True:
        time.sleep(30)
        ws.send(json.dumps({'op': 'ping'}))


def on_open(ws):
    # wallet: موجودی، order: وضعیت سفارش‌ها، usertrade: اجرای معاملات،
    # deposit / withdrawal: وضعیت واریز و برداشت
    ws.send(json.dumps({
        'op': 'subscribe',
        'args': ['wallet', 'order', 'usertrade', 'deposit', 'withdrawal'],
    }))
    threading.Thread(target=keep_alive, args=(ws,), daemon=True).start()


def on_message(ws, raw):
    message = json.loads(raw)
    if 'topic' in message:
        print(message['topic'], message.get('action'), message.get('data'))


ws = websocket.WebSocketApp(ws_url, on_open=on_open, on_message=on_message)
ws.run_forever()

<?php
// composer require textalk/websocket
require __DIR__ . '/vendor/autoload.php';

use WebSocket\Client;

$apiKey = '<API_KEY>';
$apiSecret = '<API_SECRET>';
$baseUrl = 'https://api.exir.io';

function apiRequest($method, $path, $body = null)
{
    global $apiKey, $apiSecret, $baseUrl;
    $expires = time() + 60;
    $bodyJson = $body === null ? '' : json_encode($body);
    $signature = hash_hmac('sha256', $method . $path . $expires . $bodyJson, $apiSecret);

    $ch = curl_init($baseUrl . $path);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'api-key: ' . $apiKey,
        'api-signature: ' . $signature,
        'api-expires: ' . $expires,
        'Content-Type: application/json',
    ]);
    if ($body !== null) {
        curl_setopt($ch, CURLOPT_POSTFIELDS, $bodyJson);
    }
    $response = curl_exec($ch);
    curl_close($ch);
    return json_decode($response, true);
}

// موجودی کیف پول
$balance = apiRequest('GET', '/v2/user/balance');
echo 'balance: ' . json_encode($balance) . PHP_EOL;

// ثبت سفارش limit
$order = apiRequest('POST', '/v2/order', [
    'symbol' => 'btc-usdt',
    'side' => 'buy',
    'size' => 0.001,
    'type' => 'limit',
    'price' => 50000,
]);
echo 'created order: ' . json_encode($order) . PHP_EOL;

// دریافت همان سفارش با شناسه
$fetched = apiRequest('GET', '/v2/order?order_id=' . $order['id']);
echo 'order: ' . json_encode($fetched) . PHP_EOL;

// WebSocket: اشتراک در کانال wallet
$expires = time() + 60;
$signature = hash_hmac('sha256', 'CONNECT/stream' . $expires, $apiSecret);
$ws = new Client(
    "wss://api.exir.io/stream?api-key=$apiKey&api-signature=$signature&api-expires=$expires",
    ['timeout' => 30]
);
// wallet: موجودی، order: وضعیت سفارش‌ها، usertrade: اجرای معاملات،
// deposit / withdrawal: وضعیت واریز و برداشت
$ws->send(json_encode([
    'op' => 'subscribe',
    'args' => ['wallet', 'order', 'usertrade', 'deposit', 'withdrawal'],
]));

while (true) {
    try {
        $message = json_decode($ws->receive(), true);
        if (isset($message['topic'])) {
            echo $message['topic'] . ' ' . $message['action'] . ' ' . json_encode($message['data']) . PHP_EOL;
        }
    } catch (\WebSocket\TimeoutException $e) {
        // هر ۳۰ ثانیه سکوت، یک ping بفرستید تا اتصال باز بماند
        $ws->send(json_encode(['op' => 'ping']));
    }
}

// .NET 6+ — بدون وابستگی خارجی (dotnet run)
using System.Net.WebSockets;
using System.Security.Cryptography;
using System.Text;
using System.Text.Json;

const string ApiKey = "<API_KEY>";
const string ApiSecret = "<API_SECRET>";
const string BaseUrl = "https://api.exir.io";

string Sign(string payload)
{
    using var hmac = new HMACSHA256(Encoding.UTF8.GetBytes(ApiSecret));
    return Convert.ToHexString(hmac.ComputeHash(Encoding.UTF8.GetBytes(payload))).ToLowerInvariant();
}

var http = new HttpClient();

async Task<JsonElement> ApiRequestAsync(HttpMethod method, string path, string? body = null)
{
    var expires = DateTimeOffset.UtcNow.ToUnixTimeSeconds() + 60;
    var request = new HttpRequestMessage(method, BaseUrl + path);
    request.Headers.Add("api-key", ApiKey);
    request.Headers.Add("api-signature", Sign($"{method}{path}{expires}{body}"));
    request.Headers.Add("api-expires", expires.ToString());
    if (body != null)
        request.Content = new StringContent(body, Encoding.UTF8, "application/json");
    var response = await http.SendAsync(request);
    return JsonDocument.Parse(await response.Content.ReadAsStringAsync()).RootElement;
}

// موجودی کیف پول
var balance = await ApiRequestAsync(HttpMethod.Get, "/v2/user/balance");
Console.WriteLine($"balance: {balance}");

// ثبت سفارش limit
var orderBody = JsonSerializer.Serialize(new
{
    symbol = "btc-usdt",
    side = "buy",
    size = 0.001,
    type = "limit",
    price = 50000,
});
var order = await ApiRequestAsync(HttpMethod.Post, "/v2/order", orderBody);
Console.WriteLine($"created order: {order}");

// دریافت همان سفارش با شناسه
var orderId = order.GetProperty("id").GetString();
var fetched = await ApiRequestAsync(HttpMethod.Get, $"/v2/order?order_id={orderId}");
Console.WriteLine($"order: {fetched}");

// WebSocket: اشتراک در کانال wallet
var wsExpires = DateTimeOffset.UtcNow.ToUnixTimeSeconds() + 60;
var wsUrl = "wss://api.exir.io/stream" +
    $"?api-key={ApiKey}&api-signature={Sign($"CONNECT/stream{wsExpires}")}&api-expires={wsExpires}";

using var ws = new ClientWebSocket();
await ws.ConnectAsync(new Uri(wsUrl), CancellationToken.None);

async Task SendAsync(object message) => await ws.SendAsync(
    Encoding.UTF8.GetBytes(JsonSerializer.Serialize(message)),
    WebSocketMessageType.Text, true, CancellationToken.None);

// wallet: موجودی، order: وضعیت سفارش‌ها، usertrade: اجرای معاملات،
// deposit / withdrawal: وضعیت واریز و برداشت
await SendAsync(new { op = "subscribe", args = new[] { "wallet", "order", "usertrade", "deposit", "withdrawal" } });

// هر ۳۰ ثانیه یک ping بفرستید تا اتصال باز بماند
_ = Task.Run(async () =>
{
    while (ws.State == WebSocketState.Open)
    {
        await Task.Delay(TimeSpan.FromSeconds(30));
        await SendAsync(new { op = "ping" });
    }
});

var buffer = new byte[65536];
while (ws.State == WebSocketState.Open)
{
    var result = await ws.ReceiveAsync(buffer, CancellationToken.None);
    var message = JsonDocument.Parse(Encoding.UTF8.GetString(buffer, 0, result.Count)).RootElement;
    if (message.TryGetProperty("topic", out var topic))
        Console.WriteLine(topic + " " + message.GetProperty("action") + " " + message.GetProperty("data"));
}