~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/osutils.py

  • Committer: Robert Collins
  • Date: 2005-10-06 05:13:21 UTC
  • mfrom: (1393.3.3)
  • Revision ID: robertc@robertcollins.net-20051006051321-88f1053c3bf1ca4a
merge in an adjusted version of Jelmer's empty-log detection patch.

Show diffs side-by-side

added added

removed removed

Lines of Context:
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)
19
22
from cStringIO import StringIO
20
23
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
24
import os
28
 
from os import listdir
29
 
import posixpath
30
25
import re
31
26
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
27
import sys
39
28
import time
40
29
import types
41
 
import tempfile
42
 
import unicodedata
43
30
 
44
31
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)
 
32
from bzrlib.errors import BzrError
53
33
from bzrlib.trace import mutter
54
34
 
55
35
 
85
65
        return f
86
66
 
87
67
 
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
 
68
def file_kind(f):
 
69
    mode = os.lstat(f)[ST_MODE]
 
70
    if S_ISREG(mode):
 
71
        return 'file'
 
72
    elif S_ISDIR(mode):
 
73
        return 'directory'
 
74
    elif S_ISLNK(mode):
 
75
        return 'symlink'
 
76
    elif S_ISCHR(mode):
 
77
        return 'chardev'
 
78
    elif S_ISBLK(mode):
 
79
        return 'block'
 
80
    elif S_ISFIFO(mode):
 
81
        return 'fifo'
 
82
    elif S_ISSOCK(mode):
 
83
        return 'socket'
 
84
    else:
 
85
        return 'unknown'
119
86
 
120
87
 
121
88
def kind_marker(kind):
122
89
    if kind == 'file':
123
90
        return ''
124
 
    elif kind == _directory_kind:
 
91
    elif kind == 'directory':
125
92
        return '/'
126
93
    elif kind == 'symlink':
127
94
        return '@'
128
95
    else:
129
96
        raise BzrError('invalid file kind %r' % kind)
130
97
 
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
 
    fancy_rename(old, new, rename_func=os.rename, unlink_func=os.unlink)
260
 
 
261
 
 
262
 
# Default is to just use the python builtins, but these can be rebound on
263
 
# particular platforms.
264
 
abspath = _posix_abspath
265
 
realpath = _posix_realpath
266
 
pathjoin = os.path.join
267
 
normpath = os.path.normpath
268
 
getcwd = os.getcwdu
269
 
mkdtemp = tempfile.mkdtemp
270
 
rename = os.rename
271
 
dirname = os.path.dirname
272
 
basename = os.path.basename
273
 
rmtree = shutil.rmtree
274
 
 
275
 
MIN_ABS_PATHLENGTH = 1
276
 
 
277
 
 
278
 
if sys.platform == 'win32':
279
 
    abspath = _win32_abspath
280
 
    realpath = _win32_realpath
281
 
    pathjoin = _win32_pathjoin
282
 
    normpath = _win32_normpath
283
 
    getcwd = _win32_getcwd
284
 
    mkdtemp = _win32_mkdtemp
285
 
    rename = _win32_rename
286
 
 
287
 
    MIN_ABS_PATHLENGTH = 3
288
 
 
289
 
    def _win32_delete_readonly(function, path, excinfo):
290
 
        """Error handler for shutil.rmtree function [for win32]
291
 
        Helps to remove files and dirs marked as read-only.
292
 
        """
293
 
        type_, value = excinfo[:2]
294
 
        if function in (os.remove, os.rmdir) \
295
 
            and type_ == OSError \
296
 
            and value.errno == errno.EACCES:
297
 
            bzrlib.osutils.make_writable(path)
298
 
            function(path)
299
 
        else:
300
 
            raise
301
 
 
302
 
    def rmtree(path, ignore_errors=False, onerror=_win32_delete_readonly):
303
 
        """Replacer for shutil.rmtree: could remove readonly dirs/files"""
304
 
        return shutil.rmtree(path, ignore_errors, onerror)
305
 
 
306
 
 
307
 
def get_terminal_encoding():
308
 
    """Find the best encoding for printing to the screen.
309
 
 
310
 
    This attempts to check both sys.stdout and sys.stdin to see
311
 
    what encoding they are in, and if that fails it falls back to
312
 
    bzrlib.user_encoding.
313
 
    The problem is that on Windows, locale.getpreferredencoding()
314
 
    is not the same encoding as that used by the console:
315
 
    http://mail.python.org/pipermail/python-list/2003-May/162357.html
316
 
 
317
 
    On my standard US Windows XP, the preferred encoding is
318
 
    cp1252, but the console is cp437
319
 
    """
320
 
    output_encoding = getattr(sys.stdout, 'encoding', None)
321
 
    if not output_encoding:
322
 
        input_encoding = getattr(sys.stdin, 'encoding', None)
323
 
        if not input_encoding:
324
 
            output_encoding = bzrlib.user_encoding
325
 
            mutter('encoding stdout as bzrlib.user_encoding %r', output_encoding)
326
 
        else:
327
 
            output_encoding = input_encoding
328
 
            mutter('encoding stdout as sys.stdin encoding %r', output_encoding)
329
 
    else:
330
 
        mutter('encoding stdout as sys.stdout encoding %r', output_encoding)
331
 
    return output_encoding
332
 
 
 
98
def lexists(f):
 
99
    try:
 
100
        if hasattr(os, 'lstat'):
 
101
            os.lstat(f)
 
102
        else:
 
103
            os.stat(f)
 
104
        return True
 
105
    except OSError,e:
 
106
        if e.errno == errno.ENOENT:
 
107
            return False;
 
108
        else:
 
109
            raise BzrError("lstat/stat of (%r): %r" % (f, e))
333
110
 
334
111
def normalizepath(f):
335
112
    if hasattr(os.path, 'realpath'):
336
 
        F = realpath
 
113
        F = os.path.realpath
337
114
    else:
338
 
        F = abspath
 
115
        F = os.path.abspath
339
116
    [p,e] = os.path.split(f)
340
117
    if e == "" or e == "." or e == "..":
341
118
        return F(f)
342
119
    else:
343
 
        return pathjoin(F(p), e)
344
 
 
 
120
        return os.path.join(F(p), e)
 
121
    
345
122
 
346
123
def backup_file(fn):
347
124
    """Copy a file to a backup.
354
131
        return
355
132
    bfn = fn + '~'
356
133
 
357
 
    if has_symlinks() and os.path.islink(fn):
358
 
        target = os.readlink(fn)
359
 
        os.symlink(target, bfn)
360
 
        return
361
134
    inf = file(fn, 'rb')
362
135
    try:
363
136
        content = inf.read()
370
143
    finally:
371
144
        outf.close()
372
145
 
 
146
if os.name == 'nt':
 
147
    import shutil
 
148
    rename = shutil.move
 
149
else:
 
150
    rename = os.rename
 
151
 
373
152
 
374
153
def isdir(f):
375
154
    """True if f is an accessible directory."""
396
175
def is_inside(dir, fname):
397
176
    """True if fname is inside dir.
398
177
    
399
 
    The parameters should typically be passed to osutils.normpath first, so
 
178
    The parameters should typically be passed to os.path.normpath first, so
400
179
    that . and .. and repeated slashes are eliminated, and the separators
401
180
    are canonical for the platform.
402
181
    
403
182
    The empty string as a dir name is taken as top-of-tree and matches 
404
183
    everything.
405
184
    
406
 
    >>> is_inside('src', pathjoin('src', 'foo.c'))
 
185
    >>> is_inside('src', os.path.join('src', 'foo.c'))
407
186
    True
408
187
    >>> is_inside('src', 'srccontrol')
409
188
    False
410
 
    >>> is_inside('src', pathjoin('src', 'a', 'a', 'a', 'foo.c'))
 
189
    >>> is_inside('src', os.path.join('src', 'a', 'a', 'a', 'foo.c'))
411
190
    True
412
191
    >>> is_inside('foo.c', 'foo.c')
413
192
    True
424
203
    if dir == '':
425
204
        return True
426
205
 
427
 
    if dir[-1] != '/':
428
 
        dir += '/'
 
206
    if dir[-1] != os.sep:
 
207
        dir += os.sep
429
208
 
430
209
    return fname.startswith(dir)
431
210
 
439
218
        return False
440
219
 
441
220
 
442
 
def is_inside_or_parent_of_any(dir_list, fname):
443
 
    """True if fname is a child or a parent of any of the given files."""
444
 
    for dirname in dir_list:
445
 
        if is_inside(dirname, fname) or is_inside(fname, dirname):
446
 
            return True
447
 
    else:
448
 
        return False
