Merge branch 'features/stream'

Author: Paweł Kędzia

llm_router_api/endpoints/httprequest.py

@@ -21,7 +21,6 @@
 """
 
 import json
-import urllib
 
 import requests
 import datetime
@@ -121,7 +120,6 @@ def call_http_request(
         )
 
         full_url = self._prepare_full_url_ep(ep_url)
-
         if not headers:
             headers = {"Content-Type": "application/json"}
 
@@ -222,6 +220,7 @@ def stream_response(
         if token:
             headers["Authorization"] = f"Bearer {token}"
 
+        params = self._convert_ollama_messages_if_needed(params=params)
         if is_ollama:
             return self._stream_ollama(full_url, params, method, headers)
         if is_generic_to_ollama:
@@ -233,7 +232,10 @@ def stream_response(
     # Private helpers
     # ------------------------------------------------------------------
     def _prepare_full_url_ep(self, ep_url: str) -> str:
-        return urllib.parse.urljoin(self._endpoint.api_model.api_host, ep_url)
+        full_url = (
+            self._endpoint.api_model.api_host.rstrip("/") + "/" + ep_url.lstrip("/")
+        )
+        return full_url
 
     def _call_for_each_user_message(
         self,
@@ -491,8 +493,7 @@ def _stream_ollama(
         Iterator[bytes]
             An iterator yielding Ollama‑compatible NDJSON lines.
         """
-        # Normalise messages if needed (unchanged static helper)
-        payload = self._convert_ollama_messages_if_needed(params=payload)
+
         try:
             if method == "POST":
                 with requests.post(