From 3eff756d73d194b61465808b9fb7f43687e2b20e Mon Sep 17 00:00:00 2001 From: Akshay Date: Wed, 05 Feb 2025 14:01:58 +0000 Subject: [PATCH] make jetstream inserts conflict tolerant --- knotserver/db/known_dids.go | 2 +- knotserver/db/pubkeys.go | 2 +- 2 file(s) changed, 2 insertion(s)(+), 2 deletion(s)(-) diff --git a/knotserver/db/known_dids.go b/knotserver/db/known_dids.go --- a/knotserver/db/known_dids.go +++ b/knotserver/db/known_dids.go @@ -1,7 +1,7 @@ package db func (d *DB) AddDid(did string) error { - _, err := d.db.Exec(`insert into known_dids (did) values (?)`, did) + _, err := d.db.Exec(`insert or ignore into known_dids (did) values (?)`, did) return err } diff --git a/knotserver/db/pubkeys.go b/knotserver/db/pubkeys.go --- a/knotserver/db/pubkeys.go +++ b/knotserver/db/pubkeys.go @@ -33,7 +33,7 @@ pk.Created = time.Now().Format("2006-01-02 15:04:05.99999999 -0700 MST m=-0000.000000000") } - query := `insert into public_keys (did, key, created) values (?, ?, ?)` + query := `insert or ignore into public_keys (did, key, created) values (?, ?, ?)` _, err := d.db.Exec(query, pk.Did, pk.Key, pk.Created) return err } -- tangled.sh