FTPLibFTPTransport Class Reference

#include <ftplibftpt.h>

Inheritance diagram for FTPLibFTPTransport:

Collaboration diagram for FTPLibFTPTransport:

Public Member Functions
int	copyDirectory (const char *urlPrefix, const char *dir, const char *dest, const char *suffix)
	FTPLibFTPTransport (const char *host, StatusReporter *statusReporter=0)
virtual std::vector< struct DirEntry >	getDirList (const char *dirURL)
long	getTimeoutMillis ()
char	getURL (const char *destPath, const char *sourceURL, SWBuf *destBuf=0)
bool	isPassive ()
bool	isUnverifiedPeerAllowed ()
virtual char	putURL (const char *destURL, const char *sourcePath, SWBuf *sourceBuf=0)
void	setPassive (bool passive)
void	setPasswd (const char *passwd)
void	setTimeoutMillis (long timeoutMillis)
void	setUnverifiedPeerAllowed (bool val)
void	setUser (const char *user)
void	terminate ()
	~FTPLibFTPTransport ()

Protected Attributes
SWBuf	host
SWBuf	p
bool	passive
StatusReporter *	statusReporter
bool	term
long	timeoutMillis
SWBuf	u
bool	unverifiedPeerAllowed

Private Member Functions
char	assureLoggedIn ()

Private Attributes
netbuf *	ftpConnection

Detailed Description

Definition at line 34 of file ftplibftpt.h.

Constructor & Destructor Documentation

FTPLibFTPTransport::FTPLibFTPTransport	(	const char *	host,
		StatusReporter *	statusReporter = 0
	)

Definition at line 94 of file ftplibftpt.cpp.

                                                                           : RemoteTransport(host, sr) {

    ftpConnection = 0;
}

FTPLibFTPTransport::~FTPLibFTPTransport

(

)

Definition at line 100 of file ftplibftpt.cpp.

                                        {
    if (ftpConnection)
        FtpQuit(ftpConnection);
}

Member Function Documentation

char FTPLibFTPTransport::assureLoggedIn ( )

private

Definition at line 106 of file ftplibftpt.cpp.

                                        {
    char retVal = 0;
    if (ftpConnection == 0) {
SWLOGD("connecting to host: %s...\n", host.c_str());
        if (FtpConnect(host, &ftpConnection)) {
            FtpOptions(FTPLIB_CONNMODE, (passive) ? FTPLIB_PASSIVE : FTPLIB_PORT, ftpConnection);
            FtpOptions(FTPLIB_IDLETIME, timeoutMillis, ftpConnection);

SWLOGD("connected. logging in...\n");
            if (FtpLogin(u.c_str(), p.c_str(), ftpConnection)) {
SWLOGD("logged in.\n");
                retVal = 0;
            }
            else {
                SWLog::getSystemLog()->logError("Failed to login to %s\n", host.c_str());
                retVal = -2;
            }
        }
        else {
            SWLog::getSystemLog()->logError("Failed to connect to %s\n", host.c_str());
            retVal = -2;
        }
    }
    return retVal;
}

int RemoteTransport::copyDirectory ( const char *  urlPrefix, const char *  dir, const char *  dest, const char *  suffix  )

inherited

network copy recursively a remote directly

Returns

error status 0: OK; -1: operation error, -2: connection error; -3: user requested termination

