integrationtests

Documentation

Index

• func ConvertOperationsToBase64XDR(operations []txnbuild.Operation) ([]string, error)
• func RenderResult(useCase *UseCase) string
• func SCAccountID(address string) (xdr.ScAddress, error)
• func WaitForRPCHealthAndRun(ctx context.Context, rpcService services.RPCService, timeout time.Duration, ...) error
• func WaitForTransactionConfirmation(ctx context.Context, rpcService services.RPCService, hash string, ...) (txResult entities.RPCGetTransactionResult, err error)
• type Fixtures
  • func (f *Fixtures) PrepareUseCases(ctx context.Context) ([]*UseCase, error)
• type IntegrationTests
  • func NewIntegrationTests(ctx context.Context, opts IntegrationTestsOptions) (*IntegrationTests, error)
  • func (it *IntegrationTests) Run(ctx context.Context) error
• type IntegrationTestsOptions
  • func (o *IntegrationTestsOptions) Validate() error
• type Set
  • func NewSet[T comparable](values ...T) *Set[T]
  • func (s *Set[T]) Add(value T)
  • func (s *Set[T]) Slice() []T
• type UseCase
  • func (u *UseCase) Name() string

Functions

func ConvertOperationsToBase64XDR

func ConvertOperationsToBase64XDR(operations []txnbuild.Operation) ([]string, error)

ConvertOperationsToBase64XDR converts a slice of operations to their base64 XDR representations.

func RenderResult

func RenderResult(useCase *UseCase) string

RenderResult renders a result string for a use case.

func SCAccountID

func SCAccountID(address string) (xdr.ScAddress, error)

func WaitForRPCHealthAndRun

func WaitForRPCHealthAndRun(ctx context.Context, rpcService services.RPCService, timeout time.Duration, onReady func() error) error

WaitForRPCHealthAndRun waits for the RPC service to become healthy and then runs the given function.

func WaitForTransactionConfirmation

func WaitForTransactionConfirmation(ctx context.Context, rpcService services.RPCService, hash string, retryOptions ...retry.Option) (txResult entities.RPCGetTransactionResult, err error)

Types

type Fixtures

type Fixtures struct {
	NetworkPassphrase  string
	PrimaryAccountKP   *keypair.Full
	SecondaryAccountKP *keypair.Full
	RPCService         services.RPCService
}

func (*Fixtures) PrepareUseCases

func (f *Fixtures) PrepareUseCases(ctx context.Context) ([]*UseCase, error)

type IntegrationTests

type IntegrationTests struct {
	BaseFee                            int64
	NetworkPassphrase                  string
	RPCService                         services.RPCService
	PrimaryAccountKP                   *keypair.Full
	SecondaryAccountKP                 *keypair.Full
	WBClient                           *wbclient.Client
	ChannelAccountStore                store.ChannelAccountStore
	DBConnectionPool                   db.ConnectionPool
	DistributionAccountSignatureClient signing.SignatureClient
	Fixtures                           Fixtures
}

func NewIntegrationTests

func NewIntegrationTests(ctx context.Context, opts IntegrationTestsOptions) (*IntegrationTests, error)

func (*IntegrationTests) Run

func (it *IntegrationTests) Run(ctx context.Context) error

type IntegrationTestsOptions

type IntegrationTestsOptions struct {
	BaseFee                            int64
	NetworkPassphrase                  string
	RPCService                         services.RPCService
	PrimaryAccountKP                   *keypair.Full
	SecondaryAccountKP                 *keypair.Full
	WBClient                           *wbclient.Client
	DBConnectionPool                   db.ConnectionPool
	DistributionAccountSignatureClient signing.SignatureClient
}

func (*IntegrationTestsOptions) Validate

func (o *IntegrationTestsOptions) Validate() error

type Set

type Set[T comparable] struct {
	// contains filtered or unexported fields
}

func NewSet

func NewSet[T comparable](values ...T) *Set[T]

func (*Set[T]) Add

func (s *Set[T]) Add(value T)

func (*Set[T]) Slice

func (s *Set[T]) Slice() []T

type UseCase

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

func (*UseCase) Name

func (u *UseCase) Name() string