add scan-asset endpoint

stellar · Jul 30, 2024 · 7f850c9 · 7f850c9
1 parent 138bd8e
commit 7f850c9
Show file tree

Hide file tree

Showing 3 changed files with 48 additions and 0 deletions.
diff --git a/src/helper/error.ts b/src/helper/error.ts
@@ -21,4 +21,5 @@ export const ERROR = {
   INVALID_RUN_MODE: "invalid run mode",
   UNABLE_TO_SCAN_SITE: "unable to scan site using blockaid",
   UNABLE_TO_SCAN_TX: "unable to scan tx using blockaid",
+  UNABLE_TO_SCAN_ASSET: "unable to scan asset using blockaid",
 };
diff --git a/src/route/index.ts b/src/route/index.ts
@@ -575,6 +575,34 @@ export async function initApiServer(
         },
       });
 
+      instance.route({
+        method: "GET",
+        url: "/scan-asset",
+        schema: {
+          querystring: {
+            ["address"]: {
+              type: "string",
+            },
+          },
+        },
+        handler: async (
+          request: FastifyRequest<{
+            Querystring: {
+              ["address"]: string;
+            };
+          }>,
+          reply
+        ) => {
+          const { address } = request.query;
+          try {
+            const { data, error } = await blockAidService.scanAsset(address);
+            return reply.code(error ? 400 : 200).send({ data, error });
+          } catch (error) {
+            return reply.code(500).send(ERROR.SERVER_ERROR);
+          }
+        },
+      });
+
       instance.route({
         method: "POST",
         url: "/subscription/token",

diff --git a/src/service/blockaid/index.ts b/src/service/blockaid/index.ts
@@ -78,4 +78,23 @@ export class BlockAidService {
       return { data: null, error: ERROR.UNABLE_TO_SCAN_TX };
     }
   };
+
+  scanAsset = async (
+    address: string
+  ): Promise<{
+    data: Blockaid.Token.TokenScanResponse | null;
+    error: string | null;
+  }> => {
+    try {
+      const data = await this.blockAidClient.token.scan({
+        address,
+        chain: "stellar",
+      });
+      return { data, error: null };
+    } catch (error) {
+      this.logger.error(error);
+      this.scanMissCounter.inc();
+      return { data: null, error: ERROR.UNABLE_TO_SCAN_ASSET };
+    }
+  };
 }