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("") {
}


HttpAccess::~HttpAccess(void) {
}


std::string HttpAccess::sendRequest(const char *request,
                                    int size, int timeout) {

  TcpipDevice socket;
  if (socket.connect(server.c_str(), port) < 0) {
    return "";
  }

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

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

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

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

  return htmlText;
}


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

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

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


HttpAccess& HttpAccess::clearItems(void) {

  items = "";
  return *this;
}


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

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

  return *this;
}


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

  char value_str[13];
  sprintf(value_str, "%d", value);
  return addItem(title, value_str);
}


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

  char size[11];
  sprintf(size, "%d", items.size());
  std::string request =
    "POST " + std::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(request.c_str(), request.size(), timeout);
}