Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
1.0 kB · 50 lines
Go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051package db
func AddDid(q DBTX, did string) error { _, err := q.Exec(`insert or ignore into known_dids (did) values (?)`, did) return err}
func IsDidKnown(q DBTX, did string) (bool, error) { var exists bool err := q.QueryRow(`select exists (select 1 from known_dids where did = ?)`, did).Scan(&exists) return exists, err}
func RemoveDid(q DBTX, did string) error { _, err := q.Exec(`delete from known_dids where did = ?`, did) return err}
func (d *DB) GetAllDids() ([]string, error) { var dids []string
rows, err := d.db.Query(`select did from known_dids`) if err != nil { return nil, err } defer rows.Close()
for rows.Next() { var did string if err := rows.Scan(&did); err != nil { return nil, err } dids = append(dids, did) }
if err := rows.Err(); err != nil { return nil, err }
return dids, nil}
func (d *DB) HasKnownDids() bool { var count int err := d.db.QueryRow(`select count(*) from known_dids`).Scan(&count) if err != nil { return false } return count > 0}