140 lines
3.5 KiB
Go
140 lines
3.5 KiB
Go
package main
|
|
|
|
import ()
|
|
|
|
func emailNotificationModerator(d domain, path string, title string, commenterHex string, commentHex string, state string) {
|
|
if d.EmailNotificationPolicy == "none" {
|
|
return
|
|
}
|
|
|
|
// We'll need to check again when we're sending in case the comment was
|
|
// approved midway anyway.
|
|
if d.EmailNotificationPolicy == "pending-moderation" && state == "approved" {
|
|
return
|
|
}
|
|
|
|
var commenterName string
|
|
var commenterEmail string
|
|
if commenterHex == "anonymous" {
|
|
commenterName = "Anonymous"
|
|
} else {
|
|
c, err := commenterGetByHex(commenterHex)
|
|
if err != nil {
|
|
logger.Errorf("cannot get commenter to send email notification: %v", err)
|
|
return
|
|
}
|
|
|
|
commenterName = c.Name
|
|
commenterEmail = c.Email
|
|
}
|
|
|
|
kind := d.EmailNotificationPolicy
|
|
if state != "approved" {
|
|
kind = "pending-moderation"
|
|
}
|
|
|
|
for _, m := range d.Moderators {
|
|
// Do not email the commenting moderator their own comment.
|
|
if commenterHex != "anonymous" && m.Email == commenterEmail {
|
|
continue
|
|
}
|
|
|
|
emailNotificationPendingIncrement(m.Email)
|
|
emailNotificationEnqueue(emailNotification{
|
|
Email: m.Email,
|
|
CommenterName: commenterName,
|
|
Domain: d.Domain,
|
|
Path: path,
|
|
Title: title,
|
|
CommentHex: commentHex,
|
|
Kind: kind,
|
|
})
|
|
}
|
|
}
|
|
|
|
func emailNotificationReply(d domain, path string, title string, commenterHex string, commentHex string, parentHex string, state string) {
|
|
// No reply notifications for root comments.
|
|
if parentHex == "root" {
|
|
return
|
|
}
|
|
|
|
// No reply notification emails for unapproved comments.
|
|
if state != "approved" {
|
|
return
|
|
}
|
|
|
|
statement := `
|
|
SELECT commenterHex
|
|
FROM comments
|
|
WHERE commentHex = $1;
|
|
`
|
|
row := db.QueryRow(statement, parentHex)
|
|
|
|
var parentCommenterHex string
|
|
err := row.Scan(&parentCommenterHex)
|
|
if err != nil {
|
|
logger.Errorf("cannot scan commenterHex and parentCommenterHex: %v", err)
|
|
return
|
|
}
|
|
|
|
// No reply notification emails for anonymous users.
|
|
if parentCommenterHex == "anonymous" {
|
|
return
|
|
}
|
|
|
|
// No reply notification email for self replies.
|
|
if parentCommenterHex == commenterHex {
|
|
return
|
|
}
|
|
|
|
pc, err := commenterGetByHex(parentCommenterHex)
|
|
if err != nil {
|
|
logger.Errorf("cannot get commenter to send email notification: %v", err)
|
|
return
|
|
}
|
|
|
|
var commenterName string
|
|
if commenterHex == "anonymous" {
|
|
commenterName = "Anonymous"
|
|
} else {
|
|
c, err := commenterGetByHex(commenterHex)
|
|
if err != nil {
|
|
logger.Errorf("cannot get commenter to send email notification: %v", err)
|
|
return
|
|
}
|
|
commenterName = c.Name
|
|
}
|
|
|
|
// We'll check if they want to receive reply notifications later at the time
|
|
// of sending.
|
|
emailNotificationEnqueue(emailNotification{
|
|
Email: pc.Email,
|
|
CommenterName: commenterName,
|
|
Domain: d.Domain,
|
|
Path: path,
|
|
Title: title,
|
|
CommentHex: commentHex,
|
|
Kind: "reply",
|
|
})
|
|
}
|
|
|
|
func emailNotificationNew(d domain, path string, commenterHex string, commentHex string, parentHex string, state string) {
|
|
p, err := pageGet(d.Domain, path)
|
|
if err != nil {
|
|
logger.Errorf("cannot get page to send email notification: %v", err)
|
|
return
|
|
}
|
|
|
|
if p.Title == "" {
|
|
p.Title, err = pageTitleUpdate(d.Domain, path)
|
|
if err != nil {
|
|
// Not being able to update a page title isn't serious enough to skip an
|
|
// email notification.
|
|
p.Title = d.Domain
|
|
}
|
|
}
|
|
|
|
emailNotificationModerator(d, path, p.Title, commenterHex, commentHex, state)
|
|
emailNotificationReply(d, path, p.Title, commenterHex, commentHex, parentHex, state)
|
|
}
|