chore: neat pick

Signed-off-by: Manish Dait <daitmanish88@gmail.com>

Author: manishdait

pyproject.toml

@@ -21,6 +21,8 @@ dependencies = [
     "pycryptodome>=3.18.0,<4",
     "eth-abi>=5.1.0,<6",
     "python-dotenv>=1.2.1,<3",
+    "pytest-repeat>=0.9.4",
+    "pytest-xdist>=3.8.0",
 ]
 classifiers = [
     "Development Status :: 2 - Pre-Alpha",

src/hiero_sdk_python/node.py

@@ -124,6 +124,8 @@ def _get_channel(self):
             if self._root_certificates:
                 # Use the certificate that is provided
                 self._node_pem_cert = self._root_certificates
+                print("node cert ", self._node_pem_cert)
+            
             else:
                 # Fetch pem_cert for the node
                 self._node_pem_cert = self._fetch_server_certificate_pem()

src/hiero_sdk_python/transaction/transaction.py

@@ -239,6 +239,24 @@ def _to_proto(self):
         return transaction_pb2.Transaction(
             signedTransactionBytes=signed_transaction.SerializeToString()
         )
+    
+    def _resolve_transaction_id(self, client: "Client"):
+        if self.transaction_id is not None:
+            return
+        
+        if client is not None:
+            operator_account_id = client.operator_account_id
+            if operator_account_id is not None:
+                self.transaction_id = client.generate_transaction_id()
+            else:
+                raise ValueError(
+                    "Client must have an operator_account or transactionId must be set."
+                )
+        else:
+            raise ValueError(
+                "Transaction ID must be set before freezing. Use freeze_with(client) or set_transaction_id()."
+            )
+
 
     def freeze(self):
         """
@@ -277,19 +295,7 @@ def freeze_with(self, client: "Client"):
             return self
 
         # Check transaction_id and node id to be set when using freeze()
-        if self.transaction_id is None:
-            if client is not None:
-                operator_account_id = client.operator_account_id
-                if operator_account_id is not None:
-                    self.transaction_id = client.generate_transaction_id()
-                else:
-                    raise ValueError(
-                        "Client must have an operator_account or transactionId must be set."
-                    )
-            else:
-                raise ValueError(
-                    "Transaction ID must be set before freezing. Use freeze_with(client) or set_transaction_id()."
-                )
+        self._resolve_transaction_id(client)
 
 
         if self.node_account_id is None and len(self.node_account_ids) == 0:

tests/integration/file_append_transaction_e2e_test.py

@@ -308,7 +308,7 @@ def test_integration_file_append_transaction_method_chaining(env):
     assert append_receipt.status == ResponseCode.SUCCESS 
 
 @pytest.mark.integration
-def test_file_append_chuck_transaction_can_execute_with_manual_freeze(env):
+def test_file_append_chunk_transaction_can_execute_with_manual_freeze(env):
     """Test file append transaction can execute  with manual freeze."""
     create_receipt = (
         FileCreateTransaction()
@@ -323,7 +323,7 @@ def test_file_append_chuck_transaction_can_execute_with_manual_freeze(env):
     file_contents = FileContentsQuery().set_file_id(file_id).execute(env.client)
     assert file_contents == b""
 
-    content = "A" * (4000) # content with (1024 * 14) bytes ie 14 chunks
+    content = "A" * (4000) # content with (4000/1024) bytes ie approx 4 chunks
 
     tx = (
         FileAppendTransaction()

tests/unit/mock_server.py

@@ -126,16 +126,17 @@ def close(self):
         self.server.stop(0)
 
 
+_USED_PORTS = set()
+
 def _find_free_port():
     """Find a free port on localhost."""
     with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as s:
         s.bind(("", 0))
-        s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
         port = s.getsockname()[1]
 
         # If we get the tls port 50212 port skip it
         if port == 50212:
-            return port + 1 
+            return _find_free_port()
 
         return port
 
@@ -177,10 +178,15 @@ def mock_hedera_servers(response_sequences):
 
         # Create network and client
         network = Network(nodes=nodes)
+        network.set_transport_security(False)
+        network.set_verify_certificates(False)
         client = Client(network)
 
+        # Force non-tls channel
         for node in client.network.nodes:
-            node._address = node._address._to_insecure()
+            node._address._is_transport_security = lambda: False
+            node._set_verify_certificates(False)
+            node._close()
 
         client.logger.set_level(LogLevel.DISABLED)
         # Set the operator