Sha256: 8af9f25fbec3707ad53cb9441dc41f632165efb7f12abf6e010308df107bb228
Contents?: true
Size: 1.69 KB
Versions: 5
Compression:
Stored size: 1.69 KB
Contents
require 'listen'
module Locomotive::Wagon
class Listen < Struct.new(:path, :cache)
def self.start(path, cache)
new(path, cache).tap { |instance| instance.apply_definitions }
end
def apply_definitions
self.definitions.each do |definition|
self.apply(definition)
end
end
protected
def definitions
[
['config', /\.yml/, [:site, :content_types, :pages, :snippets, :content_entries, :translations]],
['app/views', %r{(pages|snippets)/(.+\.liquid).*}, [:pages, :snippets]],
['app/content_types', /\.yml/, [:content_types, :content_entries]],
['data', /\.yml/, :content_entries],
['public', %r{((stylesheets|javascripts)/(.+\.(css|js))).*}, []]
]
end
def apply(definition)
reloader = build_reloader([*definition.last])
filter = definition[1]
_path = File.expand_path(File.join(self.path, definition.first))
listener = ::Listen.to(_path, only: filter, &reloader)
# non blocking listener
listener.start
end
def build_reloader(resources)
Proc.new do |modified, added, removed|
resources.each do |resource|
Locomotive::Common::Logger.info "service=listen action=reload resource=#{resource} timestamp=#{Time.now}"
clear_cache_for(resource, modified + added + removed)
end
end
end
def clear_cache_for(resource, files)
keys = case resource
when :sites then '_sites'
when :content_entries
files.map { |f| "site_1_content_type_#{File.basename(f, '.yml')}_content_entries" }
else
"site_1_#{resource}"
end
[*keys].each { |key| cache.delete(key) }
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems