Платформа ЦРНП "Мирокод" для разработки проектов
https://git.mirocod.ru
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
100 lines
2.7 KiB
100 lines
2.7 KiB
// Copyright 2020 The Gitea Authors. All rights reserved. |
|
// Use of this source code is governed by a MIT-style |
|
// license that can be found in the LICENSE file. |
|
|
|
package mailer |
|
|
|
import ( |
|
"bytes" |
|
|
|
"code.gitea.io/gitea/models" |
|
"code.gitea.io/gitea/models/db" |
|
repo_model "code.gitea.io/gitea/models/repo" |
|
user_model "code.gitea.io/gitea/models/user" |
|
"code.gitea.io/gitea/modules/base" |
|
"code.gitea.io/gitea/modules/log" |
|
"code.gitea.io/gitea/modules/markup" |
|
"code.gitea.io/gitea/modules/markup/markdown" |
|
"code.gitea.io/gitea/modules/setting" |
|
"code.gitea.io/gitea/modules/templates" |
|
"code.gitea.io/gitea/modules/translation" |
|
) |
|
|
|
const ( |
|
tplNewReleaseMail base.TplName = "release" |
|
) |
|
|
|
// MailNewRelease send new release notify to all all repo watchers. |
|
func MailNewRelease(rel *models.Release) { |
|
if setting.MailService == nil { |
|
// No mail service configured |
|
return |
|
} |
|
|
|
watcherIDList, err := repo_model.GetRepoWatchersIDs(db.DefaultContext, rel.RepoID) |
|
if err != nil { |
|
log.Error("GetRepoWatchersIDs(%d): %v", rel.RepoID, err) |
|
return |
|
} |
|
|
|
recipients, err := user_model.GetMaileableUsersByIDs(watcherIDList, false) |
|
if err != nil { |
|
log.Error("user_model.GetMaileableUsersByIDs: %v", err) |
|
return |
|
} |
|
|
|
langMap := make(map[string][]string) |
|
for _, user := range recipients { |
|
if user.ID != rel.PublisherID { |
|
langMap[user.Language] = append(langMap[user.Language], user.Email) |
|
} |
|
} |
|
|
|
for lang, tos := range langMap { |
|
mailNewRelease(lang, tos, rel) |
|
} |
|
} |
|
|
|
func mailNewRelease(lang string, tos []string, rel *models.Release) { |
|
locale := translation.NewLocale(lang) |
|
|
|
var err error |
|
rel.RenderedNote, err = markdown.RenderString(&markup.RenderContext{ |
|
URLPrefix: rel.Repo.Link(), |
|
Metas: rel.Repo.ComposeMetas(), |
|
}, rel.Note) |
|
if err != nil { |
|
log.Error("markdown.RenderString(%d): %v", rel.RepoID, err) |
|
return |
|
} |
|
|
|
subject := locale.Tr("mail.release.new.subject", rel.TagName, rel.Repo.FullName()) |
|
mailMeta := map[string]interface{}{ |
|
"Release": rel, |
|
"Subject": subject, |
|
"Language": locale.Language(), |
|
// helper |
|
"i18n": locale, |
|
"Str2html": templates.Str2html, |
|
"DotEscape": templates.DotEscape, |
|
} |
|
|
|
var mailBody bytes.Buffer |
|
|
|
if err := bodyTemplates.ExecuteTemplate(&mailBody, string(tplNewReleaseMail), mailMeta); err != nil { |
|
log.Error("ExecuteTemplate [%s]: %v", string(tplNewReleaseMail)+"/body", err) |
|
return |
|
} |
|
|
|
msgs := make([]*Message, 0, len(tos)) |
|
publisherName := rel.Publisher.DisplayName() |
|
relURL := "<" + rel.HTMLURL() + ">" |
|
for _, to := range tos { |
|
msg := NewMessageFrom([]string{to}, publisherName, setting.MailService.FromEmail, subject, mailBody.String()) |
|
msg.Info = subject |
|
msg.SetHeader("Message-ID", relURL) |
|
msgs = append(msgs, msg) |
|
} |
|
|
|
SendAsyncs(msgs) |
|
}
|
|
|