package org.webslinger.commons.vfs.tests;

 import java.io.File;

 import org.apache.commons.vfs.FileListener;

 import org.apache.commons.vfs.FileObject;

 import org.apache.commons.vfs.FileSystemException;

 import org.apache.commons.vfs.provider.AbstractFileSystem;

 import org.apache.commons.vfs.provider.local.LocalFile;

 import org.webslinger.commons.vfs.VFSUtil;

 import org.webslinger.io.FileMonitor;

 import org.webslinger.io.JNotifyFileMonitor;

 import org.webslinger.io.Monitor;

 public final class LocalFileObjectRoot extends AbstractFileObjectRoot<LocalFileObjectRoot, LocalFile> {

     private final File realFile;

     public LocalFileObjectRoot(LocalFile file) throws FileSystemException {

         super(file);

         realFile = VFSUtil.getLocalFile(file);

     }

     public LocalFileObjectRoot(FileObject file) throws FileSystemException {

         this((LocalFile) file);

     }

     protected LocalFileObjectRoot create(LocalFile file) throws Exception {

         return new LocalFileObjectRoot(file);

     }

     public Listener createListener() throws Exception {

         return new LocalFileObjectRootListener();

     }

     protected final class LocalFileObjectRootListener extends AbstractFileObjectRootListener implements FileMonitor.FileListener {

         public void start() throws Exception {

             System.err.println(file + ".start(): " + realFile);

             super.start();

             JNotifyFileMonitor.SINGLETON.add(realFile, this);

         }

         public void stop() throws Exception {

             JNotifyFileMonitor.SINGLETON.remove(realFile, this);

             super.stop();

         }

         protected void refresh() {

             try {

                 file.refresh();

                 file.getType();

             } catch (FileSystemException e) {

                 e.printStackTrace();

             }

         }

         public void acceptEvent(File item, Monitor.Listener.Event event) {

             System.err.println("acceptEvent(" + item + ", " + event + ")");

             assert item == realFile;

             AbstractFileSystem afs = (AbstractFileSystem) file.getFileSystem();

             switch (event) {

                 case CREATE:

                     refresh();

                     afs.fireFileCreated(file);

                     break;

                 case CHANGE:

                     afs.fireFileChanged(file);

                     break;

                 case DELETE:

                     refresh();

                     afs.fireFileDeleted(file);

                     break;

             }

         }

     }

 }