This bundle offers a predefined architecture for a notification system using Redis and Node.js
Everything is based on the Pub/Sub (publish/subscribe) system of Redis, here is simple diagram of what happen behind the scene:
Each messages contains a content rendered by twig and an array of the users id.
Use composer :
php composer.phar require ack/notification-bundle
Register the bundle in your app/AppKernel.php file :
$bundles = array(
...
new Ack\NotificationBundle\AckNotificationBundle(),
...
);
If you already have a server node running on your application you have an example of implementation in example_server.js
Else, after the assets install, you can go in /web/bundles/acknotification/nodejs and:
npm install
node server.js
From a controller or anywhere you have access to the 'ack.notifier' service:
$this->get('ack.notifier')->notify(
':notification:test.html.twig', // Any twig file
array(1, 2, 3), // Array of the users id that need to be notified, use '*' if you want to notify everyone (anonymous users included)
array() // Optional parameters according the your twig view
);
Do not forget to load socket.io.js and connect to the server.
<script src="http://your.domain:1337/socket.io/socket.io.js"></script>
<script>
if (typeof io !== 'undefined') {
var socket = io.connect('http://your.domain:1337');
}
</script>
After you have emitted the 'loaded' event from your frontend, Node.js will catch it and store your user in a Redis hash. That way we have a list of the online users somewhere and each hash contains the socketId.
<script>
socket.emit('loaded', {
id : '{{ app.user is not null ? app.user.id : "anon." }}'
});
</script>
Once Node.js receive a notification, it emits an event 'notification' to each users id, you can do that kind of script in your frontend, to notify users.
socket.on('notification', function (notification) {
// get <div> "notifications" and append notification
});
This bundle has a dependency on snc redis, so do not forget to add this on your config.yml I recommend using redis for your other needs such as session storing, caching, logging and more here: SncRedisBundle
snc_redis:
clients:
default:
type: predis
alias: default
dsn: redis://localhost
logging: %kernel.debug%