Разделение log message на части (#32)

* Разделение log message на части

* Linter

* Add dots

* Lint

* Move duplicate to helper

* Lint

* module

* Update version and changelog

* Update Gemfile.lock

Author: nile1985

CHANGELOG.md

@@ -1,6 +1,11 @@
 # Changelog
 All notable changes to this project will be documented in this file.
 
+## [1.5.0] - 2025-05-19
+### Added
+- Added ability to split log message into parts
+- Optional `logger_message_size_limit` config for message size limit
+
 ## [1.4.0] - 2025-03-10
 ### Added
 - Introduced new configuration attributes for connection reset handling:

Gemfile.lock

@@ -8,7 +8,7 @@ GIT
 PATH
   remote: .
   specs:
-    rabbit_messaging (1.4.0)
+    rabbit_messaging (1.5.0)
       bunny (~> 2.0)
       kicks
       tainbox

README.md

@@ -151,6 +151,14 @@ require "rabbit_messaging"
     ```ruby
       config.connection_reset_timeout = 0.2
     ```
+
+  - `logger_message_size_limit` (`Integer`)
+
+    Maximum logger message size. Split message to parts if message is more than limit. Default: 9500.
+
+    ```ruby
+      config.logger_message_size_limit = 9500
+    ```
 ---
 
 ### Client

lib/rabbit.rb

@@ -33,6 +33,7 @@ class Config
     attribute :connection_reset_max_retries, Integer, default: 10
     attribute :connection_reset_timeout, Float, default: 0.2
     attribute :connection_reset_exceptions, Array, default: [Bunny::ConnectionClosedError]
+    attribute :logger_message_size_limit, Integer, default: 9_500
 
     attribute :receive_logger, default: lambda {
       Logger.new(Rabbit.root.join("log", "incoming_rabbit_messages.log"))

lib/rabbit/helper.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+module Rabbit
+  module Helper
+    def self.generate_message(message_part, parts, index)
+      if parts == 1
+        message_part
+      elsif index.zero?
+        "#{message_part}..."
+      elsif index == parts - 1
+        "...#{message_part}"
+      else
+        "...#{message_part}..."
+      end
+    end
+  end
+end

lib/rabbit/publishing.rb

@@ -66,7 +66,13 @@ def log(message)
         message.event, message.confirm_select? ? "confirm" : "no-confirm"
       ]
 
-      @logger.debug "#{metadata.join ' / '}: #{JSON.dump(message.data)}"
+      message_parts = JSON.dump(message.data)
+                          .scan(/.{1,#{Rabbit.config.logger_message_size_limit}}/)
+
+      message_parts.each_with_index do |message_part, index|
+        message = Rabbit::Helper.generate_message(message_part, message_parts.size, index)
+        @logger.debug "#{metadata.join ' / '}: #{message}"
+      end
     end
 
     def reinitialize_channels_pool

lib/rabbit/receiving/receive.rb

@@ -5,6 +5,7 @@
 require "rabbit"
 require "rabbit/receiving/queue"
 require "rabbit/receiving/job"
+require "rabbit/helper"
 
 class Rabbit::Receiving::Receive
   include Tainbox
@@ -21,9 +22,15 @@ def call
   end
 
   def log!
-    Rabbit.config.receive_logger.debug(
-      [message, delivery_info, arguments].join(" / "),
-    )
+    message_parts = message.scan(/.{1,#{Rabbit.config.logger_message_size_limit}}/)
+
+    message_parts.each_with_index do |message_part, index|
+      message = Rabbit::Helper.generate_message(message_part, message_parts.size, index)
+
+      Rabbit.config.receive_logger.debug(
+        [message, delivery_info, arguments].join(" / "),
+      )
+    end
   end
 
   def process_message

lib/rabbit/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Rabbit
-  VERSION = "1.4.0"
+  VERSION = "1.5.0"
 end

spec/units/rabbit_spec.rb

@@ -30,6 +30,7 @@
       allow(channel).to receive(:open?).and_return(true)
 
       allow(Rabbit.config).to receive(:publish_logger) { publish_logger }
+      allow(Rabbit.config).to receive(:logger_message_size_limit).and_return(10)
 
       expect(channel).to receive(:confirm_select).once
       allow(channel).to receive(:wait_for_confirms).and_return(true)
@@ -70,9 +71,13 @@
         expect(Rabbit::Publishing::Job).not_to receive(:perform_later)
       end
 
-      expect(publish_logger).to receive(:debug).with(<<~MSG.strip).once
+      expect(publish_logger).to receive(:debug).with(<<~MSG.strip)
         test_group_id.test_project_id.some_exchange / some_queue / {"foo":"bar"} / some_event / \
-        confirm: {"hello":"world"}
+        confirm: {"hello":"...
+      MSG
+      expect(publish_logger).to receive(:debug).with(<<~MSG.strip)
+        test_group_id.test_project_id.some_exchange / some_queue / {"foo":"bar"} / some_event / \
+        confirm: ...world"}
       MSG
       described_class.publish(message_options)
     end