##// END OF EJS Templates
configitems: register the 'web.logoimg' config
Boris Feld -
r34612:c879fc7b default
parent child Browse files
Show More
@@ -1,848 +1,851 b''
1 # configitems.py - centralized declaration of configuration option
1 # configitems.py - centralized declaration of configuration option
2 #
2 #
3 # Copyright 2017 Pierre-Yves David <pierre-yves.david@octobus.net>
3 # Copyright 2017 Pierre-Yves David <pierre-yves.david@octobus.net>
4 #
4 #
5 # This software may be used and distributed according to the terms of the
5 # This software may be used and distributed according to the terms of the
6 # GNU General Public License version 2 or any later version.
6 # GNU General Public License version 2 or any later version.
7
7
8 from __future__ import absolute_import
8 from __future__ import absolute_import
9
9
10 import functools
10 import functools
11
11
12 from . import (
12 from . import (
13 encoding,
13 encoding,
14 error,
14 error,
15 )
15 )
16
16
17 def loadconfigtable(ui, extname, configtable):
17 def loadconfigtable(ui, extname, configtable):
18 """update config item known to the ui with the extension ones"""
18 """update config item known to the ui with the extension ones"""
19 for section, items in configtable.items():
19 for section, items in configtable.items():
20 knownitems = ui._knownconfig.setdefault(section, {})
20 knownitems = ui._knownconfig.setdefault(section, {})
21 knownkeys = set(knownitems)
21 knownkeys = set(knownitems)
22 newkeys = set(items)
22 newkeys = set(items)
23 for key in sorted(knownkeys & newkeys):
23 for key in sorted(knownkeys & newkeys):
24 msg = "extension '%s' overwrite config item '%s.%s'"
24 msg = "extension '%s' overwrite config item '%s.%s'"
25 msg %= (extname, section, key)
25 msg %= (extname, section, key)
26 ui.develwarn(msg, config='warn-config')
26 ui.develwarn(msg, config='warn-config')
27
27
28 knownitems.update(items)
28 knownitems.update(items)
29
29
30 class configitem(object):
30 class configitem(object):
31 """represent a known config item
31 """represent a known config item
32
32
33 :section: the official config section where to find this item,
33 :section: the official config section where to find this item,
34 :name: the official name within the section,
34 :name: the official name within the section,
35 :default: default value for this item,
35 :default: default value for this item,
36 :alias: optional list of tuples as alternatives.
36 :alias: optional list of tuples as alternatives.
37 """
37 """
38
38
39 def __init__(self, section, name, default=None, alias=()):
39 def __init__(self, section, name, default=None, alias=()):
40 self.section = section
40 self.section = section
41 self.name = name
41 self.name = name
42 self.default = default
42 self.default = default
43 self.alias = list(alias)
43 self.alias = list(alias)
44
44
45 coreitems = {}
45 coreitems = {}
46
46
47 def _register(configtable, *args, **kwargs):
47 def _register(configtable, *args, **kwargs):
48 item = configitem(*args, **kwargs)
48 item = configitem(*args, **kwargs)
49 section = configtable.setdefault(item.section, {})
49 section = configtable.setdefault(item.section, {})
50 if item.name in section:
50 if item.name in section:
51 msg = "duplicated config item registration for '%s.%s'"
51 msg = "duplicated config item registration for '%s.%s'"
52 raise error.ProgrammingError(msg % (item.section, item.name))
52 raise error.ProgrammingError(msg % (item.section, item.name))
53 section[item.name] = item
53 section[item.name] = item
54
54
55 # special value for case where the default is derived from other values
55 # special value for case where the default is derived from other values
56 dynamicdefault = object()
56 dynamicdefault = object()
57
57
58 # Registering actual config items
58 # Registering actual config items
59
59
60 def getitemregister(configtable):
60 def getitemregister(configtable):
61 return functools.partial(_register, configtable)
61 return functools.partial(_register, configtable)
62
62
63 coreconfigitem = getitemregister(coreitems)
63 coreconfigitem = getitemregister(coreitems)
64
64
65 coreconfigitem('auth', 'cookiefile',
65 coreconfigitem('auth', 'cookiefile',
66 default=None,
66 default=None,
67 )
67 )
68 # bookmarks.pushing: internal hack for discovery
68 # bookmarks.pushing: internal hack for discovery
69 coreconfigitem('bookmarks', 'pushing',
69 coreconfigitem('bookmarks', 'pushing',
70 default=list,
70 default=list,
71 )
71 )
72 # bundle.mainreporoot: internal hack for bundlerepo
72 # bundle.mainreporoot: internal hack for bundlerepo
73 coreconfigitem('bundle', 'mainreporoot',
73 coreconfigitem('bundle', 'mainreporoot',
74 default='',
74 default='',
75 )
75 )
76 # bundle.reorder: experimental config
76 # bundle.reorder: experimental config
77 coreconfigitem('bundle', 'reorder',
77 coreconfigitem('bundle', 'reorder',
78 default='auto',
78 default='auto',
79 )
79 )
80 coreconfigitem('censor', 'policy',
80 coreconfigitem('censor', 'policy',
81 default='abort',
81 default='abort',
82 )
82 )
83 coreconfigitem('chgserver', 'idletimeout',
83 coreconfigitem('chgserver', 'idletimeout',
84 default=3600,
84 default=3600,
85 )
85 )
86 coreconfigitem('chgserver', 'skiphash',
86 coreconfigitem('chgserver', 'skiphash',
87 default=False,
87 default=False,
88 )
88 )
89 coreconfigitem('cmdserver', 'log',
89 coreconfigitem('cmdserver', 'log',
90 default=None,
90 default=None,
91 )
91 )
92 coreconfigitem('color', 'mode',
92 coreconfigitem('color', 'mode',
93 default='auto',
93 default='auto',
94 )
94 )
95 coreconfigitem('color', 'pagermode',
95 coreconfigitem('color', 'pagermode',
96 default=dynamicdefault,
96 default=dynamicdefault,
97 )
97 )
98 coreconfigitem('commands', 'status.relative',
98 coreconfigitem('commands', 'status.relative',
99 default=False,
99 default=False,
100 )
100 )
101 coreconfigitem('commands', 'status.skipstates',
101 coreconfigitem('commands', 'status.skipstates',
102 default=[],
102 default=[],
103 )
103 )
104 coreconfigitem('commands', 'status.verbose',
104 coreconfigitem('commands', 'status.verbose',
105 default=False,
105 default=False,
106 )
106 )
107 coreconfigitem('commands', 'update.requiredest',
107 coreconfigitem('commands', 'update.requiredest',
108 default=False,
108 default=False,
109 )
109 )
110 coreconfigitem('debug', 'dirstate.delaywrite',
110 coreconfigitem('debug', 'dirstate.delaywrite',
111 default=0,
111 default=0,
112 )
112 )
113 coreconfigitem('devel', 'all-warnings',
113 coreconfigitem('devel', 'all-warnings',
114 default=False,
114 default=False,
115 )
115 )
116 coreconfigitem('devel', 'bundle2.debug',
116 coreconfigitem('devel', 'bundle2.debug',
117 default=False,
117 default=False,
118 )
118 )
119 coreconfigitem('devel', 'cache-vfs',
119 coreconfigitem('devel', 'cache-vfs',
120 default=None,
120 default=None,
121 )
121 )
122 coreconfigitem('devel', 'check-locks',
122 coreconfigitem('devel', 'check-locks',
123 default=False,
123 default=False,
124 )
124 )
125 coreconfigitem('devel', 'check-relroot',
125 coreconfigitem('devel', 'check-relroot',
126 default=False,
126 default=False,
127 )
127 )
128 coreconfigitem('devel', 'default-date',
128 coreconfigitem('devel', 'default-date',
129 default=None,
129 default=None,
130 )
130 )
131 coreconfigitem('devel', 'deprec-warn',
131 coreconfigitem('devel', 'deprec-warn',
132 default=False,
132 default=False,
133 )
133 )
134 coreconfigitem('devel', 'disableloaddefaultcerts',
134 coreconfigitem('devel', 'disableloaddefaultcerts',
135 default=False,
135 default=False,
136 )
136 )
137 coreconfigitem('devel', 'empty-changegroup',
137 coreconfigitem('devel', 'empty-changegroup',
138 default=False,
138 default=False,
139 )
139 )
140 coreconfigitem('devel', 'legacy.exchange',
140 coreconfigitem('devel', 'legacy.exchange',
141 default=list,
141 default=list,
142 )
142 )
143 coreconfigitem('devel', 'servercafile',
143 coreconfigitem('devel', 'servercafile',
144 default='',
144 default='',
145 )
145 )
146 coreconfigitem('devel', 'serverexactprotocol',
146 coreconfigitem('devel', 'serverexactprotocol',
147 default='',
147 default='',
148 )
148 )
149 coreconfigitem('devel', 'serverrequirecert',
149 coreconfigitem('devel', 'serverrequirecert',
150 default=False,
150 default=False,
151 )
151 )
152 coreconfigitem('devel', 'strip-obsmarkers',
152 coreconfigitem('devel', 'strip-obsmarkers',
153 default=True,
153 default=True,
154 )
154 )
155 coreconfigitem('devel', 'warn-config',
155 coreconfigitem('devel', 'warn-config',
156 default=None,
156 default=None,
157 )
157 )
158 coreconfigitem('devel', 'warn-config-default',
158 coreconfigitem('devel', 'warn-config-default',
159 default=None,
159 default=None,
160 )
160 )
161 coreconfigitem('devel', 'user.obsmarker',
161 coreconfigitem('devel', 'user.obsmarker',
162 default=None,
162 default=None,
163 )
163 )
164 coreconfigitem('diff', 'nodates',
164 coreconfigitem('diff', 'nodates',
165 default=None,
165 default=None,
166 )
166 )
167 coreconfigitem('diff', 'showfunc',
167 coreconfigitem('diff', 'showfunc',
168 default=None,
168 default=None,
169 )
169 )
170 coreconfigitem('diff', 'unified',
170 coreconfigitem('diff', 'unified',
171 default=None,
171 default=None,
172 )
172 )
173 coreconfigitem('diff', 'git',
173 coreconfigitem('diff', 'git',
174 default=None,
174 default=None,
175 )
175 )
176 coreconfigitem('diff', 'ignorews',
176 coreconfigitem('diff', 'ignorews',
177 default=None,
177 default=None,
178 )
178 )
179 coreconfigitem('diff', 'ignorewsamount',
179 coreconfigitem('diff', 'ignorewsamount',
180 default=None,
180 default=None,
181 )
181 )
182 coreconfigitem('diff', 'ignoreblanklines',
182 coreconfigitem('diff', 'ignoreblanklines',
183 default=None,
183 default=None,
184 )
184 )
185 coreconfigitem('diff', 'ignorewseol',
185 coreconfigitem('diff', 'ignorewseol',
186 default=None,
186 default=None,
187 )
187 )
188 coreconfigitem('diff', 'nobinary',
188 coreconfigitem('diff', 'nobinary',
189 default=None,
189 default=None,
190 )
190 )
191 coreconfigitem('diff', 'noprefix',
191 coreconfigitem('diff', 'noprefix',
192 default=None,
192 default=None,
193 )
193 )
194 coreconfigitem('email', 'bcc',
194 coreconfigitem('email', 'bcc',
195 default=None,
195 default=None,
196 )
196 )
197 coreconfigitem('email', 'cc',
197 coreconfigitem('email', 'cc',
198 default=None,
198 default=None,
199 )
199 )
200 coreconfigitem('email', 'charsets',
200 coreconfigitem('email', 'charsets',
201 default=list,
201 default=list,
202 )
202 )
203 coreconfigitem('email', 'from',
203 coreconfigitem('email', 'from',
204 default=None,
204 default=None,
205 )
205 )
206 coreconfigitem('email', 'method',
206 coreconfigitem('email', 'method',
207 default='smtp',
207 default='smtp',
208 )
208 )
209 coreconfigitem('email', 'reply-to',
209 coreconfigitem('email', 'reply-to',
210 default=None,
210 default=None,
211 )
211 )
212 coreconfigitem('experimental', 'allowdivergence',
212 coreconfigitem('experimental', 'allowdivergence',
213 default=False,
213 default=False,
214 )
214 )
215 coreconfigitem('experimental', 'bundle-phases',
215 coreconfigitem('experimental', 'bundle-phases',
216 default=False,
216 default=False,
217 )
217 )
218 coreconfigitem('experimental', 'bundle2-advertise',
218 coreconfigitem('experimental', 'bundle2-advertise',
219 default=True,
219 default=True,
220 )
220 )
221 coreconfigitem('experimental', 'bundle2-output-capture',
221 coreconfigitem('experimental', 'bundle2-output-capture',
222 default=False,
222 default=False,
223 )
223 )
224 coreconfigitem('experimental', 'bundle2.pushback',
224 coreconfigitem('experimental', 'bundle2.pushback',
225 default=False,
225 default=False,
226 )
226 )
227 coreconfigitem('experimental', 'bundle2lazylocking',
227 coreconfigitem('experimental', 'bundle2lazylocking',
228 default=False,
228 default=False,
229 )
229 )
230 coreconfigitem('experimental', 'bundlecomplevel',
230 coreconfigitem('experimental', 'bundlecomplevel',
231 default=None,
231 default=None,
232 )
232 )
233 coreconfigitem('experimental', 'changegroup3',
233 coreconfigitem('experimental', 'changegroup3',
234 default=False,
234 default=False,
235 )
235 )
236 coreconfigitem('experimental', 'clientcompressionengines',
236 coreconfigitem('experimental', 'clientcompressionengines',
237 default=list,
237 default=list,
238 )
238 )
239 coreconfigitem('experimental', 'copytrace',
239 coreconfigitem('experimental', 'copytrace',
240 default='on',
240 default='on',
241 )
241 )
242 coreconfigitem('experimental', 'copytrace.sourcecommitlimit',
242 coreconfigitem('experimental', 'copytrace.sourcecommitlimit',
243 default=100,
243 default=100,
244 )
244 )
245 coreconfigitem('experimental', 'crecordtest',
245 coreconfigitem('experimental', 'crecordtest',
246 default=None,
246 default=None,
247 )
247 )
248 coreconfigitem('experimental', 'editortmpinhg',
248 coreconfigitem('experimental', 'editortmpinhg',
249 default=False,
249 default=False,
250 )
250 )
251 coreconfigitem('experimental', 'maxdeltachainspan',
251 coreconfigitem('experimental', 'maxdeltachainspan',
252 default=-1,
252 default=-1,
253 )
253 )
254 coreconfigitem('experimental', 'mmapindexthreshold',
254 coreconfigitem('experimental', 'mmapindexthreshold',
255 default=None,
255 default=None,
256 )
256 )
257 coreconfigitem('experimental', 'nonnormalparanoidcheck',
257 coreconfigitem('experimental', 'nonnormalparanoidcheck',
258 default=False,
258 default=False,
259 )
259 )
260 coreconfigitem('experimental', 'stabilization',
260 coreconfigitem('experimental', 'stabilization',
261 default=list,
261 default=list,
262 alias=[('experimental', 'evolution')],
262 alias=[('experimental', 'evolution')],
263 )
263 )
264 coreconfigitem('experimental', 'stabilization.bundle-obsmarker',
264 coreconfigitem('experimental', 'stabilization.bundle-obsmarker',
265 default=False,
265 default=False,
266 alias=[('experimental', 'evolution.bundle-obsmarker')],
266 alias=[('experimental', 'evolution.bundle-obsmarker')],
267 )
267 )
268 coreconfigitem('experimental', 'stabilization.track-operation',
268 coreconfigitem('experimental', 'stabilization.track-operation',
269 default=True,
269 default=True,
270 alias=[('experimental', 'evolution.track-operation')]
270 alias=[('experimental', 'evolution.track-operation')]
271 )
271 )
272 coreconfigitem('experimental', 'exportableenviron',
272 coreconfigitem('experimental', 'exportableenviron',
273 default=list,
273 default=list,
274 )
274 )
275 coreconfigitem('experimental', 'extendedheader.index',
275 coreconfigitem('experimental', 'extendedheader.index',
276 default=None,
276 default=None,
277 )
277 )
278 coreconfigitem('experimental', 'extendedheader.similarity',
278 coreconfigitem('experimental', 'extendedheader.similarity',
279 default=False,
279 default=False,
280 )
280 )
281 coreconfigitem('experimental', 'format.compression',
281 coreconfigitem('experimental', 'format.compression',
282 default='zlib',
282 default='zlib',
283 )
283 )
284 coreconfigitem('experimental', 'graphshorten',
284 coreconfigitem('experimental', 'graphshorten',
285 default=False,
285 default=False,
286 )
286 )
287 coreconfigitem('experimental', 'graphstyle.parent',
287 coreconfigitem('experimental', 'graphstyle.parent',
288 default=dynamicdefault,
288 default=dynamicdefault,
289 )
289 )
290 coreconfigitem('experimental', 'graphstyle.missing',
290 coreconfigitem('experimental', 'graphstyle.missing',
291 default=dynamicdefault,
291 default=dynamicdefault,
292 )
292 )
293 coreconfigitem('experimental', 'graphstyle.grandparent',
293 coreconfigitem('experimental', 'graphstyle.grandparent',
294 default=dynamicdefault,
294 default=dynamicdefault,
295 )
295 )
296 coreconfigitem('experimental', 'hook-track-tags',
296 coreconfigitem('experimental', 'hook-track-tags',
297 default=False,
297 default=False,
298 )
298 )
299 coreconfigitem('experimental', 'httppostargs',
299 coreconfigitem('experimental', 'httppostargs',
300 default=False,
300 default=False,
301 )
301 )
302 coreconfigitem('experimental', 'manifestv2',
302 coreconfigitem('experimental', 'manifestv2',
303 default=False,
303 default=False,
304 )
304 )
305 coreconfigitem('experimental', 'mergedriver',
305 coreconfigitem('experimental', 'mergedriver',
306 default=None,
306 default=None,
307 )
307 )
308 coreconfigitem('experimental', 'obsmarkers-exchange-debug',
308 coreconfigitem('experimental', 'obsmarkers-exchange-debug',
309 default=False,
309 default=False,
310 )
310 )
311 coreconfigitem('experimental', 'rebase.multidest',
311 coreconfigitem('experimental', 'rebase.multidest',
312 default=False,
312 default=False,
313 )
313 )
314 coreconfigitem('experimental', 'revertalternateinteractivemode',
314 coreconfigitem('experimental', 'revertalternateinteractivemode',
315 default=True,
315 default=True,
316 )
316 )
317 coreconfigitem('experimental', 'revlogv2',
317 coreconfigitem('experimental', 'revlogv2',
318 default=None,
318 default=None,
319 )
319 )
320 coreconfigitem('experimental', 'spacemovesdown',
320 coreconfigitem('experimental', 'spacemovesdown',
321 default=False,
321 default=False,
322 )
322 )
323 coreconfigitem('experimental', 'treemanifest',
323 coreconfigitem('experimental', 'treemanifest',
324 default=False,
324 default=False,
325 )
325 )
326 coreconfigitem('experimental', 'updatecheck',
326 coreconfigitem('experimental', 'updatecheck',
327 default=None,
327 default=None,
328 )
328 )
329 coreconfigitem('format', 'aggressivemergedeltas',
329 coreconfigitem('format', 'aggressivemergedeltas',
330 default=False,
330 default=False,
331 )
331 )
332 coreconfigitem('format', 'chunkcachesize',
332 coreconfigitem('format', 'chunkcachesize',
333 default=None,
333 default=None,
334 )
334 )
335 coreconfigitem('format', 'dotencode',
335 coreconfigitem('format', 'dotencode',
336 default=True,
336 default=True,
337 )
337 )
338 coreconfigitem('format', 'generaldelta',
338 coreconfigitem('format', 'generaldelta',
339 default=False,
339 default=False,
340 )
340 )
341 coreconfigitem('format', 'manifestcachesize',
341 coreconfigitem('format', 'manifestcachesize',
342 default=None,
342 default=None,
343 )
343 )
344 coreconfigitem('format', 'maxchainlen',
344 coreconfigitem('format', 'maxchainlen',
345 default=None,
345 default=None,
346 )
346 )
347 coreconfigitem('format', 'obsstore-version',
347 coreconfigitem('format', 'obsstore-version',
348 default=None,
348 default=None,
349 )
349 )
350 coreconfigitem('format', 'usefncache',
350 coreconfigitem('format', 'usefncache',
351 default=True,
351 default=True,
352 )
352 )
353 coreconfigitem('format', 'usegeneraldelta',
353 coreconfigitem('format', 'usegeneraldelta',
354 default=True,
354 default=True,
355 )
355 )
356 coreconfigitem('format', 'usestore',
356 coreconfigitem('format', 'usestore',
357 default=True,
357 default=True,
358 )
358 )
359 coreconfigitem('hostsecurity', 'ciphers',
359 coreconfigitem('hostsecurity', 'ciphers',
360 default=None,
360 default=None,
361 )
361 )
362 coreconfigitem('hostsecurity', 'disabletls10warning',
362 coreconfigitem('hostsecurity', 'disabletls10warning',
363 default=False,
363 default=False,
364 )
364 )
365 coreconfigitem('http_proxy', 'always',
365 coreconfigitem('http_proxy', 'always',
366 default=False,
366 default=False,
367 )
367 )
368 coreconfigitem('http_proxy', 'host',
368 coreconfigitem('http_proxy', 'host',
369 default=None,
369 default=None,
370 )
370 )
371 coreconfigitem('http_proxy', 'no',
371 coreconfigitem('http_proxy', 'no',
372 default=list,
372 default=list,
373 )
373 )
374 coreconfigitem('http_proxy', 'passwd',
374 coreconfigitem('http_proxy', 'passwd',
375 default=None,
375 default=None,
376 )
376 )
377 coreconfigitem('http_proxy', 'user',
377 coreconfigitem('http_proxy', 'user',
378 default=None,
378 default=None,
379 )
379 )
380 coreconfigitem('logtoprocess', 'commandexception',
380 coreconfigitem('logtoprocess', 'commandexception',
381 default=None,
381 default=None,
382 )
382 )
383 coreconfigitem('logtoprocess', 'commandfinish',
383 coreconfigitem('logtoprocess', 'commandfinish',
384 default=None,
384 default=None,
385 )
385 )
386 coreconfigitem('logtoprocess', 'command',
386 coreconfigitem('logtoprocess', 'command',
387 default=None,
387 default=None,
388 )
388 )
389 coreconfigitem('logtoprocess', 'develwarn',
389 coreconfigitem('logtoprocess', 'develwarn',
390 default=None,
390 default=None,
391 )
391 )
392 coreconfigitem('logtoprocess', 'uiblocked',
392 coreconfigitem('logtoprocess', 'uiblocked',
393 default=None,
393 default=None,
394 )
394 )
395 coreconfigitem('merge', 'checkunknown',
395 coreconfigitem('merge', 'checkunknown',
396 default='abort',
396 default='abort',
397 )
397 )
398 coreconfigitem('merge', 'checkignored',
398 coreconfigitem('merge', 'checkignored',
399 default='abort',
399 default='abort',
400 )
400 )
401 coreconfigitem('merge', 'followcopies',
401 coreconfigitem('merge', 'followcopies',
402 default=True,
402 default=True,
403 )
403 )
404 coreconfigitem('merge', 'preferancestor',
404 coreconfigitem('merge', 'preferancestor',
405 default=lambda: ['*'],
405 default=lambda: ['*'],
406 )
406 )
407 coreconfigitem('pager', 'ignore',
407 coreconfigitem('pager', 'ignore',
408 default=list,
408 default=list,
409 )
409 )
410 coreconfigitem('pager', 'pager',
410 coreconfigitem('pager', 'pager',
411 default=dynamicdefault,
411 default=dynamicdefault,
412 )
412 )
413 coreconfigitem('patch', 'eol',
413 coreconfigitem('patch', 'eol',
414 default='strict',
414 default='strict',
415 )
415 )
416 coreconfigitem('patch', 'fuzz',
416 coreconfigitem('patch', 'fuzz',
417 default=2,
417 default=2,
418 )
418 )
419 coreconfigitem('paths', 'default',
419 coreconfigitem('paths', 'default',
420 default=None,
420 default=None,
421 )
421 )
422 coreconfigitem('paths', 'default-push',
422 coreconfigitem('paths', 'default-push',
423 default=None,
423 default=None,
424 )
424 )
425 coreconfigitem('phases', 'checksubrepos',
425 coreconfigitem('phases', 'checksubrepos',
426 default='follow',
426 default='follow',
427 )
427 )
428 coreconfigitem('phases', 'new-commit',
428 coreconfigitem('phases', 'new-commit',
429 default='draft',
429 default='draft',
430 )
430 )
431 coreconfigitem('phases', 'publish',
431 coreconfigitem('phases', 'publish',
432 default=True,
432 default=True,
433 )
433 )
434 coreconfigitem('profiling', 'enabled',
434 coreconfigitem('profiling', 'enabled',
435 default=False,
435 default=False,
436 )
436 )
437 coreconfigitem('profiling', 'format',
437 coreconfigitem('profiling', 'format',
438 default='text',
438 default='text',
439 )
439 )
440 coreconfigitem('profiling', 'freq',
440 coreconfigitem('profiling', 'freq',
441 default=1000,
441 default=1000,
442 )
442 )
443 coreconfigitem('profiling', 'limit',
443 coreconfigitem('profiling', 'limit',
444 default=30,
444 default=30,
445 )
445 )
446 coreconfigitem('profiling', 'nested',
446 coreconfigitem('profiling', 'nested',
447 default=0,
447 default=0,
448 )
448 )
449 coreconfigitem('profiling', 'output',
449 coreconfigitem('profiling', 'output',
450 default=None,
450 default=None,
451 )
451 )
452 coreconfigitem('profiling', 'showmax',
452 coreconfigitem('profiling', 'showmax',
453 default=0.999,
453 default=0.999,
454 )
454 )
455 coreconfigitem('profiling', 'showmin',
455 coreconfigitem('profiling', 'showmin',
456 default=dynamicdefault,
456 default=dynamicdefault,
457 )
457 )
458 coreconfigitem('profiling', 'sort',
458 coreconfigitem('profiling', 'sort',
459 default='inlinetime',
459 default='inlinetime',
460 )
460 )
461 coreconfigitem('profiling', 'statformat',
461 coreconfigitem('profiling', 'statformat',
462 default='hotpath',
462 default='hotpath',
463 )
463 )
464 coreconfigitem('profiling', 'type',
464 coreconfigitem('profiling', 'type',
465 default='stat',
465 default='stat',
466 )
466 )
467 coreconfigitem('progress', 'assume-tty',
467 coreconfigitem('progress', 'assume-tty',
468 default=False,
468 default=False,
469 )
469 )
470 coreconfigitem('progress', 'changedelay',
470 coreconfigitem('progress', 'changedelay',
471 default=1,
471 default=1,
472 )
472 )
473 coreconfigitem('progress', 'clear-complete',
473 coreconfigitem('progress', 'clear-complete',
474 default=True,
474 default=True,
475 )
475 )
476 coreconfigitem('progress', 'debug',
476 coreconfigitem('progress', 'debug',
477 default=False,
477 default=False,
478 )
478 )
479 coreconfigitem('progress', 'delay',
479 coreconfigitem('progress', 'delay',
480 default=3,
480 default=3,
481 )
481 )
482 coreconfigitem('progress', 'disable',
482 coreconfigitem('progress', 'disable',
483 default=False,
483 default=False,
484 )
484 )
485 coreconfigitem('progress', 'estimateinterval',
485 coreconfigitem('progress', 'estimateinterval',
486 default=60.0,
486 default=60.0,
487 )
487 )
488 coreconfigitem('progress', 'refresh',
488 coreconfigitem('progress', 'refresh',
489 default=0.1,
489 default=0.1,
490 )
490 )
491 coreconfigitem('progress', 'width',
491 coreconfigitem('progress', 'width',
492 default=dynamicdefault,
492 default=dynamicdefault,
493 )
493 )
494 coreconfigitem('push', 'pushvars.server',
494 coreconfigitem('push', 'pushvars.server',
495 default=False,
495 default=False,
496 )
496 )
497 coreconfigitem('server', 'bundle1',
497 coreconfigitem('server', 'bundle1',
498 default=True,
498 default=True,
499 )
499 )
500 coreconfigitem('server', 'bundle1gd',
500 coreconfigitem('server', 'bundle1gd',
501 default=None,
501 default=None,
502 )
502 )
503 coreconfigitem('server', 'compressionengines',
503 coreconfigitem('server', 'compressionengines',
504 default=list,
504 default=list,
505 )
505 )
506 coreconfigitem('server', 'concurrent-push-mode',
506 coreconfigitem('server', 'concurrent-push-mode',
507 default='strict',
507 default='strict',
508 )
508 )
509 coreconfigitem('server', 'disablefullbundle',
509 coreconfigitem('server', 'disablefullbundle',
510 default=False,
510 default=False,
511 )
511 )
512 coreconfigitem('server', 'maxhttpheaderlen',
512 coreconfigitem('server', 'maxhttpheaderlen',
513 default=1024,
513 default=1024,
514 )
514 )
515 coreconfigitem('server', 'preferuncompressed',
515 coreconfigitem('server', 'preferuncompressed',
516 default=False,
516 default=False,
517 )
517 )
518 coreconfigitem('server', 'uncompressed',
518 coreconfigitem('server', 'uncompressed',
519 default=True,
519 default=True,
520 )
520 )
521 coreconfigitem('server', 'uncompressedallowsecret',
521 coreconfigitem('server', 'uncompressedallowsecret',
522 default=False,
522 default=False,
523 )
523 )
524 coreconfigitem('server', 'validate',
524 coreconfigitem('server', 'validate',
525 default=False,
525 default=False,
526 )
526 )
527 coreconfigitem('server', 'zliblevel',
527 coreconfigitem('server', 'zliblevel',
528 default=-1,
528 default=-1,
529 )
529 )
530 coreconfigitem('smtp', 'host',
530 coreconfigitem('smtp', 'host',
531 default=None,
531 default=None,
532 )
532 )
533 coreconfigitem('smtp', 'local_hostname',
533 coreconfigitem('smtp', 'local_hostname',
534 default=None,
534 default=None,
535 )
535 )
536 coreconfigitem('smtp', 'password',
536 coreconfigitem('smtp', 'password',
537 default=None,
537 default=None,
538 )
538 )
539 coreconfigitem('smtp', 'port',
539 coreconfigitem('smtp', 'port',
540 default=dynamicdefault,
540 default=dynamicdefault,
541 )
541 )
542 coreconfigitem('smtp', 'tls',
542 coreconfigitem('smtp', 'tls',
543 default='none',
543 default='none',
544 )
544 )
545 coreconfigitem('smtp', 'username',
545 coreconfigitem('smtp', 'username',
546 default=None,
546 default=None,
547 )
547 )
548 coreconfigitem('sparse', 'missingwarning',
548 coreconfigitem('sparse', 'missingwarning',
549 default=True,
549 default=True,
550 )
550 )
551 coreconfigitem('trusted', 'groups',
551 coreconfigitem('trusted', 'groups',
552 default=list,
552 default=list,
553 )
553 )
554 coreconfigitem('trusted', 'users',
554 coreconfigitem('trusted', 'users',
555 default=list,
555 default=list,
556 )
556 )
557 coreconfigitem('ui', '_usedassubrepo',
557 coreconfigitem('ui', '_usedassubrepo',
558 default=False,
558 default=False,
559 )
559 )
560 coreconfigitem('ui', 'allowemptycommit',
560 coreconfigitem('ui', 'allowemptycommit',
561 default=False,
561 default=False,
562 )
562 )
563 coreconfigitem('ui', 'archivemeta',
563 coreconfigitem('ui', 'archivemeta',
564 default=True,
564 default=True,
565 )
565 )
566 coreconfigitem('ui', 'askusername',
566 coreconfigitem('ui', 'askusername',
567 default=False,
567 default=False,
568 )
568 )
569 coreconfigitem('ui', 'clonebundlefallback',
569 coreconfigitem('ui', 'clonebundlefallback',
570 default=False,
570 default=False,
571 )
571 )
572 coreconfigitem('ui', 'clonebundleprefers',
572 coreconfigitem('ui', 'clonebundleprefers',
573 default=list,
573 default=list,
574 )
574 )
575 coreconfigitem('ui', 'clonebundles',
575 coreconfigitem('ui', 'clonebundles',
576 default=True,
576 default=True,
577 )
577 )
578 coreconfigitem('ui', 'color',
578 coreconfigitem('ui', 'color',
579 default='auto',
579 default='auto',
580 )
580 )
581 coreconfigitem('ui', 'commitsubrepos',
581 coreconfigitem('ui', 'commitsubrepos',
582 default=False,
582 default=False,
583 )
583 )
584 coreconfigitem('ui', 'debug',
584 coreconfigitem('ui', 'debug',
585 default=False,
585 default=False,
586 )
586 )
587 coreconfigitem('ui', 'debugger',
587 coreconfigitem('ui', 'debugger',
588 default=None,
588 default=None,
589 )
589 )
590 coreconfigitem('ui', 'fallbackencoding',
590 coreconfigitem('ui', 'fallbackencoding',
591 default=None,
591 default=None,
592 )
592 )
593 coreconfigitem('ui', 'forcecwd',
593 coreconfigitem('ui', 'forcecwd',
594 default=None,
594 default=None,
595 )
595 )
596 coreconfigitem('ui', 'forcemerge',
596 coreconfigitem('ui', 'forcemerge',
597 default=None,
597 default=None,
598 )
598 )
599 coreconfigitem('ui', 'formatdebug',
599 coreconfigitem('ui', 'formatdebug',
600 default=False,
600 default=False,
601 )
601 )
602 coreconfigitem('ui', 'formatjson',
602 coreconfigitem('ui', 'formatjson',
603 default=False,
603 default=False,
604 )
604 )
605 coreconfigitem('ui', 'formatted',
605 coreconfigitem('ui', 'formatted',
606 default=None,
606 default=None,
607 )
607 )
608 coreconfigitem('ui', 'graphnodetemplate',
608 coreconfigitem('ui', 'graphnodetemplate',
609 default=None,
609 default=None,
610 )
610 )
611 coreconfigitem('ui', 'http2debuglevel',
611 coreconfigitem('ui', 'http2debuglevel',
612 default=None,
612 default=None,
613 )
613 )
614 coreconfigitem('ui', 'interactive',
614 coreconfigitem('ui', 'interactive',
615 default=None,
615 default=None,
616 )
616 )
617 coreconfigitem('ui', 'interface',
617 coreconfigitem('ui', 'interface',
618 default=None,
618 default=None,
619 )
619 )
620 coreconfigitem('ui', 'logblockedtimes',
620 coreconfigitem('ui', 'logblockedtimes',
621 default=False,
621 default=False,
622 )
622 )
623 coreconfigitem('ui', 'logtemplate',
623 coreconfigitem('ui', 'logtemplate',
624 default=None,
624 default=None,
625 )
625 )
626 coreconfigitem('ui', 'merge',
626 coreconfigitem('ui', 'merge',
627 default=None,
627 default=None,
628 )
628 )
629 coreconfigitem('ui', 'mergemarkers',
629 coreconfigitem('ui', 'mergemarkers',
630 default='basic',
630 default='basic',
631 )
631 )
632 coreconfigitem('ui', 'mergemarkertemplate',
632 coreconfigitem('ui', 'mergemarkertemplate',
633 default=('{node|short} '
633 default=('{node|short} '
634 '{ifeq(tags, "tip", "", '
634 '{ifeq(tags, "tip", "", '
635 'ifeq(tags, "", "", "{tags} "))}'
635 'ifeq(tags, "", "", "{tags} "))}'
636 '{if(bookmarks, "{bookmarks} ")}'
636 '{if(bookmarks, "{bookmarks} ")}'
637 '{ifeq(branch, "default", "", "{branch} ")}'
637 '{ifeq(branch, "default", "", "{branch} ")}'
638 '- {author|user}: {desc|firstline}')
638 '- {author|user}: {desc|firstline}')
639 )
639 )
640 coreconfigitem('ui', 'nontty',
640 coreconfigitem('ui', 'nontty',
641 default=False,
641 default=False,
642 )
642 )
643 coreconfigitem('ui', 'origbackuppath',
643 coreconfigitem('ui', 'origbackuppath',
644 default=None,
644 default=None,
645 )
645 )
646 coreconfigitem('ui', 'paginate',
646 coreconfigitem('ui', 'paginate',
647 default=True,
647 default=True,
648 )
648 )
649 coreconfigitem('ui', 'patch',
649 coreconfigitem('ui', 'patch',
650 default=None,
650 default=None,
651 )
651 )
652 coreconfigitem('ui', 'portablefilenames',
652 coreconfigitem('ui', 'portablefilenames',
653 default='warn',
653 default='warn',
654 )
654 )
655 coreconfigitem('ui', 'promptecho',
655 coreconfigitem('ui', 'promptecho',
656 default=False,
656 default=False,
657 )
657 )
658 coreconfigitem('ui', 'quiet',
658 coreconfigitem('ui', 'quiet',
659 default=False,
659 default=False,
660 )
660 )
661 coreconfigitem('ui', 'quietbookmarkmove',
661 coreconfigitem('ui', 'quietbookmarkmove',
662 default=False,
662 default=False,
663 )
663 )
664 coreconfigitem('ui', 'remotecmd',
664 coreconfigitem('ui', 'remotecmd',
665 default='hg',
665 default='hg',
666 )
666 )
667 coreconfigitem('ui', 'report_untrusted',
667 coreconfigitem('ui', 'report_untrusted',
668 default=True,
668 default=True,
669 )
669 )
670 coreconfigitem('ui', 'rollback',
670 coreconfigitem('ui', 'rollback',
671 default=True,
671 default=True,
672 )
672 )
673 coreconfigitem('ui', 'slash',
673 coreconfigitem('ui', 'slash',
674 default=False,
674 default=False,
675 )
675 )
676 coreconfigitem('ui', 'ssh',
676 coreconfigitem('ui', 'ssh',
677 default='ssh',
677 default='ssh',
678 )
678 )
679 coreconfigitem('ui', 'statuscopies',
679 coreconfigitem('ui', 'statuscopies',
680 default=False,
680 default=False,
681 )
681 )
682 coreconfigitem('ui', 'strict',
682 coreconfigitem('ui', 'strict',
683 default=False,
683 default=False,
684 )
684 )
685 coreconfigitem('ui', 'style',
685 coreconfigitem('ui', 'style',
686 default='',
686 default='',
687 )
687 )
688 coreconfigitem('ui', 'supportcontact',
688 coreconfigitem('ui', 'supportcontact',
689 default=None,
689 default=None,
690 )
690 )
691 coreconfigitem('ui', 'textwidth',
691 coreconfigitem('ui', 'textwidth',
692 default=78,
692 default=78,
693 )
693 )
694 coreconfigitem('ui', 'timeout',
694 coreconfigitem('ui', 'timeout',
695 default='600',
695 default='600',
696 )
696 )
697 coreconfigitem('ui', 'traceback',
697 coreconfigitem('ui', 'traceback',
698 default=False,
698 default=False,
699 )
699 )
700 coreconfigitem('ui', 'tweakdefaults',
700 coreconfigitem('ui', 'tweakdefaults',
701 default=False,
701 default=False,
702 )
702 )
703 coreconfigitem('ui', 'usehttp2',
703 coreconfigitem('ui', 'usehttp2',
704 default=False,
704 default=False,
705 )
705 )
706 coreconfigitem('ui', 'username',
706 coreconfigitem('ui', 'username',
707 alias=[('ui', 'user')]
707 alias=[('ui', 'user')]
708 )
708 )
709 coreconfigitem('ui', 'verbose',
709 coreconfigitem('ui', 'verbose',
710 default=False,
710 default=False,
711 )
711 )
712 coreconfigitem('verify', 'skipflags',
712 coreconfigitem('verify', 'skipflags',
713 default=None,
713 default=None,
714 )
714 )
715 coreconfigitem('web', 'allowbz2',
715 coreconfigitem('web', 'allowbz2',
716 default=None,
716 default=None,
717 )
717 )
718 coreconfigitem('web', 'allowgz',
718 coreconfigitem('web', 'allowgz',
719 default=None,
719 default=None,
720 )
720 )
721 coreconfigitem('web', 'allowpull',
721 coreconfigitem('web', 'allowpull',
722 default=True,
722 default=True,
723 )
723 )
724 coreconfigitem('web', 'allow_push',
724 coreconfigitem('web', 'allow_push',
725 default=list,
725 default=list,
726 )
726 )
727 coreconfigitem('web', 'allowzip',
727 coreconfigitem('web', 'allowzip',
728 default=None,
728 default=None,
729 )
729 )
730 coreconfigitem('web', 'cache',
730 coreconfigitem('web', 'cache',
731 default=True,
731 default=True,
732 )
732 )
733 coreconfigitem('web', 'contact',
733 coreconfigitem('web', 'contact',
734 default=None,
734 default=None,
735 )
735 )
736 coreconfigitem('web', 'deny_push',
736 coreconfigitem('web', 'deny_push',
737 default=list,
737 default=list,
738 )
738 )
739 coreconfigitem('web', 'guessmime',
739 coreconfigitem('web', 'guessmime',
740 default=False,
740 default=False,
741 )
741 )
742 coreconfigitem('web', 'hidden',
742 coreconfigitem('web', 'hidden',
743 default=None,
743 default=None,
744 )
744 )
745 coreconfigitem('web', 'labels',
745 coreconfigitem('web', 'labels',
746 default=list,
746 default=list,
747 )
747 )
748 coreconfigitem('web', 'logoimg',
749 default='hglogo.png',
750 )
748 coreconfigitem('web', 'accesslog',
751 coreconfigitem('web', 'accesslog',
749 default='-',
752 default='-',
750 )
753 )
751 coreconfigitem('web', 'address',
754 coreconfigitem('web', 'address',
752 default='',
755 default='',
753 )
756 )
754 coreconfigitem('web', 'allow_archive',
757 coreconfigitem('web', 'allow_archive',
755 default=list,
758 default=list,
756 )
759 )
757 coreconfigitem('web', 'allow_read',
760 coreconfigitem('web', 'allow_read',
758 default=list,
761 default=list,
759 )
762 )
760 coreconfigitem('web', 'baseurl',
763 coreconfigitem('web', 'baseurl',
761 default=None,
764 default=None,
762 )
765 )
763 coreconfigitem('web', 'cacerts',
766 coreconfigitem('web', 'cacerts',
764 default=None,
767 default=None,
765 )
768 )
766 coreconfigitem('web', 'certificate',
769 coreconfigitem('web', 'certificate',
767 default=None,
770 default=None,
768 )
771 )
769 coreconfigitem('web', 'collapse',
772 coreconfigitem('web', 'collapse',
770 default=False,
773 default=False,
771 )
774 )
772 coreconfigitem('web', 'csp',
775 coreconfigitem('web', 'csp',
773 default=None,
776 default=None,
774 )
777 )
775 coreconfigitem('web', 'deny_read',
778 coreconfigitem('web', 'deny_read',
776 default=list,
779 default=list,
777 )
780 )
778 coreconfigitem('web', 'descend',
781 coreconfigitem('web', 'descend',
779 default=True,
782 default=True,
780 )
783 )
781 coreconfigitem('web', 'description',
784 coreconfigitem('web', 'description',
782 default="",
785 default="",
783 )
786 )
784 coreconfigitem('web', 'encoding',
787 coreconfigitem('web', 'encoding',
785 default=lambda: encoding.encoding,
788 default=lambda: encoding.encoding,
786 )
789 )
787 coreconfigitem('web', 'errorlog',
790 coreconfigitem('web', 'errorlog',
788 default='-',
791 default='-',
789 )
792 )
790 coreconfigitem('web', 'ipv6',
793 coreconfigitem('web', 'ipv6',
791 default=False,
794 default=False,
792 )
795 )
793 coreconfigitem('web', 'maxchanges',
796 coreconfigitem('web', 'maxchanges',
794 default=10,
797 default=10,
795 )
798 )
796 coreconfigitem('web', 'maxfiles',
799 coreconfigitem('web', 'maxfiles',
797 default=10,
800 default=10,
798 )
801 )
799 coreconfigitem('web', 'maxshortchanges',
802 coreconfigitem('web', 'maxshortchanges',
800 default=60,
803 default=60,
801 )
804 )
802 coreconfigitem('web', 'motd',
805 coreconfigitem('web', 'motd',
803 default='',
806 default='',
804 )
807 )
805 coreconfigitem('web', 'name',
808 coreconfigitem('web', 'name',
806 default=dynamicdefault,
809 default=dynamicdefault,
807 )
810 )
808 coreconfigitem('web', 'port',
811 coreconfigitem('web', 'port',
809 default=8000,
812 default=8000,
810 )
813 )
811 coreconfigitem('web', 'prefix',
814 coreconfigitem('web', 'prefix',
812 default='',
815 default='',
813 )
816 )
814 coreconfigitem('web', 'push_ssl',
817 coreconfigitem('web', 'push_ssl',
815 default=True,
818 default=True,
816 )
819 )
817 coreconfigitem('web', 'refreshinterval',
820 coreconfigitem('web', 'refreshinterval',
818 default=20,
821 default=20,
819 )
822 )
820 coreconfigitem('web', 'stripes',
823 coreconfigitem('web', 'stripes',
821 default=1,
824 default=1,
822 )
825 )
823 coreconfigitem('web', 'style',
826 coreconfigitem('web', 'style',
824 default='paper',
827 default='paper',
825 )
828 )
826 coreconfigitem('web', 'templates',
829 coreconfigitem('web', 'templates',
827 default=None,
830 default=None,
828 )
831 )
829 coreconfigitem('web', 'view',
832 coreconfigitem('web', 'view',
830 default='served',
833 default='served',
831 )
834 )
832 coreconfigitem('worker', 'backgroundclose',
835 coreconfigitem('worker', 'backgroundclose',
833 default=dynamicdefault,
836 default=dynamicdefault,
834 )
837 )
835 # Windows defaults to a limit of 512 open files. A buffer of 128
838 # Windows defaults to a limit of 512 open files. A buffer of 128
836 # should give us enough headway.
839 # should give us enough headway.
837 coreconfigitem('worker', 'backgroundclosemaxqueue',
840 coreconfigitem('worker', 'backgroundclosemaxqueue',
838 default=384,
841 default=384,
839 )
842 )
840 coreconfigitem('worker', 'backgroundcloseminfilecount',
843 coreconfigitem('worker', 'backgroundcloseminfilecount',
841 default=2048,
844 default=2048,
842 )
845 )
843 coreconfigitem('worker', 'backgroundclosethreadcount',
846 coreconfigitem('worker', 'backgroundclosethreadcount',
844 default=4,
847 default=4,
845 )
848 )
846 coreconfigitem('worker', 'numcpus',
849 coreconfigitem('worker', 'numcpus',
847 default=None,
850 default=None,
848 )
851 )
@@ -1,492 +1,492 b''
1 # hgweb/hgweb_mod.py - Web interface for a repository.
1 # hgweb/hgweb_mod.py - Web interface for a repository.
2 #
2 #
3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
4 # Copyright 2005-2007 Matt Mackall <mpm@selenic.com>
4 # Copyright 2005-2007 Matt Mackall <mpm@selenic.com>
5 #
5 #
6 # This software may be used and distributed according to the terms of the
6 # This software may be used and distributed according to the terms of the
7 # GNU General Public License version 2 or any later version.
7 # GNU General Public License version 2 or any later version.
8
8
9 from __future__ import absolute_import
9 from __future__ import absolute_import
10
10
11 import contextlib
11 import contextlib
12 import os
12 import os
13
13
14 from .common import (
14 from .common import (
15 ErrorResponse,
15 ErrorResponse,
16 HTTP_BAD_REQUEST,
16 HTTP_BAD_REQUEST,
17 HTTP_NOT_FOUND,
17 HTTP_NOT_FOUND,
18 HTTP_NOT_MODIFIED,
18 HTTP_NOT_MODIFIED,
19 HTTP_OK,
19 HTTP_OK,
20 HTTP_SERVER_ERROR,
20 HTTP_SERVER_ERROR,
21 caching,
21 caching,
22 cspvalues,
22 cspvalues,
23 permhooks,
23 permhooks,
24 )
24 )
25 from .request import wsgirequest
25 from .request import wsgirequest
26
26
27 from .. import (
27 from .. import (
28 encoding,
28 encoding,
29 error,
29 error,
30 hg,
30 hg,
31 hook,
31 hook,
32 profiling,
32 profiling,
33 pycompat,
33 pycompat,
34 repoview,
34 repoview,
35 templatefilters,
35 templatefilters,
36 templater,
36 templater,
37 ui as uimod,
37 ui as uimod,
38 util,
38 util,
39 )
39 )
40
40
41 from . import (
41 from . import (
42 protocol,
42 protocol,
43 webcommands,
43 webcommands,
44 webutil,
44 webutil,
45 wsgicgi,
45 wsgicgi,
46 )
46 )
47
47
48 perms = {
48 perms = {
49 'changegroup': 'pull',
49 'changegroup': 'pull',
50 'changegroupsubset': 'pull',
50 'changegroupsubset': 'pull',
51 'getbundle': 'pull',
51 'getbundle': 'pull',
52 'stream_out': 'pull',
52 'stream_out': 'pull',
53 'listkeys': 'pull',
53 'listkeys': 'pull',
54 'unbundle': 'push',
54 'unbundle': 'push',
55 'pushkey': 'push',
55 'pushkey': 'push',
56 }
56 }
57
57
58 archivespecs = util.sortdict((
58 archivespecs = util.sortdict((
59 ('zip', ('application/zip', 'zip', '.zip', None)),
59 ('zip', ('application/zip', 'zip', '.zip', None)),
60 ('gz', ('application/x-gzip', 'tgz', '.tar.gz', None)),
60 ('gz', ('application/x-gzip', 'tgz', '.tar.gz', None)),
61 ('bz2', ('application/x-bzip2', 'tbz2', '.tar.bz2', None)),
61 ('bz2', ('application/x-bzip2', 'tbz2', '.tar.bz2', None)),
62 ))
62 ))
63
63
64 def getstyle(req, configfn, templatepath):
64 def getstyle(req, configfn, templatepath):
65 fromreq = req.form.get('style', [None])[0]
65 fromreq = req.form.get('style', [None])[0]
66 if fromreq is not None:
66 if fromreq is not None:
67 fromreq = pycompat.sysbytes(fromreq)
67 fromreq = pycompat.sysbytes(fromreq)
68 styles = (
68 styles = (
69 fromreq,
69 fromreq,
70 configfn('web', 'style'),
70 configfn('web', 'style'),
71 'paper',
71 'paper',
72 )
72 )
73 return styles, templater.stylemap(styles, templatepath)
73 return styles, templater.stylemap(styles, templatepath)
74
74
75 def makebreadcrumb(url, prefix=''):
75 def makebreadcrumb(url, prefix=''):
76 '''Return a 'URL breadcrumb' list
76 '''Return a 'URL breadcrumb' list
77
77
78 A 'URL breadcrumb' is a list of URL-name pairs,
78 A 'URL breadcrumb' is a list of URL-name pairs,
79 corresponding to each of the path items on a URL.
79 corresponding to each of the path items on a URL.
80 This can be used to create path navigation entries.
80 This can be used to create path navigation entries.
81 '''
81 '''
82 if url.endswith('/'):
82 if url.endswith('/'):
83 url = url[:-1]
83 url = url[:-1]
84 if prefix:
84 if prefix:
85 url = '/' + prefix + url
85 url = '/' + prefix + url
86 relpath = url
86 relpath = url
87 if relpath.startswith('/'):
87 if relpath.startswith('/'):
88 relpath = relpath[1:]
88 relpath = relpath[1:]
89
89
90 breadcrumb = []
90 breadcrumb = []
91 urlel = url
91 urlel = url
92 pathitems = [''] + relpath.split('/')
92 pathitems = [''] + relpath.split('/')
93 for pathel in reversed(pathitems):
93 for pathel in reversed(pathitems):
94 if not pathel or not urlel:
94 if not pathel or not urlel:
95 break
95 break
96 breadcrumb.append({'url': urlel, 'name': pathel})
96 breadcrumb.append({'url': urlel, 'name': pathel})
97 urlel = os.path.dirname(urlel)
97 urlel = os.path.dirname(urlel)
98 return reversed(breadcrumb)
98 return reversed(breadcrumb)
99
99
100 class requestcontext(object):
100 class requestcontext(object):
101 """Holds state/context for an individual request.
101 """Holds state/context for an individual request.
102
102
103 Servers can be multi-threaded. Holding state on the WSGI application
103 Servers can be multi-threaded. Holding state on the WSGI application
104 is prone to race conditions. Instances of this class exist to hold
104 is prone to race conditions. Instances of this class exist to hold
105 mutable and race-free state for requests.
105 mutable and race-free state for requests.
106 """
106 """
107 def __init__(self, app, repo):
107 def __init__(self, app, repo):
108 self.repo = repo
108 self.repo = repo
109 self.reponame = app.reponame
109 self.reponame = app.reponame
110
110
111 self.archivespecs = archivespecs
111 self.archivespecs = archivespecs
112
112
113 self.maxchanges = self.configint('web', 'maxchanges')
113 self.maxchanges = self.configint('web', 'maxchanges')
114 self.stripecount = self.configint('web', 'stripes')
114 self.stripecount = self.configint('web', 'stripes')
115 self.maxshortchanges = self.configint('web', 'maxshortchanges')
115 self.maxshortchanges = self.configint('web', 'maxshortchanges')
116 self.maxfiles = self.configint('web', 'maxfiles')
116 self.maxfiles = self.configint('web', 'maxfiles')
117 self.allowpull = self.configbool('web', 'allowpull')
117 self.allowpull = self.configbool('web', 'allowpull')
118
118
119 # we use untrusted=False to prevent a repo owner from using
119 # we use untrusted=False to prevent a repo owner from using
120 # web.templates in .hg/hgrc to get access to any file readable
120 # web.templates in .hg/hgrc to get access to any file readable
121 # by the user running the CGI script
121 # by the user running the CGI script
122 self.templatepath = self.config('web', 'templates', untrusted=False)
122 self.templatepath = self.config('web', 'templates', untrusted=False)
123
123
124 # This object is more expensive to build than simple config values.
124 # This object is more expensive to build than simple config values.
125 # It is shared across requests. The app will replace the object
125 # It is shared across requests. The app will replace the object
126 # if it is updated. Since this is a reference and nothing should
126 # if it is updated. Since this is a reference and nothing should
127 # modify the underlying object, it should be constant for the lifetime
127 # modify the underlying object, it should be constant for the lifetime
128 # of the request.
128 # of the request.
129 self.websubtable = app.websubtable
129 self.websubtable = app.websubtable
130
130
131 self.csp, self.nonce = cspvalues(self.repo.ui)
131 self.csp, self.nonce = cspvalues(self.repo.ui)
132
132
133 # Trust the settings from the .hg/hgrc files by default.
133 # Trust the settings from the .hg/hgrc files by default.
134 def config(self, section, name, default=uimod._unset, untrusted=True):
134 def config(self, section, name, default=uimod._unset, untrusted=True):
135 return self.repo.ui.config(section, name, default,
135 return self.repo.ui.config(section, name, default,
136 untrusted=untrusted)
136 untrusted=untrusted)
137
137
138 def configbool(self, section, name, default=uimod._unset, untrusted=True):
138 def configbool(self, section, name, default=uimod._unset, untrusted=True):
139 return self.repo.ui.configbool(section, name, default,
139 return self.repo.ui.configbool(section, name, default,
140 untrusted=untrusted)
140 untrusted=untrusted)
141
141
142 def configint(self, section, name, default=uimod._unset, untrusted=True):
142 def configint(self, section, name, default=uimod._unset, untrusted=True):
143 return self.repo.ui.configint(section, name, default,
143 return self.repo.ui.configint(section, name, default,
144 untrusted=untrusted)
144 untrusted=untrusted)
145
145
146 def configlist(self, section, name, default=uimod._unset, untrusted=True):
146 def configlist(self, section, name, default=uimod._unset, untrusted=True):
147 return self.repo.ui.configlist(section, name, default,
147 return self.repo.ui.configlist(section, name, default,
148 untrusted=untrusted)
148 untrusted=untrusted)
149
149
150 def archivelist(self, nodeid):
150 def archivelist(self, nodeid):
151 allowed = self.configlist('web', 'allow_archive')
151 allowed = self.configlist('web', 'allow_archive')
152 for typ, spec in self.archivespecs.iteritems():
152 for typ, spec in self.archivespecs.iteritems():
153 if typ in allowed or self.configbool('web', 'allow%s' % typ):
153 if typ in allowed or self.configbool('web', 'allow%s' % typ):
154 yield {'type': typ, 'extension': spec[2], 'node': nodeid}
154 yield {'type': typ, 'extension': spec[2], 'node': nodeid}
155
155
156 def templater(self, req):
156 def templater(self, req):
157 # determine scheme, port and server name
157 # determine scheme, port and server name
158 # this is needed to create absolute urls
158 # this is needed to create absolute urls
159
159
160 proto = req.env.get('wsgi.url_scheme')
160 proto = req.env.get('wsgi.url_scheme')
161 if proto == 'https':
161 if proto == 'https':
162 proto = 'https'
162 proto = 'https'
163 default_port = '443'
163 default_port = '443'
164 else:
164 else:
165 proto = 'http'
165 proto = 'http'
166 default_port = '80'
166 default_port = '80'
167
167
168 port = req.env['SERVER_PORT']
168 port = req.env['SERVER_PORT']
169 port = port != default_port and (':' + port) or ''
169 port = port != default_port and (':' + port) or ''
170 urlbase = '%s://%s%s' % (proto, req.env['SERVER_NAME'], port)
170 urlbase = '%s://%s%s' % (proto, req.env['SERVER_NAME'], port)
171 logourl = self.config('web', 'logourl', 'https://mercurial-scm.org/')
171 logourl = self.config('web', 'logourl', 'https://mercurial-scm.org/')
172 logoimg = self.config('web', 'logoimg', 'hglogo.png')
172 logoimg = self.config('web', 'logoimg')
173 staticurl = self.config('web', 'staticurl') or req.url + 'static/'
173 staticurl = self.config('web', 'staticurl') or req.url + 'static/'
174 if not staticurl.endswith('/'):
174 if not staticurl.endswith('/'):
175 staticurl += '/'
175 staticurl += '/'
176
176
177 # some functions for the templater
177 # some functions for the templater
178
178
179 def motd(**map):
179 def motd(**map):
180 yield self.config('web', 'motd')
180 yield self.config('web', 'motd')
181
181
182 # figure out which style to use
182 # figure out which style to use
183
183
184 vars = {}
184 vars = {}
185 styles, (style, mapfile) = getstyle(req, self.config,
185 styles, (style, mapfile) = getstyle(req, self.config,
186 self.templatepath)
186 self.templatepath)
187 if style == styles[0]:
187 if style == styles[0]:
188 vars['style'] = style
188 vars['style'] = style
189
189
190 start = req.url[-1] == '?' and '&' or '?'
190 start = req.url[-1] == '?' and '&' or '?'
191 sessionvars = webutil.sessionvars(vars, start)
191 sessionvars = webutil.sessionvars(vars, start)
192
192
193 if not self.reponame:
193 if not self.reponame:
194 self.reponame = (self.config('web', 'name', '')
194 self.reponame = (self.config('web', 'name', '')
195 or req.env.get('REPO_NAME')
195 or req.env.get('REPO_NAME')
196 or req.url.strip('/') or self.repo.root)
196 or req.url.strip('/') or self.repo.root)
197
197
198 def websubfilter(text):
198 def websubfilter(text):
199 return templatefilters.websub(text, self.websubtable)
199 return templatefilters.websub(text, self.websubtable)
200
200
201 # create the templater
201 # create the templater
202
202
203 defaults = {
203 defaults = {
204 'url': req.url,
204 'url': req.url,
205 'logourl': logourl,
205 'logourl': logourl,
206 'logoimg': logoimg,
206 'logoimg': logoimg,
207 'staticurl': staticurl,
207 'staticurl': staticurl,
208 'urlbase': urlbase,
208 'urlbase': urlbase,
209 'repo': self.reponame,
209 'repo': self.reponame,
210 'encoding': encoding.encoding,
210 'encoding': encoding.encoding,
211 'motd': motd,
211 'motd': motd,
212 'sessionvars': sessionvars,
212 'sessionvars': sessionvars,
213 'pathdef': makebreadcrumb(req.url),
213 'pathdef': makebreadcrumb(req.url),
214 'style': style,
214 'style': style,
215 'nonce': self.nonce,
215 'nonce': self.nonce,
216 }
216 }
217 tmpl = templater.templater.frommapfile(mapfile,
217 tmpl = templater.templater.frommapfile(mapfile,
218 filters={'websub': websubfilter},
218 filters={'websub': websubfilter},
219 defaults=defaults)
219 defaults=defaults)
220 return tmpl
220 return tmpl
221
221
222
222
223 class hgweb(object):
223 class hgweb(object):
224 """HTTP server for individual repositories.
224 """HTTP server for individual repositories.
225
225
226 Instances of this class serve HTTP responses for a particular
226 Instances of this class serve HTTP responses for a particular
227 repository.
227 repository.
228
228
229 Instances are typically used as WSGI applications.
229 Instances are typically used as WSGI applications.
230
230
231 Some servers are multi-threaded. On these servers, there may
231 Some servers are multi-threaded. On these servers, there may
232 be multiple active threads inside __call__.
232 be multiple active threads inside __call__.
233 """
233 """
234 def __init__(self, repo, name=None, baseui=None):
234 def __init__(self, repo, name=None, baseui=None):
235 if isinstance(repo, str):
235 if isinstance(repo, str):
236 if baseui:
236 if baseui:
237 u = baseui.copy()
237 u = baseui.copy()
238 else:
238 else:
239 u = uimod.ui.load()
239 u = uimod.ui.load()
240 r = hg.repository(u, repo)
240 r = hg.repository(u, repo)
241 else:
241 else:
242 # we trust caller to give us a private copy
242 # we trust caller to give us a private copy
243 r = repo
243 r = repo
244
244
245 r.ui.setconfig('ui', 'report_untrusted', 'off', 'hgweb')
245 r.ui.setconfig('ui', 'report_untrusted', 'off', 'hgweb')
246 r.baseui.setconfig('ui', 'report_untrusted', 'off', 'hgweb')
246 r.baseui.setconfig('ui', 'report_untrusted', 'off', 'hgweb')
247 r.ui.setconfig('ui', 'nontty', 'true', 'hgweb')
247 r.ui.setconfig('ui', 'nontty', 'true', 'hgweb')
248 r.baseui.setconfig('ui', 'nontty', 'true', 'hgweb')
248 r.baseui.setconfig('ui', 'nontty', 'true', 'hgweb')
249 # resolve file patterns relative to repo root
249 # resolve file patterns relative to repo root
250 r.ui.setconfig('ui', 'forcecwd', r.root, 'hgweb')
250 r.ui.setconfig('ui', 'forcecwd', r.root, 'hgweb')
251 r.baseui.setconfig('ui', 'forcecwd', r.root, 'hgweb')
251 r.baseui.setconfig('ui', 'forcecwd', r.root, 'hgweb')
252 # displaying bundling progress bar while serving feel wrong and may
252 # displaying bundling progress bar while serving feel wrong and may
253 # break some wsgi implementation.
253 # break some wsgi implementation.
254 r.ui.setconfig('progress', 'disable', 'true', 'hgweb')
254 r.ui.setconfig('progress', 'disable', 'true', 'hgweb')
255 r.baseui.setconfig('progress', 'disable', 'true', 'hgweb')
255 r.baseui.setconfig('progress', 'disable', 'true', 'hgweb')
256 self._repos = [hg.cachedlocalrepo(self._webifyrepo(r))]
256 self._repos = [hg.cachedlocalrepo(self._webifyrepo(r))]
257 self._lastrepo = self._repos[0]
257 self._lastrepo = self._repos[0]
258 hook.redirect(True)
258 hook.redirect(True)
259 self.reponame = name
259 self.reponame = name
260
260
261 def _webifyrepo(self, repo):
261 def _webifyrepo(self, repo):
262 repo = getwebview(repo)
262 repo = getwebview(repo)
263 self.websubtable = webutil.getwebsubs(repo)
263 self.websubtable = webutil.getwebsubs(repo)
264 return repo
264 return repo
265
265
266 @contextlib.contextmanager
266 @contextlib.contextmanager
267 def _obtainrepo(self):
267 def _obtainrepo(self):
268 """Obtain a repo unique to the caller.
268 """Obtain a repo unique to the caller.
269
269
270 Internally we maintain a stack of cachedlocalrepo instances
270 Internally we maintain a stack of cachedlocalrepo instances
271 to be handed out. If one is available, we pop it and return it,
271 to be handed out. If one is available, we pop it and return it,
272 ensuring it is up to date in the process. If one is not available,
272 ensuring it is up to date in the process. If one is not available,
273 we clone the most recently used repo instance and return it.
273 we clone the most recently used repo instance and return it.
274
274
275 It is currently possible for the stack to grow without bounds
275 It is currently possible for the stack to grow without bounds
276 if the server allows infinite threads. However, servers should
276 if the server allows infinite threads. However, servers should
277 have a thread limit, thus establishing our limit.
277 have a thread limit, thus establishing our limit.
278 """
278 """
279 if self._repos:
279 if self._repos:
280 cached = self._repos.pop()
280 cached = self._repos.pop()
281 r, created = cached.fetch()
281 r, created = cached.fetch()
282 else:
282 else:
283 cached = self._lastrepo.copy()
283 cached = self._lastrepo.copy()
284 r, created = cached.fetch()
284 r, created = cached.fetch()
285 if created:
285 if created:
286 r = self._webifyrepo(r)
286 r = self._webifyrepo(r)
287
287
288 self._lastrepo = cached
288 self._lastrepo = cached
289 self.mtime = cached.mtime
289 self.mtime = cached.mtime
290 try:
290 try:
291 yield r
291 yield r
292 finally:
292 finally:
293 self._repos.append(cached)
293 self._repos.append(cached)
294
294
295 def run(self):
295 def run(self):
296 """Start a server from CGI environment.
296 """Start a server from CGI environment.
297
297
298 Modern servers should be using WSGI and should avoid this
298 Modern servers should be using WSGI and should avoid this
299 method, if possible.
299 method, if possible.
300 """
300 """
301 if not encoding.environ.get('GATEWAY_INTERFACE',
301 if not encoding.environ.get('GATEWAY_INTERFACE',
302 '').startswith("CGI/1."):
302 '').startswith("CGI/1."):
303 raise RuntimeError("This function is only intended to be "
303 raise RuntimeError("This function is only intended to be "
304 "called while running as a CGI script.")
304 "called while running as a CGI script.")
305 wsgicgi.launch(self)
305 wsgicgi.launch(self)
306
306
307 def __call__(self, env, respond):
307 def __call__(self, env, respond):
308 """Run the WSGI application.
308 """Run the WSGI application.
309
309
310 This may be called by multiple threads.
310 This may be called by multiple threads.
311 """
311 """
312 req = wsgirequest(env, respond)
312 req = wsgirequest(env, respond)
313 return self.run_wsgi(req)
313 return self.run_wsgi(req)
314
314
315 def run_wsgi(self, req):
315 def run_wsgi(self, req):
316 """Internal method to run the WSGI application.
316 """Internal method to run the WSGI application.
317
317
318 This is typically only called by Mercurial. External consumers
318 This is typically only called by Mercurial. External consumers
319 should be using instances of this class as the WSGI application.
319 should be using instances of this class as the WSGI application.
320 """
320 """
321 with self._obtainrepo() as repo:
321 with self._obtainrepo() as repo:
322 profile = repo.ui.configbool('profiling', 'enabled')
322 profile = repo.ui.configbool('profiling', 'enabled')
323 with profiling.profile(repo.ui, enabled=profile):
323 with profiling.profile(repo.ui, enabled=profile):
324 for r in self._runwsgi(req, repo):
324 for r in self._runwsgi(req, repo):
325 yield r
325 yield r
326
326
327 def _runwsgi(self, req, repo):
327 def _runwsgi(self, req, repo):
328 rctx = requestcontext(self, repo)
328 rctx = requestcontext(self, repo)
329
329
330 # This state is global across all threads.
330 # This state is global across all threads.
331 encoding.encoding = rctx.config('web', 'encoding')
331 encoding.encoding = rctx.config('web', 'encoding')
332 rctx.repo.ui.environ = req.env
332 rctx.repo.ui.environ = req.env
333
333
334 if rctx.csp:
334 if rctx.csp:
335 # hgwebdir may have added CSP header. Since we generate our own,
335 # hgwebdir may have added CSP header. Since we generate our own,
336 # replace it.
336 # replace it.
337 req.headers = [h for h in req.headers
337 req.headers = [h for h in req.headers
338 if h[0] != 'Content-Security-Policy']
338 if h[0] != 'Content-Security-Policy']
339 req.headers.append(('Content-Security-Policy', rctx.csp))
339 req.headers.append(('Content-Security-Policy', rctx.csp))
340
340
341 # work with CGI variables to create coherent structure
341 # work with CGI variables to create coherent structure
342 # use SCRIPT_NAME, PATH_INFO and QUERY_STRING as well as our REPO_NAME
342 # use SCRIPT_NAME, PATH_INFO and QUERY_STRING as well as our REPO_NAME
343
343
344 req.url = req.env['SCRIPT_NAME']
344 req.url = req.env['SCRIPT_NAME']
345 if not req.url.endswith('/'):
345 if not req.url.endswith('/'):
346 req.url += '/'
346 req.url += '/'
347 if req.env.get('REPO_NAME'):
347 if req.env.get('REPO_NAME'):
348 req.url += req.env['REPO_NAME'] + '/'
348 req.url += req.env['REPO_NAME'] + '/'
349
349
350 if 'PATH_INFO' in req.env:
350 if 'PATH_INFO' in req.env:
351 parts = req.env['PATH_INFO'].strip('/').split('/')
351 parts = req.env['PATH_INFO'].strip('/').split('/')
352 repo_parts = req.env.get('REPO_NAME', '').split('/')
352 repo_parts = req.env.get('REPO_NAME', '').split('/')
353 if parts[:len(repo_parts)] == repo_parts:
353 if parts[:len(repo_parts)] == repo_parts:
354 parts = parts[len(repo_parts):]
354 parts = parts[len(repo_parts):]
355 query = '/'.join(parts)
355 query = '/'.join(parts)
356 else:
356 else:
357 query = req.env['QUERY_STRING'].partition('&')[0]
357 query = req.env['QUERY_STRING'].partition('&')[0]
358 query = query.partition(';')[0]
358 query = query.partition(';')[0]
359
359
360 # process this if it's a protocol request
360 # process this if it's a protocol request
361 # protocol bits don't need to create any URLs
361 # protocol bits don't need to create any URLs
362 # and the clients always use the old URL structure
362 # and the clients always use the old URL structure
363
363
364 cmd = req.form.get('cmd', [''])[0]
364 cmd = req.form.get('cmd', [''])[0]
365 if protocol.iscmd(cmd):
365 if protocol.iscmd(cmd):
366 try:
366 try:
367 if query:
367 if query:
368 raise ErrorResponse(HTTP_NOT_FOUND)
368 raise ErrorResponse(HTTP_NOT_FOUND)
369 if cmd in perms:
369 if cmd in perms:
370 self.check_perm(rctx, req, perms[cmd])
370 self.check_perm(rctx, req, perms[cmd])
371 return protocol.call(rctx.repo, req, cmd)
371 return protocol.call(rctx.repo, req, cmd)
372 except ErrorResponse as inst:
372 except ErrorResponse as inst:
373 # A client that sends unbundle without 100-continue will
373 # A client that sends unbundle without 100-continue will
374 # break if we respond early.
374 # break if we respond early.
375 if (cmd == 'unbundle' and
375 if (cmd == 'unbundle' and
376 (req.env.get('HTTP_EXPECT',
376 (req.env.get('HTTP_EXPECT',
377 '').lower() != '100-continue') or
377 '').lower() != '100-continue') or
378 req.env.get('X-HgHttp2', '')):
378 req.env.get('X-HgHttp2', '')):
379 req.drain()
379 req.drain()
380 else:
380 else:
381 req.headers.append(('Connection', 'Close'))
381 req.headers.append(('Connection', 'Close'))
382 req.respond(inst, protocol.HGTYPE,
382 req.respond(inst, protocol.HGTYPE,
383 body='0\n%s\n' % inst)
383 body='0\n%s\n' % inst)
384 return ''
384 return ''
385
385
386 # translate user-visible url structure to internal structure
386 # translate user-visible url structure to internal structure
387
387
388 args = query.split('/', 2)
388 args = query.split('/', 2)
389 if 'cmd' not in req.form and args and args[0]:
389 if 'cmd' not in req.form and args and args[0]:
390
390
391 cmd = args.pop(0)
391 cmd = args.pop(0)
392 style = cmd.rfind('-')
392 style = cmd.rfind('-')
393 if style != -1:
393 if style != -1:
394 req.form['style'] = [cmd[:style]]
394 req.form['style'] = [cmd[:style]]
395 cmd = cmd[style + 1:]
395 cmd = cmd[style + 1:]
396
396
397 # avoid accepting e.g. style parameter as command
397 # avoid accepting e.g. style parameter as command
398 if util.safehasattr(webcommands, cmd):
398 if util.safehasattr(webcommands, cmd):
399 req.form['cmd'] = [cmd]
399 req.form['cmd'] = [cmd]
400
400
401 if cmd == 'static':
401 if cmd == 'static':
402 req.form['file'] = ['/'.join(args)]
402 req.form['file'] = ['/'.join(args)]
403 else:
403 else:
404 if args and args[0]:
404 if args and args[0]:
405 node = args.pop(0).replace('%2F', '/')
405 node = args.pop(0).replace('%2F', '/')
406 req.form['node'] = [node]
406 req.form['node'] = [node]
407 if args:
407 if args:
408 req.form['file'] = args
408 req.form['file'] = args
409
409
410 ua = req.env.get('HTTP_USER_AGENT', '')
410 ua = req.env.get('HTTP_USER_AGENT', '')
411 if cmd == 'rev' and 'mercurial' in ua:
411 if cmd == 'rev' and 'mercurial' in ua:
412 req.form['style'] = ['raw']
412 req.form['style'] = ['raw']
413
413
414 if cmd == 'archive':
414 if cmd == 'archive':
415 fn = req.form['node'][0]
415 fn = req.form['node'][0]
416 for type_, spec in rctx.archivespecs.iteritems():
416 for type_, spec in rctx.archivespecs.iteritems():
417 ext = spec[2]
417 ext = spec[2]
418 if fn.endswith(ext):
418 if fn.endswith(ext):
419 req.form['node'] = [fn[:-len(ext)]]
419 req.form['node'] = [fn[:-len(ext)]]
420 req.form['type'] = [type_]
420 req.form['type'] = [type_]
421
421
422 # process the web interface request
422 # process the web interface request
423
423
424 try:
424 try:
425 tmpl = rctx.templater(req)
425 tmpl = rctx.templater(req)
426 ctype = tmpl('mimetype', encoding=encoding.encoding)
426 ctype = tmpl('mimetype', encoding=encoding.encoding)
427 ctype = templater.stringify(ctype)
427 ctype = templater.stringify(ctype)
428
428
429 # check read permissions non-static content
429 # check read permissions non-static content
430 if cmd != 'static':
430 if cmd != 'static':
431 self.check_perm(rctx, req, None)
431 self.check_perm(rctx, req, None)
432
432
433 if cmd == '':
433 if cmd == '':
434 req.form['cmd'] = [tmpl.cache['default']]
434 req.form['cmd'] = [tmpl.cache['default']]
435 cmd = req.form['cmd'][0]
435 cmd = req.form['cmd'][0]
436
436
437 # Don't enable caching if using a CSP nonce because then it wouldn't
437 # Don't enable caching if using a CSP nonce because then it wouldn't
438 # be a nonce.
438 # be a nonce.
439 if rctx.configbool('web', 'cache') and not rctx.nonce:
439 if rctx.configbool('web', 'cache') and not rctx.nonce:
440 caching(self, req) # sets ETag header or raises NOT_MODIFIED
440 caching(self, req) # sets ETag header or raises NOT_MODIFIED
441 if cmd not in webcommands.__all__:
441 if cmd not in webcommands.__all__:
442 msg = 'no such method: %s' % cmd
442 msg = 'no such method: %s' % cmd
443 raise ErrorResponse(HTTP_BAD_REQUEST, msg)
443 raise ErrorResponse(HTTP_BAD_REQUEST, msg)
444 elif cmd == 'file' and 'raw' in req.form.get('style', []):
444 elif cmd == 'file' and 'raw' in req.form.get('style', []):
445 rctx.ctype = ctype
445 rctx.ctype = ctype
446 content = webcommands.rawfile(rctx, req, tmpl)
446 content = webcommands.rawfile(rctx, req, tmpl)
447 else:
447 else:
448 content = getattr(webcommands, cmd)(rctx, req, tmpl)
448 content = getattr(webcommands, cmd)(rctx, req, tmpl)
449 req.respond(HTTP_OK, ctype)
449 req.respond(HTTP_OK, ctype)
450
450
451 return content
451 return content
452
452
453 except (error.LookupError, error.RepoLookupError) as err:
453 except (error.LookupError, error.RepoLookupError) as err:
454 req.respond(HTTP_NOT_FOUND, ctype)
454 req.respond(HTTP_NOT_FOUND, ctype)
455 msg = str(err)
455 msg = str(err)
456 if (util.safehasattr(err, 'name') and
456 if (util.safehasattr(err, 'name') and
457 not isinstance(err, error.ManifestLookupError)):
457 not isinstance(err, error.ManifestLookupError)):
458 msg = 'revision not found: %s' % err.name
458 msg = 'revision not found: %s' % err.name
459 return tmpl('error', error=msg)
459 return tmpl('error', error=msg)
460 except (error.RepoError, error.RevlogError) as inst:
460 except (error.RepoError, error.RevlogError) as inst:
461 req.respond(HTTP_SERVER_ERROR, ctype)
461 req.respond(HTTP_SERVER_ERROR, ctype)
462 return tmpl('error', error=str(inst))
462 return tmpl('error', error=str(inst))
463 except ErrorResponse as inst:
463 except ErrorResponse as inst:
464 req.respond(inst, ctype)
464 req.respond(inst, ctype)
465 if inst.code == HTTP_NOT_MODIFIED:
465 if inst.code == HTTP_NOT_MODIFIED:
466 # Not allowed to return a body on a 304
466 # Not allowed to return a body on a 304
467 return ['']
467 return ['']
468 return tmpl('error', error=str(inst))
468 return tmpl('error', error=str(inst))
469
469
470 def check_perm(self, rctx, req, op):
470 def check_perm(self, rctx, req, op):
471 for permhook in permhooks:
471 for permhook in permhooks:
472 permhook(rctx, req, op)
472 permhook(rctx, req, op)
473
473
474 def getwebview(repo):
474 def getwebview(repo):
475 """The 'web.view' config controls changeset filter to hgweb. Possible
475 """The 'web.view' config controls changeset filter to hgweb. Possible
476 values are ``served``, ``visible`` and ``all``. Default is ``served``.
476 values are ``served``, ``visible`` and ``all``. Default is ``served``.
477 The ``served`` filter only shows changesets that can be pulled from the
477 The ``served`` filter only shows changesets that can be pulled from the
478 hgweb instance. The``visible`` filter includes secret changesets but
478 hgweb instance. The``visible`` filter includes secret changesets but
479 still excludes "hidden" one.
479 still excludes "hidden" one.
480
480
481 See the repoview module for details.
481 See the repoview module for details.
482
482
483 The option has been around undocumented since Mercurial 2.5, but no
483 The option has been around undocumented since Mercurial 2.5, but no
484 user ever asked about it. So we better keep it undocumented for now."""
484 user ever asked about it. So we better keep it undocumented for now."""
485 # experimental config: web.view
485 # experimental config: web.view
486 viewconfig = repo.ui.config('web', 'view', untrusted=True)
486 viewconfig = repo.ui.config('web', 'view', untrusted=True)
487 if viewconfig == 'all':
487 if viewconfig == 'all':
488 return repo.unfiltered()
488 return repo.unfiltered()
489 elif viewconfig in repoview.filtertable:
489 elif viewconfig in repoview.filtertable:
490 return repo.filtered(viewconfig)
490 return repo.filtered(viewconfig)
491 else:
491 else:
492 return repo.filtered('served')
492 return repo.filtered('served')
@@ -1,538 +1,538 b''
1 # hgweb/hgwebdir_mod.py - Web interface for a directory of repositories.
1 # hgweb/hgwebdir_mod.py - Web interface for a directory of repositories.
2 #
2 #
3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
4 # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
4 # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
5 #
5 #
6 # This software may be used and distributed according to the terms of the
6 # This software may be used and distributed according to the terms of the
7 # GNU General Public License version 2 or any later version.
7 # GNU General Public License version 2 or any later version.
8
8
9 from __future__ import absolute_import
9 from __future__ import absolute_import
10
10
11 import os
11 import os
12 import re
12 import re
13 import time
13 import time
14
14
15 from ..i18n import _
15 from ..i18n import _
16
16
17 from .common import (
17 from .common import (
18 ErrorResponse,
18 ErrorResponse,
19 HTTP_NOT_FOUND,
19 HTTP_NOT_FOUND,
20 HTTP_OK,
20 HTTP_OK,
21 HTTP_SERVER_ERROR,
21 HTTP_SERVER_ERROR,
22 cspvalues,
22 cspvalues,
23 get_contact,
23 get_contact,
24 get_mtime,
24 get_mtime,
25 ismember,
25 ismember,
26 paritygen,
26 paritygen,
27 staticfile,
27 staticfile,
28 )
28 )
29 from .request import wsgirequest
29 from .request import wsgirequest
30
30
31 from .. import (
31 from .. import (
32 configitems,
32 configitems,
33 encoding,
33 encoding,
34 error,
34 error,
35 hg,
35 hg,
36 profiling,
36 profiling,
37 pycompat,
37 pycompat,
38 scmutil,
38 scmutil,
39 templater,
39 templater,
40 ui as uimod,
40 ui as uimod,
41 util,
41 util,
42 )
42 )
43
43
44 from . import (
44 from . import (
45 hgweb_mod,
45 hgweb_mod,
46 webutil,
46 webutil,
47 wsgicgi,
47 wsgicgi,
48 )
48 )
49
49
50 def cleannames(items):
50 def cleannames(items):
51 return [(util.pconvert(name).strip('/'), path) for name, path in items]
51 return [(util.pconvert(name).strip('/'), path) for name, path in items]
52
52
53 def findrepos(paths):
53 def findrepos(paths):
54 repos = []
54 repos = []
55 for prefix, root in cleannames(paths):
55 for prefix, root in cleannames(paths):
56 roothead, roottail = os.path.split(root)
56 roothead, roottail = os.path.split(root)
57 # "foo = /bar/*" or "foo = /bar/**" lets every repo /bar/N in or below
57 # "foo = /bar/*" or "foo = /bar/**" lets every repo /bar/N in or below
58 # /bar/ be served as as foo/N .
58 # /bar/ be served as as foo/N .
59 # '*' will not search inside dirs with .hg (except .hg/patches),
59 # '*' will not search inside dirs with .hg (except .hg/patches),
60 # '**' will search inside dirs with .hg (and thus also find subrepos).
60 # '**' will search inside dirs with .hg (and thus also find subrepos).
61 try:
61 try:
62 recurse = {'*': False, '**': True}[roottail]
62 recurse = {'*': False, '**': True}[roottail]
63 except KeyError:
63 except KeyError:
64 repos.append((prefix, root))
64 repos.append((prefix, root))
65 continue
65 continue
66 roothead = os.path.normpath(os.path.abspath(roothead))
66 roothead = os.path.normpath(os.path.abspath(roothead))
67 paths = scmutil.walkrepos(roothead, followsym=True, recurse=recurse)
67 paths = scmutil.walkrepos(roothead, followsym=True, recurse=recurse)
68 repos.extend(urlrepos(prefix, roothead, paths))
68 repos.extend(urlrepos(prefix, roothead, paths))
69 return repos
69 return repos
70
70
71 def urlrepos(prefix, roothead, paths):
71 def urlrepos(prefix, roothead, paths):
72 """yield url paths and filesystem paths from a list of repo paths
72 """yield url paths and filesystem paths from a list of repo paths
73
73
74 >>> conv = lambda seq: [(v, util.pconvert(p)) for v,p in seq]
74 >>> conv = lambda seq: [(v, util.pconvert(p)) for v,p in seq]
75 >>> conv(urlrepos(b'hg', b'/opt', [b'/opt/r', b'/opt/r/r', b'/opt']))
75 >>> conv(urlrepos(b'hg', b'/opt', [b'/opt/r', b'/opt/r/r', b'/opt']))
76 [('hg/r', '/opt/r'), ('hg/r/r', '/opt/r/r'), ('hg', '/opt')]
76 [('hg/r', '/opt/r'), ('hg/r/r', '/opt/r/r'), ('hg', '/opt')]
77 >>> conv(urlrepos(b'', b'/opt', [b'/opt/r', b'/opt/r/r', b'/opt']))
77 >>> conv(urlrepos(b'', b'/opt', [b'/opt/r', b'/opt/r/r', b'/opt']))
78 [('r', '/opt/r'), ('r/r', '/opt/r/r'), ('', '/opt')]
78 [('r', '/opt/r'), ('r/r', '/opt/r/r'), ('', '/opt')]
79 """
79 """
80 for path in paths:
80 for path in paths:
81 path = os.path.normpath(path)
81 path = os.path.normpath(path)
82 yield (prefix + '/' +
82 yield (prefix + '/' +
83 util.pconvert(path[len(roothead):]).lstrip('/')).strip('/'), path
83 util.pconvert(path[len(roothead):]).lstrip('/')).strip('/'), path
84
84
85 def geturlcgivars(baseurl, port):
85 def geturlcgivars(baseurl, port):
86 """
86 """
87 Extract CGI variables from baseurl
87 Extract CGI variables from baseurl
88
88
89 >>> geturlcgivars(b"http://host.org/base", b"80")
89 >>> geturlcgivars(b"http://host.org/base", b"80")
90 ('host.org', '80', '/base')
90 ('host.org', '80', '/base')
91 >>> geturlcgivars(b"http://host.org:8000/base", b"80")
91 >>> geturlcgivars(b"http://host.org:8000/base", b"80")
92 ('host.org', '8000', '/base')
92 ('host.org', '8000', '/base')
93 >>> geturlcgivars(b'/base', 8000)
93 >>> geturlcgivars(b'/base', 8000)
94 ('', '8000', '/base')
94 ('', '8000', '/base')
95 >>> geturlcgivars(b"base", b'8000')
95 >>> geturlcgivars(b"base", b'8000')
96 ('', '8000', '/base')
96 ('', '8000', '/base')
97 >>> geturlcgivars(b"http://host", b'8000')
97 >>> geturlcgivars(b"http://host", b'8000')
98 ('host', '8000', '/')
98 ('host', '8000', '/')
99 >>> geturlcgivars(b"http://host/", b'8000')
99 >>> geturlcgivars(b"http://host/", b'8000')
100 ('host', '8000', '/')
100 ('host', '8000', '/')
101 """
101 """
102 u = util.url(baseurl)
102 u = util.url(baseurl)
103 name = u.host or ''
103 name = u.host or ''
104 if u.port:
104 if u.port:
105 port = u.port
105 port = u.port
106 path = u.path or ""
106 path = u.path or ""
107 if not path.startswith('/'):
107 if not path.startswith('/'):
108 path = '/' + path
108 path = '/' + path
109
109
110 return name, pycompat.bytestr(port), path
110 return name, pycompat.bytestr(port), path
111
111
112 class hgwebdir(object):
112 class hgwebdir(object):
113 """HTTP server for multiple repositories.
113 """HTTP server for multiple repositories.
114
114
115 Given a configuration, different repositories will be served depending
115 Given a configuration, different repositories will be served depending
116 on the request path.
116 on the request path.
117
117
118 Instances are typically used as WSGI applications.
118 Instances are typically used as WSGI applications.
119 """
119 """
120 def __init__(self, conf, baseui=None):
120 def __init__(self, conf, baseui=None):
121 self.conf = conf
121 self.conf = conf
122 self.baseui = baseui
122 self.baseui = baseui
123 self.ui = None
123 self.ui = None
124 self.lastrefresh = 0
124 self.lastrefresh = 0
125 self.motd = None
125 self.motd = None
126 self.refresh()
126 self.refresh()
127
127
128 def refresh(self):
128 def refresh(self):
129 if self.ui:
129 if self.ui:
130 refreshinterval = self.ui.configint('web', 'refreshinterval')
130 refreshinterval = self.ui.configint('web', 'refreshinterval')
131 else:
131 else:
132 item = configitems.coreitems['web']['refreshinterval']
132 item = configitems.coreitems['web']['refreshinterval']
133 refreshinterval = item.default
133 refreshinterval = item.default
134
134
135 # refreshinterval <= 0 means to always refresh.
135 # refreshinterval <= 0 means to always refresh.
136 if (refreshinterval > 0 and
136 if (refreshinterval > 0 and
137 self.lastrefresh + refreshinterval > time.time()):
137 self.lastrefresh + refreshinterval > time.time()):
138 return
138 return
139
139
140 if self.baseui:
140 if self.baseui:
141 u = self.baseui.copy()
141 u = self.baseui.copy()
142 else:
142 else:
143 u = uimod.ui.load()
143 u = uimod.ui.load()
144 u.setconfig('ui', 'report_untrusted', 'off', 'hgwebdir')
144 u.setconfig('ui', 'report_untrusted', 'off', 'hgwebdir')
145 u.setconfig('ui', 'nontty', 'true', 'hgwebdir')
145 u.setconfig('ui', 'nontty', 'true', 'hgwebdir')
146 # displaying bundling progress bar while serving feels wrong and may
146 # displaying bundling progress bar while serving feels wrong and may
147 # break some wsgi implementations.
147 # break some wsgi implementations.
148 u.setconfig('progress', 'disable', 'true', 'hgweb')
148 u.setconfig('progress', 'disable', 'true', 'hgweb')
149
149
150 if not isinstance(self.conf, (dict, list, tuple)):
150 if not isinstance(self.conf, (dict, list, tuple)):
151 map = {'paths': 'hgweb-paths'}
151 map = {'paths': 'hgweb-paths'}
152 if not os.path.exists(self.conf):
152 if not os.path.exists(self.conf):
153 raise error.Abort(_('config file %s not found!') % self.conf)
153 raise error.Abort(_('config file %s not found!') % self.conf)
154 u.readconfig(self.conf, remap=map, trust=True)
154 u.readconfig(self.conf, remap=map, trust=True)
155 paths = []
155 paths = []
156 for name, ignored in u.configitems('hgweb-paths'):
156 for name, ignored in u.configitems('hgweb-paths'):
157 for path in u.configlist('hgweb-paths', name):
157 for path in u.configlist('hgweb-paths', name):
158 paths.append((name, path))
158 paths.append((name, path))
159 elif isinstance(self.conf, (list, tuple)):
159 elif isinstance(self.conf, (list, tuple)):
160 paths = self.conf
160 paths = self.conf
161 elif isinstance(self.conf, dict):
161 elif isinstance(self.conf, dict):
162 paths = self.conf.items()
162 paths = self.conf.items()
163
163
164 repos = findrepos(paths)
164 repos = findrepos(paths)
165 for prefix, root in u.configitems('collections'):
165 for prefix, root in u.configitems('collections'):
166 prefix = util.pconvert(prefix)
166 prefix = util.pconvert(prefix)
167 for path in scmutil.walkrepos(root, followsym=True):
167 for path in scmutil.walkrepos(root, followsym=True):
168 repo = os.path.normpath(path)
168 repo = os.path.normpath(path)
169 name = util.pconvert(repo)
169 name = util.pconvert(repo)
170 if name.startswith(prefix):
170 if name.startswith(prefix):
171 name = name[len(prefix):]
171 name = name[len(prefix):]
172 repos.append((name.lstrip('/'), repo))
172 repos.append((name.lstrip('/'), repo))
173
173
174 self.repos = repos
174 self.repos = repos
175 self.ui = u
175 self.ui = u
176 encoding.encoding = self.ui.config('web', 'encoding')
176 encoding.encoding = self.ui.config('web', 'encoding')
177 self.style = self.ui.config('web', 'style')
177 self.style = self.ui.config('web', 'style')
178 self.templatepath = self.ui.config('web', 'templates', untrusted=False)
178 self.templatepath = self.ui.config('web', 'templates', untrusted=False)
179 self.stripecount = self.ui.config('web', 'stripes')
179 self.stripecount = self.ui.config('web', 'stripes')
180 if self.stripecount:
180 if self.stripecount:
181 self.stripecount = int(self.stripecount)
181 self.stripecount = int(self.stripecount)
182 self._baseurl = self.ui.config('web', 'baseurl')
182 self._baseurl = self.ui.config('web', 'baseurl')
183 prefix = self.ui.config('web', 'prefix')
183 prefix = self.ui.config('web', 'prefix')
184 if prefix.startswith('/'):
184 if prefix.startswith('/'):
185 prefix = prefix[1:]
185 prefix = prefix[1:]
186 if prefix.endswith('/'):
186 if prefix.endswith('/'):
187 prefix = prefix[:-1]
187 prefix = prefix[:-1]
188 self.prefix = prefix
188 self.prefix = prefix
189 self.lastrefresh = time.time()
189 self.lastrefresh = time.time()
190
190
191 def run(self):
191 def run(self):
192 if not encoding.environ.get('GATEWAY_INTERFACE',
192 if not encoding.environ.get('GATEWAY_INTERFACE',
193 '').startswith("CGI/1."):
193 '').startswith("CGI/1."):
194 raise RuntimeError("This function is only intended to be "
194 raise RuntimeError("This function is only intended to be "
195 "called while running as a CGI script.")
195 "called while running as a CGI script.")
196 wsgicgi.launch(self)
196 wsgicgi.launch(self)
197
197
198 def __call__(self, env, respond):
198 def __call__(self, env, respond):
199 req = wsgirequest(env, respond)
199 req = wsgirequest(env, respond)
200 return self.run_wsgi(req)
200 return self.run_wsgi(req)
201
201
202 def read_allowed(self, ui, req):
202 def read_allowed(self, ui, req):
203 """Check allow_read and deny_read config options of a repo's ui object
203 """Check allow_read and deny_read config options of a repo's ui object
204 to determine user permissions. By default, with neither option set (or
204 to determine user permissions. By default, with neither option set (or
205 both empty), allow all users to read the repo. There are two ways a
205 both empty), allow all users to read the repo. There are two ways a
206 user can be denied read access: (1) deny_read is not empty, and the
206 user can be denied read access: (1) deny_read is not empty, and the
207 user is unauthenticated or deny_read contains user (or *), and (2)
207 user is unauthenticated or deny_read contains user (or *), and (2)
208 allow_read is not empty and the user is not in allow_read. Return True
208 allow_read is not empty and the user is not in allow_read. Return True
209 if user is allowed to read the repo, else return False."""
209 if user is allowed to read the repo, else return False."""
210
210
211 user = req.env.get('REMOTE_USER')
211 user = req.env.get('REMOTE_USER')
212
212
213 deny_read = ui.configlist('web', 'deny_read', untrusted=True)
213 deny_read = ui.configlist('web', 'deny_read', untrusted=True)
214 if deny_read and (not user or ismember(ui, user, deny_read)):
214 if deny_read and (not user or ismember(ui, user, deny_read)):
215 return False
215 return False
216
216
217 allow_read = ui.configlist('web', 'allow_read', untrusted=True)
217 allow_read = ui.configlist('web', 'allow_read', untrusted=True)
218 # by default, allow reading if no allow_read option has been set
218 # by default, allow reading if no allow_read option has been set
219 if (not allow_read) or ismember(ui, user, allow_read):
219 if (not allow_read) or ismember(ui, user, allow_read):
220 return True
220 return True
221
221
222 return False
222 return False
223
223
224 def run_wsgi(self, req):
224 def run_wsgi(self, req):
225 profile = self.ui.configbool('profiling', 'enabled')
225 profile = self.ui.configbool('profiling', 'enabled')
226 with profiling.profile(self.ui, enabled=profile):
226 with profiling.profile(self.ui, enabled=profile):
227 for r in self._runwsgi(req):
227 for r in self._runwsgi(req):
228 yield r
228 yield r
229
229
230 def _runwsgi(self, req):
230 def _runwsgi(self, req):
231 try:
231 try:
232 self.refresh()
232 self.refresh()
233
233
234 csp, nonce = cspvalues(self.ui)
234 csp, nonce = cspvalues(self.ui)
235 if csp:
235 if csp:
236 req.headers.append(('Content-Security-Policy', csp))
236 req.headers.append(('Content-Security-Policy', csp))
237
237
238 virtual = req.env.get("PATH_INFO", "").strip('/')
238 virtual = req.env.get("PATH_INFO", "").strip('/')
239 tmpl = self.templater(req, nonce)
239 tmpl = self.templater(req, nonce)
240 ctype = tmpl('mimetype', encoding=encoding.encoding)
240 ctype = tmpl('mimetype', encoding=encoding.encoding)
241 ctype = templater.stringify(ctype)
241 ctype = templater.stringify(ctype)
242
242
243 # a static file
243 # a static file
244 if virtual.startswith('static/') or 'static' in req.form:
244 if virtual.startswith('static/') or 'static' in req.form:
245 if virtual.startswith('static/'):
245 if virtual.startswith('static/'):
246 fname = virtual[7:]
246 fname = virtual[7:]
247 else:
247 else:
248 fname = req.form['static'][0]
248 fname = req.form['static'][0]
249 static = self.ui.config("web", "static", None,
249 static = self.ui.config("web", "static", None,
250 untrusted=False)
250 untrusted=False)
251 if not static:
251 if not static:
252 tp = self.templatepath or templater.templatepaths()
252 tp = self.templatepath or templater.templatepaths()
253 if isinstance(tp, str):
253 if isinstance(tp, str):
254 tp = [tp]
254 tp = [tp]
255 static = [os.path.join(p, 'static') for p in tp]
255 static = [os.path.join(p, 'static') for p in tp]
256 staticfile(static, fname, req)
256 staticfile(static, fname, req)
257 return []
257 return []
258
258
259 # top-level index
259 # top-level index
260
260
261 repos = dict(self.repos)
261 repos = dict(self.repos)
262
262
263 if (not virtual or virtual == 'index') and virtual not in repos:
263 if (not virtual or virtual == 'index') and virtual not in repos:
264 req.respond(HTTP_OK, ctype)
264 req.respond(HTTP_OK, ctype)
265 return self.makeindex(req, tmpl)
265 return self.makeindex(req, tmpl)
266
266
267 # nested indexes and hgwebs
267 # nested indexes and hgwebs
268
268
269 if virtual.endswith('/index') and virtual not in repos:
269 if virtual.endswith('/index') and virtual not in repos:
270 subdir = virtual[:-len('index')]
270 subdir = virtual[:-len('index')]
271 if any(r.startswith(subdir) for r in repos):
271 if any(r.startswith(subdir) for r in repos):
272 req.respond(HTTP_OK, ctype)
272 req.respond(HTTP_OK, ctype)
273 return self.makeindex(req, tmpl, subdir)
273 return self.makeindex(req, tmpl, subdir)
274
274
275 def _virtualdirs():
275 def _virtualdirs():
276 # Check the full virtual path, each parent, and the root ('')
276 # Check the full virtual path, each parent, and the root ('')
277 if virtual != '':
277 if virtual != '':
278 yield virtual
278 yield virtual
279
279
280 for p in util.finddirs(virtual):
280 for p in util.finddirs(virtual):
281 yield p
281 yield p
282
282
283 yield ''
283 yield ''
284
284
285 for virtualrepo in _virtualdirs():
285 for virtualrepo in _virtualdirs():
286 real = repos.get(virtualrepo)
286 real = repos.get(virtualrepo)
287 if real:
287 if real:
288 req.env['REPO_NAME'] = virtualrepo
288 req.env['REPO_NAME'] = virtualrepo
289 try:
289 try:
290 # ensure caller gets private copy of ui
290 # ensure caller gets private copy of ui
291 repo = hg.repository(self.ui.copy(), real)
291 repo = hg.repository(self.ui.copy(), real)
292 return hgweb_mod.hgweb(repo).run_wsgi(req)
292 return hgweb_mod.hgweb(repo).run_wsgi(req)
293 except IOError as inst:
293 except IOError as inst:
294 msg = encoding.strtolocal(inst.strerror)
294 msg = encoding.strtolocal(inst.strerror)
295 raise ErrorResponse(HTTP_SERVER_ERROR, msg)
295 raise ErrorResponse(HTTP_SERVER_ERROR, msg)
296 except error.RepoError as inst:
296 except error.RepoError as inst:
297 raise ErrorResponse(HTTP_SERVER_ERROR, bytes(inst))
297 raise ErrorResponse(HTTP_SERVER_ERROR, bytes(inst))
298
298
299 # browse subdirectories
299 # browse subdirectories
300 subdir = virtual + '/'
300 subdir = virtual + '/'
301 if [r for r in repos if r.startswith(subdir)]:
301 if [r for r in repos if r.startswith(subdir)]:
302 req.respond(HTTP_OK, ctype)
302 req.respond(HTTP_OK, ctype)
303 return self.makeindex(req, tmpl, subdir)
303 return self.makeindex(req, tmpl, subdir)
304
304
305 # prefixes not found
305 # prefixes not found
306 req.respond(HTTP_NOT_FOUND, ctype)
306 req.respond(HTTP_NOT_FOUND, ctype)
307 return tmpl("notfound", repo=virtual)
307 return tmpl("notfound", repo=virtual)
308
308
309 except ErrorResponse as err:
309 except ErrorResponse as err:
310 req.respond(err, ctype)
310 req.respond(err, ctype)
311 return tmpl('error', error=err.message or '')
311 return tmpl('error', error=err.message or '')
312 finally:
312 finally:
313 tmpl = None
313 tmpl = None
314
314
315 def makeindex(self, req, tmpl, subdir=""):
315 def makeindex(self, req, tmpl, subdir=""):
316
316
317 def archivelist(ui, nodeid, url):
317 def archivelist(ui, nodeid, url):
318 allowed = ui.configlist("web", "allow_archive", untrusted=True)
318 allowed = ui.configlist("web", "allow_archive", untrusted=True)
319 archives = []
319 archives = []
320 for typ, spec in hgweb_mod.archivespecs.iteritems():
320 for typ, spec in hgweb_mod.archivespecs.iteritems():
321 if typ in allowed or ui.configbool("web", "allow" + typ,
321 if typ in allowed or ui.configbool("web", "allow" + typ,
322 untrusted=True):
322 untrusted=True):
323 archives.append({"type": typ, "extension": spec[2],
323 archives.append({"type": typ, "extension": spec[2],
324 "node": nodeid, "url": url})
324 "node": nodeid, "url": url})
325 return archives
325 return archives
326
326
327 def rawentries(subdir="", **map):
327 def rawentries(subdir="", **map):
328
328
329 descend = self.ui.configbool('web', 'descend')
329 descend = self.ui.configbool('web', 'descend')
330 collapse = self.ui.configbool('web', 'collapse')
330 collapse = self.ui.configbool('web', 'collapse')
331 seenrepos = set()
331 seenrepos = set()
332 seendirs = set()
332 seendirs = set()
333 for name, path in self.repos:
333 for name, path in self.repos:
334
334
335 if not name.startswith(subdir):
335 if not name.startswith(subdir):
336 continue
336 continue
337 name = name[len(subdir):]
337 name = name[len(subdir):]
338 directory = False
338 directory = False
339
339
340 if '/' in name:
340 if '/' in name:
341 if not descend:
341 if not descend:
342 continue
342 continue
343
343
344 nameparts = name.split('/')
344 nameparts = name.split('/')
345 rootname = nameparts[0]
345 rootname = nameparts[0]
346
346
347 if not collapse:
347 if not collapse:
348 pass
348 pass
349 elif rootname in seendirs:
349 elif rootname in seendirs:
350 continue
350 continue
351 elif rootname in seenrepos:
351 elif rootname in seenrepos:
352 pass
352 pass
353 else:
353 else:
354 directory = True
354 directory = True
355 name = rootname
355 name = rootname
356
356
357 # redefine the path to refer to the directory
357 # redefine the path to refer to the directory
358 discarded = '/'.join(nameparts[1:])
358 discarded = '/'.join(nameparts[1:])
359
359
360 # remove name parts plus accompanying slash
360 # remove name parts plus accompanying slash
361 path = path[:-len(discarded) - 1]
361 path = path[:-len(discarded) - 1]
362
362
363 try:
363 try:
364 r = hg.repository(self.ui, path)
364 r = hg.repository(self.ui, path)
365 directory = False
365 directory = False
366 except (IOError, error.RepoError):
366 except (IOError, error.RepoError):
367 pass
367 pass
368
368
369 parts = [name]
369 parts = [name]
370 parts.insert(0, '/' + subdir.rstrip('/'))
370 parts.insert(0, '/' + subdir.rstrip('/'))
371 if req.env['SCRIPT_NAME']:
371 if req.env['SCRIPT_NAME']:
372 parts.insert(0, req.env['SCRIPT_NAME'])
372 parts.insert(0, req.env['SCRIPT_NAME'])
373 url = re.sub(r'/+', '/', '/'.join(parts) + '/')
373 url = re.sub(r'/+', '/', '/'.join(parts) + '/')
374
374
375 # show either a directory entry or a repository
375 # show either a directory entry or a repository
376 if directory:
376 if directory:
377 # get the directory's time information
377 # get the directory's time information
378 try:
378 try:
379 d = (get_mtime(path), util.makedate()[1])
379 d = (get_mtime(path), util.makedate()[1])
380 except OSError:
380 except OSError:
381 continue
381 continue
382
382
383 # add '/' to the name to make it obvious that
383 # add '/' to the name to make it obvious that
384 # the entry is a directory, not a regular repository
384 # the entry is a directory, not a regular repository
385 row = {'contact': "",
385 row = {'contact': "",
386 'contact_sort': "",
386 'contact_sort': "",
387 'name': name + '/',
387 'name': name + '/',
388 'name_sort': name,
388 'name_sort': name,
389 'url': url,
389 'url': url,
390 'description': "",
390 'description': "",
391 'description_sort': "",
391 'description_sort': "",
392 'lastchange': d,
392 'lastchange': d,
393 'lastchange_sort': d[1]-d[0],
393 'lastchange_sort': d[1]-d[0],
394 'archives': [],
394 'archives': [],
395 'isdirectory': True,
395 'isdirectory': True,
396 'labels': [],
396 'labels': [],
397 }
397 }
398
398
399 seendirs.add(name)
399 seendirs.add(name)
400 yield row
400 yield row
401 continue
401 continue
402
402
403 u = self.ui.copy()
403 u = self.ui.copy()
404 try:
404 try:
405 u.readconfig(os.path.join(path, '.hg', 'hgrc'))
405 u.readconfig(os.path.join(path, '.hg', 'hgrc'))
406 except Exception as e:
406 except Exception as e:
407 u.warn(_('error reading %s/.hg/hgrc: %s\n') % (path, e))
407 u.warn(_('error reading %s/.hg/hgrc: %s\n') % (path, e))
408 continue
408 continue
409 def get(section, name, default=uimod._unset):
409 def get(section, name, default=uimod._unset):
410 return u.config(section, name, default, untrusted=True)
410 return u.config(section, name, default, untrusted=True)
411
411
412 if u.configbool("web", "hidden", untrusted=True):
412 if u.configbool("web", "hidden", untrusted=True):
413 continue
413 continue
414
414
415 if not self.read_allowed(u, req):
415 if not self.read_allowed(u, req):
416 continue
416 continue
417
417
418 # update time with local timezone
418 # update time with local timezone
419 try:
419 try:
420 r = hg.repository(self.ui, path)
420 r = hg.repository(self.ui, path)
421 except IOError:
421 except IOError:
422 u.warn(_('error accessing repository at %s\n') % path)
422 u.warn(_('error accessing repository at %s\n') % path)
423 continue
423 continue
424 except error.RepoError:
424 except error.RepoError:
425 u.warn(_('error accessing repository at %s\n') % path)
425 u.warn(_('error accessing repository at %s\n') % path)
426 continue
426 continue
427 try:
427 try:
428 d = (get_mtime(r.spath), util.makedate()[1])
428 d = (get_mtime(r.spath), util.makedate()[1])
429 except OSError:
429 except OSError:
430 continue
430 continue
431
431
432 contact = get_contact(get)
432 contact = get_contact(get)
433 description = get("web", "description")
433 description = get("web", "description")
434 seenrepos.add(name)
434 seenrepos.add(name)
435 name = get("web", "name", name)
435 name = get("web", "name", name)
436 row = {'contact': contact or "unknown",
436 row = {'contact': contact or "unknown",
437 'contact_sort': contact.upper() or "unknown",
437 'contact_sort': contact.upper() or "unknown",
438 'name': name,
438 'name': name,
439 'name_sort': name,
439 'name_sort': name,
440 'url': url,
440 'url': url,
441 'description': description or "unknown",
441 'description': description or "unknown",
442 'description_sort': description.upper() or "unknown",
442 'description_sort': description.upper() or "unknown",
443 'lastchange': d,
443 'lastchange': d,
444 'lastchange_sort': d[1]-d[0],
444 'lastchange_sort': d[1]-d[0],
445 'archives': archivelist(u, "tip", url),
445 'archives': archivelist(u, "tip", url),
446 'isdirectory': None,
446 'isdirectory': None,
447 'labels': u.configlist('web', 'labels', untrusted=True),
447 'labels': u.configlist('web', 'labels', untrusted=True),
448 }
448 }
449
449
450 yield row
450 yield row
451
451
452 sortdefault = None, False
452 sortdefault = None, False
453 def entries(sortcolumn="", descending=False, subdir="", **map):
453 def entries(sortcolumn="", descending=False, subdir="", **map):
454 rows = rawentries(subdir=subdir, **map)
454 rows = rawentries(subdir=subdir, **map)
455
455
456 if sortcolumn and sortdefault != (sortcolumn, descending):
456 if sortcolumn and sortdefault != (sortcolumn, descending):
457 sortkey = '%s_sort' % sortcolumn
457 sortkey = '%s_sort' % sortcolumn
458 rows = sorted(rows, key=lambda x: x[sortkey],
458 rows = sorted(rows, key=lambda x: x[sortkey],
459 reverse=descending)
459 reverse=descending)
460 for row, parity in zip(rows, paritygen(self.stripecount)):
460 for row, parity in zip(rows, paritygen(self.stripecount)):
461 row['parity'] = parity
461 row['parity'] = parity
462 yield row
462 yield row
463
463
464 self.refresh()
464 self.refresh()
465 sortable = ["name", "description", "contact", "lastchange"]
465 sortable = ["name", "description", "contact", "lastchange"]
466 sortcolumn, descending = sortdefault
466 sortcolumn, descending = sortdefault
467 if 'sort' in req.form:
467 if 'sort' in req.form:
468 sortcolumn = req.form['sort'][0]
468 sortcolumn = req.form['sort'][0]
469 descending = sortcolumn.startswith('-')
469 descending = sortcolumn.startswith('-')
470 if descending:
470 if descending:
471 sortcolumn = sortcolumn[1:]
471 sortcolumn = sortcolumn[1:]
472 if sortcolumn not in sortable:
472 if sortcolumn not in sortable:
473 sortcolumn = ""
473 sortcolumn = ""
474
474
475 sort = [("sort_%s" % column,
475 sort = [("sort_%s" % column,
476 "%s%s" % ((not descending and column == sortcolumn)
476 "%s%s" % ((not descending and column == sortcolumn)
477 and "-" or "", column))
477 and "-" or "", column))
478 for column in sortable]
478 for column in sortable]
479
479
480 self.refresh()
480 self.refresh()
481 self.updatereqenv(req.env)
481 self.updatereqenv(req.env)
482
482
483 return tmpl("index", entries=entries, subdir=subdir,
483 return tmpl("index", entries=entries, subdir=subdir,
484 pathdef=hgweb_mod.makebreadcrumb('/' + subdir, self.prefix),
484 pathdef=hgweb_mod.makebreadcrumb('/' + subdir, self.prefix),
485 sortcolumn=sortcolumn, descending=descending,
485 sortcolumn=sortcolumn, descending=descending,
486 **dict(sort))
486 **dict(sort))
487
487
488 def templater(self, req, nonce):
488 def templater(self, req, nonce):
489
489
490 def motd(**map):
490 def motd(**map):
491 if self.motd is not None:
491 if self.motd is not None:
492 yield self.motd
492 yield self.motd
493 else:
493 else:
494 yield config('web', 'motd')
494 yield config('web', 'motd')
495
495
496 def config(section, name, default=uimod._unset, untrusted=True):
496 def config(section, name, default=uimod._unset, untrusted=True):
497 return self.ui.config(section, name, default, untrusted)
497 return self.ui.config(section, name, default, untrusted)
498
498
499 self.updatereqenv(req.env)
499 self.updatereqenv(req.env)
500
500
501 url = req.env.get('SCRIPT_NAME', '')
501 url = req.env.get('SCRIPT_NAME', '')
502 if not url.endswith('/'):
502 if not url.endswith('/'):
503 url += '/'
503 url += '/'
504
504
505 vars = {}
505 vars = {}
506 styles, (style, mapfile) = hgweb_mod.getstyle(req, config,
506 styles, (style, mapfile) = hgweb_mod.getstyle(req, config,
507 self.templatepath)
507 self.templatepath)
508 if style == styles[0]:
508 if style == styles[0]:
509 vars['style'] = style
509 vars['style'] = style
510
510
511 start = url[-1] == '?' and '&' or '?'
511 start = url[-1] == '?' and '&' or '?'
512 sessionvars = webutil.sessionvars(vars, start)
512 sessionvars = webutil.sessionvars(vars, start)
513 logourl = config('web', 'logourl', 'https://mercurial-scm.org/')
513 logourl = config('web', 'logourl', 'https://mercurial-scm.org/')
514 logoimg = config('web', 'logoimg', 'hglogo.png')
514 logoimg = config('web', 'logoimg')
515 staticurl = config('web', 'staticurl') or url + 'static/'
515 staticurl = config('web', 'staticurl') or url + 'static/'
516 if not staticurl.endswith('/'):
516 if not staticurl.endswith('/'):
517 staticurl += '/'
517 staticurl += '/'
518
518
519 defaults = {
519 defaults = {
520 "encoding": encoding.encoding,
520 "encoding": encoding.encoding,
521 "motd": motd,
521 "motd": motd,
522 "url": url,
522 "url": url,
523 "logourl": logourl,
523 "logourl": logourl,
524 "logoimg": logoimg,
524 "logoimg": logoimg,
525 "staticurl": staticurl,
525 "staticurl": staticurl,
526 "sessionvars": sessionvars,
526 "sessionvars": sessionvars,
527 "style": style,
527 "style": style,
528 "nonce": nonce,
528 "nonce": nonce,
529 }
529 }
530 tmpl = templater.templater.frommapfile(mapfile, defaults=defaults)
530 tmpl = templater.templater.frommapfile(mapfile, defaults=defaults)
531 return tmpl
531 return tmpl
532
532
533 def updatereqenv(self, env):
533 def updatereqenv(self, env):
534 if self._baseurl is not None:
534 if self._baseurl is not None:
535 name, port, path = geturlcgivars(self._baseurl, env['SERVER_PORT'])
535 name, port, path = geturlcgivars(self._baseurl, env['SERVER_PORT'])
536 env['SERVER_NAME'] = name
536 env['SERVER_NAME'] = name
537 env['SERVER_PORT'] = port
537 env['SERVER_PORT'] = port
538 env['SCRIPT_NAME'] = path
538 env['SCRIPT_NAME'] = path
General Comments 0
You need to be logged in to leave comments. Login now