<?php

namespace Cacic\CommonBundle\Helper;

define("FTP_TIMEOUT",90);

// FTP Statuscodes
define("FTP_COMMAND_OK"				,200);
define("FTP_FILE_ACTION_OK"			,250);
define("FTP_FILE_TRANSFER_OK"		,226);
define("FTP_COMMAND_NOT_IMPLEMENTED",502);
define("FTP_FILE_STATUS"			,213);
define("FTP_NAME_SYSTEM_TYPE"		,215);
define("FTP_PASSIVE_MODE"			,227);
define("FTP_PATHNAME"				,257);
define("FTP_SERVICE_READY"			,220);
define("FTP_USER_LOGGED_IN"			,230);
define("FTP_PASSWORD_NEEDED"		,331);
define("FTP_USER_NOT_LOGGED_IN"		,530);
define("FTP_PERMISSION_DENIED"		,550); // by Anderson PETERLE

if (!defined("FTP_ASCII"))
    define("FTP_ASCII",0);

if (!defined("FTP_BINARY"))
    define("FTP_BINARY",1);


class FTP
{
    var $passiveMode 	= TRUE;
    var $lastLines 		= array();
    var $lastLine 		= "";
    var $controlSocket 	= NULL;
    var $newResult 		= FALSE;
    var $lastResult 	= -1;
    var $pasvAddr 		= NULL;
    var $error_no 		= NULL;
    var $error_msg 		= NULL;

    function FTP()
    {
    }

    function connect($host, $port=21, $timeout=FTP_TIMEOUT)
    { //Opens an FTP connection
        $this->_resetError();

        $err_no = 0;
        $err_msg = "";
        $this->controlSocket = @fsockopen($host, $port, $err_no, $err_msg, $timeout) or $this->_setError(-1,"fsockopen failed");
        if ($err_no <> 0)
            $this->setError($err_no,$err_msg);

        if ($this->_isError())
            return false;

        @socket_set_timeout($this->controlSocket,$timeout) or $this->_setError(-1,"socket_set_timeout failed");
        if ($this->_isError())
            return false;

        $this->_waitForResult();
        if ($this->_isError())
            return false;

        return $this->getLastResult() == FTP_SERVICE_READY;
    }

    function isConnected()
    {
        return $this->controlSocket != NULL;
    }

    function disconnect()
    {
        if (!$this->isConnected())
            return;
        @fclose($this->controlSocket);
    }

    function close()
    { //Closes an FTP connection
        $this->disconnect();
    }

    function login($user, $pass)
    {  //Logs in to an FTP connection
        $this->_resetError();

        $this->_printCommand("USER $user");
        if ($this->_isError())
            return false;

        $this->_waitForResult();
        if ($this->_isError())
            return false;

        if ($this->getLastResult() == FTP_PASSWORD_NEEDED)
        {
            $this->_printCommand("PASS $pass");
            if ($this->_isError())
                return FALSE;

            $this->_waitForResult();
            if ($this->_isError())
                return FALSE;
        }

        $result = $this->getLastResult() == FTP_USER_LOGGED_IN;
        return $result;
    }

    function cdup()
    { //Changes to the parent directory
        $this->_resetError();

        $this->_printCommand("CDUP");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return ($lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function cwd($path)
    {
        $this->_resetError();

        $this->_printCommand("CWD $path");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return ($lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function cd($path)
    {
        return $this->cwd($path);
    }

    function chdir($path)
    { //Changes directories on a FTP server
        return $this->cwd($path);
    }

    function chmod($mode,$filename)
    { //Set permissions on a file via FTP
        return $this->site("CHMOD $mode $filename");
    }

    function delete($filename)
    { //Deletes a file on the FTP server
        $this->_resetError();

        $this->_printCommand("DELE $filename");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return ($lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function exec($cmd)
    { //Requests execution of a program on the FTP server
        return $this->site("EXEC $cmd");
    }

    function fget($fp,$remote,$mode=FTP_BINARY,$resumepos=0)
    { //Downloads a file from the FTP server and saves to an open file
        $this->_resetError();

        $type = "I";
        if ($mode==FTP_ASCII)
            $type = "A";

        $this->_printCommand("TYPE $type");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;

        $result = $this->_download("RETR $remote");
        if ($result)
            fwrite($fp,$result);

        return $result;
    }

    function fput($remote,$resource,$mode=FTP_BINARY,$startpos=0)
    { //Uploads from an open file to the FTP server
        $this->_resetError();

        $type = "I";
        if ($mode==FTP_ASCII)
            $type = "A";

        $this->_printCommand("TYPE $type");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;

        if ($startpos > 0)
            fseek($resource,$startpos);
        $result = $this->_uploadResource("STOR $remote",$resource);
        return $result;
    }

    function get_option($option)
    { //Retrieves various runtime behaviours of the current FTP stream
        $this->_resetError();

        switch ($option)
        {
            case "FTP_TIMEOUT_SEC" :
                return FTP_TIMEOUT;
            case "PHP_FTP_OPT_AUTOSEEK" :
                return FALSE;
        }
        setError(-1,"Unknown option: $option");
        return false;
    }

    function get($locale,$remote,$mode=FTP_BINARY,$resumepos=0)
    { //Downloads a file from the FTP server
        if (!($fp = @fopen($locale,"wb")))
            return FALSE;
        $result = $this->fget($fp,$remote,$mode,$resumepos);
        @fclose($fp);
        if (!$result)
            @unlink($locale);
        return $result;
    }
    function mdtm($name)
    { //Returns the last modified time of the given file
        $this->_resetError();

        $this->_printCommand("MDTM $name");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;

        if ($lr!=FTP_FILE_STATUS)
            return FALSE;

        $subject = trim(substr($this->lastLine,4));
        $arrIsWindows = array();

        if (preg_match("/([0-9][0-9][0-9][0-9])([0-9][0-9])([0-9][0-9])([0-9][0-9])([0-9][0-9])([0-9][0-9])/",$subject,$arrIsWindows))
            return mktime($arrIsWindows[4],$arrIsWindows[5],$arrIsWindows[6],$arrIsWindows[2],$arrIsWindows[3],$arrIsWindows[1],0);
        return FALSE;
    }

    function mkdir($name)
    { //Creates a directory
        $this->_resetError();

        $this->_printCommand("MKD $name");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;

        return ($lr==FTP_PATHNAME || $lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function nb_continue()
    { //Continues retrieving/sending a file (non-blocking)
        $this->_resetError();
        // todo
    }

    function nb_fget()
    { //Retrieves a file from the FTP server and writes it to an open file (non-blocking)
        $this->_resetError();
        // todo
    }

    function nb_fput()
    { //Stores a file from an open file to the FTP server (non-blocking)
        $this->_resetError();
        // todo
    }

    function nb_get()
    { //Retrieves a file from the FTP server and writes it to a local file (non-blocking)
        $this->_resetError();
        // todo
    }

    function nb_put()
    { //Stores a file on the FTP server (non-blocking)
        $this->_resetError();
        // todo
    }

    function nlist($remote_filespec="")
    { //Returns a list of files in the given directory
        $this->_resetError();
        $result = $this->_download(trim("NLST $remote_filespec"));
        return ($result !== FALSE) ? explode("\n",str_replace("\r","",trim($result))) : $result;
    }

    function pasv($pasv)
    { //Turns passive mode on or off
        if (!$pasv)
        {
            $this->_setError("Active (PORT) mode is not supported");
            return false;
        }
        return true;
    }

    function put($remote,$local,$mode=FTP_BINARY,$startpos=0)
    { //Uploads a file to the FTP server
        if (!($fp = @fopen($local,"rb")))
            return FALSE;
        $result = $this->fput($remote,$fp,$mode,$startpos);
        @fclose($fp);
        return $result;
    }

    function pwd()
    { //Returns the current directory name
        $this->_resetError();

        $this->_printCommand("PWD");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;

        if ($lr!=FTP_PATHNAME)
            return FALSE;

        $subject = trim(substr($this->lastLine,4));
        $arrIsWindows = array();
        if (preg_match("/\"(.*)\"/",$subject,$arrIsWindows))
            return $arrIsWindows[1];

        return FALSE;
    }

    function quit()
    { //Alias of close
        $this->close();
    }

    function raw($cmd)
    { //Sends an arbitrary command to an FTP server
        $this->_resetError();

        $this->_printCommand($cmd);
        $this->_waitForResult();
        $this->getLastResult();
        return array($this->lastLine);
    }

    function rawlist($remote_filespec="")
    { //Returns a detailed list of files in the given directory
        $this->_resetError();
        $result = $this->_download(trim("LIST $remote_filespec"));
        return ($result !== FALSE) ? explode("\n",str_replace("\r","",trim($result))) : $result;
    }

    function ls($remote_filespec="")
    { //Returns a parsed rawlist in an assoc array
        $a = $this->rawlist($remote_filespec);
        if (!$a)
            return $a;
        $systype = $this->systype();
        $is_windows = stristr($systype,"WIN")!==FALSE;
        $b = array();
        while (list($i,$line) = each($a))
        {
            if ($is_windows && preg_match("/([0-9]{2})-([0-9]{2})-([0-9]{2}) +([0-9]{2}):([0-9]{2})(AM|PM) +([0-9]+|<DIR>) +(.+)/",$line,$arrIsWindows))
            {
                $b[$i] = array();
                if ($arrIsWindows[3] < 70)
                    $arrIsWindows[3] += 2000;
                else
                    $arrIsWindows[3] += 1900; // 4digit year fix

                $b[$i]['isdir'] 	= ($arrIsWindows[7]=="<DIR>");
                $b[$i]['size'] 		=  $arrIsWindows[7];
                $b[$i]['month'] 	=  $arrIsWindows[1];
                $b[$i]['day'] 		=  $arrIsWindows[2];
                $b[$i]['year'] 		=  $arrIsWindows[3];
                $b[$i]['hour'] 		=  $arrIsWindows[4];
                $b[$i]['minute'] 	=  $arrIsWindows[5];
                $b[$i]['time'] 		=  @mktime($arrIsWindows[4]+(strcasecmp($arrIsWindows[6],"PM")==0?12:0),$arrIsWindows[5],0,$arrIsWindows[1],$arrIsWindows[2],$arrIsWindows[3]);
                $b[$i]['am/pm'] 	=  $arrIsWindows[6];
                $b[$i]['name'] 		=  $arrIsWindows[8];
            }
            else if (!$is_windows && $arrIsWindows=preg_split("/[ ]/",$line,9,PREG_SPLIT_NO_EMPTY))
            {
                echo $line."\n";
                $lcount = count($arrIsWindows);
                if ($lcount < 8)
                    continue;
                $b[$i] 				= array();
                $b[$i]['isdir'] 	= $arrIsWindows[0]{0} === "d";
                $b[$i]['islink'] 	= $arrIsWindows[0]{0} === "l";
                $b[$i]['perms'] 	= $arrIsWindows[0];
                $b[$i]['number'] 	= $arrIsWindows[1];
                $b[$i]['owner'] 	= $arrIsWindows[2];
                $b[$i]['group'] 	= $arrIsWindows[3];
                $b[$i]['size'] 		= $arrIsWindows[4];

                if ($lcount==8)
                {
                    sscanf($arrIsWindows[5],"%d-%d-%d"	,$b[$i]['year'],$b[$i]['month'],$b[$i]['day']);
                    sscanf($arrIsWindows[6],"%d:%d"		,$b[$i]['hour'],$b[$i]['minute']);
                    $b[$i]['time'] = @mktime($b[$i]['hour'],$b[$i]['minute'],0,$b[$i]['month'],$b[$i]['day'],$b[$i]['year']);
                    $b[$i]['name'] = $arrIsWindows[7];
                }
                else
                {
                    $b[$i]['month'] = $arrIsWindows[5];
                    $b[$i]['day'] = $arrIsWindows[6];
                    if (preg_match("/([0-9]{2}):([0-9]{2})/",$arrIsWindows[7],$l2))
                    {
                        $b[$i]['year'] = date("Y");
                        $b[$i]['hour'] = $l2[1];
                        $b[$i]['minute'] = $l2[2];
                    }
                    else
                    {
                        $b[$i]['year'] = $arrIsWindows[7];
                        $b[$i]['hour'] = 0;
                        $b[$i]['minute'] = 0;
                    }
                    $b[$i]['time'] = strtotime(sprintf("%d %s %d %02d:%02d",$b[$i]['day'],$b[$i]['month'],$b[$i]['year'],$b[$i]['hour'],$b[$i]['minute']));
                    $b[$i]['name'] = $arrIsWindows[8];
                }
            }
        }
        return $b;
    }

    function rename($from,$to)
    { //Renames a file on the FTP server
        $this->_resetError();

        $this->_printCommand("RNFR $from");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        $this->_printCommand("RNTO $to");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return ($lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function rmdir($name)
    { //Removes a directory
        $this->_resetError();

        $this->_printCommand("RMD $name");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return ($lr==FTP_FILE_ACTION_OK || $lr==FTP_COMMAND_OK);
    }

    function set_option()
    { //Set miscellaneous runtime FTP options
        $this->_resetError();
        $this->_setError(-1,"set_option not supported");
        return false;
    }

    function site($cmd)
    { //Sends a SITE command to the server
        $this->_resetError();

        $this->_printCommand("SITE $cmd");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return true;
    }

    function size($name)
    { //Returns the size of the given file
        $this->_resetError();

        $this->_printCommand("SIZE $name");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return $lr==FTP_FILE_STATUS ? trim(substr($this->lastLine,4)) : FALSE;
    }

    function ssl_connect()
    { //Opens an Secure SSL-FTP connection
        $this->_resetError();
        $this->_setError(-1,"ssl_connect not supported");
        return false;
    }

    function systype()
    { // Returns the system type identifier of the remote FTP server
        $this->_resetError();

        $this->_printCommand("SYST");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        return $lr==FTP_NAME_SYSTEM_TYPE ? trim(substr($this->lastLine,4)) : FALSE;
    }

    function getLastResult()
    {
        $this->newResult = FALSE;
        return $this->lastResult;
    }

    /* private */
    function _hasNewResult()
    {
        return $this->newResult;
    }

    /* private */
    function _waitForResult()
    {
        while(!$this->_hasNewResult() && $this->_readln()!==FALSE && !$this->_isError())
        {
            /* noop  */
        }
    }

    /* private */
    function _readln()
    {
        $line = fgets($this->controlSocket);
        if ($line === FALSE)
        {
            $this->_setError(-1,"fgets failed in _readln");
            return FALSE;
        }
        if (strlen($line)==0)
            return $line;

        $arrIsWindows = array();
        if (preg_match("/^[0-9][0-9][0-9] /",$line,$arrIsWindows))
        {
            //its a resultline
            $this->lastResult = intval($arrIsWindows[0]);
            $this->newResult = TRUE;
            if (substr($arrIsWindows[0],0,1)=='5')
                $this->_setError($this->lastResult,trim(substr($line,4)));
        }

        $this->lastLine = trim($line);
        $this->lastLines[] = "< ".trim($line);
        return $line;
    }

    /* private */
    function _printCommand($line)
    {
        $this->lastLines[] = "> ".$line;
        fwrite($this->controlSocket,$line."\r\n");
        fflush($this->controlSocket);
    }

    /* private */
    function _pasv()
    {
        $this->_resetError();
        $this->_printCommand("PASV");
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if ($this->_isError())
            return FALSE;
        if ($lr != FTP_PASSIVE_MODE)
            return FALSE;
        $subject = trim(substr($this->lastLine,4));
        $arrIsWindows = array();
        if (preg_match("/\\((\d{1,3}),(\d{1,3}),(\d{1,3}),(\d{1,3}),(\d{1,3}),(\d{1,3})\\)/",$subject,$arrIsWindows))
        {
            $this->pasvAddr=$arrIsWindows;

            $host = sprintf("%d.%d.%d.%d",$arrIsWindows[1],$arrIsWindows[2],$arrIsWindows[3],$arrIsWindows[4]);
            $port = $arrIsWindows[5]*256 + $arrIsWindows[6];

            $err_no=0;
            $err_msg="";
            $passiveConnection = fsockopen($host,$port,$err_no,$err_msg, FTP_TIMEOUT);
            if ($err_no!=0)
            {
                $this->_setError($err_no,$err_msg);
                return FALSE;
            }

            return $passiveConnection;
        }
        return FALSE;
    }

    /* private */
    function _download($cmd)
    {
        if (!($passiveConnection = $this->_pasv())) return FALSE;
        $this->_printCommand($cmd);
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if (!$this->_isError())
        {
            $result = "";
            while (!feof($passiveConnection))
                $result .= fgets($passiveConnection);

            fclose($passiveConnection);
            $this->_waitForResult();
            $lr = $this->getLastResult();
            return ($lr==FTP_FILE_TRANSFER_OK) || ($lr==FTP_FILE_ACTION_OK) || ($lr==FTP_COMMAND_OK) ? $result : FALSE;
        }
        else
        {
            fclose($passiveConnection);
            return FALSE;
        }
    }

    /* upload */
    function _uploadResource($cmd,$resource)
    {
        if (!($passiveConnection = $this->_pasv()))
            return FALSE;
        $this->_printCommand($cmd);
        $this->_waitForResult();
        $lr = $this->getLastResult();
        if (!$this->_isError())
        {
            $result = "";
            while (!feof($resource))
            {
                $buf = fread($resource,1024);
                fwrite($passiveConnection,$buf);
            }
            fclose($passiveConnection);
            $this->_waitForResult();
            $lr = $this->getLastResult();
            return ($lr==FTP_FILE_TRANSFER_OK) || ($lr==FTP_FILE_ACTION_OK) || ($lr==FTP_COMMAND_OK) ? $result : FALSE;
        }
        else
        {
            fclose($passiveConnection);
            return FALSE;
        }
    }

    /* private */
    function _resetError()
    {
        $this->error_no = NULL;
        $this->error_msg = NULL;
    }

    /* private */
    function _setError($no,$msg)
    {
        if (is_array($this->error_no))
        {
            $this->error_no[] = $no;
            $this->error_msg[] = $msg;
        }
        else if ($this->error_no!=NULL)
        {
            $this->error_no = array($this->error_no,$no);
            $this->error_msg = array($this->error_msg,$msg);
        }
        else
        {
            $this->error_no = $no;
            $this->error_msg = $msg;
        }
    }

    /* private */
    function _isError()
    {
        return ($this->error_no != NULL) && ($this->error_no !== 0);
    }


    function checkAndSend($pStrNmItem,
                          $pStrFullItemName,
                          $pStrTeServer,
                          $pStrTePathServer,
                          $pStrNmUsuarioLogin,
                          $pStrTeSenhaLogin,
                          $pStrNuPortaServer)
    {

        $strSendProcess   = 'Nao Enviado!';
        $strProcessStatus = '';
        $strProcessCode	  = '';
        try
        {

            if ($this->connect($pStrTeServer))
            {
                // Retorno esperado....: 230 => FTP_USER_LOGGED_IN
                // Retorno NÃO esperado: 530 => FTP_USER_NOT_LOGGED_IN
                if ($this->login($pStrNmUsuarioLogin,$pStrTeSenhaLogin))
                {
                    // Retorno esperado: 250 => FTP_FILE_ACTION_OK
                    // Retorno NÃO esperado: 550 => FTP_PERMISSION_DENIED (ou a pasta não existe!)
                    $this->chdir($pStrTePathServer);

                    $intFtpPutResult = $this->getLastResult();
                    $strProcessCode  = $intFtpPutResult;
                    if ($intFtpPutResult == 250)
                    {
                        // Retorno esperado....: 226 => FTP_FILE_TRANSFER_OK
                        // Retorno NÃO esperado: 550 => FTP_PERMISSION_DENIED

                        $this->put($pStrNmItem,$pStrFullItemName);
                        $intFtpPutResult = $this->getLastResult();
                        $strProcessCode  = $intFtpPutResult;
                        if ($intFtpPutResult == 226)
                        {
                            $strSendProcess   = 'Enviado com Sucesso!';
                            $strProcessStatus = 'Ok!';
                        }
                        else
                            $strProcessStatus = 'ERRO: Problema no Envio!';
                    }
                    else
                        $strProcessStatus = 'ERRO: Pasta "' . $pStrTePathServer . '" inacessivel!';
                }
                else
                {
                    $strProcessStatus = 'Falha no Login com usuario "' . $pStrNmUsuarioLogin . '"!';
                    $strProcessCode   = $this->getLastResult();
                }

                $this->disconnect();
            }
            else
            {
                $strProcessStatus = 'ERRO: Impossivel conectar o servidor "' . $pStrTeServer . '"!';
                $strProcessCode   = $this->getLastResult();
            }
        }
        catch (FTPException $e)
        {
            $strProcessStatus = 'ERRO: Problema durante a conexao! (' . $e->getMessage() . ')';
            $strProcessCode   = $this->getLastResult();
        }

        return $strSendProcess . '_=_' . $strProcessStatus . '_=_' . $strProcessCode;
    }

}