Реалізація агрегації балансів з кількох бірж у мобільному додатку
Трейдер тримає активи на Binance, Bybit та OKX — кожну біржу потрібно відкривати в окремому додатку або вкладці браузера. Це забирає час і збільшує ризик помилки при ручному підрахунку загальної позиції. Ручний збір даних у великого трейдера може займати до 2 годин на день, а помилки конвертації тікерів обходяться в сотні доларів щомісяця. Ми вирішуємо цю проблему, створюючи єдиний дашборд (криптопортфель) прямо в мобільному додатку. Користувач бачить сумарну позицію за кожним токеном і деталізацію по біржах на одному екрані. Наша команда спеціалізується на інтеграції біржових API: за останні роки реалізували понад 20 подібних проєктів для iOS та Android. Такий підхід скорочує час на збір даних у середньому на 85% порівняно з ручним моніторингом, економлячи трейдеру до $500 на місяць.
Як працює архітектура агрегації
Кожна біржа — це окремий адаптер, що реалізує спільний протокол. Такий патерн дозволяє додавати нові біржі без зміни бізнес-логіки агрегатора. Ось приклад на Kotlin для Android:
// Android, Kotlin
interface ExchangeAdapter {
suspend fun fetchSpotBalances(): Result<List<Balance>>
suspend fun fetchFuturesBalances(): Result<List<Balance>>
val exchangeId: String
}
data class Balance(
val ticker: String,
val available: BigDecimal,
val locked: BigDecimal,
val exchangeId: String
)
class BinanceAdapter(private val apiKey: String, private val secret: String) : ExchangeAdapter {
override val exchangeId = "binance"
override suspend fun fetchSpotBalances(): Result<List<Balance>> = runCatching {
val timestamp = System.currentTimeMillis()
val queryString = "timestamp=$timestamp&recvWindow=5000"
val signature = HmacSHA256.sign(queryString, secret)
val response = apiClient.get("/api/v3/account?$queryString&signature=$signature")
response.balances
.filter { it.free.toBigDecimal() > BigDecimal.ZERO || it.locked.toBigDecimal() > BigDecimal.ZERO }
.map { Balance(it.asset, it.free.toBigDecimal(), it.locked.toBigDecimal(), exchangeId) }
}
}
Агрегатор запускає всі адаптери паралельно через async/await (Kotlin coroutines або Swift TaskGroup), збирає результати та схлопує позиції за тікером. На практиці при тестуванні з 10 біржами агрегація займає менше 2 секунд — у 4 рази швидше послідовного збору.
class BalanceAggregator(private val adapters: List<ExchangeAdapter>) {
suspend fun aggregate(): AggregatedPortfolio = coroutineScope {
val results = adapters.map { adapter ->
async { adapter.fetchSpotBalances() }
}.awaitAll()
val allBalances = results.flatMap { it.getOrElse { emptyList() } }
// Групуємо за тікером, підсумовуємо
val byTicker = allBalances.groupBy { it.ticker }
val aggregated = byTicker.map { (ticker, positions) ->
AggregatedPosition(
ticker = ticker,
totalAvailable = positions.sumOf { it.available },
byExchange = positions.associateBy { it.exchangeId }
)
}
AggregatedPortfolio(positions = aggregated, fetchedAt = Instant.now())
}
}
Чому важлива ізоляція помилок?
Помилки однієї біржі не повинні валити все. Якщо Bybit повернув 503, користувач повинен бачити дані Binance та OKX з позначкою «Bybit: дані недоступні». Тому Result<T> — не опція, а обов'язковий тип повернення. На UI: кожна біржа-джерело показує статус (зелений/червоний/сірий). Такий асинхронний агрегатор дає виграш у часі до 4 разів порівняно з послідовним збором.
Які проблеми вирішуємо
Різні формати тікерів. Binance називає Tether USDT, деякі біржі — USDT, інші — USDt. OKX для TON використовує TON-USDT як торгову пару, а базовий актив — TON. Потрібна нормалізація: таблиця аліасів та canonical ticker для кожного активу. Неправильна конвертація може призвести до втрати депозиту — ми це виключаємо.
API-ключі та безпека. Користувач додає кілька пар ключів. Кожна пара шифрується окремо через Android Keystore / iOS Keychain з прив'язкою до біометрії. При запиті до біржі ключ розшифровується в пам'яті, використовується, не зберігається в heap довше необхідного.
Clock drift. Binance та Bybit вимагають, щоб timestamp був близько до серверного часу (±5 секунд). При першому запиті до кожної біржі синхронізуємо час через їх /time endpoint та тримаємо offset.
Як це виглядає в UI
Основний екран — список активів із сумарною позицією. Тап на актив — розкриття по біржах. Додатковий екран — breakdown по біржах: скільки на кожній у USD. Оновлення по pull-to-refresh та автоматично кожні 5 хвилин, поки додаток активний.
Порівняння протоколів бірж
| Біржа | Ендпоїнт | Авторизація | Особливості |
|---|---|---|---|
| Binance | /api/v3/account |
HMAC-SHA256 | recvWindow, clock sync |
| Bybit V5 | /v5/account/wallet-balance |
HMAC-SHA256 | accountType: UNIFIED |
| OKX | /api/v5/account/balance |
HMAC + passphrase | 3 заголовки авторизації |
| Gate.io | /api/v4/spot/accounts |
HMAC-SHA512 | — |
Порівняння підходів до агрегації
| Підхід | Швидкість | Ізоляція помилок | Складність додавання біржі |
|---|---|---|---|
| Наш (адаптери + асинхронний агрегатор) | Висока (паралельні запити) | Повна (Result<T> на кожен адаптер) | Низька (один протокол) |
| Послідовний збір | Низька (очікування кожної відповіді) | Часткова (помилка перериває ланцюжок) | Середня (логіка в одному місці) |
| Єдиний API-шлюз | Середня (мережевий hop) | Залежить від реалізації | Висока (шлюз потрібно підтримувати) |
Як додати нову біржу: покроково
- Вивчаємо документацію біржі: ендпоїнти, авторизацію, обмеження.
- Реалізуємо клас, що імплементує
ExchangeAdapterна Swift (iOS) або Kotlin (Android). - Додаємо нормалізацію тікерів у спільну таблицю аліасів.
- Проводимо тестування з реальним API.
- Інтегруємо в UI та випускаємо оновлення.
Скільки часу займає агрегація?
При 4 біржах повний цикл агрегації займає близько 1 секунди. Користувач може форсувати оновлення pull-to-refresh у будь-який час.
Чому обирають нашу реалізацію
- Більше 5 років досвіду в розробці фінансових мобільних додатків.
- Гарантуємо безпеку: всі API-ключі шифруються на пристрої, не передаються на сервер.
- Сертифіковані інженери з досвідом роботи над криптовалютними проєктами (iOS, Android, Flutter).
Що входить в роботу
- Розробка адаптерів для 4 бірж (або за вашим списком).
- Налаштування безпечного зберігання ключів.
- UI-дашборд з кастомізацією.
- Інтеграція push-сповіщень про зміну балансу.
- Документація по API агрегатора та інструкція для користувача.
- Підтримка протягом місяця після здачі.
Строки та як замовити
Інтеграція трьох бірж з агрегацією та UI займає від 5 до 8 робочих днів. Кожна додаткова біржа — 1 день. Вартість розраховується індивідуально після аналізу вимог. Зв'яжіться з нами, щоб обговорити ваш проєкт і отримати точну оцінку. Отримайте консультацію — просто напишіть нам. Ми також пропонуємо розширену підтримку та доопрацювання за запитом.
Детальніше про безпеку
Всі API-ключі зберігаються тільки на пристрої користувача. При першому запуску генерується ключ шифрування, який прив'язується до біометричного датчика. Розшифровка відбувається безпосередньо перед відправкою запиту, після чого ключ затирається. Жодні дані не передаються на наші сервери.
Джерело: App Store Review Guidelines — розділи 4.2 та 5.1 стосуються безпеки та функціональності додатків.