cltest

package

Go to main page

Versions in this module

v1

v1.10.17

Oct 18, 2021

Changes in this version

+ const DefaultWaitTimeout

+ const SimulatedBackendEVMChainID

+ var DefaultCSAKey = csakey.MustNewV2XXXTestingOnly(big.NewInt(1))

+ var DefaultOCRKey = ocrkey.MustNewV2XXXTestingOnly(big.NewInt(1))

+ var DefaultP2PKey = p2pkey.MustNewV2XXXTestingOnly(big.NewInt(1))

+ var DefaultVRFKey = vrfkey.MustNewV2XXXTestingOnly(big.NewInt(1))

+ var FixtureChainID = *big.NewInt(0)

+ func DynamicFeeTransactionsFromTipCaps(tipCaps ...int64) []gas.Transaction

+ func LegacyTransactionsFromGasPrices(gasPrices ...int64) []gas.Transaction

+ func MustGenerateRandomKeyState(t testing.TB) ethkey.State

+ func MustGetStateForKey(t testing.TB, kst keystore.Eth, key ethkey.KeyV2) ethkey.State

+ func MustInsertBroadcastLegacyEthTxAttempt(t *testing.T, etxID int64, db *gorm.DB, gasPrice int64) bulletprooftxmanager.EthTxAttempt

+ func MustInsertConfirmedEthTxWithLegacyAttempt(t *testing.T, db *gorm.DB, nonce int64, broadcastBeforeBlockNum int64, ...) bulletprooftxmanager.EthTx

+ func MustInsertRandomKeyReturningState(t testing.TB, keystore keystore.Eth, opts ...interface{}) (ethkey.State, common.Address)

+ func MustInsertUnconfirmedEthTxWithBroadcastDynamicFeeAttempt(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address, ...) bulletprooftxmanager.EthTx

+ func MustInsertUnconfirmedEthTxWithBroadcastLegacyAttempt(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address, ...) bulletprooftxmanager.EthTx

+ func MustSendingKeyStates(t *testing.T, ethKeyStore keystore.Eth) []ethkey.State

+ func NewChainSetMockWithOneChain(t testing.TB, ethClient eth.Client, cfg evmconfig.ChainScopedConfig) evm.ChainSet

+ func NewDynamicFeeEthTxAttempt(t *testing.T, etxID int64) bulletprooftxmanager.EthTxAttempt

+ func NewEthClientAndSubMock(t mock.TestingT) (*mocks.Client, *mocks.Subscription)

+ func NewEthClientAndSubMockWithDefaultChain(t mock.TestingT) (*mocks.Client, *mocks.Subscription)

+ func NewEthClientMock(t mock.TestingT) *mocks.Client

+ func NewEthClientMockWithDefaultChain(t testing.TB) *mocks.Client

+ func NewEthMocksWithDefaultChain(t testing.TB) (c *mocks.Client, s *mocks.Subscription, f func())

+ func NewLegacyEthTxAttempt(t *testing.T, etxID int64) bulletprooftxmanager.EthTxAttempt

+ func NewSimulatedBackend(t *testing.T, alloc core.GenesisAlloc, gasLimit uint64) *backends.SimulatedBackend

+ func NewTestChainScopedConfig(t testing.TB) evmconfig.ChainScopedConfig

+ func NewTestGeneralConfig(t testing.TB) *configtest.TestGeneralConfig

+ func WaitForPipeline(t testing.TB, nodeID int, jobID int32, expectedPipelineRuns int, ...) []pipeline.Run

+ func WaitForPipelineError(t testing.TB, nodeID int, jobID int32, expectedPipelineRuns int, ...) []pipeline.Run

type Blocks

+ func (b *Blocks) NewHead(number uint64) *eth.Head

+ type HeadBuffer struct

+ Heads []*eth.Head

+ func NewHeadBuffer(t *testing.T) *HeadBuffer

+ func (hb *HeadBuffer) Append(head *eth.Head)

type MockAPIInitializer

+ func NewMockAPIInitializer(t testing.TB) *MockAPIInitializer

+ type MockSecretGenerator struct

+ func (m MockSecretGenerator) Generate(string) ([]byte, error)

type TestApplication

+ func NewApplicationEVMDisabled(t *testing.T) *TestApplication

+ func (ta *TestApplication) Import(content string)

v1.10.16

Oct 18, 2021

Changes in this version

+ const APIKey

+ const APISecret

+ const AllowUnstarted

+ const AssertNoActionTimeout

+ const DBPollingInterval

+ const DBWaitTimeout

+ const DefaultKeyAddress

+ const DefaultKeyFixtureFileName

+ const DefaultKeyJSON

+ const DefaultOCRKeyBundleID

+ const DefaultPeerID

+ const NonExistentPeerID

+ const UseRealExternalInitiatorManager

+ const VRFPassword

+ var DefaultOCRKeyBundleIDSha256 models.Sha256Hash

+ var DefaultP2PPeerID p2pkey.PeerID

+ var FluxAggAddress = common.HexToAddress("0x3cCad4715152693fE3BC4460591e3D3Fbd071b42")

+ var NonExistentP2PPeerID p2pkey.PeerID

+ func AllExternalInitiators(t testing.TB, store *strpkg.Store) []models.ExternalInitiator

+ func AssertCount(t *testing.T, db *gorm.DB, model interface{}, expected int64)

+ func AssertCountStays(t testing.TB, store *strpkg.Store, model interface{}, want int64)

+ func AssertEthTxAttemptCountStays(t testing.TB, store *strpkg.Store, want int) []bulletprooftxmanager.EthTxAttempt

