httpAccess.cpp

/*
  HTTP ・「・ッ・サ・ケ
  Satofumi KAMIMURA
  $Id$
*/

#include "httpAccess.h"


HttpAccess::HttpAccess(const char *web_server, int web_port)
  : server(web_server), port(web_port), items(string()) {
}


HttpAccess::~HttpAccess(void) {
}


string HttpAccess::sendRequest(SocketCtrl& socket,
                               const char *request, int size, int timeout) {

  SocketSet socket_set;
  socket_set.add(socket);

  socket_set.check();
  socket.send(request, size);
  if (timeout == 0) {
    return string();
  }

  int retval = socket_set.check(timeout);
  char buf[BUFSIZ];
  int n = socket.recv(buf, sizeof(buf)-1);
  if ((retval == 0) || (n <= 0)) {
    return string();
  }

  buf[n] = '\0';
  char *pBody = strstr((const char *)buf, "\r\n\r\n");
  if (pBody == NULL) {
    return string();
  }
  pBody += 4;
  int body = pBody - buf;

  string htmlText = string(buf, body, n - body);
  do {
    retval = socket_set.check(timeout);
    n = socket.recv(buf, sizeof(buf)-1);
    if (n > 0) {
      buf[n] = '\0';
      htmlText += string(buf, 0, n);
    }
  } while ((retval > 0) && (n > 0));

  return htmlText;
}


string HttpAccess::getHtmlText(const char *path, int timeout) {

  SocketCtrl tcp_socket = SocketCtrl(server.c_str(), port);

  string request =
    "GET " + string(path) + " HTTP/1.0\n"
    "Host: " + server + "\n"
    "\n";

  return sendRequest(tcp_socket, request.c_str(), request.size(), timeout);
}


HttpAccess& HttpAccess::clearPutItem(void) {

  items = string();
  return *this;
}


HttpAccess& HttpAccess::addPutItem(const char *title, const char *value) {

  if (items.size() > 0) {
    items += "&";
  }
  items += string(title) + "=" + string(value);

  return *this;
}


string HttpAccess::sendPutItem(const char *path, int timeout) {
  SocketCtrl socket = SocketCtrl(server.c_str(), port);

  char size[11];
  sprintf(size, "%d", items.size());
  string request =
    "POST " + string(path) + " HTTP/1.0\n"
    "Host: " + server + "\n"
    "Content-Type: application/x-www-form-urlencoded\n"
    "Content-Length: " + size + "\n"
    "\n"
    + items + "\n"
    "\n";

  return sendRequest(socket, request.c_str(), request.size(), timeout);
}