types

package
v0.0.0-...-66aa405 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LegacyTxType     byte = 0
	AccessListTxType byte = 1
	DynamicFeeTxType byte = 2
)

Variables

View Source 
var ErrAlreadyKnown = errors.New("already known")
View Source 
var ErrParseTxn = fmt.Errorf("%w transaction", rlp.ErrParse)
View Source 
var ErrRejected = errors.New("rejected")
View Source 
var ErrRlpTooBig = errors.New("txn rlp too big")
View Source 
var TxParseMainnetTests = []parseTxTest{

	{PayloadStr: "f86a808459682f0082520894fe3b557e8fb62b89f4916b721be55ceb828dbd73872386f26fc10000801ca0d22fc3eed9b9b9dbef9eec230aa3fb849eff60356c6b34e86155dca5c03554c7a05e3903d7375337f103cb9583d97a59dcca7472908c31614ae240c6a8311b02d6",
		SenderStr: "fe3b557e8fb62b89f4916b721be55ceb828dbd73", IdHashStr: "595e27a835cd79729ff1eeacec3120eeb6ed1464a04ec727aaca734ead961328",
		SignHashStr: "e2b043ecdbcfed773fe7b5ffc2e23ec238081c77137134a06d71eedf9cdd81d3", Nonce: 0},

	{PayloadStr: "02f86a0180843b9aca00843b9aca0082520894e80d2a018c813577f33f9e69387dc621206fb3a48080c001a02c73a04cd144e5a84ceb6da942f83763c2682896b51f7922e2e2f9a524dd90b7a0235adda5f87a1d098e2739e40e83129ff82837c9042e6ad61d0481334dcb6f1a",
		SenderStr: "81f5daee2c61807d0fc5e4c8b4e1d3c3e028d9ab", IdHashStr: "b4a8cd0b91310b0f84216c834c4cfa25a4ffc116b54692ac1f4e682be7fa73c9",
		SignHashStr: "c63673a5d989925d01a6c1339252f546e99b6957ce566a488154e169ae9bd49c", Nonce: 0},
	{PayloadStr: "01f86b01018203e882520894236ff1e97419ae93ad80cafbaa21220c5d78fb7d880de0b6b3a764000080c080a0987e3d8d0dcd86107b041e1dca2e0583118ff466ad71ad36a8465dd2a166ca2da02361c5018e63beea520321b290097cd749febc2f437c7cb41fdd085816742060",
		SenderStr: "91406aebf7370d6db8d1796bc8fe97ca4b6bed78", IdHashStr: "7edf4b1a1594b252eb80edcf51605eb1a3b17ccdf891b303a8be146269821b65",
		SignHashStr: "ae2a02407f345601507c52d1af6a89bafd4622fbcdac0001272ebca42cf7f7c2", Nonce: 1},
	{PayloadStr: "f86780862d79883d2000825208945df9b87991262f6ba471f09758cde1c0fc1de734827a69801ca088ff6cf0fefd94db46111149ae4bfc179e9b94721fffd821d38d16464b3f71d0a045e0aff800961cfce805daef7016b9b675c137a6a41a548f7b60a3484c06a33a",
		SenderStr: "a1e4380a3b1f749673e270229993ee55f35663b4", IdHashStr: "5c504ed432cb51138bcf09aa5e8a410dd4a1e204ef84bfed1be16dfba1b22060",
		SignHashStr: "19b1e28c14f33e74b96b88eba97d4a4fc8a97638d72e972310025b7e1189b049", Nonce: 0},
	{PayloadStr: "b903a301f9039f018218bf85105e34df0083048a949410a0847c2d170008ddca7c3a688124f49363003280b902e4c11695480000000000000000000000004b274e4a9af31c20ed4151769a88ffe63d9439960000000000000000000000008510211a852f0c5994051dd85eaef73112a82eb5000000000000000000000000000000000000000000000000000000000000012000000000000000000000000000bad4de000000000000000000000000607816a600000000000000000000000000000000000000000000000000000000000002200000000000000000000000000000000000000000000000000000001146aa2600000000000000000000000000000000000000000000000000000000000001bc9b000000000000000000000000eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee000000000000000000000000482579f93dc13e6b434e38b5a0447ca543d88a4600000000000000000000000000000000000000000000000000000000000000c42df546f40000000000000000000000004b274e4a9af31c20ed4151769a88ffe63d943996000000000000000000000000eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee0000000000000000000000007d93f93d41604572119e4be7757a7a4a43705f080000000000000000000000000000000000000000000000003782dace9d90000000000000000000000000000000000000000000000000000000000000000000a00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000082b5a61569b5898ac347c82a594c86699f1981aa88ca46a6a00b8e4f27b3d17bdf3714e7c0ca6a8023b37cca556602fce7dc7daac3fcee1ab04bbb3b94c10dec301cc57266db6567aa073efaa1fa6669bdc6f0877b0aeab4e33d18cb08b8877f08931abf427f11bade042177db48ca956feb114d6f5d56d1f5889047189562ec545e1c000000000000000000000000000000000000000000000000000000000000f84ff7946856ccf24beb7ed77f1f24eee5742f7ece5557e2e1a00000000000000000000000000000000000000000000000000000000000000001d694b1dd690cc9af7bb1a906a9b5a94f94191cc553cec080a0d52f3dbcad3530e73fcef6f4a75329b569a8903bf6d8109a960901f251a37af3a00ecf570e0c0ffa6efdc6e6e49be764b6a1a77e47de7bb99e167544ffbbcd65bc",
		SenderStr: "1ced2cef30d40bb3617f8d455071b69f3b12d06f", IdHashStr: "851bad0415758075a1eb86776749c829b866d43179c57c3e4a4b9359a0358231",
		SignHashStr: "894d999ea27537def37534b3d55df3fed4e1492b31e9f640774432d21cf4512c", Nonce: 6335},
	{PayloadStr: "02f8cf01038502540be40085174876e8008301869f94e77162b7d2ceb3625a4993bab557403a7b706f18865af3107a400080f85bf85994de0b295669a9fd93d5f28d9ec85e40f4cb697baef842a00000000000000000000000000000000000000000000000000000000000000003a0000000000000000000000000000000000000000000000000000000000000000780a0f73da48f3f5c9f324dfd28d106dcf911b53f33c92ae068cf6135352300e7291aa06ee83d0f59275d90000ac8cf912c6eb47261d244c9db19ffefc49e52869ff197",
		SenderStr: "e252dd9e8b19f4bcdc0f542e04e732fed2047f00", IdHashStr: "f08b9885d48a1307c5d5841fb2f92adaa35815846ac071cba65376ccfbc99c5d",
		SignHashStr: "aeda585cd1f1dc0812d7c9ef0396fe3fb9102c9b927a14724180d4616f4568f2", Nonce: 3},

	{PayloadStr: "01f889018201f30a8301e241808080f838f7940000000000000000000000000000000000000001e1a0000000000000000000000000000000000000000000000000000000000000000080a0a2196512ef8325b781e32d96d283a9d4cf3946947da77f3cd310eee050c537d5a00144af5513a24363bf49abed9a25476cb7c33df6e0c0053b63ee8dac64b027aa",
		SenderStr: "4d8286232b1f058d8bdb1702d0f6a1e887ced385", IdHashStr: "bde66bd7925917db9e49e38a12ed0dcd6f9422f8db90de26d34a4523f8861d1e",
		SignHashStr: "7f69febd06ddc1e72d9cd34524c82b3a8a116a02a10757be34cf536d6992d51c", Nonce: 499},
	{PayloadStr: "01f84b01018080808080c080a0382d06e968cc18373209a2532b2c9df494c36475e479020730c918b1b6f73f6ba0084b433c82339de844e2531363f59fa64218e965016cc55069828d88959b58fe", Nonce: 1},
}

