mediawiki-extensions-Echo/ServiceWiring.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