test: validate UTF8 payloads

waku/v2/protocol/filter/filter_push_test.go

@@ -6,9 +6,7 @@ import (
 	"time"
 )
 
-// Test valid payloads
-
-func (s *FilterTestSuite) TestValidaPayloadsASCII() {
+func (s *FilterTestSuite) TestValidPayloadsASCII() {
 
 	// Create test context
 	s.ctx, s.ctxCancel = context.WithTimeout(context.Background(), 20*time.Second)
@@ -28,3 +26,24 @@ func (s *FilterTestSuite) TestValidaPayloadsASCII() {
 	s.Require().NoError(err)
 
 }
+
+func (s *FilterTestSuite) TestValidPayloadsUTF8() {
+
+	// Create test context
+	s.ctx, s.ctxCancel = context.WithTimeout(context.Background(), 20*time.Second)
+
+	// Subscribe
+	s.subDetails = s.subscribe(s.testTopic, s.testContentTopic, s.fullNodeHost.ID())
+
+	// Prepare basic data
+	messages := prepareData(100, false, false, true, tests.GenerateRandomUTF8String)
+
+	// All messages should be received
+	s.waitForMessages(func() {
+		s.publishMessages(messages)
+	}, s.subDetails, messages)
+
+	_, err := s.lightNode.UnsubscribeAll(s.ctx)
+	s.Require().NoError(err)
+
+}