From 0b73bbd065685200cbcab7c668942c392c7bea8b Mon Sep 17 00:00:00 2001
From: drebs <drebs@leap.se>
Date: Thu, 16 Mar 2017 10:16:46 +0100
Subject: [feat] improve blobs standalone testing options

---
 client/src/leap/soledad/client/_blobs.py | 19 +++++++++++--------
 server/src/leap/soledad/server/_blobs.py | 16 +++++++++++++---
 2 files changed, 24 insertions(+), 11 deletions(-)

diff --git a/client/src/leap/soledad/client/_blobs.py b/client/src/leap/soledad/client/_blobs.py
index 34ce8f4a..f76f3e53 100644
--- a/client/src/leap/soledad/client/_blobs.py
+++ b/client/src/leap/soledad/client/_blobs.py
@@ -21,7 +21,7 @@ Clientside BlobBackend Storage.
 from copy import copy
 from urlparse import urljoin
 
-import os.path
+import os
 import uuid
 import base64
 
@@ -323,12 +323,10 @@ def testit(reactor):
     # parse command line arguments
     import argparse
 
-    usage = "\n  mkdir /tmp/blobs/user && cd server/src/leap/soledad/server/" \
-            " && python _blobs.py" \
-            "\n  python _blobs.py upload /path/to/file blob_id" \
-            "\n  python _blobs.py download blob_id"
+    parser = argparse.ArgumentParser()
+    parser.add_argument('--url', default='http://localhost:9000/')
+    parser.add_argument('--path', default='/tmp/blobs')
 
-    parser = argparse.ArgumentParser(usage=usage)
     subparsers = parser.add_subparsers(help='sub-command help', dest='action')
 
     # parse upload command
@@ -341,6 +339,7 @@ def testit(reactor):
     parser_download = subparsers.add_parser(
         'download', help='download blob and bypass local db')
     parser_download.add_argument('blob_id')
+    parser_download.add_argument('--output-file', default='/tmp/incoming-file')
 
     # parse put command
     parser_put = subparsers.add_parser(
@@ -359,8 +358,10 @@ def testit(reactor):
     # TODO convert these into proper unittests
 
     def _manager():
+        if not os.path.isdir(args.path):
+            os.makedirs(args.path)
         manager = BlobManager(
-            '/tmp/blobs', 'http://localhost:9000/',
+            args.path, args.url,
             'A' * 32, 'secret', 'user')
         return manager
 
@@ -380,7 +381,9 @@ def testit(reactor):
         logger.info(":: Result of download: %s" % str(result))
         if result:
             fd, _ = result
-            logger.info(":: Content of blob %s: %s" % (blob_id, fd.getvalue()))
+            with open(args.output_file, 'w') as f:
+                logger.info(":: Writing data to %s" % args.output_file)
+                f.write(fd.read())
         logger.info(":: Finished download only: %s" % blob_id)
 
     @defer.inlineCallbacks
diff --git a/server/src/leap/soledad/server/_blobs.py b/server/src/leap/soledad/server/_blobs.py
index 454ff5fe..76de49bb 100644
--- a/server/src/leap/soledad/server/_blobs.py
+++ b/server/src/leap/soledad/server/_blobs.py
@@ -210,11 +210,21 @@ if __name__ == '__main__':
     from twisted.web.server import Site
     from twisted.internet import reactor
 
-    # XXX pass the path here
-    root = BlobsResource('/tmp/blobs/user')
+    # parse command line arguments
+    import argparse
+
+    parser = argparse.ArgumentParser()
+    parser.add_argument('--port', default=9000)
+    parser.add_argument('--path', default='/tmp/blobs/user')
+    args = parser.parse_args()
+
+    if not os.path.isdir(args.path):
+        os.makedirs(args.path)
+
+    root = BlobsResource(args.path)
     # I picture somethink like
     # BlobsResource(backend="filesystem", backend_opts={'path': '/tmp/blobs'})
 
     factory = Site(root)
-    reactor.listenTCP(9000, factory)
+    reactor.listenTCP(args.port, factory)
     reactor.run()
-- 
cgit v1.2.3