appview: add `NewIssueComment` event

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

appview/db/issues.go

···
 	return nil
 }
 
-func GetIssueAt(e Execer, repoAt syntax.ATURI, issueId int) (string, error) {
-	var issueAt string
-	err := e.QueryRow(`select issue_at from issues where repo_at = ? and issue_id = ?`, repoAt, issueId).Scan(&issueAt)
-	return issueAt, err
-}
-
-func GetIssueOwnerDid(e Execer, repoAt syntax.ATURI, issueId int) (string, error) {
-	var ownerDid string
-	err := e.QueryRow(`select owner_did from issues where repo_at = ? and issue_id = ?`, repoAt, issueId).Scan(&ownerDid)
-	return ownerDid, err
-}
-
 func GetIssuesPaginated(e Execer, repoAt syntax.ATURI, isOpen bool, page pagination.Page) ([]Issue, error) {
 	var issues []Issue
 	openValue := 0

appview/issues/issues.go

···
 			return
 		}
 
-		commentId := mathrand.IntN(1000000)
-		rkey := tid.TID()
-
-		err := db.NewIssueComment(rp.db, &db.Comment{
+		comment := &db.Comment{
 			OwnerDid:  user.Did,
 			RepoAt:    f.RepoAt(),
 			Issue:     issueIdInt,
-			CommentId: commentId,
+			CommentId: mathrand.IntN(1000000),
 			Body:      body,
-			Rkey:      rkey,
-		})
+			Rkey:      tid.TID(),
+		}
+
+		err := db.NewIssueComment(rp.db, comment)
 		if err != nil {
 			log.Println("failed to create comment", err)
 			rp.pages.Notice(w, "issue-comment", "Failed to create comment.")
···
 		}
 
 		createdAt := time.Now().Format(time.RFC3339)
-		commentIdInt64 := int64(commentId)
-		ownerDid := user.Did
-		issueAt, err := db.GetIssueAt(rp.db, f.RepoAt(), issueIdInt)
+		commentIdInt64 := int64(comment.CommentId)
+		issue, err := db.GetIssue(rp.db, f.RepoAt(), issueIdInt)
 		if err != nil {
-			log.Println("failed to get issue at", err)
+			log.Println("failed to get issue", err)
 			rp.pages.Notice(w, "issue-comment", "Failed to create comment.")
 			return
 		}
 
-		atUri := f.RepoAt().String()
+		atUri := comment.RepoAt.String()
 		client, err := rp.oauth.AuthorizedClient(r)
 		if err != nil {
 			log.Println("failed to get authorized client", err)
···
 		_, err = client.RepoPutRecord(r.Context(), &comatproto.RepoPutRecord_Input{
 			Collection: tangled.RepoIssueCommentNSID,
 			Repo:       user.Did,
-			Rkey:       rkey,
+			Rkey:       comment.Rkey,
 			Record: &lexutil.LexiconTypeDecoder{
 				Val: &tangled.RepoIssueComment{
 					Repo:      &atUri,
-					Issue:     issueAt,
+					Issue:     issue.AtUri().String(),
 					CommentId: &commentIdInt64,
-					Owner:     &ownerDid,
+					Owner:     &comment.OwnerDid,
 					Body:      body,
 					CreatedAt: createdAt,
 				},
···
 			return
 		}
 
-		rp.pages.HxLocation(w, fmt.Sprintf("/%s/issues/%d#comment-%d", f.OwnerSlashRepo(), issueIdInt, commentId))
+		mentions := markup.FindUserMentions(comment.Body)
+
+		rp.notifier.NewIssueComment(r.Context(), &f.Repo, issue, comment, mentions)
+
+		rp.pages.HxLocation(w, fmt.Sprintf("/%s/issues/%d#comment-%d", f.OwnerSlashRepo(), comment.Issue, comment.CommentId))
 		return
 	}
 }

appview/notify/merged_notifier.go

···
 	}
 }
 
+func (m *mergedNotifier) NewIssueComment(ctx context.Context, repo *db.Repo, issue *db.Issue, comment *db.Comment, mentions []string) {
+	for _, notifier := range m.notifiers {
+		notifier.NewIssueComment(ctx, repo, issue, comment, mentions)
+	}
+}
+
 func (m *mergedNotifier) NewFollow(ctx context.Context, follow *db.Follow) {
 	for _, notifier := range m.notifiers {
 		notifier.NewFollow(ctx, follow)

appview/notify/notifier.go

···
 	DeleteStar(ctx context.Context, star *db.Star)
 
 	NewIssue(ctx context.Context, issue *db.Issue)
+	NewIssueComment(ctx context.Context, repo *db.Repo, issue *db.Issue, comment *db.Comment, mentions []string)
 
 	NewFollow(ctx context.Context, follow *db.Follow)
 	DeleteFollow(ctx context.Context, follow *db.Follow)
···
 func (m *BaseNotifier) DeleteStar(ctx context.Context, star *db.Star) {}
 
 func (m *BaseNotifier) NewIssue(ctx context.Context, issue *db.Issue) {}
+func (m *BaseNotifier) NewIssueComment(ctx context.Context, repo *db.Repo, issue *db.Issue, comment *db.Comment, mentions []string) {}
 
 func (m *BaseNotifier) NewFollow(ctx context.Context, follow *db.Follow)    {}
 func (m *BaseNotifier) DeleteFollow(ctx context.Context, follow *db.Follow) {}

appview/posthog/notifier.go

···
 	}
 }
 
+func (n *posthogNotifier) NewIssueComment(ctx context.Context, repo *db.Repo, issue *db.Issue, comment *db.Comment, mentions []string) {
+	err := n.client.Enqueue(posthog.Capture{
+		DistinctId: comment.OwnerDid,
+		Event:      "new_issue",
+		Properties: posthog.Properties{
+			"repo_at":  comment.RepoAt.String(),
+			"issue_id": comment.Issue,
+		},
+	})
+	if err != nil {
+		log.Println("failed to enqueue posthog event:", err)
+	}
+}
+
 func (n *posthogNotifier) NewPull(ctx context.Context, pull *db.Pull) {
 	err := n.client.Enqueue(posthog.Capture{
 		DistinctId: pull.OwnerDid,