From: Brian Warner <warner@lothar.com>
Date: Sat, 2 Dec 2006 23:03:09 +0000 (-0700)
Subject: improve RemoteInterface specifications
X-Git-Tag: tahoe_v0.1.0-0-UNSTABLE~498
X-Git-Url: https://git.rkrishnan.org/%5B/%5D%20/file/URI:LIT:krugkidfnzsc4/(%5B%5E?a=commitdiff_plain;h=70f58b195c8f3b136a80a84d90124eeda4c312f0;p=tahoe-lafs%2Ftahoe-lafs.git

improve RemoteInterface specifications
---

diff --git a/allmydata/interfaces.py b/allmydata/interfaces.py
index 7886e0fb..0bacbd43 100644
--- a/allmydata/interfaces.py
+++ b/allmydata/interfaces.py
@@ -2,40 +2,42 @@
 from foolscap.schema import StringConstraint, ListOf, TupleOf, Any, Nothing
 from foolscap import RemoteInterface
 
-Nodeid = StringConstraint(20)
+Nodeid = StringConstraint(20) # base32 encoded 20-byte SHA1 hash
 PBURL = StringConstraint()
+Tubid = StringConstraint()
+ShareData = StringConstraint(20000)
 # these three are here because Foolscap does not yet support the kind of
 # restriction I really want to apply to these.
-RIClient_ = Any
-Referenceable_ = Any
-RIBucketWriter_ = Any
+RIClient_ = Any()
+Referenceable_ = Any()
+RIBucketWriter_ = Any()
 
 class RIQueenRoster(RemoteInterface):
     def hello(nodeid=Nodeid, node=RIClient_, pburl=PBURL):
-        return Nothing
+        return Nothing()
 
 class RIClient(RemoteInterface):
     def get_service(name=str):
         return Referenceable_
     def add_peers(new_peers=ListOf(TupleOf(Nodeid, PBURL), maxLength=100)):
-        return Nothing
+        return Nothing()
     def lost_peers(lost_peers=ListOf(Nodeid)):
-        return Nothing
+        return Nothing()
 
 class RIStorageServer(RemoteInterface):
     def allocate_bucket(verifierid=Nodeid, bucket_num=int, size=int,
-                        leaser=Nodeid):
+                        leaser=Tubid):
         return RIBucketWriter_
 
 
 class RIBucketWriter(RemoteInterface):
-    def write(data=str):
-        return Nothing
+    def write(data=ShareData):
+        return Nothing()
 
     def set_size(size=int):
-        return Nothing
+        return Nothing()
 
     def close():
-        return Nothing
+        return Nothing()
 
 
diff --git a/allmydata/test/test_storage.py b/allmydata/test/test_storage.py
index fa9eafe0..b0628111 100644
--- a/allmydata/test/test_storage.py
+++ b/allmydata/test/test_storage.py
@@ -7,6 +7,7 @@ from twisted.application import service
 from twisted.internet import defer
 from twisted.python import log
 from foolscap import Tub
+from foolscap.eventual import flushEventualQueue
 
 from allmydata import client
 
@@ -129,4 +130,6 @@ class StorageTest(unittest.TestCase):
         return rssd
 
     def tearDown(self):
-        return self.svc.stopService()
+        d = self.svc.stopService()
+        d.addCallback(lambda res: flushEventualQueue())
+        return d