Функция канала вещания Laravel не сработает - PullRequest
Новая
       16

Функция канала вещания Laravel не сработает

0 голосов
/ 11 мая 2019

Так что я собираюсь использовать вещание Laravel для приложения чата,

Я следовал Laravel Broadcasting подход,

  • Без комментариев App\Providers\BroadcastServiceProviderиз массива providers внутри config/app.php

  • Зарегистрирован на веб-сайте pusher, создал канал и заполнил поля ниже в файле .env информацией о моем канале-толкаче 

PUSHER_APP_ID
PUSHER_APP_KEY
PUSHER_APP_SECRET
PUSHER_APP_CLUSTER
  • Внутри моего broadcast.php файла конфигурации, в котором я установил driver по умолчанию pusher, я также добавил 
'options' => [
    'cluster' => 'us2',
    'encrypted' => true,
],

в pusher массив внутри connections массив, основанный на информации о моем канале в панели pusher

  • Установленный pusher php пакет в моем проекте laravel с помощью команды composer require pusher/pusher-php-server "~3.0"

Вот мое событиеclass 

<?php

namespace App\Events;
use App\User;
use App\TherapyMessage;
use Illuminate\Broadcasting\Channel;
use Illuminate\Queue\SerializesModels;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use App\AppLog;
use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;

class TherapyMessageSent implements ShouldBroadcastNow
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    /**
     * User that sent the message
     *
     * @var User
     */
    public $user;

    /**
     * Message details
     *
     * @var Message
     */
    public $message;

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

    /**
     * Get the channels the event should broadcast on.
     *
     * @return Channel|array
     */
    public function broadcastOn()
    {
        $message_id = $this->message->id;
        $user = $this->user;

        AppLog::create([
            'file_name' => __FILE__,
            'message' => "broadcast before send with Message ID of $message_id from $user->full_name"
        ]);

        return new PrivateChannel("therapy-chat.$message_id");
    }
}
  • AppLog - это модель, которую я использую для регистрации внутри проекта
  • Сначала я попытался реализовать интерфейс ShouldBroadcast, но он тоже не работал
  • Я также зарегистрировал свое событие в файле EventServiceProvider.php и выполнил команду php artisan event:generate, вот массив EventServiceProvider $listen: 
protected $listen = [
    Registered::class => [
        SendEmailVerificationNotification::class,
        TherapyMessageSent::class
    ],
];

Я также импортировал пространство имен событий рядом с другими пространствами имен внутри файла: use \App\Events\TherapyMessageSent;

Вот канал, который я определил внутри routes/channels.php файла: 


use App\AppLog;

Broadcast::channel('therapy-chat.{message_id}', function ($user, $message_id) {

    AppLog::create([
        'file_name' => __FILE__,
        'message' => "broadcast sending with Message ID of $message_id to $user->full_name"
    ]);

    if (!Auth::check()) return false;

    $message = \App\TherapyMessage::find($message_id);

    if (!$message) {

        AppLog::create([
            'file_name' => __FILE__,
            'message' => "Message with ID of $message_id Not Found for broadcasting"
        ]);

        return false;
    }

    $will_send = false;

    if ($therapist = $user->therapist) {
        $will_send = $therapist->id === $message->therapist_id;
    } else if ($patient = $user->patient) {
        $will_send = $message->patient_id === $patient->id;
    }

    if ($will_send) {

        AppLog::create([
            'file_name' => __FILE__,
            'message' => "Message with ID of $message_id broadcasted to $user->full_name"
        ]);
    }

    return $will_send;
});

Наконец, это мой метод контроллера: 

public function sendToTherapist(Request $request) {

    $validation = \Validator::make($request->all(), ['message' => 'required']);

    if ($validation->fails()) return $this->validationError($validation);

    $user = \Auth::user();
    $patient = $user->patient;
    $therapist = $patient->therapist;

    if (!$therapist) return $this->errorWithMessage('Patient does not have Therapist');

    $message = \App\TherapyMessage::create([
        'patient_id' => $patient->id,
        'therapist_id' => $therapist->id,
        'type' => TherapyMessageType::TEXT,
        'text' => $request->message,
        'sender_role' => TherapyMessageSenderRole::PATIENT
    ]);

    broadcast(new TherapyMessageSent($user, $message))->toOthers();

    return $this->success(['id' => $message->id]);
}
  • Мой класс контроллера расширяется от BaseController, который представляет собой пользовательский класс контроллера с вспомогательными методами, такими как success(), validationError()и errorWithMessage()

Как вы видите в приведенном выше коде, я заполнил $user и $message правильными значениями, и запрос работает без ошибок

Я думаю, что метод каналадаже не будет запущен, так как я проверяю таблицу AppLog при вызове метода broadcast, сохраняется только журнал внутри функции TherapyMessageSent event broadcastOn и даже журнал, который я сохраняю в начале channels.php Метод не сохранен, поэтому я думаю, что этот метод никогда не выполняется.

Если кто-нибудь может помочь мне с проблемой, я был бы благодарен.

...