diff frontends/src/jp/cmd_file.py @ 817:c39117d00f35

jp: refactoring: - imports from sat_frontends.jp instead of local imports - added __init__.py - commands now inherits from a base class: each base.CommandBase instance is a subcommand - new arguments are added in CommandBase.add_parser_options methods, starting point si CommandBase.run or CommandBase.connected if a profile connection is needed - commands are exported using a __commands__ variable at the top of the module - sub-subcommand are easily added by using an other CommandBase instance as parent instead of using a Jp instance. In this case, the parent subcommand must be the one exported, and have a subcommands iterable (see cmd_file or cmd_pipe for examples). - options which are often used (like --profile) are automatically added on demand (use_profile=True, use_progress=True) - commands are automatically loaded when there are in a module named cmd_XXX - restored --connect option - restored progress bar - restored getVersion bridge call on jp --version - fixed file and pipe commands - fixed forgotten translations - fixed non SàT compliant docstrings - better about/version dialog
author Goffi <goffi@goffi.org>
date Mon, 10 Feb 2014 13:44:09 +0100
parents frontends/src/jp/file.py@f8d534ed1d1e
children 300b4de701a6
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/frontends/src/jp/cmd_file.py	Mon Feb 10 13:44:09 2014 +0100
@@ -0,0 +1,126 @@
+#! /usr/bin/python
+# -*- coding: utf-8 -*-
+
+# jp: a SAT command line tool
+# Copyright (C) 2009, 2010, 2011, 2012, 2013, 2014 Jérôme Poisson (goffi@goffi.org)
+
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU Affero General Public License for more details.
+
+# You should have received a copy of the GNU Affero General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+from logging import debug, info, error, warning
+
+import base
+import sys
+import os
+import os.path
+import tarfile
+#import tempfile
+from sat.core.i18n import _
+
+__commands__ = ["File"]
+
+class Send(base.CommandBase):
+    def __init__(self, host):
+        super(Send, self).__init__(host, 'send', use_progress=True, help=_('Send a file to a contact'))
+
+    def add_parser_options(self):
+        self.parser.add_argument("files", type=str, nargs = '+', help=_("A list of file"))
+        self.parser.add_argument("jid", type=base.unicode_decoder, help=_("The destination jid"))
+        self.parser.add_argument("-b", "--bz2", action="store_true", help=_("Make a bzip2 tarball"))
+
+    def connected(self):
+        """Send files to jabber contact"""
+        self.need_loop=True
+        super(Send, self).connected()
+        self.send_files()
+
+    def send_files(self):
+
+        for file_ in self.args.files:
+            if not os.path.exists(file_):
+                error (_(u"file [%s] doesn't exist !") % file_)
+                self.host.quit(1)
+            if not self.args.bz2 and os.path.isdir(file_):
+                error (_("[%s] is a dir ! Please send files inside or use compression") % file_)
+                self.host.quit(1)
+
+        full_dest_jid = self.host.get_full_jid(self.args.jid)
+
+        if self.args.bz2:
+            tmpfile = (os.path.basename(self.args.files[0]) or os.path.basename(os.path.dirname(self.args.files[0])) ) + '.tar.bz2' #FIXME: tmp, need an algorithm to find a good name/path
+            if os.path.exists(tmpfile):
+                error (_("tmp file_ (%s) already exists ! Please remove it"), tmpfile)
+                exit(1)
+            warning(_("bz2 is an experimental option at an early dev stage, use with caution"))
+            #FIXME: check free space, writting perm, tmp dir, filename (watch for OS used)
+            print _(u"Starting compression, please wait...")
+            sys.stdout.flush()
+            bz2 = tarfile.open(tmpfile, "w:bz2")
+            for file_ in self.args.files:
+                print _(u"Adding %s") % file_
+                bz2.add(file_)
+            bz2.close()
+            print _(u"Done !")
+            path = os.path.abspath(tmpfile)
+            self.progress_id = self.host.bridge.sendFile(full_dest_jid, path, {}, self.profile)
+        else:
+            for file_ in self.args.files:
+                path = os.path.abspath(file_)
+                self.progress_id = self.host.bridge.sendFile(full_dest_jid, path, {}, self.profile) #FIXME: show progress only for last progress_id
+
+
+class Receive(base.CommandAnswering):
+    confirm_type = "FILE_TRANSFER"
+
+    def __init__(self, host):
+        super(Receive, self).__init__(host, 'recv', use_progress=True, help=_('Wait for a file to be sent by a contact'))
+
+    @property
+    def dest_jids(self):
+        return self.args.jids
+
+    def add_parser_options(self):
+        self.parser.add_argument("jids", type=base.unicode_decoder, nargs="*", help=_('Jids accepted (none means "accept everything")'))
+        self.parser.add_argument("-m", "--multiple", action="store_true", help=_("Accept multiple files (you'll have to stop manually)"))
+        self.parser.add_argument("-f", "--force", action="store_true", help=_("Force overwritting of existing files"))
+
+
+    def ask(self, data, confirm_id):
+        answer_data = {}
+        answer_data["dest_path"] = os.path.join(os.getcwd(), data['filename'])
+
+        if self.args.force or not os.path.exists(answer_data["dest_path"]):
+            self.host.bridge.confirmationAnswer(confirm_id, True, answer_data, self.profile)
+            info(_("Accepted file [%(filename)s] from %(sender)s") % {'filename':data['filename'], 'sender':data['from']})
+            self.progress_id = confirm_id
+        else:
+            self.host.bridge.confirmationAnswer(confirm_id, False, answer_data, self.profile)
+            warning(_("Refused file [%(filename)s] from %(sender)s: a file with the same name already exist") % {'filename':data['filename'], 'sender':data['from']})
+            if not self.args.multiple:
+                self.host.quit()
+
+        if not self.args.multiple and not self.args.progress:
+            #we just accept one file
+            self.host.quit()
+
+    def run(self):
+        super(Receive, self).run()
+        if self.args.multiple:
+            self.host.quit_on_progress_end = False
+
+
+class File(base.CommandBase):
+    subcommands = (Send, Receive)
+
+    def __init__(self, host):
+        super(File, self).__init__(host, 'file', use_profile=False, help=_('File sending/receiving'))