back interdiff of round #1 and #0

appview: implement pagination for pipelines index #521

closed
opened by ptr.pet targeting master from ptr.pet/core: 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
···
return err
}
-
func GetArtifact(e Execer, filters ...filter) ([]Artifact, error) {
+
func GetArtifact(e Execer, filters ...Filter) ([]Artifact, error) {
var artifacts []Artifact
var conditions []string
···
return artifacts, nil
}
-
func DeleteArtifact(e Execer, filters ...filter) error {
+
func DeleteArtifact(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/collaborators.go
···
return err
}
-
func DeleteCollaborator(e Execer, filters ...filter) error {
+
func DeleteCollaborator(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/db.go
···
return d.DB.Close()
}
-
type filter struct {
+
type Filter struct {
key string
arg any
cmp string
}
-
func newFilter(key, cmp string, arg any) filter {
-
return filter{
+
func newFilter(key, cmp string, arg any) Filter {
+
return Filter{
key: key,
arg: arg,
cmp: cmp,
}
}
-
func FilterEq(key string, arg any) filter { return newFilter(key, "=", arg) }
-
func FilterNotEq(key string, arg any) filter { return newFilter(key, "<>", arg) }
-
func FilterGte(key string, arg any) filter { return newFilter(key, ">=", arg) }
-
func FilterLte(key string, arg any) filter { return newFilter(key, "<=", arg) }
-
func FilterIs(key string, arg any) filter { return newFilter(key, "is", arg) }
-
func FilterIsNot(key string, arg any) filter { return newFilter(key, "is not", arg) }
-
func FilterIn(key string, arg any) filter { return newFilter(key, "in", arg) }
-
func FilterBetween(key string, arg1, arg2 any) filter {
+
func FilterEq(key string, arg any) Filter { return newFilter(key, "=", arg) }
+
func FilterNotEq(key string, arg any) Filter { return newFilter(key, "<>", arg) }
+
func FilterGte(key string, arg any) Filter { return newFilter(key, ">=", arg) }
+
func FilterLte(key string, arg any) Filter { return newFilter(key, "<=", arg) }
+
func FilterIs(key string, arg any) Filter { return newFilter(key, "is", arg) }
+
func FilterIsNot(key string, arg any) Filter { return newFilter(key, "is not", arg) }
+
func FilterIn(key string, arg any) Filter { return newFilter(key, "in", arg) }
+
func FilterBetween(key string, arg1, arg2 any) Filter {
return newFilter(key, "between", []any{arg1, arg2})
}
-
func (f filter) Condition() string {
+
func (f Filter) Condition() string {
rv := reflect.ValueOf(f.arg)
kind := rv.Kind()
···
return fmt.Sprintf("%s %s ?", f.key, f.cmp)
}
-
func (f filter) Arg() []any {
+
func (f Filter) Arg() []any {
rv := reflect.ValueOf(f.arg)
kind := rv.Kind()
if (kind == reflect.Slice && rv.Type().Elem().Kind() != reflect.Uint8) || kind == reflect.Array {
NEW
appview/db/follow.go
···
return result, nil
}
-
func GetFollows(e Execer, limit int, filters ...filter) ([]Follow, error) {
+
func GetFollows(e Execer, limit int, filters ...Filter) ([]Follow, error) {
var follows []Follow
var conditions []string
NEW
appview/db/issues.go
···
return err
}
-
func GetIssuesPaginated(e Execer, page pagination.Page, filters ...filter) ([]Issue, error) {
+
func GetIssuesPaginated(e Execer, page pagination.Page, filters ...Filter) ([]Issue, error) {
issueMap := make(map[string]*Issue) // at-uri -> issue
var conditions []string
···
return issues, nil
}
-
func GetIssues(e Execer, filters ...filter) ([]Issue, error) {
+
func GetIssues(e Execer, filters ...Filter) ([]Issue, error) {
return GetIssuesPaginated(e, pagination.Page{No: 0, Count: 10}, filters...)
}
···
return id, nil
}
-
func DeleteIssueComments(e Execer, filters ...filter) error {
+
func DeleteIssueComments(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func GetIssueComments(e Execer, filters ...filter) ([]IssueComment, error) {
+
func GetIssueComments(e Execer, filters ...Filter) ([]IssueComment, error) {
var comments []IssueComment
var conditions []string
···
return comments, nil
}
-
func DeleteIssues(e Execer, filters ...filter) error {
+
func DeleteIssues(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func CloseIssues(e Execer, filters ...filter) error {
+
func CloseIssues(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func ReopenIssues(e Execer, filters ...filter) error {
+
func ReopenIssues(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/language.go
···
Bytes int64
}
-
func GetRepoLanguages(e Execer, filters ...filter) ([]RepoLanguage, error) {
+
func GetRepoLanguages(e Execer, filters ...Filter) ([]RepoLanguage, error) {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/profile.go
···
return tx.Commit()
}
-
func GetProfiles(e Execer, filters ...filter) (map[string]*Profile, error) {
+
func GetProfiles(e Execer, filters ...Filter) (map[string]*Profile, error) {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/pulls.go
···
return pullId - 1, err
}
-
func GetPullsWithLimit(e Execer, limit int, filters ...filter) ([]*Pull, error) {
+
func GetPullsWithLimit(e Execer, limit int, filters ...Filter) ([]*Pull, error) {
pulls := make(map[int]*Pull)
var conditions []string
···
return orderedByPullId, nil
}
-
func GetPulls(e Execer, filters ...filter) ([]*Pull, error) {
+
func GetPulls(e Execer, filters ...Filter) ([]*Pull, error) {
return GetPullsWithLimit(e, 0, filters...)
}
···
return err
}
-
func SetPullParentChangeId(e Execer, parentChangeId string, filters ...filter) error {
+
func SetPullParentChangeId(e Execer, parentChangeId string, filters ...Filter) error {
var conditions []string
var args []any
···
// Only used when stacking to update contents in the event of a rebase (the interdiff should be empty).
// otherwise submissions are immutable
-
func UpdatePull(e Execer, newPatch, sourceRev string, filters ...filter) error {
+
func UpdatePull(e Execer, newPatch, sourceRev string, filters ...Filter) error {
var conditions []string
var args []any
NEW
appview/db/punchcard.go
···
Punches []Punch
}
-
func MakePunchcard(e Execer, filters ...filter) (*Punchcard, error) {
+
func MakePunchcard(e Execer, filters ...Filter) (*Punchcard, error) {
punchcard := &Punchcard{}
now := time.Now()
startOfYear := time.Date(now.Year(), 1, 1, 0, 0, 0, 0, time.UTC)
NEW
appview/db/registration.go
···
NeedsUpgrade
)
-
func GetRegistrations(e Execer, filters ...filter) ([]Registration, error) {
+
func GetRegistrations(e Execer, filters ...Filter) ([]Registration, error) {
var registrations []Registration
var conditions []string
···
return registrations, nil
}
-
func MarkRegistered(e Execer, filters ...filter) error {
+
func MarkRegistered(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func DeleteKnot(e Execer, filters ...filter) error {
+
func DeleteKnot(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/repos.go
···
return p
}
-
func GetRepos(e Execer, limit int, filters ...filter) ([]Repo, error) {
+
func GetRepos(e Execer, limit int, filters ...Filter) ([]Repo, error) {
repoMap := make(map[syntax.ATURI]*Repo)
var conditions []string
···
return repos, nil
}
-
func CountRepos(e Execer, filters ...filter) (int64, error) {
+
func CountRepos(e Execer, filters ...Filter) (int64, error) {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/spindle.go
···
Created time.Time
}
-
func GetSpindles(e Execer, filters ...filter) ([]Spindle, error) {
+
func GetSpindles(e Execer, filters ...Filter) ([]Spindle, error) {
var spindles []Spindle
var conditions []string
···
return err
}
-
func VerifySpindle(e Execer, filters ...filter) (int64, error) {
+
func VerifySpindle(e Execer, filters ...Filter) (int64, error) {
var conditions []string
var args []any
for _, filter := range filters {
···
return res.RowsAffected()
}
-
func DeleteSpindle(e Execer, filters ...filter) error {
+
func DeleteSpindle(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func RemoveSpindleMember(e Execer, filters ...filter) error {
+
func RemoveSpindleMember(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {
···
return err
}
-
func GetSpindleMembers(e Execer, filters ...filter) ([]SpindleMember, error) {
+
func GetSpindleMembers(e Execer, filters ...Filter) ([]SpindleMember, error) {
var members []SpindleMember
var conditions []string
NEW
appview/db/star.go
···
}
}
-
func GetStars(e Execer, limit int, filters ...filter) ([]Star, error) {
+
func GetStars(e Execer, limit int, filters ...Filter) ([]Star, error) {
var conditions []string
var args []any
for _, filter := range filters {
···
return stars, nil
}
-
func CountStars(e Execer, filters ...filter) (int64, error) {
+
func CountStars(e Execer, filters ...Filter) (int64, error) {
var conditions []string
var args []any
for _, filter := range filters {
NEW
appview/db/strings.go
···
return err
}
-
func GetStrings(e Execer, limit int, filters ...filter) ([]String, error) {
+
func GetStrings(e Execer, limit int, filters ...Filter) ([]String, error) {
var all []String
var conditions []string
···
return all, nil
}
-
func CountStrings(e Execer, filters ...filter) (int64, error) {
+
func CountStrings(e Execer, filters ...Filter) (int64, error) {
var conditions []string
var args []any
for _, filter := range filters {
···
return count, nil
}
-
func DeleteString(e Execer, filters ...filter) error {
+
func DeleteString(e Execer, filters ...Filter) error {
var conditions []string
var args []any
for _, filter := range filters {