mailer.php

Go to the documentation of this file.

<?php
// $Id: mailer.php 1019 2012-09-01 06:26:52Z i.bitcero $
// --------------------------------------------------------------
// Red México Common Utilities
// A framework for Red México Modules
// Author: Eduardo Cortés <i.bitcero@gmail.com>
// Email: i.bitcero@gmail.com
// License: GPL 2.0
// --------------------------------------------------------------

include_once RMCPATH.'/class/swift/swift_required.php';

class RMMailer
{
        private $swTransport;
        private $swMessage;
        private $swMailer;
        private $errors = array();
    
    private $vars = array();
    private $template = '';
    private $tpl_type = '';
    
    private $xusers = array();
        
        
        public function __construct($content_type = 'text/plain'){
        
        $config = RMFunctions::configs();
        $config_handler =& xoops_gethandler('config');
        $xconfig = $config_handler->getConfigsByCat(XOOPS_CONF_MAILER);
            
                // Instantiate the Swit Transport according to our preferences
                // We can change this preferences later
                switch($config['transport']){
                        case 'mail':
                                $this->swTransport = Swift_MailTransport::newInstance();
                                break;
                        case 'smtp':
                                $this->swTransport = Swift_SmtpTransport::newInstance($config['smtp_server'], $config['smtp_port'], $config['smtp_crypt']!='none' ? $config['smtp_crypt'] : '');
                                $this->swTransport->setUsername($config['smtp_user']);
                                $this->swTransport->setPassword($config['smtp_pass']);
                                break;
                        case 'sendmail':
                                $this->swTransport = Swift_SendmailTransport::newInstance($config['sendmail_path']);
                                break;
                }
        
                // Create the message object
                // Also this object could be change later with message() method
                $this->swMessage = Swift_Message::newInstance();
                $this->swMessage->setReplyTo($xconfig['from']);
                $this->swMessage->setFrom(array($xconfig['from'] => $xconfig['fromname']));
                $this->swMessage->setContentType($content_type);
                
        }
    
    public function set_from($mail, $name){
        $this->swMessage->setFrom($mail, $name);
    }
    
    public function set_from_xuser($user){
        if (strtolower(get_class($user))=='xoopsuser')
            $this->fromuser = $user;
        elseif($user>0)
            $this->fromuser = new XoopsUser($user);
    }
        
        public function &transport(){
                return $this->swTransport;
        }
        
        public function &message(){
                return $this->swMessage;
        }
        
        public function get_subject(){
                return $this->swMessage->getSubject();
        }
        
        public function set_subject($subject){
                $this->swMessage->setSubject($subject);
        }
        
        public function get_body(){
                return $this->swMessage->getBody();
        }
        
        public function set_body($body, $content_type=''){
                $this->swMessage->setBody($body, $content_type!='' ? $content_type : $this->swMessage->getContentType());
        }
        
        public function add_part($content, $type='text/html'){
                $this->swMessage->addPart($content, $type);
        }
        
        public function attach_content($type='path', $path = '', $content_type = '', $name='', $content=null, $disposition=''){
                
                switch($type){
                        case 'path':
                                
                                if (trim($path)=='' || !is_file($path)) return;                         
                                $att = Swift_Attachment::fromPath($path);
                                
                                break;
                        case 'dynamic':
                                
                                if ($content==null || $content=='') return;
                                $att = Swift_Attachment::newInstance($content);
                                
                                break;
                }
                
                if (trim($name)!='') $att->setFilename($name);
                if (trim($content_type)!='') $att->setContentType($content_type);
                if (trim($disposition)!='') $att->setDisposition($disposition);
                
                $this->swMessage->attach($att);
                
        }
        
        public function embed($type, $file='', $name=null, $content_type=null){
                
                switch($type){
                        case 'path':
                                if ($file=='') return;
                                return $this->swMessage->embed(Swift_Image::fromPath($file));
                                break;
                        case 'dynamic':
                                if ($file==null || $file=='') return;
                                return $this->swMessage->embed(Swift_Image::newInstance($file, $name, $content_type));
                }
                
        }
        
        public function set_to($recipients = array()){
                if (empty($recipients)) return;
                return $this->swMessage->setTo($recipients);
        }
        
        public function get_to(){
                return $this->swMessage->getTo();
        }
        
        public function add_to($mail, $name=''){
                if ($mail=='') return;
                return $this->swMessage->addTo($mail, $name);
        }
        
