add some documentation and test to set MaxAge

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

Hide file tree

Showing 2 changed files with 54 additions and 2 deletions.
diff --git a/src/Stream/Configuration.php b/src/Stream/Configuration.php
@@ -139,9 +139,12 @@ public function setDuplicateWindow(?float $seconds): self
         return $this;
     }
 
-    public function setMaxAge(int $maxAge): self
+    /**
+     * set the max age in nanoSeconds
+     */
+    public function setMaxAge(int $maxAgeNanoSeconds): self
     {
-        $this->maxAge = $maxAge;
+        $this->maxAge = $maxAgeNanoSeconds;
         return $this;
     }
 

diff --git a/tests/Functional/StreamTest.php b/tests/Functional/StreamTest.php
@@ -105,6 +105,55 @@ public function testConsumerExpiration()
         $this->assertSame($info, $client->connection->getInfoMessage());
     }
 
+    public function testSetConfigRetentionPolicyToMaxAge(): void
+    {
+        $api = $this->createClient()
+            ->getApi();
+        $stream = $api->getStream('tester');
+
+        $stream->getConfiguration()
+            ->setRetentionPolicy(RetentionPolicy::LIMITS)
+            ->setMaxAge(3_600_000_000_000)
+            ->setStorageBackend(StorageBackend::MEMORY)
+            ->setSubjects(['tester.greet', 'tester.bye']);
+
+        $stream->create();
+
+        $config = $stream->info()->config;
+
+        self::assertSame($config->retention, 'limits');
+        self::assertSame($config->storage, 'memory');
+        self::assertSame($config->subjects, ['tester.greet', 'tester.bye']);
+        self::assertSame($config->max_age, 3_600_000_000_000);
+
+        $stream->getConfiguration()
+            ->setSubjects(['tester.greet']);
+        $stream->update();
+
+        self::assertSame($stream->info()->config->subjects, ['tester.greet']);
+
+        $stream->getConfiguration()
+            ->setMaxAge(3_600_000_000_001)
+            ->setSubjects(['tester.greet', 'tester.bye']);
+        $stream->update();
+
+        $api = $this->createClient()
+            ->getApi();
+
+        $api->getStream('tester')
+            ->getConfiguration()
+            ->fromArray(
+                $stream->getConfiguration()
+                    ->toArray()
+            );
+
+        $configuration = $api->getStream('tester')
+            ->getConfiguration();
+        self::assertSame($configuration->getRetentionPolicy(), 'limits');
+        self::assertSame($configuration->getStorageBackend(), 'memory');
+        self::assertSame($configuration->getSubjects(), ['tester.greet', 'tester.bye']);
+    }
+
     public function testDeduplication()
     {
         $stream = $this->getClient()->getApi()->getStream('tester');