+ func AssertPipelineRunsStays(t testing.TB, pipelineSpecID int32, store *strpkg.Store, want int) []pipeline.Run

+ func AssertPipelineTaskRunsSuccessful(t testing.TB, runs []pipeline.TaskRun)

+ func AssertRecordEventually(t *testing.T, store *strpkg.Store, model interface{}, check func() bool)

+ func AssertRunsStays(t testing.TB, j models.JobSpec, store *strpkg.Store, want int) []models.JobRun

+ func AwaitJobActive(t testing.TB, jobSpawner job.Spawner, jobID int32, waitFor time.Duration)

+ func BatchElemMatchesHash(req rpc.BatchElem, hash common.Hash) bool

+ func BatchElemMustMatchHash(t *testing.T, req rpc.BatchElem, hash common.Hash)

+ func BlockWithTransactions(gasPrices ...int64) *types.Block

+ func CompareOCRJobSpecs(t *testing.T, expected, actual job.Job)

+ func CreateExternalInitiatorViaWeb(t testing.TB, app *TestApplication, payload string) *webpresenters.ExternalInitiatorAuthentication

+ func CreateJobRunViaExternalInitiator(t testing.TB, app *TestApplication, j models.JobSpec, eia auth.Token, ...) models.JobRun

+ func CreateJobRunViaExternalInitiatorV2(t testing.TB, app *TestApplication, jobID uuid.UUID, eia auth.Token, ...) webpresenters.PipelineRunResource

+ func CreateJobViaWeb(t testing.TB, app *TestApplication, request []byte) job.Job

+ func CreateJobViaWeb2(t testing.TB, app *TestApplication, spec string) webpresenters.JobResource

+ func DeleteJobViaWeb(t testing.TB, app *TestApplication, jobID int32)

+ func EventuallyExpectationsMet(t *testing.T, mock testifyExpectationsAsserter, timeout time.Duration, ...)

+ func FindEthTxWithAttempts(db *gorm.DB, etxID int64) (bulletprooftxmanager.EthTx, error)

+ func FixtureCreateJobSpecV2ViaWeb(t *testing.T, app *TestApplication, path string) job.Job

+ func GenericEncode(types []string, values ...interface{}) ([]byte, error)

+ func GetLastEthTxAttempt(t testing.TB, store *strpkg.Store) bulletprooftxmanager.EthTxAttempt

+ func GetLogs(t *testing.T, rv interface{}, logs EthereumLogIterator) []interface

+ func JobRunStaysPendingIncomingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func MakeConfigDigest(t *testing.T) ocrtypes.ConfigDigest

+ func MakeDirectRequestJobSpec(t *testing.T) *job.Job

+ func MakeRoundStateReturnData(roundID uint64, eligible bool, ...) []byte

+ func Mine(backend *backends.SimulatedBackend, blockTime time.Duration) (stopMining func())

+ func MinimalOCRNonBootstrapSpec(contractAddress, transmitterAddress ethkey.EIP55Address, peerID p2pkey.PeerID, ...) string

+ func MockApplicationEthCalls(t *testing.T, app *TestApplication, ethClient *mocks.Client) (verify func())

+ func MockFluxAggCall(client *mocks.Client, address common.Address, funcName string) *mock.Call

+ func MockSubscribeToLogsCh(ethClient *mocks.Client, sub *mocks.Subscription) chan chan<- types.Log

+ func MustAddKeyToKeystore(t testing.TB, key *ethkey.Key, ethKeyStore *keystore.Eth)

+ func MustAddRandomKeyToKeystore(t testing.TB, ethKeyStore *keystore.Eth, opts ...interface{}) (ethkey.Key, common.Address)

+ func MustBigIntFromString(t *testing.T, s string) *big.Int

+ func MustBytesToConfigDigest(t *testing.T, b []byte) ocrtypes.ConfigDigest

+ func MustGenerateRandomKey(t testing.TB, opts ...interface{}) ethkey.Key

+ func MustGenericEncode(types []string, values ...interface{}) []byte

+ func MustHelloWorldAgreement(t *testing.T) string

+ func MustHexDecodeString(s string) []byte

+ func MustInsertBroadcastEthTxAttempt(t *testing.T, etxID int64, db *gorm.DB, gasPrice int64) bulletprooftxmanager.EthTxAttempt

+ func MustInsertConfirmedEthTxWithAttempt(t *testing.T, db *gorm.DB, nonce int64, broadcastBeforeBlockNum int64, ...) bulletprooftxmanager.EthTx

+ func MustInsertConfirmedEthTxWithReceipt(t *testing.T, db *gorm.DB, fromAddress common.Address, nonce, blockNum int64) (etx bulletprooftxmanager.EthTx)

+ func MustInsertEthReceipt(t *testing.T, db *gorm.DB, blockNumber int64, blockHash common.Hash, ...) bulletprooftxmanager.EthReceipt

+ func MustInsertExternalInitiator(t *testing.T, db *gorm.DB) (ei models.ExternalInitiator)

+ func MustInsertExternalInitiatorWithOpts(t *testing.T, db *gorm.DB, opts ExternalInitiatorOpts) (ei models.ExternalInitiator)

+ func MustInsertFatalErrorEthTx(t *testing.T, db *gorm.DB, fromAddress common.Address) bulletprooftxmanager.EthTx

+ func MustInsertHead(t *testing.T, store *strpkg.Store, number int64) models.Head

+ func MustInsertInProgressEthTxWithAttempt(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address) bulletprooftxmanager.EthTx

