dedup

Documentation

Index

• type Author
• type DeduplicateMessage
• type Deduplicator
  • func NewDeduplicator(keyPairProvider keyPairProvider, db *leveldb.DB) *Deduplicator
  • func (d *Deduplicator) AddMessageByID(messageIDs [][]byte) error
  • func (d *Deduplicator) AddMessagesByID(messageIDs [][]byte) error
  • func (d *Deduplicator) Deduplicate(messages []*DeduplicateMessage) []*DeduplicateMessage
• type Metadata

Types

type Author

type Author struct {
	PublicKey statusproto.HexBytes `json:"publicKey"`
	Alias     string               `json:"alias"`
	Identicon string               `json:"identicon"`
}

type DeduplicateMessage

type DeduplicateMessage struct {
	Message       *whispertypes.Message `json:"message"`
	Metadata      Metadata              `json:"metadata"`
	Payload       string                `json:"payload"`
	MessageType   v1.StatusMessageT     `json:"messageType"`
	ParsedMessage interface{}           `json:"parsedMessage"`
}

type Deduplicator

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

Deduplicator filters out already received messages for a current filter. It keeps a limited cache of the messages.

func NewDeduplicator

func NewDeduplicator(keyPairProvider keyPairProvider, db *leveldb.DB) *Deduplicator

NewDeduplicator creates a new deduplicator

func (*Deduplicator) AddMessageByID

func (d *Deduplicator) AddMessageByID(messageIDs [][]byte) error

AddMessageByID adds a message to the deduplicator DB, so it will be filtered out.

func (*Deduplicator) AddMessagesByID

func (d *Deduplicator) AddMessagesByID(messageIDs [][]byte) error

AddMessages adds a message to the deduplicator DB, so it will be filtered out.

func (*Deduplicator) Deduplicate

func (d *Deduplicator) Deduplicate(messages []*DeduplicateMessage) []*DeduplicateMessage

Deduplicate receives a list of whisper messages and returns the list of the messages that weren't filtered previously for the specified filter.

type Metadata

type Metadata struct {
	DedupID      []byte               `json:"dedupId"`
	EncryptionID statusproto.HexBytes `json:"encryptionId"`
	MessageID    statusproto.HexBytes `json:"messageId"`
	Author       Author               `json:"author"`
}