]> arthur.barton.de Git - bup.git/blobdiff - lib/bup/ls.py
get: adjust for python 3 and test there
[bup.git] / lib / bup / ls.py
index 8968d1fddfaca62b091d7af29f5695b7ec4c6ef3..bff04010f40382402c0b6cbbba1723e968f34a3f 100644 (file)
@@ -1,13 +1,17 @@
 """Common code for listing files from a bup repository."""
 
-from __future__ import print_function
+from __future__ import absolute_import
+from binascii import hexlify
 from itertools import chain
 from stat import S_ISDIR, S_ISLNK
-import copy, locale, os.path, stat, sys, xstat
+import copy, locale, os.path, stat, sys
 
-from bup import metadata, options, vfs2 as vfs
+from bup import metadata, options, vfs, xstat
+from bup.compat import argv_bytes
+from bup.io import path_msg
+from bup.options import Options
 from bup.repo import LocalRepo, RemoteRepo
-from helpers import columnate, istty1, last, log
+from bup.helpers import columnate, istty1, last, log
 
 def item_hash(item, tree_for_commit):
     """If the item is a Commit, return its commit oid, otherwise return
@@ -25,33 +29,34 @@ def item_info(item, name,
               classification = None,
               numeric_ids = False,
               human_readable = False):
-    """Return a string containing the information to display for the VFS
+    """Return bytes containing the information to display for the VFS
     item.  Classification may be "all", "type", or None.
 
     """
-    result = ''
+    result = b''
     if show_hash:
         oid = item_hash(item, commit_hash)
-        result += '%s ' % (oid.encode('hex') if oid
-                           else '0000000000000000000000000000000000000000')
+        result += b'%s ' % (hexlify(oid) if oid
+                            else b'0000000000000000000000000000000000000000')
     if long_fmt:
         meta = item.meta.copy()
         meta.path = name
         # FIXME: need some way to track fake vs real meta items?
-        result += metadata.summary_str(meta,
-                                       numeric_ids=numeric_ids,
-                                       classification=classification,
-                                       human_readable=human_readable)
+        result += metadata.summary_bytes(meta,
+                                         numeric_ids=numeric_ids,
+                                         classification=classification,
+                                         human_readable=human_readable)
     else:
         result += name
         if classification:
-            result += xstat.classification_str(vfs.item_mode(item),
-                                               classification == 'all')
+            cls = xstat.classification_str(vfs.item_mode(item),
+                                           classification == 'all')
+            result += cls.encode('iso-8859-1')
     return result
 
 
 optspec = """
-%sls [-r host:path] [-l] [-d] [-F] [-a] [-A] [-s] [-n] [path...]
+bup ls [-r host:path] [-l] [-d] [-F] [-a] [-A] [-s] [-n] [path...]
 --
 r,remote=   remote repository path
 s,hash   show hash for each file
@@ -66,75 +71,74 @@ human-readable    print human readable file sizes (i.e. 3.9K, 4.7M)
 n,numeric-ids list numeric IDs (user, group, etc.) rather than names
 """
 
