Get Database notification id in push notification

Level 30

you need to add a table let's say it can be named notification_recipient

it contains user_id , notification_id, and read_flag

notification_id references notifications table

so when you need to update the status of the notification you update the read_flag on notification_recipient so it can be marked as read or unread

nsjithinsyam

https://laravel.com/docs/5.3/notifications#database-notifications

Level 1

read_at field is already in Laravel notifications table. That logic is solved by Laravel already and it got methods to query read and unread notifications.

My question is how the notification id in database can be send to push notification channels?

nsjithinsyam

Level 1

$this->id will contain the notification id. The same id will be inserted in the database if database is given as a channel method. You can push this to push notification through data fields.

1 like

abusalameh

Level 30

I think you can include notification object as json with your push notification so once it's received by web, android or iOS you catch the data and handle it on notification read event

0plus1

Level 1

@nsjithinsyam I am facing the same issue. It looks like it's not possible at least not in a nice and clean way. The issue lies with the fact that there is not apparent way to pass the full DatabaseNotification object to the channel for push notification (or anything else for that matter).

A possible (albeit ugly solution) would be to pass some sort of UUID to the Notification (shared by database and push) then do a like to mark the notification read, but it's expensive and not very nice.

I would love for this to be possible..

0plus1

Level 1

@nsjithinsyam this is a possible solution although it might fail due to competing notifications coming in at the same time.

return ['database', PushNotification::class];

(Order does matter, database being first will generate the actual DB notification)

// To mark the notification as read we need the notification id
        // There is no clean way to achieve this other than getting the latest notification for the user and hope for the best
        // TODO this is clearly a race condition, needs investigation to tighten this up
        $DatabaseNotification = $notifiable->notifications->first();
        if( $DatabaseNotification ) {
            $url = route('user.notification.mark.read', ['notification_id' => $DatabaseNotification->getKey()]);
        } else {
            $url = $this->link_to;
        }

Level 1

//the way i went about it was this
<?php

namespace App\Notifications;

use App\Channels\SocketChannel;
use Illuminate\Bus\Queueable;
use Illuminate\Notifications\Notification;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Notifications\Messages\MailMessage;
use Redis;

class myNotification extends Notification implements ShouldQueue
{
    use Queueable;

    /**
     * Create a new notification instance.
     *
     * @return void
     */


    public function __construct($param)
    {
    $this->param = $param;
    }

    /**
     * Get the notification's delivery channels.
     *
     * @param  mixed  $notifiable
     * @return array
     */
    public function via($notifiable)
    {
        $channels = ['database','mail',SocketChannel::class];
        return $channels;
    }

    /**
     * Get the mail representation of the notification.
     *
     * @param  mixed  $notifiable
     * @return \Illuminate\Notifications\Messages\MailMessage
     */
    public function toMail($notifiable)
    {
    $url = url('test-link/?notify_id='.$this->id);
        return (new MailMessage)
                    ->subject('Mail Notification')
                    ->greeting('Hello')
                    ->line('Mail Content')
                    ->action('View Details',$url)
                    ->line('concluding message');
    }

    /**
     * Get the array representation of the notification.
     *
     * @param  mixed  $notifiable
     * @return array
     */
    public function toDatabase($notifiable)
    {
        return [

            'url'     =>  url('test-link/?notify_id='.$this->id),
            'message' => 'Notification message',

        ];
    }

    /**
     * Broadcast with redis (My use case tho)
     */
    public function toSocket($notifiable)
    {   
        $url = url('test-link/?notify_id='.$this->id);
    $data[
        'url' => $url,
        'content' => ''your content'
    ]
        Redis::publish('push-message:', json_encode(['data'=>$data]));
    }

}

Level 1

<?php
//the custom channel according to the documentation
namespace App\Channels;

use Illuminate\Notifications\Notification;

class SocketChannel
{
    /**
     * Send the given notification.
     *
     * @param  mixed  $notifiable
     * @param  \Illuminate\Notifications\Notification  $notification
     * @return void
     */
    public function send($notifiable, Notification $notification)
    {
        $message = $notification->toSocket($notifiable);

        // Send notification to the $notifiable instance...
    }
}

Level 1

Then on the js

$(document).ready(function(){
    var url = new URL(window.location);
    var notify_id = url.searchParams.get("notify_id");
    if (notify_id != null) {
          var base_url = window.location.protocol+"//"+window.location.host;
          var  link = base_url+'/notifications/mark-as-read/'+notifyId;
              $.ajax({
                url: link,
                method:'get',
              })
              .done(function(response){
                  if (response.status == 'error') {
                      console.warn('Could not update notifications');
                  }else{
            //handle your success 

                  }
              })
              .fail(function(jqXHR){
                  console.warn('Could not update notifications');
              })
    }
})

Level 1

//Controller method to mark as read

    public function markNotification($notification_id){
        $this->currentUser();
        $user = User::where('id',session('id'))->first();
        $notification = $user->notifications()->where('id',$notification_id)->first();
      
        if($notification != null){
            $notification->markAsRead();
            return response()->json(['status'=>'success']);
        }
        return response()->json(['status'=>'error']);
    }