sprint/io/network/ftp.h

Go to the documentation of this file.

/******************************************************************************
*   sprint::xftp
*
*   Copyright (C) 2005-2011  Paolo Medici <www.pmx.it>
*
*  This library is free software; you can redistribute it and/or
*  modify it under the terms of the GNU Lesser General Public
*  License as published by the Free Software Foundation; either
*  version 2.1 of the License, or (at your option) any later version.
*
*  This library is distributed in the hope that it will be useful,
*  but WITHOUT ANY WARRANTY; without even the implied warranty of
*  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
*  Lesser General Public License for more details.
*
*  You should have received a copy of the GNU Lesser General Public
*  License along with this library; if not, write to the Free Software
*  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
*
*******************************************************************************/

#ifndef _SPRINT_FTP_H
#define _SPRINT_FTP_H

#include <sprint/io/network/socket.h>
#include <sprint/io/network/async_socket.h>

namespace sprint {

#define HR_OK                           0
#define HR_INVALID_ADDRESS      1
#define HR_CANNOT_CONNECT       2
#define HR_RESPONSE_TIMEOUT     3
#define HR_CANCELLED            4
#define HR_CANNOT_CREATE        5


#define DEFAULT_FTP_PORT        21

enum FtpResponseCode {
FTP_RESPONSE_RESTATRT_MARKER_REPLY = 110,
FTP_RESPONSE_SERVICE_READY_IN_MINUTES = 120,
FTP_RESPONSE_DATA_CONNECTION_ALREADY_OPEN = 125,
FTP_RESPONSE_FILE_STATUS_OK = 150,
FTP_RESPONSE_COMMAND_OK = 200,
FTP_RESPONSE_COMMAND_NOT_IMPLEMENTED_SUPERFLUOUS_AT_THIS_SITE = 202,
FTP_RESPONSE_SYSTEM_STATUS_OR_SYSTEM_HELP_REPLY = 211,
FTP_RESPONSE_DIRECTORY_STATUS = 212,
FTP_RESPONSE_FILE_STATUS = 213,
FTP_RESPONSE_HELP_MESSAGE = 214,
FTP_RESPONSE_NAME_SYSTEM_TYPE = 215,
FTP_RESPONSE_SERVICE_READY_FOR_NEW_USER = 220,
FTP_RESPONSE_SERVICE_CLOSING_CONTROL_CONNECTION = 221,
FTP_RESPONSE_DATA_CONNECTION_OPEN = 225,
FTP_RESPONSE_CLOSING_DATA_CONNECTION = 226,
FTP_RESPONSE_ENTERING_PASSIVE_MODE = 227,
FTP_RESPONSE_USER_LOGGED_IN = 230,
FTP_RESPONSE_REQUESTED_FILE_ACTION_OK_COMPLETED = 250,
FTP_RESPONSE_PATHNAME_CREATED = 257,
FTP_RESPONSE_USER_NAME_OK_NEED_PASSWORD = 331,
FTP_RESPONSE_NEED_ACCOUNT_FOR_LOGIN = 332,
FTP_RESPONSE_REQUESTED_FILE_ACTION_PENDING_FURTHER_INFO = 350,
FTP_RESPONSE_SERVICE_NOT_AVAILABLE_CLOSING_CONTROL_CONNECTION = 421,
FTP_RESPONSE_CANNOT_OPEN_DATA_CONNECTION = 425,
FTP_RESPONSE_CONNECTION_CLOSED_TRANSFER_ABORTED = 426,
FTP_RESPONSE_REQUESTED_FILE_ACTION_NOT_TAKEN = 450,
FTP_RESPONSE_REQUESTED_ACTION_ABORTED = 451,
FTP_RESPONSE_REQUESTED_ACTION_NOT_TAKEN = 452,
FTP_RESPONSE_SYNTAX_ERROR_COMMAND_UNRECOGNIZED = 500,
FTP_RESPONSE_SYNTAX_ERROR_IN_PARAMETERS_OR_ARGUMENTS = 501,
FTP_RESPONSE_COMMAND_NOT_IMPLEMENTED = 502,
FTP_RESPONSE_BAD_SEQUENCE_OF_COMMANDS = 503,
FTP_RESPONSE_COMMAND_NOT_IMPLEMENTED_FOR_THAT_PARAMETER = 504,
FTP_RESPONSE_NOT_LOGGED_IN = 530,
FTP_RESPONSE_NEED_ACCOUNT_FOR_STORING_FILES = 532,
FTP_RESPONSE_REQUESTED_ACTION_NOT_TAKEN_FILE_UNAVAILABLE = 550,
FTP_RESPONSE_REQUESTED_ACTION_ABORTED_PAGE_TYPE_UNKNOWN = 551,
FTP_RESPONSE_REQUESTED_FILE_ACTION_ABORTED_EXCEEDED_STORAGE_ALLOCATION = 552,
FTP_RESPONSE_REQUESTED_ACTION_NOT_TAKEN_FILE_NAME_NOT_ALLOWED = 553,
};

enum FtpStatus{
  FTP_DISCONNECTED,
  FTP_USER_LOGGED,
  FTP_CONNECTION_AUTHENTICATION,
  FTP_CONNECTION_CONNECTED
};

enum FtpTransferMode {
  FTP_ASCII_MODE,
  FTP_BINARY_MODE
};

typedef BOOL (* ENUMFILESCALLBACK) (LPVOID lpContext);

  class ftp {
    FtpStatus m_status;
    bool m_passive_mode;
    
    async_socket<socket> m_s;    /* FTP */
    socket m_port; /* PORT */
    socket m_file; /* Tranfer File Socket */

        UINT uLastFtpResp;
        char ftpresp[512];

        bool _ftp;
        bool _file;

        DWORD dwFileSize;
    
    private:
      const char *ResponseToString(int hr);
      unsigned int GetResponseIdSync(unsigned int uTimeOut, bool bIgnoreComment);
      bool Init();
      int Disconnect();
      char *GetResponse();
      unsigned int GetResponseId();
      int _setup_transfer();
      int _begin_transfer();
      int _end_transfer();
      int Pasv();
      int WaitForIncomingConnection();
      int ConnectToServer();
      int Port();
    public:
      ftp();
      ~ftp();
      
      int set_passive_mode(bool bPassiveMode);
      int connect(const char * lpszServer, unsigned int nServerPort, const char * lpszUserName, const char * lpszPassword);
      int rename(const char * lpszFrom, const char * lpszTo);
      int rename_to(const char * lpszTo);
      int rename_from(const char * lpszFrom);
      int delete_file(const char * lpszFileName);
      int remove_directory(const char * lpszDirectory);
      int create_directory(const char * lpszDirectory);
      int set_current_directory(const char * lpszCurrentDirectory);
      int get_current_directory(LPSTR lpszCurrentDirectory, unsigned int dwBufSize);
      
      int ftp_command(const char * lpszCommand);

      int get_file(const char * lpszRemoteFile, const char * lpszNewFile);
      int write_file(const char *lpBuffer, unsigned int dwBytesToWrite, unsigned int *lpdwBytesWrited);
      int read_file(char *lpBuffer, unsigned int dwBytesToRead, unsigned int *lpdwBytesReaded);
      int close_file();
      
  };
}

#endif