added filter to fetch transfers where an address is relayer

src/common/indexer/elastic/elastic.indexer.helper.ts

@@ -316,17 +316,23 @@ export class ElasticIndexerHelper {
       if (filter.withRefunds) {
         mustNotQueries = [];
       }
+
+      const shouldConditions = [
+        QueryType.Match('sender', filter.address),
+        QueryType.Match('receiver', filter.address),
+        QueryType.Match('receivers', filter.address),
+      ];
+      if (filter.withTxsRelayedByAddress) {
+        shouldConditions.push(QueryType.Match('relayer', filter.address));
+      }
+
       elasticQuery = elasticQuery.withCondition(QueryConditionOptions.should, QueryType.Must([
         QueryType.Match('type', 'unsigned'),
         QueryType.Should(smartContractResultConditions),
       ], mustNotQueries))
         .withCondition(QueryConditionOptions.should, QueryType.Must([
           QueryType.Should([QueryType.Match('type', 'normal')]),
-          QueryType.Should([
-            QueryType.Match('sender', filter.address),
-            QueryType.Match('receiver', filter.address),
-            QueryType.Match('receivers', filter.address),
-          ]),
+          QueryType.Should(shouldConditions),
         ]));
     }
 

src/common/indexer/entities/transaction.ts

@@ -31,4 +31,7 @@ export interface Transaction {
   scResults: any[];
   version: number;
   relayerAddr: string;
+  relayer: string;
+  relayerSignature: string;
+  isRelayed: boolean;
 }

src/endpoints/accounts/account.controller.ts

@@ -1018,6 +1018,7 @@ export class AccountController {
   @ApiQuery({ name: 'withOperations', description: 'Return operations for transfers. When "withOperations" parameter is applied, complexity estimation is 200', required: false })
   @ApiQuery({ name: 'withActionTransferValue', description: 'Returns value in USD and EGLD for transferred tokens within the action attribute', required: false })
   @ApiQuery({ name: 'withRefunds', description: 'Include refund transactions', required: false })
+  @ApiQuery({ name: 'withTxsRelayedByAddress', description: 'Include transactions that were relayed by the address', required: false })
   async getAccountTransfers(
     @Param('address', ParseAddressPipe) address: string,
     @Query('from', new DefaultValuePipe(0), ParseIntPipe) from: number,
@@ -1045,6 +1046,7 @@ export class AccountController {
     @Query('withOperations', ParseBoolPipe) withOperations?: boolean,
     @Query('withActionTransferValue', ParseBoolPipe) withActionTransferValue?: boolean,
     @Query('withRefunds', ParseBoolPipe) withRefunds?: boolean,
+    @Query('withTxsRelayedByAddress', ParseBoolPipe) withTxsRelayedByAddress?: boolean,
   ): Promise<Transaction[]> {
     const options = TransactionQueryOptions.applyDefaultOptions(
       size, { withScamInfo, withUsername, withBlockInfo, withOperations, withLogs, withActionTransferValue });
@@ -1067,6 +1069,7 @@ export class AccountController {
       relayer,
       round,
       withRefunds,
+      withTxsRelayedByAddress,
     }),
       new QueryPagination({ from, size }),
       options,
@@ -1075,7 +1078,7 @@ export class AccountController {
   }
 
   @Get("/accounts/:address/transfers/count")
-  @ApiOperation({ summary: 'Account transfer count', description: 'Return total count of tranfers triggerred by a user account (type = Transaction), as well as transfers triggerred by smart contracts (type = SmartContractResult)' })
+  @ApiOperation({ summary: 'Account transfer count', description: 'Return total count of transfers triggerred by a user account (type = Transaction), as well as transfers triggerred by smart contracts (type = SmartContractResult)' })
   @ApiOkResponse({ type: Number })
   @ApiQuery({ name: 'sender', description: 'Address of the transfer sender', required: false })
   @ApiQuery({ name: 'receiver', description: 'Search by multiple receiver addresses, comma-separated', required: false })

src/endpoints/transactions/entities/transaction.filter.ts

@@ -28,6 +28,7 @@ export class TransactionFilter {
   round?: number;
   withRefunds?: boolean;
   withRelayedScresults?: boolean;
+  withTxsRelayedByAddress?: boolean;
 
   constructor(init?: Partial<TransactionFilter>) {
     Object.assign(this, init);

src/endpoints/transfers/transfer.service.ts

@@ -51,7 +51,12 @@ export class TransferService {
     for (const elasticOperation of elasticOperations) {
       const transaction = ApiUtils.mergeObjects(new TransactionDetailed(), elasticOperation);
       transaction.type = elasticOperation.type === 'normal' ? TransactionType.Transaction : TransactionType.SmartContractResult;
-      transaction.relayer = elasticOperation.relayerAddr;
+      if (elasticOperation.relayer) {
+        transaction.relayer = elasticOperation.relayer;
+        transaction.isRelayed = true;
+      } else {
+        transaction.relayer = elasticOperation.relayerAddr;
+      }
 
       if (transaction.type === TransactionType.SmartContractResult) {
         delete transaction.gasLimit;