Merge pull request #719 from nats-io/test-717

[TEST] added test to cover fix for #717

Author: aricart

jetstream/objectstore.ts

@@ -788,7 +788,7 @@ export class ObjectStoreImpl implements ObjectStore {
     // pacify the tsc compiler downstream
     const sc = Object.assign({ max_age }, opts) as unknown as StreamConfig;
     sc.name = this.stream;
-    sc.num_replicas = opts.replicas ?? 1
+    sc.num_replicas = opts.replicas ?? 1;
     sc.allow_direct = true;
     sc.allow_rollup_hdrs = true;
     sc.discard = DiscardPolicy.New;

jetstream/tests/objectstore_test.ts

@@ -16,6 +16,7 @@
 import {
   cleanup,
   jetstreamServerConf,
+  NatsServer,
   notCompatible,
   setup,
 } from "../../tests/helpers/mod.ts";
@@ -29,7 +30,7 @@ import {
 import { DataBuffer } from "../../nats-base-client/databuffer.ts";
 import { crypto } from "https://deno.land/[email protected]/crypto/mod.ts";
 import { ObjectInfo, ObjectStoreMeta, StorageType } from "../mod.ts";
-import { Empty, headers, nanos, StringCodec } from "../../src/mod.ts";
+import { connect, Empty, headers, nanos, StringCodec } from "../../src/mod.ts";
 import { equals } from "https://deno.land/[email protected]/bytes/mod.ts";
 import { SHA256 } from "../../nats-base-client/sha256.js";
 import { Base64UrlPaddedCodec } from "../../nats-base-client/base64.ts";
@@ -1113,3 +1114,15 @@ Deno.test("os - compression", async () => {
   assertEquals(status.compression, false);
   await cleanup(ns, nc);
 });
+
+Deno.test("os - replicas", async () => {
+  const servers = await NatsServer.jetstreamCluster(3);
+  const nc = await connect({ port: servers[0].port });
+
+  const js = nc.jetstream();
+  const os = await js.views.os("rep", { replicas: 3 });
+  const status = await os.status();
+  assertEquals(status.replicas, 3);
+  await nc.close();
+  await NatsServer.stopAll(servers);
+});