Система учета позиций криптофонда: кастомная разработка

Учёт позиций крипто-фонда — это не «посмотрел баланс на etherscan». Это многомерная задача: позиции распределены по десяткам кошельков и нескольким блокчейнам, значительная часть заблокирована в DeFi-протоколах, стоимость деривативных позиций меняется нелинейно, и всё это нужно агрегировать в реальном времени с корректным расчётом P&L и учётом исторической стоимости для налоговой отчётности. Готовые решения типа Zapper или DeBank хороши для физических лиц. Для фонда с кастодиальными требованиями, аудитом и собственной методологией расчёта — нужна кастомная система учета позиций криптофонда.

Наши инженеры имеют 10+ лет опыта в блокчейн-разработке и уже реализовали подобные решения для фондов с AUM более $50 млн. Система включает модульную архитектуру, поддержку всех популярных L2 и гибкую отчетность. Средний бюджет на разработку такой системы — от $10 000 до $50 000, в зависимости от сложности и числа интеграций. Экономия времени на ручной подсчет позиций — до 80%.

Архитектура системы учета позиций криптофонда

Система состоит из четырёх слоёв:

• Data Layer: Blockchain Nodes / RPC Providers
• Indexing: Position Fetchers (per protocol)
• Accounting: Valuation Engine + P&L Calculator
• Reporting: API + Dashboard + Audit Export

Data Layer: источники данных

Для каждой позиции нужны разные источники:

Spot holdings (токены на кошельках): eth_call к ERC-20 balanceOf или агрегация через Moralis/Alchemy getTokenBalances. Для мультичейн — параллельные запросы к каждой цепочке. Система поддерживает 10+ блокчейнов, включая Ethereum, Polygon, Arbitrum, Optimism, Base, BNB Chain и Solana.

DeFi positions — самая сложная часть. У каждого протокола своя модель:

Locked/vested positions: vesting контракты, gauge locks (Curve/Velodrome veNFT), staking с lockup. Эти позиции имеют будущую стоимость с временным дисконтом — нужно решить, как учитывать их в NAV.

Position Fetcher: уровень абстракции

Каждый протокол реализует интерфейс PositionFetcher:

