From 9524c3f3275a720ef0ffd8adae6f78e22997a8dd Mon Sep 17 00:00:00 2001
From: hlohaus <983577+hlohaus@users.noreply.github.com>
Date: Tue, 28 Jan 2025 20:33:50 +0100
Subject: Add AsyncAuthedProvider in Copilot Add orginal url to downloaded
 image Support ssl argument in StreamSession Report Provider and Errors in
 RetryProvider Support ssl argument in OpenaiTemplate Remove model duplication
 in OpenaiChat Disable ChatGpt provider and remove it from models.py Update
 slim requirements Support provider names as model name in Image generation
 Add model qwen-2.5-1m-demo to models.py

---
 g4f/requests/curl_cffi.py        | 4 ++--
 g4f/requests/raise_for_status.py | 6 ++++--
 2 files changed, 6 insertions(+), 4 deletions(-)

(limited to 'g4f/requests')

diff --git a/g4f/requests/curl_cffi.py b/g4f/requests/curl_cffi.py
index 575a7290..6903b518 100644
--- a/g4f/requests/curl_cffi.py
+++ b/g4f/requests/curl_cffi.py
@@ -71,12 +71,12 @@ class StreamSession(AsyncSession):
     """
 
     def request(
-        self, method: str, url: str, **kwargs
+        self, method: str, url: str, ssl = None, **kwargs
     ) -> StreamResponse:
         if isinstance(kwargs.get("data"), CurlMime):
             kwargs["multipart"] = kwargs.pop("data")
         """Create and return a StreamResponse object for the given HTTP request."""
-        return StreamResponse(super().request(method, url, stream=True, **kwargs))
+        return StreamResponse(super().request(method, url, stream=True, verify=ssl, **kwargs))
 
     def ws_connect(self, url, *args, **kwargs):
         return WebSocket(self, url, **kwargs)
diff --git a/g4f/requests/raise_for_status.py b/g4f/requests/raise_for_status.py
index 06786ce7..b7cd9f04 100644
--- a/g4f/requests/raise_for_status.py
+++ b/g4f/requests/raise_for_status.py
@@ -25,7 +25,8 @@ async def raise_for_status_async(response: Union[StreamResponse, ClientResponse]
         return
     text = await response.text()
     if message is None:
-        message = "HTML content" if response.headers.get("content-type", "").startswith("text/html") else text
+        is_html = response.headers.get("content-type", "").startswith("text/html") or text.startswith("<!DOCTYPE")
+        message = "HTML content" if is_html else text
     if message == "HTML content":
         if response.status == 520:
             message = "Unknown error (Cloudflare)"
@@ -46,7 +47,8 @@ def raise_for_status(response: Union[Response, StreamResponse, ClientResponse, R
     if response.ok:
         return
     if message is None:
-        message = "HTML content" if response.headers.get("content-type", "").startswith("text/html") else response.text
+        is_html = response.headers.get("content-type", "").startswith("text/html") or response.text.startswith("<!DOCTYPE")
+        message = "HTML content" if is_html else response.text
     if message == "HTML content":
         if response.status_code == 520:
             message = "Unknown error (Cloudflare)"
-- 
cgit v1.2.3