diff options
Diffstat (limited to 'www/wiki/includes/rcfeed/RedisPubSubFeedEngine.php')
-rw-r--r-- | www/wiki/includes/rcfeed/RedisPubSubFeedEngine.php | 75 |
1 files changed, 75 insertions, 0 deletions
diff --git a/www/wiki/includes/rcfeed/RedisPubSubFeedEngine.php b/www/wiki/includes/rcfeed/RedisPubSubFeedEngine.php new file mode 100644 index 00000000..8a3aa0c1 --- /dev/null +++ b/www/wiki/includes/rcfeed/RedisPubSubFeedEngine.php @@ -0,0 +1,75 @@ +<?php +/** + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. + * http://www.gnu.org/copyleft/gpl.html + * + * @file + */ + +/** + * Send recent change notifications via Redis Pub/Sub + * + * If the feed URI contains a path component, it will be used to generate a + * channel name by stripping the leading slash and replacing any remaining + * slashes with '.'. If no path component is present, the channel is set to + * 'rc'. If the URI contains a query string, its parameters will be parsed + * as RedisConnectionPool options. + * + * @par Example: + * @code + * $wgRCFeeds['redis'] = array( + * 'formatter' => 'JSONRCFeedFormatter', + * 'uri' => "redis://127.0.0.1:6379/rc.$wgDBname", + * ); + * @endcode + * + * @since 1.22 + */ +class RedisPubSubFeedEngine extends RCFeedEngine { + + /** + * @see FormattedRCFeed::send + * @param array $feed + * @param string $line + * @return bool + */ + public function send( array $feed, $line ) { + $parsed = wfParseUrl( $feed['uri'] ); + $server = $parsed['host']; + $options = [ 'serializer' => 'none' ]; + $channel = 'rc'; + + if ( isset( $parsed['port'] ) ) { + $server .= ":{$parsed['port']}"; + } + if ( isset( $parsed['query'] ) ) { + parse_str( $parsed['query'], $options ); + } + if ( isset( $parsed['pass'] ) ) { + $options['password'] = $parsed['pass']; + } + if ( isset( $parsed['path'] ) ) { + $channel = str_replace( '/', '.', ltrim( $parsed['path'], '/' ) ); + } + $pool = RedisConnectionPool::singleton( $options ); + $conn = $pool->getConnection( $server ); + if ( $conn !== false ) { + $conn->publish( $channel, $line ); + return true; + } else { + return false; + } + } +} |