Skip to content

Commit 762ab8c

Browse files
jderussejderusse
committed
Parameterize Mailgun's region
1 parent 9d7e9fc commit 762ab8c

File tree

5 files changed

+62
-11
lines changed

5 files changed

+62
-11
lines changed

‎src/Symfony/Component/Mailer/Bridge/Mailgun/Http/Api/MailgunTransport.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,15 +27,17 @@
2727
*/
2828
class MailgunTransport extends AbstractApiTransport
2929
{
30-
private const ENDPOINT = 'https://api.mailgun.net/v3/%domain%/messages';
30+
private const ENDPOINT = 'https://api.%region_dot%mailgun.net/v3/%domain%/messages';
3131

3232
private $key;
3333
private $domain;
34+
private $region;
3435

35-
public function __construct(string $key, string $domain, HttpClientInterface $client = null, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
36+
public function __construct(string $key, string $domain, string $region = null, HttpClientInterface $client = null, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
3637
{
3738
$this->key = $key;
3839
$this->domain = $domain;
40+
$this->region = $region;
3941

4042
parent::__construct($client, $dispatcher, $logger);
4143
}
@@ -48,7 +50,7 @@ protected function doSendEmail(Email $email, SmtpEnvelope $envelope): void
4850
$headers[] = $header->toString();
4951
}
5052

51-
$endpoint = str_replace('%domain%', urlencode($this->domain), self::ENDPOINT);
53+
$endpoint = str_replace(['%domain%', '%region_dot%'], [urlencode($this->domain), 'us' !== ($this->region ?: 'us') ? $this->region.'.' : ''], self::ENDPOINT);
5254
$response = $this->client->request('POST', $endpoint, [
5355
'auth_basic' => 'api:'.$this->key,
5456
'headers' => $headers,

‎src/Symfony/Component/Mailer/Bridge/Mailgun/Http/MailgunTransport.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,14 +27,16 @@
2727
*/
2828
class MailgunTransport extends AbstractHttpTransport
2929
{
30-
private const ENDPOINT = 'https://api.mailgun.net/v3/%domain%/messages.mime';
30+
private const ENDPOINT = 'https://api.%region_dot%mailgun.net/v3/%domain%/messages.mime';
3131
private $key;
3232
private $domain;
33+
private $region;
3334

34-
public function __construct(string $key, string $domain, HttpClientInterface $client = null, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
35+
public function __construct(string $key, string $domain, string $region = null, HttpClientInterface $client = null, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
3536
{
3637
$this->key = $key;
3738
$this->domain = $domain;
39+
$this->region = $region;
3840

3941
parent::__construct($client, $dispatcher, $logger);
4042
}
@@ -49,7 +51,7 @@ protected function doSend(SentMessage $message): void
4951
foreach ($body->getPreparedHeaders()->getAll() as $header) {
5052
$headers[] = $header->toString();
5153
}
52-
$endpoint = str_replace('%domain%', urlencode($this->domain), self::ENDPOINT);
54+
$endpoint = str_replace(['%domain%', '%region_dot%'], [urlencode($this->domain), 'us' !== ($this->region ?: 'us') ? $this->region.'.' : ''], self::ENDPOINT);
5355
$response = $this->client->request('POST', $endpoint, [
5456
'auth_basic' => 'api:'.$this->key,
5557
'headers' => $headers,

‎src/Symfony/Component/Mailer/Bridge/Mailgun/Smtp/MailgunTransport.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@
2222
*/
2323
class MailgunTransport extends EsmtpTransport
2424
{
25-
public function __construct(string $username, string $password, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
25+
public function __construct(string $username, string $password, string $region = null, EventDispatcherInterface $dispatcher = null, LoggerInterface $logger = null)
2626
{
27-
parent::__construct('smtp.mailgun.org', 465, 'ssl', null, $dispatcher, $logger);
27+
parent::__construct('us' !== ($region ?: 'us') ? sprintf('smtp.%s.mailgun.org', $region) : 'smtp.mailgun.org', 465, 'ssl', null, $dispatcher, $logger);
2828

2929
$this->setUsername($username);
3030
$this->setPassword($password);

‎src/Symfony/Component/Mailer/Tests/TransportTest.php

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,10 @@
2222
use Symfony\Component\Mailer\Exception\InvalidArgumentException;
2323
use Symfony\Component\Mailer\Exception\LogicException;
2424
use Symfony\Component\Mailer\Transport;
25+
use Symfony\Component\Mime\Email;
2526
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
2627
use Symfony\Contracts\HttpClient\HttpClientInterface;
28+
use Symfony\Contracts\HttpClient\ResponseInterface;
2729

2830
class TransportTest extends TestCase
2931
{
@@ -100,12 +102,23 @@ public function testFromDsnMailgun()
100102
{
101103
$dispatcher = $this->createMock(EventDispatcherInterface::class);
102104
$logger = $this->createMock(LoggerInterface::class);
105+
103106
$transport = Transport::fromDsn('smtp://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, null, $logger);
107+
$this->assertEquals('smtp.mailgun.org', $transport->getStream()->getHost());
104108
$this->assertInstanceOf(Mailgun\Smtp\MailgunTransport::class, $transport);
105109
$this->assertEquals('u$er', $transport->getUsername());
106110
$this->assertEquals('pa$s', $transport->getPassword());
107111
$this->assertProperties($transport, $dispatcher, $logger);
108112

113+
$transport = Transport::fromDsn('smtp://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, null, $logger);
114+
$this->assertEquals('smtp.mailgun.org', $transport->getStream()->getHost());
115+
116+
$transport = Transport::fromDsn('smtp://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=eu', $dispatcher, null, $logger);
117+
$this->assertEquals('smtp.eu.mailgun.org', $transport->getStream()->getHost());
118+
119+
$transport = Transport::fromDsn('smtp://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=us', $dispatcher, null, $logger);
120+
$this->assertEquals('smtp.mailgun.org', $transport->getStream()->getHost());
121+
109122
$client = $this->createMock(HttpClientInterface::class);
110123
$transport = Transport::fromDsn('http://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, $client, $logger);
111124
$this->assertInstanceOf(Mailgun\Http\MailgunTransport::class, $transport);
@@ -115,6 +128,25 @@ public function testFromDsnMailgun()
115128
'client' => $client,
116129
]);
117130

131+
$response = $this->createMock(ResponseInterface::class);
132+
$response->expects($this->any())->method('getStatusCode')->willReturn(200);
133+
$message = (new Email())->from('me@me.com')->to('you@you.com')->subject('hello')->text('Hello you');
134+
135+
$client = $this->createMock(HttpClientInterface::class);
136+
$client->expects($this->once())->method('request')->with('POST', 'https://api.mailgun.net/v3/pa%24s/messages.mime')->willReturn($response);
137+
$transport = Transport::fromDsn('http://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, $client, $logger);
138+
$transport->send($message);
139+
140+
$client = $this->createMock(HttpClientInterface::class);
141+
$client->expects($this->once())->method('request')->with('POST', 'https://api.eu.mailgun.net/v3/pa%24s/messages.mime')->willReturn($response);
142+
$transport = Transport::fromDsn('http://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=eu', $dispatcher, $client, $logger);
143+
$transport->send($message);
144+
145+
$client = $this->createMock(HttpClientInterface::class);
146+
$client->expects($this->once())->method('request')->with('POST', 'https://api.mailgun.net/v3/pa%24s/messages.mime')->willReturn($response);
147+
$transport = Transport::fromDsn('http://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=us', $dispatcher, $client, $logger);
148+
$transport->send($message);
149+
118150
$transport = Transport::fromDsn('api://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, $client, $logger);
119151
$this->assertInstanceOf(Mailgun\Http\Api\MailgunTransport::class, $transport);
120152
$this->assertProperties($transport, $dispatcher, $logger, [
@@ -123,6 +155,21 @@ public function testFromDsnMailgun()
123155
'client' => $client,
124156
]);
125157

158+
$client = $this->createMock(HttpClientInterface::class);
159+
$client->expects($this->once())->method('request')->with('POST', 'https://api.mailgun.net/v3/pa%24s/messages')->willReturn($response);
160+
$transport = Transport::fromDsn('api://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun', $dispatcher, $client, $logger);
161+
$transport->send($message);
162+
163+
$client = $this->createMock(HttpClientInterface::class);
164+
$client->expects($this->once())->method('request')->with('POST', 'https://api.eu.mailgun.net/v3/pa%24s/messages')->willReturn($response);
165+
$transport = Transport::fromDsn('api://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=eu', $dispatcher, $client, $logger);
166+
$transport->send($message);
167+
168+
$client = $this->createMock(HttpClientInterface::class);
169+
$client->expects($this->once())->method('request')->with('POST', 'https://api.mailgun.net/v3/pa%24s/messages')->willReturn($response);
170+
$transport = Transport::fromDsn('api://'.urlencode('u$er').':'.urlencode('pa$s').'@mailgun?region=us', $dispatcher, $client, $logger);
171+
$transport->send($message);
172+
126173
$this->expectException(LogicException::class);
127174
Transport::fromDsn('foo://mailgun');
128175
}

‎src/Symfony/Component/Mailer/Transport.php

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -101,13 +101,13 @@ private static function createTransport(string $dsn, EventDispatcherInterface $d
101101
}
102102

103103
if ('smtp' === $parsedDsn['scheme']) {
104-
return new Mailgun\Smtp\MailgunTransport($user, $pass, $dispatcher, $logger);
104+
return new Mailgun\Smtp\MailgunTransport($user, $pass, $query['region'] ?? null, $dispatcher, $logger);
105105
}
106106
if ('http' === $parsedDsn['scheme']) {
107-
return new Mailgun\Http\MailgunTransport($user, $pass, $client, $dispatcher, $logger);
107+
return new Mailgun\Http\MailgunTransport($user, $pass, $query['region'] ?? null, $client, $dispatcher, $logger);
108108
}
109109
if ('api' === $parsedDsn['scheme']) {
110-
return new Mailgun\Http\Api\MailgunTransport($user, $pass, $client, $dispatcher, $logger);
110+
return new Mailgun\Http\Api\MailgunTransport($user, $pass, $query['region'] ?? null, $client, $dispatcher, $logger);
111111
}
112112

113113
throw new LogicException(sprintf('The "%s" scheme is not supported for mailer "%s".', $parsedDsn['scheme'], $parsedDsn['host']));

0 commit comments

Comments
 (0)