Viewing file:  ExpoChannel.php (2.24 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace App\NotificationChannels\Expo;
use Exception;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Notifications\Notification;
use NotificationChannels\Expo\Exceptions\CouldNotSendNotification;
class ExpoChannel
{
/**
* The Http Client.
* @var Client
*/
protected $client;
/**
* Initialise a new Expo Push Channel instance.
*
* @param Client $client
* @return void
*/
public function __construct(Client $client)
{
$this->client = $client;
}
/**
* Send the given notification.
*
* @param mixed $notifiable
* @param Notification $notification
*
* @throws CouldNotSendNotification|GuzzleException
*/
public function send($notifiable, Notification $notification)
{
if (! ($to = $notifiable->routeNotificationFor('expo'))) {
throw CouldNotSendNotification::noValidDestination($notifiable);
}
if (! method_exists($notification, 'toExpo')) {
throw CouldNotSendNotification::undefinedMethod($notification);
}
/** @var ExpoMessage $message */
if (! ($message = $notification->toExpo($notification)) instanceof ExpoMessage) {
throw CouldNotSendNotification::couldNotCreateMessage($notification);
}
if (! is_array($to)) {
$to = [$to];
}
$messages = array_map(
function ($recipient) use ($message) {
return array_merge(['to' => $recipient], $message->toArray());
},
$to
);
try {
$response = $this->client->request(
'post',
'https://exp.host/--/api/v2/push/send',
['json' => $messages]
);
if ($response->getStatusCode() !== 200) {
throw CouldNotSendNotification::serviceRespondedWithAnError($response);
}
return $response;
} catch (ClientException $exception) {
throw CouldNotSendNotification::clientError($exception);
} catch (Exception $exception) {
throw CouldNotSendNotification::unexpectedException($exception);
}
}
}
|