feat(api): Filter out unverified assets with unmatched decimals (#1774)

* feat(api): Filter out unverified assets with unmatched decimals

* feat(api): Add warning events

Author: rohanjadvani

src/assets/assets.service.ts

@@ -39,6 +39,15 @@ export class AssetsService {
     return record;
   }
 
+  async findByIdentifier(
+    identifier: string,
+  ): Promise<AssetWithMetadata | null> {
+    return this.prisma.asset.findUnique({
+      where: { identifier },
+      include: { verified_metadata: true },
+    });
+  }
+
   async findByIdentifierOrThrow(
     identifier: string,
   ): Promise<AssetWithMetadata> {

src/bridges/bridges.module.ts

@@ -4,12 +4,20 @@
 import { HttpModule } from '@nestjs/axios';
 import { Module } from '@nestjs/common';
 import { ApiConfigModule } from '../api-config/api-config.module';
+import { AssetsModule } from '../assets/assets.module';
+import { DatadogModule } from '../datadog/datadog.module';
 import { LoggerModule } from '../logger/logger.module';
 import { ChainportService } from './chainport.service';
 
 @Module({
   exports: [ChainportService],
-  imports: [ApiConfigModule, HttpModule, LoggerModule],
+  imports: [
+    ApiConfigModule,
+    AssetsModule,
+    DatadogModule,
+    HttpModule,
+    LoggerModule,
+  ],
   providers: [ChainportService],
 })
 export class BridgesModule {}

src/bridges/chainport.service.ts

@@ -12,6 +12,8 @@ import Joi from 'joi';
 import { URL } from 'node:url';
 import { catchError, firstValueFrom } from 'rxjs';
 import { ApiConfigService } from '../api-config/api-config.service';
+import { AssetsService } from '../assets/assets.service';
+import { DatadogService } from '../datadog/datadog.service';
 import { LoggerService } from '../logger/logger.service';
 
 export type ChainportNetwork = {
@@ -130,7 +132,9 @@ export type ChainportPort =
 @Injectable()
 export class ChainportService {
   constructor(
+    private readonly assetsService: AssetsService,
     private readonly config: ApiConfigService,
+    private readonly datadogService: DatadogService,
     private readonly httpService: HttpService,
     private readonly logger: LoggerService,
   ) {}
@@ -220,7 +224,48 @@ export class ChainportService {
         `Invalid Chainport response: ${validateResult.error.message}`,
       );
     }
-    return validateResult.value;
+
+    const verifiedTokens = [];
+
+    const chainportTokens = validateResult.value;
+    for (const token of chainportTokens) {
+      const asset = await this.assetsService.findByIdentifier(
+        token.web3_address,
+      );
+      if (!asset) {
+        this.datadogService.event(
+          'Mismatched asset',
+          `Could not find asset ${token.web3_address}`,
+          { alert_type: 'error' },
+        );
+        continue;
+      }
+
+      if (!asset.verified_metadata) {
+        this.datadogService.event(
+          'Unverified asset',
+          `Asset ${asset.identifier} is unverified`,
+          { alert_type: 'warning' },
+        );
+        continue;
+      }
+
+      if (asset.verified_metadata.decimals !== token.decimals) {
+        const message = `${asset.identifier}
+Iron Fish: ${asset.verified_metadata.decimals ?? 'null'}
+Chainport: ${token.decimals}`;
+        this.datadogService.event(
+          'Mismatched verified asset decimals',
+          message,
+          { alert_type: 'warning' },
+        );
+        continue;
+      }
+
+      verifiedTokens.push(token);
+    }
+
+    return verifiedTokens;
   }
 
   async getTokenPaths(tokenId: number): Promise<ChainportNetwork[]> {

src/datadog/datadog.service.ts

@@ -2,7 +2,7 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at https://mozilla.org/MPL/2.0/. */
 import { Injectable, OnModuleDestroy } from '@nestjs/common';
-import { StatsD, Tags } from 'hot-shots';
+import { EventOptions, StatsD, Tags } from 'hot-shots';
 import { ApiConfigService } from '../api-config/api-config.service';
 
 const DEFAULT_PORT = 8125;
@@ -31,6 +31,15 @@ export class DatadogService implements OnModuleDestroy {
     this.datadogClient.increment(stat, value, tags);
   }
 
+  event(
+    title: string,
+    text?: string,
+    options?: EventOptions,
+    tags?: Tags,
+  ): void {
+    this.datadogClient.event(title, text, options, tags);
+  }
+
   onModuleDestroy(): void {
     this.datadogClient.close();
   }