Definition at line 140 of file remotetrans.cpp.

                                                                                                               {
SWLOGD("RemoteTransport::copyDirectory");
    int retVal = 0;

    SWBuf url = SWBuf(urlPrefix) + SWBuf(dir);
    removeTrailingSlash(url);
    url += '/';
    
SWLOGD("NetTransport: getting dir %s\n", url.c_str());
    vector<struct DirEntry> dirList = getDirList(url.c_str());

    if (!dirList.size()) {
        SWLog::getSystemLog()->logWarning("NetTransport: failed to read dir %s\n", url.c_str());
        return -1;
    }

    // append files in sub directories and calculate total download size
    unsigned int i = 0;
    long totalBytes = 0;
    for (;;) {
        if (i == dirList.size())
            break;

        struct DirEntry &e = dirList.at(i);

        if (e.isDirectory) {
            SWBuf name(e.name); // &e will be invalidated after first insertion
            vector<struct DirEntry> sd = getDirList((url + name + '/').c_str());
            for (unsigned int ii = 0; ii < sd.size(); ii++) {
                sd[ii].name = name + '/' + sd[ii].name;
                dirList.push_back(sd[ii]);
            }
            dirList.erase(dirList.begin() + i);
        }
        else {
            totalBytes += e.size;
            i++;
        }
    }

    long completedBytes = 0;
    for (i = 0; i < dirList.size(); i++) {
        struct DirEntry &dirEntry = dirList[i];
        SWBuf buffer = (SWBuf)dest;
        removeTrailingSlash(buffer);
        buffer += "/";
        buffer += dirEntry.name;
        if (!strcmp(&buffer.c_str()[buffer.length()-strlen(suffix)], suffix)) {
            SWBuf buffer2 = "Downloading (";
            buffer2.appendFormatted("%d", i+1);
            buffer2 += " of ";
            buffer2.appendFormatted("%d", dirList.size());
            buffer2 += "): ";
            buffer2 += dirEntry.name;
            if (statusReporter)
                statusReporter->preStatus(totalBytes, completedBytes, buffer2.c_str());
            FileMgr::createParent(buffer.c_str());  // make sure parent directory exists
            SWTRY {
                SWBuf url = (SWBuf)urlPrefix + (SWBuf)dir;
                removeTrailingSlash(url);
                url += "/";
                url += dirEntry.name;
                retVal = getURL(buffer.c_str(), url.c_str());
                if (retVal) {
                    SWLog::getSystemLog()->logWarning("copyDirectory: failed to get file %s\n", url.c_str());
                    return retVal;
                }
                completedBytes += dirEntry.size;
            }
            SWCATCH (...) {}
            if (term) {
                retVal = -3;
                break;
            }
        }
    }
    return retVal;
}

vector< struct DirEntry > RemoteTransport::getDirList ( const char *  dirURL )

virtualinherited

Reimplemented in CURLHTTPTransport.

Definition at line 92 of file remotetrans.cpp.

                                                                      {

SWLOGD("RemoteTransport::getDirList(%s)", dirURL);
    vector<struct DirEntry> dirList;
    
    SWBuf dirBuf;
    if (!getURL("", dirURL, &dirBuf)) {
        char *start = dirBuf.getRawData();
        char *end = start;
        while (start < (dirBuf.getRawData()+dirBuf.size())) {
            struct ftpparse item;
            bool looking = true;
            for (end = start; *end; end++) {
                if (looking) {
                    if ((*end == 10) || (*end == 13)) {
                        *end = 0;
                        looking = false;
                    }
                }
                else if ((*end != 10) && (*end != 13))
                    break;
            }
SWLOGD("getDirList: parsing item %s(%d)\n", start, end-start);
            int status = ftpparse(&item, start, (int)(end - start));
            // in ftpparse.h, there is a warning that name is not necessarily null terminated
            SWBuf name;
            name.append(item.name, item.namelen);
SWLOGD("getDirList: got item %s\n", name.c_str());
            if (status && name != "." && name != "..") {
                struct DirEntry i;
                i.name = name;
                i.size = item.size;
                i.isDirectory = (item.flagtrycwd == 1);
                dirList.push_back(i);
            }
            start = end;
        }
    }
    else {
        SWLog::getSystemLog()->logWarning("getDirList: failed to get dir %s\n", dirURL);
    }
    return dirList;
}

long RemoteTransport::getTimeoutMillis ( )

inlineinherited

Definition at line 94 of file remotetrans.h.

{ return timeoutMillis; }

char FTPLibFTPTransport::getURL ( const char *  destPath, const char *  sourceURL, SWBuf *  destBuf = 0  )

virtual

Reimplemented from RemoteTransport.

