61 lines
1.3 KiB
Go
61 lines
1.3 KiB
Go
package provider
|
|
|
|
import (
|
|
"git.solsynth.dev/hypernet/pusher/pkg/pushkit"
|
|
"github.com/rs/zerolog/log"
|
|
"github.com/sideshow/apns2"
|
|
payload2 "github.com/sideshow/apns2/payload"
|
|
)
|
|
|
|
type AppleNotifyProvider struct {
|
|
topic string
|
|
conn *apns2.Client
|
|
}
|
|
|
|
func (v *AppleNotifyProvider) Push(in pushkit.Notification, tk string) error {
|
|
data := payload2.
|
|
NewPayload().
|
|
AlertTitle(in.Title).
|
|
AlertBody(in.Body).
|
|
Category(in.Topic).
|
|
Custom("metadata", in.Metadata).
|
|
Sound("default").
|
|
MutableContent()
|
|
if len(in.Subtitle) > 0 {
|
|
data = data.AlertSubtitle(in.Subtitle)
|
|
}
|
|
if avatar, ok := in.Metadata["avatar"]; ok {
|
|
data = data.Custom("avatar", avatar)
|
|
}
|
|
if picture, ok := in.Metadata["picture"]; ok {
|
|
data = data.Custom("picture", picture)
|
|
}
|
|
rawData, err := data.MarshalJSON()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
payload := &apns2.Notification{
|
|
DeviceToken: tk,
|
|
Topic: v.topic,
|
|
Payload: rawData,
|
|
}
|
|
|
|
resp, err := v.conn.Push(payload)
|
|
if resp != nil {
|
|
log.Debug().
|
|
Str("token", tk).
|
|
Str("remote_id", resp.ApnsID).
|
|
Str("remote_uuid", resp.ApnsUniqueID).
|
|
Int("status", resp.StatusCode).
|
|
Time("timestamp", resp.Timestamp.Time).
|
|
Str("reason", resp.Reason).
|
|
Msg("Pushed once notification to apple")
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
func (v *AppleNotifyProvider) GetName() string {
|
|
return "apns"
|
|
}
|