00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00043 #ifndef CCXX_URL_H_
00044 #define CCXX_URL_H_
00045
00046 #ifndef CCXX_CONFIG_H_
00047 #include <cc++/config.h>
00048 #endif
00049
00050 #ifndef CCXX_SOCKET_H_
00051 #include <cc++/socket.h>
00052 #endif
00053
00054 #ifndef CCXX_MIME_H_
00055 #include <cc++/mime.h>
00056 #endif
00057
00058 #ifdef CCXX_NAMESPACES
00059 namespace ost {
00060 #endif
00061
00068 class __EXPORT URLStream : public TCPStream
00069 {
00070 public:
00074 typedef enum
00075 {
00076 errSuccess = 0,
00077 errUnreachable,
00078 errMissing,
00079 errDenied,
00080 errInvalid,
00081 errForbidden,
00082 errUnauthorized,
00083 errRelocated,
00084 errFailure,
00085 errTimeout,
00086 errInterface
00087 } Error;
00088
00092 typedef enum
00093 {
00094 authAnonymous = 0,
00095 authBasic
00096 } Authentication;
00097
00101 typedef enum
00102 {
00103 encodingBinary = 0,
00104 encodingChunked
00105 } Encoding;
00106
00110 typedef enum
00111 {
00112 methodHttpGet,
00113 methodHttpPut,
00114 methodHttpPost,
00115 methodHttpPostMultipart,
00116 methodFtpGet,
00117 methodFtpPut,
00118 methodFileGet,
00119 methodFilePut
00120 } Method;
00121
00125 typedef enum
00126 {
00127 protocolHttp1_0,
00128 protocolHttp1_1
00129 } Protocol;
00130
00131 private:
00132 const char *agent, *referer, *cookie, *pragma, *user, *password;
00133 const char *proxyUser, *proxyPasswd;
00134 const char *localif;
00135 IPV4Host proxyHost;
00136 #ifdef CCXX_IPV6
00137 IPV6Host v6proxyHost;
00138 #endif
00139 tpport_t proxyPort;
00140 Method urlmethod;
00141 Encoding encoding;
00142 Protocol protocol;
00143 Authentication auth;
00144 Authentication proxyAuth;
00145 timeout_t timeout;
00146 bool persistent;
00147 bool follow;
00148 unsigned chunk;
00149
00150 Error getHTTPHeaders();
00151 URLStream(const URLStream& rhs);
00152
00153 protected:
00154 ost::String m_host, m_address;
00155
00156 Error sendHTTPHeader(const char *url, const char **vars, size_t bufsize);
00157 int underflow(void);
00158
00159 virtual int aRead(char *buffer, size_t len, timeout_t timer);
00160
00161 virtual int aWrite(char *buffer, size_t len, timeout_t timer);
00162
00169 virtual void httpHeader(const char *header, const char *value);
00170
00176 virtual char **extraHeader(void);
00177
00178 public:
00184 URLStream(Family family = IPV4, timeout_t to = 0);
00185
00193 URLStream &getline(char *buffer, size_t len);
00194
00202 Error get(const char *url, size_t buffer = 512);
00203
00212 Error get(size_t buffer = 512);
00213
00223 Error submit(const char *url, const char **vars, size_t buffer = 512);
00224
00233 Error post(const char *url, const char **vars, size_t buffer = 512);
00234
00243 Error post(const char *url, MIMEMultipartForm &form, size_t buffer = 512);
00244
00252 Error head(const char *url, size_t buffer = 512);
00253
00257 void close();
00258
00264 void setReferer(const char *str);
00265
00271 inline void setHost(const char *str)
00272 {m_host = str;};
00273
00279 inline void setAddress(const char *str)
00280 {m_address = str;};
00281
00287 inline void setCookie(const char *str)
00288 {cookie = str;};
00289
00295 inline void setUser(const char *str)
00296 {user = str;};
00297
00303 inline void setPassword(const char *str)
00304 {password = str;};
00305
00312 void setAuthentication(Authentication a, const char *str = NULL);
00313
00319 inline void setProxyUser(const char *str)
00320 {proxyUser = str;};
00321
00327 inline void setProxyPassword(const char *str)
00328 {proxyPasswd = str;};
00329
00336 void setProxyAuthentication(Authentication a, const char *str = NULL);
00337
00343 inline void setPragma(const char *str)
00344 {pragma = str;};
00345
00352 void setProxy(const char *host, tpport_t port);
00353
00359 inline void setAgent(const char *str)
00360 {agent = str;};
00361
00367 inline Method getMethod(void)
00368 {return urlmethod;};
00369
00376 inline void setTimeout(timeout_t to)
00377 {timeout = to;};
00378
00385 inline void setFollow(bool enable)
00386 {follow = enable;};
00387
00393 inline void setProtocol(Protocol pro)
00394 {protocol = pro;};
00400 inline void setLocalInterface(const char *intf)
00401 {localif=intf;}
00402 };
00403
00409 __EXPORT char* urlDecode(char *source, char *dest = NULL);
00410
00417 __EXPORT char* urlEncode(const char *source, char *dest, size_t size);
00418
00429 __EXPORT char* b64Decode(char *src, char *dest = NULL);
00430
00442 __EXPORT char* b64Encode(const char *source, char *dest, size_t size);
00443
00455 __EXPORT size_t b64Encode(const unsigned char *src, size_t srcsize,
00456 char *dst, size_t dstsize);
00457
00467 __EXPORT size_t b64Decode(const char *src,
00468 unsigned char *dst, size_t dstsize);
00469
00475 __EXPORT String b64Encode(const String& src);
00476
00484 __EXPORT String b64Decode(const String& src);
00485
00492 __EXPORT String b64Encode(const unsigned char *src, size_t srcsize);
00493
00503 __EXPORT size_t b64Decode(const String& src,
00504 unsigned char *dst, size_t dstsize);
00505
00506
00507 #ifdef CCXX_NAMESPACES
00508 }
00509 #endif
00510
00511 #endif
00512