OLD | NEW |
---|---|
1 # Copyright 2013 The Chromium Authors. All rights reserved. | 1 # Copyright 2013 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 from fnmatch import fnmatch | 5 from fnmatch import fnmatch |
6 import logging | 6 import logging |
7 from urlparse import urlparse | 7 from urlparse import urlparse |
8 | 8 |
9 from appengine_url_fetcher import AppEngineUrlFetcher | 9 from appengine_url_fetcher import AppEngineUrlFetcher |
10 from appengine_wrappers import IsDevServer | 10 from appengine_wrappers import IsDevServer |
11 from caching_file_system import CachingFileSystem | 11 from caching_file_system import CachingFileSystem |
12 from caching_rietveld_patcher import CachingRietveldPatcher | 12 from caching_rietveld_patcher import CachingRietveldPatcher |
13 from chained_compiled_file_system import ChainedCompiledFileSystem | 13 from chained_compiled_file_system import ChainedCompiledFileSystem |
14 from compiled_file_system import CompiledFileSystem | 14 from compiled_file_system import CompiledFileSystem |
15 from host_file_system_creator import HostFileSystemCreator | |
15 from instance_servlet import InstanceServlet | 16 from instance_servlet import InstanceServlet |
16 from render_servlet import RenderServlet | 17 from render_servlet import RenderServlet |
17 from rietveld_patcher import RietveldPatcher, RietveldPatcherError | 18 from rietveld_patcher import RietveldPatcher, RietveldPatcherError |
18 from object_store_creator import ObjectStoreCreator | 19 from object_store_creator import ObjectStoreCreator |
19 from patched_file_system import PatchedFileSystem | 20 from patched_file_system import PatchedFileSystem |
20 from server_instance import ServerInstance | 21 from server_instance import ServerInstance |
21 from servlet import Request, Response, Servlet | 22 from servlet import Request, Response, Servlet |
22 import svn_constants | 23 import svn_constants |
23 import url_constants | 24 import url_constants |
24 | 25 |
25 class _PatchServletDelegate(RenderServlet.Delegate): | 26 class _PatchServletDelegate(RenderServlet.Delegate): |
26 def __init__(self, issue, delegate): | 27 def __init__(self, issue, delegate): |
27 self._issue = issue | 28 self._issue = issue |
28 self._delegate = delegate | 29 self._delegate = delegate |
29 | 30 |
30 def CreateServerInstanceForChannel(self, channel): | 31 def CreateServerInstanceForChannel(self, channel): |
31 base_object_store_creator = ObjectStoreCreator(channel, | 32 base_object_store_creator = ObjectStoreCreator(channel, |
32 start_empty=False) | 33 start_empty=False) |
34 branch_utility = self._delegate.CreateBranchUtility( | |
35 base_object_store_creator) | |
33 # TODO(fj): Use OfflineFileSystem here once all json/idl files in api/ | 36 # TODO(fj): Use OfflineFileSystem here once all json/idl files in api/ |
34 # are pulled into data store by cron jobs. | 37 # are pulled into data store by cron jobs. |
35 base_file_system = CachingFileSystem( | 38 base_file_system = CachingFileSystem( |
36 self._delegate.CreateHostFileSystemForBranch(channel), | 39 self._delegate.CreateHostFileSystem( |
40 branch_utility.GetChannelInfo(channel).branch), | |
37 base_object_store_creator) | 41 base_object_store_creator) |
38 base_compiled_fs_factory = CompiledFileSystem.Factory( | 42 base_compiled_fs_factory = CompiledFileSystem.Factory( |
39 base_file_system, base_object_store_creator) | 43 base_file_system, base_object_store_creator) |
40 | 44 |
41 object_store_creator = ObjectStoreCreator('trunk@%s' % self._issue, | 45 object_store_creator = ObjectStoreCreator('trunk@%s' % self._issue, |
42 start_empty=False) | 46 start_empty=False) |
43 rietveld_patcher = CachingRietveldPatcher( | 47 rietveld_patcher = CachingRietveldPatcher( |
44 RietveldPatcher(svn_constants.EXTENSIONS_PATH, | 48 RietveldPatcher(svn_constants.EXTENSIONS_PATH, |
45 self._issue, | 49 self._issue, |
46 AppEngineUrlFetcher(url_constants.CODEREVIEW_SERVER)), | 50 AppEngineUrlFetcher(url_constants.CODEREVIEW_SERVER)), |
47 object_store_creator) | 51 object_store_creator) |
48 patched_file_system = PatchedFileSystem(base_file_system, | 52 patched_file_system = PatchedFileSystem(base_file_system, |
49 rietveld_patcher) | 53 rietveld_patcher) |
50 patched_compiled_fs_factory = CompiledFileSystem.Factory( | 54 patched_compiled_fs_factory = CompiledFileSystem.Factory( |
51 patched_file_system, object_store_creator) | 55 patched_file_system, object_store_creator) |
52 | 56 |
53 compiled_fs_factory = ChainedCompiledFileSystem.Factory( | 57 compiled_fs_factory = ChainedCompiledFileSystem.Factory( |
54 [(patched_compiled_fs_factory, patched_file_system), | 58 [(patched_compiled_fs_factory, patched_file_system), |
55 (base_compiled_fs_factory, base_file_system)]) | 59 (base_compiled_fs_factory, base_file_system)]) |
60 | |
61 host_file_system_creator = HostFileSystemCreator( | |
62 branch_utility, | |
63 self._delegate.CreateHostFileSystem, | |
64 base_object_store_creator, | |
65 offline=False) | |
not at google - send to devlin
2013/07/09 23:11:55
=False also not needed here
epeterson
2013/07/16 00:28:23
Done.
| |
66 | |
56 return ServerInstance(channel, | 67 return ServerInstance(channel, |
57 object_store_creator, | 68 object_store_creator, |
58 patched_file_system, | 69 patched_file_system, |
59 self._delegate.CreateAppSamplesFileSystem( | 70 self._delegate.CreateAppSamplesFileSystem( |
60 base_object_store_creator), | 71 base_object_store_creator), |
61 '/_patch/%s' % self._issue, | 72 '/_patch/%s' % self._issue, |
62 compiled_fs_factory) | 73 compiled_fs_factory, |
74 branch_utility, | |
75 host_file_system_creator) | |
63 | 76 |
64 class PatchServlet(Servlet): | 77 class PatchServlet(Servlet): |
65 '''Servlet which renders patched docs. | 78 '''Servlet which renders patched docs. |
66 ''' | 79 ''' |
67 def __init__(self, request, delegate=None): | 80 def __init__(self, request, delegate=None): |
68 self._request = request | 81 self._request = request |
69 self._delegate = delegate or InstanceServlet.Delegate() | 82 self._delegate = delegate or InstanceServlet.Delegate() |
70 | 83 |
71 def Get(self): | 84 def Get(self): |
72 if (not IsDevServer() and | 85 if (not IsDevServer() and |
(...skipping 24 matching lines...) Expand all Loading... | |
97 except RietveldPatcherError as e: | 110 except RietveldPatcherError as e: |
98 response = Response.NotFound(e.message, {'Content-Type': 'text/plain'}) | 111 response = Response.NotFound(e.message, {'Content-Type': 'text/plain'}) |
99 | 112 |
100 redirect_url, permanent = response.GetRedirect() | 113 redirect_url, permanent = response.GetRedirect() |
101 if redirect_url is not None: | 114 if redirect_url is not None: |
102 if redirect_url.startswith('/trunk/'): | 115 if redirect_url.startswith('/trunk/'): |
103 redirect_url = redirect_url.split('/trunk', 1)[1] | 116 redirect_url = redirect_url.split('/trunk', 1)[1] |
104 response = Response.Redirect('/_patch/%s%s' % (issue, redirect_url), | 117 response = Response.Redirect('/_patch/%s%s' % (issue, redirect_url), |
105 permanent) | 118 permanent) |
106 return response | 119 return response |
OLD | NEW |