feat(obj): Objm added open() for retrieving an ObjectStore instance (#158)

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

Author: aricart

Diff for: obj/src/objectstore.ts

@@ -103,7 +103,8 @@ export class Objm {
   }
 
   /**
-   * Creates and opens the specified ObjectStore. If the Object already exists, it opens the existing ObjectStore.
+   * Creates and opens the specified ObjectStore. If the ObjectStore already exists,
+   * it opens the existing ObjectStore.
    * @param name
    * @param opts
    */
@@ -114,6 +115,21 @@ export class Objm {
     return this.#maybeCreate(name, opts);
   }
 
+  /**
+   * Opens the specified ObjectStore
+   * @param name
+   * @param check - if set to false, it will not check if the ObjectStore exists.
+   */
+  async open(name: string, check = true): Promise<ObjectStore> {
+    const jsm = await this.js.jetstreamManager();
+    const os = new ObjectStoreImpl(name, jsm, this.js);
+    os.stream = objectStoreStreamName(name);
+    if (check) {
+      await os.status();
+    }
+    return Promise.resolve(os);
+  }
+
   #maybeCreate(
     name: string,
     opts: Partial<ObjectStoreOptions> = {},

Diff for: obj/tests/objectstore_test.ts

@@ -1226,3 +1226,42 @@ Deno.test("os - os rejects in older servers", async () => {
   await t("2.6.3", true);
   await cleanup(ns, nc);
 });
+
+Deno.test("os - objm open", async () => {
+  const { ns, nc } = await setup(jetstreamServerConf({}));
+
+  const objm = new Objm(nc);
+  await assertRejects(
+    () => {
+      return objm.open("hello");
+    },
+    Error,
+    "object store not found",
+  );
+
+  let obj = await objm.open("hello", false);
+
+  await assertRejects(
+    () => {
+      return obj.get("hello");
+    },
+    Error,
+    "stream not found",
+  );
+
+  await assertRejects(
+    () => {
+      return obj.put({ name: "hi" }, readableStreamFrom(Empty));
+    },
+    Error,
+    "stream not found",
+  );
+
+  await objm.create("hello");
+
+  obj = await objm.open("hello");
+  const oi = await obj.put({ name: "hello" }, readableStreamFrom(Empty));
+  assertEquals(oi.name, "hello");
+
+  await cleanup(ns, nc);
+});