Try to make work with later rubies.

Author: TreyE

.github/workflows/rspec.yml

@@ -11,7 +11,7 @@ jobs:
         uses: actions/cache@v4
         with:
           path: vendor/bundle
-          key: ${{ runner.os }}-3.2.1-event_source-gems-${{ hashFiles('**/Gemfile.lock') }}-${{ hashFiles('**/Gemfile' ) }}
+          key: ${{ runner.os }}-3.2.1-event_source-gems-${{ hashFiles('**/event_source.gemspec') }}-${{ hashFiles('**/Gemfile' ) }}
       - name: bundle install
         run: |
           bundle config path vendor/bundle
@@ -39,7 +39,7 @@ jobs:
         uses: actions/cache@v4
         with:
           path: vendor/bundle
-          key: ${{ runner.os }}-${{matrix.ruby_version}}-event_source-gems-${{ hashFiles('**/Gemfile.lock') }}-${{ hashFiles('**/Gemfile' ) }}
+          key: ${{ runner.os }}-${{matrix.ruby_version}}-event_source-gems-${{ hashFiles('**/event_source.gemspec') }}-${{ hashFiles('**/Gemfile' ) }}
       - name: bundle install
         run: |
           bundle config path vendor/bundle
@@ -68,7 +68,7 @@ jobs:
         uses: actions/cache@v4
         with:
           path: vendor/bundle
-          key: ${{ runner.os }}-${{matrix.ruby_version}}-event_source-gems-${{ hashFiles('**/Gemfile.lock') }}-${{ hashFiles('**/Gemfile' ) }}
+          key: ${{ runner.os }}-${{matrix.ruby_version}}-event_source-gems-${{ hashFiles('**/event_source.gemspec') }}-${{ hashFiles('**/Gemfile' ) }}
       - name: bundle install
         run: |
           bundle config path vendor/bundle

event_source.gemspec

@@ -44,9 +44,10 @@ Gem::Specification.new do |spec|
   spec.add_dependency 'dry-initializer', '~> 3.0'
   spec.add_dependency 'dry-monads', '~> 1.3'
   spec.add_dependency 'dry-struct', '~> 1.4'
-  spec.add_dependency 'dry-types', '~> 1.5'
-  spec.add_dependency 'dry-validation', '~> 1.6'
-  spec.add_dependency 'dry-schema', '~> 1.6'
+  spec.add_dependency 'dry-types', '~> 1.5', '< 1.6'
+  spec.add_dependency 'dry-validation', '~> 1.6', '< 1.8'
+  spec.add_dependency 'dry-schema', '~> 1.6', '< 1.10'
+  spec.add_dependency 'dry-logic', '< 1.3'
   spec.add_dependency 'faraday', '~> 1.4.1'
   spec.add_dependency 'faraday_middleware', '~> 1.0'
   spec.add_dependency 'logging', '~> 2.3.0'

spec/rails_app/app/contracts/parties/organization/update_fein_contract.rb

@@ -1,15 +1,17 @@
 # frozen_string_literal: true
 
-module Organizations
-  class UpdateFeinContract < Dry::Validation::Contract
+module Parties
+  module Organization
+    class UpdateFeinContract < Dry::Validation::Contract
 
-    params do
+      params do
 
-      required(:hbx_id).filled(:string)
-      required(:fein).filled(:string)
-      required(:meta).maybe(:hash)
-      optional(:event_stream).maybe(:array)
+        required(:hbx_id).filled(:string)
+        required(:fein).filled(:string)
+        required(:meta).maybe(:hash)
+        optional(:event_stream).maybe(:array)
 
+      end
     end
   end
 end

spec/rails_app/app/event_source/adapters/parties/dry_event_adapter.rb

@@ -1,67 +1,69 @@
 # frozen_string_literal: true
 