449
 
 
450
 
 
451
221
def pumpfile(fromfile, tofile):
452
222
    """Copy contents of one file to another."""
453
 
    BUFSIZE = 32768
454
 
    while True:
455
 
        b = fromfile.read(BUFSIZE)
456
 
        if not b:
457
 
            break
458
 
        tofile.write(b)
459
 
 
460
 
 
461
 
def file_iterator(input_file, readsize=32768):
462
 
    while True:
463
 
        b = input_file.read(readsize)
464
 
        if len(b) == 0:
465
 
            break
466
 
        yield b
 
223
    tofile.write(fromfile.read())
467
224
 
468
225
 
469
226
def sha_file(f):
502
259
            'sha1': s.hexdigest()}
503
260
 
504
261
 
 
262
def config_dir():
 
263
    """Return per-user configuration directory.
 
264
 
 
265
    By default this is ~/.bzr.conf/
 
266
    
 
267
    TODO: Global option --config-dir to override this.
 
268
    """
 
269
    return os.path.join(os.path.expanduser("~"), ".bzr.conf")
 
270
 
 
271
 
 
272
def _auto_user_id():
 
273
    """Calculate automatic user identification.
 
274
 
 
275
    Returns (realname, email).
 
276
 
 
277
    Only used when none is set in the environment or the id file.
 
278
 
 
279
    This previously used the FQDN as the default domain, but that can
 
280
    be very slow on machines where DNS is broken.  So now we simply
 
281
    use the hostname.
 
282
    """
 
283
    import socket
 
284
 
 
285
    # XXX: Any good way to get real user name on win32?
 
286
 
 
287
    try:
 
288
        import pwd
 
289
        uid = os.getuid()
 
290
        w = pwd.getpwuid(uid)
 
291
        gecos = w.pw_gecos.decode(bzrlib.user_encoding)
 
292
        username = w.pw_name.decode(bzrlib.user_encoding)
 
293
        comma = gecos.find(',')
 
294
        if comma == -1:
 
295
            realname = gecos
 
296
        else:
 
297
            realname = gecos[:comma]
 
298
        if not realname:
 
299
            realname = username
 
300
 
 
301
    except ImportError:
 
302
        import getpass
 
303
        realname = username = getpass.getuser().decode(bzrlib.user_encoding)
 
304
 
 
305
    return realname, (username + '@' + socket.gethostname())
 
306
 
 
307
 
 
308
def _get_user_id(branch):
 
309
    """Return the full user id from a file or environment variable.
 
310
 
 
311
    e.g. "John Hacker <jhacker@foo.org>"
 
312
 
 
313
    branch
 
314
        A branch to use for a per-branch configuration, or None.
 
315
 
 
316
    The following are searched in order:
 
317
 
 
318
    1. $BZREMAIL
 
319
    2. .bzr/email for this branch.
 
320
    3. ~/.bzr.conf/email
 
321
    4. $EMAIL
 
322
    """
 
323
    v = os.environ.get('BZREMAIL')
 
324
    if v:
 
325
        return v.decode(bzrlib.user_encoding)
 
326
 
 
327
    if branch:
 
328
        try:
 
329
            return (branch.controlfile("email", "r") 
 
330
                    .read()
 
331
                    .decode(bzrlib.user_encoding)
 
332
                    .rstrip("\r\n"))
 
333
        except IOError, e:
 
334
            if e.errno != errno.ENOENT:
 
335
                raise
 
336
        except BzrError, e:
 
337
            pass
 
338
    
 
339
    try:
 
340
        return (open(os.path.join(config_dir(), "email"))
 
341
                .read()
 
342
                .decode(bzrlib.user_encoding)
 
343
                .rstrip("\r\n"))
 
344
    except IOError, e:
 
345
        if e.errno != errno.ENOENT:
 
346
            raise e
 
347
 
 
348
    v = os.environ.get('EMAIL')
 
349
    if v:
 
350
        return v.decode(bzrlib.user_encoding)
 
351
    else:    
 
352
        return None
 
353
 
 
354
 
 
355
def username(branch):
 
356
    """Return email-style username.
 
357
 
 
358
    Something similar to 'Martin Pool <mbp@sourcefrog.net>'
 
359
 
 
360
    TODO: Check it's reasonably well-formed.
 
361
    """
 
362
    v = _get_user_id(branch)
 
363
    if v:
 
364
        return v
 
365
    
 
366
    name, email = _auto_user_id()
 
367
    if name:
 
