Mercurial > libervia-desktop-kivy

comparison src/cagou/plugins/plugin_wid_chat.py @ 22:74117b733bac

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
plugin chat: first draft: - only one 2 one display is handled for now - own messages are displayed in blue, other ones in gray - by default we display our own jid (for now) - to change target, contact in contact widget can be clicked, or a jid can be entered in header input - disco is called on jid entered in header, if it's a conference a MUCJoin will be called (not implemented yet), else a new chat widget with the jid replace the current one
author Goffi <goffi@goffi.org>
date Mon, 08 Aug 2016 01:07:43 +0200
parents
children bc15b55a4114
comparison
equal deleted inserted replaced
21:57bf68eacdb9 22:74117b733bac
1 #!/usr/bin/python
2 # -*- coding: utf-8 -*-
3
4 # Cagou: desktop/mobile frontend for Salut à Toi XMPP client
5 # Copyright (C) 2016 Jérôme Poisson (goffi@goffi.org)
6
7 # This program is free software: you can redistribute it and/or modify
8 # it under the terms of the GNU Affero General Public License as published by
9 # the Free Software Foundation, either version 3 of the License, or
10 # (at your option) any later version.
11
12 # This program is distributed in the hope that it will be useful,
13 # but WITHOUT ANY WARRANTY; without even the implied warranty of
14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 # GNU Affero General Public License for more details.
16
17 # You should have received a copy of the GNU Affero General Public License
18 # along with this program. If not, see <http://www.gnu.org/licenses/>.
19
20
21 from sat.core import log as logging
22 log = logging.getLogger(__name__)
23 from sat.core.i18n import _
24 from cagou.core.constants import Const as C
25 from kivy.uix.boxlayout import BoxLayout
26 from kivy.uix.scrollview import ScrollView
27 from kivy.uix.textinput import TextInput
28 from kivy import properties
29 from sat_frontends.quick_frontend import quick_widgets
30 from sat_frontends.quick_frontend import quick_chat
31 from sat_frontends.tools import jid
32 from cagou.core import cagou_widget
33 from cagou import G
34
35
36 PLUGIN_INFO = {
37 "name": _(u"chat"),
38 "main": "Chat",
39 "description": _(u"instant messaging with one person or a group"),
40 }
41
42
43 class MessageWidget(BoxLayout):
44 mess_data = properties.ObjectProperty()
45 mess_label = properties.ObjectProperty(None)
46
47 def __init__(self, **kwargs):
48 BoxLayout.__init__(self, orientation='vertical', **kwargs)
49
50 @property
51 def message(self):
52 """Return currently displayed message"""
53 return self.mess_data.main_message
54
55 def adjustMax(self, texture_size):
56 """this widget grows up with its children"""
57 width, height = texture_size
58 if width > self.parent.width:
59 self.mess_label.text_size = (self.parent.width - 10, None)
60
61
62 class MessageInputWidget(TextInput):
63
64 def _key_down(self, key, repeat=False):
65 displayed_str, internal_str, internal_action, scale = key
66 if internal_action == 'enter':
67 self.dispatch('on_text_validate')
68 else:
69 super(MessageInputWidget, self)._key_down(key, repeat)
70
71
72 class MessagesWidget(BoxLayout):
73 _spacing = properties.NumericProperty(10)
74 _padding = properties.NumericProperty(5)
75
76 def __init__(self, **kwargs):
77 kwargs['orientation'] = 'vertical'
78 kwargs['size_hint'] = (1, None)
79 super(MessagesWidget, self).__init__(**kwargs)
80
81 def sizeAdjust(self):
82 self.height = sum([(c.height+self._padding*2) for c in self.children]) + self._spacing
83
84
85 class Chat(quick_chat.QuickChat, cagou_widget.CagouWidget):
86
87 def __init__(self, host, target, type_=C.CHAT_ONE2ONE, occupants=None, subject=None, profiles=None):
88 quick_chat.QuickChat.__init__(self, host, target, type_, occupants, subject, profiles=profiles)
89 cagou_widget.CagouWidget.__init__(self)
90 self.header_input.hint_text = u"You are talking with {}".format(target)
91 scroll_view = ScrollView(size_hint=(1,0.8), scroll_y=0)
92 self.messages_widget = MessagesWidget()
93 scroll_view.add_widget(self.messages_widget)
94 self.add_widget(scroll_view)
95 message_input = MessageInputWidget()
96 message_input.bind(on_text_validate=self.onSend)
97 self.add_widget(message_input)
98 self.postInit()
99
100 @classmethod
101 def factory(cls, plugin_info, target, profiles):
102 profiles = list(profiles)
103 if len(profiles) > 1:
104 raise NotImplementedError(u"Multi-profiles is not available yet for chat")
105 if target is None:
106 target = G.host.profiles[profiles[0]].whoami
107 return G.host.widgets.getOrCreateWidget(cls, target, on_new_widget=None, on_existing_widget=C.WIDGET_RECREATE, profiles=profiles)
108
109 def messageDataConverter(self, idx, mess_id):
110 return {"mess_data": self.messages[mess_id]}
111
112 def _onHistoryPrinted(self):
113 """Refresh or scroll down the focus after the history is printed"""
114 # self.adapter.data = self.messages
115 for mess_data in self.messages.itervalues():
116 self.appendMessage(mess_data)
117 super(Chat, self)._onHistoryPrinted()
118
119 def createMessage(self, message):
120 self.appendMessage(message)
121
122 def appendMessage(self, mess_data):
123 self.messages_widget.add_widget(MessageWidget(mess_data=mess_data))
124
125 def onSend(self, input_widget):
126 G.host.messageSend(
127 self.target,
128 {'': input_widget.text}, # TODO: handle language
129 mess_type = C.MESS_TYPE_GROUPCHAT if self.type == C.CHAT_GROUP else C.MESS_TYPE_CHAT, # TODO: put this in QuickChat
130 profile_key=self.profile
131 )
132 input_widget.text = ''
133
134 def onHeaderInput(self):
135 text = self.header_input.text.strip()
136 try:
137 if text.count(u'@') != 1 or text.count(u' '):
138 raise ValueError
139 jid_ = jid.JID(text)
140 except ValueError:
141 log.info(u"entered text is not a jid")
142 return
143
144 def discoCb(disco):
145 # TODO: check if plugin XEP-0045 is activated
146 if "conference" in [i[0] for i in disco[1]]:
147 raise NotImplementedError(u"MUC not implemented yet")
148 # G.host.bridge.MUCJoin(unicode(jid_), "", "", self.profile)
149 else:
150 plugin_info = [p for p in G.host.getPluggedWidgets() if p["factory"] == self.factory][0] # FIXME: Q&D way, need a proper method in host
151 factory = plugin_info['factory']
152 G.host.switchWidget(self, factory(plugin_info, jid_, profiles=[self.profile]))
153
154 def discoEb(failure):
155 log.warning(u"Disco failure, ignore this text: {}".format(failure))
156
157 G.host.bridge.discoInfos(jid_.domain, self.profile, callback=discoCb, errback=discoEb)
158
159
160
161 PLUGIN_INFO["factory"] = Chat.factory
162 quick_widgets.register(quick_chat.QuickChat, Chat)