1
0
mirror of https://github.com/oceanprotocol/market.git synced 2024-12-02 05:57:29 +01:00

error handling on intializeCompute and order

This commit is contained in:
Bogdan Fazakas 2022-06-01 17:03:18 +03:00
parent 2e9898907d
commit 9ff04d3c04

View File

@ -126,18 +126,32 @@ export default function Compute({
async function initPriceAndFees() { async function initPriceAndFees() {
const computeEnv = await getComputeEnviroment(asset) const computeEnv = await getComputeEnviroment(asset)
setComputeEnv(computeEnv) console.log('computeEnv', computeEnv)
if (!computeEnv || !computeEnv.id) {
setError(`Error getting compute environments!`)
return
}
const initializedProvider = await initializeProviderForCompute( const initializedProvider = await initializeProviderForCompute(
asset, asset,
selectedAlgorithmAsset, selectedAlgorithmAsset,
accountId, accountId,
computeEnv computeEnv
) )
console.log('initializedProvider', initializedProvider)
if (
!initializedProvider ||
!initializedProvider.datasets ||
!initializedProvider.algorithm
) {
setError(`Error initializing provider for the compute job!`)
return
}
setInitializedProviderResponse(initializedProvider) setInitializedProviderResponse(initializedProvider)
if ( if (
asset?.accessDetails?.addressOrId !== ZERO_ADDRESS && asset?.accessDetails?.addressOrId !== ZERO_ADDRESS &&
asset?.accessDetails?.type !== 'free' && asset?.accessDetails?.type !== 'free' &&
initializedProvider.datasets[0].providerFee initializedProvider?.datasets?.[0]?.providerFee
) { ) {
setComputeStatusText( setComputeStatusText(
getComputeFeedback( getComputeFeedback(
@ -166,7 +180,7 @@ export default function Compute({
asset, asset,
ZERO_ADDRESS, ZERO_ADDRESS,
poolParams, poolParams,
initializedProvider.datasets[0].providerFee initializedProvider?.datasets?.[0]?.providerFee
) )
if (!datasetPriceAndFees) { if (!datasetPriceAndFees) {
setError('Error setting dataset price and fees!') setError('Error setting dataset price and fees!')
@ -179,7 +193,7 @@ export default function Compute({
if ( if (
selectedAlgorithmAsset?.accessDetails?.addressOrId !== ZERO_ADDRESS && selectedAlgorithmAsset?.accessDetails?.addressOrId !== ZERO_ADDRESS &&
selectedAlgorithmAsset?.accessDetails?.type !== 'free' && selectedAlgorithmAsset?.accessDetails?.type !== 'free' &&
initializedProvider.algorithm.providerFee initializedProvider?.algorithm?.providerFee
) { ) {
setComputeStatusText( setComputeStatusText(
getComputeFeedback( getComputeFeedback(
@ -321,7 +335,11 @@ export default function Compute({
initializedProviderResponse.datasets[0], initializedProviderResponse.datasets[0],
computeEnv.consumerAddress computeEnv.consumerAddress
) )
if (!datasetOrderTx) {
setError('Failed to order dataset.')
LoggerInstance.error('[compute] Failed to order dataset.')
return
}
setComputeStatusText( setComputeStatusText(
getComputeFeedback( getComputeFeedback(
selectedAlgorithmAsset.accessDetails.baseToken?.symbol, selectedAlgorithmAsset.accessDetails.baseToken?.symbol,
@ -335,6 +353,7 @@ export default function Compute({
: 3 : 3
] ]
) )
const algorithmOrderTx = await handleComputeOrder( const algorithmOrderTx = await handleComputeOrder(
web3, web3,
selectedAlgorithmAsset, selectedAlgorithmAsset,
@ -344,6 +363,12 @@ export default function Compute({
initializedProviderResponse.algorithm, initializedProviderResponse.algorithm,
computeEnv.consumerAddress computeEnv.consumerAddress
) )
if (!algorithmOrderTx) {
setError('Failed to order algorithm.')
LoggerInstance.error('[compute] Failed to order algorithm.')
return
}
LoggerInstance.log('[compute] Starting compute job.') LoggerInstance.log('[compute] Starting compute job.')
const computeAsset: ComputeAsset = { const computeAsset: ComputeAsset = {
documentId: asset.id, documentId: asset.id,