[FEAT] objectstore (wip)

nats-base-client/databuffer.ts

@@ -67,6 +67,17 @@ export class DataBuffer {
     }
   }
 
+  shift(): Uint8Array {
+    if (this.buffers.length) {
+      const a = this.buffers.shift();
+      if (a) {
+        this.byteLength -= a.length;
+        return a;
+      }
+    }
+    return new Uint8Array(0);
+  }
+
   drain(n?: number): Uint8Array {
     if (this.buffers.length) {
       this.pack();

nats-base-client/headers.ts

@@ -284,4 +284,20 @@ export class MsgHdrsImpl implements MsgHdrs {
   get status(): string {
     return `${this.code} ${this.description}`.trim();
   }
+
+  toRecord(): Record<string, string[]> {
+    const data = {} as Record<string, string[]>;
+    this.keys().forEach((v) => {
+      data[v] = this.values(v);
+    });
+    return data;
+  }
+
+  static fromRecord(r: Record<string, string[]>): MsgHdrs {
+    const h = new MsgHdrsImpl();
+    for (const k in r) {
+      h.headers.set(k, r[k]);
+    }
+    return h;
+  }
 }

nats-base-client/jsclient.ts

@@ -13,7 +13,14 @@
  * limitations under the License.
  */
 
-import type { ConsumerOptsBuilder, KV, KvOptions, Views } from "./types.ts";
+import type {
+  ConsumerOptsBuilder,
+  KV,
+  KvOptions,
+  ObjectStore,
+  ObjectStoreOptions,
+  Views,
+} from "./types.ts";
 import {
   AckPolicy,
   ConsumerAPI,
@@ -72,6 +79,7 @@ import { consumerOpts, isConsumerOptsBuilder } from "./jsconsumeropts.ts";
 import { Bucket } from "./kv.ts";
 import { NatsConnectionImpl } from "./nats.ts";
 import { Feature } from "./semver.ts";
+import { ObjectStoreImpl } from "./objectstore.ts";
 
 export interface JetStreamSubscriptionInfoable {
   info: JetStreamSubscriptionInfo | null;
@@ -97,6 +105,12 @@ class ViewsImpl implements Views {
     }
     return Bucket.create(this.js, name, opts);
   }
+  os(
+    name: string,
+    opts: Partial<ObjectStoreOptions> = {},
+  ): Promise<ObjectStore> {
+    return ObjectStoreImpl.create(this.js, name, opts);
+  }
 }
 
 export class JetStreamClientImpl extends BaseApiClient