Contents

module Locomotive::Wagon

  class PushBaseCommand < Struct.new(:api_client, :steam_services, :content_assets_pusher, :remote_site, :filter)

    extend Forwardable

    def_delegators :steam_services, :current_site, :locale, :repositories

    def self.push(api_client, steam_services, content_assets_pusher, remote_site)
      instance = new(api_client, steam_services, content_assets_pusher, remote_site)
      yield instance if block_given?
      instance.push
    end

    def push
      instrument do
        instrument :start
        self._push_with_timezone
        instrument :done
      end
    end

    def _push_with_timezone
      Time.use_zone(current_site.try(:timezone)) do
        _push
      end
    end

    def _push
      entities.each do |entity|
        decorated = decorate(entity)
        begin
          instrument :persist, label: label_for(decorated)
          persist(decorated)
          instrument :persist_with_success
        rescue SkipPersistingException => e
          instrument :skip_persisting
        rescue Exception => e
          instrument :persist_with_error, message: e.message
          raise e
        end
      end
    end

    def instrument(action = nil, payload = {}, &block)
      name = ['wagon.push', [*action]].flatten.compact.join('.')
      ActiveSupport::Notifications.instrument(name, { name: resource_name }.merge(payload), &block)
    end

    def resource_name
      self.class.name[/::Push(\w+)Command$/, 1].underscore
    end

    def default_locale
      current_site.default_locale
    end

    def locales
      current_site.locales
    end

    def path
      File.expand_path(repositories.adapter.options[:path])
    end

    def with_data
      @with_data = true
    end

    def with_data?
      !!@with_data
    end

    def only(entities)
      @only_entities = entities.map do |entity_or_filter|
        Locomotive::Wagon::Glob.new(entity_or_filter.gsub(/\A\//, '')).to_regexp
      end
    end

    class SkipPersistingException < Exception
    end

  end

end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
locomotivecms_wagon-2.1.0.rc3	lib/locomotive/wagon/commands/push_sub_commands/push_base_command.rb
locomotivecms_wagon-2.0.1	lib/locomotive/wagon/commands/push_sub_commands/push_base_command.rb
locomotivecms_wagon-2.0.0	lib/locomotive/wagon/commands/push_sub_commands/push_base_command.rb
locomotivecms_wagon-2.0.0.rc8	lib/locomotive/wagon/commands/push_sub_commands/push_base_command.rb
locomotivecms_wagon-2.0.0.rc7	lib/locomotive/wagon/commands/push_sub_commands/push_base_command.rb