mirror of
https://gerrit.wikimedia.org/r/mediawiki/extensions/Echo
synced 2024-11-11 17:00:10 +00:00
110 lines
3.5 KiB
PHP
110 lines
3.5 KiB
PHP
<?php
|
|
|
|
use MediaWiki\Extension\Notifications\AttributeManager;
|
|
use MediaWiki\Extension\Notifications\Cache\RevisionLocalCache;
|
|
use MediaWiki\Extension\Notifications\Cache\TitleLocalCache;
|
|
use MediaWiki\Extension\Notifications\Push\NotificationServiceClient;
|
|
use MediaWiki\Extension\Notifications\Push\SubscriptionManager;
|
|
use MediaWiki\Logger\LoggerFactory;
|
|
use MediaWiki\MediaWikiServices;
|
|
use MediaWiki\Storage\NameTableStore;
|
|
|
|
// PHP unit does not understand code coverage for this file
|
|
// as the @covers annotation cannot cover a specific file.
|
|
// Whether the services return without error is checked in ServiceWiringTest.php
|
|
// @codeCoverageIgnoreStart
|
|
|
|
return [
|
|
|
|
'EchoAttributeManager' => static function ( MediaWikiServices $services ): AttributeManager {
|
|
$userGroupManager = $services->getUserGroupManager();
|
|
$echoConfig = $services->getConfigFactory()->makeConfig( 'Echo' );
|
|
$notifications = $echoConfig->get( 'EchoNotifications' );
|
|
$categories = $echoConfig->get( 'EchoNotificationCategories' );
|
|
$typeAvailability = $echoConfig->get( 'DefaultNotifyTypeAvailability' );
|
|
$typeAvailabilityByCategory = $echoConfig->get( 'NotifyTypeAvailabilityByCategory' );
|
|
|
|
return new AttributeManager(
|
|
$notifications,
|
|
$categories,
|
|
$typeAvailability,
|
|
$typeAvailabilityByCategory,
|
|
$userGroupManager,
|
|
$services->getUserOptionsLookup()
|
|
);
|
|
},
|
|
|
|
'EchoPushNotificationServiceClient' => static function (
|
|
MediaWikiServices $services
|
|
): NotificationServiceClient {
|
|
$echoConfig = $services->getConfigFactory()->makeConfig( 'Echo' );
|
|
$httpRequestFactory = $services->getHttpRequestFactory();
|
|
$url = $echoConfig->get( 'EchoPushServiceBaseUrl' );
|
|
$client = new NotificationServiceClient( $httpRequestFactory, $url );
|
|
$client->setLogger( LoggerFactory::getInstance( 'Echo' ) );
|
|
return $client;
|
|
},
|
|
|
|
'EchoPushSubscriptionManager' => static function ( MediaWikiServices $services ): SubscriptionManager {
|
|
$echoConfig = $services->getConfigFactory()->makeConfig( 'Echo' );
|
|
// Use shared DB/cluster for push subscriptions
|
|
$cluster = $echoConfig->get( 'EchoSharedTrackingCluster' );
|
|
$database = $echoConfig->get( 'EchoSharedTrackingDB' );
|
|
$loadBalancerFactory = $services->getDBLoadBalancerFactory();
|
|
$loadBalancer = $cluster
|
|
? $loadBalancerFactory->getExternalLB( $cluster )
|
|
: $loadBalancerFactory->getMainLB( $database );
|
|
$dbw = $loadBalancer->getConnection( DB_PRIMARY, [], $database );
|
|
$dbr = $loadBalancer->getConnection( DB_REPLICA, [], $database );
|
|
|
|
$pushProviderStore = new NameTableStore(
|
|
$loadBalancer,
|
|
$services->getMainWANObjectCache(),
|
|
LoggerFactory::getInstance( 'Echo' ),
|
|
'echo_push_provider',
|
|
'epp_id',
|
|
'epp_name',
|
|
null,
|
|
$database
|
|
);
|
|
|
|
$pushTopicStore = new NameTableStore(
|
|
$loadBalancer,
|
|
$services->getMainWANObjectCache(),
|
|
LoggerFactory::getInstance( 'Echo' ),
|
|
'echo_push_topic',
|
|
'ept_id',
|
|
'ept_text',
|
|
null,
|
|
$database
|
|
);
|
|
|
|
$maxSubscriptionsPerUser = $echoConfig->get( 'EchoPushMaxSubscriptionsPerUser' );
|
|
|
|
return new SubscriptionManager(
|
|
$dbw,
|
|
$dbr,
|
|
$pushProviderStore,
|
|
$pushTopicStore,
|
|
$maxSubscriptionsPerUser
|
|
);
|
|
},
|
|
|
|
'EchoTitleLocalCache' => static function ( MediaWikiServices $services ): TitleLocalCache {
|
|
return new TitleLocalCache(
|
|
$services->getPageStore(),
|
|
$services->getTitleFactory()
|
|
);
|
|
},
|
|
|
|
'EchoRevisionLocalCache' => static function ( MediaWikiServices $services ): RevisionLocalCache {
|
|
return new RevisionLocalCache(
|
|
$services->getConnectionProvider(),
|
|
$services->getRevisionStore()
|
|
);
|
|
}
|
|
|
|
];
|
|
|
|
// @codeCoverageIgnoreEnd
|