        public function set_cc($recipients = array()){
                if (empty($recipients)) return;
                return $this->swMessage->setCc($recipients);
        }
        
        public function get_cc(){
                return $this->swMessage->getCc();
        }
        
        public function add_cc($mail, $name=''){
                if ($mail=='') return;
                
                return $this->swMessage->addCc($mail, $name);
        }
        
        public function set_bcc($recipients = array()){
                if (empty($recipients)) return;
                return $this->swMessage->seBcc($recipients);
        }
        
        public function get_bcc(){
                return $this->swMessage->getBcc();
        }
        
        public function add_bcc($mail, $name=''){
                if ($mail=='') return;
                
                return $this->swMessage->addBcc($mail, $name);
        }
    
    public function add_users($users, $field='to'){
        if (!is_array($users)) return;
        
        foreach ($users as $user){
            if (is_a($user, "XoopsUser")){
                $this->add_user($user->getVar('email'), $user->getVar('name')!='' ? $user->getVar('name') : $user->getVar('uname'), $field);
            } else {
                $user = new XoopsUser($user);
                if ($user->isNew()) continue;
                $this->add_user($user->getVar('email'), $user->getVar('name')!='' ? $user->getVar('name') : $user->getVar('uname'), $field);
            }
            $this->xusers[] = $user;
        }
        
    }
    
    public function add_user($mail, $name='', $field='to'){
        switch($field){
            case 'to':
                $this->add_to($mail, $name);
                break;
            case 'cc':
                $this->add_cc($mail, $name);
                break;
            case 'bcc':
                $this->add_bcc($mail, $name);
                break;
        }
    }
    
    public function add_xoops_users($users, $field='to'){
        
        if (is_array($users)){
            
            foreach($users as $uid){
                $user = new RMUser($uid);
                if (strtolower(get_class($user))=='rmuser'){
                    $this->xusers[] = $user;
                    $this->add_user($user->getVar('email'), $user->getVar('name')!='' ? $user->getVar('name') : $user->getVar('uname'), $field);
                }
            }
            
        } else {
            $user = new RMUser($users);
            
            if (strtolower(get_class($users))=='xoopsuser'){
                $this->xusers[] = $user;
                $this->add_user($users->getVar('email'), $users->getVar('name')!='' ? $users->getVar('name') : $users->getVar('uname'), $field);
            }
            
        }
        
    }
        
        public function set_return_path($mail){
                if ($mail=='') return;
                $this->swMessage->setReturnPath($mail);
        }
        public function get_return_path(){
                return $this->swMessage->getReturnPath();
        }
    
    public function assign($var, $value){
        $this->vars[$var] = $value;
    }
    
    public function template($file, $type=''){
        if (file_exists($file))
            $this->template = $file;
    }
        
        public function errors(){
                return $this->errors;
        }
    
    public function create_body(){
        
        if ($this->get_body()!='') return;
        
        if($this->template=='') return;
        
        if ($this->tpl_type=='old'){
            global $xoopsTpl;
            
            $ret = file_get_contents($this->template);
            
            foreach($this->vars as $name => $value){
                $ret = str_replace('{'.$name.'}', $value, $ret);
            }
            
            $this->set_body($ret);
            return;
            
        }
        
        extract($this->vars);
        ob_start();
        
        include $this->template;
        
        $ret = ob_get_clean();
        
        $this->set_body($ret);
        
    }
    
    function send_pm(){
        
        if(empty($this->xusers))
            return false;
        
        if (!$this->fromuser)
            return false;
        
        $this->create_body();
        
        $pm_handler = &xoops_gethandler('privmessage');
        $pm = &$pm_handler->create();
        $pm->setVar("subject", $this->get_subject());
        // RMV-NOTIFY
        $pm->setVar('from_userid', $this->fromuser->uid());
        $pm->setVar("msg_text", $this->get_body());
        
        foreach($this->xusers as $user){
            $pm->setVar("to_userid", $user->uid());
            $pm_handler->insert($pm);
        }
        
    }
        
        function batchSend(){
        $this->create_body();
                $this->swMailer = Swift_Mailer::newInstance($this->swTransport);
                return $this->swMailer->batchSend($this->swMessage, $this->errors);
        }
        
        function send(){
        $this->create_body();
                $this->swMailer = Swift_Mailer::newInstance($this->swTransport);
                return $this->swMailer->send($this->swMessage, $this->errors);
        }
        
}