123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251
/*******************************************************************************
     copyright:      Copyright (c) 2007-2008 Tango. All rights reserved

     license:        BSD style: $(LICENSE)

     version:        August 2008: Initial version

     author:         Lester L. Martin II
*******************************************************************************/

module tango.io.vfs.FtpFolder;

private {
    import tango.net.ftp.FtpClient;
    import tango.io.vfs.model.Vfs;
    import tango.io.vfs.FileFolder;
    import tango.io.device.Conduit;
    import tango.text.Util;
    import tango.time.Time;
}

private char[] fixName(char[] toFix) {
    if (containsPattern(toFix, "/"))
        toFix = toFix[(locatePrior(toFix, '/') + 1) .. length];
    return toFix;
}

private char[] checkFirst(char[] toFix) {
    for(; toFix.length>0 && toFix[$-1] == '/';)
        toFix = toFix[0 .. ($-1)];
    return toFix;
}

private char[] checkLast(char[] toFix) {
for(;toFix.length>1 &&  toFix[0] == '/' && toFix[1] == '/' ;)
        toFix = toFix[1 .. $];
    if(toFix.length && toFix[0] != '/')
        toFix = '/' ~ toFix;
    return toFix;
}

private char[] checkCat(char[] first, char[] last) {
    return checkFirst(first) ~ checkLast(last);
}

private FtpFileInfo[] getEntries(FTPConnection ftp, char[] path = "") {
    FtpFileInfo[] orig = ftp.ls(path);
    FtpFileInfo[] temp2;
    FtpFileInfo[] use;
    FtpFileInfo[] temp;
    foreach(FtpFileInfo inf; orig) {
        if(inf.type == FtpFileType.dir) {
            temp ~= inf;
        }
    }
    foreach(FtpFileInfo inf; temp) {
        temp2 ~= getEntries((ftp.cd(inf.name) , ftp));
        //wasn't here at the beginning
        foreach(inf2; temp2) {
            inf2.name = checkCat(inf.name, inf2.name);
            use ~= inf2;
        }
        orig ~= use;
        //end wasn't here at the beginning
        ftp.cdup();
    }
    return orig;
}

private FtpFileInfo[] getFiles(FTPConnection ftp, char[] path = "") {
    FtpFileInfo[] infos = getEntries(ftp, path);
    FtpFileInfo[] return_;
    foreach(FtpFileInfo info; infos) {
        if(info.type == FtpFileType.file || info.type == FtpFileType.other || info.type == FtpFileType.unknown)
            return_ ~= info;
    }
    return return_;
}

private FtpFileInfo[] getFolders(FTPConnection ftp, char[] path = "") {
    FtpFileInfo[] infos = getEntries(ftp, path);
    FtpFileInfo[] return_;
    foreach(FtpFileInfo info; infos) {
        if(info.type == FtpFileType.dir || info.type == FtpFileType.cdir || info.type == FtpFileType.pdir)
            return_ ~= info;
    }
    return return_;
}

/******************************************************************************
    Defines a folder over FTP that has yet to be opened, may not exist, and
      may be created.
******************************************************************************/

class FtpFolderEntry: VfsFolderEntry {

    char[] toString_, name_, username_, password_;
    uint port_;

    public this(char[] server, char[] path, char[] username = "",
                char[] password = "", uint port = 21)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
    }

    /***********************************************************************
     Open a folder
     ***********************************************************************/

    final VfsFolder open() {
        return new FtpFolder(toString_, name_, username_, password_, port_);
    }

    /***********************************************************************
     Create a new folder
     ***********************************************************************/

    final VfsFolder create() {
        FTPConnection conn;

        scope(failure) {
            if(conn !is null)
                conn.close();
        }

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        conn = new FTPConnection(toString_, username_, password_, port_);
        conn.mkdir(name_);

        return new FtpFolder(toString_, name_, username_, password_, port_);
    }

    /***********************************************************************
     Test to see if a folder exists
     ***********************************************************************/

    final bool exists() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        bool return_;
        if(name_ == "") {
            try {
                conn = new FTPConnection(toString_, username_, password_, port_);
                return_ = true;
            } catch(Exception e) {
                return false;
            }
        } else {
            try {
                conn = new FTPConnection(toString_, username_, password_, port_);
                try {
                    conn.cd(name_);
                    return_ = true;
                } catch(Exception e) {
                    if(conn.exist(name_) == 2)
                        return_ = true;
                    else
                        return_ = false;
                }
            } catch(Exception e) {
                return_ = false;
            }
        }

        return return_;
    }
}

