root/projects/WinDictator/trunk/windictator/linux/pb.py

# WinDictator:
# Dictate in Windows, have the text typed in Linux via X faked keystroke events
#
# Copyright (C) 2005-2006 by Edwin A. Suominen, http://www.eepatents.com
#
# 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 file COPYING 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., 51
# Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA


"""
Twisted Perspective Broker client that connects to a PB server running on
Windows and accepts text from the server for virtual typing.
"""

from twisted.spread import pb
from twisted.internet import reactor

from typist import Typist


class ClientRoot(pb.Referenceable):
    """
    I provide a method for a local client to send its root object to its
    server.
    """
    def __init__(self):
        self.typist = Typist()

    def remote_shutdown(self):
        """
        Server remote API for shutting down the client
        """
        print "SHUTDOWN BY SERVER"
        d1 = self.typist.shutdown()
        d2 = defer.Deferred()
        d2.addCallback(reactor.stop)
        d1.chainDeferred(d2)
        return d1
        
    def remote_backspace(self, N):
        """
        Server remote API for having the client enter I{N} BackSpace key
        events.
        """
        print "BACKSPACE %d" % N
        return self.typist.backspace(N)

    def remote_insert(self, text):
        """
        Server remote API for having the client type I{text} with key events.
        """
        print "INSERT '%s'" % text
        return self.typist.insert(text)


class Client(object):
    def __init__(self):
        self.clientRoot = ClientRoot()
        
    def connect(self, host, port):
        """
        Connects to I{host:port} and stays here if successful
        """
        factory = pb.PBClientFactory()
        reactor.connectTCP(host, port, factory)
        factory.getRootObject().addCallbacks(self.started, self.oops)
        reactor.run()

    def started(self, object):
        """
        This method is called when the client has made a connection to the
        server.
        """
        d = object.callRemote("greeter", self.clientRoot)
        d.addCallbacks(self.greeted, self.oops)
        return d

    def greeted(self, status):
        """
        This method is called when the server has responded to the client's
        offer of its root object.
        """
        print "CONNECTED: %s" % ("Busy", "Ready")[status]
        return self.clientRoot.typist.startup()

    def oops(self, failure):
        print "CONNECTION FAILURE:", failure