RedisPubSubFeedEngine.php

Go to the documentation of this file.

<?php
namespace MediaWiki\RCFeed;
 
use MediaWiki\MediaWikiServices;
use Wikimedia\ObjectCache\RedisConnectionPool;
 
class RedisPubSubFeedEngine extends FormattedRCFeed {
 
    public function send( array $feed, $line ) {
        $urlUtils = MediaWikiServices::getInstance()->getUrlUtils();
        $parsed = $urlUtils->parse( $feed['uri'] );
        // @phan-suppress-next-line PhanTypeArraySuspiciousNullable Valid URL
        $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;
        }
 
        return false;
    }
}
class_alias( RedisPubSubFeedEngine::class, 'RedisPubSubFeedEngine' );