testing

func Connect(t *testing.T, n1 *wakunode.WakuNode, n2 *wakunode.WakuNode, protocols ...protocol.ID)

func ConnectWithAddr(t *testing.T, n *wakunode.WakuNode, addr string)

func Disconnect(t *testing.T, n1 *wakunode.WakuNode, n2 *wakunode.WakuNode)

func ExpectNoPeers(t *testing.T, n *wakunode.WakuNode)

func ExpectPeers(t *testing.T, n *wakunode.WakuNode, expected ...peer.ID)

func NewAuthzDB(t testing.TB) (*bun.DB, string, func())

func NewDB(t testing.TB) (*sql.DB, string, func())

func NewEnvelope(contentTopic string, timestamp uint64, content string) *messagev1.Envelope

func NewLog(t testing.TB) *zap.Logger

func NewMLSDB(t *testing.T) (*bun.DB, string, func())

func NewNode(t testing.TB, log *zap.Logger, opts ...wakunode.WakuNodeOption) (*wakunode.WakuNode, func())

func NewPGXDB(t testing.TB) (*sql.DB, string, func())

func NewPeer(t *testing.T) host.Host

func NewPrivateKey(t testing.TB) *ecdsa.PrivateKey

func Publish(t *testing.T, n *wakunode.WakuNode, msg *pb.WakuMessage)

func RandomBytes(n int) []byte

func RandomString(n int) string

func RandomStringLower(n int) string

func Subscribe(t *testing.T, n *wakunode.WakuNode) <-chan *protocol.Envelope

func SubscribeExpect(t *testing.T, envC chan *protocol.Envelope, msgs []*pb.WakuMessage)

func SubscribeExpectNone(t *testing.T, envC chan *protocol.Envelope)