Contents

require 'synchronisable/input_descriptor'

module Synchronisable
  # @api private
  class InputDispatcher
    class << self
      def dispatch(model, synchronizer, data)
        new(model, synchronizer).dispatch(data)
      end
    end

    def initialize(model, synchronizer)
      @model = model
      @synchronizer = synchronizer
    end

    def dispatch(data)
      input = InputDescriptor.new(data)

      result = case
      when input.empty?
        @synchronizer.fetch
      when input.remote_id?
        @synchronizer.find(data)
      when input.local_id?
        find_by_local_id(data)
      when input.array_of_ids?
        find_by_array_of_ids(input)
      else
        result = data.dup
      end

      [result].flatten.compact
    end

    private

    def find_by_array_of_ids(input)
      records = find_imports(input.element_class.name, input.data)
      records.map { |r| @synchronizer.find(r.remote_id) }
    end

    def find_by_local_id(id)
      import = @model.find_by(id: id).try(:import)
      import ? @synchronizer.find(import.remote_id) : nil
    end

    def find_imports(class_name, ids)
      case class_name
      when 'Fixnum'
        ids.map { |id| @model.find_by(id: id).try(&:import) }
      when 'String'
        ids.map { |id| Import.find_by(id: id) }
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
synchronisable-0.0.9	lib/synchronisable/input_dispatcher.rb
synchronisable-0.0.8	lib/synchronisable/input_dispatcher.rb
synchronisable-0.0.7	lib/synchronisable/input_dispatcher.rb
synchronisable-0.0.6	lib/synchronisable/input_dispatcher.rb