fix KV case

basis-company · Jul 4, 2024 · 7aeaf92 · 7aeaf92
1 parent 219c5a8
commit 7aeaf92
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/KeyValue/Bucket.php b/src/KeyValue/Bucket.php
@@ -98,7 +98,7 @@ public function getStream(): Stream
     {
         if (!$this->stream) {
             $this->stream = $this->client->getApi()
-                ->getStream(strtoupper("kv_$this->name"));
+                ->getStream("KV_$this->name");
 
             if (!$this->stream->exists()) {
                 $this->getConfiguration()
@@ -112,7 +112,7 @@ public function getStream(): Stream
 
     public function getSubject(string $key): string
     {
-        return strtoupper("\$kv.$this->name.$key");
+        return "\$KV.$this->name.$key";
     }
 
     public function delete($key)

diff --git a/src/KeyValue/Configuration.php b/src/KeyValue/Configuration.php
@@ -30,7 +30,7 @@ public function configureStream(StreamConfiguration $configuration): self
             ->setMaxMessageSize($this->getMaxValueSize())
             ->setMaxMessagesPerSubject($this->getHistory() ?? 1)
             ->setReplicas($this->getReplicas() ?? 1)
-            ->setSubjects([strtoupper("\$kv.$this->name.*")]);
+            ->setSubjects(["\$KV.$this->name.*"]);
 
         return $this;
     }