appview/pipelines: add limit to pipelines query

Signed-off-by: oppiliappan <[e-mail]>

appview/db/pipeline.go

···
 
 // this is a mega query, but the most useful one:
 // get N pipelines, for each one get the latest status of its N workflows
-func GetPipelineStatuses(e Execer, filters ...filter) ([]models.Pipeline, error) {
+func GetPipelineStatuses(e Execer, limit int, filters ...filter) ([]models.Pipeline, error) {
 	var conditions []string
 	var args []any
 	for _, filter := range filters {
···
 		join
 			triggers t ON p.trigger_id = t.id
 		%s
-	`, whereClause)
+		order by p.created desc
+		limit %d
+	`, whereClause, limit)
 
 	rows, err := e.Query(query, args...)
 	if err != nil {

appview/pipelines/pipelines.go

···
 
 	ps, err := db.GetPipelineStatuses(
 		p.db,
+		30,
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),
···
 
 	ps, err := db.GetPipelineStatuses(
 		p.db,
+		1,
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),
···
 
 	ps, err := db.GetPipelineStatuses(
 		p.db,
+		1,
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),

appview/pulls/pulls.go

···
 
 	ps, err := db.GetPipelineStatuses(
 		s.db,
+		len(shas),
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),
···
 	repoInfo := f.RepoInfo(user)
 	ps, err := db.GetPipelineStatuses(
 		s.db,
+		len(shas),
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),

appview/repo/repo_util.go

···
 package repo
 
 import (
-	"crypto/rand"
-	"math/big"
 	"slices"
 	"sort"
 	"strings"
···
 	return
 }
 
-func randomString(n int) string {
-	const letters = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
-	result := make([]byte, n)
-
-	for i := 0; i < n; i++ {
-		n, _ := rand.Int(rand.Reader, big.NewInt(int64(len(letters))))
-		result[i] = letters[n.Int64()]
-	}
-
-	return string(result)
-}
-
 // grab pipelines from DB and munge that into a hashmap with commit sha as key
 //
 // golang is so blessed that it requires 35 lines of imperative code for this
···
 
 	ps, err := db.GetPipelineStatuses(
 		d,
+		len(shas),
 		db.FilterEq("repo_owner", repoInfo.OwnerDid),
 		db.FilterEq("repo_name", repoInfo.Name),
 		db.FilterEq("knot", repoInfo.Knot),