gui refactoring, using the zend mail library 1.2.x

Change-Id: Ie019ae0c241263e3acfeb09ea6779d90487fde8e
Signed-off-by: SJ <sj@acts.hu>
This commit is contained in:
SJ 2016-09-17 15:30:47 +02:00
parent 91fbeebc0f
commit ee2f507074
6 changed files with 101 additions and 447 deletions

View File

@ -58,8 +58,6 @@ class ControllerMessageBulkrestore extends Controller {
} }
$this->model_search_message->connect_to_pilergetd();
foreach($idlist as $id) { foreach($idlist as $id) {
AUDIT(ACTION_RESTORE_MESSAGE, '', '', $id, ''); AUDIT(ACTION_RESTORE_MESSAGE, '', '', $id, '');
@ -110,8 +108,6 @@ class ControllerMessageBulkrestore extends Controller {
} }
} }
$this->model_search_message->disconnect_from_pilergetd();
if(RESTORE_OVER_IMAP == 1) { $this->model_mail_mail->disconnect_imap(); } if(RESTORE_OVER_IMAP == 1) { $this->model_mail_mail->disconnect_imap(); }

View File

@ -49,9 +49,7 @@ class ControllerMessageDownload extends Controller {
header("Content-Disposition: attachment; filename=" . $filename . ".eml"); header("Content-Disposition: attachment; filename=" . $filename . ".eml");
header("Content-Transfer-Encoding: binary\n"); header("Content-Transfer-Encoding: binary\n");
$this->model_search_message->connect_to_pilergetd();
$msg = $this->model_search_message->get_raw_message($this->data['piler_id']); $msg = $this->model_search_message->get_raw_message($this->data['piler_id']);
$this->model_search_message->disconnect_from_pilergetd();
$this->model_search_message->remove_journal($msg); $this->model_search_message->remove_journal($msg);
print $msg; print $msg;

View File

@ -70,9 +70,7 @@ class ControllerMessageRestore extends Controller {
$this->data['piler_id'] = $this->model_search_message->get_piler_id_by_id($this->data['id']); $this->data['piler_id'] = $this->model_search_message->get_piler_id_by_id($this->data['id']);
$this->model_search_message->connect_to_pilergetd();
$msg = $this->model_search_message->get_raw_message($this->data['piler_id']); $msg = $this->model_search_message->get_raw_message($this->data['piler_id']);
$this->model_search_message->disconnect_from_pilergetd();
$this->model_search_message->remove_journal($msg); $this->model_search_message->remove_journal($msg);

View File

@ -14,8 +14,6 @@ class ModelMessageRestore extends Model {
if($zip->open($zipname, ZIPARCHIVE::CREATE) != true) { exit("cannot open <$zipname>\n"); } if($zip->open($zipname, ZIPARCHIVE::CREATE) != true) { exit("cannot open <$zipname>\n"); }
$this->model_search_message->connect_to_pilergetd();
foreach($idlist as $id) { foreach($idlist as $id) {
$i++; $i++;
@ -35,8 +33,6 @@ class ModelMessageRestore extends Model {
AUDIT(ACTION_DOWNLOAD_MESSAGE, '', '', $id, ''); AUDIT(ACTION_DOWNLOAD_MESSAGE, '', '', $id, '');
} }
$this->model_search_message->disconnect_from_pilergetd();
$zip->close(); $zip->close();

View File

@ -10,6 +10,25 @@ class ModelSearchMessage extends Model {
); );
public function get_boundary($line='') {
$parts = explode(";", $line);
for($i=0; $i<count($parts); $i++) {
if(stristr($parts[$i], "boundary")) {
$parts[$i] = preg_replace("/boundary\s{0,}=\s{0,}/i", "boundary=", $parts[$i]);
$parts[$i] = preg_replace("/\"\;{0,1}/", "", $parts[$i]);
$parts[$i] = preg_replace("/\'/", "", $parts[$i]);
$b = explode("boundary=", $parts[$i]);
return rtrim($b[count($b)-1]);
}
}
return "";
}
public function verify_message($piler_id = '', $data = '') { public function verify_message($piler_id = '', $data = '') {
if($piler_id == '') { return 0; } if($piler_id == '') { return 0; }
@ -37,99 +56,11 @@ class ModelSearchMessage extends Model {
} }
public function get_file_size($sd, $id = '') {
fputs($sd, "STAT $id\r\n");
$s = fgets($sd, 8192);
$a = explode(" ", $s);
if(isset($a[2]) && $a[2] > 0) { return $a[2]; }
return 0;
}
public function read_file($sd, $f = '', $size = 0) {
global $start;
$s = '';
$len = 0;
if($size <= 0) { return $s; }
fputs($sd, "RETR $f\r\n");
while(!safe_feof($sd, $start) && (microtime(true) - $start) < PILERGETD_TIMEOUT) {
$s .= fread($sd, PILERGETD_READ_LENGTH);
$len += PILERGETD_READ_LENGTH;
if($len >= $size) break;
}
return $s;
}
public function connect_to_pilergetd() {
if(PILERGETD_HOST) {
$sd = fsockopen(PILERGETD_HOST, PILERGETD_PORT);
if(!$sd) { return FALSE; }
$l = fgets($sd, 4096);
if(substr(PILERGETD_HOST, 0, 6) == 'ssl://') {
fputs($sd, "AUTH " . PILERGETD_PASSWORD . "\r\n");
$l = fgets($sd, 4096);
}
Registry::set('sd', $sd);
}
}
public function disconnect_from_pilergetd() {
if(PILERGETD_HOST) {
$sd = Registry::get('sd');
fputs($sd, "QUIT\r\n");
fclose($sd);
}
}
public function get_raw_message($id = '') { public function get_raw_message($id = '') {
$s = ''; $s = '';
if($id == '' || !preg_match("/^([0-9a-f]+)$/", $id)) { return $s; } if($id == '' || !preg_match("/^([0-9a-f]+)$/", $id)) { return $s; }
if(PILERGETD_HOST) {
$sd = Registry::get('sd');
fputs($sd, "MESSAGE $id\r\n");
$l = fgets($sd, 8192);
$message = explode(" ", rtrim($l));
while(list($k, $v) = each($message)) {
if($k == 0) {
$size = $this->get_file_size($sd, $v);
$s = $this->read_file($sd, $v, $size);
$s = gzuncompress($s);
}
else {
$size = $this->get_file_size($sd, $v);
$a = $this->read_file($sd, $v, $size);
$a = gzuncompress($a);
$repl = "ATTACHMENT_POINTER_" . $id . ".a" . $k . "_XXX_PILER";
$s = preg_replace("/$repl/", $a, $s);
$a = '';
}
}
}
else {
$handle = popen(DECRYPT_BINARY . " $id", "r"); $handle = popen(DECRYPT_BINARY . " $id", "r");
while(($buf = fread($handle, DECRYPT_BUFFER_LENGTH))) { while(($buf = fread($handle, DECRYPT_BUFFER_LENGTH))) {
$s .= $buf; $s .= $buf;
@ -143,8 +74,6 @@ class ModelSearchMessage extends Model {
} }
pclose($handle); pclose($handle);
} }
}
if(Registry::get('auditor_user') == 0 && HEADER_LINE_TO_HIDE) { if(Registry::get('auditor_user') == 0 && HEADER_LINE_TO_HIDE) {
$s = preg_replace("/" . HEADER_LINE_TO_HIDE . ".{1,}(\n(\ |\t){1,}.{1,}){0,}" . "\n/i", "", $s); $s = preg_replace("/" . HEADER_LINE_TO_HIDE . ".{1,}(\n(\ |\t){1,}.{1,}){0,}" . "\n/i", "", $s);
@ -159,26 +88,11 @@ class ModelSearchMessage extends Model {
if($piler_id == '' || $attachment_id == '' || !preg_match("/^([0-9a-f]+)$/", $piler_id) || !preg_match("/^([0-9m]+)$/", $attachment_id)) { return $data; } if($piler_id == '' || $attachment_id == '' || !preg_match("/^([0-9a-f]+)$/", $piler_id) || !preg_match("/^([0-9m]+)$/", $attachment_id)) { return $data; }
if(PILERGETD_HOST) {
$sd = fsockopen(PILERGETD_HOST, PILERGETD_PORT);
if(!$sd) { return $data; }
$l = fgets($sd, 4096);
$size = $this->get_file_size($sd, $piler_id . ".a" . $attachment_id);
$data = $this->read_file($sd, $piler_id . ".a" . $attachment_id, $size);
$data = gzuncompress($data);
fclose($sd);
}
else {
$handle = popen(DECRYPT_ATTACHMENT_BINARY . " $piler_id $attachment_id", "r"); $handle = popen(DECRYPT_ATTACHMENT_BINARY . " $piler_id $attachment_id", "r");
while(($buf = fread($handle, DECRYPT_BUFFER_LENGTH))){ while(($buf = fread($handle, DECRYPT_BUFFER_LENGTH))){
$data .= $buf; $data .= $buf;
} }
pclose($handle); pclose($handle);
}
/* check if it's a base64 encoded stuff */ /* check if it's a base64 encoded stuff */
@ -196,9 +110,7 @@ class ModelSearchMessage extends Model {
public function get_message_headers($id = '') { public function get_message_headers($id = '') {
$headers = ''; $headers = '';
$this->connect_to_pilergetd();
$msg = $this->get_raw_message($id); $msg = $this->get_raw_message($id);
$this->disconnect_from_pilergetd();
Zend_Mime_Decode::splitMessageRaw($msg, $headers, $body); Zend_Mime_Decode::splitMessageRaw($msg, $headers, $body);
@ -208,8 +120,7 @@ class ModelSearchMessage extends Model {
$headers = preg_replace("/" . HEADER_LINE_TO_HIDE . ".{1,}(\n(\ |\t){1,}.{1,}){0,}" . "\n/i", "", $headers); $headers = preg_replace("/" . HEADER_LINE_TO_HIDE . ".{1,}(\n(\ |\t){1,}.{1,}){0,}" . "\n/i", "", $headers);
} }
$headers = preg_replace("/\</", "&lt;", $headers); $headers = $this->escape_lt_gt_symbols($headers);
$headers = preg_replace("/\>/", "&gt;", $headers);
return array('headers' => $headers, 'has_journal' => $has_journal); return array('headers' => $headers, 'has_journal' => $has_journal);
} }
@ -219,9 +130,7 @@ class ModelSearchMessage extends Model {
$data = '&lt; &gt;'; $data = '&lt; &gt;';
$boundary = ''; $boundary = '';
$this->connect_to_pilergetd();
$msg = $this->get_raw_message($id); $msg = $this->get_raw_message($id);
$this->disconnect_from_pilergetd();
$hdr = substr($msg, 0, 8192); $hdr = substr($msg, 0, 8192);
@ -255,9 +164,7 @@ class ModelSearchMessage extends Model {
$p = ''; $p = '';
$data = preg_replace("/\</", "&lt;", $data); $data = $this->escape_lt_gt_symbols($data);
$data = preg_replace("/\>/", "&gt;", $data);
} }
return $data; return $data;
@ -305,184 +212,112 @@ class ModelSearchMessage extends Model {
public function extract_message($id = '', $terms = '') { public function extract_message($id = '', $terms = '') {
$header = "";
$body_chunk = "";
$is_header = 1;
$state = "UNDEF";
$b = array();
$boundary = array();
$text_plain = 1;
$text_html = 0;
$charset = "";
$qp = $base64 = 0;
$has_text_plain = 0;
$rfc822 = 0;
$_1st_header = 1;
$verification = 1;
$from = $to = $subject = $date = $text_message = $html_message = "";
$this->connect_to_pilergetd();
$msg = $this->get_raw_message($id); $msg = $this->get_raw_message($id);
if(ENABLE_ON_THE_FLY_VERIFICATION == 0) { if(ENABLE_ON_THE_FLY_VERIFICATION == 0) {
$verification = $this->verify_message($id, $msg); $verification = $this->verify_message($id, $msg);
} }
$this->disconnect_from_pilergetd();
$has_journal = $this->remove_journal($msg); $has_journal = $this->remove_journal($msg);
$a = explode("\n", $msg); $msg = ""; Zend_Mime_Decode::splitMessage($msg, $headers, $body);
$boundary = $this->get_boundary($headers['content-type']);
while(list($k, $l) = each($a)){ if(is_array($headers['date'])) { $headers['date'] = $headers['date'][0]; }
$l .= "\n";
if(($l[0] == "\r" && $l[1] == "\n" && $is_header == 1) || ($l[0] == "\n" && $is_header == 1) ){ $from = "From: " . $this->escape_lt_gt_symbols($headers['from']);
$is_header = $_1st_header = 0; $to = "To: " . $this->escape_lt_gt_symbols($headers['to']);
$subject = "Subject: " . $headers['subject'];
$date = "Date: " . $headers['date'];
if($rfc822 == 1) { $rfc822 = 0; $is_header = 1; } $message = array(
'text' => '',
'html' => ''
);
$mime_parts = Zend_Mime_Decode::splitMessageStruct($body, $boundary);
for($i=0; $i<count($mime_parts); $i++) {
$mime = array(
'content-type' => '',
'encoding' => ''
);
if(isset($mime_parts[$i]['header']['content-type']))
$mime['content-type'] = Zend_Mime_Decode::splitContentType($mime_parts[$i]['header']['content-type']);
if(isset($mime_parts[$i]['header']['content-transfer-encoding']))
$mime['encoding'] = $mime_parts[$i]['header']['content-transfer-encoding'];
if($mime['encoding'] == 'quoted-printable')
$mime_parts[$i]['body'] = Zend_Mime_Decode::decodeQuotedPrintable($mime_parts[$i]['body']);
if($mime['encoding'] == 'base64')
$mime_parts[$i]['body'] = base64_decode($mime_parts[$i]['body']);
if(strtolower($mime['content-type']['charset']) != 'utf-8')
$mime_parts[$i]['body'] = iconv($mime['content-type']['charset'], 'utf-8' . '//IGNORE', $mime_parts[$i]['body']);
// some text/plain fixes
if(strtolower($mime['content-type']['type']) == 'text/plain') {
$mime_parts[$i]['body'] = $this->escape_lt_gt_symbols($mime_parts[$i]['body']);
$mime_parts[$i]['body'] = preg_replace("/\n/", "<br />\n", $mime_parts[$i]['body']);
$mime_parts[$i]['body'] = "\n" . $this->print_nicely($mime_parts[$i]['body']);
$message['text'] .= $mime_parts[$i]['body'];
} }
if($is_header == 1 && preg_match("/^Content-Type:/i", $l)) $state = "CONTENT_TYPE"; if(strtolower($mime['content-type']['type']) == 'text/html') {
if($is_header == 1 && preg_match("/^Content-Transfer-Encoding:/i", $l)) $state = "CONTENT_TRANSFER_ENCODING";
if($state == "CONTENT_TYPE"){ $mime_parts[$i]['body'] = preg_replace("/\<style([\w\W]+)style\>/", "", $mime_parts[$i]['body']);
$x = stristr($l, "boundary"); if(ENABLE_REMOTE_IMAGES == 0) {
if($x){ $mime_parts[$i]['body'] = preg_replace("/style([\s]{0,}=[\s]{0,})\"([^\"]+)/", "style=\"xxxx", $mime_parts[$i]['body']);
$mime_parts[$i]['body'] = preg_replace("/style([\s]{0,}=[\s]{0,})\'([^\']+)/", "style='xxxx", $mime_parts[$i]['body']);
$s1 = explode(";", $x);
$x = $s1[0];
$x = preg_replace("/boundary\s{0,}=\s{0,}/i", "boundary=", $x);
//$x = preg_replace("/boundary= /i", "boundary=", $x);
$x = preg_replace("/\"\;{0,1}/", "", $x);
$x = preg_replace("/\'/", "", $x);
$b = explode("boundary=", $x);
$__boundary = rtrim($b[count($b)-1]);
if($__boundary) { array_push($boundary, $__boundary); }
$mime_parts[$i]['body'] = preg_replace("/\<img([^\>]+)\>/i", "<img src=\"" . REMOTE_IMAGE_REPLACEMENT . "\" />", $mime_parts[$i]['body']);
} }
if(preg_match("/charset/i", $l)){ $mime_parts[$i]['body'] = preg_replace("/\<body ([\w\s\;\"\'\#\d\:\-\=]+)\>/i", "<body>", $mime_parts[$i]['body']);
$types = explode(";", $l);
foreach ($types as $type){
if(preg_match("/charset/i", $type)){
$type = preg_replace("/[\"\'\ ]/", "", $type);
$x = explode("=", $type); $mime_parts[$i]['body'] = preg_replace("/\<a\s{1,}href/i", "<qqqq", $mime_parts[$i]['body']);
$charset = rtrim(strtoupper($x[1])); $mime_parts[$i]['body'] = preg_replace("/\<base href/i", "<qqqq", $mime_parts[$i]['body']);
if(isset($this->encoding_aliases[$charset])) { $charset = $this->encoding_aliases[$charset]; } $mime_parts[$i]['body'] = preg_replace("/document\.write/", "document.writeee", $mime_parts[$i]['body']);
$mime_parts[$i]['body'] = preg_replace("/<\s{0,}script([\w\W]+)\/script\s{0,}\>/i", "<!-- disabled javascript here -->", $mime_parts[$i]['body']);
}
}
}
if(strstr($l, "message/rfc822")) { $rfc822 = 1; }
if(stristr($l, "text/plain")){ $text_plain = 1; $text_html = 0; $has_text_plain = 1; }
if(stristr($l, "text/html")){ $text_html = 1; $text_plain = 0; }
}
if($state == "CONTENT_TRANSFER_ENCODING"){
if(preg_match("/quoted-printable/i", $l)){ $qp = 1; }
if(preg_match("/base64/i", $l)){ $base64 = 1; }
}
if($is_header == 1){ $message['html'] .= $mime_parts[$i]['body'];
if($l[0] != " " && $l[0] != "\t"){ $state = "UNDEF"; }
if(preg_match("/^From:/i", $l)){ $state = "FROM"; }
if(preg_match("/^To:/i", $l) || preg_match("/^Cc:/i", $l)){ $state = "TO"; }
if(preg_match("/^Date:/i", $l)){ $state = "DATE"; }
if(preg_match("/^Subject:/i", $l)){ $state = "SUBJECT"; }
if(preg_match("/^Content-Type:/i", $l)){ $state = "CONTENT_TYPE"; }
if(preg_match("/^Content-Disposition:/i", $l)){ $state = "CONTENT_DISPOSITION"; }
$l = preg_replace("/</", "&lt;", $l);
$l = preg_replace("/>/", "&gt;", $l);
if($_1st_header == 1) {
if($state == "FROM"){ $from .= preg_replace("/\r|\n/", "", $l); }
if($state == "TO"){ $to .= preg_replace("/\r|\n/", "", $l); }
if($state == "SUBJECT"){ $subject .= preg_replace("/\r|\n/", "", $l); }
if($state == "DATE"){ $date .= preg_replace("/\r|\n/", "", $l); }
}
}
else {
if($this->check_boundary($boundary, $l) == 1){
if($text_plain == 1 || $has_text_plain == 0) {
$text_message .= $this->flush_body_chunk($body_chunk, $charset, $qp, $base64, $text_plain, $text_html);
}
if($text_html == 1) {
$html_message .= $this->flush_body_chunk($body_chunk, $charset, $qp, $base64, $text_plain, $text_html);
}
$text_plain = $text_html = $qp = $base64 = 0;
$charset = $body_chunk = "";
$is_header = 1;
continue;
}
else if(($l[0] == "\r" && $l[1] == "\n") || $l[0] == "\n"){
$state = "BODY";
$body_chunk .= $l;
}
else if($state == "BODY"){
if($text_plain == 1 || $text_html == 1){ $body_chunk .= $l; }
} }
} }
return array('from' => $from,
} 'to' => $to,
'subject' => $this->highlight_search_terms($subject, $terms),
if($body_chunk) { 'date' => $date,
if($text_plain == 1 || $has_text_plain == 0) { 'message' => $message['html'] ? $message['html'] : $message['text'],
$text_message .= $this->flush_body_chunk($body_chunk, $charset, $qp, $base64, $text_plain, $text_html);
}
if($text_html == 1) {
$html_message .= $this->flush_body_chunk($body_chunk, $charset, $qp, $base64, $text_plain, $text_html);
}
}
if(strlen($html_message) > 20) {
$message = $this->highlight_search_terms($html_message, $terms, 1);
} else {
$message = $this->highlight_search_terms($text_message, $terms);
}
return array('from' => $this->decode_my_str($from),
'to' => $this->decode_my_str($to),
'subject' => $this->highlight_search_terms($this->decode_my_str($subject), $terms),
'date' => $this->decode_my_str($date),
'message' => $message,
'has_journal' => $has_journal, 'has_journal' => $has_journal,
'verification' => $verification 'verification' => $verification
); );
} }
private function escape_lt_gt_symbols($s = '') {
$s = preg_replace("/</", "&lt;", $s);
$s = preg_replace("/>/", "&gt;", $s);
return $s;
}
private function highlight_search_terms($s = '', $terms = '', $html = 0) { private function highlight_search_terms($s = '', $terms = '', $html = 0) {
$fields = array("from:", "to:", "subject:", "body:"); $fields = array("from:", "to:", "subject:", "body:");
$terms = preg_replace("/[^\w\s]/", "", $terms); $terms = preg_replace("/(\,|\s){1,}/", " ", $terms);
$a = explode(" ", $terms); $a = explode(" ", $terms);
$terms = array(); $terms = array();
@ -496,7 +331,6 @@ class ModelSearchMessage extends Model {
if(count($terms) <= 0) { return $s; } if(count($terms) <= 0) { return $s; }
if($html == 0) { if($html == 0) {
while(list($k, $v) = each($terms)) { while(list($k, $v) = each($terms)) {
$s = preg_replace("/$v/i", "<span class=\"message_highlight\">$v</span>", $s); $s = preg_replace("/$v/i", "<span class=\"message_highlight\">$v</span>", $s);
@ -505,7 +339,6 @@ class ModelSearchMessage extends Model {
return $s; return $s;
} }
$tokens = preg_split("/\</", $s); $tokens = preg_split("/\</", $s);
$s = ''; $s = '';
@ -535,77 +368,6 @@ class ModelSearchMessage extends Model {
} }
private function check_boundary($boundary, $line) {
for($i=0; $i<count($boundary); $i++){
if(strstr($line, $boundary[$i])){
return 1;
}
}
return 0;
}
private function flush_body_chunk($chunk, $charset, $qp, $base64, $text_plain, $text_html) {
if($qp == 1){
$chunk = $this->qp_decode($chunk);
}
if($base64 == 1){
$chunk = base64_decode($chunk);
}
if($charset && !preg_match("/utf-8/i", $charset)){
$s = @iconv($charset, 'utf-8' . '//IGNORE', $chunk);
if($s) { $chunk = $s; $s = ''; }
}
if($text_plain == 1){
$chunk = preg_replace("/</", "&lt;", $chunk);
$chunk = preg_replace("/>/", "&gt;", $chunk);
$chunk = preg_replace("/\n/", "<br />\n", $chunk);
$chunk = "\n" . $this->print_nicely($chunk);
}
if($text_html == 1){
$h = preg_split("/\<style/i", $chunk);
$chunk = '';
for($i=0; $i<count($h); $i++) {
$pos = stripos($h[$i], "</style>");
if($pos != FALSE) {
$s = substr($h[$i], $pos+8, strlen($h[$i]));
$chunk .= $s . "\n";
}
else { $chunk .= $h[$i] . "\n"; }
}
if(ENABLE_REMOTE_IMAGES == 0) {
$chunk = preg_replace("/style([\s]{0,}=[\s]{0,})\"([^\"]+)/", "style=\"xxxx", $chunk);
$chunk = preg_replace("/style([\s]{0,}=[\s]{0,})\'([^\']+)/", "style='xxxx", $chunk);
}
$chunk = preg_replace("/\<body ([\w\s\;\"\'\#\d\:\-\=]+)\>/i", "<body>", $chunk);
if(ENABLE_REMOTE_IMAGES == 0) { $chunk = preg_replace("/\<img([^\>]+)\>/i", "<img src=\"" . REMOTE_IMAGE_REPLACEMENT . "\" />", $chunk); }
$chunk = preg_replace("/\<base href/i", "<qqqq", $chunk);
/* prevent scripts in the HTML part */
$chunk = preg_replace("/document\.write/", "document.writeee", $chunk);
$chunk = preg_replace("/<\s{0,}script([\w\W]+)\/script\s{0,}\>/i", "<!-- disabled javascript here -->", $chunk);
}
return $chunk;
}
private function print_nicely($chunk) { private function print_nicely($chunk) {
$k = 0; $k = 0;
$nice_chunk = ""; $nice_chunk = "";
@ -613,7 +375,7 @@ class ModelSearchMessage extends Model {
$x = explode(" ", $chunk); $x = explode(" ", $chunk);
for($i=0; $i<count($x); $i++){ for($i=0; $i<count($x); $i++){
$nice_chunk .= "$x[$i] "; $nice_chunk .= $x[$i] . " ";
$k += strlen($x[$i]); $k += strlen($x[$i]);
if(strstr($x[$i], "\n")){ $k = 0; } if(strstr($x[$i], "\n")){ $k = 0; }
@ -633,98 +395,6 @@ class ModelSearchMessage extends Model {
} }
private function qp_decode($l) {
$res = "";
$c = "";
if($l == ""){ return ""; }
/* remove soft breaks at the end of lines */
if(preg_match("/\=\r\n/", $l)){ $l = preg_replace("/\=\r\n/", "", $l); }
if(preg_match("/\=\n/", $l)){ $l = preg_replace("/\=\n/", "", $l); }
for($i=0; $i<strlen($l); $i++){
$c = $l[$i];
if($c == '=' && ctype_xdigit($l[$i+1]) && ctype_xdigit($l[$i+2])){
$a = $l[$i+1];
$b = $l[$i+2];
$c = chr(16*hexdec($a) + hexdec($b));
$i += 2;
}
$res .= $c;
}
return $res;
}
public function decode_my_str($what = '') {
$result = "";
$what = rtrim($what);
$a = preg_split("/\s/", $what);
while(list($k, $v) = each($a)){
$x = preg_match("/\?\=$/", $v);
if( ($x == 0 && $k > 0) || ($x == 1 && $k == 1) ){
$result .= " ";
}
$result .= $this->fix_encoded_string($v);
}
return $result;
}
private function fix_encoded_string($what = '') {
$s = "";
$what = rtrim($what, "\"\r\n");
$what = ltrim($what, "\"");
if(preg_match("/^\=\?/", $what) && preg_match("/\?\=$/", $what)){
$what = preg_replace("/^\=\?/", "", $what);
$what = preg_replace("/\?\=$/", "", $what);
$encoding = strtoupper(substr($what, 0, strpos($what, '?')));
if(isset($this->encoding_aliases[$encoding])) { $encoding = $this->encoding_aliases[$encoding]; }
if(preg_match("/\?Q\?/i", $what)){
$x = preg_replace("/^([\w\-]+)\?Q\?/i", "", $what);
$s = quoted_printable_decode($x);
$s = preg_replace("/_/", " ", $s);
}
if(preg_match("/\?B\?/i", $what)){
$x = preg_replace("/^([\w\-]+)\?B\?/i", "", $what);
$s = base64_decode($x);
$s = preg_replace('/\0/', "*", $s);
}
if(!preg_match("/utf-8/i", $encoding)){
$s = iconv($encoding, 'utf-8' . '//IGNORE', $s);
}
}
else {
$s = utf8_encode($what);
}
return $s;
}
public function get_piler_id_by_id($id = 0) { public function get_piler_id_by_id($id = 0) {
$query = $this->db->query("SELECT `piler_id` FROM `" . TABLE_META . "` WHERE id=?", array($id)); $query = $this->db->query("SELECT `piler_id` FROM `" . TABLE_META . "` WHERE id=?", array($id));
if(isset($query->row['piler_id'])) { return $query->row['piler_id']; } if(isset($query->row['piler_id'])) { return $query->row['piler_id']; }

View File

@ -539,8 +539,6 @@ class ModelSearchSearch extends Model {
$lang = Registry::get('language'); $lang = Registry::get('language');
$this->model_search_message->connect_to_pilergetd();
foreach($query->rows as $m) { foreach($query->rows as $m) {
if(ENABLE_DELETE == 1 && $m['retained'] < NOW) $m['deleted'] = 1; else $m['deleted'] = 0; if(ENABLE_DELETE == 1 && $m['retained'] < NOW) $m['deleted'] = 1; else $m['deleted'] = 0;
@ -583,8 +581,6 @@ class ModelSearchSearch extends Model {
array_push($messages, $m); array_push($messages, $m);
} }
$this->model_search_message->disconnect_from_pilergetd();
} }
// TODO: add caching if necessary // TODO: add caching if necessary