back interdiff of round #1 and #0

appview: implement pagination for pipelines index #521

closed
opened by ptr.pet targeting master from [deleted fork]: pipeline-paginated
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 return err 58 } 59 60 - func GetArtifact(e Execer, filters ...filter) ([]Artifact, error) { 61 var artifacts []Artifact 62 63 var conditions []string ··· 130 return artifacts, nil 131 } 132 133 - func DeleteArtifact(e Execer, filters ...filter) error { 134 var conditions []string 135 var args []any 136 for _, filter := range filters {
··· 57 return err 58 } 59 60 + func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) { 61 var artifacts []Artifact 62 63 var conditions []string ··· 130 return artifacts, nil 131 } 132 133 + func DeleteArtifact(e Execer, filters ...Filter) error { 134 var conditions []string 135 var args []any 136 for _, filter := range filters {
NEW
appview/db/collaborators.go
··· 30 return err 31 } 32 33 - func DeleteCollaborator(e Execer, filters ...filter) error { 34 var conditions []string 35 var args []any 36 for _, filter := range filters {
··· 30 return err 31 } 32 33 + func DeleteCollaborator(e Execer, filters ...Filter) error { 34 var conditions []string 35 var args []any 36 for _, filter := range filters {
NEW
appview/db/db.go
··· 918 return d.DB.Close() 919 } 920 921 - type filter struct { 922 key string 923 arg any 924 cmp string 925 } 926 927 - func newFilter(key, cmp string, arg any) filter { 928 - return filter{ 929 key: key, 930 arg: arg, 931 cmp: cmp, 932 } 933 } 934 935 - func FilterEq(key string, arg any) filter { return newFilter(key, "=", arg) } 936 - func FilterNotEq(key string, arg any) filter { return newFilter(key, "<>", arg) } 937 - func FilterGte(key string, arg any) filter { return newFilter(key, ">=", arg) } 938 - func FilterLte(key string, arg any) filter { return newFilter(key, "<=", arg) } 939 - func FilterIs(key string, arg any) filter { return newFilter(key, "is", arg) } 940 - func FilterIsNot(key string, arg any) filter { return newFilter(key, "is not", arg) } 941 - func FilterIn(key string, arg any) filter { return newFilter(key, "in", arg) } 942 - func FilterBetween(key string, arg1, arg2 any) filter { 943 return newFilter(key, "between", []any{arg1, arg2}) 944 } 945 946 - func (f filter) Condition() string { 947 rv := reflect.ValueOf(f.arg) 948 kind := rv.Kind() 949 ··· 969 return fmt.Sprintf("%s %s ?", f.key, f.cmp) 970 } 971 972 - func (f filter) Arg() []any { 973 rv := reflect.ValueOf(f.arg) 974 kind := rv.Kind() 975 if (kind == reflect.Slice && rv.Type().Elem().Kind() != reflect.Uint8) || kind == reflect.Array {
··· 918 return d.DB.Close() 919 } 920 921 + type Filter struct { 922 key string 923 arg any 924 cmp string 925 } 926 927 + func newFilter(key, cmp string, arg any) Filter { 928 + return Filter{ 929 key: key, 930 arg: arg, 931 cmp: cmp, 932 } 933 } 934 935 + func FilterEq(key string, arg any) Filter { return newFilter(key, "=", arg) } 936 + func FilterNotEq(key string, arg any) Filter { return newFilter(key, "<>", arg) } 937 + func FilterGte(key string, arg any) Filter { return newFilter(key, ">=", arg) } 938 + func FilterLte(key string, arg any) Filter { return newFilter(key, "<=", arg) } 939 + func FilterIs(key string, arg any) Filter { return newFilter(key, "is", arg) } 940 + func FilterIsNot(key string, arg any) Filter { return newFilter(key, "is not", arg) } 941 + func FilterIn(key string, arg any) Filter { return newFilter(key, "in", arg) } 942 + func FilterBetween(key string, arg1, arg2 any) Filter { 943 return newFilter(key, "between", []any{arg1, arg2}) 944 } 945 946 + func (f Filter) Condition() string { 947 rv := reflect.ValueOf(f.arg) 948 kind := rv.Kind() 949 ··· 969 return fmt.Sprintf("%s %s ?", f.key, f.cmp) 970 } 971 972 + func (f Filter) Arg() []any { 973 rv := reflect.ValueOf(f.arg) 974 kind := rv.Kind() 975 if (kind == reflect.Slice && rv.Type().Elem().Kind() != reflect.Uint8) || kind == reflect.Array {
NEW
appview/db/follow.go
··· 144 return result, nil 145 } 146 147 - func GetFollows(e Execer, limit int, filters ...filter) ([]Follow, error) { 148 var follows []Follow 149 150 var conditions []string
··· 144 return result, nil 145 } 146 147 + func GetFollows(e Execer, limit int, filters ...Filter) ([]Follow, error) { 148 var follows []Follow 149 150 var conditions []string
NEW
appview/db/issues.go
··· 245 return err 246 } 247 248 - func GetIssuesPaginated(e Execer, page pagination.Page, filters ...filter) ([]Issue, error) { 249 issueMap := make(map[string]*Issue) // at-uri -> issue 250 251 var conditions []string ··· 395 return issues, nil 396 } 397 398 - func GetIssues(e Execer, filters ...filter) ([]Issue, error) { 399 return GetIssuesPaginated(e, pagination.Page{No: 0, Count: 10}, filters...) 400 } 401 ··· 462 return id, nil 463 } 464 465 - func DeleteIssueComments(e Execer, filters ...filter) error { 466 var conditions []string 467 var args []any 468 for _, filter := range filters { ··· 481 return err 482 } 483 484 - func GetIssueComments(e Execer, filters ...filter) ([]IssueComment, error) { 485 var comments []IssueComment 486 487 var conditions []string ··· 571 return comments, nil 572 } 573 574 - func DeleteIssues(e Execer, filters ...filter) error { 575 var conditions []string 576 var args []any 577 for _, filter := range filters { ··· 589 return err 590 } 591 592 - func CloseIssues(e Execer, filters ...filter) error { 593 var conditions []string 594 var args []any 595 for _, filter := range filters { ··· 607 return err 608 } 609 610 - func ReopenIssues(e Execer, filters ...filter) error { 611 var conditions []string 612 var args []any 613 for _, filter := range filters {
··· 245 return err 246 } 247 248 + func GetIssuesPaginated(e Execer, page pagination.Page, filters ...Filter) ([]Issue, error) { 249 issueMap := make(map[string]*Issue) // at-uri -> issue 250 251 var conditions []string ··· 395 return issues, nil 396 } 397 398 + func GetIssues(e Execer, filters ...Filter) ([]Issue, error) { 399 return GetIssuesPaginated(e, pagination.Page{No: 0, Count: 10}, filters...) 400 } 401 ··· 462 return id, nil 463 } 464 465 + func DeleteIssueComments(e Execer, filters ...Filter) error { 466 var conditions []string 467 var args []any 468 for _, filter := range filters { ··· 481 return err 482 } 483 484 + func GetIssueComments(e Execer, filters ...Filter) ([]IssueComment, error) { 485 var comments []IssueComment 486 487 var conditions []string ··· 571 return comments, nil 572 } 573 574 + func DeleteIssues(e Execer, filters ...Filter) error { 575 var conditions []string 576 var args []any 577 for _, filter := range filters { ··· 589 return err 590 } 591 592 + func CloseIssues(e Execer, filters ...Filter) error { 593 var conditions []string 594 var args []any 595 for _, filter := range filters { ··· 607 return err 608 } 609 610 + func ReopenIssues(e Execer, filters ...Filter) error { 611 var conditions []string 612 var args []any 613 for _, filter := range filters {
NEW
appview/db/language.go
··· 16 Bytes int64 17 } 18 19 - func GetRepoLanguages(e Execer, filters ...filter) ([]RepoLanguage, error) { 20 var conditions []string 21 var args []any 22 for _, filter := range filters {
··· 16 Bytes int64 17 } 18 19 + func GetRepoLanguages(e Execer, filters ...Filter) ([]RepoLanguage, error) { 20 var conditions []string 21 var args []any 22 for _, filter := range filters {
NEW
appview/db/profile.go
··· 366 return tx.Commit() 367 } 368 369 - func GetProfiles(e Execer, filters ...filter) (map[string]*Profile, error) { 370 var conditions []string 371 var args []any 372 for _, filter := range filters {
··· 366 return tx.Commit() 367 } 368 369 + func GetProfiles(e Execer, filters ...Filter) (map[string]*Profile, error) { 370 var conditions []string 371 var args []any 372 for _, filter := range filters {
NEW
appview/db/pulls.go
··· 311 return pullId - 1, err 312 } 313 314 - func GetPullsWithLimit(e Execer, limit int, filters ...filter) ([]*Pull, error) { 315 pulls := make(map[int]*Pull) 316 317 var conditions []string ··· 529 return orderedByPullId, nil 530 } 531 532 - func GetPulls(e Execer, filters ...filter) ([]*Pull, error) { 533 return GetPullsWithLimit(e, 0, filters...) 534 } 535 ··· 884 return err 885 } 886 887 - func SetPullParentChangeId(e Execer, parentChangeId string, filters ...filter) error { 888 var conditions []string 889 var args []any 890 ··· 908 909 // Only used when stacking to update contents in the event of a rebase (the interdiff should be empty). 910 // otherwise submissions are immutable 911 - func UpdatePull(e Execer, newPatch, sourceRev string, filters ...filter) error { 912 var conditions []string 913 var args []any 914
··· 311 return pullId - 1, err 312 } 313 314 + func GetPullsWithLimit(e Execer, limit int, filters ...Filter) ([]*Pull, error) { 315 pulls := make(map[int]*Pull) 316 317 var conditions []string ··· 529 return orderedByPullId, nil 530 } 531 532 + func GetPulls(e Execer, filters ...Filter) ([]*Pull, error) { 533 return GetPullsWithLimit(e, 0, filters...) 534 } 535 ··· 884 return err 885 } 886 887 + func SetPullParentChangeId(e Execer, parentChangeId string, filters ...Filter) error { 888 var conditions []string 889 var args []any 890 ··· 908 909 // Only used when stacking to update contents in the event of a rebase (the interdiff should be empty). 910 // otherwise submissions are immutable 911 + func UpdatePull(e Execer, newPatch, sourceRev string, filters ...Filter) error { 912 var conditions []string 913 var args []any 914
NEW
appview/db/punchcard.go
··· 29 Punches []Punch 30 } 31 32 - func MakePunchcard(e Execer, filters ...filter) (*Punchcard, error) { 33 punchcard := &Punchcard{} 34 now := time.Now() 35 startOfYear := time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.UTC)
··· 29 Punches []Punch 30 } 31 32 + func MakePunchcard(e Execer, filters ...Filter) (*Punchcard, error) { 33 punchcard := &Punchcard{} 34 now := time.Now() 35 startOfYear := time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.UTC)
NEW
appview/db/registration.go
··· 48 NeedsUpgrade 49 ) 50 51 - func GetRegistrations(e Execer, filters ...filter) ([]Registration, error) { 52 var registrations []Registration 53 54 var conditions []string ··· 108 return registrations, nil 109 } 110 111 - func MarkRegistered(e Execer, filters ...filter) error { 112 var conditions []string 113 var args []any 114 for _, filter := range filters { ··· 133 return err 134 } 135 136 - func DeleteKnot(e Execer, filters ...filter) error { 137 var conditions []string 138 var args []any 139 for _, filter := range filters {
··· 48 NeedsUpgrade 49 ) 50 51 + func GetRegistrations(e Execer, filters ...Filter) ([]Registration, error) { 52 var registrations []Registration 53 54 var conditions []string ··· 108 return registrations, nil 109 } 110 111 + func MarkRegistered(e Execer, filters ...Filter) error { 112 var conditions []string 113 var args []any 114 for _, filter := range filters { ··· 133 return err 134 } 135 136 + func DeleteKnot(e Execer, filters ...Filter) error { 137 var conditions []string 138 var args []any 139 for _, filter := range filters {
NEW
appview/db/repos.go
··· 39 return p 40 } 41 42 - func GetRepos(e Execer, limit int, filters ...filter) ([]Repo, error) { 43 repoMap := make(map[syntax.ATURI]*Repo) 44 45 var conditions []string ··· 285 return repos, nil 286 } 287 288 - func CountRepos(e Execer, filters ...filter) (int64, error) { 289 var conditions []string 290 var args []any 291 for _, filter := range filters {
··· 39 return p 40 } 41 42 + func GetRepos(e Execer, limit int, filters ...Filter) ([]Repo, error) { 43 repoMap := make(map[syntax.ATURI]*Repo) 44 45 var conditions []string ··· 285 return repos, nil 286 } 287 288 + func CountRepos(e Execer, filters ...Filter) (int64, error) { 289 var conditions []string 290 var args []any 291 for _, filter := range filters {
NEW
appview/db/spindle.go
··· 27 Created time.Time 28 } 29 30 - func GetSpindles(e Execer, filters ...filter) ([]Spindle, error) { 31 var spindles []Spindle 32 33 var conditions []string ··· 109 return err 110 } 111 112 - func VerifySpindle(e Execer, filters ...filter) (int64, error) { 113 var conditions []string 114 var args []any 115 for _, filter := range filters { ··· 132 return res.RowsAffected() 133 } 134 135 - func DeleteSpindle(e Execer, filters ...filter) error { 136 var conditions []string 137 var args []any 138 for _, filter := range filters { ··· 162 return err 163 } 164 165 - func RemoveSpindleMember(e Execer, filters ...filter) error { 166 var conditions []string 167 var args []any 168 for _, filter := range filters { ··· 181 return err 182 } 183 184 - func GetSpindleMembers(e Execer, filters ...filter) ([]SpindleMember, error) { 185 var members []SpindleMember 186 187 var conditions []string
··· 27 Created time.Time 28 } 29 30 + func GetSpindles(e Execer, filters ...Filter) ([]Spindle, error) { 31 var spindles []Spindle 32 33 var conditions []string ··· 109 return err 110 } 111 112 + func VerifySpindle(e Execer, filters ...Filter) (int64, error) { 113 var conditions []string 114 var args []any 115 for _, filter := range filters { ··· 132 return res.RowsAffected() 133 } 134 135 + func DeleteSpindle(e Execer, filters ...Filter) error { 136 var conditions []string 137 var args []any 138 for _, filter := range filters { ··· 162 return err 163 } 164 165 + func RemoveSpindleMember(e Execer, filters ...Filter) error { 166 var conditions []string 167 var args []any 168 for _, filter := range filters { ··· 181 return err 182 } 183 184 + func GetSpindleMembers(e Execer, filters ...Filter) ([]SpindleMember, error) { 185 var members []SpindleMember 186 187 var conditions []string
NEW
appview/db/star.go
··· 102 } 103 } 104 105 - func GetStars(e Execer, limit int, filters ...filter) ([]Star, error) { 106 var conditions []string 107 var args []any 108 for _, filter := range filters { ··· 185 return stars, nil 186 } 187 188 - func CountStars(e Execer, filters ...filter) (int64, error) { 189 var conditions []string 190 var args []any 191 for _, filter := range filters {
··· 102 } 103 } 104 105 + func GetStars(e Execer, limit int, filters ...Filter) ([]Star, error) { 106 var conditions []string 107 var args []any 108 for _, filter := range filters { ··· 185 return stars, nil 186 } 187 188 + func CountStars(e Execer, filters ...Filter) (int64, error) { 189 var conditions []string 190 var args []any 191 for _, filter := range filters {
NEW
appview/db/strings.go
··· 123 return err 124 } 125 126 - func GetStrings(e Execer, limit int, filters ...filter) ([]String, error) { 127 var all []String 128 129 var conditions []string ··· 206 return all, nil 207 } 208 209 - func CountStrings(e Execer, filters ...filter) (int64, error) { 210 var conditions []string 211 var args []any 212 for _, filter := range filters { ··· 230 return count, nil 231 } 232 233 - func DeleteString(e Execer, filters ...filter) error { 234 var conditions []string 235 var args []any 236 for _, filter := range filters {
··· 123 return err 124 } 125 126 + func GetStrings(e Execer, limit int, filters ...Filter) ([]String, error) { 127 var all []String 128 129 var conditions []string ··· 206 return all, nil 207 } 208 209 + func CountStrings(e Execer, filters ...Filter) (int64, error) { 210 var conditions []string 211 var args []any 212 for _, filter := range filters { ··· 230 return count, nil 231 } 232 233 + func DeleteString(e Execer, filters ...Filter) error { 234 var conditions []string 235 var args []any 236 for _, filter := range filters {