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

debug

Browse Source
This commit is contained in:
Matthias Kretschmann 2020-09-30 13:33:15 +02:00
parent a2fbbb3765
commit bad9f6641e
Signed by: m
GPG Key ID: 606EEEF3C479A91F
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/balancer/OceanPool.ts
View File

@ -438,31 +438,33 @@ export class OceanPool extends Pool {
const results: PoolTransaction[] = [] const results: PoolTransaction[] = []
const pool = new this.web3.eth.Contract(this.poolABI, poolAddress) const pool = new this.web3.eth.Contract(this.poolABI, poolAddress)
const dtAddress = await this.getDTAddress(poolAddress) const dtAddress = await this.getDTAddress(poolAddress)
const myFilter: Filter = account ? { caller: account } : {} const filter: Filter = account ? { caller: account } : {}
let events: EventData[] let events: EventData[]
events = await pool.getPastEvents('LOG_SWAP', { events = await pool.getPastEvents('LOG_SWAP', {
filter: myFilter, filter,
fromBlock: 0, fromBlock: 0,
toBlock: 'latest' toBlock: 'latest'
}) })
for (let i = 0; i < events.length; i++) { for (let i = 0; i < events.length; i++) {
if (!account || events[i].returnValues[0].toLowerCase() === account.toLowerCase()) if (!account || events[i].returnValues[0].toLowerCase() === account.toLowerCase())
results.push(await this.getEventData('swap', poolAddress, dtAddress, events[i])) results.push(await this.getEventData('swap', poolAddress, dtAddress, events[i]))
} }
events = await pool.getPastEvents('LOG_JOIN', { events = await pool.getPastEvents('LOG_JOIN', {
filter: myFilter, filter,
fromBlock: 0, fromBlock: 0,
toBlock: 'latest' toBlock: 'latest'
}) })
console.log(events)
for (let i = 0; i < events.length; i++) { for (let i = 0; i < events.length; i++) {
if (!account || events[i].returnValues[0].toLowerCase() === account.toLowerCase()) if (!account || events[i].returnValues[0].toLowerCase() === account.toLowerCase())
results.push(await this.getEventData('join', poolAddress, dtAddress, events[i])) results.push(await this.getEventData('join', poolAddress, dtAddress, events[i]))
} }
events = await pool.getPastEvents('LOG_EXIT', { events = await pool.getPastEvents('LOG_EXIT', {
filter: myFilter, filter,
fromBlock: 0, fromBlock: 0,
toBlock: 'latest' toBlock: 'latest'
}) })
@ -487,6 +489,7 @@ export class OceanPool extends Pool {
fromBlock: 0, fromBlock: 0,
toBlock: 'latest' toBlock: 'latest'
}) })
console.log(events)
for (let i = 0; i < events.length; i++) { for (let i = 0; i < events.length; i++) {
const logs = await this.getPoolLogs(events[i].returnValues[0], account) const logs = await this.getPoolLogs(events[i].returnValues[0], account)
for (let j = 0; j < logs.length; j++) results.push(logs[j]) for (let j = 0; j < logs.length; j++) results.push(logs[j])