Add Coin Analytics endpoints

app/src/main/java/io/horizontalsystems/marketkit/demo/MainViewModel.kt

@@ -453,6 +453,51 @@ class MainViewModel(private val marketKit: MarketKit) : ViewModel() {
             }
     }
 
+    fun runAnalyticsPreview() {
+        val chain = "ethereum"
+        marketKit.analyticsPreviewSingle(chain)
+            .subscribeOn(Schedulers.io())
+            .subscribe({ data ->
+                Log.e("AAA", "cexVolume rank30d: ${data.cexVolume?.rank30d} points: ${data.cexVolume?.points} dexVolume rank30d: ${data.dexVolume?.rank30d} points: ${data.dexVolume?.points} ")
+                Log.e("AAA", "fundsInvested: ${data.fundsInvested} holders: ${data.holders} ")
+            }, {
+                Log.e("AAA", "runAnalyticsPreview error", it)
+            }).let {
+                disposables.add(it)
+            }
+    }
+
+    fun runAnalytics() {
+        val chain = "ethereum"
+        val currencyCode = "usd"
+        marketKit.analyticsSingle(chain, currencyCode)
+            .subscribeOn(Schedulers.io())
+            .subscribe({ data ->
+                Log.e("AAA", "cexVolume rank30d: ${data.cexVolume?.rank30d} points.size: ${data.cexVolume?.points?.size} transactions volume30d: ${data.transactions?.volume30d} points.size: ${data.transactions?.points?.size} ")
+                Log.e("AAA", "fundsInvested: ${data.fundsInvested} holders.size: ${data.holders?.size} ")
+            }, {
+                Log.e("AAA", "runAnalyticsPreview error", it)
+            }).let {
+                disposables.add(it)
+            }
+    }
+
+    fun runTokenHolders() {
+        val blockchainUid = "uniswap"
+        marketKit.tokenHoldersSingle(blockchainUid)
+            .subscribeOn(Schedulers.io())
+            .subscribe({ data ->
+                Log.e("AAA", "runTokenHolders count: ${data.count} holders.size: ${data.topHolders.size} ")
+                data.topHolders.forEach { holder ->
+                    Log.e("AAA", "Holder: address: ${holder.address} percentage: ${holder.percentage} ")
+                }
+            }, {
+                Log.e("AAA", "runAnalyticsPreview error", it)
+            }).let {
+                disposables.add(it)
+            }
+    }
+
     override fun onCleared() {
         disposables.clear()
     }

marketkit/src/main/assets/initial_coins_list

@@ -1,4 +1,4 @@
-CREATE TABLE IF NOT EXISTS `BlockchainEntity` (`uid` TEXT NOT NULL, `name` TEXT NOT NULL, `explorerUrl` TEXT, PRIMARY KEY(`uid`));
+CREATE TABLE IF NOT EXISTS `BlockchainEntity` (`uid` TEXT NOT NULL, `name` TEXT NOT NULL, `eip3091url` TEXT, PRIMARY KEY(`uid`));
 CREATE TABLE IF NOT EXISTS `Coin` (`uid` TEXT NOT NULL, `name` TEXT NOT NULL, `code` TEXT NOT NULL, `marketCapRank` INTEGER, `coinGeckoId` TEXT, PRIMARY KEY(`uid`));
 CREATE TABLE IF NOT EXISTS `TokenEntity` (`coinUid` TEXT NOT NULL, `blockchainUid` TEXT NOT NULL, `type` TEXT NOT NULL, `decimals` INTEGER, `reference` TEXT, PRIMARY KEY(`coinUid`, `blockchainUid`, `type`), FOREIGN KEY(`coinUid`) REFERENCES `Coin`(`uid`) ON UPDATE NO ACTION ON DELETE CASCADE , FOREIGN KEY(`blockchainUid`) REFERENCES `BlockchainEntity`(`uid`) ON UPDATE NO ACTION ON DELETE CASCADE );
 INSERT INTO BlockchainEntity VALUES('swagbucks','SwagBucks',NULL);

marketkit/src/main/java/io/horizontalsystems/marketkit/MarketKit.kt

