Realtime Notification Mechanism Using Firestore

FirestoreNotificationService.php

<?php

namespace App\Services;

use Kreait\Firebase\Factory;
use Google\Cloud\Firestore\FieldValue;
use Throwable;

class FirestoreNotificationService
{
	protected $db;

	public function __construct()
    {
        $firebase = (new Factory)->withServiceAccount(
            base_path()
            . DIRECTORY_SEPARATOR
            . config('firebase.projects.app.credentials')
        );
        $this->db = $firebase->createFirestore()->database();
    }

    public function push_notification(
        string $message,
        string|null $recipient_id = null,
        string $type = 'message'
    )
    {
        $data = [
            'type' => $type,
            'message' => $message,
            'timestamp' => FieldValue::serverTimestamp(),
            'read' => false,
            'recipient_id' => $recipient_id
        ];

        try {
            $ref = $this->db->collection('notifications')
                ->add($data);

            return $ref->id();
        } catch (\Throwable $e) {
            dd($e);
        }
    }

    public function remove_notifications(array $notification_ids)
    {
        $batch = $this->db->batch();

        foreach ($notification_ids as $id) {
            $ref = $this->db->collection('notifications')->document($id);
            $batch->delete($ref);
        }
        $batch->commit();
    }
}