<?php

class Net
{
    public $hostname;
    public $ip;

    private $db_user;
    private $db_passwd;
    private $db_sourcename;
    private $db_port;
    private $db_instance;

    /*errors handle*/
    public $error;
    public $errno;
    public $errstr;

    public function __construct()
    {
        $a = func_get_args();
        $f = "init" . func_num_args();

        if (method_exists($this, $f)) {
            call_user_func_array(array($this, $f), $a);
        }
    }

    /**
     * This function is the constructor of the class net
     *
     * return void
     */
    protected function init0()
    {
        $this->errno = 0;
        $this->error = "";
    }

    /**
     * This function is the constructor of the class net
     *
     * @param string $pHost
     * @return void
     */
    protected function init1($pHost)
    {
        $this->errno = 0;
        $this->errstr = "";
        $this->db_instance = "";

        unset($this->db_user);
        unset($this->db_passwd);
        unset($this->db_sourcename);

        #verifing valid param
        if ($pHost == "") {
            $this->errno = 1000;
            $this->errstr = "NET::You must specify a host";
            //$this->showMsg();
        }
        $this->resolv($pHost);
    }

    /**
     * This function puts a host
     *
     * @param string $pHost
     * @return void
     */
    public function resolv($pHost)
    {
        $aHost = explode("\\", $pHost);
        if (count($aHost) > 1) {
            $ipHost = $aHost[0];
            $this->db_instance = $aHost[1];
        } else {
            $ipHost = $pHost;
        }
        if ($this->is_ipaddress($ipHost)) {
            $this->ip = $ipHost;
            if (! $this->hostname = @gethostbyaddr($ipHost)) {
                $this->errno = 2000;
                $this->errstr = "NET::Host down";
                $this->error = G::loadTranslation('ID_HOST_UNREACHABLE');
            }
        } else {
            $ip = @gethostbyname($ipHost);
            $long = ip2long($ip);
            if ($long == - 1 || $long === false) {
                $this->errno = 2000;
                $this->errstr = "NET::Host down";
                $this->error = G::loadTranslation('ID_HOST_UNREACHABLE');
            } else {
                $this->ip = @gethostbyname($ipHost);
                $this->hostname = $pHost;
            }
        }
    }

    /**
     * This function resolves IP from Hostname returns hostname on failure
     *
     * @param string $pPort
     * @return true
     */
    public function scannPort($pPort)
    {
        define('TIMEOUT', 5);
        $hostip = @gethostbyname($host); // resloves IP from Hostname returns hostname on failure
        // attempt to connect
        if (@fsockopen($this->ip, $pPort, $this->errno, $this->errstr, TIMEOUT)) {
            return true;
            @fclose($x); //close connection (i dont know if this is needed or not).
        } else {
            $this->errno = 9999;
            $this->errstr = "NET::Port Host Unreachable";
            $this->error = G::loadTranslation('ID_PORT_UNREACHABLE');
            return false;
        }
    }

    /**
     * This function checks if it is a ip address
     *
     * @param string $pHost
     * @return true
     */
    public function is_ipaddress($pHost)
    {
        $key = true;
        #verifing if is a ip address
        $tmp = explode(".", $pHost);
        #if have a ip address format
        if (count($tmp) == 4) {
            #if a correct ip address
            for ($i = 0; $i < count($tmp); $i ++) {
                if (! is_int($tmp[$i])) {
                    $key = false;
                    break;
                }
            }
        } else {
            $key = false;
        }
        return $key;
    }

    /**
     * This function executes pin -w time IP
     *
     * @param string $pHost
     * @return true
     */
    public function ping($pTTL = 3000)
    {
        $cmd = "ping -w $pTTL $this->ip";
        $output = exec($cmd, $a, $a1);
        $this->errstr = "";
        for ($i = 0; $i < count($a); $i ++) {
            $this->errstr += $a[$i];
        }
        $this->errno = $a1;
    }

    /**
     * This function logins in db
     *
     * @param string $pUser
     * @param string $pPasswd
     * @return void
     */
    public function loginDbServer($pUser, $pPasswd)
    {
        $this->db_user = $pUser;
        $this->db_passwd = $pPasswd;
    }

    /**
     * This function sets db
     *
     * @param string $pDb
     * @param string $pPort
     * @return void
     */
    public function setDataBase($pDb, $pPort = '')
    {
        $this->db_sourcename = $pDb;
        $this->db_port = $pPort;
    }

