Index: cms/sources.py |
=================================================================== |
--- a/cms/sources.py |
+++ b/cms/sources.py |
@@ -298,8 +298,118 @@ |
result.append(relpath + filename) |
elif os.path.isdir(path): |
do_list(path, relpath + filename + '/') |
do_list(self.get_path(subdir), '') |
return result |
def get_cache_dir(self): |
return os.path.join(self._dir, 'cache') |
+ |
+ |
+class MultiSource(Source): |
+ """A source that combines the contents of multiple other sources.""" |
+ |
+ def __init__(self, base_sources): |
+ self._bases = base_sources |
+ |
+ @property |
+ def version(self): |
+ return self._bases[0].version |
+ |
+ def get_cache_dir(self): |
+ return self._bases[0].get_cache_dir() |
+ |
+ def __enter__(self): |
+ for base in self._bases: |
+ base.__enter__() |
+ return self |
+ |
+ def __exit__(self, exc_type, exc_value, tb): |
+ return any(base.__exit__(exc_type, exc_value, tb) |
+ for base in self._bases) |
+ |
+ def close(self): |
+ for base in self._bases: |
+ base.close() |
+ |
+ def has_file(self, filename): |
+ for base in self._bases: |
Sebastian Noack
2017/09/27 02:47:53
Nit: You could use any() here as well:
return a
Vasily Kuznetsov
2017/09/27 11:34:39
Done.
|
+ if base.has_file(filename): |
+ return True |
+ return False |
+ |
+ def read_file(self, filename, binary=False): |
+ for base in self._bases: |
+ if base.has_file(filename): |
+ return base.read_file(filename, binary) |
+ raise KeyError('File not found {}'.format(filename)) |
+ |
+ def list_files(self, subdir): |
+ files = set() |
+ for base in self._bases: |
+ files.update(base.list_files(subdir)) |
+ return sorted(files) |
Sebastian Noack
2017/09/27 02:47:53
Nit: This could be written as a set literal one-li
Vasily Kuznetsov
2017/09/27 11:34:39
Done.
Thanks for this suggestion. Having thought
Sebastian Noack
2017/09/27 15:55:22
The type returned here doesn't seem to be importan
Vasily Kuznetsov
2017/09/28 09:08:17
Fair enough. Done.
|
+ |
+ |
+def _memoize(func): |
+ """Cache results of functions calls.""" |
+ memoized = {} |
+ |
+ def wrapper(*args): |
+ try: |
+ return memoized[args] |
+ except KeyError: |
+ return memoized.setdefault(args, func(*args)) |
+ wrapper.cache_clear = memoized.clear |
+ return wrapper |
+ |
+ |
+def create_source(path, static=False, revision='default'): |
Sebastian Noack
2017/09/27 02:47:53
I would rather implement this in Source.__new__, s
Vasily Kuznetsov
2017/09/27 11:34:38
Here I prefer my implementation for the following
|
+ """Create a source from path and optional revision. |
+ |
+ `static` flag determines the type of the source that will be created and |
+ its caching behavior: |
+ - If `static` is `True`, we use version-control-aware `MercurialSource`, |
+ pass the revision and cache the results of most used functions. |
+ - If `static` is `False` (as is the case with the preview server), we use |
+ simpler `FileSource` and don't cache anything to be able to respond to |
+ changes on the filesystem. |
+ |
+ If `settings.ini` in the source contains `[paths]` section with an |
+ `additional-paths` key that contains the list of additional root folders, |
+ `MultiSource` will be instantiated and its bases will be the original |
+ source plus an additional source for each additional root folder. |
+ `MultiSource` looks up files in its base sources in the order they are |
+ provided, so the files in the additional folders will only be used if the |
+ original source doesn't contain that file. |
+ """ |
+ if static: |
+ source = MercurialSource(path, revision) |
+ else: |
+ source = FileSource(path) |
+ |
+ config = source.read_config() |
+ try: |
+ ap = config.get('paths', 'additional-paths').strip() |
+ additional_paths = filter(None, ap.split()) |
+ except ConfigParser.NoSectionError: |
+ additional_paths = [] |
+ |
+ if additional_paths: |
+ additional_sources = [ |
+ create_source(os.path.join(path, p)) |
+ for p in additional_paths |
+ ] |
+ source = MultiSource([source] + additional_sources) |
+ |
+ if static: |
+ for fname in [ |
+ 'resolve_link', |
+ 'read_config', |
+ 'read_template', |
+ 'read_locale', |
+ 'read_include', |
+ 'exec_file', |
+ ]: |
+ setattr(source, fname, _memoize(getattr(source, fname))) |
+ |
+ return source |