+ func MustInsertJobSpec(t *testing.T, s *strpkg.Store) models.JobSpec

+ func MustInsertKeeperJob(t *testing.T, store *strpkg.Store, from ethkey.EIP55Address, ...) job.Job

+ func MustInsertKeeperRegistry(t *testing.T, store *strpkg.Store, ethKeyStore *keystore.Eth) (keeper.Registry, job.Job)

+ func MustInsertOffchainreportingOracleSpec(t *testing.T, db *gorm.DB, transmitterAddress ethkey.EIP55Address) job.OffchainReportingOracleSpec

+ func MustInsertPipelineRun(t *testing.T, db *gorm.DB) pipeline.Run

+ func MustInsertRandomKey(t testing.TB, db *gorm.DB, opts ...interface{}) ethkey.Key

+ func MustInsertSampleDirectRequestJob(t *testing.T, db *gorm.DB) job.Job

+ func MustInsertTaskRun(t *testing.T, store *strpkg.Store) (uuid.UUID, models.JobRun)

+ func MustInsertUnconfirmedEthTx(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address, ...) bulletprooftxmanager.EthTx

+ func MustInsertUnconfirmedEthTxWithBroadcastAttempt(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address, ...) bulletprooftxmanager.EthTx

+ func MustInsertUnconfirmedEthTxWithInsufficientEthAttempt(t *testing.T, db *gorm.DB, nonce int64, fromAddress common.Address) bulletprooftxmanager.EthTx

+ func MustInsertUnfinishedPipelineTaskRun(t *testing.T, store *strpkg.Store, pipelineRunID int64) pipeline.TaskRun

+ func MustInsertUnstartedEthTx(t *testing.T, db *gorm.DB, fromAddress common.Address, opts ...interface{}) bulletprooftxmanager.EthTx

+ func MustInsertUpkeepForRegistry(t *testing.T, store *strpkg.Store, registry keeper.Registry) keeper.UpkeepRegistration

+ func MustInsertV2JobSpec(t *testing.T, store *strpkg.Store, transmitterAddress common.Address) job.Job

+ func MustInsertWebhookSpec(t *testing.T, db *gorm.DB) (job.Job, job.WebhookSpec)

+ func MustJSONMarshal(t *testing.T, val interface{}) string

+ func MustJobIDFromString(t *testing.T, s string) models.JobID

+ func MustNewJSONSerializable(t *testing.T, s string) pipeline.JSONSerializable

+ func MustNewKeyedTransactor(t *testing.T, key *ecdsa.PrivateKey, chainID int64) *bind.TransactOpts

+ func MustNewSimulatedBackendKeyedTransactor(t *testing.T, key *ecdsa.PrivateKey) *bind.TransactOpts

+ func MustNewUser(t *testing.T, email, password string) models.User

+ func MustRandomBytes(t *testing.T, l int) (b []byte)

+ func MustRandomP2PPeerID(t *testing.T) p2ppeer.ID

+ func MustRandomUser() models.User

+ func MustResultString(t *testing.T, input models.RunResult) string

+ func MustSendingKeys(t *testing.T, ethKeyStore *keystore.Eth) (keys []ethkey.Key)

+ func MustWebURL(t *testing.T, s string) *models.WebURL

+ func NewContractMockReceiver(t *testing.T, ethMock *mocks.Client, abi abi.ABI, address common.Address) contractMockReceiver

+ func NewEIP55Address() ethkey.EIP55Address

+ func NewEthBroadcaster(t testing.TB, db *gorm.DB, ethClient eth.Client, ...) (*bulletprooftxmanager.EthBroadcaster, func())

+ func NewEthConfirmer(t testing.TB, db *gorm.DB, ethClient eth.Client, config *TestConfig, ...) *bulletprooftxmanager.EthConfirmer

+ func NewEthMocks(t testing.TB) (*mocks.Client, *mocks.Subscription, func())

+ func NewEthMocksWithStartupAssertions(t testing.TB) (*mocks.Client, *mocks.Subscription, func())

+ func NewEthTx(t *testing.T, fromAddress common.Address) bulletprooftxmanager.EthTx

+ func NewEthTxAttempt(t *testing.T, etxID int64) bulletprooftxmanager.EthTxAttempt

+ func NewHTTPMockServerWithAlterableResponse(t *testing.T, response func() string) (server *httptest.Server)

+ func NewHTTPMockServerWithAlterableResponseAndRequest(t *testing.T, response func() string, callback func(r *http.Request)) (server *httptest.Server)

+ func NewHTTPMockServerWithRequest(t *testing.T, status int, response string, callback func(r *http.Request)) (*httptest.Server, func())

+ func NewJobRun(job models.JobSpec) models.JobRun

+ func NewJobRunPendingBridge(job models.JobSpec) models.JobRun

+ func NewJobWithExternalInitiator(ei *models.ExternalInitiator) models.JobSpec

+ func NewJobWithFluxMonitorInitiator() models.JobSpec

+ func NewJobWithFluxMonitorInitiatorWithBridge(bridgeName string) models.JobSpec

+ func NewJobWithRandomnessLog() models.JobSpec

+ func NewKeyStore(t testing.TB, db *gorm.DB) *keystore.Master

+ func NewPeerID() p2ppeer.ID

+ func NewPipelineORM(t testing.TB, config *TestConfig, db *gorm.DB) (pipeline.ORM, postgres.EventBroadcaster, func())

+ func NewPollingDeviationChecker(t *testing.T, s *strpkg.Store, eks *keystore.Eth) *fluxmonitor.PollingDeviationChecker

+ func NewRandomInt64() int64