-module Parties
-  # < EventSource::Adapter
-  class DryEventAdapter
+module Adapters
+  module Parties
+    # < EventSource::Adapter
+    class DryEventAdapter
 
-    # EventSource.config do |config|
-    #   config.event_root
-    #   config.adapter
-    # end
+      # EventSource.config do |config|
+      #   config.event_root
+      #   config.adapter
+      # end
 
-    def enabled!
-      # require 'dry_events'
+      def enabled!
+        # require 'dry_events'
 
-      #    event_source_root = Rails.root.join('app', 'event_source')
-      # publishers_dir = event_source_root.join('publishers')
-      # Dir[publishers_dir.join('parties', '*.rb')].each {|file| require file }
-      # EventSource::Publisher.register_publishers(publishers_dir)
+        #    event_source_root = Rails.root.join('app', 'event_source')
+        # publishers_dir = event_source_root.join('publishers')
+        # Dir[publishers_dir.join('parties', '*.rb')].each {|file| require file }
+        # EventSource::Publisher.register_publishers(publishers_dir)
 
-      # require 'active_support/notifications'
-      # called the first time we know we are using this adapter
-      # it would be a good spot to require the libraries you're using
-      # and modify EventSource::Worker as needed
-      # raise NotImplementedError
-    end
+        # require 'active_support/notifications'
+        # called the first time we know we are using this adapter
+        # it would be a good spot to require the libraries you're using
+        # and modify EventSource::Worker as needed
+        # raise NotImplementedError
+      end
 
-    # example event  'ea.person.created'
-    def enqueue(event)
-      publisher = event.publisher_class
-      publisher.publish(event.event_key, event.payload)
-      # ActiveSupport::Notifications.instrument event.payload[:metadata][:event_key], event.payload
-    end
+      # example event  'ea.person.created'
+      def enqueue(event)
+        publisher = event.publisher_class
+        publisher.publish(event.event_key, event.payload)
+        # ActiveSupport::Notifications.instrument event.payload[:metadata][:event_key], event.payload
+      end
 
-    def dequeue(queue, event_name, subscriber, block)
-      publisher = publisher_by(queue)
+      def dequeue(queue, event_name, subscriber, block)
+        publisher = publisher_by(queue)
 
-      if block.present?
-        publisher.subscribe(event_name) do |event|
-          block.call(event)
+        if block.present?
+          publisher.subscribe(event_name) do |event|
+            block.call(event)
+          end
+        else
+          subscribe_listener(queue, subscriber)
         end
-      else
-        subscribe_listener(queue, subscriber)
-      end
 
-      # ActiveSupport::Notifications.subscribe(key) do |name, started, finished, unique_id, data|
-      #   block.call(data)
-      # end
-    end
+        # ActiveSupport::Notifications.subscribe(key) do |name, started, finished, unique_id, data|
+        #   block.call(data)
+        # end
+      end
 
-    def subscribe_listener(queue, subscriber)
-      publisher = publisher_by(queue)
-      publisher.subscribe(subscriber)
-    end
+      def subscribe_listener(queue, subscriber)
+        publisher = publisher_by(queue)
+        publisher.subscribe(subscriber)
+      end
 
-    # def dequeue(queue, key, matcher_hash, block)
-    #   # ActiveSupport::Notifications.subscribe(key) do |name, started, finished, unique_id, data|
-    #   #   block.call(data)
-    #   # end
-    # end
+      # def dequeue(queue, key, matcher_hash, block)
+      #   # ActiveSupport::Notifications.subscribe(key) do |name, started, finished, unique_id, data|
+      #   #   block.call(data)
+      #   # end
+      # end
 
-    def publisher_by(queue)
-      pub_key_parts = queue.split('.')
-      pub_const = pub_key_parts.map(&:upcase).join('_')
-      pub_const.constantize
+      def publisher_by(queue)
+        pub_key_parts = queue.split('.')
+        pub_const = pub_key_parts.map(&:upcase).join('_')
+        pub_const.constantize
+      end
     end
   end
 end

