Author URI: http://petermolnar.eu/
License: GPLv3
*/
/* Copyright 2015 Peter Molnar ( hello@petermolnar.eu )
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 3, 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 St, Fifth Floor, Boston, MA 02110-1301 USA
*/
class blogroll2email {
const revisit_time = 3600;
const schedule = 'blogroll2email';
var $schedule = null;
public function __construct () {
register_activation_hook( __FILE__ , array( &$this, 'plugin_activate' ) );
register_deactivation_hook( __FILE__ , array( &$this, 'plugin_deactivate' ) );
add_action( 'init', array( &$this, 'init'));
}
public function init () {
add_action( static::schedule, array( &$this, 'worker' ) );
//wp_schedule_event( time(), static::SCHEDULE, $this->schedule );
return false;
}
/**
* activation hook function, to be extended
*/
public function plugin_activate() {
self::debug('activating');
wp_schedule_single_event ( time(), static::schedule );
}
/**
* deactivation hook function, to be extended
*/
public function plugin_deactivate () {
self::debug('deactivating');
wp_unschedule_event( time(), static::schedule );
}
public function worker () {
self::debug('worker started');
$args = array(
'orderby' => 'owner',
'order' => 'ASC',
'limit' => -1,
);
$bookmarks = get_bookmarks( $args );
$currowner = $owner = false;
foreach ( $bookmarks as $bookmark ) {
/* print_r ($bookmark);
stdClass Object
(
[link_id] => 1
[link_url] => http://devopsreactions.tumblr.com/
[link_name] => http://devopsreactions.tumblr.com/
[link_image] =>
[link_target] =>
[link_description] =>
[link_visible] => Y
[link_owner] => 1
[link_rating] => 0
[link_updated] => 0000-00-00 00:00:00
[link_rel] =>
[link_notes] =>
[link_rss] => http://devopsreactions.tumblr.com/rss
)
*/
if ( $currowner != $bookmark->link_owner) {
$currowner = $bookmark->link_owner;
$owner = get_userdata($currowner);
$owner = $owner->data;
/* print_r ( $owner );
stdClass Object
(
[ID] => 1
[user_login] => cadeyrn
[user_pass] => $P$B.QI9GiDNyfXC7S75jJ4pcrQjx3awy/
[user_nicename] => cadeyrn
[user_email] => hello@petermolnar.eu
[user_url] => https://petermolnar.eu/
[user_registered] => 2014-04-28 21:36:35
[user_activation_key] =>
[user_status] => 0
[display_name] => Peter Molnar
)
*/
}
if ( empty($bookmark->link_rss)) {
// TODO: microformats
continue;
}
else {
$this->parse_rss( $bookmark, $owner );
}
}
// reschedule the worker
wp_schedule_single_event ( time() + static::revisit_time, static::schedule );
}
/**
*
*/
public function set_html_content_type() {
return 'text/html';
}
/**
*
*/
protected function send ( $to, $link, $title, $fromname, $sourceurl, $content ) {
add_filter( 'wp_mail_content_type', array( $this, 'set_html_content_type') );
$body = ''. $content . 'URL: '.$link.'
';
$headers = array (
'X-RSS-ID: ' . $link,
'X-RSS-URL: ' . $link,
'X-RSS-Feed: ' . $sourceurl,
'User-Agent: blogroll2email',
'From: "' . $fromname .'" <'. get_bloginfo('admin_email') .'>',
);
//wp_mail( $to, $title, $body, $headers );
self::debug('blogroll2email: ' . $title );
remove_filter( 'wp_mail_content_type', array( $this, 'set_html_content_type') );
}
/**
*
*/
protected function parse_rss ( $bookmark, $owner ) {
if ( !class_exists('SimplePie') )
require_once( ABSPATH . WPINC . '/class-simplepie.php' );
if ( empty ($bookmark) || !is_object ($bookmark))
return false;
if ( empty ($owner) || !is_object ($owner))
return false;
$url = $bookmark->link_rss;
$last_updated = strtotime( $bookmark->link_updated );
error_log('Fetching: ' . $url );
$feed = new SimplePie();
$feed->set_feed_url( $url );
$feed->set_cache_duration ( static::revisit_time );
$feed->set_cache_location( WP_CONTENT_DIR . DIRECTORY_SEPARATOR. 'cache' );
$feed->force_feed(true);
// optimization
$feed->enable_order_by_date(true);
$feed->remove_div(false);
$feed->strip_comments(true);
$feed->strip_htmltags(false);
$feed->strip_attributes(false);
$feed->set_image_handler(false);
$feed->init();
$feed->handle_content_type();
if ( $feed->error() )
return new WP_Error( 'simplepie-error', $feed->error() );
$maxitems = $feed->get_item_quantity( 12 );
$feed_items = $feed->get_items( 0, $maxitems );
$feed_title = $feed->get_title();
if ( $maxitems > 0 ) {
$last_updated_ = 0;
foreach ( $feed_items as $item ) {
$date = strtotime($item->get_date( 'Y-m-d H:i:s' ));
$from = $feed_title . ': ' . $item->get_author();
if ( $date > $last_updated ) {
$this->send (
$owner->user_email,
$item->get_link(),
$item->get_title(),
$from, $url,
$item->get_content()
);
if ( $date > $last_updated_ )
$last_updated_ = $date;
}
}
}
if ( $last_updated_ > $last_updated ) {
global $wpdb;
$wpdb->update( $wpdb->prefix . 'links', array ( 'link_updated' => date( 'Y-m-d H:i:s', $last_updated_ )), array('link_id'=> $bookmark->link_id ) );
}
}
/**
*
*/
static function debug( $message, $level = LOG_NOTICE ) {
if ( @is_array( $message ) || @is_object ( $message ) )
$message = json_encode($message);
switch ( $level ) {
case LOG_ERR :
wp_die( 'Error:
' . '' . $message . '
' );
exit;
default:
if ( !defined( 'WP_DEBUG' ) || WP_DEBUG != true )
return;
break;
}
error_log( __CLASS__ . ": " . $message );
}
}
$blogroll2email = new blogroll2email();