368
        return '%s <%s>' % (name, email)
 
369
    else:
 
370
        return email
 
371
 
 
372
 
 
373
def user_email(branch):
 
374
    """Return just the email component of a username."""
 
375
    e = _get_user_id(branch)
 
376
    if e:
 
377
        m = re.search(r'[\w+.-]+@[\w+.-]+', e)
 
378
        if not m:
 
379
            raise BzrError("%r doesn't seem to contain "
 
380
                           "a reasonable email address" % e)
 
381
        return m.group(0)
 
382
 
 
383
    return _auto_user_id()[1]
 
384
 
 
385
 
505
386
def compare_files(a, b):
506
387
    """Returns true if equal in contents"""
507
388
    BUFSIZE = 4096
526
407
        return -time.timezone
527
408
 
528
409
    
529
 
def format_date(t, offset=0, timezone='original', date_fmt=None, 
530
 
                show_offset=True):
 
410
def format_date(t, offset=0, timezone='original'):
531
411
    ## TODO: Perhaps a global option to use either universal or local time?
532
412
    ## Or perhaps just let people set $TZ?
533
413
    assert isinstance(t, float)
545
425
    else:
546
426
        raise BzrError("unsupported timezone format %r" % timezone,
547
427
                       ['options are "utc", "original", "local"'])
548
 
    if date_fmt is None:
549
 
        date_fmt = "%a %Y-%m-%d %H:%M:%S"
550
 
    if show_offset:
551
 
        offset_str = ' %+03d%02d' % (offset / 3600, (offset / 60) % 60)
552
 
    else:
553
 
        offset_str = ''
554
 
    return (time.strftime(date_fmt, tt) +  offset_str)
 
428
 
 
429
    return (time.strftime("%a %Y-%m-%d %H:%M:%S", tt)
 
430
            + ' %+03d%02d' % (offset / 3600, (offset / 60) % 60))
555
431
 
556
432
 
557
433
def compact_date(when):
563
439
    """Return size of given open file."""
564
440
    return os.fstat(f.fileno())[ST_SIZE]
565
441
 
566
 
 
567
442
# Define rand_bytes based on platform.
568
443
try:
569
444
    # Python 2.4 and later have os.urandom,
586
461
                n -= 1
587
462
            return s
588
463
 
589
 
 
590
 
ALNUM = '0123456789abcdefghijklmnopqrstuvwxyz'
591
 
def rand_chars(num):
592
 
    """Return a random string of num alphanumeric characters
593
 
    
594
 
    The result only contains lowercase chars because it may be used on 
595
 
    case-insensitive filesystems.
596
 
    """
597
 
    s = ''
598
 
    for raw_byte in rand_bytes(num):
599
 
        s += ALNUM[ord(raw_byte) % 36]
600
 
    return s
601
 
 
602
 
 
603
464
## TODO: We could later have path objects that remember their list
604
465
## decomposition (might be too tricksy though.)
605
466
 
640
501
    for f in p:
641
502
        if (f == '..') or (f == None) or (f == ''):
642
503
            raise BzrError("sorry, %r not allowed in path" % f)
643
 
    return pathjoin(*p)
644
 
 
645
 
 
646
 
@deprecated_function(zero_nine)
 
504
    return os.path.join(*p)
 
505
 
 
506
 
647
507
def appendpath(p1, p2):
648
508
    if p1 == '':
649
509
        return p2
650
510
    else:
651
 
        return pathjoin(p1, p2)
 
511
        return os.path.join(p1, p2)
652
512
    
653
513
 
 
514
def _read_config_value(name):
 
515
    """Read a config value from the file ~/.bzr.conf/<name>
 
516
    Return None if the file does not exist"""
 
517
    try:
 
518
        f = file(os.path.join(config_dir(), name), "r")
 
519
        return f.read().decode(bzrlib.user_encoding).rstrip("\r\n")
 
520
    except IOError, e:
 
521
        if e.errno == errno.ENOENT:
 
522
            return None
 
523
        raise
 
524
 
 
525
 
654
526
def split_lines(s):
655
527
    """Split s into lines, but without removing the newline characters."""
656
 
    lines = s.split('\n')
657
 
    result = [line + '\n' for line in lines[:-1]]
658
 
    if lines[-1]:
659
 
        result.append(lines[-1])
660
 
    return result
 
528
    return StringIO(s).readlines()
661
529
 
662
530
 
