oceanprotocol/ocean.js
1
0
Fork 0
mirror of https://github.com/oceanprotocol/ocean.js.git synced 2024-11-26 20:39:05 +01:00
Code Releases Activity

fix tests, keep backwards compatibility due to tests running with existing provider

Browse Source
This commit is contained in:
paulo-ocean 2024-10-31 19:33:54 +00:00
parent a6ad053cd0
commit e1c5194f43
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/services/Provider.ts
View File

@ -626,6 +626,7 @@ export class Provider {
signal?: AbortSignal, signal?: AbortSignal,
output?: ComputeOutput output?: ComputeOutput
): Promise<ComputeJob | ComputeJob[]> { ): Promise<ComputeJob | ComputeJob[]> {
console.log('called new compute start method...')
const providerEndpoints = await this.getEndpoints(providerUri) const providerEndpoints = await this.getEndpoints(providerUri)
const serviceEndpoints = await this.getServiceEndpoints( const serviceEndpoints = await this.getServiceEndpoints(
providerUri, providerUri,
@ -655,9 +656,12 @@ export class Provider {
payload.signature = signature payload.signature = signature
payload.nonce = nonce payload.nonce = nonce
payload.environment = computeEnv payload.environment = computeEnv
// kept for backwards compatibility (tests running against existing provider)
payload.dataset = datasets[0]
// new field for C2D v2
payload.datasets = datasets payload.datasets = datasets
payload.algorithm = algorithm payload.algorithm = algorithm
// if (additionalDatasets) payload.additionalDatasets = additionalDatasets
if (output) payload.output = output if (output) payload.output = output
if (!computeStartUrl) return null if (!computeStartUrl) return null
let response let response