appview: email: notify mentioned users on pull-comments

Signed-off-by: Seongmin Lee <[e-mail]>

appview/email/notifier.go

···
 	}, nil
 }
 
+func (n *EmailNotifier) buildPullEmail(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment) (Email, error) {
+	commentOwner, err := n.idResolver.ResolveIdent(ctx, comment.OwnerDid)
+	if err != nil || commentOwner.Handle.IsInvalidHandle() {
+		return Email{}, fmt.Errorf("resolve comment owner did: %w", err)
+	}
+	repoOwnerSlashName, err := n.repoOwnerSlashName(ctx, repo)
+	if err != nil {
+		return Email{}, nil
+	}
+	baseUrl := n.Config.Core.AppviewHost
+	url := fmt.Sprintf("%s/%s/pulls/%d#comment-%d", baseUrl, repoOwnerSlashName, comment.PullId, comment.ID)
+	return Email{
+		APIKey:  n.Config.Resend.ApiKey,
+		From:    n.Config.Resend.SentFrom,
+		Subject: fmt.Sprintf("[%s] %s (pr#%d)", repoOwnerSlashName, pull.Title, pull.PullId),
+		Html:    fmt.Sprintf(`<p><b>@%s</b> mentioned you</p><a href="%s">View it on tangled.sh</a>.`, commentOwner.Handle.String(), url),
+	}, nil
+}
+
 func (n *EmailNotifier) gatherRecipientEmails(ctx context.Context, handles []string) []string {
 	recipients := []string{}
 	for _, handle := range handles {
···
 	}
 }
 
-// func (n *EmailNotifier) NewPullComment(ctx context.Context, comment *db.PullComment, []string) {
-// 	n.usersMentioned(ctx, mentions)
-// }
+func (n *EmailNotifier) NewPullComment(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment, mentions []string) {
+	email, err := n.buildPullEmail(ctx, repo, pull, comment)
+	if err != nil {
+		log.Println("failed to create pull-email:", err)
+	}
+	recipients := n.gatherRecipientEmails(ctx, mentions)
+	log.Println("sending email to:", recipients)
+	if err = SendEmail(email); err != nil {
+		log.Println("error sending email:", err)
+	}
+}

appview/notify/merged_notifier.go

···
 		notifier.NewPull(ctx, pull)
 	}
 }
-func (m *mergedNotifier) NewPullComment(ctx context.Context, comment *db.PullComment) {
+func (m *mergedNotifier) NewPullComment(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment, mentions []string) {
 	for _, notifier := range m.notifiers {
-		notifier.NewPullComment(ctx, comment)
+		notifier.NewPullComment(ctx, repo, pull, comment, mentions)
 	}
 }
 

appview/notify/notifier.go

···
 	DeleteFollow(ctx context.Context, follow *db.Follow)
 
 	NewPull(ctx context.Context, pull *db.Pull)
-	NewPullComment(ctx context.Context, comment *db.PullComment)
+	NewPullComment(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment, mentions []string)
 
 	UpdateProfile(ctx context.Context, profile *db.Profile)
 }
···
 func (m *BaseNotifier) DeleteFollow(ctx context.Context, follow *db.Follow) {}
 
 func (m *BaseNotifier) NewPull(ctx context.Context, pull *db.Pull)                  {}
-func (m *BaseNotifier) NewPullComment(ctx context.Context, comment *db.PullComment) {}
+func (m *BaseNotifier) NewPullComment(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment, mentions []string) {}
 
 func (m *BaseNotifier) UpdateProfile(ctx context.Context, profile *db.Profile) {}

appview/posthog/notifier.go

···
 	}
 }
 
-func (n *posthogNotifier) NewPullComment(ctx context.Context, comment *db.PullComment) {
+func (n *posthogNotifier) NewPullComment(ctx context.Context, repo *db.Repo, pull *db.Pull, comment *db.PullComment, mentions []string) {
 	err := n.client.Enqueue(posthog.Capture{
 		DistinctId: comment.OwnerDid,
 		Event:      "new_pull_comment",

appview/pulls/pulls.go

···
 			return
 		}
 
-		s.notifier.NewPullComment(r.Context(), comment)
+		mentions := markup.FindUserMentions(comment.Body)
+
+		s.notifier.NewPullComment(r.Context(), &f.Repo, pull, comment, mentions)
 
 		s.pages.HxLocation(w, fmt.Sprintf("/%s/pulls/%d#comment-%d", f.OwnerSlashRepo(), pull.PullId, commentId))
 		return