Source code: com/memoire/fu/FuFileUrl.java

   /**
    * @modification $Date: 2002/12/16 09:09:11 $
    * @statut       unstable
    * @file         FuFileUrl.java
    * @version      0.36
    * @author       Guillaume Desnoix
    * @email        guillaume@desnoix.com
    * @license      GNU General Public License 2 (GPL2)
    * @copyright    1998-2001 Guillaume Desnoix
   */
  
  package com.memoire.fu;
  
  import com.memoire.fu.*;
  
  import java.io.*;
  import java.net.*;
  import java.util.*;
  
  /**
   * Remote file.
   */
  public class FuFileUrl
    extends    FuFile
  {
    protected URL      url_;
    protected String   name_;
  
    protected boolean  init_;
    protected boolean  exists_;
    protected long     lastModified_;
    protected long     length_;
    protected String[] list_;
  
    protected boolean canRead_;
    protected boolean canWrite_;
  
    /*
    public FuFileUrl(FuFileUrl _a, String _n) throws MalformedURLException
    {
      this(new URL(_a.url_,_n));
    }
    */
  
    public FuFileUrl(URL _a, String _n) throws MalformedURLException
    {
      this(new URL(_a,_n));
    }
  
    public FuFileUrl(URL _url)
    {
      super(_url.getFile());
      url_ =_url;
      list_=new String[0];
      init_=false;
      canRead_ =true;
      canWrite_=true;
    }
  
    public final void init()
    {
      if(!init_)
      {
        init_=true;
  
        final boolean[] done=new boolean[] { false };
  
        Runnable runnable=new Runnable()
        {
    public void run()
    {
      try
      {
        exists_=true;
        URLConnection cnx=getContentURL().openConnection();
        //System.err.println("CONTENT="+getContentURL());
        lastModified_=cnx.getLastModified();
        length_      =cnx.getContentLength();
        
        if(isDirectory())
        {
          InputStream    in=cnx.getInputStream();
          BufferedReader nr=new BufferedReader(new InputStreamReader(in));
          Vector v=readList(nr);
          nr.close();
      
          int l=v.size();
          list_=new String[l];
          for(int i=0;i<l;i++)
      list_[i]=(String)v.elementAt(i);
        }
      }
      catch(Exception ex)
      {
        exists_=false;
        //ex.printStackTrace();
      }
      done[0]=true;
    }
       };
 
       Thread t=new Thread(runnable,"Connecting "+getContentURL());
       t.start();
       for(int i=0;i<300;i++)
       {
   if(done[0]) break;
   try { Thread.sleep(100l); }
   catch(InterruptedException ex) { }
   System.err.print("~");
       }
       if(!done[0]) t.interrupt();
     }
   }
 
   protected Vector readList(BufferedReader _nr)
     throws IOException
   {
     return new Vector(0,1);
   }
 
   // FuFile API
 
   // redefine in FuFileHttp
   public URL getContentURL()
   {
     return url_;
   }
 
   public final FuFile createChild(String _name)
   {
     FuFile r=null;
     try
       { r=createFile(new URL(url_,_name)); }
     catch(MalformedURLException ex)
       { }
     return r;
   }
   
   public final InputStream getInputStream() throws IOException
   {
     InputStream r=null;
 
     if(canRead())
     {
       try
       {
         URLConnection cnx=getContentURL().openConnection();
   cnx.setDoInput(true);
   r=cnx.getInputStream();
       }
       catch(IOException ex) { }
     }
 
     if(r==null)
     {
       canRead_=false;
       throw new IOException("Can not read "+getContentURL());
     }
 
     return r;
   }
   
   public final OutputStream getOutputStream() throws IOException
   {
     OutputStream r=null;
 
     if(canWrite())
     {
       try
       {
         URLConnection cnx=getContentURL().openConnection();
   cnx.setDoOutput(true);
   r=cnx.getOutputStream();
       }
       catch(IOException ex) { }
     }
 
     if(r==null)
     {
       canWrite_=false;
       throw new IOException("Can not write "+getContentURL());
     }
 
     return r;
   }
 
   public final String getViewText()
   {
     return "["+url_.getHost()+"]"+url_.getFile();
   }
 
   // Standard API
 
   public final boolean canRead()
   {
     return canRead_;
   }
   
   public final boolean canWrite()
   {
     return canWrite_;
   }
 
   //int compareTo(File pathname)
   //int compareTo(Object o)
   
   public final boolean createNewFile()
   {
     return false;
   }
   
   public final boolean delete()
   {
     return false;
   }
   
   public final void deleteOnExit()
   {
   }
   
   public final boolean equals(Object _o)
   {
     if((_o==null)||!(_o instanceof File)) return false;
 
     String a=getAbsolutePath();
     String b=((File)_o).getAbsolutePath();
     if(a.endsWith("/")) a=a.substring(0,a.length()-1);
     if(b.endsWith("/")) b=b.substring(0,b.length()-1);
     return a.equals(b);
   }
   
   public final boolean exists()
   {
     init();
     return exists_;
     //return !init_ ? true : exists_;
   }
   
   public /*final*/ String getAbsolutePath()
   {
     return url_.toString();
   }
 
   public final String getCanonicalPath()
   {
     return url_.toString();
   }
 
   // use for '..'
   public final void setName(String _name)
   {
     name_=_name;
   }
 
   public final String getName()
   {
     if(name_!=null) return name_;
 
     String r;
     
     try
     {
       r=url_.getFile();//Path();
       if((r!=null)&&r.endsWith("/"))
   r=r.substring(0,r.length()-1);
       int i=r.lastIndexOf('/');
       r=r.substring(i+1);
     }
     catch(Exception ex) { r=null; }
     
     return r;
   }
   
   public final String getParent()
   {
     String r;
 
     try
     {
       r=url_.getFile();
       if((r!=null)&&r.endsWith("/"))
   r=r.substring(0,r.length()-1);
       int i=r.lastIndexOf('/');
       if(i>=0)
       {
   r=r.substring(0,i+1);
   r=new URL(url_,r).toString();
       }
       else r=null;
     }
     catch(Exception ex) { r=null; }
     
     return r;
   }
 
   public final String getPath()
   {
     return url_.toString();
   }
 
   public final int hashCode()
   {
     return url_.hashCode();
   }
   
   public final boolean isAbsolute()
   {
     return true;
   }
   
   public final boolean isDirectory()
   {
     String n=url_.getFile();
     return (n==null)||n.endsWith("/");
   }
 
   public final boolean isFile()
   {
     return !isDirectory();
   }
 
   public final boolean isHidden()
   {
     String n=getName();
     return (n!=null)&&n.startsWith(".");
   }
 
   public final long lastModified()
   {
     init();
     return lastModified_;
   }
 
   public final long length()
   {
     init();
     return length_;
   }
   
   public final String[] list()
   {
     init();
     return list_;
   }
 
   //String[] list(FilenameFilter filter)
   
   public final File[] listFiles()
   {
     init();
     
     int    l=list_.length;
     File[] r=new File[l];
 
     //try
     //{
     for(int i=0;i<l;i++)
       r[i]=createChild(list_[i]);
     //new URLAdapter(new URL(url_,list_[i]));
     //}
     //catch(MalformedURLException ex) { r=new File[0]; }
     
     return r;
   }
 
   //File[] listFiles(FileFilter filter)
   //File[] listFiles(FilenameFilter filter)
 
   public boolean mkdir()
   {
     return false;
   }
 
   public final boolean mkdirs()
   {
     return false;
   }
 
   public final boolean renameTo(File _dest)
   {
     return false;
   }
 
   public final boolean setLastModified(long _time)
   {
     return false;
   }
 
   public final boolean setReadOnly()
   {
     canWrite_=false;
     return true;
   }
 
   public final String toString()
   {
     return url_.toString();
   }
     
   public final URL toURL()
   {
     return url_;
   }
 }