libervia-backend: sat_frontends/quick_frontend/quick

comparison sat_frontends/quick_frontend/quick_chat.py @ 2664:e35a265ec174

quick frontend (app, chat): encryption handling: - new QuickApp.ENCRYPTION_HANDLERS class attribute, if True (default), encryption handlers are set - encryption plugins are retrieved on startup and cached in QuickApp.encryption_plugins list - QuickChat's encrypted boolean attribute indicate if a session is currently encrypted. This is updated automatically if ENCRYPTION_HANDLERS is set - if ENCRYPTION_HANDLERS is set, messageEncryptionStarted and messageEncryptionStopped are called when suitable.

author	Goffi <goffi@goffi.org>
date	Sat, 11 Aug 2018 18:24:55 +0200
parents	96911768b0f3
children	b4c0a5bec729

comparison

equal deleted inserted replaced

-:32b5f68a23b4
+:e35a265ec174
 # You should have received a copy of the GNU Affero General Public License
 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
 from sat.core.i18n import _
 from sat.core.log import getLogger
+from sat.tools.common import data_format
-log = getLogger(__name__)
 from sat.core import exceptions
 from sat_frontends.quick_frontend import quick_widgets
 from sat_frontends.quick_frontend.constants import Const as C
 from collections import OrderedDict
 from sat_frontends.tools import jid
 import time
+log = getLogger(__name__)
 try:
 from locale import getlocale
 except ImportError:
 # FIXME: pyjamas workaround
 class Message(object):
 """Message metadata"""
-def __init__(
+def __init__(self, parent, uid, timestamp, from_jid, to_jid, msg, subject, type_,
-self,
+extra, profile):
-parent,
-uid,
-timestamp,
-from_jid,
-to_jid,
-msg,
-subject,
-type_,
-extra,
-profile,
-):
 self.parent = parent
 self.profile = profile
 self.uid = uid
 self.timestamp = timestamp
 self.from_jid = from_jid
 class QuickChat(quick_widgets.QuickWidget):
 visible_states = ["chat_state"]  # FIXME: to be removed, used only in quick_games
-def __init__(
+def __init__(self, host, target, type_=C.CHAT_ONE2ONE, nick=None, occupants=None,
-self,
+subject=None, profiles=None):
-host,
+"""
-target,
+@param type_: can be C.CHAT_ONE2ONE for single conversation or C.CHAT_GROUP for
-type_=C.CHAT_ONE2ONE,
+chat à la IRC
-nick=None,
-occupants=None,
-subject=None,
-profiles=None,
-):
-"""
-@param type_: can be C.CHAT_ONE2ONE for single conversation or C.CHAT_GROUP for chat à la IRC
 """
 self.lang = ""  # default language to use for messages
 quick_widgets.QuickWidget.__init__(self, host, target, profiles=profiles)
 self._locked = True  # True when we are waiting for history/search
 # messageNew signals are cached when locked
 self._cache = OrderedDict()
 assert type_ in (C.CHAT_ONE2ONE, C.CHAT_GROUP)
 self.current_target = target
 self.type = type_
+self.encrypted = False  # True if this session is currently encrypted
 if type_ == C.CHAT_GROUP:
 if target.resource:
 raise exceptions.InternalError(
 u"a group chat entity can't have a resource"
 )
 handle the display of history and subject
 """
 self.historyPrint(profile=self.profile)
 if self.subject is not None:
 self.setSubject(self.subject)
+if self.host.ENCRYPTION_HANDLERS:
+self.getEncryptionState()
 def onDelete(self):
 if self.host.AVATARS_HANDLER:
 self.host.removeListener("avatar", self.onAvatar)
 profile,
 callback=_historyGetCb,
 errback=_historyGetEb,
 )
-def messageNew(
+def messageEncryptionGetCb(self, session_data):
-self, uid, timestamp, from_jid, to_jid, msg, subject, type_, extra, profile
+if session_data:
-):
+session_data = data_format.deserialise(session_data)
+self.messageEncryptionStarted(session_data)
+def messageEncryptionGetEb(self, failure_):
+log.error(_(u"Can't get encryption state: {reason}").format(reason=failure_))
+def getEncryptionState(self):
+"""Retrieve encryption state with current target.
+Once state is retrieved, default messageEncryptionStarted will be called if
+suitable
+"""
+self.host.bridge.messageEncryptionGet(self.target, self.profile,
+callback=self.messageEncryptionGetCb,
+errback=self.messageEncryptionGetEb)
+def messageNew(self, uid, timestamp, from_jid, to_jid, msg, subject, type_, extra,
+profile):
 if self._locked:
 self._cache[uid] = (
 uid,
 timestamp,
 from_jid,
 profile,
 )
 return
 if self.type == C.CHAT_GROUP:
 if to_jid.resource and type_ != C.MESS_TYPE_GROUPCHAT:
-# we have a private message, we forward it to a private conversation widget
+# we have a private message, we forward it to a private conversation
+# widget
 chat_widget = self.getOrCreatePrivateWidget(to_jid)
 chat_widget.messageNew(
 uid, timestamp, from_jid, to_jid, msg, subject, type_, extra, profile
 )
 return
 if "received_timestamp" in extra:
 log.warning(u"Delayed message received after history, this should not happen")
 self.createMessage(message)
+def messageEncryptionStarted(self, session_data):
+self.encrypted = True
+log.debug(_(u"message encryption started with {target} using {encryption}").format(
+target=self.target, encryption=session_data[u'name']))
+def messageEncryptionStopped(self, session_data):
+self.encrypted = False
+log.debug(_(u"message encryption stopped with {target} (was using {encryption})")
+.format(target=self.target, encryption=session_data[u'name']))
 def createMessage(self, message, append=False):
 """Must be implemented by frontend to create and show a new message widget
 This is only called on messageNew, not on history.
 You need to override historyPrint to handle the later

Mercurial > libervia-backend

comparison sat_frontends/quick_frontend/quick_chat.py @ 2664:e35a265ec174