Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337package repo
import ( "context" "encoding/json" "fmt" "net/http" "slices" "strings" "time"
"tangled.org/core/api/tangled" "tangled.org/core/appview/db" "tangled.org/core/appview/models" "tangled.org/core/appview/pagination" "tangled.org/core/orm" "tangled.org/core/types"
"github.com/bluesky-social/indigo/atproto/identity" "github.com/bluesky-social/indigo/atproto/syntax" indigoxrpc "github.com/bluesky-social/indigo/xrpc" "github.com/gorilla/feeds")
// which types of items to include in the feed.type FeedOpts struct { IncludeIssues bool IncludePulls bool IncludeCommits bool IncludeTags bool}
func parseFeedOpts(r *http.Request) FeedOpts { includeParam := r.URL.Query().Get("include")
// default: include everything if includeParam == "" { return FeedOpts{ IncludeIssues: true, IncludePulls: true, IncludeCommits: true, IncludeTags: true, } }
// parse comma-separated list opts := FeedOpts{} types := strings.SplitSeq(includeParam, ",") for t := range types { switch strings.TrimSpace(strings.ToLower(t)) { case "issues": opts.IncludeIssues = true case "pulls", "prs": opts.IncludePulls = true case "commits": opts.IncludeCommits = true case "tags": opts.IncludeTags = true } }
return opts}
func (rp *Repo) getRepoFeed(ctx context.Context, repo *models.Repo, ownerSlashRepo string, opts FeedOpts) (*feeds.Feed, error) { feedPagePerType := pagination.Page{Limit: 100}
feed := &feeds.Feed{ Title: fmt.Sprintf("activity feed for @%s", ownerSlashRepo), Link: &feeds.Link{Href: fmt.Sprintf("%s/%s", rp.config.Core.BaseUrl(), ownerSlashRepo), Type: "text/html", Rel: "alternate"}, Items: make([]*feeds.Item, 0), Updated: time.UnixMilli(0), }
// fetch and add pull requests if requested if opts.IncludePulls { pulls, err := db.GetPullsPaginated(rp.db, feedPagePerType, orm.FilterEq("repo_did", repo.RepoDid)) if err != nil { return nil, err }
for _, pull := range pulls { items, err := rp.createPullItems(ctx, pull, ownerSlashRepo) if err != nil { return nil, err } feed.Items = append(feed.Items, items...) } }
// fetch and add issues if requested if opts.IncludeIssues { issues, err := db.GetIssuesPaginated( rp.db, feedPagePerType, orm.FilterEq("repo_did", repo.RepoDid), ) if err != nil { return nil, err }
for _, issue := range issues { item, err := rp.createIssueItem(ctx, issue, ownerSlashRepo) if err != nil { return nil, err } feed.Items = append(feed.Items, item) } }
// fetch and add commits if requested if opts.IncludeCommits { commitItems, err := rp.createCommitItems(ctx, repo, ownerSlashRepo) if err != nil { // Soft failure: log error and continue with partial feed rp.logger.Error("failed to fetch commits for feed", "err", err) } else { feed.Items = append(feed.Items, commitItems...) } }
// fetch and add tags if requested if opts.IncludeTags { tagItems, err := rp.createTagItems(ctx, repo, ownerSlashRepo) if err != nil { // Soft failure: log error and continue with partial feed rp.logger.Error("failed to fetch tags for feed", "err", err) } else { feed.Items = append(feed.Items, tagItems...) } }
slices.SortFunc(feed.Items, func(a, b *feeds.Item) int { if a.Created.After(b.Created) { return -1 } return 1 })
if len(feed.Items) > 100 { feed.Items = feed.Items[:100] }
if len(feed.Items) > 0 { feed.Updated = feed.Items[0].Created }
return feed, nil}
func (rp *Repo) createPullItems(ctx context.Context, pull *models.Pull, ownerSlashRepo string) ([]*feeds.Item, error) { owner, err := rp.idResolver.ResolveIdent(ctx, pull.OwnerDid) if err != nil { return nil, err }
var items []*feeds.Item
state := rp.getPullState(pull) description := rp.buildPullDescription(owner.Handle, state, pull, ownerSlashRepo)
mainItem := &feeds.Item{ Title: fmt.Sprintf("[PR #%d] %s", pull.PullId, pull.Title), Description: description, Link: &feeds.Link{Href: fmt.Sprintf("%s/%s/pulls/%d", rp.config.Core.BaseUrl(), ownerSlashRepo, pull.PullId)}, Created: pull.Created, Author: &feeds.Author{Name: fmt.Sprintf("%s", owner.Handle)}, } items = append(items, mainItem)
for _, round := range pull.Submissions { if round == nil || round.RoundNumber == 0 { continue }
roundItem := &feeds.Item{ Title: fmt.Sprintf("[PR #%d] %s (round #%d)", pull.PullId, pull.Title, round.RoundNumber), Description: fmt.Sprintf("%s submitted changes (at round #%d) on PR #%d in %s", owner.Handle, round.RoundNumber, pull.PullId, ownerSlashRepo), Link: &feeds.Link{Href: fmt.Sprintf("%s/%s/pulls/%d/round/%d/", rp.config.Core.BaseUrl(), ownerSlashRepo, pull.PullId, round.RoundNumber)}, Created: round.Created, Author: &feeds.Author{Name: fmt.Sprintf("@%s", owner.Handle)}, } items = append(items, roundItem) }
return items, nil}
func (rp *Repo) createIssueItem(ctx context.Context, issue models.Issue, ownerSlashRepo string) (*feeds.Item, error) { owner, err := rp.idResolver.ResolveIdent(ctx, issue.Did) if err != nil { return nil, err }
state := "closed" if issue.Open { state = "opened" }
return &feeds.Item{ Title: fmt.Sprintf("[Issue #%d] %s", issue.IssueId, issue.Title), Description: fmt.Sprintf("%s %s issue #%d in %s", owner.Handle, state, issue.IssueId, ownerSlashRepo), Link: &feeds.Link{Href: fmt.Sprintf("%s/%s/issues/%d", rp.config.Core.BaseUrl(), ownerSlashRepo, issue.IssueId)}, Created: issue.Created, Author: &feeds.Author{Name: owner.Handle.String()}, }, nil}
func (rp *Repo) createCommitItems(ctx context.Context, repo *models.Repo, ownerSlashRepo string) ([]*feeds.Item, error) { xrpcc := &indigoxrpc.Client{Host: rp.config.KnotMirror.Url}
xrpcBytes, err := tangled.GitTempListCommits(ctx, xrpcc, "", 100, "", repo.RepoDid) if err != nil { return nil, fmt.Errorf("failed to call XRPC repo.log: %w", err) }
var xrpcResp types.RepoLogResponse if err := json.Unmarshal(xrpcBytes, &xrpcResp); err != nil { return nil, fmt.Errorf("failed to decode XRPC response: %w", err) }
var items []*feeds.Item for _, commit := range xrpcResp.Commits { messageLines := strings.SplitN(commit.Message, "\n", 2) firstLine := messageLines[0] if firstLine == "" { firstLine = "(no message)" }
shortHash := commit.Hash.String() if len(shortHash) > 7 { shortHash = shortHash[:7] }
item := &feeds.Item{ Title: fmt.Sprintf("[Commit %s] %s", shortHash, firstLine), Description: commit.Message, Link: &feeds.Link{Href: fmt.Sprintf("%s/%s/commit/%s", rp.config.Core.BaseUrl(), ownerSlashRepo, commit.Hash.String())}, Created: commit.Author.When, Author: &feeds.Author{Name: commit.Author.Name, Email: commit.Author.Email}, } items = append(items, item) }
return items, nil}
func (rp *Repo) createTagItems(ctx context.Context, repo *models.Repo, ownerSlashRepo string) ([]*feeds.Item, error) { xrpcc := &indigoxrpc.Client{Host: rp.config.KnotMirror.Url}
tagBytes, err := tangled.GitTempListTags(ctx, xrpcc, "", 100, repo.RepoDid) if err != nil { return nil, fmt.Errorf("failed to call XRPC repo.tags: %w", err) }
var tagResp types.RepoTagsResponse if err := json.Unmarshal(tagBytes, &tagResp); err != nil { return nil, fmt.Errorf("failed to decode XRPC response: %w", err) }
var items []*feeds.Item for _, tag := range tagResp.Tags { var description string
// only handle annotated tags for now if tag.Tag != nil { if tag.Tag.Message != "" { description = fmt.Sprintf("Tag %s created by %s:\n\n%s", tag.Name, tag.Tag.Tagger.Name, tag.Tag.Message) } else { description = fmt.Sprintf("Tag %s created by %s", tag.Name, tag.Tag.Tagger.Name) }
item := &feeds.Item{ Title: fmt.Sprintf("[Tag] %s", tag.Name), Description: description, Link: &feeds.Link{Href: fmt.Sprintf("%s/%s/tags/%s", rp.config.Core.BaseUrl(), ownerSlashRepo, tag.Name)}, Created: tag.Tag.Tagger.When, Author: &feeds.Author{ Name: tag.Tag.Tagger.Name, Email: tag.Tag.Tagger.Email, }, } items = append(items, item) } }
return items, nil}
func (rp *Repo) getPullState(pull *models.Pull) string { if pull.State == models.PullOpen { return "opened" } return pull.State.String()}
func (rp *Repo) buildPullDescription(handle syntax.Handle, state string, pull *models.Pull, repoName string) string { base := fmt.Sprintf("@%s %s pull request #%d", handle, state, pull.PullId)
if pull.State == models.PullMerged { return fmt.Sprintf("%s (on round #%d) in %s", base, pull.LastRoundNumber(), repoName) }
return fmt.Sprintf("%s in %s", base, repoName)}
func (rp *Repo) AtomFeed(w http.ResponseWriter, r *http.Request) { f, err := rp.repoResolver.Resolve(r) if err != nil { rp.logger.Error("failed to fully resolve repo", "err", err) return } repoOwnerId, ok := r.Context().Value("resolvedId").(identity.Identity) if !ok || repoOwnerId.Handle.IsInvalidHandle() { rp.logger.Error("failed to get resolved repo owner id") return } ownerSlashRepo := repoOwnerId.Handle.String() + "/" + f.Slug()
opts := parseFeedOpts(r) feed, err := rp.getRepoFeed(r.Context(), f, ownerSlashRepo, opts) if err != nil { rp.logger.Error("failed to get repo feed", "err", err) rp.pages.Error500(w) return }
atom, err := feed.ToAtom() if err != nil { rp.pages.Error500(w) return }
w.Header().Set("content-type", "application/atom+xml") w.Write([]byte(atom))}