X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Ffederica%2Ffdshell.py;fp=sfa%2Ffederica%2Ffdshell.py;h=d362c7fd1d93144b2e7ea1e01dbd71e391d9b3b8;hb=d8782631d2609a4e86bc381dea2862728a0b0a8a;hp=0000000000000000000000000000000000000000;hpb=21bd34d03135a19493ddd3f4a4589c64c158cb4a;p=sfa.git

diff --git a/sfa/federica/fdshell.py b/sfa/federica/fdshell.py
new file mode 100644
index 00000000..d362c7fd
--- /dev/null
+++ b/sfa/federica/fdshell.py
@@ -0,0 +1,43 @@
+import xmlrpclib
+
+from sfa.util.sfalogging import logger
+
+class FdShell:
+    """
+    A simple xmlrpc shell to a federica API server
+    This class can receive the XMLRPC calls to the federica testbed
+    For safety this is limited to a set of hard-coded calls
+    """
+    
+    direct_calls = [ 'listAvailableResources',
+                     'listSliceResources',
+                     'createSlice',
+                     'deleteSlice',
+                    ]
+
+    def __init__ ( self, config ) :
+        # xxx to be configurable
+        SFA_FEDERICA_URL = "http://%s:%s@%s:%s/"%\
+            (config.SFA_FEDERICA_USER,config.SFA_FEDERICA_PASSWORD,
+             config.SFA_FEDERICA_HOSTNAME,config.SFA_FEDERICA_PORT)
+        url=SFA_FEDERICA_URL
+        # xxx not sure if java xmlrpc has support for None
+        # self.proxy = xmlrpclib.Server(url, verbose = False, allow_none = True)
+        # xxx turn on verbosity
+        self.proxy = xmlrpclib.Server(url, verbose = True)
+
+    def __getattr__(self, name):
+        def func(*args, **kwds):
+            if name not in FdShell.direct_calls:
+                raise Exception, "Illegal method call %s for FEDERICA driver"%(name)
+            # xxx get credentials from the config ?
+            # right now basic auth data goes into the URL
+            # the API still provides for a first credential arg though
+            credential='xxx-unused-xxx'
+            logger.info("Issuing %s args=%s kwds=%s to federica"%\
+                            (name,args,kwds))
+            result=getattr(self.proxy, "AggregateManager.%s"%name)(credential, *args, **kwds)
+            logger.debug('FdShell %s (%s) returned ... '%(name,name))
+            return result
+        return func
+