summaryrefslogtreecommitdiff
path: root/test/test_httpfs.py
diff options
context:
space:
mode:
authorYves Fischer <yvesf-git@xapek.org>2015-02-20 18:35:30 +0100
committerYves Fischer <yvesf-git@xapek.org>2015-02-21 18:22:33 +0100
commit083899d6088492b1bc7e01f74be015070224f2c2 (patch)
tree4fef8a619e5f345f556c177643098f6a506d5969 /test/test_httpfs.py
parent1ee6c90a3de10149b04f419ec9ff4b139efa0962 (diff)
downloadfuse-httpfs-083899d6088492b1bc7e01f74be015070224f2c2.tar.gz
fuse-httpfs-083899d6088492b1bc7e01f74be015070224f2c2.zip
Some tests and using python netrc module
Diffstat (limited to 'test/test_httpfs.py')
-rw-r--r--test/test_httpfs.py73
1 files changed, 73 insertions, 0 deletions
diff --git a/test/test_httpfs.py b/test/test_httpfs.py
new file mode 100644
index 0000000..bb5435c
--- /dev/null
+++ b/test/test_httpfs.py
@@ -0,0 +1,73 @@
+import os
+import logging
+import threading
+from unittest import TestCase
+from stat import S_IFDIR, S_IFREG
+from http.server import HTTPServer
+from http.server import SimpleHTTPRequestHandler
+
+from httpfs import Httpfs
+
+
+def translate_path(p):
+ return "test/testwww/" + p
+
+
+class Handler(SimpleHTTPRequestHandler):
+ def translate_path(self, path):
+ p = super().translate_path(path)
+ pNew = translate_path(os.path.relpath(p))
+ logging.info("translated %s to %s", p, pNew)
+ return pNew
+
+ def handle_one_request(self, *a):
+ SimpleHTTPRequestHandler.handle_one_request(self, *a)
+ self.server.requests.append(vars(self))
+
+
+class TestBase(TestCase):
+ def setUp(self):
+ self.server = HTTPServer(('', 0), Handler)
+ self.server.requests = []
+ self.server_thread = threading.Thread(target=self.server.serve_forever)
+ self.server_thread.daemon = True
+ self.server_thread.start()
+ self.httpfs = Httpfs()
+ self.port = self.server.socket.getsockname()[1]
+
+ def tearDown(self):
+ self.server.shutdown()
+ self.server_thread.join()
+
+ def basePath(self):
+ return "/http/localhost:{}".format(self.port)
+
+ def stat(self, path):
+ logging.info("Translate path %s -> %s", path, translate_path(path))
+ return os.stat(translate_path(path))
+
+
+class TestZwei(TestBase):
+ def test_root(self):
+ r = self.httpfs.readdir(self.basePath(), None)
+ self.assertEqual(len(self.server.requests), 2) # made 2 requests
+ self.assertEqual(self.server.requests[0]["command"], "GET")
+ self.assertEqual(self.server.requests[1]["command"], "HEAD")
+
+ files = dict(map(lambda i: (i[0], i[1]), r))
+ self.assertSetEqual(set(('bla', 'dir', '..', '.')), set(files.keys()))
+ self.assertEqual(files['.']['st_mode'], S_IFDIR | 0o555)
+ self.assertEqual(files['.']['st_nlink'], self.stat(".").st_nlink)
+ self.assertEqual(files['..']['st_mode'], S_IFDIR | 0o555)
+ self.assertEqual(files['bla']['st_mode'], S_IFREG | 0o444)
+ self.assertEqual(files['dir']['st_mode'], S_IFDIR | 0o555)
+
+ def test_dir(self):
+ r = self.httpfs.readdir(self.basePath() + "/", None)
+ self.assertEqual(len(r), 4)
+ r = self.httpfs.readdir(self.basePath() + "/dir", None)
+ self.assertEqual(len(r), 4)
+
+ def test_read(self):
+ r = self.httpfs.read(self.basePath() + "/dir/bla1", 1000, 0, None)
+ self.assertEqual(r.strip(), b"bla1")