X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=plugins%2Fmanagesieve%2Flib%2Frcube_sieve.php;h=7c4f0aa31a20f8d7e257b6cced9688a59f0aa26e;hb=76507f7c63a660742e76889ad6e3919f3dde3bb0;hp=3bb150e444eb6d6442444261be66efa8b4925d3d;hpb=b68022ca3782d5eb5a1a7ef6f8cf7abe1dc15bd6;p=roundcube.git diff --git a/plugins/managesieve/lib/rcube_sieve.php b/plugins/managesieve/lib/rcube_sieve.php index 3bb150e..7c4f0aa 100644 --- a/plugins/managesieve/lib/rcube_sieve.php +++ b/plugins/managesieve/lib/rcube_sieve.php @@ -1,727 +1,387 @@ - - $Id$ - -*/ - -// Sieve Language Basics: http://www.ietf.org/rfc/rfc5228.txt +/** + * Classes for managesieve operations (using PEAR::Net_Sieve) + * + * Copyright (C) 2008-2011, The Roundcube Dev Team + * Copyright (C) 2011, Kolab Systems AG + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 + * as published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + * + * $Id: rcube_sieve.php 5452 2011-11-18 14:44:48Z alec $ + * + */ + +// Managesieve Protocol: RFC5804 define('SIEVE_ERROR_CONNECTION', 1); define('SIEVE_ERROR_LOGIN', 2); -define('SIEVE_ERROR_NOT_EXISTS', 3); // script not exists -define('SIEVE_ERROR_INSTALL', 4); // script installation -define('SIEVE_ERROR_ACTIVATE', 5); // script activation -define('SIEVE_ERROR_OTHER', 255); // other/unknown error +define('SIEVE_ERROR_NOT_EXISTS', 3); // script not exists +define('SIEVE_ERROR_INSTALL', 4); // script installation +define('SIEVE_ERROR_ACTIVATE', 5); // script activation +define('SIEVE_ERROR_DELETE', 6); // script deletion +define('SIEVE_ERROR_INTERNAL', 7); // internal error +define('SIEVE_ERROR_DEACTIVATE', 8); // script activation +define('SIEVE_ERROR_OTHER', 255); // other/unknown error class rcube_sieve { - var $sieve; // Net_Sieve object - var $error = false; // error flag - var $list = array(); // scripts list - - public $script; // rcube_sieve_script object - private $disabled; // array of disabled extensions - - /** - * Object constructor - * - * @param string Username (to managesieve login) - * @param string Password (to managesieve login) - * @param string Managesieve server hostname/address - * @param string Managesieve server port number - * @param string Enable/disable TLS use - * @param array Disabled extensions - */ - public function __construct($username, $password='', $host='localhost', $port=2000, $usetls=true, $disabled=array()) + private $sieve; // Net_Sieve object + private $error = false; // error flag + private $list = array(); // scripts list + + public $script; // rcube_sieve_script object + public $current; // name of currently loaded script + private $exts; // array of supported extensions + + + /** + * Object constructor + * + * @param string Username (for managesieve login) + * @param string Password (for managesieve login) + * @param string Managesieve server hostname/address + * @param string Managesieve server port number + * @param string Managesieve authentication method + * @param boolean Enable/disable TLS use + * @param array Disabled extensions + * @param boolean Enable/disable debugging + * @param string Proxy authentication identifier + * @param string Proxy authentication password + */ + public function __construct($username, $password='', $host='localhost', $port=2000, + $auth_type=null, $usetls=true, $disabled=array(), $debug=false, + $auth_cid=null, $auth_pw=null) { - $this->sieve = new Net_Sieve(); - -// $this->sieve->setDebug(); - if (PEAR::isError($this->sieve->connect($host, $port, NULL, $usetls))) - return $this->_set_error(SIEVE_ERROR_CONNECTION); + $this->sieve = new Net_Sieve(); + + if ($debug) { + $this->sieve->setDebug(true, array($this, 'debug_handler')); + } + + if (PEAR::isError($this->sieve->connect($host, $port, null, $usetls))) { + return $this->_set_error(SIEVE_ERROR_CONNECTION); + } + + if (!empty($auth_cid)) { + $authz = $username; + $username = $auth_cid; + $password = $auth_pw; + } - if (PEAR::isError($this->sieve->login($username, $password))) - return $this->_set_error(SIEVE_ERROR_LOGIN); + if (PEAR::isError($this->sieve->login($username, $password, + $auth_type ? strtoupper($auth_type) : null, $authz)) + ) { + return $this->_set_error(SIEVE_ERROR_LOGIN); + } + + $this->exts = $this->get_extensions(); + + // disable features by config + if (!empty($disabled)) { + // we're working on lower-cased names + $disabled = array_map('strtolower', (array) $disabled); + foreach ($disabled as $ext) { + if (($idx = array_search($ext, $this->exts)) !== false) { + unset($this->exts[$idx]); + } + } + } + } - $this->disabled = $disabled; - $this->_get_script(); + public function __destruct() { + $this->sieve->disconnect(); } - /** - * Getter for error code - */ - public function error() + /** + * Getter for error code + */ + public function error() { - return $this->error ? $this->error : false; + return $this->error ? $this->error : false; } - - public function save() + + /** + * Saves current script into server + */ + public function save($name = null) { - $script = $this->script->as_text(); + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + if (!$this->script) + return $this->_set_error(SIEVE_ERROR_INTERNAL); - if (!$script) - $script = '/* empty script */'; + if (!$name) + $name = $this->current; - if (PEAR::isError($this->sieve->installScript('roundcube', $script))) - return $this->_set_error(SIEVE_ERROR_INSTALL); + $script = $this->script->as_text(); - if (PEAR::isError($this->sieve->setActive('roundcube'))) - return $this->_set_error(SIEVE_ERROR_ACTIVATE); + if (!$script) + $script = '/* empty script */'; - return true; + if (PEAR::isError($this->sieve->installScript($name, $script))) + return $this->_set_error(SIEVE_ERROR_INSTALL); + + return true; } - public function get_extensions() + /** + * Saves text script into server + */ + public function save_script($name, $content = null) { - if ($this->sieve) { - $ext = $this->sieve->getExtensions(); + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); - if ($this->script) { - $supported = $this->script->get_extensions(); - foreach ($ext as $idx => $ext_name) - if (!in_array($ext_name, $supported)) - unset($ext[$idx]); - } + if (!$content) + $content = '/* empty script */'; - return array_values($ext); - } + if (PEAR::isError($this->sieve->installScript($name, $content))) + return $this->_set_error(SIEVE_ERROR_INSTALL); + + return true; } - private function _get_script() + /** + * Activates specified script + */ + public function activate($name = null) { - if (!$this->sieve) - return false; - - $this->list = $this->sieve->listScripts(); - - if (PEAR::isError($this->list)) - return $this->_set_error(SIEVE_ERROR_OTHER); - - if (in_array('roundcube', $this->list)) - { - $script = $this->sieve->getScript('roundcube'); - - if (PEAR::isError($script)) - return $this->_set_error(SIEVE_ERROR_OTHER); - } - // import scripts from squirrelmail - elseif (in_array('phpscript', $this->list)) - { - $script = $this->sieve->getScript('phpscript'); - - $script = $this->_convert_from_squirrel_rules($script); - - $this->script = new rcube_sieve_script($script); - - $this->save(); - - $script = $this->sieve->getScript('roundcube'); - - if (PEAR::isError($script)) - return $this->_set_error(SIEVE_ERROR_OTHER); - } - else - { - $this->_set_error(SIEVE_ERROR_NOT_EXISTS); - $script = ''; - } + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); - $this->script = new rcube_sieve_script($script, $this->disabled); - } - - private function _convert_from_squirrel_rules($script) - { - $i = 0; - $name = array(); - // tokenize rules - if ($tokens = preg_split('/(#START_SIEVE_RULE.*END_SIEVE_RULE)\n/', $script, -1, PREG_SPLIT_DELIM_CAPTURE)) - foreach($tokens as $token) - { - if (preg_match('/^#START_SIEVE_RULE.*/', $token, $matches)) - { - $name[$i] = "unnamed rule ".($i+1); - $content .= "# rule:[".$name[$i]."]\n"; - } - elseif (isset($name[$i])) - { - $content .= "if ".$token."\n"; - $i++; - } - } - - return $content; - } + if (!$name) + $name = $this->current; + if (PEAR::isError($this->sieve->setActive($name))) + return $this->_set_error(SIEVE_ERROR_ACTIVATE); - private function _set_error($error) - { - $this->error = $error; - return false; - } -} + return true; + } -class rcube_sieve_script -{ - var $content = array(); // script rules array - - private $supported = array( // extensions supported by class - 'fileinto', - 'reject', - 'ereject', - 'vacation', // RFC5230 - // TODO: (most wanted first) body, imapflags, notify, regex - ); - - /** - * Object constructor - * - * @param string Script's text content - * @param array Disabled extensions - */ - public function __construct($script, $disabled) + /** + * De-activates specified script + */ + public function deactivate() { - if (!empty($disabled)) - foreach ($disabled as $ext) - if (($idx = array_search($ext, $this->supported)) !== false) - unset($this->supported[$idx]); + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); - $this->content = $this->_parse_text($script); - } + if (PEAR::isError($this->sieve->setActive(''))) + return $this->_set_error(SIEVE_ERROR_DEACTIVATE); - /** - * Adds script contents as text to the script array (at the end) - * - * @param string Text script contents - */ - public function add_text($script) - { - $content = $this->_parse_text($script); - $result = false; - - // check existsing script rules names - foreach ($this->content as $idx => $elem) - $names[$elem['name']] = $idx; - - foreach ($content as $elem) - if (!isset($names[$elem['name']])) - { - array_push($this->content, $elem); - $result = true; - } - - return $result; + return true; } - /** - * Adds rule to the script (at the end) - * - * @param string Rule name - * @param array Rule content (as array) - */ - public function add_rule($content) + /** + * Removes specified script + */ + public function remove($name = null) { - // TODO: check this->supported - array_push($this->content, $content); - return sizeof($this->content)-1; + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + if (!$name) + $name = $this->current; + + // script must be deactivated first + if ($name == $this->sieve->getActive()) + if (PEAR::isError($this->sieve->setActive(''))) + return $this->_set_error(SIEVE_ERROR_DELETE); + + if (PEAR::isError($this->sieve->removeScript($name))) + return $this->_set_error(SIEVE_ERROR_DELETE); + + if ($name == $this->current) + $this->current = null; + + return true; } - public function delete_rule($index) + /** + * Gets list of supported by server Sieve extensions + */ + public function get_extensions() { - if(isset($this->content[$index])) - { - unset($this->content[$index]); - return true; - } - return false; + if ($this->exts) + return $this->exts; + + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + $ext = $this->sieve->getExtensions(); + // we're working on lower-cased names + $ext = array_map('strtolower', (array) $ext); + + if ($this->script) { + $supported = $this->script->get_extensions(); + foreach ($ext as $idx => $ext_name) + if (!in_array($ext_name, $supported)) + unset($ext[$idx]); + } + + return array_values($ext); } - public function size() + /** + * Gets list of scripts from server + */ + public function get_scripts() { - return sizeof($this->content); + if (!$this->list) { + + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + $list = $this->sieve->listScripts(); + + if (PEAR::isError($list)) + return $this->_set_error(SIEVE_ERROR_OTHER); + + $this->list = $list; + } + + return $this->list; } - public function update_rule($index, $content) + /** + * Returns active script name + */ + public function get_active() { - // TODO: check this->supported - if ($this->content[$index]) - { - $this->content[$index] = $content; - return $index; - } - return false; + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + return $this->sieve->getActive(); } - /** - * Returns script as text - */ - public function as_text() + /** + * Loads script by name + */ + public function load($name) { - $script = ''; - $exts = array(); - - // rules - foreach ($this->content as $idx => $rule) - { - $extension = ''; - $tests = array(); - $i = 0; - - // header - $script .= '# rule:[' . $rule['name'] . "]\n"; - - // constraints expressions - foreach ($rule['tests'] as $test) - { - $tests[$i] = ''; - switch ($test['test']) - { - case 'size': - $tests[$i] .= ($test['not'] ? 'not ' : ''); - $tests[$i] .= 'size :' . ($test['type']=='under' ? 'under ' : 'over ') . $test['arg']; - break; - case 'true': - $tests[$i] .= ($test['not'] ? 'not true' : 'true'); - break; - case 'exists': - $tests[$i] .= ($test['not'] ? 'not ' : ''); - if (is_array($test['arg'])) - $tests[$i] .= 'exists ["' . implode('", "', $this->_escape_string($test['arg'])) . '"]'; - else - $tests[$i] .= 'exists "' . $this->_escape_string($test['arg']) . '"'; - break; - case 'header': - $tests[$i] .= ($test['not'] ? 'not ' : ''); - $tests[$i] .= 'header :' . $test['type']; - if (is_array($test['arg1'])) - $tests[$i] .= ' ["' . implode('", "', $this->_escape_string($test['arg1'])) . '"]'; - else - $tests[$i] .= ' "' . $this->_escape_string($test['arg1']) . '"'; - if (is_array($test['arg2'])) - $tests[$i] .= ' ["' . implode('", "', $this->_escape_string($test['arg2'])) . '"]'; - else - $tests[$i] .= ' "' . $this->_escape_string($test['arg2']) . '"'; - break; - } - $i++; - } - - $script .= ($idx>0 ? 'els' : '').($rule['join'] ? 'if allof (' : 'if anyof ('); - if (sizeof($tests) > 1) - $script .= implode(",\n\t", $tests); - elseif (sizeof($tests)) - $script .= $tests[0]; - else - $script .= 'true'; - $script .= ")\n{\n"; - - // action(s) - foreach ($rule['actions'] as $action) - switch ($action['type']) - { - case 'fileinto': - $extension = 'fileinto'; - $script .= "\tfileinto \"" . $this->_escape_string($action['target']) . "\";\n"; - break; - case 'redirect': - $script .= "\tredirect \"" . $this->_escape_string($action['target']) . "\";\n"; - break; - case 'reject': - case 'ereject': - $extension = $action['type']; - if (strpos($action['target'], "\n")!==false) - $script .= "\t".$action['type']." text:\n" . $action['target'] . "\n.\n;\n"; - else - $script .= "\t".$action['type']." \"" . $this->_escape_string($action['target']) . "\";\n"; - break; - case 'keep': - case 'discard': - case 'stop': - $script .= "\t" . $action['type'] .";\n"; - break; - case 'vacation': - $extension = 'vacation'; - $script .= "\tvacation"; - if ($action['days']) - $script .= " :days " . $action['days']; - if ($action['addresses']) - $script .= " :addresses " . $this->_print_list($action['addresses']); - if ($action['subject']) - $script .= " :subject \"" . $this->_escape_string($action['subject']) . "\""; - if ($action['handle']) - $script .= " :handle \"" . $this->_escape_string($action['handle']) . "\""; - if ($action['from']) - $script .= " :from \"" . $this->_escape_string($action['from']) . "\""; - if ($action['mime']) - $script .= " :mime"; - if (strpos($action['reason'], "\n")!==false) - $script .= " text:\n" . $action['reason'] . "\n.\n;\n"; - else - $script .= " \"" . $this->_escape_string($action['reason']) . "\";\n"; - break; - } - - $script .= "}\n"; - - if ($extension && !isset($exts[$extension])) - $exts[$extension] = $extension; - } - - // requires - if (sizeof($exts)) - $script = 'require ["' . implode('","', $exts) . "\"];\n" . $script; - - return $script; + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + if ($this->current == $name) + return true; + + $script = $this->sieve->getScript($name); + + if (PEAR::isError($script)) + return $this->_set_error(SIEVE_ERROR_OTHER); + + // try to parse from Roundcube format + $this->script = $this->_parse($script); + + $this->current = $name; + + return true; } - /** - * Returns script object - * - */ - public function as_array() + /** + * Loads script from text content + */ + public function load_script($script) { - return $this->content; + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + // try to parse from Roundcube format + $this->script = $this->_parse($script); } - /** - * Returns array of supported extensions - * - */ - public function get_extensions() + /** + * Creates rcube_sieve_script object from text script + */ + private function _parse($txt) { - return array_values($this->supported); + // parse + $script = new rcube_sieve_script($txt, $this->exts); + + // fix/convert to Roundcube format + if (!empty($script->content)) { + // replace all elsif with if+stop, we support only ifs + foreach ($script->content as $idx => $rule) { + if (empty($rule['type']) || !preg_match('/^(if|elsif|else)$/', $rule['type'])) { + continue; + } + + $script->content[$idx]['type'] = 'if'; + + // 'stop' not found? + foreach ($rule['actions'] as $action) { + if (preg_match('/^(stop|vacation)$/', $action['type'])) { + continue 2; + } + } + if (empty($script->content[$idx+1]) || $script->content[$idx+1]['type'] != 'if') { + $script->content[$idx]['actions'][] = array('type' => 'stop'); + } + } + } + + return $script; } - /** - * Converts text script to rules array - * - * @param string Text script - */ - private function _parse_text($script) + /** + * Gets specified script as text + */ + public function get_script($name) { - $i = 0; - $content = array(); - - // remove C comments - $script = preg_replace('|/\*.*?\*/|sm', '', $script); - - // tokenize rules - if ($tokens = preg_split('/(# rule:\[.*\])\r?\n/', $script, -1, PREG_SPLIT_DELIM_CAPTURE)) - foreach($tokens as $token) - { - if (preg_match('/^# rule:\[(.*)\]/', $token, $matches)) - { - $content[$i]['name'] = $matches[1]; - } - elseif (isset($content[$i]['name']) && sizeof($content[$i]) == 1) - { - if ($rule = $this->_tokenize_rule($token)) - { - $content[$i] = array_merge($content[$i], $rule); - $i++; - } - else // unknown rule format - unset($content[$i]); - } - } - - return $content; + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + $content = $this->sieve->getScript($name); + + if (PEAR::isError($content)) + return $this->_set_error(SIEVE_ERROR_OTHER); + + return $content; } - /** - * Convert text script fragment to rule object - * - * @param string Text rule - */ - private function _tokenize_rule($content) - { - $result = NULL; - - if (preg_match('/^(if|elsif|else)\s+((allof|anyof|exists|header|not|size)\s+(.*))\s+\{(.*)\}$/sm', trim($content), $matches)) - { - list($tests, $join) = $this->_parse_tests(trim($matches[2])); - $actions = $this->_parse_actions(trim($matches[5])); - - if ($tests && $actions) - $result = array( - 'tests' => $tests, - 'actions' => $actions, - 'join' => $join, - ); - } - - return $result; - } - - /** - * Parse body of actions section - * - * @param string Text body - * @return array Array of parsed action type/target pairs - */ - private function _parse_actions($content) + /** + * Creates empty script or copy of other script + */ + public function copy($name, $copy) { - $result = NULL; - - // supported actions - $patterns[] = '^\s*discard;'; - $patterns[] = '^\s*keep;'; - $patterns[] = '^\s*stop;'; - $patterns[] = '^\s*redirect\s+(.*?[^\\\]);'; - if (in_array('fileinto', $this->supported)) - $patterns[] = '^\s*fileinto\s+(.*?[^\\\]);'; - if (in_array('reject', $this->supported)) { - $patterns[] = '^\s*reject\s+text:(.*)\n\.\n;'; - $patterns[] = '^\s*reject\s+(.*?[^\\\]);'; - $patterns[] = '^\s*ereject\s+text:(.*)\n\.\n;'; - $patterns[] = '^\s*ereject\s+(.*?[^\\\]);'; - } - if (in_array('vacation', $this->supported)) - $patterns[] = '^\s*vacation\s+(.*?[^\\\]);'; - - $pattern = '/(' . implode('$)|(', $patterns) . '$)/ms'; - - // parse actions body - if (preg_match_all($pattern, $content, $mm, PREG_SET_ORDER)) - { - foreach ($mm as $m) - { - $content = trim($m[0]); - - if(preg_match('/^(discard|keep|stop)/', $content, $matches)) - { - $result[] = array('type' => $matches[1]); - } - elseif(preg_match('/^fileinto/', $content)) - { - $result[] = array('type' => 'fileinto', 'target' => $this->_parse_string($m[sizeof($m)-1])); - } - elseif(preg_match('/^redirect/', $content)) - { - $result[] = array('type' => 'redirect', 'target' => $this->_parse_string($m[sizeof($m)-1])); - } - elseif(preg_match('/^(reject|ereject)\s+(.*);$/sm', $content, $matches)) - { - $result[] = array('type' => $matches[1], 'target' => $this->_parse_string($matches[2])); - } - elseif(preg_match('/^vacation\s+(.*);$/sm', $content, $matches)) - { - $vacation = array('type' => 'vacation'); - - if (preg_match('/:(days)\s+([0-9]+)/', $content, $vm)) { - $vacation['days'] = $vm[2]; - $content = preg_replace('/:(days)\s+([0-9]+)/', '', $content); - } - if (preg_match('/:(subject)\s+(".*?[^\\\]")/', $content, $vm)) { - $vacation['subject'] = $vm[2]; - $content = preg_replace('/:(subject)\s+(".*?[^\\\]")/', '', $content); - } - if (preg_match('/:(addresses)\s+\[(.*?[^\\\])\]/', $content, $vm)) { - $vacation['addresses'] = $this->_parse_list($vm[2]); - $content = preg_replace('/:(addresses)\s+\[(.*?[^\\\])\]/', '', $content); - } - if (preg_match('/:(handle)\s+(".*?[^\\\]")/', $content, $vm)) { - $vacation['handle'] = $vm[2]; - $content = preg_replace('/:(handle)\s+(".*?[^\\\]")/', '', $content); - } - if (preg_match('/:(from)\s+(".*?[^\\\]")/', $content, $vm)) { - $vacation['from'] = $vm[2]; - $content = preg_replace('/:(from)\s+(".*?[^\\\]")/', '', $content); - } - $content = preg_replace('/^vacation/', '', $content); - $content = preg_replace('/;$/', '', $content); - $content = trim($content); - if (preg_match('/^:(mime)/', $content, $vm)) { - $vacation['mime'] = true; - $content = preg_replace('/^:mime/', '', $content); - } - - $vacation['reason'] = $this->_parse_string($content); - - $result[] = $vacation; - } + if (!$this->sieve) + return $this->_set_error(SIEVE_ERROR_INTERNAL); + + if ($copy) { + $content = $this->sieve->getScript($copy); + + if (PEAR::isError($content)) + return $this->_set_error(SIEVE_ERROR_OTHER); } - } - - return $result; - } - - /** - * Parse test/conditions section - * - * @param string Text - */ - - private function _parse_tests($content) - { - $result = NULL; - - // lists - if (preg_match('/^(allof|anyof)\s+\((.*)\)$/sm', $content, $matches)) - { - $content = $matches[2]; - $join = $matches[1]=='allof' ? true : false; - } - else - $join = false; - - // supported tests regular expressions - // TODO: comparators, envelope - $patterns[] = '(not\s+)?(exists)\s+\[(.*?[^\\\])\]'; - $patterns[] = '(not\s+)?(exists)\s+(".*?[^\\\]")'; - $patterns[] = '(not\s+)?(true)'; - $patterns[] = '(not\s+)?(size)\s+:(under|over)\s+([0-9]+[KGM]{0,1})'; - $patterns[] = '(not\s+)?(header)\s+:(contains|is|matches)\s+\[(.*?[^\\\]")\]\s+\[(.*?[^\\\]")\]'; - $patterns[] = '(not\s+)?(header)\s+:(contains|is|matches)\s+(".*?[^\\\]")\s+(".*?[^\\\]")'; - $patterns[] = '(not\s+)?(header)\s+:(contains|is|matches)\s+\[(.*?[^\\\]")\]\s+(".*?[^\\\]")'; - $patterns[] = '(not\s+)?(header)\s+:(contains|is|matches)\s+(".*?[^\\\]")\s+\[(.*?[^\\\]")\]'; - - // join patterns... - $pattern = '/(' . implode(')|(', $patterns) . ')/'; - - // ...and parse tests list - if (preg_match_all($pattern, $content, $matches, PREG_SET_ORDER)) - { - foreach ($matches as $match) - { - $size = sizeof($match); - - if (preg_match('/^(not\s+)?size/', $match[0])) - { - $result[] = array( - 'test' => 'size', - 'not' => $match[$size-4] ? true : false, - 'type' => $match[$size-2], // under/over - 'arg' => $match[$size-1], // value - ); - } - elseif (preg_match('/^(not\s+)?header/', $match[0])) - { - $result[] = array( - 'test' => 'header', - 'not' => $match[$size-5] ? true : false, - 'type' => $match[$size-3], // is/contains/matches - 'arg1' => $this->_parse_list($match[$size-2]), // header(s) - 'arg2' => $this->_parse_list($match[$size-1]), // string(s) - ); - } - elseif (preg_match('/^(not\s+)?exists/', $match[0])) - { - $result[] = array( - 'test' => 'exists', - 'not' => $match[$size-3] ? true : false, - 'arg' => $this->_parse_list($match[$size-1]), // header(s) - ); - } - elseif (preg_match('/^(not\s+)?true/', $match[0])) - { - $result[] = array( - 'test' => 'true', - 'not' => $match[$size-2] ? true : false, - ); - } - } - } - - return array($result, $join); - } - - /** - * Parse string value - * - * @param string Text - */ - private function _parse_string($content) - { - $text = ''; - $content = trim($content); - - if (preg_match('/^text:(.*)\.$/sm', $content, $matches)) - $text = trim($matches[1]); - elseif (preg_match('/^"(.*)"$/', $content, $matches)) - $text = str_replace('\"', '"', $matches[1]); - - return $text; - } - - /** - * Escape special chars in string value - * - * @param string Text - */ - private function _escape_string($content) - { - $replace['/"/'] = '\\"'; - - if (is_array($content)) - { - for ($x=0, $y=sizeof($content); $x<$y; $x++) - $content[$x] = preg_replace(array_keys($replace), array_values($replace), $content[$x]); - - return $content; - } - else - return preg_replace(array_keys($replace), array_values($replace), $content); + + return $this->save_script($name, $content); } - /** - * Parse string or list of strings to string or array of strings - * - * @param string Text - */ - private function _parse_list($content) + private function _set_error($error) { - $result = array(); - - for ($x=0, $len=strlen($content); $x<$len; $x++) - { - switch ($content[$x]) - { - case '\\': - $str .= $content[++$x]; - break; - case '"': - if (isset($str)) - { - $result[] = $str; - unset($str); - } - else - $str = ''; - break; - default: - if(isset($str)) - $str .= $content[$x]; - break; - } - } - - if (sizeof($result)>1) - return $result; - elseif (sizeof($result) == 1) - return $result[0]; - else - return NULL; - } - - /** - * Convert array of elements to list of strings - * - * @param string Text - */ - private function _print_list($list) + $this->error = $error; + return false; + } + + /** + * This is our own debug handler for connection + */ + public function debug_handler(&$sieve, $message) { - $list = (array) $list; - foreach($list as $idx => $val) - $list[$idx] = $this->_escape_string($val); - - return '["' . implode('","', $list) . '"]'; + write_log('sieve', preg_replace('/\r\n$/', '', $message)); } } - -?>