http.cc

/*
 * HTTP/1.0 for streams sockets - implementation
 * Copyright(c) 2003-2018 of wave++ (Yuri D'Elia)
 * Distributed under GNU LGPL without ANY warranty.
 */

// interface
#include "http.hh"

// local headers
#include "urlencode.hh"
#include "base64.hh"

// system headers
#include <stdexcept>
#include <memory>
#include <string>
using std::string;
using std::getline;

#include <sstream>
using std::istringstream;

// c system headers
#include <netdb.h>
#include <string.h>
#include <stdlib.h>


// implementation
namespace Http
{
  namespace Proto
  {
    // definitions
    const char* proto = "http";
    const char* port = "80";
    const char* protoTy = "tcp";
    const char* version = "HTTP/1.0";
    const char* endl = "\r\n";
    const char* get = "GET";
    const char* authorization = "Authorization";
    const char* basic = "Basic";
    const char* location = "Location";
  }


  std::string
  Auth::basicHeader() const
  {
    return (string(Proto::authorization) + ": " + Proto::basic + " " +
	base64Encode(user + ":" + pass));
  }


  Http::Http(const char* host, const char* port, const timeval* timeout)
  {
    this->host = strdup(host);
    this->port = strdup(port? port: Proto::port);

    if(!timeout)
      this->timeout = NULL;
    else
    {
      this->timeout = new timeval;
      *this->timeout = *timeout;
    }
  }


  Http::~Http()
  {
    free(host);
    free(port);
    if(timeout)
      delete timeout;
  }


  void
  Http::readReply(Socket& s, Reply& reply)
  {
    string proto;
    char buf[Proto::hdrLen];
    size_t bufLen;

    // read all lines
    while((bufLen = s.gets(buf, Proto::hdrLen)) > Proto::endlSz)
    {
      if(reply.headers || !proto.size())
      {
	// cut trailing newlines from the buffer
	while(strchr(Proto::endl, buf[bufLen - 1]))
	  buf[--bufLen] = 0;

	if(!proto.size())
	  proto = string(buf, bufLen);
	else if(reply.headers)
	  reply.headers->push_back(string(buf, bufLen));
      }
    }
    if(bufLen < Proto::endlSz)
      throw std::runtime_error("premature end of http headers");

    // parse the first protocol line
    istringstream in(proto);
    in >> reply.proto;
    in >> reply.code;
    in >> std::ws;
    getline(in, reply.description);
  }


  Socket*
  Http::gen(const char* act, const char* path,
      Reply& reply, const Header* headers)
  {
    using std::auto_ptr;

    auto_ptr<Socket> s(new Socket(host, port, timeout));

    // request
    string req;
    req = string(act) + " " + urlEncode(path) + " " +
      Proto::version + Proto::endl;
    req += string("Host: ") + host + Proto::endl;

    // headers
    if(headers)
      for(Header::const_iterator it = headers->begin();
	  it != headers->end(); ++it)
	req += *it + Proto::endl;

    // final newline
    req += Proto::endl;
    s->writen(req.c_str(), req.size());

    // fetch the answer headers
    readReply(*s, reply);

    return s.release();
  }


  Socket*
  Http::get(const char* file, Reply& reply, const Header* headers)
  {
    // we used to close the write end here, as HTTP/1.0 requests really end
    // here and we're very happy to relase some resources. Unfortunately,
    // SHOUTcast > 1.9 servers simply interrupt the connection when receiving
    // the notification. "We fixed all known bugs in 1.9". Aisee...
    return gen(Proto::get, file, reply, headers);
  }
}