Return store.ErrNotFound to be consistent with other stores

micro · Jun 3, 2024 · 73391e5 · 73391e5
1 parent 94a49ba
commit 73391e5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/v4/store/nats-js-kv/nats.go b/v4/store/nats-js-kv/nats.go
@@ -397,7 +397,7 @@ func (n *natsStore) mustGetBucket(kv *nats.KeyValueConfig) (nats.KeyValue, error
 func (n *natsStore) getRecord(bucket nats.KeyValue, key string) (*store.Record, bool, error) {
 	obj, err := bucket.Get(key)
 	if errors.Is(err, nats.ErrKeyNotFound) {
-		return nil, false, nil
+		return nil, false, store.ErrNotFound
 	} else if err != nil {
 		return nil, false, errors.Wrap(err, "Failed to get object from bucket")
 	}

diff --git a/v4/store/nats-js-kv/nats_test.go b/v4/store/nats-js-kv/nats_test.go
@@ -33,8 +33,8 @@ func TestNats(t *testing.T) {
 
 		// Test reading non-existing key
 		r, err := s.Read("this-is-a-random-key")
-		if err != nil {
-			t.Fatal(err)
+		if err != store.ErrNotFound {
+			t.Errorf("Expected %# v, got %# v", store.ErrNotFound, err)
 		}
 		if len(r) > 0 {
 			t.Fatal("Lenth should be 0")