12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232 |
|
/*******************************************************************************
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 Time = tango.time.Time;
}
private const(char)[] fixName(const(char)[] toFix) {
if (containsPattern(toFix, "/"))
toFix = toFix[(locatePrior(toFix, '/') + 1) .. $];
return toFix;
}
private const(char)[] checkFirst(const(char)[] toFix) {
for(; toFix.length>0 && toFix[$-1] == '/';)
toFix = toFix[0 .. ($-1)];
return toFix;
}
private const(char)[] checkLast(const(char)[] toFix) {
for(;toFix.length>1 && toFix[0] == '/' && toFix[1] == '/' ;)
toFix = toFix[1 .. $];
if(toFix.length && toFix[0] != '/')
toFix = '/' ~ toFix;
return toFix;
}
private const(char)[] checkCat(const(char)[] first, const(char)[] last) {
return checkFirst(first) ~ checkLast(last);
}
private FtpFileInfo[] getEntries(FTPConnection ftp, const(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, const(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, const(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 {
const(char)[] toString_, name_, username_, password_;
uint port_;
public this(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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
***********************************************************************/
@property 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 {
const(char)[] toString_, name_, username_, password_;
uint port_;
public this(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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
***********************************************************************/
@property final const(char)[] name() {
return fixName(name_);
}
/***********************************************************************
Return a long name
***********************************************************************/
override final string toString() {
return checkCat(toString_, name_).idup;
}
/***********************************************************************
Return a contained file representation
***********************************************************************/
@property final VfsFile file(const(char)[] path) {
return new FtpFile(toString_, checkLast(checkCat(name_, path)), username_, password_,
port_);
}
/***********************************************************************
Return a contained folder representation
***********************************************************************/
@property final VfsFolderEntry folder(const(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
***********************************************************************/
@property final VfsFolders self() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final VfsFolders tree() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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(scope int delegate(ref VfsFolder) dg) {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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();
}
const(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(sizediff_t 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?
***********************************************************************/
@property final bool writable() {
try {
FTPConnection conn;
scope(failure) {
if(conn !is null)
conn.close();
}
scope(exit) {
if(conn !is null)
conn.close();
}
const(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 {
const(char)[] toString_, name_, username_, password_;
uint port_;
bool flat_;
FtpFileInfo[] infos_;
package this(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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();
}
const(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(scope int delegate(ref VfsFolder) dg) {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final size_t files() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final size_t folders() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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)
***********************************************************************/
@property final size_t entries() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final ulong bytes() {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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(const(char)[] pattern) {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final VfsFiles catalog(const(char)[] pattern) {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final VfsFiles catalog(VfsFilter filter = null) {
FTPConnection conn;
scope(exit) {
if(conn !is null)
conn.close();
}
const(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 {
const(char)[] toString_, name_, username_, password_;
uint port_;
bool conOpen;
FTPConnection conn;
public this(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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
***********************************************************************/
@property final const(char)[] name() {
return fixName(name_);
}
/***********************************************************************
Return a long name
***********************************************************************/
override final string toString() {
return checkCat(toString_, name_).idup;
}
/***********************************************************************
Does this file exist?
***********************************************************************/
@property 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_;
const(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
***********************************************************************/
@property final ulong size() {
scope(failure) {
if(!conOpen)
if(conn !is null)
conn.close();
}
scope(exit) {
if(!conOpen)
if(conn !is null)
conn.close();
}
const(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();
}
const(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
***********************************************************************/
@property final InputStream input() {
scope(failure) {
if(!conOpen)
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final OutputStream output() {
scope(failure) {
if(!conOpen)
if(conn !is null)
conn.close();
}
const(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
***********************************************************************/
@property final VfsFile dup() {
return new FtpFile(toString_, name_, username_, password_, port_);
}
/***********************************************************************
Time modified
***********************************************************************/
@property final Time.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();
}
const(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
***********************************************************************/
@property final Time.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();
}
const(char)[] connect = toString_;
if(connect[$ - 1] == '/') {
connect = connect[0 .. ($ - 1)];
}
if(!conOpen) {
conn = new FTPConnection(connect, username_, password_, port_);
}
return conn.getFileInfo(name_).create;
}
@property final Time.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();
}
const(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
***********************************************************************/
@property final Time.Time modified ()
{
return mtime ();
}
}
/******************************************************************************
Represents a selection of Files.
******************************************************************************/
class FtpFiles: VfsFiles {
const(char)[] toString_, name_, username_, password_;
uint port_;
FtpFileInfo[] infos_;
public this(const(char)[] server, const(char)[] path, const(char)[] username = "",
const(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();
}
const(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(scope 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
***********************************************************************/
@property final size_t files() {
return infos_.length;
}
/***********************************************************************
Return the total size of all files
***********************************************************************/
@property final ulong bytes() {
ulong return_;
foreach(FtpFileInfo inf; infos_) {
return_ += inf.size;
}
return return_;
}
}
|