#pragma hdrstop
#endif
-#if wxUSE_SOCKETS
+#if wxUSE_SOCKETS && wxUSE_STREAMS
#include <stdio.h>
#include <stdlib.h>
#include "wx/protocol/http.h"
#include "wx/sckstrm.h"
-#if !USE_SHARED_LIBRARY
IMPLEMENT_DYNAMIC_CLASS(wxHTTP, wxProtocol)
IMPLEMENT_PROTOCOL(wxHTTP, wxT("http"), wxT("80"), TRUE)
-#endif
#define HTTP_BSIZE 2048
m_read = FALSE;
m_proxy_mode = FALSE;
- SetNotify(GSOCK_LOST_FLAG);
+ SetNotify(wxSOCKET_LOST_FLAG);
}
wxHTTP::~wxHTTP()
delete string;
node = node->Next();
}
+
+ if (m_addr) {
+ delete m_addr;
+ m_addr = NULL;
+ }
}
wxString wxHTTP::GetContentType()
wxString upper_header;
upper_header = header.Upper();
-
+
node = m_headers.Find(upper_header);
if (!node)
return wxEmptyString;
wxString *str = (wxString *)head->Data();
wxString buf;
- buf.Printf(wxT("%s: %s\n\r"), head->GetKeyString(), str->GetData());
+ buf.Printf(wxT("%s: %s\r\n"), head->GetKeyString(), str->GetData());
const wxWX2MBbuf cbuf = buf.mb_str();
Write(cbuf, strlen(cbuf));
m_headers.Clear();
m_read = TRUE;
- while (1) {
+#if defined(__VISAGECPP__)
+// VA just can't stand while(1)
+ bool bOs2var = TRUE;
+ while(bOs2var) {
+#else
+ while (1) {
+#endif
m_perr = GetLine(this, line);
if (m_perr != wxPROTO_NOERR)
return FALSE;
if (line.Length() == 0)
break;
- tokenzr.SetString(line, " :\t\n\r");
- if (!tokenzr.HasMoreTokens())
- return FALSE;
-
- wxString left_str = tokenzr.GetNextToken();
- wxString *str = new wxString(tokenzr.GetNextToken());
-
+ wxString left_str = line.BeforeFirst(':');
+ wxString *str = new wxString(line.AfterFirst(':').Strip(wxString::both));
left_str.MakeUpper();
m_headers.Append(left_str, (wxObject *) str);
{
if (m_addr) {
delete m_addr;
- m_addr = NULL;
Close();
}
- m_addr = (wxSockAddress *) addr.Clone();
+ m_addr = addr.Clone();
+
return TRUE;
}
bool wxHTTP::BuildRequest(const wxString& path, wxHTTP_Req req)
{
wxChar *tmp_buf;
- wxChar buf[200]; // 200 is arbitrary.
- wxString tmp_str = path;
-
- // If there is no User-Agent defined, define it.
- if (GetHeader(wxT("User-Agent")).IsNull())
- SetHeader(wxT("User-Agent"), wxT("wxWindows 2.x"));
switch (req) {
case wxHTTP_GET:
return FALSE;
}
+ // If there is no User-Agent defined, define it.
+ if (GetHeader(wxT("User-Agent")).IsNull())
+ SetHeader(wxT("User-Agent"), wxT("wxWindows 2.x"));
+
SaveState();
- SetFlags(NONE);
+ SetFlags(wxSOCKET_NONE);
Notify(FALSE);
- wxSprintf(buf, wxT("%s %s HTTP/1.0\n\r"), tmp_buf, tmp_str.GetData());
+ wxString buf;
+ buf.Printf(wxT("%s %s HTTP/1.0\r\n"), tmp_buf, path.c_str());
const wxWX2MBbuf pathbuf = wxConvLibc.cWX2MB(buf);
Write(pathbuf, strlen(wxMBSTRINGCAST pathbuf));
SendHeaders();
- Write("\n\r", 2);
+ Write("\r\n", 2);
+ wxString tmp_str;
m_perr = GetLine(this, tmp_str);
if (m_perr != wxPROTO_NOERR) {
RestoreState();
token.NextToken();
tmp_str2 = token.NextToken();
- switch (tmp_str2[(unsigned int) 0]) {
+ switch (tmp_str2[0u]) {
case wxT('1'):
/* INFORMATION / SUCCESS */
break;
return ret_value;
}
-class wxHTTPStream : public wxSocketInputStream {
+class wxHTTPStream : public wxSocketInputStream
+{
public:
wxHTTP *m_http;
size_t m_httpsize;
bool wxHTTP::Abort(void)
{
- bool ret;
-
- ret = wxSocketClient::Close();
-
- return ret;
+ return wxSocketClient::Close();
}
wxInputStream *wxHTTP::GetInputStream(const wxString& path)
{
- wxHTTPStream *inp_stream = new wxHTTPStream(this);
+ wxHTTPStream *inp_stream;
+
wxString new_path;
m_perr = wxPROTO_CONNERR;
return NULL;
// We set m_connected back to FALSE so wxSocketBase will know what to do.
+#ifdef __WXMAC__
+ wxSocketClient::Connect(*m_addr , FALSE );
+ wxSocketClient::WaitOnConnect(10);
+
+ if (!wxSocketClient::IsConnected())
+ return NULL;
+#else
if (!wxProtocol::Connect(*m_addr))
return NULL;
+#endif
if (!BuildRequest(path, wxHTTP_GET))
return NULL;
+ inp_stream = new wxHTTPStream(this);
+
if (!GetHeader(wxT("Content-Length")).IsEmpty())
inp_stream->m_httpsize = wxAtoi(WXSTRINGCAST GetHeader(wxT("Content-Length")));
else
inp_stream->m_read_bytes = 0;
Notify(FALSE);
- SetFlags(SPEED | WAITALL);
+ SetFlags(wxSOCKET_BLOCK | wxSOCKET_WAITALL);
return inp_stream;
}