messengerutil

Documentation

Index

• Constants
• func B64DecodeBytes(s string) ([]byte, error)
• func B64EncodeBytes(b []byte) string
• func CheckDeviceIsMe(ctx context.Context, client protocoltypes.ProtocolServiceClient, ...) (bool, error)
• func EnsureValidBase64CID(str string) error
• func GroupPKFromContactPK(ctx context.Context, client protocoltypes.ProtocolServiceClient, ...) ([]byte, error)
• func StreamInteraction(dispatcher Dispatcher, db AugmentedInteractionFetcher, cid string, isNew bool) error
• func TimestampMs(t time.Time) int64
• type AugmentedInteractionFetcher
• type Dispatcher
• type NoopDispatcher
  • func (*NoopDispatcher) IsEnabled() bool
  • func (*NoopDispatcher) Notify(typ mt.StreamEvent_Notified_Type, title, body string, msg proto.Message) error
  • func (*NoopDispatcher) StreamEvent(typ mt.StreamEvent_Type, msg proto.Message, isNew bool) error

Constants

const (
	TyberEventAcknowledgeReceived = "Acknowledge received"

	MilliToNanoFactor = 1000000
)

Functions

func B64DecodeBytes

func B64DecodeBytes(s string) ([]byte, error)

func B64EncodeBytes

func B64EncodeBytes(b []byte) string

func CheckDeviceIsMe

func CheckDeviceIsMe(ctx context.Context, client protocoltypes.ProtocolServiceClient, gme *protocoltypes.GroupMessageEvent) (bool, error)

func EnsureValidBase64CID

func EnsureValidBase64CID(str string) error

func GroupPKFromContactPK

func GroupPKFromContactPK(ctx context.Context, client protocoltypes.ProtocolServiceClient, contactPK []byte) ([]byte, error)

func StreamInteraction

func StreamInteraction(dispatcher Dispatcher, db AugmentedInteractionFetcher, cid string, isNew bool) error

func TimestampMs

func TimestampMs(t time.Time) int64

Types

type AugmentedInteractionFetcher

type AugmentedInteractionFetcher interface {
	GetAugmentedInteraction(cid string) (*mt.Interaction, error)
}

type Dispatcher

type Dispatcher interface {
	StreamEvent(typ mt.StreamEvent_Type, msg proto.Message, isNew bool) error
	Notify(typ mt.StreamEvent_Notified_Type, title, body string, msg proto.Message) error
	IsEnabled() bool
}

type NoopDispatcher

type NoopDispatcher struct{}

func (*NoopDispatcher) IsEnabled

func (*NoopDispatcher) IsEnabled() bool

func (*NoopDispatcher) Notify

func (*NoopDispatcher) Notify(typ mt.StreamEvent_Notified_Type, title, body string, msg proto.Message) error

func (*NoopDispatcher) StreamEvent

func (*NoopDispatcher) StreamEvent(typ mt.StreamEvent_Type, msg proto.Message, isNew bool) error