Fix support for setting object replicas in ObjectStore (#249)

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

Author: aricart

obj/src/objectstore.ts

@@ -917,6 +917,7 @@ export class ObjectStoreImpl implements ObjectStore {
     sc.name = this.stream;
     sc.allow_direct = true;
     sc.allow_rollup_hdrs = true;
+    sc.num_replicas = opts.replicas || 1;
     sc.discard = DiscardPolicy.New;
     sc.subjects = [`$O.${this.name}.C.>`, `$O.${this.name}.M.>`];
     if (opts.placement) {

obj/tests/objectstore_test.ts

@@ -15,7 +15,9 @@
 
 import {
   cleanup,
+  connect,
   jetstreamServerConf,
+  NatsServer,
   notCompatible,
   setup,
 } from "test_helpers";
@@ -1263,3 +1265,16 @@ Deno.test("os - objm open", async () => {
 
   await cleanup(ns, nc);
 });
+
+Deno.test("os - objm creates right number of replicas", async () => {
+  const servers = await NatsServer.jetstreamCluster(3);
+  const nc = await connect({ port: servers[0].port });
+  const objm = new Objm(nc);
+
+  const obj = await objm.create("test", { replicas: 3 });
+  const status = await obj.status();
+  assertEquals(status.replicas, 3);
+
+  await nc.close();
+  await NatsServer.stopAll(servers, true);
+});