TakeV
/
forgejo
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Generate person outbox for only repo creates and stars

This commit is contained in:
Anthony Wang 2022-07-16 20:33:28 -05:00
parent b491a2ec34
commit 705706bc00
No known key found for this signature in database
GPG Key ID: BC96B00AEC5F2D76
1 changed files with 26 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
routers/api/v1/activitypub/person.go
View File

@ -9,6 +9,7 @@ import (
"net/http"
"code.gitea.io/gitea/models"
"code.gitea.io/gitea/models/db"
"code.gitea.io/gitea/models/forgefed"
repo_model "code.gitea.io/gitea/models/repo"
user_model "code.gitea.io/gitea/models/user"
@ -138,31 +139,43 @@ func PersonOutbox(ctx *context.APIContext) {
link := setting.AppURL + "api/v1/activitypub/user/" + ctx.ContextUser.Name
outbox := ap.OrderedCollectionNew(ap.IRI(link + "/outbox"))
feed, err := models.GetFeeds(ctx, models.GetFeedsOptions{
RequestedUser: ctx.ContextUser,
Actor: ctx.ContextUser,
IncludePrivate: false,
OnlyPerformedBy: true,
IncludeDeleted: false,
ListOptions: db.ListOptions{Page: 1, PageSize: 1000000},
})
if err != nil {
ctx.ServerError("Couldn't fetch outbox", err)
ctx.ServerError("Couldn't fetch feed", err)
return
}
outbox := ap.OrderedCollectionNew(ap.IRI(link + "/outbox"))
for _, action := range feed {
// TODO: There are 26 action types! This is going to take quite a while to implement...
log.Debug("action", action)
var activity ap.ObjectOrLink
switch action.OpType {
case models.ActionCreateRepo:
activity = ap.Create{Type: ap.CreateType} //, Object: forgefed.RepositoryNew()}
case models.ActionRenameRepo:
activity = ap.Move{Type: ap.MoveType} //, Object: forgefed.RepositoryNew()}
// etc
if action.OpType == models.ActionCreateRepo {
// Created a repo
object := ap.Note{Type: ap.NoteType, Content: ap.NaturalLanguageValuesNew()}
object.Content.Set("en", ap.Content(action.GetRepoName()))
create := ap.Create{Type: ap.CreateType, Object: object}
outbox.OrderedItems.Append(create)
}
outbox.OrderedItems.Append(activity)
}
stars, err := repo_model.GetStarredRepos(ctx.ContextUser.ID, false, db.ListOptions{Page: 1, PageSize: 1000000})
if err != nil {
ctx.ServerError("Couldn't fetch stars", err)
return
}
for _, star := range stars {
object := ap.Note{Type: ap.NoteType, Content: ap.NaturalLanguageValuesNew()}
object.Content.Set("en", ap.Content("Starred " + star.Name))
create := ap.Create{Type: ap.CreateType, Object: object}
outbox.OrderedItems.Append(create)
}
outbox.TotalItems = uint(len(outbox.OrderedItems))
response(ctx, outbox)