specs - start to spec

Author: 0exp

CHANGELOG.md

@@ -1,6 +1,11 @@
 # Changelog
 All notable changes to this project will be documented in this file.
 
+## [0.16.0] - 2024-10-11
+### Added
+- **Receiving**
+  - Support for custom receiving job config which is placed in receiving event handler;
+
 ## [0.15.0] - 2024-06-05
 ### Added
 - Support for custom reciving handler via `Rabbit.config.handler_resolver_callable` config;

spec/units/dummy/some_group.rb

@@ -14,6 +14,14 @@ class SomeSuccessfulEvent < Rabbit::EventHandler
       def call; end
     end
 
+    class SomeConfigurableEventHandler < Rabbit::EventHandler
+      queue_as { |message, arguments| "#{message.data[:hello]}_#{arguments[:type]}" }
+
+      attribute :hello
+
+      def call; end
+    end
+
     class SomeUnsuccessfulEvent < Rabbit::EventHandler
       queue_as :custom
 

spec/units/rabbit/receiving_spec.rb

@@ -9,14 +9,15 @@
   let(:arguments)     { { type: event, app_id: "some_group.some_app", message_id: "uuid" } }
   let(:event)         { "some_successful_event" }
   let(:job_class)     { Rabbit::Receiving::Job }
+  let(:job_configs)    { {} }
   let(:conversion)    { false }
   let(:handler)       { Rabbit::Handler::SomeGroup::SomeSuccessfulEvent }
   let(:before_hook)   { double("before hook") }
   let(:after_hook)    { double("after hook") }
   let(:message_info)  { arguments.merge(delivery_info.slice(:exchange, :routing_key)) }
 
   def expect_job_queue_to_be_set
-    expect(job_class).to receive(:set).with(queue: queue)
+    expect(job_class).to receive(:set).with(queue: queue, **job_configs)
   end
 
   def expect_some_handler_to_be_called
@@ -237,6 +238,19 @@ def call; end
       end
     end
 
+    context "custom job configuration" do
+      let(:queue) { "custom_queue" }
+      let(:job_configs) { Hash[some: :kek, pek: 123] }
+      let(:handler) { Rabbit::Handler::SomeGroup::SomeConfigurableEventHandler }
+
+      before { handler.job_configs(job_configs) }
+      after { handler.job_configs({}) }
+
+      it "invokes job with custom config" do
+        run_receive
+      end
+    end
+
     context "custom receiving job" do
       let(:custom_job_class) { class_double("CustomJobClass") }
       let(:custom_job)       { double("CustomJob") }