+#!/usr/bin/env /usr/bin/plcsh
+
+import sys
+import xmlrpclib
+sys.path.append("/usr/bin/")
+from omf_slicemgr import *
+
+xmlrpc = xmlrpclib.ServerProxy("http://localhost:5053")
+
+xmppserver = config.PLC_OMF_XMPP_SERVER
+xmppuser = "@".join([config.PLC_OMF_XMPP_USER, xmppserver])
+xmpppass = config.PLC_OMF_XMPP_PASSWORD
+pubsub = PubSubClient(xmppuser, xmpppass, verbose=True)
+
+
+def delete_all_nodes(iq):
+ global pubsub
+ print "called"
+ for i in iq.query.elements():
+ node = i['node']
+ reactor.callLater(1, pubsub.delete_node, node)
+
+if __name__ == "__main__":
+ pubsub.add_result_hook("discover", delete_all_nodes)
+ reactor.callLater(1, pubsub.discover)
+ reactor.callLater(2, pubsub.create_node, "/OMF")
+ reactor.callLater(2, pubsub.create_node, "/SYSTEM")
+
+ reactor.callLater(4, reactor.stop)
+ reactor.connectTCP(pubsub.id.host, 5222, pubsub.factory)
+ reactor.run()
+
+ slices = GetSlices()
+ for slice in slices:
+ xmlrpc.createSlice(slice['name'])
+ for node_id in slice['node_ids']:
+ node = GetNodes(node_id)[0]['hostname']
+ xmlrpc.addResource(slice['name'], node)
+
+
+