search after support

Author: stefangutica

src/common/entities/query.pagination.ts

@@ -8,4 +8,5 @@ export class QueryPagination {
 
   before?: number;
   after?: number;
+  searchAfter?: string;
 }

src/common/indexer/elastic/circuit-breaker/circuit.breaker.proxy.service.ts

@@ -68,8 +68,10 @@ export class EsCircuitBreakerProxy {
   }
 
   // eslint-disable-next-line require-await
-  async getList(index: string, id: string, query: ElasticQuery): Promise<any[]> {
-    return this.withCircuitBreaker(() => this.elasticService.getList(index, id, query));
+  async getList(index: string, id: string, query: ElasticQuery, searchAfter?: string): Promise<any[]> {
+    //TODO: update package
+    // @ts-ignore
+    return this.withCircuitBreaker(() => this.elasticService.getList(index, id, query, undefined, searchAfter));
   }
 
   // eslint-disable-next-line require-await

src/common/indexer/elastic/elastic.indexer.service.ts

@@ -136,7 +136,7 @@ export class ElasticIndexerService implements IndexerInterface {
 
     query = this.buildTokenFilter(query, filter);
 
-    return await this.elasticService.getList('accountsesdt', 'token', query);
+    return await this.elasticService.getList('accountsesdt', 'token', query, queryPagination.searchAfter);
   }
 
   async getTokenAccountsCount(identifier: string): Promise<number | undefined> {
@@ -294,7 +294,7 @@ export class ElasticIndexerService implements IndexerInterface {
       .withPagination({ from: pagination.from, size: pagination.size })
       .withSort([timestamp, nonce]);
 
-    const elasticOperations = await this.elasticService.getList('operations', 'txHash', elasticQuery);
+    const elasticOperations = await this.elasticService.getList('operations', 'txHash', elasticQuery, pagination.searchAfter);
 
     this.bulkProcessTransactions(elasticOperations);
 
@@ -559,7 +559,7 @@ export class ElasticIndexerService implements IndexerInterface {
       .withPagination({ from: pagination.from, size: pagination.size })
       .withSort([timestamp, nonce]);
 
-    const transactions = await this.elasticService.getList('operations', 'txHash', elasticQuery);
+    const transactions = await this.elasticService.getList('operations', 'txHash', elasticQuery, pagination.searchAfter);
 
     this.bulkProcessTransactions(transactions);
 

src/common/indexer/entities/account.history.ts

@@ -1,4 +1,6 @@
-export interface AccountHistory {
+import { ElasticSortable } from "./elastic.sortable";
+
+export interface AccountHistory extends ElasticSortable {
   address: string;
   timestamp: number;
   balance: string;

src/common/indexer/entities/account.token.history.ts

@@ -1,4 +1,6 @@
-export interface AccountTokenHistory {
+import { ElasticSortable } from "./elastic.sortable";
+
+export interface AccountTokenHistory extends ElasticSortable {
   address: string;
   timestamp: number;
   balance: string;

src/common/indexer/entities/account.ts

@@ -1,4 +1,6 @@
-export interface Account {
+import { ElasticSortable } from "./elastic.sortable";
+
+export interface Account extends ElasticSortable {
   address: string;
   nonce: number;
   timestampMs: number;

src/common/indexer/entities/block.ts

@@ -1,4 +1,6 @@
-export interface Block {
+import { ElasticSortable } from "./elastic.sortable";
+
+export interface Block extends ElasticSortable {
   hash: string;
   nonce: number;
   round: number;

src/common/indexer/entities/collection.ts

@@ -1,3 +1,5 @@
+import { ElasticSortable } from "./elastic.sortable";
+
 export interface CollectionProperties {
   canMint?: boolean;
   canBurn?: boolean;
@@ -11,7 +13,7 @@ export interface CollectionProperties {
   canCreateMultiShard?: boolean;
 }
 
-export interface Collection {
+export interface Collection extends ElasticSortable {
   _id: string;
   name: string;
   ticker: string;

src/common/indexer/entities/elastic.sortable.ts

@@ -0,0 +1,3 @@
+export interface ElasticSortable {
+  searchAfter?: string;
+}

src/common/indexer/entities/events.ts

@@ -1,4 +1,5 @@
 export class Events {
+  searchAfter?: string;
   _id: string = '';
   logAddress: string = '';
   identifier: string = '';