#endif // DEBUG
}
-HTTPMessage::HTTPMessage(const string& version):
- version(version) {
+HTTPMessage::HTTPMessage(const string& _body, const string& _version):
+ version(_version) {
#ifdef DEBUG
- cerr << __FILE__ << ": version = " << version << endl;
-#endif // DEBUG
-}
-
-/*
-HTTPMessage::HTTPMessage(const string& _body,
- const string& http_version):
- http_version(http_version) {
-#ifdef DEBUG
- cerr << __FILE__ << ": http_version = " << http_version
- << " | body = " << body << endl;
+ cerr << __FILE__ << ": version = " << version << " | body.length = "
+ << _body.length() << endl;
#endif // DEBUG
set_body(_body);
}
-*/
void HTTPMessage::set_body(const string& _body) {
body = _body;
if (body.length()) {
stringstream ss; // TODO ver forma mas linda de convertir
- ss << body.length();
+ ss << (body.length()+1); // FIXME No se por que tengo que sumarle 1.
+ headers["Accept-Ranges"] = "bytes";
headers["Content-Length"] = ss.str();
}
}
cerr << __FILE__ << ": operator>>()" << endl;
#endif // DEBUG
char buf[BUFSIZ];
- bool is_header = true;
- // TODO body
- // Para hacer que reciba bien el body hay que chequear la cabecera
- // Content-length, si queda tiempo lo haré...
- //stringstream body_ss;
while (is.getline(buf, BUFSIZ)) {
String sbuf(buf);
sbuf.trim();
if (sbuf.length()) {
- if (is_header) {
- stringstream ss;
- ss << sbuf;
- ss >> m.headers;
- }// else { TODO body
- // body_ss << sbuf << endl;
- //}
+ stringstream ss;
+ ss << sbuf;
+ ss >> m.headers;
+ // Fin de las cabeceras.
} else {
- if (is_header) {
- // TODO body
- // Ver si tiene un Content-Length para saber si esperamos body.
- // Si no esperamos body, no hay que hacer otro is.getline()
- // porque se queda esperando forever.
- is_header = false;
- break;
- }// else { TODO body
- // body_ss << sbuf << endl;
- //}
+ // Hay Content-Length, entonces hay body (no respeta RFC AFAIK).
+ if (m.headers.find("Content-Length") != m.headers.end()) {
+ stringstream ss(m.headers["Content-Length"]);
+ streamsize size;
+ ss >> size;
+ char* const buf2 = new char[size+1];
+ if (is.readsome(buf2, size)) {
+ m.body = buf2;
+ }
+ delete []buf2;
+ }
+ // Después de una línea vacía, haya obtenido el body o no, sale del
+ // while.
+ break;
}
}
- // TODO body
- //m.body = body_ss.str();
return is;
}
<< m.body;
}
+string HTTPMessage::reason(unsigned code) {
+ switch (code) {
+ // TODO completar los códigos.
+ case OK:
+ return "OK";
+ case BAD_REQUEST:
+ return "Bad Request";
+ case NOT_FOUND:
+ return "Not Found";
+ case LENGTH_REQUIRED:
+ return "Length Required";
+ case INTERNAL_SERVER_ERROR:
+ return "Internal Server Error";
+ case NOT_IMPLEMENTED:
+ return "Not Implemented";
+ case HTTP_VERSION_NOT_SUPPORTED:
+ return "HTTP Version Not Supported";
+ default:
+ return "No Reason";
+ }
+}
+
} // namespace Server
} // namespace PlaQui