class.ilFileDataMail.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2009 ILIAS open source, Extended GPL, see docs/LICENSE */


require_once("./Services/FileSystem/classes/class.ilFileData.php");

class ilFileDataMail extends ilFileData
{
        var $user_id;

        var $mail_path;

        protected $mail_max_upload_file_size;

        public function __construct($a_user_id = 0)
        {
                define('MAILPATH','mail');
                parent::__construct();
                $this->mail_path = parent::getPath()."/".MAILPATH;
                $this->checkReadWrite();
                $this->user_id = $a_user_id;

                $this->initAttachmentMaxUploadSize();
        }

        function initDirectory()
        {
                if(is_writable($this->getPath()))
                {
                        if(mkdir($this->getPath().'/'.MAILPATH))
                        {
                                if(chmod($this->getPath().'/'.MAILPATH,0755))
                                {
                                        $this->mail_path = $this->getPath().'/'.MAILPATH;
                                        return true;
                                }
                        } 
                }
                return false;
        }

        public function getUploadLimit()
        {
                return $this->mail_max_upload_file_size;
        }

        public function getAttachmentsTotalSizeLimit()
        {
                $max_size = $this->ilias->getSetting('mail_maxsize_attach', '');
                if(!strlen($max_size))
                {
                        return null;
                }

                return (float)$this->ilias->getSetting('mail_maxsize_attach', 0) * 1024;
        }

        function getMailPath()
        {
                return $this->mail_path;
        }
        
