mirror of
https://github.com/oceanprotocol/ocean-subgraph.git
synced 2024-12-02 05:57:29 +01:00
e1df119197
* Store eventIndex. * Changed in veDelegation. Removed import of String. * linter. * Removed tx hash. * Revert some tweaks. * added logIndex. * converted to big int. * 0 -> BigInt.zero(). * Added eventIndex to template and OPC. * updated tweak * updated tweak2 * Added eventIndex in tests. * revert. * Added eventIndex for TokenCreated and NFTCreated events. Increase time sleep for graphql request. * Changed position of eventIndex in entity. * Added eventIndex for order events and for dt events. Added new test commands in package.json. * Added eventIndex for NFT Update events. * Added eventIndex for dispenser. * Modified dispenser tests. * Reverted sleep secs. Updated tests. * Updated dispenser tests. Added eventIndex for FRE. * Added eventIndex in df rewards. * Updated Ve with eventIndex. * Updating order id with event index. * Updated @ocean/lib with multichain version. * Updated to number type. * Updated tests for order. * some changes. * Fix dt tests. Added logs for provider fee. Need fix for Simple publish and consume tests. * Problem raised by retrieving order event index in provider fee event handler. * Added function for searching the right order. * Debug order with provider fee. * Removed console logs. * Added debug logs. * Hardcoded eventIndex just for testing. * Paste logs from graph node. * added extra sleep in test. * fixed command. * Added comments. Modified util function for Order Reuse. * Added more logs and other tweaks. * fixed command for docker logs. * Added more logs. * Converted to lowercase. * Removed condition just for test. * Added more logs. Order is not null. * Call getOrder. * Added verification back. * converted to hex and add toString. * Pass toString as param. * Added ethereumjs util. * replaced with ==. * Refactored logic. * Print event index. * added more logs of event index. * Modified tweaks and asserts. * Added log for reuse order. * updates. * Reverted changes. * Added check for eventIndex == 0. * Enhanced the code. Replaced while with for. * Added more logs for reuse test. * added another condition. * Added logs in tests. Removed redundant condition. * Added more logs to test. * Fixed typo. * still debugging * Refactored code. * Getting closer. * Fix tests for orders part. Removed logs. * Removed more logs. * Fix DT tests related to order. * Implemented Publishing Market Fee event handler. Added test. * Added consume market fee handler. Test consume market fee handler. * Fixed tests for fees. Added TODOs. * Generated ID with eventIndex in ficed rate. Added assert errors messages. * Added FRE tests to workflow. * Generated dispenser transaction with event index. * Fixed dispenser tests. * Add event index for NftUpdate entity ID. * Changed IDs for VeDelegation and VeAllocationUpdate. * Added full test suite to workflow. * Fixed nft transfer ID. * print blocks. * test just dt and ending test to see the last block. * Added df test. * Added dispenser test. * Added FRE test. * Added NFT test. * Added simple publish consume test. * Added simple subgraph test. * Added users test. * Added ve test. * Increased sleep time. * commented delegation test. * respect lint * Fixed ending tests. Removed commented code. Brought back test suite. * Print values from failing tests. Updated mappings. * Rollback changes in veDelegation and veUtils. Added more prints for debug in tests. * Removed veDelegation creation record. * Rollback to the approach for veDelegation like it is in main. * Removed prints. Match changes with main. * Removed -1 from last block. * Added prints for eventIndex. Fixed some suggestions. * Fixed veDelegation. * Removed prints.
84 lines
2.8 KiB
TypeScript
84 lines
2.8 KiB
TypeScript
import { BigDecimal, BigInt } from '@graphprotocol/graph-ts'
|
|
import { Deposit, Supply, Withdraw } from '../@types/veOCEAN/veOCEAN'
|
|
import { weiToDecimal } from './utils/generic'
|
|
import { getDeposit, getveOCEAN } from './utils/veUtils'
|
|
import {
|
|
getTotalOceanLocked,
|
|
updateTotalOceanLocked
|
|
} from './utils/globalUtils'
|
|
|
|
export function handleDeposit(event: Deposit): void {
|
|
const provider = event.params.provider
|
|
const value = event.params.value
|
|
const locktime = event.params.locktime
|
|
const type = event.params.type
|
|
const ts = event.params.ts
|
|
const totalOceanLocked = getTotalOceanLocked()
|
|
const veOCEAN = getveOCEAN(provider.toHex())
|
|
// Create new Deposit entity
|
|
const deposit = getDeposit(
|
|
provider.toHex() +
|
|
'-' +
|
|
event.transaction.hash.toHex() +
|
|
'-' +
|
|
event.logIndex.toString()
|
|
)
|
|
deposit.provider = provider.toHex()
|
|
deposit.value = weiToDecimal(value.toBigDecimal(), 18)
|
|
deposit.unlockTime = locktime
|
|
deposit.type = type
|
|
deposit.timestamp = ts
|
|
deposit.block = event.block.number.toI32()
|
|
deposit.tx = event.transaction.hash.toHex()
|
|
deposit.sender = event.transaction.from.toHex()
|
|
deposit.veOcean = veOCEAN.id
|
|
|
|
deposit.totalOceanLocked = totalOceanLocked.plus(deposit.value)
|
|
updateTotalOceanLocked(deposit.totalOceanLocked)
|
|
|
|
deposit.save()
|
|
// --------------------------------------------
|
|
|
|
const lockedAmount = weiToDecimal(value.toBigDecimal(), 18)
|
|
veOCEAN.unlockTime = locktime
|
|
veOCEAN.lockedAmount = veOCEAN.lockedAmount.plus(lockedAmount)
|
|
veOCEAN.block = event.block.number.toI32()
|
|
veOCEAN.save()
|
|
}
|
|
export function handleSupply(event: Supply): void {}
|
|
export function handleWithdraw(event: Withdraw): void {
|
|
const totalOceanLocked = getTotalOceanLocked()
|
|
const provider = event.params.provider
|
|
const value = event.params.value
|
|
const ts = event.params.ts
|
|
|
|
const veOCEAN = getveOCEAN(provider.toHex())
|
|
// Create new Deposit entity
|
|
const deposit = getDeposit(
|
|
provider.toHex() +
|
|
'-' +
|
|
event.transaction.hash.toHex() +
|
|
'-' +
|
|
event.logIndex.toString()
|
|
)
|
|
deposit.provider = provider.toHex()
|
|
deposit.value = weiToDecimal(value.toBigDecimal(), 18).neg()
|
|
deposit.unlockTime = BigInt.zero()
|
|
deposit.type = BigInt.fromI32(4)
|
|
deposit.timestamp = ts
|
|
deposit.block = event.block.number.toI32()
|
|
deposit.tx = event.transaction.hash.toHex()
|
|
deposit.eventIndex = event.logIndex.toI32()
|
|
deposit.sender = event.transaction.from.toHex()
|
|
deposit.veOcean = veOCEAN.id
|
|
deposit.totalOceanLocked = totalOceanLocked.plus(deposit.value) // it's already negated above
|
|
updateTotalOceanLocked(deposit.totalOceanLocked)
|
|
deposit.save()
|
|
// --------------------------------------------
|
|
|
|
veOCEAN.lockedAmount = BigDecimal.zero()
|
|
veOCEAN.unlockTime = BigInt.zero()
|
|
veOCEAN.block = event.block.number.toI32()
|
|
veOCEAN.save()
|
|
}
|