oceanprotocol
/
ocean-subgraph
mirror of https://github.com/oceanprotocol/ocean-subgraph.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

added logIndex.

This commit is contained in:
Maria Carmina 2023-03-15 19:07:37 +02:00
parent 6578726ee6
commit b6d7dd7b3c
14 changed files with 104 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
schema.graphql
View File

@ -58,6 +58,7 @@ type Token @entity {
lastPriceToken: Token
lastPriceValue: BigDecimal!
eventIndex: Int!
}
"utility type"
@ -116,6 +117,7 @@ type Nft @entity{
nftData: [NftData!] @derivedFrom(field: "nft")
transferHistory: [NftTransferHistory!] @derivedFrom(field: "nft")
eventIndex: Int!
}
type NftData @entity{
@ -138,6 +140,7 @@ type OrderReuse @entity {
"gas price in Wei"
gasPrice: BigInt
gasUsed: BigDecimal
eventIndex: Int!
}
type Order @entity {
@ -175,6 +178,7 @@ type Order @entity {
gasUsed: BigDecimal
"gas price in Wei"
gasPrice: BigInt
eventIndex: Int!
}
type User @entity {
@ -226,8 +230,8 @@ type FixedRateExchange @entity {
publishMarketFeeAddress: String
"fee amount. Fixed value"
publishMarketSwapFee: BigDecimal
publishMarketSwapFee: BigDecimal
eventIndex: Int!
}
type FixedRateExchangeUpdate @entity {
@ -246,6 +250,7 @@ type FixedRateExchangeUpdate @entity {
block: Int!
createdTimestamp: Int!
tx: String!
eventIndex: Int!
}
type FixedRateExchangeSwap @entity {
@ -260,6 +265,7 @@ type FixedRateExchangeSwap @entity {
oceanFeeAmount: BigDecimal!
marketFeeAmount: BigDecimal!
consumeMarketFeeAmount: BigDecimal!
eventIndex: Int!
}
@ -287,6 +293,7 @@ type Dispenser @entity {
tx: String!
dispenses: [DispenserTransaction!] @derivedFrom(field: "dispenser")
eventIndex: Int!
}
type DispenserTransaction @entity {
@ -298,6 +305,7 @@ type DispenserTransaction @entity {
block: Int!
createdTimestamp: Int!
tx: String!
eventIndex: Int!
}
"utility type"
@ -382,6 +390,7 @@ type NftUpdate @entity {
block: Int!
timestamp: Int!
tx: String!
eventIndex: Int!
}
type Template @entity{
@ -404,6 +413,7 @@ type VeAllocateUser @entity{
lastContact: Int!
tx: String!
veOcean: VeOCEAN!
eventIndex: Int!
}
type VeAllocateId @entity{
@ -419,6 +429,7 @@ type VeAllocateId @entity{
firstContact: Int!
lastContact: Int!
tx: String!
eventIndex: Int!
}
# we need to track allocation of user to id
@ -438,6 +449,7 @@ type VeAllocation @entity {
firstContact: Int!
lastContact: Int!
tx: String!
eventIndex: Int!
}
enum veAllocationUpdateType {
@ -456,6 +468,7 @@ type VeAllocationUpdate @entity {
block: Int!
timestamp: Int!
tx: String!
eventIndex: Int!
}
type VeDelegation @entity {
@ -468,6 +481,7 @@ type VeDelegation @entity {
cancelTime: BigInt!
expireTime: BigInt!
block: Int!
eventIndex: Int!
}
type VeOCEAN @entity {
@ -483,6 +497,7 @@ type VeOCEAN @entity {
claims: [VeClaim!] @derivedFrom(field: "veOcean")
allocation: VeAllocateUser @derivedFrom(field: "veOcean")
block: Int!
eventIndex: Int!
}
type VeDeposit @entity {
@ -502,6 +517,7 @@ type VeDeposit @entity {
block: Int!
tx: String!
veOcean: VeOCEAN!
eventIndex: Int!
}
@ -525,6 +541,7 @@ type VeFeeDistributorCheckPoint @entity {
timestamp: BigInt!
block: Int!
tx: String!
eventIndex: Int!
}
type VeClaim @entity {
@ -541,6 +558,7 @@ type VeClaim @entity {
tx: String!
veOcean: VeOCEAN!
VeFeeDistributor: VeFeeDistributor!
eventIndex: Int!
}
enum DFHistoryType {
@ -567,6 +585,7 @@ type DFHistory @entity {
timestamp: BigInt!
block: Int!
tx: String!
eventIndex: Int!
}
@ -587,5 +606,6 @@ type NftTransferHistory @entity {
txId: String
timestamp: Int!
block: Int!
eventIndex: Int!
}

2
src/mappings/dfRewards.ts
View File

@ -28,6 +28,7 @@ export function handleAllocated(event: Allocated): void {
history.timestamp = event.block.timestamp
history.tx = event.transaction.hash.toHex()
history.block = event.block.number.toI32()
history.eventId = event.logIndex
history.save()
// update available claims
@ -57,6 +58,7 @@ export function handleClaimed(event: Claimed): void {
history.timestamp = event.block.timestamp
history.tx = event.transaction.hash.toHex()
history.block = event.block.number.toI32()
history.eventId = event.logIndex
history.save()
// update available claims

6
src/mappings/dispenser.ts
View File

@ -44,6 +44,7 @@ export function handleNewDispenser(event: DispenserCreated): void {
dispenser.createdTimestamp = event.block.timestamp.toI32()
dispenser.tx = event.transaction.hash.toHex()
dispenser.block = event.block.number.toI32()
dispenser.eventIndex = event.logIndex
dispenser.save()
addDispenser()
@ -57,6 +58,7 @@ export function handleActivate(event: DispenserActivated): void {
)
const dispenser = getDispenser(dispenserID)
dispenser.active = true
dispenser.eventIndex = event.logIndex
dispenser.save()
}
@ -67,6 +69,7 @@ export function handleDeactivate(event: DispenserDeactivated): void {
)
const dispenser = getDispenser(dispenserID)
dispenser.active = false
dispenser.eventIndex = event.logIndex
dispenser.save()
}
@ -76,6 +79,7 @@ export function handleAllowedSwapperChanged(
const dispenserID = getDispenserGraphID(event.address, event.params.datatoken)
const dispenser = getDispenser(dispenserID)
dispenser.allowedSwapper = event.params.newAllowedSwapper.toHex()
dispenser.eventIndex = event.logIndex
dispenser.save()
}
@ -99,6 +103,7 @@ export function handleTokensDispensed(event: TokensDispensed): void {
dispenserTransaction.createdTimestamp = event.block.timestamp.toI32()
dispenserTransaction.tx = event.transaction.hash.toHex()
dispenserTransaction.block = event.block.number.toI32()
dispenserTransaction.eventIndex = event.logIndex
const token = getToken(event.params.datatokenAddress, true)
dispenserTransaction.amount = weiToDecimal(
event.params.amount.toBigDecimal(),
@ -111,5 +116,6 @@ export function handleOwnerWinthdraw(event: OwnerWithdrawed): void {
const dispenserID = getDispenserGraphID(event.address, event.params.datatoken)
const dispenser = getDispenser(dispenserID)
dispenser.balance = decimal.ZERO
dispenser.eventIndex = event.logIndex
dispenser.save()
}

12
src/mappings/erc20Templates.ts
View File

@ -87,6 +87,8 @@ export function handleOrderStarted(event: OrderStarted): void {
} else {
order.gasPrice = BigInt.zero()
}
order.eventIndex = event.logIndex
token.eventIndex = event.logIndex
order.save()
token.save()
addOrder()
@ -124,6 +126,7 @@ export function handlerOrderReused(event: OrderReused): void {
reuseOrder.createdTimestamp = event.params.timestamp.toI32()
reuseOrder.tx = event.transaction.hash.toHex()
reuseOrder.block = event.params.number.toI32()
reuseOrder.eventIndex = event.logIndex
reuseOrder.save()
}
@ -149,6 +152,7 @@ export function handlePublishMarketFeeChanged(
event.params.PublishMarketFeeAmount.toBigDecimal(),
decimals
)
token.eventIndex = event.logIndex
token.save()
// TODO - shold we have a history
}
@ -163,6 +167,7 @@ export function handleAddedMinter(event: AddedMinter): void {
if (!existingRoles.includes(event.params.user.toHexString()))
existingRoles.push(event.params.user.toHexString())
token.minter = existingRoles
token.eventIndex = event.logIndex
token.save()
}
@ -179,6 +184,7 @@ export function handleRemovedMinter(event: RemovedMinter): void {
if (role !== event.params.user.toHexString()) newList.push(role)
}
token.minter = newList
token.eventIndex = event.logIndex
token.save()
}
@ -190,6 +196,7 @@ export function handleAddedPaymentManager(event: AddedPaymentManager): void {
if (!existingRoles.includes(event.params.user.toHexString()))
existingRoles.push(event.params.user.toHexString())
token.paymentManager = existingRoles
token.eventIndex = event.logIndex
token.save()
}
export function handleRemovedPaymentManager(
@ -217,12 +224,14 @@ export function handleCleanedPermissions(event: CleanedPermissions): void {
const nft = Nft.load(token.nft as string)
if (nft) token.paymentCollector = nft.owner
else token.paymentCollector = '0x0000000000000000000000000000000000000000'
token.eventIndex = event.logIndex
token.save()
}
export function handleNewPaymentCollector(event: NewPaymentCollector): void {
const token = getToken(event.address, true)
token.paymentCollector = event.params._newPaymentCollector.toHexString()
token.eventIndex = event.logIndex
token.save()
}
@ -245,6 +254,7 @@ export function handleProviderFee(event: ProviderFee): void {
if (order) {
order.providerFee = providerFee
order.providerFeeValidUntil = event.params.validUntil
order.eventIndex = event.logIndex
order.save()
return
}
@ -253,6 +263,7 @@ export function handleProviderFee(event: ProviderFee): void {
if (orderReuse) {
orderReuse.providerFee = providerFee
orderReuse.providerFeeValidUntil = event.params.validUntil
orderReuse.eventIndex = event.logIndex
orderReuse.save()
} else {
orderReuse = new OrderReuse(event.transaction.hash.toHex())
@ -269,6 +280,7 @@ export function handleProviderFee(event: ProviderFee): void {
if (event.receipt !== null && event.receipt!.gasUsed) {
orderReuse.gasUsed = event.receipt!.gasUsed.toBigDecimal()
} else orderReuse.gasUsed = BigDecimal.zero()
orderReuse.eventIndex = event.logIndex
orderReuse.save()
}
}

3
src/mappings/erc721Factory.ts
View File

@ -26,6 +26,7 @@ export function handleNftCreated(event: NFTCreated): void {
nft.tx = event.transaction.hash.toHex()
nft.block = event.block.number.toI32()
nft.transferable = event.params.transferable
nft.eventIndex = event.logIndex
nft.save()
}
@ -65,7 +66,7 @@ export function handleNewToken(event: TokenCreated): void {
token.templateId = 1 + i
}
}
token.eventIndex = event.logIndex
token.save()
addDatatoken()
}

9
src/mappings/factoryRouter.ts
View File

@ -35,6 +35,7 @@ export function handleOPCFeeChanged(event: OPCFeeChanged): void {
event.params.newProviderFee.toBigDecimal(),
decimals
)
opc.eventIndex = event.logIndex
opc.save()
}
@ -73,6 +74,7 @@ export function handleTokenAdded(event: TokenAdded): void {
opc.approvedTokens = existingTokens
opc.eventIndex = event.logIndex
opc.save()
}
@ -89,6 +91,7 @@ export function handleTokenRemoved(event: TokenRemoved): void {
if (role != event.params.token.toHexString()) newList.push(role)
}
opc.approvedTokens = newList
opc.eventIndex = event.logIndex
opc.save()
}
export function handleSSContractAdded(event: SSContractAdded): void {
@ -100,6 +103,7 @@ export function handleSSContractAdded(event: SSContractAdded): void {
if (!existingContracts.includes(event.params.contractAddress.toHexString()))
existingContracts.push(event.params.contractAddress.toHexString())
templates.ssTemplates = existingContracts
templates.eventIndex = event.logIndex
templates.save()
}
export function handleSSContractRemoved(event: SSContractRemoved): void {
@ -115,6 +119,7 @@ export function handleSSContractRemoved(event: SSContractRemoved): void {
if (role != event.params.contractAddress.toHexString()) newList.push(role)
}
templates.ssTemplates = newList
templates.eventIndex = event.logIndex
templates.save()
}
@ -130,6 +135,7 @@ export function handleFixedRateContractAdded(
if (!existingContracts.includes(event.params.contractAddress.toHexString()))
existingContracts.push(event.params.contractAddress.toHexString())
templates.fixedRateTemplates = existingContracts
templates.eventIndex = event.logIndex
templates.save()
}
export function handleFixedRateContractRemoved(
@ -147,6 +153,7 @@ export function handleFixedRateContractRemoved(
if (role != event.params.contractAddress.toHexString()) newList.push(role)
}
templates.fixedRateTemplates = newList
templates.eventIndex = event.logIndex
templates.save()
}
export function handleDispenserContractAdded(
@ -161,6 +168,7 @@ export function handleDispenserContractAdded(
if (!existingContracts.includes(event.params.contractAddress.toHexString()))
existingContracts.push(event.params.contractAddress.toHexString())
templates.dispenserTemplates = existingContracts
templates.eventIndex = event.logIndex
templates.save()
}
export function handleDispenserContractRemoved(
@ -178,5 +186,6 @@ export function handleDispenserContractRemoved(
if (role != event.params.contractAddress.toHexString()) newList.push(role)
}
templates.dispenserTemplates = newList
templates.eventIndex = event.logIndex
templates.save()
}

10
src/mappings/fixedRateExchange.ts
View File

@ -51,6 +51,7 @@ export function handleExchangeCreated(event: ExchangeCreated): void {
fixedRateExchange.createdTimestamp = event.block.timestamp.toI32()
fixedRateExchange.tx = event.transaction.hash.toHex()
fixedRateExchange.block = event.block.number.toI32()
fixedRateExchange.eventIndex = event.logIndex
fixedRateExchange.save()
addFixedRateExchange()
@ -77,6 +78,7 @@ export function handleRateChange(event: ExchangeRateChanged): void {
BigInt.fromI32(18).toI32()
)
newExchangeUpdate.newPrice = fixedRateExchange.price
newExchangeUpdate.eventIndex = event.logIndex
newExchangeUpdate.save()
fixedRateExchange.save()
@ -89,6 +91,7 @@ export function handleMintStateChanged(event: ExchangeMintStateChanged): void {
)
const fixedRateExchange = getFixedRateExchange(fixedRateId)
fixedRateExchange.withMint = event.params.withMint
fixedRateExchange.eventIndex = event.logIndex
fixedRateExchange.save()
}
@ -109,6 +112,7 @@ export function handleActivated(event: ExchangeActivated): void {
newExchangeUpdate.block = event.block.number.toI32()
fixedRateExchange.active = true
newExchangeUpdate.eventIndex = event.logIndex
newExchangeUpdate.save()
fixedRateExchange.save()
@ -132,6 +136,7 @@ export function handleDeactivated(event: ExchangeDeactivated): void {
newExchangeUpdate.block = event.block.number.toI32()
fixedRateExchange.active = false
newExchangeUpdate.eventIndex = event.logIndex
newExchangeUpdate.save()
fixedRateExchange.save()
}
@ -154,6 +159,7 @@ export function handleAllowedSwapperChanged(
newExchangeUpdate.exchangeId = fixedRateId
fixedRateExchange.allowedSwapper = event.params.allowedSwapper.toHex()
newExchangeUpdate.newAllowedSwapper = fixedRateExchange.allowedSwapper
newExchangeUpdate.eventIndex = event.logIndex
newExchangeUpdate.save()
fixedRateExchange.save()
}
@ -205,6 +211,7 @@ export function handleSwap(event: Swapped): void {
BigInt.fromI32(baseToken.decimals).toI32()
)
swap.eventIndex = event.logIndex
swap.save()
updateFixedRateExchangeSupply(event.params.exchangeId, event.address)
@ -226,6 +233,7 @@ export function handleSwap(event: Swapped): void {
)
datatoken.lastPriceToken = priceToken.id
datatoken.lastPriceValue = fixedRateExchange.price
datatoken.eventIndex = event.logIndex
datatoken.save()
}
@ -244,6 +252,7 @@ export function handlePublishMarketFeeChanged(
event.params.swapFee.toBigDecimal(),
BigInt.fromI32(18).toI32()
)
fixedRateExchange.eventIndex = event.logIndex
fixedRateExchange.save()
}
}
@ -261,6 +270,7 @@ export function handleTokenCollected(event: TokenCollected): void {
fixedRateExchange.baseTokenBalance.minus(
weiToDecimal(event.params.amount.toBigDecimal(), baseToken.decimals)
)
fixedRateExchange.eventIndex = event.logIndex
fixedRateExchange.save()
}
}

18
src/mappings/nftUpdate.ts
View File

@ -48,6 +48,8 @@ export function handleMetadataCreated(event: MetadataCreated): void {
nftUpdate.timestamp = event.block.timestamp.toI32()
nftUpdate.tx = event.transaction.hash.toHex()
nftUpdate.block = event.block.number.toI32()
nftUpdate.eventIndex = event.logIndex
nft.eventIndex = event.logIndex
nftUpdate.save()
nft.save()
@ -72,6 +74,8 @@ export function handleMetadataUpdated(event: MetadataUpdated): void {
nftUpdate.timestamp = event.block.timestamp.toI32()
nftUpdate.tx = event.transaction.hash.toHex()
nftUpdate.block = event.block.number.toI32()
nftUpdate.eventIndex = event.logIndex
nft.eventIndex = event.logIndex
nftUpdate.save()
nft.save()
@ -96,6 +100,8 @@ export function handleMetadataState(event: MetadataState): void {
nftUpdate.timestamp = event.block.timestamp.toI32()
nftUpdate.tx = event.transaction.hash.toHex()
nftUpdate.block = event.block.number.toI32()
nftUpdate.eventIndex = event.logIndex
nft.eventIndex = event.logIndex
nftUpdate.save()
nft.save()
@ -120,6 +126,8 @@ export function handleTokenUriUpdate(event: TokenURIUpdate): void {
nftUpdate.tx = event.transaction.hash.toHex()
nftUpdate.block = event.block.number.toI32()
nftUpdate.assetState = nft.assetState
nftUpdate.eventIndex = event.logIndex
nft.eventIndex = event.logIndex
nftUpdate.save()
nft.save()
}
@ -133,6 +141,7 @@ export function handleAddedManager(event: AddedManager): void {
if (!existingRoles.includes(event.params.user.toHexString()))
existingRoles.push(event.params.user.toHexString())
nft.managerRole = existingRoles
nft.eventIndex = event.logIndex
nft.save()
}
export function handleRemovedManager(event: RemovedManager): void {
@ -148,6 +157,7 @@ export function handleRemovedManager(event: RemovedManager): void {
if (role !== event.params.user.toHexString()) newList.push(role)
}
nft.managerRole = newList
nft.eventIndex = event.logIndex
nft.save()
}
@ -160,6 +170,7 @@ export function handleAddedTo725StoreList(event: AddedTo725StoreList): void {
if (!existingRoles.includes(event.params.user.toHexString()))
existingRoles.push(event.params.user.toHexString())
nft.storeUpdateRole = existingRoles
nft.eventIndex = event.logIndex
nft.save()
}
@ -178,6 +189,7 @@ export function handleRemovedFrom725StoreList(
if (role !== event.params.user.toHexString()) newList.push(role)
}
nft.storeUpdateRole = newList
nft.eventIndex = event.logIndex
nft.save()
}
@ -192,6 +204,7 @@ export function handleAddedToCreateERC20List(
if (!existingRoles.includes(event.params.user.toHexString()))
existingRoles.push(event.params.user.toHexString())
nft.erc20DeployerRole = existingRoles
nft.eventIndex = event.logIndex
nft.save()
}
@ -210,6 +223,7 @@ export function handleRemovedFromCreateERC20List(
if (role !== event.params.user.toHexString()) newList.push(role)
}
nft.erc20DeployerRole = newList
nft.eventIndex = event.logIndex
nft.save()
}
@ -240,6 +254,7 @@ export function handleRemovedFromMetadataList(
if (role !== event.params.user.toHexString()) newList.push(role)
}
nft.metadataRole = newList
nft.eventIndex = event.logIndex
nft.save()
}
@ -250,6 +265,7 @@ export function handleCleanedPermissions(event: CleanedPermissions): void {
nft.erc20DeployerRole = newList
nft.storeUpdateRole = newList
nft.managerRole = newList
nft.eventIndex = event.logIndex
nft.save()
}
@ -259,6 +275,7 @@ export function handleNftTransferred(event: Transfer): void {
const oldOwner = nft.owner
const newOwner = getUser(event.params.to.toHexString())
nft.owner = newOwner.id
nft.eventIndex = event.logIndex
nft.save()
const transferId = `${nft.address}-${event.transaction.hash.toHex()}-${
@ -271,6 +288,7 @@ export function handleNftTransferred(event: Transfer): void {
newTransfer.txId = event.transaction.hash.toHex()
newTransfer.timestamp = event.block.timestamp.toI32()
newTransfer.block = event.block.number.toI32()
newTransfer.eventIndex = event.logIndex
newTransfer.save()
}

3
src/mappings/utils/tokenUtils.ts
View File

@ -30,6 +30,7 @@ export function createToken(address: Address, isDatatoken: boolean): Token {
token.createdTimestamp = 0
token.block = 0
token.tx = ''
token.eventIndex = 0
token.save()
return token
}
@ -60,6 +61,7 @@ export function createNftToken(address: Address): Nft {
token.tx = ''
token.orderCount = BigInt.zero()
token.hasMetadata = false
token.eventIndex = 0
token.save()
addNft()
return token
@ -93,6 +95,7 @@ export function getNftTokenWithID(tokenId: string): Nft {
nftToken.tx = ''
nftToken.orderCount = BigInt.zero()
nftToken.hasMetadata = false
nftToken.eventIndex = 0
nftToken.save()
addNft()
}

11
src/mappings/utils/veUtils.ts
View File

@ -21,6 +21,7 @@ export function getveOCEAN(id: string): VeOCEAN {
ve.unlockTime = BigInt.zero()
ve.lockedAmount = BigDecimal.zero()
ve.block = 0
ve.eventIndex = 0
ve.save()
}
@ -42,6 +43,7 @@ export function getveAllocateUser(
allocateUser.lastContact = 0
const veOcean = getveOCEAN(sender)
allocateUser.veOcean = veOcean.id
allocateUser.eventIndex = event.logIndex
allocateUser.save()
}
@ -64,6 +66,7 @@ export function getveAllocateId(
allocateId.lastContact = 0
allocateId.chainId = BigInt.zero()
allocateId.nftAddress = ''
allocateId.eventIndex = event.logIndex
allocateId.save()
}
@ -89,6 +92,7 @@ export function getveAllocation(
veAllocation.tx = event.transaction.hash.toHex()
veAllocation.block = event.block.number.toI32()
veAllocation.lastContact = 0
veAllocation.eventIndex = event.logIndex
veAllocation.save()
}
@ -114,6 +118,7 @@ export function writeveAllocationUpdate(
allocationUpdate.timestamp = event.block.timestamp.toI32()
allocationUpdate.tx = event.transaction.hash.toHex()
allocationUpdate.block = event.block.number.toI32()
allocationUpdate.eventIndex = event.logIndex
allocationUpdate.save()
}
@ -133,6 +138,7 @@ export function getveDelegation(id: string): VeDelegation {
veDelegation.receiver = ''
veDelegation.delegator = ''
veDelegation.block = 0
veDelegation.eventIndex = 0
veDelegation.save()
}
return veDelegation
@ -151,6 +157,7 @@ export function getDeposit(id: string): VeDeposit {
deposit.timestamp = BigInt.zero()
deposit.tx = ''
deposit.block = 0
deposit.eventIndex = 0
// do not save it
// deposit.save()
}
@ -201,6 +208,10 @@ export function handleOneAllocation(
allocateId.chainId = chainId
allocateId.nftAddress = nftAddress
allocateUser.eventIndex = event.logIndex
allocateId.eventIndex = event.logIndex
veAllocation.eventIndex = event.logIndex
// save entities
allocateUser.save()
allocateId.save()

2
src/mappings/veDelegation.ts
View File

@ -24,6 +24,7 @@ export function handleDelegation(event: DelegateBoost): void {
veDelegation.cancelTime = _cancelTime
veDelegation.expireTime = _expireTime
veDelegation.block = event.block.number.toI32()
veDelegation.eventIndex = event.logIndex
veDelegation.save()
}
@ -42,6 +43,7 @@ export function handleExtendBoost(event: ExtendBoost): void {
veDelegation.amount = _amount
veDelegation.cancelTime = _cancelTime
veDelegation.expireTime = _expireTime
veDelegation.eventIndex = event.logIndex
veDelegation.save()
}

2
src/mappings/veFeeDistributor.ts
View File

@ -28,6 +28,7 @@ export function handleClaimed(event: Claimed): void {
claim.block = event.block.number.toI32()
claim.tx = event.transaction.hash.toHex()
claim.timestamp = event.block.timestamp
claim.eventIndex = event.logIndex
claim.save()
}
@ -46,5 +47,6 @@ export function handleCheckpoint(event: CheckpointToken): void {
checkpoint.tx = event.transaction.hash.toHex()
checkpoint.timestamp = event.params.time
checkpoint.VeFeeDistributor = distributor.id
checkpoint.eventIndex = event.logIndex
checkpoint.save()
}

4
src/mappings/veOCEAN.ts
View File

@ -28,6 +28,7 @@ export function handleDeposit(event: Deposit): void {
deposit.tx = event.transaction.hash.toHex()
deposit.sender = event.transaction.from.toHex()
deposit.veOcean = veOCEAN.id
deposit.eventIndex = event.logIndex
deposit.save()
// --------------------------------------------
@ -35,6 +36,7 @@ export function handleDeposit(event: Deposit): void {
veOCEAN.unlockTime = locktime
veOCEAN.lockedAmount = veOCEAN.lockedAmount.plus(lockedAmount)
veOCEAN.block = event.block.number.toI32()
veOCEAN.eventIndex = event.logIndex
veOCEAN.save()
}
export function handleSupply(event: Supply): void {}
@ -61,11 +63,13 @@ export function handleWithdraw(event: Withdraw): void {
deposit.tx = event.transaction.hash.toHex()
deposit.sender = event.transaction.from.toHex()
deposit.veOcean = veOCEAN.id
deposit.eventIndex = event.logIndex
deposit.save()
// --------------------------------------------
veOCEAN.lockedAmount = BigDecimal.zero()
veOCEAN.unlockTime = BigInt.zero()
veOCEAN.block = event.block.number.toI32()
veOCEAN.eventIndex = event.logIndex
veOCEAN.save()
}

2
test/integration/Datatoken.test.ts
View File

@ -169,7 +169,7 @@ describe('Datatoken tests', async () => {
method: 'POST',
body: JSON.stringify(initialQuery)
})
await sleep(2000)
await sleep(2500)
const dt = (await initialResponse.json()).data.token
assert(dt !== undefined, 'undefined token')
const dtTx = dt.tx