From abd5205233a26e8998a34e276683b6104951f211 Mon Sep 17 00:00:00 2001
From: Alberto Ricart <alberto@synadia.com>
Date: Mon, 5 Apr 2021 17:22:44 -0500
Subject: [PATCH] added test verifying contributed header

---
 tests/jetstream_test.ts | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

diff --git a/tests/jetstream_test.ts b/tests/jetstream_test.ts
index 2f89b0b2..7797af7a 100644
--- a/tests/jetstream_test.ts
+++ b/tests/jetstream_test.ts
@@ -29,6 +29,7 @@ import {
   delay,
   Empty,
   ErrorCode,
+  headers,
   JsMsg,
   JsMsgCallback,
   JSONCodec,
@@ -1299,6 +1300,25 @@ Deno.test("jetstream - cross account pull", async () => {
   await cleanup(ns, admin, nc);
 });
 
+Deno.test("jetstream - publish headers", async () => {
+  const { ns, nc } = await setup(jetstreamServerConf({ debug: true }, true));
+  const { stream, subj } = await initStream(nc);
+  const jsm = await nc.jetstreamManager();
+  await jsm.consumers.add(stream, {
+    durable_name: "me",
+    ack_policy: AckPolicy.Explicit,
+  });
+  const js = nc.jetstream();
+  const h = headers();
+  h.set("a", "b");
+
+  await js.publish(subj, Empty, { headers: h });
+  const ms = await js.pull(stream, "me");
+  ms.ack();
+  assertEquals(ms.headers!.get("a"), "b");
+  await cleanup(ns, nc);
+});
+
 // Deno.test("jetstream - cross account fetch", async () => {
 //   const { ns, nc: admin } = await setup(
 //     jetstreamExportServerConf(),