Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
2.6 kB · 119 lines
Go
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120package db
import ( "database/sql" "fmt" "strings"
"github.com/bluesky-social/indigo/atproto/syntax" "tangled.org/core/appview/models" "tangled.org/core/orm")
func GetRepoLanguages(e Execer, filters ...orm.Filter) ([]models.RepoLanguage, error) { var conditions []string var args []any for _, filter := range filters { conditions = append(conditions, filter.Condition()) args = append(args, filter.Arg()...) }
whereClause := "" if conditions != nil { whereClause = " where " + strings.Join(conditions, " and ") }
query := fmt.Sprintf( `select id, repo_at, ref, is_default_ref, language, bytes from repo_languages %s`, whereClause, ) rows, err := e.Query(query, args...) if err != nil { return nil, fmt.Errorf("failed to execute query: %w ", err) } defer rows.Close()
var langs []models.RepoLanguage for rows.Next() { var rl models.RepoLanguage var isDefaultRef int
err := rows.Scan( &rl.Id, &rl.RepoAt, &rl.Ref, &isDefaultRef, &rl.Language, &rl.Bytes, ) if err != nil { return nil, fmt.Errorf("failed to scan: %w ", err) }
if isDefaultRef != 0 { rl.IsDefaultRef = true }
langs = append(langs, rl) } if err = rows.Err(); err != nil { return nil, fmt.Errorf("failed to scan rows: %w ", err) }
return langs, nil}
func InsertRepoLanguages(e Execer, langs []models.RepoLanguage) error { stmt, err := e.Prepare( "insert or replace into repo_languages (repo_at, ref, is_default_ref, language, bytes) values (?, ?, ?, ?, ?)", ) if err != nil { return err }
for _, l := range langs { isDefaultRef := 0 if l.IsDefaultRef { isDefaultRef = 1 }
_, err := stmt.Exec(l.RepoAt, l.Ref, isDefaultRef, l.Language, l.Bytes) if err != nil { return err } }
return nil}
func DeleteRepoLanguages(e Execer, filters ...orm.Filter) error { var conditions []string var args []any for _, filter := range filters { conditions = append(conditions, filter.Condition()) args = append(args, filter.Arg()...) }
whereClause := "" if conditions != nil { whereClause = " where " + strings.Join(conditions, " and ") }
query := fmt.Sprintf(`delete from repo_languages %s`, whereClause)
_, err := e.Exec(query, args...) return err}
func UpdateRepoLanguages(tx *sql.Tx, repoAt syntax.ATURI, ref string, langs []models.RepoLanguage) error { err := DeleteRepoLanguages( tx, orm.FilterEq("repo_at", repoAt), orm.FilterEq("ref", ref), ) if err != nil { return fmt.Errorf("failed to delete existing languages: %w", err) }
return InsertRepoLanguages(tx, langs)}