publisher

Documentation

Index

• Variables
• type Config
• type Service
  • func New(config *Config, w *whisper.Whisper) *Service
  • func (s *Service) ConfirmMessagesProcessed(ids [][]byte) error
  • func (s *Service) DisableInstallation(myIdentityKey *ecdsa.PublicKey, installationID string) error
  • func (s *Service) EnableInstallation(myIdentityKey *ecdsa.PublicKey, installationID string) error
  • func (s *Service) GetBundle(myIdentityKey *ecdsa.PrivateKey) (*protobuf.Bundle, error)
  • func (s *Service) GetNegotiatedChat(identity *ecdsa.PublicKey) *filter.Chat
  • func (s *Service) GetPublicBundle(identityKey *ecdsa.PublicKey) (*protobuf.Bundle, error)
  • func (s *Service) InitProtocolWithEncyptionKey(address string, encKey string) error
  • func (s *Service) InitProtocolWithPassword(address string, password string) error
  • func (s *Service) LoadFilter(chat *filter.Chat) ([]*filter.Chat, error)
  • func (s *Service) LoadFilters(chats []*filter.Chat) ([]*filter.Chat, error)
  • func (s *Service) ProcessMessage(dedupMessage dedup.DeduplicateMessage) error
  • func (s *Service) ProcessPublicBundle(myIdentityKey *ecdsa.PrivateKey, bundle *protobuf.Bundle) ([]multidevice.IdentityAndIDPair, error)
  • func (s *Service) RemoveFilter(chat *filter.Chat) error
  • func (s *Service) SendDirectMessage(msg chat.SendDirectMessageRPC) (*whisper.NewMessage, error)
  • func (s *Service) SendPublicMessage(signature string, chatID string, payload []byte, wrap bool) (*whisper.NewMessage, error)
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
• type SignalHandler
  • func (h SignalHandler) BundleAdded(identity string, installationID string)
  • func (h SignalHandler) DecryptMessageFailed(pubKey string)
  • func (h SignalHandler) WhisperFilterAdded(filters []*signal.Filter)

Variables

var (

	// ErrPFSNotEnabled is returned when an endpoint PFS only is called but
	// PFS is disabled
	ErrPFSNotEnabled = errors.New("pfs not enabled")
)

Types

type Config

type Config struct {
	PfsEnabled     bool
	DataDir        string
	InstallationID string
}

type Service

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

func New

func New(config *Config, w *whisper.Whisper) *Service

func (*Service) ConfirmMessagesProcessed

func (s *Service) ConfirmMessagesProcessed(ids [][]byte) error

func (*Service) DisableInstallation

func (s *Service) DisableInstallation(myIdentityKey *ecdsa.PublicKey, installationID string) error

DisableInstallation disables an installation for multi-device sync.

func (*Service) EnableInstallation

func (s *Service) EnableInstallation(myIdentityKey *ecdsa.PublicKey, installationID string) error

EnableInstallation enables an installation for multi-device sync.

func (*Service) GetBundle

func (s *Service) GetBundle(myIdentityKey *ecdsa.PrivateKey) (*protobuf.Bundle, error)

func (*Service) GetNegotiatedChat

func (s *Service) GetNegotiatedChat(identity *ecdsa.PublicKey) *filter.Chat

func (*Service) GetPublicBundle

func (s *Service) GetPublicBundle(identityKey *ecdsa.PublicKey) (*protobuf.Bundle, error)

func (*Service) InitProtocolWithEncyptionKey

func (s *Service) InitProtocolWithEncyptionKey(address string, encKey string) error

InitProtocolWithEncyptionKey creates an instance of ProtocolService given an address and encryption key.

func (*Service) InitProtocolWithPassword

func (s *Service) InitProtocolWithPassword(address string, password string) error

InitProtocolWithPassword creates an instance of ProtocolService given an address and password used to generate an encryption key.

func (*Service) LoadFilter

func (s *Service) LoadFilter(chat *filter.Chat) ([]*filter.Chat, error)

func (*Service) LoadFilters

func (s *Service) LoadFilters(chats []*filter.Chat) ([]*filter.Chat, error)

func (*Service) ProcessMessage

func (s *Service) ProcessMessage(dedupMessage dedup.DeduplicateMessage) error

func (*Service) ProcessPublicBundle

func (s *Service) ProcessPublicBundle(myIdentityKey *ecdsa.PrivateKey, bundle *protobuf.Bundle) ([]multidevice.IdentityAndIDPair, error)

func (*Service) RemoveFilter

func (s *Service) RemoveFilter(chat *filter.Chat) error

func (*Service) SendDirectMessage

func (s *Service) SendDirectMessage(msg chat.SendDirectMessageRPC) (*whisper.NewMessage, error)

SendDirectMessage sends a 1:1 chat message to the underlying transport

func (*Service) SendPublicMessage

func (s *Service) SendPublicMessage(signature string, chatID string, payload []byte, wrap bool) (*whisper.NewMessage, error)

SendPublicMessage sends a public chat message to the underlying transport

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

type SignalHandler

type SignalHandler struct{}

SignalHandler sends signals on protocol events

func (SignalHandler) BundleAdded

func (h SignalHandler) BundleAdded(identity string, installationID string)

func (SignalHandler) DecryptMessageFailed

func (h SignalHandler) DecryptMessageFailed(pubKey string)

func (SignalHandler) WhisperFilterAdded

func (h SignalHandler) WhisperFilterAdded(filters []*signal.Filter)