Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
1.2 kB · 50 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051package pulls
import ( "net/http" "time"
comatproto "github.com/bluesky-social/indigo/api/atproto" "github.com/bluesky-social/indigo/atproto/syntax" lexutil "github.com/bluesky-social/indigo/lex/util" "github.com/samber/lo"
"tangled.org/core/api/tangled" "tangled.org/core/appview/models" "tangled.org/core/tid")
func (s *Pulls) writePullStatusRecords(r *http.Request, actorDid string, subjects []syntax.ATURI, value models.StateValue) error { if len(subjects) == 0 { return nil }
client, err := s.oauth.AuthorizedClient(r) if err != nil { return err }
records, err := models.AsPullStatusRecords(subjects, value, time.Now()) if err != nil { return err }
writes := lo.Map(records, func(record tangled.RepoPullStatus, _ int) *comatproto.RepoApplyWrites_Input_Writes_Elem { rkey := tid.TID() return &comatproto.RepoApplyWrites_Input_Writes_Elem{ RepoApplyWrites_Create: &comatproto.RepoApplyWrites_Create{ Collection: tangled.RepoPullStatusNSID, Rkey: &rkey, Value: &lexutil.LexiconTypeDecoder{ Val: &record, }, }, } })
_, err = comatproto.RepoApplyWrites(r.Context(), client, &comatproto.RepoApplyWrites_Input{ Repo: actorDid, Writes: writes, }) return err}