From 0d284b0ec2c5d623e34df9fcdba2329008ec262e Mon Sep 17 00:00:00 2001
From: Iliia Khaprov <iliia.khaprov@broadcom.com>
Date: Tue, 6 May 2025 13:51:37 +0200
Subject: [PATCH] STOMP: confirm utf-8 handling

(cherry picked from commit 0ec25997b680ebf805467ab5274669235a243856)
---
 deps/rabbitmq_stomp/test/frame_SUITE.erl      |  6 +++---
 .../test/python_SUITE_data/src/parsing.py     | 21 +++++++++++++++++++
 2 files changed, 24 insertions(+), 3 deletions(-)

diff --git a/deps/rabbitmq_stomp/test/frame_SUITE.erl b/deps/rabbitmq_stomp/test/frame_SUITE.erl
index 847b25a02043..4a37be191372 100644
--- a/deps/rabbitmq_stomp/test/frame_SUITE.erl
+++ b/deps/rabbitmq_stomp/test/frame_SUITE.erl
@@ -92,13 +92,13 @@ parse_resume_mid_command(_) ->
     {ok, #stomp_frame{command = "COMMAND"}, _Rest} = parse(Second, Resume).
 
 parse_resume_mid_header_key(_) ->
-    First = "COMMAND\nheade",
+    First = "COMMAND\nheadꙕ",
     Second = "r1:value1\n\n\0",
     {more, Resume} = parse(First),
     {ok, Frame = #stomp_frame{command = "COMMAND"}, _Rest} =
         parse(Second, Resume),
     ?assertEqual({ok, "value1"},
-                 rabbit_stomp_frame:header(Frame, "header1")).
+                 rabbit_stomp_frame:header(Frame, binary_to_list(<<"headꙕr1"/utf8>>))).
 
 parse_resume_mid_header_val(_) ->
     First = "COMMAND\nheader1:val",
@@ -215,7 +215,7 @@ headers_escaping_roundtrip_without_trailing_lf(_) ->
 parse(Content) ->
     parse(Content, rabbit_stomp_frame:initial_state()).
 parse(Content, State) ->
-    rabbit_stomp_frame:parse(list_to_binary(Content), State).
+    rabbit_stomp_frame:parse(unicode:characters_to_binary(Content), State).
 
 parse_complete(Content) ->
     {ok, Frame = #stomp_frame{command = Command}, State} = parse(Content),
diff --git a/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py b/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py
index c2310c62f11a..c13dabe72517 100644
--- a/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py
+++ b/deps/rabbitmq_stomp/test/python_SUITE_data/src/parsing.py
@@ -119,6 +119,27 @@ def test_send_without_content_type(self):
                 'hello\n\0')
         self.match(resp, self.cd.recv(4096).decode('utf-8'))
 
+    @connect(['cd'])
+    def test_unicode(self):
+        cmd = ('\n'
+               'SUBSCRIBE\n'
+               'destination:/exchange/amq.fanout\n'
+               '\n\x00\n'
+               'SEND\n'
+               'destination:/exchange/amq.fanout\n'
+               'headꙕr1:valꙕe1\n\n'
+               'hello\n\x00')
+        self.cd.sendall(cmd.encode('utf-8'))
+        resp = ('MESSAGE\n'
+                'destination:/exchange/amq.fanout\n'
+                'message-id:Q_/exchange/amq.fanout@@session-(.*)\n'
+                'redelivered:false\n'
+                'headꙕr1:valꙕe1\n'
+                'content-length:6\n'
+                '\n'
+                'hello\n\0')
+        self.match(resp, self.cd.recv(4096).decode('utf-8'))
+
     @connect(['cd'])
     def test_send_without_content_type_binary(self):
         msg = 'hello'