<?php

/**
 * Copyright 2019 Huawei Technologies Co.,Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
 * this file except in compliance with the License.  You may obtain a copy of the
 * License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 * CONDITIONS OF ANY KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations under the License.
 *
 */

namespace Obs\Internal\Common;

use Psr\Http\Message\StreamInterface;
use GuzzleHttp\Psr7\StreamDecoratorTrait;
use Obs\ObsException;

class CheckoutStream implements StreamInterface {
    use StreamDecoratorTrait;
    
    private $expectedLength;
    private $readedCount = 0;

    public function __construct(StreamInterface $stream, $expectedLength) {
        $this->stream = $stream;
        $this->expectedLength = $expectedLength;
    }

    public function getContents() {
        $contents = $this->stream->getContents();
        $length = strlen($contents);
        if ($this->expectedLength !== null && floatval($length) !== $this->expectedLength) {
            $this -> throwObsException($this->expectedLength, $length);
        }
        return $contents;
    }

    public function read($length) {
        $string = $this->stream->read($length);
        if ($this->expectedLength !== null) {
            $this->readedCount += strlen($string);
            if ($this->stream->eof()) {
                if (floatval($this->readedCount) !== $this->expectedLength) {
                    $this -> throwObsException($this->expectedLength, $this->readedCount);
                }
            }
        }    
        return $string;
    }

    public function throwObsException($expectedLength, $reaLength) {
        $obsException = new ObsException('premature end of Content-Length delimiter message body (expected:' . $expectedLength . '; received:' . $reaLength . ')');
        $obsException->setExceptionType('server');
        throw $obsException;
    }
}