forked from 0xPolygonHermez/zkevm-node
/
interfaces.go
58 lines (53 loc) · 3.17 KB
/
interfaces.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
package pool
import (
"context"
"math/big"
"time"
"github.com/0xPolygon/cdk-validium-node/state"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/core/types"
"github.com/jackc/pgx/v4"
)
type storage interface {
AddTx(ctx context.Context, tx Transaction) error
CountTransactionsByStatus(ctx context.Context, status ...TxStatus) (uint64, error)
CountTransactionsByFromAndStatus(ctx context.Context, from common.Address, status ...TxStatus) (uint64, error)
DeleteTransactionsByHashes(ctx context.Context, hashes []common.Hash) error
GetGasPrices(ctx context.Context) (uint64, uint64, error)
GetNonce(ctx context.Context, address common.Address) (uint64, error)
GetPendingTxHashesSince(ctx context.Context, since time.Time) ([]common.Hash, error)
GetTxsByFromAndNonce(ctx context.Context, from common.Address, nonce uint64) ([]Transaction, error)
GetTxsByStatus(ctx context.Context, state TxStatus, limit uint64) ([]Transaction, error)
GetNonWIPPendingTxs(ctx context.Context) ([]Transaction, error)
IsTxPending(ctx context.Context, hash common.Hash) (bool, error)
SetGasPrices(ctx context.Context, l2GasPrice uint64, l1GasPrice uint64) error
DeleteGasPricesHistoryOlderThan(ctx context.Context, date time.Time) error
UpdateTxsStatus(ctx context.Context, updateInfo []TxStatusUpdateInfo) error
UpdateTxStatus(ctx context.Context, updateInfo TxStatusUpdateInfo) error
UpdateTxWIPStatus(ctx context.Context, hash common.Hash, isWIP bool) error
GetTxs(ctx context.Context, filterStatus TxStatus, minGasPrice, limit uint64) ([]*Transaction, error)
GetTxFromAddressFromByHash(ctx context.Context, hash common.Hash) (common.Address, uint64, error)
GetTxByHash(ctx context.Context, hash common.Hash) (*Transaction, error)
GetTxZkCountersByHash(ctx context.Context, hash common.Hash) (*state.ZKCounters, error)
DeleteTransactionByHash(ctx context.Context, hash common.Hash) error
MarkWIPTxsAsPending(ctx context.Context) error
GetAllAddressesBlocked(ctx context.Context) ([]common.Address, error)
MinL2GasPriceSince(ctx context.Context, timestamp time.Time) (uint64, error)
policy
}
type policy interface {
CheckPolicy(ctx context.Context, policy PolicyName, address common.Address) (bool, error)
AddAddressesToPolicy(ctx context.Context, policy PolicyName, addresses []common.Address) error
RemoveAddressesFromPolicy(ctx context.Context, policy PolicyName, addresses []common.Address) error
ClearPolicy(ctx context.Context, policy PolicyName) error
DescribePolicies(ctx context.Context) ([]Policy, error)
DescribePolicy(ctx context.Context, name PolicyName) (Policy, error)
ListAcl(ctx context.Context, policy PolicyName, query []common.Address) ([]common.Address, error)
}
type stateInterface interface {
GetBalance(ctx context.Context, address common.Address, root common.Hash) (*big.Int, error)
GetLastL2Block(ctx context.Context, dbTx pgx.Tx) (*types.Block, error)
GetNonce(ctx context.Context, address common.Address, root common.Hash) (uint64, error)
GetTransactionByHash(ctx context.Context, transactionHash common.Hash, dbTx pgx.Tx) (*types.Transaction, error)
PreProcessTransaction(ctx context.Context, tx *types.Transaction, dbTx pgx.Tx) (*state.ProcessBatchResponse, error)
}