~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/osutils.py

merge merge tweaks from aaron, which includes latest .dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Bazaar -- distributed version control
2
 
#
 
1
# Bazaar-NG -- distributed version control
 
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 cStringIO import StringIO
20
 
import errno
21
 
from ntpath import (abspath as _nt_abspath,
22
 
                    join as _nt_join,
23
 
                    normpath as _nt_normpath,
24
 
                    realpath as _nt_realpath,
25
 
                    splitdrive as _nt_splitdrive,
26
 
                    )
27
 
import os
28
 
from os import listdir
29
 
import posixpath
30
 
import re
31
 
import sha
32
 
import shutil
33
 
from shutil import copyfile
34
 
import stat
35
 
from stat import (S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE,
36
 
                  S_ISCHR, S_ISBLK, S_ISFIFO, S_ISSOCK)
37
 
import string
38
 
import sys
39
 
import time
40
 
import types
41
 
import tempfile
42
 
import unicodedata
 
19
import os, types, re, time, errno, sys
 
20
from stat import S_ISREG, S_ISDIR, S_ISLNK, ST_MODE, ST_SIZE
43
21
 
 
22
from bzrlib.errors import BzrError
 
23
from bzrlib.trace import mutter
44
24
import bzrlib
45
 
from bzrlib.errors import (BzrError,
46
 
                           BzrBadParameterNotUnicode,
47
 
                           NoSuchFile,
48
 
                           PathNotChild,
49
 
                           IllegalPath,
50
 
                           )
51
 
from bzrlib.symbol_versioning import (deprecated_function, 
52
 
        zero_nine)
53
 
from bzrlib.trace import mutter
54
 
 
55
25
 
56
26
def make_readonly(filename):
57
27
    """Make a filename read-only."""
 
28
    # TODO: probably needs to be fixed for windows
58
29
    mod = os.stat(filename).st_mode
59
30
    mod = mod & 0777555
60
31
    os.chmod(filename, mod)
77
48
    # TODO: I'm not really sure this is the best format either.x
78
49
    global _QUOTE_RE
79
50
    if _QUOTE_RE == None:
80
 
        _QUOTE_RE = re.compile(r'([^a-zA-Z0-9.,:/\\_~-])')
 
51
        _QUOTE_RE = re.compile(r'([^a-zA-Z0-9.,:/_~-])')
81
52
        
82
53
    if _QUOTE_RE.search(f):
83
54
        return '"' + f + '"'
85
56
        return f
86
57
 
87
58
 
88
 
_directory_kind = 'directory'
89
 
 
90
 
_formats = {
91
 
    stat.S_IFDIR:_directory_kind,
92
 
    stat.S_IFCHR:'chardev',
93
 
    stat.S_IFBLK:'block',
94
 
    stat.S_IFREG:'file',
95
 
    stat.S_IFIFO:'fifo',
96
 
    stat.S_IFLNK:'symlink',
97
 
    stat.S_IFSOCK:'socket',
98
 
}
99
 
 
100
 
 
101
 
def file_kind_from_stat_mode(stat_mode, _formats=_formats, _unknown='unknown'):
102
 
    """Generate a file kind from a stat mode. This is used in walkdirs.
103
 
 
104
 
    Its performance is critical: Do not mutate without careful benchmarking.
105
 
    """
106
 
    try:
107
 
        return _formats[stat_mode & 0170000]
108
 
    except KeyError:
109
 
        return _unknown
110
 
 
111
 
 
112
 
def file_kind(f, _lstat=os.lstat, _mapper=file_kind_from_stat_mode):
113
 
    try:
114
 
        return _mapper(_lstat(f).st_mode)
115
 
    except OSError, e:
116
 
        if getattr(e, 'errno', None) == errno.ENOENT:
117
 
            raise bzrlib.errors.NoSuchFile(f)
118
 
        raise
 
59
def file_kind(f):
 
60
    mode = os.lstat(f)[ST_MODE]
 
61
    if S_ISREG(mode):
 
62
        return 'file'
 
63
    elif S_ISDIR(mode):
 
64
        return 'directory'
 
65
    elif S_ISLNK(mode):
 
