libervia-backend: sat_frontends/jp/cmd

annotate sat_frontends/jp/cmd_pipe.py @ 2617:81b70eeb710f

quick_frontend(contact list): refactored update: update is now called with appropriate constant value (C.UPDATE_ADD, C.UPDATE_DELETE, C.UPDATE_MODIFY and so on) when a widget change visibility according to current options. Before it was linked to cache only (C.UPDATE_ADD was only called when contact was first added to cache). This make widget handling in frontends more easy. Renamed entityToShow to entityVisible, which seems to correspond better. Started reducing lines lenght to 90 chars as a test. May become the new coding style soon.

author	Goffi <goffi@goffi.org>
date	Sun, 24 Jun 2018 21:59:29 +0200
parents	26edcf3a30eb
children	56f94936df1e

rev	line source
1960 3e168cde7a7d jp: fixed shebang python call Goffi <goffi@goffi.org> parents: 1864 diff changeset	1 #!/usr/bin/env python2
815 f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	2 # -- coding: utf-8 --
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	3
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	4 # jp: a SAT command line tool
2483 0046283a285d dates update Goffi <goffi@goffi.org> parents: 2414 diff changeset	5 # Copyright (C) 2009-2018 Jérôme Poisson (goffi@goffi.org)
815 f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	6
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	7 # This program is free software: you can redistribute it and/or modify
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	10 # (at your option) any later version.
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	11
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	12 # This program is distributed in the hope that it will be useful,
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	15 # GNU Affero General Public License for more details.
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	16
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	17 # You should have received a copy of the GNU Affero General Public License
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
f8d534ed1d1e jp: added missing license headers Goffi <goffi@goffi.org> parents: 814 diff changeset	19
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	20 from sat_frontends.jp import base
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	21
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	22 from sat_frontends.jp.constants import Const as C
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	23 import sys
814 59c7bc51c323 jp: refactoring using ArgParse Dal <kedals0@gmail.com> parents: 811 diff changeset	24 from sat.core.i18n import _
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	25 from sat_frontends.tools import jid
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	26 import xml.etree.ElementTree as ET # FIXME: used temporarily to manage XMLUI
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	27 from functools import partial
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	28 import socket
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	29 import SocketServer
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	30 import errno
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	31
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	32 __commands__ = ["Pipe"]
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	33
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	34 START_PORT = 9999
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	35
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	36 class PipeOut(base.CommandBase):
657 09bbd5c00244 jp: profiles management Dal <kedals0@gmail.com> parents: 627 diff changeset	37
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	38 def __init__(self, host):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	39 super(PipeOut, self).__init__(host, 'out', help=_('send a pipe a stream'))
1864 96ba685162f6 jp: all commands now use the new start method and set need_loop in __init__ when needed Goffi <goffi@goffi.org> parents: 1766 diff changeset	40 self.need_loop = True
393 393b35aa86d2 jp: added --connect option Goffi <goffi@goffi.org> parents: 391 diff changeset	41
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	42 def add_parser_options(self):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	43 self.parser.add_argument("jid", type=base.unicode_decoder, help=_("the destination jid"))
401 b2caa2615c4c jp roster name manegement + Pipe transfer Goffi <goffi@goffi.org> parents: 393 diff changeset	44
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	45 def streamOutCb(self, port):
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	46 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	47 s.connect(('127.0.0.1', int(port)))
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	48 while True:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	49 buf = sys.stdin.read(4096)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	50 if not buf:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	51 break
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	52 try:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	53 s.sendall(buf)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	54 except socket.error as e:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	55 if e.errno == errno.EPIPE:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	56 sys.stderr.write(str(e) + '\n')
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	57 self.host.quit(1)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	58 else:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	59 raise e
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	60 self.host.quit()
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	61
1864 96ba685162f6 jp: all commands now use the new start method and set need_loop in __init__ when needed Goffi <goffi@goffi.org> parents: 1766 diff changeset	62 def start(self):
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	63 """ Create named pipe, and send stdin to it """
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	64 self.host.bridge.streamOut(
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	65 self.host.get_full_jid(self.args.jid),
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	66 self.profile,
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	67 callback=self.streamOutCb,
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	68 errback=partial(self.errback,
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	69 msg=_(u"can't start stream: {}"),
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	70 exit_code=C.EXIT_BRIDGE_ERRBACK))
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	71
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	72
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	73 class StreamServer(SocketServer.BaseRequestHandler):
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	74
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	75 def handle(self):
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	76 while True:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	77 data = self.request.recv(4096)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	78 if not data:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	79 break
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	80 sys.stdout.write(data)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	81 try:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	82 sys.stdout.flush()
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	83 except IOError as e:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	84 sys.stderr.write(str(e) + '\n')
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	85 break
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	86 # calling shutdown will do a deadlock as we don't use separate thread
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	87 # this is a workaround (cf. https://stackoverflow.com/a/36017741)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	88 self.server._BaseServer__shutdown_request = True
401 b2caa2615c4c jp roster name manegement + Pipe transfer Goffi <goffi@goffi.org> parents: 393 diff changeset	89
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	90
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	91 class PipeIn(base.CommandAnswering):
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	92
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	93 def __init__(self, host):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	94 super(PipeIn, self).__init__(host, 'in', help=_('receive a pipe stream'))
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	95 self.action_callbacks = {"STREAM": self.onStreamAction}
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 572 diff changeset	96
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	97 def add_parser_options(self):
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	98 self.parser.add_argument("jids", type=base.unicode_decoder, nargs="*", help=_('Jids accepted (none means "accept everything")'))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	99
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	100 def getXmluiId(self, action_data):
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	101 # FIXME: we temporarily use ElementTree, but a real XMLUI managing module
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	102 # should be available in the future
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	103 # TODO: XMLUI module
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	104 try:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	105 xml_ui = action_data['xmlui']
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	106 except KeyError:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	107 self.disp(_(u"Action has no XMLUI"), 1)
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	108 else:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	109 ui = ET.fromstring(xml_ui.encode('utf-8'))
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	110 xmlui_id = ui.get('submit')
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	111 if not xmlui_id:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	112 self.disp(_(u"Invalid XMLUI received"), error=True)
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	113 return xmlui_id
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	114
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	115 def onStreamAction(self, action_data, action_id, security_limit, profile):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	116 xmlui_id = self.getXmluiId(action_data)
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	117 if xmlui_id is None:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	118 return self.host.quitFromSignal(1)
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	119 try:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	120 from_jid = jid.JID(action_data['meta_from_jid'])
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	121 except KeyError:
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	122 self.disp(_(u"Ignoring action without from_jid data"), 1)
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	123 return
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	124
3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	125 if not self.bare_jids or from_jid.bare in self.bare_jids:
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	126 host, port = "localhost", START_PORT
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	127 while True:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	128 try:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	129 server = SocketServer.TCPServer((host, port), StreamServer)
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	130 except socket.error as e:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	131 if e.errno == errno.EADDRINUSE:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	132 port += 1
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	133 else:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	134 raise e
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	135 else:
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	136 break
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	137 xmlui_data = {'answer': C.BOOL_TRUE,
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	138 'port': unicode(port)}
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	139 self.host.bridge.launchAction(xmlui_id, xmlui_data, profile_key=profile)
2489 e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	140 server.serve_forever()
e2a7bb875957 plugin pipe/stream, file transfert: refactoring and improvments: Goffi <goffi@goffi.org> parents: 2483 diff changeset	141 self.host.quitFromSignal()
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	142
1864 96ba685162f6 jp: all commands now use the new start method and set need_loop in __init__ when needed Goffi <goffi@goffi.org> parents: 1766 diff changeset	143 def start(self):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	144 self.bare_jids = [jid.JID(jid_).bare for jid_ in self.args.jids]
817 c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	145
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	146
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	147 class Pipe(base.CommandBase):
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	148 subcommands = (PipeOut, PipeIn)
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	149
c39117d00f35 jp: refactoring: Goffi <goffi@goffi.org> parents: 815 diff changeset	150 def __init__(self, host):
1670 3690b4d4157e jp (pipe): pipe commands now use the new CommandAnswering API (with actionNew) Goffi <goffi@goffi.org> parents: 1396 diff changeset	151 super(Pipe, self).__init__(host, 'pipe', use_profile=False, help=_('stream piping through XMPP'))

Mercurial > libervia-backend

annotate sat_frontends/jp/cmd_pipe.py @ 2617:81b70eeb710f