42/42_INT_12_webserv
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cgi exec compare with file method

Browse Source
This commit is contained in:
hugogogo
2022-08-08 13:20:06 +02:00
parent 78c3ffa456
commit da1f4b6e37
5 changed files with 97 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
srcs/webserv/cgi_script.cpp
View File

@@ -4,9 +4,9 @@
bool Webserv::_is_cgi(Client *client)
{
// TODO see how it works with config
if (client->fill_script_path("php-cgi"))
if (client->fill_script_path("/cgi-bin/php-cgi"))
return true;
if (client->fill_script_path("cgi_cpp.cgi"))
if (client->fill_script_path("/cgi-bin/cgi_cpp.cgi"))
return true;
return false;
}
@@ -18,6 +18,10 @@ void Webserv::_exec_cgi(Client *client)
env = _set_env(client);
_exec_script(client, env);
// _construct_response(client);
for (size_t i = 0; env[i]; i++)
delete[] env[i];
delete[] env;
}
char* Webserv::_dup_env(std::string var, std::string val = "")
@@ -54,8 +58,7 @@ char** Webserv::_set_env(Client *client)
env[9] = _dup_env("REMOTE_IDENT"); // authentification not supported
env[10] = _dup_env("REMOTE_USER"); // authentification not supported
env[11] = _dup_env("REQUEST_METHOD" , client->get_rq_method_str());
env[12] = _dup_env("SCRIPT_NAME"); // TODO: define (https://www.rfc-editor.org/rfc/rfc3875#section-4.1.13
// ,https://www.rfc-editor.org/rfc/rfc3875#section-8.2)
env[12] = _dup_env("SCRIPT_NAME" , client->get_rq_script_path());
env[13] = _dup_env("SERVER_NAME" , client->get_rq_hostname());
env[14] = _dup_env("SERVER_PORT" , client->get_rq_port());
env[15] = _dup_env("SERVER_PROTOCOL" , client->get_rq_version());
@@ -70,45 +73,82 @@ void Webserv::_exec_script(Client *client, char **env)
{
#define RD 0
#define WR 1
#define BUF_SIZE 10
#define CGI_BUF_SIZE 10
char buf[BUF_SIZE];
int fd_in[2];
int fd_out[2];
char * const * nll = NULL;
std::string response;
std::string body = client->get_rq_body();
/*1*/ #define FD_WR_TO_CHLD fd_in[WR]
/* */ #define FD_WR_TO_PRNT fd_out[WR]
/* */ #define FD_RD_FR_CHLD fd_out[RD]
/* */ #define FD_RD_FR_PRNT fd_in[RD]
/*2*/// #define FD_WR_TO_CHLD fdIn
/* */// #define FD_WR_TO_PRNT fdOut
/* */// #define FD_RD_FR_CHLD fdOut
/* */// #define FD_RD_FR_PRNT fdIn
pipe(fd_in);
pipe(fd_out);
if (fork() == 0)
pid_t pid;
char buf[CGI_BUF_SIZE]; // WIP define buffer
char * const * nll = NULL;
std::string response;
std::string body = client->get_rq_body();
/*1*/ int fd_in[2];
/* */ int fd_out[2];
/*2*/// FILE *fIn;
/* */// FILE *fOut;
/* */// long fdIn;
/* */// long fdOut;
/*1*/ pipe(fd_in);
/* */ pipe(fd_out);
/*2*/// fIn = tmpfile();
/* */// fOut = tmpfile();
/* */// fdIn = fileno(fIn);
/* */// fdOut = fileno(fOut);
pid = fork();
if (pid == -1)
std::cerr << "fork crashed" << std::endl;
else if (pid == 0)
{
close(fd_in[WR]);
close(fd_out[RD]);
dup2(fd_in[RD], STDIN_FILENO);
dup2(fd_out[WR], STDOUT_FILENO);
/*1*/ close(FD_WR_TO_CHLD);
/* */ close(FD_RD_FR_CHLD);
/*2*/
dup2(FD_RD_FR_PRNT, STDIN_FILENO);
dup2(FD_WR_TO_PRNT, STDOUT_FILENO);
execve(client->get_rq_script_path().c_str(), nll, env);
std::cerr << "execve crashed\n";
std::cerr << "execve crashed.\n";
}
else
{
close(fd_in[RD]);
close(fd_out[WR]);
// write to stdin of child programm
write(fd_in[WR], body.c_str(), body.size());
close(fd_in[WR]);
waitpid(-1, NULL, 0);
/*1*/ close(FD_RD_FR_PRNT);
/* */ close(FD_WR_TO_PRNT);
/*2*/
// read stdout of child programm
memset(buf, '\0', BUF_SIZE);
while (read(fd_out[RD], buf, BUF_SIZE) > 0)
write(FD_WR_TO_CHLD, body.c_str(), body.size());
close(FD_WR_TO_CHLD);
waitpid(-1, NULL, 0);
/*1*/
/*2*/// lseek(fdOut, 0, SEEK_SET);
memset(buf, '\0', CGI_BUF_SIZE);
while (read(FD_RD_FR_CHLD, buf, CGI_BUF_SIZE - 1) > 0)
{
response += buf;
memset(buf, '\0', BUF_SIZE);
memset(buf, '\0', CGI_BUF_SIZE);
}
}
if (response.empty())
response += "Status: 500\r\n\r\n";
response = "Status: 500\r\n\r\n";
/*1*/
/*2*/// fclose(fIn);
/* */// fclose(fOut);
/* */// close(fdIn);
/* */// close(fdOut);
// DEBUG
std::cout << "\n______response________\n" << response << "\n________________________\n";
// TODO: see how this must be handled
client->response += response;
}