        public function getAttachmentPathByMD5Filename($a_filename,$a_mail_id)
        {
                global $ilDB;
                
/*              $query = "SELECT path FROM mail_attachment ".
                        "WHERE mail_id = ".$ilDB->quote($a_mail_id)."";
                
                $row = $this->ilias->db->getRow($query,DB_FETCHMODE_OBJECT);
                $path = $this->getMailPath().'/'.$row->path;
*/
                $query = $ilDB->query("SELECT path FROM mail_attachment 
                                  WHERE mail_id = ".$ilDB->quote($a_mail_id,'integer')."");
                
                $rel_path = "";
                while($row = $ilDB->fetchObject($query))
                {
                        $rel_path = $row->path;
                        $path = $this->getMailPath().'/'.$row->path;

                }

                $files = ilUtil::getDir($path);
                foreach((array)$files as $file)
                {
                        if($file['type'] == 'file' && md5($file['entry']) == $a_filename)
                        {
                                return array(
                                        'path' => $this->getMailPath().'/'.$rel_path.'/'.$file['entry'],
                                        'filename' => $file['entry']
                                );
                        }
                }
                return '';
        }
        

        function getAttachmentPath($a_filename,$a_mail_id)
        {
                global $ilDB;
                
/*              $query = "SELECT path FROM mail_attachment ".
                        "WHERE mail_id = ".$ilDB->quote($a_mail_id)."";
                
                $row = $this->ilias->db->getRow($query,DB_FETCHMODE_OBJECT);
                $path = $this->getMailPath().'/'.$row->path.'/'.$a_filename;
*/
                $query = $ilDB->query("SELECT path FROM mail_attachment ".
                        "WHERE mail_id = ".$ilDB->quote($a_mail_id, 'integer')."");

                while($row = $ilDB->fetchObject($query))
                {
                        $path = $this->getMailPath().'/'.$row->path.'/'.$a_filename;                    
                }
                        
                if(file_exists($path))
                {
                        if(is_readable($path))
                        {
                                return $path;
                        }
                        return '';
                }
                return '';
        }
        function adoptAttachments($a_attachments,$a_mail_id)
        {
                if(is_array($a_attachments))
                {
                        foreach($a_attachments as $file)
                        {
                                $path = $this->getAttachmentPath($file,$a_mail_id);
                                if(!copy($path,$this->getMailPath().'/'.$this->user_id.'_'.$file))
                                {
                                        return "ERROR: $this->getMailPath().'/'.$this->user_id.'_'.$file cannot be created";
                                }
                        }
                }
                else
                {
                        return "ARRAY REQUIRED";
                }
                return '';
        }

        function checkReadWrite()
        {
                if(is_writable($this->mail_path) && is_readable($this->mail_path))
                {
                        return true;
                }
                else
                {
                        $this->ilias->raiseError("Mail directory is not readable/writable by webserver: ".$this->mail_path,$this->ilias->error_obj->FATAL);
                }
        }
        function getUserFilesData()
        {
                return $files = $this->getUnsentFiles();
        }

        function getUnsentFiles()
        {
                $files = array();
                $dp = opendir($this->mail_path);

                while($file = readdir($dp))
                {
                        if(is_dir($file))
                        {
                                continue;
                        }
                        list($uid,$rest) = explode('_',$file,2);
                        if($uid == $this->user_id)
                        {
                                if(!is_dir($this->mail_path.'/'.$file))
                                {
                                        $files[] = array(
                                                'name'     => $rest,
                                                'size'     => filesize($this->mail_path.'/'.$file),
                                                'ctime'    => filectime($this->mail_path.'/'.$file)
                                        );
                                }
                        }
                }
                closedir($dp);
                return $files;
        }
        
        public function storeAsAttachment($a_filename,$a_content)
        {
                if(strlen($a_content) >= $this->getUploadLimit())
                {
                        return 1;
                }

                $name = ilUtil::_sanitizeFilemame($a_filename);
                $this->rotateFiles($this->getMailPath().'/'.$this->user_id.'_'.$name);

                $abs_path = $this->getMailPath().'/'.$this->user_id.'_'.$name;
                
                if(!$fp = @fopen($abs_path,'w+'))
                {
                        return false;
                }
                if(@fwrite($fp,$a_content) === false)
                {
                        @fclose($fp);
                        return false;
                }
                @fclose($fp);
                return true;            
        }
        
        public function storeUploadedFile($file)
        {
                $file['name'] = ilUtil::_sanitizeFilemame($file['name']);

                $this->rotateFiles($this->getMailPath() . '/' . $this->user_id . '_' . $file['name']);

                ilUtil::moveUploadedFile(
                        $file['tmp_name'],
                        $file['name'],
                        $this->getMailPath() . '/' . $this->user_id . '_' . $file['name']
                );
        }

        function copyAttachmentFile($a_abs_path,$a_new_name)
        {
                @copy($a_abs_path,$this->getMailPath()."/".$this->user_id."_".$a_new_name);
                
                return true;
        }
                


        function rotateFiles($a_path)
        {
                if(file_exists($a_path))
                {
                        $this->rotateFiles($a_path.".old");
                        return rename($a_path,$a_path.'.old');
                }
                return true;
        }
        function unlinkFiles($a_filenames)
        {
                if(is_array($a_filenames))
                {
                        foreach($a_filenames as $file)
                        {
                                if(!$this->unlinkFile($file))
                                {
                                        return $file;
                                }
                        }
                }
                return '';
        }
        function unlinkFile($a_filename)
        {
                if(file_exists($this->mail_path.'/'.basename($this->user_id.'_'.$a_filename)))
                {
                        return unlink($this->mail_path.'/'.basename($this->user_id.'_'.$a_filename));
                }
        }
        function getAbsolutePath($a_path)
        {
                return $this->mail_path.'/'.$this->user_id.'_'.$a_path;
        }

        function saveFiles($a_mail_id,$a_attachments)
        {
                if(!$a_mail_id)
                {
                        return "INTERNAL HERE ERROR: No valid mail_id given";
                }
                if(is_array($a_attachments))
                {
                        foreach($a_attachments as $attachment)
                        {
                                if(!$this->saveFile($a_mail_id,$attachment))
                                {
                                        return $attachment;
                                }
                        }
                }
                else
                {
                        return "ARRAY REQUIRED";
                }
                return '';
        }
        
        public static function getStorage($a_mail_id, $a_usr_id)
        {
                static $fsstorage_cache = array();
                
                if(!is_object($fsstorage_cache[$a_mail_id][$a_usr_id]))
                {
                        include_once 'Services/Mail/classes/class.ilFSStorageMail.php';
                        $fsstorage_cache[$a_mail_id][$a_usr_id] = new ilFSStorageMail($a_mail_id, $a_usr_id);
                } 
                
                return $fsstorage_cache[$a_mail_id][$a_usr_id];
        }
        
        function saveFile($a_mail_id,$a_attachment)
        {
                $oStorage = self::getStorage($a_mail_id, $this->user_id);
                $oStorage->create();
                $storage_directory = $oStorage->getAbsolutePath();
                                
                if(@!is_dir($storage_directory))
                {
                        return false;
                }
                
                return copy($this->mail_path.'/'.$this->user_id.'_'.$a_attachment,
                                        $storage_directory.'/'.$a_attachment);
        }
        function checkFilesExist($a_files)
        {
                if($a_files)
                {
                        foreach($a_files as $file)
                        {
                                if(!file_exists($this->mail_path.'/'.$this->user_id.'_'.$file))
                                {
                                        return false;
                                }
                        }
                        return true;
                }
                return true;
        }
        function assignAttachmentsToDirectory($a_mail_id,$a_sent_mail_id)
        {
                global $ilDB;
                
/*              $query = "INSERT INTO mail_attachment ".
                        "SET mail_id = ".$ilDB->quote($a_mail_id).", ".
                        "path = ".$ilDB->quote($this->user_id."_".$a_sent_mail_id)." ";
                $res = $this->ilias->db->query($query);
*/

                $oStorage = self::getStorage($a_sent_mail_id, $this->user_id);
                $res = $ilDB->manipulateF('
                        INSERT INTO mail_attachment 
                        ( mail_id, path) VALUES (%s, %s)',
                        array('integer', 'text'),
                        array($a_mail_id, $oStorage->getRelativePathExMailDirectory())
                ); 
                                
        }
        function deassignAttachmentFromDirectory($a_mail_id)
        {
                global $ilDB;
                // IF IT'S THE LAST MAIL CONTAINING THESE ATTACHMENTS => DELETE ATTACHMENTS
                $res = $ilDB->query("SELECT path FROM mail_attachment
                                WHERE mail_id = ".$ilDB->quote($a_mail_id,'integer'));
        
                while($row = $res->fetchRow(DB_FETCHMODE_OBJECT))
                {
                        $path = $row->path;
                }
                if($path)
                {
                        $res = $ilDB->query("SELECT COUNT(mail_id) count_mail_id FROM mail_attachment 
                                        WHERE path = ".$ilDB->quote($path,'text')) ;
                        
                        while($row = $res->fetchRow(DB_FETCHMODE_OBJECT))
                        {
                                $cnt_mail_id = $row->count_mail_id;
                        }
                        if($cnt_mail_id == 1)
                        {
                                $this->__deleteAttachmentDirectory($path);
                        }
                }

                $res = $ilDB->manipulateF("DELETE FROM mail_attachment 
                                WHERE mail_id = %s",
                                array('integer'),
                                array($a_mail_id));
                return true;
        }

        function __deleteAttachmentDirectory($a_rel_path)
        {
                ilUtil::delDir($this->mail_path."/".$a_rel_path);               
                
                return true;
        }

        protected function initAttachmentMaxUploadSize()
        {
                // Copy of ilFileInputGUI: begin
                // get the value for the maximal uploadable filesize from the php.ini (if available)
                $umf = ini_get("upload_max_filesize");
                // get the value for the maximal post data from the php.ini (if available)
                $pms = ini_get("post_max_size");

                //convert from short-string representation to "real" bytes
                $multiplier_a = array("K" => 1024, "M" => 1024 * 1024, "G" => 1024 * 1024 * 1024);

                $umf_parts = preg_split("/(\d+)([K|G|M])/", $umf, -1, PREG_SPLIT_DELIM_CAPTURE | PREG_SPLIT_NO_EMPTY);
                $pms_parts = preg_split("/(\d+)([K|G|M])/", $pms, -1, PREG_SPLIT_DELIM_CAPTURE | PREG_SPLIT_NO_EMPTY);

                if(count($umf_parts) == 2)
                {
                        $umf = $umf_parts[0] * $multiplier_a[$umf_parts[1]];
                }
                if(count($pms_parts) == 2)
                {
                        $pms = $pms_parts[0] * $multiplier_a[$pms_parts[1]];
                }

                // use the smaller one as limit
                $max_filesize = min($umf, $pms);

                if(!$max_filesize) $max_filesize = max($umf, $pms);
                // Copy of ilFileInputGUI: end

                $this->mail_max_upload_file_size = $max_filesize;
        }

        function _lookupDiskUsageOfUser($user_id)
        {
                // XXX - This method is extremely slow. We should
                // use a cache to speed it up, for example, we should
                // store the disk space used in table mail_attachment.
                global $ilDB, $lng;

                $mail_data_dir = ilUtil::getDataDir('filesystem').DIRECTORY_SEPARATOR."mail";

                $q = "SELECT path ".
                        "FROM mail_attachment ma ".
                        "JOIN mail m ON ma.mail_id=m.mail_id ".
                        "WHERE m.user_id = ".$ilDB->quote($user_id);
                $result_set = $ilDB->query($q);
                $size = 0;
                $count = 0;
                while($row = $result_set->fetchRow(DB_FETCHMODE_ASSOC))
                {
                        $attachment_path = $mail_data_dir.DIRECTORY_SEPARATOR.$row['path'];
                        $attachment_size = ilUtil::dirsize($attachment_path);
                        if ($attachment_size != -1)
                        {
                                $size += $attachment_size;
                        }
                        $count++;
                }
                return array('count'=>$count, 'size'=>$size);
        }

        public function onUserDelete()
        {
                global $ilDB;
                
                // Delete uploaded mail files which are not attached to any message
                try
                {
                        $iter = new RegexIterator(
                                new DirectoryIterator($this->getMailPath()), '/^'.$this->user_id.'_/'
                        );
                        foreach($iter as $file)
                        {
                                if($file->isFile())
                                {
                                        @unlink($file->getPathname());
                                }
                        }
                }
                catch(Exception $e) { }

                // Select all files attached to messages which are not shared (... = 1) with other messages anymore
                $query = '
                        SELECT DISTINCT(ma1.path)
                        FROM mail_attachment ma1
                        INNER JOIN mail
                                ON mail.mail_id = ma1.mail_id
                        WHERE mail.user_id = %s
                        AND (SELECT COUNT(tmp.path) FROM mail_attachment tmp WHERE tmp.path = ma1.path) = 1
                ';
                $res = $ilDB->queryF(
                        $query,
                        array('integer'),
                        array($this->user_id)
                );
                while($row = $ilDB->fetchAssoc($res))
                {
                        try
                        {
                                $path = $this->getMailPath().DIRECTORY_SEPARATOR.$row['path'];
                                $iter = new RecursiveIteratorIterator(
                                        new RecursiveDirectoryIterator($path), RecursiveIteratorIterator::CHILD_FIRST
                                );
                                foreach($iter as $file)
                                {
                                        if($file->isDir())
                                        {
                                                @rmdir($file->getPathname());
                                        }
                                        else
                                        {
                                                @unlink($file->getPathname());
                                        }
                                }
                                @rmdir($path);
                        }
                        catch(Exception $e) { }
                }

                // Delete each mail attachment row assigned to a message of the deleted user.
                if($ilDB->getDBType() == 'mysql' || $ilDB->getDBType() == 'innodb')
                {
                        $ilDB->manipulateF('
                                DELETE m1
                                FROM mail_attachment m1
                                INNER JOIN (
                                        SELECT mail_attachment.mail_id
                                        FROM mail
                                        INNER JOIN mail_attachment
                                                ON mail_attachment.mail_id = mail.mail_id
                                        WHERE user_id = %s
                                ) m2
                                ON m2.mail_id = m1.mail_id
                                ',
                                array('integer'),
                                array($this->user_id)
                        );
                }
                else
                {
                        // Oracle and Postgres
                        $ilDB->manipulateF(' 
                                DELETE FROM mail_attachment
                                WHERE mail_attachment.mail_id IN (
                                        SELECT mail_attachment.mail_id
                                        FROM mail
                                        INNER JOIN mail_attachment
                                                ON mail_attachment.mail_id = mail.mail_id
                                        WHERE user_id = %s
                                )
                                ',
                                array('integer'),
                                array($this->user_id)
                        );
                }
        }
}
?>