From 369b075aa962b4f9f0852f8c087fa6b1c838d208 Mon Sep 17 00:00:00 2001
From: Bogdan Fazakas <bogdan.fazakas@gmail.com>
Date: Fri, 23 Apr 2021 16:44:31 +0300
Subject: [PATCH] fixed compute algorithm pool price value (#553)

---
 src/components/organisms/AssetActions/Compute/index.tsx | 6 +++++-
 src/utils/subgraph.ts                                   | 6 +++++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/components/organisms/AssetActions/Compute/index.tsx b/src/components/organisms/AssetActions/Compute/index.tsx
index 58ac280d6..ee6f459ca 100644
--- a/src/components/organisms/AssetActions/Compute/index.tsx
+++ b/src/components/organisms/AssetActions/Compute/index.tsx
@@ -58,6 +58,7 @@ const poolQuery = gql`
   query AlgorithmPoolPrice($datatoken: String) {
     pools(where: { datatokenAddress: $datatoken }) {
       spotPrice
+      consumePrice
     }
   }
 `
@@ -234,7 +235,10 @@ export default function Compute({
       return
     setAlgorithmPrice((prevState) => ({
       ...prevState,
-      value: poolPrice.pools[0].spotPrice
+      value:
+        poolPrice.pools[0].consumePrice === '-1'
+          ? poolPrice.pools[0].spotPrice
+          : poolPrice.pools[0].consumePrice
     }))
   }, [poolPrice])
 
diff --git a/src/utils/subgraph.ts b/src/utils/subgraph.ts
index 3ae3304cf..c424251ef 100644
--- a/src/utils/subgraph.ts
+++ b/src/utils/subgraph.ts
@@ -24,6 +24,7 @@ const poolQuery = gql`
   query AssetPoolPrice($datatokenAddress_in: [String!]) {
     pools(where: { datatokenAddress_in: $datatokenAddress_in }) {
       spotPrice
+      consumePrice
       id
       datatokenAddress
     }
@@ -106,7 +107,10 @@ export async function getAssetPrices(assets: DDO[]): Promise<PriceList> {
   }
   const poolPriceResponse: any = await fetchData(poolQuery, poolVariables)
   for (const poolPrice of poolPriceResponse.data?.pools) {
-    priceList[didDTMap[poolPrice.datatokenAddress]] = poolPrice.spotPrice
+    priceList[didDTMap[poolPrice.datatokenAddress]] =
+      poolPrice.consumePrice === '-1'
+        ? poolPrice.spotPrice
+        : poolPrice.consumePrice
   }
   const frePriceResponse: any = await fetchData(freQuery, freVariables)
   for (const frePrice of frePriceResponse.data?.fixedRateExchanges) {