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

wip add assets.create

Browse Source
This commit is contained in:
arsenyjin 2020-06-23 19:13:55 +02:00
parent dca6340424
commit d9c478b71f
2 changed files with 40 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/brizo/Brizo.ts
View File

@ -2,7 +2,7 @@ import Account from '../ocean/Account'
import { noZeroX } from '../utils' import { noZeroX } from '../utils'
import { Instantiable, InstantiableConfig } from '../Instantiable.abstract' import { Instantiable, InstantiableConfig } from '../Instantiable.abstract'
const apiPath = '/api/v1/brizo/services' const apiPath = '/api/v1/provider/services'
/** /**
* Provides an interface for provider service. * Provides an interface for provider service.

55
test/integration/Marketplaceflow.test.ts
View File

@ -2,6 +2,7 @@ import { TestContractHandler } from '../TestContractHandler'
import { DataTokens } from '../../src/datatokens/Datatokens' import { DataTokens } from '../../src/datatokens/Datatokens'
import { Ocean } from '../../src/ocean/Ocean' import { Ocean } from '../../src/ocean/Ocean'
import { Config } from '../../src/models/Config' import { Config } from '../../src/models/Config'
import Accounts from "../../src/ocean/Account" // ??
const Web3 = require('web3') const Web3 = require('web3')
const web3 = new Web3('http://127.0.0.1:8545') const web3 = new Web3('http://127.0.0.1:8545')
@ -9,14 +10,16 @@ const factory = require('@oceanprotocol/contracts/artifacts/development/Factory.
const datatokensTemplate = require('@oceanprotocol/contracts/artifacts/development/DataTokenTemplate.json') const datatokensTemplate = require('@oceanprotocol/contracts/artifacts/development/DataTokenTemplate.json')
describe('Marketplace flow', () => { describe('Marketplace flow', () => {
let ddo
let owner let owner
let bob let bob
let alice let asset
let contracts let contracts
let datatoken let datatoken
let tokenAddress
let transactionId let transactionId
let alice = new Accounts()
const tokenAmount = 100 const tokenAmount = 100
const transferAmount = 1 const transferAmount = 1
const blob = 'http://localhost:8030/api/v1/provider/services' const blob = 'http://localhost:8030/api/v1/provider/services'
@ -32,11 +35,30 @@ describe('Marketplace flow', () => {
) )
await contracts.getAccounts() await contracts.getAccounts()
owner = contracts.accounts[0] owner = contracts.accounts[0]
alice = contracts.accounts[1]
bob = contracts.accounts[2] bob = contracts.accounts[2]
await alice.setId(contracts.accounts[1])
await alice.setPassword("0x4a608ef70ce229351d37be7b07ddd7a3ce46709911cf8c8c4bcabd8a6c563711")
await contracts.deployContracts(owner) await contracts.deployContracts(owner)
}) })
it('Generates metadata', async () => {
asset = {
main: {
type: 'dataset',
name: 'test-dataset',
dateCreated:
new Date(Date.now())
.toISOString()
.split('.')[0] + 'Z', // remove milliseconds
author: 'oceanprotocol-team',
license: 'MIT'
}
}
})
it('Alice publishes a dataset', async () => { it('Alice publishes a dataset', async () => {
// Alice creates a Datatoken // Alice creates a Datatoken
datatoken = new DataTokens( datatoken = new DataTokens(
@ -49,22 +71,23 @@ describe('Marketplace flow', () => {
const config = new Config() const config = new Config()
const ocean = await Ocean.getInstance(config) const ocean = await Ocean.getInstance(config)
ddo = await ocean.assets.createSimpleAsset(datatoken, alice, blob) tokenAddress = await datatoken.create(blob, alice.getId())
await ocean.assets.create(asset, alice, [], tokenAddress)
}) })
it('Alice mints 100 tokens', async () => { // it('Alice mints 100 tokens', async () => {
await datatoken.mint(ddo, alice, tokenAmount) // await datatoken.mint(ddo, alice, tokenAmount)
}) // })
it('Bob gets 1 datatoken', async () => { // it('Bob gets 1 datatoken', async () => {
const ts = await datatoken.transfer(ddo, bob, transferAmount, alice) // const ts = await datatoken.transfer(ddo, bob, transferAmount, alice)
transactionId = ts.transactionHash // transactionId = ts.transactionHash
}) // })
it('Bob consumes dataset', async () => { // it('Bob consumes dataset', async () => {
const config = new Config() // const config = new Config()
const ocean = await Ocean.getInstance(config) // const ocean = await Ocean.getInstance(config)
await ocean.assets.download(ddo, blob, transactionId, bob) // await ocean.assets.download(ddo, blob, transactionId, bob)
}) // })
}) })
}) })