1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
|
module FileUpdateCheckerWithEnumerableTestCases
FILES = %w(1.txt 2.txt 3.txt)
def setup
FileUtils.mkdir_p('tmp_watcher')
FileUtils.touch(FILES)
end
def teardown
FileUtils.rm_rf('tmp_watcher')
FileUtils.rm_rf(FILES)
end
def test_should_not_execute_the_block_if_no_paths_are_given
i = 0
checker = build_new_watcher([]) { i += 1 }
checker.execute_if_updated
assert_equal 0, i
end
def test_should_not_invoke_the_block_if_no_file_has_changed
i = 0
checker = build_new_watcher(FILES) { i += 1 }
assert !checker.execute_if_updated
assert_equal 0, i
end
def test_should_invoke_the_block_if_a_file_has_changed
i = 0
checker = build_new_watcher(FILES) { i += 1 }
sleep 1
FileUtils.touch(FILES)
sleep 1
assert checker.execute_if_updated
assert_equal 1, i
end
def test_updated_should_become_true_when_watched_files_are_deleted
watcher = build_new_watcher(FILES) { i += 1 }
assert !watcher.updated?
FileUtils.rm(FILES)
sleep 1
assert watcher.updated?
end
def test_should_be_robust_enough_to_handle_deleted_files
i = 0
checker = build_new_watcher(FILES) { i += 1 }
FileUtils.rm_f(FILES)
sleep 1
assert checker.execute_if_updated
assert_equal 1, i
end
def test_should_be_robust_to_handle_files_with_wrong_modified_time
i = 0
now = Time.now
time = Time.mktime(now.year + 1, now.month, now.day) # wrong mtime from the future
File.utime(time, time, FILES[2])
checker = build_new_watcher(FILES) { i += 1 }
sleep 1
FileUtils.touch(FILES[0..1])
sleep 1
assert checker.execute_if_updated
assert_equal 1, i
end
def test_should_cache_updated_result_until_execute
i = 0
checker = build_new_watcher(FILES) { i += 1 }
assert !checker.updated?
sleep 1
FileUtils.touch(FILES)
sleep 1
assert checker.updated?
checker.execute
assert !checker.updated?
end
def test_should_invoke_the_block_if_a_watched_dir_changed_its_glob
i = 0
checker = build_new_watcher([], 'tmp_watcher' => [:txt]) { i += 1 }
FileUtils.cd 'tmp_watcher' do
FileUtils.touch(FILES)
end
sleep 1
assert checker.execute_if_updated
assert_equal 1, i
end
def test_should_not_invoke_the_block_if_a_watched_dir_changed_its_glob
i = 0
checker = build_new_watcher([], 'tmp_watcher' => :rb) { i += 1 }
FileUtils.cd 'tmp_watcher' do
FileUtils.touch(FILES)
end
sleep 1
assert !checker.execute_if_updated
assert_equal 0, i
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
|
