package org.webslinger.ext.commons.vfs.plan9;

 import java.io.InputStream;

 import java.io.IOException;

 import java.io.OutputStream;

 import java.security.cert.Certificate;

 import java.util.Map;

 import org.apache.commons.vfs.FileName;

 import org.apache.commons.vfs.FileObject;

 import org.apache.commons.vfs.FileSystem;

 import org.apache.commons.vfs.FileSystemException;

 import org.apache.commons.vfs.FileSystemOptions;

 import org.apache.commons.vfs.FileType;

 import org.apache.commons.vfs.RandomAccessContent;

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

 import org.apache.commons.vfs.util.RandomAccessMode;

 import uk.ac.rdg.resc.jstyx.StyxUtils;

 import uk.ac.rdg.resc.jstyx.client.CStyxFile;

 import uk.ac.rdg.resc.jstyx.client.CStyxFileInputStream;

 import uk.ac.rdg.resc.jstyx.client.CStyxFileOutputStream;

 import uk.ac.rdg.resc.jstyx.types.DirEntry;

 import uk.ac.rdg.resc.jstyx.client.StyxConnection;

 public class Plan9FileObject extends AbstractFileObject {

     protected CStyxFile styxFile;

     protected StyxConnection connection;

     protected Plan9FileSystem fileSystem;

     public Plan9FileObject(FileName name, Plan9FileSystem fileSystem) {

         super(name, fileSystem);

         this.fileSystem = fileSystem;

     }

     protected DirEntry getDirEntry() throws Exception {

         DirEntry dirEntry = styxFile.getDirEntry();

         if (dirEntry == null) {

             styxFile.refresh();

             dirEntry = styxFile.getDirEntry();

         }

         return dirEntry;

     }

     protected boolean doIsHidden() throws Exception {

         return false;

     }

     protected boolean doIsReadable() throws Exception {

         return fileSystem.isReadable(getDirEntry());

     }

     protected boolean doIsWritable() throws Exception {

         return fileSystem.isWritable(getDirEntry());

     }

     protected void doAttach() throws Exception {

         System.err.println(this + ".doAttach()");

         connection = ((Plan9FileSystem) getFileSystem()).getConnection();

         styxFile = connection.getFile(getName().getPath());

     }

     protected void doDetach() throws Exception {

         System.err.println(this + ".doDetach()");

         styxFile.close();

         ((Plan9FileSystem) getFileSystem()).putConnection(connection);

         styxFile = null;

         connection = null;

     }

     protected InputStream doGetInputStream() throws Exception {

         final CStyxFile file = styxFile.getConnection().openFile(styxFile.getPath(), StyxUtils.OREAD);

         return new CStyxFileInputStream(file) {

             public void close() throws IOException {

                 file.close();

                 super.close();

             }

         };

     }

     protected OutputStream doGetOutputStream(boolean append) throws Exception {

         int mode = StyxUtils.OWRITE;

         if (!append) mode |= StyxUtils.OTRUNC;

         final CStyxFile file = styxFile.getConnection().openFile(styxFile.getPath(), mode);

         return new CStyxFileOutputStream(file) {

             public void close() throws IOException {

                 file.close();

                 super.close();

             }

         };

     }

     protected long doGetContentSize() throws Exception {

         return getDirEntry().getFileLength().asLong();

     }

     protected String[] doListChildren() throws Exception {

         CStyxFile[] styxChildren = styxFile.getChildren();

         String[] children = new String[styxChildren.length];

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

             children[i] = styxChildren[i].getName();

         }

         return children;

     }

     protected FileType doGetType() throws Exception {

         // FIXME: Check DirEntry instead

         return styxFile.isDirectory() ? FileType.FOLDER : FileType.FILE;

     }

     protected long doGetLastModifiedTime() throws Exception {

         return getDirEntry().getLastModifiedTime() * 1000;

     }

     protected void doSetLastModifiedTime(long time) throws Exception {

         super.doSetLastModifiedTime(time);

     }

     protected Map doGetAttributes() throws Exception {

         return null;

     }

     protected void doSetAttribute(String name, Object value) throws Exception {

     }

     protected void doRemoveAttribute(String name) throws Exception {

     }

     protected Certificate[] doGetCertificates() throws Exception {

         return super.doGetCertificates();

     }

     protected RandomAccessContent doGetRandomAccessContent(final RandomAccessMode mode) throws Exception {

         return super.doGetRandomAccessContent(mode);

     }

 }