--TEST--
User-space streams
--FILE--
<?php
# vim600:syn=php:

/* This is a fairly aggressive test that looks at
 * user streams and also gives the seek/gets/buffer
 * layer of streams a thorough testing */

$lyrics = <<<EOD
...and the road becomes my bride
I have stripped of all but pride
so in her I do confide
and she keeps me satisfied
gives me all I need
...and with dust in throat I crave
to the game you stay a slave
rover  wanderer
nomad  vagabond
call me what you will
   But Ill take my time anywhere
   Free to speak my mind anywhere
   and Ill redefine anywhere
      Anywhere I roam
      Where I lay my head is home
...and the earth becomes my throne
I adapt to the unknown
under wandering stars Ive grown
by myself but not alone
I ask no one
...and my ties are severed clean
the less I have the more I gain
off the beaten path I reign
rover  wanderer
nomad  vagabond
call me what you will
   But Ill take my time anywhere
   Free to speak my mind anywhere
   and Ill never mind anywhere
      Anywhere I roam
      Where I lay my head is home
   But Ill take my time anywhere
   Free to speak my mind anywhere
   and Ill take my find anywhere
      Anywhere I roam
      Where I lay my head is home
   carved upon my stone
   my body lie but still I roam
      Wherever I may roam.

Wherever I May Roam

EOD;

/* repeat the data a few times so that it grows larger than
 * the default cache chunk size and that we have something
 * to seek around... */
$DATA = "";
for ($i = 0; $i < 30; $i++) {
    if ($i % 2 == 0)
        $DATA .= str_rot13($lyrics);
    else
        $DATA .= $lyrics;
}

/* store the data in a regular file so that we can compare
 * the results */
$tf = tmpfile();
fwrite($tf, (binary)$DATA);
$n = ftell($tf);
rewind($tf) or die("failed to rewind tmp file!");
if (ftell($tf) != 0)
    die("tmpfile is not at start!");
$DATALEN = strlen($DATA);
if ($n != $DATALEN)
    die("tmpfile stored $n bytes; should be $DATALEN!");

class uselessstream 
{
}

class mystream 
{
    public $path;
    public $mode;
    public $options;

    public $position;
    public $varname;

    function stream_open($path, $mode, $options, &$opened_path)
    {
        $this->path = $path;
        $this->mode = $mode;
        $this->options = $options;

        $split = parse_url($path);
        $this->varname = $split["host"];

        if (strchr($mode, 'a'))
            $this->position = strlen($GLOBALS[$this->varname]);
        else
            $this->position = 0;
        
        return true;
    }

    function stream_read($count)
    {
        $ret = substr($GLOBALS[$this->varname], $this->position, $count);
        $this->position += strlen($ret);
        return $ret;
    }

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

    function stream_eof()
    {
        return $this->position >= strlen($GLOBALS[$this->varname]);
    }

    function stream_seek($offset, $whence)
    {
        switch($whence) {
            case SEEK_SET:
                if ($offset < strlen($GLOBALS[$this->varname]) && $offset >= 0) {
                    $this->position = $offset;
                    return true;
                } else {
                    return false;
                }
                break;
            case SEEK_CUR:
                if ($offset >= 0) {
                    $this->position += $offset;
                    return true;
                } else {
                    return false;
                }
                break;
            case SEEK_END:
                if (strlen($GLOBALS[$this->varname]) + $offset >= 0) {
                    $this->position = strlen($GLOBALS[$this->varname]) + $offset;
                    return true;
                } else {
                    return false;
                }
                break;
            default:
                return false;
        }
    }

}

if (@stream_wrapper_register("bogus", "class_not_exist")) {
    die("Registered a non-existant class!!!???");
}
echo "Not Registered\n";

if (!stream_wrapper_register("test", "mystream")) {
    die("test wrapper registration failed");
}
echo "Registered\n";

if (!stream_wrapper_register("bogon", "uselessstream")) {
    die("bogon wrapper registration failed");
}
echo "Registered\n";

$b = @fopen("bogon://url", "rb");
if (is_resource($b)) {
    die("Opened a bogon??");
}

$fp = fopen("test://DATA", "rb");
if (!$fp || !is_resource($fp)) {
    die("Failed to open resource");
}

