Sha256: c77ed160b6128e02422193e658fffa8bc30bd3488787c24273ed40f1a132caea
Contents?: true
Size: 1.7 KB
Versions: 10
Compression:
Stored size: 1.7 KB
Contents
# frozen_string_literal: true
require "listen"
require "observer"
module ShopifyCLI
module Theme
module DevServer
# Watches for file changes and publish events to the theme
class Watcher
include Observable
def initialize(ctx, theme:, syncer:, ignore_filter: nil, poll: false)
@ctx = ctx
@theme = theme
@syncer = syncer
@ignore_filter = ignore_filter
@listener = Listen.to(@theme.root, force_polling: poll,
ignore: @ignore_filter&.regexes) do |modified, added, removed|
changed
notify_observers(modified, added, removed)
end
add_observer(self, :upload_files_when_changed)
end
def start
@listener.start
end
def stop
@listener.stop
end
def upload_files_when_changed(modified, added, removed)
modified_theme_files = filter_theme_files(modified + added)
if modified_theme_files.any?
@syncer.enqueue_updates(modified_theme_files)
end
removed_theme_files = filter_remote_files(removed)
if removed_theme_files.any?
@syncer.enqueue_deletes(removed_theme_files)
end
end
def filter_theme_files(files)
files
.select { |file| @theme.theme_file?(file) }
.map { |file| @theme[file] }
.reject { |file| @syncer.ignore_file?(file) }
end
def filter_remote_files(files)
files
.select { |file| @syncer.remote_file?(file) }
.map { |file| @theme[file] }
.reject { |file| @syncer.ignore_file?(file) }
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems