view jabberbot/ @ 2121:ae2134211ac1

XMPP -> wiki XML RPC, the beginning...
author Karol 'grzywacz' Nowak <>
date Thu, 14 Jun 2007 01:19:20 +0200
parents 805d56ccbea7
children 184975c4b86f
line wrap: on
line source
# -*- coding: iso-8859-1 -*-
    MoinMoin - a xmlrpc server and client for the notification bot

    @copyright: 2007 by Karol Nowak <>
    @license: GNU GPL, see COPYING for details.

import Queue
import time, xmlrpclib
from threading import Thread
from SimpleXMLRPCServer import SimpleXMLRPCServer

import jabberbot.commands as cmd
from jabberbot.multicall import MultiCall

class XMLRPCClient(Thread):
    """XMLRPC Client
    It's responsible for performing XMLRPC operations on
    a wiki, as inctructed by command objects received from
    the XMPP component"""
    def __init__(self, config, commands_in, commands_out):
        @param commands: an output command queue
        self.commands_in = commands_in
        self.commands_out = commands_out
        self.config = config
        self.url = config.wiki_url + "?action=xmlrpc2"
        self.connection = self.create_connection()
        self.token = None
        self.multicall = None

    def run(self):
        """Starts the server / thread"""
        while True:
                command = self.commands_in.get(True, 2)
            except Queue.Empty:
    def create_connection(self):
        return xmlrpclib.ServerProxy(self.url, allow_none=True, verbose=self.config.verbose)
    def execute_command(self, command):
        """Execute commands coming from the XMPP component"""
        # FIXME: make this kind of automatic
        if isinstance(command, cmd.GetPage):
        elif isinstance(command, cmd.GetPageHTML):
    def get_auth_token(self):
        token = self.connection.getAuthToken("grzywacz", "ppp")
        if token:
            self.token = token
    def get_page(self, command):
        if self.multicall is not None:
            del self.multicall
        self.multicall = MultiCall(self.connection)
        if not self.token:
        if not self.token:
            # FIXME: notify the user that he may not have full rights on the wiki
        token_result, getpage_result = self.multicall()

        # We get a dict only when Fault happens
        if isinstance(getpage_result, dict):
            error_str = u"""The page couldn't be retrieved. The reason is: "%s"."""
   = error_str % getpage_result["faultString"]
   = getpage_result
    def get_page_html(self, command):

class XMLRPCServer(Thread):
    """XMLRPC Server
    It waits for notifications requests coming from wiki,
    creates command objects and puts them on a queue for
    later processing by the XMPP component
    @param commands: an input command queue
    def __init__(self, config, commands):
        self.commands = commands
        self.verbose = config.verbose
        self.secret = config.secret
        self.server = SimpleXMLRPCServer((config.xmlrpc_host, config.xmlrpc_port))
    def run(self):
        """Starts the server / thread"""
        # Register methods having an "export" attribute as XML RPC functions and 
        # decorate them with a check for a shared (wiki-bot) secret.
        items = self.__class__.__dict__.items()
        methods = [(name, func) for (name, func) in items if callable(func) 
                   and "export" in func.__dict__]

        for name, func in methods:
            self.server.register_function(self.secret_check(func), name)
    def log(self, message):
        """Logs a message and its timestamp"""
        t = time.localtime( time.time() )
        print time.strftime("%H:%M:%S", t), message

    def secret_check(self, function):
        """Adds a check for a secret to a given function
        Using this one does not have to worry about checking for the secret
        in every XML RPC function.
        def protected_func(secret, *args):
            if secret != self.secret:
                raise xmlrpclib.Fault(1, "You are not allowed to use this bot!")
                return function(self, *args)
        return protected_func
    def send_notification(self, jid, text):
        """Instructs the XMPP component to send a notification
        @param jid: a jid to send a message to (bare jid)
        @type jid: str or unicode
        @param text: a message body
        @type text: unicode
        c = cmd.NotificationCommand(jid, text)
        return True
    send_notification.export = True
    def addJIDToRoster(self, jid):
        """Instructs the XMPP component to add a new JID to its roster
        @param jid: a jid to add, this must be a bare jid
        @type jid: str or unicode, 
        c = cmd.AddJIDToRosterCommand(jid)
        return True
    addJIDToRoster.export = True
    def removeJIDFromRoster(self, jid):
        """Instructs the XMPP component to remove a JID from its roster
        @param jid: a jid to remove, this must be a bare jid
        @type jid: str or unicode
        c = cmd.RemoveJIDFromRosterCommand(jid)
        return True
    removeJIDFromRoster.export = True