commit b41a8d304f162f698b6e6617e8fcbeb6c53ddfdc Author: xdrm-brackets Date: Tue Mar 28 18:45:18 2017 +0200 First commit Import diff --git a/central-manager/central-manager.c b/central-manager/central-manager.c new file mode 100644 index 0000000..cb1ced5 --- /dev/null +++ b/central-manager/central-manager.c @@ -0,0 +1,196 @@ +#include "central-manager.h" + + + + +/* +* +* @history +* [0] Initialisation des variables +* [1] On démarre le SERVEUR d'écoute globale +* [2] Attente d'une demande de connection, puis création d'un THREAD +* [3] On attends la fin de tous les THREADS +* [4] On ferme la SOCKET d'écoute globale +* +*/ +int main(int argc, char* argv[]){ + /* [0] Initialisation des variables + ==========================================================*/ + 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 + socklen_t len = sizeof(struct sockaddr_storage); + + // retour de @DROP_SERVER + char* serverPort; // contiendra le port + int LISTENSOCK; // contiendra la socket d'écoute + + + /* [1] On démarre le SERVEUR d'écoute globale + ==========================================================*/ + serverPort = malloc(maxPortLen); + + // attribution du port si dans les arguments + if( argc > 1 ) strcpy(serverPort, argv[1]); + + DROP_SERVER(remoteHost, &serverPort, &LISTENSOCK); + printf("Port: %s\n", serverPort); + + + + /* [2] Attente d'une demande de connection, puis création d'un THREAD + ============================================================================*/ + int index = -1; + while( 1 ){ + /* 1. On initialise la SOCKET en attendant la connexion et le rang du "manager" inactif */ + THREADABLE_SOCKET = -1; + index = -1; + + /* 2. On attends une connection */ + THREADABLE_SOCKET = accept(LISTENSOCK, (struct sockaddr *) &clientInfo, &len); + + /* 3. On cherche un "manager" libre */ + int i; + + // si on trouve un "manager" inactif, on l'enregistre dans index + for( i = 0 ; i < maxListLen ; i++ ) + if( activeManagers[i] == 0 ){ index = i; break; } + + // si on a trouvé un "manager" libre + if( index != -1 ){ + + /* 4. On lance un thread pour le traitement de ce client */ + pthread_create(&managers[index], NULL, manageConnection, (void*)(intptr_t) THREADABLE_SOCKET); + if( DEBUGMOD&THR ) printf("THREAD[%d] démarré\n", index); + + /* 5. On signale que ce "manager" est maintenant actif */ + activeManagers[index] = 1; + }else + if( DEBUGMOD&THR ) printf("Demande de thread refusée!\n"); + } + + + /* [3] On attends la fin de tous les THREADS + ==========================================================*/ + int i; + for( i = 0 ; i < maxListLen ; i++ ) + pthread_join(managers[i], NULL); + + /* [4] On ferme la SOCKET d'écoute globale + ==========================================================*/ + 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) +* [8] On vide les buffers +* [9] Fermeture des connections (SOCKETS) +* [10] Arrêt du THREAD +* 1. On récupère le rang dans les "managers" +* 2. On met à jour "activeManagers" +* 3. On arrête le THREAD +* +*/ +void* manageConnection(void* THREADABLE_SOCKET){ + int USER_SOCKET = (intptr_t) THREADABLE_SOCKET; // BUS DE COMMANDE utilisateur + + /* [1] Variables + ============================================================================*/ + // int USER_SOCKET = -1; + 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; // 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é + BUFFER = malloc( maxBuffLen ); + int error; + + /* [2] Envoi de la séquence de bienvenue + ============================================================================*/ + swrite(&USER_SOCKET, WLCM_MSG); + + /* BOUCLE DE COMMANDES */ + while( USER_SOCKET != -1 ){ + + /* [3] On récupère les données reçues (+attente) + ============================================================================*/ + if( WAIT_SOCKET_UPDATE(&USER_SOCKET, BUFFER) == -1 ) break; + if( DEBUGMOD&CMD ) xPrint("C->P: %s\n", BUFFER); + + + /* [4] Traitement de la requête + ============================================================================*/ + error = MANAGE_REQUEST(BUFFER, &USER_SOCKET, &FTP_SOCKET, &DUSER_SOCKET, &DFTP_SOCKET); + + // si on a pas la connection FTP (commande) initialisée, on quitte + if( error == -1 ) break; + + + /* [5] Redirection vers le serveur FTP + ============================================================================*/ + if( DEBUGMOD&CMD ) xPrint("P->F: %s\n\n", BUFFER); + CLIENT_SEND(&FTP_SOCKET, BUFFER, &BUFFER); + if( DEBUGMOD&CMD ) xPrint("F->P: %s\n", BUFFER); + + /* [6] Traitement de la réponse (FTP) + ============================================================================*/ + MANAGE_RESPONSE(BUFFER, &USER_SOCKET, &FTP_SOCKET, &DUSER_SOCKET, &DFTP_SOCKET); + + + + /* [7] Redirection vers le CLIENT + ============================================================================*/ + if( swrite(&USER_SOCKET, BUFFER) == -1 ) break; + if( DEBUGMOD&CMD ) xPrint("P->C: %s\n", BUFFER); + + + /* [8] On vide les buffers + ============================================================================*/ + memset(BUFFER, '\0', maxBuffLen); // on vide le buffer + memset(BUFFER, '\0', maxBuffLen); + } + + /* [9] Fermeture des connections (SOCKETS) + ============================================================================*/ + printf("CLOSING CONNECTIONS\n"); + close(USER_SOCKET); + close(FTP_SOCKET); + + /* [10] Arrêt du THREAD + ============================================================================*/ + /* 1. On récupère le rang dans les "managers" */ + int i, index = -1; + for( i = 0 ; i < maxListLen ; i++ ) + if( managers[i] == pthread_self() ){ index = i; break; } + + /* 2. On met à jour "activeManagers" */ + if( index != -1 ) + activeManagers[index] = 0; + + /* 3. On arrête le THREAD */ + if( DEBUGMOD&THR ) printf("THREAD[%d] libéré\n", index); + pthread_exit(NULL); +} diff --git a/central-manager/central-manager.h b/central-manager/central-manager.h new file mode 100644 index 0000000..f40d1e8 --- /dev/null +++ b/central-manager/central-manager.h @@ -0,0 +1,57 @@ +/* global */ +#include +#include +#include +#include +#include + +/* sys */ +#include +#include + +/* socket */ +#include +#include // getaddrinfo, getnameinfo +#include + + +/* debug */ +#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 THREADS 0x40 // debug des THREADS + +#define SCK 0x01 // FILTRE pour SOCKET +#define CMD 0x02 // FILTRE pour COMMAND +#define DAT 0x04 // FILTRE pour DATA +#define RVL 0x08 // FILTRE pour REVEALS +#define BUF 0x10 // FILTRE pour BUFFERS +#define HDR 0x20 // FILTRE pour HEADERS +#define THR 0x40 // FILTRE pour THREADS + +// possibilité de cumuler les DEBUGMODES +#define DEBUGMOD SOCKETS + THREADS // REVEALS + HEADER + THREADS + + +/* vars */ +#define remoteHost "localhost" +#define remotePort "80" +#define maxBuffLen 4096 +#define maxListLen 10 +#define maxHostLen 64 +#define maxPortLen 6 + +/* local dependencies */ +#include "dep/utility.c" +#include "dep/server.c" + + +/* headers */ +void* manageConnection(void* THREADABLE_SOCKET); + +// VARIABLES +static pthread_t managers[maxListLen]; // contiendra les THREADS +static int activeManagers[maxListLen] = {0}; // contiendra les THREADS actifs diff --git a/central-manager/dep/server.c b/central-manager/dep/server.c new file mode 100644 index 0000000..137e99c --- /dev/null +++ b/central-manager/dep/server.c @@ -0,0 +1,430 @@ +#include "server.h" + + + + + + + +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 + struct addrinfo hints; // contiendra le filtre/format + struct addrinfo* addrinfo; // contiendra les infos du serveur + int SOCKET, BIND, LISTEN; // file_desc(s) + + // INFOS + struct sockaddr_storage serverInfo; // contiendra les informations du server + socklen_t sockaddr_len = sizeof(struct sockaddr_storage); + char infoHost[maxHostLen]; // contiendra l'adresse du server + char infoPort[maxPortLen]; // contiendra le port du server + + /* [1] On définit le filtre/format + =======================================================*/ + memset(&hints, 0, sizeof(struct addrinfo)); // on vide le filtre + hints.ai_family = AF_UNSPEC; // Allow IPv4 ou IPv6 + hints.ai_socktype = SOCK_STREAM; // TCP (SOCK_DGRAM = UDP) + hints.ai_flags = AI_PASSIVE; // mode SERVER + hints.ai_protocol = 0; // non spécifié + + if( DEBUGMOD&SCK ) printf("============HINTS===========\n"); + if( DEBUGMOD&SCK ) printf( "AI_FLAGS = %d\n", hints.ai_flags ); // int + if( DEBUGMOD&SCK ) printf( "AI_FAMILY = %d\n", hints.ai_family ); // int + if( DEBUGMOD&SCK ) printf( "AI_SOCKTYPE = %d\n", hints.ai_socktype ); // int + if( DEBUGMOD&SCK ) printf( "AI_PROTOCOL = %d\n", hints.ai_protocol ); // int + if( DEBUGMOD&SCK ) printf( "AI_ADDRLEN = %d\n", hints.ai_addrlen ); // int + if( DEBUGMOD&SCK ) printf("\n"); + + + /* [2] On récupère les infos + =======================================================*/ + if( strlen(*givenPort) == 0 ) // si pas défini, port dynamique + getaddrinfo(serverHost, 0, &hints, &addrinfo); + else // sinon manuel + getaddrinfo(serverHost, *givenPort, &hints, &addrinfo); + // Remarque: port=0 donc va être défini dynamiquement + + if( DEBUGMOD&SCK ) printf("=============RES============\n"); + if( DEBUGMOD&SCK ) printf( "AI_FLAGS = %d\n", addrinfo->ai_flags ); // int + if( DEBUGMOD&SCK ) printf( "AI_FAMILY = %d\n", addrinfo->ai_family ); // int + if( DEBUGMOD&SCK ) printf( "AI_SOCKTYPE = %d\n", addrinfo->ai_socktype ); // int + if( DEBUGMOD&SCK ) printf( "AI_PROTOCOL = %d\n", addrinfo->ai_protocol ); // int + if( DEBUGMOD&SCK ) printf( "AI_ADDRLEN = %d\n", addrinfo->ai_addrlen ); // int + if( DEBUGMOD&SCK ) printf("\n"); + + /* [3] Création de la socket + =======================================================*/ + + SOCKET = socket(addrinfo->ai_family, addrinfo->ai_socktype, 0); + + if( DEBUGMOD&SCK ) printf("SOCKET = %d\n", SOCKET); + + // si erreur + if( SOCKET == -1 ) return; + + + /* [4] On publie la SOCKET + =======================================================*/ + BIND = bind( + SOCKET, + addrinfo->ai_addr, + addrinfo->ai_addrlen + ); + + if( DEBUGMOD&SCK ) printf("BIND = %d\n", BIND); + + // si erreur + if( BIND == -1 ) return; + + /* [5] On récupère les informations du serveur (host/port) + =======================================================*/ + int getInfo = getsockname(SOCKET, (struct sockaddr *) &serverInfo, &sockaddr_len); + + if( getInfo == -1 ) return; + + getInfo = getnameinfo( // on récupère le host et le port + (struct sockaddr *) &serverInfo, + sizeof(serverInfo), + infoHost, maxHostLen, + infoPort, maxPortLen, + NI_NUMERICHOST | NI_NUMERICSERV + ); + + if( getInfo == -1 ) return; + + if( DEBUGMOD&SCK ) printf("Server host: %s\n", infoHost); + if( DEBUGMOD&SCK ) printf("Server port: %s\n", infoPort); + + + // on a plus besoin des infos de l'adresse + freeaddrinfo(addrinfo); + + + /* [6] On met la socket sur écoute + =======================================================*/ + LISTEN = listen(SOCKET, maxListLen); + + if( DEBUGMOD&SCK ) printf("LISTEN = %d\n", LISTEN); + + // si erreur + if( LISTEN == -1 ) return; + + /* [7] On envoie les données par référence + =======================================================*/ + // port + *givenPort = malloc( maxPortLen ); + strcpy(*givenPort, infoPort); + + // socket d'écoute + *listenSocket = SOCKET; +} + + + + + + + + + +int 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 (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)); + memset(&rContent, '\0', sizeof(rContent)); + memset(&response, '\0', sizeof(response)); + + + /* [1] On découpe la requête en 2 parties + ================================================*/ + splitFtpRequest(pRequest, rCommand, rContent); + + + /* [2] Selection en fonction de @rCommand + ================================================*/ + + /* (1) USER username@serveur => connection FTP (commande) + --------------------------------------------*/ + if( strcmp(rCommand, "USER") == 0 && indexOf(rContent, '@') >= 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); + + + /* 2. On se connecte au serveur FTP (commandes) */ + int error = CONNECT_CLIENT(hostName, FTP_PORT, FTP_SOCKET); + + if( error == -1 || *FTP_SOCKET == -1 ){ // si erreur + printf("Impossible de se connecter au serveur (%s:%s)\n", hostName, FTP_PORT); + strcpy(pRequest, "421 ERREUR: impossible de se connecter au serveur!!\r\n"); + return -1; + } + + if( DEBUGMOD&SCK ) printf("FTP SOCKET CONNECTED AT %s:%s\n", hostName, FTP_PORT); + + + /* 3. On envoie la séquence d'initialisation */ + CLIENT_SEND(FTP_SOCKET, "", &ftp_response); + + if( DEBUGMOD&CMD ) xPrint("P->F: %s\n\n", "\r\n"); + if( DEBUGMOD&CMD ) xPrint("F->P: %s\n", ftp_response); + + + /* 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"); + strcpy(response, "USER xdrm\r\n"); + } + + else if( strcmp(rCommand, "USER") == 0 ) // si oubli serveur + strcpy(response, "421 'username@FTPserver' attendu\n"); + + /* (2) PORT a1,a2,a3,a4,p1,p2 => utilisateur (actif) + --------------------------------------------*/ + else if( strcmp(rCommand, "PORT") == 0 ){ + int a1, a2, a3, a4 = 0; + int p1, p2 = 0; + + char serverHost[maxHostLen] = {0}; + 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); + // on récupère le port en + sprintf(serverPort, "%d", p1*256+p2); + + + /* 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); + + /* 3. Envoi de "PASV" car on veut être en mode passif entre le proxy et le serveur FTP */ + strcpy(response, "PASV\r\n"); + } + + /* (n) Si aucun traitement on recopie la requête telquel + --------------------------------------------*/ + else + strcpy(response, pRequest); + + /* [3] Retour de la réponse + ================================================*/ + strcpy(pRequest, response); + printf("RESP: %s\n", pRequest); + + + return 0; +} + + + +void MANAGE_RESPONSE(char* pAnswer, int* USER_SOCKET, int* FTP_SOCKET, int* DUSER_SOCKET, int* DFTP_SOCKET){ + if( DEBUGMOD&HDR ) printf("====== MANAGE_RESPONSE(%s, %d, %d, %d, %d) ======\n\n", pAnswer, *USER_SOCKET, *FTP_SOCKET, *DUSER_SOCKET, *DFTP_SOCKET); + + char response[maxBuffLen]; // contiendra la réponse + char ftpCodeStr[4]; // contiendra le code FTP (1ère partie) + char ftpText[maxBuffLen]; // contiendra le texte associé à la commande (2ème partie) + int ftpCode; // contiendra le code FTP en numérique + + // on vide les buffers + memset(&ftpCodeStr, '\0', sizeof(ftpCode)); + memset(&ftpText, '\0', sizeof(ftpText)); + memset(&response, '\0', sizeof(response)); + + + /* [1] On découpe la requête en 2 parties + ================================================*/ + splitFtpResponse(pAnswer, ftpCodeStr, ftpText); + + // on met le code FTP en + ftpCode = atoi( ftpCodeStr ); + + // mise à disposition de variables temporaires + int tmp[6] = {0}; + char serverHost[maxHostLen]; + char serverPort[maxPortLen]; + char BUFFER[maxBuffLen] = {0}; + + /* [2] Selection en fonction de @ftpCode + ================================================*/ + switch(ftpCode){ + /* (1) Demande d'username + --------------------------------------------*/ + case 220: + strcpy(response, WLCM_MSG); + break; + + /* (2) username OK -> demande MDP + --------------------------------------------*/ + case 331: + strcpy(response, USER_MSG); + break; + + /* (3) Bon mdp -> connection + --------------------------------------------*/ + case 230: + strcpy(response, PASS_BON_MSG); + break; + + /* (4) Mauvais mdp -> message erreur + --------------------------------------------*/ + case 530: + strcpy(response, PASS_BAD_MSG); + break; + + /* (5) Info SYST + --------------------------------------------*/ + // case 215: + // strcpy(response, "bla\n"); + // break; + + + /* (6) LOGOUT => EXIT + --------------------------------------------*/ + case 221: + strcpy(response, EXIT_MSG); + break; + + + /* (7) Mode passif => On lance les SOCKETS du BUS DE DONNEES + --------------------------------------------*/ + case 227: // on lance la SOCKET FTP du BUS DE DONNEES + + /* 1. On récupère l'ip et le port de la réponse */ + sscanf(pAnswer, "227 Entering Passive Mode (%d,%d,%d,%d,%d,%d)", &tmp[0], &tmp[1], &tmp[2], &tmp[3], &tmp[4], &tmp[5]); + // on récupère l'adresse en + sprintf(serverHost, "%d.%d.%d.%d", tmp[0], tmp[1], tmp[2], tmp[3]); + // on récupère le port en + sprintf(serverPort, "%d", tmp[4]*256+tmp[5]); + + /* 2. Connexion au serveur FTP */ + if( DEBUGMOD&SCK ) printf("CONNECTING TO FTP %s:%s\n", serverHost, serverPort); + CONNECT_CLIENT(serverHost, serverPort, DFTP_SOCKET); + if( DEBUGMOD&SCK ) printf("CONNECTED TO FTP %s:%s\n", serverHost, serverPort); + + /* 3. Envoi du message de code 200 */ + strcpy(response, LIST_DAT_MSG); + break; + + + /* (8) On lit la SOCKET FTP du BUS DE DONNEES + --------------------------------------------*/ + case 150: + + /* 1. Envoi au client de l'écoute de la réponse (associée) du BUS DE DONNEES */ + // sread(FTP_SOCKET, BUFFER); + // if( DEBUGMOD&CMD ) xPrint("F->P: %s\n", BUFFER); + swrite(USER_SOCKET, READ_CON_MSG); + if( DEBUGMOD&CMD ) xPrint("P->C: %s\n", READ_CON_MSG); + + + /* 2. On lit la SOCKET FTP (BUS DE DONNEES) */ + tmp[0] = WAIT_SOCKET_UPDATE(DFTP_SOCKET, BUFFER); + + if( DEBUGMOD&DAT && tmp[0] == -1 ) printf("ERROR\n"); + else if( DEBUGMOD&DAT ) xPrint("[BUS_IN]: %s\n", BUFFER); + + + /* 3. On redirige sur la SOCKET utilisateur (BUS DE DONNEES) */ + tmp[1] = swrite(DUSER_SOCKET, BUFFER); + + if( DEBUGMOD&DAT && tmp[1] == -1 ) printf("ERROR\n"); + else if( DEBUGMOD&DAT ) xPrint("[BUS_OUT]: %s\n", BUFFER); + + if( DEBUGMOD&DAT ) xPrint("BUS_FTP->BUS_CLIENT: %s\n", BUFFER); + + + /* 4. On ferme les SOCKETS du BUS DE DONNEES */ + close(*DFTP_SOCKET); + if( DEBUGMOD&CMD ) printf("BUS_FTP fermé (%d)\n", *DFTP_SOCKET); + close(*DUSER_SOCKET); + if( DEBUGMOD&CMD ) printf("BUS_USER fermé (%d)\n", *DUSER_SOCKET); + + + // on vide les SOCKET FTP des 2 BUS + // WAIT_SOCKET_UPDATE(FTP_SOCKET, BUFFER); // command + // WAIT_SOCKET_UPDATE(DFTP_SOCKET, BUFFER); // données + // printf("") + + /* 5. On vide le BUS DE COMMANDE du serveur FTP */ + /* A. On définit un TIMEOUT (1 sec) */ + setSocketTimeout(FTP_SOCKET, 0, 50); + + /* B. On attends une réponse */ + tmp[2] = sread(FTP_SOCKET, BUFFER); + + /* C. On enlève le TIMEOUT (default) */ + setSocketTimeout(FTP_SOCKET, SOCKET_TIMEOUT); + + + /* 6. On transmet le message de fin de la transaction (226) */ + strcpy(response, STOP_DAT_MSG); + break; + + + /* (9) Fin de transfert de données (fermeture SOCKETS du BUS DE DONNEES) + --------------------------------------------*/ + case 226: + strcpy(response, "226 Fin de la transaction!\r\n"); + close(*DUSER_SOCKET); + close(*DFTP_SOCKET); + break; + + /* (n) Commande inconnue + --------------------------------------------*/ + default: + strcpy(response, pAnswer); + break; + } + + /* [3] Retour de la réponse + ================================================*/ + strcpy(pAnswer, response); +} + + + + + +int WAIT_SOCKET_UPDATE(int* pSocket, char* pBuffer){ + memset(pBuffer, 0, maxBuffLen); // on vide le buffer + + int nbRead = 0; + + do{ + nbRead = sread(pSocket, pBuffer); + + // si on est déconnecté, on renvoie une erreur + if( nbRead == -1 ){ + printf("Client déconnecté!\n"); + return -1; + } + + }while( pBuffer[nbRead-1] != '\n' && pBuffer[nbRead-2] != '\r' ); + + + // on retourne -1 si erreur, SINON 0 + return nbRead; +} \ No newline at end of file diff --git a/central-manager/dep/server.h b/central-manager/dep/server.h new file mode 100644 index 0000000..58d7184 --- /dev/null +++ b/central-manager/dep/server.h @@ -0,0 +1,123 @@ +/* Créé et met un serveur sur écoute +* +* ==IN== +* @serverHost Nom de l'hôte local (localhost) +* @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(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] 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 requête +* 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 +* +*/ +int MANAGE_REQUEST(char* pRequest, int* USER_SOCKET, int* FTP_SOCKET, int* DUSER_SOCKET, int* DFTP_SOCKET); + + + + + +/* Gestion de la réponse du serveur FTP et modification de la réponse +* +* @pAnswer Pointeur sur le buffer de réponse du serveur FTP +* @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] 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 +* 1. On récupère l'ip et le port de la réponse +* 2. Connexion au serveur FTP +* 3. Envoi du message de code 200 +* +* (8) 150- On lit la SOCKET FTP du BUS DE DONNEES +* 1. Envoi au client de l'écoute de la réponse (associée) du BUS DE DONNEES +* 2. On lit la SOCKET FTP (BUS DE DONNEES) +* 3. On redirige sur la SOCKET utilisateur (BUS DE DONNEES) +* 4. On ferme les SOCKETS du BUS DE DONNEES +* 5. On vide le BUS DE COMMANDE du serveur FTP +* A. On définit un TIMEOUT (1 sec +* B. On attends une réponse +* C. On enlève le TIMEOUT (default) +* 6. On transmet le message de fin de la transaction (226) +* +* (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); + + + + + +/* Attends une réponse du client +* +* @pSocket Pointeur sur la SOCKET en question +* @pBuffer Buffer qui contiendra la réponse +* +* @return nbRead On retourne le nombre de char lus, sinon -1 si erreur +* +* +* +* @history +* [1] On read() tant qu'on a pas les symboles de fin "\r\n" +* [2] On écrit sur le BUFFER +* [3] Si une erreur se produit, on retourne -1 +* +*/ +int WAIT_CLIENT(int* pSocket, char* pBuffer); \ No newline at end of file diff --git a/central-manager/dep/utility.c b/central-manager/dep/utility.c new file mode 100644 index 0000000..faecd69 --- /dev/null +++ b/central-manager/dep/utility.c @@ -0,0 +1,169 @@ +#include "utility.h" + +void splitFtpRequest(char* pRequest, char* pCommand, char* pContent){ + /* [1] Vérification du format + ===========================================*/ + int firstSpaceIndex = indexOf(pRequest, ' '); + + if( firstSpaceIndex != 3 && firstSpaceIndex != 4){ // contient aucun espace en position 3 ou 4, on quitte + strcpy(pCommand, "ERROR"); + strcpy(pContent, ""); + return; + } + + + /* [2] Séparation des 2 parties + ===========================================*/ + int i; + + for( i = 0 ; i < strlen(pRequest) && pRequest[i] != '\0' ; i++ ){ + + if( i < firstSpaceIndex ) // première partie (pCommand) + strcat( pCommand, (char[2]){(char) pRequest[i], '\0'}); + if( i > firstSpaceIndex ) // seconde partie (pContent) + strcat( pContent, (char[2]){(char) pRequest[i], '\0'}); + } + + +} + + + + +void splitFtpResponse(char* pAnswer, char* ftpCode, char* ftpText){ + /* [1] Vérification du format + ===========================================*/ + int codeLength = 3; // taille du code + + /* [2] Séparation des 2 parties + ===========================================*/ + int i; + + for( i = 0 ; i < strlen(pAnswer) && pAnswer[i] != '\0' ; i++ ){ + + if( i < codeLength ) // première partie (ftpCode) + strcat(ftpCode, (char[2]){(char)pAnswer[i], '\0' }); + if( i > codeLength ) // seconde partie (ftpText) + strcat(ftpText, (char[2]){(char)pAnswer[i], '\0' }); + } + + +} + + + + + +int indexOf(char* haystack, char needle){ + int i; + + for( i = 0 ; i < strlen(haystack) && haystack[i] != '\0' ; i++ ) + if( haystack[i] == needle ) // si on trouve le caractère + return i; + + return -1; + +} + + +int swrite(int* pSocket, char* pBuffer){ + if( *pSocket == -1 ) return -1; // si SOCKET fermée, on retourne une erreur + if( strlen(pBuffer) == 0 ) return 0; // si on a rien à écrire, on n'écrit rien :p + + + /* 1. On écrit sur la SOCKET */ + if( DEBUGMOD&BUF ) printf("SENDLEN_1: %lu\n", strlen(pBuffer)); + int nbSent = write(*pSocket, pBuffer, strlen(pBuffer)); + if( DEBUGMOD&BUF ) printf("SENDLEN_2: %d\n", nbSent); + + /* 2. Si on est déconnecté, on retourne une erreur */ + if( nbSent <= 0 ){ + if( DEBUGMOD&BUF ) printf("NOTHING TO SEND\n"); + return -1; // on retourne une erreur + } + + if( DEBUGMOD&RVL ) printf("SEND_1\n"); + if( DEBUGMOD&RVL ) revealString(pBuffer); + if( DEBUGMOD&RVL ) printf("SEND_2\n"); + + + /* 3. On retourne le nombre de envoyés */ + return nbSent; +} + + +int sread(int* pSocket, char* pBuffer){ + if( *pSocket == -1 ) return -1; // si SOCKET fermée, on retourne une erreur + + + /* 1. On vide le buffer avant de lire */ + memset(pBuffer, '\0', maxBuffLen); + if( DEBUGMOD&BUF ) printf("READLEN_1: %lu\n", strlen(pBuffer)); + + /* 2. On lit la SOCKET */ + int nbRead = read(*pSocket, pBuffer, maxBuffLen); + if( DEBUGMOD&BUF ) printf("READLEN_3: %d\n", nbRead); + + + /* 3. Si on est déconnecté, on retourne une erreur */ + if( nbRead <= 0 ){ + if( DEBUGMOD&BUF ) printf("NOTHING TO READ\n"); + return -1; // on retourne une erreur + } + + if( DEBUGMOD&RVL ) printf("READ_1\n"); + if( DEBUGMOD&RVL ) revealString(pBuffer); + if( DEBUGMOD&RVL ) printf("READ_2\n"); + + /* 4. On retourne le nombre de caractères lus */ + return nbRead; +} + + +void setSocketTimeout(int* pSocket, const int pSec, const int pUSec){ + /* 1. On créé la structure contenant le timeout */ + struct timeval timeout; + timeout.tv_sec = pSec; + timeout.tv_usec = pUSec; + + setsockopt(*pSocket, SOL_SOCKET, SO_RCVTIMEO, (char*)&timeout, sizeof(struct timeval)); + + if( DEBUGMOD&SCK ) printf("Set socket(%d) timeout to %lus\n", *pSocket, (long unsigned) timeout.tv_sec ); +} + + +void xPrint(char* pPattern, char* pBuffer){ + char tmpBuffer[maxBuffLen]; + strcpy(tmpBuffer, pBuffer); + + + int i; + + // on supprimes les retours à la ligne de la fin + for( i = strlen(tmpBuffer)-1 ; i >= 0 && tmpBuffer[i] != '\0' ; i-- ) + if( tmpBuffer[i] == '\n' || tmpBuffer[i] == '\r' ) // si c'est un retour chariot + tmpBuffer[i] = '\0'; // on efface + else + break; + + printf(pPattern, pBuffer); +} + + +void revealString(char* pString){ + /* 1. On créé une copie de @pString */ + char revealedString[maxBuffLen] = {0}; + + /* 2. On rend visible tous les caractères "invisibles" */ + int i; + for( i = 0 ; i < strlen(pString) && pString[i] != '\0' ; i++ ){ + if( pString[i] == '\r' ){ revealedString[strlen(revealedString)] = '\\'; revealedString[strlen(revealedString)] = 'r'; } + else if( pString[i] == '\n' ){ revealedString[strlen(revealedString)] = '\\'; revealedString[strlen(revealedString)] = 'n'; } + else revealedString[strlen(revealedString)] = pString[i]; + + revealedString[strlen(revealedString)] = '\0'; + } + + /* 3. On affiche la chaîne explicite */ + if( DEBUGMOD&RVL ) printf("[[%s]]\n", revealedString); +} \ No newline at end of file diff --git a/central-manager/dep/utility.h b/central-manager/dep/utility.h new file mode 100644 index 0000000..b6ef223 --- /dev/null +++ b/central-manager/dep/utility.h @@ -0,0 +1,60 @@ +/* Découpe la requête FTP en 2 parties +* +* @pRequest La requête en question +* +* @pCommand Remplissage: commande (1ère partie) +* @pContant Remplissage: contenu (2ème partie) +* +* +*/ +void splitFtpRequest(char* pRequest, char* pCommand, char* pContent); + +/* Découpe la réponse FTP en 2 parties +* +* @pAnswer La réponse en question +* +* @ftpCode Remplissage: code FTP (1ère partie) +* @ftpText Remplissage: text associé (2ème partie) +* +* +*/ +void splitFtpResponse(char* pAnswer, char* ftpCode, char* ftpText); + + +/* Retourne le rang d'un caractère dans une string +* +* @haystack La chaîne dans laquelle rechercher +* @needle Le caractère recherché +* +* @return position Retourne l'index de @needle dans @haystack ou -1 si ne trouve pas +* +*/ +int indexOf(char* haystack, char needle); + +void setSocketTimeout(int* pSocket, const int pSec, const int pUSec); + + +/* read/write socket */ +int swrite(int* pSocket, char* pBuffer); +int sread(int* pSocket, char* pBuffer); + + + +/* Affiche une string en supprimant les retours à la ligne de fin de chaînes +* +* @pPattern Schéma du print (1er arg) +* @pBuffer Buffer en question +* +*/ +void xPrint(char* pPattern, char* pBuffer); + + +/* Révèle les caractères spéciaux d'une string +* +* @pString La string à révéler +* +* +* @print explicitString On affiche la chaîne explicité +* +*/ +void revealString(char* pString); \ No newline at end of file diff --git a/command-terminal/java-code b/command-terminal/java-code new file mode 100644 index 0000000..e69de29 diff --git a/plane/dep/client.c b/plane/dep/client.c new file mode 100644 index 0000000..c6b5acb --- /dev/null +++ b/plane/dep/client.c @@ -0,0 +1,500 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + xdrm-brackets/proxy.ftp.c - xdrm-brackets' git server + + + + + + +
+ + + +
+
+
+
+
+ + + + + + Home + + + Explore + + + + + Help +
+ + + Register + + + + Sign In + +
+ + +
+
+
+
+
+ + + +
+
+ +
+
+
+
+
+ + xdrm-brackets +
/
+ proxy.ftp.c + + +
+ +
+
+ + Watch + + + 1 + +
+
+ + Star + + + 0 + +
+ +
+ + Fork + + + 0 + +
+ +
+
+
+
+
+ + +
+
+ + Files + + + + Issues 0 + + + + + Pull Requests 0 + + + + Commits 23 + + + Releases 0 + + + + Wiki + + + +
+
+
+ +
+ +
+ + + + +

+ No Description + +

+
+ +
+
+
+ + + Branch: + master + + +
+
+
+ + +
+
+
+
+ + + Branches + + + + + Tags + + +
+
+
+ + +
+
+
+ +
+
+ proxy.ftp.c + + + +
/
+ + + dep + + +
/
+ + client.c + + +
+
+
+ +
+ + +
+ + + + +
+
+ +
+

+ + + client.c 3.9KB + + +
+
+ + Permalink + + History + Raw +
+ + + + + + + + +
+ +

+
+
+ + + + + + + + + + +
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. #include "client.h"
    2. 
+
  2. 
+
  3. 
+
  4. int CONNECT_CLIENT(char* serverHost, char* serverPort, int* pSocket){
    5. 
+
  5.     if( DEBUGMOD&HDR ) printf("====== CONNECT_CLIENT(%s, %s, %d) ======\n\n", serverHost, serverPort, *pSocket);
    6. 
+
  6. 
+
  7.     struct addrinfo  hints;           // contiendra le filtre/format
    8. 
+
  8.     struct addrinfo* addrinfo;        // contiendra les infos
    9. 
+
  9.     int    CONNECT;                   // file_desc(s)
    10. 
+
  10.     int GETADDRINFO;                  // contiendra l'erreur ou pas de getaddrinfo()
    11. 
+
  11.     char   BUFFER[maxBuffLen];        // BUFFER de communication
    12. 
+
  12. 
+
  13.     /* [1] On définit le filtre/format
    14. 
+
  14.     =======================================================*/
    15. 
+
  15.     memset(&hints, 0, sizeof(struct addrinfo)); // on vide le filtre
    16. 
+
  16.     hints.ai_family   = AF_UNSPEC;   // Allow IPv4 ou IPv6
    17. 
+
  17.     hints.ai_socktype = SOCK_STREAM; // TCP (SOCK_DGRAM = UDP)
    18. 
+
  18.     hints.ai_flags    = 0;           // non spécifié
    19. 
+
  19.     hints.ai_protocol = 0;           // non spécifié
    20. 
+
  20. 
+
  21.     if( DEBUGMOD&SCK ) printf("============HINTS===========\n");
    22. 
+
  22.     if( DEBUGMOD&SCK ) printf( "AI_FLAGS    = %d\n", hints.ai_flags    ); // int
    23. 
+
  23.     if( DEBUGMOD&SCK ) printf( "AI_FAMILY   = %d\n", hints.ai_family   ); // int
    24. 
+
  24.     if( DEBUGMOD&SCK ) printf( "AI_SOCKTYPE = %d\n", hints.ai_socktype ); // int
    25. 
+
  25.     if( DEBUGMOD&SCK ) printf( "AI_PROTOCOL = %d\n", hints.ai_protocol ); // int
    26. 
+
  26.     if( DEBUGMOD&SCK ) printf( "AI_ADDRLEN  = %d\n", hints.ai_addrlen  ); // int
    27. 
+
  27.     if( DEBUGMOD&SCK ) printf("\n");
    28. 
+
  28. 
+
  29. 
+
  30.     /* [2] On récupère les infos
    31. 
+
  31.     =======================================================*/
    32. 
+
  32.     GETADDRINFO = getaddrinfo(serverHost, serverPort, &hints, &addrinfo);
    33. 
+
  33. 
+
  34.     // si erreur
    35. 
+
  35.     if( GETADDRINFO < 0 ) return -1;
    36. 
+
  36. 
+
  37.     if( DEBUGMOD&SCK ) printf("=============RES============\n");
    38. 
+
  38.     if( DEBUGMOD&SCK ) printf( "AI_FLAGS    = %d\n", addrinfo->ai_flags    ); // int
    39. 
+
  39.     if( DEBUGMOD&SCK ) printf( "AI_FAMILY   = %d\n", addrinfo->ai_family   ); // int
    40. 
+
  40.     if( DEBUGMOD&SCK ) printf( "AI_SOCKTYPE = %d\n", addrinfo->ai_socktype ); // int
    41. 
+
  41.     if( DEBUGMOD&SCK ) printf( "AI_PROTOCOL = %d\n", addrinfo->ai_protocol ); // int
    42. 
+
  42.     if( DEBUGMOD&SCK ) printf( "AI_ADDRLEN  = %d\n", addrinfo->ai_addrlen  ); // int
    43. 
+
  43.     if( DEBUGMOD&SCK ) printf("\n");
    44. 
+
  44. 
+
  45.     /* [3] Création de la socket
    46. 
+
  46.     =======================================================*/
    47. 
+
  47.     *pSocket = socket(addrinfo->ai_family, addrinfo->ai_socktype, 0);
    48. 
+
  48. 
+
  49.     if( DEBUGMOD&SCK ) printf("SOCKET = %d\n", *pSocket);
    50. 
+
  50. 
+
  51.     // si erreur
    52. 
+
  52.     if( *pSocket == -1 ) return -1;
    53. 
+
  53. 
+
  54. 
+
  55.     /* [4] On établit la connection
    56. 
+
  56.     =======================================================*/
    57. 
+
  57.     CONNECT = connect(
    58. 
+
  58.         *pSocket,
    59. 
+
  59.         addrinfo->ai_addr,
    60. 
+
  60.         addrinfo->ai_addrlen
    61. 
+
  61.     );
    62. 
+
  62. 
+
  63.     if( DEBUGMOD&SCK ) printf("CONNECT = %d\n", CONNECT);
    64. 
+
  64. 
+
  65.     // si erreur
    66. 
+
  66.     if( CONNECT == -1 ) return -1;
    67. 
+
  67. 
+
  68.     // on a plus besoin des infos de l'adresse
    69. 
+
  69.     freeaddrinfo(addrinfo);
    70. 
+
  70. 
+
  71. 
+
  72.     /* [5] On retourne la SOCKET
    73. 
+
  73.     =======================================================*/
    74. 
+
  74.     return *pSocket;
    75. 
+
  75. }
    76. 
+
  76. 
+
  77. 
+
  78. 
+
  79. 
+
  80. 
+
  81. 
+
  82. int CLIENT_SEND(int* pSocket, char* pRequest, char** pAnswer){
    83. 
+
  83.     if( DEBUGMOD&HDR ) printf("====== CLIENT_SEND(%d, %s, %s) ======\n\n", *pSocket, pRequest, *pAnswer);
    84. 
+
  84.     char BUFFER[maxBuffLen] = {0};
    85. 
+
  85. 
+
  86.     /* [1] On écrit sur la socket
    87. 
+
  87.     =======================================================*/
    88. 
+
  88.     int nbSend = swrite(pSocket, pRequest);
    89. 
+
  89. 
+
  90.     if( DEBUGMOD&BUF ) printf("nbSend:     %d\n", nbSend);
    91. 
+
  91.     if( DEBUGMOD&BUF ) printf("Message:    %s\n", pRequest);
    92. 
+
  92. 
+
  93.     // si pas tout envoyé
    94. 
+
  94.     if( strlen(pRequest) != nbSend ) return -1;
    95. 
+
  95. 
+
  96.     /* [2] On attends et lit la réponse
    97. 
+
  97.     =======================================================*/
    98. 
+
  98.     int nbRecup = WAIT_SOCKET_UPDATE(pSocket, BUFFER);
    99. 
+
  99. 
+
  100.     /* [3] On retourne la réponse par référence
    101. 
+
  101.     =======================================================*/
    102. 
+
  102.     *pAnswer = malloc( maxBuffLen );
    103. 
+
  103.     strcpy(*pAnswer, BUFFER);
    104. 
+
  104. 
+
  105.     if( DEBUGMOD&BUF ) printf("nbReceived: %d\n", nbRecup);
    106. 
+
  106.     if( DEBUGMOD&BUF ) printf("Message:    %s\n", *pAnswer);
    107. 
+
  107. }
    108. 
+
+ +
+
+
+ + + + +
+
+ +
+ + + + + + + + + + + + + + + + + diff --git a/plane/dep/client.h b/plane/dep/client.h new file mode 100644 index 0000000..e1b95a4 --- /dev/null +++ b/plane/dep/client.h @@ -0,0 +1,433 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + xdrm-brackets/proxy.ftp.c - xdrm-brackets' git server + + + + + + +
+ + + +
+
+
+
+
+ + + + + + Home + + + Explore + + + + + Help +
+ + + Register + + + + Sign In + +
+ + +
+
+
+
+
+ + + +
+
+ +
+
+
+
+
+ + xdrm-brackets +
/
+ proxy.ftp.c + + +
+ +
+
+ + Watch + + + 1 + +
+
+ + Star + + + 0 + +
+ +
+ + Fork + + + 0 + +
+ +
+
+
+
+
+ + +
+
+ + Files + + + + Issues 0 + + + + + Pull Requests 0 + + + + Commits 23 + + + Releases 0 + + + + Wiki + + + +
+
+
+ +
+ +
+ + + + +

+ No Description + +

+
+ +
+
+
+ + + Branch: + master + + +
+
+
+ + +
+
+
+
+ + + Branches + + + + + Tags + + +
+
+
+ + +
+
+
+ +
+
+ proxy.ftp.c + + + +
/
+ + + dep + + +
/
+ + client.h + + +
+
+
+ +
+ + +
+ + + + +
+
+ +
+

+ + + client.h 1.0KB + + +
+
+ + Permalink + + History + Raw +
+ + + + + + + + +
+ +

+
+
+ + + + + + + + + + +
12345678910111213141516171819202122232425262728293031323334353637383940
  1. /* Envoi d'une requête à un serveur et réception de la réponse
    2. 
+
  2. *
    3. 
+
  3. * @serverHost<char*>				Nom de l'hôte distant  (server)
    4. 
+
  4. * @serverPort<char*>				Numéro du port distant (server)
    5. 
+
  5. * @pSocket<int*>					Pointeur sur la requête à créer
    6. 
+
  6. *
    7. 
+
  7. *
    8. 
+
  8. * @return error<int>				retourne -1 en cas d'erreur, sinon la SOCKET
    9. 
+
  9. *
    10. 
+
  10. *
    11. 
+
  11. * 
    12. 
+
  12. * @history
    13. 
+
  13. *  [1] On définit le filtre/format
    14. 
+
  14. *  [2] On récupère les infos
    15. 
+
  15. *  [3] Création de la socket
    16. 
+
  16. *  [4] On établit la connection
    17. 
+
  17. *  [5] On retourne la SOCKET
    18. 
+
  18. *  
    19. 
+
  19. */
    20. 
+
  20. int CONNECT_CLIENT(char* serverHost, char* serverPort, int* pSocket);
    21. 
+
  21. 
+
  22. 
+
  23. 
+
  24. /* Envoi d'une requête vers une SOCKET et récupère la réponse
    25. 
+
  25. *
    26. 
+
  26. * @pSocket<int*>			Pointeur sur la SOCKET en question
    27. 
+
  27. * @pRequest<char*>			Requête à lui envoyer (swrite)
    28. 
+
  28. * @pAnswer<char**>			Réponse qui se lira après la requête (sread)
    29. 
+
  29. *
    30. 
+
  30. * @return error<int>		Retourne -1 en cas d'erreur
    31. 
+
  31. *
    32. 
+
  32. *
    33. 
+
  33. *
    34. 
+
  34. * @history
    35. 
+
  35. *  [1] On écrit sur la socket
    36. 
+
  36. *  [2] On attends et lit la réponse
    37. 
+
  37. *  [3] On retourne la réponse par référence
    38. 
+
  38. * 
    39. 
+
  39. */
    40. 
+
  40. int CLIENT_SEND(int* pSocket, char* pRequest, char** pAnswer);
    41. 
+
+ +
+
+
+ + + + +
+
+ +
+ + + + + + + + + + + + + + + + + diff --git a/plane/dep/utility.c b/plane/dep/utility.c new file mode 100644 index 0000000..faecd69 --- /dev/null +++ b/plane/dep/utility.c @@ -0,0 +1,169 @@ +#include "utility.h" + +void splitFtpRequest(char* pRequest, char* pCommand, char* pContent){ + /* [1] Vérification du format + ===========================================*/ + int firstSpaceIndex = indexOf(pRequest, ' '); + + if( firstSpaceIndex != 3 && firstSpaceIndex != 4){ // contient aucun espace en position 3 ou 4, on quitte + strcpy(pCommand, "ERROR"); + strcpy(pContent, ""); + return; + } + + + /* [2] Séparation des 2 parties + ===========================================*/ + int i; + + for( i = 0 ; i < strlen(pRequest) && pRequest[i] != '\0' ; i++ ){ + + if( i < firstSpaceIndex ) // première partie (pCommand) + strcat( pCommand, (char[2]){(char) pRequest[i], '\0'}); + if( i > firstSpaceIndex ) // seconde partie (pContent) + strcat( pContent, (char[2]){(char) pRequest[i], '\0'}); + } + + +} + + + + +void splitFtpResponse(char* pAnswer, char* ftpCode, char* ftpText){ + /* [1] Vérification du format + ===========================================*/ + int codeLength = 3; // taille du code + + /* [2] Séparation des 2 parties + ===========================================*/ + int i; + + for( i = 0 ; i < strlen(pAnswer) && pAnswer[i] != '\0' ; i++ ){ + + if( i < codeLength ) // première partie (ftpCode) + strcat(ftpCode, (char[2]){(char)pAnswer[i], '\0' }); + if( i > codeLength ) // seconde partie (ftpText) + strcat(ftpText, (char[2]){(char)pAnswer[i], '\0' }); + } + + +} + + + + + +int indexOf(char* haystack, char needle){ + int i; + + for( i = 0 ; i < strlen(haystack) && haystack[i] != '\0' ; i++ ) + if( haystack[i] == needle ) // si on trouve le caractère + return i; + + return -1; + +} + + +int swrite(int* pSocket, char* pBuffer){ + if( *pSocket == -1 ) return -1; // si SOCKET fermée, on retourne une erreur + if( strlen(pBuffer) == 0 ) return 0; // si on a rien à écrire, on n'écrit rien :p + + + /* 1. On écrit sur la SOCKET */ + if( DEBUGMOD&BUF ) printf("SENDLEN_1: %lu\n", strlen(pBuffer)); + int nbSent = write(*pSocket, pBuffer, strlen(pBuffer)); + if( DEBUGMOD&BUF ) printf("SENDLEN_2: %d\n", nbSent); + + /* 2. Si on est déconnecté, on retourne une erreur */ + if( nbSent <= 0 ){ + if( DEBUGMOD&BUF ) printf("NOTHING TO SEND\n"); + return -1; // on retourne une erreur + } + + if( DEBUGMOD&RVL ) printf("SEND_1\n"); + if( DEBUGMOD&RVL ) revealString(pBuffer); + if( DEBUGMOD&RVL ) printf("SEND_2\n"); + + + /* 3. On retourne le nombre de envoyés */ + return nbSent; +} + + +int sread(int* pSocket, char* pBuffer){ + if( *pSocket == -1 ) return -1; // si SOCKET fermée, on retourne une erreur + + + /* 1. On vide le buffer avant de lire */ + memset(pBuffer, '\0', maxBuffLen); + if( DEBUGMOD&BUF ) printf("READLEN_1: %lu\n", strlen(pBuffer)); + + /* 2. On lit la SOCKET */ + int nbRead = read(*pSocket, pBuffer, maxBuffLen); + if( DEBUGMOD&BUF ) printf("READLEN_3: %d\n", nbRead); + + + /* 3. Si on est déconnecté, on retourne une erreur */ + if( nbRead <= 0 ){ + if( DEBUGMOD&BUF ) printf("NOTHING TO READ\n"); + return -1; // on retourne une erreur + } + + if( DEBUGMOD&RVL ) printf("READ_1\n"); + if( DEBUGMOD&RVL ) revealString(pBuffer); + if( DEBUGMOD&RVL ) printf("READ_2\n"); + + /* 4. On retourne le nombre de caractères lus */ + return nbRead; +} + + +void setSocketTimeout(int* pSocket, const int pSec, const int pUSec){ + /* 1. On créé la structure contenant le timeout */ + struct timeval timeout; + timeout.tv_sec = pSec; + timeout.tv_usec = pUSec; + + setsockopt(*pSocket, SOL_SOCKET, SO_RCVTIMEO, (char*)&timeout, sizeof(struct timeval)); + + if( DEBUGMOD&SCK ) printf("Set socket(%d) timeout to %lus\n", *pSocket, (long unsigned) timeout.tv_sec ); +} + + +void xPrint(char* pPattern, char* pBuffer){ + char tmpBuffer[maxBuffLen]; + strcpy(tmpBuffer, pBuffer); + + + int i; + + // on supprimes les retours à la ligne de la fin + for( i = strlen(tmpBuffer)-1 ; i >= 0 && tmpBuffer[i] != '\0' ; i-- ) + if( tmpBuffer[i] == '\n' || tmpBuffer[i] == '\r' ) // si c'est un retour chariot + tmpBuffer[i] = '\0'; // on efface + else + break; + + printf(pPattern, pBuffer); +} + + +void revealString(char* pString){ + /* 1. On créé une copie de @pString */ + char revealedString[maxBuffLen] = {0}; + + /* 2. On rend visible tous les caractères "invisibles" */ + int i; + for( i = 0 ; i < strlen(pString) && pString[i] != '\0' ; i++ ){ + if( pString[i] == '\r' ){ revealedString[strlen(revealedString)] = '\\'; revealedString[strlen(revealedString)] = 'r'; } + else if( pString[i] == '\n' ){ revealedString[strlen(revealedString)] = '\\'; revealedString[strlen(revealedString)] = 'n'; } + else revealedString[strlen(revealedString)] = pString[i]; + + revealedString[strlen(revealedString)] = '\0'; + } + + /* 3. On affiche la chaîne explicite */ + if( DEBUGMOD&RVL ) printf("[[%s]]\n", revealedString); +} \ No newline at end of file diff --git a/plane/dep/utility.h b/plane/dep/utility.h new file mode 100644 index 0000000..b6ef223 --- /dev/null +++ b/plane/dep/utility.h @@ -0,0 +1,60 @@ +/* Découpe la requête FTP en 2 parties +* +* @pRequest La requête en question +* +* @pCommand Remplissage: commande (1ère partie) +* @pContant Remplissage: contenu (2ème partie) +* +* +*/ +void splitFtpRequest(char* pRequest, char* pCommand, char* pContent); + +/* Découpe la réponse FTP en 2 parties +* +* @pAnswer La réponse en question +* +* @ftpCode Remplissage: code FTP (1ère partie) +* @ftpText Remplissage: text associé (2ème partie) +* +* +*/ +void splitFtpResponse(char* pAnswer, char* ftpCode, char* ftpText); + + +/* Retourne le rang d'un caractère dans une string +* +* @haystack La chaîne dans laquelle rechercher +* @needle Le caractère recherché +* +* @return position Retourne l'index de @needle dans @haystack ou -1 si ne trouve pas +* +*/ +int indexOf(char* haystack, char needle); + +void setSocketTimeout(int* pSocket, const int pSec, const int pUSec); + + +/* read/write socket */ +int swrite(int* pSocket, char* pBuffer); +int sread(int* pSocket, char* pBuffer); + + + +/* Affiche une string en supprimant les retours à la ligne de fin de chaînes +* +* @pPattern Schéma du print (1er arg) +* @pBuffer Buffer en question +* +*/ +void xPrint(char* pPattern, char* pBuffer); + + +/* Révèle les caractères spéciaux d'une string +* +* @pString La string à révéler +* +* +* @print explicitString On affiche la chaîne explicité +* +*/ +void revealString(char* pString); \ No newline at end of file diff --git a/plane/plane.c b/plane/plane.c new file mode 100644 index 0000000..e69de29 diff --git a/plane/plane.h b/plane/plane.h new file mode 100644 index 0000000..e69de29 diff --git a/viewer-terminal/java-code b/viewer-terminal/java-code new file mode 100644 index 0000000..e69de29