From 083899d6088492b1bc7e01f74be015070224f2c2 Mon Sep 17 00:00:00 2001
From: Yves Fischer <yvesf-git@xapek.org>
Date: Fri, 20 Feb 2015 18:35:30 +0100
Subject: Some tests and using python netrc module

---
 test/__init__.py      |  6 +++++
 test/test_httpfs.py   | 73 +++++++++++++++++++++++++++++++++++++++++++++++++++
 test/testwww/bla      |  0
 test/testwww/dir/bla1 |  1 +
 test/testwww/dir/bla2 |  0
 5 files changed, 80 insertions(+)
 create mode 100644 test/__init__.py
 create mode 100644 test/test_httpfs.py
 create mode 100644 test/testwww/bla
 create mode 100644 test/testwww/dir/bla1
 create mode 100644 test/testwww/dir/bla2

(limited to 'test')

diff --git a/test/__init__.py b/test/__init__.py
new file mode 100644
index 0000000..9e0b053
--- /dev/null
+++ b/test/__init__.py
@@ -0,0 +1,6 @@
+import logging
+
+from test.test_httpfs import *
+
+
+logging.basicConfig(level=logging.ERROR)
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")
diff --git a/test/testwww/bla b/test/testwww/bla
new file mode 100644
index 0000000..e69de29
diff --git a/test/testwww/dir/bla1 b/test/testwww/dir/bla1
new file mode 100644
index 0000000..60d7890
--- /dev/null
+++ b/test/testwww/dir/bla1
@@ -0,0 +1 @@
+bla1
diff --git a/test/testwww/dir/bla2 b/test/testwww/dir/bla2
new file mode 100644
index 0000000..e69de29
-- 
cgit v1.2.1