-
Notifications
You must be signed in to change notification settings - Fork 1.7k
/
task.eth_get_block.go
82 lines (69 loc) · 2.36 KB
/
task.eth_get_block.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package pipeline
import (
"context"
"github.com/pkg/errors"
"github.com/smartcontractkit/chainlink/core/chains/evm"
"github.com/smartcontractkit/chainlink/core/logger"
)
// NOTE: Currently only returns latest block, could be extended in future to
// return block by number or hash
// Return types:
//
// map[string]interface{}
//
// Fields:
// - number: int64
// - hash: common.Hash
// - parentHash: common.Hash
// - timestamp: time.Time
// - baseFeePerGas: *big.Int
// - receiptsRoot: common.Hash
// - transactionsRoot: common.Hash
// - stateRoot: common.Hash
type ETHGetBlockTask struct {
BaseTask `mapstructure:",squash"`
EVMChainID string `json:"evmChainID" mapstructure:"evmChainID"`
chainSet evm.ChainSet
config Config
}
var _ Task = (*ETHGetBlockTask)(nil)
func (t *ETHGetBlockTask) Type() TaskType {
return TaskTypeETHGetBlock
}
func (t *ETHGetBlockTask) Run(ctx context.Context, lggr logger.Logger, vars Vars, inputs []Result) (result Result, runInfo RunInfo) {
_, err := CheckInputs(inputs, -1, -1, 0)
if err != nil {
return Result{Error: errors.Wrap(err, "task inputs")}, runInfo
}
var chainID StringParam
err = errors.Wrap(ResolveParam(&chainID, From(VarExpr(t.EVMChainID, vars), NonemptyString(t.EVMChainID), "")), "evmChainID")
if err != nil {
return Result{Error: err}, runInfo
}
chain, err := getChainByString(t.chainSet, string(chainID))
if err != nil {
return Result{Error: err}, runInfo
}
// Use the headtracker's view of the latest block, this is very fast since
// it doesn't make any external network requests, and it is the
// headtracker's job to ensure it has an up-to-date view of the chain based
// on responses from all available RPC nodes
latestHead := chain.HeadTracker().LatestChain()
if latestHead == nil {
logger.Sugared(lggr).AssumptionViolation("HeadTracker unexpectedly returned nil head, falling back to RPC call")
latestHead, err = chain.Client().HeadByNumber(ctx, nil)
if err != nil {
return Result{Error: err}, runInfo
}
}
h := make(map[string]interface{})
h["number"] = latestHead.Number
h["hash"] = latestHead.Hash
h["parentHash"] = latestHead.ParentHash
h["timestamp"] = latestHead.Timestamp
h["baseFeePerGas"] = latestHead.BaseFeePerGas
h["receiptsRoot"] = latestHead.ReceiptsRoot
h["transactionsRoot"] = latestHead.TransactionsRoot
h["stateRoot"] = latestHead.StateRoot
return Result{Value: h}, runInfo
}