1 #!/usr/bin/env /usr/bin/plcsh
5 sys.path.append("/usr/bin/")
6 from omf_slicemgr import *
8 xmlrpc = xmlrpclib.ServerProxy("http://localhost:5053")
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)
16 def delete_all_nodes(iq):
19 for i in iq.query.elements():
21 reactor.callLater(1, pubsub.delete_node, node)
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")
29 reactor.callLater(4, reactor.stop)
30 reactor.connectTCP(pubsub.id.host, 5222, pubsub.factory)
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)