noise

Nov 14, 2023

Changes in this version

+ const NoiseEncryption

Sep 17, 2023

Changes in this version

+ const DefaultShardID

Dec 21, 2022

Changes in this version

+ const DefaultApplicationName

+ const DefaultApplicationVersion

+ const DefaultShardId

+ var ErrPairingTimeout = errors.New("pairing has timed out")

+ func DecodePayloadV2(message *pb.WakuMessage) (*n.PayloadV2, error)

+ func EncodePayloadV2(payload2 *n.PayloadV2) (*pb.WakuMessage, error)

+ type NoiseMessenger interface

+ Stop func()

+ type NoiseWakuRelay struct

+ func NewWakuRelayMessenger(ctx context.Context, r *relay.WakuRelay, pubsubTopic *string, ...) (*NoiseWakuRelay, error)

+ func (r *NoiseWakuRelay) Publish(ctx context.Context, contentTopic string, payload *n.PayloadV2) error

+ func (r *NoiseWakuRelay) Stop()

+ func (r *NoiseWakuRelay) Subscribe(ctx context.Context, contentTopic string) <-chan *pb.WakuMessage

+ type Pairing struct

+ ContentTopic string

+ func NewPairing(myStaticKey n.Keypair, myEphemeralKey n.Keypair, opts PairingParameterOption, ...) (*Pairing, error)

+ func (p *Pairing) AuthCode() <-chan string

+ func (p *Pairing) ConfirmAuthCode(confirmed bool) error

+ func (p *Pairing) Decrypt(msg *pb.WakuMessage) ([]byte, error)

+ func (p *Pairing) Encrypt(plaintext []byte) (*pb.WakuMessage, error)

+ func (p *Pairing) Execute(ctx context.Context) error

+ func (p *Pairing) HandshakeComplete() bool

+ func (p *Pairing) PairingInfo() (qrString string, qrMessageNametag n.MessageNametag)

+ type PairingParameterOption func(*PairingParameters) error

+ func WithDefaultResponderParameters() PairingParameterOption

+ func WithInitiatorParameters(qrString string, qrMessageNametag n.MessageNametag) PairingParameterOption

+ func WithResponderParameters(applicationName, applicationVersion, shardId string, ...) PairingParameterOption

+ type PairingParameters struct

+ type QR struct

+ func NewQR(applicationName, applicationVersion, shardId string, ...) QR

+ func StringToQR(qrString string) (QR, error)

+ func (qr QR) Bytes() []byte

+ func (qr QR) String() string

+ type Receiver interface

+ Subscribe func(ctx context.Context, contentTopic string) <-chan *pb.WakuMessage

+ type Sender interface

+ Publish func(ctx context.Context, contentTopic string, payload *n.PayloadV2) error