e2e

Documentation

Index

• Variables
• func AddNamespace(data map[string]interface{}, ns map[string]interface{})
• func AddPluginBroadcastName(data map[string]interface{}, pluginType, broadcastName string)
• func ChangeDefaultNSPluginLocalName(data map[string]interface{}, pluginType, newLocalName string)
• func GetMemberHostname(filename string, n int) (string, error)
• func GetMemberPort(filename string, n int) (int, error)
• func PickTopic(i int, options []string) string
• func PollForUp(t *testing.T, client *client.FireFlyClient)
• func RandomName(t *testing.T) string
• func ReadConfig(t *testing.T, configFile string) map[string]interface{}
• func ResetFireFly(t *testing.T, client *resty.Client)
• func ValidateAccountBalances(t *testing.T, client *client.FireFlyClient, poolID *fftypes.UUID, ...)
• func VerifyAllOperationsSucceeded(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)
• func VerifyOperationsAlreadyMarkedFailed(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)
• func WaitForContractEvent(t *testing.T, client *client.FireFlyClient, c chan *core.EventDelivery, ...) map[string]interface{}
• func WaitForEvent(t *testing.T, c chan *core.EventDelivery, eventType core.EventType, ...)
• func WaitForIdentityConfirmed(t *testing.T, c chan *core.EventDelivery) *core.EventDelivery
• func WaitForMessageConfirmed(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery
• func WaitForMessageRejected(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery
• func WriteConfig(t *testing.T, configFile string, data map[string]interface{})
• func WsReader(conn *websocket.Conn) chan *core.EventDelivery
• type Member
• type Stack
  • func ReadStack(t *testing.T) *Stack
  • func ReadStackFile(filename string) (*Stack, error)
• type StackState
  • func ReadStackState(t *testing.T) *StackState
  • func ReadStackStateFile(filename string) (*StackState, error)
• type TestState

Variables

var WidgetSchemaJSON = []byte(`{
	"$id": "https://example.com/widget.schema.json",
	"$schema": "https://json-schema.org/draft/2020-12/schema",
	"title": "Widget",
	"type": "object",
	"properties": {
		"id": {
			"type": "string",
			"description": "The unique identifier for the widget."
		},
		"name": {
			"type": "string",
			"description": "The person's last name."
		}
	},
	"additionalProperties": false
}`)

Functions

func AddNamespace

func AddNamespace(data map[string]interface{}, ns map[string]interface{})

func AddPluginBroadcastName

func AddPluginBroadcastName(data map[string]interface{}, pluginType, broadcastName string)

func ChangeDefaultNSPluginLocalName

func ChangeDefaultNSPluginLocalName(data map[string]interface{}, pluginType, newLocalName string)

ChangeDefaultNSPluginLocalName changes the plugin local name and updates the plugin list for the default namespace

func GetMemberHostname

func GetMemberHostname(filename string, n int) (string, error)

func GetMemberPort

func GetMemberPort(filename string, n int) (int, error)

func PickTopic

func PickTopic(i int, options []string) string

func PollForUp

func PollForUp(t *testing.T, client *client.FireFlyClient)

func RandomName

func RandomName(t *testing.T) string

func ReadConfig

func ReadConfig(t *testing.T, configFile string) map[string]interface{}

func ResetFireFly

func ResetFireFly(t *testing.T, client *resty.Client)

func ValidateAccountBalances

func ValidateAccountBalances(t *testing.T, client *client.FireFlyClient, poolID *fftypes.UUID, tokenIndex string, balances map[string]int64)

func VerifyAllOperationsSucceeded

func VerifyAllOperationsSucceeded(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)

func VerifyOperationsAlreadyMarkedFailed

func VerifyOperationsAlreadyMarkedFailed(t *testing.T, clients []*client.FireFlyClient, startTime time.Time)

func WaitForContractEvent

func WaitForContractEvent(t *testing.T, client *client.FireFlyClient, c chan *core.EventDelivery, match map[string]interface{}) map[string]interface{}

func WaitForEvent

func WaitForEvent(t *testing.T, c chan *core.EventDelivery, eventType core.EventType, ref *fftypes.UUID)

func WaitForIdentityConfirmed

func WaitForIdentityConfirmed(t *testing.T, c chan *core.EventDelivery) *core.EventDelivery

func WaitForMessageConfirmed

func WaitForMessageConfirmed(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery

func WaitForMessageRejected

func WaitForMessageRejected(t *testing.T, c chan *core.EventDelivery, msgType core.MessageType) *core.EventDelivery

func WriteConfig

func WriteConfig(t *testing.T, configFile string, data map[string]interface{})

func WsReader

func WsReader(conn *websocket.Conn) chan *core.EventDelivery

Types

type Member

type Member struct {
	ExposedFireflyPort   int         `json:"exposedFireflyPort,omitempty"`
	ExposedAdminPort     int         `json:"exposedFireflyAdminPort,omitempty"`
	FireflyHostname      string      `json:"fireflyHostname,omitempty"`
	Username             string      `json:"username,omitempty"`
	Password             string      `json:"password,omitempty"`
	UseHTTPS             bool        `json:"useHttps,omitempty"`
	ExposedConnectorPort int         `json:"exposedConnectorPort,omitempty"`
	OrgName              string      `json:"orgName,omitempty"`
	Account              interface{} `json:"account,omitempty"`
}

type Stack

type Stack struct {
	Name                  string    `json:"name,omitempty"`
	ExposedBlockchainPort int       `json:"exposedBlockchainPort,omitempty"`
	BlockchainProvider    string    `json:"blockchainProvider"`
	TokenProviders        []string  `json:"tokenProviders"`
	Members               []*Member `json:"members,omitempty"`
	Database              string    `json:"database"`
}

func ReadStack

func ReadStack(t *testing.T) *Stack

func ReadStackFile

func ReadStackFile(filename string) (*Stack, error)

type StackState

type StackState struct {
	Accounts []interface{} `json:"accounts"`
}

func ReadStackState

func ReadStackState(t *testing.T) *StackState

func ReadStackStateFile

func ReadStackStateFile(filename string) (*StackState, error)

type TestState

type TestState interface {
	T() *testing.T
	StartTime() time.Time
	Done() func()
}