summaryrefslogtreecommitdiff
path: root/inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php
diff options
context:
space:
mode:
authorCarson Fleming <cflems@cflems.net>2017-03-02 22:49:24 -0500
committerCarson Fleming <cflems@cflems.net>2017-03-02 22:49:24 -0500
commitb76e2ff898b23745d4c9aaee49eeb7d88f2896ab (patch)
tree9b794be8db310a575d70165d9ebde0a183b61b01 /inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php
parentbfcc9f7a7656a2db0c905b3c13114664f00f6c37 (diff)
downloadbulletin-b76e2ff898b23745d4c9aaee49eeb7d88f2896ab.tar.gz
Updated mailgun plugin
Diffstat (limited to 'inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php')
-rw-r--r--inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php61
1 files changed, 61 insertions, 0 deletions
diff --git a/inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php b/inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php
new file mode 100644
index 0000000..53f08ae
--- /dev/null
+++ b/inc/mailgun/php-http/message/src/MessageFactory/DiactorosMessageFactory.php
@@ -0,0 +1,61 @@
+<?php
+
+namespace Http\Message\MessageFactory;
+
+use Http\Message\StreamFactory\DiactorosStreamFactory;
+use Http\Message\MessageFactory;
+use Zend\Diactoros\Request;
+use Zend\Diactoros\Response;
+
+/**
+ * Creates Diactoros messages.
+ *
+ * @author GeLo <geloen.eric@gmail.com>
+ */
+final class DiactorosMessageFactory implements MessageFactory
+{
+ /**
+ * @var DiactorosStreamFactory
+ */
+ private $streamFactory;
+
+ public function __construct()
+ {
+ $this->streamFactory = new DiactorosStreamFactory();
+ }
+
+ /**
+ * {@inheritdoc}
+ */
+ public function createRequest(
+ $method,
+ $uri,
+ array $headers = [],
+ $body = null,
+ $protocolVersion = '1.1'
+ ) {
+ return (new Request(
+ $uri,
+ $method,
+ $this->streamFactory->createStream($body),
+ $headers
+ ))->withProtocolVersion($protocolVersion);
+ }
+
+ /**
+ * {@inheritdoc}
+ */
+ public function createResponse(
+ $statusCode = 200,
+ $reasonPhrase = null,
+ array $headers = [],
+ $body = null,
+ $protocolVersion = '1.1'
+ ) {
+ return (new Response(
+ $this->streamFactory->createStream($body),
+ $statusCode,
+ $headers
+ ))->withProtocolVersion($protocolVersion);
+ }
+}