2876 lines
120 KiB
Python
2876 lines
120 KiB
Python
# Copyright (C) 2003-2014 Yann Leboulanger <asterix AT lagaule.org>
|
|
# Copyright (C) 2004-2005 Vincent Hanquez <tab AT snarc.org>
|
|
# Copyright (C) 2005 Alex Podaras <bigpod AT gmail.com>
|
|
# Norman Rasmussen <norman AT rasmussen.co.za>
|
|
# Stéphan Kochen <stephan AT kochen.nl>
|
|
# Copyright (C) 2005-2006 Dimitur Kirov <dkirov AT gmail.com>
|
|
# Alex Mauer <hawke AT hawkesnest.net>
|
|
# Copyright (C) 2005-2007 Travis Shirk <travis AT pobox.com>
|
|
# Nikos Kouremenos <kourem AT gmail.com>
|
|
# Copyright (C) 2006 Junglecow J <junglecow AT gmail.com>
|
|
# Stefan Bethge <stefan AT lanpartei.de>
|
|
# Copyright (C) 2006-2008 Jean-Marie Traissard <jim AT lapin.org>
|
|
# Copyright (C) 2007 Lukas Petrovicky <lukas AT petrovicky.net>
|
|
# James Newton <redshodan AT gmail.com>
|
|
# Copyright (C) 2007-2008 Brendan Taylor <whateley AT gmail.com>
|
|
# Julien Pivotto <roidelapluie AT gmail.com>
|
|
# Stephan Erb <steve-e AT h3c.de>
|
|
# Copyright (C) 2008 Jonathan Schleifer <js-gajim AT webkeks.org>
|
|
#
|
|
# 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/>.
|
|
|
|
import os
|
|
import sys
|
|
import re
|
|
import time
|
|
import hashlib
|
|
import logging
|
|
from functools import partial
|
|
from threading import Thread
|
|
|
|
from gi.repository import Gtk
|
|
from gi.repository import GdkPixbuf
|
|
from gi.repository import GLib
|
|
from gi.repository import Gio
|
|
from gi.repository import Gdk
|
|
from nbxmpp import idlequeue
|
|
from nbxmpp import Hashes2
|
|
import OpenSSL
|
|
|
|
try:
|
|
from PIL import Image
|
|
except Exception:
|
|
pass
|
|
|
|
from gajim.common import app
|
|
from gajim.common import events
|
|
from gajim.common.dbus import screensaver
|
|
from gajim.common.dbus import location
|
|
from gajim.common.dbus import music_track
|
|
from gajim.common.dbus import logind
|
|
|
|
from gajim import gtkgui_helpers
|
|
from gajim import gui_menu_builder
|
|
from gajim import dialogs
|
|
from gajim import notify
|
|
from gajim import message_control
|
|
from gajim.dialog_messages import get_dialog
|
|
from gajim.dialogs import ProgressWindow
|
|
|
|
from gajim.chat_control_base import ChatControlBase
|
|
from gajim.chat_control import ChatControl
|
|
from gajim.groupchat_control import GroupchatControl
|
|
from gajim.groupchat_control import PrivateChatControl
|
|
from gajim.message_window import MessageWindowMgr
|
|
from gajim.filetransfers_window import FileTransfersWindow
|
|
|
|
from gajim.atom_window import AtomWindow
|
|
from gajim.session import ChatControlSession
|
|
|
|
from gajim.common import idle
|
|
from gajim.common.zeroconf import connection_zeroconf
|
|
from gajim.common import resolver
|
|
from gajim.common import caps_cache
|
|
from gajim.common import proxy65_manager
|
|
from gajim.common import socks5
|
|
from gajim.common import helpers
|
|
from gajim.common import passwords
|
|
from gajim.common import logging_helpers
|
|
from gajim.common.i18n import _
|
|
from gajim.common.connection_handlers_events import (
|
|
OurShowEvent, FileRequestErrorEvent, FileTransferCompletedEvent,
|
|
UpdateRosterAvatarEvent, UpdateGCAvatarEvent, UpdateRoomAvatarEvent)
|
|
|
|
from gajim.common.modules.httpupload import HTTPUploadProgressEvent
|
|
from gajim.common.connection import Connection
|
|
from gajim.common.file_props import FilesProp
|
|
from gajim.common.const import AvatarSize, SSLError, PEPEventType
|
|
from gajim.common.const import ACTIVITIES, MOODS
|
|
|
|
from gajim import roster_window
|
|
from gajim import config
|
|
from gajim.common import ged
|
|
from gajim.common.caps_cache import muc_caps_cache
|
|
from gajim.common import configpaths
|
|
from gajim.common import optparser
|
|
|
|
from gajim.gtk.dialogs import ErrorDialog
|
|
from gajim.gtk.dialogs import WarningDialog
|
|
from gajim.gtk.dialogs import InformationDialog
|
|
from gajim.gtk.dialogs import InputDialog
|
|
from gajim.gtk.dialogs import YesNoDialog
|
|
from gajim.gtk.dialogs import InputTextDialog
|
|
from gajim.gtk.dialogs import PlainConnectionDialog
|
|
from gajim.gtk.dialogs import SSLErrorDialog
|
|
from gajim.gtk.dialogs import ConfirmationDialogDoubleCheck
|
|
from gajim.gtk.dialogs import ChangeNickDialog
|
|
from gajim.gtk.profile import ProfileWindow
|
|
from gajim.gtk.join_groupchat import JoinGroupchatWindow
|
|
from gajim.gtk.filechoosers import FileChooserDialog
|
|
from gajim.gtk.emoji_data import emoji_data
|
|
from gajim.gtk.emoji_data import emoji_ascii_data
|
|
|
|
|
|
parser = optparser.OptionsParser(configpaths.get('CONFIG_FILE'))
|
|
log = logging.getLogger('gajim.interface')
|
|
|
|
class Interface:
|
|
|
|
################################################################################
|
|
### Methods handling events from connection
|
|
################################################################################
|
|
|
|
def handle_event_db_error(self, unused, error):
|
|
#('DB_ERROR', account, error)
|
|
if self.db_error_dialog:
|
|
return
|
|
self.db_error_dialog = ErrorDialog(_('Database Error'), error)
|
|
def destroyed(win):
|
|
self.db_error_dialog = None
|
|
self.db_error_dialog.connect('destroy', destroyed)
|
|
|
|
@staticmethod
|
|
def handle_event_information(obj):
|
|
if not obj.popup:
|
|
return
|
|
|
|
if obj.dialog_name is not None:
|
|
get_dialog(obj.dialog_name, *obj.args, **obj.kwargs)
|
|
return
|
|
|
|
if obj.level == 'error':
|
|
cls = ErrorDialog
|
|
elif obj.level == 'warn':
|
|
cls = WarningDialog
|
|
elif obj.level == 'info':
|
|
cls = InformationDialog
|
|
else:
|
|
return
|
|
|
|
cls(obj.pri_txt, GLib.markup_escape_text(obj.sec_txt))
|
|
|
|
@staticmethod
|
|
def raise_dialog(name, *args, **kwargs):
|
|
get_dialog(name, *args, **kwargs)
|
|
|
|
def handle_ask_new_nick(self, account, room_jid, parent_win):
|
|
title = _('Unable to join group chat')
|
|
prompt = _('Your desired nickname in group chat\n'
|
|
'<b>%s</b>\n'
|
|
'is in use or registered by another occupant.\n'
|
|
'Please specify another nickname below:') % room_jid
|
|
if 'change_nick_dialog' in self.instances:
|
|
self.instances['change_nick_dialog'].add_room(
|
|
account, room_jid, prompt)
|
|
else:
|
|
self.instances['change_nick_dialog'] = ChangeNickDialog(
|
|
account, room_jid, title, prompt, transient_for=parent_win)
|
|
|
|
@staticmethod
|
|
def handle_event_http_auth(obj):
|
|
#('HTTP_AUTH', account, (method, url, transaction_id, iq_obj, msg))
|
|
def response(account, answer):
|
|
obj.conn.get_module('HTTPAuth').build_http_auth_answer(
|
|
obj.stanza, answer)
|
|
|
|
def on_yes(is_checked, obj):
|
|
response(obj, 'yes')
|
|
|
|
account = obj.conn.name
|
|
sec_msg = _('Do you accept this request?')
|
|
if app.get_number_of_connected_accounts() > 1:
|
|
sec_msg = _('Do you accept this request on account %s?') % account
|
|
if obj.msg:
|
|
sec_msg = obj.msg + '\n' + sec_msg
|
|
YesNoDialog(_('HTTP (%(method)s) Authorization for '
|
|
'%(url)s (ID: %(id)s)') % {'method': obj.method, 'url': obj.url,
|
|
'id': obj.iq_id}, sec_msg, on_response_yes=(on_yes, obj),
|
|
on_response_no=(response, obj, 'no'))
|
|
|
|
def handle_event_iq_error(self, obj):
|
|
#('ERROR_ANSWER', account, (id_, fjid, errmsg, errcode))
|
|
if str(obj.errcode) in ('400', '403', '406') and obj.id_:
|
|
# show the error dialog
|
|
sid = obj.id_
|
|
if len(obj.id_) > 3 and obj.id_[2] == '_':
|
|
sid = obj.id_[3:]
|
|
file_props = FilesProp.getFileProp(obj.conn.name, sid)
|
|
if file_props:
|
|
if str(obj.errcode) == '400':
|
|
file_props.error = -3
|
|
else:
|
|
file_props.error = -4
|
|
app.nec.push_incoming_event(FileRequestErrorEvent(None,
|
|
conn=obj.conn, jid=obj.jid, file_props=file_props,
|
|
error_msg=obj.errmsg))
|
|
obj.conn.disconnect_transfer(file_props)
|
|
return
|
|
elif str(obj.errcode) == '404':
|
|
sid = obj.id_
|
|
if len(obj.id_) > 3 and obj.id_[2] == '_':
|
|
sid = obj.id_[3:]
|
|
file_props = FilesProp.getFileProp(obj.conn.name, sid)
|
|
if file_props:
|
|
self.handle_event_file_send_error(obj.conn.name, (obj.fjid,
|
|
file_props))
|
|
obj.conn.disconnect_transfer(file_props)
|
|
return
|
|
|
|
ctrl = self.msg_win_mgr.get_control(obj.fjid, obj.conn.name)
|
|
if ctrl and ctrl.type_id == message_control.TYPE_GC:
|
|
ctrl.print_conversation('Error %s: %s' % (obj.errcode, obj.errmsg))
|
|
|
|
@staticmethod
|
|
def handle_event_connection_lost(obj):
|
|
# ('CONNECTION_LOST', account, [title, text])
|
|
account = obj.conn.name
|
|
app.notification.popup(
|
|
_('Connection Failed'), account, account,
|
|
'connection-lost', 'gajim-connection_lost', obj.title, obj.msg)
|
|
|
|
@staticmethod
|
|
def unblock_signed_in_notifications(account):
|
|
app.block_signed_in_notifications[account] = False
|
|
|
|
def handle_event_status(self, obj): # OUR status
|
|
#('STATUS', account, show)
|
|
account = obj.conn.name
|
|
if obj.show in ('offline', 'error'):
|
|
for name in list(self.instances[account]['online_dialog'].keys()):
|
|
# .keys() is needed to not have a dictionary length changed
|
|
# during iteration error
|
|
self.instances[account]['online_dialog'][name].destroy()
|
|
if name in self.instances[account]['online_dialog']:
|
|
# destroy handler may have already removed it
|
|
del self.instances[account]['online_dialog'][name]
|
|
for request in self.gpg_passphrase.values():
|
|
if request:
|
|
request.interrupt(account=account)
|
|
if account in self.pass_dialog:
|
|
self.pass_dialog[account].window.destroy()
|
|
if obj.show == 'offline':
|
|
app.block_signed_in_notifications[account] = True
|
|
else:
|
|
# 30 seconds after we change our status to sth else than offline
|
|
# we stop blocking notifications of any kind
|
|
# this prevents from getting the roster items as 'just signed in'
|
|
# contacts. 30 seconds should be enough time
|
|
GLib.timeout_add_seconds(30, self.unblock_signed_in_notifications,
|
|
account)
|
|
|
|
if account in self.show_vcard_when_connect and obj.show not in (
|
|
'offline', 'error'):
|
|
self.edit_own_details(account)
|
|
self.show_vcard_when_connect.remove(account)
|
|
|
|
def edit_own_details(self, account):
|
|
window = app.get_app_window(ProfileWindow)
|
|
if window is None:
|
|
ProfileWindow(account)
|
|
else:
|
|
window.present()
|
|
|
|
@staticmethod
|
|
def handle_gc_error(gc_control, pritext, sectext):
|
|
if gc_control and gc_control.autorejoin is not None:
|
|
if gc_control.error_dialog:
|
|
gc_control.error_dialog.destroy()
|
|
def on_close(dummy):
|
|
gc_control.error_dialog.destroy()
|
|
gc_control.error_dialog = None
|
|
gc_control.error_dialog = ErrorDialog(pritext, sectext,
|
|
on_response_ok=on_close, on_response_cancel=on_close)
|
|
gc_control.error_dialog.set_modal(False)
|
|
if gc_control.parent_win:
|
|
gc_control.error_dialog.set_transient_for(
|
|
gc_control.parent_win.window)
|
|
else:
|
|
d = ErrorDialog(pritext, sectext)
|
|
if gc_control and gc_control.parent_win:
|
|
d.set_transient_for(gc_control.parent_win.window)
|
|
d.set_modal(False)
|
|
|
|
def handle_gc_password_required(self, account, room_jid, nick):
|
|
def on_ok(text):
|
|
app.connections[account].join_gc(nick, room_jid, text)
|
|
app.gc_passwords[room_jid] = text
|
|
gc_control.error_dialog = None
|
|
|
|
def on_cancel():
|
|
# get and destroy window
|
|
if room_jid in app.interface.minimized_controls[account]:
|
|
self.roster.on_disconnect(None, room_jid, account)
|
|
else:
|
|
win = self.msg_win_mgr.get_window(room_jid, account)
|
|
ctrl = self.msg_win_mgr.get_gc_control(room_jid, account)
|
|
win.remove_tab(ctrl, 3)
|
|
gc_control.error_dialog = None
|
|
|
|
gc_control = self.msg_win_mgr.get_gc_control(room_jid, account)
|
|
if gc_control:
|
|
if gc_control.error_dialog:
|
|
gc_control.error_dialog.destroy()
|
|
|
|
gc_control.error_dialog = InputDialog(_('Password Required'),
|
|
_('A Password is required to join the room %s. Please type it.') % \
|
|
room_jid, is_modal=False, ok_handler=on_ok,
|
|
cancel_handler=on_cancel)
|
|
gc_control.error_dialog.input_entry.set_visibility(False)
|
|
|
|
def handle_event_gc_presence(self, obj):
|
|
gc_control = obj.gc_control
|
|
parent_win = None
|
|
if gc_control and gc_control.parent_win:
|
|
parent_win = gc_control.parent_win.window
|
|
if obj.ptype == 'error':
|
|
if obj.errcode == '503':
|
|
# maximum user number reached
|
|
self.handle_gc_error(gc_control,
|
|
_('Unable to join group chat'),
|
|
_('<b>%s</b> is full')\
|
|
% obj.room_jid)
|
|
elif (obj.errcode == '401') or (obj.errcon == 'not-authorized'):
|
|
# password required to join
|
|
self.handle_gc_password_required(obj.conn.name, obj.room_jid,
|
|
obj.nick)
|
|
elif (obj.errcode == '403') or (obj.errcon == 'forbidden'):
|
|
# we are banned
|
|
self.handle_gc_error(gc_control, _('Unable to join group chat'),
|
|
_('You are banned from group chat <b>%s</b>.') % \
|
|
obj.room_jid)
|
|
elif (obj.errcode == '404') or (obj.errcon in ('item-not-found',
|
|
'remote-server-not-found')):
|
|
# remote server does not exist
|
|
if obj.errcon == 'remote-server-not-found':
|
|
self.handle_gc_error(gc_control, _('Unable to join group chat'),
|
|
_('Remote server <b>%s</b> does not exist.') % obj.room_jid)
|
|
# group chat does not exist
|
|
else:
|
|
self.handle_gc_error(gc_control, _('Unable to join group chat'),
|
|
_('Group chat <b>%s</b> does not exist.') % obj.room_jid)
|
|
elif (obj.errcode == '405') or (obj.errcon == 'not-allowed'):
|
|
self.handle_gc_error(gc_control, _('Unable to join group chat'),
|
|
_('Group chat creation is not permitted.'))
|
|
elif (obj.errcode == '406') or (obj.errcon == 'not-acceptable'):
|
|
self.handle_gc_error(gc_control, _('Unable to join groupchat'),
|
|
_('You must use your registered nickname in <b>%s</b>.')\
|
|
% obj.room_jid)
|
|
elif (obj.errcode == '407') or (obj.errcon == \
|
|
'registration-required'):
|
|
self.handle_gc_error(gc_control, _('Unable to join group chat'),
|
|
_('You are not in the members list in groupchat %s.') % \
|
|
obj.room_jid)
|
|
elif (obj.errcode == '409') or (obj.errcon == 'conflict'):
|
|
self.handle_ask_new_nick(obj.conn.name, obj.room_jid, parent_win)
|
|
elif gc_control:
|
|
gc_control.print_conversation('Error %s: %s' % (obj.errcode,
|
|
obj.errmsg))
|
|
if gc_control and gc_control.autorejoin:
|
|
gc_control.autorejoin = False
|
|
|
|
def handle_event_presence(self, obj):
|
|
# 'NOTIFY' (account, (jid, status, status message, resource,
|
|
# priority, # keyID, timestamp, contact_nickname))
|
|
#
|
|
# Contact changed show
|
|
account = obj.conn.name
|
|
jid = obj.jid
|
|
|
|
# unset custom status
|
|
if (obj.old_show == 0 and obj.new_show > 1) or \
|
|
(obj.old_show > 1 and obj.new_show == 0 and obj.conn.connected > 1):
|
|
if account in self.status_sent_to_users and \
|
|
jid in self.status_sent_to_users[account]:
|
|
del self.status_sent_to_users[account][jid]
|
|
|
|
if app.jid_is_transport(jid):
|
|
# It must be an agent
|
|
|
|
# transport just signed in/out, don't show
|
|
# popup notifications for 30s
|
|
account_jid = account + '/' + jid
|
|
app.block_signed_in_notifications[account_jid] = True
|
|
GLib.timeout_add_seconds(30, self.unblock_signed_in_notifications,
|
|
account_jid)
|
|
|
|
ctrl = self.msg_win_mgr.get_control(jid, account)
|
|
if ctrl and ctrl.session and len(obj.contact_list) > 1:
|
|
ctrl.remove_session(ctrl.session)
|
|
|
|
def handle_event_msgerror(self, obj):
|
|
#'MSGERROR' (account, (jid, error_code, error_msg, msg, time[session]))
|
|
account = obj.conn.name
|
|
jids = obj.fjid.split('/', 1)
|
|
jid = jids[0]
|
|
|
|
session = obj.session
|
|
|
|
gc_control = self.msg_win_mgr.get_gc_control(jid, account)
|
|
if not gc_control and \
|
|
jid in self.minimized_controls[account]:
|
|
gc_control = self.minimized_controls[account][jid]
|
|
if gc_control and gc_control.type_id != message_control.TYPE_GC:
|
|
gc_control = None
|
|
if gc_control:
|
|
if len(jids) > 1: # it's a pm
|
|
nick = jids[1]
|
|
|
|
if session:
|
|
ctrl = session.control
|
|
else:
|
|
ctrl = self.msg_win_mgr.get_control(obj.fjid, account)
|
|
|
|
if not ctrl:
|
|
tv = gc_control.list_treeview
|
|
model = tv.get_model()
|
|
iter_ = gc_control.get_contact_iter(nick)
|
|
if iter_:
|
|
show = model[iter_][3]
|
|
else:
|
|
show = 'offline'
|
|
gc_c = app.contacts.create_gc_contact(room_jid=jid,
|
|
account=account, name=nick, show=show)
|
|
ctrl = self.new_private_chat(gc_c, account, session)
|
|
|
|
ctrl.print_conversation(_('Error %(code)s: %(msg)s') % {
|
|
'code': obj.error_code, 'msg': obj.error_msg}, 'status')
|
|
return
|
|
|
|
gc_control.print_conversation(_('Error %(code)s: %(msg)s') % {
|
|
'code': obj.error_code, 'msg': obj.error_msg}, 'status')
|
|
if gc_control.parent_win and \
|
|
gc_control.parent_win.get_active_jid() == jid:
|
|
gc_control.set_subject(gc_control.subject)
|
|
return
|
|
|
|
if app.jid_is_transport(jid):
|
|
jid = jid.replace('@', '')
|
|
msg = obj.error_msg
|
|
if obj.msg:
|
|
msg = _('error while sending %(message)s ( %(error)s )') % {
|
|
'message': obj.msg, 'error': msg}
|
|
if session:
|
|
session.roster_message(jid, msg, obj.time_, msg_type='error')
|
|
|
|
@staticmethod
|
|
def handle_event_msgsent(obj):
|
|
#('MSGSENT', account, (jid, msg, keyID))
|
|
# do not play sound when standalone chatstate message (eg no msg)
|
|
if obj.message and app.config.get_per('soundevents', 'message_sent',
|
|
'enabled'):
|
|
helpers.play_sound('message_sent')
|
|
|
|
@staticmethod
|
|
def handle_event_msgnotsent(obj):
|
|
#('MSGNOTSENT', account, (jid, ierror_msg, msg, time, session))
|
|
msg = _('error while sending %(message)s ( %(error)s )') % {
|
|
'message': obj.message, 'error': obj.error}
|
|
if not obj.session:
|
|
# No session. This can happen when sending a message from
|
|
# gajim-remote
|
|
log.warning(msg)
|
|
return
|
|
obj.session.roster_message(obj.jid, msg, obj.time_, obj.conn.name,
|
|
msg_type='error')
|
|
|
|
def handle_event_subscribe_presence(self, obj):
|
|
#('SUBSCRIBE', account, (jid, text, user_nick)) user_nick is JEP-0172
|
|
account = obj.conn.name
|
|
if helpers.allow_popup_window(account) or not self.systray_enabled:
|
|
if obj.jid in self.instances[account]['sub_request']:
|
|
self.instances[account]['sub_request'][obj.jid].destroy()
|
|
self.instances[account]['sub_request'][obj.jid] = \
|
|
dialogs.SubscriptionRequestWindow(obj.jid, obj.status, account,
|
|
obj.user_nick)
|
|
return
|
|
|
|
event = events.SubscriptionRequestEvent(obj.status, obj.user_nick)
|
|
self.add_event(account, obj.jid, event)
|
|
|
|
if helpers.allow_showing_notification(account):
|
|
event_type = _('Subscription request')
|
|
app.notification.popup(
|
|
event_type, obj.jid, account, 'subscription_request',
|
|
'gajim-subscription_request', event_type, obj.jid)
|
|
|
|
def handle_event_subscribed_presence(self, obj):
|
|
#('SUBSCRIBED', account, (jid, resource))
|
|
account = obj.conn.name
|
|
if obj.jid in app.contacts.get_jid_list(account):
|
|
c = app.contacts.get_first_contact_from_jid(account, obj.jid)
|
|
c.resource = obj.resource
|
|
self.roster.remove_contact_from_groups(c.jid, account,
|
|
[_('Not in Roster'), _('Observers')], update=False)
|
|
else:
|
|
keyID = ''
|
|
attached_keys = app.config.get_per('accounts', account,
|
|
'attached_gpg_keys').split()
|
|
if obj.jid in attached_keys:
|
|
keyID = attached_keys[attached_keys.index(obj.jid) + 1]
|
|
name = obj.jid.split('@', 1)[0]
|
|
name = name.split('%', 1)[0]
|
|
contact1 = app.contacts.create_contact(jid=obj.jid,
|
|
account=account, name=name, groups=[], show='online',
|
|
status='online', ask='to', resource=obj.resource, keyID=keyID)
|
|
app.contacts.add_contact(account, contact1)
|
|
self.roster.add_contact(obj.jid, account)
|
|
InformationDialog(_('Authorization accepted'),
|
|
_('The contact "%s" has authorized you to see their status.')
|
|
% obj.jid)
|
|
|
|
def show_unsubscribed_dialog(self, account, contact):
|
|
def on_yes(is_checked, list_):
|
|
self.roster.on_req_usub(None, list_)
|
|
list_ = [(contact, account)]
|
|
YesNoDialog(
|
|
_('Contact "%s" removed subscription from you') % contact.jid,
|
|
_('You will always see them as offline.\nDo you want to '
|
|
'remove them from your contact list?'),
|
|
on_response_yes=(on_yes, list_))
|
|
# FIXME: Per RFC 3921, we can "deny" ack as well, but the GUI does
|
|
# not show deny
|
|
|
|
def handle_event_unsubscribed_presence(self, obj):
|
|
#('UNSUBSCRIBED', account, jid)
|
|
account = obj.conn.name
|
|
contact = app.contacts.get_first_contact_from_jid(account, obj.jid)
|
|
if not contact:
|
|
return
|
|
|
|
if helpers.allow_popup_window(account) or not self.systray_enabled:
|
|
self.show_unsubscribed_dialog(account, contact)
|
|
return
|
|
|
|
event = events.UnsubscribedEvent(contact)
|
|
self.add_event(account, obj.jid, event)
|
|
|
|
if helpers.allow_showing_notification(account):
|
|
event_type = _('Unsubscribed')
|
|
app.notification.popup(
|
|
event_type, obj.jid, account,
|
|
'unsubscribed', 'gajim-unsubscribed',
|
|
event_type, obj.jid)
|
|
|
|
def handle_event_gc_config(self, obj):
|
|
#('GC_CONFIG', account, (jid, form_node)) config is a dict
|
|
account = obj.conn.name
|
|
if obj.jid in app.automatic_rooms[account]:
|
|
if 'continue_tag' in app.automatic_rooms[account][obj.jid]:
|
|
# We're converting chat to muc. allow participants to invite
|
|
for f in obj.dataform.iter_fields():
|
|
if f.var == 'muc#roomconfig_allowinvites':
|
|
f.value = True
|
|
elif f.var == 'muc#roomconfig_publicroom':
|
|
f.value = False
|
|
elif f.var == 'muc#roomconfig_membersonly':
|
|
f.value = True
|
|
elif f.var == 'public_list':
|
|
f.value = False
|
|
obj.conn.get_module('MUC').set_config(obj.jid, obj.dataform.get_purged())
|
|
user_list = {}
|
|
for jid in app.automatic_rooms[account][obj.jid]['invities']:
|
|
user_list[jid] = {'affiliation': 'member'}
|
|
obj.conn.get_module('MUC').set_affiliation(obj.jid, user_list)
|
|
else:
|
|
# use default configuration
|
|
obj.conn.get_module('MUC').set_config(obj.jid, obj.form_node)
|
|
# invite contacts
|
|
# check if it is necessary to add <continue />
|
|
continue_tag = False
|
|
if 'continue_tag' in app.automatic_rooms[account][obj.jid]:
|
|
continue_tag = True
|
|
if 'invities' in app.automatic_rooms[account][obj.jid]:
|
|
for jid in app.automatic_rooms[account][obj.jid]['invities']:
|
|
obj.conn.get_module('MUC').invite(
|
|
obj.jid, jid, continue_=continue_tag)
|
|
gc_control = self.msg_win_mgr.get_gc_control(obj.jid,
|
|
account)
|
|
if gc_control:
|
|
gc_control.print_conversation(
|
|
_('%(jid)s has been invited in this room') % {
|
|
'jid': jid}, graphics=False)
|
|
del app.automatic_rooms[account][obj.jid]
|
|
elif obj.jid not in self.instances[account]['gc_config']:
|
|
self.instances[account]['gc_config'][obj.jid] = \
|
|
config.GroupchatConfigWindow(account, obj.jid, obj.dataform)
|
|
|
|
def handle_event_gc_affiliation(self, obj):
|
|
#('GC_AFFILIATION', account, (room_jid, users_dict))
|
|
account = obj.conn.name
|
|
if obj.room_jid in self.instances[account]['gc_config']:
|
|
self.instances[account]['gc_config'][obj.room_jid].\
|
|
affiliation_list_received(obj.users_dict)
|
|
|
|
def handle_event_gc_decline(self, obj):
|
|
gc_control = self.msg_win_mgr.get_gc_control(obj.room_jid, obj.account)
|
|
if gc_control:
|
|
if obj.reason:
|
|
gc_control.print_conversation(
|
|
_('%(jid)s declined the invitation: %(reason)s') % {
|
|
'jid': obj.from_, 'reason': obj.reason},
|
|
graphics=False)
|
|
else:
|
|
gc_control.print_conversation(
|
|
_('%(jid)s declined the invitation') % {
|
|
'jid': obj.from_}, graphics=False)
|
|
|
|
def handle_event_gc_invitation(self, obj):
|
|
if helpers.allow_popup_window(obj.account) or not self.systray_enabled:
|
|
dialogs.InvitationReceivedDialog(
|
|
obj.account, obj.room_jid,
|
|
str(obj.from_), obj.password, obj.reason,
|
|
is_continued=obj.is_continued)
|
|
return
|
|
|
|
event = events.GcInvitationtEvent(
|
|
obj.room_jid, obj.reason,
|
|
obj.password, obj.is_continued, str(obj.from_))
|
|
self.add_event(obj.account, str(obj.from_), event)
|
|
|
|
if helpers.allow_showing_notification(obj.account):
|
|
event_type = _('Groupchat Invitation')
|
|
text = _('You are invited to {room} by {user}').format(
|
|
room=obj.room_jid, user=str(obj.from_))
|
|
app.notification.popup(
|
|
event_type, str(obj.from_), obj.account, 'gc-invitation',
|
|
'gajim-gc_invitation', event_type, text, room_jid=obj.room_jid)
|
|
|
|
def forget_gpg_passphrase(self, keyid):
|
|
if keyid in self.gpg_passphrase:
|
|
del self.gpg_passphrase[keyid]
|
|
return False
|
|
|
|
def handle_event_bad_gpg_passphrase(self, obj):
|
|
#('BAD_PASSPHRASE', account, ())
|
|
if obj.use_gpg_agent:
|
|
sectext = _('You configured Gajim to use OpenPGP agent, but there '
|
|
'is no OpenPGP agent running or it returned a wrong passphrase.'
|
|
'\n')
|
|
sectext += _('You are currently connected without your OpenPGP '
|
|
'key.')
|
|
WarningDialog(_('Wrong passphrase'), sectext)
|
|
else:
|
|
account = obj.conn.name
|
|
app.notification.popup(
|
|
'warning', account, account, '', 'dialog-warning',
|
|
_('Wrong OpenPGP passphrase'),
|
|
_('You are currently connected without your OpenPGP key.'))
|
|
self.forget_gpg_passphrase(obj.keyID)
|
|
|
|
@staticmethod
|
|
def handle_event_client_cert_passphrase(obj):
|
|
def on_ok(passphrase, checked):
|
|
obj.conn.on_client_cert_passphrase(passphrase, obj.con, obj.port,
|
|
obj.secure_tuple)
|
|
|
|
def on_cancel():
|
|
obj.conn.on_client_cert_passphrase('', obj.con, obj.port,
|
|
obj.secure_tuple)
|
|
|
|
dialogs.PassphraseDialog(_('Certificate Passphrase Required'),
|
|
_('Enter the certificate passphrase for account %s') % \
|
|
obj.conn.name, ok_handler=on_ok, cancel_handler=on_cancel)
|
|
|
|
def handle_event_gpg_password_required(self, obj):
|
|
#('GPG_PASSWORD_REQUIRED', account, (callback,))
|
|
if obj.keyid in self.gpg_passphrase:
|
|
request = self.gpg_passphrase[obj.keyid]
|
|
else:
|
|
request = PassphraseRequest(obj.keyid)
|
|
self.gpg_passphrase[obj.keyid] = request
|
|
request.add_callback(obj.conn.name, obj.callback)
|
|
|
|
@staticmethod
|
|
def handle_event_gpg_trust_key(obj):
|
|
#('GPG_ALWAYS_TRUST', account, callback)
|
|
def on_yes(checked):
|
|
if checked:
|
|
obj.conn.gpg.always_trust.append(obj.keyID)
|
|
obj.callback(True)
|
|
|
|
def on_no():
|
|
obj.callback(False)
|
|
|
|
YesNoDialog(_('Untrusted OpenPGP key'), _('The OpenPGP key '
|
|
'used to encrypt this chat is not trusted. Do you really want to '
|
|
'encrypt this message?'), checktext=_('_Do not ask me again'),
|
|
on_response_yes=on_yes, on_response_no=on_no)
|
|
|
|
def handle_event_password_required(self, obj):
|
|
#('PASSWORD_REQUIRED', account, None)
|
|
account = obj.conn.name
|
|
if account in self.pass_dialog:
|
|
return
|
|
text = _('Enter your password for account %s') % account
|
|
|
|
def on_ok(passphrase, save):
|
|
if save:
|
|
app.config.set_per('accounts', account, 'savepass', True)
|
|
passwords.save_password(account, passphrase)
|
|
obj.conn.set_password(passphrase)
|
|
del self.pass_dialog[account]
|
|
|
|
def on_cancel():
|
|
self.roster.set_state(account, 'offline')
|
|
self.roster.update_status_combobox()
|
|
del self.pass_dialog[account]
|
|
|
|
self.pass_dialog[account] = dialogs.PassphraseDialog(
|
|
_('Password Required'), text, _('Save password'), ok_handler=on_ok,
|
|
cancel_handler=on_cancel)
|
|
|
|
def handle_oauth2_credentials(self, obj):
|
|
account = obj.conn.name
|
|
def on_ok(refresh):
|
|
app.config.set_per('accounts', account, 'oauth2_refresh_token',
|
|
refresh)
|
|
st = app.config.get_per('accounts', account, 'last_status')
|
|
msg = helpers.from_one_line(app.config.get_per('accounts',
|
|
account, 'last_status_msg'))
|
|
app.interface.roster.send_status(account, st, msg)
|
|
del self.pass_dialog[account]
|
|
|
|
def on_cancel():
|
|
app.config.set_per('accounts', account, 'oauth2_refresh_token',
|
|
'')
|
|
self.roster.set_state(account, 'offline')
|
|
self.roster.update_status_combobox()
|
|
del self.pass_dialog[account]
|
|
|
|
instruction = _('Please copy / paste the refresh token from the website'
|
|
' that has just been opened.')
|
|
self.pass_dialog[account] = InputTextDialog(
|
|
_('Oauth2 Credentials'), instruction, is_modal=False,
|
|
ok_handler=on_ok, cancel_handler=on_cancel)
|
|
|
|
def handle_event_roster_info(self, obj):
|
|
#('ROSTER_INFO', account, (jid, name, sub, ask, groups))
|
|
account = obj.conn.name
|
|
contacts = app.contacts.get_contacts(account, obj.jid)
|
|
if (not obj.sub or obj.sub == 'none') and \
|
|
(not obj.ask or obj.ask == 'none') and not obj.nickname and \
|
|
not obj.groups:
|
|
# contact removed us.
|
|
if contacts:
|
|
self.roster.remove_contact(obj.jid, account, backend=True)
|
|
return
|
|
elif not contacts:
|
|
if obj.sub == 'remove':
|
|
return
|
|
# Add new contact to roster
|
|
keyID = ''
|
|
attached_keys = app.config.get_per('accounts', account,
|
|
'attached_gpg_keys').split()
|
|
if obj.jid in attached_keys:
|
|
keyID = attached_keys[attached_keys.index(obj.jid) + 1]
|
|
contact = app.contacts.create_contact(jid=obj.jid,
|
|
account=account, name=obj.nickname, groups=obj.groups,
|
|
show='offline', sub=obj.sub, ask=obj.ask, keyID=keyID,
|
|
avatar_sha=obj.avatar_sha)
|
|
app.contacts.add_contact(account, contact)
|
|
self.roster.add_contact(obj.jid, account)
|
|
else:
|
|
# If contact has changed (sub, ask or group) update roster
|
|
# Mind about observer status changes:
|
|
# According to xep 0162, a contact is not an observer anymore when
|
|
# we asked for auth, so also remove him if ask changed
|
|
old_groups = contacts[0].groups
|
|
if obj.sub == 'remove':
|
|
# another of our instance removed a contact. Remove it here too
|
|
self.roster.remove_contact(obj.jid, account, backend=True)
|
|
return
|
|
update = False
|
|
if contacts[0].sub != obj.sub or contacts[0].ask != obj.ask\
|
|
or old_groups != obj.groups:
|
|
# c.get_shown_groups() has changed. Reflect that in
|
|
# roster_window
|
|
self.roster.remove_contact(obj.jid, account, force=True)
|
|
update = True
|
|
for contact in contacts:
|
|
contact.name = obj.nickname or ''
|
|
contact.sub = obj.sub
|
|
contact.ask = obj.ask
|
|
contact.groups = obj.groups or []
|
|
if update:
|
|
self.roster.add_contact(obj.jid, account)
|
|
# Refilter and update old groups
|
|
for group in old_groups:
|
|
self.roster.draw_group(group, account)
|
|
self.roster.draw_contact(obj.jid, account)
|
|
if obj.jid in self.instances[account]['sub_request'] and obj.sub in (
|
|
'from', 'both'):
|
|
self.instances[account]['sub_request'][obj.jid].destroy()
|
|
|
|
def handle_event_bookmarks(self, obj):
|
|
gui_menu_builder.build_bookmark_menu(obj.account)
|
|
|
|
def handle_event_file_send_error(self, account, array):
|
|
jid = array[0]
|
|
file_props = array[1]
|
|
ft = self.instances['file_transfers']
|
|
ft.set_status(file_props, 'stop')
|
|
|
|
if helpers.allow_popup_window(account):
|
|
ft.show_send_error(file_props)
|
|
return
|
|
|
|
event = events.FileSendErrorEvent(file_props)
|
|
self.add_event(account, jid, event)
|
|
|
|
if helpers.allow_showing_notification(account):
|
|
event_type = _('File Transfer Error')
|
|
app.notification.popup(
|
|
event_type, jid, account,
|
|
'file-send-error', 'gajim-ft_error',
|
|
event_type, file_props.name)
|
|
|
|
def handle_event_file_request_error(self, obj):
|
|
# ('FILE_REQUEST_ERROR', account, (jid, file_props, error_msg))
|
|
ft = self.instances['file_transfers']
|
|
ft.set_status(obj.file_props, 'stop')
|
|
errno = obj.file_props.error
|
|
|
|
if helpers.allow_popup_window(obj.conn.name):
|
|
if errno in (-4, -5):
|
|
ft.show_stopped(obj.jid, obj.file_props, obj.error_msg)
|
|
else:
|
|
ft.show_request_error(obj.file_props)
|
|
return
|
|
|
|
if errno in (-4, -5):
|
|
event_class = events.FileErrorEvent
|
|
msg_type = 'file-error'
|
|
else:
|
|
event_class = events.FileRequestErrorEvent
|
|
msg_type = 'file-request-error'
|
|
|
|
event = event_class(obj.file_props)
|
|
self.add_event(obj.conn.name, obj.jid, event)
|
|
|
|
if helpers.allow_showing_notification(obj.conn.name):
|
|
# check if we should be notified
|
|
event_type = _('File Transfer Error')
|
|
app.notification.popup(
|
|
event_type, obj.jid, obj.conn.name,
|
|
msg_type, 'gajim-ft_error',
|
|
title=event_type, text=obj.file_props.name)
|
|
|
|
def handle_event_file_request(self, obj):
|
|
account = obj.conn.name
|
|
if obj.jid not in app.contacts.get_jid_list(account):
|
|
keyID = ''
|
|
attached_keys = app.config.get_per('accounts', account,
|
|
'attached_gpg_keys').split()
|
|
if obj.jid in attached_keys:
|
|
keyID = attached_keys[attached_keys.index(obj.jid) + 1]
|
|
contact = app.contacts.create_not_in_roster_contact(jid=obj.jid,
|
|
account=account, keyID=keyID)
|
|
app.contacts.add_contact(account, contact)
|
|
self.roster.add_contact(obj.jid, account)
|
|
contact = app.contacts.get_first_contact_from_jid(account, obj.jid)
|
|
if obj.file_props.session_type == 'jingle':
|
|
request = obj.stanza.getTag('jingle').getTag('content')\
|
|
.getTag('description').getTag('request')
|
|
if request:
|
|
# If we get a request instead
|
|
ft_win = self.instances['file_transfers']
|
|
ft_win.add_transfer(account, contact, obj.file_props)
|
|
return
|
|
if helpers.allow_popup_window(account):
|
|
self.instances['file_transfers'].show_file_request(account, contact,
|
|
obj.file_props)
|
|
return
|
|
event = events.FileRequestEvent(obj.file_props)
|
|
self.add_event(account, obj.jid, event)
|
|
if helpers.allow_showing_notification(account):
|
|
txt = _('%s wants to send you a file.') % app.get_name_from_jid(
|
|
account, obj.jid)
|
|
event_type = _('File Transfer Request')
|
|
app.notification.popup(
|
|
event_type, obj.jid, account, 'file-request',
|
|
icon_name='gajim-ft_request', title=event_type, text=txt)
|
|
|
|
@staticmethod
|
|
def handle_event_file_error(title, message):
|
|
ErrorDialog(title, message)
|
|
|
|
def handle_event_file_progress(self, account, file_props):
|
|
if time.time() - self.last_ftwindow_update > 0.5:
|
|
# update ft window every 500ms
|
|
self.last_ftwindow_update = time.time()
|
|
self.instances['file_transfers'].set_progress(file_props.type_,
|
|
file_props.sid, file_props.received_len)
|
|
|
|
def __compare_hashes(self, account, file_props):
|
|
session = app.connections[account].get_jingle_session(jid=None,
|
|
sid=file_props.sid)
|
|
ft_win = self.instances['file_transfers']
|
|
h = Hashes2()
|
|
try:
|
|
file_ = open(file_props.file_name, 'rb')
|
|
except Exception:
|
|
return
|
|
hash_ = h.calculateHash(file_props.algo, file_)
|
|
file_.close()
|
|
# If the hash we received and the hash of the file are the same,
|
|
# then the file is not corrupt
|
|
jid = file_props.sender
|
|
if file_props.hash_ == hash_:
|
|
GLib.idle_add(self.popup_ft_result, account, jid, file_props)
|
|
GLib.idle_add(ft_win.set_status, file_props, 'ok')
|
|
else:
|
|
# wrong hash, we need to get the file again!
|
|
file_props.error = -10
|
|
GLib.idle_add(self.popup_ft_result, account, jid, file_props)
|
|
GLib.idle_add(ft_win.set_status, file_props, 'hash_error')
|
|
# End jingle session
|
|
if session:
|
|
session.end_session()
|
|
|
|
def handle_event_file_rcv_completed(self, account, file_props):
|
|
ft = self.instances['file_transfers']
|
|
if file_props.error == 0:
|
|
ft.set_progress(file_props.type_, file_props.sid,
|
|
file_props.received_len)
|
|
app.nec.push_incoming_event(FileTransferCompletedEvent(None,
|
|
file_props=file_props))
|
|
else:
|
|
ft.set_status(file_props, 'stop')
|
|
if not file_props.completed and (file_props.stalled or \
|
|
file_props.paused):
|
|
return
|
|
|
|
if file_props.type_ == 'r': # we receive a file
|
|
app.socks5queue.remove_receiver(file_props.sid, True, True)
|
|
if file_props.session_type == 'jingle':
|
|
if file_props.hash_ and file_props.error == 0:
|
|
# We compare hashes in a new thread
|
|
self.hashThread = Thread(target=self.__compare_hashes,
|
|
args=(account, file_props))
|
|
self.hashThread.start()
|
|
else:
|
|
# We disn't get the hash, sender probably don't support that
|
|
jid = file_props.sender
|
|
self.popup_ft_result(account, jid, file_props)
|
|
if file_props.error == 0:
|
|
ft.set_status(file_props, 'ok')
|
|
session = app.connections[account].get_jingle_session(jid=None,
|
|
sid=file_props.sid)
|
|
# End jingle session
|
|
# TODO: only if there are no other parallel downloads in this session
|
|
if session:
|
|
session.end_session()
|
|
else: # we send a file
|
|
jid = file_props.receiver
|
|
app.socks5queue.remove_sender(file_props.sid, True, True)
|
|
self.popup_ft_result(account, jid, file_props)
|
|
|
|
def popup_ft_result(self, account, jid, file_props):
|
|
ft = self.instances['file_transfers']
|
|
if helpers.allow_popup_window(account):
|
|
if file_props.error == 0:
|
|
if app.config.get('notify_on_file_complete'):
|
|
ft.show_completed(jid, file_props)
|
|
elif file_props.error == -1:
|
|
ft.show_stopped(jid, file_props,
|
|
error_msg=_('Remote contact stopped transfer'))
|
|
elif file_props.error == -6:
|
|
ft.show_stopped(jid, file_props,
|
|
error_msg=_('Error opening file'))
|
|
elif file_props.error == -10:
|
|
ft.show_hash_error(jid, file_props, account)
|
|
elif file_props.error == -12:
|
|
ft.show_stopped(jid, file_props,
|
|
error_msg=_('SSL certificate error'))
|
|
return
|
|
|
|
msg_type = ''
|
|
event_type = ''
|
|
if file_props.error == 0 and app.config.get(
|
|
'notify_on_file_complete'):
|
|
event_class = events.FileCompletedEvent
|
|
msg_type = 'file-completed'
|
|
event_type = _('File Transfer Completed')
|
|
elif file_props.error in (-1, -6):
|
|
event_class = events.FileStoppedEvent
|
|
msg_type = 'file-stopped'
|
|
event_type = _('File Transfer Stopped')
|
|
elif file_props.error == -10:
|
|
event_class = events.FileHashErrorEvent
|
|
msg_type = 'file-hash-error'
|
|
event_type = _('File Transfer Failed')
|
|
|
|
if event_type == '':
|
|
# FIXME: ugly workaround (this can happen Gajim sent, Gaim recvs)
|
|
# this should never happen but it does. see process_result() in
|
|
# socks5.py
|
|
# who calls this func (sth is really wrong unless this func is also
|
|
# registered as progress_cb
|
|
return
|
|
|
|
if msg_type:
|
|
event = event_class(file_props)
|
|
self.add_event(account, jid, event)
|
|
|
|
if file_props is not None:
|
|
if file_props.type_ == 'r':
|
|
# get the name of the sender, as it is in the roster
|
|
sender = file_props.sender.split('/')[0]
|
|
name = app.contacts.get_first_contact_from_jid(account,
|
|
sender).get_shown_name()
|
|
filename = os.path.basename(file_props.file_name)
|
|
if event_type == _('File Transfer Completed'):
|
|
txt = _('%(filename)s received from %(name)s.')\
|
|
% {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_done'
|
|
elif event_type == _('File Transfer Stopped'):
|
|
txt = _('File transfer of %(filename)s from %(name)s '
|
|
'stopped.') % {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_stopped'
|
|
else: # ft hash error
|
|
txt = _('File transfer of %(filename)s from %(name)s '
|
|
'failed.') % {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_stopped'
|
|
else:
|
|
receiver = file_props.receiver
|
|
if hasattr(receiver, 'jid'):
|
|
receiver = receiver.jid
|
|
receiver = receiver.split('/')[0]
|
|
# get the name of the contact, as it is in the roster
|
|
name = app.contacts.get_first_contact_from_jid(account,
|
|
receiver).get_shown_name()
|
|
filename = os.path.basename(file_props.file_name)
|
|
if event_type == _('File Transfer Completed'):
|
|
txt = _('You successfully sent %(filename)s to %(name)s.')\
|
|
% {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_done'
|
|
elif event_type == _('File Transfer Stopped'):
|
|
txt = _('File transfer of %(filename)s to %(name)s '
|
|
'stopped.') % {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_stopped'
|
|
else: # ft hash error
|
|
txt = _('File transfer of %(filename)s to %(name)s '
|
|
'failed.') % {'filename': filename, 'name': name}
|
|
icon_name = 'gajim-ft_stopped'
|
|
else:
|
|
txt = ''
|
|
icon_name = None
|
|
|
|
if app.config.get('notify_on_file_complete') and \
|
|
(app.config.get('autopopupaway') or \
|
|
app.connections[account].connected in (2, 3)):
|
|
# we want to be notified and we are online/chat or we don't mind
|
|
# bugged when away/na/busy
|
|
app.notification.popup(
|
|
event_type, jid, account, msg_type,
|
|
icon_name=icon_name, title=event_type, text=txt)
|
|
|
|
def handle_event_signed_in(self, obj):
|
|
"""
|
|
SIGNED_IN event is emitted when we sign in, so handle it
|
|
"""
|
|
# ('SIGNED_IN', account, ())
|
|
# block signed in notifications for 30 seconds
|
|
|
|
# Add our own JID into the DB
|
|
app.logger.insert_jid(obj.conn.get_own_jid().getStripped())
|
|
account = obj.conn.name
|
|
app.block_signed_in_notifications[account] = True
|
|
connected = obj.conn.connected
|
|
|
|
pep_supported = obj.conn.get_module('PEP').supported
|
|
|
|
if not idle.Monitor.is_unknown() and connected in (2, 3):
|
|
# we go online or free for chat, so we activate auto status
|
|
app.sleeper_state[account] = 'online'
|
|
elif not ((idle.Monitor.is_away() and connected == 4) or \
|
|
(idle.Monitor.is_xa() and connected == 5)):
|
|
# If we are autoaway/xa and come back after a disconnection, do
|
|
# nothing
|
|
# Else disable autoaway
|
|
app.sleeper_state[account] = 'off'
|
|
|
|
if obj.conn.get_module('MAM').available and app.config.get_per('accounts',
|
|
account, 'sync_logs_with_server'):
|
|
obj.conn.get_module('MAM').request_archive_on_signin()
|
|
|
|
invisible_show = app.SHOW_LIST.index('invisible')
|
|
# We cannot join rooms if we are invisible
|
|
if connected == invisible_show:
|
|
return
|
|
# send currently played music
|
|
if (pep_supported and sys.platform not in ('win32', 'darwin') and
|
|
app.config.get_per('accounts', account, 'publish_tune')):
|
|
self.enable_music_listener()
|
|
# enable location listener
|
|
if (pep_supported and app.is_installed('GEOCLUE') and
|
|
app.config.get_per('accounts', account, 'publish_location')):
|
|
location.enable()
|
|
|
|
@staticmethod
|
|
def show_httpupload_progress(file):
|
|
ProgressWindow(file)
|
|
|
|
def send_httpupload(self, chat_control):
|
|
accept_cb = partial(self.on_file_dialog_ok, chat_control)
|
|
FileChooserDialog(accept_cb,
|
|
select_multiple=True,
|
|
transient_for=chat_control.parent_win.window)
|
|
|
|
@staticmethod
|
|
def on_file_dialog_ok(chat_control, paths):
|
|
con = app.connections[chat_control.account]
|
|
groupchat = chat_control.type_id == message_control.TYPE_GC
|
|
for path in paths:
|
|
con.get_module('HTTPUpload').check_file_before_transfer(
|
|
path,
|
|
chat_control.encryption,
|
|
chat_control.contact,
|
|
chat_control.session,
|
|
groupchat)
|
|
|
|
def encrypt_file(self, file, account, callback):
|
|
app.nec.push_incoming_event(HTTPUploadProgressEvent(
|
|
None, status='encrypt', file=file))
|
|
encryption = file.encryption
|
|
plugin = app.plugin_manager.encryption_plugins[encryption]
|
|
if hasattr(plugin, 'encrypt_file'):
|
|
plugin.encrypt_file(file, account, callback)
|
|
else:
|
|
app.nec.push_incoming_event(HTTPUploadProgressEvent(
|
|
None, status='close', file=file))
|
|
self.raise_dialog('httpupload-encryption-not-available')
|
|
|
|
@staticmethod
|
|
def handle_event_metacontacts(obj):
|
|
app.contacts.define_metacontacts(obj.conn.name, obj.meta_list)
|
|
|
|
@staticmethod
|
|
def handle_atom_entry(obj):
|
|
if obj != PEPEventType.ATOM:
|
|
return
|
|
if obj.get_entry():
|
|
AtomWindow.newAtomEntry(obj.get_entry())
|
|
|
|
def handle_event_zc_name_conflict(self, obj):
|
|
def on_ok(new_name):
|
|
app.config.set_per('accounts', obj.conn.name, 'name', new_name)
|
|
show = obj.conn.old_show
|
|
status = obj.conn.status
|
|
obj.conn.username = new_name
|
|
obj.conn.change_status(show, status)
|
|
def on_cancel():
|
|
obj.conn.change_status('offline', '')
|
|
|
|
InputDialog(_('Username Conflict'),
|
|
_('Please type a new username for your local account'),
|
|
input_str=obj.alt_name, is_modal=True, ok_handler=on_ok,
|
|
cancel_handler=on_cancel, transient_for=self.roster.window)
|
|
|
|
def handle_event_resource_conflict(self, obj):
|
|
# ('RESOURCE_CONFLICT', account, ())
|
|
# First we go offline, but we don't overwrite status message
|
|
account = obj.conn.name
|
|
conn = obj.conn
|
|
self.roster.send_status(account, 'offline', conn.status)
|
|
|
|
def on_ok(new_resource):
|
|
app.config.set_per('accounts', account, 'resource', new_resource)
|
|
self.roster.send_status(account, conn.old_show, conn.status)
|
|
|
|
proposed_resource = conn.server_resource
|
|
if proposed_resource.startswith('gajim.'):
|
|
# Dont notify the user about resource change if he didn't set
|
|
# a custom resource
|
|
on_ok('gajim.$rand')
|
|
return
|
|
|
|
proposed_resource += app.config.get('gc_proposed_nick_char')
|
|
dialogs.ResourceConflictDialog(_('Resource Conflict'),
|
|
_('You are already connected to this account with the same '
|
|
'resource. Please type a new one'), resource=proposed_resource,
|
|
ok_handler=on_ok)
|
|
|
|
def handle_event_jingleft_cancel(self, obj):
|
|
ft = self.instances['file_transfers']
|
|
file_props = None
|
|
# get the file_props of our session
|
|
file_props = FilesProp.getFileProp(obj.conn.name, obj.sid)
|
|
if not file_props:
|
|
return
|
|
ft.set_status(file_props, 'stop')
|
|
file_props.error = -4 # is it the right error code?
|
|
ft.show_stopped(obj.jid, file_props, 'Peer cancelled ' +
|
|
'the transfer')
|
|
|
|
def handle_event_jingle_incoming(self, obj):
|
|
# ('JINGLE_INCOMING', account, peer jid, sid, tuple-of-contents==(type,
|
|
# data...))
|
|
# TODO: conditional blocking if peer is not in roster
|
|
|
|
account = obj.conn.name
|
|
content_types = [obj.contents.media]
|
|
|
|
# check type of jingle session
|
|
if 'audio' in content_types or 'video' in content_types:
|
|
# a voip session...
|
|
# we now handle only voip, so the only thing we will do here is
|
|
# not to return from function
|
|
pass
|
|
else:
|
|
# unknown session type... it should be declined in common/jingle.py
|
|
return
|
|
|
|
ctrl = (self.msg_win_mgr.get_control(obj.fjid, account)
|
|
or self.msg_win_mgr.get_control(obj.jid, account))
|
|
if ctrl:
|
|
if 'audio' in content_types:
|
|
ctrl.set_audio_state('connection_received', obj.sid)
|
|
if 'video' in content_types:
|
|
ctrl.set_video_state('connection_received', obj.sid)
|
|
|
|
dlg = dialogs.VoIPCallReceivedDialog.get_dialog(obj.fjid, obj.sid)
|
|
if dlg:
|
|
dlg.add_contents(content_types)
|
|
return
|
|
|
|
if helpers.allow_popup_window(account):
|
|
dialogs.VoIPCallReceivedDialog(account, obj.fjid, obj.sid,
|
|
content_types)
|
|
return
|
|
|
|
event = events.JingleIncomingEvent(obj.fjid, obj.sid, content_types)
|
|
self.add_event(account, obj.jid, event)
|
|
|
|
if helpers.allow_showing_notification(account):
|
|
# TODO: we should use another pixmap ;-)
|
|
txt = _('%s wants to start a voice chat.') % \
|
|
app.get_name_from_jid(account, obj.fjid)
|
|
event_type = _('Voice Chat Request')
|
|
app.notification.popup(
|
|
event_type, obj.fjid, account, 'jingle-incoming',
|
|
icon_name='gajim-mic_active', title=event_type, text=txt)
|
|
|
|
def handle_event_jingle_connected(self, obj):
|
|
# ('JINGLE_CONNECTED', account, (peerjid, sid, media))
|
|
if obj.media in ('audio', 'video'):
|
|
account = obj.conn.name
|
|
ctrl = (self.msg_win_mgr.get_control(obj.fjid, account)
|
|
or self.msg_win_mgr.get_control(obj.jid, account))
|
|
if ctrl:
|
|
if obj.media == 'audio':
|
|
ctrl.set_audio_state('connected', obj.sid)
|
|
else:
|
|
ctrl.set_video_state('connected', obj.sid)
|
|
|
|
def handle_event_jingle_disconnected(self, obj):
|
|
# ('JINGLE_DISCONNECTED', account, (peerjid, sid, reason))
|
|
account = obj.conn.name
|
|
ctrl = (self.msg_win_mgr.get_control(obj.fjid, account)
|
|
or self.msg_win_mgr.get_control(obj.jid, account))
|
|
if ctrl:
|
|
if obj.media is None:
|
|
ctrl.stop_jingle(sid=obj.sid, reason=obj.reason)
|
|
elif obj.media == 'audio':
|
|
ctrl.set_audio_state('stop', sid=obj.sid, reason=obj.reason)
|
|
elif obj.media == 'video':
|
|
ctrl.set_video_state('stop', sid=obj.sid, reason=obj.reason)
|
|
dialog = dialogs.VoIPCallReceivedDialog.get_dialog(obj.fjid, obj.sid)
|
|
if dialog:
|
|
if obj.media is None:
|
|
dialog.dialog.destroy()
|
|
else:
|
|
dialog.remove_contents((obj.media, ))
|
|
|
|
def handle_event_jingle_error(self, obj):
|
|
# ('JINGLE_ERROR', account, (peerjid, sid, reason))
|
|
account = obj.conn.name
|
|
ctrl = (self.msg_win_mgr.get_control(obj.fjid, account)
|
|
or self.msg_win_mgr.get_control(obj.jid, account))
|
|
if ctrl and obj.sid == ctrl.audio_sid:
|
|
ctrl.set_audio_state('error', reason=obj.reason)
|
|
|
|
@staticmethod
|
|
def handle_event_roster_item_exchange(obj):
|
|
# data = (action in [add, delete, modify], exchange_list, jid_from)
|
|
dialogs.RosterItemExchangeWindow(obj.conn.name, obj.action,
|
|
obj.exchange_items_list, obj.fjid)
|
|
|
|
def handle_event_ssl_error(self, obj):
|
|
account = obj.conn.name
|
|
server = app.config.get_per('accounts', account, 'hostname')
|
|
|
|
def on_ok(is_checked):
|
|
del self.instances[account]['online_dialog']['ssl_error']
|
|
if is_checked[0]:
|
|
|
|
pem = OpenSSL.crypto.dump_certificate(
|
|
OpenSSL.crypto.FILETYPE_PEM, obj.cert).decode('utf-8')
|
|
|
|
# Check if cert is already in file
|
|
certs = ''
|
|
my_ca_certs = configpaths.get('MY_CACERTS')
|
|
if os.path.isfile(my_ca_certs):
|
|
with open(my_ca_certs, encoding='utf-8') as f:
|
|
certs = f.read()
|
|
if pem in certs:
|
|
ErrorDialog(_('Certificate Already in File'),
|
|
_('This certificate is already in file %s, so it\'s '
|
|
'not added again.') % my_ca_certs)
|
|
else:
|
|
with open(my_ca_certs, 'a', encoding='utf-8') as f:
|
|
f.write(server + '\n')
|
|
f.write(pem + '\n\n')
|
|
|
|
if is_checked[1]:
|
|
ignore_ssl_errors = app.config.get_per('accounts', account,
|
|
'ignore_ssl_errors').split()
|
|
ignore_ssl_errors.append(str(obj.error_num))
|
|
app.config.set_per('accounts', account, 'ignore_ssl_errors',
|
|
' '.join(ignore_ssl_errors))
|
|
obj.conn.process_ssl_errors()
|
|
|
|
def on_cancel():
|
|
del self.instances[account]['online_dialog']['ssl_error']
|
|
obj.conn.disconnect(on_purpose=True)
|
|
app.nec.push_incoming_event(OurShowEvent(None, conn=obj.conn,
|
|
show='offline'))
|
|
|
|
text = _('The authenticity of the %s '
|
|
'certificate could be invalid') % server
|
|
|
|
default_text = _('\nUnknown SSL error: %d') % obj.error_num
|
|
ssl_error_text = SSLError.get(obj.error_num, default_text)
|
|
text += _('\nSSL Error: <b>%s</b>') % ssl_error_text
|
|
|
|
fingerprint_sha1 = obj.cert.digest('sha1').decode('utf-8')
|
|
fingerprint_sha256 = obj.cert.digest('sha256').decode('utf-8')
|
|
|
|
pritext = _('Error verifying SSL certificate')
|
|
sectext = _('There was an error verifying the SSL certificate of your '
|
|
'XMPP server: %(error)s\nDo you still want to connect to this '
|
|
'server?') % {'error': text}
|
|
if obj.error_num in (18, 27):
|
|
checktext1 = _('Add this certificate to the list of trusted '
|
|
'certificates.\nSHA-1 fingerprint of the certificate:\n%(sha1)s'
|
|
'\nSHA-256 fingerprint of the certificate:\n%(sha256)s') % \
|
|
{'sha1': fingerprint_sha1, 'sha256': fingerprint_sha256}
|
|
else:
|
|
checktext1 = ''
|
|
checktext2 = _('Ignore this error for this certificate.')
|
|
if 'ssl_error' in self.instances[account]['online_dialog']:
|
|
self.instances[account]['online_dialog']['ssl_error'].destroy()
|
|
self.instances[account]['online_dialog']['ssl_error'] = \
|
|
SSLErrorDialog(obj.conn.name, obj.cert, pritext,
|
|
sectext, checktext1, checktext2, on_response_ok=on_ok,
|
|
on_response_cancel=on_cancel)
|
|
self.instances[account]['online_dialog']['ssl_error'].set_title(
|
|
_('SSL Certificate Verification for %s') % account)
|
|
|
|
def handle_event_non_anonymous_server(self, obj):
|
|
account = obj.conn.name
|
|
server = app.config.get_per('accounts', account, 'hostname')
|
|
ErrorDialog(_('Non Anonymous Server'), sectext='Server "%s"'
|
|
'does not support anonymous connection' % server,
|
|
transient_for=self.roster.window)
|
|
|
|
def handle_event_plain_connection(self, obj):
|
|
# ('PLAIN_CONNECTION', account, (connection))
|
|
def on_ok(is_checked):
|
|
if not is_checked[0]:
|
|
if is_checked[1]:
|
|
app.config.set_per('accounts', obj.conn.name,
|
|
'action_when_plaintext_connection', 'disconnect')
|
|
on_cancel()
|
|
return
|
|
# On cancel call del self.instances, so don't call it another time
|
|
# before
|
|
del self.instances[obj.conn.name]['online_dialog']\
|
|
['plain_connection']
|
|
if is_checked[1]:
|
|
app.config.set_per('accounts', obj.conn.name,
|
|
'action_when_plaintext_connection', 'connect')
|
|
obj.conn.connection_accepted(obj.xmpp_client, 'plain')
|
|
|
|
def on_cancel():
|
|
del self.instances[obj.conn.name]['online_dialog']\
|
|
['plain_connection']
|
|
obj.conn.disconnect(on_purpose=True)
|
|
app.nec.push_incoming_event(OurShowEvent(None, conn=obj.conn,
|
|
show='offline'))
|
|
|
|
if 'plain_connection' in self.instances[obj.conn.name]['online_dialog']:
|
|
self.instances[obj.conn.name]['online_dialog']['plain_connection'].\
|
|
destroy()
|
|
self.instances[obj.conn.name]['online_dialog']['plain_connection'] = \
|
|
PlainConnectionDialog(obj.conn.name, on_ok, on_cancel)
|
|
|
|
def handle_event_insecure_ssl_connection(self, obj):
|
|
# ('INSECURE_SSL_CONNECTION', account, (connection, connection_type))
|
|
def on_ok(is_checked):
|
|
if not is_checked[0]:
|
|
on_cancel()
|
|
return
|
|
del self.instances[obj.conn.name]['online_dialog']['insecure_ssl']
|
|
if is_checked[1]:
|
|
app.config.set_per('accounts', obj.conn.name,
|
|
'warn_when_insecure_ssl_connection', False)
|
|
if obj.conn.connected == 0:
|
|
# We have been disconnecting (too long time since window is
|
|
# opened)
|
|
# re-connect with auto-accept
|
|
obj.conn.connection_auto_accepted = True
|
|
show, msg = obj.conn.continue_connect_info[:2]
|
|
self.roster.send_status(obj.conn.name, show, msg)
|
|
return
|
|
obj.conn.connection_accepted(obj.xmpp_client, obj.conn_type)
|
|
|
|
def on_cancel():
|
|
del self.instances[obj.conn.name]['online_dialog']['insecure_ssl']
|
|
obj.conn.disconnect(on_purpose=True)
|
|
app.nec.push_incoming_event(OurShowEvent(None, conn=obj.conn,
|
|
show='offline'))
|
|
|
|
pritext = _('Insecure connection')
|
|
sectext = _('You are about to send your password on an insecure '
|
|
'connection. You should install PyOpenSSL to prevent that. Are you '
|
|
'sure you want to do that?')
|
|
checktext1 = _('Yes, I really want to connect insecurely')
|
|
checktext2 = _('_Do not ask me again')
|
|
if 'insecure_ssl' in self.instances[obj.conn.name]['online_dialog']:
|
|
self.instances[obj.conn.name]['online_dialog']['insecure_ssl'].\
|
|
destroy()
|
|
self.instances[obj.conn.name]['online_dialog']['insecure_ssl'] = \
|
|
ConfirmationDialogDoubleCheck(pritext, sectext, checktext1,
|
|
checktext2, on_response_ok=on_ok, on_response_cancel=on_cancel,
|
|
is_modal=False)
|
|
|
|
def handle_event_insecure_password(self, obj):
|
|
# ('INSECURE_PASSWORD', account, ())
|
|
def on_ok(is_checked):
|
|
if not is_checked[0]:
|
|
on_cancel()
|
|
return
|
|
del self.instances[obj.conn.name]['online_dialog']\
|
|
['insecure_password']
|
|
if is_checked[1]:
|
|
app.config.set_per('accounts', obj.conn.name,
|
|
'warn_when_insecure_password', False)
|
|
if obj.conn.connected == 0:
|
|
# We have been disconnecting (too long time since window is
|
|
# opened)
|
|
# re-connect with auto-accept
|
|
obj.conn.connection_auto_accepted = True
|
|
show, msg = obj.conn.continue_connect_info[:2]
|
|
self.roster.send_status(obj.conn.name, show, msg)
|
|
return
|
|
obj.conn.accept_insecure_password()
|
|
|
|
def on_cancel():
|
|
del self.instances[obj.conn.name]['online_dialog']\
|
|
['insecure_password']
|
|
obj.conn.disconnect(on_purpose=True)
|
|
app.nec.push_incoming_event(OurShowEvent(None, conn=obj.conn,
|
|
show='offline'))
|
|
|
|
pritext = _('Insecure connection')
|
|
sectext = _('You are about to send your password unencrypted on an '
|
|
'insecure connection. Are you sure you want to do that?')
|
|
checktext1 = _('Yes, I really want to connect insecurely')
|
|
checktext2 = _('_Do not ask me again')
|
|
if 'insecure_password' in self.instances[obj.conn.name]\
|
|
['online_dialog']:
|
|
self.instances[obj.conn.name]['online_dialog']\
|
|
['insecure_password'].destroy()
|
|
self.instances[obj.conn.name]['online_dialog']['insecure_password'] = \
|
|
ConfirmationDialogDoubleCheck(pritext, sectext, checktext1,
|
|
checktext2, on_response_ok=on_ok, on_response_cancel=on_cancel,
|
|
is_modal=False)
|
|
|
|
def create_core_handlers_list(self):
|
|
self.handlers = {
|
|
'DB_ERROR': [self.handle_event_db_error],
|
|
'FILE_SEND_ERROR': [self.handle_event_file_send_error],
|
|
'pep-received': [self.handle_atom_entry],
|
|
'bad-gpg-passphrase': [self.handle_event_bad_gpg_passphrase],
|
|
'bookmarks-received': [self.handle_event_bookmarks],
|
|
'client-cert-passphrase': [
|
|
self.handle_event_client_cert_passphrase],
|
|
'connection-lost': [self.handle_event_connection_lost],
|
|
'file-request-error': [self.handle_event_file_request_error],
|
|
'file-request-received': [self.handle_event_file_request],
|
|
'gc-invitation-received': [self.handle_event_gc_invitation],
|
|
'gc-decline-received': [self.handle_event_gc_decline],
|
|
'gc-presence-received': [self.handle_event_gc_presence],
|
|
'gpg-password-required': [self.handle_event_gpg_password_required],
|
|
'gpg-trust-key': [self.handle_event_gpg_trust_key],
|
|
'http-auth-received': [self.handle_event_http_auth],
|
|
'information': [self.handle_event_information],
|
|
'insecure-password': [self.handle_event_insecure_password],
|
|
'insecure-ssl-connection': \
|
|
[self.handle_event_insecure_ssl_connection],
|
|
'iq-error-received': [self.handle_event_iq_error],
|
|
'jingle-connected-received': [self.handle_event_jingle_connected],
|
|
'jingle-disconnected-received': [
|
|
self.handle_event_jingle_disconnected],
|
|
'jingle-error-received': [self.handle_event_jingle_error],
|
|
'jingle-request-received': [self.handle_event_jingle_incoming],
|
|
'jingleFT-cancelled-received': [self.handle_event_jingleft_cancel],
|
|
'message-error': [self.handle_event_msgerror],
|
|
'message-not-sent': [self.handle_event_msgnotsent],
|
|
'message-sent': [self.handle_event_msgsent],
|
|
'metacontacts-received': [self.handle_event_metacontacts],
|
|
'muc-admin-received': [self.handle_event_gc_affiliation],
|
|
'muc-owner-received': [self.handle_event_gc_config],
|
|
'oauth2-credentials-required': [self.handle_oauth2_credentials],
|
|
'our-show': [self.handle_event_status],
|
|
'password-required': [self.handle_event_password_required],
|
|
'plain-connection': [self.handle_event_plain_connection],
|
|
'presence-received': [self.handle_event_presence],
|
|
'roster-info': [self.handle_event_roster_info],
|
|
'roster-item-exchange-received': \
|
|
[self.handle_event_roster_item_exchange],
|
|
'signed-in': [self.handle_event_signed_in],
|
|
'ssl-error': [self.handle_event_ssl_error],
|
|
'non-anonymous-server-error': [self.handle_event_non_anonymous_server],
|
|
'stream-conflict-received': [self.handle_event_resource_conflict],
|
|
'subscribe-presence-received': [
|
|
self.handle_event_subscribe_presence],
|
|
'subscribed-presence-received': [
|
|
self.handle_event_subscribed_presence],
|
|
'unsubscribed-presence-received': [
|
|
self.handle_event_unsubscribed_presence],
|
|
'zeroconf-name-conflict': [self.handle_event_zc_name_conflict],
|
|
}
|
|
|
|
def register_core_handlers(self):
|
|
"""
|
|
Register core handlers in Global Events Dispatcher (GED).
|
|
|
|
This is part of rewriting whole events handling system to use GED.
|
|
"""
|
|
for event_name, event_handlers in self.handlers.items():
|
|
for event_handler in event_handlers:
|
|
prio = ged.GUI1
|
|
if isinstance(event_handler, tuple):
|
|
prio = event_handler[1]
|
|
event_handler = event_handler[0]
|
|
app.ged.register_event_handler(event_name, prio,
|
|
event_handler)
|
|
|
|
################################################################################
|
|
### Methods dealing with app.events
|
|
################################################################################
|
|
|
|
def add_event(self, account, jid, event):
|
|
"""
|
|
Add an event to the app.events var
|
|
"""
|
|
# We add it to the app.events queue
|
|
# Do we have a queue?
|
|
jid = app.get_jid_without_resource(jid)
|
|
no_queue = len(app.events.get_events(account, jid)) == 0
|
|
# event can be in common.events.*
|
|
# event_type can be in advancedNotificationWindow.events_list
|
|
event_types = {'file-request': 'ft_request',
|
|
'file-completed': 'ft_finished'}
|
|
event_type = event_types.get(event.type_)
|
|
show_in_roster = notify.get_show_in_roster(event_type, account, jid)
|
|
show_in_systray = notify.get_show_in_systray(event_type, account, jid)
|
|
event.show_in_roster = show_in_roster
|
|
event.show_in_systray = show_in_systray
|
|
app.events.add_event(account, jid, event)
|
|
|
|
self.roster.show_title()
|
|
if no_queue: # We didn't have a queue: we change icons
|
|
if app.contacts.get_contact_with_highest_priority(account, jid):
|
|
self.roster.draw_contact(jid, account)
|
|
else:
|
|
self.roster.add_to_not_in_the_roster(account, jid)
|
|
|
|
# Select the big brother contact in roster, it's visible because it has
|
|
# events.
|
|
family = app.contacts.get_metacontacts_family(account, jid)
|
|
if family:
|
|
_nearby_family, bb_jid, bb_account = \
|
|
app.contacts.get_nearby_family_and_big_brother(family,
|
|
account)
|
|
else:
|
|
bb_jid, bb_account = jid, account
|
|
self.roster.select_contact(bb_jid, bb_account)
|
|
|
|
def handle_event(self, account, fjid, type_):
|
|
w = None
|
|
ctrl = None
|
|
|
|
resource = app.get_resource_from_jid(fjid)
|
|
jid = app.get_jid_without_resource(fjid)
|
|
|
|
if type_ == 'connection-lost':
|
|
app.interface.roster.window.present()
|
|
return
|
|
|
|
if type_ in ('printed_gc_msg', 'printed_marked_gc_msg', 'gc_msg'):
|
|
w = self.msg_win_mgr.get_window(jid, account)
|
|
if jid in self.minimized_controls[account]:
|
|
self.roster.on_groupchat_maximized(None, jid, account)
|
|
return
|
|
ctrl = self.msg_win_mgr.get_gc_control(jid, account)
|
|
|
|
elif type_ in ('printed_chat', 'chat', ''):
|
|
# '' is for log in/out notifications
|
|
|
|
ctrl = self.msg_win_mgr.search_control(jid, account, resource)
|
|
|
|
if not ctrl:
|
|
highest_contact = app.contacts.\
|
|
get_contact_with_highest_priority(account, jid)
|
|
# jid can have a window if this resource was lower when he sent
|
|
# message and is now higher because the other one is offline
|
|
if resource and highest_contact.resource == resource and \
|
|
not self.msg_win_mgr.has_window(jid, account):
|
|
# remove resource of events too
|
|
app.events.change_jid(account, fjid, jid)
|
|
resource = None
|
|
fjid = jid
|
|
|
|
contact = None
|
|
if resource:
|
|
contact = app.contacts.get_contact(account, jid, resource)
|
|
if not contact:
|
|
contact = highest_contact
|
|
if not contact:
|
|
# Maybe we deleted the contact from the roster
|
|
return
|
|
|
|
ctrl = self.new_chat(contact, account, resource=resource)
|
|
|
|
app.last_message_time[account][jid] = 0 # long time ago
|
|
|
|
w = ctrl.parent_win
|
|
elif type_ in ('printed_pm', 'pm'):
|
|
|
|
ctrl = self.msg_win_mgr.get_control(fjid, account)
|
|
|
|
if not ctrl:
|
|
room_jid = jid
|
|
nick = resource
|
|
gc_contact = app.contacts.get_gc_contact(
|
|
account, room_jid, nick)
|
|
if gc_contact:
|
|
show = gc_contact.show
|
|
else:
|
|
show = 'offline'
|
|
gc_contact = app.contacts.create_gc_contact(
|
|
room_jid=room_jid, account=account, name=nick,
|
|
show=show)
|
|
|
|
ctrl = self.new_private_chat(gc_contact, account)
|
|
|
|
w = ctrl.parent_win
|
|
elif type_ in ('normal', 'file-request', 'file-request-error',
|
|
'file-send-error', 'file-error', 'file-stopped', 'file-completed',
|
|
'file-hash-error', 'jingle-incoming'):
|
|
# Get the first single message event
|
|
event = app.events.get_first_event(account, fjid, type_)
|
|
if not event:
|
|
# default to jid without resource
|
|
event = app.events.get_first_event(account, jid, type_)
|
|
if not event:
|
|
return
|
|
# Open the window
|
|
self.roster.open_event(account, jid, event)
|
|
else:
|
|
# Open the window
|
|
self.roster.open_event(account, fjid, event)
|
|
elif type_ == 'gc-invitation':
|
|
event = app.events.get_first_event(account, jid, type_)
|
|
if event is None:
|
|
return
|
|
dialogs.InvitationReceivedDialog(account, event.room_jid, jid,
|
|
event.password, event.reason, event.is_continued)
|
|
app.events.remove_events(account, jid, event)
|
|
self.roster.draw_contact(jid, account)
|
|
elif type_ == 'subscription_request':
|
|
event = app.events.get_first_event(account, jid, type_)
|
|
if event is None:
|
|
return
|
|
dialogs.SubscriptionRequestWindow(jid, event.text, account,
|
|
event.nick)
|
|
app.events.remove_events(account, jid, event)
|
|
self.roster.draw_contact(jid, account)
|
|
elif type_ == 'unsubscribed':
|
|
event = app.events.get_first_event(account, jid, type_)
|
|
if event is None:
|
|
return
|
|
self.show_unsubscribed_dialog(account, event.contact)
|
|
app.events.remove_events(account, jid, event)
|
|
self.roster.draw_contact(jid, account)
|
|
if w:
|
|
w.set_active_tab(ctrl)
|
|
w.window.present()
|
|
# Using isinstance here because we want to catch all derived types
|
|
if isinstance(ctrl, ChatControlBase):
|
|
ctrl.scroll_to_end()
|
|
|
|
def join_gc_minimal(self, account, room_jid, password=None,
|
|
transient_for=None):
|
|
if account is not None:
|
|
if app.in_groupchat(account, room_jid):
|
|
# If we already in the groupchat, join_gc_room will bring
|
|
# it to front
|
|
app.interface.join_gc_room(account, room_jid, '', '')
|
|
return
|
|
|
|
con = app.connections[account]
|
|
bookmarks = con.get_module('Bookmarks').bookmarks
|
|
bookmark = bookmarks.get(room_jid, None)
|
|
if bookmark is not None:
|
|
app.interface.join_gc_room(
|
|
account, room_jid, bookmark['nick'], bookmark['password'])
|
|
return
|
|
|
|
try:
|
|
room_jid = helpers.parse_jid(room_jid)
|
|
except helpers.InvalidFormat:
|
|
ErrorDialog('Invalid JID',
|
|
transient_for=app.app.get_active_window())
|
|
return
|
|
|
|
connected_accounts = app.get_connected_accounts()
|
|
if account is not None and account not in connected_accounts:
|
|
connected_accounts = None
|
|
if not connected_accounts:
|
|
ErrorDialog(
|
|
_('You are not connected to the server'),
|
|
_('You can not join a group chat unless you are connected.'),
|
|
transient_for=app.app.get_active_window())
|
|
return
|
|
|
|
def _on_discover_result():
|
|
if not muc_caps_cache.is_cached(room_jid):
|
|
ErrorDialog(_('JID is not a Groupchat'),
|
|
transient_for=app.app.get_active_window())
|
|
return
|
|
JoinGroupchatWindow(account, room_jid, password=password,
|
|
transient_for=transient_for)
|
|
|
|
disco_account = connected_accounts[0] if account is None else account
|
|
app.connections[disco_account].get_module('Discovery').disco_muc(
|
|
room_jid, _on_discover_result)
|
|
|
|
################################################################################
|
|
### Methods dealing with emoticons
|
|
################################################################################
|
|
|
|
@property
|
|
def basic_pattern_re(self):
|
|
if not self._basic_pattern_re:
|
|
self._basic_pattern_re = re.compile(self.basic_pattern,
|
|
re.IGNORECASE)
|
|
return self._basic_pattern_re
|
|
|
|
@property
|
|
def emot_and_basic_re(self):
|
|
if not self._emot_and_basic_re:
|
|
self._emot_and_basic_re = re.compile(
|
|
self.emot_and_basic, re.IGNORECASE)
|
|
return self._emot_and_basic_re
|
|
|
|
@property
|
|
def sth_at_sth_dot_sth_re(self):
|
|
if not self._sth_at_sth_dot_sth_re:
|
|
self._sth_at_sth_dot_sth_re = re.compile(self.sth_at_sth_dot_sth)
|
|
return self._sth_at_sth_dot_sth_re
|
|
|
|
@property
|
|
def invalid_XML_chars_re(self):
|
|
if not self._invalid_XML_chars_re:
|
|
self._invalid_XML_chars_re = re.compile(self.invalid_XML_chars)
|
|
return self._invalid_XML_chars_re
|
|
|
|
def make_regexps(self):
|
|
# regexp meta characters are: . ^ $ * + ? { } [ ] \ | ( )
|
|
# one escapes the metachars with \
|
|
# \S matches anything but ' ' '\t' '\n' '\r' '\f' and '\v'
|
|
# \s matches any whitespace character
|
|
# \w any alphanumeric character
|
|
# \W any non-alphanumeric character
|
|
# \b means word boundary. This is a zero-width assertion that
|
|
# matches only at the beginning or end of a word.
|
|
# ^ matches at the beginning of lines
|
|
#
|
|
# * means 0 or more times
|
|
# + means 1 or more times
|
|
# ? means 0 or 1 time
|
|
# | means or
|
|
# [^*] anything but '*' (inside [] you don't have to escape metachars)
|
|
# [^\s*] anything but whitespaces and '*'
|
|
# (?<!\S) is a one char lookbehind assertion and asks for any leading
|
|
# whitespace
|
|
# and matches beginning of lines so we have correct formatting detection
|
|
# even if the text is just '*foo*'
|
|
# (?!\S) is the same thing but it's a lookahead assertion
|
|
# \S*[^\s\W] --> in the matching string don't match ? or ) etc.. if at
|
|
# the end
|
|
# so http://be) will match http://be and http://be)be) will match
|
|
# http://be)be
|
|
|
|
self._basic_pattern_re = None
|
|
self._emot_and_basic_re = None
|
|
self._sth_at_sth_dot_sth_re = None
|
|
self._invalid_XML_chars_re = None
|
|
|
|
legacy_prefixes = r"((?<=\()(www|ftp)\.([A-Za-z0-9\.\-_~:/\?#\[\]@!\$"\
|
|
r"&'\(\)\*\+,;=]|%[A-Fa-f0-9]{2})+(?=\)))"\
|
|
r"|((www|ftp)\.([A-Za-z0-9\.\-_~:/\?#\[\]@!\$&'\(\)\*\+,;=]"\
|
|
r"|%[A-Fa-f0-9]{2})+"\
|
|
r"\.([A-Za-z0-9\.\-_~:/\?#\[\]@!\$&'\(\)\*\+,;=]|%[A-Fa-f0-9]{2})+)"
|
|
# NOTE: it's ok to catch www.gr such stuff exist!
|
|
|
|
# FIXME: recognize xmpp: and treat it specially
|
|
links = r"((?<=\()[A-Za-z][A-Za-z0-9\+\.\-]*:"\
|
|
r"([\w\.\-_~:/\?#\[\]@!\$&'\(\)\*\+,;=]|%[A-Fa-f0-9]{2})+"\
|
|
r"(?=\)))|(\w[\w\+\.\-]*:([^<>\s]|%[A-Fa-f0-9]{2})+)"
|
|
|
|
# 2nd one: at_least_one_char@at_least_one_char.at_least_one_char
|
|
mail = r'\bmailto:\S*[^\s\W]|' r'\b\S+@\S+\.\S*[^\s\W]'
|
|
|
|
# detects eg. *b* *bold* *bold bold* test *bold* *bold*! (*bold*)
|
|
# doesn't detect (it's a feature :P) * bold* *bold * * bold * test*bold*
|
|
formatting = r'|(?<!\w)' r'\*[^\s*]' r'([^*]*[^\s*])?' r'\*(?!\w)|'\
|
|
r'(?<!\S)' r'/[^\s/]' r'([^/]*[^\s/])?' r'/(?!\S)|'\
|
|
r'(?<!\w)' r'_[^\s_]' r'([^_]*[^\s_])?' r'_(?!\w)'
|
|
|
|
basic_pattern = links + '|' + mail + '|' + legacy_prefixes
|
|
|
|
link_pattern = basic_pattern
|
|
self.link_pattern_re = re.compile(link_pattern, re.I | re.U)
|
|
|
|
if app.config.get('ascii_formatting'):
|
|
basic_pattern += formatting
|
|
self.basic_pattern = basic_pattern
|
|
|
|
# because emoticons match later (in the string) they need to be after
|
|
# basic matches that may occur earlier
|
|
emoticons = emoji_data.get_regex()
|
|
if app.config.get('ascii_emoticons'):
|
|
emoticons += '|%s' % emoji_ascii_data.get_regex()
|
|
|
|
self.emot_and_basic = '%s|%s' % (basic_pattern, emoticons)
|
|
|
|
# at least one character in 3 parts (before @, after @, after .)
|
|
self.sth_at_sth_dot_sth = r'\S+@\S+\.\S*[^\s)?]'
|
|
|
|
# Invalid XML chars
|
|
self.invalid_XML_chars = '[\x00-\x08]|[\x0b-\x0c]|[\x0e-\x1f]|'\
|
|
'[\ud800-\udfff]|[\ufffe-\uffff]'
|
|
|
|
|
|
################################################################################
|
|
### Methods for opening new messages controls
|
|
################################################################################
|
|
|
|
def join_gc_room(self, account, room_jid, nick, password, minimize=False,
|
|
is_continued=False):
|
|
"""
|
|
Join the room immediately
|
|
"""
|
|
|
|
if app.contacts.get_contact(account, room_jid) and \
|
|
not app.contacts.get_contact(account, room_jid).is_groupchat():
|
|
ErrorDialog(
|
|
_('This is not a group chat'),
|
|
_('%(room_jid)s is already in your roster. Please check '
|
|
'if %(room_jid)s is a correct group chat name. If it is, '
|
|
'delete it from your roster and try joining the group chat '
|
|
'again.') % {'room_jid': room_jid})
|
|
return
|
|
|
|
if not nick:
|
|
nick = app.nicks[account]
|
|
|
|
minimized_control = app.interface.minimized_controls[account].get(
|
|
room_jid, None)
|
|
|
|
if (self.msg_win_mgr.has_window(room_jid, account) or \
|
|
minimized_control) and app.gc_connected[account][room_jid]:
|
|
if self.msg_win_mgr.has_window(room_jid, account):
|
|
gc_ctrl = self.msg_win_mgr.get_gc_control(room_jid, account)
|
|
win = gc_ctrl.parent_win
|
|
win.set_active_tab(gc_ctrl)
|
|
else:
|
|
self.roster.on_groupchat_maximized(None, room_jid, account)
|
|
return
|
|
|
|
invisible_show = app.SHOW_LIST.index('invisible')
|
|
if app.connections[account].connected == invisible_show:
|
|
ErrorDialog(
|
|
_('You cannot join a group chat while you are invisible'))
|
|
return
|
|
|
|
if minimized_control is None and not self.msg_win_mgr.has_window(
|
|
room_jid, account):
|
|
# Join new groupchat
|
|
if minimize:
|
|
# GCMIN
|
|
contact = app.contacts.create_contact(jid=room_jid,
|
|
account=account, groups=[_('Groupchats')], sub='none',
|
|
groupchat=True)
|
|
app.contacts.add_contact(account, contact)
|
|
gc_control = GroupchatControl(None, contact, nick, account)
|
|
app.interface.minimized_controls[account][room_jid] = \
|
|
gc_control
|
|
self.roster.add_groupchat(room_jid, account)
|
|
else:
|
|
self.new_room(room_jid, nick, account,
|
|
is_continued=is_continued)
|
|
elif minimized_control is None:
|
|
# We are already in that groupchat
|
|
gc_control = self.msg_win_mgr.get_gc_control(room_jid, account)
|
|
gc_control.nick = nick
|
|
gc_control.parent_win.set_active_tab(gc_control)
|
|
|
|
# Connect
|
|
app.connections[account].join_gc(nick, room_jid, password)
|
|
if password:
|
|
app.gc_passwords[room_jid] = password
|
|
|
|
def new_room(self, room_jid, nick, account, is_continued=False):
|
|
# Get target window, create a control, and associate it with the window
|
|
# GCMIN
|
|
contact = app.contacts.create_contact(jid=room_jid, account=account,
|
|
groups=[_('Groupchats')], sub='none', groupchat=True)
|
|
app.contacts.add_contact(account, contact)
|
|
mw = self.msg_win_mgr.get_window(contact.jid, account)
|
|
if not mw:
|
|
mw = self.msg_win_mgr.create_window(contact, account,
|
|
GroupchatControl.TYPE_ID)
|
|
gc_control = GroupchatControl(mw, contact, nick, account,
|
|
is_continued=is_continued)
|
|
mw.new_tab(gc_control)
|
|
mw.set_active_tab(gc_control)
|
|
|
|
def new_private_chat(self, gc_contact, account, session=None):
|
|
conn = app.connections[account]
|
|
if not session and gc_contact.get_full_jid() in conn.sessions:
|
|
sessions = [s for s in conn.sessions[gc_contact.get_full_jid()].\
|
|
values() if isinstance(s, ChatControlSession)]
|
|
|
|
# look for an existing session with a chat control
|
|
for s in sessions:
|
|
if s.control:
|
|
session = s
|
|
break
|
|
if not session and sessions:
|
|
# there are no sessions with chat controls, just take the first
|
|
# one
|
|
session = sessions[0]
|
|
if not session:
|
|
# couldn't find an existing ChatControlSession, just make a new one
|
|
session = conn.make_new_session(gc_contact.get_full_jid(), None,
|
|
'pm')
|
|
|
|
contact = gc_contact.as_contact()
|
|
if not session.control:
|
|
message_window = self.msg_win_mgr.get_window(
|
|
gc_contact.get_full_jid(), account)
|
|
if not message_window:
|
|
message_window = self.msg_win_mgr.create_window(contact,
|
|
account, message_control.TYPE_PM)
|
|
|
|
session.control = PrivateChatControl(message_window, gc_contact,
|
|
contact, account, session)
|
|
message_window.new_tab(session.control)
|
|
|
|
if app.events.get_events(account, gc_contact.get_full_jid()):
|
|
# We call this here to avoid race conditions with widget validation
|
|
session.control.read_queue()
|
|
|
|
return session.control
|
|
|
|
def new_chat(self, contact, account, resource=None, session=None):
|
|
# Get target window, create a control, and associate it with the window
|
|
type_ = message_control.TYPE_CHAT
|
|
|
|
fjid = contact.jid
|
|
if resource:
|
|
fjid += '/' + resource
|
|
|
|
mw = self.msg_win_mgr.get_window(fjid, account)
|
|
if not mw:
|
|
mw = self.msg_win_mgr.create_window(contact, account, type_,
|
|
resource)
|
|
|
|
chat_control = ChatControl(mw, contact, account, session, resource)
|
|
|
|
mw.new_tab(chat_control)
|
|
|
|
if app.events.get_events(account, fjid):
|
|
# We call this here to avoid race conditions with widget validation
|
|
chat_control.read_queue()
|
|
|
|
return chat_control
|
|
|
|
def new_chat_from_jid(self, account, fjid, message=None):
|
|
jid, resource = app.get_room_and_nick_from_fjid(fjid)
|
|
contact = app.contacts.get_contact(account, jid, resource)
|
|
added_to_roster = False
|
|
if not contact:
|
|
added_to_roster = True
|
|
contact = self.roster.add_to_not_in_the_roster(account, jid,
|
|
resource=resource)
|
|
|
|
ctrl = self.msg_win_mgr.get_control(fjid, account)
|
|
|
|
if not ctrl:
|
|
ctrl = self.new_chat(contact, account,
|
|
resource=resource)
|
|
if app.events.get_events(account, fjid):
|
|
ctrl.read_queue()
|
|
|
|
if message:
|
|
buffer_ = ctrl.msg_textview.get_buffer()
|
|
buffer_.set_text(message)
|
|
mw = ctrl.parent_win
|
|
mw.set_active_tab(ctrl)
|
|
# For JEP-0172
|
|
if added_to_roster:
|
|
ctrl.user_nick = app.nicks[account]
|
|
|
|
return ctrl
|
|
|
|
def on_open_chat_window(self, widget, contact, account, resource=None,
|
|
session=None):
|
|
# Get the window containing the chat
|
|
fjid = contact.jid
|
|
|
|
if resource:
|
|
fjid += '/' + resource
|
|
|
|
ctrl = None
|
|
|
|
if session:
|
|
ctrl = session.control
|
|
if not ctrl:
|
|
win = self.msg_win_mgr.get_window(fjid, account)
|
|
|
|
if win:
|
|
ctrl = win.get_control(fjid, account)
|
|
|
|
if not ctrl:
|
|
ctrl = self.new_chat(contact, account, resource=resource,
|
|
session=session)
|
|
# last message is long time ago
|
|
app.last_message_time[account][ctrl.get_full_jid()] = 0
|
|
|
|
win = ctrl.parent_win
|
|
|
|
win.set_active_tab(ctrl)
|
|
|
|
if app.connections[account].is_zeroconf and \
|
|
app.connections[account].status in ('offline', 'invisible'):
|
|
ctrl = win.get_control(fjid, account)
|
|
if ctrl:
|
|
ctrl.got_disconnected()
|
|
|
|
################################################################################
|
|
### Other Methods
|
|
################################################################################
|
|
|
|
|
|
def enable_music_listener(self):
|
|
listener = music_track.MusicTrackListener.get()
|
|
if not self.music_track_changed_signal:
|
|
self.music_track_changed_signal = listener.connect(
|
|
'music-track-changed', self.music_track_changed)
|
|
listener.start()
|
|
|
|
def disable_music_listener(self):
|
|
listener = music_track.MusicTrackListener.get()
|
|
listener.disconnect(self.music_track_changed_signal)
|
|
self.music_track_changed_signal = None
|
|
listener.stop()
|
|
|
|
@staticmethod
|
|
def music_track_changed(unused_listener, music_track_info, account=None):
|
|
if not account:
|
|
accounts = app.connections.keys()
|
|
else:
|
|
accounts = [account]
|
|
|
|
if music_track_info is None or music_track_info.paused:
|
|
artist = title = source = ''
|
|
else:
|
|
artist = music_track_info.artist
|
|
title = music_track_info.title
|
|
source = music_track_info.album
|
|
for acct in accounts:
|
|
if not app.account_is_connected(acct):
|
|
continue
|
|
if not app.connections[acct].get_module('PEP').supported:
|
|
continue
|
|
if not app.config.get_per('accounts', acct, 'publish_tune'):
|
|
continue
|
|
if app.connections[acct].music_track_info == music_track_info:
|
|
continue
|
|
app.connections[acct].get_module('UserTune').send(
|
|
(artist, title, source, '', ''))
|
|
app.connections[acct].music_track_info = music_track_info
|
|
|
|
def read_sleepy(self):
|
|
"""
|
|
Check idle status and change that status if needed
|
|
"""
|
|
if not idle.Monitor.poll():
|
|
# idle detection is not supported in that OS
|
|
return False # stop looping in vain
|
|
|
|
for account in app.connections:
|
|
if account not in app.sleeper_state or \
|
|
not app.sleeper_state[account]:
|
|
continue
|
|
if idle.Monitor.is_awake():
|
|
if app.sleeper_state[account] in ('autoaway', 'autoxa'):
|
|
# we go online
|
|
self.roster.send_status(account, 'online',
|
|
app.status_before_autoaway[account])
|
|
app.status_before_autoaway[account] = ''
|
|
app.sleeper_state[account] = 'online'
|
|
if app.sleeper_state[account] == 'idle':
|
|
# we go to the previous state
|
|
connected = app.connections[account].connected
|
|
self.roster.send_status(account, app.SHOW_LIST[connected],
|
|
app.status_before_autoaway[account])
|
|
app.status_before_autoaway[account] = ''
|
|
app.sleeper_state[account] = 'off'
|
|
elif idle.Monitor.is_away() and app.config.get('autoaway'):
|
|
if app.sleeper_state[account] == 'online':
|
|
# we save out online status
|
|
app.status_before_autoaway[account] = \
|
|
app.connections[account].status
|
|
# we go away (no auto status) [we pass True to auto param]
|
|
auto_message = app.config.get('autoaway_message')
|
|
if not auto_message:
|
|
auto_message = app.connections[account].status
|
|
else:
|
|
auto_message = auto_message.replace('$S', '%(status)s')
|
|
auto_message = auto_message.replace('$T', '%(time)s')
|
|
auto_message = auto_message % {
|
|
'status': app.status_before_autoaway[account],
|
|
'time': app.config.get('autoawaytime')
|
|
}
|
|
self.roster.send_status(account, 'away', auto_message,
|
|
auto=True)
|
|
app.sleeper_state[account] = 'autoaway'
|
|
elif app.sleeper_state[account] == 'off':
|
|
# we save out online status
|
|
app.status_before_autoaway[account] = \
|
|
app.connections[account].status
|
|
connected = app.connections[account].connected
|
|
self.roster.send_status(account, app.SHOW_LIST[connected],
|
|
app.status_before_autoaway[account], auto=True)
|
|
app.sleeper_state[account] = 'idle'
|
|
elif idle.Monitor.is_xa() and \
|
|
app.sleeper_state[account] in ('online', 'autoaway',
|
|
'autoaway-forced') and app.config.get('autoxa'):
|
|
# we go extended away [we pass True to auto param]
|
|
auto_message = app.config.get('autoxa_message')
|
|
if not auto_message:
|
|
auto_message = app.connections[account].status
|
|
else:
|
|
auto_message = auto_message.replace('$S', '%(status)s')
|
|
auto_message = auto_message.replace('$T', '%(time)s')
|
|
auto_message = auto_message % {
|
|
'status': app.status_before_autoaway[account],
|
|
'time': app.config.get('autoxatime')
|
|
}
|
|
self.roster.send_status(account, 'xa', auto_message, auto=True)
|
|
app.sleeper_state[account] = 'autoxa'
|
|
return True # renew timeout (loop for ever)
|
|
|
|
def autoconnect(self):
|
|
"""
|
|
Auto connect at startup
|
|
"""
|
|
# dict of account that want to connect sorted by status
|
|
shows = {}
|
|
for a in app.connections:
|
|
if app.config.get_per('accounts', a, 'autoconnect'):
|
|
if app.config.get_per('accounts', a, 'restore_last_status'):
|
|
self.roster.send_status(a, app.config.get_per('accounts',
|
|
a, 'last_status'), helpers.from_one_line(
|
|
app.config.get_per('accounts', a, 'last_status_msg')))
|
|
continue
|
|
show = app.config.get_per('accounts', a, 'autoconnect_as')
|
|
if show not in app.SHOW_LIST:
|
|
continue
|
|
if show not in shows:
|
|
shows[show] = [a]
|
|
else:
|
|
shows[show].append(a)
|
|
def on_message(message, pep_dict):
|
|
if message is None:
|
|
return
|
|
for a in shows[show]:
|
|
self.roster.send_status(a, show, message)
|
|
self.roster.send_pep(a, pep_dict)
|
|
for show in shows:
|
|
self.roster.get_status_message(show, on_message)
|
|
return False
|
|
|
|
def show_systray(self):
|
|
self.systray_enabled = True
|
|
self.systray.show_icon()
|
|
|
|
def hide_systray(self):
|
|
self.systray_enabled = False
|
|
self.systray.hide_icon()
|
|
|
|
@staticmethod
|
|
def on_launch_browser_mailer(widget, url, kind):
|
|
helpers.launch_browser_mailer(kind, url)
|
|
|
|
def process_connections(self):
|
|
"""
|
|
Called each foo (200) milliseconds. Check for idlequeue timeouts
|
|
"""
|
|
try:
|
|
app.idlequeue.process()
|
|
except Exception:
|
|
# Otherwise, an exception will stop our loop
|
|
|
|
if sys.platform == 'win32':
|
|
# On Windows process() calls select.select(), so we need this
|
|
# executed as often as possible.
|
|
# Adding it directly with GLib.idle_add() causes Gajim to use
|
|
# too much CPU time. That's why its added with 1ms timeout.
|
|
# On Linux only alarms are checked in process(), so we use
|
|
# a bigger timeout
|
|
timeout, in_seconds = 1, None
|
|
else:
|
|
timeout, in_seconds = app.idlequeue.PROCESS_TIMEOUT
|
|
|
|
if in_seconds:
|
|
GLib.timeout_add_seconds(timeout, self.process_connections)
|
|
else:
|
|
GLib.timeout_add(timeout, self.process_connections)
|
|
raise
|
|
return True # renew timeout (loop for ever)
|
|
|
|
@staticmethod
|
|
def save_config():
|
|
err_str = parser.write()
|
|
if err_str is not None:
|
|
print(err_str, file=sys.stderr)
|
|
# it is good to notify the user
|
|
# in case he or she cannot see the output of the console
|
|
error_dialog = ErrorDialog(_('Could not save your settings and '
|
|
'preferences'), err_str)
|
|
error_dialog.run()
|
|
sys.exit()
|
|
|
|
@staticmethod
|
|
def update_avatar(account=None, jid=None, contact=None, room_avatar=False):
|
|
if room_avatar:
|
|
app.nec.push_incoming_event(
|
|
UpdateRoomAvatarEvent(None, account=account, jid=jid))
|
|
elif contact is None:
|
|
app.nec.push_incoming_event(
|
|
UpdateRosterAvatarEvent(None, account=account, jid=jid))
|
|
else:
|
|
app.nec.push_incoming_event(
|
|
UpdateGCAvatarEvent(None, contact=contact))
|
|
|
|
def save_avatar(self, data, publish=False):
|
|
"""
|
|
Save an avatar to the harddisk
|
|
|
|
:param data: publish=False data must be bytes
|
|
publish=True data must be a path to a file
|
|
|
|
:param publish: If publish is True, the method scales the file
|
|
to AvatarSize.PUBLISH size before saving
|
|
|
|
returns SHA1 value of the avatar or None on error
|
|
"""
|
|
if data is None:
|
|
return
|
|
|
|
if publish:
|
|
with open(data, 'rb') as file:
|
|
data = file.read()
|
|
pixbuf = gtkgui_helpers.get_pixbuf_from_data(data)
|
|
if pixbuf is None:
|
|
return
|
|
|
|
width = pixbuf.get_width()
|
|
height = pixbuf.get_height()
|
|
if width > AvatarSize.PUBLISH or height > AvatarSize.PUBLISH:
|
|
# Scale only down, never up
|
|
width, height = gtkgui_helpers.scale_with_ratio(
|
|
AvatarSize.PUBLISH, width, height)
|
|
pixbuf = pixbuf.scale_simple(width,
|
|
height,
|
|
GdkPixbuf.InterpType.BILINEAR)
|
|
publish_path = os.path.join(
|
|
configpaths.get('AVATAR'), 'temp_publish')
|
|
pixbuf.savev(publish_path, 'png', [], [])
|
|
with open(publish_path, 'rb') as file:
|
|
data = file.read()
|
|
return self.save_avatar(data)
|
|
|
|
sha = hashlib.sha1(data).hexdigest()
|
|
path = os.path.join(configpaths.get('AVATAR'), sha)
|
|
try:
|
|
with open(path, "wb") as output_file:
|
|
output_file.write(data)
|
|
except Exception:
|
|
app.log('avatar').error('Saving avatar failed', exc_info=True)
|
|
return
|
|
|
|
return sha
|
|
|
|
@staticmethod
|
|
def get_avatar(filename, size=None, scale=None, publish=False):
|
|
if filename is None or '':
|
|
return
|
|
|
|
if size is None and scale is not None:
|
|
raise ValueError
|
|
|
|
if scale is not None:
|
|
size = size * scale
|
|
|
|
if publish:
|
|
path = os.path.join(configpaths.get('AVATAR'), filename)
|
|
with open(path, 'rb') as file:
|
|
data = file.read()
|
|
return data
|
|
|
|
try:
|
|
pixbuf = app.avatar_cache[filename][size]
|
|
if scale is None:
|
|
return pixbuf
|
|
return Gdk.cairo_surface_create_from_pixbuf(pixbuf, scale)
|
|
except KeyError:
|
|
pass
|
|
|
|
path = os.path.join(configpaths.get('AVATAR'), filename)
|
|
if not os.path.isfile(path):
|
|
return
|
|
|
|
pixbuf = None
|
|
try:
|
|
if size is not None:
|
|
pixbuf = GdkPixbuf.Pixbuf.new_from_file_at_scale(
|
|
path, size, size, True)
|
|
else:
|
|
pixbuf = GdkPixbuf.Pixbuf.new_from_file(path)
|
|
except GLib.GError:
|
|
app.log('avatar').info(
|
|
'loading avatar %s failed. Try to convert '
|
|
'avatar image using pillow', filename)
|
|
try:
|
|
with open(path, 'rb') as im_handle:
|
|
img = Image.open(im_handle)
|
|
avatar = img.convert("RGBA")
|
|
except (NameError, OSError):
|
|
app.log('avatar').warning('Pillow convert failed: %s', filename)
|
|
app.log('avatar').debug('Error', exc_info=True)
|
|
return
|
|
array = GLib.Bytes.new(avatar.tobytes())
|
|
width, height = avatar.size
|
|
pixbuf = GdkPixbuf.Pixbuf.new_from_bytes(
|
|
array, GdkPixbuf.Colorspace.RGB, True,
|
|
8, width, height, width * 4)
|
|
if size:
|
|
width, height = gtkgui_helpers.scale_with_ratio(
|
|
size, width, height)
|
|
pixbuf = pixbuf.scale_simple(
|
|
width, height, GdkPixbuf.InterpType.BILINEAR)
|
|
|
|
if filename not in app.avatar_cache:
|
|
app.avatar_cache[filename] = {}
|
|
app.avatar_cache[filename][size] = pixbuf
|
|
|
|
if scale is None:
|
|
return pixbuf
|
|
return Gdk.cairo_surface_create_from_pixbuf(pixbuf, scale)
|
|
|
|
@staticmethod
|
|
def avatar_exists(filename):
|
|
path = os.path.join(configpaths.get('AVATAR'), filename)
|
|
if not os.path.isfile(path):
|
|
return False
|
|
return True
|
|
|
|
# does JID exist only within a groupchat?
|
|
def is_pm_contact(self, fjid, account):
|
|
bare_jid = app.get_jid_without_resource(fjid)
|
|
|
|
gc_ctrl = self.msg_win_mgr.get_gc_control(bare_jid, account)
|
|
|
|
if not gc_ctrl and \
|
|
bare_jid in self.minimized_controls[account]:
|
|
gc_ctrl = self.minimized_controls[account][bare_jid]
|
|
|
|
return gc_ctrl and gc_ctrl.type_id == message_control.TYPE_GC
|
|
|
|
@staticmethod
|
|
def get_pep_icon(pep_obj):
|
|
if pep_obj == PEPEventType.MOOD:
|
|
received_mood = pep_obj.data['mood']
|
|
mood = received_mood if received_mood in MOODS else 'unknown'
|
|
return gtkgui_helpers.load_mood_icon(mood).get_pixbuf()
|
|
|
|
if pep_obj == PEPEventType.TUNE:
|
|
path = os.path.join(
|
|
configpaths.get('DATA'), 'emoticons', 'static', 'music.png')
|
|
return GdkPixbuf.Pixbuf.new_from_file(path)
|
|
|
|
if pep_obj == PEPEventType.ACTIVITY:
|
|
pep_ = pep_obj.data
|
|
activity = pep_['activity']
|
|
|
|
has_known_activity = activity in ACTIVITIES
|
|
has_known_subactivity = (has_known_activity and
|
|
'subactivity' in pep_ and
|
|
pep_['subactivity'] in ACTIVITIES[activity])
|
|
|
|
if has_known_activity:
|
|
if has_known_subactivity:
|
|
subactivity = pep_['subactivity']
|
|
return gtkgui_helpers.load_activity_icon(
|
|
activity, subactivity).get_pixbuf()
|
|
return gtkgui_helpers.load_activity_icon(activity).get_pixbuf()
|
|
return gtkgui_helpers.load_activity_icon('unknown').get_pixbuf()
|
|
|
|
if pep_obj == PEPEventType.LOCATION:
|
|
icon = gtkgui_helpers.get_icon_pixmap(
|
|
'applications-internet', quiet=True)
|
|
return icon
|
|
|
|
@staticmethod
|
|
def create_ipython_window():
|
|
try:
|
|
from gajim.dev.ipython_view import IPythonView
|
|
except ImportError:
|
|
print('ipython_view not found')
|
|
return
|
|
from gi.repository import Pango
|
|
|
|
if os.name == 'nt':
|
|
font = 'Lucida Console 9'
|
|
else:
|
|
font = 'Luxi Mono 10'
|
|
|
|
window = Gtk.Window()
|
|
window.set_size_request(750, 550)
|
|
window.set_resizable(True)
|
|
sw = Gtk.ScrolledWindow()
|
|
sw.set_policy(Gtk.PolicyType.AUTOMATIC, Gtk.PolicyType.AUTOMATIC)
|
|
view = IPythonView()
|
|
view.override_font(Pango.FontDescription(font))
|
|
view.set_wrap_mode(Gtk.WrapMode.CHAR)
|
|
sw.add(view)
|
|
window.add(sw)
|
|
window.show_all()
|
|
def on_delete(win, event):
|
|
win.hide()
|
|
return True
|
|
window.connect('delete_event', on_delete)
|
|
view.updateNamespace({'gajim': app})
|
|
app.ipython_window = window
|
|
|
|
def network_status_changed(self, monitor, connected):
|
|
if connected == self.network_state:
|
|
# This callback gets called a lot from GTK with the
|
|
# same state, not only on change.
|
|
return
|
|
self.network_state = connected
|
|
log.debug('NetworkMonitor state change: %s', connected)
|
|
if connected:
|
|
for connection in app.connections.values():
|
|
if connection.connected <= 0 and connection.time_to_reconnect:
|
|
log.info('Connect %s', connection.name)
|
|
connection.reconnect()
|
|
else:
|
|
for connection in app.connections.values():
|
|
if connection.connected > 1:
|
|
log.info('Disconnect %s', connection.name)
|
|
connection.disconnectedReconnCB()
|
|
|
|
def create_zeroconf_default_config(self):
|
|
if app.config.get_per('accounts', app.ZEROCONF_ACC_NAME, 'name'):
|
|
return
|
|
log.info('Creating zeroconf account')
|
|
app.config.add_per('accounts', app.ZEROCONF_ACC_NAME)
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'autoconnect', True)
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME, 'no_log_for',
|
|
'')
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME, 'password',
|
|
'zeroconf')
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'sync_with_global_status', True)
|
|
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'custom_port', 5298)
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'is_zeroconf', True)
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'use_ft_proxies', False)
|
|
app.config.set_per('accounts', app.ZEROCONF_ACC_NAME,
|
|
'active', False)
|
|
|
|
def run(self, application):
|
|
if app.config.get('trayicon') != 'never':
|
|
self.show_systray()
|
|
|
|
self.roster = roster_window.RosterWindow(application)
|
|
if self.msg_win_mgr.mode == \
|
|
MessageWindowMgr.ONE_MSG_WINDOW_ALWAYS_WITH_ROSTER:
|
|
self.msg_win_mgr.create_window(None, None, None)
|
|
|
|
# Creating plugin manager
|
|
from gajim import plugins
|
|
app.plugin_manager = plugins.PluginManager()
|
|
app.plugin_manager.init_plugins()
|
|
|
|
helpers.update_optional_features()
|
|
# prepopulate data which we are sure of; note: we do not log these info
|
|
for account in app.connections:
|
|
gajimcaps = caps_cache.capscache[
|
|
('sha-1', app.caps_hash[account])]
|
|
gajimcaps.identities = [app.gajim_identity]
|
|
gajimcaps.features = app.gajim_common_features + \
|
|
app.gajim_optional_features[account]
|
|
|
|
self.roster._before_fill()
|
|
for account in app.connections:
|
|
app.connections[account].get_module('Roster').load_roster()
|
|
self.roster._after_fill()
|
|
|
|
# get instances for windows/dialogs that will show_all()/hide()
|
|
self.instances['file_transfers'] = FileTransfersWindow()
|
|
|
|
GLib.timeout_add(100, self.autoconnect)
|
|
if sys.platform == 'win32':
|
|
timeout, in_seconds = 20, None
|
|
else:
|
|
timeout, in_seconds = app.idlequeue.PROCESS_TIMEOUT
|
|
|
|
if in_seconds:
|
|
GLib.timeout_add_seconds(timeout, self.process_connections)
|
|
else:
|
|
GLib.timeout_add(timeout, self.process_connections)
|
|
GLib.timeout_add_seconds(app.config.get(
|
|
'check_idle_every_foo_seconds'), self.read_sleepy)
|
|
|
|
def remote_init():
|
|
if app.config.get('remote_control'):
|
|
try:
|
|
from gajim import remote_control
|
|
remote_control.GajimRemote()
|
|
except Exception:
|
|
pass
|
|
GLib.timeout_add_seconds(5, remote_init)
|
|
|
|
def __init__(self):
|
|
app.interface = self
|
|
app.thread_interface = ThreadInterface
|
|
# This is the manager and factory of message windows set by the module
|
|
self.msg_win_mgr = None
|
|
self.jabber_state_images = {'16': {}, '24': {}, '32': {}, 'opened': {},
|
|
'closed': {}}
|
|
self.minimized_controls = {}
|
|
self.status_sent_to_users = {}
|
|
self.status_sent_to_groups = {}
|
|
self.gpg_passphrase = {}
|
|
self.pass_dialog = {}
|
|
self.db_error_dialog = None
|
|
|
|
self.handlers = {}
|
|
self.roster = None
|
|
self._invalid_XML_chars_re = None
|
|
self._basic_pattern_re = None
|
|
self._emot_and_basic_re = None
|
|
self._sth_at_sth_dot_sth_re = None
|
|
self.link_pattern_re = None
|
|
self.invalid_XML_chars = None
|
|
self.basic_pattern = None
|
|
self.emot_and_basic = None
|
|
self.sth_at_sth_dot_sth = None
|
|
|
|
cfg_was_read = parser.read()
|
|
|
|
if not cfg_was_read:
|
|
# enable plugin_installer by default when creating config file
|
|
app.config.set_per('plugins', 'plugin_installer', 'active', True)
|
|
|
|
# Load CSS files
|
|
app.load_css_config()
|
|
|
|
app.logger.reset_shown_unread_messages()
|
|
# override logging settings from config (don't take care of '-q' option)
|
|
if app.config.get('verbose'):
|
|
logging_helpers.set_verbose()
|
|
|
|
for account in app.config.get_per('accounts'):
|
|
if app.config.get_per('accounts', account, 'is_zeroconf'):
|
|
app.ZEROCONF_ACC_NAME = account
|
|
break
|
|
# Is gnome configured to activate row on single click ?
|
|
# try:
|
|
# gi.require_version('GConf', '2.0')
|
|
# from gi.repository import GConf
|
|
# client = GConf.Client.get_default()
|
|
# click_policy = client.get_string(
|
|
# '/apps/nautilus/preferences/click_policy')
|
|
# if click_policy == 'single':
|
|
# app.single_click = True
|
|
# except Exception:
|
|
# pass
|
|
# add default status messages if there is not in the config file
|
|
if not app.config.get_per('statusmsg'):
|
|
default = app.config.statusmsg_default
|
|
for msg in default:
|
|
app.config.add_per('statusmsg', msg)
|
|
app.config.set_per('statusmsg', msg, 'message',
|
|
default[msg][0])
|
|
app.config.set_per('statusmsg', msg, 'activity',
|
|
default[msg][1])
|
|
app.config.set_per('statusmsg', msg, 'subactivity',
|
|
default[msg][2])
|
|
app.config.set_per('statusmsg', msg, 'activity_text',
|
|
default[msg][3])
|
|
app.config.set_per('statusmsg', msg, 'mood',
|
|
default[msg][4])
|
|
app.config.set_per('statusmsg', msg, 'mood_text',
|
|
default[msg][5])
|
|
|
|
# Add Tor proxy if there is not in the config
|
|
if not app.config.get_per('proxies'):
|
|
default = app.config.proxies_default
|
|
for proxy in default:
|
|
app.config.add_per('proxies', proxy)
|
|
app.config.set_per('proxies', proxy, 'type',
|
|
default[proxy][0])
|
|
app.config.set_per('proxies', proxy, 'host',
|
|
default[proxy][1])
|
|
app.config.set_per('proxies', proxy, 'port',
|
|
default[proxy][2])
|
|
|
|
|
|
app.idlequeue = idlequeue.get_idlequeue()
|
|
# resolve and keep current record of resolved hosts
|
|
app.resolver = resolver.get_resolver()
|
|
app.socks5queue = socks5.SocksQueue(app.idlequeue,
|
|
self.handle_event_file_rcv_completed,
|
|
self.handle_event_file_progress,
|
|
self.handle_event_file_error)
|
|
app.proxy65_manager = proxy65_manager.Proxy65Manager(app.idlequeue)
|
|
app.default_session_type = ChatControlSession
|
|
|
|
# Creating Network Events Controller
|
|
from gajim.common import nec
|
|
app.nec = nec.NetworkEventsController()
|
|
app.notification = notify.Notification()
|
|
|
|
self.create_core_handlers_list()
|
|
self.register_core_handlers()
|
|
|
|
self.create_zeroconf_default_config()
|
|
if app.config.get_per('accounts', app.ZEROCONF_ACC_NAME, 'active') \
|
|
and app.is_installed('ZEROCONF'):
|
|
app.connections[app.ZEROCONF_ACC_NAME] = \
|
|
connection_zeroconf.ConnectionZeroconf(app.ZEROCONF_ACC_NAME)
|
|
for account in app.config.get_per('accounts'):
|
|
if not app.config.get_per('accounts', account, 'is_zeroconf') and\
|
|
app.config.get_per('accounts', account, 'active'):
|
|
app.connections[account] = Connection(account)
|
|
|
|
# gtk hooks
|
|
# Gtk.about_dialog_set_email_hook(self.on_launch_browser_mailer, 'mail')
|
|
# Gtk.about_dialog_set_url_hook(self.on_launch_browser_mailer, 'url')
|
|
# Gtk.link_button_set_uri_hook(self.on_launch_browser_mailer, 'url')
|
|
|
|
self.instances = {}
|
|
|
|
for a in app.connections:
|
|
self.instances[a] = {'infos': {}, 'disco': {}, 'gc_config': {},
|
|
'search': {}, 'online_dialog': {}, 'sub_request': {}}
|
|
# online_dialog contains all dialogs that have a meaning only when
|
|
# we are not disconnected
|
|
self.minimized_controls[a] = {}
|
|
app.contacts.add_account(a)
|
|
app.groups[a] = {}
|
|
app.gc_connected[a] = {}
|
|
app.automatic_rooms[a] = {}
|
|
app.newly_added[a] = []
|
|
app.to_be_removed[a] = []
|
|
app.nicks[a] = app.config.get_per('accounts', a, 'name')
|
|
app.block_signed_in_notifications[a] = True
|
|
app.sleeper_state[a] = 0
|
|
app.last_message_time[a] = {}
|
|
app.status_before_autoaway[a] = ''
|
|
app.gajim_optional_features[a] = []
|
|
app.caps_hash[a] = ''
|
|
|
|
self.remote_ctrl = None
|
|
|
|
# Handle screensaver
|
|
if sys.platform not in ('win32', 'darwin'):
|
|
logind.enable()
|
|
screensaver.enable()
|
|
|
|
self.show_vcard_when_connect = []
|
|
|
|
idle.Monitor.set_interval(app.config.get('autoawaytime') * 60,
|
|
app.config.get('autoxatime') * 60)
|
|
|
|
gtkgui_helpers.make_jabber_state_images()
|
|
|
|
self.systray_enabled = False
|
|
|
|
from gajim import statusicon
|
|
self.systray = statusicon.StatusIcon()
|
|
|
|
pixs = []
|
|
for size in (16, 32, 48, 64, 128):
|
|
pix = gtkgui_helpers.get_icon_pixmap('org.gajim.Gajim', size)
|
|
if pix:
|
|
pixs.append(pix)
|
|
if pixs:
|
|
# set the icon to all windows
|
|
Gtk.Window.set_default_icon_list(pixs)
|
|
|
|
# Init emoji_chooser
|
|
from gajim.gtk.emoji_chooser import emoji_chooser
|
|
emoji_chooser.load()
|
|
self.make_regexps()
|
|
|
|
# get transports type from DB
|
|
app.transport_type = app.logger.get_transports_type()
|
|
|
|
helpers.find_soundplayer()
|
|
|
|
self.last_ftwindow_update = 0
|
|
|
|
self.music_track_changed_signal = None
|
|
|
|
self.network_monitor = Gio.NetworkMonitor.get_default()
|
|
self.network_monitor.connect('network-changed',
|
|
self.network_status_changed)
|
|
self.network_state = self.network_monitor.get_network_available()
|
|
|
|
|
|
class PassphraseRequest:
|
|
def __init__(self, keyid):
|
|
self.keyid = keyid
|
|
self.callbacks = []
|
|
self.dialog_created = False
|
|
self.dialog = None
|
|
self.passphrase = None
|
|
self.completed = False
|
|
|
|
def interrupt(self, account=None):
|
|
if account:
|
|
for (acct, cb) in self.callbacks:
|
|
if acct == account:
|
|
self.callbacks.remove((acct, cb))
|
|
else:
|
|
self.callbacks = []
|
|
if not self.callbacks:
|
|
self.dialog.window.destroy()
|
|
|
|
def run_callback(self, account, callback):
|
|
app.connections[account].gpg_passphrase(self.passphrase)
|
|
callback()
|
|
|
|
def add_callback(self, account, cb):
|
|
if self.completed:
|
|
self.run_callback(account, cb)
|
|
else:
|
|
self.callbacks.append((account, cb))
|
|
if not self.dialog_created:
|
|
self.create_dialog(account)
|
|
|
|
def complete(self, passphrase):
|
|
self.passphrase = passphrase
|
|
self.completed = True
|
|
if passphrase is not None:
|
|
GLib.timeout_add_seconds(30, app.interface.forget_gpg_passphrase,
|
|
self.keyid)
|
|
for (account, cb) in self.callbacks:
|
|
self.run_callback(account, cb)
|
|
self.callbacks = []
|
|
|
|
def create_dialog(self, account):
|
|
title = _('Passphrase Required')
|
|
second = _('Enter OpenPGP key passphrase for key %(keyid)s '
|
|
'(account %(account)s).') % {'keyid': self.keyid,
|
|
'account': account}
|
|
|
|
def _cancel():
|
|
# user cancelled, continue without GPG
|
|
self.complete(None)
|
|
|
|
def _ok(passphrase, checked, count):
|
|
result = app.connections[account].test_gpg_passphrase(passphrase)
|
|
if result == 'ok':
|
|
# passphrase is good
|
|
self.complete(passphrase)
|
|
return
|
|
|
|
if result == 'expired':
|
|
ErrorDialog(
|
|
_('OpenPGP key expired'),
|
|
_('Your OpenPGP key has expired, you will be connected to '
|
|
'%s without OpenPGP.') % account)
|
|
# Don't try to connect with GPG
|
|
app.connections[account].continue_connect_info[2] = False
|
|
self.complete(None)
|
|
return
|
|
|
|
if count < 3:
|
|
# ask again
|
|
dialogs.PassphraseDialog(
|
|
_('Wrong Passphrase'),
|
|
_('Please retype your OpenPGP passphrase or press Cancel.'),
|
|
ok_handler=(_ok, count + 1), cancel_handler=_cancel)
|
|
else:
|
|
# user failed 3 times, continue without GPG
|
|
self.complete(None)
|
|
|
|
self.dialog = dialogs.PassphraseDialog(
|
|
title, second, ok_handler=(_ok, 1), cancel_handler=_cancel)
|
|
self.dialog_created = True
|
|
|
|
|
|
class ThreadInterface:
|
|
def __init__(self, func, func_args=(), callback=None, callback_args=()):
|
|
"""
|
|
Call a function in a thread
|
|
"""
|
|
def thread_function(func, func_args, callback, callback_args):
|
|
output = func(*func_args)
|
|
if callback:
|
|
GLib.idle_add(callback, output, *callback_args)
|
|
|
|
Thread(target=thread_function, args=(func, func_args, callback,
|
|
callback_args)).start()
|