diff options
Diffstat (limited to 'src/Sockets/HttpRequest.cpp')
| -rw-r--r-- | src/Sockets/HttpRequest.cpp | 358 |
1 files changed, 358 insertions, 0 deletions
diff --git a/src/Sockets/HttpRequest.cpp b/src/Sockets/HttpRequest.cpp new file mode 100644 index 0000000..3909595 --- /dev/null +++ b/src/Sockets/HttpRequest.cpp @@ -0,0 +1,358 @@ +/** + ** \file HttpRequest.cpp + ** \date 2007-10-05 + ** \author grymse@alhem.net +**/ +/* +Copyright (C) 2007 Anders Hedstrom + +This program is free software; you can redistribute it and/or +modify it under the terms of the GNU General Public License +as published by the Free Software Foundation; either version 2 +of the License, or (at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program; if not, write to the Free Software +Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. +*/ +#ifdef _MSC_VER +#pragma warning(disable:4786) +#endif +#include "HttpRequest.h" +#include "Utility.h" +#include "MemFile.h" +#include "HttpdForm.h" +#include "HttpdCookies.h" +#include "Parse.h" + +#ifdef SOCKETS_NAMESPACE +namespace SOCKETS_NAMESPACE { +#endif + +#ifdef _DEBUG +#define DEB(x) x; fflush(stderr); +#else +#define DEB(x) +#endif + + +// -------------------------------------------------------------------------------------- +HttpRequest::HttpRequest() : HttpTransaction() +, m_server_port(0) +, m_is_ssl(false) +, m_body_file(NULL) +, m_form(NULL) +{ +} + + +// -------------------------------------------------------------------------------------- +HttpRequest::HttpRequest(const HttpRequest& src) : HttpTransaction(src) +, m_method(src.m_method) +, m_protocol(src.m_protocol) +, m_req_uri(src.m_req_uri) +, m_remote_addr(src.m_remote_addr) +, m_remote_host(src.m_remote_host) +, m_server_name(src.m_server_name) +, m_server_port(src.m_server_port) +, m_is_ssl(src.m_is_ssl) +, m_attribute(src.m_attribute) +, m_null(src.m_null) +, m_body_file(src.m_body_file) +, m_form(src.m_form) +, m_cookies(src.m_cookies) +, m_cookie(src.m_cookie) +{ +} + + +// -------------------------------------------------------------------------------------- +HttpRequest::~HttpRequest() +{ + m_body_file = std::auto_ptr<IFile>(NULL); + m_form = std::auto_ptr<HttpdForm>(NULL); +/* + if (m_body_file) + { + delete m_body_file; + } + if (m_form) + { + delete m_form; + } +*/ +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetHttpMethod(const std::string& value) +{ + m_method = value; +} + + +const std::string& HttpRequest::HttpMethod() const +{ + return m_method; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetHttpVersion(const std::string& value) +{ + m_protocol = value; +} + + +const std::string& HttpRequest::HttpVersion() const +{ + return m_protocol; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetUri(const std::string& value) +{ + m_req_uri = Utility::rfc1738_decode(value); +} + + +const std::string& HttpRequest::Uri() const +{ + return m_req_uri; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetRemoteAddr(const std::string& value) +{ + m_remote_addr = value; +} + + +const std::string& HttpRequest::RemoteAddr() const +{ + return m_remote_addr; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetRemoteHost(const std::string& value) +{ + m_remote_host = value; +} + + +const std::string& HttpRequest::RemoteHost() const +{ + return m_remote_host; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetServerName(const std::string& value) +{ + m_server_name = value; +} + + +const std::string& HttpRequest::ServerName() const +{ + return m_server_name; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetServerPort(int value) +{ + m_server_port = value; +} + + +int HttpRequest::ServerPort() const +{ + return m_server_port; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetIsSsl(bool value) +{ + m_is_ssl = value; +} + + +bool HttpRequest::IsSsl() const +{ + return m_is_ssl; +} + + + +// -------------------------------------------------------------------------------------- +void HttpRequest::SetAttribute(const std::string& key, const std::string& value) +{ + m_attribute[Utility::ToLower(key)] = value; +} + + +void HttpRequest::SetAttribute(const std::string& key, long value) +{ + m_attribute[Utility::ToLower(key)] = Utility::l2string(value); +} + + +const std::string& HttpRequest::Attribute(const std::string& key) const +{ + std::map<std::string, std::string>::const_iterator it; + if ( (it = m_attribute.find(Utility::ToLower(key))) != m_attribute.end()) + return it -> second; + return m_null; +} + + +// -------------------------------------------------------------------------------------- +const std::map<std::string, std::string>& HttpRequest::Attributes() const +{ + return m_attribute; +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::AddCookie(const std::string& str) +{ + m_cookies.add( str ); + Parse pa(str, ";"); + std::string lstr = pa.getword(); + while (!lstr.empty()) + { + Parse pa2(lstr, "="); + std::string name = pa2.getword(); + m_cookie[name] = lstr; +DEB(fprintf(stderr, " *** AddCookie '%s' = '%s'\n", name.c_str(), lstr.c_str());) + lstr = pa.getword(); + } +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::InitBody( size_t sz ) +{ + if (!m_body_file.get()) + m_body_file = std::auto_ptr<IFile>(new MemFile); +DEB( else + fprintf(stderr, "Body data file already opened\n");) +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::Write( const char *buf, size_t sz ) +{ + if (m_body_file.get()) + m_body_file -> fwrite(buf, 1, sz); +DEB( else + fprintf(stderr, "Write: Body data file not open\n");) +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::CloseBody() +{ + if (m_body_file.get()) + m_body_file -> fclose(); +DEB( else + fprintf(stderr, "CloseBody: File not open\n");) +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::ParseBody() +{ + std::map<std::string, std::string>::const_iterator it; + if ( (it = m_attribute.find("query_string")) != m_attribute.end()) + { + std::string qs = it -> second; + m_form = std::auto_ptr<HttpdForm>(new HttpdForm( qs, qs.size() )); + } + else + if (m_body_file.get()) + { + m_form = std::auto_ptr<HttpdForm>(new HttpdForm( m_body_file.get(), ContentType(), ContentLength() )); + } + else + { + // dummy + m_form = std::auto_ptr<HttpdForm>(new HttpdForm( "", 0 )); + } +} + + +// -------------------------------------------------------------------------------------- +const HttpdForm& HttpRequest::Form() const +{ + return *m_form; +} + + +// -------------------------------------------------------------------------------------- +const HttpdCookies& HttpRequest::Cookies() const +{ + return m_cookies; +} + + +// -------------------------------------------------------------------------------------- +void HttpRequest::Reset() +{ + HttpTransaction::Reset(); + m_method = ""; + m_protocol = ""; + m_req_uri = ""; + m_remote_addr = ""; + m_remote_host = ""; + m_server_name = ""; + m_server_port = 0; + m_is_ssl = false; + while (!m_attribute.empty()) + { + m_attribute.erase(m_attribute.begin()); + } + m_body_file = std::auto_ptr<IFile>(NULL); + m_form = std::auto_ptr<HttpdForm>(NULL); +/* + if (m_body_file) + { + delete m_body_file; + m_body_file = NULL; + } + if (m_form) + { + delete m_form; + m_form = NULL; + } +*/ + m_cookies.Reset(); + while (!m_cookie.empty()) + { + m_cookie.erase(m_cookie.begin()); + } +} + + +#ifdef SOCKETS_NAMESPACE +} // namespace SOCKETS_NAMESPACE { +#endif + + |