🐛 Fix notifier

pkg/cmd/main.go

@@ -41,11 +41,9 @@ func main() {
 	}
 
 	// Connect other services
-	go func() {
 	if err := grpc.ConnectPassport(); err != nil {
 		log.Fatal().Err(err).Msg("An error occurred when connecting to passport grpc endpoint...")
 	}
-	}()
 
 	// Configure timed tasks
 	quartz := cron.New(cron.WithLogger(cron.VerbosePrintfLogger(&log.Logger)))

pkg/services/accounts.go

@@ -6,6 +6,7 @@ import (
 	"git.solsynth.dev/hydrogen/interactive/pkg/grpc"
 	"git.solsynth.dev/hydrogen/interactive/pkg/models"
 	"git.solsynth.dev/hydrogen/passport/pkg/grpc/proto"
+	"github.com/rs/zerolog/log"
 	"github.com/spf13/viper"
 	"time"
 )
@@ -68,6 +69,11 @@ func NotifyAccount(user models.Account, subject, content string, realtime bool,
 		IsRealtime:   realtime,
 		IsImportant:  false,
 	})
+	if err != nil {
+		log.Warn().Err(err).Msg("An error occurred when notify account...")
+	} else {
+		log.Debug().Uint("external", user.ExternalID).Msg("Notified account.")
+	}
 
 	return err
 }

pkg/services/comments.go

@@ -85,7 +85,11 @@ func (v *PostTypeContext) CountComment(id uint) (int64, error) {
 
 func CommentNotify(this models.PostInterface, original models.Feed, columnName, tableName string) {
 	var op models.Feed
-	if err := database.C.Where(columnName+"_id = ?", original.ID).Preload("Author").Table(tableName).First(&op).Error; err == nil {
+	if err := database.C.
+		Where(columnName+"_id = ?", original.ID).
+		Preload("Author").
+		Table(tableName).
+		First(&op).Error; err == nil {
 		if op.Author.ID != this.GetAuthor().ID {
 			postUrl := fmt.Sprintf("https://%s/posts/%d", viper.GetString("domain"), this.GetID())
 			err := NotifyAccount(

pkg/services/posts.go

@@ -314,7 +314,10 @@ func NewPost[T models.PostInterface](item T) (T, error) {
 	if item.GetReplyTo() != nil {
 		go func() {
 			var op models.Moment
-			if err := database.C.Where("id = ?", item.GetReplyTo()).Preload("Author").First(&op).Error; err == nil {
+			if err := database.C.
+				Where("id = ?", item.GetReplyTo()).
+				Preload("Author").
+				First(&op).Error; err == nil {
 				if op.Author.ID != item.GetAuthor().ID {
 					postUrl := fmt.Sprintf("https://%s/posts/%d", viper.GetString("domain"), item.GetID())
 					err := NotifyAccount(