PR TIMESにおけるメールをSendGridで送信するように実装しました

// 既存のMailTransporterInterace や 新規作成 SendGridTransporter

interface MailTransporterInterface
{
    public function send(MailableInterface $mailable): bool;
}

class SendGridTransporter implements MailTransporterInterface
{
    public function __construct(
        private MessageQueueInterface $messageQueue,
        private string $serverMode = SERVER_MODE
    ) {}
 
    public function send(MailableInterface $mailable): bool
    {
        try {
            $requestBodyFactory = new RequestBodyFactory(
                $mailable, 
                $this->serverMode
            );
            $requestBody = $requestBodyFactory->create();

            $this->messageQueue->enqueue($requestBody->toJson());
        } catch (Exception $e) {
            throw new MailTransporterException(
                $e->getMessage(), 
                $e->getCode(), 
                $e
            );
        }

        return true;
    }
}

/**
 * @see <https://www.twilio.com/docs/sendgrid/api-reference/mail-send/mail-send#request-body>
 */
class RequestBody
{
    /**
     * @param Content[] $content
     * @param Personalization[] $personalizations
     * ...
     */
    public function __construct(
        public string $subject,
        public Address $from,
        public array $content,
        public array $personalizations,
				...
    ) {}
		
    /**
     * JSON形式に変換する
     */
    public function toJson(): string
    {
        $requestBody = [];

        $requestBody['subject'] = $this->subject;
        $requestBody['from'] = $this->from->toArray();

        foreach ($this->content as $content_item) {
            $requestBody['content'][] = $content_item->toArray();
        }

        foreach ($this->personalizations as $personalization) {
            $requestBody['personalizations'][] = $personalization->toArray();
        }

        // ...

        try {
            $json = json_encode($requestBody, JSON_THROW_ON_ERROR);
        } catch (JsonException $e) {
            throw new FailedToJsonEncodeException(
                'Failed to json_encode: ' . $e->getMessage(), 
                $e->getCode(), 
                $e
            );
        }

        return $json;
    }
}

// MessageQueueInterface や SqsMessageQueue

interface MessageQueueInterface
{
    public function enqueue(string $message): void;
}

class SqsMessageQueue implements MessageQueueInterface
{
    public function __construct(
        private SqsClient $sqsClient,
        private string $queueUrl
    ) {}

    public function enqueue(string $message): void
    {
        try {
            $this->sqsClient->sendMessage([
                'QueueUrl' => $this->queueUrl,
                'MessageBody' => $message,
            ]);
        } catch (AwsException $e) {
            throw new FailedToEnqueueException(
                $e->getMessage(), 
                $e->getCode(), 
                $e
            );
        }
    }
}

// SmtpTransporterのインスタンスを作成する
// $smtpTransporter = new SmtpTransporter();

$sqsClient = new SqsClient(['region' => REGION, 'version' => VERSION]);
$messageQueue = new SqsMessageQueue($sqsClient, QUEUE_URL);

// SendGridTransporterのインスタンスを作成する
$sendgridTransporter = new SendGridTransporter($messageQueue);

// SMTPでメールを送信するMailerインスタンスを作成する
//$mailer = new PrTimesMailer($smtpTransporter, $logger);

// SendGridのWeb APIでメールを送信するMailerインスタンスを作成する
$mailer = new PrTimesMailer($sendgridTransporter, $logger);

// Mailableインスタンスを作成（パスワード再設定案内メール）
$mailable = MailableFactory::createPasswordResetGuideMail();

try {
	$mailer->send($mailable); // メール送信を行う
} catch (MailTransporterException $e) {
	// 例外ハンドリング
	$logger->error('Failed to send mail' . $e->getMessage());
}

class RequestBodyFactory
{
    public function __construct(
        private MailableInterface $mailable,
        private string $serverMode = SERVER_MODE
    ) {}

    public function create(): RequestBody
    {
        if ($this->serverMode !== PRODUCTION) {
            return $this->createForNonProductionEnv();
        }
        return $this->createForProductionEnv();
    }

    private function createForNonProductionEnv(): RequestBody
    {
        [
	        $personalizations,
	        $originalToEmailList,
	        $originalCCEmailList
	    ] = $this->getPersonalizationsWithOverriddenToAndCC();

        $requestBody = new RequestBody($personalizations, ...);

        if (count($originalToEmailList) > 0) {
            $header = new Header('X-Original-To', implode(',', $originalToEmailList));
            $requestBody->addHeader($header);
        }
        if (count($originalCCEmailList) > 0) {
            $header = new Header('X-Original-Cc', implode(',', $originalCCEmailList));
            $requestBody->addHeader($header);
        }

        return $requestBody;
    }
    
    /**
     * ステージング環境の場合は、メールの宛先やCCを開発用のメールアドレスで上書きする。
     * ステージング環境でメールを直接ユーザーに送信しないようにするため
     */
    private function getPersonalizationsWithOverriddenToAndCC(): array
    {
        $personalization = new Personalization();
        $originalToEmailList = [];
        $originalCCEmailList = [];

	    // 宛先の上書き処理を実行
        $originalToList = $this->mailable->getToList();
        for ($i = 0; $i < count($originalToList); $i++) {
            // メールアドレスを開発用のメールアドレスで上書きする
            $address = new Address(
                "devteam_mail{$i}@prtimes.co.jp",
                $originalToList[$i]->display_name
            );
            // 元のメールアドレスを "{上書きしたメールアドレス}->{オリジナルメールアドレス}" の形式で保存する
            $originalToEmailList[] = "{$address->email}->{$originalToList[$i]->email}";
            
            $personalization->addTo($address);
        }

	    // CCの上書き処理を実行
        $originalCCList = $this->mailable->getCC();
        // ...

        return [
            [$personalization],
            $originalToEmailList,
            $originalCCEmailList,
        ];
    }
    
    /**
     * このメソッドは本番環境のみに動く
     */
    private function createForProductionEnv(): RequestBody
    {
        return new RequestBody($this->getPersonalizations(), ...);
    }

    // ...
}