-def do_ls(args, default='.', onabort=None, spec_prefix=''):
-    """Output a listing of a file or directory in the bup repository.
-
-    When a long listing is not requested and stdout is attached to a
-    tty, the output is formatted in columns. When not attached to tty
-    (for example when the output is piped to another command), one
-    file is listed per line.
+def opts_from_cmdline(args, onabort=None):
+    """Parse ls command line arguments and return a dictionary of ls
+    options, agumented with "classification", "long_listing",
+    "paths", and "show_hidden".
 
     """
     if onabort:
-        o = options.Options(optspec % spec_prefix, onabort=onabort)
+        opt, flags, extra = Options(optspec, onabort=onabort).parse(args)
     else:
-        o = options.Options(optspec % spec_prefix)
-    (opt, flags, extra) = o.parse(args)
+        opt, flags, extra = Options(optspec).parse(args)
 
-    # Handle order-sensitive options.
-    classification = None
-    show_hidden = None
+    opt.paths = [argv_bytes(x) for x in extra] or (b'/',)
+    opt.long_listing = opt.l
+    opt.classification = None
+    opt.show_hidden = None
     for flag in flags:
-        (option, parameter) = flag
+        option, parameter = flag
         if option in ('-F', '--classify'):
-            classification = 'all'
+            opt.classification = 'all'
         elif option == '--file-type':
-            classification = 'type'
+            opt.classification = 'type'
         elif option in ('-a', '--all'):
-            show_hidden = 'all'
+            opt.show_hidden = 'all'
         elif option in ('-A', '--almost-all'):
-            show_hidden = 'almost'
+            opt.show_hidden = 'almost'
+    return opt
+
+def within_repo(repo, opt, out):
 
     if opt.commit_hash:
         opt.hash = True
 
     def item_line(item, name):
         return item_info(item, name,
-                         show_hash = opt.hash,
+                         show_hash=opt.hash,
                          commit_hash=opt.commit_hash,
-                         long_fmt = opt.l,
-                         classification = classification,
-                         numeric_ids = opt.numeric_ids,
-                         human_readable = opt.human_readable)
+                         long_fmt=opt.long_listing,
+                         classification=opt.classification,
+                         numeric_ids=opt.numeric_ids,
+                         human_readable=opt.human_readable)
 
-    repo = RemoteRepo(opt.remote) if opt.remote else LocalRepo()
     ret = 0
     pending = []
-    for path in (extra or [default]):
+    for path in opt.paths:
         try:
             if opt.directory:
-                resolved = vfs.lresolve(repo, path)
+                resolved = vfs.resolve(repo, path, follow=False)
             else:
                 resolved = vfs.try_resolve(repo, path)
 
             leaf_name, leaf_item = resolved[-1]
             if not leaf_item:
                 log('error: cannot access %r in %r\n'
-                    % ('/'.join(name for name, item in resolved),
-                       path))
+                    % ('/'.join(path_msg(name) for name, item in resolved),
+                       path_msg(path)))
                 ret = 1
                 continue
             if not opt.directory and S_ISDIR(vfs.item_mode(leaf_item)):
                 items = vfs.contents(repo, leaf_item)
-                if show_hidden == 'all':
+                if opt.show_hidden == 'all':
                     # Match non-bup "ls -a ... /".
                     parent = resolved[-2] if len(resolved) > 1 else resolved[0]
-                    items = chain(items, (('..', parent[1]),))
+                    items = chain(items, ((b'..', parent[1]),))
                 for sub_name, sub_item in sorted(items, key=lambda x: x[0]):
-                    if show_hidden != 'all' and sub_name == '.':
+                    if opt.show_hidden != 'all' and sub_name == b'.':
                         continue
-                    if sub_name.startswith('.') and \
-                       show_hidden not in ('almost', 'all'):
+                    if sub_name.startswith(b'.') and \
+                       opt.show_hidden not in ('almost', 'all'):
                         continue
                     if opt.l:
                         sub_item = vfs.ensure_item_has_metadata(repo, sub_item,
@@ -143,17 +147,39 @@ def do_ls(args, default='.', onabort=None, spec_prefix=''):
                         sub_item = vfs.augment_item_meta(repo, sub_item,
                                                          include_size=True)
                     line = item_line(sub_item, sub_name)
-                    pending.append(line) if not opt.l and istty1 else print(line)
+                    if not opt.long_listing and istty1:
+                        pending.append(line)
+                    else:
+                        out.write(line)
+                        out.write(b'\n')
             else:
                 leaf_item = vfs.augment_item_meta(repo, leaf_item,
                                                   include_size=True)
                 line = item_line(leaf_item, os.path.normpath(path))
-                pending.append(line) if not opt.l and istty1 else print(line)
+                if not opt.long_listing and istty1:
+                    pending.append(line)
+                else:
+                    out.write(line)
+                    out.write(b'\n')
         except vfs.IOError as ex:
             log('bup: %s\n' % ex)
             ret = 1
 
     if pending:
-        sys.stdout.write(columnate(pending, ''))
+        out.write(columnate(pending, b''))
 
     return ret
+
+def via_cmdline(args, out=None, onabort=None):
+    """Write a listing of a file or directory in the bup repository to out.
+
+    When a long listing is not requested and stdout is attached to a
+    tty, the output is formatted in columns. When not attached to tty
+    (for example when the output is piped to another command), one
+    file is listed per line.
+
+    """
+    assert out
+    opt = opts_from_cmdline(args, onabort=onabort)
+    repo = RemoteRepo(argv_bytes(opt.remote)) if opt.remote else LocalRepo()
+    return within_repo(repo, opt, out)