1: <?php
  2: /**
  3:  * Copyright 2010-2014 Horde LLC (http://www.horde.org/)
  4:  *
  5:  * See the enclosed file COPYING for license information (GPL). If you
  6:  * did not receive this file, see http://www.horde.org/licenses/gpl.
  7:  *
  8:  * @category  Horde
  9:  * @copyright 2010-2014 Horde LLC
 10:  * @license   http://www.horde.org/licenses/gpl GPL
 11:  * @package   IMP
 12:  */
 13: 
 14: /**
 15:  * Sentmail driver implementation for SQL databases.
 16:  *
 17:  * @author    Jan Schneider <jan@horde.org>
 18:  * @author    Michael Slusarz <slusarz@horde.org>
 19:  * @category  Horde
 20:  * @copyright 2010-2014 Horde LLC
 21:  * @license   http://www.horde.org/licenses/gpl GPL
 22:  * @package   IMP
 23:  */
 24: class IMP_Sentmail_Sql extends IMP_Sentmail
 25: {
 26:     /**
 27:      * Handle for the current database connection.
 28:      *
 29:      * @var Horde_Db_Adapter
 30:      */
 31:     protected $_db;
 32: 
 33:     /**
 34:      * @param array $params  Parameters:
 35:      *   - db: (Horde_Db_Adapter) [REQUIRED] The DB instance.
 36:      *   - table: (string) The name of the sentmail table.
 37:      *            DEFAULT: 'imp_sentmail'
 38:      */
 39:     public function __construct(array $params = array())
 40:     {
 41:         if (!isset($params['db'])) {
 42:             throw new IMP_Exception('Missing db parameter.');
 43:         }
 44:         $this->_db = $params['db'];
 45:         unset($params['db']);
 46: 
 47:         $params = array_merge(array(
 48:             'table' => 'imp_sentmail'
 49:         ), $params);
 50: 
 51:         parent::__construct($params);
 52:     }
 53: 
 54:     /**
 55:      */
 56:     protected function _log($action, $message_id, $recipient, $success)
 57:     {
 58:         /* Build the SQL query. */
 59:         $query = sprintf('INSERT INTO %s (sentmail_who, sentmail_ts, sentmail_messageid, sentmail_action, sentmail_recipient, sentmail_success) VALUES (?, ?, ?, ?, ?, ?)', $this->_params['table']);
 60:         $values = array(
 61:             $GLOBALS['registry']->getAuth(),
 62:             time(),
 63:             $message_id,
 64:             $action,
 65:             $recipient,
 66:             intval($success)
 67:         );
 68: 
 69:         /* Execute the query. */
 70:         try {
 71:             $this->_db->insert($query, $values);
 72:         } catch (Horde_Db_Exception $e) {}
 73:     }
 74: 
 75:     /**
 76:      */
 77:     public function favouriteRecipients($limit, $filter = null)
 78:     {
 79:         /* Build the SQL query. */
 80:         $where = '';
 81:         if (!empty($filter)) {
 82:             $filter = array_map(array($this->_db, 'quote'), $filter);
 83:             $where = sprintf(' AND sentmail_action in (%s)',
 84:                              implode(', ', $filter));
 85:         }
 86: 
 87:         $query = sprintf('SELECT sentmail_recipient, count(*) AS sentmail_count FROM %s WHERE sentmail_who = %s AND sentmail_success = 1%s GROUP BY sentmail_recipient ORDER BY sentmail_count DESC',
 88:                          $this->_params['table'],
 89:                          $this->_db->quote($GLOBALS['registry']->getAuth()),
 90:                          $where);
 91: 
 92:         /* Execute the query. */
 93:         try {
 94:             $query = $this->_db->addLimitOffset($query, array('limit' => $limit));
 95:             return $this->_db->selectValues($query);
 96:         } catch (Horde_Db_Exception $e) {
 97:             return array();
 98:         }
 99:     }
100: 
101:     /**
102:      */
103:     public function numberOfRecipients($hours, $user = false)
104:     {
105:         /* Build the SQL query. */
106:         $query = sprintf('SELECT COUNT(*) FROM %s WHERE sentmail_ts > ?',
107:                          $this->_params['table']);
108:         if ($user) {
109:             $query .= sprintf(' AND sentmail_who = %s', $this->_db->quote($GLOBALS['registry']->getAuth()));
110:         }
111: 
112:         /* Execute the query. */
113:         try {
114:             return $this->_db->selectValue($query, array(time() - $hours * 3600));
115:         } catch (Horde_Db_Exception $e) {
116:             return 0;
117:         }
118:     }
119: 
120:     /**
121:      */
122:     protected function _deleteOldEntries($before)
123:     {
124:         /* Build the SQL query. */
125:         $query = sprintf('DELETE FROM %s WHERE sentmail_ts < ?',
126:                          $this->_params['table']);
127: 
128:         /* Execute the query. */
129:         try {
130:             $this->_db->delete($query, array($before));
131:         } catch (Horde_Db_Exception $e) {}
132:     }
133: 
134: }
135: