blogspam.php

<?php

/*
Plugin Name: Blogspam
Plugin URI: http://blogspam.net/plugins/
Description: This plugin allows you to test submitted comments against a centralised service that will filter out a lot of junk.  No manual intervention required.
Author: Steve Kemp
Version: 2.6
Author URI: http://www.steve.org.uk/
*/




/*  Copyright 2008-2014  Steve Kemp  (email : http://www.steve.org.uk/contact/ )

    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    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 St, Fifth Floor, Boston, MA  02110-1301  USA
*/




//
//  Find the version number of our plugin.
//
function skx_self_version()
{
  if ( !function_exists( 'get_plugins' ) )
  {
    require_once( ABSPATH . 'wp-admin/includes/plugin.php' );
  }

  $plugins = get_plugins();
  $version = "v0.0";
  foreach ( $plugins  as $p )
  {
    if ( $p['Name'] == "Blogspam" )
    {
      $version = $p['Version'];
    }
  }
  return $version;
}



//
// Check the content of a comment, by submitting the body
// via HTTP to the JSON server.
//
function skx_check_comment( $author, $email,
	 $url, $comment,
	 $user_ip, $user_agent)
{
  //
  // Get the server name, and any options.
  //
  $server_name       = get_option('skx_blogspam_server');
  if ( !$server_name ) { $server_name = "http://test.blogspam.net:9999/"; }

  $server_options    = get_option('skx_blogspam_options');
  if ( !$server_options ) { $server_options = ""; }


  //
  // Try to ensure the comment is valid UTF-8, which is mandatory
  // for the JSON extension module.
  //
  $updated = iconv('UTF-8', 'UTF-8//IGNORE', $comment);

  //
  // iconv returns false on failure, test for that here.
  //
  if ( $updated )
  {
      $comment = $updated;
  }

  //
  // Make the structure we'll send.
  //
  // This corresponds to:
  //
  //  http://blogspam.net/api/2.0/testComment.html
  //
  $struct = array(
                   'ip'      => $_SERVER['REMOTE_ADDR'],
                   'name'    => $author,
                   'mail'    => $email,
                   'comment' => $comment,
                   'site'    => get_bloginfo('url'),
		   'options' => $server_options,
                   'version' => "Blogspam.php " . skx_self_version() . " on wordpress " . get_bloginfo('version')
                   );

  //
  // Send the JSON result.
  //
  $result = wp_remote_post( $server_name, array( 'body' => json_encode(  $struct ) ) );

  if ( ! is_wp_error( $result ) )
  {

      $obj = json_decode( $result['body'], true );

      if ( $obj['result'] == "SPAM" )
      {
          //
          // Mark the result as spam.
          //
          add_filter('pre_comment_approved',
                     create_function('$a', 'return \'spam\';'), 99);

          return 1;
       }
   }

  return 0;
}


//
//  Add a new action page underneath "settings".
//
function skx_add_pages()
{
    add_options_page('Blogspam', 'Blogspam', 8, 'blogspam', 'skx_options_page');
}



