GenerateEngines generates MeshEngines for the given networks.

GenerateIDs is a test helper that generate flow identities with a valid port and libp2p nodes.

GenerateIDsAndMiddlewares returns nodeIDs, libp2pNodes, middlewares, and observables which can be subscirbed to in order to witness protect events from pubsub.

GenerateMiddlewares creates and initializes middleware instances for all the identities.

GenerateNetworks generates the network for the given middlewares.

GenerateSubscriptionManagers creates and returns a ChannelSubscriptionManager for each middleware object.

NetworkPayloadFixture creates a blob of random bytes with the given size (in bytes) and returns it.

NewConnectionGater creates a new connection gater for testing with given allow listing filter.

NewResourceManager creates a new resource manager for testing with no limits.

OptionalSleep introduces a sleep to allow nodes to heartbeat and discover each other (only needed when using PubSub).

StartNodes starts the provided nodes and their peer managers using the provided irrecoverable context.

StartNodesAndNetworks starts the provided networks and libp2p nodes, returning the irrecoverable error channel.

StopComponents stops ReadyDoneAware instances in parallel and fails the test if they could not be stopped within the duration.

MeshEngine is a simple engine that is used for testing the correctness of driving the engines with libp2p, it simply receives and stores the incoming messages.

UpdatableIDProvider implements an IdentityProvider which can be manually updated by setting the IdentityList to a new value.

ConduitSendWrapperFunc is a wrapper around the set of methods offered by the Conduit (e.g., Publish).