rename msg_id to msg_log_id where it's the id from logs database
This commit is contained in:
parent
1f2eb5050c
commit
fbdb7656af
|
@ -849,7 +849,7 @@ class ChatControlBase(MessageControl, ChatCommandProcessor, CommandTools):
|
||||||
def print_conversation_line(self, text, kind, name, tim,
|
def print_conversation_line(self, text, kind, name, tim,
|
||||||
other_tags_for_name=[], other_tags_for_time=[], other_tags_for_text=[],
|
other_tags_for_name=[], other_tags_for_time=[], other_tags_for_text=[],
|
||||||
count_as_new=True, subject=None, old_kind=None, xhtml=None, simple=False,
|
count_as_new=True, subject=None, old_kind=None, xhtml=None, simple=False,
|
||||||
xep0184_id=None, graphics=True, displaymarking=None, msg_id=None,
|
xep0184_id=None, graphics=True, displaymarking=None, msg_log_id=None,
|
||||||
correct_id=None):
|
correct_id=None):
|
||||||
"""
|
"""
|
||||||
Print 'chat' type messages
|
Print 'chat' type messages
|
||||||
|
@ -925,7 +925,7 @@ class ChatControlBase(MessageControl, ChatCommandProcessor, CommandTools):
|
||||||
self.account, self.contact, type_)
|
self.account, self.contact, type_)
|
||||||
|
|
||||||
event = gajim.events.create_event(type_, (text, subject, self,
|
event = gajim.events.create_event(type_, (text, subject, self,
|
||||||
msg_id), show_in_roster=show_in_roster,
|
msg_log_id), show_in_roster=show_in_roster,
|
||||||
show_in_systray=show_in_systray)
|
show_in_systray=show_in_systray)
|
||||||
gajim.events.add_event(self.account, full_jid, event)
|
gajim.events.add_event(self.account, full_jid, event)
|
||||||
# We need to redraw contact if we show in roster
|
# We need to redraw contact if we show in roster
|
||||||
|
@ -2448,7 +2448,7 @@ class ChatControl(ChatControlBase):
|
||||||
|
|
||||||
def print_conversation(self, text, frm='', tim=None, encrypted=False,
|
def print_conversation(self, text, frm='', tim=None, encrypted=False,
|
||||||
subject=None, xhtml=None, simple=False, xep0184_id=None,
|
subject=None, xhtml=None, simple=False, xep0184_id=None,
|
||||||
displaymarking=None, msg_id=None, correct_id=None):
|
displaymarking=None, msg_log_id=None, correct_id=None):
|
||||||
"""
|
"""
|
||||||
Print a line in the conversation
|
Print a line in the conversation
|
||||||
|
|
||||||
|
@ -2513,7 +2513,7 @@ class ChatControl(ChatControlBase):
|
||||||
ChatControlBase.print_conversation_line(self, text, kind, name, tim,
|
ChatControlBase.print_conversation_line(self, text, kind, name, tim,
|
||||||
subject=subject, old_kind=self.old_msg_kind, xhtml=xhtml,
|
subject=subject, old_kind=self.old_msg_kind, xhtml=xhtml,
|
||||||
simple=simple, xep0184_id=xep0184_id, displaymarking=displaymarking,
|
simple=simple, xep0184_id=xep0184_id, displaymarking=displaymarking,
|
||||||
msg_id=msg_id, correct_id=correct_id)
|
msg_log_id=msg_log_id, correct_id=correct_id)
|
||||||
if text.startswith('/me ') or text.startswith('/me\n'):
|
if text.startswith('/me ') or text.startswith('/me\n'):
|
||||||
self.old_msg_kind = None
|
self.old_msg_kind = None
|
||||||
else:
|
else:
|
||||||
|
|
|
@ -1395,7 +1395,7 @@ class DecryptedMessageReceivedEvent(nec.NetworkIncomingEvent, HelperEvent):
|
||||||
self.sent = self.msg_obj.sent
|
self.sent = self.msg_obj.sent
|
||||||
self.conn = self.msg_obj.conn
|
self.conn = self.msg_obj.conn
|
||||||
self.popup = False
|
self.popup = False
|
||||||
self.msg_id = None # id in log database
|
self.msg_log_id = None # id in log database
|
||||||
self.attention = False # XEP-0224
|
self.attention = False # XEP-0224
|
||||||
self.correct_id = None # XEP-0308
|
self.correct_id = None # XEP-0308
|
||||||
self.msghash = None
|
self.msghash = None
|
||||||
|
@ -1600,7 +1600,7 @@ class GcConfigChangedReceivedEvent(nec.NetworkIncomingEvent):
|
||||||
class MessageSentEvent(nec.NetworkIncomingEvent):
|
class MessageSentEvent(nec.NetworkIncomingEvent):
|
||||||
name = 'message-sent'
|
name = 'message-sent'
|
||||||
base_network_events = []
|
base_network_events = []
|
||||||
|
|
||||||
def generate(self):
|
def generate(self):
|
||||||
if not self.automatic_message:
|
if not self.automatic_message:
|
||||||
self.conn.sent_message_ids.append(self.msg_id)
|
self.conn.sent_message_ids.append(self.msg_id)
|
||||||
|
@ -1616,7 +1616,7 @@ class MessageNotSentEvent(nec.NetworkIncomingEvent):
|
||||||
class MessageErrorEvent(nec.NetworkIncomingEvent, HelperEvent):
|
class MessageErrorEvent(nec.NetworkIncomingEvent, HelperEvent):
|
||||||
name = 'message-error'
|
name = 'message-error'
|
||||||
base_network_events = []
|
base_network_events = []
|
||||||
|
|
||||||
def generate(self):
|
def generate(self):
|
||||||
self.get_id()
|
self.get_id()
|
||||||
#only alert for errors of explicitly sent messages (see https://trac.gajim.org/ticket/8222)
|
#only alert for errors of explicitly sent messages (see https://trac.gajim.org/ticket/8222)
|
||||||
|
|
|
@ -94,7 +94,7 @@ class Contact(CommonContact):
|
||||||
"""
|
"""
|
||||||
def __init__(self, jid, account, name='', groups=[], show='', status='',
|
def __init__(self, jid, account, name='', groups=[], show='', status='',
|
||||||
sub='', ask='', resource='', priority=0, keyID='', client_caps=None,
|
sub='', ask='', resource='', priority=0, keyID='', client_caps=None,
|
||||||
our_chatstate=None, chatstate=None, last_status_time=None, msg_id=None,
|
our_chatstate=None, chatstate=None, last_status_time=None, msg_log_id=None,
|
||||||
last_activity_time=None):
|
last_activity_time=None):
|
||||||
if not isinstance(jid, str):
|
if not isinstance(jid, str):
|
||||||
print('no str')
|
print('no str')
|
||||||
|
@ -110,7 +110,7 @@ class Contact(CommonContact):
|
||||||
|
|
||||||
self.priority = priority
|
self.priority = priority
|
||||||
self.keyID = keyID
|
self.keyID = keyID
|
||||||
self.msg_id = msg_id
|
self.msg_log_id = msg_log_id
|
||||||
self.last_status_time = last_status_time
|
self.last_status_time = last_status_time
|
||||||
self.last_activity_time = last_activity_time
|
self.last_activity_time = last_activity_time
|
||||||
|
|
||||||
|
|
|
@ -448,12 +448,12 @@ class Logger:
|
||||||
sql = 'DELETE FROM unread_messages WHERE message_id IN (%s)' % ids
|
sql = 'DELETE FROM unread_messages WHERE message_id IN (%s)' % ids
|
||||||
self.simple_commit(sql)
|
self.simple_commit(sql)
|
||||||
|
|
||||||
def set_shown_unread_msgs(self, msg_id):
|
def set_shown_unread_msgs(self, msg_log_id):
|
||||||
"""
|
"""
|
||||||
Mark unread message as shown un GUI
|
Mark unread message as shown un GUI
|
||||||
"""
|
"""
|
||||||
sql = 'UPDATE unread_messages SET shown = 1 where message_id = %s' % \
|
sql = 'UPDATE unread_messages SET shown = 1 where message_id = %s' % \
|
||||||
msg_id
|
msg_log_id
|
||||||
self.simple_commit(sql)
|
self.simple_commit(sql)
|
||||||
|
|
||||||
def reset_shown_unread_messages(self):
|
def reset_shown_unread_messages(self):
|
||||||
|
@ -475,7 +475,7 @@ class Logger:
|
||||||
except Exception:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
for message in results:
|
for message in results:
|
||||||
msg_id = message[0]
|
msg_log_id = message[0]
|
||||||
shown = message[1]
|
shown = message[1]
|
||||||
# here we get infos for that message, and related jid from jids table
|
# here we get infos for that message, and related jid from jids table
|
||||||
# do NOT change order of SELECTed things, unless you change function(s)
|
# do NOT change order of SELECTed things, unless you change function(s)
|
||||||
|
@ -485,12 +485,12 @@ class Logger:
|
||||||
jids.jid
|
jids.jid
|
||||||
FROM logs, jids
|
FROM logs, jids
|
||||||
WHERE logs.log_line_id = %d AND logs.jid_id = jids.jid_id
|
WHERE logs.log_line_id = %d AND logs.jid_id = jids.jid_id
|
||||||
''' % msg_id
|
''' % msg_log_id
|
||||||
)
|
)
|
||||||
results = self.cur.fetchall()
|
results = self.cur.fetchall()
|
||||||
if len(results) == 0:
|
if len(results) == 0:
|
||||||
# Log line is no more in logs table. remove it from unread_messages
|
# Log line is no more in logs table. remove it from unread_messages
|
||||||
self.set_read_messages([msg_id])
|
self.set_read_messages([msg_log_id])
|
||||||
continue
|
continue
|
||||||
all_messages.append(results[0] + (shown,))
|
all_messages.append(results[0] + (shown,))
|
||||||
return all_messages
|
return all_messages
|
||||||
|
|
|
@ -1076,14 +1076,14 @@ class GroupchatControl(ChatControlBase):
|
||||||
correct_id=(obj.stanza.getID(), None))
|
correct_id=(obj.stanza.getID(), None))
|
||||||
obj.needs_highlight = self.needs_visual_notification(obj.msgtxt)
|
obj.needs_highlight = self.needs_visual_notification(obj.msgtxt)
|
||||||
|
|
||||||
def on_private_message(self, nick, msg, tim, xhtml, session, msg_id=None,
|
def on_private_message(self, nick, msg, tim, xhtml, session, msg_log_id=None,
|
||||||
encrypted=False, displaymarking=None):
|
encrypted=False, displaymarking=None):
|
||||||
# Do we have a queue?
|
# Do we have a queue?
|
||||||
fjid = self.room_jid + '/' + nick
|
fjid = self.room_jid + '/' + nick
|
||||||
no_queue = len(gajim.events.get_events(self.account, fjid)) == 0
|
no_queue = len(gajim.events.get_events(self.account, fjid)) == 0
|
||||||
|
|
||||||
event = gajim.events.create_event('pm', (msg, '', 'incoming', tim,
|
event = gajim.events.create_event('pm', (msg, '', 'incoming', tim,
|
||||||
encrypted, '', msg_id, xhtml, session, None, displaymarking, False))
|
encrypted, '', msg_log_id, xhtml, session, None, displaymarking, False))
|
||||||
gajim.events.add_event(self.account, fjid, event)
|
gajim.events.add_event(self.account, fjid, event)
|
||||||
|
|
||||||
autopopup = gajim.config.get('autopopup')
|
autopopup = gajim.config.get('autopopup')
|
||||||
|
@ -1373,7 +1373,7 @@ class GroupchatControl(ChatControlBase):
|
||||||
else:
|
else:
|
||||||
# otherwise pass it off to the control to be queued
|
# otherwise pass it off to the control to be queued
|
||||||
self.on_private_message(nick, obj.msgtxt, obj.timestamp,
|
self.on_private_message(nick, obj.msgtxt, obj.timestamp,
|
||||||
obj.xhtml, self.session, msg_id=obj.msg_id,
|
obj.xhtml, self.session, msg_log_id=obj.msg_log_id,
|
||||||
encrypted=obj.encrypted, displaymarking=obj.displaymarking)
|
encrypted=obj.encrypted, displaymarking=obj.displaymarking)
|
||||||
|
|
||||||
def _nec_ping_reply(self, obj):
|
def _nec_ping_reply(self, obj):
|
||||||
|
|
|
@ -1860,7 +1860,7 @@ class RosterWindow:
|
||||||
|
|
||||||
tim = time.localtime(float(result[2]))
|
tim = time.localtime(float(result[2]))
|
||||||
session.roster_message(jid, result[1], tim, msg_type='chat',
|
session.roster_message(jid, result[1], tim, msg_type='chat',
|
||||||
msg_id=result[0])
|
msg_log_id=result[0])
|
||||||
gajim.logger.set_shown_unread_msgs(result[0])
|
gajim.logger.set_shown_unread_msgs(result[0])
|
||||||
|
|
||||||
elif (time.time() - result[2]) > 2592000:
|
elif (time.time() - result[2]) > 2592000:
|
||||||
|
@ -1961,16 +1961,16 @@ class RosterWindow:
|
||||||
pending events
|
pending events
|
||||||
"""
|
"""
|
||||||
|
|
||||||
msg_ids = []
|
msg_log_ids = []
|
||||||
for ev in event_list:
|
for ev in event_list:
|
||||||
if ev.type_ != 'printed_chat':
|
if ev.type_ != 'printed_chat':
|
||||||
continue
|
continue
|
||||||
if len(ev.parameters) > 3 and ev.parameters[3]:
|
if len(ev.parameters) > 3 and ev.parameters[3]:
|
||||||
# There is a msg_id
|
# There is a msg_log_id
|
||||||
msg_ids.append(ev.parameters[3])
|
msg_log_ids.append(ev.parameters[3])
|
||||||
|
|
||||||
if msg_ids:
|
if msg_log_ids:
|
||||||
gajim.logger.set_read_messages(msg_ids)
|
gajim.logger.set_read_messages(msg_log_ids)
|
||||||
|
|
||||||
contact_list = ((event.jid.split('/')[0], event.account) for event in \
|
contact_list = ((event.jid.split('/')[0], event.account) for event in \
|
||||||
event_list)
|
event_list)
|
||||||
|
@ -2766,14 +2766,14 @@ class RosterWindow:
|
||||||
obj.session.control.print_conversation(obj.msgtxt, typ,
|
obj.session.control.print_conversation(obj.msgtxt, typ,
|
||||||
tim=obj.timestamp, encrypted=obj.encrypted, subject=obj.subject,
|
tim=obj.timestamp, encrypted=obj.encrypted, subject=obj.subject,
|
||||||
xhtml=obj.xhtml, displaymarking=obj.displaymarking,
|
xhtml=obj.xhtml, displaymarking=obj.displaymarking,
|
||||||
msg_id=obj.msg_id, correct_id=(obj.id_, obj.correct_id),
|
msg_log_id=obj.msg_log_id, correct_id=(obj.id_, obj.correct_id),
|
||||||
xep0184_id=xep0184_id)
|
xep0184_id=xep0184_id)
|
||||||
if obj.msg_id:
|
if obj.msg_log_id:
|
||||||
pw = obj.session.control.parent_win
|
pw = obj.session.control.parent_win
|
||||||
end = obj.session.control.was_at_the_end
|
end = obj.session.control.was_at_the_end
|
||||||
if not pw or (pw.get_active_control() and obj.session.control \
|
if not pw or (pw.get_active_control() and obj.session.control \
|
||||||
== pw.get_active_control() and pw.is_active() and end):
|
== pw.get_active_control() and pw.is_active() and end):
|
||||||
gajim.logger.set_read_messages([obj.msg_id])
|
gajim.logger.set_read_messages([obj.msg_log_id])
|
||||||
elif obj.popup and obj.mtype == 'chat':
|
elif obj.popup and obj.mtype == 'chat':
|
||||||
contact = gajim.contacts.get_contact(obj.conn.name, obj.jid)
|
contact = gajim.contacts.get_contact(obj.conn.name, obj.jid)
|
||||||
obj.session.control = gajim.interface.new_chat(contact,
|
obj.session.control = gajim.interface.new_chat(contact,
|
||||||
|
|
|
@ -99,7 +99,7 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
msg_to_log = obj.xhtml
|
msg_to_log = obj.xhtml
|
||||||
else:
|
else:
|
||||||
msg_to_log = obj.msgtxt
|
msg_to_log = obj.msgtxt
|
||||||
obj.msg_id = gajim.logger.write(log_type, obj.fjid,
|
obj.msg_log_id = gajim.logger.write(log_type, obj.fjid,
|
||||||
msg_to_log, tim=obj.timestamp, subject=obj.subject)
|
msg_to_log, tim=obj.timestamp, subject=obj.subject)
|
||||||
except exceptions.PysqliteOperationalError as e:
|
except exceptions.PysqliteOperationalError as e:
|
||||||
gajim.nec.push_incoming_event(InformationEvent(None,
|
gajim.nec.push_incoming_event(InformationEvent(None,
|
||||||
|
@ -142,8 +142,8 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
# Brand new message, incoming.
|
# Brand new message, incoming.
|
||||||
contact.our_chatstate = obj.chatstate
|
contact.our_chatstate = obj.chatstate
|
||||||
contact.chatstate = obj.chatstate
|
contact.chatstate = obj.chatstate
|
||||||
if obj.msg_id: # Do not overwrite an existing msg_id with None
|
if obj.msg_log_id: # Do not overwrite an existing msg_log_id with None
|
||||||
contact.msg_id = obj.msg_id
|
contact.msg_log_id = obj.msg_log_id
|
||||||
|
|
||||||
# THIS MUST BE AFTER chatstates handling
|
# THIS MUST BE AFTER chatstates handling
|
||||||
# AND BEFORE playsound (else we ear sounding on chatstates!)
|
# AND BEFORE playsound (else we ear sounding on chatstates!)
|
||||||
|
@ -182,7 +182,7 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
gajim.interface.remote_ctrl.raise_signal('NewMessage', (
|
gajim.interface.remote_ctrl.raise_signal('NewMessage', (
|
||||||
self.conn.name, [obj.fjid, obj.msgtxt, obj.timestamp,
|
self.conn.name, [obj.fjid, obj.msgtxt, obj.timestamp,
|
||||||
obj.encrypted, obj.mtype, obj.subject, obj.chatstate,
|
obj.encrypted, obj.mtype, obj.subject, obj.chatstate,
|
||||||
obj.msg_id, obj.user_nick, obj.xhtml, obj.form_node]))
|
obj.msg_log_id, obj.user_nick, obj.xhtml, obj.form_node]))
|
||||||
|
|
||||||
def roster_message2(self, obj):
|
def roster_message2(self, obj):
|
||||||
"""
|
"""
|
||||||
|
@ -255,7 +255,7 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
(obj.mtype == 'normal' and not obj.popup):
|
(obj.mtype == 'normal' and not obj.popup):
|
||||||
event = gajim.events.create_event(type_, (obj.msgtxt, obj.subject,
|
event = gajim.events.create_event(type_, (obj.msgtxt, obj.subject,
|
||||||
obj.mtype, obj.timestamp, obj.encrypted, obj.resource,
|
obj.mtype, obj.timestamp, obj.encrypted, obj.resource,
|
||||||
obj.msg_id, obj.xhtml, self, obj.form_node, obj.displaymarking,
|
obj.msg_log_id, obj.xhtml, self, obj.form_node, obj.displaymarking,
|
||||||
obj.forwarded and obj.sent),
|
obj.forwarded and obj.sent),
|
||||||
show_in_roster=obj.show_in_roster,
|
show_in_roster=obj.show_in_roster,
|
||||||
show_in_systray=obj.show_in_systray)
|
show_in_systray=obj.show_in_systray)
|
||||||
|
@ -263,7 +263,7 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
gajim.events.add_event(self.conn.name, fjid, event)
|
gajim.events.add_event(self.conn.name, fjid, event)
|
||||||
|
|
||||||
def roster_message(self, jid, msg, tim, encrypted=False, msg_type='',
|
def roster_message(self, jid, msg, tim, encrypted=False, msg_type='',
|
||||||
subject=None, resource='', msg_id=None, user_nick='', xhtml=None,
|
subject=None, resource='', msg_log_id=None, user_nick='', xhtml=None,
|
||||||
form_node=None, displaymarking=None):
|
form_node=None, displaymarking=None):
|
||||||
"""
|
"""
|
||||||
Display the message or show notification in the roster
|
Display the message or show notification in the roster
|
||||||
|
@ -332,8 +332,8 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
self.control.print_conversation(msg, typ, tim=tim, encrypted=encrypted,
|
self.control.print_conversation(msg, typ, tim=tim, encrypted=encrypted,
|
||||||
subject=subject, xhtml=xhtml, displaymarking=displaymarking)
|
subject=subject, xhtml=xhtml, displaymarking=displaymarking)
|
||||||
|
|
||||||
if msg_id:
|
if msg_log_id:
|
||||||
gajim.logger.set_read_messages([msg_id])
|
gajim.logger.set_read_messages([msg_log_id])
|
||||||
|
|
||||||
return
|
return
|
||||||
|
|
||||||
|
@ -351,7 +351,7 @@ class ChatControlSession(stanza_session.EncryptedStanzaSession):
|
||||||
contact)
|
contact)
|
||||||
|
|
||||||
event = gajim.events.create_event(type_, (msg, subject, msg_type, tim,
|
event = gajim.events.create_event(type_, (msg, subject, msg_type, tim,
|
||||||
encrypted, resource, msg_id, xhtml, self, form_node, displaymarking,
|
encrypted, resource, msg_log_id, xhtml, self, form_node, displaymarking,
|
||||||
False), show_in_roster=show_in_roster,
|
False), show_in_roster=show_in_roster,
|
||||||
show_in_systray=show_in_systray)
|
show_in_systray=show_in_systray)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue