Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 47c4b0a

Browse filesBrowse files
fabpotfabpot
committed
[Notifier] added the component
1 parent 77e42d8 commit 47c4b0a
Copy full SHA for 47c4b0a

File tree

107 files changed

+4438
-0
lines changed
Filter options

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
Dismiss banner

107 files changed

+4438
-0
lines changed

‎composer.json

Copy file name to clipboardExpand all lines: composer.json
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@
6767
"symfony/messenger": "self.version",
6868
"symfony/mime": "self.version",
6969
"symfony/monolog-bridge": "self.version",
70+
"symfony/notifier": "self.version",
7071
"symfony/options-resolver": "self.version",
7172
"symfony/postmark-mailer": "self.version",
7273
"symfony/process": "self.version",

‎src/Symfony/Bridge/Monolog/Handler/NotifierHandler.php

Copy file name to clipboard
+75Lines changed: 75 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,75 @@
1+
<?php
2+
3+
/*
4+
* This file is part of the Symfony package.
5+
*
6+
* (c) Fabien Potencier <fabien@symfony.com>
7+
*
8+
* For the full copyright and license information, please view the LICENSE
9+
* file that was distributed with this source code.
10+
*/
11+
12+
namespace Symfony\Bridge\Monolog\Handler;
13+
14+
use Monolog\Handler\AbstractHandler;
15+
use Monolog\Logger;
16+
use Symfony\Component\Notifier\Notification\Notification;
17+
use Symfony\Component\Notifier\Notifier;
18+
use Symfony\Component\Notifier\NotifierInterface;
19+
20+
/**
21+
* Uses Notifier as a log handler.
22+
*
23+
* @author Fabien Potencier <fabien@symfony.com>
24+
*/
25+
class NotifierHandler extends AbstractHandler
26+
{
27+
private $notifier;
28+
29+
public function __construct(NotifierInterface $notifier, int $level = Logger::ERROR, bool $bubble = true)
30+
{
31+
$this->notifier = $notifier;
32+
33+
parent::__construct($level < Logger::ERROR ? Logger::ERROR : $level, $bubble);
34+
}
35+
36+
public function handle(array $record): bool
37+
{
38+
if (!$this->isHandling($record)) {
39+
return false;
40+
}
41+
42+
$this->notify([$record]);
43+
44+
return !$this->bubble;
45+
}
46+
47+
public function handleBatch(array $records): void
48+
{
49+
if ($records = array_filter($records, [$this, 'isHandling'])) {
50+
$this->notify($records);
51+
}
52+
}
53+
54+
private function notify(array $records): void
55+
{
56+
$record = max(array_column($records, 'level'));
57+
if ($record['context']['exception'] instanceof \Throwable) {
58+
$notification = Notification::fromThrowable($record['context']['exception']);
59+
} else {
60+
$notification = new Notification($record['message']);
61+
}
62+
63+
$notification->importanceFromLogLevel(strtolower(Logger::getLevelName($record['level'])));
64+
65+
try {
66+
$this->notifier->send($notification, ...Notifier::getAdminReceivers());
67+
} catch (\Throwable $e) {
68+
$message = $e->getMessage();
69+
while ($e = $e->getPrevious()) {
70+
$message .= ' > '.$e->getMessage();
71+
}
72+
trigger_error($message, E_USER_ERROR);
73+
}
74+
}
75+
}

‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/Configuration.php

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/DependencyInjection/Configuration.php
+48Lines changed: 48 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
use Symfony\Component\Lock\Store\SemaphoreStore;
2828
use Symfony\Component\Mailer\Mailer;
2929
use Symfony\Component\Messenger\MessageBusInterface;
30+
use Symfony\Component\Notifier\Notifier;
3031
use Symfony\Component\PropertyInfo\PropertyInfoExtractorInterface;
3132
use Symfony\Component\Serializer\Serializer;
3233
use Symfony\Component\Translation\Translator;
@@ -114,6 +115,7 @@ public function getConfigTreeBuilder()
114115
$this->addRobotsIndexSection($rootNode);
115116
$this->addHttpClientSection($rootNode);
116117
$this->addMailerSection($rootNode);
118+
$this->addNotifierSection($rootNode);
117119

