RDBC-940 Import zstandard for the tests

Author: yh-0

.github/workflows/RavenClient.yml

@@ -75,6 +75,9 @@ jobs:
       - name: Install embedded RavenDB
         run: pip install ravendb-embedded
 
+      - name: Install zstandard
+        run: pip install zstandard
+
       - name: Run certifi script
         run: python ./.github/workflows/add_ca.py
 

ravendb/documents/commands/stream.py

@@ -51,17 +51,6 @@ def process_response(self, cache: HttpCache, response: requests.Response, url) -
         except Exception as e:
             raise RuntimeError("Unable to process stream response", e)
 
-    def send(self, session: requests.Session, request: requests.Request) -> requests.Response:
-        return session.request(
-            request.method,
-            url=request.url,
-            data=request.data,
-            files=request.files,
-            cert=session.cert,
-            headers=request.headers,
-            stream=True,
-        )
-
     def is_read_request(self) -> bool:
         return True
 
@@ -96,16 +85,5 @@ def process_response(self, cache: HttpCache, response: requests.Response, url) -
         except Exception as e:
             raise RuntimeError("Unable to process stream response: " + e.args[0], e)
 
-    def send(self, session: requests.Session, request: requests.Request) -> requests.Response:
-        return session.request(
-            request.method,
-            url=request.url,
-            data=request.data,
-            files=request.files,
-            cert=session.cert,
-            headers=request.headers,
-            stream=True,
-        )
-
     def is_read_request(self) -> bool:
         return True

ravendb/tests/issue_tests/test_RDBC_940.py

@@ -0,0 +1,28 @@
+from ravendb.tests.test_base import TestBase
+
+
+class TestDocument:
+    def __init__(self, name: str = None):
+        self.name = name
+
+
+class TestRDBC940(TestBase):
+    def setUp(self):
+        super(TestRDBC940, self).setUp()
+
+    def test_operations_with_zstandard_imported(self):
+        import zstandard
+
+        document_id = "test-documents/1"
+
+        with self.store.open_session() as session:
+            test_doc = TestDocument(name="Test Document")
+            session.store(test_doc, document_id)
+            session.save_changes()
+
+        with self.store.open_session() as session:
+            loaded_doc = session.load(document_id, TestDocument)
+
+        with self.store.open_session() as session:
+            session.delete(document_id)
+            session.save_changes()