66
        return 'symlink'
 
67
    else:
 
68
        raise BzrError("can't handle file kind with mode %o of %r" % (mode, f))
119
69
 
120
70
 
121
71
def kind_marker(kind):
122
72
    if kind == 'file':
123
73
        return ''
124
 
    elif kind == _directory_kind:
 
74
    elif kind == 'directory':
125
75
        return '/'
126
76
    elif kind == 'symlink':
127
77
        return '@'
128
78
    else:
129
79
        raise BzrError('invalid file kind %r' % kind)
130
80
 
131
 
lexists = getattr(os.path, 'lexists', None)
132
 
if lexists is None:
133
 
    def lexists(f):
134
 
        try:
135
 
            if hasattr(os, 'lstat'):
136
 
                os.lstat(f)
137
 
            else:
138
 
                os.stat(f)
139
 
            return True
140
 
        except OSError,e:
141
 
            if e.errno == errno.ENOENT:
142
 
                return False;
143
 
            else:
144
 
                raise BzrError("lstat/stat of (%r): %r" % (f, e))
145
 
 
146
 
 
147
 
def fancy_rename(old, new, rename_func, unlink_func):
148
 
    """A fancy rename, when you don't have atomic rename.
149
 
    
150
 
    :param old: The old path, to rename from
151
 
    :param new: The new path, to rename to
152
 
    :param rename_func: The potentially non-atomic rename function
153
 
    :param unlink_func: A way to delete the target file if the full rename succeeds
154
 
    """
155
 
 
156
 
    # sftp rename doesn't allow overwriting, so play tricks:
157
 
    import random
158
 
    base = os.path.basename(new)
159
 
    dirname = os.path.dirname(new)
160
 
    tmp_name = u'tmp.%s.%.9f.%d.%s' % (base, time.time(), os.getpid(), rand_chars(10))
161
 
    tmp_name = pathjoin(dirname, tmp_name)
162
 
 
163
 
    # Rename the file out of the way, but keep track if it didn't exist
164
 
    # We don't want to grab just any exception
165
 
    # something like EACCES should prevent us from continuing
166
 
    # The downside is that the rename_func has to throw an exception
167
 
    # with an errno = ENOENT, or NoSuchFile
168
 
    file_existed = False
169
 
    try:
170
 
        rename_func(new, tmp_name)
171
 
    except (NoSuchFile,), e:
172
 
        pass
173
 
    except IOError, e:
174
 
        # RBC 20060103 abstraction leakage: the paramiko SFTP clients rename
175
 
        # function raises an IOError with errno == None when a rename fails.
176
 
        # This then gets caught here.
177
 
        if e.errno not in (None, errno.ENOENT, errno.ENOTDIR):
178
 
            raise
179
 
    except Exception, e:
180
 
        if (not hasattr(e, 'errno') 
181
 
            or e.errno not in (errno.ENOENT, errno.ENOTDIR)):
182
 
            raise
183
 
    else:
184
 
        file_existed = True
185
 
 
186
 
    success = False
187
 
    try:
188
 
        # This may throw an exception, in which case success will
189
 
        # not be set.
190
 
        rename_func(old, new)
191
 
        success = True
192
 
    finally:
193
 
        if file_existed:
194
 
            # If the file used to exist, rename it back into place
195
 
            # otherwise just delete it from the tmp location
196
 
            if success:
197
 
                unlink_func(tmp_name)
198
 
            else:
199
 
                rename_func(tmp_name, new)
200
 
 
201
 
 
202
 
# In Python 2.4.2 and older, os.path.abspath and os.path.realpath
203
 
# choke on a Unicode string containing a relative path if
204
 
# os.getcwd() returns a non-sys.getdefaultencoding()-encoded
205
 
# string.
206
 
_fs_enc = sys.getfilesystemencoding()
207
 
def _posix_abspath(path):
208
 
    # jam 20060426 rather than encoding to fsencoding
209
 
    # copy posixpath.abspath, but use os.getcwdu instead
210
 
    if not posixpath.isabs(path):
211
 
        path = posixpath.join(getcwd(), path)
212
 
    return posixpath.normpath(path)
213
 
 
214
 
 
215
 
def _posix_realpath(path):
216
 
    return posixpath.realpath(path.encode(_fs_enc)).decode(_fs_enc)
217
 
 
218
 
 
219
 
def _win32_fixdrive(path):
220
 
    """Force drive letters to be consistent.
221
 
 
222
 
    win32 is inconsistent whether it returns lower or upper case
223
 
    and even if it was consistent the user might type the other
224
 
    so we force it to uppercase
225
 
    running python.exe under cmd.exe return capital C:\\
226
 
    running win32 python inside a cygwin shell returns lowercase c:\\
227
 
    """
228
 
    drive, path = _nt_splitdrive(path)
229
 
    return drive.upper() + path
230
 
 
231
 
 
232
 
def _win32_abspath(path):
233
 
    # Real _nt_abspath doesn't have a problem with a unicode cwd
234
 
    return _win32_fixdrive(_nt_abspath(unicode(path)).replace('\\', '/'))
235
 
 
236
 
 
237
 
def _win32_realpath(path):
238
 
    # Real _nt_realpath doesn't have a problem with a unicode cwd
239
 
    return _win32_fixdrive(_nt_realpath(unicode(path)).replace('\\', '/'))
240
 
 
241
 
 
242
 
def _win32_pathjoin(*args):
243
 
    return _nt_join(*args).replace('\\', '/')
244
 
 
245
 
 
246
 
def _win32_normpath(path):
247
 
    return _win32_fixdrive(_nt_normpath(unicode(path)).replace('\\', '/'))
248
 
 
249
 
 
250
 
def _win32_getcwd():
251
 
    return _win32_fixdrive(os.getcwdu().replace('\\', '/'))
252
 
 
253
 
 
254
 
def _win32_mkdtemp(*args, **kwargs):
255
 
    return _win32_fixdrive(tempfile.mkdtemp(*args, **kwargs).replace('\\', '/'))
256
 
 
257
 
 
258
 
def _win32_rename(old, new):
259
 
    """We expect to be able to atomically replace 'new' with old.
260
 
 
261
 
    On win32, if new exists, it must be moved out of the way first,
262
 
    and then deleted. 
263
 
    """
264
 
    try:
265
 
        fancy_rename(old, new, rename_func=os.rename, unlink_func=os.unlink)
266
 
    except OSError, e:
267
 
        if e.errno in (errno.EPERM, errno.EACCES, errno.EBUSY, errno.EINVAL):
268
 
            # If we try to rename a non-existant file onto cwd, we get 
269
 
            # EPERM or EACCES instead of ENOENT, this will raise ENOENT 
270
 
            # if the old path doesn't exist, sometimes we get EACCES
271
 
            # On Linux, we seem to get EBUSY, on Mac we get EINVAL
272
 
            os.lstat(old)
273
 
        raise
274
 
 
275
 
 
276
 
def _mac_getcwd():
277
 
    return unicodedata.normalize('NFKC', os.getcwdu())
278
 
 
279
 
 
280
 
# Default is to just use the python builtins, but these can be rebound on
281
 
# particular platforms.
282
 
abspath = _posix_abspath
283
 
realpath = _posix_realpath
284
 
pathjoin = os.path.join
285
 
normpath = os.path.normpath
286
 
getcwd = os.getcwdu
287
 
mkdtemp = tempfile.mkdtemp
288
 
rename = os.rename
289
 
dirname = os.path.dirname
290
 
basename = os.path.basename
291
 
rmtree = shutil.rmtree
292
 
 
293
 
MIN_ABS_PATHLENGTH = 1
294
 
 
295
 
 
296
 
if sys.platform == 'win32':
297
 
    abspath = _win32_abspath
298
 
    realpath = _win32_realpath
299
 
    pathjoin = _win32_pathjoin
300
 
    normpath = _win32_normpath
301
 
    getcwd = _win32_getcwd
302
 
    mkdtemp = _win32_mkdtemp
303
 
    rename = _win32_rename
304
 
 
305
 
    MIN_ABS_PATHLENGTH = 3
306
 
 
307
 
    def _win32_delete_readonly(function, path, excinfo):