118120
return $treeBuilder;
119121
}
@@ -1459,4 +1461,50 @@ private function addMailerSection(ArrayNodeDefinition $rootNode)
14591461
->end()
14601462
;
14611463
}
1464+
1465+
private function addNotifierSection(ArrayNodeDefinition $rootNode)
1466+
{
1467+
$rootNode
1468+
->children()
1469+
->arrayNode('notifier')
1470+
->info('Notifier configuration')
1471+
->{!class_exists(FullStack::class) && class_exists(Notifier::class) ? 'canBeDisabled' : 'canBeEnabled'}()
1472+
->fixXmlConfig('chatter_transport')
1473+
->children()
1474+
->arrayNode('chatter_transports')
1475+
->useAttributeAsKey('name')
1476+
->prototype('scalar')->end()
1477+
->end()
1478+
->end()
1479+
->fixXmlConfig('texter_transport')
1480+
->children()
1481+
->arrayNode('texter_transports')
1482+
->useAttributeAsKey('name')
1483+
->prototype('scalar')->end()
1484+
->end()
1485+
->end()
1486+
->children()
1487+
->arrayNode('channel_policy')
1488+
->useAttributeAsKey('name')
1489+
->prototype('array')
1490+
->beforeNormalization()->ifString()->then(function ($v) { return [$v]; })->end()
1491+
->prototype('scalar')->end()
1492+
->end()
1493+
->end()
1494+
->end()
1495+
->fixXmlConfig('admin_receiver')
1496+
->children()
1497+
->arrayNode('admin_receivers')
1498+
->prototype('array')
1499+
->children()
1500+
->scalarNode('email')->cannotBeEmpty()->end()
1501+
->scalarNode('phone')->defaultNull()->end()
1502+
->end()
1503+
->end()
1504+
->end()
1505+
->end()
1506+
->end()
1507+
->end()
1508+
;
1509+
}
14621510
}

‎src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/DependencyInjection/FrameworkExtension.php
+68Lines changed: 68 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,12 @@
8989
use Symfony\Component\Messenger\Transport\TransportInterface;
9090
use Symfony\Component\Mime\MimeTypeGuesserInterface;
9191
use Symfony\Component\Mime\MimeTypes;
92+
use Symfony\Component\Notifier\Bridge\Nexmo\NexmoTransportFactory;
93+
use Symfony\Component\Notifier\Bridge\Slack\SlackTransportFactory;
94+
use Symfony\Component\Notifier\Bridge\Telegram\TelegramTransportFactory;
95+
use Symfony\Component\Notifier\Bridge\Twilio\TwilioTransportFactory;
96+
use Symfony\Component\Notifier\Notifier;
97+
use Symfony\Component\Notifier\Receiver\AdminReceiver;
9298
use Symfony\Component\PropertyAccess\PropertyAccessor;
9399
use Symfony\Component\PropertyInfo\PropertyAccessExtractorInterface;
94100
use Symfony\Component\PropertyInfo\PropertyDescriptionExtractorInterface;
@@ -140,6 +146,7 @@ class FrameworkExtension extends Extension
140146
private $messengerConfigEnabled = false;
141147
private $mailerConfigEnabled = false;
142148
private $httpClientConfigEnabled = false;
149+
private $notifierConfigEnabled = false;
143150

144151
/**
145152
* Responds to the app.config configuration parameter.
@@ -297,6 +304,10 @@ public function load(array $configs, ContainerBuilder $container)
297304
$this->registerMailerConfiguration($config['mailer'], $container, $loader);
298305
}
299306

307+
if ($this->notifierConfigEnabled = $this->isConfigEnabled($container, $config['notifier'])) {
308+
$this->registerNotifierConfiguration($config['notifier'], $container, $loader);
309+
}
310+
300311
$propertyInfoEnabled = $this->isConfigEnabled($container, $config['property_info']);
301312
$this->registerValidationConfiguration($config['validation'], $container, $loader, $propertyInfoEnabled);
302313
$this->registerEsiConfiguration($config['esi'], $container, $loader);
@@ -1843,6 +1854,63 @@ private function registerMailerConfiguration(array $config, ContainerBuilder $co
18431854
$envelopeListener->setArgument(1, $recipients);
18441855
}
18451856

1857+
private function registerNotifierConfiguration(array $config, ContainerBuilder $container, XmlFileLoader $loader)
1858+
{
1859+
if (!class_exists(Notifier::class)) {
1860+
throw new LogicException('Notifier support cannot be enabled as the component is not installed. Try running "composer require symfony/notifier".');
1861+
}
1862+
1863+
$loader->load('notifier.xml');
1864+
$loader->load('notifier_transports.xml');
1865+
1866+
if ($config['chatter_transports']) {
1867+
$container->getDefinition('chatter.transports')->setArgument(0, $config['chatter_transports']);
1868+
} else {
1869+
$container->removeDefinition('chatter');
1870+
}
1871+
if ($config['texter_transports']) {
1872+
$container->getDefinition('texter.transports')->setArgument(0, $config['texter_transports']);
1873+
} else {
1874+
$container->removeDefinition('texter');
1875+
}
1876+
1877+
if ($this->mailerConfigEnabled) {
1878+
$sender = $container->getDefinition('mailer.envelope_listener')->getArgument(0);
1879+
$container->getDefinition('notifier.email_channel')->setArgument(1, $sender);
1880+
} else {
1881+
$container->removeDefinition('notifier.email_channel');
1882+
}
1883+
1884+
if (!$this->messengerConfigEnabled) {
1885+
$container->removeDefinition('notifier.failed_message_listener');
1886+
}
1887+
1888+
$container->getDefinition('notifier.channel_policy')->setArgument(0, $config['channel_policy']);
1889+
1890+
$classToServices = [
1891+
SlackTransportFactory::class => 'notifier.transport_factory.slack',
1892+
TelegramTransportFactory::class => 'notifier.transport_factory.telegram',
1893+
NexmoTransportFactory::class => 'notifier.transport_factory.nexmo',
1894+
TwilioTransportFactory::class => 'notifier.transport_factory.twilio',
1895+
];
1896+
1897+
foreach ($classToServices as $class => $service) {
1898+
if (!class_exists($class)) {
1899+
$container->removeDefinition($service);
1900+
}
1901+
}
1902+
1903+
if (isset($config['admin_receivers'])) {
1904+
$notifier = $container->getDefinition('notifier');
1905+
foreach ($config['admin_receivers'] as $i => $receiver) {
1906+
$id = 'notifier.admin_receiver.'.$i;
1907+
$def = $container->setDefinition($id, new Definition(AdminReceiver::class, [$receiver['email'], $receiver['phone']]));
1908+
$def->setPublic(false);
1909+
$notifier->addMethodCall('addAdminReceiver', [new Reference($id)]);
1910+
}
1911+
}
1912+
}
1913+
18461914
/**
18471915
* {@inheritdoc}
18481916
*/

