tangled.org / core
this repo has no description
fork atom

make jetstream inserts conflict tolerant

Akshay 3eff756d 95df0d12

options
unified split
Changed files
+2 -2
knotserver
db
known_dids.go
pubkeys.go
+1 -1
knotserver/db/known_dids.go
··· 1 1 package db 2 2 3 3 func (d *DB) AddDid(did string) error { 4 - _, err := d.db.Exec(`insert into known_dids (did) values (?)`, did) 4 + _, err := d.db.Exec(`insert or ignore into known_dids (did) values (?)`, did) 5 5 return err 6 6 } 7 7
+1 -1
knotserver/db/pubkeys.go
··· 33 33 pk.Created = time.Now().Format("2006-01-02 15:04:05.99999999 -0700 MST m=-0000.000000000") 34 34 } 35 35 36 - query := `insert into public_keys (did, key, created) values (?, ?, ?)` 36 + query := `insert or ignore into public_keys (did, key, created) values (?, ?, ?)` 37 37 _, err := d.db.Exec(query, pk.Did, pk.Key, pk.Created) 38 38 return err 39 39 }