From c533d1ee0c6de8bdb72265d75e0d1b64e53b2f49 Mon Sep 17 00:00:00 2001
From: Bogdan Fazakas <bogdan.fazakas@gmail.com>
Date: Sun, 11 Apr 2021 02:13:43 +0300
Subject: [PATCH] get compute previous orders from subgraph util

---
 .../organisms/AssetActions/Compute/index.tsx  | 10 +++-
 .../organisms/AssetActions/Consume.tsx        |  1 +
 src/utils/aquarius.ts                         |  7 +--
 src/utils/subgraph.ts                         | 58 ++++++++++++++++---
 4 files changed, 62 insertions(+), 14 deletions(-)

diff --git a/src/components/organisms/AssetActions/Compute/index.tsx b/src/components/organisms/AssetActions/Compute/index.tsx
index 83a442ed3..3036fcdf6 100644
--- a/src/components/organisms/AssetActions/Compute/index.tsx
+++ b/src/components/organisms/AssetActions/Compute/index.tsx
@@ -38,6 +38,7 @@ import { gql, useQuery } from '@apollo/client'
 import { FrePrice } from '../../../../@types/apollo/FrePrice'
 import { PoolPrice } from '../../../../@types/apollo/PoolPrice'
 import { secondsToString } from '../../../../utils/metadata'
+import { getPreviousOrders } from '../../../../utils/subgraph'
 
 const SuccessAction = () => (
   <Button style="text" to="/history" size="small">
@@ -122,7 +123,14 @@ export default function Compute({
   const hasDatatoken = Number(dtBalance) >= 1
 
   async function checkPreviousOrders(ddo: DDO, serviceType: ServiceType) {
-    const orderId = await checkPreviousOrder(ocean, accountId, ddo, serviceType)
+    const { timeout } = (
+      ddo.findServiceByType('access') || ddo.findServiceByType('compute')
+    ).attributes.main
+    const orderId = await getPreviousOrders(
+      ddo.dataToken?.toLowerCase(),
+      accountId?.toLowerCase(),
+      secondsToString(timeout)
+    )
     const assetType = ddo.findServiceByType('metadata').attributes.main.type
     if (assetType === 'algorithm') {
       setPreviousAlgorithmOrderId(orderId)
diff --git a/src/components/organisms/AssetActions/Consume.tsx b/src/components/organisms/AssetActions/Consume.tsx
index 30ba32d08..d7c19cdcc 100644
--- a/src/components/organisms/AssetActions/Consume.tsx
+++ b/src/components/organisms/AssetActions/Consume.tsx
@@ -69,6 +69,7 @@ export default function Consume({
   })
 
   useEffect(() => {
+    console.log('data', data)
     if (!data || !assetTimeout || data.tokenOrders.length === 0) return
 
     const lastOrder = data.tokenOrders[0]
diff --git a/src/utils/aquarius.ts b/src/utils/aquarius.ts
index 74d14d19d..8aaff7f27 100644
--- a/src/utils/aquarius.ts
+++ b/src/utils/aquarius.ts
@@ -114,18 +114,15 @@ export async function transformDDOToAssetSelection(
   const source = axios.CancelToken.source()
   const didList: string[] = []
   const priceList: any = await getAssetPrice(ddoList)
-  console.log(priceList)
   const symbolList: any = {}
-  for (const ddo: DDO of ddoList) {
+  for (const ddo of ddoList) {
     didList.push(ddo.id)
     symbolList[ddo.id] = ddo.dataTokenInfo.symbol
   }
   const ddoNames = await getAssetsNames(didList, metadataCacheUri, source.token)
   const algorithmList: AssetSelectionAsset[] = []
   didList?.forEach((did: string) => {
-    console.log(did)
-    console.log(priceList[did])
-    if (priceList[did] != '') {
+    if (priceList[did] !== 'none') {
       let selected = false
       selectedAlgorithms?.forEach((algorithm: PublisherTrustedAlgorithm) => {
         if (algorithm.did === did) {
diff --git a/src/utils/subgraph.ts b/src/utils/subgraph.ts
index 14acbcfd0..63b2b2c15 100644
--- a/src/utils/subgraph.ts
+++ b/src/utils/subgraph.ts
@@ -1,8 +1,7 @@
-import { gql, DocumentNode } from '@apollo/client'
-import { FrePrice } from '../@types/apollo/FrePrice'
-import { PoolPrice } from '../@types/apollo/PoolPrice'
+import { gql, DocumentNode, ApolloQueryResult } from '@apollo/client'
 import { DDO } from '@oceanprotocol/lib'
 import { getApolloClientInstance } from '../providers/ApolloClientProvider'
+import BigNumber from 'bignumber.js'
 
 const freQuery = gql`
   query AssetFrePrice($datatoken_in: [String!]) {
@@ -27,10 +26,24 @@ const poolQuery = gql`
   }
 `
 
+const previousOrderQuery = gql`
+  query AssetPreviousOrder($id: String!, $account: String!) {
+    tokenOrders(
+      first: 1
+      where: { datatokenId: $id, payer: $account }
+      orderBy: timestamp
+      orderDirection: desc
+    ) {
+      timestamp
+      tx
+    }
+  }
+`
+
 async function fetchData(
   query: DocumentNode,
   variables: any
-): Promise<ApolloQueryResult> {
+): Promise<ApolloQueryResult<any>> {
   try {
     const client = getApolloClientInstance()
     const response = await client.query({
@@ -39,7 +52,36 @@ async function fetchData(
     })
     return response
   } catch (error) {
-    console.error('Error parsing json: ', error)
+    console.error('Error fetchData: ', error.message)
+  }
+}
+
+export async function getPreviousOrders(
+  id: string,
+  account: string,
+  assetTimeout: string
+): Promise<string> {
+  const variables = {
+    id: id,
+    account: account
+  }
+  const fatchedPreviousOrders: any = await fetchData(
+    previousOrderQuery,
+    variables
+  )
+  if (fatchedPreviousOrders.data?.tokenOrders?.length === 0) return null
+  if (assetTimeout === 'Forever') {
+    return fatchedPreviousOrders?.data?.tokenOrders[0]?.tx
+  } else {
+    const expiry = new BigNumber(
+      fatchedPreviousOrders?.data?.tokenOrders[0]?.timestamp
+    ).plus(assetTimeout)
+    const unixTime = new BigNumber(Math.floor(Date.now() / 1000))
+    if (unixTime.isLessThan(expiry)) {
+      return fatchedPreviousOrders?.data?.tokenOrders[0]?.tx
+    } else {
+      return null
+    }
   }
 }
 
@@ -49,13 +91,15 @@ export async function getAssetPrice(assets: DDO[]): Promise<any> {
   const poolDTadressDID: any = {}
   const frePriceAssets: string[] = []
   const freDTadressDID: any = {}
-  for (const ddo: DDO of assets) {
+  for (const ddo of assets) {
     if (ddo.price?.type === 'pool') {
       poolDTadressDID[ddo?.dataToken.toLowerCase()] = ddo.id
       poolPriceAssets.push(ddo?.dataToken.toLowerCase())
     } else if (ddo.price?.type === 'exchange') {
       freDTadressDID[ddo?.dataToken.toLowerCase()] = ddo.id
       frePriceAssets.push(ddo?.dataToken.toLowerCase())
+    } else {
+      priceList[ddo.id] = 'none'
     }
   }
   const freVariables = {
@@ -65,12 +109,10 @@ export async function getAssetPrice(assets: DDO[]): Promise<any> {
     datatokenAddress_in: poolPriceAssets
   }
   const poolPriceResponse: any = await fetchData(poolQuery, poolVariables)
-  console.log('poolPriceResponse', poolPriceResponse)
   for (const poolPirce of poolPriceResponse.data?.pools) {
     priceList[poolDTadressDID[poolPirce.datatokenAddress]] = poolPirce.spotPrice
   }
   const frePriceResponse: any = await fetchData(freQuery, freVariables)
-  console.log('frePriceResponse', frePriceResponse)
   for (const frePrice of frePriceResponse.data?.fixedRateExchanges) {
     priceList[freDTadressDID[frePrice.datatoken?.address]] = frePrice.rate
   }