ftp_server.h

Go to the documentation of this file.

 
#ifndef _FTP_SERVER_H
#define _FTP_SERVER_H
 
//Dependencies
#include "core/net.h"
#include "core/socket.h"
#include "fs_port.h"
 
//FTP server support
#ifndef FTP_SERVER_SUPPORT
   #define FTP_SERVER_SUPPORT ENABLED
#elif (FTP_SERVER_SUPPORT != ENABLED && FTP_SERVER_SUPPORT != DISABLED)
   #error FTP_SERVER_SUPPORT parameter is not valid
#endif
 
//FTP over TLS
#ifndef FTP_SERVER_TLS_SUPPORT
   #define FTP_SERVER_TLS_SUPPORT DISABLED
#elif (FTP_SERVER_TLS_SUPPORT != ENABLED && FTP_SERVER_TLS_SUPPORT != DISABLED)
   #error FTP_SERVER_TLS_SUPPORT parameter is not valid
#endif
 
//Stack size required to run the FTP server
#ifndef FTP_SERVER_STACK_SIZE
   #define FTP_SERVER_STACK_SIZE 650
#elif (FTP_SERVER_STACK_SIZE < 1)
   #error FTP_SERVER_STACK_SIZE parameter is not valid
#endif
 
//Priority at which the FTP server should run
#ifndef FTP_SERVER_PRIORITY
   #define FTP_SERVER_PRIORITY OS_TASK_PRIORITY_NORMAL
#endif
 
//Maximum number of simultaneous connections
#ifndef FTP_SERVER_MAX_CONNECTIONS
   #define FTP_SERVER_MAX_CONNECTIONS 10
#elif (FTP_SERVER_MAX_CONNECTIONS < 1)
   #error FTP_SERVER_MAX_CONNECTIONS parameter is not valid
#endif
 
//Maximum time the server will wait before closing the connection
#ifndef FTP_SERVER_TIMEOUT
   #define FTP_SERVER_TIMEOUT 60000
#elif (FTP_SERVER_TIMEOUT < 1000)
   #error FTP_SERVER_TIMEOUT parameter is not valid
#endif
 
//FTP server tick interval
#ifndef FTP_SERVER_TICK_INTERVAL
   #define FTP_SERVER_TICK_INTERVAL 1000
#elif (FTP_SERVER_TICK_INTERVAL < 100)
   #error FTP_SERVER_TICK_INTERVAL parameter is not valid
#endif
 
//Maximum length of the pending connection queue
#ifndef FTP_SERVER_BACKLOG
   #define FTP_SERVER_BACKLOG 4
#elif (FTP_SERVER_BACKLOG < 1)
   #error FTP_SERVER_BACKLOG parameter is not valid
#endif
 
//Maximum line length
#ifndef FTP_SERVER_MAX_LINE_LEN
   #define FTP_SERVER_MAX_LINE_LEN 255
#elif (FTP_SERVER_MAX_LINE_LEN < 64)
   #error FTP_SERVER_MAX_LINE_LEN parameter is not valid
#endif
 
//Size of buffer used for input/output operations
#ifndef FTP_SERVER_BUFFER_SIZE
   #define FTP_SERVER_BUFFER_SIZE 1024
#elif (FTP_SERVER_BUFFER_SIZE < 128)
   #error FTP_SERVER_BUFFER_SIZE parameter is not valid
#endif
 
//Maximum size of root directory
#ifndef FTP_SERVER_MAX_ROOT_DIR_LEN
   #define FTP_SERVER_MAX_ROOT_DIR_LEN 63
#elif (FTP_SERVER_MAX_ROOT_DIR_LEN < 7)
   #error FTP_SERVER_MAX_ROOT_DIR_LEN parameter is not valid
#endif
 
//Maximum size of home directory
#ifndef FTP_SERVER_MAX_HOME_DIR_LEN
   #define FTP_SERVER_MAX_HOME_DIR_LEN 63
#elif (FTP_SERVER_MAX_HOME_DIR_LEN < 7)
   #error FTP_SERVER_MAX_HOME_DIR_LEN parameter is not valid
