piler/webui/model/search/search.php

850 lines
27 KiB
PHP
Raw Normal View History

2012-02-08 23:14:28 +01:00
<?php
class ModelSearchSearch extends Model {
2012-09-06 15:27:20 +02:00
public function search_messages($data = array(), $page = 0) {
2012-02-08 23:14:28 +01:00
$one_page_of_ids = array();
$total_hits = 0;
$sort = "sent";
$order = "DESC";
$sortorder = "ORDER BY sent DESC";
$cache_key = "";
$q = "";
$s = "";
2012-03-10 14:52:50 +01:00
$all_ids_csv = "";
2012-02-08 23:14:28 +01:00
while(list($k,$v) = each($data)) {
if($v) { $s .= '&' . $k . '=' . $v; }
}
if($s) { $s = substr($s, 1, strlen($s)); }
AUDIT(ACTION_SEARCH, '', '', 0, $s);
if($data['sort'] == "sent") { $sort = "sent"; }
if($data['sort'] == "size") { $sort = "size"; }
if($data['sort'] == "from") { $sort = "from"; }
if($data['sort'] == "subj") { $sort = "subject"; }
if($data['order'] == 1) { $order = "ASC"; }
$sortorder = "ORDER BY `$sort` $order";
$m = array();
if(MEMCACHED_ENABLED) {
$cache_key = $this->make_cache_file_name($data, $sortorder);
$memcache = Registry::get('memcache');
$m = $memcache->get($cache_key);
}
if(isset($m['ids'])) {
$all_ids = $m['ids'];
} else {
2012-06-21 10:53:42 +02:00
if(isset($data['ref']) && $data['ref']){
2012-02-10 14:06:00 +01:00
$all_ids = $this->query_all_possible_IDs_by_reference($data['ref'], $cache_key);
2012-02-08 23:14:28 +01:00
}
else {
2012-09-06 15:27:20 +02:00
$all_ids = $this->query_all_possible_IDs($data, $sort, $order, $sortorder, $cache_key);
2012-02-10 14:06:00 +01:00
}
2012-02-08 23:14:28 +01:00
}
$total_hits = count($all_ids);
2012-09-06 15:27:20 +02:00
2012-02-08 23:14:28 +01:00
$data['page_len'] = get_page_length();
if($total_hits > 0) {
$i = 0;
foreach($all_ids as $id) {
if($i >= $data['page_len'] * $page && $i < $data['page_len'] * ($page+1) ) {
array_push($one_page_of_ids, $id);
2012-03-10 14:52:50 +01:00
$all_ids_csv .= ",$id";
2012-02-08 23:14:28 +01:00
if($q) { $q .= ",?"; } else { $q = "?"; }
}
$i++;
}
}
2012-09-06 15:27:20 +02:00
$all_ids_csv = substr($all_ids_csv, 1, strlen($all_ids_csv));
2012-03-10 14:52:50 +01:00
return array($total_hits, $all_ids_csv, $this->get_meta_data($one_page_of_ids, $q, $sortorder));
2012-02-08 23:14:28 +01:00
}
2012-09-06 15:27:20 +02:00
private function assemble_email_address_condition($from = '', $to = '') {
$s = '';
$f_from = $f_fromdomain = $f_to = $f_todomain = '';
$o_from = $o_fromdomain = $o_to = $o_todomain = '';
$f_f = $o_f = $f_t = $o_t = '';
$f = $t = $fdomain = $tdomain = '';
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$session_emails = $this->fix_email_address_for_sphinx($_SESSION['emails']);
2013-01-05 16:42:36 +01:00
$session_domains = $this->fix_email_address_for_sphinx($_SESSION['auditdomains']);
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$all_your_addresses = $this->get_all_your_address();
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$from = preg_replace("/OR/", "", $from);
$to = preg_replace("/OR/", "", $to);
2012-08-28 22:00:45 +02:00
2012-09-06 15:27:20 +02:00
if($from) {
$e = preg_split("/\s/", $from);
foreach ($e as $email) {
if($email == '') { continue; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$email = $this->fix_email_address_for_sphinx($email);
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$field = 'from';
if($email[0] == 'X') {
$email = substr($email, 1, strlen($email));
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$field = 'fromdomain';
$fdomain .= "|$email";
}
else {
$f .= "|$email";
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if(in_array($email, $session_emails)) {
$a = "o_$field";
2012-02-08 23:14:28 +01:00
}
2012-09-06 15:27:20 +02:00
else {
$a = "f_$field";
}
if($$a) { $$a .= "|"; }
$$a .= "$email";
2012-02-08 23:14:28 +01:00
}
}
2012-09-06 15:27:20 +02:00
if($to) {
$e = preg_split("/\s/", $to);
foreach ($e as $email) {
if($email == '') { continue; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$email = $this->fix_email_address_for_sphinx($email);
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$field = 'to';
if($email[0] == 'X') {
$email = substr($email, 1, strlen($email));
$field = 'todomain';
$tdomain .= "|$email";
}
else {
$t .= "|$email";
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if(in_array($email, $session_emails)) {
$a = "o_$field";
}
else {
$a = "f_$field";
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($$a) { $$a .= "|"; }
$$a .= "$email";
}
2012-02-08 23:14:28 +01:00
}
2012-09-06 15:27:20 +02:00
if($f) { $f = preg_replace("/^\|/", "@from ", $f); }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($fdomain) {
$fdomain = preg_replace("/^\|/", "@fromdomain ", $fdomain);
if($f) { $f = "(($f)|($fdomain))"; }
else { $f = "($fdomain)"; }
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($t) { $t = preg_replace("/^\|/", "@to ", $t); }
2012-08-28 22:00:45 +02:00
2012-09-06 15:27:20 +02:00
if($tdomain) {
$tdomain = preg_replace("/^\|/", "@todomain ", $tdomain);
if($t) { $t = "(($t)|($tdomain))"; }
else { $t = "($tdomain)"; }
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if(Registry::get('auditor_user') == 1 || ENABLE_FOLDER_RESTRICTIONS == 1) {
$domain_restrictions = '';
$sd = $this->fix_email_address_for_sphinx($_SESSION['domain']);
2013-01-05 16:42:36 +01:00
foreach ($session_domains as $d) {
$sd .= '|'.$d;
}
$sd = preg_replace("/^\|/", "", $sd);
2012-02-08 23:14:28 +01:00
if(RESTRICTED_AUDITOR == 1) {
2013-01-05 16:42:36 +01:00
$domain_restrictions = ' (@todomain ' . $sd . ' | @fromdomain ' . $sd . ')';
}
if($from == '' && $to == '') { return $domain_restrictions; }
if(RESTRICTED_AUDITOR == 1) {
$domain_restrictions = " & $domain_restrictions";
}
if($f && $t) { return "($f & $t) $domain_restrictions"; }
else if($f) { return "($f) $domain_restrictions"; }
else if($t) { return "($t) $domain_restrictions"; }
2012-09-06 15:27:20 +02:00
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($f_from) { $f_f = "@from $f_from"; }
if($f_fromdomain) { if($f_f) { $f_f = "($f_f | @fromdomain $f_fromdomain)"; } else { $f_f = "@fromdomain $f_fromdomain"; } }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($o_from) { $o_f = "@from $o_from"; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($f_to) { $f_t = "@to $f_to"; }
if($f_todomain) { if($f_t) { $f_t = "($f_t | @todomain $f_todomain)"; } else { $f_t = "@todomain $f_todomain"; } }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($o_to) { $o_t = "@to $o_to"; }
2012-02-08 23:14:28 +01:00
if($f_f == '' && $o_f == '' && $f_t == '' && $o_t == '') { return "(@from $all_your_addresses | @to $all_your_addresses)"; }
2012-09-06 15:27:20 +02:00
if($f_f == '' && $o_f == '' && $f_t == '' && $o_t ) { return "$o_t"; }
if($f_f == '' && $o_f == '' && $f_t && $o_t == '') { return "(@from $all_your_addresses & $f_t)"; }
if($f_f == '' && $o_f == '' && $f_t && $o_t ) { return "($o_t | (@from $all_your_addresses & $f_t))"; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($f_f == '' && $o_f && $f_t == '' && $o_t == '') { return "$o_f"; }
if($f_f == '' && $o_f && $f_t == '' && $o_t ) { return "($o_f & $o_t)"; }
if($f_f == '' && $o_f && $f_t && $o_t == '') { return "($o_f & $f_t)"; }
if($f_f == '' && $o_f && $f_t && $o_t ) { return "(($o_f & $f_t) | ($o_f & $o_t))"; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($f_f && $o_f == '' && $f_t == '' && $o_t == '') { return "($f_f & @to $all_your_addresses)"; }
if($f_f && $o_f == '' && $f_t == '' && $o_t ) { return "($f_f & $o_t)"; }
if($f_f && $o_f == '' && $f_t && $o_t == '') { return "@from INVALID"; }
if($f_f && $o_f == '' && $f_t && $o_t ) { return "($f_f & $o_t)"; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($f_f && $o_f && $f_t == '' && $o_t == '') { return "(($f_f & @to $all_your_addresses)|$o_f)"; }
if($f_f && $o_f && $f_t == '' && $o_t ) { return "(($f_f & $o_t)|($o_f & $o_t))"; }
if($f_f && $o_f && $f_t && $o_t == '') { return "($o_f & $f_t)"; }
if($f_f && $o_f && $f_t && $o_t ) { return "(($f_f & $o_t)|($o_f & $f_t))"; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
return "(@from $all_your_addresses | @to $all_your_addresses)";
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
}
private function query_all_possible_IDs($data = array(), $sort = 'sent', $order = 'DESC', $sortorder = '', $cache_key = '') {
$ids = array();
$__folders = array();
$match = '';
$direction = $attachment = $size = $folders = '';
$tag_id_list = '';
$a = "";
$id = "";
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
$match = $this->assemble_email_address_condition($data['from'], $data['to']);
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($data['body']) {
$data['body'] = $this->fixup_meta_characters($data['body']);
2012-09-06 15:27:20 +02:00
$data['body'] = $this->fixup_sphinx_operators($data['body']);
if($match) { $match .= " & "; } $match .= "(@body " . $data['body'] . ") ";
}
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($data['subject']) {
$data['subject'] = $this->fixup_meta_characters($data['subject']);
2012-02-08 23:14:28 +01:00
$data['subject'] = $this->fixup_sphinx_operators($data['subject']);
2012-09-06 15:27:20 +02:00
if($match) { $match .= " & "; } $match .= "(@subject " . $data['subject'] . ") ";
2012-02-08 23:14:28 +01:00
}
if($data['attachment_type'] && !strstr($data['attachment_type'], "any")) { if($match) { $match .= " & "; } $match .= "(@attachment_types " . preg_replace("/\,/", "|", $data['attachment_type']) . ") "; }
2012-02-08 23:14:28 +01:00
2012-09-06 15:27:20 +02:00
if($data['any']) {
$data['any'] = $this->fixup_meta_characters($data['any']);
2012-09-06 15:27:20 +02:00
$data['any'] = $this->fixup_sphinx_operators($data['any']);
$data['any'] = $this->fix_email_address_for_sphinx($data['any']);
2013-01-05 20:58:49 +01:00
$fields = '';
2013-08-25 21:57:04 +02:00
if($match) { $match = "($match) & "; } $match .= "(@(subject,body) " . $data['any'] . ") ";
2012-09-06 15:27:20 +02:00
}
2012-02-08 23:14:28 +01:00
if($data['sort'] == 'from' || $data['sort'] == 'subj') { $sortorder = ''; }
$date = fixup_date_condition('sent', $data['date1'], $data['date2']);
if($date) { $date .= " AND "; }
if(isset($data['direction']) && $data['direction'] != '') { $direction = "direction = " . $data['direction'] . " AND "; }
if(isset($data['size']) && $data['size']) {
$data['size'] = preg_replace("/\s/", "", $data['size']);
if(preg_match("/^(\>|\<)\={0,}\d{1,}$/", $data['size'])) { $size = "size " . $data['size'] . " AND "; }
}
if(isset($data['attachment_type']) && strstr($data['attachment_type'], 'any')) { $a = "attachments > 0 AND "; }
2012-09-06 15:27:20 +02:00
else if(isset($data['has_attachment']) && $data['has_attachment'] == 1) { $attachment = "attachments > 0 AND "; }
2012-02-08 23:14:28 +01:00
if(isset($data['id'])) {
$data['id'] = preg_replace("/ /", "," , substr($data['id'], 1, strlen($data['id'])));
$id = " id IN (" . $data['id'] . ") AND ";
}
2012-09-06 15:27:20 +02:00
if(ENABLE_FOLDER_RESTRICTIONS == 1) {
$s = explode(" ", $data['folders']);
while(list($k,$v) = each($s)) {
if(in_array($v, $_SESSION['folders'])) {
array_push($__folders, $v);
}
2012-02-08 23:14:28 +01:00
}
2012-09-14 11:04:17 +02:00
if(count($__folders) > 0) {
$folders = "folder IN (" . implode(",", $__folders) . ") AND ";
}
2013-03-31 14:50:21 +02:00
else {
$folders = "folder IN (" . implode(",", $_SESSION['folders']) . ") AND ";
}
2012-09-06 15:27:20 +02:00
}
if(isset($data['tag']) && $data['tag']) {
$id_list = $this->get_sphinx_id_list($data['tag'], SPHINX_TAG_INDEX, 'tag');
$query = $this->sphx->query("SELECT id FROM " . SPHINX_MAIN_INDEX . " WHERE $folders id IN ($id_list) $sortorder LIMIT 0," . MAX_SEARCH_HITS . " OPTION max_matches=" . MAX_SEARCH_HITS);
2012-09-06 15:27:20 +02:00
}
else if(isset($data['note']) && $data['note']) {
$id_list = $this->get_sphinx_id_list($data['note'], SPHINX_NOTE_INDEX, 'note');
$query = $this->sphx->query("SELECT id FROM " . SPHINX_MAIN_INDEX . " WHERE $folders id IN ($id_list) $sortorder LIMIT 0," . MAX_SEARCH_HITS . " OPTION max_matches=" . MAX_SEARCH_HITS);
2012-02-10 14:06:00 +01:00
}
2012-09-15 15:30:35 +02:00
else if(ENABLE_FOLDER_RESTRICTIONS == 1 && isset($data['extra_folders']) && $data['extra_folders']) {
$ids_in_extra_folders = $this->get_sphinx_id_list_by_extra_folders($data['extra_folders']);
$query = $this->sphx->query("SELECT id FROM " . SPHINX_MAIN_INDEX . " WHERE $a $id $date $attachment $direction $size MATCH('$match') AND id IN ($ids_in_extra_folders) $sortorder LIMIT 0," . MAX_SEARCH_HITS . " OPTION max_matches=" . MAX_SEARCH_HITS);
2012-09-15 15:30:35 +02:00
}
2012-02-10 14:06:00 +01:00
else {
$query = $this->sphx->query("SELECT id FROM " . SPHINX_MAIN_INDEX . " WHERE $a $id $date $attachment $direction $size $folders MATCH('$match') $sortorder LIMIT 0," . MAX_SEARCH_HITS . " OPTION max_matches=" . MAX_SEARCH_HITS);
2012-02-08 23:14:28 +01:00
}
2012-10-23 19:16:24 +02:00
if(ENABLE_SYSLOG == 1) { syslog(LOG_INFO, sprintf("sphinx query: '%s' in %.2f s, %d hits", $query->query, $query->exec_time, $query->num_rows)); }
2012-02-08 23:14:28 +01:00
/*
* build an id list
*/
$q = "";
2012-07-06 15:02:23 +02:00
if(isset($query->rows)) {
foreach($query->rows as $a) {
array_push($ids, $a['id']);
2012-02-08 23:14:28 +01:00
2012-07-06 15:02:23 +02:00
if($q) { $q .= ",?"; }
else { $q = "?"; }
}
2012-02-08 23:14:28 +01:00
}
/*
* if the query was requested to be sorted by sender or subject, then sphinx cannot do
* that, so we assemble the list of all sphinx IDs matching the query
*/
if($data['sort'] == 'from' || $data['sort'] == 'subj') {
$query = $this->db->query("SELECT id FROM " . TABLE_META . " WHERE id IN ($q) ORDER BY `$sort` $order", $ids);
$ids = array();
foreach($query->rows as $q) {
array_push($ids, $q['id']);
}
}
if(MEMCACHED_ENABLED && $cache_key) {
$memcache = Registry::get('memcache');
$memcache->add($cache_key, array('ts' => time(), 'total_hits' => count($ids), 'ids' => $ids), 0, MEMCACHED_TTL);
}
return $ids;
}
2012-02-10 14:06:00 +01:00
private function query_all_possible_IDs_by_reference($reference = '', $cache_key = '') {
$ids = array();
if($reference == '') { return $ids; }
$query = $this->db->query("SELECT id FROM " . TABLE_META . " WHERE message_id=? OR reference=? ORDER BY id DESC", array($reference, $reference));
foreach($query->rows as $q) {
array_push($ids, $q['id']);
}
2012-09-06 15:27:20 +02:00
if(ENABLE_FOLDER_RESTRICTIONS == 1) {
$query = $this->sphx->query("SELECT id, folder FROM " . SPHINX_MAIN_INDEX . " WHERE id IN (" . implode(",", $ids) . ")");
$ids = array();
foreach($query->rows as $q) {
if(isset($q['folder']) && in_array($q['folder'], $_SESSION['folders'])) { array_push($ids, $q['id']); }
}
}
2012-02-10 14:06:00 +01:00
if(MEMCACHED_ENABLED && $cache_key) {
$memcache = Registry::get('memcache');
$memcache->add($cache_key, array('ts' => time(), 'total_hits' => count($ids), 'ids' => $ids), 0, MEMCACHED_TTL);
}
return $ids;
}
2012-09-06 15:27:20 +02:00
private function get_sphinx_id_list($s = '', $sphx_table = '', $field = '') {
$id_list = '';
$s = $this->fixup_sphinx_operators($s);
$q = $this->sphx->query("SELECT id FROM $sphx_table WHERE uid=" . $_SESSION['uid'] . " AND MATCH('@$field $s') ");
foreach($q->rows as $a) {
$id_list .= "," . $a['id'];
}
if($id_list) { $id_list = substr($id_list, 1, strlen($id_list)); }
return $id_list;
}
2012-09-15 15:30:35 +02:00
private function get_sphinx_id_list_by_extra_folders($extra_folders = '') {
$id_list = '';
$q = '';
$__folders = array();
$s = explode(" ", $extra_folders);
while(list($k,$v) = each($s)) {
if(in_array($v, $_SESSION['extra_folders']) && is_numeric($v)) {
array_push($__folders, $v);
if($q) { $q .= ",?"; }
else { $q = "?"; }
}
}
$q = $this->db->query("SELECT id FROM " . TABLE_FOLDER_MESSAGE . " WHERE folder_id IN ($q)", $__folders);
foreach($q->rows as $a) {
$id_list .= "," . $a['id'];
}
if($id_list) { $id_list = substr($id_list, 1, strlen($id_list)); }
return $id_list;
}
2012-02-08 23:14:28 +01:00
private function get_meta_data($ids = array(), $q = '', $sortorder = '') {
$messages = array();
2013-01-14 14:46:34 +01:00
$rcpt = $srcpt = array();
2012-02-08 23:14:28 +01:00
$tag = array();
2012-09-06 15:27:20 +02:00
$note = array();
2012-02-08 23:14:28 +01:00
if(count($ids) == 0) return $messages;
2012-12-04 22:34:15 +01:00
if(MEMCACHED_ENABLED) {
$cache_key = $this->make_cache_file_name($ids, 'meta');
$memcache = Registry::get('memcache');
$m = $memcache->get($cache_key);
if(isset($m['meta'])) { return unserialize($m['meta']); }
}
2012-02-08 23:14:28 +01:00
2013-01-14 14:46:34 +01:00
$query = $this->db->query("SELECT `id`, `to` FROM `" . TABLE_RCPT . "` WHERE `id` IN ($q)", $ids);
if(isset($query->rows)) {
foreach($query->rows as $r) {
if(!isset($rcpt[$r['id']])) {
$srcpt[$r['id']] = $r['to'];
2013-01-31 22:20:50 +01:00
$rcpt[$r['id']] = $r['to'];
2013-01-14 14:46:34 +01:00
}
else {
$rcpt[$r['id']] .= ",\n" . $r['to'];
}
}
}
2012-12-04 22:34:15 +01:00
$query = $this->db->query("SELECT `id`, `from`, `subject`, `piler_id`, `reference`, `size`, `spam`, `sent`, `arrived`, `attachments` FROM `" . TABLE_META . "` WHERE `id` IN ($q) $sortorder", $ids);
2012-02-08 23:14:28 +01:00
if(isset($query->rows)) {
2012-04-27 14:39:10 +02:00
array_unshift($ids, (int)$_SESSION['uid']);
$tags = $this->db->query("SELECT `id`, `tag` FROM `" . TABLE_TAG . "` WHERE `uid`=? AND `id` IN ($q)", $ids);
2012-02-08 23:14:28 +01:00
foreach ($tags->rows as $t) {
$tag[$t['id']] = $t['tag'];
}
2012-09-06 15:27:20 +02:00
$notes = $this->db->query("SELECT `id`, `note` FROM " . TABLE_NOTE . " WHERE `uid`=? AND `id` IN ($q)", $ids);
foreach ($notes->rows as $n) {
$note[$n['id']] = $n['note'];
}
2012-02-08 23:14:28 +01:00
$lang = Registry::get('language');
2013-04-09 15:02:10 +02:00
$this->model_search_message->connect_to_pilergetd();
2012-02-08 23:14:28 +01:00
foreach($query->rows as $m) {
$m['shortfrom'] = make_short_string($m['from'], MAX_CGI_FROM_SUBJ_LEN);
2013-02-11 20:24:19 +01:00
$m['from'] = escape_gt_lt_quote_symbols($m['from']);
isset($srcpt[$m['id']]) ? $m['shortto'] = $srcpt[$m['id']] : $m['shortto'] = '';
isset($rcpt[$m['id']]) ? $m['to'] = $rcpt[$m['id']] : $m['to'] = '';
$m['to'] = escape_gt_lt_quote_symbols($m['to']);
2012-02-08 23:14:28 +01:00
2013-01-14 14:46:34 +01:00
2012-02-08 23:14:28 +01:00
if($m['subject'] == "") { $m['subject'] = "&lt;" . $lang->data['text_no_subject'] . "&gt;"; }
$m['subject'] = escape_gt_lt_quote_symbols($m['subject']);
$m['shortsubject'] = make_short_string($m['subject'], MAX_CGI_FROM_SUBJ_LEN);
$m['date'] = date(DATE_TEMPLATE, $m['sent']);
2012-02-08 23:14:28 +01:00
$m['size'] = nice_size($m['size']);
in_array($m['from'], $_SESSION['emails']) ? $m['yousent'] = 1 : $m['yousent'] = 0;
2012-02-08 23:14:28 +01:00
/*
* verifying 20 messages takes some time, still it's useful
*/
if(ENABLE_ON_THE_FLY_VERIFICATION == 1) {
$m['verification'] = $this->model_search_message->verify_message($m['piler_id']);
}
if(isset($tag[$m['id']])) { $m['tag'] = $tag[$m['id']]; } else { $m['tag'] = ''; }
2012-09-06 15:27:20 +02:00
if(isset($note[$m['id']])) { $m['note'] = $note[$m['id']]; } else { $m['note'] = ''; }
2012-02-08 23:14:28 +01:00
2013-04-06 11:32:17 +02:00
$m['note'] = preg_replace("/\"/", "*", strip_tags($m['note']));
$m['tag'] = preg_replace("/\"/", "*", strip_tags($m['tag']));
2013-02-11 20:24:19 +01:00
2012-02-08 23:14:28 +01:00
array_push($messages, $m);
}
2013-04-09 15:02:10 +02:00
$this->model_search_message->disconnect_from_pilergetd();
2012-02-08 23:14:28 +01:00
}
2012-12-04 22:34:15 +01:00
if(MEMCACHED_ENABLED) {
$memcache->add($cache_key, array('meta' => serialize($messages)), 0, MEMCACHED_TTL);
}
2012-02-08 23:14:28 +01:00
return $messages;
}
public function get_message_recipients($id = '') {
$rcpt = array();
$domains = array();
2012-02-08 23:14:28 +01:00
if(Registry::get('auditor_user') == 0) { return $rcpt; }
2012-02-08 23:14:28 +01:00
$query = $this->db->query("SELECT `domain` FROM " . TABLE_DOMAIN);
foreach($query->rows as $q) {
array_push($domains, $q['domain']);
}
2012-09-06 15:27:20 +02:00
$query = $this->db->query("SELECT `to` FROM " . VIEW_MESSAGES . " WHERE id=?", array($id));
2012-02-08 23:14:28 +01:00
foreach($query->rows as $q) {
$mydomain = 0;
foreach ($domains as $domain) {
if(preg_match("/\@$domain$/", $q['to'])) { $mydomain = 1; break; }
}
if($mydomain == 1) {
array_push($rcpt, $q['to']);
}
2012-02-08 23:14:28 +01:00
}
return $rcpt;
}
public function get_message_addresses_in_my_domain($id = '') {
$addr = array();
$domains = array();
if(Registry::get('auditor_user') == 0) { return $addr; }
$query = $this->db->query("SELECT `domain` FROM " . TABLE_DOMAIN);
foreach($query->rows as $q) {
array_push($domains, $q['domain']);
}
$query = $this->db->query("SELECT `from`, `to` FROM " . VIEW_MESSAGES . " WHERE id=?", array($id));
2013-02-11 20:24:19 +01:00
if(isset($query->row['from'])) {
foreach ($domains as $domain) {
if(preg_match("/\@$domain$/", $query->row['from'])) { array_push($addr, $query->row['from']); }
}
}
foreach($query->rows as $q) {
$mydomain = 0;
foreach ($domains as $domain) {
if(preg_match("/\@$domain$/", $q['to'])) { $mydomain = 1; break; }
}
if($mydomain == 1) {
if(!in_array($q['to'], $addr)) { array_push($addr, $q['to']); }
}
}
return $addr;
}
2012-02-08 23:14:28 +01:00
private function get_all_your_address() {
$s = '';
while(list($k, $v) = each($_SESSION['emails'])) {
if($s) { $s .= '| ' . $this->fix_email_address_for_sphinx($v); }
else { $s = $this->fix_email_address_for_sphinx($v); }
}
return $s;
}
2012-09-06 15:27:20 +02:00
public function check_your_permission_by_id($id = '') {
2012-02-08 23:14:28 +01:00
$q = '';
$arr = $a = array();
if($id == '') { return 0; }
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 0) { return 1; }
2012-02-08 23:14:28 +01:00
array_push($arr, $id);
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 1) {
2013-02-16 13:54:41 +01:00
if(validdomain($_SESSION['domain']) == 1) {
$q .= ",?";
array_push($a, $_SESSION['domain']);
}
2013-01-05 16:42:36 +01:00
while(list($k, $v) = each($_SESSION['auditdomains'])) {
2013-02-16 13:54:41 +01:00
if(validdomain($v) == 1 && !in_array($v, $a)) {
2013-01-05 16:42:36 +01:00
$q .= ",?";
array_push($a, $v);
}
}
}
else {
while(list($k, $v) = each($_SESSION['emails'])) {
if(validemail($v) == 1) {
$q .= ",?";
array_push($a, $v);
}
2012-02-08 23:14:28 +01:00
}
}
2013-01-05 16:42:36 +01:00
$q = preg_replace("/^\,/", "", $q);
2012-02-08 23:14:28 +01:00
$arr = array_merge($arr, $a, $a);
2012-09-06 15:27:20 +02:00
if(ENABLE_FOLDER_RESTRICTIONS == 1) {
$query = $this->sphx->query("SELECT folder FROM " . SPHINX_MAIN_INDEX . " WHERE id=" . (int)$id);
if(isset($query->row['folder']) && in_array($query->row['folder'], $_SESSION['folders'])) { return 1; }
}
else {
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 1) {
$query = $this->db->query("SELECT id FROM " . VIEW_MESSAGES . " WHERE id=? AND ( `fromdomain` IN ($q) OR `todomain` IN ($q) )", $arr);
} else {
$query = $this->db->query("SELECT id FROM " . VIEW_MESSAGES . " WHERE id=? AND ( `from` IN ($q) OR `to` IN ($q) )", $arr);
}
2012-09-06 15:27:20 +02:00
if(isset($query->row['id'])) { return 1; }
}
2012-02-08 23:14:28 +01:00
return 0;
}
2012-03-10 14:52:50 +01:00
public function check_your_permission_by_id_list($id = array()) {
$q = $q2 = '';
2012-09-06 15:27:20 +02:00
$arr = $a = $result = array();
2012-03-10 14:52:50 +01:00
2012-09-06 15:27:20 +02:00
if(count($id) < 1) { return $result; }
2012-03-10 14:52:50 +01:00
$arr = $id;
for($i=0; $i<count($id); $i++) {
$q2 .= ",?";
}
2012-09-06 15:27:20 +02:00
2012-03-10 14:52:50 +01:00
$q2 = preg_replace("/^\,/", "", $q2);
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 1) {
2013-02-16 13:54:41 +01:00
if(validdomain($_SESSION['domain']) == 1) {
$q .= ",?";
array_push($a, $_SESSION['domain']);
}
2013-01-05 16:42:36 +01:00
while(list($k, $v) = each($_SESSION['auditdomains'])) {
2013-02-16 13:54:41 +01:00
if(validdomain($v) == 1 && !in_array($v, $a)) {
2013-01-05 16:42:36 +01:00
$q .= ",?";
array_push($a, $v);
}
}
}
else {
if(Registry::get('auditor_user') == 0) {
while(list($k, $v) = each($_SESSION['emails'])) {
if(validemail($v) == 1) {
$q .= ",?";
array_push($a, $v);
}
}
2012-03-10 14:52:50 +01:00
}
}
2013-01-05 16:42:36 +01:00
$q = preg_replace("/^\,/", "", $q);
2012-03-10 14:52:50 +01:00
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 0) {
2012-09-06 15:27:20 +02:00
$query = $this->db->query("SELECT id FROM `" . TABLE_META . "` WHERE `id` IN ($q2)", $arr);
}
else {
2012-03-10 14:52:50 +01:00
2012-09-06 15:27:20 +02:00
if(ENABLE_FOLDER_RESTRICTIONS == 1) {
$query = $this->sphx->query("SELECT id, folder FROM " . SPHINX_MAIN_INDEX . " WHERE id IN (" . implode(",", $id) . ")");
2012-09-06 15:27:20 +02:00
}
else {
$arr = array_merge($arr, $a, $a);
if(Registry::get('auditor_user') == 1 && RESTRICTED_AUDITOR == 1) {
$query = $this->db->query("SELECT id FROM `" . VIEW_MESSAGES . "` WHERE `id` IN ($q2) AND ( `fromdomain` IN ($q) OR `todomain` IN ($q) )", $arr);
} else {
$query = $this->db->query("SELECT id FROM `" . VIEW_MESSAGES . "` WHERE `id` IN ($q2) AND ( `from` IN ($q) OR `to` IN ($q) )", $arr);
}
2012-09-06 15:27:20 +02:00
}
}
2012-03-10 14:52:50 +01:00
if($query->num_rows > 0) {
foreach ($query->rows as $q) {
2012-09-06 15:27:20 +02:00
if(ENABLE_FOLDER_RESTRICTIONS == 1) {
if(in_array($q['folder'], $_SESSION['folders'])) { array_push($result, $q['id']); }
}
else {
array_push($result, $q['id']);
}
2012-03-10 14:52:50 +01:00
}
}
2012-09-06 15:27:20 +02:00
return $result;
2012-03-10 14:52:50 +01:00
}
2012-02-08 23:14:28 +01:00
private function fix_email_address_for_sphinx($email = '') {
2012-04-27 14:39:10 +02:00
$email = preg_replace("/\|@/", "|", $email);
return preg_replace("/[\@\.\+\-\_]/", "X", $email);
2012-02-08 23:14:28 +01:00
}
public function get_search_terms() {
2013-08-01 22:28:42 +02:00
$query = $this->db->query("SELECT term, ts FROM " . TABLE_SEARCH . " WHERE email=? ORDER BY ts DESC", array($_SESSION['email']));
2012-02-08 23:14:28 +01:00
if(isset($query->rows)) { return $query->rows; }
return array();
}
public function add_search_term($term = '') {
if($term == '') { return 0; }
2013-03-24 10:02:34 +01:00
parse_str($term, $s);
if(!isset($s['search']) || $s['search'] == '') { return 0; }
2012-02-08 23:14:28 +01:00
if($this->update_search_term($term) == 0) {
AUDIT(ACTION_SAVE_SEARCH, '', '', '', $term);
$query = $this->db->query("INSERT INTO " . TABLE_SEARCH . " (email, ts, term) VALUES(?,?,?)", array($_SESSION['email'], time(), $term));
}
return 1;
}
public function update_search_term($term = '') {
if($term == '') { return 0; }
AUDIT(ACTION_SEARCH, '', '', '', $term);
$query = $this->db->query("UPDATE " . TABLE_SEARCH . " SET ts=? WHERE term=? AND email=?", array(time(), $term, $_SESSION['email']));
return $this->db->countAffected();
2013-07-27 13:10:48 +02:00
}
2013-08-01 22:28:42 +02:00
public function remove_search_term($ts = 0) {
$query = $this->db->query("DELETE FROM " . TABLE_SEARCH . " WHERE email=? AND ts=?", array($_SESSION['email'], $ts));
2012-02-08 23:14:28 +01:00
}
private function fixup_meta_characters($s = '') {
if($s == '') { return $s; }
$s = preg_replace("/\'/", ' ', $s);
$s = preg_replace("/\./", ' ', $s);
return $s;
}
2012-02-08 23:14:28 +01:00
private function fixup_sphinx_operators($s = '') {
if($s == '') { return $s; }
$s = preg_replace("/ OR /", "|", $s);
2012-02-10 14:06:00 +01:00
$s = preg_replace("/(\-)/", " ", $s);
2012-09-06 15:27:20 +02:00
$s = preg_replace("/\'/", '"', $s);
2012-02-08 23:14:28 +01:00
$a = explode(" ", $s);
$s = '';
while(list($k, $v) = each($a)) {
if(substr($v, 0, 4) == 'http') {
$v = preg_replace("/http(s){0,1}\:\/\//", "__URL__", $v);
$b = explode("/", $v);
$s .= ' ' . $this->fix_email_address_for_sphinx($b[0]);
}
else {
$s .= ' ' . $v;
}
}
return $s;
}
private function make_cache_file_name($data = array(), $sortorder = '') {
return sha1($_SESSION['email'] . "/" . join("*", $data) . "-" . (NOW - NOW % 3600) . "-" . $sortorder);
}
}
?>