Remove old skype plugin. Use the skypeweb purple plugin instead.

RIP

This plugin relied on the skype linux client, which doesn't work
anymore. During login it just does exit(0) for mysterious reasons.
I guess that's the server trying to say that it's not supported.

This is officially dead now after a few years of kinda-almost-working.

1 files changed, 0 insertions, 523 deletions

diff --git a/protocols/skype/skyped.py b/protocols/skype/skyped.py
deleted file mode 100644
index c9bb103b..00000000
--- a/protocols/skype/skyped.py
+++ /dev/null
@@ -1,523 +0,0 @@
-#!/usr/bin/env python2.7
-#
-#   skyped.py
-#
-#   Copyright (c) 2007-2013 by Miklos Vajna <vmiklos@vmiklos.hu>
-#
-#   This program 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; either version 2 of the License, or
-#   (at your option) any later version.
-#
-#   This program 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 this program; if not, write to the Free Software
-#   Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307,
-#   USA.
-#
-
-import sys
-import os
-import signal
-import time
-import socket
-import Skype4Py
-import hashlib
-from ConfigParser import ConfigParser, NoOptionError
-from traceback import print_exception
-from fcntl import fcntl, F_SETFD, FD_CLOEXEC
-import ssl
-
-__version__ = "0.1.1"
-
-try:
-	import gobject
-	hasgobject = True
-except ImportError:
-	import select
-	import threading
-	hasgobject = False
-
-def eh(type, value, tb):
-	global options
-
-	if type != KeyboardInterrupt:
-		print_exception(type, value, tb)
-	if hasgobject:
-		gobject.MainLoop().quit()
-	if options.conn:
-		options.conn.close()
-	if not options.dont_start_skype:
-		# shut down client if it's running
-		try:
-			skype.skype.Client.Shutdown()
-		except NameError:
-			pass
-	sys.exit("Exiting.")
-
-sys.excepthook = eh
-
-def wait_for_lock(lock, timeout_to_print, timeout, msg):
-	start = time.time()
-	locked = lock.acquire(0)
-	while not(locked):
-		time.sleep(0.5)
-		if timeout_to_print and (time.time() - timeout_to_print > start):
-			dprint("%s: Waited %f seconds" % \
-					(msg, time.time() - start))
-			timeout_to_print = False
-		if timeout and (time.time() - timeout > start):
-			dprint("%s: Waited %f seconds, giving up" % \
-					(msg, time.time() - start))
-			return False
-		locked = lock.acquire(0)
-	return True
-
-def input_handler(fd, io_condition = None):
-	global options
-	global skype
-	if options.buf:
-		for i in options.buf:
-			skype.send(i.strip())
-		options.buf = None
-		if not hasgobject:
-			return True
-	else:
-		if not hasgobject:
-			close_socket = False
-			if wait_for_lock(options.lock, 3, 10, "input_handler"):
-				try:
-						input = fd.recv(1024)
-						options.lock.release()
-				except Exception, s:
-					dprint("Warning, receiving 1024 bytes failed (%s)." % s)
-					fd.close()
-					options.conn = False
-					options.lock.release()
-					return False
-				for i in input.split("\n"):
-					if i.strip() == "SET USERSTATUS OFFLINE":
-						close_socket = True
-					skype.send(i.strip())
-			return not(close_socket)
-		try:
-			input = fd.recv(1024)
-		except Exception, s:
-			dprint("Warning, receiving 1024 bytes failed (%s)." % s)
-			fd.close()
-			return False
-		for i in input.split("\n"):
-			skype.send(i.strip())
-		return True
-
-def skype_idle_handler(skype):
-	try:
-		c = skype.skype.Command("PING", Block=True)
-		skype.skype.SendCommand(c)
-	except (Skype4Py.SkypeAPIError, AttributeError), s:
-		dprint("Warning, pinging Skype failed (%s)." % (s))
-		time.sleep(1)
-	return True
-
-def send(sock, txt, tries=10):
-	global options
-	if hasgobject:
-		if not options.conn: return
-		try:
-			done = sock.sendall(txt)
-		except socket.error as s:
-			dprint("Warning, sending '%s' failed (%s)." % (txt, s))
-			options.conn.close()
-			options.conn = False
-	else:
-		for attempt in xrange(1, tries+1):
-			if not options.conn: break
-			if wait_for_lock(options.lock, 3, 10, "socket send"):
-				try:
-					 if options.conn: done = sock.sendall(txt)
-					 options.lock.release()
-				except socket.error as s:
-					options.lock.release()
-					dprint("Warning, sending '%s' failed (%s). count=%d" % (txt, s, count))
-					time.sleep(1)
-				else:
-					break
-		else:
-			if options.conn:
-				options.conn.close()
-			options.conn = False
-		return done
-
-def bitlbee_idle_handler(skype):
-	global options
-	done = False
-	if options.conn:
-		try:
-			e = "PING"
-			done = send(options.conn, "%s\n" % e)
-		except Exception, s:
-			dprint("Warning, sending '%s' failed (%s)." % (e, s))
-			if hasgobject:
-				options.conn.close()
-			else:
-				if options.conn: options.conn.close()
-				options.conn = False
-				done = False
-	if hasgobject:
-		return True
-	else:
-		return done
-	return True
-
-def server(host, port, skype = None):
-	global options
-	if ":" in host:
-		sock = socket.socket(socket.AF_INET6)
-	else:
-		sock = socket.socket()
-	sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-	fcntl(sock, F_SETFD, FD_CLOEXEC);
-	sock.bind((host, port))
-	sock.listen(1)
-
-	if hasgobject:
-		gobject.io_add_watch(sock, gobject.IO_IN, listener)
-	else:
-		dprint("Waiting for connection...")
-		listener(sock, skype)
-
-def listener(sock, skype):
-	global options
-	if not hasgobject:
-		if not(wait_for_lock(options.lock, 3, 10, "listener")): return False
-	rawsock, addr = sock.accept()
-	try:
-		options.conn = ssl.wrap_socket(rawsock,
-			server_side=True,
-			certfile=options.config.sslcert,
-			keyfile=options.config.sslkey,
-			ssl_version=ssl.PROTOCOL_TLSv1)
-	except (ssl.SSLError, socket.error) as err:
-		if isinstance(err, ssl.SSLError):
-			dprint("Warning, SSL init failed, did you create your certificate?")
-			return False
-		else:
-			dprint('Warning, SSL init failed')
-			return True
-	if hasattr(options.conn, 'handshake'):
-		try:
-			options.conn.handshake()
-		except Exception:
-			if not hasgobject:
-				options.lock.release()
-			dprint("Warning, handshake failed, closing connection.")
-			return False
-	ret = 0
-	try:
-		line = options.conn.recv(1024)
-		if line.startswith("USERNAME") and line.split(' ')[1].strip() == options.config.username:
-			ret += 1
-		line = options.conn.recv(1024)
-		if line.startswith("PASSWORD") and hashlib.sha1(line.split(' ')[1].strip()).hexdigest() == options.config.password:
-			ret += 1
-	except Exception, s:
-		dprint("Warning, receiving 1024 bytes failed (%s)." % s)
-		options.conn.close()
-		if not hasgobject:
-			options.conn = False
-			options.lock.release()
-		return False
-	if ret == 2:
-		dprint("Username and password OK.")
-		options.conn.send("PASSWORD OK\n")
-		if hasgobject:
-			gobject.io_add_watch(options.conn, gobject.IO_IN, input_handler)
-		else:
-			options.lock.release()
-			serverloop(options, skype)
-		return True
-	else:
-		dprint("Username and/or password WRONG.")
-		options.conn.send("PASSWORD KO\n")
-		if not hasgobject:
-			options.conn.close()
-			options.conn = False
-			options.lock.release()
-		return False
-
-def dprint(msg):
-	from time import strftime
-	global options
-
-	if options.debug:
-		import inspect
-		prefix = strftime("[%Y-%m-%d %H:%M:%S]") + " %s:%d" % inspect.stack()[1][1:3]
-		sanitized = msg
-
-		try:
-			print prefix + ": " + msg
-		except Exception, s:
-			try:
-				sanitized = msg.encode("ascii", "backslashreplace")
-			except Error, s:
-				try:
-					sanitized = "hex [" + msg.encode("hex") + "]"
-				except Error, s:
-					sanitized = "[unable to print debug message]"
-			print prefix + "~=" + sanitized
-
-		if options.log:
-			sock = open(options.log, "a")
-			sock.write("%s: %s\n" % (prefix, sanitized))
-			sock.close()
-
-		sys.stdout.flush()
-
-class MockedSkype:
-	"""Mock class for Skype4Py.Skype(), in case the -m option is used."""
-	def __init__(self, mock):
-		sock = open(mock)
-		self.lines = sock.readlines()
-
-	def SendCommand(self, c):
-		pass
-
-	def Command(self, msg, Block):
-		if msg == "PING":
-			return ["PONG"]
-		line = self.lines[0].strip()
-		if not line.startswith(">> "):
-			raise Exception("Corrupted mock input")
-		line = line[3:]
-		if line != msg:
-			raise Exception("'%s' != '%s'" % (line, msg))
-		self.lines = self.lines[1:] # drop the expected incoming line
-		ret = []
-		while True:
-			# and now send back all the following lines, up to the next expected incoming line
-			if len(self.lines) == 0:
-				break
-			if self.lines[0].startswith(">> "):
-				break
-			if not self.lines[0].startswith("<< "):
-				raise Exception("Corrupted mock input")
-			ret.append(self.lines[0][3:].strip())
-			self.lines = self.lines[1:]
-		return ret
-
-class SkypeApi:
-	def __init__(self, mock):
-		global options
-		if not mock:
-			self.skype = Skype4Py.Skype()
-			self.skype.OnNotify = self.recv
-			if not options.dont_start_skype:
-				self.skype.Client.Start()
-		else:
-			self.skype = MockedSkype(mock)
-
-	def recv(self, msg_text):
-		global options
-		if msg_text == "PONG":
-			return
-		if "\n" in msg_text:
-			# crappy skype prefixes only the first line for
-			# multiline messages so we need to do so for the other
-			# lines, too. this is something like:
-			# 'CHATMESSAGE id BODY first line\nsecond line' ->
-			# 'CHATMESSAGE id BODY first line\nCHATMESSAGE id BODY second line'
-			prefix = " ".join(msg_text.split(" ")[:3])
-			msg_text = ["%s %s" % (prefix, i) for i in " ".join(msg_text.split(" ")[3:]).split("\n")]
-		else:
-			msg_text = [msg_text]
-		for i in msg_text:
-			try:
-				# Internally, BitlBee always uses UTF-8 and encodes/decodes as
-				# necessary to communicate with the IRC client; thus send the
-				# UTF-8 it expects
-				e = i.encode('UTF-8')
-			except:
-				# Should never happen, but it's better to send difficult to
-				# read data than crash because some message couldn't be encoded
-				e = i.encode('ascii', 'backslashreplace')
-			if options.conn:
-				dprint('<< ' + e)
-				try:
-					send(options.conn, e + "\n")
-				except Exception, s:
-					dprint("Warning, sending '%s' failed (%s)." % (e, s))
-					if options.conn: options.conn.close()
-					options.conn = False
-			else:
-				dprint('-- ' + e)
-
-	def send(self, msg_text):
-		if not len(msg_text) or msg_text == "PONG":
-			if msg_text == "PONG":
-				options.last_bitlbee_pong = time.time()
-			return
-		try:
-			# Internally, BitlBee always uses UTF-8 and encodes/decodes as
-			# necessary to communicate with the IRC client; thus decode the
-			# UTF-8 it sent us
-			e = msg_text.decode('UTF-8')
-		except:
-			# Should never happen, but it's better to send difficult to read
-			# data to Skype than to crash
-			e = msg_text.decode('ascii', 'backslashreplace')
-		dprint('>> ' + e)
-		try:
-			c = self.skype.Command(e, Block=True)
-			self.skype.SendCommand(c)
-			if hasattr(c, "Reply"):
-				self.recv(c.Reply) # Skype4Py answer
-			else:
-				for i in c: # mock may return multiple iterable answers
-					self.recv(i)
-		except Skype4Py.SkypeError:
-			pass
-		except Skype4Py.SkypeAPIError, s:
-			dprint("Warning, sending '%s' failed (%s)." % (e, s))
-
-
-def serverloop(options, skype):
-	timeout = 1; # in seconds
-	skype_ping_period = 5
-	bitlbee_ping_period = 10
-	bitlbee_pong_timeout = 30
-	now = time.time()
-	skype_ping_start_time = now
-	bitlbee_ping_start_time = now
-	options.last_bitlbee_pong = now
-	in_error = []
-	handler_ok = True
-	while (len(in_error) == 0) and handler_ok and options.conn:
-		ready_to_read, ready_to_write, in_error = \
-			select.select([options.conn], [], [options.conn], \
-				timeout)
-		now = time.time()
-		handler_ok = len(in_error) == 0
-		if (len(ready_to_read) == 1) and handler_ok:
-			handler_ok = input_handler(ready_to_read.pop())
-			# don't ping bitlbee/skype if they already received data
-			now = time.time() # allow for the input_handler to take some time
-			bitlbee_ping_start_time = now
-			skype_ping_start_time = now
-			options.last_bitlbee_pong = now
-		if (now - skype_ping_period > skype_ping_start_time) and handler_ok:
-			handler_ok = skype_idle_handler(skype)
-			skype_ping_start_time = now
-		if now - bitlbee_ping_period > bitlbee_ping_start_time:
-			handler_ok = bitlbee_idle_handler(skype)
-			bitlbee_ping_start_time = now
-			if options.last_bitlbee_pong:
-				if (now - options.last_bitlbee_pong) > bitlbee_pong_timeout:
-					dprint("Bitlbee pong timeout")
-					# TODO is following line necessary? Should there be a options.conn.unwrap() somewhere?
-					# options.conn.shutdown()
-					if options.conn:
-						options.conn.close()
-					options.conn = False
-			else:
-				options.last_bitlbee_pong = now
-
-
-def main(args=None):
-	global options
-	global skype
-
-	cfgpath = os.path.join(os.environ['HOME'], ".skyped", "skyped.conf")
-	syscfgpath = "/usr/local/etc/skyped/skyped.conf"
-	if not os.path.exists(cfgpath) and os.path.exists(syscfgpath):
-		cfgpath = syscfgpath # fall back to system-wide settings
-	port = 2727
-
-	import argparse
-	parser = argparse.ArgumentParser()
-	parser.add_argument('-c', '--config',
-		metavar='path', default=cfgpath,
-		help='path to configuration file (default: %(default)s)')
-	parser.add_argument('-H', '--host', default='0.0.0.0',
-		help='set the tcp host, supports IPv4 and IPv6 (default: %(default)s)')
-	parser.add_argument('-p', '--port', type=int,
-		help='set the tcp port (default: %(default)s)')
-	parser.add_argument('-l', '--log', metavar='path',
-		help='set the log file in background mode (default: none)')
-	parser.add_argument('-v', '--version', action='store_true', help='display version information')
-	parser.add_argument('-n', '--nofork',
-		action='store_true', help="don't run as daemon in the background")
-	parser.add_argument('-s', '--dont-start-skype', action='store_true',
-		help="assume that skype is running independently, don't try to start/stop it")
-	parser.add_argument('-m', '--mock', help='fake interactions with skype (only useful for tests)')
-	parser.add_argument('-d', '--debug', action='store_true', help='enable debug messages')
-	options = parser.parse_args(sys.argv[1:] if args is None else args)
-
-	if options.version:
-		print "skyped %s" % __version__
-		sys.exit(0)
-
-	# well, this is a bit hackish. we store the socket of the last connected client
-	# here and notify it. maybe later notify all connected clients?
-	options.conn = None
-	# this will be read first by the input handler
-	options.buf = None
-
-	if not os.path.exists(options.config):
-		parser.error(( "Can't find configuration file at '%s'. "
-			"Use the -c option to specify an alternate one." )% options.config)
-
-	cfgpath = options.config
-	options.config = ConfigParser()
-	options.config.read(cfgpath)
-	options.config.username = options.config.get('skyped', 'username').split('#', 1)[0]
-	options.config.password = options.config.get('skyped', 'password').split('#', 1)[0]
-	options.config.sslkey = os.path.expanduser(options.config.get('skyped', 'key').split('#', 1)[0])
-	options.config.sslcert = os.path.expanduser(options.config.get('skyped', 'cert').split('#', 1)[0])
-
-	# hack: we have to parse the parameters first to locate the
-	# config file but the -p option should overwrite the value from
-	# the config file
-	try:
-		options.config.port = int(options.config.get('skyped', 'port').split('#', 1)[0])
-		if not options.port:
-			options.port = options.config.port
-	except NoOptionError:
-		pass
-	if not options.port:
-		options.port = port
-	dprint("Parsing config file '%s' done, username is '%s'." % (cfgpath, options.config.username))
-	if not options.nofork:
-		pid = os.fork()
-		if pid == 0:
-			nullin = file(os.devnull, 'r')
-			nullout = file(os.devnull, 'w')
-			os.dup2(nullin.fileno(), sys.stdin.fileno())
-			os.dup2(nullout.fileno(), sys.stdout.fileno())
-			os.dup2(nullout.fileno(), sys.stderr.fileno())
-		else:
-			print 'skyped is started on port %s, pid: %d' % (options.port, pid)
-			sys.exit(0)
-	else:
-		dprint('skyped is started on port %s' % options.port)
-	if hasgobject:
-		server(options.host, options.port)
-	try:
-		skype = SkypeApi(options.mock)
-	except Skype4Py.SkypeAPIError, s:
-		sys.exit("%s. Are you sure you have started Skype?" % s)
-	if hasgobject:
-		gobject.timeout_add(2000, skype_idle_handler, skype)
-		gobject.timeout_add(60000, bitlbee_idle_handler, skype)
-		gobject.MainLoop().run()
-	else:
-		while 1:
-			options.conn = False
-			options.lock = threading.Lock()
-			server(options.host, options.port, skype)
-
-
-if __name__ == '__main__': main()