308
 
        """Error handler for shutil.rmtree function [for win32]
309
 
        Helps to remove files and dirs marked as read-only.
310
 
        """
311
 
        type_, value = excinfo[:2]
312
 
        if function in (os.remove, os.rmdir) \
313
 
            and type_ == OSError \
314
 
            and value.errno == errno.EACCES:
315
 
            bzrlib.osutils.make_writable(path)
316
 
            function(path)
317
 
        else:
318
 
            raise
319
 
 
320
 
    def rmtree(path, ignore_errors=False, onerror=_win32_delete_readonly):
321
 
        """Replacer for shutil.rmtree: could remove readonly dirs/files"""
322
 
        return shutil.rmtree(path, ignore_errors, onerror)
323
 
elif sys.platform == 'darwin':
324
 
    getcwd = _mac_getcwd
325
 
 
326
 
 
327
 
def get_terminal_encoding():
328
 
    """Find the best encoding for printing to the screen.
329
 
 
330
 
    This attempts to check both sys.stdout and sys.stdin to see
331
 
    what encoding they are in, and if that fails it falls back to
332
 
    bzrlib.user_encoding.
333
 
    The problem is that on Windows, locale.getpreferredencoding()
334
 
    is not the same encoding as that used by the console:
335
 
    http://mail.python.org/pipermail/python-list/2003-May/162357.html
336
 
 
337
 
    On my standard US Windows XP, the preferred encoding is
338
 
    cp1252, but the console is cp437
339
 
    """
340
 
    output_encoding = getattr(sys.stdout, 'encoding', None)
341
 
    if not output_encoding:
342
 
        input_encoding = getattr(sys.stdin, 'encoding', None)
343
 
        if not input_encoding:
344
 
            output_encoding = bzrlib.user_encoding
345
 
            mutter('encoding stdout as bzrlib.user_encoding %r', output_encoding)
346
 
        else:
347
 
            output_encoding = input_encoding
348
 
            mutter('encoding stdout as sys.stdin encoding %r', output_encoding)
349
 
    else:
350
 
        mutter('encoding stdout as sys.stdout encoding %r', output_encoding)
351
 
    return output_encoding
352
 
 
353
 
 
354
 
def normalizepath(f):
355
 
    if hasattr(os.path, 'realpath'):
356
 
        F = realpath
357
 
    else:
358
 
        F = abspath
359
 
    [p,e] = os.path.split(f)
360
 
    if e == "" or e == "." or e == "..":
361
 
        return F(f)
362
 
    else:
363
 
        return pathjoin(F(p), e)
364
81
 
365
82
 
366
83
def backup_file(fn):
370
87
 
371
88
    If the file is already a backup, it's not copied.
372
89
    """
 
90
    import os
373
91
    if fn[-1] == '~':
374
92
        return
375
93
    bfn = fn + '~'
376
94
 
377
 
    if has_symlinks() and os.path.islink(fn):
378
 
        target = os.readlink(fn)
379
 
        os.symlink(target, bfn)
380
 
        return
381
95
    inf = file(fn, 'rb')
382
96
    try:
383
97
        content = inf.read()
390
104
    finally:
391
105
        outf.close()
392
106
 
 
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
 
 
119
 
393
120
 
394
121
def isdir(f):
395
122
    """True if f is an accessible directory."""
399
126
        return False
400
127
 
401
128
 
 
129
 
402
130
def isfile(f):
403
131
    """True if f is a regular file."""
404
132
    try:
406
134
    except OSError:
407
135
        return False
408
136
 
409
 
def islink(f):
410
 
    """True if f is a symlink."""
411
 
    try:
412
 
        return S_ISLNK(os.lstat(f)[ST_MODE])
413
 
    except OSError:
414
 
        return False
415
137
 
416
138
def is_inside(dir, fname):
417
139
    """True if fname is inside dir.
418
140
    
419
 
    The parameters should typically be passed to osutils.normpath first, so
 
141
    The parameters should typically be passed to os.path.normpath first, so
420
142
    that . and .. and repeated slashes are eliminated, and the separators
421
143
    are canonical for the platform.
422
144
    
