appview: implement pagination for pipelines index #521

ERROR

appview/db/pipeline.go

Failed to calculate interdiff for this file.

ERROR

appview/pages/pages.go

Failed to calculate interdiff for this file.

ERROR

appview/pages/templates/repo/pipelines/pipelines.html

Failed to calculate interdiff for this file.

ERROR

appview/pipelines/pipelines.go

Failed to calculate interdiff for this file.

ERROR

appview/pipelines/router.go

Failed to calculate interdiff for this file.

NEW

appview/db/artifact.go

··· 57 57 return err 58 58 } 59 59 60 60 - func GetArtifact(e Execer, filters ...filter) ([]Artifact, error) { 60 60 + func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) { 61 61 var artifacts []Artifact 62 62 63 63 var conditions []string ··· 130 130 return artifacts, nil 131 131 } 132 132 133 133 - func DeleteArtifact(e Execer, filters ...filter) error { 133 133 + func DeleteArtifact(e Execer, filters ...Filter) error { 134 134 var conditions []string 135 135 var args []any 136 136 for _, filter := range filters {

NEW

appview/db/collaborators.go

··· 30 30 return err 31 31 } 32 32 33 33 - func DeleteCollaborator(e Execer, filters ...filter) error { 33 33 + func DeleteCollaborator(e Execer, filters ...Filter) error { 34 34 var conditions []string 35 35 var args []any 36 36 for _, filter := range filters {

NEW

appview/db/db.go

··· 918 918 return d.DB.Close() 919 919 } 920 920 921 921 - type filter struct { 921 921 + type Filter struct { 922 922 key string 923 923 arg any 924 924 cmp string 925 925 } 926 926 927 927 - func newFilter(key, cmp string, arg any) filter { 928 928 - return filter{ 927 927 + func newFilter(key, cmp string, arg any) Filter { 928 928 + return Filter{ 929 929 key: key, 930 930 arg: arg, 931 931 cmp: cmp, 932 932 } 933 933 } 934 934 935 935 - func FilterEq(key string, arg any) filter { return newFilter(key, "=", arg) } 936 936 - func FilterNotEq(key string, arg any) filter { return newFilter(key, "<>", arg) } 937 937 - func FilterGte(key string, arg any) filter { return newFilter(key, ">=", arg) } 938 938 - func FilterLte(key string, arg any) filter { return newFilter(key, "<=", arg) } 939 939 - func FilterIs(key string, arg any) filter { return newFilter(key, "is", arg) } 940 940 - func FilterIsNot(key string, arg any) filter { return newFilter(key, "is not", arg) } 941 941 - func FilterIn(key string, arg any) filter { return newFilter(key, "in", arg) } 942 942 - func FilterBetween(key string, arg1, arg2 any) filter { 935 935 + func FilterEq(key string, arg any) Filter { return newFilter(key, "=", arg) } 936 936 + func FilterNotEq(key string, arg any) Filter { return newFilter(key, "<>", arg) } 937 937 + func FilterGte(key string, arg any) Filter { return newFilter(key, ">=", arg) } 938 938 + func FilterLte(key string, arg any) Filter { return newFilter(key, "<=", arg) } 939 939 + func FilterIs(key string, arg any) Filter { return newFilter(key, "is", arg) } 940 940 + func FilterIsNot(key string, arg any) Filter { return newFilter(key, "is not", arg) } 941 941 + func FilterIn(key string, arg any) Filter { return newFilter(key, "in", arg) } 942 942 + func FilterBetween(key string, arg1, arg2 any) Filter { 943 943 return newFilter(key, "between", []any{arg1, arg2}) 944 944 } 945 945 946 946 - func (f filter) Condition() string { 946 946 + func (f Filter) Condition() string { 947 947 rv := reflect.ValueOf(f.arg) 948 948 kind := rv.Kind() 949 949 ··· 969 969 return fmt.Sprintf("%s %s ?", f.key, f.cmp) 970 970 } 971 971 972 972 - func (f filter) Arg() []any { 972 972 + func (f Filter) Arg() []any { 973 973 rv := reflect.ValueOf(f.arg) 974 974 kind := rv.Kind() 975 975 if (kind == reflect.Slice && rv.Type().Elem().Kind() != reflect.Uint8) || kind == reflect.Array {

NEW

appview/db/follow.go

··· 144 144 return result, nil 145 145 } 146 146 147 147 - func GetFollows(e Execer, limit int, filters ...filter) ([]Follow, error) { 147 147 + func GetFollows(e Execer, limit int, filters ...Filter) ([]Follow, error) { 148 148 var follows []Follow 149 149 150 150 var conditions []string

NEW

appview/db/issues.go

··· 245 245 return err 246 246 } 247 247 248 248 - func GetIssuesPaginated(e Execer, page pagination.Page, filters ...filter) ([]Issue, error) { 248 248 + func GetIssuesPaginated(e Execer, page pagination.Page, filters ...Filter) ([]Issue, error) { 249 249 issueMap := make(map[string]*Issue) // at-uri -> issue 250 250 251 251 var conditions []string ··· 395 395 return issues, nil 396 396 } 397 397 398 398 - func GetIssues(e Execer, filters ...filter) ([]Issue, error) { 398 398 + func GetIssues(e Execer, filters ...Filter) ([]Issue, error) { 399 399 return GetIssuesPaginated(e, pagination.Page{No: 0, Count: 10}, filters...) 400 400 } 401 401 ··· 462 462 return id, nil 463 463 } 464 464 465 465 - func DeleteIssueComments(e Execer, filters ...filter) error { 465 465 + func DeleteIssueComments(e Execer, filters ...Filter) error { 466 466 var conditions []string 467 467 var args []any 468 468 for _, filter := range filters { ··· 481 481 return err 482 482 } 483 483 484 484 - func GetIssueComments(e Execer, filters ...filter) ([]IssueComment, error) { 484 484 + func GetIssueComments(e Execer, filters ...Filter) ([]IssueComment, error) { 485 485 var comments []IssueComment 486 486 487 487 var conditions []string ··· 571 571 return comments, nil 572 572 } 573 573 574 574 - func DeleteIssues(e Execer, filters ...filter) error { 574 574 + func DeleteIssues(e Execer, filters ...Filter) error { 575 575 var conditions []string 576 576 var args []any 577 577 for _, filter := range filters { ··· 589 589 return err 590 590 } 591 591 592 592 - func CloseIssues(e Execer, filters ...filter) error { 592 592 + func CloseIssues(e Execer, filters ...Filter) error { 593 593 var conditions []string 594 594 var args []any 595 595 for _, filter := range filters { ··· 607 607 return err 608 608 } 609 609 610 610 - func ReopenIssues(e Execer, filters ...filter) error { 610 610 + func ReopenIssues(e Execer, filters ...Filter) error { 611 611 var conditions []string 612 612 var args []any 613 613 for _, filter := range filters {

NEW

appview/db/language.go

··· 16 16 Bytes int64 17 17 } 18 18 19 19 - func GetRepoLanguages(e Execer, filters ...filter) ([]RepoLanguage, error) { 19 19 + func GetRepoLanguages(e Execer, filters ...Filter) ([]RepoLanguage, error) { 20 20 var conditions []string 21 21 var args []any 22 22 for _, filter := range filters {

NEW

appview/db/profile.go

··· 366 366 return tx.Commit() 367 367 } 368 368 369 369 - func GetProfiles(e Execer, filters ...filter) (map[string]*Profile, error) { 369 369 + func GetProfiles(e Execer, filters ...Filter) (map[string]*Profile, error) { 370 370 var conditions []string 371 371 var args []any 372 372 for _, filter := range filters {

NEW

appview/db/pulls.go

··· 311 311 return pullId - 1, err 312 312 } 313 313 314 314 - func GetPullsWithLimit(e Execer, limit int, filters ...filter) ([]*Pull, error) { 314 314 + func GetPullsWithLimit(e Execer, limit int, filters ...Filter) ([]*Pull, error) { 315 315 pulls := make(map[int]*Pull) 316 316 317 317 var conditions []string ··· 529 529 return orderedByPullId, nil 530 530 } 531 531 532 532 - func GetPulls(e Execer, filters ...filter) ([]*Pull, error) { 532 532 + func GetPulls(e Execer, filters ...Filter) ([]*Pull, error) { 533 533 return GetPullsWithLimit(e, 0, filters...) 534 534 } 535 535 ··· 884 884 return err 885 885 } 886 886 887 887 - func SetPullParentChangeId(e Execer, parentChangeId string, filters ...filter) error { 887 887 + func SetPullParentChangeId(e Execer, parentChangeId string, filters ...Filter) error { 888 888 var conditions []string 889 889 var args []any 890 890 ··· 908 908 909 909 // Only used when stacking to update contents in the event of a rebase (the interdiff should be empty). 910 910 // otherwise submissions are immutable 911 911 - func UpdatePull(e Execer, newPatch, sourceRev string, filters ...filter) error { 911 911 + func UpdatePull(e Execer, newPatch, sourceRev string, filters ...Filter) error { 912 912 var conditions []string 913 913 var args []any 914 914

NEW

appview/db/punchcard.go

··· 29 29 Punches []Punch 30 30 } 31 31 32 32 - func MakePunchcard(e Execer, filters ...filter) (*Punchcard, error) { 32 32 + func MakePunchcard(e Execer, filters ...Filter) (*Punchcard, error) { 33 33 punchcard := &Punchcard{} 34 34 now := time.Now() 35 35 startOfYear := time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.UTC)

NEW

appview/db/registration.go

··· 48 48 NeedsUpgrade 49 49 ) 50 50 51 51 - func GetRegistrations(e Execer, filters ...filter) ([]Registration, error) { 51 51 + func GetRegistrations(e Execer, filters ...Filter) ([]Registration, error) { 52 52 var registrations []Registration 53 53 54 54 var conditions []string ··· 108 108 return registrations, nil 109 109 } 110 110 111 111 - func MarkRegistered(e Execer, filters ...filter) error { 111 111 + func MarkRegistered(e Execer, filters ...Filter) error { 112 112 var conditions []string 113 113 var args []any 114 114 for _, filter := range filters { ··· 133 133 return err 134 134 } 135 135 136 136 - func DeleteKnot(e Execer, filters ...filter) error { 136 136 + func DeleteKnot(e Execer, filters ...Filter) error { 137 137 var conditions []string 138 138 var args []any 139 139 for _, filter := range filters {

NEW

appview/db/repos.go

··· 39 39 return p 40 40 } 41 41 42 42 - func GetRepos(e Execer, limit int, filters ...filter) ([]Repo, error) { 42 42 + func GetRepos(e Execer, limit int, filters ...Filter) ([]Repo, error) { 43 43 repoMap := make(map[syntax.ATURI]*Repo) 44 44 45 45 var conditions []string ··· 285 285 return repos, nil 286 286 } 287 287 288 288 - func CountRepos(e Execer, filters ...filter) (int64, error) { 288 288 + func CountRepos(e Execer, filters ...Filter) (int64, error) { 289 289 var conditions []string 290 290 var args []any 291 291 for _, filter := range filters {

NEW

appview/db/spindle.go

··· 27 27 Created time.Time 28 28 } 29 29 30 30 - func GetSpindles(e Execer, filters ...filter) ([]Spindle, error) { 30 30 + func GetSpindles(e Execer, filters ...Filter) ([]Spindle, error) { 31 31 var spindles []Spindle 32 32 33 33 var conditions []string ··· 109 109 return err 110 110 } 111 111 112 112 - func VerifySpindle(e Execer, filters ...filter) (int64, error) { 112 112 + func VerifySpindle(e Execer, filters ...Filter) (int64, error) { 113 113 var conditions []string 114 114 var args []any 115 115 for _, filter := range filters { ··· 132 132 return res.RowsAffected() 133 133 } 134 134 135 135 - func DeleteSpindle(e Execer, filters ...filter) error { 135 135 + func DeleteSpindle(e Execer, filters ...Filter) error { 136 136 var conditions []string 137 137 var args []any 138 138 for _, filter := range filters { ··· 162 162 return err 163 163 } 164 164 165 165 - func RemoveSpindleMember(e Execer, filters ...filter) error { 165 165 + func RemoveSpindleMember(e Execer, filters ...Filter) error { 166 166 var conditions []string 167 167 var args []any 168 168 for _, filter := range filters { ··· 181 181 return err 182 182 } 183 183 184 184 - func GetSpindleMembers(e Execer, filters ...filter) ([]SpindleMember, error) { 184 184 + func GetSpindleMembers(e Execer, filters ...Filter) ([]SpindleMember, error) { 185 185 var members []SpindleMember 186 186 187 187 var conditions []string

NEW

appview/db/star.go

··· 102 102 } 103 103 } 104 104 105 105 - func GetStars(e Execer, limit int, filters ...filter) ([]Star, error) { 105 105 + func GetStars(e Execer, limit int, filters ...Filter) ([]Star, error) { 106 106 var conditions []string 107 107 var args []any 108 108 for _, filter := range filters { ··· 185 185 return stars, nil 186 186 } 187 187 188 188 - func CountStars(e Execer, filters ...filter) (int64, error) { 188 188 + func CountStars(e Execer, filters ...Filter) (int64, error) { 189 189 var conditions []string 190 190 var args []any 191 191 for _, filter := range filters {

NEW

appview/db/strings.go

··· 123 123 return err 124 124 } 125 125 126 126 - func GetStrings(e Execer, limit int, filters ...filter) ([]String, error) { 126 126 + func GetStrings(e Execer, limit int, filters ...Filter) ([]String, error) { 127 127 var all []String 128 128 129 129 var conditions []string ··· 206 206 return all, nil 207 207 } 208 208 209 209 - func CountStrings(e Execer, filters ...filter) (int64, error) { 209 209 + func CountStrings(e Execer, filters ...Filter) (int64, error) { 210 210 var conditions []string 211 211 var args []any 212 212 for _, filter := range filters { ··· 230 230 return count, nil 231 231 } 232 232 233 233 - func DeleteString(e Execer, filters ...filter) error { 233 233 + func DeleteString(e Execer, filters ...Filter) error { 234 234 var conditions []string 235 235 var args []any 236 236 for _, filter := range filters {