Definition at line 133 of file ftplibftpt.cpp.

                                                                                           {

    char retVal = 0;

SWLOGD("FTPLibFTPTransport::getURL(%s, %s, ...);\n", (destPath)?destPath:"(null)", sourceURL);
    // assert we can login
    retVal = assureLoggedIn();
    if (retVal) return retVal;
SWLOGD("FTPLibFTPTransport - logged in.\n");

    SWBuf sourcePath = sourceURL;

    SWBuf outFile;
    if (!destBuf) {
        outFile = destPath;
    }

    sourcePath << (6 + host.length()); // shift << "ftp://hostname";
SWLOGD("getting file %s to %s\n", sourcePath.c_str(), destBuf ? "*internal buffer*" : outFile.c_str());
    struct MyProgressData pd;
    pd.sr = statusReporter;
    pd.term = &term;
    pd.totalSize = 0;
    int fd = 0;
    if (destBuf) {
        FtpOptions(FTPLIB_CALLBACK_WRITER, (long)&my_swbufwriter, ftpConnection);
        FtpOptions(FTPLIB_CALLBACK_WRITERARG, (long)destBuf, ftpConnection);
    }
    else {
        fd = FileMgr::createPathAndFile(outFile);
        FtpOptions(FTPLIB_CALLBACK_WRITER, (long)&my_filewriter, ftpConnection);
        FtpOptions(FTPLIB_CALLBACK_WRITERARG, (long)&fd, ftpConnection);
    }

    FtpOptions(FTPLIB_CALLBACK, (long)&my_fprogress, ftpConnection);
    FtpOptions(FTPLIB_CALLBACKARG, (long)&pd, ftpConnection);
    FtpOptions(FTPLIB_CALLBACKBYTES, (long)2048, ftpConnection);

    if (sourcePath.endsWith("/") || sourcePath.endsWith("\\")) {
//SWLOGD("getting test directory %s\n", sourcePath.c_str());
//      FtpDir(NULL, sourcePath, ftpConnection);
SWLOGD("getting real directory %s\n", sourcePath.c_str());
        retVal = FtpDir(0, sourcePath, ftpConnection) - 1;
SWLOGD("got real directory %s to %s\n", sourcePath.c_str(), destBuf ? "*internal buffer*" : outFile.c_str());
    }
    else {
SWLOGD("getting file %s\n", sourcePath.c_str());
        int size;
        FtpSize(sourcePath, &size, FTPLIB_IMAGE, ftpConnection);
        pd.totalSize = size;
        retVal = FtpGet(0, sourcePath, FTPLIB_IMAGE, ftpConnection) - 1;
    }
    if (fd > 0) FileMgr::closeFile(fd);
SWLOGD("FTPLibFTPTransport - returning: %d\n", retVal);
    return retVal;
}

bool RemoteTransport::isPassive ( )

inlineinherited

Definition at line 95 of file remotetrans.h.

{ return passive; }

bool RemoteTransport::isUnverifiedPeerAllowed ( )

inlineinherited

Definition at line 99 of file remotetrans.h.

{ return unverifiedPeerAllowed; }

char RemoteTransport::putURL ( const char *  destURL, const char *  sourcePath, SWBuf *  sourceBuf = 0  )

virtualinherited

Reimplemented in RTransportGDrive.

Definition at line 85 of file remotetrans.cpp.

                                                                                          {
    SWLog::getSystemLog()->logWarning("RemoteTransport::putURL called but unsupported");
    char retVal = -1;
    return retVal;
}

void RemoteTransport::setPassive ( bool  passive )

inlineinherited

Definition at line 92 of file remotetrans.h.

{ this->passive = passive; }

void RemoteTransport::setPasswd ( const char *  passwd )

inlineinherited

Definition at line 97 of file remotetrans.h.

{ p = passwd; }

void RemoteTransport::setTimeoutMillis ( long  timeoutMillis )

inlineinherited

Definition at line 93 of file remotetrans.h.

{ this->timeoutMillis = timeoutMillis; }

void RemoteTransport::setUnverifiedPeerAllowed ( bool  val )

inlineinherited

Definition at line 98 of file remotetrans.h.

{ this->unverifiedPeerAllowed = val; }

void RemoteTransport::setUser ( const char *  user )

inlineinherited

Definition at line 96 of file remotetrans.h.

{ u = user; }

void RemoteTransport::terminate ( )

inlineinherited

Definition at line 100 of file remotetrans.h.

{ term = true; }

Member Data Documentation

netbuf* FTPLibFTPTransport::ftpConnection

private

Definition at line 35 of file ftplibftpt.h.

SWBuf RemoteTransport::host

protectedinherited

Definition at line 64 of file remotetrans.h.

SWBuf RemoteTransport::p

protectedinherited

Definition at line 66 of file remotetrans.h.

bool RemoteTransport::passive

protectedinherited

Definition at line 60 of file remotetrans.h.

StatusReporter* RemoteTransport::statusReporter

protectedinherited

Definition at line 59 of file remotetrans.h.

bool RemoteTransport::term

protectedinherited

Definition at line 62 of file remotetrans.h.

long RemoteTransport::timeoutMillis

protectedinherited

Definition at line 61 of file remotetrans.h.

SWBuf RemoteTransport::u

protectedinherited

Definition at line 65 of file remotetrans.h.

bool RemoteTransport::unverifiedPeerAllowed

protectedinherited

Definition at line 63 of file remotetrans.h.

---

The documentation for this class was generated from the following files:

• include/ftplibftpt.h
• src/mgr/ftplibftpt.cpp