diff --git a/dep/server.c b/dep/server.c index ce3f000..7ccc6eb 100644 --- a/dep/server.c +++ b/dep/server.c @@ -6,7 +6,7 @@ -void DROP_SERVER(char* serverHost, char** givenPort, int* listenSocket){ +void DROP_SERVER(const char* serverHost, char** givenPort, int* listenSocket){ if( DEBUGMOD&HDR ) printf("====== DROP_SERVER(%s, %s, %d) ======\n\n", serverHost, *givenPort, *listenSocket); // FONCTIONNEMENT @@ -124,17 +124,17 @@ void DROP_SERVER(char* serverHost, char** givenPort, int* listenSocket){ -// CMD: CLIENT (SRV) PROXY (CLT) FTP -// DTA: CLIENT (CLT) PROXY (CLT) FTP -// + + + void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSER_SOCKET, int* DFTP_SOCKET){ if( DEBUGMOD&HDR ) printf("====== MANAGE_REQUEST(%s, %d, %d, %d, %d) ======\n\n", pRequest, *USER_SOCKET, *FTP_SOCKET, *DUSER_SOCKET, *DFTP_SOCKET); - char response[maxBuffLen]; // contiendra la réponse - int nbSend; // contiendra le nombre de données envoyées - char rCommand[5]; // contiendra les commandes (1ère partie) - char rContent[maxBuffLen]; // contiendra le contenu associé à la commande (2ème partie) + char response[maxBuffLen]; // contiendra la réponse (2*taille buffer pour strcat(BUFLEN, BUFLEN)) + int nbSend; // contiendra le nombre de données envoyées + char rCommand[5]; // contiendra les commandes (1ère partie) + char rContent[maxBuffLen]; // contiendra le contenu associé à la commande (2ème partie) // on vide les buffers memset(&rCommand, '\0', sizeof(rCommand)); @@ -153,40 +153,40 @@ void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE /* (1) USER username@serveur => connection FTP (commande) --------------------------------------------*/ if( strcmp(rCommand, "USER") == 0 && indexOf(rContent, '@') >= 0 ){ - char userName[maxBuffLen] = {0}; + char userName[100] = {0}; char hostName[maxHostLen] = {0}; + // pour l'envoi de la séquence d'initialisation + char* ftp_response; ftp_response = malloc(maxBuffLen); + memset(ftp_response, 0, maxBuffLen); + /* 1. On extrait @username et @hostname */ sscanf(rContent, "%[^@]@%s\r\n", userName, hostName); - if( DEBUGMOD&BUF ) printf("USERNAME [[%s]]\n", userName); if( DEBUGMOD&BUF ) printf("HOSTNAME [[%s]]\n", hostName); - /* On se connecte au serveur FTP (commandes) */ + + /* 2. On se connecte au serveur FTP (commandes) */ CONNECT_CLIENT(hostName, FTP_PORT, FTP_SOCKET); if( *FTP_SOCKET == -1 ) printf("CAN'T CONNECT TO GIVEN SERVER!!\n"); if( DEBUGMOD&SCK ) printf("FTP SOCKET CONNECTED AT %s:%s\n", hostName, FTP_PORT); - /* On envoie la séquence d'initialisation */ - char BUFFER[maxBuffLen] = {0}; - char* ftp_response; ftp_response = malloc(maxBuffLen); - memset(ftp_response, 0, maxBuffLen); - strcpy(BUFFER, "\r\n"); - CLIENT_SEND(FTP_SOCKET, BUFFER, &ftp_response); + /* 3. On envoie la séquence d'initialisation */ + CLIENT_SEND(FTP_SOCKET, "\r\n", &ftp_response); - if( DEBUGMOD&CMD ) xPrint("P->F: %s\n\n", BUFFER); + if( DEBUGMOD&CMD ) xPrint("P->F: %s\n\n", "\r\n"); if( DEBUGMOD&CMD ) xPrint("F->P: %s\n", ftp_response); - - // char BUFF[maxBuffLen] = {0}; - // strcpy(BUFF, ""); - // swrite(FTP_SOCKET, BUFF); - // sread(FTP_SOCKET, BUFF); - // swrite(USER_SOCKET, strcat(BUFF, "\r\n")); + + /* 4. On envoie la requête USER au serveur FTP auquel on vient de se connecter */ + char newRequest[maxBuffLen]; + strcat(newRequest, "USER "); + strcat(newRequest, userName); + strcat(newRequest, "\r\n"); + printf("NEW REQ: [[%s]]\n", newRequest); strcpy(response, "USER xdrm\r\n"); - printf("RESP: [[%s]]\n", response); } /* (2) PORT a1,a2,a3,a4,p1,p2 => utilisateur (actif) @@ -199,6 +199,7 @@ void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE char serverPort[maxPortLen] = {0}; char BUFFER[maxBuffLen] = {0}; + /* 1. On récupère l'ip et le port de la réponse */ sscanf(pRequest, "PORT %d,%d,%d,%d,%d,%d", &a1, &a2, &a3, &a4, &p1, &p2); // on récupère l'adresse en sprintf(serverHost, "%d.%d.%d.%d", a1, a2, a3, a4); @@ -206,12 +207,12 @@ void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE sprintf(serverPort, "%d", p1*256+p2); - // on se connecte au client + /* 2. On se connecte au client */ if( DEBUGMOD&SCK ) printf("CONNECTING TO CLIENT %s:%s\n", serverHost, serverPort); CONNECT_CLIENT(serverHost, serverPort, DUSER_SOCKET); if( DEBUGMOD&SCK ) printf("CONNECTED TO CLIENT %s:%s\n", serverHost, serverPort); - // on envoie PASV car on veut être en mode passif entre le proxy et le serveur FTP + /* 3. Envoi de "PASV" car on veut être en mode passif entre le proxy et le serveur FTP */ strcpy(response, "PASV\r\n"); } @@ -251,44 +252,48 @@ void MANAGE_RESPONSE(char* pAnswer, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE /* [2] Selection en fonction de @ftpCode ================================================*/ - - /* (2) Demande d'username + switch(ftpCode){ + /* (1) Demande d'username --------------------------------------------*/ if( ftpCode == 220 ) strcpy(response, WLCM_MSG); - /* (3) username OK -> demande MDP + /* (2) username OK -> demande MDP --------------------------------------------*/ - else if( ftpCode == 331 ) + case 331: strcpy(response, USER_MSG); + break; - /* (4) Bon mdp -> connection + /* (3) Bon mdp -> connection --------------------------------------------*/ - else if( ftpCode == 230 ) + case 230: strcpy(response, PASS_BON_MSG); - + break; - - /* (5) Mauvais mdp -> connection + /* (4) Mauvais mdp -> message erreur --------------------------------------------*/ - else if( ftpCode == 530 ) + case 530: strcpy(response, PASS_BAD_MSG); + break; - /* (6) Info SYST + /* (5) Info SYST --------------------------------------------*/ - // else if( ftpCode == 215 ) + // case 215: // strcpy(response, "bla\n"); - - /* (7) LOGOUT => EXIT + // break; + + + /* (6) LOGOUT => EXIT --------------------------------------------*/ - else if( ftpCode == 221 ) + case 221: strcpy(response, EXIT_MSG); + break; - /* (8) Mode passif => On lance les SOCKETS du BUS DE DONNEES + /* (7) Mode passif => On lance les SOCKETS du BUS DE DONNEES --------------------------------------------*/ - else if( ftpCode == 227 ){ // on lance la SOCKET FTP du BUS DE DONNEES + case 227: // on lance la SOCKET FTP du BUS DE DONNEES int a1, a2, a3, a4 = 0; int p1, p2 = 0; @@ -306,12 +311,12 @@ void MANAGE_RESPONSE(char* pAnswer, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE if( DEBUGMOD&SCK ) printf("CONNECTED TO FTP %s:%s\n", serverHost, serverPort); strcpy(response, LIST_DAT_MSG); - } + break; - /* (9) On lit la SOCKET FTP du BUS DE DONNEES + /* (8) On lit la SOCKET FTP du BUS DE DONNEES --------------------------------------------*/ - else if( ftpCode == 150 ){ // on lit la SOCKET FTP du BUS DE DONNEES + case 150: char BUFFER[maxBuffLen] = {0}; @@ -355,23 +360,24 @@ void MANAGE_RESPONSE(char* pAnswer, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE // fin de la transaction strcpy(response, STOP_DAT_MSG); - } + break; - /* (10) Fin de transfert de données + /* (9) Fin de transfert de données (fermeture SOCKETS du BUS DE DONNEES) --------------------------------------------*/ - else if( ftpCode == 226 ){ // on ferme les SOCKETS du BUS DE DONNEES + case 226: // strcpy(response, "226 Fin de la transaction!\r\n"); strcpy(response, "\r\n"); close(*DUSER_SOCKET); close(*DFTP_SOCKET); - } + break; /* (n) Commande inconnue --------------------------------------------*/ - else + default: strcpy(response, pAnswer); - + break; + } /* [3] Retour de la réponse ================================================*/ diff --git a/dep/server.h b/dep/server.h index 980dbf4..8050bda 100644 --- a/dep/server.h +++ b/dep/server.h @@ -1,27 +1,58 @@ /* Créé et met un serveur sur écoute * +* ==IN== * @serverHost Nom de l'hôte local (localhost) -* -* @givenPort Pointeur sur le à remplir => contiendra le port donné par le système +* @givenPort Si renseigné, définit le port à utiliser +* +* ==OUT== +* @givenPort Pointeur sur le à remplir => contiendra le port donné par le système (si pas renseigné en entrée) * @listenSocket Pointeur sur le à remplir => contiendra un pointeur sur la socket d'écoute +* * +* +* @history +* [1] On définit le filtre/format +* [2] On récupère les infos (adresse, port) +* Note: Gestion IPv4/IPv6 +* [3] Création de la socket +* [4] On publie la SOCKET (bind) +* [5] On récupère les informations du serveur (host/port) +* [6] On met la socket sur écoute (listen) +* [7] On envoie les données par référence +* */ -void DROP_SERVER(char* serverHost, char** givenPort, int* listenSocket); +void DROP_SERVER(const char* serverHost, char** givenPort, int* listenSocket); /* Gestion de la requête du client -* +* ==IN/OUT== * @pBuffer Requête en question * @USER_SOCKET Pointeur sur la SOCKET du BUS DE COMMANDES utilisateur * @FTP_SOCKET Pointeur sur la SOCKET du BUS DE COMMANDES FTP * @DUSER_SOCKET Pointeur sur la SOCKET du BUS DE DONNEES utilisateur * @DFTP_SOCKET Pointeur sur la SOCKET du BUS DE DONNEES FTP * +* +* * @history -* [1] si "PORT a1,a2,a3,a4,p1,p2" on démarre la SOCKET CLIENT du BUS DE DONNEES -* [2] -* [3] +* [1] On découpe la requête en 2 parties (rCommand, rContent) +* [2] Selection en fonction de @rCommand +* +* (1) USER username@serveur => connection FTP (commande) +* 1. On extrait @username et @hostname +* 2. On se connecte au serveur FTP (commandes) +* 3. On envoie la séquence d'initialisation +* 4. On envoie la requête USER au serveur FTP auquel on vient de se connecter +* +* (2) PORT a1,a2,a3,a4,p1,p2 => utilisateur (actif) +* 1. On récupère l'ip et le port de la réponse +* 2. On se connecte au client +* 3. Envoi de "PASV" car on veut être en mode passif entre le proxy et le serveur FTP +* (n) Si aucun traitement on recopie la requête telquel +* +* [3] Retour de la réponse +* */ void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSER_SOCKET, int* DFTP_SOCKET); @@ -35,17 +66,24 @@ void MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSE * @DUSER_SOCKET Pointeur sur la SOCKET du BUS DE DONNEES utilisateur * @DFTP_SOCKET Pointeur sur la SOCKET du BUS DE DONNEES FTP * -* @history -* [1] SI commande sans transfert nécessaire, on modifie la réponse - -* [2] SI on a besoin d'un transfert de données -* (1) On initialise les SOCKETS avec la valeur de PORT a,b,c,d,p1,p2 -* (2) a.b.c.d (adresse ip) + p1*256+p2 (port) -* (3) UTILISATEUR (ACIF) PROXY (PASSIF) SRV_FTP -* -* [3] SI 227, on lance la SOCKET FTP du BUS DE DONNEES (mode passif) -* [4] SI 226, on ferme les SOCKETS du BUS DE DONNEES * +* +* @history +* [1] On découpe la requête en 2 parties (ftpCode, ftpText) +* [2] Selection en fonction de @ftpCode +* +* (1) 220- Demande d'username +* (2) 331- username OK -> demande MDP +* (3) 230- Bon mdp -> connection +* (4) 530- Mauvais mdp -> message erreur +* (5) 215- Info SYST [COMMENTÉ] +* (6) 221- LOGOUT => EXIT (commande QUIT) +* (7) 227- Mode passif => On lance les SOCKETS du BUS DE DONNEES +* (8) 150- On lit la SOCKET FTP du BUS DE DONNEES +* (9) 226- Fin de transfert de données (fermeture SOCKETS du BUS DE DONNEES) +* (n) xxx- Commande inconnue +* +* [3] Retour de la réponse */ void MANAGE_RESPONSE(char* pAnswer, int* USER_SOCKET, int* FTP_SOCKET, int* DUSER_SOCKET, int* DFTP_SOCKET); diff --git a/dep/utility.c b/dep/utility.c index fa6c205..9e8ddfe 100644 --- a/dep/utility.c +++ b/dep/utility.c @@ -19,9 +19,9 @@ void splitFtpRequest(char* pRequest, char* pCommand, char* pContent){ for( i = 0 ; i < strlen(pRequest) && pRequest[i] != '\0' ; i++ ){ if( i < firstSpaceIndex ) // première partie (pCommand) - strcpy( pCommand, strcat(pCommand, (char[2]) { (char) pRequest[i], '\0' }) ); + strcat( pCommand, (char[2]){(char) pRequest[i], '\0'}); if( i > firstSpaceIndex ) // seconde partie (pContent) - strcpy( pContent, strcat(pContent, (char[2]) { (char) pRequest[i], '\0' }) ); + strcat( pContent, (char[2]){(char) pRequest[i], '\0'}); } @@ -42,9 +42,9 @@ void splitFtpResponse(char* pAnswer, char* ftpCode, char* ftpText){ for( i = 0 ; i < strlen(pAnswer) && pAnswer[i] != '\0' ; i++ ){ if( i < codeLength ) // première partie (ftpCode) - strcpy( ftpCode, strcat(ftpCode, (char[2]) { (char) pAnswer[i], '\0' }) ); + strcat(ftpCode, (char[2]){(char)pAnswer[i], '\0' }); if( i > codeLength ) // seconde partie (ftpText) - strcpy( ftpText, strcat(ftpText, (char[2]) { (char) pAnswer[i], '\0' }) ); + strcat(ftpText, (char[2]){(char)pAnswer[i], '\0' }); } @@ -86,7 +86,7 @@ void formatBuffer(char* pBuffer){ revealString(pBuffer); /* [2] On ajoute "\r\n" à la fin ============================================================*/ - strcpy(pBuffer, strcat(pBuffer, "\r\n")); + strcat(pBuffer, "\r\n\0"); if( DEBUGMOD&BUF ) printf( "BUFLEN (aft): %lu\n", strlen(pBuffer) ); } @@ -102,7 +102,7 @@ void read_stdin(char* pBuffer, unsigned long pLength){ while( pBuffer[strlen(pBuffer)-1] == '\r' || pBuffer[strlen(pBuffer)-1] == '\n' ) pBuffer[strlen(pBuffer)-1] = '\0'; - strcpy(pBuffer, strcat(pBuffer, "\r\n\0")); + strcat(pBuffer, "\r\n\0"); } diff --git a/proxy_ftp.c b/proxy_ftp.c index 0f79349..f20f3c9 100644 --- a/proxy_ftp.c +++ b/proxy_ftp.c @@ -2,10 +2,11 @@ // DECLARATIONS static pthread_t managers[maxListLen]; +static int activeManagers = 0x00; /* headers */ static void* testServer(); - +void* manageConnection(void* THREADABLE_SOCKET); @@ -40,21 +41,14 @@ int main(int argc, char* argv[]){ static void* testServer(char* localPort){ - int USER_SOCKET = -1; // contiendra le BUS DE COMMANDE utilisateur - int FTP_SOCKET = -1; // contiendra le BUS DE COMMANDE FTP - int DUSER_SOCKET = -1; // contiendra le BUS DE DONNES utilisateur - int DFTP_SOCKET = -1; // contiendra le BUS DE DONNEES FTP - - char BUFFER[maxBuffLen]; // contiendra le BUFFER + int THREADABLE_SOCKET = -1; // contiendra le BUS DE COMMANDE utilisateur à envoyer à un THREAD struct sockaddr_storage clientInfo; // contiendra les infos client char repeat; // sert à sortir de la boucle - int nbReceived, nbSend; // contiendra les nb reçu && envoyé socklen_t len = sizeof(struct sockaddr_storage); // retour de @DROP_SERVER char* serverPort; // contiendra le port int LISTENSOCK; // contiendra la socket d'écoute - char* ftp_response; /* [0] On démarre le SERVEUR + le CLIENT ==========================================================*/ @@ -71,11 +65,64 @@ static void* testServer(char* localPort){ /* [1] Attente d'une demande de connection, puis création d'une socket ============================================================================*/ - USER_SOCKET = accept(LISTENSOCK, (struct sockaddr *) &clientInfo, &len); + int index = 0; + while( index <= maxListLen ){ + THREADABLE_SOCKET = -1; // on initialise la SOCKET en attendant la connexion + THREADABLE_SOCKET = accept(LISTENSOCK, (struct sockaddr *) &clientInfo, &len); -// static void* manageConnection(int* USER_SOCKET){ + // on lance un thread pour le traitement + pthread_create(&managers[index], NULL, manageConnection, (void*)(intptr_t) THREADABLE_SOCKET); + index++; + } + + int i; + for( i = 0 ; i < maxListLen ; i++ ) + pthread_join(managers[i], NULL); + printf("FERMETURE DE TOUTES LES CONNECTIONS!\n"); + close(LISTENSOCK); +} + + + + + + + + + + + +/* Gestion d'une connexion client +* +* @THREADABLE_SOCKET SOCKET de la connexion client +* +* @history +* [1] Initialisation des variables +* [2] Envoi de la séquence de bienvenue +* [3] Attente des données reçues et reception (CLIENT_FTP->PROXY) +* [4] Traitement de la requête client +* [5] Redirection de la requête vers le serveur FTP (PROXY->SERVER_FTP) +* [6] Traitement de la reponse du serveur FTP +* [7] Redirection de la réponse vers le client (PROXY->CLIENT_FTP) +* +* +*/ +void* manageConnection(void* THREADABLE_SOCKET){ + int USER_SOCKET = (intptr_t) THREADABLE_SOCKET; + + /* [1] Variables + ============================================================================*/ + // int USER_SOCKET = -1; // contiendra le BUS DE COMMANDE utilisateur + int FTP_SOCKET = -1; // contiendra le BUS DE COMMANDE FTP + int DUSER_SOCKET = -1; // contiendra le BUS DE DONNES utilisateur + int DFTP_SOCKET = -1; // contiendra le BUS DE DONNEES FTP + + char BUFFER[maxBuffLen]; // contiendra le BUFFER + char* ftp_response; // contiendra le BUFFER de réponse du serveur FTP (commandes) + int nbReceived, nbSend; // contiendra les nb reçu && envoyé + /* [2] Envoi de la séquence de Bienvenue ============================================================================*/ swrite(&USER_SOCKET, WLCM_MSG); @@ -117,8 +164,8 @@ static void* testServer(char* localPort){ /* [8] On vide les buffers ============================================================================*/ - // memset(BUFFER, '\0', maxBuffLen); // on vide le buffer - // memset(ftp_response, '\0', maxBuffLen); + memset(BUFFER, '\0', maxBuffLen); // on vide le buffer + memset(ftp_response, '\0', maxBuffLen); } /* [9] Fermeture des connections (SOCKETS) @@ -126,7 +173,9 @@ static void* testServer(char* localPort){ printf("CLOSING CONNECTIONS\n"); close(USER_SOCKET); close(FTP_SOCKET); - close(LISTENSOCK); + + // on arrête le THREAD + pthread_exit(NULL); } diff --git a/proxy_ftp.h b/proxy_ftp.h index b76a557..0799275 100644 --- a/proxy_ftp.h +++ b/proxy_ftp.h @@ -1,6 +1,7 @@ /* global */ #include #include +#include #include #include @@ -15,12 +16,12 @@ /* debug */ -#define SOCKETS 0x01 // debug RESEAU -#define COMMAND 0x02 // debug COMMANDES -#define DATA 0x04 // debug DONNEES -#define REVEALS 0x08 // debug EXPLICITATION des strings -#define BUFFERS 0x10 // debug des BUFFERS -#define HEADERS 0x20 // debug des HEADERS de fonctions +#define SOCKETS 0x01 // debug RESEAU +#define COMMANDS 0x02 // debug COMMANDES +#define DATA 0x04 // debug DONNEES +#define REVEALS 0x08 // debug EXPLICITATION des strings +#define BUFFERS 0x10 // debug des BUFFERS +#define HEADERS 0x20 // debug des HEADERS de fonctions #define SCK 0x01 // FILTRE pour ONLY_SOCKET #define CMD 0x02 // FILTRE pour ONLY_COMMAND @@ -30,8 +31,7 @@ #define HDR 0x20 // FILTRE pour ONLY_HEADERS // possibilité de cumuler les DEBUGMODES -/* DEBUGMOD ONLY_COMMAND + ONLY_DATA + .. */ -#define DEBUGMOD COMMAND // REVEALS + HEADER +#define DEBUGMOD COMMANDS // REVEALS + HEADER /* vars */ diff --git a/test b/test index b8d2a49..1a8eec9 100755 Binary files a/test and b/test differ