messaging

type ClientRejectedLoginMessageHandler struct {
}

type ClientRejectedPaymentMessageHandler struct {
}

type CodeScannedMessageHandler struct {
}

type ConfigProvider func() *conf

type InternalMessageClient interface {
	// InternallyCreateMessage creates and forwards a message on a stream
	// identified by the rendezvous key
	InternallyCreateMessage(ctx context.Context, rendezvousKey *common.Account, message *messagingpb.Message) (uuid.UUID, error)
}

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

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

type MessageHandler interface {
	// Validate validates a message, which determines whether it should be
	// allowed to be sent and persisted
	Validate(ctx context.Context, rendezvous *common.Account, message *messagingpb.Message) error

	// RequiresActiveStream determines whether a message can only be sent if an
	// active stream is available. If true, then the message must also provide
	// the maximum time it expects the stream to be valid for, which is dependent
	// on the use case.
	RequiresActiveStream() (bool, time.Duration)

	// OnSuccess is called upon creating the message after validation
	OnSuccess(ctx context.Context) error
}

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

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

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

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