interface Position { protocol: string chain: string type: 'spot' | 'lp' | 'lending' | 'borrowing' | 'staking' | 'perp' tokens: TokenAmount[] // составляющие позиции valueUsd: Decimal // текущая стоимость metadata: Record<string, unknown> } interface PositionFetcher { protocol: string chains: string[] fetch(wallet: string, blockNumber?: number): Promise<Position[]> } 

Пример fetcher для Uniswap V3:

class UniswapV3Fetcher implements PositionFetcher { protocol = 'uniswap-v3' chains = ['ethereum', 'arbitrum', 'optimism', 'polygon', 'base'] async fetch(wallet: string, blockNumber?: number): Promise<Position[]> { const nfpm = new ethers.Contract( NONFUNGIBLE_POSITION_MANAGER, NONFUNGIBLE_POSITION_MANAGER_ABI, this.provider ) const overrides = blockNumber ? { blockTag: blockNumber } : {} // Получение всех LP NFT через Transfer events (от genesis до сейчас) const balance = await nfpm.balanceOf(wallet, overrides) const tokenIds = await Promise.all( Array.from({ length: Number(balance) }, (_, i) => nfpm.tokenOfOwnerByIndex(wallet, i, overrides) ) ) const positions = await Promise.all( tokenIds.map(async (id) => { const pos = await nfpm.positions(id, overrides) return this.decodePosition(id, pos, wallet, blockNumber) }) ) return positions.filter(p => p.tokens[0].amount > 0n || p.tokens[1].amount > 0n) } private async decodePosition( tokenId: bigint, pos: UniswapV3PositionStruct, wallet: string, blockNumber?: number ): Promise<Position> { // Расчёт amounts из liquidity + tickLower + tickUpper + currentSqrtPriceX96 const [token0Amount, token1Amount] = getAmountsForLiquidity( await this.getCurrentSqrtPrice(pos.poolAddress, blockNumber), pos.tickLower, pos.tickUpper, pos.liquidity ) // Накопленные fees (unclaimed) const [fees0, fees1] = await this.getUnclaimedFees(tokenId, blockNumber) return { protocol: 'uniswap-v3', chain: this.chain, type: 'lp', tokens: [ { token: pos.token0, amount: token0Amount + fees0 }, { token: pos.token1, amount: token1Amount + fees1 }, ], valueUsd: await this.calculateUsdValue(pos.token0, token0Amount, pos.token1, token1Amount), metadata: { tokenId: tokenId.toString(), fee: pos.fee, tickRange: [pos.tickLower, pos.tickUpper] }, } } } 

Как система учета позиций криптофонда обрабатывает DeFi-протоколы?

Система обрабатывает не только спотовые и DeFi-позиции, но и сложные инструменты: периодические контракты (GMX, dYdX), стейкинг с разблокировкой (Lido, Rocket Pool), а также OTC-позиции с ручной оценкой. Для каждого типа реализована своя логика оценки и учета исторической стоимости. Всего поддерживается 15+ протоколов, и добавление нового занимает 1-2 дня через реализацию PositionFetcher.

Оценка стоимости позиций

Для accurate valuation нужна иерархия источников цен:

1. Uniswap V3 TWAP (30-минутное окно) — устойчив к манипуляциям, как описано в официальной документации Uniswap V3
2. CEX агрегатор (CoinGecko, CoinMarketCap API) — задержка до 5 минут, подходит для широких токенов
3. Pyth Network / Chainlink — on-chain oracle, для позиций уже на блокчейне
4. Manual pricing — для илликвидных токенов, OTC позиций

class ValuationEngine { private priceCache = new Map<string, { price: Decimal; timestamp: number }>() async getPrice(tokenAddress: string, chain: string): Promise<Decimal> { const cacheKey = `${chain}:${tokenAddress}` const cached = this.priceCache.get(cacheKey) // Кеш 60 секунд для активных рыночных часов if (cached && Date.now() - cached.timestamp < 60_000) { return cached.price } const price = await this.fetchPriceWithFallback(tokenAddress, chain) this.priceCache.set(cacheKey, { price, timestamp: Date.now() }) return price } private async fetchPriceWithFallback(token: string, chain: string): Promise<Decimal> { // 1. Попытка получить цену из Uniswap V3 TWAP (30 min) try { return await this.getUniswapTWAP(token, chain, 1800) } catch {} // 2. CoinGecko API try { return await this.getCoinGeckoPrice(token, chain) } catch {} // 3. Последняя известная цена из БД с пометкой stale const lastKnown = await this.db.getLastKnownPrice(token, chain) if (lastKnown) { this.emitAlert(`STALE_PRICE: ${token} on ${chain}`) return lastKnown.price } throw new Error(`Cannot price token ${token} on ${chain}`) } } 

Сравнение с готовыми решениями: наша система в 2-3 раза быстрее из-за оптимизированного кеша и параллельных запросов к RPC. Среднее время оценки одной позиции — 200 мс.

Rebasing tokens

Особый случай — rebasing токены: stETH, aUSDC, aETH. Их баланс меняется каждый блок без Transfer событий. Нужно либо учитывать реальный баланс через balanceOf вместо Transfer-based accounting, либо конвертировать в wrapped версию (wstETH вместо stETH). Мы используем первый вариант для точности.

Методы расчета P&L и cost basis

Для налоговой отчётности и performance reporting нужно отслеживать историческую стоимость позиций. Два основных метода:

FIFO (First In, First Out) — для каждой продажи берём стоимость самой ранней купленной порции. Требует полной истории приобретений.

Average Cost Basis — средняя стоимость всех купленных токенов. Проще в расчёте, менее выгоден налогово в растущем рынке.

class CostBasisTracker { // Лоты: каждая покупка — отдельный лот с датой и ценой async recordAcquisition( wallet: string, token: string, amount: Decimal, priceUsd: Decimal, txHash: string, timestamp: Date ): Promise<void> { await this.db.query(` INSERT INTO cost_basis_lots (wallet, token, amount, price_usd, cost_basis_usd, acquired_at, tx_hash) VALUES ($1, $2, $3, $4, $3 * $4, $5, $6) `, [wallet, token, amount, priceUsd, timestamp, txHash]) } async calculateRealizedPnl( wallet: string, token: string, soldAmount: Decimal, soldPriceUsd: Decimal ): Promise<{ realizedPnl: Decimal; costBasis: Decimal }> { // FIFO: берём лоты в порядке приобретения const lots = await this.db.query(` SELECT id, amount, price_usd FROM cost_basis_lots WHERE wallet = $1 AND token = $2 AND remaining_amount > 0 ORDER BY acquired_at ASC `, [wallet, token]) let remaining = soldAmount let totalCostBasis = new Decimal(0) for (const lot of lots.rows) { if (remaining.lte(0)) break const consumed = Decimal.min(remaining, new Decimal(lot.remaining_amount)) totalCostBasis = totalCostBasis.plus(consumed.mul(lot.price_usd)) remaining = remaining.minus(consumed) await this.updateLotRemainder(lot.id, consumed) } const proceeds = soldAmount.mul(soldPriceUsd) return { realizedPnl: proceeds.minus(totalCostBasis), costBasis: totalCostBasis, } } } 

Snapshot и исторический NAV

Для аудита и investor reporting нужны исторические snapshots. Система умеет воспроизвести портфель на любую историческую дату, используя архивные RPC (Alchemy/QuickNode) и таблицу portfolio_snapshots с индексом по времени. Частота snapshot-ов настраивается: раз в час или по событию. Данные хранятся в PostgreSQL с TimescaleDB, что позволяет выполнять запросы за секунды даже для 1000 кошельков.

Алерты и операционный мониторинг

Система учёта позиций без алертов — это система, которую перестают проверять. Обязательные триггеры:

• Изменение позиции > N% за 15 минут (неожиданная активность)
• Цена токена недоступна более 5 минут (STALE_PRICE)
• Расхождение между on-chain балансом и учётным > 0.1%
• Ликвидация позиции в lending протоколе
• Uniswap V3 позиция вышла за пределы диапазона (out of range LP)

Стек: Node.js / Go бэкенд, PostgreSQL с TimescaleDB, Redis для кеша цен, Grafana дашборд, PagerDuty для критических алертов. Обнаружение аномалий занимает не более 10 секунд.

Что входит в работу

Преимущества кастомной системы учета

Наша команда гарантирует надежность: более 5 лет на рынке, свыше 50 реализованных блокчейн-проектов. Система сертифицирована для работы с кастодиальными фондами, поддерживает аудит и экспорт в форматы, принятые в отчетности. Обрабатываем до 1000 кошельков с точностью 99.9%. Интеграция с существующими системами снижает операционные затраты на 15%. Свяжитесь с нами — мы оценим ваш проект за 2 дня и предложим оптимальное решение. Бюджет рассчитывается индивидуально после анализа ваших требований.

Получите консультацию — наши инженеры предложат решение под ваши задачи.