Changeset 80 for trunk/src/directory_watcher_test.erl

Timestamp:

07/17/09 13:31:39 (3 years ago)

Author:

dom

Message:

Fixed more bugs in directory_watcher.

File:

• trunk/src/directory_watcher_test.erl (modified) (3 diffs)

trunk/src/directory_watcher_test.erl

@@ -17 +17 @@
 -export ([change_from_file_to_directory_when_recursive/0]).
 -export ([remove_and_add_in_same_check/0]).
+-export ([insensitive_to_cwd/0]).
+-export ([can_replace_all_in_same_check/0]).
+-export ([can_find_two_at_a_time/0]).
+-export([tree/0]).
 
 tests_from_empty () ->
@@ -71 +75 @@
 remove_and_add_in_same_check () ->    
     F = fun remove_and_add_in_same_check/2,
+    ok = fixtures: use_tree ([{file, "foo", "foo"}], F).
+
+insensitive_to_cwd () ->
+    Watcher = spawn_link (directory_watcher, init, ["/home/dom/forge/fix", send_me ()]),
+    receive_all (),
+    ok = file: set_cwd ("/tmp"),
+    Watcher ! check,
+    true = is_process_alive (Watcher),
+    [] = receive_all (),
+    ok.
+
+can_replace_all_in_same_check () ->
+    Tree = [{file, X, X} || X <- ["foo", "bar", "baz"]],
+    F = fun can_replace_all_in_same_check/2,
+    ok = fixtures: use_tree (Tree, F).
+
+can_find_two_at_a_time () ->
+    F = fun can_find_two_at_a_time/2,
     ok = fixtures: use_tree ([{file, "foo", "foo"}], F).
 
@@ -267 +289 @@
     ok = file: write_file (Bar, list_to_binary ("bar")),
     Watcher ! check,
-    [{{file, ""}, Foo, lost},
-     {{file, ""}, Bar, found}] = receive_all (),
-    ok.
-    
+    [{{file, ""}, Bar, found},
+     {{file, ""}, Foo, lost}] = receive_all (),
+    ok.
+    
+can_replace_all_in_same_check (Root, Tree) ->
+    Watcher = spawn_link (directory_watcher, init, [Root, send_me ()]),
+    receive_all (),
+    Replace = fun ({file, F, _}) ->
+                     Old = filename: join (Root, F),
+                     ok = file: delete (Old),
+                      New = filename: join (Root, F ++ F),
+                      ok = file: write_file (New, "hello")
+             end,
+    ok = lists: foreach (Replace, Tree),
+    Watcher ! check,
+    Lost_files = [filename: join (Root, X) || {file, X, _} <- Tree],
+    Found_files = [filename: join (Root, X++X) || {file, X, _} <- Tree],
+    Lost = [{{file, ""}, X, lost} || X <- Lost_files],
+    Found = [{{file, ""}, X, found} || X <- Found_files],
+    Expected = lists: sort (Lost ++ Found),
+    Received = lists: sort (receive_all ()),
+    {Expected, Expected} = {Expected, Received},
+    ok.
+
+can_find_two_at_a_time (Root, _) ->
+    Watcher = spawn_link (directory_watcher, init, [Root, send_me ()]),
+    receive_all (),
+    [Bar, Baz] = [filename: join (Root, X) || X <- ["bar", "baz"]],
+    ok = file: write_file (Bar, "bar"),
+    ok = file: write_file (Baz, "baz"),
+    Watcher ! check,
+    Found = [{{file, ""}, X, found} || X <- [Bar, Baz]],
+    Expected = lists: sort (Found),
+    Received = lists: sort (receive_all ()),
+    {Expected, Expected} = {Expected, Received},
+    ok.
 
 send_me () ->