prototype encoder

allmydata/encode.py

@@ -0,0 +1,15 @@
+from twisted.internet import defer
+
+class Encoder(object):
+    def __init__(self, infile, m):
+        self.infile = infile
+        self.k = 2
+        self.m = m
+
+    def do_upload(self, landlords):
+        data = self.infile.read()
+        for (peerid, bucket_num, remotebucket) in landlords:
+            remotebucket.callRemote('write', data)
+            remotebucket.callRemote('finalise')
+
+        return defer.succeed()