+ func NewRandomnessRequestLog(t *testing.T, r models.RandomnessRequestLog, emitter common.Address, blk int) types.Log

+ func NewRoundStateForRoundID(store *strpkg.Store, roundID uint32, latestSubmission *big.Int) flux_aggregator_wrapper.OracleRoundState

+ func NewRunInputWithResult(value interface{}) models.RunInput

+ func NewRunInputWithString(t testing.TB, value string) models.RunInput

+ func NewSimulatedBackendIdentity(t *testing.T) *bind.TransactOpts

+ func Random32Byte() (b [32]byte)

+ func RandomLog(t *testing.T) types.Log

+ func RawNewRoundLog(t *testing.T, contractAddr common.Address, blockHash common.Hash, ...) types.Log

+ func RawNewRoundLogWithTopics(t *testing.T, contractAddr common.Address, blockHash common.Hash, ...) types.Log

+ func RequireTxSuccessful(t testing.TB, client TransactionReceipter, txHash common.Hash) *types.Receipt

+ func SendBlocksUntilComplete(t testing.TB, store *strpkg.Store, jr models.JobRun, ...) models.JobRun

+ func SimulateIncomingHeads(t *testing.T, args SimulateIncomingHeadsArgs) (func(), chan struct{})

+ func StoredVRFKey(t *testing.T, ks *keystore.VRF) *secp256k1.PublicKey

+ func TransactionsFromGasPrices(gasPrices ...int64) []gas.Transaction

+ func UnauthenticatedPost(t testing.TB, url string, body io.Reader, headers map[string]string) (*http.Response, func())

+ func WaitForCount(t testing.TB, store *strpkg.Store, model interface{}, want int64)

+ func WaitForEthTxAttemptCount(t testing.TB, store *strpkg.Store, want int) []bulletprooftxmanager.EthTxAttempt

+ func WaitForEthTxAttemptsForEthTx(t testing.TB, store *strpkg.Store, ethTx bulletprooftxmanager.EthTx) []bulletprooftxmanager.EthTxAttempt

+ func WaitForJobRunToPendIncomingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForJobRunToPendOutgoingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForPipelineComplete(t testing.TB, nodeID int, jobID int32, expectedPipelineRuns int, ...) []pipeline.Run

+ func WaitForPipelineRuns(t testing.TB, nodeID int, jobID int32, jo job.ORM, want int, ...) []pipeline.Run

+ func WaitForSpecError(t *testing.T, store *strpkg.Store, jobID models.JobID, count int) []models.JobSpecError

+ func WaitForSpecErrorV2(t *testing.T, store *strpkg.Store, jobID int32, count int) []job.SpecError

+ type Awaiter chan struct

+ func NewAwaiter() Awaiter

+ func (a Awaiter) AssertHappened(t *testing.T, expected bool)

+ func (a Awaiter) AwaitOrFail(t testing.TB, durationParams ...time.Duration)

+ func (a Awaiter) ItHappened()

+ type Blocks struct

+ Hashes []common.Hash

+ Heads map[int64]*models.Head

+ func NewBlocks(t *testing.T, numHashes int) *Blocks

+ func (b *Blocks) ForkAt(t *testing.T, blockNum int64, numHashes int) *Blocks

+ func (b *Blocks) HashesMap() map[int64]common.Hash

+ func (b *Blocks) Head(number uint64) *models.Head

+ func (b *Blocks) LogOnBlockNum(i uint64, addr common.Address) types.Log

+ func (b *Blocks) LogOnBlockNumRemoved(i uint64, addr common.Address) types.Log

+ func (b *Blocks) LogOnBlockNumWithIndex(i uint64, logIndex uint, addr common.Address) types.Log

+ func (b *Blocks) LogOnBlockNumWithIndexRemoved(i uint64, logIndex uint, addr common.Address) types.Log

+ func (b *Blocks) LogOnBlockNumWithTopics(i uint64, logIndex uint, addr common.Address, topics []common.Hash) types.Log

type CallbackAuthenticator

+ func (a CallbackAuthenticator) AuthenticateCSAKey(*keystore.CSA, string) error

+ func (a CallbackAuthenticator) AuthenticateEthKey(ethKeyStore *keystore.Eth, pwd string) (string, error)

+ func (a CallbackAuthenticator) AuthenticateOCRKey(*keystore.OCR, *config.Config, string) error

+ func (a CallbackAuthenticator) AuthenticateVRFKey(vrfKeyStore *keystore.VRF, pwd string) error

+ type EthereumLogIterator interface

+ Next func() bool

type EventWebSocketServer

+ ReceivedBinary chan []byte

+ ReceivedText chan string

+ type ExternalInitiatorOpts struct

+ NamePrefix string

+ OutgoingSecret string

+ OutgoingToken string

+ URL *models.WebURL

type HTTPClientCleaner

+ func (r *HTTPClientCleaner) Put(path string, body io.Reader) (*http.Response, func())

+ type HeadTrackableFunc func(context.Context, models.Head)

+ func (HeadTrackableFunc) Connect(*models.Head) error

+ func (fn HeadTrackableFunc) OnNewLongestChain(ctx context.Context, head models.Head)

+ type JobPipelineV2TestHelper struct

+ Eb postgres.EventBroadcaster

+ Jrm job.ORM

+ Pr pipeline.Runner

+ Prm pipeline.ORM

+ func NewJobPipelineV2(t testing.TB, tc *TestConfig, db *gorm.DB, ethClient eth.Client, ...) JobPipelineV2TestHelper

type MockCookieAuthenticator

