~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/osutils.py

  • Committer: Martin Pool
  • Date: 2005-09-05 05:35:25 UTC
  • mfrom: (974.1.55)
  • Revision ID: mbp@sourcefrog.net-20050905053525-2112bac069dbe331
- merge various bug fixes from aaron

aaron.bentley@utoronto.ca-20050905020131-a2d5b7711dd6cd98

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
# Bazaar-NG -- distributed version control
2
 
#
 
2
 
3
3
# Copyright (C) 2005 by Canonical Ltd
4
 
#
 
4
 
5
5
# This program is free software; you can redistribute it and/or modify
6
6
# it under the terms of the GNU General Public License as published by
7
7
# the Free Software Foundation; either version 2 of the License, or
8
8
# (at your option) any later version.
9
 
#
 
9
 
10
10
# This program is distributed in the hope that it will be useful,
11
11
# but WITHOUT ANY WARRANTY; without even the implied warranty of
12
12
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13
13
# GNU General Public License for more details.
14
 
#
 
14
 
15
15
# You should have received a copy of the GNU General Public License
16
16
# along with this program; if not, write to the Free Software
17
17
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
18
18
 
19
 
from shutil import copyfile
20
 
from stat import (S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE,
21
 
                  S_ISCHR, S_ISBLK, S_ISFIFO, S_ISSOCK)
22
 
from cStringIO import StringIO
23
 
import errno
24
 
import os
25
 
import re
26
 
import sha
27
 
import string
28
 
import sys
29
 
import time
30
 
import types
 
19
import os, types, re, time, errno, sys
 
20
from stat import S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE
31
21
 
32
 
import bzrlib
33
22
from bzrlib.errors import BzrError
34
23
from bzrlib.trace import mutter
35
 
 
 
24
import bzrlib
36
25
 
37
26
def make_readonly(filename):
38
27
    """Make a filename read-only."""
 
28
    # TODO: probably needs to be fixed for windows
39
29
    mod = os.stat(filename).st_mode
40
30
    mod = mod & 0777555
41
31
    os.chmod(filename, mod)
58
48
    # TODO: I'm not really sure this is the best format either.x
59
49
    global _QUOTE_RE
60
50
    if _QUOTE_RE == None:
61
 
        _QUOTE_RE = re.compile(r'([^a-zA-Z0-9.,:/\\_~-])')
 
51
        _QUOTE_RE = re.compile(r'([^a-zA-Z0-9.,:/_~-])')
62
52
        
63
53
    if _QUOTE_RE.search(f):
64
54
        return '"' + f + '"'
74
64
        return 'directory'
75
65
    elif S_ISLNK(mode):
76
66
        return 'symlink'
77
 
    elif S_ISCHR(mode):
78
 
        return 'chardev'
79
 
    elif S_ISBLK(mode):
80
 
        return 'block'
81
 
    elif S_ISFIFO(mode):
82
 
        return 'fifo'
83
 
    elif S_ISSOCK(mode):
84
 
        return 'socket'
85
67
    else:
86
 
        return 'unknown'
 
68
        raise BzrError("can't handle file kind with mode %o of %r" % (mode, f))
87
69
 
88
70
 
89
71
def kind_marker(kind):
96
78
    else:
97
79
        raise BzrError('invalid file kind %r' % kind)
98
80
 
99
 
def lexists(f):
100
 
    try:
101
 
        if hasattr(os, 'lstat'):
102
 
            os.lstat(f)
103
 
        else:
104
 
            os.stat(f)
105
 
        return True
106
 
    except OSError,e:
107
 
        if e.errno == errno.ENOENT:
108
 
            return False;
109
 
        else:
110
 
            raise BzrError("lstat/stat of (%r): %r" % (f, e))
111
81
 
112
 
def normalizepath(f):
113
 
    if hasattr(os.path, 'realpath'):
114
 
        F = os.path.realpath
115
 
    else:
116
 
        F = os.path.abspath
117
 
    [p,e] = os.path.split(f)
118
 
    if e == "" or e == "." or e == "..":
119
 
        return F(f)
120
 
    else:
121
 
        return os.path.join(F(p), e)
122
 
    
123
82
 
