X-Git-Url: https://git.llucax.com/z.facultad/75.42/plaqui.git/blobdiff_plain/b92547a5de3a3fb4f14a2bea4a4e776b8da3cb5c..ea3d0f30b8e44952b1b9ac3e2f5b2a08cd65ca48:/Server/src/httpmessage.cpp?ds=sidebyside diff --git a/Server/src/httpmessage.cpp b/Server/src/httpmessage.cpp index 3a563cd..cda5064 100644 --- a/Server/src/httpmessage.cpp +++ b/Server/src/httpmessage.cpp @@ -25,6 +25,7 @@ // $Id$ // +#include "plaqui/server/string.h" #include "plaqui/server/httpmessage.h" #include #include @@ -40,36 +41,25 @@ namespace Server { HTTPMessage::~HTTPMessage(void) { #ifdef DEBUG - cerr << __FILE__ << ": destructor." << endl; + cerr << __FILE__ << "(" << __LINE__ << ")" + << ": destructor." << endl; #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__ << "(" << __LINE__ << ")" + << ": version = " << version << " | body (" + << _body.length() << ") = " << _body << endl; #endif // DEBUG + headers["Accept-Ranges"] = "bytes"; 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(); - headers["Content-Length"] = ss.str(); - } + headers["Content-Length"] = String().from(body.length()); } const string& HTTPMessage::get_body(void) const { @@ -78,42 +68,69 @@ const string& HTTPMessage::get_body(void) const { istream& operator>>(istream& is, HTTPMessage& m) { #ifdef DEBUG - cerr << __FILE__ << ": operator>>()" << endl; + cerr << __FILE__ << "(" << __LINE__ << ")" + << ": operator>>()" << endl; #endif // DEBUG char buf[BUFSIZ]; - bool is_header = true; - stringstream body_ss; while (is.getline(buf, BUFSIZ)) { - string sbuf = buf; + String sbuf(buf); + sbuf.trim(); if (sbuf.length()) { - if (is_header) { - stringstream ss; - ss << buf; - ss >> m.headers; - } else { - body_ss << buf << endl; - } + stringstream ss(sbuf); + ss >> m.headers; + // Fin de las cabeceras. } else { - if (is_header) { - is_header = false; - } else { - body_ss << buf << endl; + // Hay Content-Length, entonces hay body (no respeta RFC AFAIK). + if (m.headers.find("Content-Length") != m.headers.end()) { + streamsize size; + to(m.headers["Content-Length"], size); + char* const buf2 = new char[size+1]; + if (is.readsome(buf2, size) == size) { + // Agrego fin de string porque el readsome no lo hace. + buf2[size] = '\0'; + m.set_body(buf2); + } // TODO else dar error? + delete []buf2; } + // Después de una línea vacía, haya obtenido el body o no, sale del + // while. + break; } } - // TODO si el body es un serializable, deberia auto deserializarse. - m.body = body_ss.str(); return is; } ostream& operator<<(ostream& os, const HTTPMessage& m) { #ifdef DEBUG - cerr << __FILE__ << ": operator<<()" << endl; + cerr << __FILE__ << "(" << __LINE__ << ")" + << ": operator<<()" << endl; #endif // DEBUG return os << m.headers << "\r\n" // Fin de cabeceras << 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