    /**
     * This function tries to connect to server
     *
     * @param string $pDbDriver
     * @param array  $arrayServerData
     *
     * @return void
     */
    public function tryConnectServer($pDbDriver, array $arrayServerData = array(), $dbsEncode = "")
    {
        $filter = new InputFilter();
        $this->ip = $filter->validateInput($this->ip);
        $this->db_port = $filter->validateInput($this->db_port, 'int');
        $this->db_user = $filter->validateInput($this->db_user);
        $this->db_passwd = $filter->validateInput($this->db_passwd);
        $this->db_sourcename = $filter->validateInput($this->db_sourcename);
        if ($this->errno != 0) {
            return 0;
        }
        $stat = new Stat();

        if (array_key_exists("connectionType", $arrayServerData) || array_key_exists("DBS_TYPEORACLE", $arrayServerData)) {
            if ($arrayServerData["connectionType"] == "TNS" || $arrayServerData["DBS_TYPEORACLE"] == "TNS") {
                $flagTns=1;
            } else {
                $flagTns=0;
            }
        } else {
            $flagTns=0;
        }

        if (isset($this->db_user) && (isset($this->db_passwd) || $this->db_passwd == "") && (isset($this->db_sourcename) || $flagTns == 1)) {
            switch ($pDbDriver) {
                case 'mysql':
                    if ($this->db_passwd == '') {
                        $link = @mysql_connect($this->ip . (($this->db_port != '') && ($this->db_port != 0) ? ':' . $this->db_port : ''), $this->db_user);
                    } else {
                        $link = @mysql_connect($this->ip . (($this->db_port != '') && ($this->db_port != 0) ? ':' . $this->db_port : ''), $this->db_user, $this->db_passwd);
                    }
                    if ($link) {
                        if (@mysql_ping($link)) {
                            $stat->status = 'SUCCESS';
                            $this->errstr = "";
                            $this->errno = 0;
                        } else {
                            $this->error = "Lost MySql Connection";
                            $this->errstr = "NET::MYSQL->Lost Connection";
                            $this->errno = 10010;
                        }
                    } else {
                        $this->error = "MySql connection refused!";
                        $this->errstr = "NET::MYSQL->The connection was refused";
                        $this->errno = 10001;
                    }
                    break;
                case 'pgsql':
                    $this->db_port = ($this->db_port == "") ? "5432" : $this->db_port;
                    $link = @pg_connect("host='$this->ip' port='$this->db_port' user='$this->db_user' password='$this->db_passwd' dbname='$this->db_sourcename'");
                    if ($link) {
                        $stat->status = 'SUCCESS';
                        $this->errstr = "";
                        $this->errno = 0;
                    } else {
                        $this->error = "PostgreSql connection refused!";
                        $this->errstr = "NET::POSTGRES->The connection was refused";
                        $this->errno = 20001;
                    }
                    break;
                case 'mssql':
                    if ($this->db_instance != "") {
                        $str_port = "";
                        $link = @mssql_connect($this->ip . "\\" . $this->db_instance, $this->db_user, $this->db_passwd);
                    } else {
                        $str_port = (($this->db_port == "") || ($this->db_port == 0) || ($this->db_port == 1433)) ? "" : ":" . $this->db_port;
                        $link = @mssql_connect($this->ip . $str_port, $this->db_user, $this->db_passwd);
                    }

                    if ($link) {
                        $stat->status = 'SUCCESS';
                        $this->errstr = "";
                        $this->errno = 0;
                    } else {
                        $this->error = "MS-SQL Server connection refused";
                        $this->errstr = "NET::MSSQL->The connection was refused";
                        $this->errno = 30001;
                    }
                    break;
                case 'oracle':
                    try {
                        if ($flagTns == 0) {
                            $this->db_port = ($this->db_port == "" || $this->db_port == 0)? "1521" : $this->db_port;

                            $cnn = @oci_connect($this->db_user, $this->db_passwd, "(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP) (HOST=$this->ip) (PORT=$this->db_port) )) (CONNECT_DATA=(SERVICE_NAME=$this->db_sourcename)))", $dbsEncode);
                        } else {
                            $cnn = @oci_connect($this->db_user, $this->db_passwd, $arrayServerData["tns"], $dbsEncode);
                        }

                        if ($cnn) {
                            $stat->status = "SUCCESS";
                            $this->errstr = "";
                            $this->errno = 0;
                        } else {
                            $this->error = "Oracle connection refused";
                            $this->errstr = "NET::ORACLE->The connection was refused";
                            $this->errno = 30001;
                        }
                    } catch (Exception $e) {
                        throw new Exception("[erik] Couldn't connect to Oracle Server! - " . $e->getMessage());
                    }
                    break;
                case 'informix':
                    break;
                case 'sqlite':
                    break;
            }
        } else {
            throw new Exception("CLASS::NET::ERROR: No connections param.");
        }

        return $stat;
    }

