pdewey.com / tangled-core
forked from tangled.org/core
Monorepo for Tangled
fork atom

appview/ingester: ingest label ops on pulls too

Signed-off-by: oppiliappan <me@oppi.li>

oppi.li 18989027 998c7b1b

verified
+13 -2
unified split
+13 -2
appview/ingester.go
··· 1008 1008 subject := syntax.ATURI(record.Subject) 1009 1009 collection := subject.Collection() 1010 1010 1011 - var repo *models.Repo 1011 + var repoAt syntax.ATURI 1012 1012 switch collection { 1013 1013 case tangled.RepoIssueNSID: 1014 1014 i, err := db.GetIssues(ddb, orm.FilterEq("at_uri", subject)) 1015 1015 if err != nil || len(i) != 1 { 1016 1016 return fmt.Errorf("failed to find subject: %w || subject count %d", err, len(i)) 1017 1017 } 1018 - repo = i[0].Repo 1018 + repoAt = i[0].RepoAt 1019 + case tangled.RepoPullNSID: 1020 + p, err := db.GetPulls(ddb, orm.FilterEq("at_uri", subject)) 1021 + if err != nil || len(p) != 1 { 1022 + return fmt.Errorf("failed to find subject: %w || subject count %d", err, len(p)) 1023 + } 1024 + repoAt = p[0].RepoAt 1019 1025 default: 1020 1026 return fmt.Errorf("unsupport label subject: %s", collection) 1027 + } 1028 + 1029 + repo, err := db.GetRepo(ddb, orm.FilterEq("at_uri", repoAt)) 1030 + if err != nil { 1031 + return fmt.Errorf("failed to find source repo: %w, %s", err, repoAt) 1021 1032 } 1022 1033 1023 1034 actx, err := db.NewLabelApplicationCtx(ddb, orm.FilterIn("at_uri", repo.Labels))