55 parent::__construct( $config );
56 $this->backend = $config[
'backend'];
57 $this->repoName = $config[
'repoName'];
58 $this->dbHandleFunc = $config[
'dbHandleFactory'];
83 return current( $paths );
101 foreach ( $paths as $i =>
$path ) {
102 if ( !$latest && $this->resolvedPathCache->hasField(
$path,
'target', 10 ) ) {
103 $resolved[$i] = $this->resolvedPathCache->getField(
$path,
'target' );
109 if ( $container ===
"{$this->repoName}-public" ) {
111 if ( str_contains(
$path,
'!' ) ) {
112 $sha1 = $db->newSelectQueryBuilder()
113 ->select(
'oi_sha1' )
115 ->where( [
'oi_archive_name' =>
$name ] )
116 ->caller( __METHOD__ )->fetchField();
118 $sha1 = $db->newSelectQueryBuilder()
119 ->select(
'img_sha1' )
121 ->where( [
'img_name' =>
$name ] )
122 ->caller( __METHOD__ )->fetchField();
124 if ( $sha1 ===
null || !strlen( $sha1 ) ) {
125 $resolved[$i] =
$path;
129 $this->resolvedPathCache->setField(
$path,
'target', $resolved[$i] );
130 } elseif ( $container ===
"{$this->repoName}-deleted" ) {
132 $sha1 = substr(
$name, 0, strpos(
$name,
'.' ) );
134 $this->resolvedPathCache->setField(
$path,
'target', $resolved[$i] );
136 $resolved[$i] =
$path;
141 foreach ( $paths as $i =>
$path ) {
142 $res[$i] = $resolved[$i];
149 return $this->backend->doOperationsInternal( $this->
mungeOpPaths( $ops ), $opts );
153 return $this->backend->doQuickOperationsInternal( $this->
mungeOpPaths( $ops ), $opts );
157 return $this->backend->doPrepare(
$params );
161 return $this->backend->doSecure(
$params );
165 return $this->backend->doPublish(
$params );
169 return $this->backend->doClean(
$params );
209 $type = StreamFile::contentTypeFromPath(
$params[
'src'] );
210 if ( $type && $type !=
'unknown/unknown' ) {
211 $params[
'headers'][] =
"Content-type: $type";
233 return $this->backend->directoryExists(
$params );
237 return $this->backend->getDirectoryList(
$params );
241 return $this->backend->getFileList(
$params );
245 return $this->backend->getFeatures();
249 $this->backend->clearCache(
null );
254 $this->backend->preloadCache( $paths );
262 return $this->backend->getScopedLocksForOps( $ops, $status );
274 if ( strlen( $sha1 ) < 3 ) {
275 throw new InvalidArgumentException(
"Invalid file SHA-1." );
277 return $this->backend->getContainerStoragePath(
"{$this->repoName}-original" ) .
278 "/{$sha1[0]}/{$sha1[1]}/{$sha1[2]}/{$sha1}";
287 protected function getDB( $index ) {
288 if ( !isset( $this->dbs[$index] ) ) {
290 $this->dbs[$index] = $func( $index );
292 return $this->dbs[$index];
303 $latest = !empty(
$params[
'latest'] );
305 if ( isset(
$params[
'src'] ) ) {
309 if ( isset(
$params[
'srcs'] ) ) {
313 return $this->backend->$function(
$params );
326 $pathMap = array_combine(
$params[
'srcs'], $origPaths );
328 $results = $this->backend->$function(
$params );
331 foreach ( $results as
$path => $result ) {
332 $contents[$pathMap[
$path]] = $result;
348 static $srcRefOps = [
'store',
'copy',
'describe' ];
349 foreach ( $ops as &$op ) {
350 if ( isset( $op[
'src'] ) && in_array( $op[
'op'], $srcRefOps ) ) {
353 if ( isset( $op[
'srcs'] ) ) {
array $params
The job parameters.
Proxy backend that manages file layout rewriting for FileRepo.
getFileSha1Base36(array $params)
Get a SHA-1 hash of the content of the file at a storage path in the backend.
__construct(array $config)
Create a new backend instance from configuration.
concatenate(array $params)
Concatenate a list of storage files into a single file system file.
streamFile(array $params)
Stream the content of the file at a storage path in the backend.
getScopedLocksForOps(array $ops, StatusValue $status)
Get an array of scoped locks needed for a batch of file operations.
getInternalBackend()
Get the underlying FileBackend that is being wrapped.
getLocalCopyMulti(array $params)
Like getLocalCopy() except it takes an array of storage paths and yields an order preserved-map of st...
doOperationsInternal(array $ops, array $opts)
fileExists(array $params)
Check if a file exists at a storage path in the backend.
clearCache(array $paths=null)
Invalidate any in-process file stat and property cache.
getPathForSHA1( $sha1)
Get the ultimate original storage path for a file.
getDB( $index)
Get a connection to the repo file registry DB.
translateSrcParams( $function, array $params)
Translates paths found in the "src" or "srcs" keys of a params array.
mungeOpPaths(array $ops)
Translate legacy "title" source paths to their "sha1" counterparts.
getFileHttpUrl(array $params)
Return an HTTP URL to a given file that requires no authentication to use.
getLocalReferenceMulti(array $params)
Like getLocalReference() except it takes an array of storage paths and yields an order-preserved map ...
preloadCache(array $paths)
Preload persistent file stat cache and property cache into in-process cache.
getFileSize(array $params)
Get the size (bytes) of a file at a storage path in the backend.
getFileProps(array $params)
Get the properties of the content of the file at a storage path in the backend.
getFeatures()
Get the a bitfield of extra features supported by the backend medium.
MapCacheLRU $resolvedPathCache
translateArrayResults( $function, array $params)
Translates paths when the backend function returns results keyed by paths.
preloadFileStat(array $params)
Preload file stat information (concurrently if possible) into in-process cache.
directoryExists(array $params)
Check if a directory exists at a given storage path.
getBackendPaths(array $paths, $latest=true)
Translate legacy "title" paths to their "sha1" counterparts.
getFileList(array $params)
Get an iterator to list all stored files under a storage directory.
getFileStat(array $params)
Get quick information about a file at a storage path in the backend.
getFileTimestamp(array $params)
Get the last-modified timestamp of the file at a storage path.
getFileXAttributes(array $params)
Get metadata about a file at a storage path in the backend.
getFileContentsMulti(array $params)
Like getFileContents() except it takes an array of storage paths and returns an order preserved map o...
doQuickOperationsInternal(array $ops, array $opts)
getDirectoryList(array $params)
Get an iterator to list all directories under a storage directory.
getBackendPath( $path, $latest=true)
Translate a legacy "title" path to its "sha1" counterpart.
Base class for all file backend classes (including multi-write backends).
string $name
Unique backend name.
getDomainId()
Get the domain identifier used for this backend (possibly empty).
static splitStoragePath( $storagePath)
Split a storage path into a backend name, a container name, and a relative file path.
getName()
Get the unique backend name.
Store key-value entries in a size-limited in-memory LRU cache.
Generic operation result class Has warning/error list, boolean status and arbitrary value.