Logo Search packages:      
Sourcecode: ibid version File versions  Download package

pb.py

# Copyright (c) 2009-2010, Michael Gorven
# Released under terms of the MIT/X/Expat Licence. See COPYING for details.

import logging

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

import ibid
from ibid.source import IbidSourceFactory
from ibid.config import IntOption
from ibid.event import Event

class IbidRoot(pb.Root):

    def __init__(self, name):
        self.name = name
        self.log = logging.getLogger('sources.%s' % name)

    def respond(self, event):
        return [response['reply'] for response in event.responses]

    def remote_message(self, message):
        event = Event(self.name, u'message')
        event.sender['connection'] = event.sender['id'] = event.sender['nick'] = event.channel = self.name
        event.addressed = True
        event.public = False
        event.message = unicode(message, 'utf-8', 'replace')
        self.log.debug(u'message("%s")' % event.message)
        return ibid.dispatcher.dispatch(event).addCallback(self.respond)

    def remote_get_plugin(self, plugin):
        self.log.debug(u'get_plugin("%s")' % plugin)
        return ibid.rpc[plugin]

class SourceFactory(IbidSourceFactory):

    supports = ('multiline',)

    port = IntOption('port', 'Port number to listen on', 8789)

    def setServiceParent(self, service):
        root = pb.PBServerFactory(IbidRoot(self.name))
        if service:
            return internet.TCPServer(self.port, root).setServiceParent(service)
        else:
            reactor.listenTCP(self.port, root)

# vi: set et sta sw=4 ts=4:

Generated by  Doxygen 1.6.0   Back to index