1 files changed, 113 insertions, 0 deletions

diff --git a/plugins/org.eclipse.osee.framework.jdk.core.test/src/org/eclipse/osee/framework/jdk/core/test/util/io/FileWatcherTest.java b/plugins/org.eclipse.osee.framework.jdk.core.test/src/org/eclipse/osee/framework/jdk/core/test/util/io/FileWatcherTest.java
new file mode 100644
index 00000000000..ac56c6cbad8
--- /dev/null
+++ b/plugins/org.eclipse.osee.framework.jdk.core.test/src/org/eclipse/osee/framework/jdk/core/test/util/io/FileWatcherTest.java
@@ -0,0 +1,113 @@
+/*******************************************************************************
+ * Copyright (c) 2010 Boeing.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Boeing - initial API and implementation
+ *******************************************************************************/
+package org.eclipse.osee.framework.jdk.core.test.util.io;
+
+import java.io.File;
+import java.util.Collection;
+import java.util.concurrent.TimeUnit;
+import junit.framework.Assert;
+import org.eclipse.osee.framework.jdk.core.test.mock.MockFileWatcherListener;
+import org.eclipse.osee.framework.jdk.core.util.io.FileChangeEvent;
+import org.eclipse.osee.framework.jdk.core.util.io.FileChangeType;
+import org.eclipse.osee.framework.jdk.core.util.io.FileWatcher;
+import org.junit.Test;
+
+/**
+ * @author Roberto E. Escobar
+ */
+public class FileWatcherTest {
+
+   @Test
+   public void testWatcher() throws InterruptedException {
+      MockFileWatcherListener listener = new MockFileWatcherListener();
+
+      FileWatcher watcher = new FileWatcher(320, TimeUnit.MILLISECONDS);
+
+      MockFile file = new MockFile("abcde", true);
+
+      Assert.assertTrue(file.exists());
+
+      watcher.addListener(listener);
+      watcher.addFile(file);
+      watcher.start();
+
+      file.setLastModified(10000);
+      synchronized (listener) {
+         listener.wait(1000);
+      }
+      checkEvent(listener, file, FileChangeType.CREATED);
+
+      listener.clear();
+      file.setLastModified(15000);
+      synchronized (listener) {
+         listener.wait(1000);
+      }
+      checkEvent(listener, file, FileChangeType.MODIFIED);
+
+      listener.clear();
+      file.setExists(false);
+      file.setLastModified(0);
+      synchronized (listener) {
+         listener.wait(1000);
+      }
+      checkEvent(listener, file, FileChangeType.DELETED);
+
+      watcher.stop();
+      watcher.removeFile(file);
+      watcher.removeListener(listener);
+   }
+
+   private static void checkEvent(MockFileWatcherListener listener, File expectedFile, FileChangeType expectedType) {
+      Assert.assertEquals("File modified event was not received", 1, listener.getFileModifiedCallCount());
+      Collection<FileChangeEvent> items = listener.getFileChangeEvents();
+      Assert.assertEquals(1, items.size());
+      FileChangeEvent event = items.iterator().next();
+      Assert.assertNotNull(event);
+      Assert.assertEquals(expectedType, event.getChangeType());
+      Assert.assertEquals(expectedFile, event.getFile());
+   }
+
+   private final class MockFile extends File {
+
+      private static final long serialVersionUID = 8677714040873925615L;
+      private long lastModified;
+      private boolean exists;
+
+      public MockFile(String pathname, boolean exists) {
+         super(pathname);
+         this.exists = exists;
+      }
+
+      @Override
+      public long lastModified() {
+         return lastModified;
+      }
+
+      @Override
+      public boolean setLastModified(long time) {
+         boolean change = lastModified() != time;
+         if (change) {
+            this.lastModified = time;
+         }
+         return change;
+      }
+
+      @Override
+      public boolean exists() {
+         return exists;
+      }
+
+      public void setExists(boolean exists) {
+         this.exists = exists;
+      }
+
+   }
+}
\ No newline at end of file