663
531
def hardlinks_good():
676
544
            raise
677
545
        copyfile(src, dest)
678
546
 
679
 
def delete_any(full_path):
680
 
    """Delete a file or directory."""
681
 
    try:
682
 
        os.unlink(full_path)
683
 
    except OSError, e:
684
 
    # We may be renaming a dangling inventory id
685
 
        if e.errno not in (errno.EISDIR, errno.EACCES, errno.EPERM):
686
 
            raise
687
 
        os.rmdir(full_path)
688
 
 
689
547
 
690
548
def has_symlinks():
691
549
    if hasattr(os, 'symlink'):
692
550
        return True
693
551
    else:
694
552
        return False
695
 
        
696
 
 
697
 
def contains_whitespace(s):
698
 
    """True if there are any whitespace characters in s."""
699
 
    for ch in string.whitespace:
700
 
        if ch in s:
701
 
            return True
702
 
    else:
703
 
        return False
704
 
 
705
 
 
706
 
def contains_linebreaks(s):
707
 
    """True if there is any vertical whitespace in s."""
708
 
    for ch in '\f\n\r':
709
 
        if ch in s:
710
 
            return True
711
 
    else:
712
 
        return False
713
 
 
714
 
 
715
 
def relpath(base, path):
716
 
    """Return path relative to base, or raise exception.
717
 
 
718
 
    The path may be either an absolute path or a path relative to the
719
 
    current working directory.
720
 
 
721
 
    os.path.commonprefix (python2.4) has a bad bug that it works just
722
 
    on string prefixes, assuming that '/u' is a prefix of '/u2'.  This
723
 
    avoids that problem.
724
 
    """
725
 
 
726
 
    assert len(base) >= MIN_ABS_PATHLENGTH, ('Length of base must be equal or'
727
 
        ' exceed the platform minimum length (which is %d)' % 
728
 
        MIN_ABS_PATHLENGTH)
729
 
 
730
 
    rp = abspath(path)
731
 
 
732
 
    s = []
733
 
    head = rp
734
 
    while len(head) >= len(base):
735
 
        if head == base:
736
 
            break
737
 
        head, tail = os.path.split(head)
738
 
        if tail:
739
 
            s.insert(0, tail)
740
 
    else:
741
 
        raise PathNotChild(rp, base)
742
 
 
743
 
    if s:
744
 
        return pathjoin(*s)
745
 
    else:
746
 
        return ''
747
 
 
748
 
 
749
 
def safe_unicode(unicode_or_utf8_string):
750
 
    """Coerce unicode_or_utf8_string into unicode.
751
 
 
752
 
    If it is unicode, it is returned.
753
 
    Otherwise it is decoded from utf-8. If a decoding error
754
 
    occurs, it is wrapped as a If the decoding fails, the exception is wrapped 
755
 
    as a BzrBadParameter exception.
756
 
    """
757
 
    if isinstance(unicode_or_utf8_string, unicode):
758
 
        return unicode_or_utf8_string
759
 
    try:
760
 
        return unicode_or_utf8_string.decode('utf8')
761
 
    except UnicodeDecodeError:
762
 
        raise BzrBadParameterNotUnicode(unicode_or_utf8_string)
763
 
 
764
 
 
765
 
_platform_normalizes_filenames = False
766
 
if sys.platform == 'darwin':
767
 
    _platform_normalizes_filenames = True
768
 
 
769
 
 
770
 
def normalizes_filenames():
771
 
    """Return True if this platform normalizes unicode filenames.
772
 
 
773
 
    Mac OSX does, Windows/Linux do not.
774
 
    """
775
 
    return _platform_normalizes_filenames
776
 
 
777
 
 
778
 
def _accessible_normalized_filename(path):
779
 
    """Get the unicode normalized path, and if you can access the file.
780
 
 
781
 
    On platforms where the system normalizes filenames (Mac OSX),
782
 
    you can access a file by any path which will normalize correctly.
783
 
    On platforms where the system does not normalize filenames 
784
 
    (Windows, Linux), you have to access a file by its exact path.
785
 
 
786
 
    Internally, bzr only supports NFC/NFKC normalization, since that is 
787
 
    the standard for XML documents.
788
 
 
789
 
    So return the normalized path, and a flag indicating if the file
790
 
    can be accessed by that path.
791
 
    """
792
 
 
793
 
    return unicodedata.normalize('NFKC', path), True
