Contents

# frozen_string_literal: true

module Dynamoid
  module Persistence
    # @private
    class Inc
      def self.call(model_class, hash_key, range_key = nil, counters)
        new(model_class, hash_key, range_key, counters).call
      end

      # rubocop:disable Style/OptionalArguments
      def initialize(model_class, hash_key, range_key = nil, counters)
        @model_class = model_class
        @hash_key = hash_key
        @range_key = range_key
        @counters = counters
      end
      # rubocop:enable Style/OptionalArguments

      def call
        touch = @counters.delete(:touch)

        Dynamoid.adapter.update_item(@model_class.table_name, @hash_key, update_item_options) do |t|
          @counters.each do |name, value|
            t.add(name => cast_and_dump_attribute_value(name, value))
          end

          if touch
            value = DateTime.now.in_time_zone(Time.zone)

            timestamp_attributes_to_touch(touch).each do |name|
              t.set(name => cast_and_dump_attribute_value(name, value))
            end
          end
        end
      end

      private

      def update_item_options
        if @model_class.range_key
          range_key_options = @model_class.attributes[@model_class.range_key]
          value_casted = TypeCasting.cast_field(@range_key, range_key_options)
          value_dumped = Dumping.dump_field(value_casted, range_key_options)
          { range_key: value_dumped }
        else
          {}
        end
      end

      def cast_and_dump_attribute_value(name, value)
        value_casted = TypeCasting.cast_field(value, @model_class.attributes[name])
        Dumping.dump_field(value_casted, @model_class.attributes[name])
      end

      def timestamp_attributes_to_touch(touch)
        return [] unless touch

        names = []
        names << :updated_at if @model_class.timestamps_enabled?
        names += Array.wrap(touch) if touch != true
        names
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
dynamoid-3.10.0	lib/dynamoid/persistence/inc.rb
dynamoid-3.9.0	lib/dynamoid/persistence/inc.rb