fix: market scan error

package.json

@@ -1,6 +1,6 @@
 {
   "name": "unique-marketplace-backend",
-  "version": "3.0.246",
+  "version": "3.0.248",
   "description": "Backend project for unique marketplace",
   "author": "Unique Network",
   "private": true,
@@ -65,7 +65,7 @@
     "helmet": "^6.1.2",
     "husky": "^8.0.3",
     "minio": "^7.1.1",
-    "nestjs-graphile-worker": "^0.3.1",
+    "nestjs-graphile-worker": "^0.7.0",
     "nestjs-typeorm-paginate": "^4.0.3",
     "pg": "^8.9.0",
     "pg-connection-string": "^2.5.0",

packages/escrow/src/app/sdk.service.ts

@@ -1,4 +1,4 @@
-import { Injectable, Logger } from "@nestjs/common";
+import { Injectable, Logger } from '@nestjs/common';
 
 import {
   ChainPropertiesResponse,
@@ -26,7 +26,6 @@ export type TokenBalance = {
 
 @Injectable()
 export class SdkService {
-
   private logger = new Logger('SDK');
   constructor(private readonly sdk: Sdk) {}
 
@@ -82,8 +81,19 @@ export class SdkService {
     return [...new Set(recurseBundle(bundle))];
   }
 
-  async getTokenSchema(collectionId: number, tokenId: number): Promise<TokenByIdResponse> {
-    return await this.sdk.tokens.get({ collectionId: collectionId, tokenId: tokenId });
+  async getTokenSchema(collectionId: number, tokenId: number): Promise<TokenByIdResponse | null> {
+    let token: TokenByIdResponse;
+    try {
+      token = await this.sdk.token.get({ collectionId: collectionId, tokenId: tokenId });
+    } catch (error) {
+      if (error.message === 'Token not found') {
+        return null;
+      }
+
+      throw error;
+    }
+
+    return token;
   }
 
   /**
@@ -150,12 +160,16 @@ export class SdkService {
    * @param collectionId
    * @param at
    */
-  async getSchemaToken(tokenId: number, collectionId: number): Promise<TokenByIdResponse> {
+  async getSchemaToken(tokenId: number, collectionId: number): Promise<TokenByIdResponse | null> {
     let getSchema;
     try {
       getSchema = await this.sdk.token.get({ collectionId, tokenId });
     } catch (e) {
-      this.logger.error(e);
+      if (e.message === 'Token not found') {
+        return null;
+      }
+
+      throw e;
     }
     if (!getSchema) {
       return null;

packages/escrow/src/collections/tokens.service.ts

@@ -48,9 +48,8 @@ export class TokensService {
     if (collection) {
       const chain = await this.sdk.getChainProperties();
       //Check token lives in the chain
-      try {
-        await this.sdk.getTokenSchema(collectionId, tokenId);
-      } catch (e) {
+      const token = await this.sdk.getTokenSchema(collectionId, tokenId);
+      if (token == null) {
         await this.cleanTokenAndProperties(collectionId, tokenId, chain.token);
         this.logger.error('Token not found or burned!');
         return;

packages/escrow/src/tasks/properties.task.ts

@@ -32,12 +32,11 @@ export class PropertiesTask {
    */
   @TaskHandler()
   async handler(payload: Market.Payload, helpers: Helpers): Promise<void> {
-    this.addSearchIndexIfNotExists(payload);
+    await this.addSearchIndexIfNotExists(payload);
   }
 
   async getTokenInfoItems({ collectionId, tokenId }: CollectionToken): Promise<SerializeTokenType> {
-    const source = await this.preparePropertiesData(tokenId, collectionId);
-    return source;
+    return this.preparePropertiesData(tokenId, collectionId);
   }
 
   private findNestedToken(bundle: NestedToken, tokenId: number): NestedToken | undefined {
@@ -60,7 +59,7 @@ export class PropertiesTask {
     collection: any;
     isBundle: boolean;
     serializeBundle: Array<BundleType>;
-  }> {
+  }> | null {
     const { isBundle } = await this.sdkService.isBundle(tokenId, collectionId);
     let token = null;
     let serializeBundle = [];
@@ -69,6 +68,8 @@ export class PropertiesTask {
         this.sdkService.getBundle(tokenId, collectionId),
         this.sdkService.getTokenSchema(collectionId, tokenId),
       ]);
+      if (!tokenData) return null;
+
       token = tokenData;
 
       if (bundle.tokenId === tokenId) {
@@ -85,7 +86,9 @@ export class PropertiesTask {
       serializeBundle = this.sdkService.serializeBunlde(token);
     } else {
       token = await this.sdkService.getTokenSchema(collectionId, tokenId);
+      if (!token) return null;
     }
+
     const collection = await this.sdkService.getSchemaCollection(collectionId);
     return {
       token,
@@ -95,7 +98,7 @@ export class PropertiesTask {
     };
   }
 
-  async addSearchIndexIfNotExists(collectionToken: CollectionToken): Promise<any> {
+  async addSearchIndexIfNotExists(collectionToken: CollectionToken): Promise<void> {
     const { collectionId, tokenId, network } = collectionToken;
 
     const dbIndexList = await this.propertiesRepository.find({
@@ -115,7 +118,9 @@ export class PropertiesTask {
     }
 
     const searchIndexItems = await this.getTokenInfoItems(collectionToken);
-    return this.saveProperties(collectionToken, searchIndexItems);
+    if (searchIndexItems) {
+      await this.saveProperties(collectionToken, searchIndexItems);
+    }
   }
 
   async saveProperties(collectionToken: CollectionToken, source: SerializeTokenType): Promise<PropertiesEntity[]> {
@@ -157,10 +162,13 @@ export class PropertiesTask {
     return this.propertiesRepository.save(propertiesDataItems);
   }
 
-  async preparePropertiesData(tokenId: number, collectionId: number): Promise<any> {
+  async preparePropertiesData(tokenId: number, collectionId: number): Promise<SerializeTokenType | null> {
     const tokenData = await this.tokenWithCollection(tokenId, collectionId);
+    if (!tokenData) {
+      return null;
+    }
 
-    const source = new Set();
+    const source: Set<TokenInfo> = new Set();
     // Collection
     source
       .add({