wamblee.org Git - utils/blob - support/src/main/java/org/wamblee/io/DirectoryMonitor.java

   1 /*
   2  * Copyright 2006 the original author or authors.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package org.wamblee.io;
  18
  19 import java.io.File;
  20 import java.io.FileFilter;
  21 import java.util.ArrayList;
  22 import java.util.Date;
  23 import java.util.HashMap;
  24 import java.util.List;
  25 import java.util.Map;
  26
  27 import org.apache.commons.logging.Log;
  28 import org.apache.commons.logging.LogFactory;
  29
  30 /**
  31  * Monitors a directory for changes.
  32  */
  33 public class DirectoryMonitor {
  34
  35     private static final Log LOG = LogFactory.getLog(DirectoryMonitor.class);
  36
  37     public static interface Listener {
  38         void fileChanged(File aFile);
  39         void fileCreated(File aFile);
  40         void fileDeleted(File aFile);
  41     };
  42
  43     private File _directory;
  44     private FileFilter _filter;
  45     private Listener _listener;
  46     private Map<File,Date> _contents;
  47
  48     public DirectoryMonitor(File aDirectory, FileFilter aFilefilter, Listener aListener) {
  49         _directory = aDirectory;
  50         if ( !_directory.isDirectory()) {
  51             throw new IllegalArgumentException("Directory '" + _directory + "' does not exist");
  52         }
  53         _filter = aFilefilter;
  54         _listener = aListener;
  55         _contents = new HashMap<File,Date>();
  56     }
  57
  58     public void poll() {
  59         LOG.debug("Polling " + _directory);
  60         Map<File,Date> newContents = new HashMap<File,Date>();
  61         File[] files = _directory.listFiles(_filter);
  62         for (File file: files) {
  63             if ( _contents.containsKey(file)) {
  64                 Date oldDate = _contents.get(file);
  65                 if (file.lastModified() != oldDate.getTime()) {
  66                     _listener.fileChanged(file);
  67                 } else {
  68                     // No change.
  69                 }
  70                 _contents.remove(file);
  71                 newContents.put(file, new Date(file.lastModified()));
  72             } else {
  73                 _listener.fileCreated(file);
  74                 newContents.put(file, new Date(file.lastModified()));
  75             }
  76         }
  77         for (File file: _contents.keySet()) {
  78             _listener.fileDeleted(file);
  79         }
  80         _contents = newContents;
  81     }
  82
  83 }