From d0d7866ad9380836b07df9b9596f6d66f2188641 Mon Sep 17 00:00:00 2001 From: Matthias Kretschmann Date: Fri, 9 Oct 2020 20:29:20 +0200 Subject: [PATCH 1/3] pass through mpAddress --- src/hooks/useConsume/useConsume.ts | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/hooks/useConsume/useConsume.ts b/src/hooks/useConsume/useConsume.ts index 3aed28c..1450924 100644 --- a/src/hooks/useConsume/useConsume.ts +++ b/src/hooks/useConsume/useConsume.ts @@ -8,7 +8,8 @@ interface UseConsume { consume: ( did: DID | string, dataTokenAddress: string, - serviceType: ServiceType + serviceType: ServiceType, + marketFeeAddress: string ) => Promise consumeStep?: number consumeStepText?: string @@ -39,7 +40,8 @@ function useConsume(): UseConsume { async function consume( did: DID | string, dataTokenAddress: string, - serviceType: ServiceType = 'access' + serviceType: ServiceType = 'access', + marketFeeAddress: string ): Promise { if (!ocean || !account || !accountId) return setIsLoading(true) @@ -53,7 +55,9 @@ function useConsume(): UseConsume { const tokenTransfer = await ocean.assets.order( did as string, serviceType, - accountId + accountId, + undefined, + marketFeeAddress ) Logger.log('order created', tokenTransfer) setStep(2) From 803c5f971748202e69a3574de69c5f6fbbf1ffbf Mon Sep 17 00:00:00 2001 From: Matthias Kretschmann Date: Fri, 9 Oct 2020 20:40:15 +0200 Subject: [PATCH 2/3] update example --- example/src/ConsumeDdo.tsx | 5 +++-- src/hooks/useConsume/README.md | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/example/src/ConsumeDdo.tsx b/example/src/ConsumeDdo.tsx index 5adb1ab..94ba730 100644 --- a/example/src/ConsumeDdo.tsx +++ b/example/src/ConsumeDdo.tsx @@ -9,7 +9,7 @@ import { useState } from 'react' import { useEffect } from 'react' export function ConsumeDdo() { - const { ocean } = useOcean() + const { ocean, accountId } = useOcean() const { consumeStepText, consume, consumeError } = useConsume() const { compute, computeStepText } = useCompute() const [did, setDid] = useState() @@ -22,7 +22,8 @@ export function ConsumeDdo() { if (!did) return const ddo = await ocean.assets.resolve(did) - await consume(did, ddo.dataToken, 'access') + // use own accountId for marketFeeAddress for testing purposes + await consume(did, ddo.dataToken, 'access', accountId) } const computeDid = async () => { diff --git a/src/hooks/useConsume/README.md b/src/hooks/useConsume/README.md index cdefd71..516a200 100644 --- a/src/hooks/useConsume/README.md +++ b/src/hooks/useConsume/README.md @@ -14,13 +14,13 @@ export default function MyComponent() { const { accountId } = useOcean() // Get metadata for this asset - const { title, price } = useMetadata(did) + const { title, price, ddo } = useMetadata(did) // Consume helpers const { consume, consumeStep } = useConsume() async function handleDownload() { - await consume(did) + await consume(did, ddo.dataToken, 'access') } return ( From 232e08e177c42a7ef1aa66c24086e9debcf5dbcb Mon Sep 17 00:00:00 2001 From: Matthias Kretschmann Date: Fri, 9 Oct 2020 20:47:03 +0200 Subject: [PATCH 3/3] update compute --- src/hooks/useCompute/useCompute.ts | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/src/hooks/useCompute/useCompute.ts b/src/hooks/useCompute/useCompute.ts index 81e8a22..2cb10d3 100644 --- a/src/hooks/useCompute/useCompute.ts +++ b/src/hooks/useCompute/useCompute.ts @@ -1,7 +1,7 @@ import { useState } from 'react' import { useOcean } from 'providers' import { ComputeValue } from './ComputeOptions' -import { Logger } from '@oceanprotocol/lib' +import { Logger, ServiceCompute } from '@oceanprotocol/lib' import { MetadataAlgorithm } from '@oceanprotocol/lib/dist/node/ddo/interfaces/MetadataAlgorithm' import { ComputeJob } from '@oceanprotocol/lib/dist/node/ocean/interfaces/ComputeJob' import { checkAndBuyDT } from 'utils/dtUtils' @@ -9,10 +9,11 @@ import { checkAndBuyDT } from 'utils/dtUtils' interface UseCompute { compute: ( did: string, - computeService: any, + computeService: ServiceCompute, dataTokenAddress: string, algorithmRawCode: string, - computeContainer: ComputeValue + computeContainer: ComputeValue, + marketFeeAddress: string ) => Promise computeStep?: number computeStepText?: string @@ -57,10 +58,11 @@ function useCompute(): UseCompute { async function compute( did: string, - computeService: any, + computeService: ServiceCompute, dataTokenAddress: string, algorithmRawCode: string, - computeContainer: ComputeValue + computeContainer: ComputeValue, + marketFeeAddress: string ): Promise { if (!ocean || !account) return @@ -80,14 +82,16 @@ function useCompute(): UseCompute { accountId, did, computeService, - rawAlgorithmMeta + rawAlgorithmMeta, + marketFeeAddress ) const tokenTransfer = await ocean.compute.order( accountId, did, computeService.index, undefined, - rawAlgorithmMeta + rawAlgorithmMeta, + marketFeeAddress ) setStep(1) @@ -108,7 +112,7 @@ function useCompute(): UseCompute { undefined, rawAlgorithmMeta, output, - computeService.index, + `${computeService.index}`, computeService.type ) return response