Contents

require "active_support/core_ext/class"
require "active_support/core_ext/string"
require "active_support/hash_with_indifferent_access"
require "sync_machine/change_listener"
require "sync_machine/ensure_publication"
require "sync_machine/ensure_publication_worker"
require "sync_machine/find_subjects_worker"
require "sync_machine/tracer_adapters"
require "sync_machine/redis_lock"
require "sync_machine/orm_adapters"
require "sync_machine/version"
require "sync_machine/railtie" if defined?(Rails::Railtie)

# A mini-framework for intelligently publishing complex model changes to an
# external API..
module SyncMachine
  def self.abort_with_installation_hint(gem_name, dependency)
    Kernel.abort(
      "Please install the #{gem_name} gem when using SyncMachine with #{dependency}."
    )
  end

  # Force loading of all relevant classes.  Should only be necessary when
  # running your application in a way that it defers loading constants, i.e.,
  # Rails' development or test mode.
  def self.eager_load(base)
    const_names = %w(
      Payload FindSubjectsWorker EnsurePublicationWorker ChangeListener
    )
    const_names.each do |const_name|
      base.const_get(const_name)
    end
  end

  def self.extended(base)
    base.mattr_accessor :subject_sym
    base.mattr_accessor :subject_opts
  end

  def self.sync_module(child_const)
    child_const.name.split(/::/)[0..-2].join('::').constantize
  end

  def orm_adapter
    SyncMachine::OrmAdapters.orm_adapter(self)
  end

  def subject(subject_sym, opts = {})
    self.subject_sym = subject_sym
    self.subject_opts = ActiveSupport::HashWithIndifferentAccess.new(opts)
  end

  def subject_class
    (subject_opts[:class_name] || subject_sym.to_s.camelize).constantize
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
sync_machine-1.4.0	lib/sync_machine.rb