proxy5

#include  <stdio.h>
#include  <stdlib.h>
#include  <sys/socket.h>
#include  <netdb.h>
#include  <string.h>
#include <unistd.h>
#include  <stdbool.h>

#define PROXYADDR "localhost"        // Définition de l'adresse IP d'écoute
#define PROXYPORT "0"                // Définition du port d'écoute,
                                    // si 0 port choisi dynamiquement
#define LISTENLEN 1                 // Taille du tampon de demande de connexion
#define MAXBUFFERLEN 1024
#define MAXHOSTLEN 64
#define MAXPORTLEN 6
#define SERVPORT "21"
int main(){
	int ecode;                       // Code retour des fonctions
	int descSock;                  // Descripteur de la socket
	char proxyAddr[MAXHOSTLEN];     // Adresse du serveur
	char proxyPort[MAXPORTLEN];     // Port du server
	int descSockRDV;                 // Descripteur de socket de rendez-vous
	int descSockCOM;                 // Descripteur de socket de communication
	struct addrinfo hints;           // Contrôle la fonction getaddrinfo
	struct addrinfo *res, *resPtr;            // Contient le résultat de la fonction getaddrinfo
	struct sockaddr_storage myinfo;  // Informations sur la connexion de RDV
	struct sockaddr_storage from;    // Informations sur le client connecté
	socklen_t len;                   // Variable utilisée pour stocker les
				                        // longueurs des structures de socket
	char buffer[MAXBUFFERLEN];       // Tampon de communication entre le client et le serveur
	char server_name [MAXHOSTLEN] ;
	char password [2048] ;
	char login [MAXBUFFERLEN] ;
	bool isConnected = false;      // booléen indiquant que l'on est bien connecté


	// Publication de la socket au niveau du système
	// Assignation d'une adresse IP et un numéro de port
	// Mise à zéro de hints
	memset(&hints, 0, sizeof(hints));
	// Initailisation de hints
	hints.ai_flags = AI_PASSIVE;      // mode serveur, nous allons utiliser la fonction bind
	hints.ai_socktype = SOCK_STREAM;  // TCP
	hints.ai_family = AF_INET;      // les adresses IPv4 et IPv6 seront présentées par
				                         // la fonction getaddrinfo

	// Récupération des informations du serveur
	ecode = getaddrinfo(PROXYADDR, PROXYPORT, &hints, &res);
	if (ecode) {
		fprintf(stderr,"getaddrinfo: %s\n", gai_strerror(ecode));
		exit(1);
	}

	//Création de la socket IPv4/TCP
	descSockRDV = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
	if (descSockRDV == -1) {
		perror("Erreur creation socket");
		exit(4);
	}

	// Publication de la socket
	ecode = bind(descSockRDV, res->ai_addr, res->ai_addrlen);
	if (ecode == -1) {
		perror("Erreur liaison de la socket de RDV");
		exit(3);
	}
	// Nous n'avons plus besoin de cette liste chainée addrinfo
	freeaddrinfo(res);
	// Récuppération du nom de la machine et du numéro de port pour affichage à l'écran

	len=sizeof(struct sockaddr_storage);
	ecode=getsockname(descSockRDV, (struct sockaddr *) &myinfo, &len);
	if (ecode == -1)
	{
		perror("SERVEUR: getsockname");
		exit(4);
	}
	ecode = getnameinfo((struct sockaddr*)&myinfo, sizeof(myinfo), proxyAddr,MAXHOSTLEN,
                         proxyPort, MAXPORTLEN, NI_NUMERICHOST | NI_NUMERICSERV);
	if (ecode != 0) {
		fprintf(stderr, "error in getnameinfo: %s\n", gai_strerror(ecode));
		exit(4);
	}
	printf("L'adresse d'ecoute est: %s\n", proxyAddr);
	printf("Le port d'ecoute est: %s\n", proxyPort);
	// Definition de la taille du tampon contenant les demandes de connexion
	ecode = listen(descSockRDV, LISTENLEN);
	if (ecode == -1) {
		perror("Erreur initialisation buffer d'écoute");
		exit(5);
	}

	len = sizeof(struct sockaddr_storage);
	// Attente connexion du client
	// Lorsque demande de connexion, creation d'une socket de communication avec le client
	descSockCOM = accept(descSockRDV, (struct sockaddr *) &from, &len);
	if (descSockCOM == -1){
		perror("Erreur accept\n");
		exit(6);
	}
	// Echange de données avec le client connecté
	strcpy(buffer, "220 PROXY FTP READY\n");
	write(descSockCOM, buffer, strlen(buffer));

	//Reception commande utilisateur type : USER login@serveur
	ecode = read(descSockCOM, buffer, MAXBUFFERLEN);
	if (ecode == -1) {perror("Problème de lecture\n"); exit(3);}
	buffer[ecode] = '\0';
	printf("MESSAGE RECU DU CLIENT: \"%s\".\n",buffer);
	sscanf(buffer,"%[^@]@%s",login,server_name);
	printf("NOM SERVEUR : \"%s\".\n",server_name);


			// CONNEXION SERVEUR

	   // Initailisation de hints
	memset(&hints, 0, sizeof(hints));
	hints.ai_socktype = SOCK_STREAM;  // TCP
	hints.ai_family = AF_UNSPEC;      // les adresses IPv4 et IPv6 seront présentées par
				                          // la fonction getaddrinfo

	//Récupération des informations sur le serveur
	ecode = getaddrinfo(server_name,SERVPORT,&hints,&res);
	if (ecode){
		fprintf(stderr,"getaddrinfo: %s\n", gai_strerror(ecode));
		exit(1);
	}

	resPtr = res;

	while(!isConnected && resPtr!=NULL){

		//Création de la socket IPv4/TCP
		descSock = socket(resPtr->ai_family, resPtr->ai_socktype, resPtr->ai_protocol);
		if (descSock == -1) {
			perror("Erreur creation socket");
			exit(2);
		}

  		//Connexion au serveur
		ecode = connect(descSock, resPtr->ai_addr, resPtr->ai_addrlen);
		if (ecode == -1) {
			resPtr = resPtr->ai_next;
			close(descSock);
		}
		// On a pu se connecté
		else isConnected = true;
	}
	freeaddrinfo(res);
	if (!isConnected){
		perror("Connexion impossible");
		exit(2);
	}
		//Echange de donneés avec le serveur
	ecode = read(descSock, buffer, MAXBUFFERLEN);
	if (ecode == -1) {perror("Problème de lecture\n"); exit(3);}
	buffer[ecode] = '\0';
	printf("MESSAGE RECU DU SERVEUR: \"%s\".\n",buffer);

	strcat(login,"\n");
	printf("MESSAGE RECU DU SERVEUR: \"%s\".\n",buffer);
	write(descSock, login, strlen(login));

		//Echange de données avec le serveur
	ecode = read(descSock, buffer, MAXBUFFERLEN);
	if (ecode == -1) {perror("Problème de lecture\n"); exit(3);}
	buffer[ecode] = '\0';
	printf("MESSAGE RECU DU SERVEUR: \"%s\".\n",buffer);

	// demande mot de passe au client par le serveur
	write(descSockCOM, buffer, strlen(buffer));

	//Reception commande utilisateur type : USER login@serveur
	ecode = read(descSockCOM, buffer, MAXBUFFERLEN);
	if (ecode == -1) {perror("Problème de lecture\n"); exit(3);}
	buffer[ecode] = '\0';
	printf("MESSAGE RECU DU CLIENT: \"%s\".\n",buffer);
	strcpy(password,buffer);

	// demande mot de passe au client par le serveur
	write(descSock, password, strlen(password));

		//Echange de données avec le serveur
	ecode = read(descSock, buffer, MAXBUFFERLEN);
	if (ecode == -1) {perror("Problème de lecture\n"); exit(3);}
	buffer[ecode] = '\0';
	printf("MESSAGE RECU DU SERVEUR: \"%s\".\n",buffer);

}