#include <unistd.h>
#include <errno.h>
#include <sys/wait.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>

# define TAILLE_BUF 80 // 80 = taille d'une ligne


void fermeTubesPere(int N, int tubes[N][2]) {
    int i;
    for (i=0 ; i<N ; i++) {
        close(tubes[i][0]);
    }
}

void fermeTubesFils(int N, int tubes[N][2]) {
    int i;
    for (i=0 ; i<N ; i++) {
        close(tubes[i][1]);
    }
}

void fermeAutresTubes(int N, int tubes[N][2], int numTube) {
    int i;
    for (i=0 ; i<N ; i++) {
        if(i != numTube) {
            close(tubes[i][0]);
        }
    }
}

void fermeTubes(int N, int tubes[N][2]) {
    int i;
    for (i=0 ; i<N ; i++) {
        close(tubes[i][0]);
        close(tubes[i][1]);
    }
}

void codeDuFils(int N, int tubes[N][2], int numFils) {
    char buffer[TAILLE_BUF];
    unsigned int cpt = 0;
    // for(i=0;)
    while (read(tubes[numFils][0], buffer, TAILLE_BUF)) {
        cpt++;
        printf("\t\e[1;33mFils n° %d : %d : lecture de\e[1;31m %s\e[0m\n", numFils, cpt, buffer);
    }
    printf("Fils se termine sur fin de lecteure du tube\n");
    fermeTubesFils(N, tubes);
    fermeAutresTubes(N, tubes, numFils);
    exit(0);
}

void codeDuPere(int N, int tubes[N][2], int i) {
    char buffer[TAILLE_BUF];

    while(fgets(buffer, TAILLE_BUF, stdin) != NULL){
            write(tubes[i][1], buffer, TAILLE_BUF);
    }

    fermeTubes(N, tubes);
    wait(NULL);
    printf("Pere se termine apès son fils.\n");
    exit(EXIT_SUCCESS);
}

int main(int argc, char *argv[])
{
    int i, etat, N;
    pid_t pid;
    int tubes[100][2];
    int *tmp;

    if (argc!=2) {
        fputs("Donner un arg entier\n", stderr);
        exit(1);
    }

    N=atoi(argv[1]); 
    if (N <= 0 || N > 100) {
        fprintf(stderr, "N doit être un entier positif ou inférieur à 100.\n");
        exit(1);
    }
    if(pipe(tubes[0])== -1) { 
        perror(" pipe "); 
        exit(errno); 
    }
    tmp = (int*)malloc(sizeof(int) * 2 * N);

    if(tmp == NULL){
        printf("Erreur Malloc");
        exit(EXIT_FAILURE);
    }

    /* le pere va creer N fils */
    for (i=0 ; i<N ; i++) {
        if((pid=fork())==-1) {
            perror("pb fork");
            exit(errno);
        }
        else if (pid==0) {
            fermeTubesFils(i, tubes);
            codeDuFils(N, tubes, i);
            exit(0); 
            /* le ieme fils ne doit pas retourner dans la boucle */
        }
    }

    fermeTubesPere(N, tubes);
    codeDuPere(N, tubes, 3);
    return 0;
}