Minswap v2

Author: Sluder

src/IndexerApplication.ts

@@ -53,7 +53,7 @@ export class IndexerApplication {
             new VyFiAnalyzer(this),
         ]),
         new OrderBookDexTransactionIndexer([
-            new GeniusYieldAnalyzer(this),
+            // new GeniusYieldAnalyzer(this),
             // new AxoAnalyzer(this),
         ]),
         new HybridDexTransactionIndexer([
@@ -176,6 +176,7 @@ export class IndexerApplication {
          * Spectrum    - 98301694,  d0d2abcaf741be13d353ac80b0f9001d7b323a2b5827ff2dce6480bf032dd3db
          * TeddySwap   - 109078697, 8494922f6266885a671408055d7123e1c7bdf78b9cd86720680c55c1f94e839e
          * GeniusYield - 110315300, d7281a52d68eef89a7472860fdece323ecc39d3054cdd1fa0825afe56b942a86
+         * Minswap v2  - 128247239,  d7edc62dcfeb8e809f4a8584354b9bf0df640d365ff47cb26a0f9e972ba1dca4
          */
         return lastSync
             ? this.chainSyncClient.startSync([{ slot: lastSync.slot, hash: lastSync.blockHash }])

src/api/controllers/AssetController.ts

@@ -1,12 +1,15 @@
 import { BaseApiController } from './BaseApiController';
 import express from 'express';
 import { dbApiService } from '../../apiServices';
-import { Brackets, EntityManager } from 'typeorm';
+import { Brackets, EntityManager, SelectQueryBuilder } from 'typeorm';
 import { Asset } from '../../db/entities/Asset';
 import { AssetResource } from '../resources/AssetResource';
 import { LiquidityPoolState } from '../../db/entities/LiquidityPoolState';
 import { LiquidityPoolResource } from '../resources/LiquidityPoolResource';
 import { LiquidityPool } from '../../db/entities/LiquidityPool';
+import { TickInterval } from '../../constants';
+import { LiquidityPoolTick } from '../../db/entities/LiquidityPoolTick';
+import { LiquidityPoolTickResource } from '../resources/LiquidityPoolTickResource';
 
 const MAX_PER_PAGE: number = 100;
 
@@ -16,6 +19,7 @@ export class AssetController extends BaseApiController {
         this.router.get(`${this.basePath}`, this.assets);
         this.router.post(`${this.basePath}`, this.assets);
         this.router.get(`${this.basePath}/search`, this.search);
+        this.router.post(`${this.basePath}/ticks`, this.ticks);
         this.router.get(`${this.basePath}/:lpToken/pool`, this.lpTokenPool);
         this.router.get(`${this.basePath}/:asset`, this.asset);
         this.router.get(`${this.basePath}/:asset/price`, this.assetPrice);
@@ -217,4 +221,74 @@ export class AssetController extends BaseApiController {
         }).catch(() => response.send(super.failResponse('Unable to retrieve asset price')));
     }
 
+    private ticks(request: express.Request, response: express.Response) {
+        const {
+            forAssets,
+        } = request.body;
+        const {
+            resolution,
+            fromTime,
+            toTime,
+            orderBy,
+        } = request.query;
+
+        if (forAssets && ! (forAssets instanceof Array)) {
+            return response.send(super.failResponse('Assets must be an array'));
+        }
+        if (! (Object.values(TickInterval) as string[]).includes(resolution as string)) {
+            return response.send(super.failResponse(`Must supply 'resolution' as ${Object.values(TickInterval).join(',')}`));
+        }
+        if (orderBy && ! ['ASC', 'DESC'].includes(orderBy as string)) {
+            return response.send(super.failResponse("orderBy must be 'ASC' or 'DESC'"));
+        }
+
+        const assets: Asset[] = ((forAssets ?? []) as string[]).map((identifier: string) => Asset.fromId(identifier));
+        const policyIds: string[] = assets.map((asset: Asset) => asset.policyId);
+        const nameHexs: string[] = assets.map((asset: Asset) => asset.nameHex);
+
+        const fetchTicks: any = (manager: EntityManager) => {
+            return manager.createQueryBuilder(LiquidityPoolTick, 'ticks')
+                .leftJoinAndSelect('ticks.liquidityPool', 'liquidityPool')
+                .leftJoinAndMapOne(
+                    'liquidityPool.latestState',
+                    LiquidityPoolState,
+                    'states',
+                    'states.liquidityPoolId = liquidityPool.id AND states.id = (SELECT MAX(id) FROM liquidity_pool_states WHERE liquidity_pool_states.slot + 1596491091 - 4924800 <= ticks.time AND liquidity_pool_states.liquidityPoolId = liquidityPool.id)'
+                )
+                .leftJoinAndSelect('liquidityPool.tokenB', 'tokenB')
+                .andWhere('liquidityPool.tokenA IS NULL')
+                .andWhere(
+                    new Brackets((query) => {
+                        query.andWhere('tokenB.policyId IN(:policyIds) AND tokenB.nameHex IN(:nameHexs)', {
+                            policyIds,
+                            nameHexs,
+                        });
+
+                        if (fromTime && ! isNaN(parseInt(fromTime as string))) {
+                            query.andWhere('ticks.time >= :fromTime', {
+                                fromTime: parseInt(fromTime as string),
+                            });
+                        }
+
+                        if (toTime && ! isNaN(parseInt(toTime as string))) {
+                            query.andWhere('ticks.time < :toTime', {
+                                toTime: parseInt(toTime as string),
+                            });
+                        }
+
+                        return query;
+                    }),
+                )
+                .orderBy('time', orderBy ? (orderBy as 'ASC' | 'DESC') : 'ASC')
+                .getMany();
+        };
+
+        return dbApiService.transaction(fetchTicks)
+            .then((ticks: LiquidityPoolTick[]) => {
+                const resource: LiquidityPoolTickResource = new LiquidityPoolTickResource();
+
+                response.send(resource.manyToJson(ticks));
+            }).catch((e) => response.send(super.failResponse(e)));
+    }
+
 }

src/constants.ts

@@ -36,6 +36,11 @@ export enum DatumParameterKey {
     OpeningFee = 'OpeningFee',
     FinalFee = 'FinalFee',
     ProtocolFee = 'ProtocolFee',
+    BaseFee = 'BaseFee',
+    FeeSharingNumerator = 'FeeSharingNumerator',
+    ReserveA = 'ReserveA',
+    ReserveB = 'ReserveB',
+    Direction = 'Direction',
 
     TokenPolicyId = 'TokenPolicyId',
     TokenAssetName = 'TokenAssetName',
@@ -68,6 +73,7 @@ export enum DatumParameterKey {
 
 export enum Dex {
     Minswap = 'Minswap',
+    MinswapV2 = 'MinswapV2',
     SundaeSwap = 'SundaeSwap',
     SundaeSwapV3 = 'SundaeSwapV3',
     WingRiders = 'WingRiders',