Mercurial > libervia-web
view libervia/web/pages/chat/page_meta.py @ 1545:be20e6ac9f22
browser (bridge): add methods/properties to wait for Websocket/BroadcastChannel to be ready
author | Goffi <goffi@goffi.org> |
---|---|
date | Thu, 06 Jul 2023 12:10:25 +0200 |
parents | f00497c00e38 |
children | 7941444c1671 |
line wrap: on
line source
#!/usr/bin/env python3 from libervia.backend.core.i18n import _ from twisted.internet import defer from libervia.backend.core.log import getLogger from libervia.backend.tools.common import data_objects from libervia.backend.tools.common import data_format from libervia.frontends.tools import jid from libervia.web.server.constants import Const as C from libervia.web.server import session_iface log = getLogger(__name__) name = "chat" access = C.PAGES_ACCESS_PROFILE template = "chat/chat.html" dynamic = True def parse_url(self, request): rdata = self.get_r_data(request) try: target_jid_s = self.next_path(request) except IndexError: # not chat jid, we redirect to jid selection page self.page_redirect("chat_select", request) return try: target_jid = jid.JID(target_jid_s) if not target_jid.local: raise ValueError(_("invalid jid for chat (no local part)")) except Exception as e: log.warning( _("bad chat jid entered: {jid} ({msg})").format(jid=target_jid_s, msg=e) ) self.page_error(request, C.HTTP_BAD_REQUEST) else: rdata["target"] = target_jid async def prepare_render(self, request): # Â FIXME: bug on room filtering (currently display messages from all rooms) session = self.host.get_session_data(request, session_iface.IWebSession) template_data = request.template_data rdata = self.get_r_data(request) target_jid = rdata["target"] profile = session.profile profile_jid = session.jid disco = await self.host.bridge_call( "disco_infos", target_jid.domain, "", True, profile ) if "conference" in [i[0] for i in disco[1]]: chat_type = C.CHAT_GROUP join_ret = await self.host.bridge_call( "muc_join", target_jid.bare, "", "", profile ) (already_joined, room_jid_s, occupants, user_nick, room_subject, room_statuses, __) = join_ret template_data["subject"] = room_subject template_data["room_statuses"] = room_statuses own_jid = jid.JID(room_jid_s) own_jid = own_jid.change_resource(user_nick) else: room_subject = None chat_type = C.CHAT_ONE2ONE own_jid = profile_jid rdata["chat_type"] = chat_type template_data["own_jid"] = own_jid history = await self.host.bridge_call( "history_get", profile_jid.userhost(), target_jid.bare, 20, True, {}, profile, ) authors = {m[2] for m in history} identities = session.identities for author in authors: id_raw = await self.host.bridge_call( "identity_get", author, [], True, profile) identities[author] = data_format.deserialise(id_raw) template_data["messages"] = data_objects.Messages(history) rdata['identities'] = identities template_data["target_jid"] = target_jid template_data["chat_type"] = chat_type self.expose_to_scripts( request, room_subject=room_subject, own_jid=str(own_jid), target_jid=target_jid, chat_type=chat_type, ) def on_data(self, request, data): session = self.host.get_session_data(request, session_iface.IWebSession) rdata = self.get_r_data(request) target = rdata["target"] data_type = data.get("type", "") if data_type == "msg": message = data["body"] mess_type = ( C.MESS_TYPE_GROUPCHAT if rdata["chat_type"] == C.CHAT_GROUP else C.MESS_TYPE_CHAT ) log.debug("message received: {}".format(message)) self.host.bridge_call( "message_send", target.full(), {"": message}, {}, mess_type, "", session.profile, ) else: log.warning("unknown message type: {type}".format(type=data_type))