Mercurial > libervia-backend
view frontends/src/jp/cmd_file.py @ 1582:a41cc0849008
primitivus: partly reverted commit 641cfd2faefe :
- showDialog is actually still used and useful
- updated the code to use the widget argument in removePopup
author | Goffi <goffi@goffi.org> |
---|---|
date | Fri, 13 Nov 2015 16:45:56 +0100 |
parents | 069ad98b360d |
children | de785fcf9a7b |
line wrap: on
line source
#! /usr/bin/python # -*- coding: utf-8 -*- # jp: a SAT command line tool # Copyright (C) 2009, 2010, 2011, 2012, 2013, 2014, 2015 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 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'))