From 66ea25c18b76fe5ba167b052caddcc57fd3219a4 Mon Sep 17 00:00:00 2001
From: binwiederhier <phil@heckel.io>
Date: Thu, 8 Jan 2026 15:45:50 -0500
Subject: [PATCH] Add JSON publishing support

---
 server/server.go      |  3 +++
 server/server_test.go | 12 ++++++++++++
 2 files changed, 15 insertions(+)

diff --git a/server/server.go b/server/server.go
index c60154ec..635258fa 100644
--- a/server/server.go
+++ b/server/server.go
@@ -2027,6 +2027,9 @@ func (s *Server) transformBodyJSON(next handleFunc) handleFunc {
 		if m.Firebase != "" {
 			r.Header.Set("X-Firebase", m.Firebase)
 		}
+		if m.SequenceID != "" {
+			r.Header.Set("X-Sequence-ID", m.SequenceID)
+		}
 		return next(w, r, v)
 	}
 }
diff --git a/server/server_test.go b/server/server_test.go
index 2978947f..964d6156 100644
--- a/server/server_test.go
+++ b/server/server_test.go
@@ -727,6 +727,18 @@ func TestServer_PublishWithSIDViaGet(t *testing.T) {
 	require.Equal(t, "sid1", msg.SequenceID)
 }
 
+func TestServer_PublishAsJSON_WithSequenceID(t *testing.T) {
+	s := newTestServer(t, newTestConfig(t))
+
+	body := `{"topic":"mytopic","message":"A message","sequence_id":"my-sequence-123"}`
+	response := request(t, s, "PUT", "/", body, nil)
+	require.Equal(t, 200, response.Code)
+
+	msg := toMessage(t, response.Body.String())
+	require.NotEmpty(t, msg.ID)
+	require.Equal(t, "my-sequence-123", msg.SequenceID)
+}
+
 func TestServer_PublishWithInvalidSIDInPath(t *testing.T) {
 	s := newTestServer(t, newTestConfig(t))