omf/reset_xmpp_pubsub_nodes.py

   1 #!/usr/bin/env /usr/bin/plcsh
   2
   3 import sys
   4 import xmlrpclib
   5 sys.path.append("/usr/bin/")
   6 from omf_slicemgr import *
   7
   8 xmlrpc = xmlrpclib.ServerProxy("http://localhost:5053")
   9
  10 xmppserver = config.PLC_OMF_XMPP_SERVER
  11 xmppuser = "@".join([config.PLC_OMF_XMPP_USER, xmppserver])
  12 xmpppass = config.PLC_OMF_XMPP_PASSWORD
  13 pubsub = PubSubClient(xmppuser, xmpppass, verbose=True)
  14
  15
  16 def delete_all_nodes(iq):
  17     global pubsub
  18     print "called"
  19     for i in iq.query.elements():
  20         node = i['node']
  21         reactor.callLater(1, pubsub.delete_node, node)
  22
  23 if __name__ == "__main__":
  24     pubsub.add_result_hook("discover", delete_all_nodes)
  25     reactor.callLater(1, pubsub.discover)
  26     reactor.callLater(2, pubsub.create_node, "/OMF")
  27     reactor.callLater(2, pubsub.create_node, "/SYSTEM")
  28
  29     reactor.callLater(4, reactor.stop)
  30     reactor.connectTCP(pubsub.id.host, 5222, pubsub.factory)
  31     reactor.run()
  32
  33     slices = GetSlices()
  34     for slice in slices:
  35         xmlrpc.createSlice(slice['name'])
  36         for node_id in slice['node_ids']:
  37             node = GetNodes(node_id)[0]['hostname']
  38             xmlrpc.addResource(slice['name'], node)
  39
  40
  41