name = __('Duplicate'); $this->description = __('Same comments on others blogs of a multiblog'); } public function isSpam($type, $author, $email, $site, $ip, $content, $post_id, &$status) { if ($type != 'comment') { return null; } if (strlen($content) < abs((integer) $this->core->blog->settings->dcFilterDuplicate->dcfilterduplicate_minlen)) { return null; } try { if ($this->isDuplicate($content, $ip)) { $this->markDuplicate($content, $ip); $status = 'Duplicate on other blog'; return true; } else { return null; } } catch (Exception $e) { throw new Exception($e->getMessage()); } } public function isDuplicate($content, $ip) { $rs = $this->core->con->select( 'SELECT C.comment_id '. 'FROM ' . $this->core->prefix . 'comment C ' . 'LEFT JOIN ' . $this->core->prefix . 'post P ON C.post_id=P.post_id ' . "WHERE P.blog_id != '" . $this->core->blog->id . "' " . "AND C.comment_content='" . $this->core->con->escape($content) . "' " . "AND C.comment_ip='" . $ip . "' " ); return !$rs->isEmpty(); } public function markDuplicate($content, $ip) { $cur = $this->core->con->openCursor($this->core->prefix . 'comment'); $this->core->con->writeLock($this->core->prefix . 'comment'); $cur->comment_status = -2; $cur->comment_spam_status = 'Duplicate on other blog'; $cur->comment_spam_filter = 'dcFilterDuplicate'; $cur->update( "WHERE comment_content='" . $this->core->con->escape($content) . "' " . "AND comment_ip='" . $ip . "' " ); $this->core->con->unlock(); $this->triggerOtherBlogs($content, $ip); } public function gui($url) { if (isset($_POST['dcfilterduplicate_minlen'])) { $this->core->blog->settings->dcFilterDuplicate->put( 'dcfilterduplicate_minlen', abs((integer) $_POST['dcfilterduplicate_minlen']), 'integer' ); dcPage::addSuccessNotice(__('Configuration successfully updated.')); http::redirect($url); } return '
'; } public function triggerOtherBlogs($content, $ip) { $rs = $this->core->con->select( 'SELECT P.blog_id ' . 'FROM ' . $this->core->prefix . 'comment C ' . 'LEFT JOIN ' . $this->core->prefix . 'post P ON C.post_id=P.post_id ' . "WHERE C.comment_content='" . $this->core->con->escape($content) . "' " . "AND C.comment_ip='" . $ip . "' " ); while ($rs->fetch()) { $b = new dcBlog($this, $rs->blog_id); $b->triggerBlog(); unset($b); } } }