import os
import sys
+import time
import Queue
from twisted.words.xish import domish
from twisted.web import xmlrpc, server
# add protocol handlers
xs.addObserver("/presence[@type='subscribe']", self.presence_subscribe)
xs.addObserver("/presence[@type='unsubscribe']", self.presence_unsubscribe)
- xs.addObserver("/precence", self.presence)
+ xs.addObserver("/presence", self.presence)
xs.addObserver("/message[@type='chat']", self.message_chat)
def presence_subscribe(self, m):
def presence(self, m):
p = domish.Element(("jabber:client", "presence"))
p['from'], p['to'] = m['to'], m['from']
- presence.addElement("show", content="dnd")
- presence.addElement("status", content="man at work")
+ # initially read presence.addElement, my wild guess.. -- Thierry
+ p.addElement("show", content="dnd")
+ p.addElement("status", content="man at work")
self.xmlstream.send(p)
def message_chat(self, m):
self.command_queue.put(( self.create_node, "/".join([self.DOMAIN,slice,self.RESOURCES]) ))
def add_resource(self, slice, resource):
- self.command_queue.put(( self.create_node, "/".join([self.DOMAIN,slice,self.RESOURCES,resource]) ))
+ resname = "/".join([self.DOMAIN,slice,self.RESOURCES,resource])
+ self.command_queue.put(( self.create_node, resname ))
def delete_slice(self, slice):
slice_prefix = "/".join([self.DOMAIN,slice])
xmppserver = config.PLC_OMF_XMPP_SERVER
xmppuser = "@".join([config.PLC_OMF_XMPP_USER, xmppserver])
xmpppass = config.PLC_OMF_XMPP_PASSWORD
+ monthstring=time.strftime("%Y-%m")
slicemgr = Slicemgr(xmppuser, xmpppass,
- log=open("/var/log/omf/pubsub_client.log", "a"),
- verbose=True)
+ log=open("/var/log/omf/pubsub-client-%s.log"%monthstring, "a"),
+ # used to be verbose=True but that amounts to huge totally helpless logs, so..
+ verbose=False)
t = task.LoopingCall(slicemgr.flush_commands)
t.start(5.0) # check every 5 seconds