/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   pipe.c                                             :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: apommier <apommier@student.42.fr>          +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2022/04/02 18:51:31 by apommier          #+#    #+#             */
/*   Updated: 2022/04/18 03:16:38 by apommier         ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */

#include "../../includes/minishell.h"


void	close_pipe(t_cmd *cmd)
{
	int i;

	i = 0;
	close(0);
	while (cmd->s_cmds[i])
	{
		close(cmd->s_cmds[i]->fd[0]);
		close(cmd->s_cmds[i]->fd[1]);
		i++;
	}
}

int	wait_exit(t_cmd *cmd)
{
	int i;
	int	ret;
	int	exit_pid;
	int	status;

	i = 0;
	ret = 0;
	exit_pid = 1;
	while (exit_pid > 0)
    {
        i = 0;
		exit_pid = wait(&status);
        while (exit_pid != -1 && cmd->s_cmds[i])
        {
            if (exit_pid == cmd->s_cmds[i]->child)
            {
				close(cmd->s_cmds[i]->fd[0]);
				close(cmd->s_cmds[i]->fd[1]);
			if (WIFEXITED(status))
			{
				//printf("return normally cmd = -%s-\n", cmd->s_cmds[i]->cmd);
				//if (!cmd->err_var)
				cmd->err_var = WEXITSTATUS(status);
				//printf("err_var= %d\n", cmd->err_var);
				//printf("code= %d\n", cmd->err_var);
			}
			else if (WIFSIGNALED(status))
			{
				//printf("return by signal cmd = -%s-\n", cmd->s_cmds[i]->cmd);
				if (WTERMSIG(status) != 13)
					cmd->err_var = WTERMSIG(status);
				//if (cmd->err_var == 2)
				ft_putstr_fd("\b\b\b\b\b", 1);
			}
			}
			i++;
        }
    }
	return (ret);
}

void    exec_cmd(t_cmd *cmd, char **env, int *fdpipe)
{
	cmd->current_s_cmd->child = fork();
	if (cmd->current_s_cmd->child == 0)
	{
		if (fdpipe)
			close(fdpipe[0]);
		dup2(cmd->current_s_cmd->fd[0], 0);
		dup2(cmd->current_s_cmd->fd[1], 1);
		close(cmd->current_s_cmd->fd[0]);
		close(cmd->current_s_cmd->fd[1]);
		if (is_builtin(cmd->current_s_cmd->cmd))
		{
			call_builtin(cmd);
			exit(0);
		}
		if (!cmd->current_s_cmd->cmd || access(cmd->current_s_cmd->cmd, F_OK))
		{
			ft_putstr_fd("Minishell: command not found: ", 2);
			ft_putstr_fd(cmd->current_s_cmd->cmd + 1, 2);
			ft_putstr_fd("\n", 2);
			exit(127);
		}
        if (-1 == execve(cmd->current_s_cmd->cmd, cmd->current_s_cmd->args, env))
			ft_putstr_fd("Minishell: exec error\n", 2);
        exit(126);
    }
	else if (!cmd->current_s_cmd->cmd || access(cmd->current_s_cmd->cmd, F_OK))
		cmd->err_var = 127;
	else
		cmd->err_var = 126;
	/*if (cmd->current_s_cmd->child)
	{
		if (cmd->current_s_cmd->infile)
			close(cmd->current_s_cmd->infile);
		if (cmd->current_s_cmd->outfile)
			close(cmd->current_s_cmd->outfile);
	}*/
}

void	execute(t_cmd *cmd, char **env)
{
	int fdpipe[2];
	int fdout;
	int fdin;
	int tmpin = -1;
	int tmpout = -1;
	int i;



	i = 0;
	fdpipe[1] = -1;
	tmpin = dup(0);
	tmpout = dup(1);
	cmd->tmpin = tmpin;
	cmd->tmpout = tmpout;
	//printf("infile= %s\n", cmd->current_s_cmd->infile);
	if (cmd->current_s_cmd->infile)
	{
		fdin = open(cmd->current_s_cmd->infile, O_RDWR);
		if (fdin < 0)
			printf("Minishell: open : bad file descriptor\n");
	}
	else
		fdin = dup(tmpin);
	while(cmd->current_s_cmd)
	{	
		if (i > 0 )
			close(fdout);
		cmd->current_s_cmd->child = 1;
		fdout = -1;
		if (i > 0 && cmd->current_s_cmd->infile)
		{
			close(fdin);
			fdin = open(cmd->current_s_cmd->infile, O_RDWR);
			if (fdin < 0)
				printf("Minishell: open : bad file descriptor\n");
		}
		if (i == cmd->nb_s_cmd - 1)
		{
			cmd->current_s_cmd->last = 1;
			if (cmd->current_s_cmd->outfile)
				fdout = open(cmd->current_s_cmd->outfile, O_RDWR | O_CREAT | O_APPEND, 0666);
			else
				fdout = dup(tmpout);
			cmd->current_s_cmd->fd[0] = fdin;
			cmd->current_s_cmd->fd[1] = fdout;
			if (i == 0 && is_builtin(cmd->current_s_cmd->cmd))
				call_builtin(cmd);
			else
				exec_cmd(cmd, env, 0);
		}
		else 
		{
			cmd->current_s_cmd->last = 0;
			pipe(fdpipe);
			cmd->current_s_cmd->fd[0] = fdin;
			if (cmd->current_s_cmd->outfile)
			{
				fdout = open(cmd->current_s_cmd->outfile, O_RDWR | O_CREAT | O_APPEND, 0666);
				cmd->current_s_cmd->fd[1] = fdout;
			}
			else
				cmd->current_s_cmd->fd[1] = fdpipe[1];
			fdin=fdpipe[0];
			exec_cmd(cmd, env, fdpipe);
			close(cmd->current_s_cmd->fd[0]);
			//close(fdin); //bad thing
		}
		if (fdpipe[1] != -1)
			close(fdpipe[1]);
		i++;
		cmd->current_s_cmd = cmd->s_cmds[i];
		//printf("cmd->err_var= %d\n", cmd->err_var);
	}
	close_pipe(cmd);
	dup2(tmpin, 0);
	dup2(tmpout, 1);
	close(tmpin);
	close(tmpout);
	wait_exit(cmd);
	//close(tmpin);
	//tmpin = -1;
	//close(tmpout);
	//tmpout = -1;
}