kopano_webapp/emailtracking
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

More improvemnts and new folderstructure

Browse Source
This commit is contained in:
Christoph Haas
2015-04-30 22:11:52 +02:00
parent 27e2886de8
commit b11f487816
24 changed files with 2 additions and 812 deletions
Download Patch File Download Diff File Expand all files Collapse all files

62
php/class.plugintrackingmodule.php Executable file
View File

@@ -0,0 +1,62 @@
<?php
require_once __DIR__ . "/lib/class.EmailTracker.php";
class PluginTrackingModule extends Module
{
/**
* @var EmailTracker
*/
private $emailTracker;
/**
* Constructor
* @param int $id unique id.
* @param string $folderentryid Entryid of the folder. Data will be selected from this folder.
* @param array $data list of all actions.
*/
function PluginEmailtrackingModule($id, $data)
{
$this->store = $GLOBALS['mapisession']->getDefaultMessageStore();
parent::Module($id, $data);
}
/**
* Executes all the actions in the $data variable.
* @return boolean true on success of false on fialure.
*/
function execute()
{
$this->emailTracker = new EmailTracker();
foreach($this->data as $actionType => $actionData)
{
if(isset($actionType)) {
try {
switch($actionType)
{
case "gettrackinglog" :
$data = $this->getTrackingLog($actionData);
$this->addActionData('gettrackinglog', $data);
$GLOBALS['bus']->addData($this->getResponseData());
break;
default:
$this->handleUnknownActionType($actionType);
}
} catch (Exception $e) {
$this->sendFeedback(false, parent::errorDetailsFromException($e));
}
}
}
}
function getTrackingLog($actionData) {
$data = array();
$data["trackingid"] = $actionData["trackingid"];
$data["log"] = $this->emailTracker->getAllLogs($data["trackingid"]);
$data["status"] = true;
return $data;
}
}

120
php/lib/class.EmailTracker.php Executable file
View File

@@ -0,0 +1,120 @@
<?php
require __DIR__ . '/medoo.php';
require_once __DIR__ . '/../../config.php';
class EmailTracker {
/**
* @var Database connector object. A medoo object.
*/
private $dbObj;
/**
* Contructor
*/
function __construct() {
$dbOptions = array(
'database_type' => 'mysql',
'database_name' => PLUGIN_EMAILTRACKING_DB_DB,
'server' => PLUGIN_EMAILTRACKING_DB_HOST,
'username' => PLUGIN_EMAILTRACKING_DB_USER,
'password' => PLUGIN_EMAILTRACKING_DB_PASS,
'port' => PLUGIN_EMAILTRACKING_DB_PORT,
'charset' => 'utf8',
);
$this->dbObj = new medoo($dbOptions);
}
/**
* Generates a new ID out of some values
*
* @param $emailId
* @param $destAddr
* @param $srcAddr
* @param $subject
* @return string
*/
public function getNewTrackingCode ($emailId, $destAddr, $srcAddr, $subject) {
$currentTimeStamp = time();
$trackingHash = md5($emailId . $destAddr . $subject . $currentTimeStamp);
$data = array(
"email_id" => $emailId,
"destination_addr" => $destAddr,
"source_addr" => $srcAddr,
"subject" => $subject,
"current_time" => date('Y-m-d H:i:s',$currentTimeStamp),
"generated_id" => $trackingHash
);
$this->dbObj->insert("trackingid", $data);
return $trackingHash;
}
/**
* Get the database ID for the given hash
*
* @param $trackingHash
* @return int
*/
private function getTrackingIDbyCode ($trackingHash) {
$filter = array(
"generated_id" => $trackingHash,
);
$data = $this->dbObj->select("trackingid", "id", $filter);
if (is_array($data) && count($data) > 0) {
return $data[0];
} else {
return -1;
}
}
/**
* Stores a new log entry to db
*
* @param $trackingHash
* @param $data
*/
public function addLog($trackingHash, $data) {
// first get the id - to add it to our new entry
$dbID = $this->getTrackingIDbyCode($trackingHash);
// check if trackingHash was valid
if($dbID != -1) {
// build our tracking entry
$data["trackingid_id"] = $dbID;
$this->dbObj->insert("trackinglog", $data);
}
}
/**
* Get all Tracking logs for the specified hash.
*
* @param $trackingHash
* @return array|bool
*/
public function getAllLogs($trackingHash) {
// first get the id - to add it to our new entry
$dbID = $this->getTrackingIDbyCode($trackingHash);
// check if trackingHash was valid
if($dbID != -1) {
$data = $this->dbObj->select("trackinglog", [
"ip_addr",
"timestamp",
"referrer",
"client",
"tracking_type"
], [
"trackingid_id" => $dbID
]);
return $data;
}
return false;
}
}