124
83
def backup_file(fn):
125
84
    """Copy a file to a backup.
128
87
 
129
88
    If the file is already a backup, it's not copied.
130
89
    """
 
90
    import os
131
91
    if fn[-1] == '~':
132
92
        return
133
93
    bfn = fn + '~'
134
94
 
135
 
    if has_symlinks() and os.path.islink(fn):
136
 
        target = os.readlink(fn)
137
 
        os.symlink(target, bfn)
138
 
        return
139
95
    inf = file(fn, 'rb')
140
96
    try:
141
97
        content = inf.read()
148
104
    finally:
149
105
        outf.close()
150
106
 
151
 
if os.name == 'nt':
152
 
    import shutil
153
 
    rename = shutil.move
154
 
else:
155
 
    rename = os.rename
 
107
def rename(path_from, path_to):
 
108
    """Basically the same as os.rename() just special for win32"""
 
109
    if sys.platform == 'win32':
 
110
        try:
 
111
            os.remove(path_to)
 
112
        except OSError, e:
 
113
            if e.errno != e.ENOENT:
 
114
                raise
 
115
    os.rename(path_from, path_to)
 
116
 
 
117
 
 
118
 
156
119
 
157
120
 
158
121
def isdir(f):
163
126
        return False
164
127
 
165
128
 
 
129
 
166
130
def isfile(f):
167
131
    """True if f is a regular file."""
168
132
    try:
170
134
    except OSError:
171
135
        return False
172
136
 
173
 
def islink(f):
174
 
    """True if f is a symlink."""
175
 
    try:
176
 
        return S_ISLNK(os.lstat(f)[ST_MODE])
177
 
    except OSError:
178
 
        return False
179
137
 
180
138
def is_inside(dir, fname):
181
139
    """True if fname is inside dir.
187
145
    The empty string as a dir name is taken as top-of-tree and matches 
188
146
    everything.
189
147
    
190
 
    >>> is_inside('src', os.path.join('src', 'foo.c'))
 
148
    >>> is_inside('src', 'src/foo.c')
191
149
    True
192
150
    >>> is_inside('src', 'srccontrol')
193
151
    False
194
 
    >>> is_inside('src', os.path.join('src', 'a', 'a', 'a', 'foo.c'))
 
152
    >>> is_inside('src', 'src/a/a/a/foo.c')
195
153
    True
196
154
    >>> is_inside('foo.c', 'foo.c')
197
155
    True
207
165
    
208
166
    if dir == '':
209
167
        return True
210
 
 
 
168
    
211
169
    if dir[-1] != os.sep:
212
170
        dir += os.sep
213
 
 
 
171
    
214
172
    return fname.startswith(dir)
215
173
 
216
174
 
228
186
    tofile.write(fromfile.read())
229
187
 
230
188
 
 
189
def uuid():
 
190
    """Return a new UUID"""
 
191
    try:
 
192
        return file('/proc/sys/kernel/random/uuid').readline().rstrip('\n')
 
193
    except IOError:
 
194
        return chomp(os.popen('uuidgen').readline())
 
195
 
 
196
 
231
197
def sha_file(f):
 
198
    import sha
232
199
    if hasattr(f, 'tell'):
233
200
        assert f.tell() == 0
234
201
    s = sha.new()
241
208
    return s.hexdigest()
242
209
 
243
210
 
244
 
 
245
 
def sha_strings(strings):
246
 
    """Return the sha-1 of concatenation of strings"""
247
 
    s = sha.new()
248
 
    map(s.update, strings)
249
 
    return s.hexdigest()
250
 
 
251
 
 
252
211
def sha_string(f):
 
212
    import sha
253
213
    s = sha.new()
254
214
    s.update(f)
255
215
    return s.hexdigest()
256
216
 
257
217
 
 
218
 
258
219
def fingerprint_file(f):
 
220
    import sha
259
221
    s = sha.new()
260
222
    b = f.read()
261
223
    s.update(b)
264
226
            'sha1': s.hexdigest()}
265
227
 
266
228
 
 
229
def config_dir():
 
230
    """Return per-user configuration directory.
 
231
 
 
232
    By default this is ~/.bzr.conf/
 
233
    
 
234
    TODO: Global option --config-dir to override this.
 
