<?php

/*
Copyright (c) Balamurugan S, 2006. sbalamurugan at hotmail.com
Development support by Jexp, Inc http://www.jexp.com 

This package is free software. It is distributed under LGPL - 
legalese removed, it means that you can use this for any purpose, 
but cannot charge for this software. Any enhancements you make 
to this piece of code, should be made available free to the general 
public! You should carry this copyright notice with your distribution 
and a link to the original page so users can download the latest version
free!

Latest version can be downloaded from http://www.sbmkpm.com

This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  
*/

// Get google
//get("www.google.com", "80", "/");

// Get a specific resource 
//get("www.google.com","80", "/terms_of_service.html");

// Get a specific resource and pass query string
//get("www.google.com", "80", "/search?q=test");

// Post a request (Google doesn't process POST requests!)
//post("search.yahoo.com", "80", "/search","p=test&sm=Yahoo+Search");

function get($host, $port, $url)
 {
  $data = contactServer($host, $port, "GET", $url, "");
  $result = parseData($data);

  if( $result["status"] == "200")
    {
      echo  $result["responseText"];
    }
  else
    {
      echo  "Error:".$result['statusText'];
      echo   $result["status"];
      echo   $result["responseText"];
    }
 }

function post($host, $port, $url, $qs)
 {
  $data = contactServer($host, $port, "POST", $url, $qs);
  $result = parseData($data);

  if( $result["status"] == "200")
    {
      echo  $result["responseText"];
    }
  else
    {
      echo  "Error:".$result['statusText'];
      echo   $result["status"];
      echo   $result["responseText"];
    }
 }


// ------------------------------------------------------------------------
// Following are the actual functions that do the work
// ------------------------------------------------------------------------

    function contactServer($host, $port, $method, $resource, $qs) {
        $fp = fsockopen($host, $port, $errno, $errstr, 10);
        if(!$fp) 
           return "";

        $out = $method." ".$resource." HTTP/1.0\r\n";
        $out .= "Host: ".$host."$port\r\n";
        if($method == 'POST')
	  {
            $out .= "Content-Type: application/x-www-form-urlencoded\r\n";
            $out .= 'Content-Length: '.strlen($qs)."\r\n";
            $out .= "Connection: Close\r\n\r\n";
            $out .= $qs; 
          }
        else
          {
            $out .= "Connection: Close\r\n\r\n";
          }

        fwrite($fp, $out); $data = "";
        while (!feof($fp)) { $data .= fgets($fp, 128); }
        fclose($fp);
        return $data;
    }

    function parseData($data) {
        $result = Array();
        $result['success'] = true;

        $result['responseHeaders'] = Array();
        $headers = substr($data, 0, strpos($data, "\r\n\r\n"));
        $headers = explode("\r\n", $headers);
        for ($i = 1; $i < count($headers); $i++) {
            $header = splitData(":", $headers[$i], 2);
            $result['responseHeaders'][$header[0]] = trim($header[1]);
        }
        
        $status = explode(' ', $headers[0]);
        $result['status'] = $status[1];
        $result['statusText'] = $status[2];

        $data = substr($data, strpos($data, "\r\n\r\n") + 4);

        $data = trim($data);

        $result["responseText"] = $data;

        return $result;
    }
    
    function splitData($separator, $data, $length) {
        if(!$separator) return Array();
        if(!$data) return Array();
        $data = explode($separator, $data);
        if($length) {
            while(count($data) > $length) {
                $data[count($data)-2] .= $separator.$data[count($data)-1];
                array_pop($data);
            }
        }
        return $data;
    }
    
?>