Mercurial > libervia-backend

comparison frontends/src/jp/cmd_pipe.py @ 817:c39117d00f35

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
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/pipe.py@f8d534ed1d1e
children 069ad98b360d
comparison
equal deleted inserted replaced
816:4429bd7d5efb 817:c39117d00f35
1 #! /usr/bin/python
2 # -*- coding: utf-8 -*-
3
4 # jp: a SAT command line tool
5 # Copyright (C) 2009, 2010, 2011, 2012, 2013, 2014 Jérôme Poisson (goffi@goffi.org)
6
7 # This program is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU Affero General Public License as published by
9 # the Free Software Foundation, either version 3 of the License, or
10 # (at your option) any later version.
11
12 # This program is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU Affero General Public License for more details.
16
17 # You should have received a copy of the GNU Affero General Public License
18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
19
20 from sat_frontends.jp import base
21
22 import tempfile
23 import sys
24 import os
25 import os.path
26 import shutil
27 from sat.core.i18n import _
28
29 __commands__ = ["Pipe"]
30
31 class PipeOut(base.CommandBase):
32
33 def __init__(self, host):
34 super(PipeOut, self).__init__(host, 'out', help=_('Pipe a stream out'))
35
36 def add_parser_options(self):
37 self.parser.add_argument("jid", type=base.unicode_decoder, help=_("The destination jid"))
38
39 def pipe_out(self):
40 """ Create named pipe, and send stdin to it """
41 tmp_dir = tempfile.mkdtemp()
42 fifopath = os.path.join(tmp_dir,"pipe_out")
43 os.mkfifo(fifopath)
44 self.host.bridge.pipeOut(self.host.get_full_jid(self.args.jid), fifopath, {}, self.profile)
45 with open(fifopath, 'w') as f:
46 shutil.copyfileobj(sys.stdin, f)
47 shutil.rmtree(tmp_dir)
48 self.host.quit()
49
50 def connected(self):
51 # TODO: check_jids
52 self.need_loop = True
53 super(PipeOut, self).connected()
54 self.pipe_out()
55
56
57 class PipeIn(base.CommandAnswering):
58 confirm_type = "PIPE_TRANSFER"
59
60 def __init__(self, host):
61 super(PipeIn, self).__init__(host, 'in', help=_('Wait for the reception of a pipe stream'))
62
63 @property
64 def dest_jids(self):
65 return self.args.jids
66
67 def add_parser_options(self):
68 self.parser.add_argument("jids", type=base.unicode_decoder, nargs="*", help=_('Jids accepted (none means "accept everything")'))
69
70 def ask(self, data, confirm_id):
71 answer_data = {}
72 tmp_dir = tempfile.mkdtemp()
73 fifopath = os.path.join(tmp_dir,"pipe_in")
74 answer_data["dest_path"] = fifopath
75 os.mkfifo(fifopath)
76 self.host.bridge.confirmationAnswer(confirm_id, True, answer_data, self.profile)
77 with open(fifopath, 'r') as f:
78 shutil.copyfileobj(f, sys.stdout)
79 shutil.rmtree(tmp_dir)
80 self.host.quit()
81
82
83 class Pipe(base.CommandBase):
84 subcommands = (PipeOut, PipeIn)
85
86 def __init__(self, host):
87 super(Pipe, self).__init__(host, 'pipe', use_profile=False, help=_('Stream piping through XMPP'))