‎src/Symfony/Bundle/FrameworkBundle/Resources/config/notifier.xml

Copy file name to clipboard
+92Lines changed: 92 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,92 @@
1+
<?xml version="1.0" encoding="UTF-8" ?>
2+
3+
<container xmlns="http://symfony.com/schema/dic/services"
4+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
5+
xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
6+
7+
<services>
8+
<service id="notifier" class="Symfony\Component\Notifier\Notifier">
9+
<argument type="tagged_locator" tag="notifier.channel" index-by="key" />
10+
<argument type="service" id="notifier.channel_policy" on-invalid="ignore" />
11+
<argument type="service" id="messenger.default_bus" on-invalid="ignore" />
12+
</service>
13+
<service id="Symfony\Component\Notifier\NotifierInterface" alias="notifier" />
14+
15+
<service id="notifier.channel_policy" class="Symfony\Component\Notifier\Channel\ChannelPolicy">
16+
<argument type="collection" /> <!-- policy -->
17+
</service>
18+
19+
<service id="notifier.browser_channel" class="Symfony\Component\Notifier\Channel\BrowserChannel">
20+
<argument type="service" id="request_stack" />
21+
<tag name="notifier.channel" key="browser" />
22+
</service>
23+
24+
<service id="notifier.chat_channel" class="Symfony\Component\Notifier\Channel\ChatChannel">
25+
<argument type="service" id="chatter.transports" />
26+
<tag name="notifier.channel" key="chat" />
27+
</service>
28+
29+
<service id="notifier.sms_channel" class="Symfony\Component\Notifier\Channel\SmsChannel">
30+
<argument type="service" id="texter.transports" />
31+
<tag name="notifier.channel" key="sms" />
32+
</service>
33+
34+
<service id="notifier.email_channel" class="Symfony\Component\Notifier\Channel\EmailChannel">
35+
<argument type="service" id="mailer.transports" />
36+
<tag name="notifier.channel" key="email" />
37+
</service>
38+
39+
<service id="notifier.monolog_handler" class="Symfony\Bridge\Monolog\Handler\NotifierHandler">
40+
<argument type="service" id="notifier" />
41+
</service>
42+
43+
<service id="notifier.failed_message_listener" class="Symfony\Component\Notifier\EventListener\SendFailedMessageToNotifierListener">
44+
<argument type="service" id="notifier" />
45+
<tag name="kernel.event_subscriber" />
46+
</service>
47+
48+
<!-- chatter -->
49+
<service id="chatter" class="Symfony\Component\Notifier\Chatter">
50+
<argument type="service" id="chatter.transports" />
51+
<argument type="service" id="messenger.default_bus" on-invalid="ignore" />
52+
<argument type="service" id="event_dispatcher" on-invalid="ignore" />
53+
</service>
54+
<service id="Symfony\Component\Notifier\ChatterInterface" alias="chatter" />
55+
56+
<service id="chatter.transports" class="Symfony\Component\Notifier\Transport\Transports">
57+
<factory service="chatter.transport_factory" method="fromStrings" />
58+
<argument type="collection" /> <!-- transports -->
59+
</service>
60+
61+
<service id="chatter.transport_factory" class="Symfony\Component\Notifier\Transport">
62+
<argument type="tagged_iterator" tag="chatter.transport_factory" />
63+
</service>
64+
65+
<service id="chatter.messenger.chat_handler" class="Symfony\Component\Notifier\Messenger\MessageHandler">
66+
<argument type="service" id="chatter.transports" />
67+
<tag name="messenger.message_handler" handles="Symfony\Component\Notifier\Message\ChatMessage" />
68+
</service>
69+
70+
<!-- texter -->
71+
<service id="texter" class="Symfony\Component\Notifier\Texter">
72+
<argument type="service" id="texter.transports" />
73+
<argument type="service" id="messenger.default_bus" on-invalid="ignore" />
74+
<argument type="service" id="event_dispatcher" on-invalid="ignore" />
75+
</service>
76+
<service id="Symfony\Component\Notifier\TexterInterface" alias="texter" />
77+
78+
<service id="texter.transports" class="Symfony\Component\Notifier\Transport\Transports">
79+
<factory service="texter.transport_factory" method="fromStrings" />
80+
<argument type="collection" /> <!-- transports -->
81+
</service>
82+
83+
<service id="texter.transport_factory" class="Symfony\Component\Notifier\Transport">
84+
<argument type="tagged_iterator" tag="texter.transport_factory" />
85+
</service>
86+
87+
<service id="texter.messenger.sms_handler" class="Symfony\Component\Notifier\Messenger\MessageHandler">
88+
<argument type="service" id="texter.transports" />
89+
<tag name="messenger.message_handler" handles="Symfony\Component\Notifier\Message\SmsMessage" />
90+
</service>
91+
</services>
92+
</container>

