<?php
 ignore_user_abort(true);
 
 define ('METHOD_GET',			0x01);
 define ('METHOD_POST',			0x02);
 define ('METHOD_HEAD',			0x04);
 define ('USE_PROXY_HTTP',		0x08);
 define ('USE_PROXY_SOCKS4',	0x10);
 define ('USE_PROXY_SOCKS5',	0x20);
 
 class httprequest {
  private $opts = 0;
  private $headers = Array();
  private $socket;
  private $contents = Array();
  private $buffer = 4096;
  private $gheaders = Array();
  private $repcode = 0;
  private $proxy = Array();
  private $last = false;
  
  public final function __construct($w = 'GET') {
   if (!in_array(strtoupper($w), Array('GET', 'POST', 'HEAD'))) {
    throw new Exception ('Methode http incorrecte');
    return false;
   }
   if (!strcasecmp($w, 'GET')) $this->opts |= METHOD_GET;
   else if (!strcasecmp($w, 'POST')) $this->opts |= METHOD_POST;
   else if (!strcasecmp($w, 'HEAD')) $this->opts |= METHOD_HEAD;
   return true;
  }
  
  public final function setproxy($ip, $port, $w = USE_PROXY_HTTP) {
   if ((!is_numeric($port)) || (!in_array($w, Array(USE_PROXY_HTTP, USE_PROXY_SOCKS4, USE_PROXY_SOCKS5)))) {
    throw new Exception ('Parametres proxy incorrects');
    return false;
   }
   $this->opts |= ~(USE_PROXY_HTTP|USE_PROXY_SOCKS4|USE_PROXY_SOCKS5);
   $this->opts |= $w;
   $this->proxy = Array($ip, $port);
   return true;
  }
  
  public final function cleardata() {
   $this->contents = $this->gheaders = Array();
   $this->repcode = 0;
   $this->last = false;
  }
  
  public final function setheader($header, $value) {
   $header = trim($header);
   if (substr($header, -1, 1) == ':') $header = substr($header, 0, -1);
   $this->headers[strtolower($header)] = $value;
   return true;
  }
  
  private final function getheader($header) {
   $h = strtolower($header);
   return isset($this->headers[$h]) ? $this->headers[$h] : false;
  }
  
  public final function getheaders() {
   return $this->gheaders;
  }
  
  public final function getcookies() {
   $c = Array();
   foreach ($this->gheaders as $a => $b) {
    if (!strcasecmp($b[0], 'set-cookie')) {
     if (preg_match('/^([^;]+)/', $b[1], $r)) $c[] = $r[1];
    }
   }
   return $c;
  }
  
  public final function close() {
   if ($this->socket) @fclose($this->socket);
  }
  
  public final function addcontent($name, $content) {
   $this->contents[$name] = $content;
   return true;
  }
  
  private final function proxy_http($host, $port) {
   if (!$this->writeline('CONNECT '.$host.':'.$port.' HTTP/1.0'."\r\n".'Host: '.$this->proxy[0].':'.$this->proxy[1]."\r\n".'User-agent: Mozilla/5.0'."\r\n")) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   if (!preg_match('/^HTTP\/1\.\d 200/', $this->readline())) {
    throw new Exception ('Erreur de connexion à l\'hote via le proxy (code invalide)');
    return false;
   }
   $b = false;
   while (($a = $this->readline()) !== false) {
    if ($a == "\r\n") {
     $b = true;
     break;
    }
   }
   return $b;
  }
  
  private final function proxy_socks5($host, $port) {
   if (!$this->writeline("\x05\x01\x00", false)) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   $b = $this->readline(10, true);
   if ($b === false) {
    throw new Exception ('Erreur de lecture');
    return false;
   }
   if ((isset($b[1])) && ($b{1} == "\x00")) {
    if (!$this->writeline("\x05\x01\x00\x03".chr(strlen($host) % 256).$host.chr($port / 256).chr($port % 256), false)) {
     throw new Exception ('Erreur d\'ecriture');
     return false;
    }
    $b = $this->readline(10, true);
    if ($b === false) {
     throw new Exception ('Erreur de lecture');
     return false;
    }
    echo ord($b{0});
    if ((isset($b{1})) && ($b{1} == "\x00")) return true;
   }
   return false;
  }
  
  private final function proxy_socks4($host, $port) {
   if (!$this->writeline("\x04\x01".chr(($port / 256)).chr($port % 256)."\x00\x00\x00".chr(rand(1, 255))."\x00".$host."\x00")) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   if (($b = @$this->readline(10, true)) === false) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   if ((isset($b{1})) && ($b{1} == "\x5A")) return true;
   return false;
  }
  
  public final function go($url) {
   $u = @parse_url($url);
   if (($u === false) || (!isset($u['scheme'])) || (!isset($u['host']))) {
    throw new Exception ('Url de destination incorrecte');
    return false;   
   }
   
   if ($this->opts & (USE_PROXY_HTTP|USE_PROXY_SOCKS4|USE_PROXY_SOCKS5)) {
    if (!$this->socket = @fsockopen($this->proxy[0], $this->proxy[1], $errno = NULL, $errstr = NULL, 5)) {
     throw new Exception ('Impossible de se connecter au serveur proxy.');
     return false;
    }
    if ($this->opts & USE_PROXY_HTTP) {
     if (!$this->proxy_http($u['host'], (isset($u['port']) ? $u['port'] : 80))) {
      throw new Exception ('Impossible d\'utiliser le proxy');
      return false;
     }
    }
    else if ($this->opts & USE_PROXY_SOCKS4) {
     if (!$this->proxy_socks4($u['host'], (isset($u['port']) ? $u['port'] : 80))) {
      throw new Exception ('Impossible d\'utiliser le proxy');
      return false;
     }
    }
    else if ($this->opts & USE_PROXY_SOCKS5) {
     if (!$this->proxy_socks5($u['host'], (isset($u['port']) ? $u['port'] : 80))) {
      throw new Exception ('Impossible d\'utiliser le proxy');
      return false;
     }
    }
   }
   else if (!$this->socket = @fsockopen($u['host'], (isset($u['port']) ? $u['port'] : 80), $errno = NULL, $errstr, 5)) {
    throw new Exception ('Impossible de se connecter à l\'hote distant '.$errstr);
    return false;
   }
   $request = isset($u['path']) ? $u['path'] : '/';
   if (isset($u['query'])) $request .= '?'.$u['query'];
   if ($this->opts & METHOD_GET) {
    if (!$this->writeline('GET '.$request.' HTTP/1.0')) {
     throw new Exception ('Erreur d\'ecriture');
     return false;
    }
   }
   else if ($this->opts & METHOD_POST) {
    if (!$this->writeline('POST '.$request.' HTTP/1.0')) {
     throw new Exception ('Erreur d\'ecriture');
     return false;
    }
   }
   else if ($this->opts & METHOD_HEAD) {
    if (!$this->writeline('HEAD '.$request.' HTTP/1.0')) {
     throw new Exception ('Erreur d\'ecriture');
     return false;
    }
   }
   if (!$this->writeline('host: '.$u['host'].':'.(isset($u['port']) ? $u['port'] : 80))) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   
   $q = '';
   
   if (($this->opts & METHOD_POST) && ($this->contents)) {
    if ($this->getheader('content-type') === false) $this->setheader('content-type', 'application/x-www-form-urlencoded');
    $q = http_build_query($this->contents);
    if ($this->getheader('content-length') === false) $this->setheader('content-length', strlen($q));
   }
   foreach ($this->headers as $v => $w) {
    if (!$this->writeline($v.': '.$w)) {
     throw new Exception ('Erreur d\'ecriture');
     return false;
    }
   }
   if (!$this->writeline('')) {
    throw new Exception ('Erreur d\'ecriture');
    return false;
   }
   if (($this->opts & METHOD_POST) && ($q != '')) {
    $r = explode("\0", wordwrap($q, $this->buffer, "\0", true));
    foreach ($r as $s) {
     if (!$this->writeline($s, false)) {
      throw new Exception ('Erreur d\'ecriture');
      return false;
     }
    }
   }
   while (($g = $this->readline()) !== false) {
    if ($g == "\r\n") break;
    if (preg_match('/^HTTP\/1\.\d (\d+) /', $g, $r)) $this->repcode = $r[1];
    else if (preg_match('/^([^:]+):([^\r\n]+)/', $g, $r)) $this->gheaders[] = Array($r[1], trim($r[2]));
   }
   if ($this->repcode == 0) {
    throw new Exception ('Erreur de lecture :: Pas de header http correct ?');
    return false;
   }
   return $this->repcode;
  }
  
  public final function readline($buffer = 1024, $force = false) {
   if (!$this->socket) return false;
   if ($force) {
    if ($this->last) {
     $this->last = false;
     return substr(@fread($this->socket, $buffer+1), 1);
    }
    return @fread($this->socket, $buffer);
   }
   else {
    $this->last = true;
    return @fgets($this->socket, $buffer);
   }
  }
  
  public final function readall() {
   return @stream_get_contents($this->socket);
  }
  
  private final function writeline($line, $lf = true) {
   if ($lf) $line .= "\r\n";
   if ((@fwrite($this->socket, $line)) !== false) return true;
   return false;
  }
  
  public final function getasxml() {
   return @simplexml_load_string($this->readall());
  }
  
 }
?>