…vent_source/events/signup_notifiation.rb …ent_source/events/signup_notification.rbspec/rails_app/app/event_source/events/signup_notifiation.rb renamed to spec/rails_app/app/event_source/events/signup_notification.rb spec/rails_app/app/event_source/events/signup_notifiation.rb renamed to spec/rails_app/app/event_source/events/signup_notification.rb

@@ -1,11 +1,12 @@
 # frozen_string_literal: true
 
-module Parties
-  class OrganizationPublisher
-    # include ::EventSource::Publisher[amqp: 'enroll.parties.organizations.fein_corrected']
+module Publishers
+  module Parties
+    class OrganizationPublisher
+      # include ::EventSource::Publisher[amqp: 'enroll.parties.organizations.fein_corrected']
 
-    # register_event 'fein_corrected'
-    # # register_event 'created'
+      # register_event 'fein_corrected'
+      # # register_event 'created'
+    end
   end
 end
-

spec/rails_app/app/event_source/publishers/parties/organization_publisher.rb

@@ -1,24 +1,26 @@
 # frozen_string_literal: true
 
-class DeterminationSubscriber
-  include EventSource::Logging
-  include ::EventSource::Subscriber[amqp: 'magi_medicaid.mitc.eligibilities']
+module Subscribers
+  class DeterminationSubscriber
+    include EventSource::Logging
+    include ::EventSource::Subscriber[amqp: 'magi_medicaid.mitc.eligibilities']
 
-  subscribe(
-    :on_enroll_magi_medicaid_mitc_eligibilities
-  ) do |delivery_info, _metadata, _payload|
-    logger.debug "invoked on_enroll_magi_medicaid_mitc_eligibilities with #{delivery_info}"
-  end
+    subscribe(
+      :on_enroll_magi_medicaid_mitc_eligibilities
+    ) do |delivery_info, _metadata, _payload|
+      logger.debug "invoked on_enroll_magi_medicaid_mitc_eligibilities with #{delivery_info}"
+    end
 
-  subscribe(
-    :on_determined_aqhp_eligible
-  ) do |delivery_info, _metadata, _payload|
-    logger.debug "invoked on_determined_aqhp_eligible with #{delivery_info}"
-  end
+    subscribe(
+      :on_determined_aqhp_eligible
+    ) do |delivery_info, _metadata, _payload|
+      logger.debug "invoked on_determined_aqhp_eligible with #{delivery_info}"
+    end
 
-  subscribe(
-    :on_determined_uqhp_eligible
-  ) do |delivery_info, _metadata, _payload|
-    logger.debug "invoked on_determined_uqhp_eligible with #{delivery_info}"
+    subscribe(
+      :on_determined_uqhp_eligible
+    ) do |delivery_info, _metadata, _payload|
+      logger.debug "invoked on_determined_uqhp_eligible with #{delivery_info}"
+    end
   end
 end

spec/rails_app/app/event_source/subscribers/determination_subscriber.rb

@@ -4,6 +4,7 @@
 
 require "rails"
 require "active_job/railtie"
+require "action_controller/railtie"
 
 Bundler.require(*Rails.groups)
 

spec/rails_app/config/application.rb

@@ -3,10 +3,10 @@
 require_relative './rails_helper'
 require "event_source/rspec/event_routing_matchers"
 
-RSpec.describe DeterminationSubscriber do
+RSpec.describe Subscribers::DeterminationSubscriber do
   it "correctly routes a 'magi_medicaid.mitc.eligibilities', :on_determined_aqhp_eligible message" do
     expect([:amqp, 'magi_medicaid.mitc.eligibilities', 'determined_aqhp_eligible']).to route_to_subscription(
-      DeterminationSubscriber,
+      Subscribers::DeterminationSubscriber,
       :on_determined_aqhp_eligible
     )
   end