feat: filter by witnet network and pair

Author: gabaldon

packages/api/src/index.ts

@@ -82,6 +82,7 @@ class DataFeedsExplorer {
     }
     this.repositories.feedRepository.setLegacyFeeds(legacyFeeds)
     this.repositories.feedRepository.setV2Feeds(v2Feeds)
+    this.repositories.feedRepository.setConfiguration(this.configuration)
 
     const web3Middleware = new Web3Middleware(
       this.configuration,

packages/api/src/repository/Feed.ts

@@ -1,9 +1,16 @@
 import { FeedsState } from './feedState'
-import { PaginatedFeedsObject, FeedInfo, ConfigByFullName } from '../../types'
+import {
+  PaginatedFeedsObject,
+  FeedInfo,
+  ConfigByFullName,
+  Network,
+  FeedsFilters,
+} from '../../types'
+import { Configuration } from '../web3Middleware/Configuration'
 
 export class FeedRepository {
   feedsState: FeedsState
-  // TODO: replace string with Network
+  dataFeeds: Record<string, Record<Network, Array<FeedInfo>>>
   dataFeedsByNetwork: Record<string, Array<FeedInfo>>
   configByFullName: ConfigByFullName
 
@@ -15,15 +22,43 @@ export class FeedRepository {
   initialize() {
     const feeds = this.feedsState.listFeeds()
 
+    this.dataFeeds = feeds.reduce(
+      (
+        acc: Record<string, Record<Network, Array<FeedInfo>>>,
+        feedInfo: FeedInfo,
+      ) => {
+        let value
+        const isPairKeyPresent: boolean = !!acc[feedInfo.name]
+        const isNetworkAndPairKeyPresent: boolean =
+          isPairKeyPresent && !!acc[feedInfo.name][feedInfo.network]
+        if (isNetworkAndPairKeyPresent) {
+          value = [...acc[feedInfo.name][feedInfo.network], feedInfo]
+        } else {
+          value = [feedInfo]
+        }
+        return {
+          ...acc,
+          [feedInfo.name]: {
+            ...acc[feedInfo.name],
+            [feedInfo.network]: value,
+          },
+        }
+      },
+      {},
+    )
+
     this.dataFeedsByNetwork = feeds.reduce(
-      (acc: Record<string, Array<FeedInfo>>, feedInfo: FeedInfo) => ({
-        ...acc,
-        [feedInfo.network]: acc[feedInfo.network]
-          ? [...acc[feedInfo.network], feedInfo]
-          : [feedInfo],
-      }),
+      (acc: Record<string, Array<FeedInfo>>, feedInfo: FeedInfo) => {
+        return {
+          ...acc,
+          [feedInfo.network]: acc[feedInfo.network]
+            ? [...acc[feedInfo.network], feedInfo]
+            : [feedInfo],
+        }
+      },
       {},
     )
+
     this.configByFullName = feeds.reduce(
       (acc, feedInfo) => ({
         ...acc,
@@ -43,19 +78,65 @@ export class FeedRepository {
       .find((feed) => feed.feedFullName === feedFullName)
   }
 
-  async getFeedsByNetwork(
-    // starts in 1
-    network: string,
-  ): Promise<PaginatedFeedsObject> {
-    let feeds: Array<FeedInfo>
+  async getFilteredFeeds({
+    network,
+    pair,
+    mainnet,
+  }: FeedsFilters): Promise<PaginatedFeedsObject> {
+    let feeds: Array<FeedInfo> = []
     if (network === 'all') {
-      feeds = Object.values(this.dataFeedsByNetwork).flat()
+      feeds = this.feedsState.listFeeds()
+    } else {
+      if (network && pair) {
+        feeds = this.dataFeeds[pair][network]
+      } else if (network) {
+        feeds = this.dataFeedsByNetwork[network]
+      } else if (pair) {
+        feeds = Object.values(this.dataFeeds[pair]).flat()
+      }
+    }
+    console.log('data feeds FLAT', this.dataFeedsByNetwork[network])
+    console.log(`network::${network} pair::${pair} mainnet::${mainnet}`)
+    return this.getPaginatedFeedsByNet(feeds, mainnet)
+  }
+
+  getPaginatedFeedsByNet(feeds: FeedInfo[], mainnet: boolean | null) {
+    if (mainnet === null) {
+      return {
+        feeds: feeds || [],
+        total: feeds ? feeds.length : 0,
+      }
+    }
+    if (mainnet) {
+      return this.getMainnetFeeds(feeds)
     } else {
-      feeds = this.dataFeedsByNetwork[network]
+      return this.getTestnetFeeds(feeds)
     }
+  }
+
+  getConfigurationFromNetwork(network: Network) {
+    return this.feedsState.getConfiguration().getNetworkConfiguration(network)
+  }
+
+  getTestnetFeeds(feeds: Array<FeedInfo>): PaginatedFeedsObject {
+    const filteredFeeds: FeedInfo[] =
+      feeds?.filter(
+        (feed) => !this.getConfigurationFromNetwork(feed.network).mainnet,
+      ) ?? []
     return {
-      feeds: feeds || [],
-      total: feeds ? feeds.length : 0,
+      feeds: filteredFeeds,
+      total: filteredFeeds.length,
+    }
+  }
+
+  getMainnetFeeds(feeds: Array<FeedInfo>): PaginatedFeedsObject {
+    const filteredFeeds: FeedInfo[] =
+      feeds?.filter(
+        (feed) => this.getConfigurationFromNetwork(feed.network).mainnet,
+      ) ?? []
+    return {
+      feeds: filteredFeeds,
+      total: filteredFeeds.length,
     }
   }
 
@@ -98,4 +179,9 @@ export class FeedRepository {
     this.feedsState.setV2Feeds(v2Feeds)
     this.initialize()
   }
+
+  setConfiguration(configuration: Configuration) {
+    this.feedsState.setConfiguration(configuration)
+    this.initialize()
+  }
 }

packages/api/src/repository/ResultRequest.ts

@@ -48,6 +48,25 @@ export class ResultRequestRepository {
       .map(this.normalizeId)
   }
 
+  async getFeedRequestsPageByPair(
+    pair: string,
+    page: number,
+    size: number,
+  ): Promise<PaginatedRequests> {
+    const query = { feedFullName: { $regex: pair } }
+    return {
+      requests: (
+        await this.collection
+          .find(query)
+          .sort({ timestamp: -1 })
+          .skip(size * (page - 1))
+          .limit(size)
+          .toArray()
+      ).map(this.normalizeId),
+      total: (await this.collection.find(query).toArray()).length,
+    }
+  }
+
   async getFeedRequestsPage(
     feedFullName: string,
     page: number,

packages/api/src/repository/feedState.ts

@@ -1,8 +1,10 @@
 import { FeedInfo } from '../../types'
+import { Configuration } from '../web3Middleware/Configuration'
 
 export class FeedsState {
   private legacyFeeds: Array<FeedInfo>
   private v2Feeds: Array<FeedInfo>
+  private configuration: Configuration
 
   constructor() {
     this.legacyFeeds = []
@@ -17,10 +19,18 @@ export class FeedsState {
     this.legacyFeeds = legacyFeeds
   }
 
+  setConfiguration(configuration: Configuration) {
+    this.configuration = configuration
+  }
+
   getV2Feeds(): Array<FeedInfo> {
     return this.v2Feeds
   }
 
+  getConfiguration(): Configuration {
+    return this.configuration
+  }
+
   getLegacyFeeds(): Array<FeedInfo> {
     return this.legacyFeeds
   }

packages/api/src/resolvers.ts

@@ -3,7 +3,12 @@ import { Context } from '../types'
 const resolvers = {
   Query: {
     feeds: async (_parent, args, { feedRepository }: Context) => {
-      return await feedRepository.getFeedsByNetwork(args.network)
+      console.log(args.network)
+      return await feedRepository.getFilteredFeeds({
+        network: args.network,
+        pair: args.pair,
+        mainnet: args.mainnet,
+      })
     },
 
     networks: (_parent, _args, { config }: Context) => {

packages/api/src/typeDefs.ts

@@ -63,7 +63,7 @@ const typeDefs = gql`
 
   type Query {
     feed(feedFullName: String!): Feed
-    feeds(network: String): FeedsPage!
+    feeds(network: String, mainnet: Boolean, pair: String): FeedsPage!
     requests(
       feedFullName: String!
       page: Int!

packages/api/types.ts

@@ -40,6 +40,10 @@ export type ConfigByFullName = {
   [key: string]: FeedInfo
 }
 
+export type NetworkConfigByNetwork = {
+  [key: string]: Configuration
+}
+
 export enum Network {
   ArbitrumOne = 'arbitrum-one',
   ArbitrumGoerli = 'arbitrum-goerli',
@@ -259,6 +263,12 @@ export type LegacyRouterDataFeedsConfig = {
   chains: Record<string, Chain>
 }
 
+export type FeedsFilters = {
+  network: string | null
+  pair: string | null
+  mainnet: boolean
+}
+
 export type FeedInfosWithoutAbis = Array<
   Omit<FeedInfoConfig, 'abi' | 'routerAbi'>
 >

packages/ui/api/index.ts

@@ -10,12 +10,22 @@ function getApiEndpoint() {
   return useRuntimeConfig().public.apiBase
 }
 
-export const getAllFeedsRequests = async ({ network }: { network: string }) =>
+export const getAllFeedsRequests = async ({
+  network,
+  mainnet,
+  pair,
+}: {
+  network: string | null
+  mainnet: boolean | null
+  pair: string | null
+}) =>
   (await request(
     getApiEndpoint(),
     feedsQuery,
     {
       network,
+      mainnet,
+      pair,
     },
     { accept: 'application/json' },
   )) as {

packages/ui/api/queries/feeds.ts

@@ -1,8 +1,8 @@
 import { gql } from 'graphql-request'
 
 export default gql`
-  query feeds($network: String!) {
-    feeds(network: $network) {
+  query feeds($network: String, $mainnet: Boolean, $pair: String) {
+    feeds(network: $network, mainnet: $mainnet, pair: $pair) {
       feeds {
         isRouted
         feedFullName

packages/ui/components/DataFeeds.vue

@@ -94,9 +94,23 @@ watch(networkFeeds, () => {
   }
 })
 onMounted(async () => {
-  networkFeeds.value = await store.fetchFeeds({
+  const fetchedNetworks = await store.fetchFeeds({
     network: props.network.key.toLowerCase(),
+    mainnet: null,
   })
+  // const fetchedByPair = await store.fetchFeeds({
+  //   mainnet: null,
+  //   pair: 'eth/usd',
+  // })
+  // const fetchedByPairAndNetwork = await store.fetchFeeds({
+  //   mainnet: null,
+  //   network: props.network.key.toLowerCase(),
+  //   pair: 'eth/usd',
+  // })
+  console.log('fetch by network', fetchedNetworks)
+  // console.log('Fetch eth/usd feeds >>>', fetchedByPair)
+  // console.log('Fetch eth/usd and avalanche feeds >>>', fetchedByPairAndNetwork)
+  networkFeeds.value = fetchedNetworks
 })
 </script>