//
//  This is called when the admin page is loaded.
//
function skx_options_page()
{
  //
  //  Get the configured value from the db.
  //
  $server_name       = get_option('skx_blogspam_server');
  $server_options    = get_option('skx_blogspam_options');

  //
  //  If not set then use sane defaults.
  //
  if ( !$server_name )
  {
       $server_name = "http://test.blogspam.net:9999/" ;
  }
  if ( !$server_options )
  {
       $server_options = "";
  }

  //
  // See if the user has submitted a test-request.
  //
  if( $_POST[ 'test' ] == 'Test' )
  {
      $plugins_url  = get_option( 'skx_blogspam_server' );
      if ( !$plugins_url ) {
         $plugins_url = "http://test.blogspam.net:9999/plugins" ;
      } else {
         $plugins_url = $plugins_url . "plugins";
      }
      $res = wp_remote_get( $plugins_url );
      if ( is_wp_error( $res ) )
      {
         echo "<div class=\"updated\"><p><strong>Test failed :" . $res->get_error_message(). "</strong></p></div>";      }
      else
      {
         $obj = json_decode( $res['body'], true );
         if ( $obj && is_array($obj) ) {
           echo "<div class=\"updated\"><p><strong>Test SUCCEEDED</strong></p></div>";
         }
         else {
           echo "<div class=\"updated\"><p><strong>Test FAILED</strong></p></div>";             }
      }
  }

  //
  // See if the user has submitted updated values.
  //
  if( $_POST[ 'submit' ] == 'Submit' )
  {
    // Read the submitted valies.
    $server_name    = $_POST[ 'server_name' ];
    $server_options = $_POST[ 'server_options' ];

    // Save the posted value in the database
    update_option( 'skx_blogspam_server', $server_name );
    update_option( 'skx_blogspam_options', $server_options );

    // Put an options updated message on the screen
?>
<div class="updated"><p><strong><?php _e('Options saved.', 'mt_trans_domain' ); ?></strong></p></div>
<?php

                                                                                  }

  // Now display the options editing screen
  echo '<div class="wrap">';

  // header
  $version = skx_self_version();
  echo "<h2>Blogspam v$version Options </h2>";
  ?>

  <p>The blogspam plugin will pass all submitted comments through a remote service which will test comments.</p><p>Here you can specify the URL of that testing service, along with some optional configuration settings.</p>

  <form name="form1" method="post" action="<?php echo str_replace( '%7E', '~', $_SERVER['REQUEST_URI']); ?>">

  <p>Server:
  <input type="text" name="server_name" value="<?php echo $server_name; ?>" size="40">
  </p>

  <p><a href="http://blogspam.net/api/2.0/testComment.html#options">Server Options</a>:
  <input type="text" name="server_options" value="<?php echo $server_options; ?>" size="40">
  </p><hr />

  <p class="submit">
  <input type="submit" name="submit" value="Submit" />
  <input type="submit" name="test" value="Test" />
  </p>

  </form>
  </div>

<?php

  //
  // Stats
  //
  $stats_url  = get_option( 'skx_blogspam_server' );
  $stats_data = array( 'site' => get_bloginfo('url') );

  if ( !$stats_url ) {
      $stats_url = "http://test.blogspam.net:9999/stats" ;
  } else {
      $stats_url = $stats_url . "stats";
  }

  $stats = wp_remote_post( $stats_url , array( 'body' => json_encode(  $stats_data ) ) );
  if ( ! is_wp_error( $stats ) )
  {
      $obj = json_decode( $stats['body'], true );
      if ( $obj && array_key_exists( "spam", $obj ) ) {
          echo "<p>Dropped " . $obj['spam'] . " comment(s).</p>";
      }
      if ( $obj && array_key_exists( "ok", $obj ) ) {
          echo "<p>Permitted " . $obj['ok'] . " comment(s)</p>";
      }
  }
  echo "<iframe height=\"800\" width=\"90%\" style=\"text-align:center;border:1px solid black\" src=\"http://blogspam.net/news.html\"></iframe>";
}


//
//  This function is called when a comment is submitted as
// spam, by the wordpress admin.
//
//  We fire off a JSON request to blacklist the IP.
//
function skx_train_comment( $id, $status )
{
    if ( $status == "spam" )
    {
	//
	// Get the comment data.
	//
        $data = get_comment( $id, ARRAY_A );
        $ip   = $data['comment_author_IP'];

	//
	// The data we'll train with.
	//
        $json_data = array(  'ip'   => $ip,
                             'site' => get_bloginfo('url'),
                             'train' => 'spam' );

	//
	// Post to the URL
	//
        $train_url  = get_option( 'skx_blogspam_server' );
        if ( !$train_url ) {
          $train_url = "http://test.blogspam.net:9999/classify" ;
        } else {
          $train_url = $train_url . "classify";
        }

        $stats = wp_remote_post( $train_url , array( 'body' => json_encode(  $json_data ) ) );
        if ( ! is_wp_error( $stats ) )
        {
	}
	else
        {
	    die( $stats->get_error_message() );
        }
    }
}

//
//  Add the hooks
//
add_action( 'wp_blacklist_check', 'skx_check_comment', 10, 6);
add_action( 'wp_set_comment_status', 'skx_train_comment', 10, 2 );
add_action( 'admin_menu', 'skx_add_pages' );



?>