Sha256: b33e841cd09f9782a946606165e9f4472440f80362834cf75d25fea4a0bd4d68
Contents?: true
Size: 1.97 KB
Versions: 28
Compression:
Stored size: 1.97 KB
Contents
require_relative './concerns/assets_concern'
module Locomotive::Wagon
class PullBaseCommand < Struct.new(:api_client, :current_site, :path)
include Locomotive::Wagon::AssetsConcern
def self.pull(api_client, current_site, path)
new(api_client, current_site, path).pull
end
def pull
instrument do
instrument :start
self._pull_with_timezone
instrument :done
end
end
def _pull_with_timezone
Time.use_zone(current_site.try(:timezone)) do
_pull
end
end
def instrument(action = nil, payload = {}, &block)
name = [instrument_base_name, [*action]].flatten.compact.join('.')
ActiveSupport::Notifications.instrument(name, { name: resource_name }.merge(payload), &block)
end
def dump(element, options = {})
if element.is_a?(Hash)
StyledYAML.dump(element.dup.tap do |attributes|
[*options[:inline]].each do |name|
attributes[name] = StyledYAML.inline(attributes[name])
end
end)
else
element.to_yaml
end.gsub(/\A---\n/, '')
end
def clean_attributes(attributes)
# remove nil or empty values
attributes.delete_if { |_, v| v.nil? || v == '' || (v.is_a?(Hash) && v.empty?) }
end
def write_to_file(filepath, content = nil, mode = 'w+', &block)
_filepath = File.join(path, filepath)
folder = File.dirname(_filepath)
FileUtils.mkdir_p(folder) unless File.exists?(folder)
File.open(_filepath, mode) do |file|
file.write(content ? content : yield)
end
end
def reset_file(filepath)
_filepath = File.join(path, filepath)
FileUtils.rm(_filepath) if File.exists?(_filepath)
end
def instrument_base_name
'wagon.pull'
end
def resource_name
self.class.name[/::Pull(\w+)Command$/, 1].underscore
end
def default_locale
current_site.locales.first
end
def locales
current_site.locales
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems