diff options
author | Yves Fischer <yvesf-git@xapek.org> | 2015-02-20 18:35:30 +0100 |
---|---|---|
committer | Yves Fischer <yvesf-git@xapek.org> | 2015-02-21 18:22:33 +0100 |
commit | 083899d6088492b1bc7e01f74be015070224f2c2 (patch) | |
tree | 4fef8a619e5f345f556c177643098f6a506d5969 /test/test_httpfs.py | |
parent | 1ee6c90a3de10149b04f419ec9ff4b139efa0962 (diff) | |
download | fuse-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.py | 73 |
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") |