@@ -181,8 +181,8 @@ class MarketKit(
 
     // Details
 
-    fun topHoldersSingle(coinUid: String): Single<List<TokenHolder>> {
-        return coinManager.topHoldersSingle(coinUid)
+    fun tokenHoldersSingle(blockchainUid: String): Single<TokenHolders> {
+        return hsProvider.tokenHoldersSingle(blockchainUid)
     }
 
     fun treasuriesSingle(coinUid: String, currencyCode: String): Single<List<CoinTreasury>> {
@@ -219,6 +219,14 @@ class MarketKit(
         return coinManager.activeAddressesSingle(coinUid, currencyCode, timePeriod, sessionKey)
     }
 
+    fun analyticsPreviewSingle(coinUid: String): Single<AnalyticsPreview> {
+        return hsProvider.analyticsPreviewSingle(coinUid)
+    }
+
+    fun analyticsSingle(coinUid: String, currencyCode: String): Single<Analytics> {
+        return hsProvider.analyticsSingle(coinUid, currencyCode)
+    }
+
     // Overview
     fun marketOverviewSingle(currencyCode: String): Single<MarketOverview> =
         marketOverviewManager.marketOverviewSingle(currencyCode)

marketkit/src/main/java/io/horizontalsystems/marketkit/managers/CoinManager.kt

@@ -119,10 +119,6 @@ class CoinManager(
         return hsProvider.marketInfoGlobalTvlSingle(chain, currencyCode, timePeriod)
     }
 
-    fun topHoldersSingle(coinUid: String): Single<List<TokenHolder>> {
-        return hsProvider.topHoldersSingle(coinUid)
-    }
-
     fun treasuriesSingle(coinUid: String, currencyCode: String): Single<List<CoinTreasury>> {
         return hsProvider.coinTreasuriesSingle(coinUid, currencyCode)
     }

marketkit/src/main/java/io/horizontalsystems/marketkit/models/Blockchain.kt

@@ -8,7 +8,7 @@ import java.util.*
 data class Blockchain(
     val type: BlockchainType,
     val name: String,
-    val explorerUrl: String?
+    val eip3091url: String?
 ) : Parcelable {
 
     val uid: String

marketkit/src/main/java/io/horizontalsystems/marketkit/models/BlockchainEntity.kt

@@ -13,10 +13,10 @@ data class BlockchainEntity(
     @PrimaryKey
     val uid: String,
     val name: String,
-    val explorerUrl: String?
+    val eip3091url: String?
 ) {
 
     val blockchain: Blockchain
-        get() = Blockchain(BlockchainType.fromUid(uid), name, explorerUrl)
+        get() = Blockchain(BlockchainType.fromUid(uid), name, eip3091url)
 
 }

marketkit/src/main/java/io/horizontalsystems/marketkit/models/HsProModels.kt

@@ -1,5 +1,6 @@
 package io.horizontalsystems.marketkit.models
 
+import com.google.gson.annotations.SerializedName
 import java.math.BigDecimal
 
 data class ProChartPointDataRaw(
@@ -78,3 +79,129 @@ data class ActiveAddressesDataResponse(
         get() = ProChartPointDataRaw.countPoints(addresses)
 
 }
+
+data class Analytics(
+    @SerializedName("cex_volume")
+    val cexVolume: ExVolume?,
+    @SerializedName("dex_volume")
+    val dexVolume: ExVolume?,
+    @SerializedName("dex_liquidity")
+    val dexLiquidity: DexLiquidity?,
+    val addresses: Addresses?,
+    val transactions: Transactions?,
+    val revenue: Revenue?,
+    val tvl: Tvl?,
+    val reports: Int?,
+    @SerializedName("funds_invested")
+    val fundsInvested: BigDecimal?,
+    val treasuries: BigDecimal?,
+    val holders: List<HolderBlockchain>?,
+) {
+
+    data class ExVolume(
+        @SerializedName("rank_30d")
+        val rank30d: Int,
+        val points: List<VolumePoint>,
+    )
+
+    data class DexLiquidity(
+        val rank: Int,
+        val points: List<VolumePoint>,
+    )
+
+    data class Addresses(
+        @SerializedName("rank_30d")
+        val rank30d: Int,
+        @SerializedName("count_30d")
+        val count30d: Int,
+        val points: List<CountPoint>,
+    )
+
+    data class Transactions(
+        @SerializedName("rank_30d")
+        val rank30d: Int,
+        @SerializedName("volume_30d")
+        val volume30d: BigDecimal,
+        val points: List<CountPoint>,
+    )
+
+    data class Tvl(
+        val rank: Int,
+        val ratio: BigDecimal,
+        val points: List<CountPoint>,
+    )
+
+    data class CountPoint(
+        val count: BigDecimal,
+        val timestamp: Long,
+    )
+
+    data class VolumePoint(
+        val volume: BigDecimal,
+        val timestamp: Long,
+    )
+
+    data class HolderBlockchain(
+        @SerializedName("blockchain_uid")
+        val blockchainUid: String,
+        val count: BigDecimal,
+    )
+
+    data class Revenue(
+        @SerializedName("rank_30d")
+        val rank30d: Int,
+        @SerializedName("value_30d")
+        val value30d: BigDecimal,
+    )
+}
+
+data class AnalyticsPreview(
+    @SerializedName("cex_volume")
+    val cexVolume: VolumePreview?,
+    @SerializedName("dex_volume")
+    val dexVolume: VolumePreview?,
+    @SerializedName("dex_liquidity")
+    val dexLiquidity: LiquidityPreview?,
+    val addresses: VolumePreview?,
+    val transactions: TransactionPreview?,
+    val revenue: RevenuePreview?,
+    val tvl: TvlPreview?,
+    val reports: Boolean = false,
+    @SerializedName("funds_invested")
+    val fundsInvested: Boolean = false,
+    val treasuries: Boolean = false,
+    val holders: Boolean = false,
+) {
+
+    data class VolumePreview(
+        @SerializedName("rank_30d")
+        val rank30d: Boolean = false,
+        val points: Boolean = false,
+    )
+
+    data class LiquidityPreview(
+        val rank: Boolean = false,
+        val points: Boolean = false,
+    )
+
+    data class TransactionPreview(
+        @SerializedName("rank_30d")
+        val rank30d: Boolean = false,
+        @SerializedName("volume_30d")
+        val volume30d: Boolean = false,
+        val points: Boolean = false,
+    )
+
+    data class RevenuePreview(
+        @SerializedName("rank_30d")
+        val rank30d: Boolean = false,
+        @SerializedName("value_30d")
+        val value30d: Boolean = false,
+    )
+
+    data class TvlPreview(
+        val rank: Boolean = false,
+        val ratio: Boolean = false,
+        val points: Boolean = false,
+    )
+}

marketkit/src/main/java/io/horizontalsystems/marketkit/models/TokenHolders.kt

@@ -0,0 +1,16 @@
+package io.horizontalsystems.marketkit.models
+
+import com.google.gson.annotations.SerializedName
+import java.math.BigDecimal
+
+data class TokenHolders(
+    val count: BigDecimal,
+    @SerializedName("top_holders")
+    val topHolders: List<Holder>
+)
+
+data class Holder(
+    val address: String,
+    val percentage: BigDecimal,
+    val balance: BigDecimal
+)

marketkit/src/main/java/io/horizontalsystems/marketkit/providers/HsProvider.kt

@@ -142,8 +142,8 @@ class HsProvider(baseUrl: String, apiKey: String) {
         }
     }
 
-    fun topHoldersSingle(coinUid: String): Single<List<TokenHolder>> {
-        return service.getTopHolders(coinUid)
+    fun tokenHoldersSingle(blockchainUid: String): Single<TokenHolders> {
+        return service.getTokenHolders(blockchainUid)
     }
 
     fun coinTreasuriesSingle(coinUid: String, currencyCode: String): Single<List<CoinTreasury>> {
@@ -225,6 +225,14 @@ class HsProvider(baseUrl: String, apiKey: String) {
         return service.getAllTokens()
     }
 
+    fun analyticsPreviewSingle(coinUid: String): Single<AnalyticsPreview> {
+        return service.getAnalyticsPreview(coinUid)
+    }
+
+    fun analyticsSingle(coinUid: String, currencyCode: String): Single<Analytics> {
+        return service.getAnalyticsData(coinUid, currencyCode)
+    }
+
     private interface MarketService {
 
         @GET("coins")
@@ -357,10 +365,10 @@ class HsProvider(baseUrl: String, apiKey: String) {
             @Query("blockchain") blockchain: String?
         ): Single<List<MarketInfoTvlResponse>>
 
-        @GET("addresses/holders")
-        fun getTopHolders(
-            @Query("coin_uid") coinUid: String
-        ): Single<List<TokenHolder>>
+        @GET("analytics/{blockchainUid}/holders")
+        fun getTokenHolders(
+            @Path("blockchainUid") coinUid: String
+        ): Single<TokenHolders>
 
         @GET("funds/treasuries")
         fun getCoinTreasuries(
@@ -425,6 +433,17 @@ class HsProvider(baseUrl: String, apiKey: String) {
         @GET("tokens/list")
         fun getAllTokens(): Single<List<TokenResponse>>
 
+        @GET("analytics/{coinUid}/preview")
+        fun getAnalyticsPreview(
+            @Path("coinUid") coinUid: String,
+        ): Single<AnalyticsPreview>
+
+        @GET("analytics/{coinUid}")
+        fun getAnalyticsData(
+            @Path("coinUid") coinUid: String,
+            @Query("currency") currencyCode: String,
+        ): Single<Analytics>
+
         companion object {
             private const val marketInfoFields =
                 "name,code,price,price_change_24h,market_cap_rank,coingecko_id,market_cap,market_cap_rank,total_volume"

marketkit/src/main/java/io/horizontalsystems/marketkit/storage/MarketDatabase.kt

@@ -25,7 +25,7 @@ import java.util.logging.Logger
         Exchange::class,
         SyncerState::class,
     ],
-    version = 6,
+    version = 7,
     exportSchema = false
 )
 @TypeConverters(DatabaseTypeConverters::class)