common

package
v0.35.5 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PROVIDER  string = "provider_"
	CONSUMER  string = "consumer_"
	VALIDATOR string = "validator_"
	DEVELOPER string = "developer_"
)

Variables

This section is empty.

Functions

func BuildRelayRequest 

func BuildRelayRequest(ctx context.Context, provider string, contentHash []byte, cuSum uint64, spec string, qos *types.QualityOfServiceReport) *types.RelaySession

func BuildRelayRequestWithBadge 

func BuildRelayRequestWithBadge(ctx context.Context, provider string, contentHash []byte, sessionId uint64, cuSum uint64, spec string, qos *types.QualityOfServiceReport, badge *types.Badge) *types.RelaySession

func BuildRelayRequestWithSession 

func BuildRelayRequestWithSession(ctx context.Context, provider string, contentHash []byte, sessionId uint64, cuSum uint64, spec string, qos *types.QualityOfServiceReport) *types.RelaySession

func BuySubscription 

func BuySubscription(ctx context.Context, keepers testkeeper.Keepers, servers testkeeper.Servers, acc sigs.Account, plan string)

func CreateMockPlan 

func CreateMockPlan() plantypes.Plan

func CreateMockPolicy 

func CreateMockPolicy() plantypes.Policy

func CreateMockSpec 

func CreateMockSpec() spectypes.Spec

func CreateMsgDetectionTest 

func CreateMsgDetectionTest(ctx context.Context, consumer, provider0, provider1 sigs.Account, spec spectypes.Spec) (detectionMsg *conflicttypes.MsgDetection, reply1, reply2 *types.RelayReply, errRet error)

func CreateNewAccount 

func CreateNewAccount(ctx context.Context, keepers testkeeper.Keepers, balance int64) (acc sigs.Account)

func NewCoin 

func NewCoin(tokenDenom string, amount int64) sdk.Coin

func NewCoins 

func NewCoins(tokenDenom string, amount ...int64) []sdk.Coin

func StakeAccount 

func StakeAccount(t *testing.T, ctx context.Context, keepers testkeeper.Keepers, servers testkeeper.Servers, acc sigs.Account, spec spectypes.Spec, stake int64, validator sigs.Account)

Types

type Tester 

type Tester struct {
	T *testing.T

	GoCtx   context.Context
	Ctx     sdk.Context
	Servers *testkeeper.Servers
	Keepers *testkeeper.Keepers
	// contains filtered or unexported fields
}

func NewTester 

func NewTester(t *testing.T) *Tester

func NewTesterRaw 

func NewTesterRaw(t *testing.T) *Tester

func (*Tester) Account 

func (ts *Tester) Account(name string) (sigs.Account, string)

func (*Tester) AccountByAddr 

func (ts *Tester) AccountByAddr(addr string) (sigs.Account, string)

func (*Tester) Accounts 

func (ts *Tester) Accounts(name string) []sigs.Account

func (*Tester) AccountsMap 

func (ts *Tester) AccountsMap() map[string]sigs.Account

func (*Tester) AddAccount 

func (ts *Tester) AddAccount(kind string, idx int, balance int64) (sigs.Account, string)

func (*Tester) AddPlan 

func (ts *Tester) AddPlan(name string, plan planstypes.Plan) *Tester

func (*Tester) AddPolicy 

func (ts *Tester) AddPolicy(name string, policy planstypes.Policy) *Tester

func (*Tester) AddProjectData 

func (ts *Tester) AddProjectData(name string, pd projectstypes.ProjectData) *Tester

func (*Tester) AddSpec 

func (ts *Tester) AddSpec(name string, spec spectypes.Spec) *Tester

func (*Tester) AdvanceBlock 

func (ts *Tester) AdvanceBlock(delta ...time.Duration) *Tester

func (*Tester) AdvanceBlockUntilStale 

func (ts *Tester) AdvanceBlockUntilStale(delta ...time.Duration) *Tester

func (*Tester) AdvanceBlocks 

func (ts *Tester) AdvanceBlocks(count uint64, delta ...time.Duration) *Tester

func (*Tester) AdvanceEpoch 

func (ts *Tester) AdvanceEpoch(delta ...time.Duration) *Tester

func (*Tester) AdvanceEpochUntilStale 

func (ts *Tester) AdvanceEpochUntilStale(delta ...time.Duration) *Tester

func (*Tester) AdvanceEpochs 

func (ts *Tester) AdvanceEpochs(count uint64, delta ...time.Duration) *Tester

func (*Tester) AdvanceMonths 

func (ts *Tester) AdvanceMonths(months int) *Tester

