Contents

require 'encore/persister/param_injection'
require 'encore/persister/errors_parser'
require 'encore/persister/key_mapping'
require 'encore/persister/links_parser'

module Encore
  module Persister
    class Instance
      include LinksParser
      include ErrorsParser

      attr_reader :errors

      def initialize(model, payload, options = {})
        @model = model
        @payload = payload
        @options = options
        @errors = []
        @ids = Set.new
      end

      def persist!
        @model.transaction do
          procces_payload!(action)

          if @errors.any? || @ids.empty?
            raise ActiveRecord::Rollback
          end

          true
        end
      end

      def active_records
        active_record_class.where(id: @ids.to_a.compact)
      end

    private

      def procces_payload!(action)
        payload = key_mapping(@payload)
        payload = param_injection(payload)

        payload.each_with_index do |args, i|
          args = parse_links(args)
          record = send("#{action}_record", args)

          next unless record.present?

          @ids += fetch_id(record)
          @errors += parse_errors(record, i)
        end
      end

      def active_record_class
        @model.is_a?(Class) ? @model : @model.class
      end

      def action
        @model.is_a?(Class) ? :create : :update
      end

      def create_record(args)
        @model.create args
      end

      def update_record(args)
        @model.update_attributes(args)
        @model
      end

      def fetch_id(record)
        [record.id]
      end

      def key_mapping(payload)
        @model.active_model_serializer ? KeyMapping.map_keys(payload, @model.active_model_serializer) : payload
      end

      def param_injection(payload)
        ParamInjection.inject(payload, @options[:inject_params])
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
encore-0.2.3	lib/encore/persister/instance.rb
encore-0.2.2	lib/encore/persister/instance.rb
encore-0.2.1	lib/encore/persister/instance.rb
encore-0.2	lib/encore/persister/instance.rb
encore-0.1	lib/encore/persister/instance.rb