/******************************************************************************
     Represents a FTP Folder in full, allowing one to address
     specific folders of an FTP File system.
******************************************************************************/

class FtpFolder: VfsFolder {

    char[] toString_, name_, username_, password_;
    uint port_;

    public this(char[] server, char[] path, char[] username = "",
                char[] password = "", uint port = 21)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
    }

    /***********************************************************************
     Return a short name
     ***********************************************************************/

    final char[] name() {
        return fixName(name_);
    }

    /***********************************************************************
     Return a long name
     ***********************************************************************/

    final char[] toString() {
        return checkCat(toString_, name_);
    }

    /***********************************************************************
     Return a contained file representation
     ***********************************************************************/

    final VfsFile file(char[] path) {
        return new FtpFile(toString_, checkLast(checkCat(name_, path)), username_, password_,
            port_);
    }

    /***********************************************************************
     Return a contained folder representation
     ***********************************************************************/

    final VfsFolderEntry folder(char[] path) {
        return new FtpFolderEntry(toString_, checkLast(checkCat(name_, path)), username_,
            password_, port_);
    }

    /***********************************************************************
     Returns a folder set containing only this one. Statistics
     are inclusive of entries within this folder only
     ***********************************************************************/

    final VfsFolders self() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        return new FtpFolders(toString_, name_, username_, password_, port_,
            getFiles(conn), true);
    }

    /***********************************************************************
     Returns a subtree of folders. Statistics are inclusive of
     files within this folder and all others within the tree
     ***********************************************************************/

    final VfsFolders tree() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        return new FtpFolders(toString_, name_, username_, password_, port_,
            getEntries(conn), false);
    }

    /***********************************************************************
     Iterate over the set of immediate child folders. This is
     useful for reflecting the hierarchy
     ***********************************************************************/

    final int opApply(int delegate(ref VfsFolder) dg) {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        FtpFileInfo[] info = getFolders(conn);

        int result;

        foreach(FtpFileInfo fi; info) {
            VfsFolder x = new FtpFolder(toString_, checkLast(checkCat(name_, fi.name)), username_,
                password_, port_);
            if((result = dg(x)) != 0)
                break;
        }

        return result;
    }

    /***********************************************************************
     Clear all content from this folder and subordinates
     ***********************************************************************/

    final VfsFolder clear() {
        FTPConnection conn;

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        conn = new FTPConnection(connect, username_, password_, port_);

        conn.cd(name_);

        FtpFileInfo[] reverse(FtpFileInfo[] infos) {
            FtpFileInfo[] reversed;
            for(int i = infos.length - 1; i >= 0; i--) {
                reversed ~= infos[i];
            }
            return reversed;
        }

        foreach(VfsFolder f; tree.subset(null))
        conn.rm(f.name);

        foreach(FtpFileInfo entries; getEntries(conn))
        conn.del(entries.name);

        //foreach(VfsFolder f; tree.subset(null))
        //    conn.rm(f.name);

        return this;
    }

    /***********************************************************************
     Is folder writable?
     ***********************************************************************/

    final bool writable() {
        try {
            FTPConnection conn;

            scope(failure) {
                if(conn !is null)
                    conn.close();
            }

            scope(exit) {
                if(conn !is null)
                    conn.close();
            }

            char[] connect = toString_;

            if(connect[$ - 1] == '/') {
                connect = connect[0 .. ($ - 1)];
            }

            conn = new FTPConnection(connect, username_, password_, port_);

            if(name_ != "")
                conn.cd(name_);

            conn.mkdir("ABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890");
            conn.rm("ABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890");
            return true;

        } catch(Exception e) {
            return false;
        }
    }

    /***********************************************************************
     Close and/or synchronize changes made to this folder. Each
     driver should take advantage of this as appropriate, perhaps
     combining multiple files together, or possibly copying to a
     remote location
     ***********************************************************************/

    VfsFolder close(bool commit = true) {
        return this;
    }

    /***********************************************************************
     A folder is being added or removed from the hierarchy. Use
     this to test for validity (or whatever) and throw exceptions
     as necessary
     ***********************************************************************/

    void verify(VfsFolder folder, bool mounting) {
        return;
    }
}

/******************************************************************************
     A set of folders within an FTP file system as was selected by the
     Adapter or as was selected at initialization.
******************************************************************************/