423
145
    The empty string as a dir name is taken as top-of-tree and matches 
424
146
    everything.
425
147
    
426
 
    >>> is_inside('src', pathjoin('src', 'foo.c'))
 
148
    >>> is_inside('src', 'src/foo.c')
427
149
    True
428
150
    >>> is_inside('src', 'srccontrol')
429
151
    False
430
 
    >>> is_inside('src', pathjoin('src', 'a', 'a', 'a', 'foo.c'))
 
152
    >>> is_inside('src', 'src/a/a/a/foo.c')
431
153
    True
432
154
    >>> is_inside('foo.c', 'foo.c')
433
155
    True
443
165
    
444
166
    if dir == '':
445
167
        return True
446
 
 
447
 
    if dir[-1] != '/':
448
 
        dir += '/'
449
 
 
 
168
    
 
169
    if dir[-1] != os.sep:
 
170
        dir += os.sep
 
171
    
450
172
    return fname.startswith(dir)
451
173
 
452
174
 
459
181
        return False
460
182
 
461
183
 
462
 
def is_inside_or_parent_of_any(dir_list, fname):
463
 
    """True if fname is a child or a parent of any of the given files."""
464
 
    for dirname in dir_list:
465
 
        if is_inside(dirname, fname) or is_inside(fname, dirname):
466
 
            return True
467
 
    else:
468
 
        return False
469
 
 
470
 
 
471
184
def pumpfile(fromfile, tofile):
472
185
    """Copy contents of one file to another."""
473
 
    BUFSIZE = 32768
474
 
    while True:
475
 
        b = fromfile.read(BUFSIZE)
476
 
        if not b:
477
 
            break
478
 
        tofile.write(b)
479
 
 
480
 
 
481
 
def file_iterator(input_file, readsize=32768):
482
 
    while True:
483
 
        b = input_file.read(readsize)
484
 
        if len(b) == 0:
485
 
            break
486
 
        yield b
 
186
    tofile.write(fromfile.read())
 
187
 
 
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())
487
195
 
488
196
 
489
197
def sha_file(f):
 
198
    import sha
490
199
    if hasattr(f, 'tell'):
491
200
        assert f.tell() == 0
492
201
    s = sha.new()
499
208
    return s.hexdigest()
500
209
 
501
210
 
502
 
 
503
 
def sha_strings(strings):
504
 
    """Return the sha-1 of concatenation of strings"""
505
 
    s = sha.new()
506
 
    map(s.update, strings)
507
 
    return s.hexdigest()
508
 
 
509
 
 
510
211
def sha_string(f):
 
212
    import sha
511
213
    s = sha.new()
512
214
    s.update(f)
513
215
    return s.hexdigest()
514
216
 
515
217
 
 
218
 
516
219
def fingerprint_file(f):
 
220
    import sha
517
221
    s = sha.new()
518
222
    b = f.read()
519
223
    s.update(b)
522
226
            'sha1': s.hexdigest()}
523
227
 
524
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
 
525
353
def compare_files(a, b):
526
354
    """Returns true if equal in contents"""
527
355
    BUFSIZE = 4096
534
362
            return True
535
363
 
536
364
 
 
365
 
537
366
def local_time_offset(t=None):
538
367
    """Return offset of local zone from GMT, either at present or at time t."""
539
368
    # python2.3 localtime() can't take None
546
375
        return -time.timezone
547
376
 
548
377
    
549
 
def format_date(t, offset=0, timezone='original', date_fmt=None, 
550
 
                show_offset=True):
 
378
def format_date(t, offset=0, timezone='original'):
551
379
    ## TODO: Perhaps a global option to use either universal or local time?
552
380
    ## Or perhaps just let people set $TZ?
553
381
    assert isinstance(t, float)
565
393
    else:
566
394
        raise BzrError("unsupported timezone format %r" % timezone,
567
395
                       ['options are "utc", "original", "local"'])
568
 
    if date_fmt is None:
569
 
        date_fmt = "%a %Y-%m-%d %H:%M:%S"
570
 
    if show_offset:
571
 
        offset_str = ' %+03d%02d' % (offset / 3600, (offset / 60) % 60)