+ SessionID string

type MockCountingPrompter

+ T *testing.T

type MockHeadTrackable

+ func (m *MockHeadTrackable) OnNewLongestChain(context.Context, models.Head)

+ func (m *MockHeadTrackable) OnNewLongestChainCount() int32

type MockSigner

+ func (s MockSigner) SignHash(common.Hash) (models.Signature, error)

+ type SimulateIncomingHeadsArgs struct

+ BackfillDepth int64

+ Blocks *Blocks

+ EndBlock int64

+ HeadTrackables []httypes.HeadTrackable

+ Interval time.Duration

+ StartBlock int64

+ Timeout time.Duration

+ type SimulatedBackendClient struct

+ func (c *SimulatedBackendClient) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ func (c *SimulatedBackendClient) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error

+ func (c *SimulatedBackendClient) BlockByNumber(ctx context.Context, n *big.Int) (*types.Block, error)

+ func (c *SimulatedBackendClient) Call(result interface{}, method string, args ...interface{}) error

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

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

+ func (c *SimulatedBackendClient) ChainID(context.Context) (*big.Int, error)

+ func (c *SimulatedBackendClient) Close()

+ func (c *SimulatedBackendClient) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

+ func (c *SimulatedBackendClient) Dial(context.Context) error

+ func (c *SimulatedBackendClient) EstimateGas(ctx context.Context, call ethereum.CallMsg) (gas uint64, err error)

+ func (c *SimulatedBackendClient) FilterLogs(ctx context.Context, q ethereum.FilterQuery) (logs []types.Log, err error)

+ func (c *SimulatedBackendClient) GetERC20Balance(address common.Address, contractAddress common.Address) (balance *big.Int, err error)

+ func (c *SimulatedBackendClient) GetEthBalance(ctx context.Context, account common.Address, blockNumber *big.Int) (*assets.Eth, error)

+ func (c *SimulatedBackendClient) GetLINKBalance(linkAddress common.Address, address common.Address) (*assets.Link, error)

+ func (c *SimulatedBackendClient) HeadByNumber(ctx context.Context, n *big.Int) (*models.Head, error)

+ func (c *SimulatedBackendClient) HeaderByNumber(ctx context.Context, n *big.Int) (*types.Header, error)

+ func (c *SimulatedBackendClient) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ func (c *SimulatedBackendClient) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

+ func (c *SimulatedBackendClient) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

+ func (c *SimulatedBackendClient) RoundRobinBatchCallContext(ctx context.Context, b []rpc.BatchElem) error

+ func (c *SimulatedBackendClient) SendTransaction(ctx context.Context, tx *types.Transaction) error

+ func (c *SimulatedBackendClient) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, channel chan<- types.Log) (ethereum.Subscription, error)

+ func (c *SimulatedBackendClient) SubscribeNewHead(ctx context.Context, channel chan<- *models.Head) (ethereum.Subscription, error)

+ func (c *SimulatedBackendClient) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (c *SimulatedBackendClient) SuggestGasTipCap(ctx context.Context) (tipCap *big.Int, err error)

+ func (c *SimulatedBackendClient) TransactionReceipt(ctx context.Context, receipt common.Hash) (*types.Receipt, error)

type TestApplication

+ Backend *backends.SimulatedBackend

+ Key ethkey.Key

+ Logger *logger.Logger

+ Started bool

+ func NewApplicationEthereumDisabled(t *testing.T) (*TestApplication, func())

+ func NewApplicationWithConfigAndKeyOnSimulatedBlockchain(t testing.TB, tc *TestConfig, backend *backends.SimulatedBackend, ...) (app *TestApplication, cleanup func())

+ func (ta *TestApplication) MustCreateJobRun(txHashBytes []byte, blockHashBytes []byte) *models.JobRun

+ func (ta *TestApplication) MustSeedNewSession() string

+ func (ta *TestApplication) Start() error

type TestConfig

+ func NewTestConfig(t testing.TB, options ...interface{}) *TestConfig

+ type TransactionReceipter interface

+ TransactionReceipt func(context.Context, common.Hash) (*types.Receipt, error)

type TriggerClock

+ func (t *TriggerClock) TriggerWithoutTimeout()

+ func (t TriggerClock) Now() time.Time

v0

v0.6.4

Jul 24, 2019

v0.6.3

Jul 9, 2019

v0.6.2

Jun 27, 2019

v0.6.1

Jun 26, 2019

v0.6.0

Jun 25, 2019

Changes in this version

+ const APIEmail

+ const APISessionID

+ const Password

+ const RootDir

+ const SessionSecret

+ const Strict

+ const Username

+ func AllJobs(t testing.TB, store *strpkg.Store) []models.JobSpec

+ func AssertError(t testing.TB, want bool, err error)

+ func AssertServerResponse(t testing.TB, resp *http.Response, expectedStatusCode int)

+ func AssertSyncEventCountStays(t testing.TB, orm *orm.ORM, want int)

+ func AssertValidHash(t testing.TB, length int, hash string)

+ func BigHexInt(val interface{}) hexutil.Big

+ func BuildInitiatorRequests(t *testing.T, initrs []models.Initiator) []models.InitiatorRequest

+ func BuildTaskRequests(t *testing.T, initrs []models.TaskSpec) []models.TaskSpecRequest

+ func CallbackOrTimeout(t testing.TB, msg string, callback func(), durationParams ...time.Duration)

+ func CopyFile(t testing.TB, src, dst string)

+ func CreateBridgeTypeViaWeb(t testing.TB, app *TestApplication, payload string) *models.BridgeTypeAuthentication

