fakes

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2021 License: AGPL-3.0 Imports: 20 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FakeAddress        = common.HexToAddress("0x" + RandomString(40))
	AnotherFakeAddress = common.HexToAddress("0x" + RandomString(40))
	FakeError          = errors.New("failed")
	FakeHash           = common.BytesToHash([]byte{1, 2, 3, 4, 5})
	AnotherFakeHash    = common.BytesToHash([]byte{6, 7, 8, 9, 0})
)
View Source 
var FakeHeader = core.Header{
	Hash:      FakeHash.String(),
	Raw:       rawFakeHeader,
	Timestamp: strconv.FormatInt(fakeTimestamp, 10),
}

Functions

func GetFakeHeader 

func GetFakeHeader(blockNumber int64) core.Header

func GetFakeHeaderWithTimestamp added in v0.0.2 

func GetFakeHeaderWithTimestamp(timestamp, blockNumber int64) core.Header

func RandomString added in v0.0.10 

func RandomString(length int) string

Types

type BatchGetStorageAtCall added in v0.1.0 

type BatchGetStorageAtCall struct {
	Account     common.Address
	Keys        []common.Hash
	BlockNumber *big.Int
}

type MockBlockChain 

type MockBlockChain struct {
	BatchGetStorageAtCalls      []BatchGetStorageAtCall
	BatchGetStorageAtError      error
	GetTransactionsCalled       bool
	GetTransactionsError        error
	GetTransactionsPassedHashes []common.Hash
	Transactions                []core.TransactionModel
	GetHeadersByNumbersErr      error
	// contains filtered or unexported fields
}

func NewMockBlockChain 

func NewMockBlockChain() *MockBlockChain

func (*MockBlockChain) AssertFetchContractDataCalledWith 

func (blockChain *MockBlockChain) AssertFetchContractDataCalledWith(abiJSON string, address string, method string, methodArgs []interface{}, result interface{}, blockNumber int64)

func (*MockBlockChain) AssertGetEthLogsWithCustomQueryCalledWith 

func (blockChain *MockBlockChain) AssertGetEthLogsWithCustomQueryCalledWith(query ethereum.FilterQuery)

func (*MockBlockChain) BatchGetStorageAt added in v0.1.0 

func (blockChain *MockBlockChain) BatchGetStorageAt(account common.Address, keys []common.Hash, blockNumber *big.Int) (map[common.Hash][]byte, error)

func (*MockBlockChain) CallContract 

func (blockChain *MockBlockChain) CallContract(contractHash string, input []byte, blockNumber *big.Int) ([]byte, error)

func (*MockBlockChain) ChainHead added in v0.1.1 

func (blockChain *MockBlockChain) ChainHead() (*big.Int, error)

func (*MockBlockChain) FetchContractData 

func (blockChain *MockBlockChain) FetchContractData(abiJSON string, address string, method string, methodArgs []interface{}, result interface{}, blockNumber int64) error

func (*MockBlockChain) GetEthLogsWithCustomQuery 

func (blockChain *MockBlockChain) GetEthLogsWithCustomQuery(query ethereum.FilterQuery) ([]types.Log, error)

func (*MockBlockChain) GetHeaderByNumber 

func (blockChain *MockBlockChain) GetHeaderByNumber(blockNumber int64) (core.Header, error)

func (*MockBlockChain) GetHeadersByNumbers added in v0.0.3 

func (blockChain *MockBlockChain) GetHeadersByNumbers(blockNumbers []int64) ([]core.Header, error)

func (*MockBlockChain) GetTransactions 

func (blockChain *MockBlockChain) GetTransactions(transactionHashes []common.Hash) ([]core.TransactionModel, error)

func (*MockBlockChain) Node 

func (blockChain *MockBlockChain) Node() core.Node

func (*MockBlockChain) SetChainHead added in v0.1.1 

func (blockChain *MockBlockChain) SetChainHead(blockNumber *big.Int)

func (*MockBlockChain) SetChainHeadError added in v0.1.1 

func (blockChain *MockBlockChain) SetChainHeadError(err error)

func (*MockBlockChain) SetFetchContractDataErr 

func (blockChain *MockBlockChain) SetFetchContractDataErr(err error)

func (*MockBlockChain) SetGetEthLogsWithCustomQueryErr 

func (blockChain *MockBlockChain) SetGetEthLogsWithCustomQueryErr(err error)

func (*MockBlockChain) SetGetEthLogsWithCustomQueryReturnLogs 

func (blockChain *MockBlockChain) SetGetEthLogsWithCustomQueryReturnLogs(logs []types.Log)

func (*MockBlockChain) SetStorageValuesToReturn added in v0.1.0 

func (blockChain *MockBlockChain) SetStorageValuesToReturn(blockNumber int64, address common.Address, value []byte)