    /**
     * This function tries to open to the DB
     *
     * @param string $pDbDriver
     * @param array  $arrayServerData
     *
     * @return void
     */
    public function tryOpenDataBase($pDbDriver, array $arrayServerData = array(), $dbsEncode = "")
    {
        $filter = new InputFilter();
        $this->ip = $filter->validateInput($this->ip);
        $this->db_port = $filter->validateInput($this->db_port, 'int');
        $this->db_user = $filter->validateInput($this->db_user);
        $this->db_passwd = $filter->validateInput($this->db_passwd);
        $this->db_sourcename = $filter->validateInput($this->db_sourcename);
        if ($this->errno != 0) {
            return 0;
        }

        set_time_limit(0);
        $stat = new Stat();

        if (array_key_exists("connectionType", $arrayServerData) || array_key_exists("DBS_TYPEORACLE", $arrayServerData)) {
            if ($arrayServerData["connectionType"] == "TNS" || $arrayServerData["DBS_TYPEORACLE"] == "TNS") {
                $flagTns=1;
            } else {
                $flagTns=0;
            }
        } else {
            $flagTns=0;
        }

        if (isset($this->db_user) && (isset($this->db_passwd) || $this->db_passwd == "") && (isset($this->db_sourcename) || $flagTns == 1)) {
            switch ($pDbDriver) {
                case 'mysql':
                    $link = @mysql_connect($this->ip . (($this->db_port != '') && ($this->db_port != 0) ? ':' . $this->db_port : ''), $this->db_user, $this->db_passwd);
                    $db = @mysql_select_db($this->db_sourcename);
                    if ($link) {
                        if ($db) {
                            $result = @mysql_query("show tables;");
                            if ($result) {
                                $stat->status = 'SUCCESS';
                                $this->errstr = "";
                                $this->errno = 0;
                                @mysql_free_result($result);
                            } else {
                                $this->error = "the user $this->db_user doesn't have privileges to run queries!";
                                $this->errstr = "NET::MYSQL->Test query failed";
                                $this->errno = 10100;
                            }
                        } else {
                            $this->error = "The $this->db_sourcename data base does'n exist!";
                            $this->errstr = "NET::MYSQL->Select data base failed";
                            $this->errno = 10011;
                        }
                    } else {
                        $this->error = "MySql connection refused!";
                        $this->errstr = "NET::MYSQL->The connection was refused";
                        $this->errno = 10001;
                    }
                    break;
                case 'pgsql':
                    $this->db_port = (($this->db_port == "") || ($this->db_port == 0)) ? "5432" : $this->db_port;
                    $link = @pg_connect("host='$this->ip' port='$this->db_port' user='$this->db_user' password='$this->db_passwd' dbname='$this->db_sourcename'");
                    if ($link) {
                        if (@pg_ping($link)) {
                            $stat->status = 'SUCCESS';
                            $this->errstr = "";
                            $this->errno = 0;
                        } else {
                            $this->error = "PostgreSql Connection to $this->ip is  unreachable!";
                            $this->errstr = "NET::POSTGRES->Lost Connection";
                            $this->errno = 20010;
                        }
                    } else {
                        $this->error = "PostgrSql connection refused";
                        $this->errstr = "NET::POSTGRES->The connection was refused";
                        $this->errno = 20001;
                    }
                    break;
                case 'mssql':
                    //          $str_port = (($this->db_port == "")  || ($this->db_port == 0) || ($this->db_port == 1433)) ? "" : ":".$this->db_port;
                    //          $link = @mssql_connect($this->ip . $str_port, $this->db_user, $this->db_passwd);
                    if ($this->db_instance != "") {
                        $str_port = "";
                        $link = @mssql_connect($this->ip . "\\" . $this->db_instance, $this->db_user, $this->db_passwd);
                    } else {
                        $str_port = (($this->db_port == "") || ($this->db_port == 0) || ($this->db_port == 1433)) ? "" : ":" . $this->db_port;
                        $link = @mssql_connect($this->ip . $str_port, $this->db_user, $this->db_passwd);
                    }
                    if ($link) {
                        $db = @mssql_select_db($this->db_sourcename, $link);
                        if ($db) {
                            $stat->status = 'SUCCESS';
                            $this->errstr = "";
                            $this->errno = 0;
                        } else {
                            $this->error = "The $this->db_sourcename data base does'n exist!";
                            $this->errstr = "NET::MSSQL->Select data base failed";
                            $this->errno = 30010;
                        }
                    } else {
                        $this->error = "MS-SQL Server connection refused!";
                        $this->errstr = "NET::MSSQL->The connection was refused";
                        $this->errno = 30001;
                    }
                    break;
                case 'oracle':
                    if ($flagTns == 0) {
                        $this->db_port = ($this->db_port == "" || $this->db_port == 0)? "1521" : $this->db_port;

                        $cnn = @oci_connect($this->db_user, $this->db_passwd, "(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP) (HOST=$this->ip) (PORT=$this->db_port) )) (CONNECT_DATA=(SERVICE_NAME=$this->db_sourcename)))", $dbsEncode);
                    } else {
                        $cnn = @oci_connect($this->db_user, $this->db_passwd, $arrayServerData["tns"], $dbsEncode);
                    }

                    if ($cnn) {
                        $stid = @oci_parse($cnn, 'select AUTHENTICATION_TYPE from v$session_connect_info');
                        $result = @oci_execute($stid, OCI_DEFAULT);
                        if ($result) {
                            $stat->status = 'SUCCESS';
                            $this->errstr = "";
                            $this->errno = 0;
                            @oci_close($cnn);
                        } else {
                            $this->error = "the user $this->db_user doesn't have privileges to run queries!";
                            $this->errstr = "NET::ORACLE->Couldn't execute any query on this server!";
                            $this->errno = 40010;
                        }
                    } else {
                        $this->error = "Oracle connection refused!";
                        $this->errstr = "NET::ORACLE->The connection was refused";
                        $this->errno = 40001;
                    }
                    break;
                case 'informix':
                    break;
                case 'sqlite':
                    break;
            }
        } else {
            throw new Exception("CLASS::NET::ERROR: No connections param.");
        }
        return $stat;
    }