235
    """
 
236
    return os.path.expanduser("~/.bzr.conf")
 
237
 
 
238
 
 
239
def _auto_user_id():
 
240
    """Calculate automatic user identification.
 
241
 
 
242
    Returns (realname, email).
 
243
 
 
244
    Only used when none is set in the environment or the id file.
 
245
 
 
246
    This previously used the FQDN as the default domain, but that can
 
247
    be very slow on machines where DNS is broken.  So now we simply
 
248
    use the hostname.
 
249
    """
 
250
    import socket
 
251
 
 
252
    # XXX: Any good way to get real user name on win32?
 
253
 
 
254
    try:
 
255
        import pwd
 
256
        uid = os.getuid()
 
257
        w = pwd.getpwuid(uid)
 
258
        gecos = w.pw_gecos.decode(bzrlib.user_encoding)
 
259
        username = w.pw_name.decode(bzrlib.user_encoding)
 
260
        comma = gecos.find(',')
 
261
        if comma == -1:
 
262
            realname = gecos
 
263
        else:
 
264
            realname = gecos[:comma]
 
265
        if not realname:
 
266
            realname = username
 
267
 
 
268
    except ImportError:
 
269
        import getpass
 
270
        realname = username = getpass.getuser().decode(bzrlib.user_encoding)
 
271
 
 
272
    return realname, (username + '@' + socket.gethostname())
 
273
 
 
274
 
 
275
def _get_user_id(branch):
 
276
    """Return the full user id from a file or environment variable.
 
277
 
 
278
    e.g. "John Hacker <jhacker@foo.org>"
 
279
 
 
280
    branch
 
281
        A branch to use for a per-branch configuration, or None.
 
282
 
 
283
    The following are searched in order:
 
284
 
 
285
    1. $BZREMAIL
 
286
    2. .bzr/email for this branch.
 
287
    3. ~/.bzr.conf/email
 
288
    4. $EMAIL
 
289
    """
 
290
    v = os.environ.get('BZREMAIL')
 
291
    if v:
 
292
        return v.decode(bzrlib.user_encoding)
 
293
 
 
294
    if branch:
 
295
        try:
 
296
            return (branch.controlfile("email", "r") 
 
297
                    .read()
 
298
                    .decode(bzrlib.user_encoding)
 
299
                    .rstrip("\r\n"))
 
300
        except IOError, e:
 
301
            if e.errno != errno.ENOENT:
 
302
                raise
 
303
        except BzrError, e:
 
304
            pass
 
305
    
 
306
    try:
 
307
        return (open(os.path.join(config_dir(), "email"))
 
308
                .read()
 
309
                .decode(bzrlib.user_encoding)
 
310
                .rstrip("\r\n"))
 
311
    except IOError, e:
 
312
        if e.errno != errno.ENOENT:
 
313
            raise e
 
314
 
 
315
    v = os.environ.get('EMAIL')
 
316
    if v:
 
317
        return v.decode(bzrlib.user_encoding)
 
318
    else:    
 
319
        return None
 
320
 
 
321
 
 
322
def username(branch):
 
323
    """Return email-style username.
 
324
 
 
325
    Something similar to 'Martin Pool <mbp@sourcefrog.net>'
 
326
 
 
327
    TODO: Check it's reasonably well-formed.
 
