// Created: August 1997
// RCS-ID: $Id$
// Copyright: (c) 1997, 1998 Guilhem Lavaux
-// Licence: wxWindows license
+// Licence: wxWindows licence
/////////////////////////////////////////////////////////////////////////////
#ifdef __GNUG__
#define HTTP_BSIZE 2048
wxHTTP::wxHTTP()
- : wxProtocol(),
- m_headers(wxKEY_STRING)
+ : wxProtocol()
{
m_addr = NULL;
m_read = FALSE;
m_proxy_mode = FALSE;
+ m_post_buf = wxEmptyString;
SetNotify(wxSOCKET_LOST_FLAG);
}
void wxHTTP::ClearHeaders()
{
- // wxString isn't a wxObject
- wxNode *node = m_headers.First();
- wxString *string;
-
- while (node) {
- string = (wxString *)node->Data();
- delete string;
- node = node->Next();
- }
-
- m_headers.Clear();
+ m_headers.clear();
}
wxString wxHTTP::GetContentType()
m_read = FALSE;
}
- wxNode *node = m_headers.Find(header);
-
- if (!node)
- m_headers.Append(header, (wxObject *)(new wxString(h_data)));
- else {
- wxString *str = (wxString *)node->Data();
- (*str) = h_data;
- }
+ wxStringToStringHashMap::iterator it = m_headers.find(header);
+ if (it != m_headers.end())
+ it->second = h_data;
+ else
+ m_headers[header.Upper()] = h_data;
}
wxString wxHTTP::GetHeader(const wxString& header)
{
- wxNode *node;
- wxString upper_header;
+ wxStringToStringHashMap::iterator it = m_headers.find(header.Upper());
- upper_header = header.Upper();
-
- node = m_headers.Find(upper_header);
- if (!node)
+ if (it == m_headers.end())
return wxEmptyString;
- return *((wxString *)node->Data());
+ return it->second;
+}
+
+void wxHTTP::SetPostBuffer(const wxString& post_buf)
+{
+ m_post_buf = post_buf;
}
void wxHTTP::SendHeaders()
{
- wxNode *head = m_headers.First();
+ typedef wxStringToStringHashMap::iterator iterator;
+ wxString buf;
- while (head)
+ for (iterator it = m_headers.begin(), en = m_headers.end(); it != en; ++it )
{
- wxString *str = (wxString *)head->Data();
-
- wxString buf;
- buf.Printf(wxT("%s: %s\r\n"), head->GetKeyString(), str->GetData());
+ buf.Printf(wxT("%s: %s\r\n"), it->first.c_str(), it->second.c_str());
const wxWX2MBbuf cbuf = buf.mb_str();
Write(cbuf, strlen(cbuf));
-
- head = head->Next();
}
}
break;
wxString left_str = line.BeforeFirst(':');
- wxString *str = new wxString(line.AfterFirst(':').Strip(wxString::both));
left_str.MakeUpper();
- m_headers.Append(left_str, (wxObject *) str);
+ m_headers[left_str] = line.AfterFirst(':').Strip(wxString::both);
}
return TRUE;
}
-bool wxHTTP::Connect(const wxString& host)
+bool wxHTTP::Connect(const wxString& host, unsigned short port)
{
wxIPV4address *addr;
return FALSE;
}
- if (!addr->Service(wxT("http")))
+ if ( port ) addr->Service(port);
+ else if (!addr->Service(wxT("http")))
addr->Service(80);
SetHeader(wxT("Host"), host);
case wxHTTP_GET:
request = wxT("GET");
break;
+ case wxHTTP_POST:
+ request = wxT("POST");
+ break;
default:
return FALSE;
}
wxString buf;
buf.Printf(wxT("%s %s HTTP/1.0\r\n"), request, path.c_str());
- const wxWX2MBbuf pathbuf = wxConvLibc.cWX2MB(buf);
+ const wxWX2MBbuf pathbuf = wxConvLocal.cWX2MB(buf);
Write(pathbuf, strlen(wxMBSTRINGCAST pathbuf));
SendHeaders();
Write("\r\n", 2);
+ if ( req == wxHTTP_POST ) {
+ Write(m_post_buf, m_post_buf.Len());
+ m_post_buf = wxEmptyString;
+ }
+
wxString tmp_str;
m_perr = GetLine(this, tmp_str);
if (m_perr != wxPROTO_NOERR) {
protected:
size_t OnSysRead(void *buffer, size_t bufsize);
+
+ DECLARE_NO_COPY_CLASS(wxHTTPStream)
};
size_t wxHTTPStream::OnSysRead(void *buffer, size_t bufsize)
{
- size_t ret;
-
- if (m_httpsize > 0 && m_read_bytes >= m_httpsize)
- return 0;
+ if (m_httpsize > 0 && m_read_bytes >= m_httpsize)
+ {
+ m_lasterror = wxSTREAM_EOF;
+ return 0;
+ }
- ret = wxSocketInputStream::OnSysRead(buffer, bufsize);
- m_read_bytes += ret;
+ size_t ret = wxSocketInputStream::OnSysRead(buffer, bufsize);
+ m_read_bytes += ret;
- return ret;
+ return ret;
}
bool wxHTTP::Abort(void)
return NULL;
#endif
- if (!BuildRequest(path, wxHTTP_GET))
+ if (!BuildRequest(path, m_post_buf.IsEmpty() ? wxHTTP_GET : wxHTTP_POST))
return NULL;
inp_stream = new wxHTTPStream(this);