mirror of
https://github.com/EGroupware/egroupware.git
synced 2024-12-23 07:09:20 +01:00
188 lines
5.1 KiB
PHP
188 lines
5.1 KiB
PHP
|
<?php
|
||
|
/**************************************************************************\
|
||
|
* phpGroupWare Library (Network) *
|
||
|
* http://www.phpgroupware.org *
|
||
|
* Written by Mark Peters <mpeters@satx.rr.com> *
|
||
|
* -------------------------------------------- *
|
||
|
* This program is free software; you can redistribute it and/or modify it *
|
||
|
* under the terms of the GNU General Public License as published by the *
|
||
|
* Free Software Foundation; either version 2 of the License, or (at your *
|
||
|
* option) any later version. *
|
||
|
\**************************************************************************/
|
||
|
|
||
|
/* $Id$ */
|
||
|
|
||
|
class network
|
||
|
{
|
||
|
var $socket;
|
||
|
var $addcrlf = TRUE;
|
||
|
var $error;
|
||
|
var $errorset = 0;
|
||
|
|
||
|
function network($addcrlf=true)
|
||
|
{
|
||
|
$this->errorset = 0;
|
||
|
$this->set_addcrlf($addcrlf);
|
||
|
}
|
||
|
|
||
|
function set_addcrlf($value)
|
||
|
{
|
||
|
$this->addcrlf = $value;
|
||
|
}
|
||
|
|
||
|
function set_error($code,$msg,$desc)
|
||
|
{
|
||
|
$this->error = array("code","msg","desc");
|
||
|
$this->error["code"] = $code;
|
||
|
$this->error["msg"] = $msg;
|
||
|
$this->error["desc"] = $desc;
|
||
|
// $this->close_port();
|
||
|
$this->errorset = 1;
|
||
|
return 0;
|
||
|
}
|
||
|
|
||
|
function open_port($server,$port,$timeout=15)
|
||
|
{
|
||
|
global $phpgw_info;
|
||
|
|
||
|
switch($port) {
|
||
|
case 80:
|
||
|
case 443:
|
||
|
if((isset($phpgw_info["server"]["httpproxy_server"]) && $phpgw_info["server"]["httpproxy_server"]) &&
|
||
|
(isset($phpgw_info["server"]["httpproxy_port"]) && $phpgw_info["server"]["httpproxy_port"])) {
|
||
|
$server = $phpgw_info["server"]["httpproxy_server"];
|
||
|
$port = (int)$phpgw_info["server"]["httpproxy_port"];
|
||
|
}
|
||
|
break;
|
||
|
}
|
||
|
if(floor(phpversion()) == 4)
|
||
|
$this->socket = fsockopen($server,$port,&$errcode,&$errmsg,$timeout);
|
||
|
else
|
||
|
$this->socket = fsockopen($server,$port,&$errcode,&$errmsg);
|
||
|
if (!$this->socket) {
|
||
|
return $this->set_error("Error","$errcode:$errmsg","Connection to $server:$port failed - could not open socket.");
|
||
|
} else {
|
||
|
return 1;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function close_port()
|
||
|
{
|
||
|
return fclose($this->socket);
|
||
|
}
|
||
|
|
||
|
function read_port()
|
||
|
{
|
||
|
return fgets($this->socket, 1024);
|
||
|
}
|
||
|
|
||
|
function bs_read_port($bytes)
|
||
|
{
|
||
|
return fread($this->socket, $bytes);
|
||
|
}
|
||
|
|
||
|
function write_port($str)
|
||
|
{
|
||
|
if (isset($this->addcrlf) && $this->addcrlf == True) $str .= "\r\n";
|
||
|
|
||
|
$ok = fputs($this->socket,$str);
|
||
|
if (!$ok)
|
||
|
{
|
||
|
return $this->set_error("Error","Connection Lost","lost connection to server");
|
||
|
} else {
|
||
|
return 1;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function bs_write_port($str,$bytes=0)
|
||
|
{
|
||
|
if (isset($this->addcrlf) && $this->addcrlf == True) $str .= "\r\n";
|
||
|
|
||
|
if ($bytes)
|
||
|
$ok = fwrite($this->socket,$str,$bytes);
|
||
|
else
|
||
|
$ok = fwrite($this->socket,$str);
|
||
|
|
||
|
if (!$ok)
|
||
|
{
|
||
|
return $this->set_error("Error","Connection Lost","lost connection to server");
|
||
|
} else {
|
||
|
return 1;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
function msg2socket($str,$expected_response,$response)
|
||
|
{
|
||
|
if(!$this->socket && substr($expected_response,1,1) == "+") {
|
||
|
return $this->set_error("521",
|
||
|
"socket does not exist",
|
||
|
"The required socket does not exist. The settings for your mail server may be wrong.");
|
||
|
}
|
||
|
if (!$this->write_port($str)) {
|
||
|
if(substr($expected_response,1,1) == "+") {
|
||
|
return $this->set_error("420",
|
||
|
"lost connection",
|
||
|
"Lost connection to pop server.");
|
||
|
} else {
|
||
|
return 0;
|
||
|
}
|
||
|
}
|
||
|
$response = $this->read_port();
|
||
|
if (!ereg(strtoupper($expected_response),strtoupper($response))) {
|
||
|
if(substr($expected_response,1,1) == "+") {
|
||
|
return $this->set_error("550",
|
||
|
"",
|
||
|
"");
|
||
|
}
|
||
|
$pos = strpos(" ",$response);
|
||
|
return $this->set_error(substr($response,0,$pos),
|
||
|
"invalid response($expected_response)",
|
||
|
substr($response,($pos + 1),(strlen($response)-$pos)));
|
||
|
} else {
|
||
|
return 1;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
// return contents of a web url as an array or false if timeout
|
||
|
function gethttpsocketfile($file)
|
||
|
{
|
||
|
global $phpgw_info;
|
||
|
|
||
|
$server = str_replace("http://","",$file);
|
||
|
$file = strstr($server,"/");
|
||
|
$server = str_replace("$file","",$server);
|
||
|
if ($phpgw_info["server"]["httpproxy_server"]) {
|
||
|
if ($this->open_port($server,80, 15)) {
|
||
|
if (! $this->write_port("GET http://" . $server . $file . " HTTP/1.0\n\n")) {
|
||
|
return False;
|
||
|
}
|
||
|
$i = 0;
|
||
|
while ($line = $this->read_port()) {
|
||
|
if (feof($this->socket)) {
|
||
|
break;
|
||
|
}
|
||
|
$lines[] = $line;
|
||
|
$i++;
|
||
|
}
|
||
|
$this->close_port();
|
||
|
return $lines;
|
||
|
} else {
|
||
|
return False;
|
||
|
}
|
||
|
} else {
|
||
|
if ($this->open_port($server, 80, 15)) {
|
||
|
if (!$this->write_port("GET $file HTTP/1.0\nHost: $server\n\n")) {
|
||
|
return 0;
|
||
|
}
|
||
|
while ($line = $this->read_port()) {
|
||
|
$lines[] = $line;
|
||
|
}
|
||
|
$this->close_port();
|
||
|
return $lines;
|
||
|
} else {
|
||
|
return 0;
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
}
|