572
 
    else:
573
 
        offset_str = ''
574
 
    return (time.strftime(date_fmt, tt) +  offset_str)
 
396
 
 
397
    return (time.strftime("%a %Y-%m-%d %H:%M:%S", tt)
 
398
            + ' %+03d%02d' % (offset / 3600, (offset / 60) % 60))
575
399
 
576
400
 
577
401
def compact_date(when):
583
407
    """Return size of given open file."""
584
408
    return os.fstat(f.fileno())[ST_SIZE]
585
409
 
586
 
 
587
410
# Define rand_bytes based on platform.
588
411
try:
589
412
    # Python 2.4 and later have os.urandom,
606
429
                n -= 1
607
430
            return s
608
431
 
609
 
 
610
 
ALNUM = '0123456789abcdefghijklmnopqrstuvwxyz'
611
 
def rand_chars(num):
612
 
    """Return a random string of num alphanumeric characters
613
 
    
614
 
    The result only contains lowercase chars because it may be used on 
615
 
    case-insensitive filesystems.
616
 
    """
617
 
    s = ''
618
 
    for raw_byte in rand_bytes(num):
619
 
        s += ALNUM[ord(raw_byte) % 36]
620
 
    return s
621
 
 
622
 
 
623
432
## TODO: We could later have path objects that remember their list
624
433
## decomposition (might be too tricksy though.)
625
434
 
660
469
    for f in p:
661
470
        if (f == '..') or (f == None) or (f == ''):
662
471
            raise BzrError("sorry, %r not allowed in path" % f)
663
 
    return pathjoin(*p)
664
 
 
665
 
 
666
 
@deprecated_function(zero_nine)
 
472
    return os.path.join(*p)
 
473
 
 
474
 
667
475
def appendpath(p1, p2):
668
476
    if p1 == '':
669
477
        return p2
670
478
    else:
671
 
        return pathjoin(p1, p2)
672
 
    
673
 
 
674
 
def split_lines(s):
675
 
    """Split s into lines, but without removing the newline characters."""
676
 
    lines = s.split('\n')
677
 
    result = [line + '\n' for line in lines[:-1]]
678
 
    if lines[-1]:
679
 
        result.append(lines[-1])
680
 
    return result
681
 
 
682
 
 
683
 
def hardlinks_good():
684
 
    return sys.platform not in ('win32', 'cygwin', 'darwin')
685
 
 
686
 
 
687
 
def link_or_copy(src, dest):
688
 
    """Hardlink a file, or copy it if it can't be hardlinked."""
689
 
    if not hardlinks_good():
690
 
        copyfile(src, dest)
691
 
        return
692
 
    try:
693
 
        os.link(src, dest)
694
 
    except (OSError, IOError), e:
695
 
        if e.errno != errno.EXDEV:
696
 
            raise
697
 
        copyfile(src, dest)
698
 
 
699
 
def delete_any(full_path):
700
 
    """Delete a file or directory."""
701
 
    try:
702
 
        os.unlink(full_path)
703
 
    except OSError, e:
704
 
    # We may be renaming a dangling inventory id
705
 
        if e.errno not in (errno.EISDIR, errno.EACCES, errno.EPERM):
706
 
            raise
707
 
        os.rmdir(full_path)
708
 
 
709
 
 
710
 
def has_symlinks():
711
 
    if hasattr(os, 'symlink'):
712
 
        return True
713
 
    else:
714
 
        return False
715
 
        
716
 
 
717
 
def contains_whitespace(s):
718
 
    """True if there are any whitespace characters in s."""
719
 
    for ch in string.whitespace:
720
 
        if ch in s:
721
 
            return True
722
 
    else:
723
 
        return False
724
 
 
725
 
 
726
 
def contains_linebreaks(s):
727
 
    """True if there is any vertical whitespace in s."""
728
 
    for ch in '\f\n\r':
729
 
        if ch in s:
730
 
            return True
731
 
    else:
732
 
        return False
733
 
 
734
 
 
735
 
def relpath(base, path):
736
 
    """Return path relative to base, or raise exception.
737
 
 
738
 
    The path may be either an absolute path or a path relative to the
739
 
    current working directory.
740
 
 
741
 
    os.path.commonprefix (python2.4) has a bad bug that it works just
742
 
    on string prefixes, assuming that '/u' is a prefix of '/u2'.  This
743
 
    avoids that problem.
744
 
    """
745
 
 
746
 
    assert len(base) >= MIN_ABS_PATHLENGTH, ('Length of base must be equal or'
747
 
        ' exceed the platform minimum length (which is %d)' % 
748
 
        MIN_ABS_PATHLENGTH)
749
 
 
750
 
    rp = abspath(path)
751
 
 
752
 
    s = []
753
 
    head = rp
754
 
    while len(head) >= len(base):
755
 
        if head == base:
756
 
            break
757
 
        head, tail = os.path.split(head)
758
 
        if tail:
759
 
            s.insert(0, tail)
760
 
    else:
761
 
        raise PathNotChild(rp, base)
762
 
 
763
 
    if s:
764
 
        return pathjoin(*s)
765
 
    else:
766
 
        return ''
767
 
 
768
 
 
769
 
def safe_unicode(unicode_or_utf8_string):
770
 
    """Coerce unicode_or_utf8_string into unicode.
771
 
 
772
 
    If it is unicode, it is returned.
773
 
    Otherwise it is decoded from utf-8. If a decoding error
774
 
    occurs, it is wrapped as a If the decoding fails, the exception is wrapped 
775
 
    as a BzrBadParameter exception.
776
 
    """
777
 
    if isinstance(unicode_or_utf8_string, unicode):
778
 
        return unicode_or_utf8_string
779
 
    try:
780
 
        return unicode_or_utf8_string.decode('utf8')
781
 
    except UnicodeDecodeError:
782
 
        raise BzrBadParameterNotUnicode(unicode_or_utf8_string)
783
 
 
784
 
 
785
 
_platform_normalizes_filenames = False
786
 
if sys.platform == 'darwin':
787
 
    _platform_normalizes_filenames = True
788
 
 
789
 
 
790
 
def normalizes_filenames():
791
 
    """Return True if this platform normalizes unicode filenames.
792
 
 
793
 
    Mac OSX does, Windows/Linux do not.
794
 
    """
795
 
    return _platform_normalizes_filenames
796
 
 
797
 
 
798
 
def _accessible_normalized_filename(path):
799
 
    """Get the unicode normalized path, and if you can access the file.
800
 
 
801
 
    On platforms where the system normalizes filenames (Mac OSX),
802
 
    you can access a file by any path which will normalize correctly.
803
 
    On platforms where the system does not normalize filenames 
804
 
    (Windows, Linux), you have to access a file by its exact path.
805
 
 
806
 
    Internally, bzr only supports NFC/NFKC normalization, since that is 
807
 
    the standard for XML documents.
808
 
 
809
 
    So return the normalized path, and a flag indicating if the file
810
 
    can be accessed by that path.
811
 
    """
812
 
 
813
 
    return unicodedata.normalize('NFKC', unicode(path)), True
814
 
 
815
 
 
816
 
def _inaccessible_normalized_filename(path):
817
 
    __doc__ = _accessible_normalized_filename.__doc__
818
 
 
819
 
    normalized = unicodedata.normalize('NFKC', unicode(path))
820
 
    return normalized, normalized == path
821
 
 
822
 
 
823
 
if _platform_normalizes_filenames:
824
 
    normalized_filename = _accessible_normalized_filename
825
 
else:
826
 
    normalized_filename = _inaccessible_normalized_filename
827
 
 
828
 
 
829
 
def terminal_width():
830
 
    """Return estimated terminal width."""
831
 
    if sys.platform == 'win32':
832
 
        import bzrlib.win32console
833
 
        return bzrlib.win32console.get_console_size()[0]
834
 
    width = 0
835
 
    try:
836
 
        import struct, fcntl, termios
837
 
        s = struct.pack('HHHH', 0, 0, 0, 0)
838
 
        x = fcntl.ioctl(1, termios.TIOCGWINSZ, s)
839
 
        width = struct.unpack('HHHH', x)[1]
840
 
    except IOError:
841
 
        pass
842
 
    if width <= 0:
843
 
        try:
844
 
            width = int(os.environ['COLUMNS'])
845
 
        except:
846
 
            pass
847
 
    if width <= 0:
848
 
        width = 80
849
 
 
850
 
    return width
851
 
 
852
 
def supports_executable():
853
 
    return sys.platform != "win32"
854
 
 
855
 
 
856
 
_validWin32PathRE = re.compile(r'^([A-Za-z]:[/\\])?[^:<>*"?\|]*$')
857
 
 
858
 
 
859
 
def check_legal_path(path):
860
 
    """Check whether the supplied path is legal.  
861
 
    This is only required on Windows, so we don't test on other platforms
862
 
    right now.
863
 
    """
864
 
    if sys.platform != "win32":
865
 
        return
866
 
    if _validWin32PathRE.match(path) is None:
867
 
        raise IllegalPath(path)
868
 
 
869
 
 
870
 
def walkdirs(top, prefix=""):
871
 
    """Yield data about all the directories in a tree.
872
 
    
873
 
    This yields all the data about the contents of a directory at a time.
874
 
    After each directory has been yielded, if the caller has mutated the list
875
 
    to exclude some directories, they are then not descended into.
876
 
    
877
 
    The data yielded is of the form:
878
 
    [(relpath, basename, kind, lstat, path_from_top), ...]
879
 
 
880
 
    :param prefix: Prefix the relpaths that are yielded with 'prefix'. This 
881
 
        allows one to walk a subtree but get paths that are relative to a tree
882
 
        rooted higher up.
883
 
    :return: an iterator over the dirs.
884
 
    """
885
 
    lstat = os.lstat
886
 
    pending = []
887
 
    _directory = _directory_kind
888
 
    _listdir = listdir
889
 
    pending = [(prefix, "", _directory, None, top)]
890
 
    while pending:
891
 
        dirblock = []
892
 
        currentdir = pending.pop()
893
 
        # 0 - relpath, 1- basename, 2- kind, 3- stat, 4-toppath
894
 
        top = currentdir[4]
895
 
        if currentdir[0]:
896
 
            relroot = currentdir[0] + '/'
897
 
        else:
898
 
            relroot = ""
899
 
        for name in sorted(_listdir(top)):
900
 
            abspath = top + '/' + name
901
 
            statvalue = lstat(abspath)
902
 
            dirblock.append ((relroot + name, name, file_kind_from_stat_mode(statvalue.st_mode), statvalue, abspath))
903
 
        yield dirblock
904
 
        # push the user specified dirs from dirblock
905
 
        for dir in reversed(dirblock):
906
 
            if dir[2] == _directory:
907
 
                pending.append(dir)
908
 
 
909
 
 
910
 
def path_prefix_key(path):
911
 
    """Generate a prefix-order path key for path.
912
 
 
913
 
    This can be used to sort paths in the same way that walkdirs does.
914
 
    """
915
 
    return (dirname(path) , path)
916
 
 
917
 
 
918
 
def compare_paths_prefix_order(path_a, path_b):
919
 
    """Compare path_a and path_b to generate the same order walkdirs uses."""
920
 
    key_a = path_prefix_key(path_a)
921
 
    key_b = path_prefix_key(path_b)
922
 
    return cmp(key_a, key_b)
 
479
        return os.path.join(p1, p2)
 
480
    
 
481
 
 
482
def extern_command(cmd, ignore_errors = False):
 
483
    mutter('external command: %s' % `cmd`)
 
484
    if os.system(cmd):
 
485
        if not ignore_errors:
 
486
            raise BzrError('command failed')
 
487
 
 
488
 
 
489
def _read_config_value(name):
 
490
    """Read a config value from the file ~/.bzr.conf/<name>
 
491
    Return None if the file does not exist"""
 
492
    try:
 
493
        f = file(os.path.join(config_dir(), name), "r")
 
494
        return f.read().decode(bzrlib.user_encoding).rstrip("\r\n")
 
495
    except IOError, e:
 
496
        if e.errno == errno.ENOENT:
 
497
            return None
 
498
        raise
 
499
 
 
500