#endif
 
//Maximum user name length
#ifndef FTP_SERVER_MAX_USERNAME_LEN
   #define FTP_SERVER_MAX_USERNAME_LEN 63
#elif (FTP_SERVER_MAX_USERNAME_LEN < 7)
   #error FTP_SERVER_MAX_USERNAME_LEN parameter is not valid
#endif
 
//Maximum path length
#ifndef FTP_SERVER_MAX_PATH_LEN
   #define FTP_SERVER_MAX_PATH_LEN 255
#elif (FTP_SERVER_MAX_PATH_LEN < 7)
   #error FTP_SERVER_MAX_PATH_LEN parameter is not valid
#endif
 
//Minimum buffer size for TCP sockets
#ifndef FTP_SERVER_MIN_TCP_BUFFER_SIZE
   #define FTP_SERVER_MIN_TCP_BUFFER_SIZE 1430
#elif (FTP_SERVER_MIN_TCP_BUFFER_SIZE < 512)
   #error FTP_SERVER_MIN_TCP_BUFFER_SIZE parameter is not valid
#endif
 
//Maximum buffer size for TCP sockets
#ifndef FTP_SERVER_MAX_TCP_BUFFER_SIZE
   #define FTP_SERVER_MAX_TCP_BUFFER_SIZE 2860
#elif (FTP_SERVER_MAX_TCP_BUFFER_SIZE < 512)
   #error FTP_SERVER_MAX_TCP_BUFFER_SIZE parameter is not valid
#endif
 
//TX buffer size for TLS connections
#ifndef FTP_SERVER_TLS_TX_BUFFER_SIZE
   #define FTP_SERVER_TLS_TX_BUFFER_SIZE 4096
#elif (FTP_SERVER_TLS_TX_BUFFER_SIZE < 512)
   #error FTP_SERVER_TLS_TX_BUFFER_SIZE parameter is not valid
#endif
 
//Minimum RX buffer size for TLS connections
#ifndef FTP_SERVER_MIN_TLS_RX_BUFFER_SIZE
   #define FTP_SERVER_MIN_TLS_RX_BUFFER_SIZE 2048
#elif (FTP_SERVER_MIN_TLS_RX_BUFFER_SIZE < 512)
   #error FTP_SERVER_MIN_TLS_RX_BUFFER_SIZE parameter is not valid
#endif
 
//Maximum RX buffer size for TLS connections
#ifndef FTP_SERVER_MAX_TLS_RX_BUFFER_SIZE
   #define FTP_SERVER_MAX_TLS_RX_BUFFER_SIZE 16384
#elif (FTP_SERVER_MAX_TLS_RX_BUFFER_SIZE < 512)
   #error FTP_SERVER_MAX_TLS_RX_BUFFER_SIZE parameter is not valid
#endif
 
//Passive port range (lower limit)
#ifndef FTP_SERVER_PASSIVE_PORT_MIN
   #define FTP_SERVER_PASSIVE_PORT_MIN 48128
#elif (FTP_SERVER_PASSIVE_PORT_MIN < 1024)
   #error FTP_SERVER_PASSIVE_PORT_MIN parameter is not valid
#endif
 
//Passive port range (upper limit)
#ifndef FTP_SERVER_PASSIVE_PORT_MAX
   #define FTP_SERVER_PASSIVE_PORT_MAX 49151
#elif (FTP_SERVER_PASSIVE_PORT_MAX <= FTP_SERVER_PASSIVE_PORT_MIN || FTP_SERVER_PASSIVE_PORT_MAX > 65535)
   #error FTP_SERVER_PASSIVE_PORT_MAX parameter is not valid
#endif
 
//Application specific context
#ifndef FTP_SERVER_PRIVATE_CONTEXT
   #define FTP_SERVER_PRIVATE_CONTEXT
#endif
 
//TLS supported?
#if (FTP_SERVER_TLS_SUPPORT == ENABLED)
   #include "core/crypto.h"
   #include "tls.h"
   #include "tls_ticket.h"
