package org.webslinger.modules;

 import java.io.File;

 import java.io.IOException;

 import java.io.PrintStream;

 import java.util.Collection;

 import java.util.Enumeration;

 import java.util.HashMap;

 import java.util.Iterator;

 import java.util.logging.Logger;

 import org.apache.commons.vfs.FileObject;

 import org.apache.commons.vfs.FileSystemManager;

 import org.webslinger.commons.vfs.FileReplicator;

 import org.webslinger.commons.vfs.VFSUtil;

 import org.webslinger.commons.vfs.operations.COWStateOperation;

 import org.webslinger.commons.vfs.virtual.VirtualFileSystem;

 public class StandardModuleState implements ModuleState, WorkAreaFactory<WorkArea> {

     private static final Logger logger = Logger.getLogger(StandardModuleState.class.getName());

     protected final GenericWorkAreaFactory workAreaFactory;

     protected final FileSystemManager fsm;

     protected final VirtualFileSystem vfs;

     protected final FileObject cow;

     protected final FileReplicator replicator;

     public StandardModuleState(FileObject root) throws IOException {

         this(root, (FileObject[]) null);

     }

     public StandardModuleState(FileObject root, FileObject base) throws IOException {

         this(root, new FileObject[] {base});

     }

     public StandardModuleState(FileObject root, FileObject[] bases) throws IOException {

         replicator = new FileReplicator(root.resolveFile("Var/ModuleCache/"));

         replicator.getCacheLocation().createFolder();

         final FileObject workAreaRoot = root.resolveFile("Var/WorkArea");

         fsm = root.getFileSystem().getFileSystemManager();

         workAreaFactory = new GenericWorkAreaFactory(root, workAreaRoot);

         vfs = workAreaFactory.getVirtual();

         cow = workAreaFactory.getCOW();

         COWStateOperation siteCOW = VFSUtil.getOperation(cow.resolveFile("/site"), COWStateOperation.class);

         siteCOW.clear();

         VFSUtil.getOperation(cow.resolveFile("/modules/enabled"), COWStateOperation.class).clear();

         if (bases != null) {

             for (int i = 0; i < bases.length; i++) {

                 vfs.resolveFile("/base/" + i).createFolder();

                 vfs.addJunction("/base/" + i, bases[i]);

                 siteCOW.addBase("base/" + i);

                 try {

                     Thread.sleep(5);

                 } catch (InterruptedException e) {

                     // ignore, bug work-around, race condition?

                 }

             }

         }

         vfs.resolveFile("/libraries/Lib").createFolder();

         siteCOW.addBase("libraries");

         vfs.resolveFile("/modules/available").createFolder();

         vfs.resolveFile("/modules/layout").createFolder();

         vfs.resolveFile("/modules/enabled").createFolder();

         siteCOW.addBase("modules/enabled");

     }

     public FileObject getRoot() {

         return workAreaFactory.getRoot();

     }

     protected FileObject makeLocalFile(FileObject file) throws IOException {

         return replicator.getLocalFile(file);

     }

     protected void deleteLocalFile(String url) throws IOException {

         replicator.deleteLocalFile(url);

     }

     public boolean addLibrary(String name, String url) throws IOException {

         logger.info("addLibrary(" + name + ", " + url + ")");

         FileObject file = makeLocalFile(fsm.resolveFile(url));

         logger.fine("file=" + file);

         //addModulePoint(name, file, "config");

         //addModulePoint(name, file, "www");

         //addModulePoint(name, file, "var");

         vfs.addJunction("/libraries/Lib/" + name, file);

         return true;

     }

     public boolean addModule(String name, String url) throws IOException {

         logger.info("addModule(" + name + ", " + url + ")");

         FileObject file = makeLocalFile(fsm.resolveFile(url));

         if (fsm.canCreateFileSystem(file)) file = fsm.createFileSystem(file);

         logger.info("file=" + file);

         //addModulePoint(name, file, "config");

         //addModulePoint(name, file, "www");

         //addModulePoint(name, file, "var");

         FileObject target = vfs.resolveFile("/modules/available/" + name);

         if (!file.getType().hasChildren()) target = target.getParent();

         target.createFolder();

         vfs.addJunction("/modules/available/" + name, file);

         return true;

     }

     public boolean removeLibrary(String name) throws IOException {

         workAreaFactory.getVirtual().removeJunction("/libraries/Lib/" + name);

         return true;

     }

     public boolean removeModule(String name) throws IOException {

         workAreaFactory.getVirtual().removeJunction("/modules/available/" + name);

         return true;

     }

     public boolean enableModule(String name) throws IOException {

         logger.info("enableModule(" + name + ")");

         return VFSUtil.getOperation(vfs, "/modules/enabled", COWStateOperation.class).addBase("/modules/layout/" + name);

     }

     public boolean disableModule(String name) throws IOException {

         return VFSUtil.getOperation(vfs, "/modules/enabled", COWStateOperation.class).removeBase("/modules/layout/" + name);

     }

     public boolean addModuleMount(String name, String src, String dest) throws IOException {

         logger.info("addModuleMount(" + name + ", " + src + ", " + dest + ")");

         FileObject toMount = vfs.resolveFile("/modules/available/" + name + "/" + src);

         FileObject target = vfs.resolveFile("/modules/layout/" + name + "/" + dest);

         if (!toMount.getType().hasChildren()) target = target.getParent();

         target.createFolder();

         vfs.addJunction("/modules/layout/" + name + "/" + dest, toMount);

         return true;

     }

     public boolean removeModuleMount(String name, String dest) throws IOException {

         vfs.removeJunction("/modules/layout/" + name + dest);

         return true;

     }

     public WorkArea create() throws IOException {

         return workAreaFactory.create();

     }

     public WorkArea join(String name) throws IOException {

         return workAreaFactory.join(name);

     }

     public Collection<? extends WorkArea> getWorkAreas() throws IOException {

         return workAreaFactory.getWorkAreas();

     }

 }