‎src/Symfony/Bundle/FrameworkBundle/Resources/config/notifier_transports.xml

Copy file name to clipboard
+33Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
<?xml version="1.0" encoding="UTF-8" ?>
2+
3+
<container xmlns="http://symfony.com/schema/dic/services"
4+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
5+
xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
6+
7+
<services>
8+
<service id="notifier.transport_factory.abstract" class="Symfony\Component\Notifier\Transport\AbstractTransportFactory" abstract="true">
9+
<argument type="service" id="event_dispatcher" />
10+
<argument type="service" id="http_client" on-invalid="ignore" />
11+
</service>
12+
13+
<service id="notifier.transport_factory.slack" class="Symfony\Component\Notifier\Bridge\Slack\SlackTransportFactory" parent="notifier.transport_factory.abstract">
14+
<tag name="chatter.transport_factory" />
15+
</service>
16+
17+
<service id="notifier.transport_factory.telegram" class="Symfony\Component\Notifier\Bridge\Telegram\TelegramTransportFactory" parent="notifier.transport_factory.abstract">
18+
<tag name="chatter.transport_factory" />
19+
</service>
20+
21+
<service id="notifier.transport_factory.nexmo" class="Symfony\Component\Notifier\Bridge\Nexmo\NexmoTransportFactory" parent="notifier.transport_factory.abstract">
22+
<tag name="texter.transport_factory" />
23+
</service>
24+
25+
<service id="notifier.transport_factory.twilio" class="Symfony\Component\Notifier\Bridge\Twilio\TwilioTransportFactory" parent="notifier.transport_factory.abstract">
26+
<tag name="texter.transport_factory" />
27+
</service>
28+
29+
<service id="notifier.transport_factory.null" class="Symfony\Component\Notifier\Transport\NullTransportFactory" parent="notifier.transport_factory.abstract">
30+
<tag name="notifier.transport_factory" />
31+
</service>
32+
</services>
33+
</container>

‎src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/ConfigurationTest.php

Copy file name to clipboardExpand all lines: src/Symfony/Bundle/FrameworkBundle/Tests/DependencyInjection/ConfigurationTest.php
+8Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
use Symfony\Component\Lock\Store\SemaphoreStore;
2222
use Symfony\Component\Mailer\Mailer;
2323
use Symfony\Component\Messenger\MessageBusInterface;
24+
use Symfony\Component\Notifier\Notifier;
2425

2526
class ConfigurationTest extends TestCase
2627
{
@@ -348,6 +349,13 @@ class_exists(SemaphoreStore::class) && SemaphoreStore::isSupported() ? 'semaphor
348349
'transports' => [],
349350
'enabled' => !class_exists(FullStack::class) && class_exists(Mailer::class),
350351
],
352+
'notifier' => [
353+
'enabled' => !class_exists(FullStack::class) && class_exists(Notifier::class),
354+
'chatter_transports' => [],
355+
'texter_transports' => [],
356+
'channel_policy' => [],
357+
'admin_receivers' => [],
358+
],
351359
'error_controller' => 'error_controller',
352360
];
353361
}

‎src/Symfony/Component/Notifier/.gitattributes

Copy file name to clipboard
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
/Tests export-ignore
2+
/phpunit.xml.dist export-ignore

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.