auth->isSuperAdmin()) { $this->has_gui = false; } } protected function setInfo() { $this->description = __('Akismet spam filter'); } public function getStatusMessage($status, $comment_id) { return sprintf(__('Filtered by %s.'), $this->guiLink()); } private function akInit() { $blog = &$this->core->blog; if (!$blog->settings->akismet->ak_key) { return false; } return new akismet($blog->url, $blog->settings->akismet->ak_key); } public function isSpam($type, $author, $email, $site, $ip, $content, $post_id, &$status) { if (($ak = $this->akInit()) === false) { return; } $blog = &$this->core->blog; try { if ($ak->verify()) { $post = $blog->getPosts(['post_id' => $post_id]); $c = $ak->comment_check( $post->getURL(), $type, $author, $email, $site, $content ); if ($c) { $status = 'Filtered by Akismet'; return true; } } } catch (Exception $e) {} # If http or akismet is dead, we don't need to know it } public function trainFilter($status, $filter, $type, $author, $email, $site, $ip, $content, $rs) { # We handle only false positive from akismet if ($status == 'spam' && $filter != 'dcFilterAkismet') { return; } $f = $status == 'spam' ? 'submit_spam' : 'submit_ham'; if (($ak = $this->akInit()) === false) { return; } try { if ($ak->verify()) { $ak->{$f}($rs->getPostURL(), $type, $author, $email, $site, $content); } } catch (Exception $e) {} # If http or akismet is dead, we don't need to know it } public function gui($url) { $blog = &$this->core->blog; $blog->settings->addNamespace('akismet'); $ak_key = $blog->settings->akismet->ak_key; $ak_verified = null; if (isset($_POST['ak_key'])) { try { $ak_key = $_POST['ak_key']; $blog->settings->akismet->put('ak_key', $ak_key, 'string'); dcPage::addSuccessNotice(__('Filter configuration have been successfully saved.')); http::redirect($url); } catch (Exception $e) { $this->core->error->add($e->getMessage()); } } if ($blog->settings->akismet->ak_key) { try { $ak = new akismet($blog->url, $blog->settings->akismet->ak_key); $ak_verified = $ak->verify(); } catch (Exception $e) { $this->core->error->add($e->getMessage()); } } $res = dcPage::notices(); $res .= ''; return $res; } } class akismet extends netHttp { protected $base_host = 'rest.akismet.com'; protected $ak_host = ''; protected $ak_version = '1.1'; protected $ak_path = '/%s/%s'; protected $ak_key = null; protected $blog_url; protected $timeout = 3; public function __construct($blog_url, $api_key) { $this->blog_url = $blog_url; $this->ak_key = $api_key; $this->ak_path = sprintf($this->ak_path, $this->ak_version, '%s'); $this->ak_host = $this->ak_key . '.' . $this->base_host; parent::__construct($this->ak_host, 80); } public function verify() { $this->host = $this->base_host; $path = sprintf($this->ak_path, 'verify-key'); $data = [ 'key' => $this->ak_key, 'blog' => $this->blog_url ]; if ($this->post($path, $data, 'UTF-8')) { return $this->getContent() == 'valid'; } return false; } public function comment_check($permalink, $type, $author, $email, $url, $content) { $info_ignore = ['HTTP_COOKIE']; $info = []; foreach ($_SERVER as $k => $v) { if (strpos($k, 'HTTP_') === 0 && !in_array($k, $info_ignore)) { $info[$k] = $v; } } return $this->callFunc('comment-check', $permalink, $type, $author, $email, $url, $content, $info); } public function submit_spam($permalink, $type, $author, $email, $url, $content) { $this->callFunc('submit-spam', $permalink, $type, $author, $email, $url, $content); return true; } public function submit_ham($permalink, $type, $author, $email, $url, $content) { $this->callFunc('submit-ham', $permalink, $type, $author, $email, $url, $content); return true; } protected function callFunc($function, $permalink, $type, $author, $email, $url, $content, $info = []) { $ua = isset($info['HTTP_USER_AGENT']) ? $info['HTTP_USER_AGENT'] : ''; $referer = isset($info['HTTP_REFERER']) ? $info['HTTP_REFERER'] : ''; # Prepare comment data $data = [ 'blog' => $this->blog_url, 'user_ip' => http::realIP(), 'user_agent' => $ua, 'referrer' => $referer, 'permalink' => $permalink, 'comment_type' => $type, 'comment_author' => $author, 'comment_author_email' => $email, 'comment_author_url' => $url, 'comment_content' => $content ]; $data = array_merge($data, $info); $this->host = $this->ak_host; $path = sprintf($this->ak_path, $function); if (!$this->post($path, $data, 'UTF-8')) { throw new Exception('HTTP error: ' . $this->getError()); } return $this->getContent() == 'true'; } }