/* some default seeks that will cause buffer/cache misses */
$seeks = array(
    array(SEEK_SET, 0, 0),
    array(SEEK_CUR, 8450, 8450),
    array(SEEK_CUR, -7904, 546),
    array(SEEK_CUR, 12456, 13002),

    /* end up at BOF so that randomly generated seek offsets
     * below will know where they are supposed to be */
    array(SEEK_SET, 0, 0)
);

$whence_map = array(
    SEEK_CUR,
    SEEK_SET,
    SEEK_END
);
$whence_names = array(
    SEEK_CUR => "SEEK_CUR",
    SEEK_SET => "SEEK_SET",
    SEEK_END => "SEEK_END"
    );

/* generate some random seek offsets */
$position = 0;
for ($i = 0; $i < 256; $i++) {
    $whence = $whence_map[array_rand($whence_map, 1)];
    switch($whence) {
        case SEEK_SET:
            $offset = rand(0, $DATALEN - 1);
            $position = $offset;
            break;
        case SEEK_END:
            $offset = -rand(0, $DATALEN - 1);
            $position = $DATALEN + $offset;
            break;
        case SEEK_CUR:
            $offset = rand(0, $DATALEN - 1);
            $offset -= $position;
            $position += $offset;
            break;
    }

    $seeks[] = array($whence, $offset, $position);
}

/* we compare the results of fgets using differing line lengths to 
 * test the fgets layer also */
$line_lengths = array(1024, 256, 64, 16);
$fail_count = 0;

ob_start();
foreach($line_lengths as $line_length) {
    /* now compare the real stream with the user stream */
    $j = 0;
    rewind($tf);
    rewind($fp);
    foreach($seeks as $seekdata) {
        list($whence, $offset, $position) = $seekdata;

        $rpb = ftell($tf);
        $rr = (int)fseek($tf, $offset, $whence);
        $rpa = ftell($tf);
        $rline = fgets($tf, $line_length);
        (int)fseek($tf, - strlen($rline), SEEK_CUR);

        $upb = ftell($fp);
        $ur = (int)fseek($fp, $offset, $whence);
        $upa = ftell($fp);
        $uline = fgets($fp, $line_length);
        (int)fseek($fp, - strlen($uline), SEEK_CUR);

        printf("\n--[%d] whence=%s offset=%d line_length=%d position_should_be=%d --\n",
            $j, $whence_names[$whence], $offset, $line_length, $position);
        printf("REAL: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $rpb, $rpa, ftell($tf), $rr, strlen($rline), $rline);
        printf("USER: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $upb, $upa, ftell($fp), $ur, strlen($uline), $uline);

        if ($rr != $ur || $rline != $uline || $rpa != $position || $upa != $position) {
            $fail_count++;
            echo "###################################### FAIL!\n";
            $dat = stream_get_meta_data($fp);
            var_dump($dat);
            break;
        }
        
        $j++;
    }
    if ($fail_count)
        break;
}

if ($fail_count == 0) {
    ob_end_clean();
    echo "SEEK: OK\n";
} else {
    echo "SEEK: FAIL\n";
    ob_end_flush();
}

$fail_count = 0;

fseek($fp, $DATALEN / 2, SEEK_SET);
fseek($tf, $DATALEN / 2, SEEK_SET);

if (ftell($fp) != ftell($tf)) {
    echo "SEEK: positions do not match!\n";
}

$n = 0;
while(!feof($fp)) {
    $uline = fgets($fp, 1024);
    $rline = fgets($tf, 1024);

    if ($uline != $rline) {
        echo "FGETS: FAIL\niter=$n user=$uline [pos=" . ftell($fp) . "]\nreal=$rline [pos=" . ftell($tf) . "]\n";
        $fail_count++;
        break;
    }
}

if ($fail_count == 0) {
    echo "FGETS: OK\n";
}

/* One final test to see if the position is respected when opened for append */
$fp = fopen("test://lyrics", "a+");
rewind($fp);
var_dump(ftell($fp));
$data = fgets($fp);
fclose($fp);
echo $data . "\n";

?>
--EXPECT--
Not Registered
Registered
Registered
SEEK: OK
FGETS: OK
int(0)
...and the road becomes my bride