class FtpFolders: VfsFolders {

    char[] toString_, name_, username_, password_;
    uint port_;
    bool flat_;
    FtpFileInfo[] infos_;

    package this(char[] server, char[] path, char[] username = "",
                 char[] password = "", uint port = 21, FtpFileInfo[] infos = null,
                 bool flat = false)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
        infos_ = infos;
        flat_ = flat;
    }

    public this(char[] server, char[] path, char[] username = "",
                char[] password = "", uint port = 21, bool flat = false)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
        flat_ = flat;

        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        if(!flat_)
            infos_ = getEntries(conn);
        else
            infos_ = getFiles(conn);
    }

    /***********************************************************************
     Iterate over the set of contained VfsFolder instances
     ***********************************************************************/

    final int opApply(int delegate(ref VfsFolder) dg) {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        FtpFileInfo[] info = getFolders(conn);

        int result;

        foreach(FtpFileInfo fi; info) {
            VfsFolder x = new FtpFolder(toString_, checkLast(checkCat(name_, fi.name)),
                username_, password_, port_);
    
            // was
            // VfsFolder x = new FtpFolder(toString_ ~ "/" ~ name_, fi.name,
            // username_, password_, port_);
            if((result = dg(x)) != 0)
                break;
        }

        return result;
    }

    /***********************************************************************
     Return the number of files
     ***********************************************************************/

    final uint files() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        return getFiles(conn).length;
    }

    /***********************************************************************
     Return the number of folders
     ***********************************************************************/

    final uint folders() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        return getFolders(conn).length;
    }

    /***********************************************************************
     Return the total number of entries (files + folders)
     ***********************************************************************/

    final uint entries() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        return getEntries(conn).length;
    }

    /***********************************************************************
     Return the total size of contained files
     ***********************************************************************/

    final ulong bytes() {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        ulong return_;

        foreach(FtpFileInfo inf; getEntries(conn)) {
            return_ += inf.size;
        }

        return return_;
    }

    /***********************************************************************
     Return a subset of folders matching the given pattern
     ***********************************************************************/

    final VfsFolders subset(char[] pattern) {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        FtpFileInfo[] return__;

        if(pattern !is null)
            foreach(FtpFileInfo inf; getFolders(conn)) {
            if(containsPattern(inf.name, pattern))
                return__ ~= inf;
        }
        else
            return__ = getFolders(conn);

        return new FtpFolders(toString_, name_, username_, password_, port_,
            return__);
    }

    /***********************************************************************
     Return a set of files matching the given pattern
     ***********************************************************************/

    final VfsFiles catalog(char[] pattern) {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        FtpFileInfo[] return__;

        if(pattern !is null) {
            foreach(FtpFileInfo inf; getFiles(conn)) {
                if(containsPattern(inf.name, pattern)) {
                    return__ ~= inf;
                }
            }
        } else {
            return__ = getFiles(conn);
        }

        return new FtpFiles(toString_, name_, username_, password_, port_,
            return__);
    }

    /***********************************************************************
     Return a set of files matching the given filter
     ***********************************************************************/

    final VfsFiles catalog(VfsFilter filter = null) {
        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        FtpFileInfo[] return__;

        if(filter !is null)
            foreach(FtpFileInfo inf; getFiles(conn)) {
            VfsFilterInfo vinf;
            vinf.bytes = inf.size;
            vinf.name = inf.name;
            vinf.folder = false;
            vinf.path = checkCat(checkFirst(toString_), checkCat(name_ ,inf.name));
            if(filter(&vinf))
                return__ ~= inf;
        }
        else
            return__ = getFiles(conn);

        return new FtpFiles(toString_, name_, username_, password_, port_,
            return__);
    }
}

/*******************************************************************************
     Represents a file over a FTP file system.
*******************************************************************************/

class FtpFile: VfsFile {

    char[] toString_, name_, username_, password_;
    uint port_;
    bool conOpen;
    FTPConnection conn;

    public this(char[] server, char[] path, char[] username = "",
                char[] password = "", uint port = 21)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
    }

    /***********************************************************************
     Return a short name
     ***********************************************************************/

    final char[] name() {
        return fixName(name_);
    }

    /***********************************************************************
     Return a long name
     ***********************************************************************/

    final char[] toString() {
        return checkCat(toString_, name_);
    }

    /***********************************************************************
     Does this file exist?
     ***********************************************************************/

    final bool exists() {
        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        bool return_;

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        if(conn.exist(name_) == 1) {
            return_ = true;
        } else {
            return_ = false;
        }

        return return_;
    }

    /***********************************************************************
     Return the file size
     ***********************************************************************/

    final ulong size() {
        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        return conn.size(name_);
    }

    /***********************************************************************
     Create and copy the given source
     ***********************************************************************/

    final VfsFile copy(VfsFile source) {
        output.copy(source.input);
        return this;
    }

    /***********************************************************************
     Create and copy the given source, and remove the source
     ***********************************************************************/

    final VfsFile move(VfsFile source) {
        copy(source);
        source.remove;
        return this;
    }

    /***********************************************************************
     Create a new file instance
     ***********************************************************************/

    final VfsFile create() {
        char[1] a = "0";
        output.write(a);
        return this;
    }

    /***********************************************************************
     Create a new file instance and populate with stream
     ***********************************************************************/

    final VfsFile create(InputStream stream) {
        output.copy(stream);
        return this;
    }

    /***********************************************************************
     Remove this file
     ***********************************************************************/

    final VfsFile remove() {

        conn.close();

        conOpen = false;

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        conn.del(name_);

        return this;
    }

    /***********************************************************************
     Return the input stream. Don't forget to close it
     ***********************************************************************/

    final InputStream input() {

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        conOpen = true;

        return conn.input(name_);
    }

    /***********************************************************************
     Return the output stream. Don't forget to close it
     ***********************************************************************/

    final OutputStream output() {

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        conOpen = true;

        return conn.output(name_);
    }

    /***********************************************************************
     Duplicate this entry
     ***********************************************************************/

    final VfsFile dup() {
        return new FtpFile(toString_, name_, username_, password_, port_);
    }

    /***********************************************************************
     Time modified
     ***********************************************************************/

    final Time mtime() {
        conn.close();

        conOpen = false;

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        return conn.getFileInfo(name_).modify;
    }

    /***********************************************************************
     Time created
     ***********************************************************************/

    final Time ctime() {
        conn.close();

        conOpen = false;

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        return conn.getFileInfo(name_).create;
    }

    final Time atime() {
        conn.close();

        conOpen = false;

        scope(failure) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        scope(exit) {
            if(!conOpen)
                if(conn !is null)
                    conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        if(!conOpen) {
            conn = new FTPConnection(connect, username_, password_, port_);
        }

        return conn.getFileInfo(name_).modify;
    }
        
        /***********************************************************************

                Modified time of the file

        ***********************************************************************/

        final Time modified ()
        {
                return mtime ();
        }
}

/******************************************************************************
  Represents a selection of Files.
******************************************************************************/

class FtpFiles: VfsFiles {

    char[] toString_, name_, username_, password_;
    uint port_;
    FtpFileInfo[] infos_;

    public this(char[] server, char[] path, char[] username = "",
                char[] password = "", uint port = 21, FtpFileInfo[] infos = null)
    in {
        assert(server.length > 0);
    }
    body {
        toString_ = checkFirst(server);
        name_ = checkLast(path);
        username_ = username;
        password_ = password;
        port_ = port;
        if(infos !is null)
            infos_ = infos;
        else
            fillInfos();
    }

    final void fillInfos() {

        FTPConnection conn;

    

        scope(exit) {
            if(conn !is null)
                conn.close();
        }

        char[] connect = toString_;

        if(connect[$ - 1] == '/') {
            connect = connect[0 .. ($ - 1)];
        }

        conn = new FTPConnection(connect, username_, password_, port_);

        if(name_ != "")
            conn.cd(name_);

        infos_ = getFiles(conn);
    }

    /***********************************************************************
     Iterate over the set of contained VfsFile instances
     ***********************************************************************/

    final int opApply(int delegate(ref VfsFile) dg) {
        int result = 0;

        foreach(FtpFileInfo inf; infos_) {
            VfsFile x = new FtpFile(toString_, checkLast(checkCat(name_, inf.name)),
                username_, password_, port_);
            if((result = dg(x)) != 0)
                break;
        }

        return result;
    }

    /***********************************************************************
     Return the total number of entries
     ***********************************************************************/

    final uint files() {
        return infos_.length;
    }

    /***********************************************************************
     Return the total size of all files
     ***********************************************************************/

    final ulong bytes() {
        ulong return_;

        foreach(FtpFileInfo inf; infos_) {
            return_ += inf.size;
        }

        return return_;
    }
}