AdvanceMonth advanced blocks by given months, like AdvanceMonthsFrom, starting from the current block's timestamp

func (*Tester) AdvanceMonthsFrom 

func (ts *Tester) AdvanceMonthsFrom(from time.Time, months int) *Tester

AdvanceMonthFrom advanced blocks by given months, i.e. until block times exceeds at least that many months since the from argument (minus 5 seconds, so caller can control when to cross the desired time).

func (*Tester) AdvanceToBlock 

func (ts *Tester) AdvanceToBlock(block uint64)

func (*Tester) BlockHeight 

func (ts *Tester) BlockHeight() uint64

func (*Tester) BlockTime 

func (ts *Tester) BlockTime() time.Time

func (*Tester) BlocksToSave 

func (ts *Tester) BlocksToSave() uint64

func (*Tester) BondDenom 

func (ts *Tester) BondDenom() string

func (*Tester) ChangeDelegationTimestamp 

func (ts *Tester) ChangeDelegationTimestamp(provider, delegator, chainID string, block uint64, timestamp int64) error

func (*Tester) DisableParticipationFees 

func (ts *Tester) DisableParticipationFees()

DisableParticipationFees zeros validators and community participation fees

func (*Tester) EpochBlocks 

func (ts *Tester) EpochBlocks(block ...uint64) uint64

func (*Tester) EpochStart 

func (ts *Tester) EpochStart(block ...uint64) uint64

func (*Tester) EpochsToSave 

func (ts *Tester) EpochsToSave(block ...uint64) uint64

func (*Tester) FindPlan 

func (ts *Tester) FindPlan(index string, block uint64) (planstypes.Plan, bool)

func (*Tester) GetAccount 

func (ts *Tester) GetAccount(kind string, idx int) (sigs.Account, string)

func (*Tester) GetBalance 

func (ts *Tester) GetBalance(accAddr sdk.AccAddress) int64

func (*Tester) GetNextEpoch 

func (ts *Tester) GetNextEpoch() uint64

func (*Tester) GetNextMonth 

func (ts *Tester) GetNextMonth(from time.Time) int64

func (*Tester) GetPlanFromSubscription 

func (ts *Tester) GetPlanFromSubscription(addr string, block uint64) (planstypes.Plan, error)

func (*Tester) GetProjectDeveloperData 

func (ts *Tester) GetProjectDeveloperData(devkey string, block uint64) (projectstypes.ProtoDeveloperData, error)

func (*Tester) GetProjectForBlock 

func (ts *Tester) GetProjectForBlock(projectID string, block uint64) (projectstypes.Project, error)

func (*Tester) GetProjectForDeveloper 

func (ts *Tester) GetProjectForDeveloper(devkey string, block uint64) (projectstypes.Project, error)

func (*Tester) GetValidator 

func (ts *Tester) GetValidator(addr sdk.AccAddress) stakingtypes.Validator

GetValidator gets a validator object Usually, you get the account of your created validator with ts.GetAccount so input valAcc.addr to this function

func (*Tester) ModifyPlan 

func (ts *Tester) ModifyPlan(name string, plan planstypes.Plan) *Tester

func (*Tester) Plan 

func (ts *Tester) Plan(name string) planstypes.Plan

func (*Tester) Policy 

func (ts *Tester) Policy(name string) planstypes.Policy

func (*Tester) ProjectData 

func (ts *Tester) ProjectData(name string) projectstypes.ProjectData

func (*Tester) QueryDualstakingDelegatorProviders 

func (ts *Tester) QueryDualstakingDelegatorProviders(delegator string, withPending bool) (*dualstakingtypes.QueryDelegatorProvidersResponse, error)

QueryPairingVerifyPairing implements 'q dualstaking delegator-providers'

func (*Tester) QueryDualstakingDelegatorRewards 

func (ts *Tester) QueryDualstakingDelegatorRewards(delegator string, provider string, chainID string) (*dualstakingtypes.QueryDelegatorRewardsResponse, error)

QueryDualstakingDelegatorRewards implements 'q dualstaking delegator-rewards'

func (*Tester) QueryDualstakingProviderDelegators 

func (ts *Tester) QueryDualstakingProviderDelegators(provider string, withPending bool) (*dualstakingtypes.QueryProviderDelegatorsResponse, error)

QueryDualstakingProviderDelegators implements 'q dualstaking provider-delegators'

func (*Tester) QueryFixationAllIndices 

func (ts *Tester) QueryFixationAllIndices(storeKey string, prefix string) (*fixationstoretypes.QueryAllIndicesResponse, error)

QueryFixationAllIndices implements 'q fixationstore all-indices'