Functions

func DecodeSender 

func DecodeSender(enc []byte) (nonce uint64, balance uint256.Int, err error)

func EncodeGetPooledTransactions66 

func EncodeGetPooledTransactions66(hashes []byte, requestID uint64, encodeBuf []byte) ([]byte, error)

EncodeGetPooledTransactions66 produces encoding of GetPooledTransactions66 packet

func EncodeHashes 

func EncodeHashes(hashes []byte, encodeBuf []byte) []byte

EncodeHashes produces RLP encoding of given number of hashes, as RLP list It appends encoding to the given given slice (encodeBuf), reusing the space there is there is enough capacity. The first returned value is the slice where encodinfg

func EncodePooledTransactions66 

func EncodePooledTransactions66(txsRlp [][]byte, requestID uint64, encodeBuf []byte) []byte

func EncodeSender 

func EncodeSender(nonce uint64, balance uint256.Int, buffer []byte)

func EncodeSenderLengthForStorage 

func EncodeSenderLengthForStorage(nonce uint64, balance uint256.Int) uint

func EncodeTransactions 

func EncodeTransactions(txsRlp [][]byte, encodeBuf []byte) []byte

func ParseGetPooledTransactions66 

func ParseGetPooledTransactions66(payload []byte, pos int, hashbuf []byte) (requestID uint64, hashes []byte, newPos int, err error)

