oceanprotocol/ocean-subgraph
1
0
Fork 0
mirror of https://github.com/oceanprotocol/ocean-subgraph.git synced 2024-12-02 05:57:29 +01:00
Code Issues Projects Releases Wiki Activity

fix decmail math (#117)

Browse Source
This commit is contained in:
Alex Coseru 2021-06-10 10:30:10 +03:00 committed by GitHub
parent 69834d89c1
commit 0de181fe9d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/mappings/pool.ts
View File

@ -101,7 +101,7 @@ export function _handleRebind(
if (tokenAddress != OCEAN) { if (tokenAddress != OCEAN) {
pool.datatokenAddress = tokenAddress pool.datatokenAddress = tokenAddress
} }
pool.tokenCount += BigInt.fromI32(1) pool.tokenCount = pool.tokenCount.plus(BigInt.fromI32(1))
const address = Address.fromString(tokenAddress) const address = Address.fromString(tokenAddress)
const denormWeight = hexToDecimal(denormWeightStr, decimals) const denormWeight = hexToDecimal(denormWeightStr, decimals)
const poolTokenId = poolId.concat('-').concat(address.toHexString()) const poolTokenId = poolId.concat('-').concat(address.toHexString())
@ -109,13 +109,13 @@ export function _handleRebind(
if (poolToken == null) { if (poolToken == null) {
createPoolTokenEntity(poolTokenId, poolId, address.toHexString()) createPoolTokenEntity(poolTokenId, poolId, address.toHexString())
poolToken = PoolToken.load(poolTokenId) poolToken = PoolToken.load(poolTokenId)
pool.totalWeight += denormWeight pool.totalWeight = pool.totalWeight.plus(denormWeight)
} else { } else {
const oldWeight = poolToken.denormWeight const oldWeight = poolToken.denormWeight
if (denormWeight > oldWeight) { if (denormWeight > oldWeight) {
pool.totalWeight = pool.totalWeight + (denormWeight - oldWeight) pool.totalWeight = pool.totalWeight.plus(denormWeight).minus(oldWeight)
} else { } else {
pool.totalWeight = pool.totalWeight - (oldWeight - denormWeight) pool.totalWeight = pool.totalWeight.minus(oldWeight).minus(denormWeight)
} }
} }
@ -451,9 +451,9 @@ export function handleTransfer(event: Transfer): void {
createPoolShareEntity(poolShareToId, poolId, event.params.to.toHex()) createPoolShareEntity(poolShareToId, poolId, event.params.to.toHex())
poolShareTo = PoolShare.load(poolShareToId) poolShareTo = PoolShare.load(poolShareToId)
} }
poolShareTo.balance += value poolShareTo.balance = poolShareTo.balance.plus(value)
poolShareTo.save() poolShareTo.save()
pool.totalShares += value pool.totalShares = pool.totalShares.plus(value)
if (poolTx != null) { if (poolTx != null) {
poolTx.sharesTransferAmount = value poolTx.sharesTransferAmount = value
poolTx.sharesBalance = poolShareTo.balance poolTx.sharesBalance = poolShareTo.balance
@ -474,11 +474,11 @@ export function handleTransfer(event: Transfer): void {
createPoolShareEntity(poolShareFromId, poolId, event.params.from.toHex()) createPoolShareEntity(poolShareFromId, poolId, event.params.from.toHex())
poolShareFrom = PoolShare.load(poolShareFromId) poolShareFrom = PoolShare.load(poolShareFromId)
} }
poolShareFrom.balance -= value poolShareFrom.balance = poolShareFrom.balance.minus(value)
poolShareFrom.save() poolShareFrom.save()
pool.totalShares -= value pool.totalShares = pool.totalShares.minus(value)
if (poolTx != null) { if (poolTx != null) {
poolTx.sharesTransferAmount = -value poolTx.sharesTransferAmount = poolTx.sharesTransferAmount.minus(value)
poolTx.sharesBalance = poolShareFrom.balance poolTx.sharesBalance = poolShareFrom.balance
} }
debuglog( debuglog(
@ -497,14 +497,14 @@ export function handleTransfer(event: Transfer): void {
createPoolShareEntity(poolShareToId, poolId, event.params.to.toHex()) createPoolShareEntity(poolShareToId, poolId, event.params.to.toHex())
poolShareTo = PoolShare.load(poolShareToId) poolShareTo = PoolShare.load(poolShareToId)
} }
poolShareTo.balance.plus(value) poolShareTo.balance = poolShareTo.balance.plus(value)
poolShareTo.save() poolShareTo.save()
if (poolShareFrom == null) { if (poolShareFrom == null) {
createPoolShareEntity(poolShareFromId, poolId, event.params.from.toHex()) createPoolShareEntity(poolShareFromId, poolId, event.params.from.toHex())
poolShareFrom = PoolShare.load(poolShareFromId) poolShareFrom = PoolShare.load(poolShareFromId)
} }
poolShareFrom.balance.minus(value) poolShareFrom.balance = poolShareFrom.balance.minus(value)
poolShareFrom.save() poolShareFrom.save()
debuglog( debuglog(
'pool shares transfer: ' + 'pool shares transfer: ' +
@ -527,7 +527,7 @@ export function handleTransfer(event: Transfer): void {
poolShareTo.balance.notEqual(ZERO_BD) && poolShareTo.balance.notEqual(ZERO_BD) &&
poolShareToBalance.equals(ZERO_BD) poolShareToBalance.equals(ZERO_BD)
) { ) {
pool.holderCount.plus(BigInt.fromI32(1)) pool.holderCount = pool.holderCount.plus(BigInt.fromI32(1))
} }
if ( if (
@ -535,7 +535,7 @@ export function handleTransfer(event: Transfer): void {
poolShareFrom.balance.equals(ZERO_BD) && poolShareFrom.balance.equals(ZERO_BD) &&
poolShareFromBalance.notEqual(ZERO_BD) poolShareFromBalance.notEqual(ZERO_BD)
) { ) {
pool.holderCount.plus(BigInt.fromI32(1)) pool.holderCount = pool.holderCount.plus(BigInt.fromI32(1))
} }
if (poolTx != null) { if (poolTx != null) {