From a92b1d69a2e19c5f2434e124050e2005ad448989 Mon Sep 17 00:00:00 2001
From: Morty Space <morty.space@gmail.com>
Date: Sun, 16 Jan 2022 16:43:18 +0200
Subject: [PATCH] Fixed huge memory leak caused by httpx

---
 README.md                          | 3 +++
 src/cryptocom/exchange/__init__.py | 2 +-
 src/cryptocom/exchange/api.py      | 9 +++++----
 3 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index ec9994b..df3ee5f 100644
--- a/README.md
+++ b/README.md
@@ -15,6 +15,8 @@ Documentation: [https://cryptocom-exchange.rtfd.io](https://cryptocom-exchange.r
 
 Exchange original API docs: [https://exchange-docs.crypto.com](https://exchange-docs.crypto.com)
 
+### **WARNING: PLEASE use 0.10.2+ or up to 0.9.5 version because of httpx memory leak** [0.10, 0.10.1] -> are broken
+
 ### Description
 
 `pip install cryptocom-exchange`
@@ -27,6 +29,7 @@ Exchange original API docs: [https://exchange-docs.crypto.com](https://exchange-
 
 ### Changelog
 
+- **0.10.2** - fixed huge memory leak by `httpx`
 - **0.10.1** - added read timeouts for websockets, fixed test with tickers
 - **0.10.0** - moved into httpx + websockets, added autoreconnect, simplified code, improved stability
 - **0.9.5** - added timeout for websocket if no data received in 3 mins we trying to reconnect
diff --git a/src/cryptocom/exchange/__init__.py b/src/cryptocom/exchange/__init__.py
index e1cf4f1..e6eab1a 100644
--- a/src/cryptocom/exchange/__init__.py
+++ b/src/cryptocom/exchange/__init__.py
@@ -23,4 +23,4 @@ __all__ = [
     'ApiError', 'ApiProvider'
 ]
 
-__version__ = '0.10.1'
+__version__ = '0.10.2'
diff --git a/src/cryptocom/exchange/api.py b/src/cryptocom/exchange/api.py
index fcf08a9..883d6ba 100644
--- a/src/cryptocom/exchange/api.py
+++ b/src/cryptocom/exchange/api.py
@@ -117,7 +117,6 @@ class ApiListenAsyncIterable:
                 self.sub_data_sent = True
 
 
-
 class ApiProvider:
     """Provides HTTP-api requests and websocket requests."""
     def __init__(
@@ -125,7 +124,7 @@ class ApiProvider:
             auth_required=True, timeout=25, retries=6,
             root_url='https://api.crypto.com/v2/',
             ws_root_url='wss://stream.crypto.com/v2/', logger=None):
-
+        self.ssl_context = httpx.create_ssl_context()
         self.api_key = api_key
         self.api_secret = api_secret
         self.root_url = root_url
@@ -203,7 +202,9 @@ class ApiProvider:
 
         for count in range(self.retries + 1):
             client = httpx.AsyncClient(
-                timeout=httpx.Timeout(timeout=self.timeout))
+                timeout=httpx.Timeout(timeout=self.timeout),
+                verify=self.ssl_context
+            )
             if sign:
                 data = self.sign(path, original_data)
             try:
@@ -231,7 +232,7 @@ class ApiProvider:
                 if resp.status_code == 429:
                     continue
                 raise ApiError(
-                    f"Can't decode json, content: {resp.text()}. "
+                    f"Can't decode json, content: {resp.text}. "
                     f"Code: {resp.status_code}")
             finally:
                 await client.aclose()