libervia-backend: src/plugins/plugin_xep

annotate src/plugins/plugin_xep_0096.py @ 1119:5968fd8d2248

primitivus: change behavior of commands ":presence" and ":status" : - ":presence " and ":status " open a dialog (like if you type it without the trailing space) - you need to type ":presence online" to directly reset your presence (was done with ":presence " before) - there's no more way to directly set an empty status (you now do it via the dialog)

author	souliane <souliane@mailoo.org>
date	Sat, 23 Aug 2014 20:11:37 +0200
parents	4dbe8e57ff51
children	9a85836f0d45

rev	line source
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	1 #!/usr/bin/python
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	2 # -- coding: utf-8 --
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	3
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	4 # SAT plugin for managing xep-0096
811 1fe00f0c9a91 dates update Goffi <goffi@goffi.org> parents: 771 diff changeset	5 # Copyright (C) 2009, 2010, 2011, 2012, 2013, 2014 Jérôme Poisson (goffi@goffi.org)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	6
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	7 # This program is free software: you can redistribute it and/or modify
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	8 # it under the terms of the GNU Affero General Public License as published by
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	9 # the Free Software Foundation, either version 3 of the License, or
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	10 # (at your option) any later version.
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	11
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	12 # This program is distributed in the hope that it will be useful,
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	15 # GNU Affero General Public License for more details.
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	16
609 84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	17 # You should have received a copy of the GNU Affero General Public License
84a6e83157c2 fixed licences in docstrings (they are now in comments) Goffi <goffi@goffi.org> parents: 594 diff changeset	18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	19
771 bfabeedbf32e core: i18n refactoring: Goffi <goffi@goffi.org> parents: 721 diff changeset	20 from sat.core.i18n import _
916 1a759096ccbd core: use of Const for profile_key + replaced '@DEFAULT@' default profile_key by '@NONE@' Goffi <goffi@goffi.org> parents: 811 diff changeset	21 from sat.core.constants import Const as C
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	22 from sat.core.log import getLogger
301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	23 log = getLogger(__name__)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	24 from twisted.words.xish import domish
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	25 from twisted.words.protocols.jabber import jid
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	26 from twisted.words.protocols import jabber
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	27 import os
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	28 from twisted.internet import reactor
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	29
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	30 from wokkel import data_form
15 218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	31
218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	32 IQ_SET = '/iq[@type="set"]'
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	33 PROFILE_NAME = "file-transfer"
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	34 PROFILE = "http://jabber.org/protocol/si/profile/" + PROFILE_NAME
15 218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	35
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	36 PLUGIN_INFO = {
721 0077912bc9ba jp: removed named argument for pipeOut, as it's not managed with dynamicaly added methods Goffi <goffi@goffi.org> parents: 638 diff changeset	37 "name": "XEP-0096 Plugin",
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	38 "import_name": "XEP-0096",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	39 "type": "XEP",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	40 "protocols": ["XEP-0096"],
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	41 "dependencies": ["XEP-0020", "XEP-0095", "XEP-0065", "XEP-0047"],
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	42 "main": "XEP_0096",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	43 "handler": "no",
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	44 "description": _("""Implementation of SI File Transfer""")
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	45 }
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	46
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	47
588 beaf6bec2fcd Remove every old-style class. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 587 diff changeset	48 class XEP_0096(object):
19 f2a745ca0fbc refactoring: using xml params part III (parameters import) Goffi <goffi@goffi.org> parents: 15 diff changeset	49
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	50 def __init__(self, host):
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	51 log.info(_("Plugin XEP_0096 initialization"))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	52 self.host = host
540 47e45a577ab7 plugin XEP-0096: restored XEP-0065 usage Goffi <goffi@goffi.org> parents: 538 diff changeset	53 self.managed_stream_m = [self.host.plugins["XEP-0065"].NAMESPACE,
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	54 self.host.plugins["XEP-0047"].NAMESPACE] # Stream methods managed
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	55 self.host.plugins["XEP-0095"].registerSIProfile(PROFILE_NAME, self.transferRequest)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	56 host.bridge.addMethod("sendFile", ".plugin", in_sign='ssa{ss}s', out_sign='s', method=self.sendFile)
15 218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	57
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	58 def profileConnected(self, profile):
2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	59 client = self.host.getClient(profile)
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	60 client._xep_0096_waiting_for_approval = {} # key = id, value = [transfer data, IdelayedCall Reactor timeout,
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	61 # current stream method, [failed stream methods], profile]
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	62
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	63 def _kill_id(self, approval_id, profile):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	64 """Delete a waiting_for_approval id, called after timeout
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	65 @param approval_id: id of _xep_0096_waiting_for_approval"""
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	66 log.info(_("SI File Transfer: TimeOut reached for id %s") % approval_id)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	67 try:
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	68 client = self.host.getClient(profile)
2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	69 del client._xep_0096_waiting_for_approval[approval_id]
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	70 except KeyError:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	71 log.warning(_("kill id called on a non existant approval id"))
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	72
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	73 def transferRequest(self, iq_id, from_jid, si_id, si_mime_type, si_el, profile):
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	74 """Called when a file transfer is requested
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	75 @param iq_id: id of the iq request
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	76 @param from_jid: jid of the sender
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	77 @param si_id: Stream Initiation session id
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	78 @param si_mime_type: Mime type of the file (or default "application/octet-stream" if unknown)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	79 @param si_el: domish.Element of the request
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	80 @param profile: %(doc_profile)s"""
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	81 log.info(_("XEP-0096 file transfer requested"))
301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	82 log.debug(si_el.toXml())
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	83 client = self.host.getClient(profile)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	84 filename = ""
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	85 file_size = ""
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	86 file_date = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	87 file_hash = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	88 file_desc = ""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	89 can_range = False
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	90 file_elts = filter(lambda elt: elt.name == 'file', si_el.elements())
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	91 feature_elts = self.host.plugins["XEP-0020"].getFeatureElt(si_el)
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	92
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	93 if file_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	94 file_el = file_elts[0]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	95 filename = file_el["name"]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	96 file_size = file_el["size"]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	97 file_date = file_el.getAttribute("date", "")
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	98 file_hash = file_el.getAttribute("hash", "")
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	99 log.info(_("File proposed: name=[%(name)s] size=%(size)s") % {'name': filename, 'size': file_size})
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	100 for file_child_el in file_el.elements():
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	101 if file_child_el.name == "desc":
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	102 file_desc = unicode(file_child_el)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	103 elif file_child_el.name == "range":
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	104 can_range = True
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	105 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	106 log.warning(_("No file element found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	107 self.host.plugins["XEP-0095"].sendBadRequestError(iq_id, from_jid, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	108 return
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	109
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	110 if feature_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	111 feature_el = feature_elts[0]
941 c6d8fc63b1db core, plugins: host.getClient now raise an exception instead of returning None when no profile is found, plugins have been adapted consequently and a bit cleaned Goffi <goffi@goffi.org> parents: 916 diff changeset	112 data_form.Form.fromElement(feature_el.firstChildElement())
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	113 try:
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	114 stream_method = self.host.plugins["XEP-0020"].negociate(feature_el, 'stream-method', self.managed_stream_m)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	115 except KeyError:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	116 log.warning(_("No stream method found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	117 self.host.plugins["XEP-0095"].sendBadRequestError(iq_id, from_jid, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	118 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	119 if not stream_method:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	120 log.warning(_("Can't find a valid stream method"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	121 self.host.plugins["XEP-0095"].sendFailedError(iq_id, from_jid, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	122 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	123 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	124 log.warning(_("No feature element found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	125 self.host.plugins["XEP-0095"].sendBadRequestError(iq_id, from_jid, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	126 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	127
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	128 #if we are here, the transfer can start, we just need user's agreement
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	129 data = {"filename": filename, "id": iq_id, "from": from_jid, "size": file_size, "date": file_date, "hash": file_hash, "desc": file_desc, "can_range": str(can_range)}
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	130 client._xep_0096_waiting_for_approval[si_id] = [data, reactor.callLater(300, self._kill_id, si_id, profile), stream_method, []]
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	131
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	132 self.host.askConfirmation(si_id, "FILE_TRANSFER", data, self.confirmationCB, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	133
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	134 def _getFileObject(self, dest_path, can_range=False):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	135 """Open file, put file pointer to the end if the file if needed
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	136 @param dest_path: path of the destination file
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	137 @param can_range: True if the file pointer can be moved
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	138 @return: File Object"""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	139 return open(dest_path, "ab" if can_range else "wb")
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	140
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	141 def confirmationCB(self, sid, accepted, frontend_data, profile):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	142 """Called on confirmation answer
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	143 @param sid: file transfer session id
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	144 @param accepted: True if file transfer is accepted
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	145 @param frontend_data: data sent by frontend"""
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	146 client = self.host.getClient(profile)
2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	147 data, timeout, stream_method, failed_methods = client._xep_0096_waiting_for_approval[sid]
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	148 can_range = data['can_range'] == "True"
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	149 range_offset = 0
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	150 if accepted:
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	151 if timeout.active():
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	152 timeout.cancel()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	153 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	154 dest_path = frontend_data['dest_path']
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	155 except KeyError:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	156 log.error(_('dest path not found in frontend_data'))
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	157 del(client._xep_0096_waiting_for_approval[sid])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	158 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	159 if stream_method == self.host.plugins["XEP-0065"].NAMESPACE:
394 8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	160 file_obj = self._getFileObject(dest_path, can_range)
8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	161 range_offset = file_obj.tell()
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	162 self.host.plugins["XEP-0065"].prepareToReceive(jid.JID(data['from']), sid, file_obj, int(data["size"]), self._transferSucceeded, self._transferFailed, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	163 elif stream_method == self.host.plugins["XEP-0047"].NAMESPACE:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	164 file_obj = self._getFileObject(dest_path, can_range)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	165 range_offset = file_obj.tell()
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	166 self.host.plugins["XEP-0047"].prepareToReceive(jid.JID(data['from']), sid, file_obj, int(data["size"]), self._transferSucceeded, self._transferFailed, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	167 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	168 log.error(_("Unknown stream method, this should not happen at this stage, cancelling transfer"))
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	169 del(client._xep_0096_waiting_for_approval[sid])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	170 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	171
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	172 #we can send the iq result
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	173 feature_elt = self.host.plugins["XEP-0020"].chooseOption({'stream-method': stream_method})
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	174 misc_elts = []
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	175 misc_elts.append(domish.Element((PROFILE, "file")))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	176 if can_range:
536 a31abb97310d core, plugins: fixed bad namespace in stanza creation Goffi <goffi@goffi.org> parents: 480 diff changeset	177 range_elt = domish.Element((None, "range"))
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	178 range_elt['offset'] = str(range_offset)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	179 #TODO: manage range length
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	180 misc_elts.append(range_elt)
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	181 self.host.plugins["XEP-0095"].acceptStream(data["id"], data['from'], feature_elt, misc_elts, profile)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	182 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	183 log.debug(_("Transfer [%s] refused"), sid)
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	184 self.host.plugins["XEP-0095"].sendRejectedError(data["id"], data['from'], profile=profile)
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	185 del(client._xep_0096_waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	186
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	187 def _transferSucceeded(self, sid, file_obj, stream_method, profile):
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	188 """Called by the stream method when transfer successfuly finished
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	189 @param id: stream id"""
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	190 client = self.host.getClient(profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	191 file_obj.close()
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	192 log.info(_('Transfer %s successfuly finished') % sid)
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	193 del(client._xep_0096_waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	194
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	195 def _transferFailed(self, sid, file_obj, stream_method, reason, profile):
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	196 """Called when something went wrong with the transfer
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	197 @param id: stream id
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	198 @param reason: can be TIMEOUT, IO_ERROR, PROTOCOL_ERROR"""
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	199 client = self.host.getClient(profile)
2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	200 data, timeout, stream_method, failed_methods = client._xep_0096_waiting_for_approval[sid]
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	201 log.warning(_('Transfer %(id)s failed with stream method %(s_method)s: %(reason)s') % {
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	202 'id': sid,
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	203 's_method': stream_method,
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	204 'reason': reason})
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	205 filepath = file_obj.name
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	206 file_obj.close()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	207 os.remove(filepath)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	208 #TODO: session remenber (within a time limit) when a stream method fail, and avoid that stream method with full jid for the rest of the session
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	209 log.warning(_("All stream methods failed, can't transfer the file"))
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	210 del(client._xep_0096_waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	211
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	212 def fileCb(self, filepath, sid, size, profile, IQ):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	213 if IQ['type'] == "error":
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	214 stanza_err = jabber.error.exceptionFromStanza(IQ)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	215 if stanza_err.code == '403' and stanza_err.condition == 'forbidden':
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	216 log.debug(_("File transfer refused by %s") % IQ['from'])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	217 self.host.bridge.newAlert(_("The contact %s refused your file") % IQ['from'], _("File refused"), "INFO", profile)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	218 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	219 log.warning(_("Error during file transfer with %s") % IQ['from'])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	220 self.host.bridge.newAlert(_("Something went wrong during the file transfer session intialisation with %s") % IQ['from'], _("File transfer error"), "ERROR", profile)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	221 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	222
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	223 si_elt = IQ.firstChildElement()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	224
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	225 if IQ['type'] != "result" or not si_elt or si_elt.name != "si":
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	226 log.error(_("Protocol error during file transfer"))
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	227 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	228
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	229 feature_elts = self.host.plugins["XEP-0020"].getFeatureElt(si_elt)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	230 if not feature_elts:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	231 log.warning(_("No feature element"))
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	232 return
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	233
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	234 choosed_options = self.host.plugins["XEP-0020"].getChoosedOptions(feature_elts[0])
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	235 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	236 stream_method = choosed_options["stream-method"]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	237 except KeyError:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	238 log.warning(_("No stream method choosed"))
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	239 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	240
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	241 range_offset = 0
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	242 range_length = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	243 range_elts = filter(lambda elt: elt.name == 'range', si_elt.elements())
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	244 if range_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	245 range_elt = range_elts[0]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	246 range_offset = range_elt.getAttribute("offset", 0)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	247 range_length = range_elt.getAttribute("length")
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	248
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	249 if stream_method == self.host.plugins["XEP-0065"].NAMESPACE:
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	250 file_obj = open(filepath, 'r')
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	251 if range_offset:
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	252 file_obj.seek(range_offset)
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	253 self.host.plugins["XEP-0065"].startStream(file_obj, jid.JID(IQ['from']), sid, range_length, self.sendSuccessCb, self.sendFailureCb, size, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	254 elif stream_method == self.host.plugins["XEP-0047"].NAMESPACE:
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	255 file_obj = open(filepath, 'r')
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	256 if range_offset:
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	257 file_obj.seek(range_offset)
e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	258 self.host.plugins["XEP-0047"].startStream(file_obj, jid.JID(IQ['from']), sid, range_length, self.sendSuccessCb, self.sendFailureCb, size, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	259 else:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	260 log.warning(_("Invalid stream method received"))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	261
916 1a759096ccbd core: use of Const for profile_key + replaced '@DEFAULT@' default profile_key by '@NONE@' Goffi <goffi@goffi.org> parents: 811 diff changeset	262 def sendFile(self, to_jid, filepath, data={}, profile_key=C.PROF_KEY_NONE):
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	263 """send a file using XEP-0096
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	264 @to_jid: recipient
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	265 @filepath: absolute path to the file to send
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	266 @data: dictionnary with the optional following keys:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	267 - "description": description of the file
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	268 @param profile_key: %(doc_profile_key)s
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	269 @return: an unique id to identify the transfer
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	270 """
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	271 profile = self.host.memory.getProfileName(profile_key)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	272 if not profile:
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	273 log.warning(_("Trying to send a file from an unknown profile"))
64 d46f849664aa SàT: multi-profile, plugins updated Goffi <goffi@goffi.org> parents: 57 diff changeset	274 return ""
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	275 feature_elt = self.host.plugins["XEP-0020"].proposeFeatures({'stream-method': self.managed_stream_m})
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	276
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	277 file_transfer_elts = []
587 952322b1d490 Remove trailing whitespaces. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 585 diff changeset	278
995 4dbe8e57ff51 plugin XEP-0096: fixed a bug introduced by the log refactoring Goffi <goffi@goffi.org> parents: 993 diff changeset	279 statinfo = os.stat(filepath)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	280 file_elt = domish.Element((PROFILE, 'file'))
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	281 file_elt['name'] = os.path.basename(filepath)
995 4dbe8e57ff51 plugin XEP-0096: fixed a bug introduced by the log refactoring Goffi <goffi@goffi.org> parents: 993 diff changeset	282 size = file_elt['size'] = str(statinfo.st_size)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	283 file_transfer_elts.append(file_elt)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	284
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	285 file_transfer_elts.append(domish.Element((None, 'range')))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	286
594 e629371a28d3 Fix pep8 support in src/plugins. Emmanuel Gil Peyrot <linkmauve@linkmauve.fr> parents: 588 diff changeset	287 sid, offer = self.host.plugins["XEP-0095"].proposeStream(jid.JID(to_jid), PROFILE, feature_elt, file_transfer_elts, profile_key=profile)
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	288 offer.addCallback(self.fileCb, filepath, sid, size, profile)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	289 return sid
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	290
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	291 def sendSuccessCb(self, sid, file_obj, stream_method, profile):
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	292 log.info(_('Transfer %(sid)s successfuly finished [%(profile)s]')
638 6821fc06a324 misc: a few "cosmetic" changes (PEP 8...) souliane <souliane@mailoo.org> parents: 609 diff changeset	293 % {"sid": sid, "profile": profile})
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	294 file_obj.close()
64 d46f849664aa SàT: multi-profile, plugins updated Goffi <goffi@goffi.org> parents: 57 diff changeset	295
538 2c4016921403 core, frontends, bridgen plugins: fixed methods which were unproperly managing multi-profiles Goffi <goffi@goffi.org> parents: 536 diff changeset	296 def sendFailureCb(self, sid, file_obj, stream_method, reason, profile):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	297 file_obj.close()
993 301b342c697a core: use of the new core.log module: Goffi <goffi@goffi.org> parents: 941 diff changeset	298 log.warning(_('Transfer %(id)s failed with stream method %(s_method)s: %(reason)s [%(profile)s]') % {'id': sid, "s_method": stream_method, 'reason': reason, 'profile': profile})

Mercurial > libervia-backend

annotate src/plugins/plugin_xep_0096.py @ 1119:5968fd8d2248