fakes

package
v0.0.13-rc.1 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2020 License: AGPL-3.0 Imports: 21 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 BlockRetriever 

type BlockRetriever struct {
	FirstBlock    int64
	FirstBlockErr error
}

func (*BlockRetriever) RetrieveFirstBlock 

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

func (*BlockRetriever) RetrieveMostRecentBlock 

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

type MockBlockChain 

type MockBlockChain struct {
	GetTransactionsCalled         bool
	GetTransactionsError          error
	GetTransactionsPassedHashes   []common.Hash
	GetStorageAtPassedAccounts    []common.Address
	GetStorageAtPassedKeys        []common.Hash
	GetStorageAtPassedBlockNumber *big.Int
	GetStorageAtError             error

	Transactions []core.TransactionModel
	// 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) CallContract 

func (blockChain *MockBlockChain) CallContract(contractHash string, input []byte, blockNumber *big.Int) ([]byte, 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) GetStorageAt 

func (blockChain *MockBlockChain) GetStorageAt(account common.Address, key common.Hash, blockNumber *big.Int) ([]byte, error)

func (*MockBlockChain) GetTransactions 

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

func (*MockBlockChain) LastBlock 

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

func (*MockBlockChain) Node 

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

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) SetGetStorageAtError 

func (blockChain *MockBlockChain) SetGetStorageAtError(err error)

func (*MockBlockChain) SetLastBlock 

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

func (*MockBlockChain) SetStorageValuesToReturn added in v0.1.0 

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

type MockCheckedHeaderRepository 

type MockCheckedHeaderRepository struct {
}

func (*MockCheckedHeaderRepository) AddCheckColumn 

func (*MockCheckedHeaderRepository) AddCheckColumn(id string) error

func (*MockCheckedHeaderRepository) AddCheckColumns 

func (*MockCheckedHeaderRepository) AddCheckColumns(ids []string) error

func (*MockCheckedHeaderRepository) CheckCache 

func (*MockCheckedHeaderRepository) CheckCache(key string) (interface{}, bool)

func (*MockCheckedHeaderRepository) MarkHeaderChecked 

func (*MockCheckedHeaderRepository) MarkHeaderChecked(headerID int64, eventID string) error

func (*MockCheckedHeaderRepository) MarkHeaderCheckedForAll 

func (*MockCheckedHeaderRepository) MarkHeaderCheckedForAll(headerID int64, ids []string) error

func (*MockCheckedHeaderRepository) MarkHeadersCheckedForAll 

func (*MockCheckedHeaderRepository) MarkHeadersCheckedForAll(headers []core.Header, ids []string) error

func (*MockCheckedHeaderRepository) MissingHeaders 

func (*MockCheckedHeaderRepository) MissingHeaders(startingBlockNumber int64, endingBlockNumber int64, eventID string) ([]core.Header, error)

func (*MockCheckedHeaderRepository) MissingHeadersForAll 

func (*MockCheckedHeaderRepository) MissingHeadersForAll(startingBlockNumber, endingBlockNumber int64, ids []string) ([]core.Header, error)

func (*MockCheckedHeaderRepository) MissingMethodsCheckedEventsIntersection 

func (*MockCheckedHeaderRepository) MissingMethodsCheckedEventsIntersection(startingBlockNumber, endingBlockNumber int64, methodIds, eventIds []string) ([]core.Header, error)

type MockCheckedHeadersRepository added in v0.0.10 

type MockCheckedHeadersRepository struct {
	MarkHeaderCheckedHeaderID               int64
	MarkHeaderCheckedReturnError            error
	MarkHeadersUncheckedCalled              bool
	MarkHeadersUncheckedReturnError         error
	MarkHeadersUncheckedStartingBlockNumber int64
	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) MarkHeadersUncheckedSince 

func (repository *MockCheckedHeadersRepository) MarkHeadersUncheckedSince(startingBlockNumber 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) AssertBalanceAtCalled 

func (client *MockEthClient) AssertBalanceAtCalled(ctx context.Context, account common.Address, blockNumber *big.Int)

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) AssertStorageAtCalledWith 

func (client *MockEthClient) AssertStorageAtCalledWith(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int)

func (*MockEthClient) BalanceAt 

func (client *MockEthClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

func (*MockEthClient) BatchCall 

func (client *MockEthClient) BatchCall(batch []client.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) SetBalanceAt 

func (client *MockEthClient) SetBalanceAt(balance *big.Int)

func (*MockEthClient) SetBalanceAtErr 

func (client *MockEthClient) SetBalanceAtErr(err 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) SetStorageAtError 

func (client *MockEthClient) SetStorageAtError(err error)

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) StorageAt 

func (client *MockEthClient) StorageAt(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int) ([]byte, 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
	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() ([]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 {
	CreateTransactionsCalled bool
	CreateTransactionsError  error
	GetHeaderError           error
	GetHeaderReturnHash      string
	GetHeaderReturnID        int64

	GetHeaderPassedBlockNumber int64
	// contains filtered or unexported fields
}

func NewMockHeaderRepository 

func NewMockHeaderRepository() *MockHeaderRepository

func (*MockHeaderRepository) AssertCreateOrUpdateHeaderCallCountAndPassedBlockNumbers 

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

func (*MockHeaderRepository) CreateOrUpdateHeader 

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

func (*MockHeaderRepository) CreateTransactions 

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

func (*MockHeaderRepository) GetHeader 

func (repository *MockHeaderRepository) GetHeader(blockNumber int64) (core.Header, error)

func (*MockHeaderRepository) MissingBlockNumbers 

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

func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr 

func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnErr(err error)

func (*MockHeaderRepository) SetCreateOrUpdateHeaderReturnID 

func (repository *MockHeaderRepository) SetCreateOrUpdateHeaderReturnID(id int64)

func (*MockHeaderRepository) SetMissingBlockNumbers 

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

type MockParser 

type MockParser struct {
	AbiToReturn string
	EventName   string
	Event       types.Event
}

func (*MockParser) Abi 

func (parser *MockParser) Abi() string

func (*MockParser) GetEvents 

func (parser *MockParser) GetEvents(wanted []string) map[string]types.Event

func (*MockParser) GetMethods 

func (*MockParser) GetMethods(wanted []string) []types.Method

func (*MockParser) GetSelectMethods 

func (*MockParser) GetSelectMethods(wanted []string) []types.Method

func (*MockParser) Parse 

func (*MockParser) Parse(contractAddr string) error

func (*MockParser) ParseAbiStr 

func (parser *MockParser) ParseAbiStr(abiStr string) error

func (*MockParser) ParsedAbi 

func (*MockParser) ParsedAbi() abi.ABI

type MockPoller 

type MockPoller struct {
	ContractName string
}

func (*MockPoller) FetchContractData 

func (poller *MockPoller) FetchContractData(contractAbi, contractAddress, method string, methodArgs []interface{}, result interface{}, blockNumber int64) error

func (*MockPoller) PollContract 

func (*MockPoller) PollContract(con contract.Contract, lastBlock int64) error

func (*MockPoller) PollContractAt 

func (*MockPoller) PollContractAt(con contract.Contract, blockNumber int64) error

type MockRpcClient 

type MockRpcClient struct {
	ClientVersion string
	GethNodeInfo  p2p.NodeInfo

	NetworkID string

	ParityEnode    string
	ParityNodeInfo core.ParityNodeInfo
	// contains filtered or unexported fields
}

func NewMockRpcClient 

func NewMockRpcClient() *MockRpcClient

func (*MockRpcClient) AssertBatchCalledWith 

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

func (*MockRpcClient) AssertCallContextCalledWith 

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

func (*MockRpcClient) AssertSubscribeCalledWith added in v0.0.10 

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

func (*MockRpcClient) BatchCall 

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

func (*MockRpcClient) CallContext 

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

func (*MockRpcClient) IpcPath 

func (client *MockRpcClient) IpcPath() string

func (*MockRpcClient) SetCallContextErr 

func (client *MockRpcClient) SetCallContextErr(err error)

func (*MockRpcClient) SetIpcPath 

func (client *MockRpcClient) SetIpcPath(ipcPath string)

func (*MockRpcClient) SetReturnPOAHeader 

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

func (*MockRpcClient) SetReturnPOAHeaders 

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

func (*MockRpcClient) SetReturnPOWHeaders 

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

func (*MockRpcClient) Subscribe added in v0.0.10 

func (client *MockRpcClient) Subscribe(namespace string, payloadChan interface{}, args ...interface{}) (*rpc.ClientSubscription, error)

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.