willdot.net / tangled-fork
forked from tangled.org/core
Monorepo for Tangled
fork atom

appview/db: add limit to GetRepos

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

oppi.li e590d819 c44a81a5

verified
+15 -2
unified split
+9 -2
appview/db/repos.go
··· 73 return repos, nil 74 } 75 76 - func GetRepos(e Execer, filters ...filter) ([]Repo, error) { 77 repoMap := make(map[syntax.ATURI]*Repo) 78 79 var conditions []string ··· 88 whereClause = " where " + strings.Join(conditions, " and ") 89 } 90 91 repoQuery := fmt.Sprintf( 92 `select 93 did, ··· 100 spindle 101 from 102 repos r 103 %s`, 104 whereClause, 105 ) 106 rows, err := e.Query(repoQuery, args...) 107 ··· 585 return nil, nil 586 } 587 588 - return GetRepos(e, FilterIn("id", repoIds)) 589 } 590 591 type RepoStats struct {
··· 73 return repos, nil 74 } 75 76 + func GetRepos(e Execer, limit int, filters ...filter) ([]Repo, error) { 77 repoMap := make(map[syntax.ATURI]*Repo) 78 79 var conditions []string ··· 88 whereClause = " where " + strings.Join(conditions, " and ") 89 } 90 91 + limitClause := "" 92 + if limit != 0 { 93 + limitClause = fmt.Sprintf(" limit %d", limit) 94 + } 95 + 96 repoQuery := fmt.Sprintf( 97 `select 98 did, ··· 105 spindle 106 from 107 repos r 108 + %s 109 %s`, 110 whereClause, 111 + limitClause, 112 ) 113 rows, err := e.Query(repoQuery, args...) 114 ··· 592 return nil, nil 593 } 594 595 + return GetRepos(e, 0, FilterIn("id", repoIds)) 596 } 597 598 type RepoStats struct {
+1
appview/knots/knots.go
··· 319 320 repos, err := db.GetRepos( 321 k.Db, 322 db.FilterEq("knot", domain), 323 db.FilterIn("did", members), 324 )
··· 319 320 repos, err := db.GetRepos( 321 k.Db, 322 + 0, 323 db.FilterEq("knot", domain), 324 db.FilterIn("did", members), 325 )
+1
appview/spindles/spindles.go
··· 104 105 repos, err := db.GetRepos( 106 s.Db, 107 db.FilterEq("spindle", instance), 108 ) 109 if err != nil {
··· 104 105 repos, err := db.GetRepos( 106 s.Db, 107 + 0, 108 db.FilterEq("spindle", instance), 109 ) 110 if err != nil {
+2
appview/state/knotstream.go
··· 136 137 repos, err := db.GetRepos( 138 d, 139 db.FilterEq("did", record.RepoDid), 140 db.FilterEq("name", record.RepoName), 141 ) ··· 188 // does this repo have a spindle configured? 189 repos, err := db.GetRepos( 190 d, 191 db.FilterEq("did", record.TriggerMetadata.Repo.Did), 192 db.FilterEq("name", record.TriggerMetadata.Repo.Repo), 193 )
··· 136 137 repos, err := db.GetRepos( 138 d, 139 + 0, 140 db.FilterEq("did", record.RepoDid), 141 db.FilterEq("name", record.RepoName), 142 ) ··· 189 // does this repo have a spindle configured? 190 repos, err := db.GetRepos( 191 d, 192 + 0, 193 db.FilterEq("did", record.TriggerMetadata.Repo.Did), 194 db.FilterEq("name", record.TriggerMetadata.Repo.Repo), 195 )
+2
appview/state/profile.go
··· 52 53 repos, err := db.GetRepos( 54 s.db, 55 db.FilterEq("did", ident.DID.String()), 56 ) 57 if err != nil { ··· 176 177 repos, err := db.GetRepos( 178 s.db, 179 db.FilterEq("did", ident.DID.String()), 180 ) 181 if err != nil {
··· 52 53 repos, err := db.GetRepos( 54 s.db, 55 + 0, 56 db.FilterEq("did", ident.DID.String()), 57 ) 58 if err != nil { ··· 177 178 repos, err := db.GetRepos( 179 s.db, 180 + 0, 181 db.FilterEq("did", ident.DID.String()), 182 ) 183 if err != nil {