func (*Tester) QueryFixationEntry 

func (ts *Tester) QueryFixationEntry(storeKey string, prefix string, key string, block uint64, hideData bool, stringData bool) (*fixationstoretypes.QueryEntryResponse, error)

QueryFixationEntry implements 'q fixationstore entry'

func (*Tester) QueryFixationVersions 

func (ts *Tester) QueryFixationVersions(storeKey string, prefix string, key string) (*fixationstoretypes.QueryVersionsResponse, error)

QueryFixationVersions implements 'q fixationstore versions'

func (*Tester) QueryPairingEffectivePolicy 

func (ts *Tester) QueryPairingEffectivePolicy(chainID, consumer string) (*pairingtypes.QueryEffectivePolicyResponse, error)

QueryPairingEffectivePolicy implements 'q pairing effective-policy'

func (*Tester) QueryPairingGetPairing 

func (ts *Tester) QueryPairingGetPairing(chainID, client string) (*pairingtypes.QueryGetPairingResponse, error)

QueryPairingGetPairing implements 'q pairing get-pairing'

func (*Tester) QueryPairingListEpochPayments 

func (ts *Tester) QueryPairingListEpochPayments() (*pairingtypes.QueryAllEpochPaymentsResponse, error)

QueryPairingListEpochPayments implements 'q pairing list-epoch-payments'

func (*Tester) QueryPairingProviderMonthlyPayout 

func (ts *Tester) QueryPairingProviderMonthlyPayout(provider string) (*pairingtypes.QueryProviderMonthlyPayoutResponse, error)

QueryPairingProviderMonthlyPayout implements 'q pairing provider-monthly-payout'

func (*Tester) QueryPairingProviders 

func (ts *Tester) QueryPairingProviders(chainID string, frozen bool) (*pairingtypes.QueryProvidersResponse, error)

QueryPairingProviders: implement 'q pairing providers'

func (*Tester) QueryPairingSubscriptionMonthlyPayout 

func (ts *Tester) QueryPairingSubscriptionMonthlyPayout(consumer string) (*pairingtypes.QuerySubscriptionMonthlyPayoutResponse, error)

QueryPairingSubscriptionMonthlyPayout implements 'q pairing subscription-monthly-payout'

func (*Tester) QueryPairingVerifyPairing 

func (ts *Tester) QueryPairingVerifyPairing(chainID, client, provider string, block uint64) (*pairingtypes.QueryVerifyPairingResponse, error)

QueryPairingVerifyPairing implements 'q pairing verfy-pairing'

func (*Tester) QueryProjectDeveloper 

func (ts *Tester) QueryProjectDeveloper(devkey string) (*projectstypes.QueryDeveloperResponse, error)

QueryProjectDeveloper implements 'q project developer'

func (*Tester) QueryProjectInfo 

func (ts *Tester) QueryProjectInfo(projectID string) (*projectstypes.QueryInfoResponse, error)

QueryProjectInfo implements 'q project info'

func (*Tester) QueryRewardsBlockReward 

func (ts *Tester) QueryRewardsBlockReward() (*rewardstypes.QueryBlockRewardResponse, error)

QueryRewardsBlockReward implements 'q rewards block-reward'

func (*Tester) QueryRewardsPools 

func (ts *Tester) QueryRewardsPools() (*rewardstypes.QueryPoolsResponse, error)

QueryRewardsPools implements 'q rewards pools'

func (*Tester) QueryRewardsProviderReward 

func (ts *Tester) QueryRewardsProviderReward(chainID string, provider string) (*rewardstypes.QueryProviderRewardResponse, error)

QueryRewardsProviderReward implements 'q rewards provider-reward'

func (*Tester) QueryStoreKeys 

func (ts *Tester) QueryStoreKeys() (*fixationstoretypes.QueryStoreKeysResponse, error)

QueryStoreKeys implements 'q fixationstore store-keys'

func (*Tester) QuerySubscriptionCurrent 

func (ts *Tester) QuerySubscriptionCurrent(subkey string) (*subscriptiontypes.QueryCurrentResponse, error)

QuerySubscriptionCurrent: implement 'q subscription current'

func (*Tester) QuerySubscriptionListProjects 

func (ts *Tester) QuerySubscriptionListProjects(subkey string) (*subscriptiontypes.QueryListProjectsResponse, error)

QuerySubscriptionListProjects: implement 'q subscription list-projects'

func (*Tester) QuerySubscriptionNextToMonthExpiry 

func (ts *Tester) QuerySubscriptionNextToMonthExpiry() (*subscriptiontypes.QueryNextToMonthExpiryResponse, error)

