Socket.php

   1 <?php
   2 /* $Id: socket.php,v 1.3 2002/09/08 19:25:02 shaggy Exp $ */
   3
   4 /*
   5 Copyright (c) 2001, 2002 by Martin Tsachev. All rights reserved.
   6 http://www.mtweb.org
   7
   8 Redistribution and use in source and binary forms,
   9 with or without modification, are permitted provided
  10 that the conditions available at
  11 http://www.opensource.org/licenses/bsd-license.html
  12 are met.
  13 */
  14
  15 // From http://www.mtdev.com/download/2002/09/http-keep-alive-connections-in-php/socket.phps
  16
  17 Class Socket {
  18         var $fp = null;
  19         var $host;
  20         var $ssl;
  21         var $timeout = 30;
  22         var $maxlen = 4096;
  23
  24         var $accept = 'text/plain'; // MIME types to accept
  25         var $lang = 'en'; // Language to accept
  26
  27         var $headers; // response headers
  28         var $body; // response body
  29
  30         var $status; // HTTP status
  31         var $connection; // Connection type: close/keep-alive
  32         var $te; // Transfer encoding
  33         var $type; // returned MIME type
  34
  35
  36         function Socket($host, $ssl=false) {
  37                 $this->host = $host;
  38                 $this->ssl = $ssl;
  39         }
  40
  41
  42         function setAccept($types) {
  43                 $this->accept = $types;
  44         }
  45
  46
  47         function connect() {
  48           $port = 80;
  49           $host = $this->host;
  50           if ($this->ssl) {
  51             $host = "ssl://$host";
  52             $port = 443;
  53           }
  54                 $this->fp = fsockopen($host, $port, $errno, $errstr, $this->timeout);
  55
  56                 if (!$this->fp) {
  57                         return "Network error: $errstr ($errno)";
  58                 }
  59
  60                 return 0;
  61         }
  62
  63
  64         function disconnect() {
  65                 fclose($this->fp);
  66         }
  67
  68
  69         function get($uri) {
  70                 $request =
  71                         "GET $uri HTTP/1.1\r\n" .
  72                         "Host: $this->host\r\n" .
  73                         "Connection: Keep-Alive\r\n" .
  74                   //"Accept: $this->accept\r\n" .
  75                   //"Accept-Language: $this->lang\r\n" .
  76                   //"Accept-Encoding: chunked\r\n" .
  77                   //"User-Agent: PHP/4.2.1\r\n" .
  78                         "\r\n";
  79
  80                 fputs($this->fp, $request);
  81
  82                 $this->headers = fgets($this->fp, $this->maxlen);
  83                 if (!$this->headers) { // if disconnected meanwhile
  84                         $this->connect();
  85                         fputs($this->fp, $request);
  86                         $this->headers = fgets($this->fp, $this->maxlen);
  87                 }
  88
  89                 preg_match('|^HTTP.+? (\d+?) |', $this->headers, $matches);
  90                 $this->status = $matches[1];
  91
  92                 $this->type = '';
  93                 $this->connection = '';
  94                 $this->te = '';
  95
  96                 while ($line = fgets($this->fp, $this->maxlen)) {
  97                         if ($line == "\r\n") { break; }
  98
  99                         if (preg_match('/^Content-Length: (.+)/', $line, $matches)) {
 100                                 $length = (int) trim($matches[1]);
 101                         }
 102
 103                         if (preg_match('/^Content-Type: (.+)/', $line, $matches)) {
 104                                 $this->type = strtolower(trim($matches[1]));
 105                         }
 106
 107                         if (preg_match('/^Connection: (.+)/', $line, $matches)) {
 108                                 $this->connection = strtolower(trim($matches[1]));
 109                         }
 110
 111                         if (preg_match('/^Transfer-Encoding: (.+)/', $line, $matches)) {
 112                                 $this->te = strtolower(trim($matches[1]));
 113                         }
 114
 115                         $this->headers .= $line;
 116                 }
 117
 118                 $this->body = '';
 119                 if ($this->connection == 'close') {
 120                         while (!feof($this->fp)) {
 121                                 $this->body .= fread($this->fp, $this->maxlen);
 122                         }
 123                         return ;
 124                 }
 125
 126                 if (isset($length) and strpos($this->te, 'chunked') === false) {
 127                   $this->body = '';
 128                   while ($length > 0) {
 129                     $str = fread($this->fp, $length);
 130                     $this->body .= $str;
 131                     $length -= strlen($str);
 132                   }
 133                   return ;
 134                 }
 135
 136                 // chunked encoding
 137                 $length = rtrim(fgets($this->fp, $this->maxlen));
 138                 $length = hexdec($length);
 139
 140                 while (true) {
 141                         if ($length < 1) { break; }
 142                         $this->body .= fread($this->fp, $length);
 143
 144                         fgets($this->fp, $this->maxlen);
 145                         $length = rtrim(fgets($this->fp, $this->maxlen));
 146                         $length = hexdec($length);
 147                 }
 148
 149                 fgets($this->fp, $this->maxlen);
 150         }
 151
 152 } // class Socket
 153 ?>