mirror of
https://github.com/oceanprotocol/ocean.js.git
synced 2024-11-26 20:39:05 +01:00
update contracts & provider
This commit is contained in:
parent
bedd07ed2a
commit
fc6a515630
@ -20,7 +20,7 @@ before_script:
|
|||||||
- git clone https://github.com/oceanprotocol/barge
|
- git clone https://github.com/oceanprotocol/barge
|
||||||
- cd barge
|
- cd barge
|
||||||
- git checkout v3
|
- git checkout v3
|
||||||
- export PROVIDER_VERSION=latest
|
- export PROVIDER_VERSION=v0.3.0
|
||||||
- bash -x start_ocean.sh --no-dashboard 2>&1 > start_ocean.log &
|
- bash -x start_ocean.sh --no-dashboard 2>&1 > start_ocean.log &
|
||||||
- cd ..
|
- cd ..
|
||||||
- sleep 300
|
- sleep 300
|
||||||
|
6
package-lock.json
generated
6
package-lock.json
generated
@ -939,9 +939,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"@oceanprotocol/contracts": {
|
"@oceanprotocol/contracts": {
|
||||||
"version": "0.4.1",
|
"version": "0.4.2",
|
||||||
"resolved": "https://registry.npmjs.org/@oceanprotocol/contracts/-/contracts-0.4.1.tgz",
|
"resolved": "https://registry.npmjs.org/@oceanprotocol/contracts/-/contracts-0.4.2.tgz",
|
||||||
"integrity": "sha512-gc6bCt3pq9cpk1mYDKfsZhLlaM+8yQDFmOjtmT1KGXRmnTBcvmwCQXMrL5VohFaFi7Iqio3FZtuhYyRaEjikCw=="
|
"integrity": "sha512-IKRUe60pcBcEmQhkpusSc+w2CIEHxmyNzth+VRU5Je6lrP6/XnDaFRHjeYbSy306I/WxLjma88S1xOn86BMCOA=="
|
||||||
},
|
},
|
||||||
"@octokit/auth-token": {
|
"@octokit/auth-token": {
|
||||||
"version": "2.4.2",
|
"version": "2.4.2",
|
||||||
|
@ -42,7 +42,7 @@
|
|||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@ethereum-navigator/navigator": "^0.5.0",
|
"@ethereum-navigator/navigator": "^0.5.0",
|
||||||
"@oceanprotocol/contracts": "^0.4.1",
|
"@oceanprotocol/contracts": "^0.4.2",
|
||||||
"decimal.js": "^10.2.0",
|
"decimal.js": "^10.2.0",
|
||||||
"fs": "0.0.1-security",
|
"fs": "0.0.1-security",
|
||||||
"node-fetch": "^2.6.1",
|
"node-fetch": "^2.6.1",
|
||||||
|
@ -380,23 +380,19 @@ export class DataTokens {
|
|||||||
|
|
||||||
/** Start Order
|
/** Start Order
|
||||||
* @param {String} dataTokenAddress
|
* @param {String} dataTokenAddress
|
||||||
* @param {String} providerAddress
|
|
||||||
* @param {String} amount
|
* @param {String} amount
|
||||||
* @param {String} did
|
* @param {String} did
|
||||||
* @param {Number} serviceId
|
* @param {Number} serviceId
|
||||||
* @param {String} mpFeeAddress
|
* @param {String} mpFeeAddress
|
||||||
* @param {String} mpFeePercentage
|
|
||||||
* @param {String} address consumer Address
|
* @param {String} address consumer Address
|
||||||
* @return {Promise<string>} string
|
* @return {Promise<string>} string
|
||||||
*/
|
*/
|
||||||
public async startOrder(
|
public async startOrder(
|
||||||
dataTokenAddress: string,
|
dataTokenAddress: string,
|
||||||
providerAddress: string,
|
|
||||||
amount: string,
|
amount: string,
|
||||||
did: string,
|
did: string,
|
||||||
serviceId: number,
|
serviceId: number,
|
||||||
mpFeeAddress: string,
|
mpFeeAddress: string,
|
||||||
mpFeePercentage: string,
|
|
||||||
address: string
|
address: string
|
||||||
): Promise<TransactionReceipt> {
|
): Promise<TransactionReceipt> {
|
||||||
const datatoken = new this.web3.eth.Contract(this.datatokensABI, dataTokenAddress, {
|
const datatoken = new this.web3.eth.Contract(this.datatokensABI, dataTokenAddress, {
|
||||||
@ -404,14 +400,7 @@ export class DataTokens {
|
|||||||
})
|
})
|
||||||
try {
|
try {
|
||||||
const trxReceipt = await datatoken.methods
|
const trxReceipt = await datatoken.methods
|
||||||
.startOrder(
|
.startOrder(this.web3.utils.toWei(amount), did, String(serviceId), mpFeeAddress)
|
||||||
providerAddress,
|
|
||||||
this.web3.utils.toWei(amount),
|
|
||||||
did,
|
|
||||||
String(serviceId),
|
|
||||||
mpFeeAddress,
|
|
||||||
this.web3.utils.toWei(mpFeePercentage)
|
|
||||||
)
|
|
||||||
.send({ from: address, gas: 600000 })
|
.send({ from: address, gas: 600000 })
|
||||||
return trxReceipt
|
return trxReceipt
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
@ -422,7 +411,6 @@ export class DataTokens {
|
|||||||
|
|
||||||
/** Search and return txid for a previous valid order with the same params
|
/** Search and return txid for a previous valid order with the same params
|
||||||
* @param {String} dataTokenAddress
|
* @param {String} dataTokenAddress
|
||||||
* @param {String} providerAddress
|
|
||||||
* @param {String} amount
|
* @param {String} amount
|
||||||
* @param {String} did
|
* @param {String} did
|
||||||
* @param {Number} serviceId
|
* @param {Number} serviceId
|
||||||
@ -432,7 +420,6 @@ export class DataTokens {
|
|||||||
*/
|
*/
|
||||||
public async getPreviousValidOrders(
|
public async getPreviousValidOrders(
|
||||||
dataTokenAddress: string,
|
dataTokenAddress: string,
|
||||||
providerAddress: string,
|
|
||||||
amount: string,
|
amount: string,
|
||||||
did: string,
|
did: string,
|
||||||
serviceId: number,
|
serviceId: number,
|
||||||
@ -450,7 +437,6 @@ export class DataTokens {
|
|||||||
if (
|
if (
|
||||||
events[i].returnValues.did === did &&
|
events[i].returnValues.did === did &&
|
||||||
String(events[i].returnValues.amount) === String(amount) &&
|
String(events[i].returnValues.amount) === String(amount) &&
|
||||||
events[i].returnValues.receiver === providerAddress &&
|
|
||||||
String(events[i].returnValues.serviceId) === String(serviceId)
|
String(events[i].returnValues.serviceId) === String(serviceId)
|
||||||
) {
|
) {
|
||||||
const transaction = await this.web3.eth.getTransaction(events[i].transactionHash)
|
const transaction = await this.web3.eth.getTransaction(events[i].transactionHash)
|
||||||
|
@ -413,8 +413,7 @@ export class Assets extends Instantiable {
|
|||||||
did: string,
|
did: string,
|
||||||
serviceType: string,
|
serviceType: string,
|
||||||
consumerAddress: string,
|
consumerAddress: string,
|
||||||
serviceIndex = -1,
|
serviceIndex = -1
|
||||||
mpFeePercent?: string
|
|
||||||
): Promise<any> {
|
): Promise<any> {
|
||||||
const res = await this.ocean.provider.initialize(
|
const res = await this.ocean.provider.initialize(
|
||||||
did,
|
did,
|
||||||
@ -424,19 +423,6 @@ export class Assets extends Instantiable {
|
|||||||
)
|
)
|
||||||
if (res === null) return null
|
if (res === null) return null
|
||||||
const providerData = JSON.parse(res)
|
const providerData = JSON.parse(res)
|
||||||
const { datatokens } = this.ocean
|
|
||||||
const dtCost = new BigNumber(this.web3.utils.fromWei(String(providerData.numTokens)))
|
|
||||||
const totalFee = new BigNumber(
|
|
||||||
await datatokens.calculateTotalFee(
|
|
||||||
providerData.dataToken,
|
|
||||||
this.web3.utils.fromWei(String(providerData.numTokens)),
|
|
||||||
mpFeePercent,
|
|
||||||
consumerAddress
|
|
||||||
)
|
|
||||||
)
|
|
||||||
providerData.totalFee = totalFee.toString()
|
|
||||||
providerData.dtCost = dtCost.toString()
|
|
||||||
providerData.totalCost = dtCost.plus(totalFee).toString()
|
|
||||||
return providerData
|
return providerData
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -446,7 +432,6 @@ export class Assets extends Instantiable {
|
|||||||
* @param {String} serviceType
|
* @param {String} serviceType
|
||||||
* @param {String} consumerAddress
|
* @param {String} consumerAddress
|
||||||
* @param {Number} serviceIndex
|
* @param {Number} serviceIndex
|
||||||
* @param {String} mpFeePercent will be converted to Wei
|
|
||||||
* @param {String} mpAddress mp fee collector address
|
* @param {String} mpAddress mp fee collector address
|
||||||
* @return {Promise<String>} transactionHash of the payment
|
* @return {Promise<String>} transactionHash of the payment
|
||||||
*/
|
*/
|
||||||
@ -455,7 +440,6 @@ export class Assets extends Instantiable {
|
|||||||
serviceType: string,
|
serviceType: string,
|
||||||
consumerAddress: string,
|
consumerAddress: string,
|
||||||
serviceIndex = -1,
|
serviceIndex = -1,
|
||||||
mpFeePercent?: string,
|
|
||||||
mpAddress?: string
|
mpAddress?: string
|
||||||
): Promise<string> {
|
): Promise<string> {
|
||||||
if (serviceIndex === -1) {
|
if (serviceIndex === -1) {
|
||||||
@ -465,22 +449,18 @@ export class Assets extends Instantiable {
|
|||||||
const service = await this.getServiceByIndex(did, serviceIndex)
|
const service = await this.getServiceByIndex(did, serviceIndex)
|
||||||
serviceType = service.type
|
serviceType = service.type
|
||||||
}
|
}
|
||||||
if (!mpFeePercent) mpFeePercent = '0'
|
|
||||||
if (!mpAddress) mpAddress = '0x000000000000000000000000000000000000dEaD'
|
|
||||||
const { datatokens } = this.ocean
|
const { datatokens } = this.ocean
|
||||||
try {
|
try {
|
||||||
const providerData = await this.initialize(
|
const providerData = await this.initialize(
|
||||||
did,
|
did,
|
||||||
serviceType,
|
serviceType,
|
||||||
consumerAddress,
|
consumerAddress,
|
||||||
serviceIndex,
|
serviceIndex
|
||||||
mpFeePercent
|
|
||||||
)
|
)
|
||||||
if (!providerData) return null
|
if (!providerData) return null
|
||||||
const service = await this.getServiceByIndex(did, serviceIndex)
|
const service = await this.getServiceByIndex(did, serviceIndex)
|
||||||
const previousOrder = await datatokens.getPreviousValidOrders(
|
const previousOrder = await datatokens.getPreviousValidOrders(
|
||||||
providerData.dataToken,
|
providerData.dataToken,
|
||||||
providerData.to,
|
|
||||||
providerData.numTokens,
|
providerData.numTokens,
|
||||||
didZeroX(did),
|
didZeroX(did),
|
||||||
serviceIndex,
|
serviceIndex,
|
||||||
@ -491,7 +471,7 @@ export class Assets extends Instantiable {
|
|||||||
const balance = new BigNumber(
|
const balance = new BigNumber(
|
||||||
await datatokens.balance(providerData.dataToken, consumerAddress)
|
await datatokens.balance(providerData.dataToken, consumerAddress)
|
||||||
)
|
)
|
||||||
const totalCost = new BigNumber(providerData.totalCost)
|
const totalCost = new BigNumber(providerData.numTokens)
|
||||||
if (balance.isLessThanOrEqualTo(totalCost)) {
|
if (balance.isLessThanOrEqualTo(totalCost)) {
|
||||||
console.error(
|
console.error(
|
||||||
'Not enough funds. Needed ' +
|
'Not enough funds. Needed ' +
|
||||||
@ -503,12 +483,10 @@ export class Assets extends Instantiable {
|
|||||||
}
|
}
|
||||||
const txid = await datatokens.startOrder(
|
const txid = await datatokens.startOrder(
|
||||||
providerData.dataToken,
|
providerData.dataToken,
|
||||||
providerData.to,
|
|
||||||
this.web3.utils.fromWei(String(providerData.numTokens)),
|
this.web3.utils.fromWei(String(providerData.numTokens)),
|
||||||
didZeroX(did),
|
didZeroX(did),
|
||||||
serviceIndex,
|
serviceIndex,
|
||||||
mpAddress,
|
mpAddress,
|
||||||
mpFeePercent,
|
|
||||||
consumerAddress
|
consumerAddress
|
||||||
)
|
)
|
||||||
if (txid) return txid.transactionHash
|
if (txid) return txid.transactionHash
|
||||||
|
@ -350,7 +350,6 @@ export class Compute extends Instantiable {
|
|||||||
serviceIndex: number,
|
serviceIndex: number,
|
||||||
algorithmDid?: string,
|
algorithmDid?: string,
|
||||||
algorithmMeta?: MetadataAlgorithm,
|
algorithmMeta?: MetadataAlgorithm,
|
||||||
mpFeePercent?: string,
|
|
||||||
mpAddress?: string
|
mpAddress?: string
|
||||||
): SubscribablePromise<OrderProgressStep, string> {
|
): SubscribablePromise<OrderProgressStep, string> {
|
||||||
return new SubscribablePromise(async (observer) => {
|
return new SubscribablePromise(async (observer) => {
|
||||||
@ -384,7 +383,6 @@ export class Compute extends Instantiable {
|
|||||||
service.type,
|
service.type,
|
||||||
consumerAccount,
|
consumerAccount,
|
||||||
-1,
|
-1,
|
||||||
mpFeePercent,
|
|
||||||
mpAddress
|
mpAddress
|
||||||
)
|
)
|
||||||
return order
|
return order
|
||||||
|
Loading…
x
Reference in New Issue
Block a user