From ac72c51681d873f13bc1a7c7cdee46b693b2b6a2 Mon Sep 17 00:00:00 2001
From: Brusk Awat <broosk.edogawa@gmail.com>
Date: Wed, 1 Mar 2023 00:42:48 +0300
Subject: [PATCH] Sets up configuration

---
 lib/outboxable/configuration.rb | 57 +++++++++++++++++++++++++++++++++
 1 file changed, 57 insertions(+)
 create mode 100644 lib/outboxable/configuration.rb

diff --git a/lib/outboxable/configuration.rb b/lib/outboxable/configuration.rb
new file mode 100644
index 0000000..27bed0d
--- /dev/null
+++ b/lib/outboxable/configuration.rb
@@ -0,0 +1,57 @@
+module Outboxable
+  class << self
+    attr_accessor :configuration
+  end
+
+  def self.configure
+    self.configuration ||= Configuration.new
+    yield(configuration)
+  end
+
+  class Configuration
+    ALLOWED_MESSAGE_BROKERS = %i[rabbitmq].freeze
+    ALLOWED_ORMS = %i[activerecord].freeze
+
+    attr_accessor :rabbitmq_host, 
+                  :rabbitmq_port,
+                  :rabbitmq_user,
+                  :rabbitmq_password,
+                  :rabbitmq_vhost,
+                  :rabbitmq_event_bus_exchange,
+                  :message_broker,
+                  :orm
+
+    def initialize
+      raise Error, 'Sidekiq is not available. Unfortunately, sidekiq must be available for Outboxable to work' unless Object.const_defined?('Sidekiq')
+      raise Error, 'Outboxable Gem only supports Rails but you application does not seem to be a Rails app' unless Object.const_defined?('Rails')
+      raise Error, 'Outboxable Gem only support Rails version 7 and newer' if Rails::VERSION::MAJOR < 7
+      raise Error, 'Outboxable Gem uses the sidekiq-cron Gem. Make sure you add it to your project' unless Object.const_defined?('Sidekiq::Cron')
+
+      # In accordance to sidekiq-cron README: https://github.com/sidekiq-cron/sidekiq-cron#under-the-hood
+      Sidekiq::Options[:cron_poll_interval] = 5
+
+      # Create the cron job for the polling publisher
+      Sidekiq::Cron::Job.create(name: 'OutboxablePollingPublisher', cron: '*/5 * * * * *', class: 'Outboxable::PollingPublisherWorker') 
+    end
+
+    def message_broker=(message_broker)
+      raise ArgumentError, "Message broker must be one of #{ALLOWED_MESSAGE_BROKERS}" unless ALLOWED_MESSAGE_BROKERS.include?(message_broker)
+
+      @message_broker = message_broker
+    end
+
+    def message_broker
+      @message_broker || :rabbitmq
+    end
+
+    def orm=(orm)
+      raise ArgumentError, "ORM must be one of #{ALLOWED_ORMS}" unless ALLOWED_ORMS.include?(orm)
+
+      @orm = orm
+    end
+
+    def orm
+      @orm || :activerecord
+    end
+  end
+end