libervia-backend: src/plugins/plugin_xep

annotate src/plugins/plugin_xep_0096.py @ 432:31e8c48b5f5d

core: - memory refactoring (moved memory.py and sqlite.py from tools to memory) - private values are now stored in storage (currently sqlite database) and splitted in normal/binary storage. Normal storage is for string key/values, binary storage is for string key and any python data for value - PersistentDict and PersistentBinaryDict are sugar classes to manage the data in storage thought a python dictionary like class.

author	Goffi <goffi@goffi.org>
date	Sun, 20 Nov 2011 15:34:37 +0100
parents	22788653ae8d
children	cf005701624b

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
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	4 """
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	5 SAT plugin for managing xep-0096
228 b1794cbb88e5 2011 copyright upgrade Goffi <goffi@goffi.org> parents: 223 diff changeset	6 Copyright (C) 2009, 2010, 2011 Jérôme Poisson (goffi@goffi.org)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	7
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	8 This program is free software: you can redistribute it and/or modify
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	9 it under the terms of the GNU General Public License as published by
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	10 the Free Software Foundation, either version 3 of the License, or
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	11 (at your option) any later version.
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	12
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	13 This program is distributed in the hope that it will be useful,
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	14 but WITHOUT ANY WARRANTY; without even the implied warranty of
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	16 GNU General Public License for more details.
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	17
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	18 You should have received a copy of the GNU General Public License
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	19 along with this program. If not, see <http://www.gnu.org/licenses/>.
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	20 """
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	21
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	22 from logging import debug, info, warning, error
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	23 from twisted.words.xish import domish
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	24 from twisted.internet import protocol
64 d46f849664aa SàT: multi-profile, plugins updated Goffi <goffi@goffi.org> parents: 57 diff changeset	25 from twisted.words.protocols.jabber import client, jid
39 2e3411a6baad Wix: external server management in gateways manager, SàT: bug fixes in gateway management Goffi <goffi@goffi.org> parents: 22 diff changeset	26 from twisted.words.protocols.jabber import error as jab_error
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	27 import os, os.path
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
1 a06a151fc31f Disconnect first draft Goffi <goffi@goffi.org> parents: 0 diff changeset	29 import pdb
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	30
15 218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	31 from zope.interface import implements
218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	32
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	33 from wokkel import disco, iwokkel, data_form
15 218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	34
218ec9984fa5 wokkel integration part III + memory saved again Goffi <goffi@goffi.org> parents: 8 diff changeset	35 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	36 PROFILE_NAME = "file-transfer"
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	37 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	38
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	39 PLUGIN_INFO = {
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	40 "name": "XEP 0096 Plugin",
291 7c79d4a8c9e6 plugins: fixed bad import names Goffi <goffi@goffi.org> parents: 228 diff changeset	41 "import_name": "XEP-0096",
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	42 "type": "XEP",
48 4392f1fdb064 plugins improvement Goffi <goffi@goffi.org> parents: 39 diff changeset	43 "protocols": ["XEP-0096"],
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	44 "dependencies": ["XEP-0020", "XEP-0095", "XEP-0065", "XEP-0047"],
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	45 "main": "XEP_0096",
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	46 "handler": "no",
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	47 "description": _("""Implementation of SI File Transfer""")
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	48 }
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	49
64 d46f849664aa SàT: multi-profile, plugins updated Goffi <goffi@goffi.org> parents: 57 diff changeset	50 class XEP_0096():
19 f2a745ca0fbc refactoring: using xml params part III (parameters import) Goffi <goffi@goffi.org> parents: 15 diff changeset	51
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	52 def __init__(self, host):
69 86f1f7f6d332 i18n first draft Goffi <goffi@goffi.org> parents: 64 diff changeset	53 info(_("Plugin XEP_0096 initialization"))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	54 self.host = host
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	55 self._waiting_for_approval = {} #key = id, value = [transfer data, IdelayedCall Reactor timeout,
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	56 # current stream method, [failed stream methods], profile]
394 8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	57 self.managed_stream_m = [self.host.plugins["XEP-0065"].NAMESPACE,
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	58 self.host.plugins["XEP-0047"].NAMESPACE] #Stream methods managed
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	59 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	60 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	61
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	62 def _kill_id(self, approval_id):
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	63 """Delete a waiting_for_approval id, called after timeout
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	64 @param approval_id: id of _waiting_for_approval"""
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	65 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	66 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	67 del self._waiting_for_approval[approval_id]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	68 except KeyError:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	69 warning(_("kill id called on a non existant approval id"))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	70
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	71 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	72 """Called when a file transfer is requested
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	73 @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	74 @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	75 @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	76 @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	77 @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	78 @param profile: %(doc_profile)s"""
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	79 info (_("XEP-0096 file transfer requested"))
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	80 debug(si_el.toXml())
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	81 filename = ""
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	82 file_size = ""
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	83 file_date = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	84 file_hash = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	85 file_desc = ""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	86 can_range = False
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	87 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	88 feature_elts = self.host.plugins["XEP-0020"].getFeatureElt(si_el)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	89
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	90 if file_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	91 file_el = file_elts[0]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	92 filename = file_el["name"]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	93 file_size = file_el["size"]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	94 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	95 file_hash = file_el.getAttribute("hash", "")
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	96 info (_("File proposed: name=[%(name)s] size=%(size)s") % {'name':filename, 'size':file_size})
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	97 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	98 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	99 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	100 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	101 can_range = True
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	102 else:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	103 warning(_("No file element found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	104 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	105 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	106
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	107 if feature_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	108 feature_el = feature_elts[0]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	109 form = data_form.Form.fromElement(feature_el.firstChildElement())
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	110 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	111 stream_method = self.host.plugins["XEP-0020"].negociate(feature_el, 'stream-method',self.managed_stream_m)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	112 except KeyError:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	113 warning(_("No stream method found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	114 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	115 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	116 if not stream_method:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	117 warning(_("Can't find a valid stream method"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	118 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	119 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	120 else:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	121 warning(_("No feature element found"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	122 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	123 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	124
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	125 #if we are here, the transfer can start, we just need user's agreement
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	126 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) }
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	127 self._waiting_for_approval[si_id] = [data, reactor.callLater(300, self._kill_id, si_id), stream_method, [], profile]
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	128
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	129 self.host.askConfirmation(si_id, "FILE_TRANSFER", data, self.confirmationCB)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	130
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	131
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	132 def _getFileObject(self, dest_path, can_range = False):
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	133 """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	134 @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	135 @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	136 @return: File Object"""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	137 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	138
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	139 def confirmationCB(self, sid, accepted, frontend_data):
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	140 """Called on confirmation answer
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	141 @param sid: file transfer session id
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	142 @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	143 @param frontend_data: data sent by frontend"""
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	144 data, timeout, stream_method, failed_methods, profile = self._waiting_for_approval[sid]
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	145 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	146 range_offset = 0
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	147 if accepted:
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	148 if timeout.active():
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	149 timeout.cancel()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	150 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	151 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	152 except KeyError:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	153 error(_('dest path not found in frontend_data'))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	154 del(self._waiting_for_approval[sid])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	155 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	156 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	157 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	158 range_offset = file_obj.tell()
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	159 self.host.plugins["XEP-0065"].prepareToReceive(jid.JID(data['from']), sid, file_obj, int(data["size"]), self._transferSucceeded, self._transferFailed)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	160 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	161 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	162 range_offset = file_obj.tell()
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	163 self.host.plugins["XEP-0047"].prepareToReceive(jid.JID(data['from']), sid, file_obj, int(data["size"]), self._transferSucceeded, self._transferFailed)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	164 else:
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	165 error(_("Unknown stream method, this should not happen at this stage, cancelling transfer"))
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	166 del(self._waiting_for_approval[sid])
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	167 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	168
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	169 #we can send the iq result
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	170 feature_elt = self.host.plugins["XEP-0020"].chooseOption({'stream-method':stream_method})
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	171 misc_elts = []
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	172 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	173 if can_range:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	174 range_elt = domish.Element(('', "range"))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	175 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	176 #TODO: manage range length
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	177 misc_elts.append(range_elt)
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	178 self.host.plugins["XEP-0095"].acceptStream(data["id"], data['from'], feature_elt, misc_elts, profile)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	179 else:
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	180 debug (_("Transfer [%s] refused"), sid)
cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	181 self.host.plugins["XEP-0095"].sendRejectedError (data["id"], data['from'], profile=profile)
cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	182 del(self._waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	183
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	184 def _transferSucceeded(self, sid, file_obj, stream_method):
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	185 """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	186 @param id: stream id"""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	187 file_obj.close()
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	188 info(_('Transfer %s successfuly finished') % sid)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	189 del(self._waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	190
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	191 def _transferFailed(self, sid, file_obj, stream_method, reason):
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	192 """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	193 @param id: stream id
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	194 @param reason: can be TIMEOUT, IO_ERROR, PROTOCOL_ERROR"""
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	195 data, timeout, stream_method, failed_methods, profile = self._waiting_for_approval[sid]
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	196 warning(_('Transfer %(id)s failed with stream method %(s_method)s') % { 'id': sid,
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	197 's_method': stream_method })
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	198 filepath = file_obj.name
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	199 file_obj.close()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	200 os.remove(filepath)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	201 #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
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	202 warning(_("All stream methods failed, can't transfer the file"))
394 8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	203 del(self._waiting_for_approval[sid])
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	204
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	205 def fileCb(self, profile, filepath, sid, size, IQ):
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	206 if IQ['type'] == "error":
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	207 stanza_err = jab_error.exceptionFromStanza(IQ)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	208 if stanza_err.code == '403' and stanza_err.condition == 'forbidden':
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	209 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	210 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	211 else:
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	212 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	213 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	214 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	215
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	216 si_elt = IQ.firstChildElement()
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	217
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	218 if IQ['type'] != "result" or not si_elt or si_elt.name != "si":
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	219 error(_("Protocol error during file transfer"))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	220 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	221
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	222 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	223 if not feature_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	224 warning(_("No feature element"))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	225 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	226
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	227 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	228 try:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	229 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	230 except KeyError:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	231 warning(_("No stream method choosed"))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	232 return
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	233
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	234 range_offset = 0
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	235 range_length = None
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	236 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	237 if range_elts:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	238 range_elt = range_elts[0]
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	239 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	240 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	241
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	242 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	243 file_obj = open(filepath, 'r')
8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	244 if range_offset:
8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	245 file_obj.seek(range_offset)
8f3551ceee17 plugin XEP-0065: refactored and misc stuff fixed. Still not finished Goffi <goffi@goffi.org> parents: 391 diff changeset	246 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	247 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	248 file_obj = open(filepath, 'r')
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	249 if range_offset:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	250 file_obj.seek(range_offset)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	251 self.host.plugins["XEP-0047"].startStream(file_obj, jid.JID(IQ['from']), sid, range_length, self.sendSuccessCb, self.sendFailureCb, size, profile)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	252 else:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	253 warning(_("Invalid stream method received"))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	254
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	255 def sendFile(self, to_jid, filepath, data={}, profile_key='@DEFAULT@'):
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	256 """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	257 @to_jid: recipient
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	258 @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	259 @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	260 - "description": description of the file
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	261 @param profile_key: %(doc_profile_key)s
391 c34fd9d6242e spelling Goffi <goffi@goffi.org> parents: 386 diff changeset	262 @return: an unique id to identify the transfer
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	263 """
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	264 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	265 if not profile:
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	266 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	267 return ""
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	268 feature_elt = self.host.plugins["XEP-0020"].proposeFeatures({'stream-method': self.managed_stream_m})
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	269
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	270 file_transfer_elts = []
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	271
c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	272 statinfo = os.stat(filepath)
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	273 file_elt = domish.Element((PROFILE, 'file'))
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	274 file_elt['name']=os.path.basename(filepath)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	275 size = file_elt['size']=str(statinfo.st_size)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	276 file_transfer_elts.append(file_elt)
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	277
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	278 file_transfer_elts.append(domish.Element((None,'range')))
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	279
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	280 sid, offer = self.host.plugins["XEP-0095"].proposeStream(jid.JID(to_jid), PROFILE, feature_elt, file_transfer_elts, profile_key = profile)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	281 offer.addCallback(self.fileCb, profile, filepath, sid, size)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	282 return sid
0 c4bc297b82f0 sat: goffi@necton2 parents: diff changeset	283
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	284 def sendSuccessCb(self, sid, file_obj, stream_method):
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	285 info(_('Transfer %s successfuly finished') % sid)
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	286 file_obj.close()
64 d46f849664aa SàT: multi-profile, plugins updated Goffi <goffi@goffi.org> parents: 57 diff changeset	287
386 deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	288 def sendFailureCb(self, sid, file_obj, stream_method, reason):
deeebf697d9a plugins: plugin XEP-0096 update, use of XEP-0047 (IBB) Goffi <goffi@goffi.org> parents: 372 diff changeset	289 file_obj.close()
398 cb0285372818 File transfer: Goffi <goffi@goffi.org> parents: 394 diff changeset	290 warning(_('Transfer %(id)s failed with stream method %(s_method)s') % { 'id': sid, "s_method": stream_method })

Mercurial > libervia-backend

annotate src/plugins/plugin_xep_0096.py @ 432:31e8c48b5f5d