# HG changeset patch
# User Goffi <goffi@goffi.org>
# Date 1553070584 -3600
# Node ID f5302d57fb09eda249c79fc9966f0d7d0cb75fec
# Parent  a0835f0212d81cbdca01d441bd005e067bc64778
chat: use the new progress_cb and progress_eb methods of actionManager:

thanks to those arguments, progress management code in chat is not needed anymore, simplifying the code.

diff -r a0835f0212d8 -r f5302d57fb09 cagou/plugins/plugin_wid_chat.py
--- a/cagou/plugins/plugin_wid_chat.py	Wed Mar 20 09:29:44 2019 +0100
+++ b/cagou/plugins/plugin_wid_chat.py	Wed Mar 20 09:29:44 2019 +0100
@@ -384,9 +384,6 @@
             self.encryption_btn = EncryptionMainButton(self)
             self.headerInputAddExtra(self.encryption_btn)
         self.header_input.hint_text = u"{}".format(target)
-        self.host.addListener('progressError', self.onProgressError, profiles)
-        self.host.addListener('progressFinished', self.onProgressFinished, profiles)
-        self._waiting_pids = {}  # waiting progress ids
         self.postInit()
 
     def __unicode__(self):
@@ -588,28 +585,13 @@
             )
         input_widget.text = ''
 
-    def onProgressFinished(self, progress_id, metadata, profile):
-        try:
-            callback, cleaning_cb = self._waiting_pids.pop(progress_id)
-        except KeyError:
-            return
+    def fileTransferEb(self, err_msg, cleaning_cb, profile):
         if cleaning_cb is not None:
             cleaning_cb()
-        callback(metadata, profile)
-
-    def onProgressError(self, progress_id, err_msg, profile):
-        try:
-            dummy, cleaning_cb = self._waiting_pids[progress_id]
-        except KeyError:
-            return
-        else:
-            del self._waiting_pids[progress_id]
-            if cleaning_cb is not None:
-                cleaning_cb()
         # TODO: display message to user
         log.warning(u"Can't transfer file: {}".format(err_msg))
 
-    def fileTransferDone(self, metadata, profile):
+    def fileTransferCb(self, metadata, cleaning_cb, profile):
         log.debug("file transfered: {}".format(metadata))
         extra = {}
 
@@ -629,16 +611,6 @@
             profile_key=profile
             )
 
-    def fileTransferCb(self, progress_data, cleaning_cb):
-        try:
-            progress_id = progress_data['progress']
-        except KeyError:
-            # FIXME: following code doesn't looks right, XMLUI should be created first
-            xml_ui = progress_data['xmlui']
-            G.host.showUI(xml_ui)
-        else:
-            self._waiting_pids[progress_id] = (self.fileTransferDone, cleaning_cb)
-
     def onTransferOK(self, file_path, cleaning_cb, transfer_type):
         if transfer_type == C.TRANSFER_UPLOAD:
             G.host.bridge.fileUpload(
@@ -647,9 +619,11 @@
                 "",
                 {"ignore_tls_errors": C.BOOL_TRUE},  # FIXME: should not be the default
                 self.profile,
-                callback = lambda progress_data: self.fileTransferCb(
-                    progress_data, cleaning_cb)
-                )
+                callback = partial(
+                    G.host.actionManager,
+                    progress_cb = partial(self.fileTransferCb, cleaning_cb=cleaning_cb),
+                    progress_eb = partial(self.fileTransferEb, cleaning_cb=cleaning_cb),               )
+            )
         elif transfer_type == C.TRANSFER_SEND:
             if self.type == C.CHAT_GROUP:
                 log.warning(u"P2P transfer is not possible for group chat")
@@ -686,11 +660,6 @@
     def _mucJoinEb(self, failure):
         log.warning(u"Can't join room: {}".format(failure))
 
-    def _onDelete(self):
-        self.host.removeListener('progressFinished', self.onProgressFinished)
-        self.host.removeListener('progressError', self.onProgressError)
-        return super(Chat, self).onDelete()
-
     def onOTRState(self, state, dest_jid, profile):
         assert profile in self.profiles
         if state in OTR_STATE_ENCRYPTION:
@@ -712,8 +681,6 @@
         # TODO: delete all widgets when chat is closed
         nb_instances = sum(1 for _ in self.host.widgets.getWidgetInstances(self))
         if nb_instances > 1:
-            self.host.removeListener('progressFinished', self.onProgressFinished)
-            self.host.removeListener('progressError', self.onProgressError)
             return super(Chat, self).onDelete()
         else:
             return False