PluginProbe
FeedWordPress / 2011.0531
FeedWordPress v2011.0531
trunk 0.8 0.9 0.91 0.95 0.96 0.97 0.98 0.981 0.99 0.991 0.992 0.993 2008.1030 2008.1101 2008.1105 2008.1214 2009.0612 2009.0613 2009.0618 2009.0707 2009.1111 2009.1112 2010.0127 2010.0528 All 65 releases
← All changes | feedwordpress.php +1493 -2135 2008.11052011.0531 View file →
@@ -1,38 +1,60 @@
1 1 <?php
2 2 /*
3 3 Plugin Name: FeedWordPress
4 -Plugin URI: http://projects.radgeek.com/feedwordpress
4 +Plugin URI: http://feedwordpress.radgeek.com/
5 5 Description: simple and flexible Atom/RSS syndication for WordPress
6 -Version: 2008.1105
6 +Version: 2011.0531
7 7 Author: Charles Johnson
8 8 Author URI: http://radgeek.com/
9 9 License: GPL
10 -Last modified: 2008-11-05 4:35pm PST
11 10 */
12 11
12 +/**
13 + * @package FeedWordPress
14 + * @version 2011.0531
15 + */
16 +
13 17 # This uses code derived from:
14 18 # - wp-rss-aggregate.php by Kellan Elliot-McCrea <kellan@protest.net>
15 -# - HTTP Navigator 2 by Keyvan Minoukadeh <keyvan@k1m.com>
19 +# - MagpieRSS by Kellan Elliot-McCrea <kellan@protest.net>
16 20 # - Ultra-Liberal Feed Finder by Mark Pilgrim <mark@diveintomark.org>
21 +# - WordPress Blog Tool and Publishing Platform <http://wordpress.org/>
17 22 # according to the terms of the GNU General Public License.
18 23 #
19 -# INSTALLATION: see README.text or <http://projects.radgeek.com/install>
24 +# INSTALLATION: see readme.txt or <http://projects.radgeek.com/install>
20 25 #
21 26 # USAGE: once FeedWordPress is installed, you manage just about everything from
22 -# the WordPress Dashboard, under Options --> Syndication or Links --> Syndicated
23 -# To ensure that fresh content is added as it becomes available, get your
24 -# contributors to put your XML-RPC URI (if WordPress is installed at
27 +# the WordPress Dashboard, under the Syndication menu. To ensure that fresh
28 +# content is added as it becomes available, you can convince your contributors
29 +# to put your XML-RPC URI (if WordPress is installed at
25 30 # <http://www.zyx.com/blog>, XML-RPC requests should be sent to
26 -# <http://www.zyx.com/blog/xmlrpc.php>), or see `update-feeds.php`
31 +# <http://www.zyx.com/blog/xmlrpc.php>), or update manually under the
32 +# Syndication menu, or set up automatic updates under Syndication --> Settings,
33 +# or use a cron job.
27 34
28 35 # -- Don't change these unless you know what you're doing...
29 36
30 -define ('FEEDWORDPRESS_VERSION', '2008.1105');
37 +define ('FEEDWORDPRESS_VERSION', '2011.0531');
31 38 define ('FEEDWORDPRESS_AUTHOR_CONTACT', 'http://radgeek.com/contact');
39 +
40 +if (!defined('FEEDWORDPRESS_BLEG')) :
41 + define ('FEEDWORDPRESS_BLEG', true);
42 +endif;
43 +
44 +// Defaults
32 45 define ('DEFAULT_SYNDICATION_CATEGORY', 'Contributors');
46 +define ('DEFAULT_UPDATE_PERIOD', 60); // value in minutes
33 47
34 -define ('FEEDWORDPRESS_DEBUG', false);
48 +if (isset($_REQUEST['feedwordpress_debug'])) :
49 + $feedwordpress_debug = $_REQUEST['feedwordpress_debug'];
50 +else :
51 + $feedwordpress_debug = get_option('feedwordpress_debug');
52 + if (is_string($feedwordpress_debug)) :
53 + $feedwordpress_debug = ($feedwordpress_debug == 'yes');
54 + endif;
55 +endif;
56 +define ('FEEDWORDPRESS_DEBUG', $feedwordpress_debug);
35 57
36 58 define ('FEEDWORDPRESS_CAT_SEPARATOR_PATTERN', '/[:\n]/');
37 59 define ('FEEDWORDPRESS_CAT_SEPARATOR', "\n");
38 60
@@ -40,19 +62,23 @@
40 62
41 63 define ('FEEDWORDPRESS_FRESHNESS_INTERVAL', 10*60); // Every ten minutes
42 64
43 65 define ('FWP_SCHEMA_HAS_USERMETA', 2966);
66 +define ('FWP_SCHEMA_USES_ARGS_TAXONOMY', 12694); // Revision # for using $args['taxonomy'] to get link categories
44 67 define ('FWP_SCHEMA_20', 3308); // Database schema # for WP 2.0
45 68 define ('FWP_SCHEMA_21', 4772); // Database schema # for WP 2.1
46 69 define ('FWP_SCHEMA_23', 5495); // Database schema # for WP 2.3
47 70 define ('FWP_SCHEMA_25', 7558); // Database schema # for WP 2.5
48 71 define ('FWP_SCHEMA_26', 8201); // Database schema # for WP 2.6
72 +define ('FWP_SCHEMA_27', 9872); // Database schema # for WP 2.7
73 +define ('FWP_SCHEMA_28', 11548); // Database schema # for WP 2.8
74 +define ('FWP_SCHEMA_29', 12329); // Database schema # for WP 2.9
75 +define ('FWP_SCHEMA_30', 12694); // Database schema # for WP 3.0
49 76
50 77 if (FEEDWORDPRESS_DEBUG) :
51 78 // Help us to pick out errors, if any.
52 79 ini_set('error_reporting', E_ALL & ~E_NOTICE);
53 80 ini_set('display_errors', true);
54 - define('MAGPIE_DEBUG', true);
55 81
56 82 // When testing we don't want cache issues to interfere. But this is
57 83 // a VERY BAD SETTING for a production server. Webmasters will eat your
58 84 // face for breakfast if you use it, and the baby Jesus will cry. So
@@ -57,45 +83,55 @@
57 83 // a VERY BAD SETTING for a production server. Webmasters will eat your
58 84 // face for breakfast if you use it, and the baby Jesus will cry. So
59 85 // make sure FEEDWORDPRESS_DEBUG is FALSE for any site that will be
60 86 // used for more than testing purposes!
61 - define('MAGPIE_CACHE_AGE', 1);
87 + define('FEEDWORDPRESS_CACHE_AGE', 1);
88 + define('FEEDWORDPRESS_CACHE_LIFETIME', 1);
89 + define('FEEDWORDPRESS_FETCH_TIMEOUT_DEFAULT', 60);
62 90 else :
63 - define('MAGPIE_DEBUG', false);
91 + // Hold onto data all day for conditional GET purposes,
92 + // but consider it stale after 1 min (requiring a conditional GET)
93 + define('FEEDWORDPRESS_CACHE_LIFETIME', 24*60*60);
94 + define('FEEDWORDPRESS_CACHE_AGE', 1*60);
95 + define('FEEDWORDPRESS_FETCH_TIMEOUT_DEFAULT', 20);
64 96 endif;
65 97
66 -// Note that the rss-functions.php that comes prepackaged with WordPress is
67 -// old & busted. For the new hotness, drop a copy of rss.php from
68 -// this archive into wp-includes/rss.php
98 +// Use our the cache settings that we want.
99 +add_filter('wp_feed_cache_transient_lifetime', array('FeedWordPress', 'cache_lifetime'));
69 100
70 -if (is_readable(ABSPATH . WPINC . '/rss.php')) :
71 - require_once (ABSPATH . WPINC . '/rss.php');
72 -else :
73 - require_once (ABSPATH . WPINC . '/rss-functions.php');
101 +// Ensure that we have SimplePie loaded up and ready to go.
102 +// We no longer need a MagpieRSS upgrade module. Hallelujah!
103 +if (!class_exists('SimplePie')) :
104 + require_once(ABSPATH . WPINC . '/class-simplepie.php');
74 105 endif;
106 +require_once(ABSPATH . WPINC . '/class-feed.php');
75 107
76 -if (isset($wp_db_version)) :
77 - if ($wp_db_version >= FWP_SCHEMA_23) :
78 - require_once (ABSPATH . WPINC . '/registration.php'); // for wp_insert_user
79 - elseif ($wp_db_version >= FWP_SCHEMA_21) : // WordPress 2.1 and 2.2, but not 2.3
80 - require_once (ABSPATH . WPINC . '/registration.php'); // for wp_insert_user
81 - require_once (ABSPATH . 'wp-admin/admin-db.php'); // for wp_insert_category
82 - elseif ($wp_db_version >= FWP_SCHEMA_20) : // WordPress 2.0
83 - require_once (ABSPATH . WPINC . '/registration-functions.php'); // for wp_insert_user
84 - require_once (ABSPATH . 'wp-admin/admin-db.php'); // for wp_insert_category
85 - endif;
108 +if (!function_exists('wp_insert_user')) :
109 + require_once (ABSPATH . WPINC . '/registration.php'); // for wp_insert_user
86 110 endif;
87 111
88 -require_once(dirname(__FILE__) . '/compatability.php'); // LEGACY API: Replicate or mock up functions for legacy support purposes
112 +$dir = dirname(__FILE__);
113 +require_once("${dir}/admin-ui.php");
114 +require_once("${dir}/feedwordpresssyndicationpage.class.php");
115 +require_once("${dir}/compatability.php"); // Legacy API
116 +require_once("${dir}/syndicatedpost.class.php");
117 +require_once("${dir}/syndicatedlink.class.php");
118 +require_once("${dir}/feedwordpresshtml.class.php");
119 +require_once("${dir}/feedwordpress-content-type-sniffer.class.php");
120 +require_once("${dir}/inspectpostmeta.class.php");
121 +require_once("${dir}/syndicationdataqueries.class.php");
89 122
90 123 // Magic quotes are just about the stupidest thing ever.
91 124 if (is_array($_POST)) :
92 - $fwp_post = stripslashes_deep($_POST);
125 + $fwp_post = $_POST;
126 + if (get_magic_quotes_gpc()) :
127 + $fwp_post = stripslashes_deep($fwp_post);
128 + endif;
93 129 endif;
94 130
95 131 // Get the path relative to the plugins directory in which FWP is stored
96 132 preg_match (
97 - '|/wp-content/plugins/(.+)$|',
133 + '|'.preg_quote(WP_PLUGIN_DIR).'/(.+)$|',
98 134 dirname(__FILE__),
99 135 $ref
100 136 );
101 137
@@ -106,27 +142,21 @@
106 142 endif;
107 143
108 144 // If this is a FeedWordPress admin page, queue up scripts for AJAX functions that FWP uses
109 145 // If it is a display page or a non-FeedWordPress admin page, don't.
110 -if (is_admin() and isset($_REQUEST['page']) and preg_match("|^{$fwp_path}/|", $_REQUEST['page'])) :
111 - if (function_exists('wp_enqueue_script')) :
112 - if (isset($wp_db_version) and $wp_db_version >= FWP_SCHEMA_25) :
113 - wp_enqueue_script('post'); // for magic tag and category boxes
114 - wp_enqueue_script('thickbox'); // for fold-up boxes
115 - wp_enqueue_script('admin-forms'); // for checkbox selection
116 - else :
117 - wp_enqueue_script( 'ajaxcat' ); // Provides the handy-dandy new category text box
118 - endif;
119 - endif;
120 - if (function_exists('wp_enqueue_style')) :
121 - if (fwp_test_wp_version(FWP_SCHEMA_25)) :
122 - wp_enqueue_style('dashboard');
123 - endif;
124 - endif;
146 +wp_register_style('feedwordpress-elements', WP_PLUGIN_URL.'/'.$fwp_path.'/feedwordpress-elements.css');
147 +if (FeedWordPressSettingsUI::is_admin()) :
148 + // For JavaScript that needs to be generated dynamically
149 + add_action('admin_print_scripts', array('FeedWordPressSettingsUI', 'admin_scripts'));
150 +
151 + // For CSS that needs to be generated dynamically.
152 + add_action('admin_print_styles', array('FeedWordPressSettingsUI', 'admin_styles'));
153 +
154 + wp_enqueue_style('dashboard');
155 + wp_enqueue_style('feedwordpress-elements');
156 +
125 157 if (function_exists('wp_admin_css')) :
126 - if (fwp_test_wp_version(FWP_SCHEMA_25)) :
127 - wp_admin_css('css/dashboard');
128 - endif;
158 + wp_admin_css('css/dashboard');
129 159 endif;
130 160 endif;
131 161
132 162 if (!FeedWordPress::needs_upgrade()) : // only work if the conditions are safe!
@@ -149,10 +179,17 @@
149 179
150 180 add_action('atom_entry', 'feedwordpress_item_feed_data');
151 181
152 182 # Filter in original permalinks if the user wants that
153 - add_filter('post_link', 'syndication_permalink', 1);
183 + add_filter('post_link', 'syndication_permalink', /*priority=*/ 1, /*arguments=*/ 3);
154 184
185 + # When foreign URLs are used for permalinks in feeds or display
186 + # contexts, they need to be escaped properly.
187 + add_filter('the_permalink', 'syndication_permalink_escaped');
188 + add_filter('the_permalink_rss', 'syndication_permalink_escaped');
189 +
190 + add_filter('post_comments_feed_link', 'syndication_comments_feed_link');
191 +
155 192 # WTF? By default, wp_insert_link runs incoming link_url and link_rss
156 193 # URIs through default filters that include `wp_kses()`. But `wp_kses()`
157 194 # just happens to escape any occurrence of & to &amp; -- which just
158 195 # happens to fuck up any URI with a & to separate GET parameters.
@@ -160,12 +197,18 @@
160 197 remove_filter('pre_link_url', 'wp_filter_kses');
161 198
162 199 # Admin menu
163 200 add_action('admin_menu', 'fwp_add_pages');
201 + add_action('admin_notices', 'fwp_check_debug');
202 +
203 + add_action('admin_menu', 'feedwordpress_add_post_edit_controls');
204 + add_action('save_post', 'feedwordpress_save_post_edit_controls');
205 +
206 + add_action('admin_footer', array('FeedWordPress', 'admin_footer'));
164 207
165 208 # Inbound XML-RPC update methods
166 - add_filter('xmlrpc_methods', 'feedwordpress_xmlrpc_hook');
167 -
209 + $feedwordpressRPC = new FeedWordPressRPC;
210 +
168 211 # Outbound XML-RPC ping reform
169 212 remove_action('publish_post', 'generic_ping'); // WP 1.5.x
170 213 remove_action('do_pings', 'do_all_pings', 10, 1); // WP 2.1, 2.2
171 214 remove_action('publish_post', '_publish_post_hook', 5, 1); // WP 2.3
@@ -174,22 +217,27 @@
174 217 add_action('do_pings', 'fwp_do_pings', 10, 1);
175 218 add_action('feedwordpress_update', 'fwp_hold_pings');
176 219 add_action('feedwordpress_update_complete', 'fwp_release_pings');
177 220
178 - # Hook in logging functions only if the logging option is ON
179 - $update_logging = get_option('feedwordpress_update_logging');
180 - if ($update_logging == 'yes') :
181 - add_action('post_syndicated_item', 'log_feedwordpress_post', 100);
182 - add_action('update_syndicated_item', 'log_feedwordpress_update_post', 100);
183 - add_action('feedwordpress_update', 'log_feedwordpress_update_feeds', 100);
184 - add_action('feedwordpress_check_feed', 'log_feedwordpress_check_feed', 100);
185 - add_action('feedwordpress_update_complete', 'log_feedwordpress_update_complete', 100);
221 + add_action('syndicated_feed_error', array('FeedWordPressDiagnostic', 'feed_error'), 100, 3);
222 +
223 + add_action('wp_footer', 'debug_out_feedwordpress_footer', -100);
224 + add_action('admin_footer', 'debug_out_feedwordpress_footer', -100);
225 +
226 + $feedwordpress = new FeedWordPress;
227 +
228 + # Cron-less auto-update. Hooray!
229 + $autoUpdateHook = get_option('feedwordpress_automatic_updates');
230 + if ($autoUpdateHook != 'init') :
231 + $autoUpdateHook = 'shutdown';
186 232 endif;
187 -
188 - # Cron-less auto-update. Hooray!
189 - add_action('init', 'feedwordpress_auto_update');
190 -
233 + add_action($autoUpdateHook, array(&$feedwordpress, 'auto_update'));
234 + add_action('init', array(&$feedwordpress, 'init'));
235 + add_action('shutdown', array(&$feedwordpress, 'email_diagnostic_log'));
236 + add_action('wp_dashboard_setup', array(&$feedwordpress, 'dashboard_setup'));
237 +
191 238 # Default sanitizers
239 + add_filter('syndicated_item_content', array('SyndicatedPost', 'resolve_relative_uris'), 0, 2);
192 240 add_filter('syndicated_item_content', array('SyndicatedPost', 'sanitize_content'), 0, 2);
193 241
194 242 else :
195 243 # Hook in the menus, which will just point to the upgrade interface
@@ -195,174 +243,261 @@
195 243 # Hook in the menus, which will just point to the upgrade interface
196 244 add_action('admin_menu', 'fwp_add_pages');
197 245 endif; // if (!FeedWordPress::needs_upgrade())
198 246
199 -function feedwordpress_auto_update () {
200 - if (FeedWordPress::stale()) :
201 - $feedwordpress =& new FeedWordPress;
202 - $feedwordpress->update();
203 - endif;
204 -
205 - if (FeedWordPress::update_requested()) :
206 - exit;
207 - endif;
208 -} /* feedwordpress_auto_update () */
209 -
210 247 ################################################################################
211 248 ## LOGGING FUNCTIONS: log status updates to error_log if you want it ###########
212 249 ################################################################################
213 250
214 -function log_feedwordpress_post ($id) {
215 - $post = wp_get_single_post($id);
216 - error_log("[".date('Y-m-d H:i:s')."][feedwordpress] posted "
217 - ."'{$post->post_title}' ({$post->post_date})");
218 -}
251 +class FeedWordPressDiagnostic {
252 + function feed_error ($error, $old, $link) {
253 + $wpError = $error['object'];
254 + $url = $link->uri();
255 +
256 + $mesgs = $wpError->get_error_messages();
257 + foreach ($mesgs as $mesg) :
258 + $mesg = esc_html($mesg);
259 + FeedWordPress::diagnostic(
260 + 'updated_feeds:errors',
261 + "Feed Error: [${url}] update returned error: $mesg"
262 + );
263 +
264 + $hours = get_option('feedwordpress_diagnostics_persistent_errors_hours', 2);
265 + $span = ($error['ts'] - $error['since']);
219 266
220 -function log_feedwordpress_update_post ($id) {
221 - $post = wp_get_single_post($id);
222 - error_log("[".date('Y-m-d H:i:s')."][feedwordpress] updated "
223 - ."'{$post->post_title}' ({$post->post_date})"
224 - ." (as of {$post->post_modified})");
225 -}
267 + if ($span >= ($hours * 60 * 60)) :
268 + $since = date('r', $error['since']);
269 + $mostRecent = date('r', $error['ts']);
270 + FeedWordPress::diagnostic(
271 + 'updated_feeds:errors:persistent',
272 + "Feed Update Error: [${url}] returning errors"
273 + ." since ${since}:<br/><code>$mesg</code>",
274 + $url, $error['since'], $error['ts']
275 + );
276 + endif;
277 + endforeach;
278 + }
226 279
227 -function log_feedwordpress_update_feeds ($uri) {
228 - error_log("[".date('Y-m-d H:i:s')."][feedwordpress] update('$uri')");
229 -}
280 + function admin_emails ($id = '') {
281 + $users = get_users_of_blog($id);
282 + $recipients = array();
283 + foreach ($users as $user) :
284 + $user_id = (isset($user->user_id) ? $user->user_id : $user->ID);
285 + $dude = new WP_User($user_id);
286 + if ($dude->has_cap('administrator')) :
287 + if ($dude->user_email) :
288 + $recipients[] = $dude->user_email;
289 + endif;
290 + endif;
291 + endforeach;
292 + return $recipients;
293 + }
294 +} /* class FeedWordPressDiagnostic */
230 295
231 -function log_feedwordpress_check_feed ($feed) {
232 - $uri = $feed['link/uri']; $name = $feed['link/name'];
233 - error_log("[".date('Y-m-d H:i:s')."][feedwordpress] Examining $name <$uri>");
296 +function debug_out_human_readable_bytes ($quantity) {
297 + $quantity = (int) $quantity;
298 + $magnitude = 'B';
299 + $orders = array('KB', 'MB', 'GB', 'TB');
300 + while (($quantity > (1024*100)) and (count($orders) > 0)) :
301 + $quantity = floor($quantity / 1024);
302 + $magnitude = array_shift($orders);
303 + endwhile;
304 + return "${quantity} ${magnitude}";
234 305 }
235 306
236 -function log_feedwordpress_update_complete ($delta) {
237 - $mesg = array();
238 - if (isset($delta['new'])) $mesg[] = 'added '.$delta['new'].' new posts';
239 - if (isset($delta['updated'])) $mesg[] = 'updated '.$delta['updated'].' existing posts';
240 - if (empty($mesg)) $mesg[] = 'nothing changed';
307 +function debug_out_feedwordpress_footer () {
308 + if (FeedWordPress::diagnostic_on('memory_usage')) :
309 + if (function_exists('memory_get_usage')) :
310 + FeedWordPress::diagnostic ('memory_usage', "Memory: Current usage: ".debug_out_human_readable_bytes(memory_get_usage()));
311 + endif;
312 + if (function_exists('memory_get_peak_usage')) :
313 + FeedWordPress::diagnostic ('memory_usage', "Memory: Peak usage: ".debug_out_human_readable_bytes(memory_get_peak_usage()));
314 + endif;
315 + endif;
316 +} /* debug_out_feedwordpress_footer() */
241 317
242 - error_log("[".date('Y-m-d H:i:s')."][feedwordpress] "
243 - .(is_null($delta) ? "Error: I don't syndicate that URI"
244 - : implode(' and ', $mesg)));
245 -}
246 -
247 318 ################################################################################
248 319 ## TEMPLATE API: functions to make your templates syndication-aware ############
249 320 ################################################################################
250 321
251 -function is_syndicated () { return (strlen(get_syndication_feed_id()) > 0); }
322 +/**
323 + * is_syndicated: Tests whether the current post in a Loop context, or a post
324 + * given by ID number, was syndicated by FeedWordPress. Useful for templates
325 + * to determine whether or not to retrieve syndication-related meta-data in
326 + * displaying a post.
327 + *
328 + * @param int $id The post to check for syndicated status. Defaults to the current post in a Loop context.
329 + * @return bool TRUE if the post's meta-data indicates it was syndicated; FALSE otherwise
330 + */
331 +function is_syndicated ($id = NULL) {
332 + return (strlen(get_syndication_feed_id($id)) > 0);
333 +} /* function is_syndicated() */
252 334
253 -function get_syndication_source_link ($original = NULL) {
254 - if (is_null($original)) : $original = FeedWordPress::use_aggregator_source_data();
335 +function feedwordpress_display_url ($url, $before = 60, $after = 0) {
336 + $bits = parse_url($url);
337 +
338 + // Strip out crufty subdomains
339 + if (isset($bits['host'])) :
340 + $bits['host'] = preg_replace('/^www[0-9]*\./i', '', $bits['host']);
341 + endif;
342 +
343 + // Reassemble bit-by-bit with minimum of crufty elements
344 + $url = (isset($bits['user'])?$bits['user'].'@':'')
345 + .(isset($bits['host'])?$bits['host']:'')
346 + .(isset($bits['path'])?$bits['path']:'')
347 + .(isset($uri_bits['port'])?':'.$uri_bits['port']:'')
348 + .(isset($bits['query'])?'?'.$bits['query']:'');
349 +
350 + if (strlen($url) > ($before+$after)) :
351 + $url = substr($url, 0, $before).'…'.substr($url, 0 - $after, $after);
255 352 endif;
256 353
257 - if ($original) : $vals = get_post_custom_values('syndication_source_uri_original');
258 - else : $vals = array();
354 + return $url;
355 +} /* feedwordpress_display_url () */
356 +
357 +function get_syndication_source_property ($original, $id, $local, $remote = NULL) {
358 + $ret = NULL;
359 + if (is_null($original)) :
360 + $original = FeedWordPress::use_aggregator_source_data();
259 361 endif;
260 362
261 - if (count($vals) == 0) : $vals = get_post_custom_values('syndication_source_uri');
363 + if (is_null($remote)) :
364 + $remote = $local . '_original';
262 365 endif;
263 366
264 - if (count($vals) > 0) : $ret = $vals[0]; else : $ret = NULL; endif;
265 -
266 - return $ret;
267 -} /* function get_syndication_source_link() */
268 -
269 -function the_syndication_source_link ($original = NULL) { echo get_syndication_source_link($original); }
270 -
271 -function get_syndication_source ($original = NULL) {
272 - if (is_null($original)) : $original = FeedWordPress::use_aggregator_source_data();
367 + $vals = ($original ? get_post_custom_values($remote, $id) : array());
368 + if (count($vals) < 1) :
369 + $vals = get_post_custom_values($local, $id);
273 370 endif;
274 -
275 - if ($original) : $vals = get_post_custom_values('syndication_source_original');
276 - else : $vals = array();
277 - endif;
278 371
279 - if (count($vals) == 0) : $vals = get_post_custom_values('syndication_source');
372 + if (count($vals) > 0) :
373 + $ret = $vals[0];
280 374 endif;
281 -
282 - if (count($vals) > 0) : $ret = $vals[0]; else : $ret = NULL; endif;
283 -
284 375 return $ret;
285 -} /* function get_syndication_source() */
376 +} /* function get_syndication_source_property () */
286 377
287 -function the_syndication_source ($original = NULL) { echo get_syndication_source($original); }
378 +function the_syndication_source_link ($original = NULL, $id = NULL) { echo get_syndication_source_link($original, $id); }
379 +function get_syndication_source_link ($original = NULL, $id = NULL) {
380 + return get_syndication_source_property($original, $id, 'syndication_source_uri');
381 +} /* function get_syndication_source_link() */
288 382
289 -function get_syndication_feed ($original = NULL) {
290 - if (is_null($original)) : $original = FeedWordPress::use_aggregator_source_data();
383 +function the_syndication_source ($original = NULL, $id = NULL) { echo get_syndication_source($original, $id); }
384 +function get_syndication_source ($original = NULL, $id = NULL) {
385 + $ret = get_syndication_source_property($original, $id, 'syndication_source');
386 + if (is_null($ret) or strlen(trim($ret)) == 0) : // Fall back to URL of blog
387 + $ret = feedwordpress_display_url(get_syndication_source_link());
291 388 endif;
389 + return $ret;
390 +} /* function get_syndication_source() */
292 391
293 - if ($original) : $vals = get_post_custom_values('syndication_feed_original');
294 - else : $vals = array();
295 - endif;
296 -
297 - if (count($vals) == 0) : $vals = get_post_custom_values('syndication_feed');
298 - endif;
299 -
300 - if (count($vals) > 0) : $ret = $vals[0]; else : $ret = NULL; endif;
301 -
302 - return $ret;
392 +function the_syndication_feed ($original = NULL, $id = NULL) { echo get_syndication_feed($original, $id); }
393 +function get_syndication_feed ($original = NULL, $id = NULL) {
394 + return get_syndication_source_property($original, $id, 'syndication_feed');
303 395 } /* function get_syndication_feed() */
304 396
305 -function the_syndication_feed ($original = NULL) { echo get_syndication_feed ($original); }
306 -
307 -function get_syndication_feed_guid ($original = NULL) {
308 - if (is_null($original)) : $original = FeedWordPress::use_aggregator_source_data();
397 +function the_syndication_feed_guid ($original = NULL, $id = NULL) { echo get_syndication_feed_guid($original, $id); }
398 +function get_syndication_feed_guid ($original = NULL, $id = NULL) {
399 + $ret = get_syndication_source_property($original, $id, 'syndication_source_id');
400 + if (is_null($ret) or strlen(trim($ret))==0) : // Fall back to URL of feed
401 + $ret = get_syndication_feed();
309 402 endif;
310 -
311 - if ($original) : $vals = get_post_custom_values('syndication_source_id_original');
312 - else : $vals = array();
313 - endif;
314 -
315 - if (count($vals) == 0) : $vals = array(get_feed_meta('feed/id'));
316 - endif;
317 -
318 - if (count($vals) > 0) : $ret = $vals[0]; else : $ret = NULL; endif;
319 -
320 403 return $ret;
321 404 } /* function get_syndication_feed_guid () */
322 405
323 -function the_syndication_feed_guid ($original = NULL) { echo get_syndication_feed_guid($original); }
406 +function get_syndication_feed_id ($id = NULL) { list($u) = get_post_custom_values('syndication_feed_id', $id); return $u; }
407 +function the_syndication_feed_id ($id = NULL) { echo get_syndication_feed_id($id); }
324 408
325 -function get_syndication_feed_id () { list($u) = get_post_custom_values('syndication_feed_id'); return $u; }
326 -function the_syndication_feed_id () { echo get_syndication_feed_id(); }
327 -
328 409 $feedwordpress_linkcache = array (); // only load links from database once
410 +function get_syndication_feed_object ($id = NULL) {
411 + global $feedwordpress_linkcache;
329 412
330 -function get_feed_meta ($key) {
331 - global $wpdb, $feedwordpress_linkcache;
332 - $feed_id = get_syndication_feed_id();
413 + $link = NULL;
333 414
334 - $ret = NULL;
415 + $feed_id = get_syndication_feed_id($id);
335 416 if (strlen($feed_id) > 0):
336 417 if (isset($feedwordpress_linkcache[$feed_id])) :
337 418 $link = $feedwordpress_linkcache[$feed_id];
338 419 else :
339 - $link =& new SyndicatedLink($feed_id);
420 + $link = new SyndicatedLink($feed_id);
340 421 $feedwordpress_linkcache[$feed_id] = $link;
341 422 endif;
423 + endif;
424 + return $link;
425 +}
342 426
427 +function get_feed_meta ($key, $id = NULL) {
428 + $ret = NULL;
429 +
430 + $link = get_syndication_feed_object($id);
431 + if (is_object($link) and isset($link->settings[$key])) :
343 432 $ret = $link->settings[$key];
344 433 endif;
345 434 return $ret;
346 435 } /* get_feed_meta() */
347 436
348 -function get_syndication_permalink () {
349 - list($u) = get_post_custom_values('syndication_permalink'); return $u;
437 +function get_syndication_permalink ($id = NULL) {
438 + list($u) = get_post_custom_values('syndication_permalink', $id); return $u;
350 439 }
351 -function the_syndication_permalink () {
352 - echo get_syndication_permalink();
440 +function the_syndication_permalink ($id = NULL) {
441 + echo get_syndication_permalink($id);
353 442 }
354 443
444 +/**
445 + * get_local_permalink: returns a string containing the internal permalink
446 + * for a post (whether syndicated or not) on your local WordPress installation.
447 + * This may be useful if you want permalinks to point to the original source of
448 + * an article for most purposes, but want to retrieve a URL for the local
449 + * representation of the post for one or two limited purposes (for example,
450 + * linking to a comments page on your local aggregator site).
451 + *
452 + * @param $id The numerical ID of the post to get the permalink for. If empty,
453 + * defaults to the current post in a Loop context.
454 + * @return string The URL of the local permalink for this post.
455 + *
456 + * @uses get_permalink()
457 + * @global $feedwordpress_the_original_permalink
458 + *
459 + * @since 2010.0217
460 + */
461 +function get_local_permalink ($id = NULL) {
462 + global $feedwordpress_the_original_permalink;
463 +
464 + // get permalink, and thus activate filter and force global to be filled
465 + // with original URL.
466 + $url = get_permalink($id);
467 + return $feedwordpress_the_original_permalink;
468 +} /* get_local_permalink() */
469 +
470 +/**
471 + * the_original_permalink: displays the contents of get_original_permalink()
472 + *
473 + * @param $id The numerical ID of the post to get the permalink for. If empty,
474 + * defaults to the current post in a Loop context.
475 + *
476 + * @uses get_local_permalinks()
477 + * @uses apply_filters
478 + *
479 + * @since 2010.0217
480 + */
481 +function the_local_permalink ($id = NULL) {
482 + print apply_filters('the_permalink', get_local_permalink($id));
483 +} /* function the_local_permalink() */
484 +
355 485 ################################################################################
356 486 ## FILTERS: syndication-aware handling of post data for templates and feeds ####
357 487 ################################################################################
358 488
359 489 $feedwordpress_the_syndicated_content = NULL;
490 +$feedwordpress_the_original_permalink = NULL;
360 491
361 492 function feedwordpress_preserve_syndicated_content ($text) {
362 493 global $feedwordpress_the_syndicated_content;
363 494
364 - if ( is_syndicated() and get_option('feedwordpress_formatting_filters') != 'yes' ) :
495 + $globalExpose = (get_option('feedwordpress_formatting_filters') == 'yes');
496 + $localExpose = get_post_custom_values('_feedwordpress_formatting_filters');
497 + $expose = ($globalExpose or ((count($localExpose) > 0) and $localExpose[0]));
498 +
499 + if ( is_syndicated() and !$expose ) :
365 500 $feedwordpress_the_syndicated_content = $text;
366 501 else :
367 502 $feedwordpress_the_syndicated_content = NULL;
368 503 endif;
@@ -383,16 +518,16 @@
383 518 // In a post context....
384 519 if (is_syndicated()) :
385 520 ?>
386 521 <source>
387 - <title><?php the_syndication_source(); ?></title>
388 - <link rel="alternate" type="text/html" href="<?php the_syndication_source_link(); ?>" />
389 - <link rel="self" href="<?php the_syndication_feed(); ?>" />
522 + <title><?php print htmlspecialchars(get_syndication_source()); ?></title>
523 + <link rel="alternate" type="text/html" href="<?php print htmlspecialchars(get_syndication_source_link()); ?>" />
524 + <link rel="self" href="<?php print htmlspecialchars(get_syndication_feed()); ?>" />
390 525 <?php
391 526 $id = get_syndication_feed_guid();
392 527 if (strlen($id) > 0) :
393 528 ?>
394 - <id><?php print $id; ?></id>
529 + <id><?php print htmlspecialchars($id); ?></id>
395 530 <?php
396 531 endif;
397 532 $updated = get_feed_meta('feed/updated');
398 533 if (strlen($updated) > 0) : ?>
@@ -404,31 +539,221 @@
404 539 <?php
405 540 endif;
406 541 }
407 542
408 -function syndication_permalink ($permalink = '') {
409 - if (get_option('feedwordpress_munge_permalink') != 'no'):
410 - $uri = get_syndication_permalink();
411 - return ((strlen($uri) > 0) ? $uri : $permalink);
412 - else:
413 - return $permalink;
543 +/**
544 + * syndication_permalink: Allow WordPress to use the original remote URL of
545 + * syndicated posts as their permalink. Can be turned on or off by by setting in
546 + * Syndication => Posts & Links. Saves the old internal permalink in a global
547 + * variable for later use.
548 + *
549 + * @param string $permalink The internal permalink
550 + * @return string The new permalink. Same as the old if the post is not
551 + * syndicated, or if FWP is set to use internal permalinks, or if the post
552 + * was syndicated, but didn't have a proper permalink recorded.
553 + *
554 + * @uses SyndicatedLink::setting()
555 + * @uses get_syndication_permalink()
556 + * @uses get_syndication_feed_object()
557 + * @uses url_to_postid()
558 + * @global $id
559 + * @global $feedwordpress_the_original_permalink
560 + */
561 +function syndication_permalink ($permalink = '', $post = null, $leavename = false) {
562 + global $id;
563 + global $feedwordpress_the_original_permalink;
564 +
565 + // Save the local permalink in case we need to retrieve it later.
566 + $feedwordpress_the_original_permalink = $permalink;
567 +
568 + if (is_object($post) and isset($post->ID) and !empty($post->ID)) :
569 + // Use the post ID we've been provided with.
570 + $postId = $post->ID;
571 + elseif (is_string($permalink) and strlen($permalink) > 0) :
572 + // Map this permalink to a post ID so we can get the correct
573 + // permalink even outside of the Post Loop. Props Björn.
574 + $postId = url_to_postid($permalink);
575 + else :
576 + // If the permalink string is empty but Post Loop context
577 + // provides an id.
578 + $postId = $id;
414 579 endif;
415 -} // function syndication_permalink ()
416 580
581 + $munge = false;
582 + $link = get_syndication_feed_object($postId);
583 + if (is_object($link)) :
584 + $munge = ($link->setting('munge permalink', 'munge_permalink', 'yes') != 'no');
585 + endif;
586 +
587 + if ($munge):
588 + $uri = get_syndication_permalink($postId);
589 + $permalink = ((strlen($uri) > 0) ? $uri : $permalink);
590 + endif;
591 + return $permalink;
592 +} /* function syndication_permalink () */
593 +
594 +/**
595 + * syndication_permalink_escaped: Escape XML special characters in syndicated
596 + * permalinks when used in feed contexts and HTML display contexts.
597 + *
598 + * @param string $permalink
599 + * @return string
600 + *
601 + * @uses is_syndicated()
602 + * @uses FeedWordPress::munge_permalinks()
603 + *
604 + */
605 +function syndication_permalink_escaped ($permalink) {
606 + /* FIXME: This should review link settings not just global settings */
607 + if (is_syndicated() and FeedWordPress::munge_permalinks()) :
608 + // This is a foreign link; WordPress can't vouch for its not
609 + // having any entities that need to be &-escaped. So we'll do
610 + // it here.
611 + $permalink = esc_html($permalink);
612 + endif;
613 + return $permalink;
614 +} /* function syndication_permalink_escaped() */
615 +
616 +/**
617 + * syndication_comments_feed_link: Escape XML special characters in comments
618 + * feed links
619 + *
620 + * @param string $link
621 + * @return string
622 + *
623 + * @uses is_syndicated()
624 + * @uses FeedWordPress::munge_permalinks()
625 + */
626 +function syndication_comments_feed_link ($link) {
627 + global $feedwordpress_the_original_permalink, $id;
628 +
629 + if (is_syndicated() and FeedWordPress::munge_permalinks()) :
630 + // If the source post provided a comment feed URL using
631 + // wfw:commentRss or atom:link/@rel="replies" we can make use of
632 + // that value here.
633 + $source = get_syndication_feed_object();
634 + $replacement = NULL;
635 + if ($source->setting('munge comments feed links', 'munge_comments_feed_links', 'yes') != 'no') :
636 + $commentFeeds = get_post_custom_values('wfw:commentRSS');
637 + if (
638 + is_array($commentFeeds)
639 + and (count($commentFeeds) > 0)
640 + and (strlen($commentFeeds[0]) > 0)
641 + ) :
642 + $replacement = $commentFeeds[0];
643 +
644 + // This is a foreign link; WordPress can't vouch for its not
645 + // having any entities that need to be &-escaped. So we'll do it
646 + // here.
647 + $replacement = esc_html($replacement);
648 + endif;
649 + endif;
650 +
651 + if (is_null($replacement)) :
652 + // Q: How can we get the proper feed format, since the
653 + // format is, stupidly, not passed to the filter?
654 + // A: Kludge kludge kludge kludge!
655 + $fancy_permalinks = ('' != get_option('permalink_structure'));
656 + if ($fancy_permalinks) :
657 + preg_match('|/feed(/([^/]+))?/?$|', $link, $ref);
658 +
659 + $format = (isset($ref[2]) ? $ref[2] : '');
660 + if (strlen($format) == 0) : $format = get_default_feed(); endif;
661 +
662 + $replacement = trailingslashit($feedwordpress_the_original_permalink) . 'feed';
663 + if ($format != get_default_feed()) :
664 + $replacement .= '/'.$format;
665 + endif;
666 + $replacement = user_trailingslashit($replacement, 'single_feed');
667 + else :
668 + // No fancy permalinks = no problem
669 + // WordPress doesn't call get_permalink() to
670 + // generate the comment feed URL, so the
671 + // comments feed link is never munged by FWP.
672 + endif;
673 + endif;
674 +
675 + if (!is_null($replacement)) : $link = $replacement; endif;
676 + endif;
677 + return $link;
678 +} /* function syndication_comments_feed_link() */
679 +
417 680 ################################################################################
418 681 ## ADMIN MENU ADD-ONS: register Dashboard management pages #####################
419 682 ################################################################################
420 683
421 684 function fwp_add_pages () {
422 - global $fwp_capability;
423 - global $fwp_path;
685 + $menu_cap = FeedWordPress::menu_cap();
686 + $settings_cap = FeedWordPress::menu_cap(/*sub=*/ true);
687 + $syndicationMenu = FeedWordPress::path('syndication.php');
688 +
689 + add_menu_page(
690 + 'Syndicated Sites', 'Syndication',
691 + $menu_cap,
692 + $syndicationMenu,
693 + NULL,
694 + WP_PLUGIN_URL.'/'.FeedWordPress::path('feedwordpress-tiny.png')
695 + );
424 696
425 - add_menu_page('Syndicated Sites', 'Syndication', $fwp_capability['manage_links'], $fwp_path.'/syndication.php');
426 - add_submenu_page($fwp_path.'/syndication.php', 'Syndicated Authors', 'Authors', $fwp_capability['manage_options'], $fwp_path.'/authors.php');
427 - add_submenu_page($fwp_path.'/syndication.php', 'Syndication Options', 'Options', $fwp_capability['manage_options'], $fwp_path.'/syndication-options.php');
428 - add_options_page('Syndication Options', 'Syndication', $fwp_capability['manage_options'], $fwp_path.'/syndication-options.php');
429 -} // function fwp_add_pages () */
697 + do_action('feedwordpress_admin_menu_pre_feeds', $menu_cap, $settings_cap);
698 + add_submenu_page(
699 + $syndicationMenu, 'Syndicated Feeds & Updates', 'Feeds & Updates',
700 + $settings_cap, FeedWordPress::path('feeds-page.php')
701 + );
430 702
703 + do_action('feedwordpress_admin_menu_pre_posts', $menu_cap, $settings_cap);
704 + add_submenu_page(
705 + $syndicationMenu, 'Syndicated Posts & Links', 'Posts & Links',
706 + $settings_cap, FeedWordPress::path('posts-page.php')
707 + );
708 +
709 + do_action('feedwordpress_admin_menu_pre_authors', $menu_cap, $settings_cap);
710 + add_submenu_page(
711 + $syndicationMenu, 'Syndicated Authors', 'Authors',
712 + $settings_cap, FeedWordPress::path('authors-page.php')
713 + );
714 +
715 + do_action('feedwordpress_admin_menu_pre_categories', $menu_cap, $settings_cap);
716 + add_submenu_page(
717 + $syndicationMenu, 'Categories'.FEEDWORDPRESS_AND_TAGS, 'Categories'.FEEDWORDPRESS_AND_TAGS,
718 + $settings_cap, FeedWordPress::path('categories-page.php')
719 + );
720 +
721 + do_action('feedwordpress_admin_menu_pre_performance', $menu_cap, $settings_cap);
722 + add_submenu_page(
723 + $syndicationMenu, 'FeedWordPress Performance', 'Performance',
724 + $settings_cap, FeedWordPress::path('performance-page.php')
725 + );
726 +
727 + do_action('feedwordpress_admin_menu_pre_diagnostics', $menu_cap, $settings_cap);
728 + add_submenu_page(
729 + $syndicationMenu, 'FeedWordPress Diagnostics', 'Diagnostics',
730 + $settings_cap, FeedWordPress::path('diagnostics-page.php')
731 + );
732 +} /* function fwp_add_pages () */
733 +
734 +function fwp_check_debug () {
735 + // This is a horrible fucking kludge that I have to do because the
736 + // admin notice code is triggered before the code that updates the
737 + // setting.
738 + if (isset($_POST['feedwordpress_debug'])) :
739 + $feedwordpress_debug = $_POST['feedwordpress_debug'];
740 + else :
741 + $feedwordpress_debug = get_option('feedwordpress_debug');
742 + endif;
743 + if ($feedwordpress_debug==='yes') :
744 +?>
745 + <div class="error">
746 +<p><strong>FeedWordPress warning.</strong> Debugging mode is <strong>ON</strong>.
747 +While it remains on, FeedWordPress displays many diagnostic error messages,
748 +warnings, and notices that are ordinarily suppressed, and also turns off all
749 +caching of feeds. Use with caution: this setting is absolutely inappropriate
750 +for a production server.</p>
751 + </div>
752 +<?php
753 + endif;
754 +} /* function fwp_check_debug () */
755 +
431 756 ################################################################################
432 757 ## fwp_hold_pings() and fwp_release_pings(): Outbound XML-RPC ping reform ####
433 758 ## ... 'coz it's rude to send 500 pings the first time your aggregator runs ####
434 759 ################################################################################
@@ -484,8 +809,70 @@
484 809 endif;
485 810 endif;
486 811 }
487 812
813 + function feedwordpress_add_post_edit_controls () {
814 + add_meta_box('feedwordpress-post-controls', __('Syndication'), 'feedwordpress_post_edit_controls', 'post', 'side', 'high');
815 + if (FeedWordPress::diagnostic_on('syndicated_posts:static_meta_data')) :
816 + $GLOBALS['inspectPostMeta'] = new InspectPostMeta;
817 + endif;
818 + } // function FeedWordPress::postEditControls
819 +
820 + function feedwordpress_post_edit_controls () {
821 + global $post;
822 +
823 + $frozen_values = get_post_custom_values('_syndication_freeze_updates', $post->ID);
824 + $frozen_post = (count($frozen_values) > 0 and 'yes' == $frozen_values[0]);
825 +
826 + if (is_syndicated($post->ID)) :
827 + ?>
828 + <p>This is a syndicated post, which originally appeared at
829 + <cite><?php print esc_html(get_syndication_source(NULL, $post->ID)); ?></cite>.
830 + <a href="<?php print esc_html(get_syndication_permalink($post->ID)); ?>">View original post</a>.</p>
831 +
832 + <p><input type="hidden" name="feedwordpress_noncename" id="feedwordpress_noncename" value="<?php print wp_create_nonce(plugin_basename(__FILE__)); ?>" />
833 + <label><input type="checkbox" name="freeze_updates" value="yes" <?php if ($frozen_post) : ?>checked="checked"<?php endif; ?> /> <strong>Manual editing.</strong>
834 + If set, FeedWordPress will not overwrite the changes you make manually
835 + to this post, if the syndicated content is updated on the
836 + feed.</label></p>
837 + <?php
838 + else :
839 + ?>
840 + <p>This post was created locally at this website.</p>
841 + <?php
842 + endif;
843 + } // function feedwordpress_post_edit_controls () */
844 +
845 + function feedwordpress_save_post_edit_controls ( $post_id ) {
846 + global $post;
847 +
848 + if (!isset($_POST['feedwordpress_noncename']) or !wp_verify_nonce($_POST['feedwordpress_noncename'], plugin_basename(__FILE__))) :
849 + return $post_id;
850 + endif;
851 +
852 + // Verify if this is an auto save routine. If it is our form has
853 + // not been submitted, so we don't want to do anything.
854 + if ( defined('DOING_AUTOSAVE') and DOING_AUTOSAVE ) :
855 + return $post_id;
856 + endif;
857 +
858 + // Check permissions
859 + if ( !current_user_can( 'edit_'.$_POST['post_type'], $post_id) ) :
860 + return $post_id;
861 + endif;
862 +
863 + // OK, we're golden. Now let's save some data.
864 + if (isset($_POST['freeze_updates'])) :
865 + update_post_meta($post_id, '_syndication_freeze_updates', $_POST['freeze_updates']);
866 + $ret = $_POST['freeze_updates'];
867 + else :
868 + delete_post_meta($post_id, '_syndication_freeze_updates');
869 + $ret = NULL;
870 + endif;
871 +
872 + return $ret;
873 + } // function feedwordpress_save_edit_controls
874 +
488 875 ################################################################################
489 876 ## class FeedWordPress #########################################################
490 877 ################################################################################
491 878
@@ -529,9 +916,9 @@
529 916 function FeedWordPress () {
530 917 $this->feeds = array ();
531 918 $links = FeedWordPress::syndicated_links();
532 919 if ($links): foreach ($links as $link):
533 - $this->feeds[] =& new SyndicatedLink($link);
920 + $this->feeds[] = new SyndicatedLink($link);
534 921 endforeach; endif;
535 922 } // FeedWordPress::FeedWordPress ()
536 923
537 924 # function update (): polls for updates on one or more Contributor feeds
@@ -589,9 +976,9 @@
589 976 if (FeedWordPress::needs_upgrade()) : // Will make duplicate posts if we don't hold off
590 977 return NULL;
591 978 endif;
592 979
593 - if (!is_null($uri)) :
980 + if (!is_null($uri) and $uri != '*') :
594 981 $uri = trim($uri);
595 982 else : // Update all
596 983 update_option('feedwordpress_last_update_all', time());
597 984 endif;
@@ -598,20 +985,17 @@
598 985
599 986 do_action('feedwordpress_update', $uri);
600 987
601 988 if (is_null($crash_ts)) :
602 - $crash_dt = (int) get_option('feedwordpress_update_time_limit');
603 - if ($crash_dt > 0) :
604 - $crash_ts = time() + $crash_dt;
605 - else :
606 - $crash_ts = NULL;
607 - endif;
989 + $crash_ts = $this->crash_ts();
608 990 endif;
609 -
991 +
610 992 // Randomize order for load balancing purposes
611 993 $feed_set = $this->feeds;
612 994 shuffle($feed_set);
613 995
996 + $feed_set = apply_filters('feedwordpress_update_feeds', $feed_set, $uri);
997 +
614 998 // Loop through and check for new posts
615 999 $delta = NULL;
616 1000 foreach ($feed_set as $feed) :
617 1001 if (!is_null($crash_ts) and (time() > $crash_ts)) : // Check whether we've exceeded the time limit
@@ -617,9 +1001,9 @@
617 1001 if (!is_null($crash_ts) and (time() > $crash_ts)) : // Check whether we've exceeded the time limit
618 1002 break;
619 1003 endif;
620 1004
621 - $pinged_that = (is_null($uri) or in_array($uri, array($feed->uri(), $feed->homepage())));
1005 + $pinged_that = (is_null($uri) or ($uri=='*') or in_array($uri, array($feed->uri(), $feed->homepage())));
622 1006
623 1007 if (!is_null($uri)) : // A site-specific ping always updates
624 1008 $timely = true;
625 1009 else :
@@ -625,9 +1009,9 @@
625 1009 else :
626 1010 $timely = $feed->stale();
627 1011 endif;
628 1012
629 - if ($pinged_that and is_null($delta)) : // If at least one feed was hit for updating...
1013 + if ($pinged_that and is_null($delta)) : // If at least one feed was hit for updating...
630 1014 $delta = array('new' => 0, 'updated' => 0); // ... don't return error condition
631 1015 endif;
632 1016
633 1017 if ($pinged_that and $timely) :
@@ -635,10 +1019,12 @@
635 1019 $start_ts = time();
636 1020 $added = $feed->poll($crash_ts);
637 1021 do_action('feedwordpress_check_feed_complete', $feed->settings, $added, time() - $start_ts);
638 1022
639 - if (isset($added['new'])) : $delta['new'] += $added['new']; endif;
640 - if (isset($added['updated'])) : $delta['updated'] += $added['updated']; endif;
1023 + if (is_array($added)) : // Success
1024 + if (isset($added['new'])) : $delta['new'] += $added['new']; endif;
1025 + if (isset($added['updated'])) : $delta['updated'] += $added['updated']; endif;
1026 + endif;
641 1027 endif;
642 1028 endforeach;
643 1029
644 1030 do_action('feedwordpress_update_complete', $delta);
@@ -645,10 +1031,23 @@
645 1031
646 1032 return $delta;
647 1033 }
648 1034
1035 + function crash_ts ($default = NULL) {
1036 + $crash_dt = (int) get_option('feedwordpress_update_time_limit', 0);
1037 + if ($crash_dt > 0) :
1038 + $crash_ts = time() + $crash_dt;
1039 + else :
1040 + $crash_ts = $default;
1041 + endif;
1042 + return $crash_ts;
1043 + }
1044 +
649 1045 function stale () {
650 1046 if (get_option('feedwordpress_automatic_updates')) :
1047 + // Do our best to avoid possible simultaneous
1048 + // updates by getting up-to-the-minute settings.
1049 +
651 1050 $last = get_option('feedwordpress_last_update_all');
652 1051
653 1052 // If we haven't updated all yet, give it a time window
654 1053 if (false === $last) :
@@ -664,73 +1063,208 @@
664 1063 $ret = ( (time() - $last) > $freshness);
665 1064
666 1065 // This should never happen.
667 1066 else :
668 - FeedWordPress::critical_bug('FeedWordPress::stale::last', $last, __LINE__);
1067 + FeedWordPress::critical_bug('FeedWordPress::stale::last', $last, __LINE__, __FILE__);
669 1068 endif;
670 1069
671 - // Explicit request for an update (e.g. from a cron job).
672 - elseif (FeedWordPress::update_requested()) :
673 - $ret = true;
674 -
675 1070 else :
676 1071 $ret = false;
677 1072 endif;
678 1073 return $ret;
679 1074 } // FeedWordPress::stale()
1075 +
1076 + function init () {
1077 + $this->clear_cache_magic_url();
1078 + $this->update_magic_url();
1079 + } /* FeedWordPress::init() */
680 1080
1081 + function dashboard_setup () {
1082 + $see_it = FeedWordPress::menu_cap();
1083 +
1084 + if (current_user_can($see_it)) :
1085 + // Get the stylesheet
1086 + wp_enqueue_style('feedwordpress-elements');
1087 +
1088 + $widget_id = 'feedwordpress_dashboard';
1089 + $widget_name = __('Syndicated Sources');
1090 + $column = 'side';
1091 + $priority = 'core';
1092 +
1093 + // I would love to use wp_add_dashboard_widget() here and save
1094 + // myself some trouble. But WP 3 does not yet have any way to
1095 + // push a dashboard widget onto the side, or to give it a default
1096 + // location.
1097 + add_meta_box(
1098 + /*id=*/ $widget_id,
1099 + /*title=*/ $widget_name,
1100 + /*callback=*/ array(&$this, 'dashboard'),
1101 + /*page=*/ 'dashboard',
1102 + /*context=*/ $column,
1103 + /*priority=*/ $priority
1104 + );
1105 + /*control_callback= array(&$this, 'dashboard_control') */
1106 +
1107 + // This is kind of rude, I know, but the dashboard widget isn't
1108 + // worth much if users don't know that it exists, and I don't
1109 + // know of any better way to reorder the boxen.
1110 + //
1111 + // Gleefully ripped off of codex.wordpress.org/Dashboard_Widgets_API
1112 +
1113 + // Globalize the metaboxes array, this holds all the widgets for wp-admin
1114 + global $wp_meta_boxes;
1115 +
1116 + // Get the regular dashboard widgets array
1117 + // (which has our new widget already but at the end)
1118 +
1119 + $normal_dashboard = $wp_meta_boxes['dashboard'][$column][$priority];
1120 +
1121 + // Backup and delete our new dashbaord widget from the end of the array
1122 + if (isset($normal_dashboard[$widget_id])) :
1123 + $backup = array();
1124 + $backup[$widget_id] = $normal_dashboard[$widget_id];
1125 + unset($normal_dashboard[$widget_id]);
1126 +
1127 + // Merge the two arrays together so our widget is at the
1128 + // beginning
1129 + $sorted_dashboard = array_merge($backup, $normal_dashboard);
1130 +
1131 + // Save the sorted array back into the original metaboxes
1132 + $wp_meta_boxes['dashboard'][$column][$priority] = $sorted_dashboard;
1133 + endif;
1134 + endif;
1135 + } /* FeedWordPress::dashboard_setup () */
1136 +
1137 + function dashboard () {
1138 + $syndicationPage = new FeedWordPressSyndicationPage(dirname(__FILE__).'/syndication.php');
1139 + $syndicationPage->dashboard_box($syndicationPage);
1140 + } /* FeedWordPress::dashboard () */
1141 +
1142 + function update_magic_url () {
1143 + global $wpdb;
1144 +
1145 + // Explicit update request in the HTTP request (e.g. from a cron job)
1146 + if ($this->update_requested()) :
1147 + $this->update($this->update_requested_url());
1148 +
1149 + if (FEEDWORDPRESS_DEBUG and count($wpdb->queries) > 0) :
1150 + $mysqlTime = 0.0;
1151 + $byTime = array();
1152 + foreach ($wpdb->queries as $query) :
1153 + $time = $query[1] * 1000000.0;
1154 + $mysqlTime += $query[1];
1155 + if (!isset($byTime[$time])) : $byTime[$time] = array(); endif;
1156 + $byTime[$time][] = $query[0]. ' // STACK: ' . $query[2];
1157 + endforeach;
1158 + krsort($byTime);
1159 +
1160 + foreach ($byTime as $time => $querySet) :
1161 + foreach ($querySet as $query) :
1162 + print "[".(sprintf('%4.4f', $time/1000.0)) . "ms] $query\n";
1163 + endforeach;
1164 + endforeach;
1165 + echo $this->log_prefix()."$wpdb->num_queries queries. $mysqlTime seconds in MySQL. Total of "; timer_stop(1); print " seconds.";
1166 + endif;
1167 +
1168 + debug_out_feedwordpress_footer();
1169 +
1170 + // Magic URL should return nothing but a 200 OK header packet
1171 + // when successful.
1172 + exit;
1173 + endif;
1174 + } /* FeedWordPress::magic_update_url () */
1175 +
1176 + function clear_cache_magic_url () {
1177 + if ($this->clear_cache_requested()) :
1178 + $this->clear_cache();
1179 + endif;
1180 + } /* FeedWordPress::clear_cache_magic_url() */
1181 +
1182 + function clear_cache_requested () {
1183 + return (
1184 + isset($_GET['clear_cache'])
1185 + and $_GET['clear_cache']
1186 + );
1187 + } /* FeedWordPress::clear_cache_requested() */
1188 +
681 1189 function update_requested () {
682 - return (isset($_REQUEST['update_feedwordpress']) and $_REQUEST['update_feedwordpress']);
1190 + return (
1191 + isset($_REQUEST['update_feedwordpress'])
1192 + and $_REQUEST['update_feedwordpress']
1193 + );
683 1194 } // FeedWordPress::update_requested()
684 1195
685 - function syndicate_link ($name, $uri, $rss) {
1196 + function update_requested_url () {
1197 + $ret = null;
1198 +
1199 + if (($_REQUEST['update_feedwordpress']=='*')
1200 + or (preg_match('|^http://.*|i', $_REQUEST['update_feedwordpress']))) :
1201 + $ret = $_REQUEST['update_feedwordpress'];
1202 + endif;
1203 +
1204 + return $ret;
1205 + } // FeedWordPress::update_requested_url()
1206 +
1207 + function auto_update () {
1208 + if ($this->stale()) :
1209 + $this->update();
1210 + endif;
1211 + } /* FeedWordPress::auto_update () */
1212 +
1213 + function find_link ($uri, $field = 'link_rss') {
686 1214 global $wpdb;
687 1215
1216 + $unslashed = untrailingslashit($uri);
1217 + $slashed = trailingslashit($uri);
1218 + $link_id = $wpdb->get_var($wpdb->prepare("
1219 + SELECT link_id FROM $wpdb->links WHERE $field IN ('%s', '%s')
1220 + LIMIT 1", $unslashed, $slashed
1221 + ));
1222 +
1223 + return $link_id;
1224 + } /* FeedWordPress::find_link () */
1225 +
1226 + function syndicate_link ($name, $uri, $rss) {
688 1227 // Get the category ID#
689 1228 $cat_id = FeedWordPress::link_category_id();
690 -
1229 + if (!is_wp_error($cat_id)) :
1230 + $link_category = array($cat_id);
1231 + else :
1232 + $link_category = array();
1233 + endif;
1234 +
691 1235 // WordPress gets cranky if there's no homepage URI
692 - if (!isset($uri) or strlen($uri)<1) : $uri = $rss; endif;
1236 + if (!is_string($uri) or strlen($uri)<1) : $uri = $rss; endif;
693 1237
694 - if (function_exists('wp_insert_link')) { // WordPress 2.x
695 - $link_id = wp_insert_link(array(
696 - "link_name" => $name,
697 - "link_url" => $uri,
698 - "link_category" => array($cat_id),
699 - "link_rss" => $rss
700 - ));
701 - } else { // WordPress 1.5.x
702 - $result = $wpdb->query("
703 - INSERT INTO $wpdb->links
704 - SET
705 - link_name = '".$wpdb->escape($name)."',
706 - link_url = '".$wpdb->escape($uri)."',
707 - link_category = '".$wpdb->escape($cat_id)."',
708 - link_rss = '".$wpdb->escape($rss)."'
709 - ");
710 - $link_id = $wpdb->insert_id;
711 - } // if
1238 + // Check if this feed URL is already being syndicated.
1239 + $link_id = wp_insert_link(array(
1240 + "link_id" => FeedWordPress::find_link($rss), // insert if nothing was found; else update
1241 + "link_rss" => $rss,
1242 + "link_name" => $name,
1243 + "link_url" => $uri,
1244 + "link_category" => $link_category,
1245 + "link_visible" => 'Y', // reactivate if inactivated
1246 + ));
1247 +
712 1248 return $link_id;
713 - } // function FeedWordPress::syndicate_link()
1249 + } /* function FeedWordPress::syndicate_link() */
714 1250
715 - function on_unfamiliar ($what = 'author', $override = NULL) {
716 - $set = array(
717 - 'author' => array('create', 'default', 'filter'),
718 - 'category' => array('create', 'tag', 'default', 'filter'),
719 - );
720 -
721 - if (is_string($override)) :
722 - $ret = strtolower($override);
1251 + /*static*/ function syndicated_status ($what, $default) {
1252 + $ret = get_option("feedwordpress_syndicated_{$what}_status");
1253 + if (!$ret) :
1254 + $ret = $default;
723 1255 endif;
1256 + return $ret;
1257 + } /* FeedWordPress::syndicated_status() */
724 1258
725 - if (!is_numeric($override) and !in_array($ret, $set[$what])) :
726 - $ret = get_option('feedwordpress_unfamiliar_'.$what);
727 - if (!is_numeric($ret) and !in_array($ret, $set[$what])) :
728 - $ret = 'create';
729 - endif;
730 - endif;
731 -
732 - return $ret;
1259 + function on_unfamiliar ($what = 'author') {
1260 + switch ($what) :
1261 + case 'category' : $suffix = ':category'; break;
1262 + case 'post_tag' : $suffix = ':post_tag'; break;
1263 + default: $suffix = '';
1264 + endswitch;
1265 +
1266 + return get_option('feedwordpress_unfamiliar_'.$what, 'create'.$suffix);
733 1267 } // function FeedWordPress::on_unfamiliar()
734 1268
735 1269 function null_email_set () {
736 1270 $base = get_option('feedwordpress_null_email_set');
@@ -756,14 +1290,28 @@
756 1290 $ret = get_option('feedwordpress_use_aggregator_source_data');
757 1291 return apply_filters('syndicated_post_use_aggregator_source_data', ($ret=='yes'));
758 1292 }
759 1293
760 - function syndicated_links () {
1294 + /**
1295 + * FeedWordPress::munge_permalinks: check whether or not FeedWordPress
1296 + * should rewrite permalinks for syndicated items to reflect their
1297 + * original location.
1298 + *
1299 + * @return bool TRUE if FeedWordPress SHOULD rewrite permalinks; FALSE otherwise
1300 + */
1301 + /*static*/ function munge_permalinks () {
1302 + return (get_option('feedwordpress_munge_permalink', /*default=*/ 'yes') != 'no');
1303 + } /* FeedWordPress::munge_permalinks() */
1304 +
1305 + function syndicated_links ($args = array()) {
761 1306 $contributors = FeedWordPress::link_category_id();
762 - if (function_exists('get_bookmarks')) :
763 - $links = get_bookmarks(array("category" => $contributors));
764 - else:
765 - $links = get_linkobjects($contributors); // deprecated as of WP 2.1
1307 + if (!is_wp_error($contributors)) :
1308 + $links = get_bookmarks(array_merge(
1309 + array("category" => $contributors),
1310 + $args
1311 + ));
1312 + else :
1313 + $links = array();
766 1314 endif;
767 1315 return $links;
768 1316 } // function FeedWordPress::syndicated_links()
769 1317
@@ -771,61 +1319,32 @@
771 1319 global $wpdb, $wp_db_version;
772 1320
773 1321 $cat_id = get_option('feedwordpress_cat_id');
774 1322
775 - // If we don't yet *have* the category, we'll have to create it
776 - if ($cat_id === false) :
777 - $cat = $wpdb->escape(DEFAULT_SYNDICATION_CATEGORY);
778 -
779 - // Look for something with the right name...
780 - // -----------------------------------------
1323 + // If we don't yet have the category ID stored, search by name
1324 + if (!$cat_id) :
1325 + $cat_id = FeedWordPressCompatibility::link_category_id(DEFAULT_SYNDICATION_CATEGORY);
781 1326
782 - // WordPress 2.3 introduces a new taxonomy/term API
783 - if (function_exists('is_term')) :
784 - $cat_id = is_term($cat, 'link_category');
785 - // WordPress 2.1 and 2.2 use a common table for both link and post categories
786 - elseif (isset($wp_db_version) and ($wp_db_version >= FWP_SCHEMA_21 and $wp_db_version < FWP_SCHEMA_23) ) :
787 - $cat_id = $wpdb->get_var("SELECT cat_id FROM {$wpdb->categories} WHERE cat_name='$cat'");
788 - // WordPress 1.5 and 2.0.x have a separate table for link categories
789 - elseif (!isset($wp_db_version) or $wp_db_version < FWP_SCHEMA_21) :
790 - $cat_id = $wpdb->get_var("SELECT cat_id FROM {$wpdb->linkcategories} WHERE cat_name='$cat'");
791 - // This should never happen.
792 - else :
793 - FeedWordPress::critical_bug('FeedWordPress::link_category_id::wp_db_version', $wp_db_version, __LINE__);
1327 + if ($cat_id) :
1328 + // We found it; let's stamp it.
1329 + update_option('feedwordpress_cat_id', $cat_id);
794 1330 endif;
795 1331
796 - // If you still can't find anything, make it for yourself.
797 - // -------------------------------------------------------
798 - if (!$cat_id) :
799 - // WordPress 2.3+ term/taxonomy API
800 - if (function_exists('wp_insert_term')) :
801 - $term = wp_insert_term($cat, 'link_category');
802 - $cat_id = $term['term_id'];
803 - // WordPress 2.1, 2.2 category API. By the way, why the fuck is this API function only available in a wp-admin module?
804 - elseif (function_exists('wp_insert_category')) :
805 - $cat_id = wp_insert_category(array('cat_name' => $cat));
806 - // WordPress 1.5 and 2.0.x
807 - elseif (!isset($wp_db_version) or $wp_db_version < FWP_SCHEMA_21) :
808 - $result = $wpdb->query("
809 - INSERT INTO $wpdb->linkcategories
810 - SET
811 - cat_id = 0,
812 - cat_name='$cat',
813 - show_images='N',
814 - show_description='N',
815 - show_rating='N',
816 - show_updated='N',
817 - sort_order='name'
818 - ");
819 - $cat_id = $wpdb->insert_id;
820 - // This should never happen.
821 - else :
822 - FeedWordPress::critical_bug('FeedWordPress::link_category_id::wp_db_version', $wp_db_version, __LINE__);
823 - endif;
1332 + // If we *do* have the category ID stored, verify that it exists
1333 + else :
1334 + $cat_id = FeedWordPressCompatibility::link_category_id((int) $cat_id, 'cat_id');
1335 + endif;
1336 +
1337 + // If we could not find an appropriate link category,
1338 + // make a new one for ourselves.
1339 + if (!$cat_id) :
1340 + $cat_id = FeedWordPressCompatibility::insert_link_category(DEFAULT_SYNDICATION_CATEGORY);
1341 + if (!is_wp_error($cat_id)) :
1342 + // Stamp it
1343 + update_option('feedwordpress_cat_id', $cat_id);
824 1344 endif;
1345 + endif;
825 1346
826 - update_option('feedwordpress_cat_id', $cat_id);
827 - endif;
828 1347 return $cat_id;
829 1348 } // function FeedWordPress::link_category_id()
830 1349
831 1350 # Upgrades and maintenance...
@@ -835,12 +1354,9 @@
835 1354 $ret = false; // innocent until proven guilty
836 1355 if (!$fwp_db_version or $fwp_db_version < FEEDWORDPRESS_VERSION) :
837 1356 // This is an older version or a fresh install. Does it
838 1357 // require a database upgrade or database initialization?
839 - if ($fwp_db_version > 0.96) :
840 - // No. Just brand it with the new version.
841 - update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
842 - else :
1358 + if ($fwp_db_version <= 0.96) :
843 1359 // Yes. Check to see whether this is a fresh install or an upgrade.
844 1360 $syn = $wpdb->get_col("
845 1361 SELECT post_id
846 1362 FROM $wpdb->postmeta
@@ -850,8 +1366,53 @@
850 1366 $ret = true;
851 1367 else : // fresh install; brand it as ours
852 1368 update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
853 1369 endif;
1370 + elseif ($fwp_db_version < 2009.0707) :
1371 + // We need to clear out any busted AJAX crap
1372 + $wpdb->query("
1373 + DELETE FROM $wpdb->usermeta
1374 + WHERE LOCATE('feedwordpress', meta_key)
1375 + AND LOCATE('box', meta_key);
1376 + ");
1377 +
1378 + update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
1379 + elseif ($fwp_db_version < 2010.0814) :
1380 + // Change in terminology.
1381 + if (get_option('feedwordpress_unfamiliar_category', 'create')=='default') :
1382 + update_option('feedwordpress_unfamiliar_category', 'null');
1383 + endif;
1384 + foreach (FeedWordPress::syndicated_links() as $link) :
1385 + $sub = new SyndicatedLink($link);
1386 +
1387 + $remap_uf = array(
1388 + 'default' => 'null',
1389 + 'filter' => 'null',
1390 + 'create' => 'create:category',
1391 + 'tag' => 'create:post_tag'
1392 + );
1393 + if (isset($sub->settings['unfamiliar category'])) :
1394 + if ($sub->settings['unfamiliar category']=='filter') :
1395 + $sub->settings['match/filter'] = array('category');
1396 + endif;
1397 + foreach ($remap_uf as $from => $to) :
1398 + if ($sub->settings['unfamiliar category']==$from) :
1399 + $sub->settings['unfamiliar category'] = $to;
1400 + endif;
1401 + endforeach;
1402 + endif;
1403 +
1404 + if (isset($sub->settings['add global categories'])) :
1405 + $sub->settings['add/category'] = $sub->settings['add global categories'];
1406 + unset($sub->settings['add global categories']);
1407 + endif;
1408 +
1409 + $sub->save_settings(/*reload=*/ true);
1410 + endforeach;
1411 + update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
1412 + else :
1413 + // No. Just brand it with the new version.
1414 + update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
854 1415 endif;
855 1416 endif;
856 1417 return $ret;
857 1418 }
@@ -861,56 +1422,14 @@
861 1422
862 1423 if (is_null($from) or $from <= 0.96) : $from = 0.96; endif;
863 1424
864 1425 switch ($from) :
865 - case 0.96: // account for changes to syndication custom values and guid
866 - echo "<p>Upgrading database from {$from} to ".FEEDWORDPRESS_VERSION."...</p>\n";
1426 + case 0.96:
1427 + // Dropping legacy upgrade code. If anyone is still
1428 + // using 0.96 and just now decided to upgrade, well, I'm
1429 + // sorry about that. You'll just have to cope with a few
1430 + // duplicate posts.
867 1431
868 - $cat_id = FeedWordPress::link_category_id();
869 -
870 - // Avoid duplicates
871 - $wpdb->query("DELETE FROM `{$wpdb->postmeta}` WHERE meta_key = 'syndication_feed_id'");
872 -
873 - // Look up all the link IDs
874 - $wpdb->query("
875 - CREATE TEMPORARY TABLE tmp_custom_values
876 - SELECT
877 - NULL AS meta_id,
878 - post_id,
879 - 'syndication_feed_id' AS meta_key,
880 - link_id AS meta_value
881 - FROM `{$wpdb->postmeta}`, `{$wpdb->links}`
882 - WHERE
883 - meta_key='syndication_feed'
884 - AND meta_value=link_rss
885 - AND link_category = {$cat_id}
886 - ");
887 -
888 - // Now attach them to their posts
889 - $wpdb->query("INSERT INTO `{$wpdb->postmeta}` SELECT * FROM tmp_custom_values");
890 -
891 - // And clean up after ourselves.
892 - $wpdb->query("DROP TABLE tmp_custom_values");
893 -
894 - // Now fix the guids to avoid duplicate posts
895 - echo "<ul>";
896 - foreach ($this->feeds as $feed) :
897 - echo "<li>Fixing post meta-data for <cite>".$feed['link/name']."</cite> &#8230; "; flush();
898 - $rss = @fetch_rss($feed['link/uri']);
899 - if (is_array($rss->items)) :
900 - foreach ($rss->items as $item) :
901 - $guid = $wpdb->escape(FeedWordPress::guid($item, $feed)); // new GUID algorithm
902 - $link = $wpdb->escape($item['link']);
903 -
904 - $wpdb->query("
905 - UPDATE `{$wpdb->posts}` SET guid='{$guid}' WHERE guid='{$link}'
906 - ");
907 - endforeach;
908 - endif;
909 - echo "<strong>complete.</strong></li>\n";
910 - endforeach;
911 - echo "</ul>\n";
912 -
913 1432 // Mark the upgrade as successful.
914 1433 update_option('feedwordpress_version', FEEDWORDPRESS_VERSION);
915 1434 endswitch;
916 1435 echo "<p>Upgrade complete. FeedWordPress is now ready to use again.</p>";
@@ -915,8 +1434,27 @@
915 1434 endswitch;
916 1435 echo "<p>Upgrade complete. FeedWordPress is now ready to use again.</p>";
917 1436 } /* FeedWordPress::upgrade_database() */
918 1437
1438 + function has_guid_index () {
1439 + global $wpdb;
1440 +
1441 + $found = false; // Guilty until proven innocent.
1442 +
1443 + $results = $wpdb->get_results("
1444 + SHOW INDEXES FROM {$wpdb->posts}
1445 + ");
1446 + if ($results) :
1447 + foreach ($results as $index) :
1448 + if (isset($index->Column_name)
1449 + and ('guid' == $index->Column_name)) :
1450 + $found = true;
1451 + endif;
1452 + endforeach;
1453 + endif;
1454 + return $found;
1455 + } /* FeedWordPress::has_guid_index () */
1456 +
919 1457 function create_guid_index () {
920 1458 global $wpdb;
921 1459
922 1460 $wpdb->query("
@@ -923,1899 +1461,719 @@
923 1461 CREATE INDEX {$wpdb->posts}_guid_idx ON {$wpdb->posts}(guid)
924 1462 ");
925 1463 } /* FeedWordPress::create_guid_index () */
926 1464
927 - # Utility functions for handling text settings
928 - function negative ($f, $setting) {
929 - $nego = array ('n', 'no', 'f', 'false');
930 - return (isset($f[$setting]) and in_array(strtolower($f[$setting]), $nego));
1465 + function remove_guid_index () {
1466 + global $wpdb;
1467 +
1468 + $wpdb->query("
1469 + DROP INDEX {$wpdb->posts}_guid_idx ON {$wpdb->posts}
1470 + ");
931 1471 }
932 1472
933 - function affirmative ($f, $setting) {
934 - $affirmo = array ('y', 'yes', 't', 'true', 1);
935 - return (isset($f[$setting]) and in_array(strtolower($f[$setting]), $affirmo));
1473 + /*static*/ function fetch_timeout () {
1474 + return apply_filters(
1475 + 'feedwordpress_fetch_timeout',
1476 + intval(get_option('feedwordpress_fetch_timeout', FEEDWORDPRESS_FETCH_TIMEOUT_DEFAULT))
1477 + );
936 1478 }
937 -
938 -
939 - # Internal debugging functions
940 - function critical_bug ($varname, $var, $line) {
941 - global $wp_version;
942 -
943 - echo '<p>There may be a bug in FeedWordPress. Please <a href="'.FEEDWORDPRESS_AUTHOR_CONTACT.'">contact the author</a> and paste the following information into your e-mail:</p>';
944 - echo "\n<plaintext>";
945 - echo "Triggered at line # ".$line."\n";
946 - echo "FeedWordPress version: ".FEEDWORDPRESS_VERSION."\n";
947 - echo "WordPress version: $wp_version\n";
948 - echo "PHP version: ".phpversion()."\n";
949 - echo "\n";
950 - echo $varname.": "; var_dump($var); echo "\n";
951 - die;
952 - }
953 -} // class FeedWordPress
954 -
955 -class SyndicatedPost {
956 - var $item = null;
957 1479
958 - var $link = null;
959 - var $feed = null;
960 - var $feedmeta = null;
961 -
962 - var $post = array ();
963 - var $_base = null;
1480 + /*static*/ function fetch ($url, $params = array()) {
1481 + $force_feed = true; // Default
964 1482
965 - var $_freshness = null;
966 - var $_wp_id = null;
967 -
968 - function SyndicatedPost ($item, $link) {
969 - global $wpdb;
970 -
971 - $this->link = $link;
972 - $feedmeta = $link->settings;
973 - $feed = $link->magpie;
974 -
975 - # This is ugly as all hell. I'd like to use apply_filters()'s
976 - # alleged support for a variable argument count, but this seems
977 - # to have been broken in WordPress 1.5. It'll be fixed somehow
978 - # in WP 1.5.1, but I'm aiming at WP 1.5 compatibility across
979 - # the board here.
980 - #
981 - # Cf.: <http://mosquito.wordpress.org/view.php?id=901>
982 - global $fwp_channel, $fwp_feedmeta;
983 - $fwp_channel = $feed; $fwp_feedmeta = $feedmeta;
984 -
985 - $this->feed = $feed;
986 - $this->feedmeta = $feedmeta;
987 -
988 - $this->item = $item;
989 - $this->item = apply_filters('syndicated_item', $this->item, $this);
990 -
991 - # Filters can halt further processing by returning NULL
992 - if (is_null($this->item)) :
993 - $this->post = NULL;
994 - else :
995 - # Note that nothing is run through $wpdb->escape() here.
996 - # That's deliberate. The escaping is done at the point
997 - # of insertion, not here, to avoid double-escaping and
998 - # to avoid screwing with syndicated_post filters
999 -
1000 - $this->post['post_title'] = apply_filters('syndicated_item_title', $this->item['title'], $this);
1001 -
1002 - // This just gives us an alphanumeric representation of
1003 - // the author. We will look up (or create) the numeric
1004 - // ID for the author in SyndicatedPost::add()
1005 - $this->post['named']['author'] = apply_filters('syndicated_item_author', $this->author(), $this);
1006 -
1007 - # Identify content and sanitize it.
1008 - # ---------------------------------
1009 - if (isset($this->item['xhtml']['body'])) :
1010 - $content = $this->item['xhtml']['body'];
1011 - elseif (isset($this->item['xhtml']['div'])) :
1012 - $content = $this->item['xhtml']['div'];
1013 - elseif (isset($this->item['content']['encoded']) and $this->item['content']['encoded']):
1014 - $content = $this->item['content']['encoded'];
1015 - else:
1016 - $content = $this->item['description'];
1017 - endif;
1018 - $this->post['post_content'] = apply_filters('syndicated_item_content', $content, $this);
1019 -
1020 - # Identify and sanitize excerpt
1021 - $excerpt = NULL;
1022 - if ( isset($this->item['description']) and $this->item['description'] ) :
1023 - $excerpt = $this->item['description'];
1024 - elseif ( isset($content) and $content ) :
1025 - $excerpt = strip_tags($content);
1026 - if (strlen($excerpt) > 255) :
1027 - $excerpt = substr($excerpt,0,252).'...';
1028 - endif;
1029 - endif;
1030 - $excerpt = apply_filters('syndicated_item_excerpt', $excerpt, $this);
1031 -
1032 - if (!is_null($excerpt)):
1033 - $this->post['post_excerpt'] = $excerpt;
1034 - endif;
1483 + // Allow user to change default feed-fetch timeout with a global setting. Props Erigami Scholey-Fuller <http://www.piepalace.ca/blog/2010/11/feedwordpress-broke-my-heart.html> 'timeout' =>
1484 + $timeout = FeedWordPress::fetch_timeout();
1485 +
1486 + if (!is_array($params)) :
1487 + $force_feed = $params;
1488 + else : // Parameter array
1489 + $args = shortcode_atts(array(
1490 + 'force_feed' => $force_feed,
1491 + 'timeout' => $timeout
1492 + ), $params);
1035 1493
1036 - // This is unnecessary if we use wp_insert_post
1037 - if (!$this->use_api('wp_insert_post')) :
1038 - $this->post['post_name'] = sanitize_title($this->post['post_title']);
1039 - endif;
1040 -
1041 - $this->post['epoch']['issued'] = apply_filters('syndicated_item_published', $this->published(), $this);
1042 - $this->post['epoch']['created'] = apply_filters('syndicated_item_created', $this->created(), $this);
1043 - $this->post['epoch']['modified'] = apply_filters('syndicated_item_updated', $this->updated(), $this);
1044 -
1045 - // Dealing with timestamps in WordPress is so fucking fucked.
1046 - $offset = (int) get_option('gmt_offset') * 60 * 60;
1047 - $this->post['post_date'] = gmdate('Y-m-d H:i:s', $this->published() + $offset);
1048 - $this->post['post_modified'] = gmdate('Y-m-d H:i:s', $this->updated() + $offset);
1049 - $this->post['post_date_gmt'] = gmdate('Y-m-d H:i:s', $this->published());
1050 - $this->post['post_modified_gmt'] = gmdate('Y-m-d H:i:s', $this->updated());
1051 -
1052 - // Use feed-level preferences or the global default.
1053 - $this->post['post_status'] = $this->link->syndicated_status('post', 'publish');
1054 - $this->post['comment_status'] = $this->link->syndicated_status('comment', 'closed');
1055 - $this->post['ping_status'] = $this->link->syndicated_status('ping', 'closed');
1056 -
1057 - // Unique ID (hopefully a unique tag: URI); failing that, the permalink
1058 - $this->post['guid'] = apply_filters('syndicated_item_guid', $this->guid(), $this);
1059 -
1060 - // RSS 2.0 / Atom 1.0 enclosure support
1061 - if ( isset($this->item['enclosure#']) ) :
1062 - for ($i = 1; $i <= $this->item['enclosure#']; $i++) :
1063 - $eid = (($i > 1) ? "#{$id}" : "");
1064 - $this->post['meta']['enclosure'][] =
1065 - apply_filters('syndicated_item_enclosure_url', $this->item["enclosure{$eid}@url"], $this)."\n".
1066 - apply_filters('syndicated_item_enclosure_length', $this->item["enclosure{$eid}@length"], $this)."\n".
1067 - apply_filters('syndicated_item_enclosure_type', $this->item["enclosure{$eid}@type"], $this);
1068 - endfor;
1069 - endif;
1070 -
1071 - // In case you want to point back to the blog this was syndicated from
1072 - if (isset($this->feed->channel['title'])) :
1073 - $this->post['meta']['syndication_source'] = apply_filters('syndicated_item_source_title', $this->feed->channel['title'], $this);
1074 - endif;
1075 -
1076 - if (isset($this->feed->channel['link'])) :
1077 - $this->post['meta']['syndication_source_uri'] = apply_filters('syndicated_item_source_link', $this->feed->channel['link'], $this);
1078 - endif;
1079 -
1080 - // Make use of atom:source data, if present in an aggregated feed
1081 - if (isset($this->item['source_title'])) :
1082 - $this->post['meta']['syndication_source_original'] = $this->item['source_title'];
1083 - endif;
1084 -
1085 - if (isset($this->item['source_link'])) :
1086 - $this->post['meta']['syndication_source_uri_original'] = $this->item['source_link'];
1087 - endif;
1088 -
1089 - if (isset($this->item['source_id'])) :
1090 - $this->post['meta']['syndication_source_id_original'] = $this->item['source_id'];
1091 - endif;
1092 -
1093 - // Store information on human-readable and machine-readable comment URIs
1094 - if (isset($this->item['comments'])) :
1095 - $this->post['meta']['rss:comments'] = apply_filters('syndicated_item_comments', $this->item['comments']);
1096 - endif;
1097 - if (isset($this->item['wfw']['commentrss'])) :
1098 - $this->post['meta']['wfw:commentRSS'] = apply_filters('syndicated_item_commentrss', $this->item['wfw']['commentrss']);
1099 - endif;
1100 -
1101 - // Store information to identify the feed that this came from
1102 - $this->post['meta']['syndication_feed'] = $this->feedmeta['link/uri'];
1103 - $this->post['meta']['syndication_feed_id'] = $this->feedmeta['link/id'];
1104 -
1105 - if (isset($this->item['source_link_self'])) :
1106 - $this->post['meta']['syndication_feed_original'] = $this->item['source_link_self'];
1107 - endif;
1108 -
1109 - // In case you want to know the external permalink...
1110 - $this->post['meta']['syndication_permalink'] = apply_filters('syndicated_item_link', $this->item['link']);
1111 -
1112 - // Store a hash of the post content for checking whether something needs to be updated
1113 - $this->post['meta']['syndication_item_hash'] = $this->update_hash();
1114 -
1115 - // Feed-by-feed options for author and category creation
1116 - $this->post['named']['unfamiliar']['author'] = $this->feedmeta['unfamiliar author'];
1117 - $this->post['named']['unfamiliar']['category'] = $this->feedmeta['unfamiliar category'];
1118 -
1119 - // Categories: start with default categories, if any
1120 - $fc = get_option("feedwordpress_syndication_cats");
1121 - if ($fc) :
1122 - $this->post['named']['preset/category'] = explode("\n", $fc);
1123 - else :
1124 - $this->post['named']['preset/category'] = array();
1125 - endif;
1126 -
1127 - if (is_array($this->feedmeta['cats'])) :
1128 - $this->post['named']['preset/category'] = array_merge($this->post['named']['preset/category'], $this->feedmeta['cats']);
1129 - endif;
1130 -
1131 - // Now add categories from the post, if we have 'em
1132 - $this->post['named']['category'] = array();
1133 - if ( isset($this->item['category#']) ) :
1134 - for ($i = 1; $i <= $this->item['category#']; $i++) :
1135 - $cat_idx = (($i > 1) ? "#{$i}" : "");
1136 - $cat = $this->item["category{$cat_idx}"];
1137 -
1138 - if ( isset($this->feedmeta['cat_split']) and strlen($this->feedmeta['cat_split']) > 0) :
1139 - $pcre = "\007".$this->feedmeta['cat_split']."\007";
1140 - $this->post['named']['category'] = array_merge($this->post['named']['category'], preg_split($pcre, $cat, -1 /*=no limit*/, PREG_SPLIT_NO_EMPTY));
1141 - else :
1142 - $this->post['named']['category'][] = $cat;
1143 - endif;
1144 - endfor;
1145 - endif;
1146 - $this->post['named']['category'] = apply_filters('syndicated_item_categories', $this->post['named']['category'], $this);
1147 -
1148 - // Tags: start with default tags, if any
1149 - $ft = get_option("feedwordpress_syndication_tags");
1150 - if ($ft) :
1151 - $this->post['tags_input'] = explode('FEEDWORDPRESS_CAT_SEPARATOR', $ft);
1152 - else :
1153 - $this->post['tags_input'] = array();
1154 - endif;
1155 -
1156 - if (is_array($this->feedmeta['tags'])) :
1157 - $this->post['tags_input'] = array_merge($this->post['tags_input'], $this->feedmeta['tags']);
1158 - endif;
1159 -
1494 + extract($args);
1160 1495 endif;
1161 - } // SyndicatedPost::SyndicatedPost()
1162 -
1163 - function filtered () {
1164 - return is_null($this->post);
1165 - }
1166 -
1167 - function freshness () {
1168 - global $wpdb;
1169 -
1170 - if ($this->filtered()) : // This should never happen.
1171 - FeedWordPress::critical_bug('SyndicatedPost', $this, __LINE__);
1172 - endif;
1496 + $timeout = intval($timeout);
1173 1497
1174 - if (is_null($this->_freshness)) :
1175 - $guid = $wpdb->escape($this->guid());
1498 + $pie_class = apply_filters('feedwordpress_simplepie_class', 'SimplePie');
1499 + $cache_class = apply_filters('feedwordpress_cache_class', 'WP_Feed_Cache');
1500 + $file_class = apply_filters('feedwordpress_file_class', 'FeedWordPress_File');
1501 + $parser_class = apply_filters('feedwordpress_parser_class', 'FeedWordPress_Parser');
1176 1502
1177 - $result = $wpdb->get_row("
1178 - SELECT id, guid, post_modified_gmt
1179 - FROM $wpdb->posts WHERE guid='$guid'
1180 - ");
1503 + $sniffer_class = apply_filters('feedwordpress_sniffer_class', 'FeedWordPress_Content_Type_Sniffer');
1181 1504
1182 - if (!$result) :
1183 - $this->_freshness = 2; // New content
1184 - else:
1185 - $stored_update_hashes = get_post_custom_values('syndication_item_hash', $result->id);
1186 - if (count($stored_update_hashes) > 0) :
1187 - $stored_update_hash = $stored_update_hashes[0];
1188 - $update_hash_changed = ($stored_update_hash != $this->update_hash());
1189 - else :
1190 - $update_hash_changed = false;
1191 - endif;
1192 -
1193 - preg_match('/([0-9]+)-([0-9]+)-([0-9]+) ([0-9]+):([0-9]+):([0-9]+)/', $result->post_modified_gmt, $backref);
1194 -
1195 - $last_rev_ts = gmmktime($backref[4], $backref[5], $backref[6], $backref[2], $backref[3], $backref[1]);
1196 - $updated_ts = $this->updated(/*fallback=*/ true, /*default=*/ NULL);
1197 - $updated = ((
1198 - !is_null($updated_ts)
1199 - and ($updated_ts > $last_rev_ts)
1200 - ) or $update_hash_changed);
1201 -
1202 - if ($updated) :
1203 - $this->_freshness = 1; // Updated content
1204 - $this->_wp_id = $result->id;
1205 - else :
1206 - $this->_freshness = 0; // Same old, same old
1207 - $this->_wp_id = $result->id;
1208 - endif;
1209 - endif;
1210 - endif;
1211 - return $this->_freshness;
1212 - }
1213 -
1214 - function wp_id () {
1215 - if ($this->filtered()) : // This should never happen.
1216 - FeedWordPress::critical_bug('SyndicatedPost', $this, __LINE__);
1217 - endif;
1505 + $feed = new $pie_class;
1506 + $feed->set_feed_url($url);
1507 + $feed->set_cache_class($cache_class);
1508 + $feed->set_timeout($timeout);
1218 1509
1219 - if (is_null($this->_wp_id) and is_null($this->_freshness)) :
1220 - $fresh = $this->freshness(); // sets WP DB id in the process
1221 - endif;
1222 - return $this->_wp_id;
1223 - }
1224 -
1225 - function store () {
1226 - global $wpdb;
1227 -
1228 - if ($this->filtered()) : // This should never happen.
1229 - FeedWordPress::critical_bug('SyndicatedPost', $this, __LINE__);
1230 - endif;
1510 + //$feed->set_file_class('WP_SimplePie_File');
1511 + $feed->set_content_type_sniffer_class($sniffer_class);
1512 + $feed->set_file_class($file_class);
1513 + $feed->set_parser_class($parser_class);
1514 + $feed->force_feed($force_feed);
1515 + $feed->set_cache_duration(FeedWordPress::cache_duration());
1516 + $feed->init();
1517 + $feed->handle_content_type();
1231 1518
1232 - $freshness = $this->freshness();
1233 - if ($freshness > 0) :
1234 - # -- Look up, or create, numeric ID for author
1235 - $this->post['post_author'] = $this->author_id (
1236 - FeedWordPress::on_unfamiliar('author', $this->post['named']['unfamiliar']['author'])
1237 - );
1238 -
1239 - if (is_null($this->post['post_author'])) :
1240 - $this->post = NULL;
1241 - endif;
1242 - endif;
1243 -
1244 - if (!$this->filtered() and $freshness > 0) :
1245 - # -- Look up, or create, numeric ID for categories
1246 - list($pcats, $ptags) = $this->category_ids (
1247 - $this->post['named']['category'],
1248 - FeedWordPress::on_unfamiliar('category', $this->post['named']['unfamiliar']['category']),
1249 - /*tags_too=*/ true
1250 - );
1251 -
1252 - $this->post['post_category'] = $pcats;
1253 - $this->post['tags_input'] = array_merge($this->post['tags_input'], $ptags);
1254 -
1255 - if (is_null($this->post['post_category'])) :
1256 - // filter mode on, no matching categories; drop the post
1257 - $this->post = NULL;
1258 - else :
1259 - // filter mode off or at least one match; now add on the feed and global presets
1260 - $this->post['post_category'] = array_merge (
1261 - $this->post['post_category'],
1262 - $this->category_ids (
1263 - $this->post['named']['preset/category'],
1264 - 'default'
1265 - )
1266 - );
1267 -
1268 - if (count($this->post['post_category']) < 1) :
1269 - $this->post['post_category'][] = 1; // Default to category 1 ("Uncategorized" / "General") if nothing else
1270 - endif;
1271 - endif;
1272 - endif;
1273 -
1274 - if (!$this->filtered() and $freshness > 0) :
1275 - unset($this->post['named']);
1276 - $this->post = apply_filters('syndicated_post', $this->post, $this);
1277 - endif;
1278 -
1279 - if (!$this->filtered() and $freshness == 2) :
1280 - // The item has not yet been added. So let's add it.
1281 - $this->insert_new();
1282 - $this->add_rss_meta();
1283 - do_action('post_syndicated_item', $this->wp_id());
1284 -
1285 - $ret = 'new';
1286 - elseif (!$this->filtered() and $freshness == 1) :
1287 - $this->post['ID'] = $this->wp_id();
1288 - $this->update_existing();
1289 - $this->add_rss_meta();
1290 - do_action('update_syndicated_item', $this->wp_id());
1291 -
1292 - $ret = 'updated';
1519 + if ($feed->error()) :
1520 + $ret = new WP_Error('simplepie-error', $feed->error());
1293 1521 else :
1294 - $ret = false;
1522 + $ret = $feed;
1295 1523 endif;
1296 -
1297 1524 return $ret;
1298 - } // function SyndicatedPost::store ()
1525 + } /* FeedWordPress::fetch () */
1299 1526
1300 - function insert_new () {
1301 - global $wpdb, $wp_db_version;
1302 -
1303 - // Why the fuck doesn't wp_insert_post already do this?
1304 - foreach ($this->post as $key => $value) :
1305 - if (is_string($value)) :
1306 - $dbpost[$key] = $wpdb->escape($value);
1307 - else :
1308 - $dbpost[$key] = $value;
1309 - endif;
1310 - endforeach;
1311 -
1312 - if (strlen($dbpost['post_title'].$dbpost['post_content'].$dbpost['post_excerpt']) == 0) :
1313 - // FIXME: Option for filtering out empty posts
1314 - endif;
1315 - if (strlen($dbpost['post_title'])==0) :
1316 - $dbpost['post_title'] = $this->post['meta']['syndication_source']
1317 - .' '.gmdate('Y-m-d H:i:s', $this->published() + $offset);
1318 - // FIXME: Option for what to fill a blank title with...
1319 - endif;
1320 -
1321 - if ($this->use_api('wp_insert_post')) :
1322 - $dbpost['post_pingback'] = false; // Tell WP 2.1 and 2.2 not to process for pingbacks
1323 -
1324 - // This is a ridiculous fucking kludge necessitated by WordPress 2.6 munging authorship meta-data
1325 - add_action('_wp_put_post_revision', array($this, 'fix_revision_meta'));
1326 -
1327 - // Kludge to prevent kses filters from stripping the
1328 - // content of posts when updating without a logged in
1329 - // user who has `unfiltered_html` capability.
1330 - add_filter('content_save_pre', array($this, 'avoid_kses_munge'), 11);
1331 -
1332 - $this->_wp_id = wp_insert_post($dbpost);
1333 -
1334 - // Turn off ridiculous fucking kludges #1 and #2
1335 - remove_action('_wp_put_post_revision', array($this, 'fix_revision_meta'));
1336 - remove_filter('content_save_pre', array($this, 'avoid_kses_munge'), 11);
1337 -
1338 - // This should never happen.
1339 - if (!is_numeric($this->_wp_id) or ($this->_wp_id == 0)) :
1340 - FeedWordPress::critical_bug('SyndicatedPost (_wp_id problem)', array("dbpost" => $dbpost, "this" => $this), __LINE__);
1341 - endif;
1342 -
1343 - // Unfortunately, as of WordPress 2.3, wp_insert_post()
1344 - // *still* offers no way to use a guid of your choice,
1345 - // and munges your post modified timestamp, too.
1346 - $result = $wpdb->query("
1347 - UPDATE $wpdb->posts
1348 - SET
1349 - guid='{$dbpost['guid']}',
1350 - post_modified='{$dbpost['post_modified']}',
1351 - post_modified_gmt='{$dbpost['post_modified_gmt']}'
1352 - WHERE ID='{$this->_wp_id}'
1353 - ");
1354 - else :
1355 - # The right way to do this is the above. But, alas,
1356 - # in earlier versions of WordPress, wp_insert_post has
1357 - # too much behavior (mainly related to pings) that can't
1358 - # be overridden. In WordPress 1.5, it's enough of a
1359 - # resource hog to make PHP segfault after inserting
1360 - # 50-100 posts. This can get pretty annoying, especially
1361 - # if you are trying to update your feeds for the first
1362 - # time.
1363 -
1364 - $result = $wpdb->query("
1365 - INSERT INTO $wpdb->posts
1366 - SET
1367 - guid = '{$dbpost['guid']}',
1368 - post_author = '{$dbpost['post_author']}',
1369 - post_date = '{$dbpost['post_date']}',
1370 - post_date_gmt = '{$dbpost['post_date_gmt']}',
1371 - post_content = '{$dbpost['post_content']}',"
1372 - .(isset($dbpost['post_excerpt']) ? "post_excerpt = '{$dbpost['post_excerpt']}'," : "")."
1373 - post_title = '{$dbpost['post_title']}',
1374 - post_name = '{$dbpost['post_name']}',
1375 - post_modified = '{$dbpost['post_modified']}',
1376 - post_modified_gmt = '{$dbpost['post_modified_gmt']}',
1377 - comment_status = '{$dbpost['comment_status']}',
1378 - ping_status = '{$dbpost['ping_status']}',
1379 - post_status = '{$dbpost['post_status']}'
1380 - ");
1381 - $this->_wp_id = $wpdb->insert_id;
1382 -
1383 - // This should never happen.
1384 - if (!is_numeric($this->_wp_id) or ($this->_wp_id == 0)) :
1385 - FeedWordPress::critical_bug('SyndicatedPost (_wp_id problem)', array("dbpost" => $dbpost, "this" => $this), __LINE__);
1386 - endif;
1387 -
1388 - // WordPress 1.5.x - 2.0.x
1389 - wp_set_post_cats('1', $this->wp_id(), $this->post['post_category']);
1390 -
1391 - // Since we are not going through official channels, we need to
1392 - // manually tell WordPress that we've published a new post.
1393 - // We need to make sure to do this in order for FeedWordPress
1394 - // to play well with the staticize-reloaded plugin (something
1395 - // that a large aggregator website is going to *want* to be
1396 - // able to use).
1397 - do_action('publish_post', $this->_wp_id);
1398 - endif;
1399 - } /* SyndicatedPost::insert_new() */
1400 -
1401 - function update_existing () {
1527 + function clear_cache () {
1402 1528 global $wpdb;
1403 -
1404 - // Why the fuck doesn't wp_insert_post already do this?
1405 - $dbpost = array();
1406 - foreach ($this->post as $key => $value) :
1407 - if (is_string($value)) :
1408 - $dbpost[$key] = $wpdb->escape($value);
1409 - else :
1410 - $dbpost[$key] = $value;
1411 - endif;
1412 - endforeach;
1413 -
1414 - if ($this->use_api('wp_insert_post')) :
1415 - $dbpost['post_pingback'] = false; // Tell WP 2.1 and 2.2 not to process for pingbacks
1416 -
1417 - // This is a ridiculous fucking kludge necessitated by WordPress 2.6 munging authorship meta-data
1418 - add_action('_wp_put_post_revision', array($this, 'fix_revision_meta'));
1419 -
1420 - // Kludge to prevent kses filters from stripping the
1421 - // content of posts when updating without a logged in
1422 - // user who has `unfiltered_html` capability.
1423 - add_filter('content_save_pre', array($this, 'avoid_kses_munge'), 11);
1424 -
1425 - $this->_wp_id = wp_insert_post($dbpost);
1426 -
1427 - // Turn off ridiculous fucking kludges #1 and #2
1428 - remove_action('_wp_put_post_revision', array($this, 'fix_revision_meta'));
1429 - remove_filter('content_save_pre', array($this, 'avoid_kses_munge'), 11);
1430 -
1431 - // This should never happen.
1432 - if (!is_numeric($this->_wp_id) or ($this->_wp_id == 0)) :
1433 - FeedWordPress::critical_bug('SyndicatedPost (_wp_id problem)', array("dbpost" => $dbpost, "this" => $this), __LINE__);
1434 - endif;
1435 -
1436 - // Unfortunately, as of WordPress 2.3, wp_insert_post()
1437 - // munges your post modified timestamp.
1438 - $result = $wpdb->query("
1439 - UPDATE $wpdb->posts
1440 - SET
1441 - post_modified='{$dbpost['post_modified']}',
1442 - post_modified_gmt='{$dbpost['post_modified_gmt']}'
1443 - WHERE ID='{$this->_wp_id}'
1444 - ");
1445 - else :
1446 -
1447 - $result = $wpdb->query("
1448 - UPDATE $wpdb->posts
1449 - SET
1450 - post_author = '{$dbpost['post_author']}',
1451 - post_content = '{$dbpost['post_content']}',"
1452 - .(isset($dbpost['post_excerpt']) ? "post_excerpt = '{$dbpost['post_excerpt']}'," : "")."
1453 - post_title = '{$dbpost['post_title']}',
1454 - post_name = '{$dbpost['post_name']}',
1455 - post_modified = '{$dbpost['post_modified']}',
1456 - post_modified_gmt = '{$dbpost['post_modified_gmt']}'
1457 - WHERE guid='{$dbpost['guid']}'
1458 - ");
1459 -
1460 - // WordPress 2.1.x and up
1461 - if (function_exists('wp_set_post_categories')) :
1462 - wp_set_post_categories($this->wp_id(), $this->post['post_category']);
1463 - // WordPress 1.5.x - 2.0.x
1464 - elseif (function_exists('wp_set_post_cats')) :
1465 - wp_set_post_cats('1', $this->wp_id(), $this->post['post_category']);
1466 - // This should never happen.
1467 - else :
1468 - FeedWordPress::critical_bug('SyndicatedPost (_wp_id problem)', array("dbpost" => $dbpost, "this" => $this), __LINE__);
1469 - endif;
1470 -
1471 - // Since we are not going through official channels, we need to
1472 - // manually tell WordPress that we've published a new post.
1473 - // We need to make sure to do this in order for FeedWordPress
1474 - // to play well with the staticize-reloaded plugin (something
1475 - // that a large aggregator website is going to *want* to be
1476 - // able to use).
1477 - do_action('edit_post', $this->post['ID']);
1478 - endif;
1479 - } /* SyndicatedPost::update_existing() */
1480 -
1481 - /**
1482 - * SyndicatedPost::fix_revision_meta() - Fixes the way WP 2.6+ fucks up
1483 - * meta-data (authorship, etc.) when storing revisions of an updated
1484 - * syndicated post.
1485 - *
1486 - * In their infinite wisdom, the WordPress coders have made it completely
1487 - * impossible for a plugin that uses wp_insert_post() to set certain
1488 - * meta-data (such as the author) when you store an old revision of an
1489 - * updated post. Instead, it uses the WordPress defaults (= currently
1490 - * active user ID if the process is running with a user logged in, or
1491 - * = #0 if there is no user logged in). This results in bogus authorship
1492 - * data for revisions that are syndicated from off the feed, unless we
1493 - * use a ridiculous kludge like this to end-run the munging of meta-data
1494 - * by _wp_put_post_revision.
1495 - *
1496 - * @param int $revision_id The revision ID to fix up meta-data
1497 - */
1498 - function fix_revision_meta ($revision_id) {
1499 - global $wpdb;
1500 1529
1501 - $post_author = (int) $this->post['post_author'];
1502 -
1503 - $revision_id = (int) $revision_id;
1504 - $wpdb->query("
1505 - UPDATE $wpdb->posts
1506 - SET post_author={$this->post['post_author']}
1507 - WHERE post_type = 'revision' AND ID='$revision_id'
1530 + // Just in case, clear out any old MagpieRSS cache records.
1531 + $magpies = $wpdb->query("
1532 + DELETE FROM {$wpdb->options}
1533 + WHERE option_name LIKE 'rss_%' AND LENGTH(option_name) > 32
1508 1534 ");
1509 - } /* SyndicatedPost::fix_revision_meta () */
1510 1535
1511 - /**
1512 - * SyndicatedPost::avoid_kses_munge() -- If FeedWordPress is processing
1513 - * an automatic update, that generally means that wp_insert_post() is
1514 - * being called under the user credentials of whoever is viewing the
1515 - * blog at the time -- usually meaning no user at all. But if WordPress
1516 - * gets a wp_insert_post() when current_user_can('unfiltered_html') is
1517 - * false, it will run the content of the post through a kses function
1518 - * that strips out lots of HTML tags -- notably <object> and some others.
1519 - * This causes problems for syndicating (for example) feeds that contain
1520 - * YouTube videos. It also produces an unexpected asymmetry between
1521 - * automatically-initiated updates and updates initiated manually from
1522 - * the WordPress Dashboard (which are usually initiated under the
1523 - * credentials of a logged-in admin, and so don't get run through the
1524 - * kses function). So, to avoid the whole mess, what we do here is
1525 - * just forcibly disable the kses munging for a single syndicated post,
1526 - * by restoring the contents of the `post_content` field.
1527 - *
1528 - * @param string $content The content of the post, after other filters have gotten to it
1529 - * @return string The original content of the post, before other filters had a chance to munge it.
1530 - */
1531 - function avoid_kses_munge ($content) {
1532 - global $wpdb;
1533 - return $wpdb->escape($this->post['post_content']);
1534 - }
1535 -
1536 - // SyndicatedPost::add_rss_meta: adds interesting meta-data to each entry
1537 - // using the space for custom keys. The set of keys and values to add is
1538 - // specified by the keys and values of $post['meta']. This is used to
1539 - // store anything that the WordPress user might want to access from a
1540 - // template concerning the post's original source that isn't provided
1541 - // for by standard WP meta-data (i.e., any interesting data about the
1542 - // syndicated post other than author, title, timestamp, categories, and
1543 - // guid). It's also used to hook into WordPress's support for
1544 - // enclosures.
1545 - function add_rss_meta () {
1546 - global $wpdb;
1547 - if ( is_array($this->post) and isset($this->post['meta']) and is_array($this->post['meta']) ) :
1548 - $postId = $this->wp_id();
1549 -
1550 - // Aggregated posts should NOT send out pingbacks.
1551 - // WordPress 2.1-2.2 claim you can tell them not to
1552 - // using $post_pingback, but they don't listen, so we
1553 - // make sure here.
1554 - $result = $wpdb->query("
1555 - DELETE FROM $wpdb->postmeta
1556 - WHERE post_id='$postId' AND meta_key='_pingme'
1557 - ");
1536 + // The WordPress SimplePie module stores its cached feeds as
1537 + // transient records in the options table. The data itself is
1538 + // stored in `_transient_feed_{md5 of url}` and the last-modified
1539 + // timestamp in `_transient_feed_mod_{md5 of url}`. Timeouts for
1540 + // these records are stored in `_transient_timeout_feed_{md5}`.
1541 + // Since the md5 is always 32 characters in length, the
1542 + // option_name is always over 32 characters.
1543 + $simplepies = $wpdb->query("
1544 + DELETE FROM {$wpdb->options}
1545 + WHERE option_name LIKE '_transient%_feed_%' AND LENGTH(option_name) > 32
1546 + ");
1547 + $simplepies = (int) ($simplepies / 4); // Each transient has 4 rows: the data, the modified timestamp; and the timeouts for each
1558 1548
1559 - foreach ( $this->post['meta'] as $key => $values ) :
1549 + return ($magpies + $simplepies);
1550 + } /* FeedWordPress::clear_cache () */
1560 1551
1561 - $key = $wpdb->escape($key);
1562 -
1563 - // If this is an update, clear out the old
1564 - // values to avoid duplication.
1565 - $result = $wpdb->query("
1566 - DELETE FROM $wpdb->postmeta
1567 - WHERE post_id='$postId' AND meta_key='$key'
1568 - ");
1569 -
1570 - // Allow for either a single value or an array
1571 - if (!is_array($values)) $values = array($values);
1572 - foreach ( $values as $value ) :
1573 - $value = $wpdb->escape($value);
1574 - $result = $wpdb->query("
1575 - INSERT INTO $wpdb->postmeta
1576 - SET
1577 - post_id='$postId',
1578 - meta_key='$key',
1579 - meta_value='$value'
1580 - ");
1581 - endforeach;
1582 - endforeach;
1552 + function cache_duration () {
1553 + $duration = NULL;
1554 + if (defined('FEEDWORDPRESS_CACHE_AGE')) :
1555 + $duration = FEEDWORDPRESS_CACHE_AGE;
1583 1556 endif;
1584 - } /* SyndicatedPost::add_rss_meta () */
1557 + return $duration;
1558 + }
1559 + function cache_lifetime ($duration) {
1560 + // Check for explicit setting of a lifetime duration
1561 + if (defined('FEEDWORDPRESS_CACHE_LIFETIME')) :
1562 + $duration = FEEDWORDPRESS_CACHE_LIFETIME;
1585 1563
1586 - // SyndicatedPost::author_id (): get the ID for an author name from
1587 - // the feed. Create the author if necessary.
1588 - function author_id ($unfamiliar_author = 'create') {
1589 - global $wpdb;
1590 -
1591 - $a = $this->author();
1592 - $author = $a['name'];
1593 - $email = $a['email'];
1594 - $url = $a['uri'];
1595 -
1596 - $match_author_by_email = !('yes' == get_option("feedwordpress_do_not_match_author_by_email"));
1597 - if ($match_author_by_email and !FeedWordPress::is_null_email($email)) :
1598 - $test_email = $email;
1599 - else :
1600 - $test_email = NULL;
1564 + // Fall back to the cache freshness duration
1565 + elseif (defined('FEEDWORDPRESS_CACHE_AGE')) :
1566 + $duration = FEEDWORDPRESS_CACHE_AGE;
1601 1567 endif;
1568 +
1569 + // Fall back to WordPress default
1570 + return $duration;
1571 + } /* FeedWordPress::cache_lifetime () */
1602 1572
1603 - // Never can be too careful...
1604 - $login = sanitize_user($author, /*strict=*/ true);
1605 - $login = apply_filters('pre_user_login', $login);
1573 + # Utility functions for handling text settings
1574 + function negative ($f, $setting) {
1575 + $nego = array ('n', 'no', 'f', 'false');
1576 + return (isset($f[$setting]) and in_array(strtolower($f[$setting]), $nego));
1577 + }
1606 1578
1607 - $nice_author = sanitize_title($author);
1608 - $nice_author = apply_filters('pre_user_nicename', $nice_author);
1579 + function affirmative ($f, $setting) {
1580 + $affirmo = array ('y', 'yes', 't', 'true', 1);
1581 + return (isset($f[$setting]) and in_array(strtolower($f[$setting]), $affirmo));
1582 + }
1609 1583
1610 - $reg_author = $wpdb->escape(preg_quote($author));
1611 - $author = $wpdb->escape($author);
1612 - $email = $wpdb->escape($email);
1613 - $test_email = $wpdb->escape($test_email);
1614 - $url = $wpdb->escape($url);
1615 -
1616 - // Check for an existing author rule....
1617 - if (isset($this->link->settings['map authors']['name'][strtolower(trim($author))])) :
1618 - $author_rule = $this->link->settings['map authors']['name'][strtolower(trim($author))];
1584 + # Internal debugging functions
1585 + function critical_bug ($varname, $var, $line, $file = NULL) {
1586 + global $wp_version;
1587 +
1588 + if (!is_null($file)) :
1589 + $location = "line # ${line} of ".basename($file);
1619 1590 else :
1620 - $author_rule = NULL;
1591 + $location = "line # ${line}";
1621 1592 endif;
1622 -
1623 - // User name is mapped to a particular author. If that author ID exists, use it.
1624 - if (is_numeric($author_rule) and get_userdata((int) $author_rule)) :
1625 - $id = (int) $author_rule;
1626 -
1627 - // User name is filtered out
1628 - elseif ('filter' == $author_rule) :
1629 - $id = NULL;
1630 1593
1631 - else :
1632 - // Check the database for an existing author record that might fit
1633 -
1634 - #-- WordPress 2.0+
1635 - if (fwp_test_wp_version(FWP_SCHEMA_HAS_USERMETA)) :
1636 -
1637 - // First try the user core data table.
1638 - $id = $wpdb->get_var(
1639 - "SELECT ID FROM $wpdb->users
1640 - WHERE
1641 - TRIM(LCASE(user_login)) = TRIM(LCASE('$login'))
1642 - OR (
1643 - LENGTH(TRIM(LCASE(user_email))) > 0
1644 - AND TRIM(LCASE(user_email)) = TRIM(LCASE('$test_email'))
1645 - )
1646 - OR TRIM(LCASE(user_nicename)) = TRIM(LCASE('$nice_author'))
1647 - ");
1594 + print '<p><strong>Critical error:</strong> There may be a bug in FeedWordPress. Please <a href="'.FEEDWORDPRESS_AUTHOR_CONTACT.'">contact the author</a> and paste the following information into your e-mail:</p>';
1595 + print "\n<plaintext>";
1596 + print "Triggered at ${location}\n";
1597 + print "FeedWordPress: ".FEEDWORDPRESS_VERSION."\n";
1598 + print "WordPress: {$wp_version}\n";
1599 + print "PHP: ".phpversion()."\n";
1600 + print "Error data: ";
1601 + print $varname.": "; var_dump($var); echo "\n";
1602 + die;
1603 + }
1648 1604
1649 - // If that fails, look for aliases in the user meta data table
1650 - if (is_null($id)) :
1651 - $id = $wpdb->get_var(
1652 - "SELECT user_id FROM $wpdb->usermeta
1653 - WHERE
1654 - (meta_key = 'description' AND TRIM(LCASE(meta_value)) = TRIM(LCASE('$author')))
1655 - OR (
1656 - meta_key = 'description'
1657 - AND TRIM(LCASE(meta_value))
1658 - RLIKE CONCAT(
1659 - '(^|\\n)a\\.?k\\.?a\\.?( |\\t)*:?( |\\t)*',
1660 - TRIM(LCASE('$reg_author')),
1661 - '( |\\t|\\r)*(\\n|\$)'
1662 - )
1663 - )
1664 - ");
1665 - endif;
1666 -
1667 - #-- WordPress 1.5.x
1668 - else :
1669 - $id = $wpdb->get_var(
1670 - "SELECT ID from $wpdb->users
1671 - WHERE
1672 - TRIM(LCASE(user_login)) = TRIM(LCASE('$login')) OR
1673 - (
1674 - LENGTH(TRIM(LCASE(user_email))) > 0
1675 - AND TRIM(LCASE(user_email)) = TRIM(LCASE('$test_email'))
1676 - ) OR
1677 - TRIM(LCASE(user_firstname)) = TRIM(LCASE('$author')) OR
1678 - TRIM(LCASE(user_nickname)) = TRIM(LCASE('$author')) OR
1679 - TRIM(LCASE(user_nicename)) = TRIM(LCASE('$nice_author')) OR
1680 - TRIM(LCASE(user_description)) = TRIM(LCASE('$author')) OR
1681 - (
1682 - LOWER(user_description)
1683 - RLIKE CONCAT(
1684 - '(^|\\n)a\\.?k\\.?a\\.?( |\\t)*:?( |\\t)*',
1685 - LCASE('$reg_author'),
1686 - '( |\\t|\\r)*(\\n|\$)'
1687 - )
1688 - )
1689 - ");
1690 -
1691 - endif;
1692 -
1693 - // ... if you don't find one, then do what you need to do
1694 - if (is_null($id)) :
1695 - if ($unfamiliar_author === 'create') :
1696 - $userdata = array();
1697 -
1698 - #-- user table data
1699 - $userdata['ID'] = NULL; // new user
1700 - $userdata['user_login'] = $login;
1701 - $userdata['user_nicename'] = $nice_author;
1702 - $userdata['user_pass'] = substr(md5(uniqid(microtime())), 0, 6); // just something random to lock it up
1703 - $userdata['user_email'] = $email;
1704 - $userdata['user_url'] = $url;
1705 - $userdata['display_name'] = $author;
1605 + function noncritical_bug ($varname, $var, $line, $file = NULL) {
1606 + if (FEEDWORDPRESS_DEBUG) : // halt only when we are doing debugging
1607 + FeedWordPress::critical_bug($varname, $var, $line, $file);
1608 + endif;
1609 + }
1706 1610
1707 - $id = wp_insert_user($userdata);
1708 - elseif (is_numeric($unfamiliar_author) and get_userdata((int) $unfamiliar_author)) :
1709 - $id = (int) $unfamiliar_author;
1710 - elseif ($unfamiliar_author === 'default') :
1711 - $id = 1;
1712 - endif;
1713 - endif;
1611 + function val ($v, $no_newlines = false) {
1612 + ob_start();
1613 + var_dump($v);
1614 + $out = ob_get_contents(); ob_end_clean();
1615 +
1616 + if ($no_newlines) :
1617 + $out = preg_replace('/\s+/', " ", $out);
1714 1618 endif;
1619 + return $out;
1620 + } /* FeedWordPress::val () */
1715 1621
1716 - if ($id) :
1717 - $this->link->settings['map authors']['name'][strtolower(trim($author))] = $id;
1718 - endif;
1719 - return $id;
1720 - } // function SyndicatedPost::author_id ()
1622 + function diagnostic_on ($level) {
1623 + $show = get_option('feedwordpress_diagnostics_show', array());
1624 + return (in_array($level, $show));
1625 + } /* FeedWordPress::diagnostic_on () */
1721 1626
1722 - // look up (and create) category ids from a list of categories
1723 - function category_ids ($cats, $unfamiliar_category = 'create', $tags_too = false) {
1724 - global $wpdb;
1627 + function diagnostic ($level, $out, $persist = NULL, $since = NULL, $mostRecent = NULL) {
1628 + global $feedwordpress_admin_footer;
1725 1629
1726 - // We need to normalize whitespace because (1) trailing
1727 - // whitespace can cause PHP and MySQL not to see eye to eye on
1728 - // VARCHAR comparisons for some versions of MySQL (cf.
1729 - // <http://dev.mysql.com/doc/mysql/en/char.html>), and (2)
1730 - // because I doubt most people want to make a semantic
1731 - // distinction between 'Computers' and 'Computers '
1732 - $cats = array_map('trim', $cats);
1630 + $output = get_option('feedwordpress_diagnostics_output', array());
1631 + $dlog = get_option('feedwordpress_diagnostics_log', array());
1733 1632
1734 - $tags = array();
1633 + $diagnostic_nesting = count(explode(":", $level));
1735 1634
1736 - $cat_ids = array ();
1737 - foreach ($cats as $cat_name) :
1738 - if (preg_match('/^{#([0-9]+)}$/', $cat_name, $backref)) :
1739 - $cat_id = (int) $backref[1];
1740 - if (function_exists('is_term') and is_term($cat_id, 'category')) :
1741 - $cat_ids[] = $cat_id;
1742 - elseif (get_category($cat_id)) :
1743 - $cat_ids[] = $cat_id;
1744 - endif;
1745 - else :
1746 - $esc = $wpdb->escape($cat_name);
1747 - $resc = $wpdb->escape(preg_quote($cat_name));
1748 -
1749 - // WordPress 2.3+
1750 - if (function_exists('is_term')) :
1751 - $cat_id = is_term($cat_name, 'category');
1752 - if ($cat_id) :
1753 - $cat_ids[] = $cat_id['term_id'];
1754 - // There must be a better way to do this...
1755 - elseif ($results = $wpdb->get_results(
1756 - "SELECT term_id
1757 - FROM $wpdb->term_taxonomy
1758 - WHERE
1759 - LOWER(description) RLIKE
1760 - CONCAT('(^|\\n)a\\.?k\\.?a\\.?( |\\t)*:?( |\\t)*', LOWER('{$resc}'), '( |\\t|\\r)*(\\n|\$)')"
1761 - )) :
1762 - foreach ($results AS $term) :
1763 - $cat_ids[] = (int) $term->term_id;
1764 - endforeach;
1765 - elseif ('tag'==$unfamiliar_category) :
1766 - $tags[] = $cat_name;
1767 - elseif ('create'===$unfamiliar_category) :
1768 - $term = wp_insert_term($cat_name, 'category');
1769 - $cat_ids[] = $term['term_id'];
1635 + if (FeedWordPress::diagnostic_on($level)) :
1636 + foreach ($output as $method) :
1637 + switch ($method) :
1638 + case 'echo' :
1639 + if (!FeedWordPress::update_requested()) :
1640 + echo "<div><pre><strong>Diag".str_repeat('====', $diagnostic_nesting-1).'|</strong> '.$out."</pre></div>";
1770 1641 endif;
1771 -
1772 - // WordPress 1.5.x - 2.2.x
1773 - else :
1774 - $results = $wpdb->get_results(
1775 - "SELECT cat_ID
1776 - FROM $wpdb->categories
1777 - WHERE
1778 - (LOWER(cat_name) = LOWER('$esc'))
1779 - OR (LOWER(category_description)
1780 - RLIKE CONCAT('(^|\\n)a\\.?k\\.?a\\.?( |\\t)*:?( |\\t)*', LOWER('{$resc}'), '( |\\t|\\r)*(\\n|\$)'))
1781 - ");
1782 - if ($results) :
1783 - foreach ($results as $term) :
1784 - $cat_ids[] = (int) $term->cat_ID;
1785 - endforeach;
1786 - elseif ('create'===$unfamiliar_category) :
1787 - if (function_exists('wp_insert_category')) :
1788 - $cat_id = wp_insert_category(array('cat_name' => $cat_name));
1789 - // And into the database we go.
1790 - else :
1791 - $nice_kitty = sanitize_title($cat_name);
1792 - $wpdb->query(sprintf("
1793 - INSERT INTO $wpdb->categories
1794 - SET
1795 - cat_name='%s',
1796 - category_nicename='%s'
1797 - ", $wpdb->escape($cat_name), $nice_kitty
1798 - ));
1799 - $cat_id = $wpdb->insert_id;
1800 - endif;
1801 - $cat_ids[] = $cat_id;
1642 + break;
1643 + case 'echo_in_cronjob' :
1644 + if (FeedWordPress::update_requested()) :
1645 + echo FeedWordPress::log_prefix()." ".$out."\n";
1802 1646 endif;
1803 - endif;
1804 - endif;
1805 - endforeach;
1806 -
1807 - if ((count($cat_ids) == 0) and ($unfamiliar_category === 'filter')) :
1808 - $cat_ids = NULL; // Drop the post
1809 - else :
1810 - $cat_ids = array_unique($cat_ids);
1647 + break;
1648 + case 'admin_footer' :
1649 + $feedwordpress_admin_footer[] = $out;
1650 + break;
1651 + case 'error_log' :
1652 + error_log(FeedWordPress::log_prefix().' '.$out);
1653 + break;
1654 + case 'email' :
1655 + if (is_null($persist)) :
1656 + $sect = 'occurrent';
1657 + $hook = (isset($dlog['mesg'][$sect]) ? count($dlog['mesg'][$sect]) : 0);
1658 + $line = array("Time" => time(), "Message" => $out);
1659 + else :
1660 + $sect = 'persistent';
1661 + $hook = md5($level."\n".$persist);
1662 + $line = array("Since" => $since, "Message" => $out, "Most Recent" => $mostRecent);
1663 + endif;
1664 +
1665 + if (!isset($dlog['mesg'])) : $dlog['mesg'] = array(); endif;
1666 + if (!isset($dlog['mesg'][$sect])) : $dlog['mesg'][$sect] = array(); endif;
1667 +
1668 + $dlog['mesg'][$sect][$hook] = $line;
1669 + endswitch;
1670 + endforeach;
1811 1671 endif;
1812 1672
1813 - if ($tags_too) : $ret = array($cat_ids, $tags);
1814 - else : $ret = $cat_ids;
1815 - endif;
1816 -
1817 - return $ret;
1818 - } // function SyndicatedPost::category_ids ()
1819 -
1820 - function use_api ($tag) {
1821 - global $wp_db_version;
1822 - switch ($tag) :
1823 - case 'wp_insert_post':
1824 - // Before 2.2, wp_insert_post does too much of the wrong stuff to use it
1825 - // In 1.5 it was such a resource hog it would make PHP segfault on big updates
1826 - $ret = (isset($wp_db_version) and $wp_db_version > FWP_SCHEMA_21);
1827 - break;
1828 - case 'post_status_pending':
1829 - $ret = (isset($wp_db_version) and $wp_db_version > FWP_SCHEMA_23);
1830 - break;
1831 - endswitch;
1832 - return $ret;
1833 - } // function SyndicatedPost::use_api ()
1834 -
1835 - #### EXTRACT DATA FROM FEED ITEM ####
1836 -
1837 - function created () {
1838 - $epoch = null;
1839 - if (isset($this->item['dc']['created'])) :
1840 - $epoch = @parse_w3cdtf($this->item['dc']['created']);
1841 - elseif (isset($this->item['dcterms']['created'])) :
1842 - $epoch = @parse_w3cdtf($this->item['dcterms']['created']);
1843 - elseif (isset($this->item['created'])): // Atom 0.3
1844 - $epoch = @parse_w3cdtf($this->item['created']);
1845 - endif;
1846 - return $epoch;
1847 - }
1848 - function published ($fallback = true) {
1849 - $epoch = null;
1850 -
1851 - # RSS is a fucking mess. Figure out whether we have a date in
1852 - # <dc:date>, <issued>, <pubDate>, etc., and get it into Unix
1853 - # epoch format for reformatting. If we can't find anything,
1854 - # we'll use the last-updated time.
1855 - if (isset($this->item['dc']['date'])): // Dublin Core
1856 - $epoch = @parse_w3cdtf($this->item['dc']['date']);
1857 - elseif (isset($this->item['dcterms']['issued'])) : // Dublin Core extensions
1858 - $epoch = @parse_w3cdtf($this->item['dcterms']['issued']);
1859 - elseif (isset($this->item['published'])) : // Atom 1.0
1860 - $epoch = @parse_w3cdtf($this->item['published']);
1861 - elseif (isset($this->item['issued'])): // Atom 0.3
1862 - $epoch = @parse_w3cdtf($this->item['issued']);
1863 - elseif (isset($this->item['pubdate'])): // RSS 2.0
1864 - $epoch = strtotime($this->item['pubdate']);
1865 - elseif ($fallback) : // Fall back to <updated> / <modified> if present
1866 - $epoch = $this->updated(/*fallback=*/ false);
1867 - endif;
1673 + update_option('feedwordpress_diagnostics_log', $dlog);
1674 + } /* FeedWordPress::diagnostic () */
1675 +
1676 + function email_diagnostic_log () {
1677 + $dlog = get_option('feedwordpress_diagnostics_log', array());
1868 1678
1869 - # If everything failed, then default to the current time.
1870 - if (is_null($epoch)) :
1871 - if (-1 == $default) :
1872 - $epoch = time();
1873 - else :
1874 - $epoch = $default;
1875 - endif;
1876 - endif;
1877 -
1878 - return $epoch;
1879 - }
1880 - function updated ($fallback = true, $default = -1) {
1881 - $epoch = null;
1679 + if (isset($dlog['schedule']) and isset($dlog['schedule']['last'])) :
1680 + if (time() > ($dlog['schedule']['last'] + $dlog['schedule']['freq'])) :
1681 + // No news is good news; only send if
1682 + // there are some messages to send.
1683 + $body = NULL;
1684 + foreach ($dlog['mesg'] as $sect => $mesgs) :
1685 + if (count($mesgs) > 0) :
1686 + if (is_null($body)) : $body = ''; endif;
1687 +
1688 + $paradigm = reset($mesgs);
1689 + $body .= "<h2>".ucfirst($sect)." issues</h2>\n"
1690 + ."<table>\n"
1691 + ."<thead><tr>\n";
1692 + foreach ($paradigm as $col => $value) :
1693 + $body .= '<th scope="col">'.$col."</th>\n";
1694 + endforeach;
1695 + $body .= "</tr></thead>\n"
1696 + ."<tbody>\n";
1697 +
1698 + foreach ($mesgs as $line) :
1699 + $body .= "<tr>\n";
1700 + foreach ($line as $col => $cell) :
1701 + if (is_numeric($cell)) :
1702 + $cell = date('j-M-y, h:i a', $cell);
1703 + endif;
1704 + $class = strtolower(preg_replace('/\s+/', '-', $col));
1705 + $body .= "<td class=\"$class\">${cell}</td>";
1706 + endforeach;
1707 + $body .= "</tr>\n";
1708 + endforeach;
1709 +
1710 + $body .= "</tbody>\n</table>\n\n";
1711 + endif;
1712 + endforeach;
1713 +
1714 + if (!is_null($body)) :
1715 + $home = feedwordpress_display_url(get_bloginfo('url'));
1716 + $subj = $home . " syndication issues for ".date('j-M-y', time());
1717 + $agent = 'FeedWordPress '.FEEDWORDPRESS_VERSION;
1718 + $body = <<<EOMAIL
1719 +<html>
1720 +<head>
1721 +<title>$subj</title>
1722 +<style type="text/css">
1723 + body { background-color: white; color: black; }
1724 + table { width: 100%; border: 1px solid black; }
1725 + table thead tr th { background-color: #ff7700; color: white; border-bottom: 1px solid black; }
1726 + table thead tr { border-bottom: 1px solid black; }
1727 + table tr { vertical-align: top; }
1728 + table .since { width: 20%; }
1729 + table .time { width: 20%; }
1730 + table .most-recently { width: 20%; }
1731 + table .message { width: auto; }
1732 +</style>
1733 +</head>
1734 +<body>
1735 +<h1>Syndication Issues encountered by $agent on $home</h1>
1736 +$body
1737 +</body>
1738 +</html>
1882 1739
1883 - # As far as I know, only dcterms and Atom have reliable ways to
1884 - # specify when something was *modified* last. If neither is
1885 - # available, then we'll try to get the time of publication.
1886 - if (isset($this->item['dc']['modified'])) : // Not really correct
1887 - $epoch = @parse_w3cdtf($this->item['dc']['modified']);
1888 - elseif (isset($this->item['dcterms']['modified'])) : // Dublin Core extensions
1889 - $epoch = @parse_w3cdtf($this->item['dcterms']['modified']);
1890 - elseif (isset($this->item['modified'])): // Atom 0.3
1891 - $epoch = @parse_w3cdtf($this->item['modified']);
1892 - elseif (isset($this->item['updated'])): // Atom 1.0
1893 - $epoch = @parse_w3cdtf($this->item['updated']);
1894 - elseif ($fallback) : // Fall back to issued / dc:date
1895 - $epoch = $this->published(/*fallback=*/ false, /*default=*/ $default);
1896 - endif;
1897 -
1898 - # If everything failed, then default to the current time.
1899 - if (is_null($epoch)) :
1900 - if (-1 == $default) :
1901 - $epoch = time();
1902 - else :
1903 - $epoch = $default;
1904 - endif;
1905 - endif;
1740 +EOMAIL;
1906 1741
1907 - return $epoch;
1908 - }
1742 + $ded = get_option('feedwordpress_diagnostics_email_destination', 'admins');
1909 1743
1910 - function update_hash () {
1911 - return md5(serialize($this->item));
1912 - }
1744 + // e-mail address
1745 + if (preg_match('/^mailto:(.*)$/', $ded, $ref)) :
1746 + $recipients = array($ref[1]);
1747 +
1748 + // userid
1749 + elseif (preg_match('/^user:(.*)$/', $ded, $ref)) :
1750 + $userdata = get_userdata((int) $ref[1]);
1751 + $recipients = array($userdata->user_email);
1752 +
1753 + // admins
1754 + else :
1755 + $recipients = FeedWordPressDiagnostic::admin_emails();
1756 + endif;
1913 1757
1914 - function guid () {
1915 - $guid = null;
1916 - if (isset($this->item['id'])): // Atom 0.3 / 1.0
1917 - $guid = $this->item['id'];
1918 - elseif (isset($this->item['atom']['id'])) : // Namespaced Atom
1919 - $guid = $this->item['atom']['id'];
1920 - elseif (isset($this->item['guid'])) : // RSS 2.0
1921 - $guid = $this->item['guid'];
1922 - elseif (isset($this->item['dc']['identifier'])) :// yeah, right
1923 - $guid = $this->item['dc']['identifier'];
1924 - else :
1925 - // The feed does not seem to have provided us with a
1926 - // unique identifier, so we'll have to cobble together
1927 - // a tag: URI that might work for us. The base of the
1928 - // URI will be the host name of the feed source ...
1929 - $bits = parse_url($this->feedmeta['link/uri']);
1930 - $guid = 'tag:'.$bits['host'];
1931 -
1932 - // If we have a date of creation, then we can use that
1933 - // to uniquely identify the item. (On the other hand, if
1934 - // the feed producer was consicentious enough to
1935 - // generate dates of creation, she probably also was
1936 - // conscientious enough to generate unique identifiers.)
1937 - if (!is_null($this->created())) :
1938 - $guid .= '://post.'.date('YmdHis', $this->created());
1939 -
1940 - // Otherwise, use both the URI of the item, *and* the
1941 - // item's title. We have to use both because titles are
1942 - // often not unique, and sometimes links aren't unique
1943 - // either (e.g. Bitch (S)HITLIST, Mozilla Dot Org news,
1944 - // some podcasts). But it's rare to have *both* the same
1945 - // title *and* the same link for two different items. So
1946 - // this is about the best we can do.
1947 - else :
1948 - $guid .= '://'.md5($this->item['link'].'/'.$this->item['title']);
1949 - endif;
1950 - endif;
1951 - return $guid;
1952 - }
1953 -
1954 - function author () {
1955 - $author = array ();
1956 -
1957 - if (isset($this->item['author_name'])):
1958 - $author['name'] = $this->item['author_name'];
1959 - elseif (isset($this->item['dc']['creator'])):
1960 - $author['name'] = $this->item['dc']['creator'];
1961 - elseif (isset($this->item['dc']['contributor'])):
1962 - $author['name'] = $this->item['dc']['contributor'];
1963 - elseif (isset($this->feed->channel['dc']['creator'])) :
1964 - $author['name'] = $this->feed->channel['dc']['creator'];
1965 - elseif (isset($this->feed->channel['dc']['contributor'])) :
1966 - $author['name'] = $this->feed->channel['dc']['contributor'];
1967 - elseif (isset($this->feed->channel['author_name'])) :
1968 - $author['name'] = $this->feed->channel['author_name'];
1969 - elseif ($this->feed->is_rss() and isset($this->item['author'])) :
1970 - // The author element in RSS is allegedly an
1971 - // e-mail address, but lots of people don't use
1972 - // it that way. So let's make of it what we can.
1973 - $author = parse_email_with_realname($this->item['author']);
1974 -
1975 - if (!isset($author['name'])) :
1976 - if (isset($author['email'])) :
1977 - $author['name'] = $author['email'];
1978 - else :
1979 - $author['name'] = $this->feed->channel['title'];
1758 + foreach ($recipients as $email) :
1759 + add_filter('wp_mail_content_type', array('FeedWordPress', 'allow_html_mail'));
1760 + wp_mail($email, $subj, $body);
1761 + remove_filter('wp_mail_content_type', array('FeedWordPress', 'allow_html_mail'));
1762 + endforeach;
1980 1763 endif;
1764 +
1765 + // Clear the logs
1766 + $dlog['mesg']['persistent'] = array();
1767 + $dlog['mesg']['occurrent'] = array();
1768 +
1769 + // Set schedule for next update
1770 + $dlog['schedule']['last'] = time();
1981 1771 endif;
1982 1772 else :
1983 - $author['name'] = $this->feed->channel['title'];
1773 + $dlog['schedule'] = array(
1774 + 'freq' => 24 /*hr*/ * 60 /*min*/ * 60 /*s*/,
1775 + 'last' => time(),
1776 + );
1984 1777 endif;
1985 1778
1986 - if (isset($this->item['author_email'])):
1987 - $author['email'] = $this->item['author_email'];
1988 - elseif (isset($this->feed->channel['author_email'])) :
1989 - $author['email'] = $this->feed->channel['author_email'];
1990 - endif;
1991 -
1992 - if (isset($this->item['author_url'])):
1993 - $author['uri'] = $this->item['author_url'];
1994 - elseif (isset($this->feed->channel['author_url'])) :
1995 - $author['uri'] = $this->item['author_url'];
1996 - else:
1997 - $author['uri'] = $this->feed->channel['link'];
1998 - endif;
1779 + update_option('feedwordpress_diagnostics_log', $dlog);
1780 + } /* FeedWordPress::email_diagnostic_log () */
1781 +
1782 + function allow_html_mail () {
1783 + return 'text/html';
1784 + } /* FeedWordPress::allow_html_mail () */
1999 1785
2000 - return $author;
2001 - } // SyndicatedPost::author()
2002 -
2003 - var $strip_attrs = array (
2004 - array('[a-z]+', 'style'),
2005 - array('[a-z]+', 'target'),
2006 - );
2007 - function sanitize_content ($content, $obj) {
2008 - # FeedWordPress used to resolve URIs relative to the
2009 - # feed URI. It now relies on the xml:base support
2010 - # baked in to the MagpieRSS upgrade. So all we do here
2011 - # now is to sanitize problematic attributes.
2012 - #
2013 - # This kind of sucks. I intend to replace it with
2014 - # lib_filter sometime soon.
2015 - foreach ($obj->strip_attrs as $pair):
2016 - list($tag,$attr) = $pair;
2017 - $content = preg_replace (
2018 - ":(<$tag [^>]*)($attr=(\"[^\">]*\"|[^>\\s]+))([^>]*>):i",
2019 - "\\1\\4",
2020 - $content
2021 - );
1786 + function admin_footer () {
1787 + global $feedwordpress_admin_footer;
1788 + foreach ($feedwordpress_admin_footer as $line) :
1789 + echo '<div><pre>'.$line.'</pre></div>';
2022 1790 endforeach;
2023 - return $content;
2024 - }
2025 -} // class SyndicatedPost
2026 -
2027 -# class SyndicatedLink: represents a syndication feed stored within the
2028 -# WordPress database
2029 -#
2030 -# To keep things compact and editable from within WordPress, we use all the
2031 -# links under a particular category in the WordPress "Blogroll" for the list of
2032 -# feeds to syndicate. "Contributors" is the category used by default; you can
2033 -# configure that under Options --> Syndication.
2034 -#
2035 -# Fields used are:
2036 -#
2037 -# * link_rss: the URI of the Atom/RSS feed to syndicate
2038 -#
2039 -# * link_notes: user-configurable options, with keys and values
2040 -# like so:
2041 -#
2042 -# key: value
2043 -# cats: computers\nweb
2044 -# feed/key: value
2045 -#
2046 -# Keys that start with "feed/" are gleaned from the data supplied
2047 -# by the feed itself, and will be overwritten with each update.
2048 -#
2049 -# Values have linebreak characters escaped with C-style
2050 -# backslashes (so, for example, a newline becomes "\n").
2051 -#
2052 -# The value of `cats` is used as a newline-separated list of
2053 -# default categories for any post coming from a particular feed.
2054 -# (In the example above, any posts from this feed will be placed
2055 -# in the "computers" and "web" categories--*in addition to* any
2056 -# categories that may already be applied to the posts.)
2057 -#
2058 -# Values of keys in link_notes are accessible from templates using
2059 -# the function `get_feed_meta($key)` if this plugin is activated.
2060 -
2061 -class SyndicatedLink {
2062 - var $id = null;
2063 - var $link = null;
2064 - var $settings = array ();
2065 - var $magpie = null;
2066 -
2067 - function SyndicatedLink ($link) {
2068 - global $wpdb;
2069 -
2070 - if (is_object($link)) :
2071 - $this->link = $link;
2072 - $this->id = $link->link_id;
2073 - else :
2074 - $this->id = $link;
2075 - if (function_exists('get_bookmark')) : // WP 2.1+
2076 - $this->link = get_bookmark($link);
2077 - else :
2078 - $this->link = $wpdb->get_row("
2079 - SELECT * FROM $wpdb->links
2080 - WHERE (link_id = '".$wpdb->escape($link)."')"
2081 - );
2082 - endif;
2083 - endif;
2084 -
2085 - if (strlen($this->link->link_rss) > 0) :
2086 - // Read off feed settings from link_notes
2087 - $notes = explode("\n", $this->link->link_notes);
2088 - foreach ($notes as $note):
2089 - list($key, $value) = explode(": ", $note, 2);
1791 + } /* FeedWordPress::admin_footer () */
2090 1792
2091 - if (strlen($key) > 0) :
2092 - // Unescape and trim() off the whitespace.
2093 - // Thanks to Ray Lischner for pointing out the
2094 - // need to trim off whitespace.
2095 - $this->settings[$key] = stripcslashes (trim($value));
2096 - endif;
2097 - endforeach;
2098 -
2099 - // "Magic" feed settings
2100 - $this->settings['link/uri'] = $this->link->link_rss;
2101 - $this->settings['link/name'] = $this->link->link_name;
2102 - $this->settings['link/id'] = $this->link->link_id;
2103 -
2104 - // `hardcode categories` and `unfamiliar categories` are deprecated in favor of `unfamiliar category`
2105 - if (
2106 - isset($this->settings['unfamiliar categories'])
2107 - and !isset($this->settings['unfamiliar category'])
2108 - ) :
2109 - $this->settings['unfamiliar category'] = $this->settings['unfamiliar categories'];
2110 - endif;
2111 - if (
2112 - FeedWordPress::affirmative($this->settings, 'hardcode categories')
2113 - and !isset($this->settings['unfamiliar category'])
2114 - ) :
2115 - $this->settings['unfamiliar category'] = 'default';
2116 - endif;
2117 -
2118 - // Set this up automagically for del.icio.us
2119 - $bits = parse_url($this->link->link_rss);
2120 - $tagspacers = array('del.icio.us', 'feeds.delicious.com');
2121 - if (!isset($this->settings['cat_split']) and in_array($bits['host'], $tagspacers)) :
2122 - $this->settings['cat_split'] = '\s'; // Whitespace separates multiple tags in del.icio.us RSS feeds
2123 - endif;
2124 -
2125 - if (isset($this->settings['cats'])):
2126 - $this->settings['cats'] = preg_split(FEEDWORDPRESS_CAT_SEPARATOR_PATTERN, $this->settings['cats']);
2127 - endif;
2128 - if (isset($this->settings['tags'])):
2129 - $this->settings['tags'] = preg_split(FEEDWORDPRESS_CAT_SEPARATOR_PATTERN, $this->settings['tags']);
2130 - endif;
2131 -
2132 - if (isset($this->settings['map authors'])) :
2133 - $author_rules = explode("\n\n", $this->settings['map authors']);
2134 - $ma = array();
2135 - foreach ($author_rules as $rule) :
2136 - list($rule_type, $author_name, $author_action) = explode("\n", $rule);
2137 -
2138 - // Normalize for case and whitespace
2139 - $rule_type = strtolower(trim($rule_type));
2140 - $author_name = strtolower(trim($author_name));
2141 - $author_action = strtolower(trim($author_action));
2142 -
2143 - $ma[$rule_type][$author_name] = $author_action;
2144 - endforeach;
2145 - $this->settings['map authors'] = $ma;
2146 - endif;
1793 + function log_prefix ($date = false) {
1794 + $home = get_bloginfo('url');
1795 + $prefix = '['.feedwordpress_display_url($home).'] [feedwordpress] ';
1796 + if ($date) :
1797 + $prefix = "[".date('Y-m-d H:i:s')."]".$prefix;
2147 1798 endif;
2148 - } /* SyndicatedLink::SyndicatedLink () */
1799 + return $prefix;
1800 + } /* FeedWordPress::log_prefix () */
2149 1801
2150 - function found () {
2151 - return is_object($this->link);
2152 - } /* SyndicatedLink::found () */
2153 -
2154 - function stale () {
2155 - $stale = true;
2156 - if (isset($this->settings['update/hold']) and ($this->settings['update/hold']=='ping')) :
2157 - $stale = false; // don't update on any timed updates; pings only
2158 - elseif (isset($this->settings['update/hold']) and ($this->settings['update/hold']=='next')) :
2159 - $stale = true; // update on the next timed update
2160 - elseif (!isset($this->settings['update/ttl']) or !isset($this->settings['update/last'])) :
2161 - $stale = true; // initial update
1802 + function menu_cap ($sub = false) {
1803 + if ($sub) :
1804 + $cap = apply_filters('feedwordpress_menu_settings_capacity', 'manage_options');
2162 1805 else :
2163 - $after = ((int) $this->settings['update/last'])
2164 - +((int) $this->settings['update/ttl'] * 60);
2165 - $stale = (time() >= $after);
1806 + $cap = apply_filters('feedwordpress_menu_main_capacity', 'manage_links');
2166 1807 endif;
2167 - return $stale;
2168 - } /* SyndicatedLink::stale () */
2169 -
2170 - function poll ($crash_ts = NULL) {
2171 - global $wpdb;
2172 -
2173 - $this->magpie = fetch_rss($this->link->link_rss);
2174 - $new_count = NULL;
2175 -
2176 - $resume = FeedWordPress::affirmative($this->settings, 'update/unfinished');
2177 - if ($resume) :
2178 - // pick up where we left off
2179 - $processed = array_map('trim', explode("\n", $this->settings['update/processed']));
2180 - else :
2181 - // begin at the beginning
2182 - $processed = array();
1808 + return $cap;
1809 + } /* FeedWordPress::menu_cap () */
1810 +
1811 + function path ($filename = '') {
1812 + global $fwp_path;
1813 +
1814 + $path = $fwp_path;
1815 + if (strlen($filename) > 0) :
1816 + $path .= '/'.$filename;
2183 1817 endif;
2184 -
2185 - if (is_object($this->magpie)) :
2186 - $new_count = array('new' => 0, 'updated' => 0);
2187 -
2188 - # -- Update Link metadata live from feed
2189 - $channel = $this->magpie->channel;
2190 -
2191 - if (!isset($channel['id'])) :
2192 - $channel['id'] = $this->link->link_rss;
2193 - endif;
1818 + return $path;
1819 + }
2194 1820
2195 - $update = array();
2196 - if (!$this->hardcode('url') and isset($channel['link'])) :
2197 - $update[] = "link_url = '".$wpdb->escape($channel['link'])."'";
2198 - endif;
2199 -
2200 - if (!$this->hardcode('name') and isset($channel['title'])) :
2201 - $update[] = "link_name = '".$wpdb->escape($channel['title'])."'";
2202 - endif;
2203 -
2204 - if (!$this->hardcode('description')) :
2205 - if (isset($channel['tagline'])) :
2206 - $update[] = "link_description = '".$wpdb->escape($channel['tagline'])."'";
2207 - elseif (isset($channel['description'])) :
2208 - $update[] = "link_description = '".$wpdb->escape($channel['description'])."'";
1821 + function param ($key, $type = 'REQUEST', $default = NULL) {
1822 + $where = '_'.strtoupper($type);
1823 + $ret = $default;
1824 + if (isset($GLOBALS[$where]) and is_array($GLOBALS[$where])) :
1825 + if (isset($GLOBALS[$where][$key])) :
1826 + $ret = $GLOBALS[$where][$key];
1827 + if (get_magic_quotes_gpc()) :
1828 + $ret = stripslashes_deep($ret);
2209 1829 endif;
2210 1830 endif;
2211 -
2212 - $this->settings = array_merge($this->settings, $this->flatten_array($channel));
2213 -
2214 - $this->settings['update/last'] = time(); $ttl = $this->ttl();
2215 - if (!is_null($ttl)) :
2216 - $this->settings['update/ttl'] = $ttl;
2217 - $this->settings['update/timed'] = 'feed';
2218 - else :
2219 - $this->settings['update/ttl'] = rand(30, 120); // spread over time interval for staggered updates
2220 - $this->settings['update/timed'] = 'automatically';
2221 - endif;
2222 -
2223 - if (!isset($this->settings['update/hold']) or $this->settings['update/hold']!='ping') :
2224 - $this->settings['update/hold'] = 'scheduled';
2225 - endif;
2226 -
2227 - $this->settings['update/unfinished'] = 'yes';
2228 -
2229 - $update[] = "link_notes = '".$wpdb->escape($this->settings_to_notes())."'";
2230 -
2231 - $update_set = implode(',', $update);
2232 -
2233 - // Update the properties of the link from the feed information
2234 - $result = $wpdb->query("
2235 - UPDATE $wpdb->links
2236 - SET $update_set
2237 - WHERE link_id='$this->id'
2238 - ");
2239 -
2240 - # -- Add new posts from feed and update any updated posts
2241 - $crashed = false;
2242 -
2243 - if (is_array($this->magpie->items)) :
2244 - foreach ($this->magpie->items as $item) :
2245 - $post =& new SyndicatedPost($item, $this);
2246 - if (!$resume or !in_array(trim($post->guid()), $processed)) :
2247 - $processed[] = $post->guid();
2248 - if (!$post->filtered()) :
2249 - $new = $post->store();
2250 - if ( $new !== false ) $new_count[$new]++;
2251 - endif;
2252 -
2253 - if (!is_null($crash_ts) and (time() > $crash_ts)) :
2254 - $crashed = true;
2255 - break;
2256 - endif;
2257 - endif;
2258 - endforeach;
2259 - endif;
2260 -
2261 - // Copy back any changes to feed settings made in the course of updating (e.g. new author rules)
2262 - $to_notes = $this->settings;
2263 -
2264 - $this->settings['update/processed'] = $processed;
2265 - if (!$crashed) :
2266 - $this->settings['update/unfinished'] = 'no';
2267 - endif;
2268 -
2269 - $update_set = "link_notes = '".$wpdb->escape($this->settings_to_notes())."'";
2270 -
2271 - // Update the properties of the link from the feed information
2272 - $result = $wpdb->query("
2273 - UPDATE $wpdb->links
2274 - SET $update_set
2275 - WHERE link_id='$this->id'
2276 - ");
2277 1831 endif;
2278 -
2279 - return $new_count;
2280 - } /* SyndicatedLink::poll() */
1832 + return $ret;
1833 + }
1834 + function post ($key, $default = NULL) {
1835 + return FeedWordPress::param($key, 'POST');
1836 + }
1837 +} // class FeedWordPress
2281 1838
2282 - function map_name_to_new_user ($name, $newuser_name) {
2283 - global $wpdb;
1839 +class FeedWordPress_File extends WP_SimplePie_File {
1840 + function FeedWordPress_File ($url, $timeout = 10, $redirects = 5, $headers = null, $useragent = null, $force_fsockopen = false) {
1841 + WP_SimplePie_File::WP_SimplePie_File($url, $timeout, $redirects, $headers, $useragent, $force_fsockopen);
2284 1842
2285 - if (strlen($newuser_name) > 0) :
2286 - $userdata = array();
2287 - $userdata['ID'] = NULL;
2288 -
2289 - $userdata['user_login'] = sanitize_user($newuser_name);
2290 - $userdata['user_login'] = apply_filters('pre_user_login', $userdata['user_login']);
2291 -
2292 - $userdata['user_nicename'] = sanitize_title($newuser_name);
2293 - $userdata['user_nicename'] = apply_filters('pre_user_nicename', $userdata['user_nicename']);
2294 -
2295 - $userdata['display_name'] = $wpdb->escape($newuser_name);
2296 -
2297 - $newuser_id = wp_insert_user($userdata);
2298 - if (is_numeric($newuser_id)) :
2299 - if (is_null($name)) : // Unfamiliar author
2300 - $this->settings['unfamiliar author'] = $newuser_id;
2301 - else :
2302 - $this->settings['map authors']['name'][$name] = $newuser_id;
2303 - endif;
2304 - else :
2305 - // TODO: Add some error detection and reporting
2306 - endif;
2307 - else :
2308 - // TODO: Add some error reporting
2309 - endif;
2310 - } /* SyndicatedLink::map_name_to_new_user () */
1843 + // SimplePie makes a strongly typed check against integers with
1844 + // this, but WordPress puts a string in. Which causes caching
1845 + // to break and fall on its ass when SimplePie is getting a 304,
1846 + // but doesn't realize it because this member is "304" instead.
1847 + $this->status_code = (int) $this->status_code;
1848 + }
1849 +} /* class FeedWordPress_File () */
2311 1850
2312 - function settings_to_notes () {
2313 - $to_notes = $this->settings;
1851 +class FeedWordPress_Parser extends SimplePie_Parser {
1852 + function parse (&$data, $encoding) {
1853 + // Use UTF-8 if we get passed US-ASCII, as every US-ASCII character is a UTF-8 character
1854 + if (strtoupper($encoding) === 'US-ASCII')
1855 + {
1856 + $this->encoding = 'UTF-8';
1857 + }
1858 + else
1859 + {
1860 + $this->encoding = $encoding;
1861 + }
2314 1862
2315 - unset($to_notes['link/id']); // Magic setting; don't save
2316 - unset($to_notes['link/uri']); // Magic setting; don't save
2317 - unset($to_notes['link/name']); // Magic setting; don't save
2318 - unset($to_notes['hardcode categories']); // Deprecated
2319 - unset($to_notes['unfamiliar categories']); // Deprecated
1863 + // Strip BOM:
1864 + // UTF-32 Big Endian BOM
1865 + if (substr($data, 0, 4) === "\x00\x00\xFE\xFF")
1866 + {
1867 + $data = substr($data, 4);
1868 + }
1869 + // UTF-32 Little Endian BOM
1870 + elseif (substr($data, 0, 4) === "\xFF\xFE\x00\x00")
1871 + {
1872 + $data = substr($data, 4);
1873 + }
1874 + // UTF-16 Big Endian BOM
1875 + elseif (substr($data, 0, 2) === "\xFE\xFF")
1876 + {
1877 + $data = substr($data, 2);
1878 + }
1879 + // UTF-16 Little Endian BOM
1880 + elseif (substr($data, 0, 2) === "\xFF\xFE")
1881 + {
1882 + $data = substr($data, 2);
1883 + }
1884 + // UTF-8 BOM
1885 + elseif (substr($data, 0, 3) === "\xEF\xBB\xBF")
1886 + {
1887 + $data = substr($data, 3);
1888 + }
2320 1889
2321 - // Collapse array settings
2322 - if (isset($to_notes['update/processed']) and (is_array($to_notes['update/processed']))) :
2323 - $to_notes['update/processed'] = implode("\n", $to_notes['update/processed']);
2324 - endif;
1890 + if (substr($data, 0, 5) === '<?xml' && strspn(substr($data, 5, 1), "\x09\x0A\x0D\x20") && ($pos = strpos($data, '?>')) !== false)
1891 + {
1892 + $declaration =& new SimplePie_XML_Declaration_Parser(substr($data, 5, $pos - 5));
1893 + if ($declaration->parse())
1894 + {
1895 + $data = substr($data, $pos + 2);
1896 + $data = '<?xml version="' . $declaration->version . '" encoding="' . $encoding . '" standalone="' . (($declaration->standalone) ? 'yes' : 'no') . '"?>' . $data;
1897 + }
1898 + else
1899 + {
1900 + $this->error_string = 'SimplePie bug! Please report this!';
1901 + return false;
1902 + }
1903 + }
2325 1904
2326 - if (is_array($to_notes['cats'])) :
2327 - $to_notes['cats'] = implode(FEEDWORDPRESS_CAT_SEPARATOR, $to_notes['cats']);
2328 - endif;
2329 - if (is_array($to_notes['tags'])) :
2330 - $to_notes['tags'] = implode(FEEDWORDPRESS_CAT_SEPARATOR, $to_notes['tags']);
2331 - endif;
1905 + $return = true;
2332 1906
2333 - // Collapse the author mapping rule structure back into a flat string
2334 - if (isset($to_notes['map authors'])) :
2335 - $ma = array();
2336 - foreach ($to_notes['map authors'] as $rule_type => $author_rules) :
2337 - foreach ($author_rules as $author_name => $author_action) :
2338 - $ma[] = $rule_type."\n".$author_name."\n".$author_action;
2339 - endforeach;
2340 - endforeach;
2341 - $to_notes['map authors'] = implode("\n\n", $ma);
2342 - endif;
1907 + static $xml_is_sane = null;
1908 + if ($xml_is_sane === null)
1909 + {
1910 + $parser_check = xml_parser_create();
1911 + xml_parse_into_struct($parser_check, '<foo>&amp;</foo>', $values);
1912 + xml_parser_free($parser_check);
1913 + $xml_is_sane = isset($values[0]['value']);
1914 + }
2343 1915
2344 - $notes = '';
2345 - foreach ($to_notes as $key => $value) :
2346 - $notes .= $key . ": ". addcslashes($value, "\0..\37".'\\') . "\n";
2347 - endforeach;
2348 - return $notes;
2349 - } /* SyndicatedLink::settings_to_notes () */
1916 + // Create the parser
1917 + if ($xml_is_sane)
1918 + {
1919 + $xml = xml_parser_create_ns($this->encoding, $this->separator);
1920 + xml_parser_set_option($xml, XML_OPTION_SKIP_WHITE, 1);
1921 + xml_parser_set_option($xml, XML_OPTION_CASE_FOLDING, 0);
1922 + xml_set_object($xml, $this);
1923 + xml_set_character_data_handler($xml, 'cdata');
1924 + xml_set_element_handler($xml, 'tag_open', 'tag_close');
1925 + xml_set_start_namespace_decl_handler($xml, 'start_xmlns');
2350 1926
2351 - function uri () {
2352 - return (is_object($this->link) ? $this->link->link_rss : NULL);
2353 - } /* SyndicatedLink::uri () */
1927 + // Parse!
1928 + if (!xml_parse($xml, $data, true))
1929 + {
1930 + $this->error_code = xml_get_error_code($xml);
1931 + $this->error_string = xml_error_string($this->error_code);
1932 + $return = false;
1933 + }
2354 1934
2355 - function homepage () {
2356 - return (isset($this->settings['feed/link']) ? $this->settings['feed/link'] : NULL);
2357 - } /* SyndicatedLink::homepage () */
1935 + $this->current_line = xml_get_current_line_number($xml);
1936 + $this->current_column = xml_get_current_column_number($xml);
1937 + $this->current_byte = xml_get_current_byte_index($xml);
1938 + xml_parser_free($xml);
2358 1939
2359 - function ttl () {
2360 - if (is_object($this->magpie)) :
2361 - $channel = $this->magpie->channel;
2362 - else :
2363 - $channel = array();
2364 - endif;
1940 + return $return;
1941 + }
1942 + else
1943 + {
1944 + libxml_clear_errors();
1945 + $xml =& new XMLReader();
1946 + $xml->xml($data);
1947 + while (@$xml->read())
1948 + {
1949 + switch ($xml->nodeType)
1950 + {
2365 1951
2366 - if (isset($channel['ttl'])) :
2367 - // "ttl stands for time to live. It's a number of
2368 - // minutes that indicates how long a channel can be
2369 - // cached before refreshing from the source."
2370 - // <http://blogs.law.harvard.edu/tech/rss#ltttlgtSubelementOfLtchannelgt>
2371 - $ret = $channel['ttl'];
2372 - elseif (isset($channel['sy']['updatefrequency']) or isset($channel['sy']['updateperiod'])) :
2373 - $period_minutes = array (
2374 - 'hourly' => 60, /* minutes in an hour */
2375 - 'daily' => 1440, /* minutes in a day */
2376 - 'weekly' => 10080, /* minutes in a week */
2377 - 'monthly' => 43200, /* minutes in a month */
2378 - 'yearly' => 525600, /* minutes in a year */
2379 - );
1952 + case constant('XMLReader::END_ELEMENT'):
1953 + if ($xml->namespaceURI !== '')
1954 + {
1955 + $tagName = "{$xml->namespaceURI}{$this->separator}{$xml->localName}";
1956 + }
1957 + else
1958 + {
1959 + $tagName = $xml->localName;
1960 + }
1961 + $this->tag_close(null, $tagName);
1962 + break;
1963 + case constant('XMLReader::ELEMENT'):
1964 + $empty = $xml->isEmptyElement;
1965 + if ($xml->namespaceURI !== '')
1966 + {
1967 + $tagName = "{$xml->namespaceURI}{$this->separator}{$xml->localName}";
1968 + }
1969 + else
1970 + {
1971 + $tagName = $xml->localName;
1972 + }
1973 + $attributes = array();
1974 + while ($xml->moveToNextAttribute())
1975 + {
1976 + if ($xml->namespaceURI !== '')
1977 + {
1978 + $attrName = "{$xml->namespaceURI}{$this->separator}{$xml->localName}";
1979 + }
1980 + else
1981 + {
1982 + $attrName = $xml->localName;
1983 + }
1984 + $attributes[$attrName] = $xml->value;
1985 + }
1986 +
1987 + foreach ($attributes as $attr => $value) :
1988 + list($ns, $local) = $this->split_ns($attr);
1989 + if ($ns=='http://www.w3.org/2000/xmlns/') :
1990 + if ('xmlns' == $local) : $local = false; endif;
1991 + $this->start_xmlns(null, $local, $value);
1992 + endif;
1993 + endforeach;
1994 +
1995 + $this->tag_open(null, $tagName, $attributes);
1996 + if ($empty)
1997 + {
1998 + $this->tag_close(null, $tagName);
1999 + }
2000 + break;
2001 + case constant('XMLReader::TEXT'):
2380 2002
2381 - // "sy:updatePeriod: Describes the period over which the
2382 - // channel format is updated. Acceptable values are:
2383 - // hourly, daily, weekly, monthly, yearly. If omitted,
2384 - // daily is assumed." <http://web.resource.org/rss/1.0/modules/syndication/>
2385 - if (isset($channel['sy']['updateperiod'])) : $period = $channel['sy']['updateperiod'];
2386 - else : $period = 'daily';
2387 - endif;
2388 -
2389 - // "sy:updateFrequency: Used to describe the frequency
2390 - // of updates in relation to the update period. A
2391 - // positive integer indicates how many times in that
2392 - // period the channel is updated. ... If omitted a value
2393 - // of 1 is assumed." <http://web.resource.org/rss/1.0/modules/syndication/>
2394 - if (isset($channel['sy']['updatefrequency'])) : $freq = (int) $channel['sy']['updatefrequency'];
2395 - else : $freq = 1;
2396 - endif;
2397 -
2398 - $ret = (int) ($period_minutes[$period] / $freq);
2399 - else :
2400 - $ret = NULL;
2003 + case constant('XMLReader::CDATA'):
2004 + $this->cdata(null, $xml->value);
2005 + break;
2006 + }
2007 + }
2008 + if ($error = libxml_get_last_error())
2009 + {
2010 + $this->error_code = $error->code;
2011 + $this->error_string = $error->message;
2012 + $this->current_line = $error->line;
2013 + $this->current_column = $error->column;
2014 + return false;
2015 + }
2016 + else
2017 + {
2018 + return true;
2019 + }
2020 + }
2021 + } /* FeedWordPress_Parser::parse() */
2022 +
2023 + var $xmlns_stack = array();
2024 + var $xmlns_current = array();
2025 + function tag_open ($parser, $tag, $attributes) {
2026 + $ret = parent::tag_open($parser, $tag, $attributes);
2027 + if ($this->current_xhtml_construct < 0) :
2028 + $this->data['xmlns'] = $this->xmlns_current;
2029 + $this->xmlns_stack[] = $this->xmlns_current;
2401 2030 endif;
2402 2031 return $ret;
2403 - } /* SyndicatedLink::ttl() */
2404 -
2405 - // SyndicatedLink::flatten_array (): flatten an array. Useful for
2406 - // hierarchical and namespaced elements.
2407 - //
2408 - // Given an array which may contain array or object elements in it,
2409 - // return a "flattened" array: a one-dimensional array of scalars
2410 - // containing each of the scalar elements contained within the array
2411 - // structure. Thus, for example, if $a['b']['c']['d'] == 'e', then the
2412 - // returned array for FeedWordPress::flatten_array($a) will contain a key
2413 - // $a['feed/b/c/d'] with value 'e'.
2414 - function flatten_array ($arr, $prefix = 'feed/', $separator = '/') {
2415 - $ret = array ();
2416 - if (is_array($arr)) :
2417 - foreach ($arr as $key => $value) :
2418 - if (is_scalar($value)) :
2419 - $ret[$prefix.$key] = $value;
2420 - else :
2421 - $ret = array_merge($ret, $this->flatten_array($value, $prefix.$key.$separator, $separator));
2422 - endif;
2423 - endforeach;
2032 + }
2033 +
2034 + function tag_close($parser, $tag) {
2035 + if ($this->current_xhtml_construct < 0) :
2036 + $this->xmlns_current = array_pop($this->xmlns_stack);
2424 2037 endif;
2038 + $ret = parent::tag_close($parser, $tag);
2425 2039 return $ret;
2426 - } /* SyndicatedLink::flatten_array () */
2427 -
2428 - function hardcode ($what) {
2429 - $default = get_option("feedwordpress_hardcode_$what");
2430 - if ( $default === 'yes' ) :
2431 - // If the default is to hardcode, then we want the
2432 - // negation of negative(): TRUE by default and FALSE if
2433 - // the setting is explicitly "no"
2434 - $ret = !FeedWordPress::negative($this->settings, "hardcode $what");
2435 - else :
2436 - // If the default is NOT to hardcode, then we want
2437 - // affirmative(): FALSE by default and TRUE if the
2438 - // setting is explicitly "yes"
2439 - $ret = FeedWordPress::affirmative($this->settings, "hardcode $what");
2040 + }
2041 +
2042 + function start_xmlns ($parser, $prefix, $uri) {
2043 + if (!$prefix) :
2044 + $prefix = '';
2440 2045 endif;
2441 - return $ret;
2442 - } /* SyndicatedLink::hardcode () */
2443 -
2444 - function syndicated_status ($what, $default) {
2445 - global $wpdb;
2446 -
2447 - $ret = get_option("feedwordpress_syndicated_{$what}_status");
2448 - if ( isset($this->settings["$what status"]) ) :
2449 - $ret = $this->settings["$what status"];
2450 - elseif (!$ret) :
2451 - $ret = $default;
2046 + if ($this->current_xhtml_construct < 0) :
2047 + $this->xmlns_current[$prefix] = $uri;
2452 2048 endif;
2453 - return $wpdb->escape(trim(strtolower($ret)));
2454 - } /* SyndicatedLink:syndicated_status () */
2455 -} // class SyndicatedLink
2456 -
2457 -################################################################################
2458 -## XML-RPC HOOKS: accept XML-RPC update pings from Contributors ################
2459 -################################################################################
2460 -
2461 -function feedwordpress_xmlrpc_hook ($args = array ()) {
2462 - $args['weblogUpdates.ping'] = 'feedwordpress_pong';
2463 - return $args;
2049 + return true;
2050 + } /* FeedWordPress_Parser::start_xmlns() */
2464 2051 }
2465 2052
2466 -function feedwordpress_pong ($args) {
2467 - $feedwordpress =& new FeedWordPress;
2468 - $delta = @$feedwordpress->update($args[1]);
2469 - if (is_null($delta)):
2470 - return array('flerror' => true, 'message' => "Sorry. I don't syndicate <$args[1]>.");
2471 - else:
2472 - $mesg = array();
2473 - if (isset($delta['new'])) { $mesg[] = ' '.$delta['new'].' new posts were syndicated'; }
2474 - if (isset($delta['updated'])) { $mesg[] = ' '.$delta['updated'].' existing posts were updated'; }
2053 +$feedwordpress_admin_footer = array();
2475 2054
2476 - return array('flerror' => false, 'message' => "Thanks for the ping.".implode(' and', $mesg));
2477 - endif;
2478 -}
2479 -
2480 2055 ################################################################################
2481 -## class FeedFinder: find likely feeds using autodetection and/or guesswork ####
2056 +## XML-RPC HOOKS: accept XML-RPC update pings from Contributors ################
2482 2057 ################################################################################
2483 2058
2484 -class FeedFinder {
2485 - var $uri = NULL;
2486 - var $_cache_uri = NULL;
2059 +class FeedWordPressRPC {
2060 + function FeedWordPressRPC () {
2061 + add_filter('xmlrpc_methods', array(&$this, 'xmlrpc_methods'));
2062 + }
2487 2063
2488 - var $verify = FALSE;
2064 + function xmlrpc_methods ($args = array()) {
2065 + $args['weblogUpdates.ping'] = array(&$this, 'ping');
2066 + $args['feedwordpress.subscribe'] = array(&$this, 'subscribe');
2067 + $args['feedwordpress.deactivate'] = array(&$this, 'deactivate');
2068 + $args['feedwordpress.delete'] = array(&$this, 'delete');
2069 + $args['feedwordpress.nuke'] = array(&$this, 'nuke');
2070 + return $args;
2071 + }
2489 2072
2490 - var $_data = NULL;
2491 - var $_head = NULL;
2492 -
2493 - # -- Recognition patterns
2494 - var $_feed_types = array(
2495 - 'application/rss+xml',
2496 - 'text/xml',
2497 - 'application/atom+xml',
2498 - 'application/x.atom+xml',
2499 - 'application/x-atom+xml'
2500 - );
2501 - var $_feed_markers = array('\\<feed', '\\<rss', 'xmlns="http://purl.org/rss/1.0');
2502 - var $_html_markers = array('\\<html');
2503 - var $_obvious_feed_url = array('[./]rss', '[./]rdf', '[./]atom', '[./]feed', '\.xml');
2504 - var $_maybe_feed_url = array ('rss', 'rdf', 'atom', 'feed', 'xml');
2505 -
2506 - function FeedFinder ($uri = NULL, $verify = TRUE) {
2507 - $this->uri = $uri; $this->verify = $verify;
2508 - } /* FeedFinder::FeedFinder () */
2509 -
2510 - function find ($uri = NULL) {
2511 - $ret = array ();
2512 - if (!is_null($this->data($uri))) {
2513 - if ($this->is_feed($uri)) {
2514 - $ret = array($this->uri);
2515 - } else {
2516 - // Assume that we have HTML or XHTML (even if we don't, who's it gonna hurt?)
2517 - // Autodiscovery is the preferred method
2518 - $href = $this->_link_rel_feeds();
2519 -
2520 - // ... but we'll also take the little orange buttons
2521 - $href = array_merge($href, $this->_a_href_feeds(TRUE));
2522 -
2523 - // If all that failed, look harder
2524 - if (count($href) == 0) $href = $this->_a_href_feeds(FALSE);
2525 -
2526 - // Verify feeds and resolve relative URIs
2527 - foreach ($href as $u) {
2528 - $the_uri = Relative_URI::resolve($u, $this->uri);
2529 - if ($this->verify) {
2530 - $feed =& new FeedFinder($the_uri);
2531 - if ($feed->is_feed()) $ret[] = $the_uri;
2532 - $feed = NULL;
2533 - } else {
2534 - $ret[] = $the_uri;
2535 - }
2536 - } /* foreach */
2537 - } /* if */
2538 - } /* if */
2539 - return array_unique($ret);
2540 - } /* FeedFinder::find () */
2541 -
2542 - function data ($uri = NULL) {
2543 - $this->_get($uri);
2544 - return $this->_data;
2545 - }
2546 -
2547 - function is_feed ($uri = NULL) {
2548 - $data = $this->data($uri);
2549 -
2550 - return (
2551 - preg_match (
2552 - "\007(".implode('|',$this->_feed_markers).")\007i",
2553 - $data
2554 - ) and !preg_match (
2555 - "\007(".implode('|',$this->_html_markers).")\007i",
2556 - $data
2557 - )
2558 - );
2559 - } /* FeedFinder::is_feed () */
2560 -
2561 - # --- Private methods ---
2562 - function _get ($uri = NULL) {
2563 - if ($uri) $this->uri = $uri;
2564 -
2565 - // Is the result not yet cached?
2566 - if ($this->_cache_uri !== $this->uri) :
2567 - // Snoopy is an HTTP client in PHP
2568 - $client = new Snoopy();
2569 -
2570 - // Prepare headers and internal settings
2571 - $client->rawheaders['Connection'] = 'close';
2572 - $client->accept = 'application/atom+xml application/rdf+xml application/rss+xml application/xml text/html */*';
2573 - $client->agent = 'feedfinder/1.2 (compatible; PHP FeedFinder) +http://projects.radgeek.com/feedwordpress';
2574 - $client->read_timeout = 25;
2575 -
2576 - // Fetch the HTML or feed
2577 - @$client->fetch($this->uri);
2578 - $this->_data = $client->results;
2579 -
2580 - // Kilroy was here
2581 - $this->_cache_uri = $this->uri;
2073 + function ping ($args) {
2074 + global $feedwordpress;
2075 +
2076 + $delta = @$feedwordpress->update($args[1]);
2077 + if (is_null($delta)):
2078 + return array('flerror' => true, 'message' => "Sorry. I don't syndicate <$args[1]>.");
2079 + else:
2080 + $mesg = array();
2081 + if (isset($delta['new'])) { $mesg[] = ' '.$delta['new'].' new posts were syndicated'; }
2082 + if (isset($delta['updated'])) { $mesg[] = ' '.$delta['updated'].' existing posts were updated'; }
2083 +
2084 + return array('flerror' => false, 'message' => "Thanks for the ping.".implode(' and', $mesg));
2582 2085 endif;
2583 - } /* FeedFinder::_get () */
2584 -
2585 - function _link_rel_feeds () {
2586 - $links = $this->_tags('link');
2587 - $link_count = count($links);
2588 -
2589 - // now figure out which one points to the RSS file
2590 - $href = array ();
2591 - for ($n=0; $n<$link_count; $n++) {
2592 - if (strtolower($links[$n]['rel']) == 'alternate') {
2593 - if (in_array(strtolower($links[$n]['type']), $this->_feed_types)) {
2594 - $href[] = $links[$n]['href'];
2595 - } /* if */
2596 - } /* if */
2597 - } /* for */
2598 - return $href;
2599 2086 }
2087 +
2088 + function validate (&$args) {
2089 + global $wp_xmlrpc_server;
2600 2090
2601 - function _a_href_feeds ($obvious = TRUE) {
2602 - $pattern = ($obvious ? $this->_obvious_feed_url : $this->_maybe_feed_url);
2091 + // First two params are username/password
2092 + $username = $wp_xmlrpc_server->escape(array_shift($args));
2093 + $password = $wp_xmlrpc_server->escape(array_shift($args));
2603 2094
2604 - $links = $this->_tags('a');
2605 - $link_count = count($links);
2606 -
2607 - // now figure out which one points to the RSS file
2608 - $href = array ();
2609 - for ($n=0; $n<$link_count; $n++) {
2610 - if (preg_match("\007(".implode('|',$pattern).")\007i", $links[$n]['href'])) {
2611 - $href[] = $links[$n]['href'];
2612 - } /* if */
2613 - } /* for */
2614 - return $href;
2615 - }
2616 -
2617 - function _tags ($tag) {
2618 - $html = $this->data();
2619 -
2620 - // search through the HTML, save all <link> tags
2621 - // and store each link's attributes in an associative array
2622 - preg_match_all('/<'.$tag.'\s+(.*?)\s*\/?>/si', $html, $matches);
2623 - $links = $matches[1];
2624 2095 $ret = array();
2625 - $link_count = count($links);
2626 - for ($n=0; $n<$link_count; $n++) {
2627 - $attributes = preg_split('/\s+/s', $links[$n]);
2628 - foreach($attributes as $attribute) {
2629 - $att = preg_split('/\s*=\s*/s', $attribute, 2);
2630 - if (isset($att[1])) {
2631 - $att[1] = preg_replace('/([\'"]?)(.*)\1/', '$2', $att[1]);
2632 - $final_link[strtolower($att[0])] = $att[1];
2633 - } /* if */
2634 - } /* foreach */
2635 - $ret[$n] = $final_link;
2636 - } /* for */
2096 + if ( !$user = $wp_xmlrpc_server->login($username, $password) ) :
2097 + $ret = $wp_xmlrpc_server->error;
2098 + elseif (!current_user_can('manage_links')) :
2099 + $ret = new IXR_Error(401, 'Sorry, you cannot change the subscription list.');
2100 + endif;
2637 2101 return $ret;
2638 2102 }
2639 -} /* class FeedFinder */
2640 2103
2641 -# Relative URI static class: PHP class for resolving relative URLs
2642 -#
2643 -# This class is derived (under the terms of the GPL) from URL Class 0.3 by
2644 -# Keyvan Minoukadeh <keyvan@k1m.com>, which is great but more than we need
2645 -# for FeedWordPress's purposes. The class has been stripped down to a single
2646 -# public method: Relative_URI::resolve($url, $base), which resolves the URI in
2647 -# $url relative to the URI in $base
2648 -#
2649 -# The upgraded MagpieRSS also uses this class. So if we have it loaded
2650 -# in, don't load it again.
2651 -if (!class_exists('Relative_URI')) {
2652 -
2653 - class Relative_URI
2654 - {
2655 - // Resolve relative URI in $url against the base URI in $base. If $base
2656 - // is not supplied, then we use the REQUEST_URI of this script.
2657 - //
2658 - // I'm hoping this method reflects RFC 2396 Section 5.2
2659 - function resolve ($url, $base = NULL)
2660 - {
2661 - if (is_null($base)):
2662 - $base = 'http://'.$_SERVER['HTTP_HOST'].$_SERVER['REQUEST_URI'];
2663 - endif;
2104 + function subscribe ($args) {
2105 + $ret = $this->validate($args);
2106 + if (is_array($ret)) : // Success
2107 + // The remaining params are feed URLs
2108 + foreach ($args as $arg) :
2109 + $finder = new FeedFinder($arg, /*verify=*/ false, /*fallbacks=*/ 1);
2110 + $feeds = array_values(array_unique($finder->find()));
2111 +
2112 + if (count($feeds) > 0) :
2113 + $link_id = FeedWordPress::syndicate_link(
2114 + /*title=*/ feedwordpress_display_url($feeds[0]),
2115 + /*homepage=*/ $feeds[0],
2116 + /*feed=*/ $feeds[0]
2117 + );
2118 + $ret[] = array(
2119 + 'added',
2120 + $feeds[0],
2121 + $arg,
2122 + );
2123 + else :
2124 + $ret[] = array(
2125 + 'error',
2126 + $arg
2127 + );
2128 + endif;
2129 + endforeach;
2130 + endif;
2131 + return $ret;
2132 + } /* FeedWordPressRPC::subscribe () */
2664 2133
2665 - $base = Relative_URI::_encode(trim($base));
2666 - $uri_parts = Relative_URI::_parse_url($base);
2667 -
2668 - $url = Relative_URI::_encode(trim($url));
2669 - $parts = Relative_URI::_parse_url($url);
2670 -
2671 - $uri_parts['fragment'] = (isset($parts['fragment']) ? $parts['fragment'] : null);
2672 - $uri_parts['query'] = (isset($parts['query']) ? $parts['query'] : null);
2673 -
2674 - // if path is empty, and scheme, host, and query are undefined,
2675 - // the URL is referring the base URL
2676 -
2677 - if (($parts['path'] == '') && !isset($parts['scheme']) && !isset($parts['host']) && !isset($parts['query'])) {
2678 - // If the URI is empty or only a fragment, return the base URI
2679 - return $base . (isset($parts['fragment']) ? '#'.$parts['fragment'] : '');
2680 - } elseif (isset($parts['scheme'])) {
2681 - // If the scheme is set, then the URI is absolute.
2682 - return $url;
2683 - } elseif (isset($parts['host'])) {
2684 - $uri_parts['host'] = $parts['host'];
2685 - $uri_parts['path'] = $parts['path'];
2686 - } else {
2687 - // We have a relative path but not a host.
2688 -
2689 - // start ugly fix:
2690 - // prepend slash to path if base host is set, base path is not set, and url path is not absolute
2691 - if ($uri_parts['host'] && ($uri_parts['path'] == '')
2692 - && (strlen($parts['path']) > 0)
2693 - && (substr($parts['path'], 0, 1) != '/')) {
2694 - $parts['path'] = '/'.$parts['path'];
2695 - } // end ugly fix
2134 + function unsubscribe ($method, $args) {
2135 + $ret = $this->validate($args);
2136 + if (is_array($ret)) : // Success
2137 + // The remaining params are feed URLs
2138 + foreach ($args as $arg) :
2139 + $link_id = FeedWordPress::find_link($arg);
2696 2140
2697 - if (substr($parts['path'], 0, 1) == '/') {
2698 - $uri_parts['path'] = $parts['path'];
2699 - } else {
2700 - // copy base path excluding any characters after the last (right-most) slash character
2701 - $buffer = substr($uri_parts['path'], 0, (int)strrpos($uri_parts['path'], '/')+1);
2702 - // append relative path
2703 - $buffer .= $parts['path'];
2704 - // remove "./" where "." is a complete path segment.
2705 - $buffer = str_replace('/./', '/', $buffer);
2706 - if (substr($buffer, 0, 2) == './') {
2707 - $buffer = substr($buffer, 2);
2708 - }
2709 - // if buffer ends with "." as a complete path segment, remove it
2710 - if (substr($buffer, -2) == '/.') {
2711 - $buffer = substr($buffer, 0, -1);
2712 - }
2713 - // remove "<segment>/../" where <segment> is a complete path segment not equal to ".."
2714 - $search_finished = false;
2715 - $segment = explode('/', $buffer);
2716 - while (!$search_finished) {
2717 - for ($x=0; $x+1 < count($segment);) {
2718 - if (($segment[$x] != '') && ($segment[$x] != '..') && ($segment[$x+1] == '..')) {
2719 - if ($x+2 == count($segment)) $segment[] = '';
2720 - unset($segment[$x], $segment[$x+1]);
2721 - $segment = array_values($segment);
2722 - continue 2;
2723 - } else {
2724 - $x++;
2725 - }
2726 - }
2727 - $search_finished = true;
2728 - }
2729 - $buffer = (count($segment) == 1) ? '/' : implode('/', $segment);
2730 - $uri_parts['path'] = $buffer;
2141 + if (!$link_id) :
2142 + $link_id = FeedWordPress::find_link($arg, 'link_url');
2143 + endif;
2144 +
2145 + if ($link_id) :
2146 + $link = new SyndicatedLink($link_id);
2147 +
2148 + $link->{$method}();
2149 + $ret[] = array(
2150 + 'deactivated',
2151 + $arg,
2152 + );
2153 + else :
2154 + $ret[] = array(
2155 + 'error',
2156 + $arg,
2157 + );
2158 + endif;
2159 + endforeach;
2160 + endif;
2161 + return $ret;
2162 + } /* FeedWordPress::unsubscribe () */
2731 2163
2732 - }
2733 - }
2164 + function deactivate ($args) {
2165 + return $this->unsubscribe('deactivate', $args);
2166 + } /* FeedWordPressRPC::deactivate () */
2734 2167
2735 - // If we've gotten to this point, we can try to put the pieces
2736 - // back together.
2737 - $ret = '';
2738 - if (isset($uri_parts['scheme'])) $ret .= $uri_parts['scheme'].':';
2739 - if (isset($uri_parts['user'])) {
2740 - $ret .= $uri_parts['user'];
2741 - if (isset($uri_parts['pass'])) $ret .= ':'.$uri_parts['parts'];
2742 - $ret .= '@';
2743 - }
2744 - if (isset($uri_parts['host'])) {
2745 - $ret .= '//'.$uri_parts['host'];
2746 - if (isset($uri_parts['port'])) $ret .= ':'.$uri_parts['port'];
2747 - }
2748 - $ret .= $uri_parts['path'];
2749 - if (isset($uri_parts['query'])) $ret .= '?'.$uri_parts['query'];
2750 - if (isset($uri_parts['fragment'])) $ret .= '#'.$uri_parts['fragment'];
2168 + function delete ($args) {
2169 + return $this->unsubscribe('delete', $args);
2170 + } /* FeedWordPressRPC::delete () */
2751 2171
2752 - return $ret;
2753 - }
2754 -
2755 - /**
2756 - * Parse URL
2757 - *
2758 - * Regular expression grabbed from RFC 2396 Appendix B.
2759 - * This is a replacement for PHPs builtin parse_url().
2760 - * @param string $url
2761 - * @access private
2762 - * @return array
2763 - */
2764 - function _parse_url($url)
2765 - {
2766 - // I'm using this pattern instead of parse_url() as there's a few strings where parse_url()
2767 - // generates a warning.
2768 - if (preg_match('!^(([^:/?#]+):)?(//([^/?#]*))?([^?#]*)(\?([^#]*))?(#(.*))?!', $url, $match)) {
2769 - $parts = array();
2770 - if ($match[1] != '') $parts['scheme'] = $match[2];
2771 - if ($match[3] != '') $parts['auth'] = $match[4];
2772 - // parse auth
2773 - if (isset($parts['auth'])) {
2774 - // store user info
2775 - if (($at_pos = strpos($parts['auth'], '@')) !== false) {
2776 - $userinfo = explode(':', substr($parts['auth'], 0, $at_pos), 2);
2777 - $parts['user'] = $userinfo[0];
2778 - if (isset($userinfo[1])) $parts['pass'] = $userinfo[1];
2779 - $parts['auth'] = substr($parts['auth'], $at_pos+1);
2780 - }
2781 - // get port number
2782 - if ($port_pos = strrpos($parts['auth'], ':')) {
2783 - $parts['host'] = substr($parts['auth'], 0, $port_pos);
2784 - $parts['port'] = (int)substr($parts['auth'], $port_pos+1);
2785 - if ($parts['port'] < 1) $parts['port'] = null;
2786 - } else {
2787 - $parts['host'] = $parts['auth'];
2788 - }
2789 - }
2790 - unset($parts['auth']);
2791 - $parts['path'] = $match[5];
2792 - if (isset($match[6]) && ($match[6] != '')) $parts['query'] = $match[7];
2793 - if (isset($match[8]) && ($match[8] != '')) $parts['fragment'] = $match[9];
2794 - return $parts;
2795 - }
2796 - // shouldn't reach here
2797 - return array('path'=>'');
2798 - }
2799 -
2800 - function _encode($string)
2801 - {
2802 - static $replace = array();
2803 - if (!count($replace)) {
2804 - $find = array(32, 34, 60, 62, 123, 124, 125, 91, 92, 93, 94, 96, 127);
2805 - $find = array_merge(range(0, 31), $find);
2806 - $find = array_map('chr', $find);
2807 - foreach ($find as $char) {
2808 - $replace[$char] = '%'.bin2hex($char);
2809 - }
2810 - }
2811 - // escape control characters and a few other characters
2812 - $encoded = strtr($string, $replace);
2813 - // remove any character outside the hex range: 21 - 7E (see www.asciitable.com)
2814 - return preg_replace('/[^\x21-\x7e]/', '', $encoded);
2815 - }
2816 - } // class Relative_URI
2817 -}
2172 + function nuke ($args) {
2173 + return $this->unsubscribe('nuke', $args);
2174 + } /* FeedWordPressRPC::nuke () */
2175 +} /* class FeedWordPressRPC */
2818 2176
2819 2177 // take your best guess at the realname and e-mail, given a string
2820 2178 define('FWP_REGEX_EMAIL_ADDY', '([^@"(<\s]+@[^"@(<\s]+\.[^"@(<\s]+)');
2821 2179 define('FWP_REGEX_EMAIL_NAME', '("([^"]*)"|([^"<(]+\S))');