akismet.class.php

Go to the documentation of this file.

<?php
class helper_akismet extends object {

        public function isSpam(array $vars = array()) {
                foreach ($vars as $k=>$v)
                        $this->setCommentVar($k, $v);

                $response = $this->sendRequest(
                                $this->cfg->apiKey.'.'.$this->cfg->apiServer,
                                '/'.$this->cfg->apiVersion.'/comment-check',
                                $this->getQueryString());

                if ($response[1] == 'invalid' && !$this->verifyKey())
                        throw new nException('The API key passed to the Akismet helper is invalid. Please obtain a valid one from https://akismet.com/signup/');

                return ($response[1] == 'true');
        }

        public function submitSpam(array $vars = array()) {
                foreach ($vars as $k=>$v)
                        $this->setCommentVar($k, $v);

                $this->sendRequest(
                                $this->cfg->apiKey.'.'.$this->cfg->apiServer,
                                '/'.$this->cfg->apiVersion.'/submit-spam',
                                $this->getQueryString());
        }

        public function submitHam(array $vars = array()) {
                foreach($vars as $k=>$v)
                        $this->setCommentVar($k, $v);

                $this->sendRequest(
                                $this->cfg->apiKey.'.'.$this->cfg->apiServer,
                                '/'.$this->cfg->apiVersion.'/submit-ham',
                                $this->getQueryString());
        }

        public function setCommentVar($key, $val) {
                $this->cfg->setInArray('comment', $key, $val);
        }

        public function setAuthor($author) {
                $this->setCommentVar('comment_author', $author);
        }

        public function setAuthorEmail($email) {
                $this->setCommentVar('comment_author_email', $email);
        }

        public function setAuthorUrl($url) {
                $this->setCommentVar('comment_author_url', $url);
        }

        public function setContent($content) {
                $this->setCommentVar('comment_content', $content);
        }

        public function verifyKey() {
                $response = $this->sendRequest(
                                $this->cfg->apiServer,
                                '/'.$this->cfg->apiVersion.'/verify-key',
                                'key='.$this->cfg->apiKey.'&blog='.$this->cfg->url);
                return $response[1] == 'valid';
        }

        protected function sendRequest($host, $path, $request) {
                $httpRequest = "POST ".$path." HTTP/1.0\r\n";
                $httpRequest.= "Host: ".$host."\r\n";
                $httpRequest.= "Content-Type: application/x-www-form-urlencoded; charset=utf-8\r\n";
                $httpRequest.= "Content-Length: ".strlen($request)."\r\n";
                $httpRequest.= "User-Agent: ".$this->cfg->userAgent."\r\n";
                $httpRequest.= "\r\n";
                $httpRequest.= $request;

                $response = '';
                if (false !== ($fs = @fsockopen($host, $this->cfg->apiPort, $errno, $errstr, 3))) {
                        fwrite($fs, $httpRequest);
                        while (!feof($fs))
                                $response.= fgets($fs, 1160); // One TCP-IP packet
                        fclose($fs);
                        $response = explode("\r\n\r\n", $response, 2);
                }
                return $response;
        }

        protected function getQueryString() {
                $queryString = 'blog='.urlencode(stripslashes($this->cfg->url)).'&';
                $queryString.= 'user_agent='.urlencode(stripslashes($this->cfg->userAgent)).'&';
                foreach ($this->cfg->comment as $k=>$v)
                        $queryString.= $k.'='.urlencode(stripslashes($v)).'&';

                $vars = array_diff_key($_SERVER, array_flip($this->cfg->ignoreServerVars));
                foreach ($vars as $k=>$v)
                        $queryString.= $k.'='.urlencode(stripslashes($v)).'&';

                return $queryString;
        }
}