oceanprotocol/market
1
0
Fork 0
mirror of https://github.com/oceanprotocol/market.git synced 2024-11-15 01:34:57 +01:00
Code Releases Activity

trigger check previous order after starting a compute job

Browse Source
This commit is contained in:
Bogdan Fazakas 2021-05-07 16:00:40 +03:00
parent 6cc268bd3f
commit e73d140012
2 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/components/organisms/AssetActions/Compute/index.tsx
View File

@ -136,6 +136,7 @@ export default function Compute({
timeout.toString()
)
const assetType = ddo.findServiceByType('metadata').attributes.main.type
console.log('checkPreviousOrders asset ' + assetType + ' id= ', orderId)
if (assetType === 'algorithm') {
setPreviousAlgorithmOrderId(orderId)
setHasPreviousAlgorithmOrder(!!orderId)
@ -430,7 +431,10 @@ export default function Compute({
Logger.log('[compute] Starting compute job response: ', response)
setHasPreviousDatasetOrder(true)
// setHasPreviousDatasetOrder(true)
// setHasPreviousAlgorithmOrder(true)
checkPreviousOrders(selectedAlgorithmAsset)
checkPreviousOrders(ddo)
setIsPublished(true)
} catch (error) {
setError('Failed to start job!')

12
src/utils/subgraph.ts
View File

@ -75,14 +75,18 @@ export async function getPreviousOrders(
variables
)
if (fetchedPreviousOrders.data?.tokenOrders?.length === 0) return null
console.log('order fetchedPreviousOrders', fetchedPreviousOrders?.data)
if (assetTimeout === '0') {
return fetchedPreviousOrders?.data?.tokenOrders[0]?.tx
} else {
const expiry = new BigNumber(
console.log(
'order timestamp',
fetchedPreviousOrders?.data?.tokenOrders[0]?.timestamp
).plus(assetTimeout)
const unixTime = new BigNumber(Math.floor(Date.now() / 1000))
if (unixTime.isLessThan(expiry)) {
)
const expiry =
fetchedPreviousOrders?.data?.tokenOrders[0]?.timestamp * 1000 +
Number(assetTimeout) * 1000
if (Date.now() <= expiry) {
return fetchedPreviousOrders?.data?.tokenOrders[0]?.tx
} else {
return null