mvanduijker / laravel-mercure-broadcaster Goto Github PK

Route::middleware('mercure.auth:user.notifications,id')->get('/user/{id}', [UserController::class, 'notifications']);
Route::middleware('mercure.auth:https://my.app/users/{id}/notifications')->get('/user/{id}', [UserController::class, 'notifications']);
Route::middleware('mercure.auth:/users/{id}/notifications')->get('/user/{id}', [UserController::class, 'notifications']);

        'mercure' => [
            'driver' => 'mercure',
            'url' => env('MERCURE_URL', 'http://example.web:3030/.well-known/mercure'),
            'secret_pub' => env('MERCURE_SECRET_PUB', 'aVerySecretKey'),
            'secret_sub' => env('MERCURE_SECRET_SUB', 'aVerySecretKey'),
        ],

<?php

namespace App\Http\Middleware;

use Closure;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Support\Facades\Cookie;
use Lcobucci\JWT\Configuration;
// use Lcobucci\JWT\Signer\Hmac\Sha256;
use Lcobucci\JWT\Signer;
use Lcobucci\JWT\Signer\Key\LocalFileReference;
use Lcobucci\JWT\Signer\Key\InMemory;

class MercureBroadcasterAuthorizationCookie
{
    /**
     * Handle an incoming request.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \Closure  $next
     * @return mixed
     */
    public function handle(Request $request, Closure $next)
    {
        /** @var Response $response */
        $response = $next($request);

        if (!method_exists($response, 'withCookie')) {
            return $response;
        }

        if (!\Auth::check()) {
            return $response;
        }

        $user = $request->user();

        if (!$user->profile()->exists()) {
             return $response;
        }
        return $response->withCookie($this->createCookie($request->user(), $request->secure()));
    }

    private function createCookie($user, bool $secure)
    {
        $subscriptions = [
            sprintf("http://expl/profile/%d", $user->profile->id)
        ];

        $jwtConfiguration = Configuration::forAsymmetricSigner(
            new Signer\Rsa\Sha256(),
            LocalFileReference::file(__DIR__ . '/../../../.docker/mercure/subscriber.key'),
            InMemory::plainText(config('broadcasting.connections.mercure.secret_sub'))
        );
        $token = $jwtConfiguration->builder()
            ->withClaim('mercure', ['subscribe' => $subscriptions])
            ->getToken($jwtConfiguration->signer(), $jwtConfiguration->signingKey())
            ->toString();

        return Cookie::make(
            'mercureAuthorization',
            $token,
            15,
            '/.well-known/mercure', // or which path you have mercure running
            parse_url(config('app.url'), PHP_URL_HOST),
            $secure,
            true
        );
    }
}

<?php declare(strict_types = 1);

namespace Duijker\LaravelMercureBroadcaster;

use Duijker\LaravelMercureBroadcaster\Broadcasting\Broadcasters\MercureBroadcaster;
use Illuminate\Broadcasting\BroadcastManager;
use Illuminate\Support\ServiceProvider;
use Symfony\Component\Mercure\Publisher;
use Lcobucci\JWT\Configuration;
use Lcobucci\JWT\Signer;
use Lcobucci\JWT\Signer\Key\LocalFileReference;
use Lcobucci\JWT\Signer\Key\InMemory;

class LaravelMercureBroadcasterServiceProvider extends ServiceProvider
{
    public function boot()
    {

        $jwtConfiguration = Configuration::forAsymmetricSigner(
            new Signer\Rsa\Sha256(),
            LocalFileReference::file(__DIR__ . '/../../../../.docker/mercure/publisher.key'),
            InMemory::plainText(config('broadcasting.connections.mercure.secret_pub'))
        );
        $token = $jwtConfiguration->builder()
            ->withClaim('mercure', ['publish' => ["*"]])
            ->getToken($jwtConfiguration->signer(), $jwtConfiguration->signingKey())
            ->toString();

        $this->app
            ->make(BroadcastManager::class)
            ->extend('mercure', function ($app, array $config) use ($token) {
                return new MercureBroadcaster(
                    new Publisher(
                        $config['url'],
                        function () use ($config, $token) {
                            return (string) $token;
                        }
                    )
                );
            });
    }

    public function register()
    {
    }
}

\App\Http\Middleware\MercureBroadcasterAuthorizationCookie::class,

<?php

namespace App\Events;

use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
use Duijker\LaravelMercureBroadcaster\Broadcasting\Channel;

use App\Models\Message;

class MessageSent implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    public $message;
    public $dest_id;
    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct(Message $message, int $dest_id)
    {
        $this->message = $message;
        $this->dest_id = $dest_id;
    }

    /**
     * Get the channels the event should broadcast on.
     *
     * @return \Illuminate\Broadcasting\Channel|array
     */
    public function broadcastOn()
    {
        return new Channel("http://expl/profile/".$this->dest_id, true);
    }
}

MessageSent::dispatch($message->load('profile'), $dest_id);