updated rabbit-messaging gem

Author: dmitrii.buk

Gemfile.lock

@@ -1,11 +1,12 @@
 PATH
   remote: .
   specs:
-    table_sync (6.6.3)
+    table_sync (6.7.0)
       memery
-      rabbit_messaging (>= 1.1.0)
+      rabbit_messaging (>= 1.6.1)
       rails
       self_data
+      tainbox
 
 GEM
   remote: https://rubygems.org/
@@ -148,6 +149,22 @@ GEM
     nokogiri (1.18.8)
       mini_portile2 (~> 2.8.2)
       racc (~> 1.4)
+    nokogiri (1.18.8-aarch64-linux-gnu)
+      racc (~> 1.4)
+    nokogiri (1.18.8-aarch64-linux-musl)
+      racc (~> 1.4)
+    nokogiri (1.18.8-arm-linux-gnu)
+      racc (~> 1.4)
+    nokogiri (1.18.8-arm-linux-musl)
+      racc (~> 1.4)
+    nokogiri (1.18.8-arm64-darwin)
+      racc (~> 1.4)
+    nokogiri (1.18.8-x86_64-darwin)
+      racc (~> 1.4)
+    nokogiri (1.18.8-x86_64-linux-gnu)
+      racc (~> 1.4)
+    nokogiri (1.18.8-x86_64-linux-musl)
+      racc (~> 1.4)
     ostruct (0.6.1)
     parallel (1.27.0)
     parser (3.3.8.0)
@@ -164,10 +181,9 @@ GEM
     psych (5.2.6)
       date
       stringio
-    rabbit_messaging (1.5.0)
+    rabbit_messaging (1.6.1)
       bunny (~> 2.0)
       kicks
-      tainbox
     racc (1.8.1)
     rack (3.1.15)
     rack-session (2.1.1)
@@ -312,7 +328,15 @@ GEM
     zeitwerk (2.6.18)
 
 PLATFORMS
+  aarch64-linux-gnu
+  aarch64-linux-musl
+  arm-linux-gnu
+  arm-linux-musl
+  arm64-darwin
   ruby
+  x86_64-darwin
+  x86_64-linux-gnu
+  x86_64-linux-musl
 
 DEPENDENCIES
   activejob

lib/table_sync.rb

@@ -6,6 +6,7 @@
 require "rabbit/event_handler" # NOTE: from rabbit_messaging"
 require "active_support/core_ext/object/blank"
 require "active_support/core_ext/numeric/time"
+require "tainbox"
 
 module TableSync
   require_relative "table_sync/event"

lib/table_sync/receiving/handler.rb

@@ -3,10 +3,16 @@
 class TableSync::Receiving::Handler < Rabbit::EventHandler
   extend TableSync::Receiving::DSL
 
-  # Rabbit::EventHandler uses Tainbox and performs `handler.new(message).call`
-  attribute :event
-  attribute :model
-  attribute :version
+  attr_accessor :version
+  attr_reader :event, :model
+
+  def initialize(message)
+    super
+
+    self.event   = message.data[:event]
+    self.model   = message.data[:model]
+    self.version = message.data[:version]
+  end
 
   def call
     configs.each do |config|
@@ -40,22 +46,22 @@ def call
   private
 
   # redefine setter from Rabbit::EventHandler
-  def data=(data)
-    super(Array.wrap(data[:attributes]))
+  def data=(raw_data)
+    super(Array.wrap(raw_data[:attributes]))
   end
 
   def event=(event_name)
     event_name = event_name.to_sym
 
     if event_name.in?(TableSync::Event::VALID_RESOLVED_EVENTS)
-      super
+      @event = event_name
     else
       raise TableSync::UndefinedEvent.new(event)
     end
   end
 
   def model=(model_name)
-    super(model_name.to_s)
+    @model = model_name.to_s
   end
 
   def configs

lib/table_sync/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module TableSync
-  VERSION = "6.6.3"
+  VERSION = "6.7.0"
 end

table_sync.gemspec

@@ -27,7 +27,8 @@ Gem::Specification.new do |spec|
   end
 
   spec.add_dependency "memery"
-  spec.add_dependency "rabbit_messaging", ">= 1.1.0"
+  spec.add_dependency "rabbit_messaging", ">= 1.6.1"
   spec.add_dependency "rails"
   spec.add_dependency "self_data"
+  spec.add_dependency "tainbox"
 end