QuerySubscriptionNextToMonthExpiry: implement 'q subscription next-to-month-expiry'

func (*Tester) SendRelay 

func (ts *Tester) SendRelay(provider string, clientAcc sigs.Account, chainIDs []string, cuSum uint64) pairingtypes.MsgRelayPayment

func (*Tester) SetChainID 

func (ts *Tester) SetChainID(chainID string)

func (*Tester) SetupAccounts 

func (ts *Tester) SetupAccounts(numSub, numAdm, numDev int) *Tester

func (*Tester) SetupForTests 

func (ts *Tester) SetupForTests(getToTopMostPath string, specId string, validators int, subscriptions int, projectsInSubscription int, providers int) error

func (*Tester) SlashValidator 

func (ts *Tester) SlashValidator(valAcc sigs.Account, fraction math.LegacyDec, power int64, block int64) math.Int

SlashValidator slashes a validator and returns the expected amount of burned tokens (of the validator). Usually, you get the account of your created validator with ts.GetAccount, so input valAcc to this function

func (*Tester) Spec 

func (ts *Tester) Spec(name string) spectypes.Spec

func (*Tester) StakeProvider 

func (ts *Tester) StakeProvider(addr string, spec spectypes.Spec, amount int64) error

func (*Tester) StakeProviderExtra 

func (ts *Tester) StakeProviderExtra(
	addr string,
	spec spectypes.Spec,
	amount int64,
	endpoints []epochstoragetypes.Endpoint,
	geoloc int32,
	moniker string,
) error

func (*Tester) TokenDenom 

func (ts *Tester) TokenDenom() string

func (*Tester) TxCancelUnbondValidator 

func (ts *Tester) TxCancelUnbondValidator(delegator, validator sigs.Account, block int64, amount sdk.Coin) (*stakingtypes.MsgCancelUnbondingDelegationResponse, error)

TxUnbondValidator: implement 'tx staking undond'

func (*Tester) TxCreateValidator 

func (ts *Tester) TxCreateValidator(validator sigs.Account, amount math.Int)

TxCreateValidator: implement 'tx staking createvalidator' and bond its tokens

func (*Tester) TxDelegateValidator 

func (ts *Tester) TxDelegateValidator(delegator, validator sigs.Account, amount math.Int) (*stakingtypes.MsgDelegateResponse, error)

TxDelegateValidator: implement 'tx staking delegate'

func (*Tester) TxDualstakingClaimRewards 

func (ts *Tester) TxDualstakingClaimRewards(
	creator string,
	provider string,
) (*dualstakingtypes.MsgClaimRewardsResponse, error)

TxDualstakingClaimRewards: implement 'tx dualstaking claim-rewards'

func (*Tester) TxDualstakingDelegate 

func (ts *Tester) TxDualstakingDelegate(
	creator string,
	provider string,
	chainID string,
	amount sdk.Coin,
) (*dualstakingtypes.MsgDelegateResponse, error)

TxDualstakingDelegate: implement 'tx dualstaking delegate'

func (*Tester) TxDualstakingDelegateValidator 

func (ts *Tester) TxDualstakingDelegateValidator(
	creator string,
	validator string,
	provider string,
	chainID string,
	amount sdk.Coin,
) (*dualstakingtypes.MsgDelegateResponse, error)

TxDualstakingDelegate: implement 'tx dualstaking delegate'

func (*Tester) TxDualstakingRedelegate 

func (ts *Tester) TxDualstakingRedelegate(
	creator string,
	fromProvider string,
	toProvider string,
	fromChainID string,
	toChainID string,
	amount sdk.Coin,
) (*dualstakingtypes.MsgRedelegateResponse, error)

TxDualstakingDelegate: implement 'tx dualstaking delegate'

func (*Tester) TxDualstakingUnbond 

func (ts *Tester) TxDualstakingUnbond(
	creator string,
	provider string,
	chainID string,
	amount sdk.Coin,
) (*dualstakingtypes.MsgUnbondResponse, error)

TxDualstakingUnbond: implement 'tx dualstaking unbond'

func (*Tester) TxDualstakingUnbondValidator 

func (ts *Tester) TxDualstakingUnbondValidator(
	creator string,
	validator string,
	provider string,
	chainID string,
	amount sdk.Coin,
) (*dualstakingtypes.MsgUnbondResponse, error)

TxDualstakingUnbond: implement 'tx dualstaking unbond'

func (*Tester) TxPairingFreezeProvider 

func (ts *Tester) TxPairingFreezeProvider(addr, chainID string) (*pairingtypes.MsgFreezeProviderResponse, error)

TxPairingFreezeProvider: implement 'tx pairing freeze'

