✨ Apple push notification services

pkg/cmd/main.go

@@ -49,6 +49,9 @@ func main() {
 	if err := services.SetupFirebase(); err != nil {
 		log.Error().Err(err).Msg("An error occurred when connecting firebase...")
 	}
+	if err := services.SetupAPNS(); err != nil {
+		log.Error().Err(err).Msg("An error occurred when connecting APNs...")
+	}
 	if err := grpc.ConnectPaperclip(); err != nil {
 		log.Fatal().Err(err).Msg("An error occurred when connecting to paperclip...")
 	}

pkg/models/notifications.go

@@ -29,6 +29,7 @@ type NotificationLink struct {
 
 const (
 	NotifySubscriberFirebase = "firebase"
+	NotifySubscriberAPNs     = "apple"
 )
 
 type NotificationSubscriber struct {

pkg/services/external_apns.go

@@ -0,0 +1,25 @@
+package services
+
+import (
+	"github.com/sideshow/apns2"
+	"github.com/sideshow/apns2/token"
+	"github.com/spf13/viper"
+)
+
+// ExtAPNS is Apple Notification Services client
+var ExtAPNS *apns2.Client
+
+func SetupAPNS() error {
+	authKey, err := token.AuthKeyFromFile(viper.GetString("apns_credentials"))
+	if err != nil {
+		return err
+	}
+
+	ExtAPNS = apns2.NewTokenClient(&token.Token{
+		AuthKey: authKey,
+		KeyID:   viper.GetString("apns_credentials_key"),
+		TeamID:  viper.GetString("apns_credentials_team"),
+	})
+
+	return nil
+}

pkg/services/external_firebase.go

@@ -7,6 +7,7 @@ import (
 	"google.golang.org/api/option"
 )
 
+// ExtFire is the firebase app client
 var ExtFire *firebase.App
 
 func SetupFirebase() error {

pkg/services/notifications.go

@@ -3,11 +3,12 @@ package services
 import (
 	"context"
 	"firebase.google.com/go/messaging"
-	"reflect"
-
 	"git.solsynth.dev/hydrogen/passport/pkg/database"
 	"git.solsynth.dev/hydrogen/passport/pkg/models"
 	"github.com/rs/zerolog/log"
+	"github.com/sideshow/apns2"
+	payload2 "github.com/sideshow/apns2/payload"
+	"reflect"
 )
 
 func AddNotifySubscriber(user models.Account, provider, id, tk, ua string) (models.NotificationSubscriber, error) {
@@ -105,6 +106,27 @@ func PushNotification(notification models.Notification) error {
 						Msg("Notified subscriber via FCM.")
 				}
 			}
+		case models.NotifySubscriberAPNs:
+			if ExtAPNS != nil {
+				data, err := payload2.
+					NewPayload().
+					AlertTitle(notification.Subject).
+					AlertBody(notification.Content).
+					MarshalJSON()
+				if err != nil {
+					log.Warn().Err(err).Msg("An error occurred when preparing to notify subscriber via APNs...")
+				}
+				payload := &apns2.Notification{
+					DeviceToken: subscriber.DeviceToken,
+					Topic:       "dev.solsynth.solian.UniversalNotification",
+					Payload:     data,
+				}
+
+				_, err = ExtAPNS.Push(payload)
+				if err != nil {
+					log.Warn().Err(err).Msg("An error occurred when notify subscriber via APNs...")
+				}
+			}
 		}
 	}