123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317 |
- // Copyright 2021 The Gitea Authors. All rights reserved.
- // SPDX-License-Identifier: MIT
-
- package feed
-
- import (
- "fmt"
- "html"
- "net/http"
- "net/url"
- "strconv"
- "strings"
-
- activities_model "code.gitea.io/gitea/models/activities"
- repo_model "code.gitea.io/gitea/models/repo"
- "code.gitea.io/gitea/modules/context"
- "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/util"
-
- "github.com/gorilla/feeds"
- )
-
- func toBranchLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/src/branch/" + util.PathEscapeSegments(act.GetBranch())
- }
-
- func toTagLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/src/tag/" + util.PathEscapeSegments(act.GetTag())
- }
-
- func toIssueLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/issues/" + url.PathEscape(act.GetIssueInfos()[0])
- }
-
- func toPullLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/pulls/" + url.PathEscape(act.GetIssueInfos()[0])
- }
-
- func toSrcLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/src/" + util.PathEscapeSegments(act.GetBranch())
- }
-
- func toReleaseLink(ctx *context.Context, act *activities_model.Action) string {
- return act.GetRepoAbsoluteLink(ctx) + "/releases/tag/" + util.PathEscapeSegments(act.GetBranch())
- }
-
- // renderMarkdown creates a minimal markdown render context from an action.
- // If rendering fails, the original markdown text is returned
- func renderMarkdown(ctx *context.Context, act *activities_model.Action, content string) string {
- markdownCtx := &markup.RenderContext{
- Ctx: ctx,
- Links: markup.Links{
- Base: act.GetRepoLink(ctx),
- },
- Type: markdown.MarkupName,
- Metas: map[string]string{
- "user": act.GetRepoUserName(ctx),
- "repo": act.GetRepoName(ctx),
- },
- }
- markdown, err := markdown.RenderString(markdownCtx, content)
- if err != nil {
- return content
- }
- return markdown
- }
-
- // feedActionsToFeedItems convert gitea's Action feed to feeds Item
- func feedActionsToFeedItems(ctx *context.Context, actions activities_model.ActionList) (items []*feeds.Item, err error) {
- for _, act := range actions {
- act.LoadActUser(ctx)
-
- var content, desc, title string
-
- link := &feeds.Link{Href: act.GetCommentHTMLURL(ctx)}
-
- // title
- title = act.ActUser.DisplayName() + " "
- switch act.OpType {
- case activities_model.ActionCreateRepo:
- title += ctx.TrHTMLEscapeArgs("action.create_repo", act.GetRepoAbsoluteLink(ctx), act.ShortRepoPath(ctx))
- link.Href = act.GetRepoAbsoluteLink(ctx)
- case activities_model.ActionRenameRepo:
- title += ctx.TrHTMLEscapeArgs("action.rename_repo", act.GetContent(), act.GetRepoAbsoluteLink(ctx), act.ShortRepoPath(ctx))
- link.Href = act.GetRepoAbsoluteLink(ctx)
- case activities_model.ActionCommitRepo:
- link.Href = toBranchLink(ctx, act)
- if len(act.Content) != 0 {
- title += ctx.TrHTMLEscapeArgs("action.commit_repo", act.GetRepoAbsoluteLink(ctx), link.Href, act.GetBranch(), act.ShortRepoPath(ctx))
- } else {
- title += ctx.TrHTMLEscapeArgs("action.create_branch", act.GetRepoAbsoluteLink(ctx), link.Href, act.GetBranch(), act.ShortRepoPath(ctx))
- }
- case activities_model.ActionCreateIssue:
- link.Href = toIssueLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.create_issue", link.Href, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionCreatePullRequest:
- link.Href = toPullLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.create_pull_request", link.Href, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionTransferRepo:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.transfer_repo", act.GetContent(), act.GetRepoAbsoluteLink(ctx), act.ShortRepoPath(ctx))
- case activities_model.ActionPushTag:
- link.Href = toTagLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.push_tag", act.GetRepoAbsoluteLink(ctx), link.Href, act.GetTag(), act.ShortRepoPath(ctx))
- case activities_model.ActionCommentIssue:
- issueLink := toIssueLink(ctx, act)
- if link.Href == "#" {
- link.Href = issueLink
- }
- title += ctx.TrHTMLEscapeArgs("action.comment_issue", issueLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionMergePullRequest:
- pullLink := toPullLink(ctx, act)
- if link.Href == "#" {
- link.Href = pullLink
- }
- title += ctx.TrHTMLEscapeArgs("action.merge_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionAutoMergePullRequest:
- pullLink := toPullLink(ctx, act)
- if link.Href == "#" {
- link.Href = pullLink
- }
- title += ctx.TrHTMLEscapeArgs("action.auto_merge_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionCloseIssue:
- issueLink := toIssueLink(ctx, act)
- if link.Href == "#" {
- link.Href = issueLink
- }
- title += ctx.TrHTMLEscapeArgs("action.close_issue", issueLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionReopenIssue:
- issueLink := toIssueLink(ctx, act)
- if link.Href == "#" {
- link.Href = issueLink
- }
- title += ctx.TrHTMLEscapeArgs("action.reopen_issue", issueLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionClosePullRequest:
- pullLink := toPullLink(ctx, act)
- if link.Href == "#" {
- link.Href = pullLink
- }
- title += ctx.TrHTMLEscapeArgs("action.close_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionReopenPullRequest:
- pullLink := toPullLink(ctx, act)
- if link.Href == "#" {
- link.Href = pullLink
- }
- title += ctx.TrHTMLEscapeArgs("action.reopen_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionDeleteTag:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.delete_tag", act.GetRepoAbsoluteLink(ctx), act.GetTag(), act.ShortRepoPath(ctx))
- case activities_model.ActionDeleteBranch:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.delete_branch", act.GetRepoAbsoluteLink(ctx), html.EscapeString(act.GetBranch()), act.ShortRepoPath(ctx))
- case activities_model.ActionMirrorSyncPush:
- srcLink := toSrcLink(ctx, act)
- if link.Href == "#" {
- link.Href = srcLink
- }
- title += ctx.TrHTMLEscapeArgs("action.mirror_sync_push", act.GetRepoAbsoluteLink(ctx), srcLink, act.GetBranch(), act.ShortRepoPath(ctx))
- case activities_model.ActionMirrorSyncCreate:
- srcLink := toSrcLink(ctx, act)
- if link.Href == "#" {
- link.Href = srcLink
- }
- title += ctx.TrHTMLEscapeArgs("action.mirror_sync_create", act.GetRepoAbsoluteLink(ctx), srcLink, act.GetBranch(), act.ShortRepoPath(ctx))
- case activities_model.ActionMirrorSyncDelete:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.mirror_sync_delete", act.GetRepoAbsoluteLink(ctx), act.GetBranch(), act.ShortRepoPath(ctx))
- case activities_model.ActionApprovePullRequest:
- pullLink := toPullLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.approve_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionRejectPullRequest:
- pullLink := toPullLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.reject_pull_request", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionCommentPull:
- pullLink := toPullLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.comment_pull", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx))
- case activities_model.ActionPublishRelease:
- releaseLink := toReleaseLink(ctx, act)
- if link.Href == "#" {
- link.Href = releaseLink
- }
- title += ctx.TrHTMLEscapeArgs("action.publish_release", act.GetRepoAbsoluteLink(ctx), releaseLink, act.ShortRepoPath(ctx), act.Content)
- case activities_model.ActionPullReviewDismissed:
- pullLink := toPullLink(ctx, act)
- title += ctx.TrHTMLEscapeArgs("action.review_dismissed", pullLink, act.GetIssueInfos()[0], act.ShortRepoPath(ctx), act.GetIssueInfos()[1])
- case activities_model.ActionStarRepo:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.starred_repo", act.GetRepoAbsoluteLink(ctx), act.GetRepoPath(ctx))
- case activities_model.ActionWatchRepo:
- link.Href = act.GetRepoAbsoluteLink(ctx)
- title += ctx.TrHTMLEscapeArgs("action.watched_repo", act.GetRepoAbsoluteLink(ctx), act.GetRepoPath(ctx))
- default:
- return nil, fmt.Errorf("unknown action type: %v", act.OpType)
- }
-
- // description & content
- {
- switch act.OpType {
- case activities_model.ActionCommitRepo, activities_model.ActionMirrorSyncPush:
- push := templates.ActionContent2Commits(act)
-
- for _, commit := range push.Commits {
- if len(desc) != 0 {
- desc += "\n\n"
- }
- desc += fmt.Sprintf("<a href=\"%s\">%s</a>\n%s",
- html.EscapeString(fmt.Sprintf("%s/commit/%s", act.GetRepoAbsoluteLink(ctx), commit.Sha1)),
- commit.Sha1,
- templates.RenderCommitMessage(ctx, commit.Message, nil),
- )
- }
-
- if push.Len > 1 {
- link = &feeds.Link{Href: fmt.Sprintf("%s/%s", setting.AppSubURL, push.CompareURL)}
- } else if push.Len == 1 {
- link = &feeds.Link{Href: fmt.Sprintf("%s/commit/%s", act.GetRepoAbsoluteLink(ctx), push.Commits[0].Sha1)}
- }
-
- case activities_model.ActionCreateIssue, activities_model.ActionCreatePullRequest:
- desc = strings.Join(act.GetIssueInfos(), "#")
- content = renderMarkdown(ctx, act, act.GetIssueContent(ctx))
- case activities_model.ActionCommentIssue, activities_model.ActionApprovePullRequest, activities_model.ActionRejectPullRequest, activities_model.ActionCommentPull:
- desc = act.GetIssueTitle(ctx)
- comment := act.GetIssueInfos()[1]
- if len(comment) != 0 {
- desc += "\n\n" + renderMarkdown(ctx, act, comment)
- }
- case activities_model.ActionMergePullRequest, activities_model.ActionAutoMergePullRequest:
- desc = act.GetIssueInfos()[1]
- case activities_model.ActionCloseIssue, activities_model.ActionReopenIssue, activities_model.ActionClosePullRequest, activities_model.ActionReopenPullRequest:
- desc = act.GetIssueTitle(ctx)
- case activities_model.ActionPullReviewDismissed:
- desc = ctx.Tr("action.review_dismissed_reason") + "\n\n" + act.GetIssueInfos()[2]
- }
- }
- if len(content) == 0 {
- content = desc
- }
-
- items = append(items, &feeds.Item{
- Title: title,
- Link: link,
- Description: desc,
- Author: &feeds.Author{
- Name: act.ActUser.DisplayName(),
- Email: act.ActUser.GetEmail(),
- },
- Id: fmt.Sprintf("%v: %v", strconv.FormatInt(act.ID, 10), link.Href),
- Created: act.CreatedUnix.AsTime(),
- Content: content,
- })
- }
- return items, err
- }
-
- // GetFeedType return if it is a feed request and altered name and feed type.
- func GetFeedType(name string, req *http.Request) (bool, string, string) {
- if strings.HasSuffix(name, ".rss") ||
- strings.Contains(req.Header.Get("Accept"), "application/rss+xml") {
- return true, strings.TrimSuffix(name, ".rss"), "rss"
- }
-
- if strings.HasSuffix(name, ".atom") ||
- strings.Contains(req.Header.Get("Accept"), "application/atom+xml") {
- return true, strings.TrimSuffix(name, ".atom"), "atom"
- }
-
- return false, name, ""
- }
-
- // feedActionsToFeedItems convert gitea's Repo's Releases to feeds Item
- func releasesToFeedItems(ctx *context.Context, releases []*repo_model.Release, isReleasesOnly bool) (items []*feeds.Item, err error) {
- for _, rel := range releases {
- err := rel.LoadAttributes(ctx)
- if err != nil {
- return nil, err
- }
-
- var title, content string
-
- if rel.IsTag {
- title = rel.TagName
- } else {
- title = rel.Title
- }
-
- link := &feeds.Link{Href: rel.HTMLURL()}
- content, err = markdown.RenderString(&markup.RenderContext{
- Ctx: ctx,
- Links: markup.Links{
- Base: rel.Repo.Link(),
- },
- Metas: rel.Repo.ComposeMetas(),
- }, rel.Note)
-
- if err != nil {
- return nil, err
- }
-
- items = append(items, &feeds.Item{
- Title: title,
- Link: link,
- Created: rel.CreatedUnix.AsTime(),
- Author: &feeds.Author{
- Name: rel.Publisher.DisplayName(),
- Email: rel.Publisher.GetEmail(),
- },
- Id: fmt.Sprintf("%v: %v", strconv.FormatInt(rel.ID, 10), link.Href),
- Content: content,
- })
- }
-
- return items, err
- }
|