xmpp

type Ack struct {
	MessageID               string // Original message id.
	From                    string // App registration token.
	CanonicalRegistrationID string // Canonical registration id.
}

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

type ClientOptions struct {
	Endpoint           Endpoint          // Used endpoint Default to Prod.
	MaxPendingMessages uint              // Max pending messages. Default to 100.
	Debug              bool              // Enable debug mode. Default to false.
	XMPPClientFactory  XMPPClientFactory // The XMPPClientFactory. Default to RealXMPPClientFactory.
}

type Control struct {
	Type string // Control type, currently only CONNECTION_DRAINING.
}

type Endpoint int

type Handler interface {
	Handle(src, msg interface{}) error
}

type HandlerFunc func(src, msg interface{}) error

type Nack struct {
	MessageID        string // Original message id.
	From             string // App registration id.
	Error            string // Error code (ex: BAD_REGISTRATION, DEVICE_MESSAGE_RATE_EXCEEDED, INVALID_JSON).
	ErrorDescription string // Error description.
}

type Notification struct {
	Title string `json:"title"`
	Body  string `json:"body"`
	Image string `json:"image"`
	Sound string `json:"sound"`
}

type RealXMPPClientFactory struct {
	Debug bool
}

type Receipt struct {
	MessageStatus string    // Message status (ex: MESSAGE_SENT_TO_DEVICE).
	MessageID     string    // Original message id.
	From          string    // App registration id.
	SentTime      time.Time // Message sent timestamp.
}

type SendOptions struct {
	DryRun                 bool          // Test without actually sending. Default to false.
	RequestDeliveryReceipt bool          // Request for deliverey receipt. Default to false.
	TimeToLive             time.Duration // Time to live. Default to 4 weeks, max up to 4 weeks.
}

type XMPPClient interface {
	SendOrg(org string) (n int, err error)
	PingC2S(jid, server string) error
	Recv() (stanza interface{}, err error)
	Close() error
}

type XMPPClientFactory interface {
	NewXMPPClient(host, user, passwd string) (XMPPClient, error)
}