func (*Tester) TxPairingRelayPayment 

func (ts *Tester) TxPairingRelayPayment(addr string, rs ...*pairingtypes.RelaySession) (*pairingtypes.MsgRelayPaymentResponse, error)

TxPairingRelayPayment: implement 'tx pairing relay-payment'

func (*Tester) TxPairingStakeProvider 

func (ts *Tester) TxPairingStakeProvider(
	addr string,
	chainID string,
	amount sdk.Coin,
	endpoints []epochstoragetypes.Endpoint,
	geoloc int32,
	moniker string,
) (*pairingtypes.MsgStakeProviderResponse, error)

TxPairingStakeProvider: implement 'tx pairing stake-provider'

func (*Tester) TxPairingUnfreezeProvider 

func (ts *Tester) TxPairingUnfreezeProvider(addr, chainID string) (*pairingtypes.MsgUnfreezeProviderResponse, error)

TxPairingUnfreezeProvider: implement 'tx pairing unfreeze'

func (*Tester) TxPairingUnstakeProvider 

func (ts *Tester) TxPairingUnstakeProvider(
	addr string,
	chainID string,
) (*pairingtypes.MsgUnstakeProviderResponse, error)

TxPairingUnstakeProvider: implement 'tx pairing unstake-provider'

func (*Tester) TxProjectAddKeys 

func (ts *Tester) TxProjectAddKeys(projectID, creator string, projectKeys ...projectstypes.ProjectKey) error

TxProjectAddKeys: implement 'tx project add-keys'

func (*Tester) TxProjectDelKeys 

func (ts *Tester) TxProjectDelKeys(projectID, creator string, projectKeys ...projectstypes.ProjectKey) error

TxProjectDelKeys: implement 'tx project del-keys'

func (*Tester) TxProjectSetPolicy 

func (ts *Tester) TxProjectSetPolicy(projectID, subkey string, policy *planstypes.Policy) (*projectstypes.MsgSetPolicyResponse, error)

TxProjectSetPolicy: implement 'tx project set-policy'

func (*Tester) TxProjectSetSubscriptionPolicy 

func (ts *Tester) TxProjectSetSubscriptionPolicy(projectID, subkey string, policy *planstypes.Policy) (*projectstypes.MsgSetSubscriptionPolicyResponse, error)

TxProjectSetSubscriptionPolicy: implement 'tx project set-subscription-policy'

func (*Tester) TxProposalAddPlans 

func (ts *Tester) TxProposalAddPlans(plans ...planstypes.Plan) error

func (*Tester) TxProposalAddSpecs 

func (ts *Tester) TxProposalAddSpecs(specs ...spectypes.Spec) error

func (*Tester) TxProposalChangeParam 

func (ts *Tester) TxProposalChangeParam(module, paramKey, paramVal string) error

func (*Tester) TxProposalDelPlans 

func (ts *Tester) TxProposalDelPlans(indices ...string) error

func (*Tester) TxReDelegateValidator 

func (ts *Tester) TxReDelegateValidator(delegator, fromValidator, toValidator sigs.Account, amount math.Int) (*stakingtypes.MsgBeginRedelegateResponse, error)

TxReDelegateValidator: implement 'tx staking redelegate'

func (*Tester) TxSubscriptionAddProject 

func (ts *Tester) TxSubscriptionAddProject(creator string, pd projectstypes.ProjectData) error

TxSubscriptionAddProject: implement 'tx subscription add-project'

func (*Tester) TxSubscriptionAutoRenewal 

func (ts *Tester) TxSubscriptionAutoRenewal(creator, consumer, planIndex string, enable bool) error

TxSubscriptionAutoRenewal: implement 'tx subscription auto-renewal'

func (*Tester) TxSubscriptionBuy 

func (ts *Tester) TxSubscriptionBuy(creator, consumer, plan string, months int, autoRenewal, advancePurchase bool) (*subscriptiontypes.MsgBuyResponse, error)

TxSubscriptionBuy: implement 'tx subscription buy'

func (*Tester) TxSubscriptionDelProject 

func (ts *Tester) TxSubscriptionDelProject(creator, projectName string) error

TxSubscriptionDelProject: implement 'tx subscription del-project'

func (*Tester) TxUnbondValidator 

func (ts *Tester) TxUnbondValidator(delegator, validator sigs.Account, amount math.Int) (*stakingtypes.MsgUndelegateResponse, error)

TxUnbondValidator: implement 'tx staking undond'

func (*Tester) VotePeriod 

func (ts *Tester) VotePeriod() uint64

Source Files

View all Source files

Directories

Path Synopsis

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.