Mercurial > libervia-backend
changeset 3293:f5a5aa9fa73a
plugin XEP-0363: fixed fileHTTPUploadGetSlot
author | Goffi <goffi@goffi.org> |
---|---|
date | Tue, 09 Jun 2020 05:58:57 +0200 |
parents | 84f77f04aa08 |
children | 6505e5cc6ab9 |
files | sat/plugins/plugin_xep_0363.py |
diffstat | 1 files changed, 7 insertions(+), 5 deletions(-) [+] |
line wrap: on
line diff
--- a/sat/plugins/plugin_xep_0363.py Mon Jun 08 08:54:53 2020 +0200 +++ b/sat/plugins/plugin_xep_0363.py Tue Jun 09 05:58:57 2020 +0200 @@ -93,7 +93,7 @@ "fileHTTPUploadGetSlot", ".plugin", in_sign="sisss", - out_sign="(ss)", + out_sign="(ssaa{ss})", method=self._getSlot, async_=True, ) @@ -272,15 +272,17 @@ This method can be used when uploading is done by the frontend @param filename(unicode): name of the file to upload @param size(int): size of the file (must be non null) - @param upload_jid(jid.JID(), None, ''): HTTP upload capable entity + @param upload_jid(str, ''): HTTP upload capable entity @param content_type(unicode, None): MIME type of the content empty string or None to guess automatically """ client = self.host.getClient(profile_key) filename = filename.replace("/", "_") - return defer.ensureDeferred(self.getSlot( - client, filename, size, content_type or None, upload_jid or None + d = defer.ensureDeferred(self.getSlot( + client, filename, size, content_type or None, jid.JID(upload_jid) or None )) + d.addCallback(lambda slot: (slot.get, slot.put, slot.headers)) + return d async def getSlot(self, client, filename, size, content_type=None, upload_jid=None): """Get a slot (i.e. download/upload links) @@ -304,7 +306,7 @@ try: upload_jid = client.http_upload_service except AttributeError: - found_entity = await self.getHTTPUploadEntity(profile=client.profile) + found_entity = await self.getHTTPUploadEntity(client) return await self.getSlot( client, filename, size, content_type, found_entity) else: