1
by mbp at sourcefrog
import from baz patch-364 |
1 |
# Bazaar-NG -- distributed version control
|
2 |
||
3 |
# Copyright (C) 2005 by Canonical Ltd
|
|
4 |
||
5 |
# This program is free software; you can redistribute it and/or modify
|
|
6 |
# it under the terms of the GNU General Public License as published by
|
|
7 |
# the Free Software Foundation; either version 2 of the License, or
|
|
8 |
# (at your option) any later version.
|
|
9 |
||
10 |
# This program is distributed in the hope that it will be useful,
|
|
11 |
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
12 |
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
13 |
# GNU General Public License for more details.
|
|
14 |
||
15 |
# You should have received a copy of the GNU General Public License
|
|
16 |
# along with this program; if not, write to the Free Software
|
|
17 |
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
18 |
||
19 |
import os, types, re, time, types |
|
20
by mbp at sourcefrog
don't abort on trees that happen to contain symlinks |
20 |
from stat import S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE |
1
by mbp at sourcefrog
import from baz patch-364 |
21 |
|
22 |
from errors import bailout |
|
23 |
||
24 |
def make_readonly(filename): |
|
25 |
"""Make a filename read-only."""
|
|
26 |
# TODO: probably needs to be fixed for windows
|
|
27 |
mod = os.stat(filename).st_mode |
|
28 |
mod = mod & 0777555 |
|
29 |
os.chmod(filename, mod) |
|
30 |
||
31 |
||
32 |
def make_writable(filename): |
|
33 |
mod = os.stat(filename).st_mode |
|
34 |
mod = mod | 0200 |
|
35 |
os.chmod(filename, mod) |
|
36 |
||
37 |
||
38 |
_QUOTE_RE = re.compile(r'([^a-zA-Z0-9.,:/_~-])') |
|
39 |
def quotefn(f): |
|
40 |
"""Return shell-quoted filename"""
|
|
41 |
## We could be a bit more terse by using double-quotes etc
|
|
42 |
f = _QUOTE_RE.sub(r'\\\1', f) |
|
43 |
if f[0] == '~': |
|
44 |
f[0:1] = r'\~' |
|
45 |
return f |
|
46 |
||
47 |
||
48 |
def file_kind(f): |
|
49 |
mode = os.lstat(f)[ST_MODE] |
|
50 |
if S_ISREG(mode): |
|
51 |
return 'file' |
|
52 |
elif S_ISDIR(mode): |
|
53 |
return 'directory' |
|
20
by mbp at sourcefrog
don't abort on trees that happen to contain symlinks |
54 |
elif S_ISLNK(mode): |
55 |
return 'symlink' |
|
1
by mbp at sourcefrog
import from baz patch-364 |
56 |
else: |
20
by mbp at sourcefrog
don't abort on trees that happen to contain symlinks |
57 |
bailout("can't handle file kind with mode %o of %r" % (mode, f)) |
1
by mbp at sourcefrog
import from baz patch-364 |
58 |
|
59 |
||
60 |
||
61 |
def isdir(f): |
|
62 |
"""True if f is an accessible directory."""
|
|
63 |
try: |
|
64 |
return S_ISDIR(os.lstat(f)[ST_MODE]) |
|
65 |
except OSError: |
|
66 |
return False |
|
67 |
||
68 |
||
69 |
||
70 |
def isfile(f): |
|
71 |
"""True if f is a regular file."""
|
|
72 |
try: |
|
73 |
return S_ISREG(os.lstat(f)[ST_MODE]) |
|
74 |
except OSError: |
|
75 |
return False |
|
76 |
||
77 |
||
78 |
def pumpfile(fromfile, tofile): |
|
79 |
"""Copy contents of one file to another."""
|
|
80 |
tofile.write(fromfile.read()) |
|
81 |
||
82 |
||
83 |
def uuid(): |
|
84 |
"""Return a new UUID"""
|
|
85 |
||
86 |
## XXX: Could alternatively read /proc/sys/kernel/random/uuid on
|
|
87 |
## Linux, but we need something portable for other systems;
|
|
88 |
## preferably an implementation in Python.
|
|
63
by mbp at sourcefrog
fix up uuid command |
89 |
try: |
90 |
return chomp(file('/proc/sys/kernel/random/uuid').readline()) |
|
91 |
except IOError: |
|
92 |
return chomp(os.popen('uuidgen').readline()) |
|
93 |
||
1
by mbp at sourcefrog
import from baz patch-364 |
94 |
|
95 |
def chomp(s): |
|
96 |
if s and (s[-1] == '\n'): |
|
97 |
return s[:-1] |
|
98 |
else: |
|
99 |
return s |
|
100 |
||
101 |
||
102 |
def sha_file(f): |
|
103 |
import sha |
|
104 |
## TODO: Maybe read in chunks to handle big files
|
|
105 |
if hasattr(f, 'tell'): |
|
106 |
assert f.tell() == 0 |
|
107 |
s = sha.new() |
|
108 |
s.update(f.read()) |
|
109 |
return s.hexdigest() |
|
110 |
||
111 |
||
112 |
def sha_string(f): |
|
113 |
import sha |
|
114 |
s = sha.new() |
|
115 |
s.update(f) |
|
116 |
return s.hexdigest() |
|
117 |
||
118 |
||
119 |
||
124
by mbp at sourcefrog
- check file text for past revisions is correct |
120 |
def fingerprint_file(f): |
121 |
import sha |
|
122 |
s = sha.new() |
|
123 |
size = 0 |
|
124 |
BUFSIZE = 64<<10 |
|
125 |
while True: |
|
126 |
b = f.read(BUFSIZE) |
|
127 |
if b == '': |
|
128 |
break
|
|
129 |
s.update(b) |
|
130 |
size += len(b) |
|
131 |
return {'size': size, |
|
132 |
'sha1': s.hexdigest()} |
|
133 |
||
134 |
||
135 |
||
1
by mbp at sourcefrog
import from baz patch-364 |
136 |
def username(): |
137 |
"""Return email-style username.
|
|
138 |
||
139 |
Something similar to 'Martin Pool <mbp@sourcefrog.net>'
|
|
140 |
||
141 |
:todo: Check it's reasonably well-formed.
|
|
142 |
||
143 |
:todo: Allow taking it from a dotfile to help people on windows
|
|
144 |
who can't easily set variables.
|
|
145 |
||
146 |
:todo: Cope without pwd module, which is only on unix.
|
|
147 |
"""
|
|
148 |
e = os.environ.get('BZREMAIL') or os.environ.get('EMAIL') |
|
149 |
if e: return e |
|
150 |
||
151 |
import socket |
|
152 |
||
153 |
try: |
|
154 |
import pwd |
|
155 |
uid = os.getuid() |
|
156 |
w = pwd.getpwuid(uid) |
|
25
by Martin Pool
cope when gecos field doesn't have a comma |
157 |
gecos = w.pw_gecos |
158 |
comma = gecos.find(',') |
|
159 |
if comma == -1: |
|
160 |
realname = gecos |
|
161 |
else: |
|
162 |
realname = gecos[:comma] |
|
1
by mbp at sourcefrog
import from baz patch-364 |
163 |
return '%s <%s@%s>' % (realname, w.pw_name, socket.getfqdn()) |
164 |
except ImportError: |
|
165 |
pass
|
|
166 |
||
167 |
import getpass, socket |
|
168 |
return '<%s@%s>' % (getpass.getuser(), socket.getfqdn()) |
|
169 |
||
170 |
||
171 |
def user_email(): |
|
172 |
"""Return just the email component of a username."""
|
|
173 |
e = os.environ.get('BZREMAIL') or os.environ.get('EMAIL') |
|
174 |
if e: |
|
175 |
import re |
|
176 |
m = re.search(r'[\w+.-]+@[\w+.-]+', e) |
|
177 |
if not m: |
|
178 |
bailout('%r is not a reasonable email address' % e) |
|
179 |
return m.group(0) |
|
180 |
||
181 |
||
182 |
import getpass, socket |
|
183 |
return '%s@%s' % (getpass.getuser(), socket.getfqdn()) |
|
184 |
||
185 |
||
186 |
||
187 |
||
188 |
def compare_files(a, b): |
|
189 |
"""Returns true if equal in contents"""
|
|
190 |
# TODO: don't read the whole thing in one go.
|
|
74
by mbp at sourcefrog
compare_files: read in one page at a time rather than |
191 |
BUFSIZE = 4096 |
192 |
while True: |
|
193 |
ai = a.read(BUFSIZE) |
|
194 |
bi = b.read(BUFSIZE) |
|
195 |
if ai != bi: |
|
196 |
return False |
|
197 |
if ai == '': |
|
198 |
return True |
|
1
by mbp at sourcefrog
import from baz patch-364 |
199 |
|
200 |
||
201 |
||
49
by mbp at sourcefrog
fix local-time-offset calculation |
202 |
def local_time_offset(t=None): |
203 |
"""Return offset of local zone from GMT, either at present or at time t."""
|
|
73
by mbp at sourcefrog
fix time.localtime call for python 2.3 |
204 |
# python2.3 localtime() can't take None
|
205 |
if t is None: |
|
206 |
t = time.time() |
|
207 |
||
49
by mbp at sourcefrog
fix local-time-offset calculation |
208 |
if time.localtime(t).tm_isdst and time.daylight: |
8
by mbp at sourcefrog
store committer's timezone in revision and show |
209 |
return -time.altzone |
210 |
else: |
|
211 |
return -time.timezone |
|
212 |
||
213 |
||
214 |
def format_date(t, offset=0, timezone='original'): |
|
1
by mbp at sourcefrog
import from baz patch-364 |
215 |
## TODO: Perhaps a global option to use either universal or local time?
|
216 |
## Or perhaps just let people set $TZ?
|
|
217 |
import time |
|
218 |
||
219 |
assert isinstance(t, float) |
|
220 |
||
8
by mbp at sourcefrog
store committer's timezone in revision and show |
221 |
if timezone == 'utc': |
1
by mbp at sourcefrog
import from baz patch-364 |
222 |
tt = time.gmtime(t) |
223 |
offset = 0 |
|
8
by mbp at sourcefrog
store committer's timezone in revision and show |
224 |
elif timezone == 'original': |
23
by mbp at sourcefrog
format_date: handle revisions with no timezone offset |
225 |
if offset == None: |
226 |
offset = 0 |
|
16
by mbp at sourcefrog
fix inverted calculation for original timezone -> utc |
227 |
tt = time.gmtime(t + offset) |
12
by mbp at sourcefrog
new --timezone option for bzr log |
228 |
elif timezone == 'local': |
1
by mbp at sourcefrog
import from baz patch-364 |
229 |
tt = time.localtime(t) |
49
by mbp at sourcefrog
fix local-time-offset calculation |
230 |
offset = local_time_offset(t) |
12
by mbp at sourcefrog
new --timezone option for bzr log |
231 |
else: |
232 |
bailout("unsupported timezone format %r", |
|
233 |
['options are "utc", "original", "local"']) |
|
8
by mbp at sourcefrog
store committer's timezone in revision and show |
234 |
|
1
by mbp at sourcefrog
import from baz patch-364 |
235 |
return (time.strftime("%a %Y-%m-%d %H:%M:%S", tt) |
8
by mbp at sourcefrog
store committer's timezone in revision and show |
236 |
+ ' %+03d%02d' % (offset / 3600, (offset / 60) % 60)) |
1
by mbp at sourcefrog
import from baz patch-364 |
237 |
|
238 |
||
239 |
def compact_date(when): |
|
240 |
return time.strftime('%Y%m%d%H%M%S', time.gmtime(when)) |
|
241 |
||
242 |
||
243 |
||
244 |
def filesize(f): |
|
245 |
"""Return size of given open file."""
|
|
246 |
return os.fstat(f.fileno())[ST_SIZE] |
|
247 |
||
248 |
||
249 |
if hasattr(os, 'urandom'): # python 2.4 and later |
|
250 |
rand_bytes = os.urandom |
|
251 |
else: |
|
252 |
# FIXME: No good on non-Linux
|
|
253 |
_rand_file = file('/dev/urandom', 'rb') |
|
254 |
rand_bytes = _rand_file.read |
|
255 |
||
256 |
||
257 |
## TODO: We could later have path objects that remember their list
|
|
258 |
## decomposition (might be too tricksy though.)
|
|
259 |
||
260 |
def splitpath(p): |
|
261 |
"""Turn string into list of parts.
|
|
262 |
||
263 |
>>> splitpath('a')
|
|
264 |
['a']
|
|
265 |
>>> splitpath('a/b')
|
|
266 |
['a', 'b']
|
|
267 |
>>> splitpath('a/./b')
|
|
268 |
['a', 'b']
|
|
269 |
>>> splitpath('a/.b')
|
|
270 |
['a', '.b']
|
|
271 |
>>> splitpath('a/../b')
|
|
272 |
Traceback (most recent call last):
|
|
273 |
...
|
|
274 |
BzrError: ("sorry, '..' not allowed in path", [])
|
|
275 |
"""
|
|
276 |
assert isinstance(p, types.StringTypes) |
|
277 |
ps = [f for f in p.split('/') if f != '.'] |
|
278 |
for f in ps: |
|
279 |
if f == '..': |
|
280 |
bailout("sorry, %r not allowed in path" % f) |
|
281 |
return ps |
|
282 |
||
283 |
def joinpath(p): |
|
284 |
assert isinstance(p, list) |
|
285 |
for f in p: |
|
286 |
if (f == '..') or (f is None) or (f == ''): |
|
287 |
bailout("sorry, %r not allowed in path" % f) |
|
288 |
return '/'.join(p) |
|
289 |
||
290 |
||
291 |
def appendpath(p1, p2): |
|
292 |
if p1 == '': |
|
293 |
return p2 |
|
294 |
else: |
|
295 |
return p1 + '/' + p2 |
|
296 |
||
297 |
||
298 |
def extern_command(cmd, ignore_errors = False): |
|
299 |
mutter('external command: %s' % `cmd`) |
|
300 |
if os.system(cmd): |
|
301 |
if not ignore_errors: |
|
302 |
bailout('command failed') |
|
303 |