type MockBlockRetriever added in v0.1.0 

type MockBlockRetriever struct {
	FirstBlock    int64
	FirstBlockErr error
}

func (*MockBlockRetriever) RetrieveFirstBlock added in v0.1.0 

func (retriever *MockBlockRetriever) RetrieveFirstBlock() (int64, error)

func (*MockBlockRetriever) RetrieveMostRecentBlock added in v0.1.0 

func (retriever *MockBlockRetriever) RetrieveMostRecentBlock() (int64, error)

type MockCheckedHeadersRepository added in v0.0.10 

type MockCheckedHeadersRepository struct {
	MarkHeaderCheckedHeaderID           int64
	MarkHeaderCheckedReturnError        error
	UncheckedHeadersCheckCount          int64
	UncheckedHeadersEndingBlockNumber   int64
	UncheckedHeadersReturnError         error
	UncheckedHeadersReturnHeaders       []core.Header
	UncheckedHeadersStartingBlockNumber int64
}

func (*MockCheckedHeadersRepository) MarkHeaderChecked added in v0.0.10 

func (repository *MockCheckedHeadersRepository) MarkHeaderChecked(headerID int64) error

func (*MockCheckedHeadersRepository) MarkSingleHeaderUnchecked added in v0.1.0 

func (repository *MockCheckedHeadersRepository) MarkSingleHeaderUnchecked(blockNumber int64) error

func (*MockCheckedHeadersRepository) UncheckedHeaders added in v0.0.10 

func (repository *MockCheckedHeadersRepository) UncheckedHeaders(startingBlockNumber, endingBlockNumber, checkCount int64) ([]core.Header, error)

type MockCheckedLogsRepository added in v0.0.10 

type MockCheckedLogsRepository struct {
	AlreadyWatchingLogAddresses []string
	AlreadyWatchingLogError     error
	AlreadyWatchingLogReturn    bool
	AlreadyWatchingLogTopicZero string
	MarkLogWatchedAddresses     []string
	MarkLogWatchedError         error
	MarkLogWatchedTopicZero     string
}

func (*MockCheckedLogsRepository) AlreadyWatchingLog added in v0.0.10 

func (repository *MockCheckedLogsRepository) AlreadyWatchingLog(addresses []string, topic0 string) (bool, error)

func (*MockCheckedLogsRepository) MarkLogWatched added in v0.0.10 

func (repository *MockCheckedLogsRepository) MarkLogWatched(addresses []string, topic0 string) error

type MockEthClient 

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

func NewMockEthClient 

func NewMockEthClient() *MockEthClient

func (*MockEthClient) AssertBatchCalledWith 

func (client *MockEthClient) AssertBatchCalledWith(method string)

func (*MockEthClient) AssertBlockByNumberCalledWith 

func (client *MockEthClient) AssertBlockByNumberCalledWith(ctx context.Context, number *big.Int)

func (*MockEthClient) AssertCallContractCalledWith 

func (client *MockEthClient) AssertCallContractCalledWith(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int)

func (*MockEthClient) AssertFilterLogsCalledWith 

func (client *MockEthClient) AssertFilterLogsCalledWith(ctx context.Context, q ethereum.FilterQuery)

func (*MockEthClient) AssertHeaderByNumberCalledWith 

func (client *MockEthClient) AssertHeaderByNumberCalledWith(ctx context.Context, number *big.Int)

func (*MockEthClient) AssertHeaderByNumbersCalledWith 

func (client *MockEthClient) AssertHeaderByNumbersCalledWith(number []*big.Int)

func (*MockEthClient) AssertSubscribeNewStateChangesCalledWith added in v0.1.0 

func (client *MockEthClient) AssertSubscribeNewStateChangesCalledWith(filterQuery ethereum.FilterQuery, payloadCh chan<- filters.Payload)

func (*MockEthClient) BatchCall 

func (client *MockEthClient) BatchCall(batch []core.BatchElem) error

func (*MockEthClient) BlockByNumber 

func (client *MockEthClient) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

func (*MockEthClient) CallContract 

func (client *MockEthClient) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

func (*MockEthClient) FilterLogs 

