Viewing file:  SendGridHandler.php (3.02 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php declare(strict_types=1);
/*
* This file is part of the Monolog package.
*
* (c) Jordi Boggiano <j.boggiano@seld.be>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Monolog\Handler;
use Monolog\Level;
use Monolog\Utils;
/**
* SendGridHandler uses the SendGrid API v3 function to send Log emails, more information in https://www.twilio.com/docs/sendgrid/for-developers/sending-email/api-getting-started
*
* @author Ricardo Fontanelli <ricardo.fontanelli@hotmail.com>
*/
class SendGridHandler extends MailHandler
{
/**
* The SendGrid API User
* @deprecated this is not used anymore as of SendGrid API v3
*/
protected string $apiUser;
/**
* The email addresses to which the message will be sent
* @var string[]
*/
protected array $to;
/**
* @param string|null $apiUser Unused user as of SendGrid API v3, you can pass null or any string
* @param list<string>|string $to
* @param non-empty-string $apiHost Allows you to use another endpoint (e.g. api.eu.sendgrid.com)
* @throws MissingExtensionException If the curl extension is missing
*/
public function __construct(
string|null $apiUser,
protected string $apiKey,
protected string $from,
array|string $to,
protected string $subject,
int|string|Level $level = Level::Error,
bool $bubble = true,
/** @var non-empty-string */
private readonly string $apiHost = 'api.sendgrid.com',
) {
if (!\extension_loaded('curl')) {
throw new MissingExtensionException('The curl extension is needed to use the SendGridHandler');
}
$this->to = (array) $to;
// @phpstan-ignore property.deprecated
$this->apiUser = $apiUser ?? '';
parent::__construct($level, $bubble);
}
protected function send(string $content, array $records): void
{
$body = [];
$body['personalizations'] = [];
$body['from']['email'] = $this->from;
foreach ($this->to as $recipient) {
$body['personalizations'][]['to'][]['email'] = $recipient;
}
$body['subject'] = $this->subject;
if ($this->isHtmlBody($content)) {
$body['content'][] = [
'type' => 'text/html',
'value' => $content,
];
} else {
$body['content'][] = [
'type' => 'text/plain',
'value' => $content,
];
}
$ch = curl_init();
curl_setopt($ch, CURLOPT_HTTPHEADER, [
'Content-Type: application/json',
'Authorization: Bearer '.$this->apiKey,
]);
curl_setopt($ch, CURLOPT_URL, 'https://'.$this->apiHost.'/v3/mail/send');
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, Utils::jsonEncode($body));
Curl\Util::execute($ch, 2);
}
}
|