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.0)
       rails
       self_data
+      tainbox
 
 GEM
   remote: https://rubygems.org/
@@ -133,7 +134,6 @@ GEM
     memery (1.7.0)
     method_source (1.1.0)
     mini_mime (1.1.5)
-    mini_portile2 (2.8.9)
     minitest (5.25.5)
     net-imap (0.5.8)
       date
@@ -164,10 +164,9 @@ GEM
     psych (5.2.6)
       date
       stringio
-    rabbit_messaging (1.5.0)
+    rabbit_messaging (1.6.0)
       bunny (~> 2.0)
       kicks
-      tainbox
     racc (1.8.1)
     rack (3.1.15)
     rack-session (2.1.1)

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

spec/spec_helper.rb

@@ -2,6 +2,7 @@
 
 require "simplecov"
 require "simplecov-lcov"
+require "tainbox"
 
 SimpleCov::Formatter::LcovFormatter.config do |config|
   config.report_with_single_file = true

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.0"
   spec.add_dependency "rails"
   spec.add_dependency "self_data"
+  spec.add_dependency "tainbox"
 end