298 lines
10 KiB
Python
298 lines
10 KiB
Python
# This file is part of Gajim.
|
|
#
|
|
# Gajim is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published
|
|
# by the Free Software Foundation; version 3 only.
|
|
#
|
|
# Gajim is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with Gajim. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
# Message handler
|
|
|
|
import time
|
|
import logging
|
|
|
|
import nbxmpp
|
|
|
|
from gajim.common import app
|
|
from gajim.common import helpers
|
|
from gajim.common.nec import NetworkIncomingEvent, NetworkEvent
|
|
from gajim.common.modules.security_labels import parse_securitylabel
|
|
from gajim.common.modules.user_nickname import parse_nickname
|
|
from gajim.common.modules.chatstates import parse_chatstate
|
|
from gajim.common.modules.carbons import parse_carbon
|
|
from gajim.common.modules.misc import parse_delay
|
|
from gajim.common.modules.misc import parse_eme
|
|
from gajim.common.modules.misc import parse_correction
|
|
from gajim.common.modules.misc import parse_attention
|
|
from gajim.common.modules.misc import parse_form
|
|
from gajim.common.modules.misc import parse_oob
|
|
from gajim.common.modules.misc import parse_xhtml
|
|
from gajim.common.modules.util import is_self_message
|
|
from gajim.common.modules.util import is_muc_pm
|
|
from gajim.common.connection_handlers_events import GcMessageReceivedEvent
|
|
|
|
|
|
log = logging.getLogger('gajim.c.m.message')
|
|
|
|
|
|
class Message:
|
|
def __init__(self, con):
|
|
self._con = con
|
|
self._account = con.name
|
|
|
|
self.handlers = [('message', self._message_received)]
|
|
|
|
# XEPs for which this message module should not be executed
|
|
self._message_namespaces = set([nbxmpp.NS_HTTP_AUTH,
|
|
nbxmpp.NS_PUBSUB_EVENT,
|
|
nbxmpp.NS_ROSTERX,
|
|
nbxmpp.NS_MAM_1,
|
|
nbxmpp.NS_MAM_2,
|
|
nbxmpp.NS_CONFERENCE,
|
|
nbxmpp.NS_IBB])
|
|
|
|
def _message_received(self, con, stanza):
|
|
# Check if a child of the message contains any
|
|
# namespaces that we handle in other modules.
|
|
# nbxmpp executes less common handlers last
|
|
if self._message_namespaces & set(stanza.getProperties()):
|
|
return
|
|
|
|
muc_user = stanza.getTag('x', namespace=nbxmpp.NS_MUC_USER)
|
|
if muc_user is not None:
|
|
if muc_user.getChildren():
|
|
# Not a PM, handled by MUC module
|
|
return
|
|
|
|
log.info('Received from %s', stanza.getFrom())
|
|
|
|
app.nec.push_incoming_event(NetworkEvent(
|
|
'raw-message-received',
|
|
conn=self._con,
|
|
stanza=stanza,
|
|
account=self._account))
|
|
|
|
if stanza.getFrom() == self._con.get_own_jid(warn=True):
|
|
# Drop messages sent from our own full jid
|
|
# It can happen that when we sent message to our own bare jid
|
|
# that the server routes that message back to us
|
|
log.info('Received message from self: %s, message is dropped',
|
|
stanza.getFrom())
|
|
return
|
|
|
|
stanza, sent, forwarded = parse_carbon(self._con, stanza)
|
|
|
|
from_ = stanza.getFrom()
|
|
type_ = stanza.getType()
|
|
if type_ is None:
|
|
type_ = 'normal'
|
|
self_message = is_self_message(stanza, type_ == 'groupchat')
|
|
muc_pm = is_muc_pm(stanza, from_, type_ == 'groupchat')
|
|
|
|
id_ = stanza.getID()
|
|
|
|
fjid = None
|
|
if from_ is not None:
|
|
try:
|
|
fjid = helpers.parse_jid(str(from_))
|
|
except helpers.InvalidFormat:
|
|
log.warning('Invalid JID: %s, ignoring it',
|
|
stanza.getFrom())
|
|
return
|
|
|
|
jid, resource = app.get_room_and_nick_from_fjid(fjid)
|
|
|
|
# Check for duplicates
|
|
unique_id = self._get_unique_id(stanza, forwarded, sent,
|
|
self_message, muc_pm)
|
|
|
|
# Check groupchat messages for duplicates,
|
|
# We do this because of MUC History messages
|
|
if type_ == 'groupchat' or self_message or muc_pm:
|
|
if type_ == 'groupchat':
|
|
archive_jid = stanza.getFrom().getStripped()
|
|
else:
|
|
archive_jid = self._con.get_own_jid().getStripped()
|
|
if app.logger.find_stanza_id(self._account,
|
|
archive_jid,
|
|
unique_id,
|
|
groupchat=type_ == 'groupchat'):
|
|
return
|
|
|
|
thread_id = stanza.getThread()
|
|
msgtxt = stanza.getBody()
|
|
|
|
# TODO: remove all control UI stuff
|
|
gc_control = app.interface.msg_win_mgr.get_gc_control(
|
|
jid, self._account)
|
|
if not gc_control:
|
|
minimized = app.interface.minimized_controls[self._account]
|
|
gc_control = minimized.get(jid)
|
|
|
|
if gc_control and jid == fjid:
|
|
if type_ == 'error':
|
|
msgtxt = _('error while sending %(message)s ( %(error)s )') % {
|
|
'message': msgtxt, 'error': stanza.getErrorMsg()}
|
|
# TODO: why is this here?
|
|
if stanza.getTag('html'):
|
|
stanza.delChild('html')
|
|
|
|
session = None
|
|
if type_ != 'groupchat':
|
|
if muc_pm and type_ == 'error':
|
|
session = self._con.find_session(fjid, thread_id)
|
|
if not session:
|
|
session = self._con.get_latest_session(fjid)
|
|
if not session:
|
|
session = self._con.make_new_session(
|
|
fjid, thread_id, type_='pm')
|
|
else:
|
|
session = self._con.get_or_create_session(fjid, thread_id)
|
|
|
|
if thread_id and not session.received_thread_id:
|
|
session.received_thread_id = True
|
|
|
|
session.last_receive = time.time()
|
|
|
|
timestamp = parse_delay(stanza)
|
|
if timestamp is None:
|
|
timestamp = time.time()
|
|
|
|
event_attr = {
|
|
'conn': self._con,
|
|
'stanza': stanza,
|
|
'account': self._account,
|
|
'id_': id_,
|
|
'encrypted': False,
|
|
'additional_data': {},
|
|
'forwarded': forwarded,
|
|
'sent': sent,
|
|
'timestamp': timestamp,
|
|
'fjid': fjid,
|
|
'jid': jid,
|
|
'resource': resource,
|
|
'unique_id': unique_id,
|
|
'mtype': type_,
|
|
'msgtxt': msgtxt,
|
|
'thread_id': thread_id,
|
|
'session': session,
|
|
'self_message': self_message,
|
|
'muc_pm': muc_pm,
|
|
'gc_control': gc_control
|
|
}
|
|
|
|
event = MessageReceivedEvent(None, **event_attr)
|
|
app.nec.push_incoming_event(event)
|
|
|
|
app.plugin_manager.extension_point(
|
|
'decrypt', self._con, event, self._on_message_decrypted)
|
|
if not event.encrypted:
|
|
eme = parse_eme(event.stanza)
|
|
if eme is not None:
|
|
event.msgtxt = eme
|
|
self._on_message_decrypted(event)
|
|
|
|
def _on_message_decrypted(self, event):
|
|
try:
|
|
self._con.get_module('Receipts').delegate(event)
|
|
except nbxmpp.NodeProcessed:
|
|
return
|
|
|
|
event_attr = {
|
|
'popup': False,
|
|
'msg_log_id': None,
|
|
'subject': event.stanza.getSubject(),
|
|
'displaymarking': parse_securitylabel(event.stanza),
|
|
'attention': parse_attention(event.stanza),
|
|
'correct_id': parse_correction(event.stanza),
|
|
'user_nick': parse_nickname(event.stanza),
|
|
'form_node': parse_form(event.stanza),
|
|
'xhtml': parse_xhtml(event.stanza),
|
|
'chatstate': parse_chatstate(event.stanza),
|
|
'stanza_id': event.unique_id
|
|
}
|
|
parse_oob(event.stanza, event.additional_data)
|
|
|
|
for name, value in event_attr.items():
|
|
setattr(event, name, value)
|
|
|
|
if event.mtype == 'error':
|
|
if not event.msgtxt:
|
|
event.msgtxt = _('message')
|
|
self._con.dispatch_error_message(
|
|
event.stanza, event.msgtxt,
|
|
event.session, event.fjid, event.timestamp)
|
|
return
|
|
|
|
if event.mtype == 'groupchat':
|
|
app.nec.push_incoming_event(GcMessageReceivedEvent(
|
|
None,
|
|
conn=self._con,
|
|
msg_obj=event,
|
|
stanza_id=event.unique_id))
|
|
return
|
|
|
|
app.nec.push_incoming_event(
|
|
DecryptedMessageReceivedEvent(
|
|
None, **vars(event)))
|
|
|
|
def _get_unique_id(self, stanza, forwarded, sent, self_message, muc_pm):
|
|
if stanza.getType() == 'groupchat':
|
|
# TODO: Disco the MUC check if 'urn:xmpp:mam:2' is announced
|
|
return self._get_stanza_id(stanza)
|
|
|
|
if stanza.getType() != 'chat':
|
|
return
|
|
|
|
# Messages we receive live
|
|
if self._con.get_module('MAM').archiving_namespace != nbxmpp.NS_MAM_2:
|
|
# Only mam:2 ensures valid stanza-id
|
|
return
|
|
|
|
if forwarded:
|
|
if sent:
|
|
if self_message or muc_pm:
|
|
return stanza.getOriginID()
|
|
return self._get_stanza_id(stanza)
|
|
else:
|
|
if muc_pm:
|
|
return stanza.getOriginID()
|
|
return self._get_stanza_id(stanza)
|
|
|
|
# Normal Message
|
|
if self_message or muc_pm:
|
|
return stanza.getOriginID()
|
|
return self._get_stanza_id(stanza)
|
|
|
|
def _get_stanza_id(self, stanza):
|
|
stanza_id, by = stanza.getStanzaIDAttrs()
|
|
if by is None:
|
|
# We can not verify who set this stanza-id, ignore it.
|
|
return
|
|
if stanza.getType() == 'groupchat':
|
|
if stanza.getFrom().bareMatch(by):
|
|
# by attribute must match the server
|
|
return stanza_id
|
|
elif self._con.get_own_jid().bareMatch(by):
|
|
# by attribute must match the server
|
|
return stanza_id
|
|
return
|
|
|
|
|
|
class MessageReceivedEvent(NetworkIncomingEvent):
|
|
name = 'message-received'
|
|
|
|
|
|
class DecryptedMessageReceivedEvent(NetworkIncomingEvent):
|
|
name = 'decrypted-message-received'
|
|
|
|
|
|
def get_instance(*args, **kwargs):
|
|
return Message(*args, **kwargs), 'Message'
|