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

add optional filter

Browse Source
This commit is contained in:
alexcos20 2020-10-01 06:12:56 -07:00
parent 2c3c8bb04e
commit 4d00c882df
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/ocean/Assets.ts
View File

@ -595,9 +595,13 @@ export class Assets extends Instantiable {
/** /**
* get Order History * get Order History
* @param {Account} account * @param {Account} account
* @param {string} serviceType Optional, filter by
* @return {Promise<OrderHistory[]>} transactionHash of the payment * @return {Promise<OrderHistory[]>} transactionHash of the payment
*/ */
public async getOrderHistory(account: Account): Promise<OrderHistory[]> { public async getOrderHistory(
account: Account,
serviceType?: string
): Promise<OrderHistory[]> {
const results: OrderHistory[] = [] const results: OrderHistory[] = []
const address = this.web3.utils.toChecksumAddress(account.getId()) const address = this.web3.utils.toChecksumAddress(account.getId())
const events = await this.web3.eth.getPastLogs({ const events = await this.web3.eth.getPastLogs({
@ -623,7 +627,8 @@ export class Assets extends Instantiable {
order.did = didPrefixed(didNoZeroX(order.dtAddress)) order.did = didPrefixed(didNoZeroX(order.dtAddress))
const service = await this.getServiceByIndex(order.did, order.serviceId) const service = await this.getServiceByIndex(order.did, order.serviceId)
order.serviceType = service.type order.serviceType = service.type
results.push(order) if (!serviceType || (serviceType && serviceType === service.type))
results.push(order)
} }
return results return results
} }