MediaWiki REL1_37
FileBackendDBRepoWrapper.php
Go to the documentation of this file.
1<?php
26
43 protected $backend;
45 protected $repoName;
47 protected $dbHandleFunc;
51 protected $dbs;
52
53 public function __construct( array $config ) {
55 $backend = $config['backend'];
56 $config['name'] = $backend->getName();
57 $config['domainId'] = $backend->getDomainId();
58 parent::__construct( $config );
59 $this->backend = $config['backend'];
60 $this->repoName = $config['repoName'];
61 $this->dbHandleFunc = $config['dbHandleFactory'];
62 $this->resolvedPathCache = new MapCacheLRU( 100 );
63 }
64
70 public function getInternalBackend() {
71 return $this->backend;
72 }
73
84 public function getBackendPath( $path, $latest = true ) {
85 $paths = $this->getBackendPaths( [ $path ], $latest );
86 return current( $paths );
87 }
88
99 public function getBackendPaths( array $paths, $latest = true ) {
100 $db = $this->getDB( $latest ? DB_PRIMARY : DB_REPLICA );
101
102 // @TODO: batching
103 $resolved = [];
104 foreach ( $paths as $i => $path ) {
105 if ( !$latest && $this->resolvedPathCache->hasField( $path, 'target', 10 ) ) {
106 $resolved[$i] = $this->resolvedPathCache->getField( $path, 'target' );
107 continue;
108 }
109
110 list( , $container ) = FileBackend::splitStoragePath( $path );
111
112 if ( $container === "{$this->repoName}-public" ) {
113 $name = basename( $path );
114 if ( strpos( $path, '!' ) !== false ) {
115 $sha1 = $db->selectField( 'oldimage', 'oi_sha1',
116 [ 'oi_archive_name' => $name ],
117 __METHOD__
118 );
119 } else {
120 $sha1 = $db->selectField( 'image', 'img_sha1',
121 [ 'img_name' => $name ],
122 __METHOD__
123 );
124 }
125 if ( $sha1 === null || !strlen( $sha1 ) ) {
126 $resolved[$i] = $path; // give up
127 continue;
128 }
129 $resolved[$i] = $this->getPathForSHA1( $sha1 );
130 $this->resolvedPathCache->setField( $path, 'target', $resolved[$i] );
131 } elseif ( $container === "{$this->repoName}-deleted" ) {
132 $name = basename( $path ); // <hash>.<ext>
133 $sha1 = substr( $name, 0, strpos( $name, '.' ) ); // ignore extension
134 $resolved[$i] = $this->getPathForSHA1( $sha1 );
135 $this->resolvedPathCache->setField( $path, 'target', $resolved[$i] );
136 } else {
137 $resolved[$i] = $path;
138 }
139 }
140
141 $res = [];
142 foreach ( $paths as $i => $path ) {
143 $res[$i] = $resolved[$i];
144 }
145
146 return $res;
147 }
148
149 protected function doOperationsInternal( array $ops, array $opts ) {
150 return $this->backend->doOperationsInternal( $this->mungeOpPaths( $ops ), $opts );
151 }
152
153 protected function doQuickOperationsInternal( array $ops, array $opts ) {
154 return $this->backend->doQuickOperationsInternal( $this->mungeOpPaths( $ops ), $opts );
155 }
156
157 protected function doPrepare( array $params ) {
158 return $this->backend->doPrepare( $params );
159 }
160
161 protected function doSecure( array $params ) {
162 return $this->backend->doSecure( $params );
163 }
164
165 protected function doPublish( array $params ) {
166 return $this->backend->doPublish( $params );
167 }
168
169 protected function doClean( array $params ) {
170 return $this->backend->doClean( $params );
171 }
172
173 public function concatenate( array $params ) {
174 return $this->translateSrcParams( __FUNCTION__, $params );
175 }
176
177 public function fileExists( array $params ) {
178 return $this->translateSrcParams( __FUNCTION__, $params );
179 }
180
181 public function getFileTimestamp( array $params ) {
182 return $this->translateSrcParams( __FUNCTION__, $params );
183 }
184
185 public function getFileSize( array $params ) {
186 return $this->translateSrcParams( __FUNCTION__, $params );
187 }
188
189 public function getFileStat( array $params ) {
190 return $this->translateSrcParams( __FUNCTION__, $params );
191 }
192
193 public function getFileXAttributes( array $params ) {
194 return $this->translateSrcParams( __FUNCTION__, $params );
195 }
196
197 public function getFileSha1Base36( array $params ) {
198 return $this->translateSrcParams( __FUNCTION__, $params );
199 }
200
201 public function getFileProps( array $params ) {
202 return $this->translateSrcParams( __FUNCTION__, $params );
203 }
204
205 public function streamFile( array $params ) {
206 // The stream methods use the file extension to determine the
207 // Content-Type (as MediaWiki should already validate it on upload).
208 // The translated SHA1 path has no extension, so this needs to use
209 // the untranslated path extension.
210 $type = StreamFile::contentTypeFromPath( $params['src'] );
211 if ( $type && $type != 'unknown/unknown' ) {
212 $params['headers'][] = "Content-type: $type";
213 }
214 return $this->translateSrcParams( __FUNCTION__, $params );
215 }
216
217 public function getFileContentsMulti( array $params ) {
218 return $this->translateArrayResults( __FUNCTION__, $params );
219 }
220
221 public function getLocalReferenceMulti( array $params ) {
222 return $this->translateArrayResults( __FUNCTION__, $params );
223 }
224
225 public function getLocalCopyMulti( array $params ) {
226 return $this->translateArrayResults( __FUNCTION__, $params );
227 }
228
229 public function getFileHttpUrl( array $params ) {
230 return $this->translateSrcParams( __FUNCTION__, $params );
231 }
232
233 public function directoryExists( array $params ) {
234 return $this->backend->directoryExists( $params );
235 }
236
237 public function getDirectoryList( array $params ) {
238 return $this->backend->getDirectoryList( $params );
239 }
240
241 public function getFileList( array $params ) {
242 return $this->backend->getFileList( $params );
243 }
244
245 public function getFeatures() {
246 return $this->backend->getFeatures();
247 }
248
249 public function clearCache( array $paths = null ) {
250 $this->backend->clearCache( null ); // clear all
251 }
252
253 public function preloadCache( array $paths ) {
254 $paths = $this->getBackendPaths( $paths );
255 $this->backend->preloadCache( $paths );
256 }
257
258 public function preloadFileStat( array $params ) {
259 return $this->translateSrcParams( __FUNCTION__, $params );
260 }
261
262 public function getScopedLocksForOps( array $ops, StatusValue $status ) {
263 return $this->backend->getScopedLocksForOps( $ops, $status );
264 }
265
274 public function getPathForSHA1( $sha1 ) {
275 if ( strlen( $sha1 ) < 3 ) {
276 throw new InvalidArgumentException( "Invalid file SHA-1." );
277 }
278 return $this->backend->getContainerStoragePath( "{$this->repoName}-original" ) .
279 "/{$sha1[0]}/{$sha1[1]}/{$sha1[2]}/{$sha1}";
280 }
281
288 protected function getDB( $index ) {
289 if ( !isset( $this->dbs[$index] ) ) {
290 $func = $this->dbHandleFunc;
291 $this->dbs[$index] = $func( $index );
292 }
293 return $this->dbs[$index];
294 }
295
303 protected function translateSrcParams( $function, array $params ) {
304 $latest = !empty( $params['latest'] );
305
306 if ( isset( $params['src'] ) ) {
307 $params['src'] = $this->getBackendPath( $params['src'], $latest );
308 }
309
310 if ( isset( $params['srcs'] ) ) {
311 $params['srcs'] = $this->getBackendPaths( $params['srcs'], $latest );
312 }
313
314 return $this->backend->$function( $params );
315 }
316
324 protected function translateArrayResults( $function, array $params ) {
325 $origPaths = $params['srcs'];
326 $params['srcs'] = $this->getBackendPaths( $params['srcs'], !empty( $params['latest'] ) );
327 $pathMap = array_combine( $params['srcs'], $origPaths );
328
329 $results = $this->backend->$function( $params );
330
331 $contents = [];
332 foreach ( $results as $path => $result ) {
333 $contents[$pathMap[$path]] = $result;
334 }
335
336 return $contents;
337 }
338
347 protected function mungeOpPaths( array $ops ) {
348 // Ops that use 'src' and do not mutate core file data there
349 static $srcRefOps = [ 'store', 'copy', 'describe' ];
350 foreach ( $ops as &$op ) {
351 if ( isset( $op['src'] ) && in_array( $op['op'], $srcRefOps ) ) {
352 $op['src'] = $this->getBackendPath( $op['src'], true );
353 }
354 if ( isset( $op['srcs'] ) ) {
355 $op['srcs'] = $this->getBackendPaths( $op['srcs'], true );
356 }
357 }
358 return $ops;
359 }
360}
getDB()
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.
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 it's "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.
Handles a simple LRU key/value map with a maximum number of entries.
Generic operation result class Has warning/error list, boolean status and arbitrary value.
static contentTypeFromPath( $filename, $safe=true)
Determine the file type of a file based on the path.
Helper class used for automatically marking an IDatabase connection as reusable (once it no longer ma...
Definition DBConnRef.php:29
const DB_REPLICA
Definition defines.php:25
const DB_PRIMARY
Definition defines.php:27