[thrift] branch master updated: Add file and memory buffer tests for Python

[dc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dcelasun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/thrift.git


The following commit(s) were added to refs/heads/master by this push:
     new 3938169  Add file and memory buffer tests for Python
3938169 is described below

commit 39381695eb456349b02e68d9167181ae41656b73
Author: Zezeng Wang <51...@qq.com>
AuthorDate: Tue Apr 28 14:24:58 2020 +0800

    Add file and memory buffer tests for Python
    
    Client: py
---
 lib/py/CMakeLists.txt           |  1 +
 lib/py/Makefile.am              |  2 ++
 lib/py/test/thrift_transport.py | 70 +++++++++++++++++++++++++++++++++++++++++
 3 files changed, 73 insertions(+)

diff --git a/lib/py/CMakeLists.txt b/lib/py/CMakeLists.txt
index cba2d65..909f61a 100644
--- a/lib/py/CMakeLists.txt
+++ b/lib/py/CMakeLists.txt
@@ -28,5 +28,6 @@ add_custom_target(python_build ALL
 if(BUILD_TESTING)
     add_test(PythonTestSSLSocket ${PYTHON_EXECUTABLE} ${CMAKE_CURRENT_SOURCE_DIR}/test/test_sslsocket.py)
     add_test(PythonThriftJson ${PYTHON_EXECUTABLE} ${CMAKE_CURRENT_SOURCE_DIR}/test/thrift_json.py)
+    add_test(PythonThriftTransport ${PYTHON_EXECUTABLE} ${CMAKE_CURRENT_SOURCE_DIR}/test/thrift_transport.py)
     add_test(PythonThriftJson ${PYTHON_EXECUTABLE} ${CMAKE_CURRENT_SOURCE_DIR}/test/thrift_TBinaryProtocol.py)
 endif()
diff --git a/lib/py/Makefile.am b/lib/py/Makefile.am
index de7afd3..69aa4e7 100644
--- a/lib/py/Makefile.am
+++ b/lib/py/Makefile.am
@@ -24,6 +24,7 @@ py3-build:
 	$(PYTHON3) setup.py build
 py3-test: py3-build
 	$(PYTHON3) test/thrift_json.py
+	$(PYTHON3) test/thrift_transport.py
 	$(PYTHON3) test/test_sslsocket.py
 	$(PYTHON3) test/thrift_TBinaryProtocol.py
 else
@@ -43,6 +44,7 @@ install-exec-hook:
 
 check-local: all py3-test
 	$(PYTHON) test/thrift_json.py
+	$(PYTHON) test/thrift_transport.py
 	$(PYTHON) test/test_sslsocket.py
 	$(PYTHON) test/thrift_TBinaryProtocol.py
 
diff --git a/lib/py/test/thrift_transport.py b/lib/py/test/thrift_transport.py
new file mode 100644
index 0000000..cb1bb0c
--- /dev/null
+++ b/lib/py/test/thrift_transport.py
@@ -0,0 +1,70 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
+import unittest
+import os
+
+import _import_local_thrift  # noqa
+from thrift.transport import TTransport
+
+
+class TestTFileObjectTransport(unittest.TestCase):
+
+    def test_TFileObjectTransport(self):
+        test_dir = os.path.dirname(os.path.abspath(__file__))
+        datatxt_path = os.path.join(test_dir, 'data.txt')
+        buffer = '{"soft":"thrift","version":0.13,"1":true}'
+        with open(datatxt_path, "w+") as f:
+            buf = TTransport.TFileObjectTransport(f)
+            buf.write(buffer)
+            buf.flush()
+            buf.close()
+
+        with open(datatxt_path, "rb") as f:
+            buf = TTransport.TFileObjectTransport(f)
+            value = buf.read(len(buffer)).decode('utf-8')
+            self.assertEqual(buffer, value)
+            buf.close()
+        os.remove(datatxt_path)
+
+
+class TestMemoryBuffer(unittest.TestCase):
+
+    def test_memorybuffer_write(self):
+        data = '{"1":[1,"hello"],"a":{"A":"abc"},"bool":true,"num":12345}'
+
+        buffer_w = TTransport.TMemoryBuffer()
+        buffer_w.write(data.encode('utf-8'))
+        value = buffer_w.getvalue()
+        self.assertEqual(value.decode('utf-8'), data)
+        buffer_w.close()
+
+    def test_memorybuffer_read(self):
+        data = '{"1":[1, "hello"],"a":{"A":"abc"},"bool":true,"num":12345}'
+
+        buffer_r = TTransport.TMemoryBuffer(data.encode('utf-8'))
+        value_r = buffer_r.read(len(data))
+        value = buffer_r.getvalue()
+        self.assertEqual(value.decode('utf-8'), data)
+        self.assertEqual(value_r.decode('utf-8'), data)
+        buffer_r.close()
+
+
+if __name__ == '__main__':
+    unittest.main()