bertypush

Documentation

Index

• Constants
• func DecryptPushDataFromServer(data []byte, serverPK, ownSK *[32]byte) ([]byte, error)
• func FormatDecryptedPush(decrypted *pushtypes.DecryptedPush, printer *message.Printer) *pushtypes.FormatedPush
• func PushDecrypt(ctx context.Context, rootDir string, input []byte, opts *PushDecryptOpts) (*messengertypes.PushReceivedData, *accounttypes.AccountMetadata, error)
• func PushDecryptStandalone(logger *zap.Logger, rootDir string, inputB64 string, ...) (*pushtypes.DecryptedPush, error)
• func PushEnrich(rawPushData *messengertypes.PushReceivedData, ...) (*pushtypes.DecryptedPush, error)
• type EventHandler
• type MessengerPushReceiver
  • func NewPushReceiver(pushHandler PushHandler, evtHandler EventHandler, ...) MessengerPushReceiver
• type PushDecryptOpts
• type PushHandler
  • func NewPushHandler(serviceClient oosmtypes.OutOfStoreMessageServiceClient, ...) (PushHandler, error)
• type PushHandlerOpts

Constants

const InMemoryDir = ":memory:"

Functions

func DecryptPushDataFromServer

func DecryptPushDataFromServer(data []byte, serverPK, ownSK *[32]byte) ([]byte, error)

func FormatDecryptedPush

func FormatDecryptedPush(decrypted *pushtypes.DecryptedPush, printer *message.Printer) *pushtypes.FormatedPush

func PushDecrypt

func PushDecrypt(ctx context.Context, rootDir string, input []byte, opts *PushDecryptOpts) (*messengertypes.PushReceivedData, *accounttypes.AccountMetadata, error)

func PushDecryptStandalone

func PushDecryptStandalone(logger *zap.Logger, rootDir string, inputB64 string, ks accountutils.NativeKeystore) (*pushtypes.DecryptedPush, error)

func PushEnrich

func PushEnrich(rawPushData *messengertypes.PushReceivedData, accountData *accounttypes.AccountMetadata, logger *zap.Logger) (*pushtypes.DecryptedPush, error)

Types

type EventHandler

type EventHandler interface {
	HandleOutOfStoreAppMessage(groupPK []byte, message *protocoltypes.OutOfStoreMessage, payload []byte) (*messengertypes.Interaction, bool, error)
}

type MessengerPushReceiver

type MessengerPushReceiver interface {
	PushReceive(ctx context.Context, input []byte) (*messengertypes.PushReceive_Reply, error)
}

func NewPushReceiver

func NewPushReceiver(pushHandler PushHandler, evtHandler EventHandler, dbFetcher dbfetcher.DBFetcher, logger *zap.Logger) MessengerPushReceiver

type PushDecryptOpts

type PushDecryptOpts struct {
	Logger           *zap.Logger
	Keystore         accountutils.NativeKeystore
	ExcludedAccounts []string
}

type PushHandler

type PushHandler interface {
	PushReceive(ctx context.Context, payload []byte) (*protocoltypes.OutOfStoreReceive_Reply, error)
	PushPK() *[cryptoutil.KeySize]byte
}

func NewPushHandler

func NewPushHandler(serviceClient oosmtypes.OutOfStoreMessageServiceClient, dbFetcher dbfetcher.DBFetcher, pushSK *[cryptoutil.KeySize]byte, opts *PushHandlerOpts) (PushHandler, error)

type PushHandlerOpts

type PushHandlerOpts struct {
	Logger *zap.Logger
}