50 while (curr < buf.
Length() - 2) {
61 if ((value == 0) && doing_set) {
63 buf.
Remove(curr, next - curr + 2);
68 while ((curr < next) && (buf[curr] !=
':'))
71 while ((curr < next) && (buf[curr] ==
' '))
75 return buf(curr, next - curr);
76 buf.
Remove(curr, next - curr);
93 Int_t curr(0), cnt(0);
95 while (curr < buf.
Length() - 2) {
103 Int_t separ = curr + 1;
104 while ((separ < next) && (buf[separ] !=
':'))
106 return buf(curr, separ - curr);
221 if (data && length) {
222 std::copy((
const char *)data, (
const char *)data + length,
fPostData.begin());
223 if (!make_copy)
free(data);
262 std::size_t start_pos = 0;
263 while((start_pos =
fContent.find(from, start_pos)) != std::string::npos) {
264 fContent.replace(start_pos, from.length(), to);
266 start_pos += to.length();
284 const char *rslash = strrchr(fullpath,
'/');
288 while ((fullpath != rslash) && (*fullpath ==
'/'))
305 if (strcmp(
name,
"Content-Type") == 0)
307 if (strcmp(
name,
"Content-Length") == 0)
320 if ((
name == 0) || (*
name == 0) || (strcmp(
name,
"Content-Length") == 0))
323 if (strcmp(
name,
"Content-Type") == 0)
334 AddHeader(
"Cache-Control",
"private, no-cache, no-store, must-revalidate, max-age=0, proxy-revalidate, s-maxage=0");
343 std::string hdr(
name ?
name :
"HTTP/1.1");
346 hdr.append(
" 404 Not Found\r\n"
347 "Content-Length: 0\r\n"
348 "Connection: close\r\n\r\n");
350 hdr.append(
Form(
" 200 OK\r\n"
351 "Content-Type: %s\r\n"
352 "Connection: keep-alive\r\n"
353 "Content-Length: %ld\r\n"
368 unsigned long objcrc = R__crc32(0, NULL, 0);
369 objcrc = R__crc32(objcrc, (
const unsigned char *)objbuf, objlen);
372 Int_t buflen = 10 + objlen + 8;
377 buffer.resize(buflen);
379 char *bufcur = (
char *)buffer.data();
395 memcpy(dummy, bufcur - 6, 6);
398 unsigned long ziplen = R__memcompress(bufcur - 6, objlen + 6, objbuf, objlen);
400 memcpy(bufcur - 6, dummy, 6);
402 bufcur += (ziplen - 6);
405 *bufcur++ = objcrc & 0xff;
406 *bufcur++ = (objcrc >> 8) & 0xff;
407 *bufcur++ = (objcrc >> 16) & 0xff;
408 *bufcur++ = (objcrc >> 24) & 0xff;
411 *bufcur++ = objlen & 0xff;
412 *bufcur++ = (objlen >> 8) & 0xff;
413 *bufcur++ = (objlen >> 16) & 0xff;
414 *bufcur++ = (objlen >> 24) & 0xff;
416 buffer.resize(bufcur - (
char *)buffer.data());
char * Form(const char *fmt,...)
std::string fPostData
! data received with post request - text - or binary
Bool_t fNotifyFlag
! indicate that notification called
Bool_t CompressWithGzip()
compress reply data with gzip compression
void SetJson()
Set content type as "application/json".
TString GetHeader(const char *name)
return specified header
std::condition_variable fCond
! condition used to wait for processing
void SetPostData(void *data, Long_t length, Bool_t make_copy=kFALSE)
std::shared_ptr< THttpWSEngine > TakeWSEngine()
takeout websocket handle with HTTP call can be done only once
void AddHeader(const char *name, const char *value)
Set name: value pair to reply header Content-Type field handled separately - one should use SetConten...
void SetText()
Set content type as "text/plain".
void SetTextContent(std::string &&txt)
Set content type as "text/plain" and also assigns content After method call argument.
virtual void HttpReplied()
virtual method to inform object that http request is processed Normally condition is notified and wai...
void ReplaceAllinContent(const std::string &from, const std::string &to, bool once=false)
Replace all occurrences of.
TString fPathName
! item path
std::shared_ptr< THttpWSEngine > fWSEngine
! web-socket engine, which supplied to run created web socket
void NotifyCondition()
method used to notify condition which waiting when operation will complete Condition notified only if...
void SetPathAndFileName(const char *fullpath)
set complete path of requested http element For instance, it could be "/folder/subfolder/get....
TString fContentType
! type of content
Long_t GetContentLength() const
virtual ~THttpCallArg()
destructor
TString CountHeader(const TString &buf, Int_t number=-1111) const
method used to counter number of headers or returns name of specified header
const void * GetContent() const
void SetBinary()
Set content type as "application/x-binary".
void AddNoCacheHeader()
Set CacheControl http header to disable browser caching.
TString AccessHeader(TString &buf, const char *name, const char *value=nullptr, Bool_t doing_set=kFALSE)
method used to get or set http header in the string buffer Header has following format: field1 : valu...
void SetXml()
Set content type as "text/xml".
void SetContent(const char *cont)
Set content as text.
Bool_t IsPostponed() const
void SetWSId(UInt_t id)
set web-socket id
TString fFileName
! file name
std::string fContent
! content - text or binary
void SetBinaryContent(std::string &&bin)
Set content type as "application/x-binary" and also assigns content After method call argument.
void SetContentType(const char *typ)
set content type like "text/xml" or "application/json"
void SetEncoding(const char *typ)
Set Content-Encoding header like gzip.
void SetJsonContent(std::string &&json)
Set content type as "application/json" and also assigns content After method call argument.
const char * GetContentType() const
void AssignWSId()
Assign websocket identifier from the engine.
void SetXmlContent(std::string &&xml)
Set content type as "text/xml" and also assigns content After method call argument.
std::string FillHttpHeader(const char *header=nullptr)
Fills HTTP header, which can be send at the beggining of reply on the http request.
TString fHeader
! response header like ContentEncoding, Cache-Control and so on
TString & Insert(Ssiz_t pos, const char *s)
void Clear()
Clear string without changing its capacity.
const char * Data() const
TString & Remove(Ssiz_t pos)
TString & Append(const char *cs)
static TString Format(const char *fmt,...)
Static method which formats a string using a printf style format descriptor and return a TString.
Ssiz_t Index(const char *pat, Ssiz_t i=0, ECaseCompare cmp=kExact) const