    /**
     * This function gets DB-s version
     *
     * @param string $driver
     * @return void
     */
    public function getDbServerVersion($driver)
    {
        if (! isset($this->ip)) {
            $this->ip = getenv('HTTP_CLIENT_IP');
        }

        if (isset($this->ip) && isset($this->db_user) && isset($this->db_passwd)) {
            try {
                if (! isset($this->db_sourcename)) {
                    $this->db_sourcename = DB_NAME;
                }
                $value = 'none';
                $sDataBase = 'database_' . strtolower(DB_ADAPTER);
                if (G::LoadSystemExist($sDataBase)) {
                    $oDataBase = new database();
                    $value = $oDataBase->getServerVersion($driver, $this->ip, $this->db_port, $this->db_user, $this->db_passwd, $this->db_sourcename);
                }
                return $value;
            } catch (Exception $e) {
                throw new Exception($e->getMessage());
            }
        } else {
            throw new Exception('NET::Error->No params for Data Base Server!');
        }
    }

    /**
     * This function reurns DB name
     *
     * @param string $pAdapter
     * @return void
     */
    public function dbName($pAdapter)
    {
        switch ($pAdapter) {
            case 'mysql':
                return 'MySql';
                break;
            case 'pgsql':
                return 'PostgreSQL';
                break;
            case 'mssql':
                return 'Microsoft SQL Server';
                break;
            case 'oracle':
                return 'Oracle';
                break;
            case 'informix':
                return 'Informix';
                break;
            case 'sqlite':
                return 'SQLite';
                break;
        }
    }

    /**
     * If there is an error then it shows
     *
     * @param string $pAdapter
     * @return void
     */
    public function showMsg()
    {
        if ($this->errno != 0) {
            $msg = "
    <center>
    <fieldset style='width:90%'><legend>Class NET</legend>
      <div align=left>
      <font color='red'>
        <b>NET::ERROR NO -> $this->errno<br/>
        NET::ERROR MSG -> $this->errstr</b>
      </font>
      </div>
    </fieldset>
    <center>";
            print($msg) ;
        }
    }

    /**
     * This function gets an error
     * param
     *
     * @return string
     */
    public function getErrno()
    {
        return $this->errno;
    }

    /**
     * This function gets an error message
     * param
     *
     * @return string
     */
    public function getErrmsg()
    {
        return $this->errstr;
    }
}