root/trunk/RBPrivate/Prototypes/ChatClient/MessageFactory.py

#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#~ Imports 
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

import weakref
from Foundation.Skinning import SkinFile
from Foundation.SubjectObserver.Observer import Observer

#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
#~ Definitions 
#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

class JabberClientMessageFactory:
    Bid = 1

    def __init__(self, JC, context):
        self.JC = weakref.ref(JC)
        self.context = context
        JC.stream.AddObserver('message', Observer(self.Update, self.Bid))

    def Update(self, subject, **UpdateDict):
        if 'message' in UpdateDict:
            skin = SkinFile('ChatFrame.skin', self.context._OwnerContext('application'), JC=self.JC, message=UpdateDict['message'])

#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

class MessageFactory:
    def __init__(self, node):
        self.context = node.context
        self.context.Model.AddObserver('JabberClients', self.Update)

    def Update(self, subject, **UpdateDict):
        self.Factories = {}
        for JC in UpdateDict['JabberClients'].itervalues():
            self.Factories[id(JC)] = JabberClientMessageFactory(JC, self.context)