Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
4.4 kB · 204 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205package db
import ( "database/sql" "fmt" "strings" "time"
"tangled.org/core/appview/models" "tangled.org/core/orm")
func GetRegistrations(e Execer, filters ...orm.Filter) ([]models.Registration, error) { var registrations []models.Registration
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, domain, did, created, registered, needs_upgrade from registrations %s order by created `, whereClause, )
rows, err := e.Query(query, args...) if err != nil { return nil, err } defer rows.Close()
for rows.Next() { var createdAt string var registeredAt sql.Null[string] var needsUpgrade int var reg models.Registration
err = rows.Scan(®.Id, ®.Domain, ®.ByDid, &createdAt, ®isteredAt, &needsUpgrade) if err != nil { return nil, err }
if t, err := time.Parse(time.RFC3339, createdAt); err == nil { reg.Created = &t }
if registeredAt.Valid { if t, err := time.Parse(time.RFC3339, registeredAt.V); err == nil { reg.Registered = &t } }
if needsUpgrade != 0 { reg.NeedsUpgrade = true }
registrations = append(registrations, reg) }
return registrations, nil}
func MarkRegistered(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()...) }
query := "update registrations set registered = strftime('%Y-%m-%dT%H:%M:%SZ', 'now'), needs_upgrade = 0" if len(conditions) > 0 { query += " where " + strings.Join(conditions, " and ") }
_, err := e.Exec(query, args...) return err}
func AddKnot(e Execer, domain, did string) error { _, err := e.Exec(` insert into registrations (domain, did) values (?, ?) on conflict (domain, did) do nothing `, domain, did) return err}
func DeleteKnot(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 registrations %s`, whereClause)
_, err := e.Exec(query, args...) return err}
func AddKnotMember(e Execer, member models.KnotMember) error { _, err := e.Exec( `insert into knot_members (did, rkey, domain, subject) values (?, ?, ?, ?) on conflict (did, domain, subject) do update set rkey = excluded.rkey`, member.Did, member.Rkey, member.Domain, member.Subject, ) return err}
func RemoveKnotMember(e Execer, filters ...orm.Filter) error { if len(filters) == 0 { return fmt.Errorf("RemoveKnotMember requires at least one filter") }
var conditions []string var args []any for _, filter := range filters { conditions = append(conditions, filter.Condition()) args = append(args, filter.Arg()...) }
query := fmt.Sprintf(`delete from knot_members where %s`, strings.Join(conditions, " and "))
_, err := e.Exec(query, args...) return err}
func GetKnotMembers(e Execer, filters ...orm.Filter) ([]models.KnotMember, error) { var members []models.KnotMember
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, did, rkey, domain, subject, created from knot_members %s order by created `, whereClause, )
rows, err := e.Query(query, args...) if err != nil { return nil, err } defer rows.Close()
for rows.Next() { var member models.KnotMember var createdAt string
if err := rows.Scan( &member.Id, &member.Did, &member.Rkey, &member.Domain, &member.Subject, &createdAt, ); err != nil { return nil, err }
member.Created, err = time.Parse(time.RFC3339, createdAt) if err != nil { member.Created = time.Now() }
members = append(members, member) }
return members, nil}