2 from __future__ import with_statement
4 # sfi -- slice-based facility interface
8 from optparse import OptionParser
9 from util.cert import Keypair, Certificate
10 from util.credential import Credential
11 from util.geniclient import GeniClient
13 sfi_dir = os.path.expanduser("~/.sfi/")
21 # Establish Connection to SliceMgr and Registry Servers
23 def set_servers(options):
30 if (options.sm is not None):
32 elif ("SFI_SM" in os.environ):
33 sm_url = os.environ["SFI_SM"]
35 print "No Known Slice Manager"
39 if (options.registry is not None):
40 reg_url = options.registry
41 elif ("SFI_REGISTRY" in os.environ):
42 reg_url = os.environ["SFI_REGISTRY"]
44 print "No Known Registry Server"
48 print "Contacting Slice Manager at:", sm_url
49 print "Contacting Registry at:", registry_url
52 if (options.user is not None):
54 elif ("SFI_USER" in os.environ):
55 user = os.environ["SFI_USER"]
57 print "No Known User Name"
61 if (options.auth is not None):
62 authority = options.auth
63 elif ("SFI_AUTH" in os.environ):
64 authority = os.environ["SFI_AUTH"]
68 # Get key and certificate
69 key_file = get_key_file()
70 cert_file = get_cert_file(key_file)
72 # Establish connection to server(s)
73 slicemgr = GeniClient(sm_url, key_file, cert_file)
74 registry = GeniClient(registry_url, key_file, cert_file)
78 # Get various credential and spec files
80 # Establishes limiting conventions
81 # - conflates MAs and SAs
82 # - assumes last token in slice name is unique
84 # Bootstraps credentials
85 # - bootstrap user credential from self-signed certificate
86 # - bootstrap authority credential from user credential
87 # - bootstrap slice credential from user credential
91 parts = name.split(".")
95 file = os.path.join(sfi_dir, get_leaf(user) + ".pkey")
96 if (os.path.isfile(file)):
99 print "Key file", file, "does not exist"
103 def get_cert_file(key_file):
106 file = os.path.join(sfi_dir, get_leaf(user) + ".cert")
107 if (os.path.isfile(file)):
110 k = Keypair(filename = key_file)
111 cert = Certificate(subject=user)
113 cert.set_issuer(k, user)
116 print "Writing self-signed certificate to", file
117 cert.save_to_file(file)
123 file = os.path.join(sfi_dir, get_leaf(user) + ".cred")
124 if (os.path.isfile(file)):
125 user_cred = Credential(filename=file)
128 # bootstrap user credential
129 user_cred = get_credential(None, "user", user)
131 user_cred.save_to_file(file, save_parents=True)
133 print "Writing user credential to", file
136 print "Failed to get user credential"
142 file = os.path.join(sfi_dir, "authority.cred")
143 if (os.path.isfile(file)):
144 auth_cred = Credential(filename=file)
147 # bootstrap authority credential from user credential
148 user_cred = get_user_cred()
149 auth_cred = get_credential(user_cred, "sa", authority)
151 auth_cred.save_to_file(file, save_parents=True)
153 print "Writing authority credential to", file
156 print "Failed to get authority credential"
159 def get_slice_cred(name):
160 file = os.path.join(sfi_dir, "slice_" + get_leaf(name) + ".cred")
161 if (os.path.isfile(file)):
162 slice_cred = Credential(filename=file)
165 # bootstrap slice credential from user credential
166 user_cred = get_user_cred()
167 slice_cred = get_credential(user_cred, "slice", name)
169 slice_cred.save_to_file(file, save_parents=True)
171 print "Writing slice credential to", file
174 print "Failed to get slice credential"
177 def get_rspec_file(rspec):
178 if (os.path.isabs(rspec)):
181 file = os.path.join(sfi_dir, rspec)
182 if (os.path.isfile(file)):
185 print "No such rspec file"
188 def get_record_file(record):
189 if (os.path.isabs(record)):
192 file = os.path.join(sfi_dir, record)
193 if (os.path.isfile(file)):
196 print "No such registry record file"
200 # Generate sub-command parser
202 def create_cmd_parser(command):
203 cmdargs = {"list": "name",
206 "add": "name record",
207 "update": "name record",
211 "create": "name rspec",
217 if command not in cmdargs:
218 print "Invalid command\n"
219 print "Commands:list,show,remove,add,update,nodes,slices,resources,create,delete,start,stop,reset"
222 parser = OptionParser(usage="sfi [sfi_options] %s [options] %s" \
223 % (command, cmdargs[command]))
224 if command in ("nodes", "resources"):
225 parser.add_option("-f", "--format", dest="format",type="choice",
226 help="display format (dns|ip|hrn|rspec)",default="rspec",
227 choices=("dns","ip","hrn","rspec"))
228 if command in ("list", "show", "remove"):
229 parser.add_option("-t", "--type", dest="type",type="choice",
230 help="type filter (user|slice|sa|ma|node|aggregate)",
231 choices=("user","slice","sa","ma","node","aggregate", "all"),
233 if command in ("show", "nodes", "resources"):
234 parser.add_option("-o", "--output", dest="file",
235 help="output XML to file", metavar="FILE", default=None)
239 # Main: parse arguments and dispatch to command
244 # Generate command line parser
245 parser = OptionParser(usage="sfi [options] command [command_options] [command_args]",
246 description="Commands: list,show,remove,add,update,nodes,slices,resources,create,delete,start,stop,reset")
247 parser.add_option("-r", "--registry", dest="registry",
248 help="root registry", metavar="URL", default=None)
249 parser.add_option("-s", "--slicemgr", dest="sm",
250 help="slice manager", metavar="URL", default=None)
251 parser.add_option("-d", "--dir", dest="dir",
252 help="working directory", metavar="PATH", default = sfi_dir)
253 parser.add_option("-u", "--user", dest="user",
254 help="user name", metavar="HRN", default=None)
255 parser.add_option("-a", "--auth", dest="auth",
256 help="authority name", metavar="HRN", default=None)
257 parser.add_option("-v", "--verbose",
258 action="store_true", dest="verbose", default=False,
260 parser.disable_interspersed_args()
261 (options, args) = parser.parse_args()
263 (cmd_opts, cmd_args) = create_cmd_parser(command).parse_args(args[1:])
264 verbose = options.verbose
266 print options.registry, options.sm, options.dir, options.verbose,\
267 options.user, options.auth
269 if command in ("nodes", "resources"):
270 print cmd_opts.format
271 elif command in ("list","show","remove"):
277 # Dispatch to selected command
279 globals()[command](cmd_opts, cmd_args)
281 print "Command not found:", command
286 # Following functions implement the commands
288 # Registry-related commands
291 # list entires in named authority registry
292 def list(opts, args):
294 user_cred = get_user_cred()
295 result = registry.list(user_cred, args[0])
296 display_record(opts.type, results)
299 # show named registry record
300 def show(opts, args):
302 user_cred = get_user_cred()
303 result = reg_chan.resolve(user_cred, args[0])
304 display_record(opts.type, results)
305 if (opts.file is not None):
306 save_record_to_file(opts.file, result)
309 # removed named registry record
310 # - have to first retrieve the record to be removed
311 def remove(opts, args):
313 auth_cred = get_auth_cred()
314 results = registry.resolve(auth_cred, args[0])
315 record = filter_record(opts.type, results)
316 return registry.remove(auth_cred, record)
318 # add named registry record
321 auth_cred = get_auth_cred()
322 rec_file = get_record_file(args[1])
323 with open(rec_file) as f:
325 return registry.register(auth_cred, record)
327 # update named registry entry
328 def update(opts, args):
330 user_cred = get_user_cred()
331 rec_file = get_record_file(args[1])
332 with open(rec_file) as f:
334 return registry.update(user_cred, record)
337 # Slice-related commands
340 # list available nodes
341 def nodes(opts, args):
343 user_cred = get_user_cred()
348 result = slicemgr.list_nodes(user_cred, context)
349 display_rspec(opts.format, result)
350 if (opts.file is not None):
351 save_rspec_to_file(opts.file, result)
354 # list instantiated slices
355 def slices(opts, args):
357 user_cred = get_user_cred()
358 result = slicemgr.list_slices(user_cred)
359 display_rspec(opts.format, results)
362 # show rspec for named slice
363 def resources(opts, args):
365 slice_cred = get_slice_cred(args[0])
366 result = slicemgr.get_slice_resources(slice_cred, args[0])
367 display_rspec(opts.format, result)
368 if (opts.file is not None):
369 save_rspec_to_file(opts.file, result)
372 # created named slice with given rspec
373 def create(opts, args):
375 slice_cred = get_slice_cred(args[0])
376 rspec_file = get_rspec_file(args[1])
377 with open(rspec_file) as f:
379 return slicemgr.create_slice(slice_cred, rspec)
382 def delete(opts, args):
384 slice_cred = get_slice_cred(args[0])
385 return slicemgr.delete_slice(slice_cred)
388 def start(opts, args):
390 slice_cred = get_slice_cred(args[0])
391 return slicemgr.start_slice(slice_cred)
394 def stop(opts, args):
396 slice_cred = get_slice_cred(args[0])
397 return slicemgr.stop_slice(slice_cred)
400 def reset(opts, args):
402 slice_cred = get_slice_cred(args[0])
403 return slicemgr.reset_slice(slice_cred)
407 # Display, Save, and Filter RSpecs and Records
408 # - to be replace by EMF-generated routines
412 def display_rspec(format, rspec):
413 print "display rspec"
416 def save_rspec_to_file(file, rspec):
420 def display_record(type, record):
421 rec = filter_record(type, record)
422 print "display record"
425 def filter_record(type, record):
426 print "filter record"
429 def save_record_to_file(file, record):
434 if __name__=="__main__":