48
php/lib/database_structure.sql Executable file
View File

@@ -0,0 +1,48 @@
--
-- Database: `emailtracking`
--
-- --------------------------------------------------------
--
-- Table structure for table `trackingid`
--
CREATE TABLE IF NOT EXISTS `trackingid` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`email_id` varchar(500) NOT NULL,
`destination_addr` varchar(200) NOT NULL,
`source_addr` varchar(200) NOT NULL,
`subject` varchar(1024) NOT NULL,
`current_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
`generated_id` varchar(32) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 AUTO_INCREMENT=2 ;
-- --------------------------------------------------------
--
-- Table structure for table `trackinglog`
--
CREATE TABLE IF NOT EXISTS `trackinglog` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`trackingid_id` int(11) NOT NULL,
`ip_addr` varchar(100) NOT NULL,
`referrer` varchar(500) NOT NULL,
`client` varchar(1024) NOT NULL,
`tracking_type` varchar(20) NOT NULL,
`timestamp` datetime NOT NULL,
PRIMARY KEY (`id`),
KEY `trackingid_id` (`trackingid_id`)
) ENGINE=InnoDB DEFAULT CHARSET=latin1 AUTO_INCREMENT=3 ;
--
-- Constraints for dumped tables
--
--
-- Constraints for table `trackinglog`
--
ALTER TABLE `trackinglog`
ADD CONSTRAINT `trackinglog_ibfk_1` FOREIGN KEY (`trackingid_id`) REFERENCES `trackingid` (`id`) ON DELETE CASCADE ON UPDATE CASCADE;

936
php/lib/medoo.php Executable file
View File

@@ -0,0 +1,936 @@
<?php
/*!
* Medoo database framework
* http://medoo.in
* Version 0.9.8
*
* Copyright 2015, Angel Lai
* Released under the MIT license
*/
class medoo
{
// General
protected $database_type;
protected $charset;
protected $database_name;
// For MySQL, MariaDB, MSSQL, Sybase, PostgreSQL, Oracle
protected $server;
protected $username;
protected $password;
// For SQLite
protected $database_file;
// For MySQL or MariaDB with unix_socket
protected $socket;
// Optional
protected $port;
protected $option = array();
// Variable
protected $logs = array();
protected $debug_mode = false;
public function __construct($options = null)
{
try {
$commands = array();
if (is_string($options) && !empty($options))
{
if (strtolower($this->database_type) == 'sqlite')
{
$this->database_file = $options;
}
else
{
$this->database_name = $options;
}
}
elseif (is_array($options))
{
foreach ($options as $option => $value)
{
$this->$option = $value;
}
}
if (
isset($this->port) &&
is_int($this->port * 1)
)
{
$port = $this->port;
}
$type = strtolower($this->database_type);
$is_port = isset($port);
switch ($type)
{
case 'mariadb':
$type = 'mysql';
case 'mysql':
if ($this->socket)
{
$dsn = $type . ':unix_socket=' . $this->socket . ';dbname=' . $this->database_name;
}
else
{
$dsn = $type . ':host=' . $this->server . ($is_port ? ';port=' . $port : '') . ';dbname=' . $this->database_name;
}
// Make MySQL using standard quoted identifier
$commands[] = 'SET SQL_MODE=ANSI_QUOTES';
break;
case 'pgsql':
$dsn = $type . ':host=' . $this->server . ($is_port ? ';port=' . $port : '') . ';dbname=' . $this->database_name;
break;
case 'sybase':
$dsn = 'dblib:host=' . $this->server . ($is_port ? ':' . $port : '') . ';dbname=' . $this->database_name;
break;
case 'oracle':
$dbname = $this->server ?
'//' . $this->server . ($is_port ? ':' . $port : ':1521') . '/' . $this->database_name :
$this->database_name;
$dsn = 'oci:dbname=' . $dbname . ($this->charset ? ';charset=' . $this->charset : '');
break;
case 'mssql':
$dsn = strstr(PHP_OS, 'WIN') ?
'sqlsrv:server=' . $this->server . ($is_port ? ',' . $port : '') . ';database=' . $this->database_name :
'dblib:host=' . $this->server . ($is_port ? ':' . $port : '') . ';dbname=' . $this->database_name;
// Keep MSSQL QUOTED_IDENTIFIER is ON for standard quoting
$commands[] = 'SET QUOTED_IDENTIFIER ON';
break;
case 'sqlite':
$dsn = $type . ':' . $this->database_file;
$this->username = null;
$this->password = null;
break;
}
if (
in_array($type, explode(' ', 'mariadb mysql pgsql sybase mssql')) &&
$this->charset
)
{
$commands[] = "SET NAMES '" . $this->charset . "'";
}
$this->pdo = new PDO(
$dsn,
$this->username,
$this->password,
$this->option
);
foreach ($commands as $value)
{
$this->pdo->exec($value);
}
}
catch (PDOException $e) {
throw new Exception($e->getMessage());
}
}
public function query($query)
{
if ($this->debug_mode)
{
echo $query;
$this->debug_mode = false;
return false;
}
array_push($this->logs, $query);
return $this->pdo->query($query);
}
public function exec($query)
{
if ($this->debug_mode)
{
echo $query;
$this->debug_mode = false;
return false;
}
array_push($this->logs, $query);
return $this->pdo->exec($query);
}
public function quote($string)
{
return $this->pdo->quote($string);
}
protected function column_quote($string)
{
return '"' . str_replace('.', '"."', preg_replace('/(^#|\(JSON\))/', '', $string)) . '"';
}
protected function column_push($columns)
{
if ($columns == '*')
{
return $columns;
}
if (is_string($columns))
{
$columns = array($columns);
}
$stack = array();
foreach ($columns as $key => $value)
{
preg_match('/([a-zA-Z0-9_\-\.]*)\s*\(([a-zA-Z0-9_\-]*)\)/i', $value, $match);
if (isset($match[1], $match[2]))
{
array_push($stack, $this->column_quote( $match[1] ) . ' AS ' . $this->column_quote( $match[2] ));
}
else
{
array_push($stack, $this->column_quote( $value ));
}
}
return implode($stack, ',');
}
protected function array_quote($array)
{
$temp = array();
foreach ($array as $value)
{
$temp[] = is_int($value) ? $value : $this->pdo->quote($value);
}
return implode($temp, ',');
}
protected function inner_conjunct($data, $conjunctor, $outer_conjunctor)
{
$haystack = array();
foreach ($data as $value)
{
$haystack[] = '(' . $this->data_implode($value, $conjunctor) . ')';
}
return implode($outer_conjunctor . ' ', $haystack);
}
protected function fn_quote($column, $string)
{
return (strpos($column, '#') === 0 && preg_match('/^[A-Z0-9\_]*\([^)]*\)$/', $string)) ?
$string :
$this->quote($string);
}
protected function data_implode($data, $conjunctor, $outer_conjunctor = null)
{
$wheres = array();
foreach ($data as $key => $value)
{
$type = gettype($value);
if (
preg_match("/^(AND|OR)\s*#?/i", $key, $relation_match) &&
$type == 'array'
)
{
$wheres[] = 0 !== count(array_diff_key($value, array_keys(array_keys($value)))) ?
'(' . $this->data_implode($value, ' ' . $relation_match[1]) . ')' :
'(' . $this->inner_conjunct($value, ' ' . $relation_match[1], $conjunctor) . ')';
}
else
{
preg_match('/(#?)([\w\.]+)(\[(\>|\>\=|\<|\<\=|\!|\<\>|\>\<|\!?~)\])?/i', $key, $match);
$column = $this->column_quote($match[2]);
if (isset($match[4]))
{
$operator = $match[4];
if ($operator == '!')
{
switch ($type)
{
case 'NULL':
$wheres[] = $column . ' IS NOT NULL';
break;
case 'array':
$wheres[] = $column . ' NOT IN (' . $this->array_quote($value) . ')';
break;
case 'integer':
case 'double':
$wheres[] = $column . ' != ' . $value;
break;
case 'boolean':
$wheres[] = $column . ' != ' . ($value ? '1' : '0');
break;
case 'string':
$wheres[] = $column . ' != ' . $this->fn_quote($key, $value);
break;
}
}
if ($operator == '<>' || $operator == '><')
{
if ($type == 'array')
{
if ($operator == '><')
{
$column .= ' NOT';
}
if (is_numeric($value[0]) && is_numeric($value[1]))
{
$wheres[] = '(' . $column . ' BETWEEN ' . $value[0] . ' AND ' . $value[1] . ')';
}
else
{
$wheres[] = '(' . $column . ' BETWEEN ' . $this->quote($value[0]) . ' AND ' . $this->quote($value[1]) . ')';
}
}
}
if ($operator == '~' || $operator == '!~')
{
if ($type == 'string')
{
$value = array($value);
}
if (!empty($value))
{
$like_clauses = array();
foreach ($value as $item)
{
if ($operator == '!~')
{
$column .= ' NOT';
}
if (preg_match('/^(?!%).+(?<!%)$/', $item))
{
$item = '%' . $item . '%';
}
$like_clauses[] = $column . ' LIKE ' . $this->fn_quote($key, $item);
}
$wheres[] = implode(' OR ', $like_clauses);
}
}
if (in_array($operator, array('>', '>=', '<', '<=')))
{
if (is_numeric($value))
{
$wheres[] = $column . ' ' . $operator . ' ' . $value;
}
elseif (strpos($key, '#') === 0)
{
$wheres[] = $column . ' ' . $operator . ' ' . $this->fn_quote($key, $value);
}
else
{
$wheres[] = $column . ' ' . $operator . ' ' . $this->quote($value);
}
}
}
else
{
switch ($type)
{
case 'NULL':
$wheres[] = $column . ' IS NULL';
break;
case 'array':
$wheres[] = $column . ' IN (' . $this->array_quote($value) . ')';
break;
case 'integer':
case 'double':
$wheres[] = $column . ' = ' . $value;
break;
case 'boolean':
$wheres[] = $column . ' = ' . ($value ? '1' : '0');
break;
case 'string':
$wheres[] = $column . ' = ' . $this->fn_quote($key, $value);
break;
}
}
}
}
return implode($conjunctor . ' ', $wheres);
}
protected function where_clause($where)
{
$where_clause = '';
if (is_array($where))
{
$where_keys = array_keys($where);
$where_AND = preg_grep("/^AND\s*#?$/i", $where_keys);
$where_OR = preg_grep("/^OR\s*#?$/i", $where_keys);
$single_condition = array_diff_key($where, array_flip(
explode(' ', 'AND OR GROUP ORDER HAVING LIMIT LIKE MATCH')
));
if ($single_condition != array())
{
$where_clause = ' WHERE ' . $this->data_implode($single_condition, '');
}
if (!empty($where_AND))
{
$value = array_values($where_AND);
$where_clause = ' WHERE ' . $this->data_implode($where[ $value[0] ], ' AND');
}
if (!empty($where_OR))
{
$value = array_values($where_OR);
$where_clause = ' WHERE ' . $this->data_implode($where[ $value[0] ], ' OR');
}
if (isset($where['MATCH']))
{
$MATCH = $where['MATCH'];
if (is_array($MATCH) && isset($MATCH['columns'], $MATCH['keyword']))
{
$where_clause .= ($where_clause != '' ? ' AND ' : ' WHERE ') . ' MATCH ("' . str_replace('.', '"."', implode($MATCH['columns'], '", "')) . '") AGAINST (' . $this->quote($MATCH['keyword']) . ')';
}
}
if (isset($where['GROUP']))
{
$where_clause .= ' GROUP BY ' . $this->column_quote($where['GROUP']);
if (isset($where['HAVING']))
{
$where_clause .= ' HAVING ' . $this->data_implode($where['HAVING'], ' AND');
}
}
if (isset($where['ORDER']))
{
$rsort = '/(^[a-zA-Z0-9_\-\.]*)(\s*(DESC|ASC))?/';
$ORDER = $where['ORDER'];
if (is_array($ORDER))
{
if (
isset($ORDER[1]) &&
is_array($ORDER[1])
)
{
$where_clause .= ' ORDER BY FIELD(' . $this->column_quote($ORDER[0]) . ', ' . $this->array_quote($ORDER[1]) . ')';
}
else
{
$stack = array();
foreach ($ORDER as $column)
{
preg_match($rsort, $column, $order_match);
array_push($stack, '"' . str_replace('.', '"."', $order_match[1]) . '"' . (isset($order_match[3]) ? ' ' . $order_match[3] : ''));
}
$where_clause .= ' ORDER BY ' . implode($stack, ',');
}
}
else
{
preg_match($rsort, $ORDER, $order_match);
$where_clause .= ' ORDER BY "' . str_replace('.', '"."', $order_match[1]) . '"' . (isset($order_match[3]) ? ' ' . $order_match[3] : '');
}
}
if (isset($where['LIMIT']))
{
$LIMIT = $where['LIMIT'];
if (is_numeric($LIMIT))
{
$where_clause .= ' LIMIT ' . $LIMIT;
}
if (
is_array($LIMIT) &&
is_numeric($LIMIT[0]) &&
is_numeric($LIMIT[1])
)
{
$where_clause .= ' LIMIT ' . $LIMIT[0] . ',' . $LIMIT[1];
}
}
}
else
{
if ($where != null)
{
$where_clause .= ' ' . $where;
}
}
return $where_clause;
}
protected function select_context($table, $join, &$columns = null, $where = null, $column_fn = null)
{
$table = '"' . $table . '"';
$join_key = is_array($join) ? array_keys($join) : null;
if (
isset($join_key[0]) &&
strpos($join_key[0], '[') === 0
)
{
$table_join = array();
$join_array = array(
'>' => 'LEFT',
'<' => 'RIGHT',
'<>' => 'FULL',
'><' => 'INNER'
);
foreach($join as $sub_table => $relation)
{
preg_match('/(\[(\<|\>|\>\<|\<\>)\])?([a-zA-Z0-9_\-]*)\s?(\(([a-zA-Z0-9_\-]*)\))?/', $sub_table, $match);
if ($match[2] != '' && $match[3] != '')
{
if (is_string($relation))
{
$relation = 'USING ("' . $relation . '")';
}
if (is_array($relation))
{
// For ['column1', 'column2']
if (isset($relation[0]))
{
$relation = 'USING ("' . implode($relation, '", "') . '")';
}
// For ['column1' => 'column2']
else
{
$relation = 'ON ' . $table . '."' . key($relation) . '" = "' . (isset($match[5]) ? $match[5] : $match[3]) . '"."' . current($relation) . '"';
}
}
$table_join[] = $join_array[ $match[2] ] . ' JOIN "' . $match[3] . '" ' . (isset($match[5]) ? 'AS "' . $match[5] . '" ' : '') . $relation;
}
}
$table .= ' ' . implode($table_join, ' ');
}
else
{
if (is_null($columns))
{
if (is_null($where))
{
if (
is_array($join) &&
isset($column_fn)
)
{
$where = $join;
$columns = null;
}
else
{
$where = null;
$columns = $join;
}
}
else
{
$where = $join;
$columns = null;
}
}
else
{
$where = $columns;
$columns = $join;
}
}
if (isset($column_fn))
{
if ($column_fn == 1)
{
$column = '1';
if (is_null($where))
{
$where = $columns;
}
}
else
{
if (empty($columns))
{
$columns = '*';
$where = $join;
}
$column = $column_fn . '(' . $this->column_push($columns) . ')';
}
}
else
{
$column = $this->column_push($columns);
}
return 'SELECT ' . $column . ' FROM ' . $table . $this->where_clause($where);
}
public function select($table, $join, $columns = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $columns, $where));
return $query ? $query->fetchAll(
(is_string($columns) && $columns != '*') ? PDO::FETCH_COLUMN : PDO::FETCH_ASSOC
) : false;
}
public function insert($table, $datas)
{
$lastId = array();
// Check indexed or associative array
if (!isset($datas[0]))
{
$datas = array($datas);
}
foreach ($datas as $data)
{
$keys = array_keys($data);
$values = array();
$columns = array();
foreach ($data as $key => $value)
{
array_push($columns, $this->column_quote($key));
switch (gettype($value))
{
case 'NULL':
$values[] = 'NULL';
break;
case 'array':
preg_match("/\(JSON\)\s*([\w]+)/i", $key, $column_match);
$values[] = isset($column_match[0]) ?
$this->quote(json_encode($value)) :
$this->quote(serialize($value));
break;
case 'boolean':
$values[] = ($value ? '1' : '0');
break;
case 'integer':
case 'double':
case 'string':
$values[] = $this->fn_quote($key, $value);
break;
}
}
$this->exec('INSERT INTO "' . $table . '" (' . implode(', ', $columns) . ') VALUES (' . implode($values, ', ') . ')');
$lastId[] = $this->pdo->lastInsertId();
}
return count($lastId) > 1 ? $lastId : $lastId[ 0 ];
}
public function update($table, $data, $where = null)
{
$fields = array();
foreach ($data as $key => $value)
{
preg_match('/([\w]+)(\[(\+|\-|\*|\/)\])?/i', $key, $match);
if (isset($match[3]))
{
if (is_numeric($value))
{
$fields[] = $this->column_quote($match[1]) . ' = ' . $this->column_quote($match[1]) . ' ' . $match[3] . ' ' . $value;
}
}
else
{
$column = $this->column_quote($key);
switch (gettype($value))
{
case 'NULL':
$fields[] = $column . ' = NULL';
break;
case 'array':
preg_match("/\(JSON\)\s*([\w]+)/i", $key, $column_match);
$fields[] = $column . ' = ' . $this->quote(
isset($column_match[0]) ? json_encode($value) : serialize($value)
);
break;
case 'boolean':
$fields[] = $column . ' = ' . ($value ? '1' : '0');
break;
case 'integer':
case 'double':
case 'string':
$fields[] = $column . ' = ' . $this->fn_quote($key, $value);
break;
}
}
}
return $this->exec('UPDATE "' . $table . '" SET ' . implode(', ', $fields) . $this->where_clause($where));
}
public function delete($table, $where)
{
return $this->exec('DELETE FROM "' . $table . '"' . $this->where_clause($where));
}
public function replace($table, $columns, $search = null, $replace = null, $where = null)
{
if (is_array($columns))
{
$replace_query = array();
foreach ($columns as $column => $replacements)
{
foreach ($replacements as $replace_search => $replace_replacement)
{
$replace_query[] = $column . ' = REPLACE(' . $this->column_quote($column) . ', ' . $this->quote($replace_search) . ', ' . $this->quote($replace_replacement) . ')';
}
}
$replace_query = implode(', ', $replace_query);
$where = $search;
}
else
{
if (is_array($search))
{
$replace_query = array();
foreach ($search as $replace_search => $replace_replacement)
{
$replace_query[] = $columns . ' = REPLACE(' . $this->column_quote($columns) . ', ' . $this->quote($replace_search) . ', ' . $this->quote($replace_replacement) . ')';
}
$replace_query = implode(', ', $replace_query);
$where = $replace;
}
else
{
$replace_query = $columns . ' = REPLACE(' . $this->column_quote($columns) . ', ' . $this->quote($search) . ', ' . $this->quote($replace) . ')';
}
}
return $this->exec('UPDATE "' . $table . '" SET ' . $replace_query . $this->where_clause($where));
}
public function get($table, $join = null, $column = null, $where = null)
{
if (!isset($where))
{
$where = array();
}
$where['LIMIT'] = 1;
$query = $this->query($this->select_context($table, $join, $column, $where));
if ($query)
{
$data = $query->fetchAll(PDO::FETCH_ASSOC);
if (isset($data[0]))
{
$column = $where == null ? $join : $column;
if (is_string($column) && $column != '*')
{
return $data[ 0 ][ $column ];
}
return $data[ 0 ];
}
else
{
return false;
}
}
else
{
return false;
}
}
public function has($table, $join, $where = null)
{
$column = null;
$query = $this->query('SELECT EXISTS(' . $this->select_context($table, $join, $column, $where, 1) . ')');
return $query ? $query->fetchColumn() === '1' : false;
}
public function count($table, $join = null, $column = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $column, $where, 'COUNT'));
return $query ? 0 + $query->fetchColumn() : false;
}
public function max($table, $join, $column = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $column, $where, 'MAX'));
if ($query)
{
$max = $query->fetchColumn();
return is_numeric($max) ? $max + 0 : $max;
}
else
{
return false;
}
}
public function min($table, $join, $column = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $column, $where, 'MIN'));
if ($query)
{
$min = $query->fetchColumn();
return is_numeric($min) ? $min + 0 : $min;
}
else
{
return false;
}
}
public function avg($table, $join, $column = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $column, $where, 'AVG'));
return $query ? 0 + $query->fetchColumn() : false;
}
public function sum($table, $join, $column = null, $where = null)
{
$query = $this->query($this->select_context($table, $join, $column, $where, 'SUM'));
return $query ? 0 + $query->fetchColumn() : false;
}
public function debug()
{
$this->debug_mode = true;
return $this;
}
public function error()
{
return $this->pdo->errorInfo();
}
public function last_query()
{
return end($this->logs);
}
public function log()
{
return $this->logs;
}
public function info()
{
$output = array(
'server' => 'SERVER_INFO',
'driver' => 'DRIVER_NAME',
'client' => 'CLIENT_VERSION',
'version' => 'SERVER_VERSION',
'connection' => 'CONNECTION_STATUS'
);
foreach ($output as $key => $value)
{
$output[ $key ] = $this->pdo->getAttribute(constant('PDO::ATTR_' . $value));
}
return $output;
}
}
?>

151
php/plugin.emailtracking.php Executable file
View File

@@ -0,0 +1,151 @@
<?php
require_once __DIR__ . "/lib/class.EmailTracker.php";
class Pluginemailtracking extends Plugin {
private $emailTracker;
/**
* Constructor
*/
function Pluginemailtracking(){}
/**
* Called to initialize the plugin and register for hooks.
*/
function init(){
$this->registerHook('server.core.settings.init.before');
$this->registerHook('server.core.operations.submitmessage');
$this->store = $GLOBALS['mapisession']->getDefaultMessageStore();
$this->emailTracker = new EmailTracker();
}
/**
* Process the incoming events that where fired by the client.
*
* @param String $eventID Identifier of the hook
* @param Array $data Reference to the data of the triggered hook
*/
function execute($eventID, &$data) {
switch($eventID){
// Register plugin
case 'server.core.settings.init.before':
$this->onBeforeSettingsInit($data);
break;
// Add tracking stuff before submitting the message
case 'server.core.operations.submitmessage':
$this->onBeforeSubmit($data);
break;
// Add tracking property, which is send to the client
case 'server.module.itemmodule.open.after':
$this->onAfterOpen($data);
break;
}
}
/**
* This function handles the 'beforesend' hook which is triggered before sending the email.
* If the PR_MESSAGE_CLASS is set to a signed email (IPM.Note.SMIME.Multipartsigned), this function
* will convert the mapi message to RFC822, sign the eml and attach the signed email to the mapi message.
*
* @param {mixed} $data from php hook
*/
function onBeforeSubmit(&$data)
{
$message = $data['message'];
// Retrieve message class
$props = mapi_getprops($message, array(PR_MESSAGE_CLASS, PR_SUBJECT, PR_SENDER_EMAIL_ADDRESS));
if (mapi_is_error(mapi_last_hresult())) {
error_log("error loading props!");
}
$recipients = mapi_message_getrecipienttable($message);
$messageClass = $props[PR_MESSAGE_CLASS];
if(isset($messageClass) && (stripos($messageClass, 'IPM.Note.Tracking') !== false)) {
// reset messageClass
mapi_setprops($message, array(PR_MESSAGE_CLASS => 'IPM.Note'));
error_log("Number of recipients: " . mapi_table_getrowcount($recipients));
// get all recipient email addresses
$filters=array(PR_ADDRTYPE, PR_EMAIL_ADDRESS, PR_SMTP_ADDRESS);
$rows = mapi_table_queryrows($recipients,$filters,0,1); // get only the first recipient
$recipient = "";
foreach($rows as $row) {
$recipient = $row[PR_ADDRTYPE] === "SMTP" ? $row[PR_SMTP_ADDRESS] : $row[PR_EMAIL_ADDRESS];
}
// get a new tracking id:
$trackingId = $this->emailTracker->getNewTrackingCode(md5($props[PR_SUBJECT] . time()), $recipient, $props[PR_SENDER_EMAIL_ADDRESS], $props[PR_SUBJECT]);
$trackingURL_Image = PLUGIN_EMAILTRACKING_PUBLIC_WEBAPP_URL . "/plugins/emailtracking/php/track.php?img=" . $trackingId;
$trackingURL_Sound = PLUGIN_EMAILTRACKING_PUBLIC_WEBAPP_URL . "/plugins/emailtracking/php/track.php?bgsound=" . $trackingId;
// add the tracking html tags to the body
$trackingHTML = '<img send="true" alt="" lowsrc="" src="' . $trackingURL_Image . '" border="0" height="1" width="3" />';
$trackingHTML .= '<bgsound volume="-10000" alt="" lowsrc="" src="' . $trackingURL_Sound . '">';
// stream the body and add the tracking changes!
$messageStream = mapi_openproperty($message, PR_HTML, IID_IStream, 0, 0);
$stat = mapi_stream_stat($messageStream);
// create temporary files
$tmpEmail = tempnam(sys_get_temp_dir(),true);
$fhandle = fopen($tmpEmail,'w');
$buffer = null;
for($i = 0; $i < $stat["cb"]; $i += BLOCK_SIZE) {
// Write stream
$buffer = mapi_stream_read($messageStream, BLOCK_SIZE);
fwrite($fhandle,$buffer,strlen($buffer));
}
// append tracking stuff
fwrite($fhandle, $trackingHTML, strlen($trackingHTML));
fclose($fhandle);
// Save the signed message as attachment of the send email
$outStream = mapi_openproperty($message, PR_HTML, IID_IStream, 0, MAPI_CREATE | MAPI_MODIFY);
$handle = fopen($tmpEmail, 'r');
while (!feof($handle)) {
$contents = fread($handle, BLOCK_SIZE);
mapi_stream_write($outStream, $contents);
}
fclose($handle);
// Save stream
mapi_stream_commit($outStream);
// remove tmp files
unlink($tmpEmail);
// Save changes
mapi_savechanges($message);
}
}
/**
* Called when the core Settings class is initialized and ready to accept sysadmin default
* settings. Registers the sysadmin defaults for the example plugin.
*
* @param {mixed} $data Reference to the data of the triggered hook
*/
function onBeforeSettingsInit(&$data){
$data['settingsObj']->addSysAdminDefaults(Array(
'zarafa' => Array(
'v1' => Array(
'plugins' => Array(
'emailtracking' => Array(
'enable' => PLUGIN_EMAILTRACKING_USER_DEFAULT_ENABLE_TRACKING,
'internals' => PLUGIN_EMAILTRACKING_SHOW_INTERNAL_LOGS
)
)
)
)
));
}
}
?>

32
php/track.php Executable file
View File

@@ -0,0 +1,32 @@
<?php
require __DIR__ . "/lib/class.EmailTracker.php";
$trackingID = "";
$type = "none";
// check which type was logged
if(isset($_GET["img"])) {
$trackingID = $_GET["img"];
$type = "img";
} else if(isset($_GET["sound"])) {
$trackingID = $_GET["bgsound"];
$type = "bgsound";
}
if(!empty($trackingID) && $type !== "none") {
$dbObj = new EmailTracker();
// build our tracking entry
$data = array(
"ip_addr" => $_SERVER["REMOTE_ADDR"],
"referrer" => isset($_SERVER["HTTP_REFERER"]) ? $_SERVER["HTTP_REFERER"] : "",
"client" => isset($_SERVER["HTTP_USER_AGENT"]) ? $_SERVER["HTTP_USER_AGENT"] : "",
"tracking_type" => $type,
"timestamp" => date('Y-m-d H:i:s', time()),
);
// log it to db
$dbObj->addLog($trackingID, $data);
} else {
echo "Powerful you have become, the dark side I sense in you.";
}