+ func CreateHelloWorldJobViaWeb(t testing.TB, app *TestApplication, url string) models.JobSpec

+ func CreateJobRunViaWeb(t testing.TB, app *TestApplication, j models.JobSpec, body ...string) models.JobRun

+ func CreateJobRunWithStatus(t testing.TB, store *store.Store, j models.JobSpec, status models.RunStatus) models.JobRun

+ func CreateJobSpecViaWeb(t testing.TB, app *TestApplication, job models.JobSpec) models.JobSpec

+ func CreateSpecViaWeb(t testing.TB, app *TestApplication, spec string) models.JobSpec

+ func CreateTx(t testing.TB, store *strpkg.Store, from common.Address, sentAt uint64) *models.Tx

+ func DecodeSessionCookie(value string) (string, error)

+ func EmptyCLIContext() *cli.Context

+ func ExtractTargetAddressFromERC20EthEthCallMock(t *testing.T, arg ...interface{}) common.Address

+ func FindJob(t testing.TB, s *strpkg.Store, id string) models.JobSpec

+ func FindJobRun(t testing.TB, s *strpkg.Store, id string) models.JobRun

+ func FindServiceAgreement(t testing.TB, s *strpkg.Store, id string) models.ServiceAgreement

+ func FixtureCreateJobViaWeb(t *testing.T, app *TestApplication, path string) models.JobSpec

+ func FixtureCreateServiceAgreementViaWeb(t *testing.T, app *TestApplication, path string) models.ServiceAgreement

+ func GetAccountAddress(t testing.TB, store *strpkg.Store) common.Address

+ func GetAccountAddresses(store *strpkg.Store) []common.Address

+ func GetLastTxAttempt(t testing.TB, store *strpkg.Store) models.TxAttempt

+ func Head(val interface{}) *models.Head

+ func Int(val interface{}) *models.Big

+ func JSONFromBytes(t testing.TB, body []byte) models.JSON

+ func JSONFromFixture(t *testing.T, path string) models.JSON

+ func JSONFromString(t testing.TB, body string, args ...interface{}) models.JSON

+ func JSONResultFromFixture(t *testing.T, path string) models.JSON

+ func JobRunStays(t testing.TB, store *strpkg.Store, jr models.JobRun, status models.RunStatus, ...) models.JobRun

+ func JobRunStaysPendingConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func LogFromFixture(t *testing.T, path string) models.Log

+ func MarkJobRunPendingBridge(jr models.JobRun, i int) models.JobRun

+ func MustAllJobsWithStatus(t testing.TB, store *strpkg.Store, statuses ...models.RunStatus) []*models.JobRun

+ func MustGenerateSessionCookie(value string) *http.Cookie

+ func MustJSONDel(t *testing.T, json, path string) string

+ func MustJSONSet(t *testing.T, json, path string, value interface{}) string

+ func MustParseDuration(t testing.TB, durationStr string) time.Duration

+ func MustParseURL(input string) *url.URL

+ func MustReadFile(t testing.TB, file string) []byte

+ func MustSha256(in string) string

+ func MustUser(email, pwd string) models.User

+ func NewAddress() common.Address

+ func NewBigHexInt(val interface{}) *hexutil.Big

+ func NewBlockHeader(number int) *models.BlockHeader

+ func NewBridgeType(t testing.TB, info ...string) (*models.BridgeTypeAuthentication, *models.BridgeType)

+ func NewHTTPMockServer(t *testing.T, status int, wantMethod string, response string, ...) (*httptest.Server, func())

+ func NewHash() common.Hash

+ func NewJob() models.JobSpec

+ func NewJobRunner(s *strpkg.Store) (services.JobRunner, func())

+ func NewJobSubscriber(t testing.TB) (*strpkg.Store, services.JobSubscriber, func())

+ func NewJobWithLogInitiator() models.JobSpec

+ func NewJobWithRunAtInitiator(t time.Time) models.JobSpec

+ func NewJobWithRunLogInitiator() models.JobSpec

+ func NewJobWithSALogInitiator() models.JobSpec

+ func NewJobWithSchedule(sched string) models.JobSpec

+ func NewJobWithWebInitiator() models.JobSpec

+ func NewMockAuthenticatedHTTPClient(cfg store.Config) cmd.HTTPClient

+ func NewRunLog(t *testing.T, jobID string, emitter common.Address, requester common.Address, ...) models.Log

+ func NewServiceAgreementExecutionLog(t *testing.T, jobID string, logEmitter common.Address, ...) models.Log

+ func NewSession(optionalSessionID ...string) models.Session

+ func NewStore(t testing.TB) (*strpkg.Store, func())

+ func NewStoreWithConfig(config *TestConfig) (*strpkg.Store, func())

+ func NewTask(t *testing.T, taskType string, json ...string) models.TaskSpec

+ func NewTx(from common.Address, sentAt uint64) *models.Tx

+ func NewWSServer(msg string) (*httptest.Server, func())

+ func NormalizedJSON(t testing.TB, input []byte) string

+ func NullString(val interface{}) null.String

+ func NullTime(t testing.TB, val interface{}) null.Time

+ func NullableTime(t time.Time) null.Time

+ func ObserveLogs() *observer.ObservedLogs

+ func ParseISO8601(t testing.TB, s string) time.Time

+ func ParseJSON(t testing.TB, body io.Reader) models.JSON

+ func ParseJSONAPIErrors(t testing.TB, body io.Reader) *models.JSONAPIErrors

+ func ParseJSONAPIResponse(t testing.TB, resp *http.Response, resource interface{}) error

