<?php// dipatch an update from Symfony (for instance in a POST controller)namespaceApp\Controller;useSymfony\Component\HttpFoundation\Response;useSymfony\Component\Messenger\MessageBusInterface;useSymfony\Component\Mercure\Update;class Publish{publicfunction__invoke(MessageBusInterface$bus)    {// use doctrine to save an event$bus->dispatch(newUpdate('http://example.com/foo/bar','New content of the resource'        ));returnnewResponse('OK');    }}

// subscribe to updates client side, can be in a Twig template, in a Progressive Web App...consteventSource=newEventSource('https://demo.mercure.rocks/subscribe?topic=http://example.com/foo/bar');// The callback will be called every time an update is publishedeventSource.onmessage=e=>console.log(e);// do something with the payload, for instance update the view

# configframework:mercure:hubs:default:url:'https://demo.mercure.rocks/hub'jwt:'%env(MERCURE_JWT)%'# The publisher JWT, provided by the hub

// client sideconsthub=newURL('https://demo.mercure.rocks/hub');hub.searchParams.append('topic','https://example.com/foo/{id}');// Templated IRI, any topic matching it will be receivedhub.searchParams.append('topic','https://example.com/another/resource');consteventSource=newEventSource(hub);eventSource.onmessage=e=>console.log(e);// do something with the payload

<?phpnamespaceApp\Controller;useFig\Link\Link;useLcobucci\JWT\Builder;useLcobucci\JWT\Signer\Hmac\Sha256;useSymfony\Bundle\FrameworkBundle\Controller\AbstractController;useSymfony\Component\HttpFoundation\Request;class Discoverextends AbstractController{publicfunction__invoke(Request$request)    {$this->addLink($request,newLink('mercure','https://demo.mercure.rocks'));return$this->json(['@id' =>'http://example.com/foo/bar','availability' =>'https://schema.org/InStock']);    }}

<?phpnamespaceApp\Controller;useFig\Link\Link;useLcobucci\JWT\Builder;useLcobucci\JWT\Signer\Hmac\Sha256;useSymfony\Bundle\FrameworkBundle\Controller\AbstractController;useSymfony\Component\HttpFoundation\JsonResponse;useSymfony\Component\HttpFoundation\Request;class Discoverextends AbstractController{publicfunction__invoke(Request$request)    {// ...$username =$this->getUser()->getUsername();$token = (newBuilder())// set other JWT appropriate JWT claims, such as an expiration date            ->set('mercure', ['subscribe' => [$username,'another-target']])// could also include the security roles            ->sign(newSha256(),'!UnsecureChangeMe!')// store the key in a parameter instead            ->getToken();$response =newJsonResponse(['@id' =>'/demo/books/1.jsonld','availability' =>'https://schema.org/InStock']);$response->headers->set('set-cookie',sprintf('mercureAuthorization=%s; path=/subscribe; secure; httponly; SameSite=strict',$token));return$response;    }}

<?phpnamespaceApp\Controller;useSymfony\Component\HttpFoundation\Response;useSymfony\Component\Messenger\MessageBusInterface;useSymfony\Component\Mercure\Update;class Publish{publicfunction__invoke(MessageBusInterface$bus)    {// use doctrine to save an event$id =$bus->dispatch(newUpdate('http://example.com/foo/bar','New content of the resource',            ['a-username','a-group','anything-else']// the targets authorized to receive this update        ));returnnewResponse($id,200, ['Content-Type' =>'text/plain']);    }}