feat: fxrp launch api controller

Author: kuco23

packages/fasset-indexer-api/src/analytics/dashboard.ts

@@ -746,24 +746,24 @@ export class DashboardAnalytics extends SharedAnalytics {
     )) as FAssetAmountResult
   }
 
-  private convertOrmResultToFAssetValueResult<K extends string>(
+  protected convertOrmResultToFAssetValueResult<K extends string>(
     result: ({ fasset: number } & { [key in K]: string | bigint })[], key: K
   ): FAssetValueResult {
     const ret = {} as FAssetValueResult
     for (const x of result) {
       ret[FAssetType[x.fasset] as FAsset] = { value: BigInt(x?.[key] ?? 0) }
     }
-    return ret
+    return this.complementFAssetValueResult(ret)
   }
 
-  private convertOrmResultToFAssetAmountResult<K extends string>(
+  protected convertOrmResultToFAssetAmountResult<K extends string>(
     result: ({ fasset: number } & { [key in K]: string | number })[], key: K
   ): FAssetAmountResult {
     const ret = {} as FAssetAmountResult
     for (const x of result) {
       ret[FAssetType[x.fasset] as FAsset] = { amount: Number(x?.[key] ?? 0) }
     }
-    return ret
+    return this.complementFAssetAmountResult(ret)
   }
 
   private convertFAssetTimeSeriesToFAssetTimespan(timeseries: FAssetTimeSeries<bigint>): FAssetTimespan<bigint> {
@@ -782,4 +782,22 @@ export class DashboardAnalytics extends SharedAnalytics {
     return timespan
   }
 
+  private complementFAssetValueResult(result: FAssetValueResult): FAssetValueResult {
+    for (const fasset of this.supportedFAssets) {
+      if (result[fasset] == null) {
+        result[fasset] = { value: BigInt(0) }
+      }
+    }
+    return result
+  }
+
+  private complementFAssetAmountResult(result: FAssetAmountResult): FAssetAmountResult {
+    for (const fasset of this.supportedFAssets) {
+      if (result[fasset] == null) {
+        result[fasset] = { amount: 0 }
+      }
+    }
+    return result
+  }
+
 }

packages/fasset-indexer-api/src/analytics/fxrp-launch.ts

@@ -0,0 +1,25 @@
+import { FAssetType } from "fasset-indexer-core"
+import { EntityManager, raw } from "fasset-indexer-core/orm"
+import * as Entities from "fasset-indexer-core/entities"
+import { DashboardAnalytics } from "./dashboard"
+import type { FAssetValueResult } from "./interface"
+
+export class FxrpLaunchAnalytics extends DashboardAnalytics {
+
+  public mintedByUserFromTimestamp(user: string, from: number): Promise<FAssetValueResult> {
+    return this._mintedByUserFromTimestamp(this.orm.em.fork(), user, from)
+  }
+
+  protected async _mintedByUserFromTimestamp(em: EntityManager, user: string, from: number): Promise<FAssetValueResult> {
+    const minted = await em.createQueryBuilder(Entities.MintingExecuted, 'me')
+      .select(['me.fasset', raw('sum(cr.value_uba) as value')])
+      .join('me.collateralReserved', 'cr')
+      .join('me.evmLog', 'el')
+      .join('el.block', 'block')
+      .join('cr.minter', 'cm')
+      .where({ 'block.timestamp': { $gte: from }, 'cm.hex': user })
+      .groupBy('fasset')
+      .execute() as { fasset: FAssetType, value: string }[]
+    return this.convertOrmResultToFAssetValueResult(minted, 'value')
+  }
+}

packages/fasset-indexer-api/src/app.module.ts

@@ -10,6 +10,8 @@ import { StatisticsController } from './controllers/statistics.controller'
 import { MetadataController } from './controllers/metadata.controller'
 import { ExplorerService } from './services/explorer.service'
 import { ExplorerController } from './controllers/explorer.controller'
+import { FxrpLaunchService } from './services/fxrp-launch.service'
+import { FxrpLaunch } from './controllers/fxrp-launch.controller'
 import { ApiConfigLoader } from './config/config'
 import { ApiContext } from './config/context'
 import { CACHE_MAX_ENTRIES, CACHE_TTL_MS } from './config/constants'
@@ -33,15 +35,17 @@ const apiContextProvider = {
     ExplorerController,
     NotificationController,
     MetadataController,
-    StatisticsController
+    StatisticsController,
+    FxrpLaunch
   ],
   providers: [
     apiContextProvider,
     DashboardService,
     ExplorerService,
     NotificationService,
     MetadataService,
-    StatisticsService
+    StatisticsService,
+    FxrpLaunchService
   ]
 })
 export class FAssetIndexerModule {}

packages/fasset-indexer-api/src/controllers/fxrp-launch.controller.ts

@@ -0,0 +1,24 @@
+import { CacheInterceptor } from "@nestjs/cache-manager"
+import { ApiOperation, ApiParam, ApiTags } from "@nestjs/swagger"
+import { Controller, Get, Param, UseInterceptors } from "@nestjs/common"
+import { FxrpLaunchService } from "../services/fxrp-launch.service"
+import { ApiResponse, apiResponse } from "../shared/api-response"
+import { FAssetValueResult } from "../analytics/interface"
+
+@ApiTags('FXRP Launch')
+@UseInterceptors(CacheInterceptor)
+@Controller('api/fxrp-launch')
+export class FxrpLaunch {
+  constructor(private readonly service: FxrpLaunchService) { }
+
+  @Get('/total-minted/:user/:from')
+  @ApiOperation({ summary: 'Amount of FAsset user has minted from given timestamp on' })
+  @ApiParam({ name: 'user', type: String, description: 'minting user' })
+  @ApiParam({ name: "from", type: Number, description: 'time of first allowed minting' })
+  getPoolCollateralDiff(
+    @Param('user') user: string,
+    @Param('from') from: number
+  ): Promise<ApiResponse<FAssetValueResult>> {
+    return apiResponse(this.service.mintedByUserFromTimestamp(user, from), 200)
+  }
+}

packages/fasset-indexer-api/src/services/fxrp-launch.service.ts

@@ -0,0 +1,12 @@
+import { Injectable, Inject } from '@nestjs/common'
+import { FxrpLaunchAnalytics } from '../analytics/fxrp-launch'
+import type { ApiContext } from '../config/context'
+
+
+@Injectable()
+export class FxrpLaunchService extends FxrpLaunchAnalytics {
+
+  constructor(@Inject('apiContext') config: ApiContext) {
+    super(config.orm, config.chain, config.loader.addressesJson)
+  }
+}