func ParseHash 

func ParseHash(payload []byte, pos int, hashbuf []byte) ([]byte, int, error)

ParseHash extracts the next hash from the RLP encoding (payload) from a given position. It appends the hash to the given slice, reusing the space if there is enough capacity The first returned value is the slice where hash is appended to. The second returned value is the new position in the RLP payload after the extraction of the hash.

func ParseHashesCount 

func ParseHashesCount(payload []byte, pos int) (count int, dataPos int, err error)

ParseHashesCount looks at the RLP length Prefix for list of 32-byte hashes and returns number of hashes in the list to expect

func ParsePooledTransactions66 

func ParsePooledTransactions66(payload []byte, pos int, ctx *TxParseContext, txSlots *TxSlots, validateHash func([]byte) error) (requestID uint64, newPos int, err error)

func ParseTransactions 

func ParseTransactions(payload []byte, pos int, ctx *TxParseContext, txSlots *TxSlots, validateHash func([]byte) error) (newPos int, err error)

Types

type AccessList 

type AccessList []AccessTuple

AccessList is an EIP-2930 access list.

func (AccessList) StorageKeys 

func (al AccessList) StorageKeys() int

StorageKeys returns the total number of storage keys in the access list.

type AccessTuple 

type AccessTuple struct {
	Address     common.Address `json:"address"`
	StorageKeys []common.Hash  `json:"storageKeys"`
}

AccessTuple is the element type of an access list.

type Addresses 

type Addresses []byte // flatten list of 20-byte addresses

func (Addresses) AddressAt 

func (h Addresses) AddressAt(i int) common.Address

AddressAt returns an address at the given index in the flattened list. Use this method if you want to reduce memory allocations

func (Addresses) At 

func (h Addresses) At(i int) []byte

func (Addresses) Len 

func (h Addresses) Len() int

type Announcements 

type Announcements struct {
	// contains filtered or unexported fields
}

func (*Announcements) Append 

func (a *Announcements) Append(t byte, size uint32, hash []byte)

func (*Announcements) AppendOther 

func (a *Announcements) AppendOther(other Announcements)

func (Announcements) At 

func (a Announcements) At(i int) (byte, uint32, []byte)

func (Announcements) Copy 

func (a Announcements) Copy() Announcements

func (Announcements) DedupCopy 

func (a Announcements) DedupCopy() Announcements

DedupCopy sorts hashes, and creates deduplicated copy

func (Announcements) DedupHashes 

func (a Announcements) DedupHashes() Hashes

func (Announcements) Hashes 

func (a Announcements) Hashes() Hashes

func (Announcements) Len 

func (a Announcements) Len() int

func (Announcements) Less 

func (a Announcements) Less(i, j int) bool

func (*Announcements) Reset 

func (a *Announcements) Reset()

func (Announcements) Swap 

func (a Announcements) Swap(i, j int)

type Hashes 

type Hashes []byte // flatten list of 32-byte hashes

func (Hashes) At 

func (h Hashes) At(i int) []byte

func (Hashes) DedupCopy 

func (h Hashes) DedupCopy() Hashes

DedupCopy sorts hashes, and creates deduplicated copy

func (Hashes) Len 

func (h Hashes) Len() int

func (Hashes) Less 

func (h Hashes) Less(i, j int) bool

func (Hashes) Swap 

func (h Hashes) Swap(i, j int)

type NewPooledTransactionHashesPacket 

type NewPooledTransactionHashesPacket [][length.Hash]byte

type PeerID 

type PeerID *types.H512

type TxParseConfig 

type TxParseConfig struct {
	ChainID uint256.Int
}

type TxParseContext 

type TxParseContext struct {
	Keccak2 hash.Hash
	Keccak1 hash.Hash

	ChainID       uint256.Int // Signature values
	R             uint256.Int // Signature values
	S             uint256.Int // Signature values
	V             uint256.Int // Signature values
	ChainIDMul    uint256.Int
	DeriveChainID uint256.Int // pre-allocated variable to calculate Sub(&ctx.v, &ctx.chainIDMul)

	Sig     [65]byte
	Sighash [32]byte

	IsProtected bool
	// contains filtered or unexported fields
}

TxParseContext is object that is required to parse transactions and turn transaction payload into TxSlot objects usage of TxContext helps avoid extra memory allocations

func NewTxParseContext 

func NewTxParseContext(chainID uint256.Int) *TxParseContext

func (*TxParseContext) ChainIDRequired 

func (ctx *TxParseContext) ChainIDRequired() *TxParseContext

func (*TxParseContext) ParseTransaction 

func (ctx *TxParseContext) ParseTransaction(payload []byte, pos int, slot *TxSlot, sender []byte, hasEnvelope bool, validateHash func([]byte) error) (p int, err error)

ParseTransaction extracts all the information from the transactions's payload (RLP) necessary to build TxSlot it also performs syntactic validation of the transactions

func (*TxParseContext) ValidateRLP 

func (ctx *TxParseContext) ValidateRLP(f func(txnRlp []byte) error)

func (*TxParseContext) WithAllowPreEip2s 

func (ctx *TxParseContext) WithAllowPreEip2s(v bool)

func (*TxParseContext) WithSender 

func (ctx *TxParseContext) WithSender(v bool)

type TxSlot 

type TxSlot struct {
	Rlp            []byte      // TxPool set it to nil after save it to db
	Value          uint256.Int // Value transferred by the transaction
	Tip            uint256.Int // Maximum tip that transaction is giving to miner/block proposer
	FeeCap         uint256.Int // Maximum fee that transaction burns and gives to the miner/block proposer
	SenderID       uint64      // SenderID - require external mapping to it's address
	Nonce          uint64      // Nonce of the transaction
	DataLen        int         // Length of transaction's data (for calculation of intrinsic gas)
	DataNonZeroLen int
	AlAddrCount    int      // Number of addresses in the access list
	AlStorCount    int      // Number of storage keys in the access list
	Gas            uint64   // Gas limit of the transaction
	IDHash         [32]byte // Transaction hash for the purposes of using it as a transaction Id
	Traced         bool     // Whether transaction needs to be traced throughout transaction pool code and generate debug printing
	Creation       bool     // Set to true if "To" field of the transaction is not set
	Type           byte     // Transaction type
	Size           uint32   // Size of the payload
}

TxSlot contains information extracted from an Ethereum transaction, which is enough to manage it inside the transaction. Also, it contains some auxillary information, like ephemeral fields, and indices within priority queues

func (*TxSlot) PrintDebug 

func (tx *TxSlot) PrintDebug(prefix string)

nolint

type TxSlots 

type TxSlots struct {
	Txs     []*TxSlot
	Senders Addresses
	IsLocal []bool
}

func (*TxSlots) Append 

func (s *TxSlots) Append(slot *TxSlot, sender []byte, isLocal bool)

func (*TxSlots) Resize 

func (s *TxSlots) Resize(targetSize uint)

Resize internal arrays to len=targetSize, shrinks if need. It rely on `append` algorithm to realloc

func (*TxSlots) Valid 

func (s *TxSlots) Valid() error

type TxsRlp 

type TxsRlp struct {
	Txs     [][]byte
	Senders Addresses
	IsLocal []bool
}

func (*TxsRlp) Resize 

func (s *TxsRlp) Resize(targetSize uint)

Resize internal arrays to len=targetSize, shrinks if need. It rely on `append` algorithm to realloc

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.