feat(jsapi): add PersistMode and type definitions for stream persistence options

- Introduced `PersistMode` enum with `Default` and `Async` options for configuring stream persistence.
- Added `persist_mode` property to stream configurations for flexibility in persistence model settings.

Signed-off-by: Alberto Ricart <[email protected]>

Author: aricart

jetstream/src/internal_mod.ts

@@ -179,6 +179,7 @@ export {
   AckPolicy,
   DeliverPolicy,
   DiscardPolicy,
+  PersistMode,
   PubHeaders,
   ReplayPolicy,
   RetentionPolicy,

jetstream/tests/streams_test.ts

@@ -19,7 +19,12 @@ import {
   notCompatible,
   setup,
 } from "test_helpers";
-import { AckPolicy, jetstream, jetstreamManager } from "../src/mod.ts";
+import {
+  AckPolicy,
+  jetstream,
+  jetstreamManager,
+  PersistMode,
+} from "../src/mod.ts";
 
 import { assertEquals, assertExists, assertRejects } from "@std/assert";
 import { initStream } from "./jstest_util.ts";
@@ -167,3 +172,41 @@ Deno.test("streams - first_seq fails if wrong server", async () => {
 
   await cleanup(ns, nc);
 });
+
+Deno.test("streams - persist mode", async () => {
+  const { ns, nc } = await setup(jetstreamServerConf({}));
+  if (await notCompatible(ns, nc, "2.12.0")) {
+    return;
+  }
+
+  const jsm = await jetstreamManager(nc);
+
+  let si = await jsm.streams.add({
+    name: "A",
+    subjects: ["a"],
+    persist_mode: PersistMode.Default,
+  });
+  assertEquals(si.config.persist_mode, undefined);
+  let md = si.config.metadata || {};
+  assertEquals(md["_nats.req.level"], "0");
+
+  si = await jsm.streams.add({
+    name: "B",
+    subjects: ["b"],
+    persist_mode: PersistMode.Async,
+  });
+  assertEquals(si.config.persist_mode, PersistMode.Async);
+  md = si.config.metadata || {};
+  assertEquals(md["_nats.req.level"], "2");
+
+  await assertRejects(
+    () => {
+      // @ts-expect-error: testing server rejection
+      return jsm.streams.update("B", { persist_mode: PersistMode.Default });
+    },
+    Error,
+    "can not change persist mode",
+  );
+
+  await cleanup(ns, nc);
+});