#endif
 
//FTP port number
#define FTP_PORT 21
//FTP data port number
#define FTP_DATA_PORT 20
 
//FTPS port number (implicit mode)
#define FTPS_PORT 990
//FTPS data port number (implicit mode)
#define FTPS_DATA_PORT 989
 
//Forward declaration of FtpServerContext structure
struct _FtpServerContext;
#define FtpServerContext struct _FtpServerContext
 
//Forward declaration of FtpClientConnection structure
struct _FtpClientConnection;
#define FtpClientConnection struct _FtpClientConnection
 
//C++ guard
#ifdef __cplusplus
extern "C" {
#endif
 
 
typedef enum
{
   FTP_CHANNEL_STATE_CLOSED       = 0,
   FTP_CHANNEL_STATE_CONNECT_TLS  = 1,
   FTP_CHANNEL_STATE_LISTEN       = 2,
   FTP_CHANNEL_STATE_IDLE         = 3,
   FTP_CHANNEL_STATE_SEND         = 4,
   FTP_CHANNEL_STATE_RECEIVE      = 5,
   FTP_CHANNEL_STATE_DISCARD      = 6,
   FTP_CHANNEL_STATE_AUTH_TLS_1   = 7,
   FTP_CHANNEL_STATE_AUTH_TLS_2   = 8,
   FTP_CHANNEL_STATE_USER         = 9,
   FTP_CHANNEL_STATE_LIST         = 10,
   FTP_CHANNEL_STATE_NLST         = 11,
   FTP_CHANNEL_STATE_RETR         = 12,
   FTP_CHANNEL_STATE_STOR         = 13,
   FTP_CHANNEL_STATE_APPE         = 14,
   FTP_CHANNEL_STATE_RNFR         = 15,
   FTP_CHANNEL_STATE_SHUTDOWN_TLS = 16,
   FTP_CHANNEL_STATE_WAIT_ACK     = 17,
   FTP_CHANNEL_STATE_SHUTDOWN_TX  = 18,
   FTP_CHANNEL_STATE_SHUTDOWN_RX  = 19
} FtpServerChannelState;
 
 
typedef enum
{
   FTP_SERVER_MODE_PLAINTEXT    = 1,
   FTP_SERVER_MODE_IMPLICIT_TLS = 2,
   FTP_SERVER_MODE_EXPLICIT_TLS = 4
} FtpServerMode;
 
 
typedef enum
{
   FTP_ACCESS_DENIED     = 0,
   FTP_ACCESS_ALLOWED    = 1,
   FTP_PASSWORD_REQUIRED = 2
} FtpAccessStatus;
 
 
typedef enum
{
   FTP_FILE_PERM_LIST  = 0x01,
   FTP_FILE_PERM_READ  = 0x02,
   FTP_FILE_PERM_WRITE = 0x04
} FtpFilePerm;
 
 
typedef error_t (*FtpServerConnectCallback)(FtpClientConnection *connection,
   const IpAddr *clientIpAddr, uint16_t clientPort);
 
 
typedef void (*FtpServerDisconnectCallback)(FtpClientConnection *connection,
   const IpAddr *clientIpAddr, uint16_t clientPort);
 
 
//TLS supported?
#if (FTP_SERVER_TLS_SUPPORT == ENABLED)
 
typedef error_t (*FtpServerTlsInitCallback)(FtpClientConnection *connection,
   TlsContext *tlsContext);
 
#endif
 
 
typedef uint_t (*FtpServerCheckUserCallback)(FtpClientConnection *connection,
   const char_t *user);
 
 
typedef uint_t (*FtpServerCheckPasswordCallback)(FtpClientConnection *connection,
   const char_t *user, const char_t *password);
 
 
typedef uint_t (*FtpServerGetFilePermCallback)(FtpClientConnection *connection,
   const char_t *user, const char_t *path);
 
 
typedef error_t (*FtpServerUnknownCommandCallback)(FtpClientConnection *connection,
   const char_t *command, const char_t *param);
 
 
typedef struct
{
   NetInterface *interface;                                
   uint16_t port;                                          
   uint16_t dataPort;                                      
   uint16_t passivePortMin;                                
   uint16_t passivePortMax;                                
   Ipv4Addr publicIpv4Addr;                                
   uint_t mode;                                            
   uint_t maxConnections;                                  
   FtpClientConnection *connections;                       
   char_t rootDir[FTP_SERVER_MAX_ROOT_DIR_LEN + 1];        
   FtpServerConnectCallback connectCallback;               
   FtpServerDisconnectCallback disconnectCallback;         
#if (FTP_SERVER_TLS_SUPPORT == ENABLED)
   FtpServerTlsInitCallback tlsInitCallback;               
#endif
   FtpServerCheckUserCallback checkUserCallback;           
   FtpServerCheckPasswordCallback checkPasswordCallback;   
   FtpServerGetFilePermCallback getFilePermCallback;       
   FtpServerUnknownCommandCallback unknownCommandCallback; 
} FtpServerSettings;
 
 
typedef struct
{
   FtpServerChannelState state; 
   Socket *socket;              
#if (FTP_SERVER_TLS_SUPPORT == ENABLED)
   TlsContext *tlsContext;      
#endif
} FtpServerChannel;
 
 
struct _FtpClientConnection
{
   FtpServerContext *context;                       
   NetInterface *interface;                         
   bool_t userLoggedIn;                             
   systime_t timestamp;                             
   FtpServerChannel controlChannel;                 
   FtpServerChannel dataChannel;                    
   FsFile *file;                                    
   FsDir *dir;                                      
   bool_t passiveMode;                              
   IpAddr remoteIpAddr;                             
   uint16_t remotePort;                             
   char_t user[FTP_SERVER_MAX_USERNAME_LEN + 1];    
   char_t homeDir[FTP_SERVER_MAX_HOME_DIR_LEN + 1]; 
   char_t currentDir[FTP_SERVER_MAX_PATH_LEN + 1];  
   char_t path[FTP_SERVER_MAX_PATH_LEN + 1];        
   char_t command[FTP_SERVER_MAX_LINE_LEN + 1];     
   size_t commandLen;                               
   char_t response[FTP_SERVER_MAX_LINE_LEN + 1];    
   size_t responseLen;                              
   size_t responsePos;                              
   char_t buffer[FTP_SERVER_BUFFER_SIZE];           
   size_t bufferLength;                             
   size_t bufferPos;                                
};
 
 
struct _FtpServerContext
{
   FtpServerSettings settings;                                    
   bool_t running;                                                
   bool_t stop;                                                   
   OsEvent event;                                                 
   OsTaskId taskId;                                               
#if (OS_STATIC_TASK_SUPPORT == ENABLED)
   OsTaskTcb taskTcb;                                             
   OsStackType taskStack[FTP_SERVER_STACK_SIZE];                  
#endif
   Socket *socket;                                                
   uint16_t passivePort;                                          
   FtpClientConnection *connections;                              
   SocketEventDesc eventDesc[2 * FTP_SERVER_MAX_CONNECTIONS + 1]; 
#if (FTP_SERVER_TLS_SUPPORT == ENABLED && TLS_TICKET_SUPPORT == ENABLED)
   TlsTicketContext tlsTicketContext;                             
#endif
   FTP_SERVER_PRIVATE_CONTEXT                                     
};
 
 
//FTP server related functions
void ftpServerGetDefaultSettings(FtpServerSettings *settings);
 
error_t ftpServerInit(FtpServerContext *context,
   const FtpServerSettings *settings);
 
error_t ftpServerStart(FtpServerContext *context);
error_t ftpServerStop(FtpServerContext *context);
 
error_t ftpServerSetHomeDir(FtpClientConnection *connection,
   const char_t *homeDir);
 
void ftpServerTask(FtpServerContext *context);
 
void ftpServerDeinit(FtpServerContext *context);
 
//C++ guard
#ifdef __cplusplus
}
#endif
 
#endif