+ func ParseJSONAPIResponseMeta(input []byte) (map[string]*json.RawMessage, error)

+ func ParseJSONAPIResponseMetaCount(input []byte) (int, error)

+ func ParseNullableTime(t testing.TB, s string) null.Time

+ func ParseResponseBody(t testing.TB, resp *http.Response) []byte

+ func ReadLogs(app *TestApplication) (string, error)

+ func RunResultWithData(val string) models.RunResult

+ func RunResultWithDataAndLinkPayout(val string, amt *assets.Link) models.RunResult

+ func RunResultWithError(err error) models.RunResult

+ func RunResultWithResult(val string) models.RunResult

+ func ServiceAgreementFromString(str string) (models.ServiceAgreement, error)

+ func StringToHash(s string) common.Hash

+ func StringToVersionedLogData0(t *testing.T, internalID, str string) []byte

+ func StringToVersionedLogData20190123withFulfillmentParams(t *testing.T, internalID, str string) []byte

+ func StringToVersionedLogData20190207withoutIndexes(t *testing.T, internalID string, requester common.Address, str string) []byte

+ func TxReceiptFromFixture(t *testing.T, path string) models.TxReceipt

+ func UnauthenticatedPatch(t testing.TB, url string, body io.Reader, headers map[string]string) (*http.Response, func())

+ func UpdateJobRunViaWeb(t testing.TB, app *TestApplication, jr models.JobRun, ...) models.JobRun

+ func WaitForJobRunStatus(t testing.TB, store *strpkg.Store, jr models.JobRun, status models.RunStatus) models.JobRun

