[FIXED] OBJ_ prefix when listing object stores

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>
nats-io · Dec 12, 2023 · eae2849 · eae2849
1 parent 30e50d3
commit eae2849
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/jetstream/object.go b/jetstream/object.go
@@ -1218,7 +1218,7 @@ func (js *jetStream) ObjectStoreNames(ctx context.Context) ObjectStoreNamesListe
 				if !strings.HasPrefix(name, "OBJ_") {
 					continue
 				}
-				res.obsNames <- name
+				res.obsNames <- strings.TrimPrefix(name, "OBJ_")
 			}
 			if errors.Is(err, ErrEndOfData) {
 				return

diff --git a/jetstream/test/object_test.go b/jetstream/test/object_test.go
@@ -24,6 +24,7 @@ import (
 	"path"
 	"path/filepath"
 	"reflect"
+	"strings"
 	"testing"
 	"time"
 
@@ -975,6 +976,9 @@ func TestListObjectStores(t *testing.T) {
 			names := make([]string, 0)
 			objectStoreNames := js.ObjectStoreNames(ctx)
 			for name := range objectStoreNames.Name() {
+				if strings.HasPrefix(name, "OBJ_") {
+					t.Fatalf("Expected name without OBJ_ prefix, got: %s", name)
+				}
 				names = append(names, name)
 			}
 			expectOk(t, objectStoreNames.Error())