mocks

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: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var FakeTransformerConfig = event.TransformerConfig{
	TransformerName:   "FakeTransformer",
	ContractAddresses: []string{fakes.FakeAddress.Hex()},
	Topic:             fakes.FakeHash.Hex(),
}

Functions

This section is empty.

Types

type MockConverter

type MockConverter struct {
	ToModelsError           error
	ContractAbi             string
	LogsToConvert           []core.EventLog
	PassedContractAddresses []string
	ToModelsCalledCounter   int
}

func (*MockConverter) ToModels

func (converter *MockConverter) ToModels(abi string, logs []core.EventLog, _ *postgres.DB) ([]event.InsertionModel, error)

type MockEventTransformer added in v0.0.10

type MockEventTransformer struct {
	ExecuteWasCalled bool
	ExecuteError     error
	PassedLogs       []core.EventLog
	// contains filtered or unexported fields
}

func (*MockEventTransformer) Execute added in v0.0.10

func (t *MockEventTransformer) Execute(logs []core.EventLog) error

func (*MockEventTransformer) FakeTransformerInitializer added in v0.0.10

func (t *MockEventTransformer) FakeTransformerInitializer(db *postgres.DB) event.ITransformer

func (*MockEventTransformer) GetConfig added in v0.0.10

func (*MockEventTransformer) SetTransformerConfig added in v0.0.10

func (t *MockEventTransformer) SetTransformerConfig(config event.TransformerConfig)

type MockLogDelegator added in v0.0.10

type MockLogDelegator struct {
	AddedTransformers   []event.ITransformer
	DelegateCallCount   int
	DelegateErrors      []error
	DelegatePassedLimit int
}

func (*MockLogDelegator) AddTransformer added in v0.0.10

func (delegator *MockLogDelegator) AddTransformer(t event.ITransformer)

func (*MockLogDelegator) DelegateLogs added in v0.0.10

func (delegator *MockLogDelegator) DelegateLogs(limit int) error

type MockLogExtractor added in v0.0.10

type MockLogExtractor struct {
	AddedConfigs              []event.TransformerConfig
	AddTransformerConfigError error
	ExtractLogsCount          int
	ExtractLogsErrors         []error
}

func (*MockLogExtractor) AddTransformerConfig added in v0.0.10

func (extractor *MockLogExtractor) AddTransformerConfig(config event.TransformerConfig) error

func (*MockLogExtractor) BackFillLogs added in v0.1.0

func (extractor *MockLogExtractor) BackFillLogs(endingBlock int64) error

func (*MockLogExtractor) ExtractLogs added in v0.0.10

func (extractor *MockLogExtractor) ExtractLogs(recheckHeaders constants.TransformerExecution) error

type MockLogFetcher added in v0.0.10

type MockLogFetcher struct {
	ContractAddresses []common.Address
	FetchCalled       bool
	MissingHeader     core.Header
	ReturnError       error
	ReturnLogs        []types.Log
	Topics            []common.Hash
}

func (*MockLogFetcher) FetchLogs added in v0.0.10

func (fetcher *MockLogFetcher) FetchLogs(contractAddresses []common.Address, topics []common.Hash, missingHeader core.Header) ([]types.Log, error)

type MockStorageDiffRepository added in v0.1.0

type MockStorageDiffRepository struct {
	CreateBackFilledStorageValuePassedRawDiffs []types.RawDiff
	CreateBackFilledStorageValueReturnError    error
	CreatePassedRawDiffs                       []types.RawDiff
	GetNewDiffsToReturn                        []types.PersistedDiff
	GetNewDiffsErrors                          []error
	GetNewDiffsPassedMinIDs                    []int
	GetNewDiffsPassedLimits                    []int
	GetPendingDiffsToReturn                    []types.PersistedDiff
	GetPendingDiffsErrors                      []error
	GetPendingDiffsPassedMinIDs                []int
	GetPendingDiffsPassedLimits                []int
	GetUnrecognizedDiffsToReturn               []types.PersistedDiff
	GetUnrecognizedDiffsErrors                 []error
	GetUnrecognizedDiffsPassedMinIDs           []int
	GetUnrecognizedDiffsPassedLimits           []int
	MarkTransformedPassedID                    int64
	MarkUnrecognizedPassedID                   int64
	MarkNoncanonicalPassedID                   int64
	MarkPendingPassedID                        int64
	MarkUnwatchedPassedID                      int64
	GetFirstDiffIDToReturn                     int64
	GetFirstDiffIDErr                          error
	GetFirstDiffBlockHeightPassed              int64
}

func (*MockStorageDiffRepository) CreateBackFilledStorageValue added in v0.1.0

func (repository *MockStorageDiffRepository) CreateBackFilledStorageValue(rawDiff types.RawDiff) error

func (*MockStorageDiffRepository) CreateStorageDiff added in v0.1.0

func (repository *MockStorageDiffRepository) CreateStorageDiff(rawDiff types.RawDiff) (int64, error)

func (*MockStorageDiffRepository) GetFirstDiffIDForBlockHeight added in v0.1.0

func (repository *MockStorageDiffRepository) GetFirstDiffIDForBlockHeight(blockHeight int64) (int64, error)

func (*MockStorageDiffRepository) GetNewDiffs added in v0.1.0

func (repository *MockStorageDiffRepository) GetNewDiffs(minID, limit int) ([]types.PersistedDiff, error)

func (*MockStorageDiffRepository) GetPendingDiffs added in v0.1.1

func (repository *MockStorageDiffRepository) GetPendingDiffs(minID, limit int) ([]types.PersistedDiff, error)

