Add history TTL configuration validation during message publishing

errors.go

@@ -109,4 +109,10 @@ var (
 		Code:    112,
 		Message: "unrecoverable position",
 	}
+	// ErrorIncorrectHistoryTTLConfiguration means that history meta TTL is less than history TTL.
+	// History meta TTL must be greater than or equal to history TTL to avoid stream inconsistencies.
+	ErrorIncorrectHistoryTTLConfiguration = &Error{
+		Code:    113,
+		Message: "history meta TTL must be greater than or equal to history TTL",
+	}
 )

node.go

@@ -771,6 +771,18 @@ func (n *Node) publish(ch string, data []byte, opts ...PublishOption) (PublishRe
 	for _, opt := range opts {
 		opt(pubOpts)
 	}
+
+	// Validate history TTL configuration if history is enabled.
+	if pubOpts.HistorySize > 0 && pubOpts.HistoryTTL > 0 {
+		historyMetaTTL := pubOpts.HistoryMetaTTL
+		if historyMetaTTL == 0 {
+			historyMetaTTL = n.config.HistoryMetaTTL
+		}
+		if historyMetaTTL > 0 && historyMetaTTL < pubOpts.HistoryTTL {
+			return PublishResult{}, ErrorIncorrectHistoryTTLConfiguration
+		}
+	}
+
 	n.metrics.incMessagesSent("publication", ch)
 	streamPos, fromCache, err := n.getBroker(ch).Publish(ch, data, *pubOpts)
 	if err != nil {

node_test.go

@@ -1471,3 +1471,32 @@ func TestGetPresenceManager(t *testing.T) {
 	_, err = node.Presence("test2")
 	require.NoError(t, err)
 }
+
+func TestNode_PublishHistoryTTLValidation(t *testing.T) {
+	node := defaultTestNode()
+	defer func() { _ = node.Shutdown(context.Background()) }()
+
+	_, err := node.Publish("test", []byte("{}"), WithHistory(10, time.Hour, 2*time.Hour))
+	require.NoError(t, err)
+
+	_, err = node.Publish("test", []byte("{}"), WithHistory(10, time.Hour, time.Hour))
+	require.NoError(t, err)
+
+	_, err = node.Publish("test", []byte("{}"), WithHistory(10, 2*time.Hour, time.Hour))
+	require.Error(t, err)
+	require.Equal(t, ErrorIncorrectHistoryTTLConfiguration, err)
+
+	_, err = node.Publish("test", []byte("{}"), WithHistory(10, time.Hour))
+	require.NoError(t, err)
+
+	longTTL := 31 * 24 * time.Hour // 31 days
+	_, err = node.Publish("test", []byte("{}"), WithHistory(10, longTTL))
+	require.Error(t, err)
+	require.Equal(t, ErrorIncorrectHistoryTTLConfiguration, err)
+
+	_, err = node.Publish("test", []byte("{}"), WithHistory(0, 2*time.Hour, time.Hour))
+	require.NoError(t, err)
+
+	_, err = node.Publish("test", []byte("{}"), WithHistory(10, 0, time.Hour))
+	require.NoError(t, err)
+}