Getting events from explorer datasource

src/rskExplorerApi/index.ts

@@ -6,9 +6,14 @@ import {
   TokensServerResponse,
   RbtcBalancesServerResponse,
   TransactionServerResponse,
-  InternalTransactionServerResponse
+  InternalTransactionServerResponse,
+  Events
 } from './types'
-import { fromApiToRtbcBalance, fromApiToTEvents, fromApiToTokens, fromApiToTokenWithBalance } from './utils'
+import {
+  fromApiToRtbcBalance, fromApiToTEvents, fromApiToTokens,
+  fromApiToTokenWithBalance, fromExplorerApiToTEvents
+} from './utils'
+import { GetEventLogsByAddressAndTopic0 } from '../service/address/AddressService'
 
 export class RSKExplorerAPI extends DataSource {
   private chainId: number
@@ -140,7 +145,16 @@ export class RSKExplorerAPI extends DataSource {
     throw new Error('Feature not supported')
   }
 
-  getEventLogsByAddressAndTopic0 () {
-    throw new Error('Feature not supported')
+  getEventLogsByAddressAndTopic0 ({ address, topic0 } :
+    Omit<GetEventLogsByAddressAndTopic0, 'chainId'>) {
+    const params = {
+      module: 'events',
+      action: 'getEventsByAddress',
+      address: address.toLowerCase()
+    }
+    return this.axios!.get<Events>(this.url, { params })
+      .then(response => fromExplorerApiToTEvents(address, topic0,
+        response.data.data))
+      .catch(this.errorHandling)
   }
 }

src/rskExplorerApi/types.ts

@@ -140,3 +140,51 @@ export interface IInternalTransaction {
 export interface InternalTransactionServerResponse {
   data: IInternalTransaction[]
 }
+
+export interface Pages {
+  sortDir: number;
+  limit: number;
+  next: null;
+  prev: null;
+  page: number;
+  total: null;
+  pages: any[];
+}
+
+export interface Datum {
+  eventId: string;
+  address: string;
+  blockHash: string;
+  blockNumber: number;
+  data: string;
+  event: null | string;
+  logIndex: number;
+  timestamp: number;
+  transactionHash: string;
+  transactionIndex: number;
+  txStatus: string;
+  topics: string[];
+  _addresses: string[];
+  abi: any;
+  _addressData: any;
+  args?: string[];
+  signature?: string;
+}
+
+export interface Events {
+  pages: Pages;
+  data: Datum[];
+}
+
+export interface ExplorerEvent {
+  address: string;
+  blockNumber: string;
+  data: string;
+  gasPrice: string;
+  gasUsed: string;
+  logIndex: string;
+  timeStamp: string;
+  topics: Array<null | string>;
+  transactionHash: string;
+  transactionIndex: string;
+}

src/rskExplorerApi/utils.ts

@@ -1,4 +1,6 @@
 import {
+  Datum,
+  ExplorerEvent,
   IApiEvents,
   IApiTokens,
   IEvent,
@@ -51,3 +53,20 @@ export const fromApiToTEvents = (apiEvent:IApiEvents): IEvent =>
     transactionHash: apiEvent.transactionHash,
     txStatus: apiEvent.txStatus
   })
+
+export const fromExplorerApiToTEvents = (address: string, topic0: string, events: Datum[]): ExplorerEvent[] => {
+  return events
+    .filter(event => event.topics.includes(topic0))
+    .map(event => ({
+      address,
+      blockNumber: event.blockNumber + '',
+      data: event.data,
+      gasPrice: event._addressData?.createdByTx?.gasPrice as string,
+      gasUsed: event._addressData?.createdByTx?.receipt?.gasUsed as string,
+      logIndex: event.logIndex + '',
+      timeStamp: event.timestamp + '',
+      topics: event.topics,
+      transactionHash: event.transactionHash,
+      transactionIndex: event.transactionIndex + ''
+    }))
+}