Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
2.4 kB · 114 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115package db
import ( "database/sql" "fmt" "strings" "time"
"tangled.org/core/appview/models")
func GetRegistrations(e Execer, filters ...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 }
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 ...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 (?, ?) `, domain, did) return err}
func DeleteKnot(e Execer, filters ...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}