UploadSourceAdapter.php

Go to the documentation of this file.

<?php
namespace MediaWiki\Import;
 
class UploadSourceAdapter {
    public static $sourceRegistrations = [];
 
    public $context;
 
    private $mSource;
 
    private $mBuffer = '';
 
    private $mPosition;
 
    public static function registerSource( ImportSource $source ) {
        $id = wfRandomString();
 
        self::$sourceRegistrations[$id] = $source;
 
        return $id;
    }
 
    public static function isSeekableSource( string $id ) {
        if ( !isset( self::$sourceRegistrations[$id] ) ) {
            return false;
        }
        return self::$sourceRegistrations[$id]->isSeekable();
    }
 
    public static function seekSource( string $id, int $offset ) {
        if ( !isset( self::$sourceRegistrations[$id] ) ) {
            return false;
        }
        return self::$sourceRegistrations[$id]->seek( $offset );
    }
 
    public function stream_open( $path, $mode, $options, &$opened_path ) {
        $url = parse_url( $path );
        if ( !isset( $url['host'] ) ) {
            return false;
        }
        $id = $url['host'];
 
        if ( !isset( self::$sourceRegistrations[$id] ) ) {
            return false;
        }
 
        $this->mSource = self::$sourceRegistrations[$id];
 
        return true;
    }
 
    public function stream_read( $count ) {
        $return = '';
        $leave = false;
 
        while ( !$leave && !$this->mSource->atEnd() &&
            strlen( $this->mBuffer ) < $count
        ) {
            $read = $this->mSource->readChunk();
 
            if ( !strlen( $read ) ) {
                $leave = true;
            }
 
            $this->mBuffer .= $read;
        }
 
        if ( strlen( $this->mBuffer ) ) {
            $return = substr( $this->mBuffer, 0, $count );
            $this->mBuffer = substr( $this->mBuffer, $count );
        }
 
        $this->mPosition += strlen( $return );
 
        return $return;
    }
 
    public function stream_write( $data ) {
        return false;
    }
 
    public function stream_tell() {
        return $this->mPosition;
    }
 
    public function stream_eof() {
        return $this->mSource->atEnd();
    }
 
    public function url_stat() {
        $result = [];
 
        $result['dev'] = $result[0] = 0;
        $result['ino'] = $result[1] = 0;
        $result['mode'] = $result[2] = 0;
        $result['nlink'] = $result[3] = 0;
        $result['uid'] = $result[4] = 0;
        $result['gid'] = $result[5] = 0;
        $result['rdev'] = $result[6] = 0;
        $result['size'] = $result[7] = 0;
        $result['atime'] = $result[8] = 0;
        $result['mtime'] = $result[9] = 0;
        $result['ctime'] = $result[10] = 0;
        $result['blksize'] = $result[11] = 0;
        $result['blocks'] = $result[12] = 0;
 
        return $result;
    }
}
 
class_alias( UploadSourceAdapter::class, 'UploadSourceAdapter' );