Использование пользовательской потоковой оболочки в качестве тестовой заглушки для PHP-потоковой оболочки http://

Question

Я пишу пользовательскую потоковую оболочку для использования в качестве заглушки в модульных тестах для класса клиента HTTP, который использует встроенный http:// обертка

В частности, мне нужно контролировать значение, возвращаемое в 'wrapper_data' ключ по вызовам stream_get_meta_data на потоках, созданных пользовательской потоковой оберткой. К сожалению, документация о пользовательских потоковых упаковщиках ужасна, и API кажется не интуитивным.

Какой метод в пользовательской оболочке контролирует мета wrapper_data ответ?

Используя класс внизу, я смог получить следующий результат только тогда, когда var_dump(stream_get_meta_data($stream)); на потоки, созданные с помощью пользовательской оболочки...

array(10) {
  'wrapper_data' =>
  class CustomHttpStreamWrapper#5 (3) {
    public $context =>
    resource(13) of type (stream-context)
    public $position =>
    int(0)
    public $bodyData =>
    string(14) "test body data"
  }
  ...

Но мне нужно уговорить оболочку выдать что-то вроде следующего при извлечении метаданных, чтобы я мог проверить синтаксический анализ данных клиентского класса, возвращаемых реальным http:// потоковая оболочка...

array(10) {
  'wrapper_data' => Array(
       [0] => HTTP/1.1 200 OK
       [1] => Content-Length: 438
   )
   ...

Вот код, который я сейчас использую для пользовательской оболочки:

class CustomHttpStreamWrapper {

    public $context;
    public $position = 0;
    public $bodyData = 'test body data';

    public function stream_open($path, $mode, $options, &$opened_path) {
        return true;
    }

    public function stream_read($count) {
        $this->position += strlen($this->bodyData);
        if ($this->position > strlen($this->bodyData)) {
            return false;
        }
        return $this->bodyData;
    }

    public function stream_eof() {
        return $this->position >= strlen($this->bodyData);
    }

    public function stream_stat() {
        return array('wrapper_data' => array('test'));
    }

    public function stream_tell() {
        return $this->position;
    }
}

Answer 1

stream_get_meta_data реализовано в ext / standard / streamfunc.c. Соответствующая часть

if (stream->wrapperdata) {
    MAKE_STD_ZVAL(newval);
    MAKE_COPY_ZVAL(&stream->wrapperdata, newval);

    add_assoc_zval(return_value, "wrapper_data", newval);
}

то есть все, что содержит zval stream->wrapperdata, "копируется" в / ссылается на $retval["wrapper_data"].
Ваш код обертки "обрабатывается" user_wrapper_opener в main / streams / userspace.c. И там у вас есть

/* set wrapper data to be a reference to our object */
stream->wrapperdata = us->object;

us->object "is" экземпляр вашей пользовательской оболочки, которая была создана для потока. Я не нашел способ повлиять stream->wrapperdata из сценариев пользовательского пространства, кроме этого.
Но вы можете реализовать Iterator/ IteratorAggregate и / или ArrayAccess, если все, что вам нужно, это foreach($metadata['wrapper_data'] ...) а также $metadata['wrapper_data'][$i],
Например

<?php
function test() {
    stream_wrapper_register("mock", "CustomHttpStreamWrapper") or die("Failed to register protocol");
    $fp = fopen("mock://myvar", "r+");
    $md = stream_get_meta_data($fp);

    echo "Iterator / IteratorAggregate\n";
    foreach($md['wrapper_data'] as $e) {
        echo $e, "\n";
    }

    echo "\nArrayAccess\n";
    echo $md['wrapper_data'][0], "\n";

    echo "\nvar_dump\n";
    echo var_dump($md['wrapper_data']);
}

class CustomHttpStreamWrapper implements IteratorAggregate, ArrayAccess  {
    public $context;
    public $position = 0;
    public $bodyData = 'test body data';

    protected $foo = array('HTTP/1.1 200 OK', 'Content-Length: 438', 'foo: bar', 'ham: eggs');
    /* IteratorAggregate */
    public function getIterator() {
        return new ArrayIterator($this->foo);
    }
    /* ArrayAccess */
    public function offsetExists($offset) { return array_key_exists($offset, $this->foo); }
    public function offsetGet($offset ) { return $this->foo[$offset]; }
    public function offsetSet($offset, $value) { $this->foo[$offset] = $value; }
    public function offsetUnset($offset) { unset($this->foo[$offset]); }

    /* StreamWrapper */
    public function stream_open($path, $mode, $options, &$opened_path) {
        return true;
    }

    public function stream_read($count) {
        $this->position += strlen($this->bodyData);
        if ($this->position > strlen($this->bodyData)) {
            return false;
        }
        return $this->bodyData;
    }

    public function stream_eof() {
        return $this->position >= strlen($this->bodyData);
    }

    public function stream_stat() {
        return array('wrapper_data' => array('test'));
    }

    public function stream_tell() {
        return $this->position;
    }
}

test();

печать

Iterator / IteratorAggregate
HTTP/1.1 200 OK
Content-Length: 438
foo: bar
ham: eggs

ArrayAccess
HTTP/1.1 200 OK

var_dump
object(CustomHttpStreamWrapper)#1 (4) {
  ["context"]=>
  resource(5) of type (stream-context)
  ["position"]=>
  int(0)
  ["bodyData"]=>
  string(14) "test body data"
  ["foo":protected]=>
  array(4) {
    [0]=>
    string(15) "HTTP/1.1 200 OK"
    [1]=>
    string(19) "Content-Length: 438"
    [2]=>
    string(8) "foo: bar"
    [3]=>
    string(9) "ham: eggs"
  }
}