func (*MockStorageDiffRepository) GetUnrecognizedDiffs added in v0.1.0

func (repository *MockStorageDiffRepository) GetUnrecognizedDiffs(minID, limit int) ([]types.PersistedDiff, error)

func (*MockStorageDiffRepository) MarkNoncanonical added in v0.1.0

func (repository *MockStorageDiffRepository) MarkNoncanonical(id int64) error

func (*MockStorageDiffRepository) MarkNoncanonicalDiffsAsNew added in v0.1.1

func (repository *MockStorageDiffRepository) MarkNoncanonicalDiffsAsNew(blockNumber int64) error

func (*MockStorageDiffRepository) MarkPending added in v0.1.1

func (repository *MockStorageDiffRepository) MarkPending(id int64) error

func (*MockStorageDiffRepository) MarkTransformed added in v0.1.0

func (repository *MockStorageDiffRepository) MarkTransformed(id int64) error

func (*MockStorageDiffRepository) MarkUnrecognized added in v0.1.0

func (repository *MockStorageDiffRepository) MarkUnrecognized(id int64) error

func (*MockStorageDiffRepository) MarkUnwatched added in v0.1.0

func (repository *MockStorageDiffRepository) MarkUnwatched(id int64) error

type MockStorageFetcher added in v0.0.2

type MockStorageFetcher struct {
	DiffsToReturn           []types.RawDiff
	ErrsToReturn            []error
	FetchStorageDiffsCalled bool
}

func NewMockStorageFetcher added in v0.0.2

func NewMockStorageFetcher() *MockStorageFetcher

func (*MockStorageFetcher) FetchStorageDiffs added in v0.0.2

func (fetcher *MockStorageFetcher) FetchStorageDiffs(out chan<- types.RawDiff, errs chan<- error)

type MockStorageKeysLoader added in v0.0.10

type MockStorageKeysLoader struct {
	LoadMappingsCallCount int
	LoadMappingsError     error
	SetDBCalled           bool
	StorageKeyMappings    map[common.Hash]types.ValueMetadata
}

func (*MockStorageKeysLoader) LoadMappings added in v0.0.10

func (loader *MockStorageKeysLoader) LoadMappings() (map[common.Hash]types.ValueMetadata, error)

func (*MockStorageKeysLoader) SetDB added in v0.0.10

func (loader *MockStorageKeysLoader) SetDB(db *postgres.DB)

type MockStorageKeysLookup added in v0.0.10

type MockStorageKeysLookup struct {
	Metadata      types.ValueMetadata
	LookupCalled  bool
	LookupErr     error
	KeysToReturn  []common.Hash
	GetKeysCalled bool
	GetKeysError  error
	// contains filtered or unexported fields
}

func (*MockStorageKeysLookup) GetKeys added in v0.1.0

func (lookup *MockStorageKeysLookup) GetKeys() ([]common.Hash, error)

func (*MockStorageKeysLookup) Lookup added in v0.0.10

func (lookup *MockStorageKeysLookup) Lookup(key common.Hash) (types.ValueMetadata, error)

func (*MockStorageKeysLookup) SetDB added in v0.0.10

func (lookup *MockStorageKeysLookup) SetDB(db *postgres.DB)

type MockStorageRepository

type MockStorageRepository struct {
	CreateErr      error
	PassedHeaderID int64
	PassedDiffID   int64
	PassedMetadata types.ValueMetadata
	PassedValue    interface{}
	// contains filtered or unexported fields
}

func (*MockStorageRepository) Create

func (repository *MockStorageRepository) Create(diffID, headerID int64, metadata types.ValueMetadata, value interface{}) error

func (*MockStorageRepository) SetDB

func (repository *MockStorageRepository) SetDB(db *postgres.DB)

type MockStorageTransformer

type MockStorageTransformer struct {
	Address           common.Address
	StorageKeysLookup storage.KeysLookup
	ExecuteErr        error
	PassedDiff        types.PersistedDiff
}

func (*MockStorageTransformer) Execute

func (transformer *MockStorageTransformer) Execute(diff types.PersistedDiff) error

func (*MockStorageTransformer) FakeTransformerInitializer

func (transformer *MockStorageTransformer) FakeTransformerInitializer(db *postgres.DB) storage.ITransformer

func (*MockStorageTransformer) GetContractAddress added in v0.1.0

func (transformer *MockStorageTransformer) GetContractAddress() common.Address

func (*MockStorageTransformer) GetStorageKeysLookup added in v0.1.0

func (transformer *MockStorageTransformer) GetStorageKeysLookup() storage.KeysLookup

type MockStoragediffStreamer added in v0.1.0

type MockStoragediffStreamer struct {
	ClientSubscription *fakes.MockSubscription
	PassedPayloadChan  chan filters.Payload
	// contains filtered or unexported fields
}

func (*MockStoragediffStreamer) SetPayloads added in v0.1.0

func (streamer *MockStoragediffStreamer) SetPayloads(payloads []filters.Payload)

func (*MockStoragediffStreamer) SetSubscribeError added in v0.1.0

func (streamer *MockStoragediffStreamer) SetSubscribeError(err error)

func (*MockStoragediffStreamer) Stream added in v0.1.0

func (streamer *MockStoragediffStreamer) Stream(statediffPayloadChan chan filters.Payload) (core.Subscription, error)

type MockThrottler added in v0.1.1

type MockThrottler struct {
	SleepTime time.Duration
	// contains filtered or unexported fields
}

func (*MockThrottler) Throttle added in v0.1.1

func (throttler *MockThrottler) Throttle(sleep time.Duration, f utils.Callback) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL