提交 60de179c 编写于 作者: X Xavier Noria

refactors the file monitors test suite

In particular files are no longer created in the current working directory,
but in a temporary folder.
上级 e8fbf68a
require 'abstract_unit' require 'abstract_unit'
require 'fileutils'
require 'thread'
require 'pathname' require 'pathname'
require 'file_update_checker_with_enumerable_test_cases' require 'file_update_checker_with_enumerable_test_cases'
class FileEventedUpdateCheckerTest < ActiveSupport::TestCase class FileEventedUpdateCheckerTest < ActiveSupport::TestCase
include FileUpdateCheckerWithEnumerableTestCases include FileUpdateCheckerWithEnumerableTestCases
def build_new_watcher(files, dirs={}, &block) def build_new_watcher(files=[], dirs={}, &block)
ActiveSupport::FileEventedUpdateChecker.new(files, dirs, &block) ActiveSupport::FileEventedUpdateChecker.new(files, dirs, &block)
end end
...@@ -15,6 +13,10 @@ def teardown ...@@ -15,6 +13,10 @@ def teardown
super super
Listen.stop Listen.stop
end end
def wait
sleep 0.5
end
end end
class FileEventedUpdateCheckerPathHelperTest < ActiveSupport::TestCase class FileEventedUpdateCheckerPathHelperTest < ActiveSupport::TestCase
......
require 'abstract_unit' require 'abstract_unit'
require 'fileutils'
require 'thread'
require 'file_update_checker_with_enumerable_test_cases' require 'file_update_checker_with_enumerable_test_cases'
class FileUpdateCheckerTest < ActiveSupport::TestCase class FileUpdateCheckerTest < ActiveSupport::TestCase
include FileUpdateCheckerWithEnumerableTestCases include FileUpdateCheckerWithEnumerableTestCases
def build_new_watcher(files, dirs={}, &block) def build_new_watcher(files=[], dirs={}, &block)
ActiveSupport::FileUpdateChecker.new(files, dirs, &block) ActiveSupport::FileUpdateChecker.new(files, dirs, &block)
end end
end end
require 'fileutils'
module FileUpdateCheckerWithEnumerableTestCases module FileUpdateCheckerWithEnumerableTestCases
FILES = %w(1.txt 2.txt 3.txt) include FileUtils
def wait
# noop
end
def setup def setup
FileUtils.mkdir_p('tmp_watcher') @tmpdir = Dir.mktmpdir
FileUtils.touch(FILES)
@files = %w(foo.rb bar.rb baz.rb).map {|f| "#{@tmpdir}/#{f}"}
touch(@files)
end end
def teardown def teardown
FileUtils.rm_rf('tmp_watcher') rm_rf(@tmpdir)
FileUtils.rm_rf(FILES)
end end
def test_should_not_execute_the_block_if_no_paths_are_given def test_should_not_execute_the_block_if_no_paths_are_given
i = 0 i = 0
checker = build_new_watcher([]) { i += 1 } checker = build_new_watcher { i += 1 }
checker.execute_if_updated
assert !checker.execute_if_updated
assert_equal 0, i assert_equal 0, i
end end
def test_should_not_invoke_the_block_if_no_file_has_changed def test_should_not_invoke_the_block_if_no_file_has_changed
i = 0 i = 0
checker = build_new_watcher(FILES) { i += 1 } checker = build_new_watcher(@files) { i += 1 }
assert !checker.execute_if_updated assert !checker.execute_if_updated
assert_equal 0, i assert_equal 0, i
...@@ -32,22 +39,24 @@ def test_should_not_invoke_the_block_if_no_file_has_changed ...@@ -32,22 +39,24 @@ def test_should_not_invoke_the_block_if_no_file_has_changed
def test_should_invoke_the_block_if_a_file_has_changed def test_should_invoke_the_block_if_a_file_has_changed
i = 0 i = 0
checker = build_new_watcher(FILES) { i += 1 } checker = build_new_watcher(@files) { i += 1 }
sleep 1
FileUtils.touch(FILES)
sleep 1 sleep 1
touch(@files)
wait
assert checker.execute_if_updated assert checker.execute_if_updated
assert_equal 1, i assert_equal 1, i
end end
def test_updated_should_become_true_when_watched_files_are_deleted def test_updated_should_become_true_when_watched_files_are_deleted
watcher = build_new_watcher(FILES) { i += 1 } i = 0
watcher = build_new_watcher(@files) { i += 1 }
assert !watcher.updated? assert !watcher.updated?
FileUtils.rm(FILES) rm_f(@files)
sleep 1 wait
assert watcher.updated? assert watcher.updated?
end end
...@@ -55,10 +64,10 @@ def test_updated_should_become_true_when_watched_files_are_deleted ...@@ -55,10 +64,10 @@ def test_updated_should_become_true_when_watched_files_are_deleted
def test_should_be_robust_enough_to_handle_deleted_files def test_should_be_robust_enough_to_handle_deleted_files
i = 0 i = 0
checker = build_new_watcher(FILES) { i += 1 } checker = build_new_watcher(@files) { i += 1 }
FileUtils.rm_f(FILES)
sleep 1 rm_f(@files)
wait
assert checker.execute_if_updated assert checker.execute_if_updated
assert_equal 1, i assert_equal 1, i
...@@ -69,13 +78,13 @@ def test_should_be_robust_to_handle_files_with_wrong_modified_time ...@@ -69,13 +78,13 @@ def test_should_be_robust_to_handle_files_with_wrong_modified_time
now = Time.now now = Time.now
time = Time.mktime(now.year + 1, now.month, now.day) # wrong mtime from the future time = Time.mktime(now.year + 1, now.month, now.day) # wrong mtime from the future
File.utime(time, time, FILES[2]) File.utime(time, time, @files[0])
checker = build_new_watcher(FILES) { i += 1 } checker = build_new_watcher(@files) { i += 1 }
sleep 1
FileUtils.touch(FILES[0..1])
sleep 1 sleep 1
touch(@files[1..-1])
wait
assert checker.execute_if_updated assert checker.execute_if_updated
assert_equal 1, i assert_equal 1, i
...@@ -84,59 +93,40 @@ def test_should_be_robust_to_handle_files_with_wrong_modified_time ...@@ -84,59 +93,40 @@ def test_should_be_robust_to_handle_files_with_wrong_modified_time
def test_should_cache_updated_result_until_execute def test_should_cache_updated_result_until_execute
i = 0 i = 0
checker = build_new_watcher(FILES) { i += 1 } checker = build_new_watcher(@files) { i += 1 }
assert !checker.updated? assert !checker.updated?
sleep 1
FileUtils.touch(FILES)
sleep 1 sleep 1
touch(@files)
wait
assert checker.updated? assert checker.updated?
checker.execute checker.execute
assert !checker.updated? assert !checker.updated?
end end
def test_should_invoke_the_block_if_a_watched_dir_changed_its_glob def test_should_invoke_the_block_if_a_watched_dir_changes
i = 0 i = 0
checker = build_new_watcher([], 'tmp_watcher' => [:txt]) { i += 1 } checker = build_new_watcher([], @tmpdir => :rb) { i += 1 }
FileUtils.cd 'tmp_watcher' do
FileUtils.touch(FILES)
end
sleep 1 sleep 1
touch(@files)
wait
assert checker.execute_if_updated assert checker.execute_if_updated
assert_equal 1, i assert_equal 1, i
end end
def test_should_not_invoke_the_block_if_a_watched_dir_changed_its_glob def test_should_not_invoke_the_block_if_a_watched_dir_does_not_change
i = 0 i = 0
checker = build_new_watcher([], 'tmp_watcher' => :rb) { i += 1 } checker = build_new_watcher([], @tmpdir => :txt) { i += 1 }
FileUtils.cd 'tmp_watcher' do touch(@files)
FileUtils.touch(FILES) wait
end
sleep 1
assert !checker.execute_if_updated assert !checker.execute_if_updated
assert_equal 0, i assert_equal 0, i
end end
def test_should_not_block_with_unusual_file_names
unusual_dirname = 'tmp_watcher/valid,yetstrange,path,'
FileUtils.mkdir_p(unusual_dirname)
FileUtils.touch(FILES.map { |file_name| "#{unusual_dirname}/#{file_name}" })
test = Thread.new do
build_new_watcher([], unusual_dirname => :txt) { i += 1 }
Thread.exit
end
test.priority = -1
test.join(5)
assert !test.alive?
end
end end
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册