func (client *MockEthClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

func (*MockEthClient) HeaderByNumber 

func (client *MockEthClient) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

func (*MockEthClient) HeaderByNumbers 

func (client *MockEthClient) HeaderByNumbers(numbers []*big.Int) ([]*types.Header, error)

func (*MockEthClient) SetBlockByNumberErr 

func (client *MockEthClient) SetBlockByNumberErr(err error)

func (*MockEthClient) SetBlockByNumberReturnBlock 

func (client *MockEthClient) SetBlockByNumberReturnBlock(block *types.Block)

func (*MockEthClient) SetCallContractErr 

func (client *MockEthClient) SetCallContractErr(err error)

func (*MockEthClient) SetCallContractReturnBytes 

func (client *MockEthClient) SetCallContractReturnBytes(returnBytes []byte)

func (*MockEthClient) SetFilterLogsErr 

func (client *MockEthClient) SetFilterLogsErr(err error)

func (*MockEthClient) SetFilterLogsReturnLogs 

func (client *MockEthClient) SetFilterLogsReturnLogs(logs []types.Log)

func (*MockEthClient) SetHeaderByNumberErr 

func (client *MockEthClient) SetHeaderByNumberErr(err error)

func (*MockEthClient) SetHeaderByNumberReturnHeader 

func (client *MockEthClient) SetHeaderByNumberReturnHeader(header *types.Header)

func (*MockEthClient) SetHeaderByNumbersReturnHeader 

func (client *MockEthClient) SetHeaderByNumbersReturnHeader(headers []*types.Header)

func (*MockEthClient) SetTransactionReceiptErr 

func (client *MockEthClient) SetTransactionReceiptErr(err error)

func (*MockEthClient) SetTransactionReceipts 

func (client *MockEthClient) SetTransactionReceipts(receipts []*types.Receipt)

func (*MockEthClient) SetTransactionSenderErr 

func (client *MockEthClient) SetTransactionSenderErr(err error)

func (*MockEthClient) SubscribeNewStateChanges added in v0.1.0 

func (client *MockEthClient) SubscribeNewStateChanges(ctx context.Context, q ethereum.FilterQuery, ch chan<- filters.Payload) (ethereum.Subscription, error)

func (*MockEthClient) TransactionReceipt 

func (client *MockEthClient) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

func (*MockEthClient) TransactionSender 

func (client *MockEthClient) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

type MockEventLogRepository added in v0.1.0 

type MockEventLogRepository struct {
	CreateError    error
	GetCalled      bool
	GetError       error
	PassedMinIDs   []int
	PassedLimits   []int
	PassedHeaderID int64
	PassedLogs     []types.Log
	ReturnLogs     []core.EventLog
}

func (*MockEventLogRepository) CreateEventLogs added in v0.1.0 

func (repository *MockEventLogRepository) CreateEventLogs(headerID int64, logs []types.Log) error

func (*MockEventLogRepository) GetUntransformedEventLogs added in v0.1.0 

func (repository *MockEventLogRepository) GetUntransformedEventLogs(minID, limit int) ([]core.EventLog, error)

type MockFsReader 

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

func (*MockFsReader) AssertReadCalledWith 

func (mfr *MockFsReader) AssertReadCalledWith(path string)

func (*MockFsReader) Read 

func (mfr *MockFsReader) Read(path string) ([]byte, error)

func (*MockFsReader) SetReturnBytes 

func (mfr *MockFsReader) SetReturnBytes(returnBytes []byte)

func (*MockFsReader) SetReturnErr 

func (mfr *MockFsReader) SetReturnErr(err error)

type MockHeaderRepository 

type MockHeaderRepository struct {
	AllHeaders                             []core.Header
	CreateTransactionsCalled               bool
	CreateTransactionsError                error
	GetHeaderByBlockNumberError            error
	GetHeaderByBlockNumberReturnHash       string
	GetHeaderByBlockNumberReturnID         int64
	GetHeaderByIDError                     error
	GetHeaderByIDHeaderToReturn            core.Header
	GetHeaderPassedBlockNumber             int64
	GetHeadersInRangeEndingBlocks          []int64
	GetHeadersInRangeError                 error
	GetHeadersInRangeStartingBlocks        []int64
	MissingBlockNumbersPassedEndingBlock   int64
	MissingBlockNumbersPassedStartingBlock int64
	MostRecentHeaderBlockNumber            int64
	MostRecentHeaderBlockNumberErr         error
	// contains filtered or unexported fields
}

func NewMockHeaderRepository 

func NewMockHeaderRepository() *MockHeaderRepository

func (*MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers 

func (mock *MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers(times int, blockNumbers []int64)

func (*MockHeaderRepository) CreateOrUpdateHeader 

func (mock *MockHeaderRepository) CreateOrUpdateHeader(header core.Header) (int64, error)

func (*MockHeaderRepository) CreateTransactionInTx added in v0.1.0 

func (mock *MockHeaderRepository) CreateTransactionInTx(tx *sqlx.Tx, headerID int64, transaction core.TransactionModel) (int64, error)

func (*MockHeaderRepository) CreateTransactions 

func (mock *MockHeaderRepository) CreateTransactions(headerID int64, transactions []core.TransactionModel) error

func (*MockHeaderRepository) DeleteHeader added in v0.1.1 

func (mock *MockHeaderRepository) DeleteHeader(blockNumber int64) error

func (*MockHeaderRepository) GetHeaderByBlockNumber added in v0.1.0 

func (mock *MockHeaderRepository) GetHeaderByBlockNumber(blockNumber int64) (core.Header, error)

func (*MockHeaderRepository) GetHeaderByID added in v0.1.0 

func (mock *MockHeaderRepository) GetHeaderByID(id int64) (core.Header, error)

func (*MockHeaderRepository) GetHeadersInRange added in v0.1.0 

func (mock *MockHeaderRepository) GetHeadersInRange(startingBlock, endingBlock int64) ([]core.Header, error)

func (*MockHeaderRepository) GetMostRecentHeaderBlockNumber added in v0.1.0 

func (mock *MockHeaderRepository) GetMostRecentHeaderBlockNumber() (int64, error)

func (*MockHeaderRepository) MissingBlockNumbers 

func (mock *MockHeaderRepository) MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64) ([]int64, error)

func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr 

func (mock *MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr(err error)

func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnID 

func (mock *MockHeaderRepository) SetCreateOrUpdateHeaderReturnID(id int64)

func (*MockHeaderRepository) SetMissingBlockNumbers 

func (mock *MockHeaderRepository) SetMissingBlockNumbers(blockNumbers []int64)

type MockRpcClient 

type MockRpcClient struct {
	ClientVersion string
	GethNodeInfo  p2p.NodeInfo

	NetworkID string

	ParityEnode    string
	ParityNodeInfo core.ParityNodeInfo

	StorageValueToReturn []byte
	// contains filtered or unexported fields
}

func NewMockRpcClient 

func NewMockRpcClient() *MockRpcClient

func (*MockRpcClient) AssertBatchCalledWith 

func (c *MockRpcClient) AssertBatchCalledWith(method string, lengthOfBatch int)

func (*MockRpcClient) AssertCallContextCalledWith 

func (c *MockRpcClient) AssertCallContextCalledWith(ctx context.Context, result interface{}, method string)

func (*MockRpcClient) AssertSubscribeCalledWith added in v0.0.10 

func (c *MockRpcClient) AssertSubscribeCalledWith(namespace string, payloadChan chan filters.Payload, args []interface{})

func (*MockRpcClient) BatchCall 

func (c *MockRpcClient) BatchCall(batch []core.BatchElem) error

func (*MockRpcClient) CallContext 

func (c *MockRpcClient) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

func (*MockRpcClient) IpcPath 

func (c *MockRpcClient) IpcPath() string

func (*MockRpcClient) SetCallContextErr 

func (c *MockRpcClient) SetCallContextErr(err error)

func (*MockRpcClient) SetIpcPath 

func (c *MockRpcClient) SetIpcPath(ipcPath string)

func (*MockRpcClient) SetReturnPOAHeader 

func (c *MockRpcClient) SetReturnPOAHeader(header core.POAHeader)

func (*MockRpcClient) SetReturnPOAHeaders 

func (c *MockRpcClient) SetReturnPOAHeaders(headers []core.POAHeader)

func (*MockRpcClient) SetReturnPOWHeaders 

func (c *MockRpcClient) SetReturnPOWHeaders(headers []*types.Header)

func (*MockRpcClient) Subscribe added in v0.0.10 

func (c *MockRpcClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (core.Subscription, error)

type MockStatusWriter added in v0.1.0 

type MockStatusWriter struct {
	WriteCalled bool
}

func (*MockStatusWriter) Write added in v0.1.0 

func (w *MockStatusWriter) Write() error

type MockSubscription added in v0.1.0 

type MockSubscription struct {
	Errs chan error
}

func (*MockSubscription) Err added in v0.1.0 

func (m *MockSubscription) Err() <-chan error

func (*MockSubscription) Unsubscribe added in v0.1.0 

func (m *MockSubscription) Unsubscribe()

type MockTailer 

type MockTailer struct {
	Lines   chan *tail.Line
	TailErr error
}

func NewMockTailer 

func NewMockTailer() *MockTailer

func (*MockTailer) Tail 

func (mock *MockTailer) Tail() (*tail.Tail, error)

type MockTransactionConverter 

type MockTransactionConverter struct {
	ConvertRpcTransactionsToModelsCalled bool
}

func NewMockTransactionConverter 

func NewMockTransactionConverter() *MockTransactionConverter

func (*MockTransactionConverter) ConvertRpcTransactionsToModels 

func (converter *MockTransactionConverter) ConvertRpcTransactionsToModels(transactions []core.RpcTransaction) ([]core.TransactionModel, error)

type MockTransactionSyncer 

type MockTransactionSyncer struct {
	SyncTransactionsCalled bool
	SyncTransactionsError  error
}

func (*MockTransactionSyncer) SyncTransactions 

func (syncer *MockTransactionSyncer) SyncTransactions(headerID int64, logs []types.Log) error

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.