Contents

require 'synchronisable/input_descriptor'

module Synchronisable
  # Responsible for guessing the user input format.
  #
  # @api private
  #
  # @see Synchronisable::InputDescriptor
  class InputParser
    def initialize(model, synchronizer)
      @model = model
      @synchronizer = synchronizer
    end

    # Parses the user input.
    #
    # @param data [Array<Hash>, Array<String>, Array<Integer>, String, Integer]
    #   synchronization data to handle.
    #
    # @return [Array<Hash>] array of hashes with remote attributes
    def parse(data)
      input = InputDescriptor.new(data)

      result = case
               when input.empty?
                 @synchronizer.fetch
               when input.params?
                 find_or_fetch_by_data(input.data)
               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_or_fetch_by_data(data)
      sync_method = data.key?(:id) ? :find : :fetch
      @synchronizer.send(sync_method, data)
    end

    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

5 entries across 5 versions & 1 rubygems

Version	Path
synchronisable-1.1.1	lib/synchronisable/input_parser.rb
synchronisable-1.1.0	lib/synchronisable/input_parser.rb
synchronisable-1.0.9	lib/synchronisable/input_parser.rb
synchronisable-1.0.8	lib/synchronisable/input_parser.rb
synchronisable-1.0.7	lib/synchronisable/input_parser.rb