+ func WaitForJobRunToComplete(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForJobRunToPendBridge(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForJobRunToPendConfirmations(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForJobRunToPendSleep(t testing.TB, store *strpkg.Store, jr models.JobRun) models.JobRun

+ func WaitForJobs(t testing.TB, store *strpkg.Store, want int) []models.JobSpec

+ func WaitForRuns(t testing.TB, j models.JobSpec, store *strpkg.Store, want int) []models.JobRun

+ func WaitForRunsAtLeast(t testing.TB, j models.JobSpec, store *strpkg.Store, want int)

+ func WaitForSyncEventCount(t testing.TB, orm *orm.ORM, want int)

+ func WaitForTxAttemptCount(t testing.TB, store *strpkg.Store, want int) []models.TxAttempt

+ func WebURL(t testing.TB, unparsed string) models.WebURL

+ func WipePostgresDatabase(c strpkg.Config)

+ type BlockedRunner struct

+ Done chan struct{}

+ func (r BlockedRunner) Run(app services.Application) error

+ type CallbackAuthenticator struct

+ Callback func(*store.Store, string) (string, error)

+ func (a CallbackAuthenticator) Authenticate(store *store.Store, pwd string) (string, error)

+ type CommonJSON struct

+ Digest string

+ ID string

+ Name string

+ func ParseCommonJSON(t testing.TB, body io.Reader) CommonJSON

+ type EmptyRunner struct

+ func (r EmptyRunner) Run(app services.Application) error

+ type ErrorsJSON struct

+ Errors []string

+ func ParseErrorsJSON(t testing.TB, body io.Reader) ErrorsJSON

+ type EthMock struct

+ Responses []MockResponse

+ Subscriptions []MockSubscription

+ func MockEthOnStore(t testing.TB, s *store.Store, flags ...string) *EthMock

+ func (mock *EthMock) AllCalled() bool

+ func (mock *EthMock) AssertAllCalled()

+ func (mock *EthMock) Call(result interface{}, method string, args ...interface{}) error

+ func (mock *EthMock) Clear()

+ func (mock *EthMock) Context(context string, callback func(*EthMock))

+ func (mock *EthMock) Dial(url string) (store.CallerSubscriber, error)

+ func (mock *EthMock) EthSubscribe(ctx context.Context, channel interface{}, args ...interface{}) (models.EthSubscription, error)

+ func (mock *EthMock) EventuallyAllCalled(t *testing.T)

+ func (mock *EthMock) NoMagic()

+ func (mock *EthMock) Register(method string, response interface{}, ...)

+ func (mock *EthMock) RegisterError(method, errMsg string)

+ func (mock *EthMock) RegisterNewHead(blockNumber int64) chan models.BlockHeader

+ func (mock *EthMock) RegisterNewHeads() chan models.BlockHeader

+ func (mock *EthMock) RegisterSubscription(name string, channels ...interface{}) MockSubscription

+ func (mock *EthMock) Remaining() string

+ func (mock *EthMock) ShouldCall(setup func(mock *EthMock)) ethMockDuring

+ type EventWebSocketServer struct

+ Connected chan struct{}

+ Received chan string

+ URL *url.URL

+ func NewEventWebSocketServer(t *testing.T) (*EventWebSocketServer, func())

+ func (wss *EventWebSocketServer) Broadcast(message string) error

+ func (wss *EventWebSocketServer) WriteCloseMessage()

+ type HTTPClientCleaner struct

+ HTTPClient cmd.HTTPClient

+ func (r *HTTPClientCleaner) Delete(path string) (*http.Response, func())

+ func (r *HTTPClientCleaner) Get(path string, headers ...map[string]string) (*http.Response, func())

+ func (r *HTTPClientCleaner) Patch(path string, body io.Reader, headers ...map[string]string) (*http.Response, func())

+ func (r *HTTPClientCleaner) Post(path string, body io.Reader) (*http.Response, func())

+ type InstanceAppFactory struct

+ App services.Application

+ func (f InstanceAppFactory) NewApplication(config store.Config, onConnectCallbacks ...func(services.Application)) services.Application

+ type InstantClock struct

+ func (InstantClock) After(_ time.Duration) <-chan time.Time

+ func (InstantClock) Now() time.Time

+ type MockAPIInitializer struct

+ Count int

+ func (m *MockAPIInitializer) Initialize(store *store.Store) (models.User, error)

+ type MockChangePasswordPrompter struct

+ func (m MockChangePasswordPrompter) Prompt() (models.ChangePasswordRequest, error)

+ type MockCookieAuthenticator struct

+ Error error

+ func (m MockCookieAuthenticator) Authenticate(models.SessionRequest) (*http.Cookie, error)

+ func (m MockCookieAuthenticator) Cookie() (*http.Cookie, error)

+ type MockCountingPrompter struct

+ Count int

+ EnteredStrings []string

+ NotTerminal bool

+ func (p *MockCountingPrompter) IsTerminal() bool

+ func (p *MockCountingPrompter) PasswordPrompt(string) string

+ func (p *MockCountingPrompter) Prompt(string) string

+ type MockCron struct

+ Entries []MockCronEntry

+ func NewMockCron() *MockCron

+ func (*MockCron) Start()

+ func (*MockCron) Stop()

+ func (mc *MockCron) AddFunc(schd string, fn func()) error

+ func (mc *MockCron) RunEntries()

+ type MockCronEntry struct

+ Function func()

+ Schedule string

+ type MockHeadTrackable struct

+ ConnectedCallback func(bn *models.Head)

+ func (m *MockHeadTrackable) Connect(bn *models.Head) error

+ func (m *MockHeadTrackable) ConnectedCount() int32

+ func (m *MockHeadTrackable) Disconnect()

+ func (m *MockHeadTrackable) DisconnectedCount() int32

+ func (m *MockHeadTrackable) OnNewHead(*models.Head)

+ func (m *MockHeadTrackable) OnNewHeadCount() int32

+ type MockPasswordPrompter struct

+ Password string

+ func (m MockPasswordPrompter) Prompt() string

+ type MockResponse struct

+ type MockRunChannel struct

+ Runs []models.RunResult

+ func NewMockRunChannel() *MockRunChannel

+ func (m *MockRunChannel) Close()

+ func (m *MockRunChannel) Receive() <-chan store.RunRequest

+ func (m *MockRunChannel) Send(jobRunID string) error

+ type MockSessionRequestBuilder struct

+ Count int

+ Error error

+ func (m *MockSessionRequestBuilder) Build(string) (models.SessionRequest, error)

+ type MockSigner struct

+ func (s MockSigner) Sign(input []byte) (models.Signature, error)

+ type MockSubscription struct

+ Errors chan error

+ func EmptyMockSubscription() MockSubscription

+ func (mes MockSubscription) Err() <-chan error

+ func (mes MockSubscription) Unsubscribe()

+ type NeverClock struct

+ func (NeverClock) After(_ time.Duration) <-chan time.Time

+ func (NeverClock) Now() time.Time

+ type NeverSleeper struct

+ func (ns NeverSleeper) After() time.Duration

+ func (ns NeverSleeper) Duration() time.Duration

+ func (ns NeverSleeper) Reset()

+ func (ns NeverSleeper) Sleep()

+ type RendererMock struct

+ Renders []interface{}

+ func (rm *RendererMock) Render(v interface{}) error

+ type SettableClock struct

+ func UseSettableClock(s *store.Store) *SettableClock

+ func (*SettableClock) After(_ time.Duration) <-chan time.Time

+ func (clock *SettableClock) Now() time.Time

+ func (clock *SettableClock) SetTime(t time.Time)

+ type TestApplication struct

+ Config strpkg.Config

+ Server *httptest.Server

+ func NewApplication(t testing.TB) (*TestApplication, func())

+ func NewApplicationWithConfig(t testing.TB, tc *TestConfig) (*TestApplication, func())

+ func NewApplicationWithConfigAndKey(t testing.TB, tc *TestConfig) (*TestApplication, func())

+ func NewApplicationWithKey(t testing.TB) (*TestApplication, func())

+ func (ta *TestApplication) AddUnlockedKey()

+ func (ta *TestApplication) ImportKey(content string)

+ func (ta *TestApplication) InstantClock() InstantClock

+ func (ta *TestApplication) MockEthClient(flags ...string) *EthMock

+ func (ta *TestApplication) MockStartAndConnect() (*EthMock, error)

+ func (ta *TestApplication) MustSeedUserSession() models.User

+ func (ta *TestApplication) NewAuthenticatingClient(prompter cmd.Prompter) *cmd.Client

+ func (ta *TestApplication) NewBox() packr.Box

+ func (ta *TestApplication) NewClientAndRenderer() (*cmd.Client, *RendererMock)

+ func (ta *TestApplication) NewHTTPClient() HTTPClientCleaner

+ func (ta *TestApplication) StartAndConnect() error

+ func (ta *TestApplication) Stop() error

+ func (ta *TestApplication) WaitForConnection() error

+ type TestConfig struct

+ func NewConfig(t testing.TB) (*TestConfig, func())

+ func NewConfigWithWSServer(t testing.TB, wsserver *httptest.Server) *TestConfig

+ func (tc *TestConfig) SetEthereumServer(wss *httptest.Server)

+ type TriggerClock struct

+ func NewTriggerClock() *TriggerClock

+ func (t *TriggerClock) After(_ time.Duration) <-chan time.Time

+ func (t *TriggerClock) Trigger()

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