794
 
 
795
 
 
796
 
def _inaccessible_normalized_filename(path):
797
 
    __doc__ = _accessible_normalized_filename.__doc__
798
 
 
799
 
    normalized = unicodedata.normalize('NFKC', path) 
800
 
    return normalized, normalized == path
801
 
 
802
 
 
803
 
if _platform_normalizes_filenames:
804
 
    normalized_filename = _accessible_normalized_filename
805
 
else:
806
 
    normalized_filename = _inaccessible_normalized_filename
807
 
 
808
 
 
809
 
def terminal_width():
810
 
    """Return estimated terminal width."""
811
 
    if sys.platform == 'win32':
812
 
        import bzrlib.win32console
813
 
        return bzrlib.win32console.get_console_size()[0]
814
 
    width = 0
815
 
    try:
816
 
        import struct, fcntl, termios
817
 
        s = struct.pack('HHHH', 0, 0, 0, 0)
818
 
        x = fcntl.ioctl(1, termios.TIOCGWINSZ, s)
819
 
        width = struct.unpack('HHHH', x)[1]
820
 
    except IOError:
821
 
        pass
822
 
    if width <= 0:
823
 
        try:
824
 
            width = int(os.environ['COLUMNS'])
825
 
        except:
826
 
            pass
827
 
    if width <= 0:
828
 
        width = 80
829
 
 
830
 
    return width
831
 
 
832
 
def supports_executable():
833
 
    return sys.platform != "win32"
834
 
 
835
 
 
836
 
_validWin32PathRE = re.compile(r'^([A-Za-z]:[/\\])?[^:<>*"?\|]*$')
837
 
 
838
 
 
839
 
def check_legal_path(path):
840
 
    """Check whether the supplied path is legal.  
841
 
    This is only required on Windows, so we don't test on other platforms
842
 
    right now.
843
 
    """
844
 
    if sys.platform != "win32":
845
 
        return
846
 
    if _validWin32PathRE.match(path) is None:
847
 
        raise IllegalPath(path)
848
 
 
849
 
 
850
 
def walkdirs(top, prefix=""):
851
 
    """Yield data about all the directories in a tree.
852
 
    
853
 
    This yields all the data about the contents of a directory at a time.
854
 
    After each directory has been yielded, if the caller has mutated the list
855
 
    to exclude some directories, they are then not descended into.
856
 
    
857
 
    The data yielded is of the form:
858
 
    [(relpath, basename, kind, lstat, path_from_top), ...]
859
 
 
860
 
    :param prefix: Prefix the relpaths that are yielded with 'prefix'. This 
861
 
        allows one to walk a subtree but get paths that are relative to a tree
862
 
        rooted higher up.
863
 
    :return: an iterator over the dirs.
864
 
    """
865
 
    lstat = os.lstat
866
 
    pending = []
867
 
    _directory = _directory_kind
868
 
    _listdir = listdir
869
 
    pending = [(prefix, "", _directory, None, top)]
870
 
    while pending:
871
 
        dirblock = []
872
 
        currentdir = pending.pop()
873
 
        # 0 - relpath, 1- basename, 2- kind, 3- stat, 4-toppath
874
 
        top = currentdir[4]
875
 
        if currentdir[0]:
876
 
            relroot = currentdir[0] + '/'
877
 
        else:
878
 
            relroot = ""
879
 
        for name in sorted(_listdir(top)):
880
 
            abspath = top + '/' + name
881
 
            statvalue = lstat(abspath)
882
 
            dirblock.append ((relroot + name, name, file_kind_from_stat_mode(statvalue.st_mode), statvalue, abspath))
883
 
        yield dirblock
884
 
        # push the user specified dirs from dirblock
885
 
        for dir in reversed(dirblock):
886
 
            if dir[2] == _directory:
887
 
                pending.append(dir)
888
 
 
889
 
 
890
 
def path_prefix_key(path):
891
 
    """Generate a prefix-order path key for path.
892
 
 
893
 
    This can be used to sort paths in the same way that walkdirs does.
894
 
    """
895
 
    return (dirname(path) , path)
896
 
 
897
 
 
898
 
def compare_paths_prefix_order(path_a, path_b):
899
 
    """Compare path_a and path_b to generate the same order walkdirs uses."""
900
 
    key_a = path_prefix_key(path_a)
901
 
    key_b = path_prefix_key(path_b)
902
 
    return cmp(key_a, key_b)