328
    """
 
329
    v = _get_user_id(branch)
 
330
    if v:
 
331
        return v
 
332
    
 
333
    name, email = _auto_user_id()
 
334
    if name:
 
335
        return '%s <%s>' % (name, email)
 
336
    else:
 
337
        return email
 
338
 
 
339
 
 
340
def user_email(branch):
 
341
    """Return just the email component of a username."""
 
342
    e = _get_user_id(branch)
 
343
    if e:
 
344
        m = re.search(r'[\w+.-]+@[\w+.-]+', e)
 
345
        if not m:
 
346
            raise BzrError("%r doesn't seem to contain a reasonable email address" % e)
 
347
        return m.group(0)
 
348
 
 
349
    return _auto_user_id()[1]
 
350
    
 
351
 
 
352
 
267
353
def compare_files(a, b):
268
354
    """Returns true if equal in contents"""
269
355
    BUFSIZE = 4096
276
362
            return True
277
363
 
278
364
 
 
365
 
279
366
def local_time_offset(t=None):
280
367
    """Return offset of local zone from GMT, either at present or at time t."""
281
368
    # python2.3 localtime() can't take None
320
407
    """Return size of given open file."""
321
408
    return os.fstat(f.fileno())[ST_SIZE]
322
409
 
323
 
# Define rand_bytes based on platform.
324
 
try:
325
 
    # Python 2.4 and later have os.urandom,
326
 
    # but it doesn't work on some arches
327
 
    os.urandom(1)
 
410
 
 
411
if hasattr(os, 'urandom'): # python 2.4 and later
328
412
    rand_bytes = os.urandom
329
 
except (NotImplementedError, AttributeError):
330
 
    # If python doesn't have os.urandom, or it doesn't work,
331
 
    # then try to first pull random data from /dev/urandom
332
 
    if os.path.exists("/dev/urandom"):
333
 
        rand_bytes = file('/dev/urandom', 'rb').read
334
 
    # Otherwise, use this hack as a last resort
335
 
    else:
336
 
        # not well seeded, but better than nothing
337
 
        def rand_bytes(n):
338
 
            import random
339
 
            s = ''
340
 
            while n:
341
 
                s += chr(random.randint(0, 255))
342
 
                n -= 1
343
 
            return s
 
413
elif sys.platform == 'linux2':
 
414
    rand_bytes = file('/dev/urandom', 'rb').read
 
415
else:
 
416
    # not well seeded, but better than nothing
 
417
    def rand_bytes(n):
 
418
        import random
 
419
        s = ''
 
420
        while n:
 
421
            s += chr(random.randint(0, 255))
 
422
            n -= 1
 
423
        return s
 
424
 
344
425
 
345
426
## TODO: We could later have path objects that remember their list
346
427
## decomposition (might be too tricksy though.)
392
473
        return os.path.join(p1, p2)
393
474
    
394
475
 
395
 
def split_lines(s):
396
 
    """Split s into lines, but without removing the newline characters."""
397
 
    return StringIO(s).readlines()
398
 
 
399
 
 
400
 
def hardlinks_good():
401
 
    return sys.platform not in ('win32', 'cygwin', 'darwin')
402
 
 
403
 
 
404
 
def link_or_copy(src, dest):
405
 
    """Hardlink a file, or copy it if it can't be hardlinked."""
406
 
    if not hardlinks_good():
407
 
        copyfile(src, dest)
408
 
        return
 
476
def extern_command(cmd, ignore_errors = False):
 
477
    mutter('external command: %s' % `cmd`)
 
478
    if os.system(cmd):
 
479
        if not ignore_errors:
 
480
            raise BzrError('command failed')
 
481
 
 
482
 
 
483
def _read_config_value(name):
 
484
    """Read a config value from the file ~/.bzr.conf/<name>
 
485
    Return None if the file does not exist"""
409
486
    try:
410
 
        os.link(src, dest)
411
 
    except (OSError, IOError), e:
412
 
        if e.errno != errno.EXDEV:
413
 
            raise
414
 
        copyfile(src, dest)
415
 
 
416
 
 
417
 
def has_symlinks():
418
 
    if hasattr(os, 'symlink'):
419
 
        return True
420
 
    else:
421
 
        return False
422
 
        
423
 
 
424
 
def contains_whitespace(s):
425
 
    """True if there are any whitespace characters in s."""
426
 
    for ch in string.whitespace:
427
 
        if ch in s:
428
 
            return True
429
 
    else:
430
 
        return False
431
 
 
432
 
 
433
 
def contains_linebreaks(s):
434
 
    """True if there is any vertical whitespace in s."""
435
 
    for ch in '\f\n\r':
436
 
        if ch in s:
437
 
            return True
438
 
    else:
439
 
        return False
 
487
        f = file(os.path.join(config_dir(), name), "r")
 
488
        return f.read().decode(bzrlib.user_encoding).rstrip("\r\n")
 
489
    except IOError, e:
 
490
        if e.errno == errno.ENOENT:
 
491
            return None
 
492
        raise
 
493
 
 
494