Skip to content

Commit

Permalink
chore(fuel): add missing block number to context (#963)
Browse files Browse the repository at this point in the history
  • Loading branch information
spacedragon authored Sep 12, 2024
1 parent cc8b52d commit 986c261
Show file tree
Hide file tree
Showing 4 changed files with 19 additions and 11 deletions.
3 changes: 2 additions & 1 deletion packages/sdk/src/fuel/asset-processor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,8 @@ export class FuelAssetProcessor implements FuelBaseProcessor<FuelAssetProcessorC
assetId,
this.config.name ?? '',
call.timestamp || new Date(0),
tx
tx,
null
)
await handler(transfer, ctx)
return ctx.stopAndGetResult()
Expand Down
12 changes: 7 additions & 5 deletions packages/sdk/src/fuel/context.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ import { ChainId } from '@sentio/chain'
import { RecordMetaData } from '@sentio/protos'
import type { CallResult, Contract } from 'fuels'
import { InvocationScopeLike } from 'fuels'
import { FuelLog, FuelTransaction } from './types.js'
import { FuelBlock, FuelLog, FuelTransaction } from './types.js'

export class FuelCall {
constructor(
Expand All @@ -24,7 +24,8 @@ export class FuelContext extends BaseContext {
readonly contractAddress: string,
readonly contractName: string,
readonly timestamp: Date,
readonly transaction: FuelTransaction | null
readonly transaction: FuelTransaction | null,
readonly block: FuelBlock | null
) {
super({})
}
Expand All @@ -41,7 +42,7 @@ export class FuelContext extends BaseContext {
return {
address: this.contractAddress,
contractName: this.contractName,
blockNumber: BigInt(this.transaction?.blockNumber || 0),
blockNumber: BigInt(this.block?.height?.toString() ?? (this.transaction?.blockNumber || 0)),
transactionIndex: 0,
transactionHash: this.transaction?.id || '', // TODO
chainId: this.getChainId(),
Expand All @@ -59,9 +60,10 @@ export class FuelContractContext<TContract extends Contract> extends FuelContext
readonly contractAddress: string,
readonly contractName: string,
readonly timestamp: Date,
readonly transaction: FuelTransaction | null
readonly transaction: FuelTransaction | null,
readonly block: FuelBlock | null
) {
super(chainId, contractAddress, contractName, timestamp, transaction)
super(chainId, contractAddress, contractName, timestamp, transaction, block)
}

get provider() {
Expand Down
12 changes: 8 additions & 4 deletions packages/sdk/src/fuel/fuel-processor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,8 @@ export class FuelProcessor<TContract extends Contract> implements FuelBaseProces
this.config.address,
this.config.name ?? this.config.address,
call.timestamp || new Date(0),
tx
tx,
null
)
await handler(tx, ctx)
return ctx.stopAndGetResult()
Expand Down Expand Up @@ -121,7 +122,8 @@ export class FuelProcessor<TContract extends Contract> implements FuelBaseProces
this.config.address,
this.config.name ?? this.config.address,
call.timestamp || new Date(0),
tx
tx,
null
)
for (const op of tx.operations) {
for (const call of op.calls || []) {
Expand Down Expand Up @@ -182,7 +184,8 @@ export class FuelProcessor<TContract extends Contract> implements FuelBaseProces
this.config.address,
this.config.name ?? this.config.address,
call.timestamp || new Date(0),
tx
tx,
null
)
ctx.setLogIndex(log.receiptIndex)
await handler(log, ctx)
Expand Down Expand Up @@ -255,7 +258,8 @@ export class FuelProcessor<TContract extends Contract> implements FuelBaseProces
processor.config.address,
processor.config.name ?? processor.config.address,
data.timestamp || new Date(0),
null
null,
block
)
await handler(block, ctx)
return ctx.stopAndGetResult()
Expand Down
3 changes: 2 additions & 1 deletion packages/sdk/src/fuel/global-processor.ts
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,8 @@ export class FuelGlobalProcessor implements FuelBaseProcessor<GlobalFuelProcesso
'*',
this.config.name ?? '*',
call.timestamp || new Date(0),
tx
tx,
null
)
await handler(tx, ctx)
return ctx.stopAndGetResult()
Expand Down

0 comments on commit 986c261

Please sign in to comment.