Skip to content
Snippets Groups Projects
Commit 4a1e73c8 authored by David Stainton's avatar David Stainton
Browse files

ud: us kv.Exists

parent 2476d123
Branches
No related tags found
6 merge requests!510Release,!419rewrote the health tracker to both consider if there are waiting rounds and...,!371[Channel RSAtoPrivate] Implement Reverse Asymmetric in Client/Broadcast,!354Channels impl,!340Project/channels,!338Xx 4055/channel identity tracking
...@@ -4,7 +4,6 @@ import ( ...@@ -4,7 +4,6 @@ import (
"crypto/ed25519" "crypto/ed25519"
"encoding/json" "encoding/json"
"errors" "errors"
"os"
"sync" "sync"
"time" "time"
...@@ -185,12 +184,8 @@ var _ NameService = (*clientIDTracker)(nil) ...@@ -185,12 +184,8 @@ var _ NameService = (*clientIDTracker)(nil)
func newclientIDTracker(comms channelLeaseComms, host *connect.Host, username string, kv *versioned.KV, func newclientIDTracker(comms channelLeaseComms, host *connect.Host, username string, kv *versioned.KV,
receptionIdentity xxdk.ReceptionIdentity, udPubKey ed25519.PublicKey, rngSource *fastRNG.StreamGenerator) *clientIDTracker { receptionIdentity xxdk.ReceptionIdentity, udPubKey ed25519.PublicKey, rngSource *fastRNG.StreamGenerator) *clientIDTracker {
var err error
// kv api sucks... forcing me to do this:
objectNotFoundErr := "object not found"
reg, err := loadRegistrationDisk(kv) reg, err := loadRegistrationDisk(kv)
if os.IsNotExist(err) || err.Error() == objectNotFoundErr { if !kv.Exists(err) {
rng := rngSource.GetStream() rng := rngSource.GetStream()
defer rng.Close() defer rng.Close()
......
...@@ -31,11 +31,7 @@ func TestLoadSaveRegistration(t *testing.T) { ...@@ -31,11 +31,7 @@ func TestLoadSaveRegistration(t *testing.T) {
registrationDisk, err := loadRegistrationDisk(kv) registrationDisk, err := loadRegistrationDisk(kv)
require.Error(t, err) require.Error(t, err)
t.Logf("err is %v", err) require.False(t, kv.Exists(err))
// kv api sucks... forcing me to do this:
objectNotFoundErr := "object not found"
require.Equal(t, err.Error(), objectNotFoundErr)
err = saveRegistrationDisk(kv, reg) err = saveRegistrationDisk(kv, reg)
require.NoError(t, err) require.NoError(t, err)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment