added stream transport implementation

src/stream/Request.php

@@ -11,6 +11,7 @@
 namespace hiqdev\hiart\stream;
 
 use hiqdev\hiart\AbstractRequest;
+use yii\helpers\Inflector;
 
 /**
  * PHP stream request implementation.
@@ -21,7 +22,70 @@ class Request extends AbstractRequest
 {
  protected $workerClass = RequestWorker::class;
 
- protected function createWorker()
+ public $defaultOptions = [
+ 'http' => [
+ 'ignore_errors' => true,
+ ],
+ 'ssl' => [
+ 'verify_peer' => false,
+ ],
+ ];
+
+ public function send($options = [])
  {
+ $this->build();
+
+ try {
+ $context = stream_context_create($this->prepareContextOptions($options));
+ $stream = fopen($this->getFullUri(), 'rb', false, $context);
+ $responseContent = stream_get_contents($stream);
+ // see http://php.net/manual/en/reserved.variables.httpresponseheader.php
+ $responseHeaders = $http_response_header;
+ fclose($stream);
+ } catch (\Exception $e) {
+ throw new Exception($e->getMessage(), $e->getCode(), $e);
+ }
+
+ return new $this->responseClass($this, $responseContent, $responseHeaders);
+ }
+
+ protected function prepareContextOptions($options)
+ {
+ $requestOptions = [
+ 'http' => [
+ 'method' => $this->method,
+ 'header' => $this->headers,
+ ],
+ ];
+
+ if (isset($this->body)) {
+ $requestOptions['http']['content'] = $this->body;
+ }
+
+ $dbOptions = $this->convertContextOptions($this->getDb()->requestOptions);
+ $sendOptions = $this->convertContextOptions($options);
+
+ return ArrayHelper::merge($this->defaultOptions, $dbOptions, $requestOptions, $sendOptions);
+ }
+
+ /**
+ * Converts raw options to stream context options.
+ * @param array $options raw options.
+ * @return array stream context options.
+ */
+ protected function convertContextOptions(array $options)
+ {
+ $contextOptions = [];
+ foreach ($options as $key => $value) {
+ $section = 'http';
+ if (strpos($key, 'ssl') === 0) {
+ $section = 'ssl';
+ $key = substr($key, 3);
+ }
+ $key = Inflector::underscore($key);
+ $contextOptions[$section][$key] = $value;
+ }
+
+ return $contextOptions;
  }
 }

src/stream/Response.php

@@ -19,8 +19,24 @@
  */
 class Response extends AbstractResponse
 {
- /**
- * @var ResponseWorker
- */
- protected $worker;
+ protected $rawData;
+
+ protected $headers;
+
+ public function __construct(Request $request, $rawData, array $headers)
+ {
+ $this->request = $request;
+ $this->rawData = $rawData;
+ $this->headers = $headers;
+ }
+
+ public function getRawData()
+ {
+ return $this->rawData;
+ }
+
+ public function getHeader($name)
+ {
+ return isset($this->headers[$name]) ? $this->headers[$name] : null;
+ }
 }